From 647eb898ae50d923226dfab640be7bc188d06e8e Mon Sep 17 00:00:00 2001 From: Ryan Daum Date: Thu, 8 Feb 2024 19:57:04 -0500 Subject: [PATCH] Name a few more threads --- crates/daemon/src/main.rs | 4 +++- crates/daemon/src/rpc_server.rs | 10 ++++++---- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/crates/daemon/src/main.rs b/crates/daemon/src/main.rs index 04a78a3d..2ea1af7d 100644 --- a/crates/daemon/src/main.rs +++ b/crates/daemon/src/main.rs @@ -222,7 +222,9 @@ fn main() -> Result<(), Report> { // The scheduler thread: let loop_scheduler = scheduler.clone(); - let scheduler_loop_jh = std::thread::spawn(move || loop_scheduler.run()); + let scheduler_loop_jh = std::thread::Builder::new() + .name("moor-scheduler".to_string()) + .spawn(move || loop_scheduler.run())?; zmq_loop( keypair, diff --git a/crates/daemon/src/rpc_server.rs b/crates/daemon/src/rpc_server.rs index 5cce27d5..7947e9f8 100644 --- a/crates/daemon/src/rpc_server.rs +++ b/crates/daemon/src/rpc_server.rs @@ -1029,10 +1029,12 @@ pub(crate) fn zmq_loop( // Start up the ping-ponger timer in a background thread... let t_rpc_server = rpc_server.clone(); - std::thread::spawn(move || loop { - std::thread::sleep(std::time::Duration::from_secs(5)); - t_rpc_server.ping_pong().expect("Unable to play ping-pong"); - }); + std::thread::Builder::new() + .name("rpc-ping-pong".to_string()) + .spawn(move || loop { + std::thread::sleep(std::time::Duration::from_secs(5)); + t_rpc_server.ping_pong().expect("Unable to play ping-pong"); + })?; // We need to bind a generic publisher to the narrative endpoint, so that subsequent sessions // are visible...