diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-07-25 18:19:35 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-07-29 12:25:03 +0200 |
| commit | e935861854deed5d1ca66767fc51d9849201a4dd (patch) | |
| tree | fd368113ae4ad4b672fbcaaf37be8666e2695411 /src/block | |
| parent | f0ee3056d3357221d71ad7d346e419dc26b9e063 (diff) | |
| download | garage-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.rs | 2 |
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); |