fix(controller): honor the configured ICMP probe interval
Use advanced_settings.tick_interval for Controller schedules so ICMP probe pacing follows the configured measurement cadence.
This commit is contained in:
1 parent
de77e5a281
commit
78bcb7886a
2 files changed
+3
-1
No files matched your search
+2
-1
@@ -50,6 +50,7 @@ impl Controller {
|
||||
active_streams: Arc<RwLock<Vec<MeasurementStream>>>,
|
||||
endpoint_streams: Arc<RwLock<HashMap<SocketAddr, MeasurementStream>>>,
|
||||
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(),
|
||||
}
|
||||
|
||||
@@ -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();
|
||||
|
||||
Reference in new issue
Block a user