aboutsummaryrefslogtreecommitdiff
path: root/src/block
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-07-25 18:19:35 +0200
committerAlex Auvolat <alex@adnab.me>2022-07-29 12:25:03 +0200
commite935861854deed5d1ca66767fc51d9849201a4dd (patch)
treefd368113ae4ad4b672fbcaaf37be8666e2695411 /src/block
parentf0ee3056d3357221d71ad7d346e419dc26b9e063 (diff)
downloadgarage-e935861854deed5d1ca66767fc51d9849201a4dd.tar.gz
garage-e935861854deed5d1ca66767fc51d9849201a4dd.zip
Factor out node request order selection logic & use in manager
Diffstat (limited to 'src/block')
-rw-r--r--src/block/manager.rs2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs
index bb01c300..80c52510 100644
--- a/src/block/manager.rs
+++ b/src/block/manager.rs
@@ -185,6 +185,7 @@ impl BlockManager {
hash: &Hash,
) -> Result<(DataBlockHeader, ByteStream), Error> {
let who = self.replication.read_nodes(hash);
+ //let who = self.system.rpc.request_order(&who);
for node in who.iter() {
let node_id = NodeID::from(*node);
@@ -225,6 +226,7 @@ impl BlockManager {
/// Return its entire body
async fn rpc_get_raw_block(&self, hash: &Hash) -> Result<DataBlock, Error> {
let who = self.replication.read_nodes(hash);
+ //let who = self.system.rpc.request_order(&who);
for node in who.iter() {
let node_id = NodeID::from(*node);