diff options
author | metamuffin <metamuffin@disroot.org> | 2025-01-06 14:28:02 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2025-01-06 14:28:02 +0100 |
commit | 814cc1cb01692aa934a40636c9226ff7bb911266 (patch) | |
tree | 47a50a5dc1861ace4bc1854a9156618b70df3847 /server/src | |
parent | c2ee65a83838a0ce13402e2c4634bae409d55071 (diff) | |
download | weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.bz2 weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.zst |
new proto
Diffstat (limited to 'server/src')
-rw-r--r-- | server/src/main.rs | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/server/src/main.rs b/server/src/main.rs index cc55488..6b2911f 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -11,7 +11,11 @@ use std::{ }, thread::spawn, }; -use weareshared::{packets::Packet, store::ResourceStore, tree::SceneTree}; +use weareshared::{ + packets::{Packet, ReadWrite}, + store::ResourceStore, + tree::SceneTree, +}; #[derive(Parser, Debug)] struct Args { @@ -59,7 +63,7 @@ fn main() -> Result<()> { fn handle_conn_read(conn: usize, sock: TcpStream, state: Arc<Mutex<State>>) -> Result<()> { let mut sock = BufReader::new(sock); loop { - let packet = Packet::deserialize(&mut sock)?; + let packet = Packet::read(&mut sock)?; debug!("{conn} <- {packet:?}"); state.lock().unwrap().handle_packet(conn, packet)?; } @@ -68,7 +72,7 @@ fn handle_conn_write(conn: usize, sock: TcpStream, rx: Receiver<Packet>) -> Resu let mut sock = BufWriter::new(sock); for packet in rx { debug!("{conn} -> {packet:?}"); - packet.serialize(&mut sock)?; + packet.write(&mut sock)?; sock.flush()?; } Ok(()) |