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

udp load test: improve statistics code

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-28 01:05:52 +01:00
parent b70cbe6349
commit 6605055b3d
1 changed files with 27 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

54
aquatic_udp_load_test/src/main.rs
View file

@ -115,7 +115,7 @@ fn monitor_statistics(state: LoadTestState, config: &Config) {
let mut last = start_time; let mut last = start_time;
loop { let time_elapsed = loop {
thread::sleep(Duration::from_secs(interval)); thread::sleep(Duration::from_secs(interval));
let requests = fetch_and_reset(&state.statistics.requests); let requests = fetch_and_reset(&state.statistics.requests);
@ -164,33 +164,33 @@ fn monitor_statistics(state: LoadTestState, config: &Config) {
let time_elapsed = start_time.elapsed(); let time_elapsed = start_time.elapsed();
if config.duration != 0 && time_elapsed >= duration { if config.duration != 0 && time_elapsed >= duration {
let len = report_avg_connect.len() as f64; break time_elapsed;
let avg_connect: f64 = report_avg_connect.into_iter().sum::<f64>() / len;
let avg_announce: f64 = report_avg_announce.into_iter().sum::<f64>() / len;
let avg_scrape: f64 = report_avg_scrape.into_iter().sum::<f64>() / len;
let avg_error: f64 = report_avg_error.into_iter().sum::<f64>() / len;
let avg_total = avg_connect + avg_announce + avg_scrape + avg_error;
println!(
concat!(
"\n# aquatic load test report\n\n",
"Test ran for {} seconds.\n",
"Average responses per second: {:.2}\n\nConfig: {:#?}\n"
),
time_elapsed.as_secs(),
avg_total,
config
);
println!(" - Connect responses: {:.2}", avg_connect);
println!(" - Announce responses: {:.2}", avg_announce);
println!(" - Scrape responses: {:.2}", avg_scrape);
println!(" - Error responses: {:.2}", avg_error);
break;
} }
} };
let len = report_avg_connect.len() as f64;
let avg_connect: f64 = report_avg_connect.into_iter().sum::<f64>() / len;
let avg_announce: f64 = report_avg_announce.into_iter().sum::<f64>() / len;
let avg_scrape: f64 = report_avg_scrape.into_iter().sum::<f64>() / len;
let avg_error: f64 = report_avg_error.into_iter().sum::<f64>() / len;
let avg_total = avg_connect + avg_announce + avg_scrape + avg_error;
println!(
concat!(
"\n# aquatic load test report\n\n",
"Test ran for {} seconds.\n",
"Average responses per second: {:.2}\n\nConfig: {:#?}\n"
),
time_elapsed.as_secs(),
avg_total,
config
);
println!(" - Connect responses: {:.2}", avg_connect);
println!(" - Announce responses: {:.2}", avg_announce);
println!(" - Scrape responses: {:.2}", avg_scrape);
println!(" - Error responses: {:.2}", avg_error);
} }
fn fetch_and_reset(atomic_usize: &AtomicUsize) -> f64 { fn fetch_and_reset(atomic_usize: &AtomicUsize) -> f64 {