diff --git a/aquatic_ws/src/lib.rs b/aquatic_ws/src/lib.rs index 7d48a08..d7e961d 100644 --- a/aquatic_ws/src/lib.rs +++ b/aquatic_ws/src/lib.rs @@ -96,6 +96,8 @@ pub fn run(config: Config) -> ::anyhow::Result<()> { executors.push(executor); } + ::log::info!("spawned socket workers"); + for i in 0..(config.swarm_workers) { let sentinel = sentinel.clone(); let config = config.clone(); @@ -129,6 +131,8 @@ pub fn run(config: Config) -> ::anyhow::Result<()> { executors.push(executor); } + ::log::info!("spawned swarm workers"); + if config.cpu_pinning.active { set_affinity_for_util_worker( &config.cpu_pinning, diff --git a/aquatic_ws/src/workers/socket.rs b/aquatic_ws/src/workers/socket.rs index fdfd5a9..6626832 100644 --- a/aquatic_ws/src/workers/socket.rs +++ b/aquatic_ws/src/workers/socket.rs @@ -65,6 +65,8 @@ pub async fn run_socket_worker( let listener = create_tcp_listener(&config, priv_dropper).expect("create tcp listener"); + ::log::info!("created tcp listener"); + let (control_message_senders, _) = control_message_mesh_builder .join(Role::Producer) .await @@ -86,6 +88,8 @@ pub async fn run_socket_worker( out_message_mesh_builder.join(Role::Consumer).await.unwrap(); let out_message_consumer_id = ConsumerId(out_message_receivers.consumer_id().unwrap()); + ::log::info!("joined channels"); + let connection_slab = Rc::new(RefCell::new(Slab::new())); // Periodically clean connections