aboutsummaryrefslogtreecommitdiff
path: root/src/garage
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-07-08 10:45:20 +0200
committerAlex Auvolat <alex@adnab.me>2022-07-08 10:45:20 +0200
commit08cd5f2f1d4a42e63a256eb3a7811e874d222fe4 (patch)
tree256ee885e93cf1c41dc2869fe13a648aa91ab9b5 /src/garage
parent18d014dcc5840e5eae8581a5bfa846aad93beeea (diff)
downloadgarage-08cd5f2f1d4a42e63a256eb3a7811e874d222fe4.tar.gz
garage-08cd5f2f1d4a42e63a256eb3a7811e874d222fe4.zip
Diffstat (limited to 'src/garage')
-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;