Apply negotiated Reliability to Link config

eclipse-zenoh · Sep 5, 2024 · d5e59e2 · d5e59e2
1 parent 979796d
commit d5e59e2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/io/zenoh-transport/src/unicast/establishment/accept.rs b/io/zenoh-transport/src/unicast/establishment/accept.rs
@@ -786,7 +786,11 @@ pub(crate) async fn accept_link(
             is_compression: state.link.ext_compression.is_compression(),
         },
         priorities: state.transport.ext_qos.priorities(),
-        reliability: Reliability::from(link.link.is_reliable()),
+        reliability: state
+            .transport
+            .ext_qos
+            .reliability()
+            .unwrap_or_else(|| Reliability::from(link.link.is_reliable())),
     };
     let a_link = link.reconfigure(a_config);
     let s_link = format!("{:?}", a_link);

diff --git a/io/zenoh-transport/src/unicast/establishment/open.rs b/io/zenoh-transport/src/unicast/establishment/open.rs
@@ -671,7 +671,11 @@ pub(crate) async fn open_link(
             is_compression: state.link.ext_compression.is_compression(),
         },
         priorities: state.transport.ext_qos.priorities(),
-        reliability: Reliability::from(link.link.is_reliable()),
+        reliability: state
+            .transport
+            .ext_qos
+            .reliability()
+            .unwrap_or_else(|| Reliability::from(link.link.is_reliable())),
     };
     let o_link = link.reconfigure(o_config);
     let s_link = format!("{:?}", o_link);