Decrease RaftMessageSender queue size back to 128

qdrant · Apr 25, 2024 · 997566f · 997566f
1 parent add4a3c
commit 997566f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/consensus.rs b/src/consensus.rs
@@ -969,7 +969,7 @@ impl RaftMessageBroker {
     }
 
     fn message_sender(&self) -> (RaftMessageSender, RaftMessageSenderHandle) {
-        let (messages_tx, messages_rx) = tokio::sync::mpsc::channel(256);
+        let (messages_tx, messages_rx) = tokio::sync::mpsc::channel(128);
         let (heartbeat_tx, heartbeat_rx) = tokio::sync::watch::channel(Default::default());
 
         let task = RaftMessageSender {