intf prio

Author: Arqu

iroh/src/endpoint.rs

@@ -206,6 +206,7 @@ impl Builder {
             insecure_skip_relay_cert_verify: self.insecure_skip_relay_cert_verify,
             #[cfg(any(test, feature = "test-utils"))]
             path_selection: self.path_selection,
+            interface_priority: Default::default(),
             metrics,
         };
 

iroh/src/magicsock.rs

@@ -77,6 +77,7 @@ use crate::{
     net_report::{self, IfStateDetails, IpMappedAddresses, Report},
 };
 
+mod interface_priority;
 mod metrics;
 mod node_map;
 
@@ -85,6 +86,7 @@ pub(crate) mod transports;
 pub use node_map::Source;
 
 pub use self::{
+    interface_priority::InterfacePriority,
     metrics::Metrics,
     node_map::{ConnectionType, ControlMsg, DirectAddrInfo, RemoteInfo},
 };
@@ -158,6 +160,12 @@ pub(crate) struct Options {
     #[cfg(any(test, feature = "test-utils"))]
     pub(crate) path_selection: PathSelection,
 
+    /// Interface-based path prioritization configuration.
+    ///
+    /// Allows preferring certain network interfaces over others when multiple paths exist.
+    /// Useful for scenarios like preferring Ethernet over Wi-Fi.
+    pub(crate) interface_priority: InterfacePriority,
+
     pub(crate) metrics: EndpointMetrics,
 }
 
@@ -688,7 +696,7 @@ impl MagicSock {
                         // UDP
 
                         // Update the NodeMap and remap RecvMeta to the NodeIdMappedAddr.
-                        match self.node_map.receive_udp(*addr) {
+                        match self.node_map.receive_udp(*addr, quinn_meta.dst_ip) {
                             None => {
                                 // Check if this address is mapped to an IpMappedAddr
                                 if let Some(ip_mapped_addr) =
@@ -1367,9 +1375,27 @@ impl Handle {
             insecure_skip_relay_cert_verify,
             #[cfg(any(test, feature = "test-utils"))]
             path_selection,
+            interface_priority,
             metrics,
         } = opts;
 
+        // Load interface priority from environment if not explicitly set
+        let interface_priority = if interface_priority.is_empty() {
+            match InterfacePriority::from_env() {
+                Ok(Some(priority)) => {
+                    info!("Loaded interface priority from IROH_INTERFACE_PRIORITY");
+                    priority
+                }
+                Ok(None) => InterfacePriority::default(),
+                Err(e) => {
+                    warn!("Failed to parse IROH_INTERFACE_PRIORITY: {}", e);
+                    InterfacePriority::default()
+                }
+            }
+        } else {
+            interface_priority
+        };
+
         let addr_v4 = addr_v4.unwrap_or_else(|| SocketAddrV4::new(Ipv4Addr::UNSPECIFIED, 0));
 
         #[cfg(not(wasm_browser))]
@@ -1383,14 +1409,7 @@ impl Handle {
         let ipv6_reported = false;
 
         // load the node data
-        let node_map = node_map.unwrap_or_default();
-        let node_map = NodeMap::load_from_vec(
-            node_map,
-            #[cfg(any(test, feature = "test-utils"))]
-            path_selection,
-            ipv6_reported,
-            &metrics.magicsock,
-        );
+        let node_addrs = node_map.unwrap_or_default();
 
         let my_relay = Watchable::new(None);
         let ipv6_reported = Arc::new(AtomicBool::new(ipv6_reported));
@@ -1417,6 +1436,35 @@ impl Handle {
         #[cfg(wasm_browser)]
         let transports = Transports::new(relay_transports);
 
+        // Create network monitor early, so we can build the interface map
+        let network_monitor = netmon::Monitor::new()
+            .await
+            .context(CreateNetmonMonitorSnafu)?;
+
+        // Build interface map from bind addresses and network state
+        #[cfg(not(wasm_browser))]
+        let ip_to_interface = {
+            let netmon_state = network_monitor.interface_state().get();
+            let bind_addrs = transports.ip_bind_addrs();
+            interface_priority::build_interface_map(&bind_addrs, &netmon_state)
+        };
+        #[cfg(wasm_browser)]
+        let ip_to_interface = Default::default();
+
+        // Create NodeMap with the interface map
+        let node_map = NodeMap::load_from_vec(
+            node_addrs,
+            #[cfg(any(test, feature = "test-utils"))]
+            path_selection,
+            interface_priority.clone(),
+            ip_to_interface,
+            #[cfg(not(wasm_browser))]
+            ipv6,
+            #[cfg(wasm_browser)]
+            false,
+            &metrics.magicsock,
+        );
+
         let (disco, disco_receiver) = DiscoState::new(secret_encryption_key);
 
         let msock = Arc::new(MagicSock {
@@ -1425,7 +1473,7 @@ impl Handle {
             closed: AtomicBool::new(false),
             disco,
             actor_sender: actor_sender.clone(),
-            ipv6_reported,
+            ipv6_reported: ipv6_reported.clone(),
             node_map,
             ip_mapped_addrs: ip_mapped_addrs.clone(),
             discovery,
@@ -1467,10 +1515,6 @@ impl Handle {
         )
         .context(CreateQuinnEndpointSnafu)?;
 
-        let network_monitor = netmon::Monitor::new()
-            .await
-            .context(CreateNetmonMonitorSnafu)?;
-
         let qad_endpoint = endpoint.clone();
 
         #[cfg(any(test, feature = "test-utils"))]
@@ -1516,6 +1560,7 @@ impl Handle {
         );
 
         let netmon_watcher = network_monitor.interface_state();
+
         let actor = Actor {
             msg_receiver: actor_receiver,
             msock: msock.clone(),
@@ -2589,6 +2634,7 @@ mod tests {
                 insecure_skip_relay_cert_verify: false,
                 #[cfg(any(test, feature = "test-utils"))]
                 path_selection: PathSelection::default(),
+                interface_priority: Default::default(),
                 discovery_user_data: None,
                 metrics: Default::default(),
             }
@@ -3121,6 +3167,7 @@ mod tests {
             server_config,
             insecure_skip_relay_cert_verify: false,
             path_selection: PathSelection::default(),
+            interface_priority: Default::default(),
             metrics: Default::default(),
         };
         let msock = MagicSock::spawn(opts).await?;