diff options
author | Jonathan Davies <jpds@protonmail.com> | 2023-04-23 19:32:28 +0100 |
---|---|---|
committer | Jonathan Davies <jpds@protonmail.com> | 2023-04-23 22:22:26 +0100 |
commit | fb3bd11dce1f1a9fb8f60b93894300ce4fc72520 (patch) | |
tree | 1a8eb7371e2cf3362f6552a8285085a25c3885ab | |
parent | a2a35ac7a87fce2e38b8406f083e2350d4181b69 (diff) | |
download | garage-fb3bd11dce1f1a9fb8f60b93894300ce4fc72520.tar.gz garage-fb3bd11dce1f1a9fb8f60b93894300ce4fc72520.zip |
block/repair.rs: Added log entries for scrub start/finish.
-rw-r--r-- | src/block/repair.rs | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/src/block/repair.rs b/src/block/repair.rs index 37ccd59a..c89484d9 100644 --- a/src/block/repair.rs +++ b/src/block/repair.rs @@ -281,6 +281,7 @@ impl ScrubWorker { ScrubWorkerCommand::Start => { self.work = match std::mem::take(&mut self.work) { ScrubWorkerState::Finished => { + info!("Scrub worker initializing, now performing datastore scrub"); let iterator = BlockStoreIterator::new(&self.manager); ScrubWorkerState::Running(iterator) } @@ -394,12 +395,21 @@ impl Worker for ScrubWorker { .tranquilizer .tranquilize_worker(self.persister.get_with(|p| p.tranquility))) } else { + let now = now_msec(); + let next_scrub_timestamp = randomize_next_scrub_run_time(now); + self.persister.set_with(|p| { - p.time_last_complete_scrub = now_msec(); - p.time_next_run_scrub = randomize_next_scrub_run_time(now_msec()); + p.time_last_complete_scrub = now; + p.time_next_run_scrub = next_scrub_timestamp; })?; self.work = ScrubWorkerState::Finished; self.tranquilizer.clear(); + + info!( + "Datastore scrub completed, next scrub scheduled for {}", + msec_to_rfc3339(next_scrub_timestamp) + ); + Ok(WorkerState::Idle) } } |