diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-28 16:59:19 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-28 16:59:19 +0200 |
| commit | b053fc051842677dbabe1cab294af74ed26932a4 (patch) | |
| tree | 68600a49ad5a10e21e21a0a2429aa0305c12f11c /src/garage | |
| parent | f1c972289d53e956a5837dcae2a53cc13f61ec7b (diff) | |
| download | garage-b053fc051842677dbabe1cab294af74ed26932a4.tar.gz garage-b053fc051842677dbabe1cab294af74ed26932a4.zip | |
Persist scrub worker thing in Persister
Diffstat (limited to 'src/garage')
| -rw-r--r-- | src/garage/cli/util.rs | 2 | ||||
| -rw-r--r-- | src/garage/repair/online.rs | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/garage/cli/util.rs b/src/garage/cli/util.rs index fc5a9932..8be56138 100644 --- a/src/garage/cli/util.rs +++ b/src/garage/cli/util.rs @@ -263,7 +263,7 @@ pub fn print_worker_info(wi: HashMap<usize, WorkerInfo>, wlo: WorkerListOpt) { continue; } - table.push(format!("{}\t{:?}\t{}", tid, info.status, info.name)); + table.push(format!("{}\t{}\t{}", tid, info.status, info.name)); if let Some(i) = &info.info { table.push(format!("\t\t {}", i)); } diff --git a/src/garage/repair/online.rs b/src/garage/repair/online.rs index 8207a8b4..d4366486 100644 --- a/src/garage/repair/online.rs +++ b/src/garage/repair/online.rs @@ -46,7 +46,6 @@ pub async fn launch_online_repair(garage: Arc<Garage>, opt: RepairOpt) { )); } RepairWhat::Scrub { cmd } => { - info!("Verifying integrity of stored blocks"); let cmd = match cmd { ScrubCmd::Start => ScrubWorkerCommand::Start, ScrubCmd::Pause => ScrubWorkerCommand::Pause(Duration::from_secs(3600 * 24)), @@ -56,6 +55,7 @@ pub async fn launch_online_repair(garage: Arc<Garage>, opt: RepairOpt) { ScrubWorkerCommand::SetTranquility(tranquility) } }; + info!("Sending command to scrub worker: {:?}", cmd); garage.block_manager.send_scrub_command(cmd).await; } } |