aboutsummaryrefslogtreecommitdiffstats
path: root/mumd
diff options
context:
space:
mode:
Diffstat (limited to 'mumd')
-rw-r--r--mumd/src/main.rs7
1 files changed, 3 insertions, 4 deletions
diff --git a/mumd/src/main.rs b/mumd/src/main.rs
index 8639c35..14a43c1 100644
--- a/mumd/src/main.rs
+++ b/mumd/src/main.rs
@@ -37,7 +37,6 @@ async fn main() {
);
let state = Arc::new(Mutex::new(state));
- // Run it
let (_, _, _, e) = join!(
network::tcp::handle(
Arc::clone(&state),
@@ -54,7 +53,7 @@ async fn main() {
state,
command_receiver,
),
- spawn_blocking(move || {
+ spawn_blocking(move || { // IpcSender is blocking
receive_oneshot_commands(command_sender);
}),
);
@@ -68,11 +67,11 @@ fn receive_oneshot_commands(
// create listener
let (server, server_name): (IpcOneShotServer<(Command, IpcSender<Result<Option<CommandResponse>, ()>>)>, String) = IpcOneShotServer::new().unwrap();
fs::write("/var/tmp/mumd-oneshot", &server_name).unwrap();
- debug!("Listening for command at {}...", server_name);
+ debug!("Listening to {}", server_name);
// receive command and response channel
let (_, conn): (_, (Command, IpcSender<Result<Option<CommandResponse>, ()>>)) = server.accept().unwrap();
- debug!("Sending command {:?} to command handler", conn.0);
+ debug!("Sending to command handler: {:#?}", conn.0);
command_sender.send(conn).unwrap();
}
}