British-Information-Technologies
/
ChatKit-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added better debug messages

This commit is contained in:
michael-bailey 2024-04-18 13:21:14 +01:00
parent 025ee5e49f
commit 577bfb3e55
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/listener_manager.rs
View File

@ -19,6 +19,7 @@ pub struct ListenerManager {
impl ListenerManager {
/// Binds listeners and stores them in the ListenerManager
pub async fn new(channel: UnboundedSender<ServerMessages>) -> Self {
println!("[ListenerManager] setting up listeners");
let protobuf_listener = TcpListener::bind("0.0.0.0:6500")
.await
.expect("[ListenerManager] failed to bind to 0.0.0.0:6500");
@ -31,6 +32,7 @@ impl ListenerManager {
pub async fn run(&self) {
loop {
println!("[ListenerManager] waiting for connection");
let accept_protobuf = self.protobuf_listener.accept();
let msg = select! {
@ -41,7 +43,6 @@ impl ListenerManager {
};
println!("[ListenerManager] passing message to server");
self.sender.send(msg).unwrap();
println!("[ListenerManager] looping to accept new");
}
}
}

2
server/src/os_signal_manager.rs
View File

@ -15,7 +15,9 @@ impl OSSignalManager {
pub async fn run(&self) {
loop {
println!("[OSSignalManager] waiting for ctrl+c");
tokio::signal::ctrl_c().await.unwrap();
println!("[OSSignalManager] ctrl+c received, closing down server");
self
.server_channel
.send(ServerMessages::Exit)