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

Actually prevent Insight from sending if it hasn't been enabled.

Browse Source
This commit is contained in:
Herbert Wolverson
2024-12-17 09:11:18 -06:00
parent 8329a5e404
commit 15e16fa981
1 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/rust/lqosd/src/lts2_sys/lts2_client/ingestor/message_queue.rs
View File

@@ -102,6 +102,12 @@ impl MessageQueue {
} }
pub(crate) fn send(&mut self, keys: Arc<KeyStore>) -> Result<()> { pub(crate) fn send(&mut self, keys: Arc<KeyStore>) -> Result<()> {
let config = load_config()?;
if config.long_term_stats.use_insight.unwrap_or(false) {
self.clear();
return Ok(());
}
use std::net::ToSocketAddrs; use std::net::ToSocketAddrs;
let remote_host = get_remote_host(); let remote_host = get_remote_host();
let target = &format!("{}:9121", remote_host); let target = &format!("{}:9121", remote_host);
@@ -166,4 +172,18 @@ impl MessageQueue {
println!("Finished sending messages to {}", remote_host); println!("Finished sending messages to {}", remote_host);
Ok(()) Ok(())
} }
pub(crate) fn clear(&mut self) {
self.general_queue.clear();
self.circuit_throughput.clear();
self.circuit_retransmits.clear();
self.circuit_rtt.clear();
self.circuit_cake_drops.clear();
self.circuit_cake_marks.clear();
self.site_throughput.clear();
self.site_retransmits.clear();
self.site_cake_drops.clear();
self.site_cake_marks.clear();
self.site_rtt.clear();
}
} }