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

Limit RTT tracking to flows that have achieved 1 Mbps or more.

Browse Source
This commit is contained in:
Herbert Wolverson 2024-03-18 10:19:50 -05:00
parent dec1440b31
commit 7b6da8e32e
2 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/kernel_ringbuffer.rs
View File

@ -99,6 +99,9 @@ pub unsafe extern "C" fn flowbee_handle_events(
if let Ok(now) = time_since_boot() { if let Ok(now) = time_since_boot() {
let since_boot = Duration::from(now); let since_boot = Duration::from(now);
if incoming.rtt == 0 {
return 0;
}
let mut lock = FLOW_RTT.lock().unwrap(); let mut lock = FLOW_RTT.lock().unwrap();
if let Some(entry) = lock.get_mut(&incoming.key) { if let Some(entry) = lock.get_mut(&incoming.key) {
entry.push( entry.push(

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

@ -267,16 +267,19 @@ impl ThroughputTracker {
rtts.sort(); rtts.sort();
let median = rtts[rtts.len() / 2]; let median = rtts[rtts.len() / 2];
if let Some(mut tracker) = self.raw_data.get_mut(&local_ip) { if let Some(mut tracker) = self.raw_data.get_mut(&local_ip) {
// Shift left // Only apply if the flow has achieved 1 Mbps or more
for i in 1..60 { if tracker.bytes_per_second.0 + tracker.bytes_per_second.1 > 125000 {
tracker.recent_rtt_data[i] = tracker.recent_rtt_data[i - 1]; // Shift left
} for i in 1..60 {
tracker.recent_rtt_data[0] = *median; tracker.recent_rtt_data[i] = tracker.recent_rtt_data[i - 1];
tracker.last_fresh_rtt_data_cycle = self_cycle; }
if let Some(parents) = &tracker.network_json_parents { tracker.recent_rtt_data[0] = *median;
let net_json = NETWORK_JSON.write().unwrap(); tracker.last_fresh_rtt_data_cycle = self_cycle;
if let Some(rtt) = tracker.median_latency() { if let Some(parents) = &tracker.network_json_parents {
net_json.add_rtt_cycle(parents, rtt); let net_json = NETWORK_JSON.write().unwrap();
if let Some(rtt) = tracker.median_latency() {
net_json.add_rtt_cycle(parents, rtt);
}
} }
} }
} }