spacebar/rust-nex
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages 50 Wiki Activity Actions

added logging

Browse source
This commit is contained in:
DJMrTV 2025-01-19 14:37:29 +01:00
commit 776de55abc
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/prudp/server.rs
View file

@ -48,6 +48,8 @@ impl NexServer{
} }
fn server_thread_entry(self: Arc<Self>, socket: Arc<UdpSocket>){ fn server_thread_entry(self: Arc<Self>, socket: Arc<UdpSocket>){
info!("starting datagram thread");
while self.running.load(Ordering::Relaxed) { while self.running.load(Ordering::Relaxed) {
// yes we actually allow the max udp to be read lol // yes we actually allow the max udp to be read lol
let mut msg_buffer = vec![0u8; 65507]; let mut msg_buffer = vec![0u8; 65507];
@ -56,7 +58,7 @@ impl NexServer{
.expect("Datagram thread crashed due to unexpected error from recv_from"); .expect("Datagram thread crashed due to unexpected error from recv_from");
let current_msg = &msg_buffer[0..len]; let current_msg = &msg_buffer[0..len];
info!("attempting to process message");
self.process_prudp_packets(addr, current_msg); self.process_prudp_packets(addr, current_msg);
} }
} }
@ -77,6 +79,7 @@ impl NexServer{
for _ in 0..*SERVER_DATAGRAMS { for _ in 0..*SERVER_DATAGRAMS {
let socket = socket.clone(); let socket = socket.clone();
let server= arc.clone(); let server= arc.clone();
thread = Some(thread::spawn(move || { thread = Some(thread::spawn(move || {
server.server_thread_entry(socket); server.server_thread_entry(socket);
})); }));