IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

Another consistency update - the iterator for adding data was missing a filter we use elsewhere.

Browse Source
This commit is contained in:
Herbert Wolverson
2023-07-11 16:20:41 +00:00
parent acabdc7ff2
commit 4a1e7e7eb7
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/rust/lqosd/src/throughput_tracker/tracking_data.rs
View File

@@ -193,12 +193,12 @@ impl ThroughputTracker {
#[inline(always)]
fn add_atomic_tuple(tuple: &(AtomicU64, AtomicU64), n: (u64, u64)) {
let mut n0 = tuple.0.load(std::sync::atomic::Ordering::Relaxed);
let n0 = tuple.0.load(std::sync::atomic::Ordering::Relaxed);
if let Some(n) = n0.checked_add(n.0) {
tuple.0.store(n, std::sync::atomic::Ordering::Relaxed);
}
let mut n1 = tuple.1.load(std::sync::atomic::Ordering::Relaxed);
let n1 = tuple.1.load(std::sync::atomic::Ordering::Relaxed);
if let Some(n) = n1.checked_add(n.1) {
tuple.1.store(n, std::sync::atomic::Ordering::Relaxed);
}
@@ -211,6 +211,7 @@ impl ThroughputTracker {
self
.raw_data
.iter()
.filter(|v| v.most_recent_cycle == self.cycle.load(std::sync::atomic::Ordering::Relaxed))
.map(|v| {
(
v.bytes.0.saturating_sub(v.prev_bytes.0),