IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2025-02-16 14:34:45 -06:00
Code Issues Packages Projects Releases Wiki Activity

One more try before I go and eat something...

Browse Source
This commit is contained in:
Herbert Wolverson 2024-03-18 16:13:06 -05:00
parent ebc3ab73da
commit e45bedc7ce
1 changed files with 8 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/finished_flows.rs
View File

@ -80,21 +80,6 @@ impl TimeBuffer {
if last_country != country {
if !last_country.is_empty() {
// Store the country
let rtt = [
if total_rtt[0] > 0.0 {
rtt_count[0] += 1;
(total_rtt[0] / rtt_count[0] as f64) as f32
} else {
0.0
},
if total_rtt[1] > 0.0 {
rtt_count[1] += 1;
(total_rtt[1] / rtt_count[1] as f64) as f32
} else {
0.0
},
];
if rtt_count[0] > 0 {
total_rtt[0] = (total_rtt[0] / rtt_count[0] as f64) as f64;
}
@ -117,10 +102,14 @@ impl TimeBuffer {
}
total_bytes[0] += bytes[0];
total_bytes[1] += bytes[1];
total_rtt[0] += rtt[0] as f64;
total_rtt[1] += rtt[1] as f64;
rtt_count[0] += 1;
rtt_count[1] += 1;
if rtt[0] > 0.0 {
total_rtt[0] += rtt[0] as f64;
rtt_count[0] += 1;
}
if rtt[1] > 0.0 {
total_rtt[1] += rtt[1] as f64;
rtt_count[1] += 1;
}
}
// Store the last country