diff --git a/src/controller.rs b/src/controller.rs index 258c414..6a131bf 100644 --- a/src/controller.rs +++ b/src/controller.rs @@ -50,6 +50,7 @@ impl Controller { active_streams: Arc>>, endpoint_streams: Arc>>, source: MeasurementSource, + period: Duration, ) -> Self { Self { reflector_rx, @@ -60,7 +61,7 @@ impl Controller { active_streams, endpoint_streams, source, - period: Duration::from_millis(500), + period, next_stream_id: 0, stream_ids: HashMap::new(), } diff --git a/src/main.rs b/src/main.rs index cef3c66..02074e1 100644 --- a/src/main.rs +++ b/src/main.rs @@ -332,6 +332,7 @@ fn run(settings: &Settings) -> anyhow::Result<()> { Arc::clone(&active_streams), Arc::clone(&endpoint_streams), source, + Duration::from_secs_f64(settings.advanced_settings.tick_interval), ); let icmp_engine = { let _guard = rt.enter();