1024

sifis-home · Feb 8, 2024 · d6f5247 · d6f5247
1 parent 1f1b659
commit d6f5247
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/dht-cache/src/domocache.rs b/dht-cache/src/domocache.rs
@@ -570,7 +570,7 @@ impl DomoCache {
 
         let peer_id = swarm.local_peer_id().to_string();
 
-        let (client_tx_channel, client_rx_channel) = mpsc::channel::<DomoEvent>(128);
+        let (client_tx_channel, client_rx_channel) = mpsc::channel::<DomoEvent>(1024);
 
         let send_cache_state_timer: tokio::time::Instant =
             tokio::time::Instant::now() + Duration::from_secs(u64::from(SEND_CACHE_HASH_PERIOD));

diff --git a/src/webapimanager.rs b/src/webapimanager.rs
@@ -62,7 +62,7 @@ impl WebApiManager {
             _ = socket::setsockopt(listener.as_raw_fd(), ReuseAddr, &true);
         }
 
-        let (tx_rest, rx_rest) = mpsc::channel(128);
+        let (tx_rest, rx_rest) = mpsc::channel(1024);
 
         let tx_get_all = tx_rest.clone();
 
@@ -77,12 +77,12 @@ impl WebApiManager {
         let tx_pub_message = tx_rest;
 
         let (async_tx_websocket, mut _async_rx_websocket) =
-            broadcast::channel::<AsyncWebSocketDomoMessage>(128);
+            broadcast::channel::<AsyncWebSocketDomoMessage>(1024);
 
         let async_tx_websocket_copy = async_tx_websocket.clone();
 
         let (sync_tx_websocket, sync_rx_websocket) =
-            broadcast::channel::<SyncWebSocketDomoMessage>(128);
+            broadcast::channel::<SyncWebSocketDomoMessage>(1024);
 
         let sync_tx_websocket_copy = sync_tx_websocket.clone();