added some closing thread debug prints
This commit is contained in:
parent
e5e50e5422
commit
7e97255acb
1 changed files with 2 additions and 1 deletions
|
@ -24,6 +24,7 @@ impl Socket {
|
||||||
|
|
||||||
let thread_owned_streams = Arc::clone(&socket_streams);
|
let thread_owned_streams = Arc::clone(&socket_streams);
|
||||||
|
|
||||||
|
println!("initializing socket connection handling thread");
|
||||||
let handle = thread::spawn(move || {
|
let handle = thread::spawn(move || {
|
||||||
listener.set_nonblocking(true).unwrap();
|
listener.set_nonblocking(true).unwrap();
|
||||||
let mut service_sockets: Vec<Arc<TcpStream>> = Vec::new();
|
let mut service_sockets: Vec<Arc<TcpStream>> = Vec::new();
|
||||||
|
@ -39,7 +40,7 @@ impl Socket {
|
||||||
Socket::service_clients(&mut service_sockets, messenger_tx.clone());
|
Socket::service_clients(&mut service_sockets, messenger_tx.clone());
|
||||||
thread::sleep(Duration::from_millis(100));
|
thread::sleep(Duration::from_millis(100));
|
||||||
}
|
}
|
||||||
println!("closed socket loop");
|
println!("closed socket connection handling thread");
|
||||||
drop(listener);
|
drop(listener);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue