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

ws load test: use relaxed atomics

Browse source
This commit is contained in:
Joakim Frostegård 2023-01-25 22:40:35 +01:00
parent 6f95a8cf4a
commit 1d8eec3c44
2 changed files with 13 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

14
aquatic_ws_load_test/src/main.rs
View file

@ -129,20 +129,20 @@ fn monitor_statistics(state: LoadTestState, config: &Config) {
let statistics = state.statistics.as_ref();
let responses_announce =
statistics.responses_announce.fetch_and(0, Ordering::SeqCst) as f64;
statistics.responses_announce.fetch_and(0, Ordering::Relaxed) as f64;
// let response_peers = statistics.response_peers
// .fetch_and(0, Ordering::SeqCst) as f64;
// .fetch_and(0, Ordering::Relaxed) as f64;
let requests_per_second =
statistics.requests.fetch_and(0, Ordering::SeqCst) as f64 / interval_f64;
statistics.requests.fetch_and(0, Ordering::Relaxed) as f64 / interval_f64;
let responses_offer_per_second =
statistics.responses_offer.fetch_and(0, Ordering::SeqCst) as f64 / interval_f64;
statistics.responses_offer.fetch_and(0, Ordering::Relaxed) as f64 / interval_f64;
let responses_answer_per_second =
statistics.responses_answer.fetch_and(0, Ordering::SeqCst) as f64 / interval_f64;
statistics.responses_answer.fetch_and(0, Ordering::Relaxed) as f64 / interval_f64;
let responses_scrape_per_second =
statistics.responses_scrape.fetch_and(0, Ordering::SeqCst) as f64 / interval_f64;
statistics.responses_scrape.fetch_and(0, Ordering::Relaxed) as f64 / interval_f64;
let responses_error_per_second =
statistics.responses_error.fetch_and(0, Ordering::SeqCst) as f64 / interval_f64;
statistics.responses_error.fetch_and(0, Ordering::Relaxed) as f64 / interval_f64;
let responses_announce_per_second = responses_announce / interval_f64;

12
aquatic_ws_load_test/src/network.rs
View file

@ -149,7 +149,7 @@ impl Connection {
self.load_test_state
.statistics
.requests
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
self.can_send = false;
}
@ -183,7 +183,7 @@ impl Connection {
self.load_test_state
.statistics
.responses_offer
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
self.send_answer = Some((offer.peer_id, offer.offer_id));
@ -193,7 +193,7 @@ impl Connection {
self.load_test_state
.statistics
.responses_answer
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
self.can_send = true;
}
@ -201,7 +201,7 @@ impl Connection {
self.load_test_state
.statistics
.responses_announce
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
self.can_send = true;
}
@ -209,7 +209,7 @@ impl Connection {
self.load_test_state
.statistics
.responses_scrape
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
self.can_send = true;
}
@ -217,7 +217,7 @@ impl Connection {
self.load_test_state
.statistics
.responses_error
.fetch_add(1, Ordering::SeqCst);
.fetch_add(1, Ordering::Relaxed);
::log::warn!("received error response: {:?}", response.failure_reason);