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

udp: statistics: improve atomic usize vec sum code

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-19 12:22:11 +01:00
parent c78716153b
commit 2c336793b1
1 changed files with 6 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

22
aquatic_udp/src/lib/tasks.rs
View file

@ -25,20 +25,10 @@ pub fn gather_and_print_statistics(state: &State, config: &Config) {
let bytes_received_per_second: f64 = bytes_received / interval as f64;
let bytes_sent_per_second: f64 = bytes_sent / interval as f64;
let num_torrents_ipv4: usize = state
.statistics
.torrents_ipv4
.iter()
.map(|n| n.load(Ordering::SeqCst))
.sum();
let num_torrents_ipv6: usize = state
.statistics
.torrents_ipv6
.iter()
.map(|n| n.load(Ordering::SeqCst))
.sum();
let num_peers_ipv4 = sum_atomic_usize_vec(&state.statistics.peers_ipv4);
let num_peers_ipv6 = sum_atomic_usize_vec(&state.statistics.peers_ipv6);
let num_torrents_ipv4: usize = sum_atomic_usizes(&state.statistics.torrents_ipv4);
let num_torrents_ipv6 = sum_atomic_usizes(&state.statistics.torrents_ipv6);
let num_peers_ipv4 = sum_atomic_usizes(&state.statistics.peers_ipv4);
let num_peers_ipv6 = sum_atomic_usizes(&state.statistics.peers_ipv6);
let access_list_len = state.access_list.load().len();
@ -67,6 +57,6 @@ pub fn gather_and_print_statistics(state: &State, config: &Config) {
println!();
}
fn sum_atomic_usize_vec(vec: &Vec<AtomicUsize>) -> usize {
vec.iter().map(|n| n.load(Ordering::SeqCst)).sum()
fn sum_atomic_usizes(values: &[AtomicUsize]) -> usize {
values.iter().map(|n| n.load(Ordering::SeqCst)).sum()
}