From b6287d12e46816e4bbffc567638cbd5083b1527e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Sun, 25 Sep 2022 12:36:20 +0200
Subject: [PATCH] ws, http: name threads properly and include indices

---
 aquatic_http/src/lib.rs | 4 ++--
 aquatic_ws/src/lib.rs   | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/aquatic_http/src/lib.rs b/aquatic_http/src/lib.rs
index 8b82c4f..72a9656 100644
--- a/aquatic_http/src/lib.rs
+++ b/aquatic_http/src/lib.rs
@@ -64,7 +64,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
             config.swarm_workers,
             WorkerIndex::SocketWorker(i),
         )?;
-        let builder = LocalExecutorBuilder::new(placement).name("socket");
+        let builder = LocalExecutorBuilder::new(placement).name(&format!("socket-{:02}", i + 1));
 
         let executor = builder
             .spawn(move || async move {
@@ -96,7 +96,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
             config.swarm_workers,
             WorkerIndex::SwarmWorker(i),
         )?;
-        let builder = LocalExecutorBuilder::new(placement).name("request");
+        let builder = LocalExecutorBuilder::new(placement).name(&format!("swarm-{:02}", i + 1));
 
         let executor = builder
             .spawn(move || async move {
diff --git a/aquatic_ws/src/lib.rs b/aquatic_ws/src/lib.rs
index d8b6cd0..a7c2e83 100644
--- a/aquatic_ws/src/lib.rs
+++ b/aquatic_ws/src/lib.rs
@@ -80,7 +80,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
             config.swarm_workers,
             WorkerIndex::SocketWorker(i),
         )?;
-        let builder = LocalExecutorBuilder::new(placement).name("socket");
+        let builder = LocalExecutorBuilder::new(placement).name(&format!("socket-{:02}", i + 1));
 
         let executor = builder
             .spawn(move || async move {
@@ -118,7 +118,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
             config.swarm_workers,
             WorkerIndex::SwarmWorker(i),
         )?;
-        let builder = LocalExecutorBuilder::new(placement).name("request");
+        let builder = LocalExecutorBuilder::new(placement).name(&format!("swarm-{:02}", i + 1));
 
         let executor = builder
             .spawn(move || async move {