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

Change the semantics of the stats gathering thread. If "gather stats"

Browse Source 
is set to false, don't spawn any of the collation tasks at all. Instead,
just setup a null channel recipient to silently drop stats messages.

This should allow for close-to-zero CPU overhead if you are a non-stats
using luddite.
This commit is contained in:
Herbert Wolverson 2023-11-20 08:59:53 -06:00
parent 56286f69ee
commit bba7209caf
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/rust/lts_client/src/collector/collection_manager.rs
View File

@ -22,9 +22,24 @@ pub(crate) static DEVICE_ID_LIST: Lazy<DashSet<String>> = Lazy::new(DashSet::new
///
/// Returns a channel that may be used to notify of data availability.
pub async fn start_long_term_stats() -> Sender<StatsUpdateMessage> {
let (update_tx, update_rx): (Sender<StatsUpdateMessage>, Receiver<StatsUpdateMessage>) = mpsc::channel(10);
let (update_tx, mut update_rx): (Sender<StatsUpdateMessage>, Receiver<StatsUpdateMessage>) = mpsc::channel(10);
let (comm_tx, comm_rx): (Sender<SenderChannelMessage>, Receiver<SenderChannelMessage>) = mpsc::channel(10);
if let Ok(cfg) = lqos_config::EtcLqos::load() {
if let Some(lts) = cfg.long_term_stats {
if !lts.gather_stats {
// Wire up a null recipient to the channel, so it receives messages
// but doesn't do anything with them.
tokio::spawn(async move {
while let Some(_msg) = update_rx.recv().await {
// Do nothing
}
});
return update_tx;
}
}
}
tokio::spawn(lts_manager(update_rx, comm_tx));
tokio::spawn(collation_scheduler(update_tx.clone()));
tokio::spawn(uisp_collection_manager(update_tx.clone()));