diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-11-27 11:52:57 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-11-27 11:52:57 +0100 |
| commit | d6d239fc7909cbd017da6ea35cceb3d561a87cca (patch) | |
| tree | 18725effafdd990d7e2953adcc1b50399673caed /src/block | |
| parent | 3ecd14b9f6202ad3c5513c6ad7422bd408134002 (diff) | |
| download | garage-d6d239fc7909cbd017da6ea35cceb3d561a87cca.tar.gz garage-d6d239fc7909cbd017da6ea35cceb3d561a87cca.zip | |
block manager: read_block using old layout versions if necessary
Diffstat (limited to 'src/block')
| -rw-r--r-- | src/block/manager.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs index be2e4951..47111160 100644 --- a/src/block/manager.rs +++ b/src/block/manager.rs @@ -264,8 +264,10 @@ impl BlockManager { F: Fn(DataBlockHeader, ByteStream) -> Fut, Fut: futures::Future<Output = Result<T, Error>>, { - let who = self.replication.read_nodes(hash); - let who = self.system.rpc_helper().request_order(&who); + let who = self + .system + .cluster_layout() + .block_read_nodes_of(hash, self.system.rpc_helper()); for node in who.iter() { let node_id = NodeID::from(*node); |