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

load testers: name worker threads "load-test"

Browse source
This commit is contained in:
Joakim Frostegård 2022-04-06 19:15:01 +02:00
parent 5fb91ccc73
commit 0a63ee3ce7
3 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

1
aquatic_http_load_test/src/main.rs
View file

@ -70,6 +70,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
)?; )?;
LocalExecutorBuilder::new(placement) LocalExecutorBuilder::new(placement)
.name("load-test")
.spawn(move || async move { .spawn(move || async move {
run_socket_thread(config, tls_config, state).await.unwrap(); run_socket_thread(config, tls_config, state).await.unwrap();
}) })

6
aquatic_udp_load_test/src/main.rs
View file

@ -1,7 +1,7 @@
use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr}; use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr};
use std::sync::atomic::AtomicUsize; use std::sync::atomic::AtomicUsize;
use std::sync::{atomic::Ordering, Arc}; use std::sync::{atomic::Ordering, Arc};
use std::thread; use std::thread::{self, Builder};
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
#[cfg(feature = "cpu-pinning")] #[cfg(feature = "cpu-pinning")]
@ -79,7 +79,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
let config = config.clone(); let config = config.clone();
let state = state.clone(); let state = state.clone();
thread::spawn(move || { Builder::new().name("load-test".into()).spawn(move || {
#[cfg(feature = "cpu-pinning")] #[cfg(feature = "cpu-pinning")]
pin_current_if_configured_to( pin_current_if_configured_to(
&config.cpu_pinning, &config.cpu_pinning,
@ -89,7 +89,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
); );
run_worker_thread(state, pareto, &config, addr) run_worker_thread(state, pareto, &config, addr)
}); })?;
} }
#[cfg(feature = "cpu-pinning")] #[cfg(feature = "cpu-pinning")]

1
aquatic_ws_load_test/src/main.rs
View file

@ -67,6 +67,7 @@ fn run(config: Config) -> ::anyhow::Result<()> {
)?; )?;
LocalExecutorBuilder::new(placement) LocalExecutorBuilder::new(placement)
.name("load-test")
.spawn(move || async move { .spawn(move || async move {
run_socket_thread(config, tls_config, state).await.unwrap(); run_socket_thread(config, tls_config, state).await.unwrap();
}) })