dandri/aquatic
1
0
Fork 0
mirror of https://github.com/greatest-ape/aquatic.git synced 2026-08-25 03:19:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

ws, http: name threads properly and include indices

Browse Source
This commit is contained in:
Joakim Frostegård
2022-09-25 12:36:20 +02:00
parent 749add3fc8
commit b6287d12e4
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
aquatic_http/src/lib.rs
+2 -2
View File
@@ -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 {
aquatic_ws/src/lib.rs
+2 -2
View File
@@ -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 {