aboutsummaryrefslogtreecommitdiff
path: root/src/block/manager.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-09-01 16:35:43 +0200
committerAlex Auvolat <alex@adnab.me>2022-09-01 16:35:43 +0200
commit99b532b85bf35b5acf621c229fb991825f3d994c (patch)
treec1bb0e13524c87c7480c361271399c7a5e2b6603 /src/block/manager.rs
parente648bf7b69a487ca3f43d4ba607bfc2e354a5832 (diff)
downloadgarage-99b532b85bf35b5acf621c229fb991825f3d994c.tar.gz
garage-99b532b85bf35b5acf621c229fb991825f3d994c.zip
Apply PRIO_SECONDARY to block data transfers
Diffstat (limited to 'src/block/manager.rs')
-rw-r--r--src/block/manager.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs
index 00438648..a9def3b0 100644
--- a/src/block/manager.rs
+++ b/src/block/manager.rs
@@ -198,7 +198,7 @@ impl BlockManager {
let rpc = self.endpoint.call_streaming(
&node_id,
BlockRpc::GetBlock(*hash, order_tag),
- PRIO_NORMAL,
+ PRIO_NORMAL | PRIO_SECONDARY,
);
tokio::select! {
res = rpc => {
@@ -245,7 +245,7 @@ impl BlockManager {
let rpc = self.endpoint.call_streaming(
&node_id,
BlockRpc::GetBlock(*hash, order_tag),
- PRIO_NORMAL,
+ PRIO_NORMAL | PRIO_SECONDARY,
);
tokio::select! {
res = rpc => {
@@ -336,7 +336,7 @@ impl BlockManager {
&self.endpoint,
&who[..],
put_block_rpc,
- RequestStrategy::with_priority(PRIO_NORMAL)
+ RequestStrategy::with_priority(PRIO_NORMAL | PRIO_SECONDARY)
.with_quorum(self.replication.write_quorum())
.with_timeout(BLOCK_RW_TIMEOUT),
)