summaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-01-06 22:36:03 +0100
committermetamuffin <metamuffin@disroot.org>2025-01-06 22:36:03 +0100
commit45282d3a54cc50306383c41e4c7e3d982cac69d1 (patch)
treed9b9046dae519f1e48716a7497c1dc8505d5e4d8 /server
parent44ef37bca0aa633f8c59d849946faf2319c5446b (diff)
downloadweareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar
weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.bz2
weareserver-45282d3a54cc50306383c41e4c7e3d982cac69d1.tar.zst
mesh not visible
Diffstat (limited to 'server')
-rw-r--r--server/src/main.rs6
-rw-r--r--server/src/network.rs4
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)?;