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/table/sync.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/table/sync.rs')
| -rw-r--r-- | src/table/sync.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs index 7008a383..1e7618ca 100644 --- a/src/table/sync.rs +++ b/src/table/sync.rs @@ -87,12 +87,12 @@ where syncer } - pub(crate) fn spawn_workers(self: &Arc<Self>) { + pub(crate) fn spawn_workers(self: &Arc<Self>, bg: &BackgroundRunner) { let (add_full_sync_tx, add_full_sync_rx) = mpsc::unbounded_channel(); self.add_full_sync_tx .store(Some(Arc::new(add_full_sync_tx))); - self.system.background.spawn_worker(SyncWorker { + bg.spawn_worker(SyncWorker { syncer: self.clone(), ring_recv: self.system.ring.clone(), ring: self.system.ring.borrow().clone(), |