IntenseWebs/LibreQoS
3
0 Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2026-10-25 22:30:05 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix unknown IP refresh after dyn expiry

Browse Source 
- Emit unknown observations for existing entries when still unresolved\n- Downgrade watched queue miss to debug
This commit is contained in:
Herbert Wolverson committed 2026-04-13 11:07:25 -05:00
1 parent be57228084
commit 6e4bb732ed
2 files changed
+12 -4
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/rust/lqos_queue_tracker/src/tracking/watched_queues.rs
+2 -2
View File
@@ -4,7 +4,7 @@ use lqos_bus::TcHandle;
use lqos_sys::num_possible_cpus;
use lqos_utils::unix_time::unix_now;
use once_cell::sync::Lazy;
use tracing::{info, warn};
use tracing::{debug, info, warn};
pub(crate) static WATCHED_QUEUES: Lazy<DashMap<String, WatchedQueue>> = Lazy::new(DashMap::new);
@@ -74,7 +74,7 @@ pub fn add_watched_queue(circuit_id: &str) {
WATCHED_QUEUES.insert(circuit_id.to_string(), new_watch);
//info!("Added {circuit_id} to watched queues. Now watching {} queues.", WATCHED_QUEUES.len());
} else {
warn!("No circuit ID of {circuit_id}");
debug!("Circuit queue not found for watch request: {circuit_id}");
}
} else {
warn!("Unable to access watched queue list. Try again later.");
src/rust/lqosd/src/throughput_tracker/tracking_data.rs
+10 -2
View File
@@ -586,6 +586,15 @@ impl ThroughputTracker {
entry.device_hash,
entry.circuit_hash,
);
if shaped_device.is_none()
&& observations.len() < MAX_UNKNOWN_OBSERVATIONS_PER_TICK
{
observations.push(lqos_network_devices::CircuitObservation {
ip: *xdp_ip,
device_hash: entry.device_hash,
circuit_hash: entry.circuit_hash,
});
}
if let Some(parents) = &entry.network_json_parents {
net_json_calc.add_throughput_cycle(
@@ -661,8 +670,7 @@ impl ThroughputTracker {
device_hash,
circuit_hash,
);
if shaped_device.is_none() && observations.len() < MAX_UNKNOWN_OBSERVATIONS_PER_TICK
{
if shaped_device.is_none() && observations.len() < MAX_UNKNOWN_OBSERVATIONS_PER_TICK {
observations.push(lqos_network_devices::CircuitObservation {
ip: *xdp_ip,
device_hash,