From 5368dce9f0d1d1ec22aa048c8cbc647a2943f99a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Thu, 11 Nov 2021 17:59:31 +0100 Subject: [PATCH] http: name worker threads --- aquatic_http/src/lib/lib.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/aquatic_http/src/lib/lib.rs b/aquatic_http/src/lib/lib.rs index 4c1f478..48ade1c 100644 --- a/aquatic_http/src/lib/lib.rs +++ b/aquatic_http/src/lib/lib.rs @@ -76,7 +76,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, @@ -104,7 +106,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,