diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-09-02 16:47:15 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-09-02 16:47:15 +0200 |
| commit | 47be652a1fe08a8e6dab6aa2c4a41d8eb119f392 (patch) | |
| tree | 9e7d1c9513fb6a4727dca8c66e96e61cf693bbd8 /src/garage/admin.rs | |
| parent | 943d76c583f5740b1d922275a673233a27fe1693 (diff) | |
| download | garage-47be652a1fe08a8e6dab6aa2c4a41d8eb119f392.tar.gz garage-47be652a1fe08a8e6dab6aa2c4a41d8eb119f392.zip | |
block manager: refactor: split resync into separate file
Diffstat (limited to 'src/garage/admin.rs')
| -rw-r--r-- | src/garage/admin.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/garage/admin.rs b/src/garage/admin.rs index 1d80889c..9f4764df 100644 --- a/src/garage/admin.rs +++ b/src/garage/admin.rs @@ -781,13 +781,13 @@ impl AdminRpcHandler { writeln!( &mut ret, " resync queue length: {}", - self.garage.block_manager.resync_queue_len()? + self.garage.block_manager.resync.queue_len()? ) .unwrap(); writeln!( &mut ret, " blocks with resync errors: {}", - self.garage.block_manager.resync_errors_len()? + self.garage.block_manager.resync.errors_len()? ) .unwrap(); @@ -850,7 +850,8 @@ impl AdminRpcHandler { WorkerSetCmd::ResyncTranquility { tranquility } => { self.garage .block_manager - .set_resync_tranquility(tranquility) + .resync + .set_tranquility(tranquility) .await?; Ok(AdminRpc::Ok("Resync tranquility updated".into())) } |