diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-27 16:52:46 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-27 16:52:46 +0200 |
| commit | 0e5175abeeb1b2d9cfe27603005b7feb3cf040de (patch) | |
| tree | 0264a8c0a154a9c130ba97062aa3951f33276c05 /src/garage/repair | |
| parent | fc507242569a91ee638485848f0fd7def6e026f7 (diff) | |
| download | garage-0e5175abeeb1b2d9cfe27603005b7feb3cf040de.tar.gz garage-0e5175abeeb1b2d9cfe27603005b7feb3cf040de.zip | |
Report progress of scrub and block repair
Diffstat (limited to 'src/garage/repair')
| -rw-r--r-- | src/garage/repair/online.rs | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/garage/repair/online.rs b/src/garage/repair/online.rs index a5ccfa02..b0437c5e 100644 --- a/src/garage/repair/online.rs +++ b/src/garage/repair/online.rs @@ -13,7 +13,7 @@ use garage_util::error::Error; use crate::*; -pub async fn launch_online_repair(garage: Arc<Garage>, opt: RepairOpt) -> Result<(), Error> { +pub fn launch_online_repair(garage: Arc<Garage>, opt: RepairOpt) { match opt.what { RepairWhat::Tables => { info!("Launching a full sync of tables"); @@ -45,13 +45,14 @@ pub async fn launch_online_repair(garage: Arc<Garage>, opt: RepairOpt) -> Result } RepairWhat::Scrub { tranquility } => { info!("Verifying integrity of stored blocks"); - garage.background.spawn_worker( - garage_block::repair::ScrubWorker::new(garage.block_manager.clone(), tranquility) - .await?, - ); + garage + .background + .spawn_worker(garage_block::repair::ScrubWorker::new( + garage.block_manager.clone(), + tranquility, + )); } } - Ok(()) } // ---- |