aboutsummaryrefslogtreecommitdiff
path: root/src/rpc
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-01-11 16:12:07 +0100
committerAlex Auvolat <alex@adnab.me>2023-01-11 16:12:07 +0100
commit638c5a3ce006eba9d90a6358655ba2091423efd7 (patch)
treeabdb44553c6ea93907521db3fac9c8c788c9778f /src/rpc
parent399f137fd079be2c59b032e67d9ccd8d9214407e (diff)
downloadgarage-638c5a3ce006eba9d90a6358655ba2091423efd7.tar.gz
garage-638c5a3ce006eba9d90a6358655ba2091423efd7.zip
PollRange: add extra RPC delay after quorum is achieved,
to give a chance to the 3rd node to respond
Diffstat (limited to 'src/rpc')
-rw-r--r--src/rpc/rpc_helper.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rpc/rpc_helper.rs b/src/rpc/rpc_helper.rs
index 1ec250c3..e59c372a 100644
--- a/src/rpc/rpc_helper.rs
+++ b/src/rpc/rpc_helper.rs
@@ -15,10 +15,9 @@ 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,
- PRIO_SECONDARY,
+ IntoReq, 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};