aboutsummaryrefslogtreecommitdiff
path: root/src/garage/repair/online.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/garage/repair/online.rs')
-rw-r--r--src/garage/repair/online.rs10
1 files changed, 2 insertions, 8 deletions
diff --git a/src/garage/repair/online.rs b/src/garage/repair/online.rs
index 160ce8f8..e33cf097 100644
--- a/src/garage/repair/online.rs
+++ b/src/garage/repair/online.rs
@@ -89,10 +89,7 @@ impl Worker for RepairVersionsWorker {
Some(format!("{} items done", self.counter))
}
- async fn work(
- &mut self,
- _must_exit: &mut watch::Receiver<bool>,
- ) -> Result<WorkerState, Error> {
+ async fn work(&mut self, _must_exit: &mut watch::Receiver<bool>) -> Result<WorkerState, Error> {
let item_bytes = match self.garage.version_table.data.store.get_gt(&self.pos)? {
Some((k, v)) => {
self.pos = k;
@@ -170,10 +167,7 @@ impl Worker for RepairBlockrefsWorker {
Some(format!("{} items done", self.counter))
}
- async fn work(
- &mut self,
- _must_exit: &mut watch::Receiver<bool>,
- ) -> Result<WorkerState, Error> {
+ async fn work(&mut self, _must_exit: &mut watch::Receiver<bool>) -> Result<WorkerState, Error> {
let item_bytes = match self.garage.block_ref_table.data.store.get_gt(&self.pos)? {
Some((k, v)) => {
self.pos = k;