YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 02:35:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #94 from greatest-ape/work-2022-09-25

Browse source 
ws, http: name threads properly and include indices; update TODO
This commit is contained in:
Joakim Frostegård 2022-09-25 12:49:57 +02:00 • committed by GitHub
commit d1cd02e233
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

1
TODO.md
View file

@ -2,7 +2,6 @@
## High priority ## High priority
* Only return peers when AnnounceEvent != Stopped
* Do new udp load test round * Do new udp load test round
* Release new version * Release new version

4
aquatic_http/src/lib.rs
View file

@ -64,7 +64,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
config.swarm_workers, config.swarm_workers,
WorkerIndex::SocketWorker(i), WorkerIndex::SocketWorker(i),
)?; )?;
let builder = LocalExecutorBuilder::new(placement).name("socket"); let builder = LocalExecutorBuilder::new(placement).name(&format!("socket-{:02}", i + 1));
let executor = builder let executor = builder
.spawn(move || async move { .spawn(move || async move {
@ -96,7 +96,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
config.swarm_workers, config.swarm_workers,
WorkerIndex::SwarmWorker(i), WorkerIndex::SwarmWorker(i),
)?; )?;
let builder = LocalExecutorBuilder::new(placement).name("request"); let builder = LocalExecutorBuilder::new(placement).name(&format!("swarm-{:02}", i + 1));
let executor = builder let executor = builder
.spawn(move || async move { .spawn(move || async move {

4
aquatic_ws/src/lib.rs
View file

@ -80,7 +80,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
config.swarm_workers, config.swarm_workers,
WorkerIndex::SocketWorker(i), WorkerIndex::SocketWorker(i),
)?; )?;
let builder = LocalExecutorBuilder::new(placement).name("socket"); let builder = LocalExecutorBuilder::new(placement).name(&format!("socket-{:02}", i + 1));
let executor = builder let executor = builder
.spawn(move || async move { .spawn(move || async move {
@ -118,7 +118,7 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
config.swarm_workers, config.swarm_workers,
WorkerIndex::SwarmWorker(i), WorkerIndex::SwarmWorker(i),
)?; )?;
let builder = LocalExecutorBuilder::new(placement).name("request"); let builder = LocalExecutorBuilder::new(placement).name(&format!("swarm-{:02}", i + 1));
let executor = builder let executor = builder
.spawn(move || async move { .spawn(move || async move {