diff options
| author | Alex <alex@adnab.me> | 2023-01-03 11:37:31 +0000 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2023-01-03 11:37:31 +0000 |
| commit | 582b0761790b7958a3ba10c4b549b466997d2dcd (patch) | |
| tree | b94c84bd21ef45e2480c653dc7ed2b37fd5907fb /src/block/repair.rs | |
| parent | 76230f20282e73a5a5afa33af68152acaf732cf5 (diff) | |
| parent | 939a6d67e8ace1aa38998281f52511a61f4b4d94 (diff) | |
| download | garage-582b0761790b7958a3ba10c4b549b466997d2dcd.tar.gz garage-582b0761790b7958a3ba10c4b549b466997d2dcd.zip | |
Merge pull request 'Some improvements to Garage internals' (#451) from internals-rework into main
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/451
Diffstat (limited to 'src/block/repair.rs')
| -rw-r--r-- | src/block/repair.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/block/repair.rs b/src/block/repair.rs index 1878027e..f5515d4e 100644 --- a/src/block/repair.rs +++ b/src/block/repair.rs @@ -148,7 +148,7 @@ impl Worker for RepairWorker { } } - async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerState { + async fn wait_for_work(&mut self) -> WorkerState { unreachable!() } } @@ -341,7 +341,7 @@ impl Worker for ScrubWorker { } } - async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerState { + async fn wait_for_work(&mut self) -> WorkerState { let (wait_until, command) = match &self.work { ScrubWorkerState::Running(_) => return WorkerState::Busy, ScrubWorkerState::Paused(_, resume_time) => (*resume_time, ScrubWorkerCommand::Resume), |