Actually silence output of extra stats

sdr-enthusiasts · Nov 17, 2023 · 711a5c8 · 711a5c8
1 parent 475075f
commit 711a5c8
Showing 1 changed file with 23 additions and 12 deletions.
diff --git a/rust/libraries/acars_connection_manager/src/message_handler.rs b/rust/libraries/acars_connection_manager/src/message_handler.rs
@@ -87,8 +87,12 @@ impl MessageHandlerConfig {
         let stats_total_messages_context: Arc<Mutex<i32>> = Arc::clone(&total_messages_processed);
         let stats_total_messages_since_last_context: Arc<Mutex<i32>> =
             Arc::clone(&total_messages_since_last);
-        let stats_frequency_context: Arc<Mutex<Vec<FrequencyCount>>> =
-            Arc::clone(&all_frequencies_logged);
+        let stats_frequency_context: Option(Arc<Mutex<Vec<FrequencyCount>>>) = if self.stats_verbose
+        {
+            Some(Arc::clone(&all_frequencies_logged))
+        } else {
+            None
+        };
 
         tokio::spawn(async move {
             print_stats(
@@ -314,7 +318,7 @@ impl MessageHandlerConfig {
 pub async fn print_stats(
     total_all_time: Arc<Mutex<i32>>,
     total_since_last: Arc<Mutex<i32>>,
-    frequencies: Arc<Mutex<Vec<FrequencyCount>>>,
+    frequencies: Option(Arc<Mutex<Vec<FrequencyCount>>>),
     stats_every: u64,
     queue_type: &str,
 ) {
@@ -331,15 +335,22 @@ pub async fn print_stats(
 
         // now print the frequencies, and show each as a percentage of the total_all_time
 
-        for freq in frequencies.lock().await.iter_mut() {
-            let percentage: f64 = (freq.count as f64 / total_all_time_locked as f64) * 100.0;
-            output.push_str(
-                format!(
-                    "{} {}: {}/{} ({:.2}%)\n",
-                    queue_type, freq.freq, freq.count, total_all_time_locked, percentage
-                )
-                .as_str(),
-            );
+        match frequencies {
+            None => {}
+            Some(frequencies) => {
+                // now print the frequencies, and show each as a percentage of the total_all_time
+                for freq in frequencies.lock().await.iter_mut() {
+                    let percentage: f64 =
+                        (freq.count as f64 / total_all_time_locked as f64) * 100.0;
+                    output.push_str(
+                        format!(
+                            "{} {}: {}/{} ({:.2}%)\n",
+                            queue_type, freq.freq, freq.count, total_all_time_locked, percentage
+                        )
+                        .as_str(),
+                    );
+                }
+            }
         }
 
         println!("{}", output);