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

Chore: Add some info and debug level messages to indicate that the queue monitors are still alive/making changes.

Browse Source
This commit is contained in:
Herbert Wolverson 2025-01-11 11:42:35 -06:00
parent 1d2a0f36f4
commit 106fe2a5ed
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/rust/lqos_queue_tracker/src/tracking/mod.rs
View File

@ -5,7 +5,7 @@ use crate::{
circuit_to_queue::CIRCUIT_TO_QUEUE, interval::QUEUE_MONITOR_INTERVAL, circuit_to_queue::CIRCUIT_TO_QUEUE, interval::QUEUE_MONITOR_INTERVAL,
queue_store::QueueStore, tracking::reader::read_named_queue_from_interface, queue_store::QueueStore, tracking::reader::read_named_queue_from_interface,
}; };
use tracing::{debug, warn}; use tracing::{debug, info, warn};
use lqos_utils::fdtimer::periodic; use lqos_utils::fdtimer::periodic;
mod reader; mod reader;
mod watched_queues; mod watched_queues;
@ -237,6 +237,7 @@ pub fn spawn_queue_monitor() -> anyhow::Result<()> {
track_queues(); track_queues();
unlock_tc(); unlock_tc();
did_something = true; did_something = true;
debug!("Queue reader completed.");
} }
// Wait for the timer to expire // Wait for the timer to expire
@ -244,6 +245,7 @@ pub fn spawn_queue_monitor() -> anyhow::Result<()> {
if missed_ticks > 0 && did_something { if missed_ticks > 0 && did_something {
// If we missed a tick, adjust the interval // If we missed a tick, adjust the interval
interval_ms = (missed_ticks + 1) * QUEUE_MONITOR_INTERVAL.load(std::sync::atomic::Ordering::Relaxed); interval_ms = (missed_ticks + 1) * QUEUE_MONITOR_INTERVAL.load(std::sync::atomic::Ordering::Relaxed);
info!("Queue monitor interval adjusted to {interval_ms} ms.");
tfd.set_state(TimerState::Periodic{ tfd.set_state(TimerState::Periodic{
current: Duration::new(interval_ms / 1000, 0), current: Duration::new(interval_ms / 1000, 0),
interval: Duration::new(interval_ms / 1000, 0)}, SetTimeFlags::Default interval: Duration::new(interval_ms / 1000, 0)}, SetTimeFlags::Default
@ -269,6 +271,7 @@ pub fn spawn_queue_monitor() -> anyhow::Result<()> {
if lock_tc() { if lock_tc() {
all_queue_reader(); all_queue_reader();
unlock_tc(); unlock_tc();
debug!("All queue reader completed.");
did_something = true; did_something = true;
} }
@ -277,6 +280,7 @@ pub fn spawn_queue_monitor() -> anyhow::Result<()> {
if missed_ticks > 0 && did_something { if missed_ticks > 0 && did_something {
// If we missed a tick, adjust the interval // If we missed a tick, adjust the interval
interval_ms = (missed_ticks + 2) * 2000; interval_ms = (missed_ticks + 2) * 2000;
info!("All queue monitor interval adjusted to {interval_ms} ms.");
tfd.set_state(TimerState::Periodic{ tfd.set_state(TimerState::Periodic{
current: Duration::new(interval_ms / 1000, 0), current: Duration::new(interval_ms / 1000, 0),
interval: Duration::new(interval_ms / 1000, 0)}, SetTimeFlags::Default interval: Duration::new(interval_ms / 1000, 0)}, SetTimeFlags::Default