diff options
| author | Alex <alex@adnab.me> | 2024-03-28 12:40:27 +0000 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2024-03-28 12:40:27 +0000 |
| commit | ecf641d88c264f7278d13a6d988288feb24a5dfe (patch) | |
| tree | 5cd60dfa4f0d6d32a66d2e32d7912c9e289067c8 /src/model/k2v | |
| parent | 75cd14926d8dec8c36289197822df78391686c6a (diff) | |
| parent | 85f580cbde4913fe8382316ff3c27b8443c61dd7 (diff) | |
| download | garage-ecf641d88c264f7278d13a6d988288feb24a5dfe.tar.gz garage-ecf641d88c264f7278d13a6d988288feb24a5dfe.zip | |
Merge pull request 'Fix unbounded buffering when one node has slower network' (#792) from fix-buffering into main
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/792
Diffstat (limited to 'src/model/k2v')
| -rw-r--r-- | src/model/k2v/rpc.rs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/model/k2v/rpc.rs b/src/model/k2v/rpc.rs index 4ab44c22..af7df341 100644 --- a/src/model/k2v/rpc.rs +++ b/src/model/k2v/rpc.rs @@ -300,7 +300,11 @@ impl K2VRpcHandler { let rs = RequestStrategy::with_priority(PRIO_NORMAL).without_timeout(); let mut requests = nodes .iter() - .map(|node| self.system.rpc.call(&self.endpoint, *node, msg.clone(), rs)) + .map(|node| { + self.system + .rpc + .call(&self.endpoint, *node, msg.clone(), rs.clone()) + }) .collect::<FuturesUnordered<_>>(); // Fetch responses. This procedure stops fetching responses when any of the following |