From 776de55abccd3fa75b0882dabfd105f9e76a182a Mon Sep 17 00:00:00 2001 From: DJMrTV Date: Sun, 19 Jan 2025 14:37:29 +0100 Subject: [PATCH] added logging --- src/prudp/server.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/prudp/server.rs b/src/prudp/server.rs index 74344d1..fa56ae9 100644 --- a/src/prudp/server.rs +++ b/src/prudp/server.rs @@ -48,6 +48,8 @@ impl NexServer{ } fn server_thread_entry(self: Arc, socket: Arc){ + info!("starting datagram thread"); + while self.running.load(Ordering::Relaxed) { // yes we actually allow the max udp to be read lol let mut msg_buffer = vec![0u8; 65507]; @@ -56,7 +58,7 @@ impl NexServer{ .expect("Datagram thread crashed due to unexpected error from recv_from"); let current_msg = &msg_buffer[0..len]; - + info!("attempting to process message"); self.process_prudp_packets(addr, current_msg); } } @@ -77,6 +79,7 @@ impl NexServer{ for _ in 0..*SERVER_DATAGRAMS { let socket = socket.clone(); let server= arc.clone(); + thread = Some(thread::spawn(move || { server.server_thread_entry(socket); }));