diff --git a/aquatic_ws_load_test/src/main.rs b/aquatic_ws_load_test/src/main.rs index 67a4a00..7ef2fbd 100644 --- a/aquatic_ws_load_test/src/main.rs +++ b/aquatic_ws_load_test/src/main.rs @@ -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; diff --git a/aquatic_ws_load_test/src/network.rs b/aquatic_ws_load_test/src/network.rs index b537eab..1c7f64c 100644 --- a/aquatic_ws_load_test/src/network.rs +++ b/aquatic_ws_load_test/src/network.rs @@ -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);