Add reliability to UDP link via unsecure QUIC

Cargo.toml

@@ -137,6 +137,7 @@ pnet_datalink = "0.35.0"
 proc-macro2 = "1.0.101"
 prometheus-client = "0.24.0"
 quinn = "0.11.5"
+quinn-proto = "0.11.5"
 quote = "1.0.40"
 rand = { version = "0.8.5", default-features = false } # Default features are disabled due to usage in no_std crates
 rand_chacha = "0.3.1"

commons/zenoh-protocol/src/core/endpoint.rs

@@ -195,6 +195,7 @@ pub struct Metadata<'a>(pub(super) &'a str);
 impl<'a> Metadata<'a> {
     pub const RELIABILITY: &'static str = "rel";
     pub const PRIORITIES: &'static str = "prio";
+    pub const MULTISTREAM: &'static str = "multistream";
 
     pub fn as_str(&self) -> &'a str {
         self.0
@@ -330,19 +331,19 @@ impl<'a> Config<'a> {
         self.0
     }
 
-    pub fn is_empty(&'a self) -> bool {
+    pub fn is_empty(&self) -> bool {
         self.as_str().is_empty()
     }
 
-    pub fn iter(&'a self) -> impl DoubleEndedIterator<Item = (&'a str, &'a str)> + Clone {
+    pub fn iter(&self) -> impl DoubleEndedIterator<Item = (&'a str, &'a str)> + Clone {
         parameters::iter(self.0)
     }
 
-    pub fn get(&'a self, k: &str) -> Option<&'a str> {
+    pub fn get(&self, k: &str) -> Option<&'a str> {
         parameters::get(self.0, k)
     }
 
-    pub fn values(&'a self, k: &str) -> impl DoubleEndedIterator<Item = &'a str> {
+    pub fn values(&self, k: &str) -> impl DoubleEndedIterator<Item = &'a str> {
         parameters::values(self.0, k)
     }
 }

commons/zenoh-sync/src/object_pool.rs

@@ -32,6 +32,15 @@ where
     f: F,
 }
 
+impl<T, F: Fn() -> T + Clone> Clone for RecyclingObjectPool<T, F> {
+    fn clone(&self) -> Self {
+        Self {
+            inner: self.inner.clone(),
+            f: self.f.clone(),
+        }
+    }
+}
+
 impl<T, F: Fn() -> T> RecyclingObjectPool<T, F> {
     pub fn new(num: usize, f: F) -> RecyclingObjectPool<T, F> {
         let inner: Arc<LifoQueue<T>> = Arc::new(LifoQueue::new(num));

io/zenoh-link-commons/Cargo.toml

@@ -28,7 +28,10 @@ version = { workspace = true }
 compression = []
 quic = [
   "dep:base64",
+  "dep:bytes",
   "dep:quinn",
+  "dep:quinn-proto",
+  "dep:rcgen",
   "dep:rustls-pemfile",
   "dep:rustls-pki-types",
   "dep:secrecy",
@@ -38,13 +41,17 @@ quic = [
   "tls",
 ]
 tls = ["dep:rustls", "dep:rustls-webpki"]
+unsecure_quic = ["quic"]
 
 [dependencies]
 async-trait = { workspace = true }
 base64 = { workspace = true, optional = true }
+bytes = { workspace = true, optional = true }
 flume = { workspace = true }
 futures = { workspace = true }
 quinn = { workspace = true, optional = true }
+quinn-proto = { workspace = true, optional = true }
+rcgen = { workspace = true, optional = true }
 rustls = { workspace = true, optional = true }
 rustls-pemfile = { workspace = true, optional = true }
 rustls-pki-types = { workspace = true, optional = true }

io/zenoh-link-commons/src/quic/mod.rs

@@ -0,0 +1,18 @@
+//
+// Copyright (c) 2026 ZettaScale Technology
+//
+// This program and the accompanying materials are made available under the
+// terms of the Eclipse Public License 2.0 which is available at
+// http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+// which is available at https://www.apache.org/licenses/LICENSE-2.0.
+//
+// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+//
+// Contributors:
+//   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
+//
+mod plaintext;
+mod socket;
+mod utils;
+pub use utils::*;
+pub mod unicast;