diff options
author | metamuffin <metamuffin@disroot.org> | 2025-01-06 22:36:03 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2025-01-06 22:36:03 +0100 |
commit | 45282d3a54cc50306383c41e4c7e3d982cac69d1 (patch) | |
tree | d9b9046dae519f1e48716a7497c1dc8505d5e4d8 /server/src/network.rs | |
parent | 44ef37bca0aa633f8c59d849946faf2319c5446b (diff) | |
download | weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.bz2 weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.zst |
mesh not visible
Diffstat (limited to 'server/src/network.rs')
-rw-r--r-- | server/src/network.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/src/network.rs b/server/src/network.rs index 211d0bc..64bcf63 100644 --- a/server/src/network.rs +++ b/server/src/network.rs @@ -73,7 +73,7 @@ impl ServerNetwork { } }; spawn(move || { - if let Err(e) = handle_conn_write(conn, sock2, send_rx) { + if let Err(e) = handle_conn_write(sock2, send_rx) { warn!("client outbound error: {e}"); } }); @@ -183,7 +183,7 @@ fn handle_conn_read(conn: u128, sock: TcpStream, tx: Sender<(u128, Packet)>) -> tx.send((conn, packet)).unwrap(); } } -fn handle_conn_write(conn: u128, sock: TcpStream, rx: Receiver<Arc<Vec<u8>>>) -> Result<()> { +fn handle_conn_write(sock: TcpStream, rx: Receiver<Arc<Vec<u8>>>) -> Result<()> { let mut sock = BufWriter::new(sock); for packet in rx { sock.write_all(&packet)?; |