diff options
| -rw-r--r-- | src/block/manager.rs | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs index 73dd453f..decf33cc 100644 --- a/src/block/manager.rs +++ b/src/block/manager.rs @@ -218,9 +218,17 @@ impl BlockManager { /// to fix any mismatch between the two. pub async fn repair_data_store(&self, must_exit: &watch::Receiver<bool>) -> Result<(), Error> { // 1. Repair blocks from RC table. + // TODO don't do this like this + let mut hashes = vec![]; for (i, entry) in self.rc.rc.iter()?.enumerate() { let (hash, _) = entry?; let hash = Hash::try_from(&hash[..]).unwrap(); + hashes.push(hash); + if i & 0xFF == 0 && *must_exit.borrow() { + return Ok(()); + } + } + for (i, hash) in hashes.into_iter().enumerate() { self.put_to_resync(&hash, Duration::from_secs(0))?; if i & 0xFF == 0 && *must_exit.borrow() { return Ok(()); |