IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2024-11-22 08:16:25 -06:00
Code Issues Packages Projects Releases Wiki Activity

ISSUE #511

Browse Source 
Replace instant::now/subtraction with a Tokio scheduled ticker, in "skip" mode to handle time overruns.
This commit is contained in:
Herbert Wolverson 2024-07-09 09:27:59 -05:00
parent fbefdf813e
commit 6b94e67faa
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/rust/lqosd/src/throughput_tracker/mod.rs
View File

@ -73,6 +73,8 @@ async fn throughput_task(
false
};
let mut ticker = tokio::time::interval(Duration::from_millis(interval_ms));
ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
loop {
let start = Instant::now();
@ -102,13 +104,7 @@ async fn throughput_task(
}
tokio::spawn(submit_throughput_stats(long_term_stats_tx.clone()));
let elapsed = start.elapsed();
if elapsed.as_secs_f32() < 1.0 {
let sleep_duration = Duration::from_millis(interval_ms) - start.elapsed();
tokio::time::sleep(sleep_duration).await;
} else {
log::error!("Throughput monitor thread is running behind. It took {elapsed} to poll the network.", elapsed=elapsed.as_secs_f32());
}
ticker.tick().await;
}
}