diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-24 11:04:55 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-24 11:04:55 +0200 |
| commit | e7810e9cb3cdbe6aaecddddd1146bf15e5b50c7c (patch) | |
| tree | 6a7ae3528371e32a2eea722e0ff214b46a3a9bc8 /src/block | |
| parent | 0837b3dacd994b35dbccbfefdd68be044eb4b5ac (diff) | |
| download | garage-e7810e9cb3cdbe6aaecddddd1146bf15e5b50c7c.tar.gz garage-e7810e9cb3cdbe6aaecddddd1146bf15e5b50c7c.zip | |
Smaller batches for index counter propagation
Diffstat (limited to 'src/block')
| -rw-r--r-- | src/block/repair.rs | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/block/repair.rs b/src/block/repair.rs index a5c01629..97989780 100644 --- a/src/block/repair.rs +++ b/src/block/repair.rs @@ -53,6 +53,7 @@ impl Worker for RepairWorker { // This is mostly because the Rust bindings for SQLite assume a worst-case scenario // where SQLite is not compiled in thread-safe mode, so we have to wrap everything // in a mutex (see db/sqlite_adapter.rs and discussion in PR #322). + // TODO: maybe do this with tokio::task::spawn_blocking ? let mut batch_of_hashes = vec![]; let start_bound = match self.next_start.as_ref() { None => Bound::Unbounded, |