diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-15 20:09:44 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-15 20:09:44 +0100 |
| commit | 4d4117f2b4eb69b63e2329f6e0b8929e6a8b5b31 (patch) | |
| tree | 03da6808b6f0391293ab5a252d5efd1328acdefc /src/table/gc.rs | |
| parent | 667e4e72a8e64a094d57ceeb6442cef08f1ef0e1 (diff) | |
| download | garage-4d4117f2b4eb69b63e2329f6e0b8929e6a8b5b31.tar.gz garage-4d4117f2b4eb69b63e2329f6e0b8929e6a8b5b31.zip | |
Refactor block resync loop; make workers infaillible
Diffstat (limited to 'src/table/gc.rs')
| -rw-r--r-- | src/table/gc.rs | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/table/gc.rs b/src/table/gc.rs index c13c8234..fd9a26d1 100644 --- a/src/table/gc.rs +++ b/src/table/gc.rs @@ -70,7 +70,7 @@ where gc } - async fn gc_loop(self: Arc<Self>, mut must_exit: watch::Receiver<bool>) -> Result<(), Error> { + async fn gc_loop(self: Arc<Self>, mut must_exit: watch::Receiver<bool>) { while !*must_exit.borrow() { match self.gc_loop_iter().await { Ok(true) => { @@ -89,7 +89,6 @@ where _ = must_exit.recv().fuse() => (), } } - Ok(()) } async fn gc_loop_iter(&self) -> Result<bool, Error> { |