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 | |
parent | 44ef37bca0aa633f8c59d849946faf2319c5446b (diff) | |
download | weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.bz2 weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.zst |
mesh not visible
Diffstat (limited to 'server')
-rw-r--r-- | server/src/main.rs | 6 | ||||
-rw-r--r-- | server/src/network.rs | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/server/src/main.rs b/server/src/main.rs index 58c3cb2..5216b41 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -13,7 +13,7 @@ use weareshared::{ #[derive(Parser, Debug)] struct Args { - #[arg(short, long, default_value = "::0")] + #[arg(short, long, default_value = "::")] bind_addr: IpAddr, #[arg(short, long, default_value = "28555")] port: u16, @@ -76,10 +76,10 @@ impl State { net.broadcast(Packet::Remove(object), true); } Packet::Position(object, pos, rot) => { - net.broadcast(Packet::Position(object, pos, rot), true); + net.broadcast(Packet::Position(object, pos, rot), false); } Packet::Pose(object, vec) => { - net.broadcast(Packet::Pose(object, vec), true); + net.broadcast(Packet::Pose(object, vec), false); } Packet::Parent(parent, child) => { net.broadcast(Packet::Parent(parent, child), true); 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)?; |