YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 18:55:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ws: add some info level logging

Browse source
This commit is contained in:
Joakim Frostegård 2022-07-19 23:45:15 +02:00
parent 809aa4def9
commit b79636730c
2 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
aquatic_ws/src/lib.rs
View file

@ -96,6 +96,8 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
executors.push(executor); executors.push(executor);
} }
::log::info!("spawned socket workers");
for i in 0..(config.swarm_workers) { for i in 0..(config.swarm_workers) {
let sentinel = sentinel.clone(); let sentinel = sentinel.clone();
let config = config.clone(); let config = config.clone();
@ -129,6 +131,8 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
executors.push(executor); executors.push(executor);
} }
::log::info!("spawned swarm workers");
if config.cpu_pinning.active { if config.cpu_pinning.active {
set_affinity_for_util_worker( set_affinity_for_util_worker(
&config.cpu_pinning, &config.cpu_pinning,

4
aquatic_ws/src/workers/socket.rs
View file

@ -65,6 +65,8 @@ pub async fn run_socket_worker(
let listener = create_tcp_listener(&config, priv_dropper).expect("create tcp listener"); 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 let (control_message_senders, _) = control_message_mesh_builder
.join(Role::Producer) .join(Role::Producer)
.await .await
@ -86,6 +88,8 @@ pub async fn run_socket_worker(
out_message_mesh_builder.join(Role::Consumer).await.unwrap(); out_message_mesh_builder.join(Role::Consumer).await.unwrap();
let out_message_consumer_id = ConsumerId(out_message_receivers.consumer_id().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())); let connection_slab = Rc::new(RefCell::new(Slab::new()));
// Periodically clean connections // Periodically clean connections