perf(baseliner): bound the reselection channel to prevent memory buildup

Change the reselection channel from unbounded to a size of 1 and use non-blocking sends to avoid unnecessary queuing of reselection triggers.

src/baseliner.rs

@@ -122,9 +122,9 @@ impl Baseliner {
                     reflector: Some(time_data.reflector),
                     tags: &[],
                 });
-                // If reselection is disabled this would trigger an error
-                // so just ignore the result
-                let _ = self.reselect_trigger.send(true);
+                // The reselect channel is bounded to 1,
+                // so we use try_send to avoid blocking if the channel is full
+                let _ = self.reselect_trigger.try_send(true);
             } else {
                 owd_baseline.down_ewma = owd_baseline.down_ewma * slow_factor
                     + (1.0 - slow_factor) * time_data.down_time;

src/main.rs

@@ -265,7 +265,7 @@ fn run(config: Config) -> anyhow::Result<()> {
 
     let (baseliner_stats_tx, baseliner_stats_rx) = flume::unbounded();
     let (error_tx, error_rx) = flume::unbounded::<anyhow::Error>();
-    let (reselect_tx, reselect_rx) = flume::unbounded();
+    let (reselect_tx, reselect_rx) = flume::bounded(1);
 
     let dropped = Arc::new(AtomicU32::new(0));
 

src/ratecontroller.rs

@@ -308,7 +308,7 @@ impl<S: InterfaceStatsProvider, T: TrafficControlBackend> Ratecontroller<S, T> {
                 state_dl.deltas.len(),
                 state_ul.deltas.len()
             );
-            let _ = self.reselect_trigger.send(true);
+            let _ = self.reselect_trigger.try_send(true);
         }
 
         Ok(())