From 0a63ee3ce739567f2472a1a414a9aeeff9ddceec Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Wed, 6 Apr 2022 19:15:01 +0200
Subject: [PATCH] load testers: name worker threads "load-test"

---
 aquatic_http_load_test/src/main.rs | 1 +
 aquatic_udp_load_test/src/main.rs  | 6 +++---
 aquatic_ws_load_test/src/main.rs   | 1 +
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/aquatic_http_load_test/src/main.rs b/aquatic_http_load_test/src/main.rs
index 4b060e0..1955885 100644
--- a/aquatic_http_load_test/src/main.rs
+++ b/aquatic_http_load_test/src/main.rs
@@ -70,6 +70,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
         )?;
 
         LocalExecutorBuilder::new(placement)
+            .name("load-test")
             .spawn(move || async move {
                 run_socket_thread(config, tls_config, state).await.unwrap();
             })
diff --git a/aquatic_udp_load_test/src/main.rs b/aquatic_udp_load_test/src/main.rs
index 27ddd6a..7066b5f 100644
--- a/aquatic_udp_load_test/src/main.rs
+++ b/aquatic_udp_load_test/src/main.rs
@@ -1,7 +1,7 @@
 use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr};
 use std::sync::atomic::AtomicUsize;
 use std::sync::{atomic::Ordering, Arc};
-use std::thread;
+use std::thread::{self, Builder};
 use std::time::{Duration, Instant};
 
 #[cfg(feature = "cpu-pinning")]
@@ -79,7 +79,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
         let config = config.clone();
         let state = state.clone();
 
-        thread::spawn(move || {
+        Builder::new().name("load-test".into()).spawn(move || {
             #[cfg(feature = "cpu-pinning")]
             pin_current_if_configured_to(
                 &config.cpu_pinning,
@@ -89,7 +89,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
             );
 
             run_worker_thread(state, pareto, &config, addr)
-        });
+        })?;
     }
 
     #[cfg(feature = "cpu-pinning")]
diff --git a/aquatic_ws_load_test/src/main.rs b/aquatic_ws_load_test/src/main.rs
index 1603c93..c660267 100644
--- a/aquatic_ws_load_test/src/main.rs
+++ b/aquatic_ws_load_test/src/main.rs
@@ -67,6 +67,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
         )?;
 
         LocalExecutorBuilder::new(placement)
+            .name("load-test")
             .spawn(move || async move {
                 run_socket_thread(config, tls_config, state).await.unwrap();
             })