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

The lqos_node_manager cache manager uses a persistent BusClient

Browse Source
This commit is contained in:
Herbert Wolverson
2023-01-18 23:39:12 +00:00
parent 2633974839
commit a5fc96abc9
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/rust/lqos_node_manager/src/tracker/cache_manager.rs
View File

@@ -4,7 +4,7 @@
use super::cache::*; use super::cache::*;
use anyhow::Result; use anyhow::Result;
use lqos_bus::{ use lqos_bus::{
BusRequest, BusResponse, IpStats, bus_request, BusRequest, BusResponse, IpStats, BusClient,
}; };
use lqos_config::ConfigShapedDevices; use lqos_config::ConfigShapedDevices;
use rocket::tokio::{ use rocket::tokio::{
@@ -26,7 +26,7 @@ pub async fn update_tracking() {
spawn_blocking(|| { spawn_blocking(|| {
let _ = watch_for_shaped_devices_changing(); let _ = watch_for_shaped_devices_changing();
}); });
let mut bus_client = BusClient::new().await.unwrap();
loop { loop {
//println!("Updating tracking data"); //println!("Updating tracking data");
sys.refresh_cpu(); sys.refresh_cpu();
@@ -42,7 +42,7 @@ pub async fn update_tracking() {
mem_use[0] = sys.used_memory(); mem_use[0] = sys.used_memory();
mem_use[1] = sys.total_memory(); mem_use[1] = sys.total_memory();
} }
let _ = get_data_from_server().await; // Ignoring errors to keep running let _ = get_data_from_server(&mut bus_client).await; // Ignoring errors to keep running
rocket::tokio::time::sleep(Duration::from_secs(1)).await; rocket::tokio::time::sleep(Duration::from_secs(1)).await;
} }
} }
@@ -67,7 +67,7 @@ fn watch_for_shaped_devices_changing() -> Result<()> {
/// Requests data from `lqosd` and stores it in local /// Requests data from `lqosd` and stores it in local
/// caches. /// caches.
async fn get_data_from_server() -> Result<()> { async fn get_data_from_server(bus_client: &mut BusClient) -> Result<()> {
// Send request to lqosd // Send request to lqosd
let requests = vec![ let requests = vec![
BusRequest::GetCurrentThroughput, BusRequest::GetCurrentThroughput,
@@ -76,7 +76,7 @@ async fn get_data_from_server() -> Result<()> {
BusRequest::RttHistogram, BusRequest::RttHistogram,
BusRequest::AllUnknownIps, BusRequest::AllUnknownIps,
]; ];
for r in bus_request(requests).await?.iter() { for r in bus_client.request(requests).await?.iter() {
match r { match r {
BusResponse::CurrentThroughput { BusResponse::CurrentThroughput {
bits_per_second, bits_per_second,