From b6287d12e46816e4bbffc567638cbd5083b1527e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sun, 25 Sep 2022 12:36:20 +0200 Subject: [PATCH 1/2] 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 { From 6d44280eb390d03641cc23a2b0de1e23c026c784 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sun, 25 Sep 2022 12:37:43 +0200 Subject: [PATCH 2/2] Update TODO --- TODO.md | 1 - 1 file changed, 1 deletion(-) diff --git a/TODO.md b/TODO.md index 7ed79f2..bbaf194 100644 --- a/TODO.md +++ b/TODO.md @@ -2,7 +2,6 @@ ## High priority -* Only return peers when AnnounceEvent != Stopped * Do new udp load test round * Release new version