From 550ff1e4c5b98f2e724c2f251b840c5a13de815b Mon Sep 17 00:00:00 2001
From: alterdekim <alterwain@protonmail.com>
Date: Sun, 11 Aug 2024 21:20:01 +0300
Subject: [PATCH]  Changes to be committed: 	modified:   src/client.rs 
 modified:   src/server.rs

---
 src/client.rs | 2 +-
 src/server.rs | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/client.rs b/src/client.rs
index b8428b0..08cf3a3 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -105,7 +105,7 @@ pub async fn client_mode(remote_addr: String) -> io::Result<()> {
     });
 
     set.spawn(async move {
-        let mut buf = [0; 1024];
+        let mut buf = [0; 4096];
         loop {
             match receive_sock.recv_from(&mut buf).await {
                 Ok((len, addr)) => {
diff --git a/src/server.rs b/src/server.rs
index f3951fb..62f68c4 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -42,7 +42,6 @@ pub async fn server_mode() -> Result<(), BoxError> {
             let size = reader.read(&mut buf)?;
             let pkt = &buf[..size];
             use std::io::{Error, ErrorKind::Other};
-            //tx.send(pkt.to_vec()).map_err(|e| Error::new(Other, e))?;
             let m = clients_getter.lock().await;
             match m.get(&"10.0.8.2") {
                 Some(&ref sock) => { sock.send(&pkt).await.unwrap(); info!("Wrote to sock") },
@@ -56,7 +55,7 @@ pub async fn server_mode() -> Result<(), BoxError> {
     });
 
     set.spawn(async move {
-        let mut buf = [0; 1024];
+        let mut buf = [0; 4096];
         loop {
             if let Ok((len, addr)) = receiver_sock.recv_from(&mut buf).await {
                 let mut m = clients_inserter.lock().await;