aboutsummaryrefslogtreecommitdiff
path: root/src/model/k2v/rpc.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2024-03-27 15:26:08 +0100
committerAlex Auvolat <alex@adnab.me>2024-03-27 16:22:40 +0100
commit0d3e285d133459fd53e28f879a86c0de1a0c36df (patch)
tree4301ed7bd7ed72e79701c68bebdb4c5ea1db37a5 /src/model/k2v/rpc.rs
parent95eb8808e8ede5439cf6352ce4f9a148fac2f236 (diff)
downloadgarage-0d3e285d133459fd53e28f879a86c0de1a0c36df.tar.gz
garage-0d3e285d133459fd53e28f879a86c0de1a0c36df.zip
[fix-buffering] implement `block_ram_buffer_max` to avoid excessive RAM usage
Diffstat (limited to 'src/model/k2v/rpc.rs')
-rw-r--r--src/model/k2v/rpc.rs6
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