aboutsummaryrefslogtreecommitdiff
path: root/src/block/manager.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/block/manager.rs')
-rw-r--r--src/block/manager.rs3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs
index 72b4ea66..2bb9c23d 100644
--- a/src/block/manager.rs
+++ b/src/block/manager.rs
@@ -354,7 +354,8 @@ impl BlockManager {
/// Send block to nodes that should have it
pub async fn rpc_put_block(&self, hash: Hash, data: Bytes) -> Result<(), Error> {
- let who = self.replication.write_nodes(&hash);
+ // TODO: use quorums among latest write set
+ let who = self.replication.storage_nodes(&hash);
let (header, bytes) = DataBlock::from_buffer(data, self.compression_level)
.await