diff --git a/aquatic_udp/src/lib/glommio/mod.rs b/aquatic_udp/src/lib/glommio/mod.rs index 058f5e9..8cc8d27 100644 --- a/aquatic_udp/src/lib/glommio/mod.rs +++ b/aquatic_udp/src/lib/glommio/mod.rs @@ -67,7 +67,9 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> { let response_mesh_builder = response_mesh_builder.clone(); let num_bound_sockets = num_bound_sockets.clone(); - let executor = LocalExecutorBuilder::default().spawn(move || async move { + let builder = LocalExecutorBuilder::default().name("socket"); + + let executor = builder.spawn(move || async move { pin_current_if_configured_to( &config.cpu_pinning, config.socket_workers, @@ -93,7 +95,9 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> { let request_mesh_builder = request_mesh_builder.clone(); let response_mesh_builder = response_mesh_builder.clone(); - let executor = LocalExecutorBuilder::default().spawn(move || async move { + let builder = LocalExecutorBuilder::default().name("request"); + + let executor = builder.spawn(move || async move { pin_current_if_configured_to( &config.cpu_pinning, config.socket_workers, diff --git a/aquatic_ws/src/lib/glommio/mod.rs b/aquatic_ws/src/lib/glommio/mod.rs index 3d74042..ed6c495 100644 --- a/aquatic_ws/src/lib/glommio/mod.rs +++ b/aquatic_ws/src/lib/glommio/mod.rs @@ -39,7 +39,9 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> { let response_mesh_builder = response_mesh_builder.clone(); let num_bound_sockets = num_bound_sockets.clone(); - let executor = LocalExecutorBuilder::default().spawn(move || async move { + let builder = LocalExecutorBuilder::default().name("socket"); + + let executor = builder.spawn(move || async move { #[cfg(feature = "cpu-pinning")] pin_current_if_configured_to( &config.cpu_pinning, @@ -67,7 +69,9 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> { let request_mesh_builder = request_mesh_builder.clone(); let response_mesh_builder = response_mesh_builder.clone(); - let executor = LocalExecutorBuilder::default().spawn(move || async move { + let builder = LocalExecutorBuilder::default().name("request"); + + let executor = builder.spawn(move || async move { #[cfg(feature = "cpu-pinning")] pin_current_if_configured_to( &config.cpu_pinning,