maybe working channels size

client/src/connections/tcp_connection.rs

@@ -3,6 +3,7 @@ use std::time::Duration;
 use bytes::Bytes;
 use netrunner_core::protocol::codec::frame::FrameType;
 use netrunner_core::protocol::codec::socks::TargetAddress;
+use netrunner_core::proxy::connection::BUF_SIZE;
 use netrunner_core::proxy::connection::muxer::{MuxMessage, Muxer};
 use smoltcp::iface::SocketHandle;
 use smoltcp::socket::tcp;
@@ -44,7 +45,7 @@ impl TcpConnection {
         tokio::spawn(async move {
             // ИСПРАВЛЕНИЕ: Даем Муксеру ограниченный канал, как он и просит (тип mpsc::Sender)
             // Делаем его достаточно вместительным (1024)
-            let (v_tx, mut v_rx) = mpsc::channel::<Bytes>(1024);
+            let (v_tx, mut v_rx) = mpsc::channel::<Bytes>(BUF_SIZE);
             muxer.register_stream(stream_id, v_tx);
 
             let connect_payload = target_addr.to_string();

client/src/tun/connection_manager.rs

@@ -358,7 +358,7 @@ impl ConnectionManager {
         }
     }
     pub fn setup_sockets(n_icmp: usize) -> SocketSet<'static> {
-        let mut sockets = SocketSet::new(Vec::with_capacity(1024));
+        let mut sockets = SocketSet::new(Vec::with_capacity(48));
 
         for _ in 0..n_icmp {
             sockets.add(Self::create_icmp_socket());

client/src/tun/engine.rs

@@ -47,7 +47,7 @@ impl Engine {
         let (mut device, to_smoltcp_tx, from_smoltcp_rx, avail) = VirtTunDevice::new(caps);
         let interface = Interface::new(config, &mut device, now);
 
-        let socket_set = ConnectionManager::setup_sockets(4);
+        let socket_set = ConnectionManager::setup_sockets(2);
         let manager = ConnectionManager::new(dns_handler, muxer);
 
         Self {

core/src/proxy/connection/bridge.rs

@@ -1,6 +1,6 @@
 use crate::protocol::codec::frame::FrameType;
-use crate::proxy::connection::connection::BUF_SIZE;
 use crate::proxy::connection::muxer::{MuxMessage, Muxer};
+use crate::proxy::connection::BUF_SIZE;
 use bytes::{Bytes, BytesMut};
 use netrunner_logger::{debug, error};
 use tokio::net::UdpSocket;

core/src/proxy/connection/connection.rs

@@ -13,6 +13,7 @@ use crate::{
         engine::TunnelEngine,
         handler::StreamHandler,
         muxer::{MuxMessage, Muxer},
+        BUF_SIZE, CHANNEL_SIZE,
     },
     tlseng::profile::BrowserProfile,
 };
@@ -28,9 +29,6 @@ use tokio::{
 };
 use tokio_util::sync::CancellationToken;
 
-pub const BUF_SIZE: usize = 65536;
-pub const CHANNEL_SIZE: usize = 256;
-
 #[derive(Clone, Copy, Debug, PartialEq)]
 pub enum ConnectionRole {
     Client,
@@ -205,7 +203,7 @@ impl TunnelHandler for ClientHandler {
                 target,
             } => {
                 let stream_id = self.muxer.next_id();
-                let (v_tx, mut v_rx) = mpsc::channel::<bytes::Bytes>(1024);
+                let (v_tx, mut v_rx) = mpsc::channel::<bytes::Bytes>(BUF_SIZE);
                 self.muxer.register_stream(stream_id, v_tx);
 
                 self.muxer

core/src/proxy/connection/mod.rs

@@ -3,3 +3,6 @@ pub mod connection;
 pub mod engine;
 pub mod handler;
 pub mod muxer;
+
+pub const BUF_SIZE: usize = 65536;
+pub const CHANNEL_SIZE: usize = 16;

core/src/proxy/network.rs

@@ -1,11 +1,10 @@
 use crate::{
     protocol::errors::ErrorAction,
     proxy::connection::{
-        connection::{
+        connection::{ClientHandler, Connection, ConnectionRole, ServerHandler, TunnelHandler},
-            ClientHandler, Connection, ConnectionRole, ServerHandler, TunnelHandler, CHANNEL_SIZE,
-        },
         engine::TunnelEngine,
         muxer::Muxer,
+        CHANNEL_SIZE,
     },
     tlseng::profile::BrowserProfile,
 };
@@ -132,7 +131,7 @@ impl Network {
             }
         }
 
-        let (mux_tx, mux_rx) = tokio::sync::mpsc::channel(CHANNEL_SIZE);
+        let (mux_tx, mux_rx) = tokio::sync::mpsc::channel(CHANNEL_SIZE * 48);
         let muxer = Muxer::new(mux_tx, true);
 
         let handler = std::sync::Arc::new(crate::proxy::connection::handler::StreamHandler::new(