Add endpoint_poll_interval_ms to configure the network change detection poll interval

Author: Hugo Laloge

DEFAULT_CONFIG.json5

@@ -113,6 +113,9 @@
       /// increase factor for the next timeout until next try
       period_increase_factor: 2,
     },
+    /// Interval in millisecond to check if the listening endpoints changed (i.e. when listening on 0.0.0.0 or [::]).
+    /// Also update the multicast scouting listening interfaces. Use -1 to disable.
+    endpoint_poll_interval_ms: 10000,
   },
   /// Configure the session open behavior.
   open: {

commons/zenoh-config/src/defaults.rs

@@ -55,6 +55,8 @@ pub mod listen {
 
     pub const timeout_ms: ModeDependentValue<i64> = ModeDependentValue::Unique(0);
     pub const exit_on_failure: ModeDependentValue<bool> = ModeDependentValue::Unique(true);
+
+    pub const endpoint_poll_interval_ms: Option<i64> = Some(10_000);
 }
 
 #[allow(non_upper_case_globals)]
@@ -180,6 +182,7 @@ impl Default for ListenConfig {
                 peer: Some(vec![]),
                 client: None,
             }),
+            endpoint_poll_interval_ms: Some(10_000),
             exit_on_failure: None,
             retry: None,
         }

commons/zenoh-config/src/lib.rs

@@ -384,6 +384,9 @@ validated_struct::validator! {
             /// if connection timeout exceed, exit from application
             pub exit_on_failure: Option<ModeDependentValue<bool>>,
             pub retry: Option<connection_retry::ConnectionRetryModeDependentConf>,
+            /// Interval in millisecond to check if the listening endpoints changed (e.g. when listening on 0.0.0.0).
+            /// Also update the multicast scouting listening interfaces. Use -1 to disable.
+            pub endpoint_poll_interval_ms: Option<i64>,
         },
         /// Configure the session open behavior.
         pub open: #[derive(Default)]

zenoh/src/net/runtime/mod.rs

@@ -380,12 +380,21 @@ impl Runtime {
     }
 
     async fn monitor_available_addrs(&self) {
-        let token = self.get_cancellation_token();
-        let update_interval = Duration::from_secs(10);
-        loop {
-            tokio::select! {
-                _ = tokio::time::sleep(update_interval) => self.update_available_addrs().await,
-                _ = token.cancelled() => return,
+        let update_interval_ms = self
+            .config()
+            .lock()
+            .0
+            .listen
+            .endpoint_poll_interval_ms()
+            .unwrap_or(10_000);
+        if update_interval_ms > 0 {
+            let update_interval = Duration::from_millis(update_interval_ms as u64);
+            let token = self.get_cancellation_token();
+            loop {
+                tokio::select! {
+                    _ = tokio::time::sleep(update_interval) => self.update_available_addrs().await,
+                    _ = token.cancelled() => return,
+                }
             }
         }
     }