Garage v0.9 #473
1 changed files with 3 additions and 0 deletions
|
@ -372,6 +372,9 @@ impl ScrubWorker {
|
||||||
ScrubWorkerCommand::Cancel => {
|
ScrubWorkerCommand::Cancel => {
|
||||||
self.work = match std::mem::take(&mut self.work) {
|
self.work = match std::mem::take(&mut self.work) {
|
||||||
ScrubWorkerState::Running { .. } | ScrubWorkerState::Paused { .. } => {
|
ScrubWorkerState::Running { .. } | ScrubWorkerState::Paused { .. } => {
|
||||||
|
if let Err(e) = self.persister.set_with(|x| x.checkpoint = None) {
|
||||||
|
error!("Could not save scrub checkpoint: {}", e);
|
||||||
|
}
|
||||||
ScrubWorkerState::Finished
|
ScrubWorkerState::Finished
|
||||||
}
|
}
|
||||||
work => {
|
work => {
|
||||||
|
|
Loading…
Reference in a new issue