Compare locator Reliability even if not set

eclipse-zenoh · Sep 13, 2024 · 4699952 · 4699952
1 parent be26fe3
commit 4699952
Showing 1 changed file with 6 additions and 10 deletions.
diff --git a/zenoh/src/net/runtime/orchestrator.rs b/zenoh/src/net/runtime/orchestrator.rs
@@ -34,10 +34,7 @@ use zenoh_config::{
 };
 use zenoh_link::{Locator, LocatorInspector};
 use zenoh_protocol::{
-    core::{
-        whatami::WhatAmIMatcher, EndPoint, Metadata, PriorityRange, Reliability, WhatAmI,
-        ZenohIdProto,
-    },
+    core::{whatami::WhatAmIMatcher, EndPoint, Metadata, PriorityRange, WhatAmI, ZenohIdProto},
     scouting::{HelloProto, Scout, ScoutingBody, ScoutingMessage},
 };
 use zenoh_result::{bail, zerror, ZResult};
@@ -953,14 +950,13 @@ impl Runtime {
                 .metadata()
                 .get(Metadata::PRIORITIES)
                 .and_then(|p| PriorityRange::from_str(p).ok());
-            let reliability = locator
-                .metadata()
-                .get(Metadata::RELIABILITY)
-                .and_then(|r| Reliability::from_str(r).ok());
+            let reliability = inspector.is_reliable(locator).ok();
             if !transport.as_ref().is_some_and(|t| {
                 t.get_links().is_ok_and(|ls| {
-                    ls.iter()
-                        .any(|l| l.priorities == priorities && l.reliability == reliability)
+                    ls.iter().any(|l| {
+                        l.priorities == priorities
+                            && inspector.is_reliable(&l.dst).ok() == reliability
+                    })
                 })
             }) {
                 if is_multicast {