Commit ab927363 authored by nanamicat's avatar nanamicat

syn

parent 30181305
......@@ -60,15 +60,15 @@ async fn main() -> anyhow::Result<()> {
// from server
let (message, _): (Change, usize) = bincode::decode_from_slice(&buf[..len], bincode::config::standard())?;
server.on_message(&message);
syn = false;
let report = Report {
id: config.id,
syn: message.rst,
syn,
ack: server.ack,
peers: Vec::new()
};
let message = bincode::encode_to_vec(&report, bincode::config::standard())?;
let _ = socket.send_to(message.as_slice(), server_addr).await;
syn = false;
} else if let Some(peer) = Router::get(&mut routers, addr){
// from client
let (message, _): (Hello, usize) = bincode::decode_from_slice(&buf[..len], bincode::config::standard())?;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment