aboutsummaryrefslogtreecommitdiff
path: root/src/model
diff options
context:
space:
mode:
Diffstat (limited to 'src/model')
-rw-r--r--src/model/block.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/model/block.rs b/src/model/block.rs
index 85468258..d1ea1512 100644
--- a/src/model/block.rs
+++ b/src/model/block.rs
@@ -129,7 +129,7 @@ impl BlockManager {
/// Ask nodes that might have a block for it
pub async fn rpc_get_block(&self, hash: &Hash) -> Result<Vec<u8>, Error> {
- let who = self.replication.read_nodes(&hash);
+ let who = self.replication.read_nodes(hash);
let resps = self
.system
.rpc
@@ -224,7 +224,7 @@ impl BlockManager {
})?;
let old_rc = old_rc.map(u64_from_be_bytes).unwrap_or(0);
if old_rc == 0 {
- self.put_to_resync(&hash, BLOCK_RW_TIMEOUT)?;
+ self.put_to_resync(hash, BLOCK_RW_TIMEOUT)?;
}
Ok(())
}
@@ -240,7 +240,7 @@ impl BlockManager {
}
})?;
if new_rc.is_none() {
- self.put_to_resync(&hash, BLOCK_GC_TIMEOUT)?;
+ self.put_to_resync(hash, BLOCK_GC_TIMEOUT)?;
}
Ok(())
}
@@ -406,7 +406,7 @@ impl BlockManager {
if exists && !needed {
trace!("Offloading block {:?}", hash);
- let mut who = self.replication.write_nodes(&hash);
+ let mut who = self.replication.write_nodes(hash);
if who.len() < self.replication.write_quorum() {
return Err(Error::Message("Not trying to offload block because we don't have a quorum of nodes to write to".to_string()));
}
@@ -478,7 +478,7 @@ impl BlockManager {
// TODO find a way to not do this if they are sending it to us
// Let's suppose this isn't an issue for now with the BLOCK_RW_TIMEOUT delay
// between the RC being incremented and this part being called.
- let block_data = self.rpc_get_block(&hash).await?;
+ let block_data = self.rpc_get_block(hash).await?;
self.write_block(hash, &block_data[..]).await?;
}
@@ -600,7 +600,7 @@ impl BlockManagerLocked {
let mut path2 = path.clone();
path2.set_extension(".corrupted");
fs::rename(path, path2).await?;
- mgr.put_to_resync(&hash, Duration::from_millis(0))?;
+ mgr.put_to_resync(hash, Duration::from_millis(0))?;
Ok(())
}