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

Set 3 different tick cadences (1, 2 and 5 seconds) to reduce the weight of the heavier operations (such as browsing the whole tree), and avoid updating data that isn't updated that frequently (such as Cake stats).

Browse Source
This commit is contained in:
Herbert Wolverson 2024-07-09 11:05:52 -05:00
parent 35d0903224
commit 7cf9fba83e
1 changed files with 57 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
src/rust/lqosd/src/node_manager/ws/ticker.rs
View File

@ -1,3 +1,11 @@
use std::sync::Arc;
use std::time::Duration;
use tokio::join;
use tokio::time::timeout;
use crate::node_manager::ws::publish_subscribe::PubSub;
mod cadence;
mod throughput;
mod rtt_histogram;
@ -11,36 +19,61 @@ mod tree_summary;
mod queue_stats_total;
mod network_tree;
use std::sync::Arc;
use std::time::Duration;
use tokio::time::timeout;
use crate::node_manager::ws::publish_subscribe::PubSub;
/// Runs a periodic tick to feed data to the node manager.
pub(super) async fn channel_ticker(channels: Arc<PubSub>) {
join!(
one_second_cadence(channels.clone()),
two_second_cadence(channels.clone()),
five_second_cadence(channels.clone()),
);
}
async fn one_second_cadence(channels: Arc<PubSub>) {
let mut interval = tokio::time::interval(tokio::time::Duration::from_secs(1));
let timeout_time = Duration::from_secs_f32(0.9);
interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
loop {
interval.tick().await; // Once per second
let _ = tokio::join!(
timeout(Duration::from_secs_f32(0.9), cadence::cadence(channels.clone())),
timeout(Duration::from_secs_f32(0.9), throughput::throughput(channels.clone())),
timeout(Duration::from_secs_f32(0.9), rtt_histogram::rtt_histo(channels.clone())),
timeout(Duration::from_secs_f32(0.9), flow_counter::flow_count(channels.clone())),
timeout(Duration::from_secs_f32(0.9), top_10::top_10_downloaders(channels.clone())),
timeout(Duration::from_secs_f32(0.9), top_10::worst_10_downloaders(channels.clone())),
timeout(Duration::from_secs_f32(0.9), top_10::worst_10_retransmit(channels.clone())),
timeout(Duration::from_secs_f32(0.9), top_flows::top_flows_bytes(channels.clone())),
timeout(Duration::from_secs_f32(0.9), top_flows::top_flows_rate(channels.clone())),
timeout(Duration::from_secs_f32(0.9), flow_endpoints::endpoints_by_country(channels.clone())),
timeout(Duration::from_secs_f32(0.9), flow_endpoints::ether_protocols(channels.clone())),
timeout(Duration::from_secs_f32(0.9), flow_endpoints::ip_protocols(channels.clone())),
timeout(Duration::from_secs_f32(0.9), system_info::cpu_info(channels.clone())),
timeout(Duration::from_secs_f32(0.9), system_info::ram_info(channels.clone())),
timeout(Duration::from_secs_f32(0.9), tree_summary::tree_summary(channels.clone())),
timeout(Duration::from_secs_f32(0.9), queue_stats_total::queue_stats_totals(channels.clone())),
timeout(Duration::from_secs_f32(0.9), network_tree::network_tree(channels.clone())),
let _ = join!(
timeout(timeout_time, cadence::cadence(channels.clone())),
timeout(timeout_time, throughput::throughput(channels.clone())),
timeout(timeout_time, rtt_histogram::rtt_histo(channels.clone())),
timeout(timeout_time, flow_counter::flow_count(channels.clone())),
timeout(timeout_time, top_10::top_10_downloaders(channels.clone())),
timeout(timeout_time, top_10::worst_10_downloaders(channels.clone())),
timeout(timeout_time, top_10::worst_10_retransmit(channels.clone())),
timeout(timeout_time, top_flows::top_flows_bytes(channels.clone())),
timeout(timeout_time, top_flows::top_flows_rate(channels.clone())),
timeout(timeout_time, flow_endpoints::endpoints_by_country(channels.clone())),
timeout(timeout_time, flow_endpoints::ether_protocols(channels.clone())),
timeout(timeout_time, flow_endpoints::ip_protocols(channels.clone())),
);
}
}
async fn two_second_cadence(channels: Arc<PubSub>) {
let mut interval = tokio::time::interval(tokio::time::Duration::from_secs(2));
let timeout_time = Duration::from_secs_f32(1.9);
interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
loop {
interval.tick().await; // Once per second
let _ = join!(
timeout(timeout_time, tree_summary::tree_summary(channels.clone())),
timeout(timeout_time, queue_stats_total::queue_stats_totals(channels.clone())),
);
}
}
async fn five_second_cadence(channels: Arc<PubSub>) {
let mut interval = tokio::time::interval(tokio::time::Duration::from_secs(5));
let timeout_time = Duration::from_secs_f32(4.9);
interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
loop {
interval.tick().await; // Once per second
let _ = join!(
timeout(timeout_time, network_tree::network_tree(channels.clone())),
timeout(timeout_time, system_info::cpu_info(channels.clone())),
timeout(timeout_time, system_info::ram_info(channels.clone())),
);
}
}