diff --git a/prudpv0/src/server.rs b/prudpv0/src/server.rs index 1305d81..ce6cd21 100644 --- a/prudpv0/src/server.rs +++ b/prudpv0/src/server.rs @@ -284,6 +284,9 @@ impl Server { }); let mut conns = self.connections.write().await; + if conns.contains_key(&addr) { + error!("client already connected but tried to connect again"); + } conns.insert(addr, conn.clone()); drop(conns); @@ -346,7 +349,8 @@ impl Server { ); while let Some((_, mut packet)) = { let ctr = conn.client_packet_counter; - conn.packet_queue.remove(&ctr) + let packet = conn.packet_queue.remove(&ctr); + packet } { info!("processing packet: {}", conn.client_packet_counter); let Some(payload) = packet.payload_mut() else {