diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-12-14 12:51:16 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-12-14 12:51:42 +0100 |
| commit | d56c472712df7c064387429a5af73d3bc0eb438d (patch) | |
| tree | d3d73490ae3167a228ee91f69a583242c572cd9f /src/model/index_counter.rs | |
| parent | 2183518edccadef47cdeaf6476033b52d8832d6e (diff) | |
| download | garage-d56c472712df7c064387429a5af73d3bc0eb438d.tar.gz garage-d56c472712df7c064387429a5af73d3bc0eb438d.zip | |
Refactor background runner and get rid of job worker
Diffstat (limited to 'src/model/index_counter.rs')
| -rw-r--r-- | src/model/index_counter.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/model/index_counter.rs b/src/model/index_counter.rs index d907e947..6303ea3e 100644 --- a/src/model/index_counter.rs +++ b/src/model/index_counter.rs @@ -9,6 +9,7 @@ use garage_db as db; use garage_rpc::ring::Ring; use garage_rpc::system::System; +use garage_util::background::BackgroundRunner; use garage_util::data::*; use garage_util::error::*; use garage_util::time::*; @@ -164,8 +165,8 @@ impl<T: CountedItem> IndexCounter<T> { }) } - pub fn spawn_workers(&self) { - self.table.spawn_workers(); + pub fn spawn_workers(&self, bg: &BackgroundRunner) { + self.table.spawn_workers(bg); } pub fn count( |