From 99b532b85bf35b5acf621c229fb991825f3d994c Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Thu, 1 Sep 2022 16:35:43 +0200
Subject: [PATCH] Apply PRIO_SECONDARY to block data transfers

---
 src/block/manager.rs  | 6 +++---
 src/rpc/rpc_helper.rs | 2 +-
 2 files changed, 4 insertions(+), 4 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),
 			)
diff --git a/src/rpc/rpc_helper.rs b/src/rpc/rpc_helper.rs
index e9575261..aa204c5e 100644
--- a/src/rpc/rpc_helper.rs
+++ b/src/rpc/rpc_helper.rs
@@ -18,7 +18,7 @@ use opentelemetry::{
 pub use netapp::endpoint::{Endpoint, EndpointHandler, StreamingEndpointHandler};
 use netapp::message::IntoReq;
 pub use netapp::message::{
-	Message as Rpc, OrderTag, Req, RequestPriority, Resp, PRIO_BACKGROUND, PRIO_HIGH, PRIO_NORMAL,
+	Message as Rpc, OrderTag, Req, RequestPriority, Resp, PRIO_BACKGROUND, PRIO_HIGH, PRIO_NORMAL, PRIO_SECONDARY
 };
 use netapp::peering::fullmesh::FullMeshPeeringStrategy;
 pub use netapp::{self, NetApp, NodeID};