feat: allocate rx buffer

DEFAULT_CONFIG.json5

@@ -514,12 +514,6 @@
       },
       /// Configure the zenoh RX parameters of a link
       rx: {
-        /// Receiving buffer size in bytes for each link
-        /// The default the rx_buffer_size value is the same as the default batch size: 65535.
-        /// For very high throughput scenarios, the rx_buffer_size can be increased to accommodate
-        /// more in-flight data. This is particularly relevant when dealing with large messages.
-        /// E.g. for 16MiB rx_buffer_size set the value to: 16777216.
-        buffer_size: 65535,
         /// Maximum size of the defragmentation buffer at receiver end.
         /// Fragmented messages that are larger than the configured size will be dropped.
         /// The default value is 1GiB. This would work in most scenarios.

commons/zenoh-buffers/src/zslice.rs

@@ -168,6 +168,12 @@ impl ZSlice {
         self.len() == 0
     }
 
+    #[doc(hidden)]
+    #[inline]
+    pub fn capacity(&self) -> usize {
+        self.buf.as_slice().len()
+    }
+
     #[inline]
     #[must_use]
     pub fn as_slice(&self) -> &[u8] {

commons/zenoh-config/src/defaults.rs

@@ -315,7 +315,6 @@ impl Default for BatchingConf {
 impl Default for LinkRxConf {
     fn default() -> Self {
         Self {
-            buffer_size: BatchSize::MAX as usize,
             max_message_size: 2_usize.pow(30),
         }
     }

commons/zenoh-config/src/lib.rs

@@ -519,12 +519,6 @@ validated_struct::validator! {
                     threads: usize,
                 },
                 pub rx: LinkRxConf {
-                    /// Receiving buffer size in bytes for each link
-                    /// The default the rx_buffer_size value is the same as the default batch size: 65535.
-                    /// For very high throughput scenarios, the rx_buffer_size can be increased to accommodate
-                    /// more in-flight data. This is particularly relevant when dealing with large messages.
-                    /// E.g. for 16MiB rx_buffer_size set the value to: 16777216.
-                    buffer_size: usize,
                     /// Maximum size of the defragmentation buffer at receiver end (default: 1GiB).
                     /// Fragmented messages that are larger than the configured size will be dropped.
                     max_message_size: usize,

commons/zenoh-sync/Cargo.toml

@@ -18,9 +18,9 @@ version = { workspace = true }
 repository = { workspace = true }
 homepage = { workspace = true }
 authors = [
-  "kydos <[email protected]>",
-  "Luca Cominardi <[email protected]>",
-  "Pierre Avital <[email protected]>",
+    "kydos <[email protected]>",
+    "Luca Cominardi <[email protected]>",
+    "Pierre Avital <[email protected]>",
 ]
 edition = { workspace = true }
 license = { workspace = true }
@@ -32,10 +32,6 @@ description = "Internal crate for zenoh."
 event-listener = { workspace = true }
 futures = { workspace = true }
 tokio = { workspace = true, features = ["sync"] }
-zenoh-buffers = { workspace = true }
-zenoh-collections = { workspace = true, features = ["default"] }
-zenoh-core = { workspace = true }
 
 [dev-dependencies]
 tokio = { workspace = true, features = ["macros", "sync", "rt-multi-thread", "time"] }
-zenoh-result = { workspace = true }

commons/zenoh-sync/src/lib.rs

@@ -28,18 +28,6 @@ use futures::FutureExt;
 pub mod event;
 pub use event::*;
 
-pub mod fifo_queue;
-pub use fifo_queue::*;
-
-pub mod lifo_queue;
-pub use lifo_queue::*;
-
-pub mod object_pool;
-pub use object_pool::*;
-
-pub mod mvar;
-pub use mvar::*;
-
 pub mod condition;
 pub use condition::*;