Increase buffer_size of inter-node channel

akiradeveloper · Jun 16, 2024 · d1d65cd · d1d65cd
1 parent 71a1e66
commit d1d65cd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lolraft/src/communicator/mod.rs b/lolraft/src/communicator/mod.rs
@@ -26,6 +26,7 @@ impl RaftConnection {
     pub fn new(self_node_id: NodeId, dest_node_id: NodeId) -> Self {
         let client = {
             let endpoint = tonic::transport::Endpoint::from(dest_node_id.0.clone())
+                .buffer_size(1 << 16)
                 // (http2) Send ping to keep connection (default: disabled)
                 .http2_keep_alive_interval(Duration::from_secs(1))
                 // (http2) Send ping even if there is no active streams (default: disabled)