diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-09-02 16:52:22 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-09-02 16:52:22 +0200 |
| commit | 5e8baa433d743a06ab3ee90f375f24c3c36fc236 (patch) | |
| tree | 752f0e4a28d6b2a8648322d76cf98d23c2b2837e /src/block/resync.rs | |
| parent | 47be652a1fe08a8e6dab6aa2c4a41d8eb119f392 (diff) | |
| download | garage-5e8baa433d743a06ab3ee90f375f24c3c36fc236.tar.gz garage-5e8baa433d743a06ab3ee90f375f24c3c36fc236.zip | |
Make BlockManagerLocked fully private again
Diffstat (limited to 'src/block/resync.rs')
| -rw-r--r-- | src/block/resync.rs | 14 |
1 files changed, 2 insertions, 12 deletions
diff --git a/src/block/resync.rs b/src/block/resync.rs index 2a8184b7..dab08338 100644 --- a/src/block/resync.rs +++ b/src/block/resync.rs @@ -282,12 +282,7 @@ impl BlockResyncManager { } async fn resync_block(&self, manager: &BlockManager, hash: &Hash) -> Result<(), Error> { - let BlockStatus { exists, needed } = manager - .mutation_lock - .lock() - .await - .check_block_status(hash, manager) - .await?; + let BlockStatus { exists, needed } = manager.check_block_status(hash).await?; if exists != needed.is_needed() || exists != needed.is_nonzero() { debug!( @@ -370,12 +365,7 @@ impl BlockResyncManager { who.len() ); - manager - .mutation_lock - .lock() - .await - .delete_if_unneeded(hash, manager) - .await?; + manager.delete_if_unneeded(hash).await?; manager.rc.clear_deleted_block_rc(hash)?; } |