diff --git a/src/main.rs b/src/main.rs index 3a8b1d2..1e8c12f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -139,7 +139,7 @@ fn main() -> anyhow::Result<()> { let reflector_peers_lock_clone = reflector_peers_lock.clone(); let sender_handle = thread::Builder::new().name("sender".to_string()).spawn( move || -> anyhow::Result<()> { - pinger_sender.send(id, config.measurement_type, reflector_peers_lock_clone) + pinger_sender.send(id, config.measurement_type, reflector_peers_lock_clone, config.tick_interval) }, )?; diff --git a/src/pinger.rs b/src/pinger.rs index b7ead77..5d425aa 100644 --- a/src/pinger.rs +++ b/src/pinger.rs @@ -91,11 +91,12 @@ pub trait PingSender { id: u16, type_: MeasurementType, reflectors_lock: Arc>>, + tick_interval: f64, ) -> anyhow::Result<()> { let mut socket = open_socket(type_)?; let mut seq: u16 = 0; - let tick_duration_ms: u16 = 500; + let tick_duration_ms: u16 = (tick_interval * 1000.0) as u16; loop { let reflectors_unlocked = reflectors_lock.read().unwrap();