From b29831a5aeb590ade6a00b46802387fae061dc3a Mon Sep 17 00:00:00 2001 From: Herbert Wolverson Date: Tue, 2 Jul 2024 09:19:02 -0500 Subject: [PATCH] Remove now unused functions. --- src/rust/Cargo.lock | 1 + .../src/throughput_tracker/tracking_data.rs | 19 ------------------- 2 files changed, 1 insertion(+), 19 deletions(-) diff --git a/src/rust/Cargo.lock b/src/rust/Cargo.lock index c72b2a2b..ce2aa956 100644 --- a/src/rust/Cargo.lock +++ b/src/rust/Cargo.lock @@ -1869,6 +1869,7 @@ dependencies = [ "ip_network", "ip_network_table", "log", + "lqos_utils", "once_cell", "pyo3", "serde", diff --git a/src/rust/lqosd/src/throughput_tracker/tracking_data.rs b/src/rust/lqosd/src/throughput_tracker/tracking_data.rs index df940916..4257af65 100644 --- a/src/rust/lqosd/src/throughput_tracker/tracking_data.rs +++ b/src/rust/lqosd/src/throughput_tracker/tracking_data.rs @@ -331,25 +331,6 @@ impl ThroughputTracker { } } - #[inline(always)] - fn set_atomic_tuple_to_zero(tuple: &(AtomicU64, AtomicU64)) { - tuple.0.store(0, std::sync::atomic::Ordering::Relaxed); - tuple.1.store(0, std::sync::atomic::Ordering::Relaxed); - } - - #[inline(always)] - fn add_atomic_tuple(tuple: &(AtomicU64, AtomicU64), n: (u64, u64)) { - 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 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); - } - } - pub(crate) fn update_totals(&self) { let current_cycle = self.cycle.load(std::sync::atomic::Ordering::Relaxed); self.bytes_per_second.set_to_zero();