feat: Add TTL connection param to multicast

Author: Julian Monticelli

io/zenoh-links/zenoh-link-udp/src/lib.rs

@@ -107,6 +107,7 @@ impl LocatorInspector for UdpLocatorInspector {
 pub mod config {
     pub const UDP_MULTICAST_IFACE: &str = "iface";
     pub const UDP_MULTICAST_JOIN: &str = "join";
+    pub const UDP_MULTICAST_TTL: &str = "ttl";
 }
 
 pub async fn get_udp_addrs(address: Address<'_>) -> ZResult<impl Iterator<Item = SocketAddr>> {

io/zenoh-links/zenoh-link-udp/src/multicast.rs

@@ -272,7 +272,7 @@ impl LinkManagerMulticastUdp {
                 .map_err(|e| zerror!("{}: {}", mcast_addr, e))?;
         }
 
-        // Bind the socket: let's bing to the unspecified address so we can join and read
+        // Bind the socket: let's bind to the unspecified address so we can join and read
         // from multiple multicast groups.
         let bind_mcast_addr = match mcast_addr.ip() {
             IpAddr::V4(_) => IpAddr::V4(Ipv4Addr::UNSPECIFIED),
@@ -321,6 +321,31 @@ impl LinkManagerMulticastUdp {
         // https://docs.rs/tokio/latest/tokio/net/struct.UdpSocket.html#notes
         mcast_sock.set_nonblocking(true)?;
 
+        // If TTL is specified, add set the socket's TTL
+        if let Some(ttl_str) = config.get(UDP_MULTICAST_TTL) {
+            let ttl = match ttl_str.parse::<u32>() {
+                Ok(ttl)  => ttl,
+                Err(e) => bail!("Can not parse TTL '{}' to a u32: {}", ttl_str, e)
+            };
+
+            match &local_addr {
+                IpAddr::V4(_) => {
+                    ucast_sock
+                        .set_multicast_ttl_v4(ttl)
+                        .map_err(|e| zerror!("{}: {}", mcast_addr, e))?;
+                }
+                IpAddr::V6(_) => match zenoh_util::net::get_index_of_interface(local_addr) {
+                    Ok(_) => {
+                        tracing::warn!("set_multicast_ttl_v4 on v6 socket (may have no effect): {}", mcast_addr);
+                        ucast_sock
+                            .set_multicast_ttl_v4(ttl)
+                            .map_err(|e| zerror!("{}: {}", mcast_addr, e))?
+                    },
+                    Err(e) => bail!("{}: {}", mcast_addr, e),
+                },
+            }
+        }
+
         // Build the tokio multicast UdpSocket
         let mcast_sock = UdpSocket::from_std(mcast_sock.into())?;