Deuxfleurs/garage
48
56
Fork 73
Code Issues 100 Pull requests 13 Releases 30 Wiki Activity

Background task manager #332

Merged
lx merged 35 commits from background-task-manager into main 2022-07-08 11:30:32 +00:00
Conversation 0 Commits 35 Files changed 27 +2 -3
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 8fb8569912 - Show all commits

5
src/table/sync.rs
View file

@ -597,11 +597,10 @@ impl<F: TableSchema + 'static, R: TableReplication + 'static> Worker for SyncWor
async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerStatus { async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerStatus {
select! { select! {
s = self.add_full_sync_rx.recv() => match s { s = self.add_full_sync_rx.recv() => {
Some(()) => { if let Some(()) = s {
self.add_full_sync(); self.add_full_sync();
} }
None => (),
}, },
_ = self.ring_recv.changed() => { _ = self.ring_recv.changed() => {
let new_ring = self.ring_recv.borrow(); let new_ring = self.ring_recv.borrow();