Send locators updates to peers&routers

When updating the locators after a network change, send the new
locators to the routers and the peers if in linkstate mode.

Author: Hugo Laloge

zenoh/src/net/protocol/network.rs

@@ -987,6 +987,21 @@ impl Network {
         }
     }
 
+    pub(crate) fn update_locators(&mut self) {
+        self.graph[self.idx].sn += 1;
+        self.send_on_links(
+            vec![(
+                self.idx,
+                Details {
+                    zid: false,
+                    locators: true,
+                    links: self.full_linkstate || self.router_peers_failover_brokering,
+                },
+            )],
+            |link| link.transport.get_whatami().unwrap_or(WhatAmI::Peer) == WhatAmI::Router,
+        );
+    }
+
     fn remove_detached_nodes(&mut self) -> Vec<(NodeIndex, Node)> {
         let mut dfs_stack = vec![self.idx];
         let mut visit_map = self.graph.visit_map();

zenoh/src/net/routing/hat/linkstate_peer/mod.rs

@@ -277,6 +277,12 @@ impl HatBaseTrait for HatCode {
         Ok(())
     }
 
+    fn update_self_locators(&self, tables: &mut Tables) {
+        if let Some(net) = hat_mut!(tables).linkstatepeers_net.as_mut() {
+            net.update_locators();
+        }
+    }
+
     fn close_face(
         &self,
         tables: &TablesLock,

zenoh/src/net/routing/hat/mod.rs

@@ -105,6 +105,8 @@ pub(crate) trait HatBaseTrait {
         send_declare: &mut SendDeclare,
     ) -> ZResult<()>;
 
+    fn update_self_locators(&self, _tables: &mut Tables) {}
+
     fn handle_oam(
         &self,
         tables: &mut Tables,

zenoh/src/net/routing/hat/p2p_peer/gossip.rs

@@ -605,4 +605,19 @@ impl Network {
         }
         vec![]
     }
+
+    pub(super) fn update_locators(&mut self) {
+        self.graph[self.idx].sn += 1;
+        self.send_on_links(
+            vec![(
+                self.idx,
+                Details {
+                    zid: false,
+                    locators: true,
+                    links: self.router_peers_failover_brokering,
+                },
+            )],
+            |link| link.transport.get_whatami().unwrap_or(WhatAmI::Peer) == WhatAmI::Router,
+        );
+    }
 }

zenoh/src/net/routing/hat/p2p_peer/mod.rs

@@ -219,6 +219,12 @@ impl HatBaseTrait for HatCode {
         Ok(())
     }
 
+    fn update_self_locators(&self, tables: &mut Tables) {
+        if let Some(net) = hat_mut!(tables).gossip.as_mut() {
+            net.update_locators();
+        }
+    }
+
     fn close_face(
         &self,
         tables: &TablesLock,

zenoh/src/net/routing/hat/router/mod.rs

@@ -460,6 +460,15 @@ impl HatBaseTrait for HatCode {
         Ok(())
     }
 
+    fn update_self_locators(&self, tables: &mut Tables) {
+        if let Some(net) = hat_mut!(tables).routers_net.as_mut() {
+            net.update_locators();
+        }
+        if let Some(net) = hat_mut!(tables).linkstatepeers_net.as_mut() {
+            net.update_locators();
+        }
+    }
+
     fn close_face(
         &self,
         tables: &TablesLock,

zenoh/src/net/runtime/mod.rs

@@ -449,7 +449,13 @@ impl Runtime {
 
             update_iface_cache();
             self.update_locators();
-            // TODO Transmit new locators to peers?
+
+            {
+                let tables_lock = &self.state.router.tables;
+                let _ctrl_lock = zlock!(tables_lock.ctrl_lock);
+                let mut tables = zwrite!(tables_lock.tables);
+                tables_lock.hat_code.update_self_locators(&mut tables);
+            }
 
             let scouting = self.state.scouting.lock().await;
             if let Some(scouting) = scouting.as_ref() {