From 33dda598f34fd0f8c3fdf0e6d2d5aae93d33d3d5 Mon Sep 17 00:00:00 2001
From: Anastasios Kichidis <tasos@mystenlabs.com>
Date: Thu, 21 Dec 2023 18:20:31 +0000
Subject: [PATCH] increase network channel size

---
 mysticeti-core/src/network.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/mysticeti-core/src/network.rs b/mysticeti-core/src/network.rs
index 02e96b64..fc9e8ba5 100644
--- a/mysticeti-core/src/network.rs
+++ b/mysticeti-core/src/network.rs
@@ -434,8 +434,8 @@ impl Worker {
     }
 
     async fn make_connection(&self) -> Option<WorkerConnection> {
-        let (network_in_sender, network_in_receiver) = mpsc::channel(16);
-        let (network_out_sender, network_out_receiver) = mpsc::channel(16);
+        let (network_in_sender, network_in_receiver) = mpsc::channel(1_000);
+        let (network_out_sender, network_out_receiver) = mpsc::channel(1_000);
         let (latency_last_value_sender, latency_last_value_receiver) =
             tokio::sync::watch::channel(Duration::from_millis(0));
         let connection = Connection {