fix(913): using 2+batch.len() when increasing rx_bytes (#914)

* fix(913): using 2+batch.len() when increasing rx_bytes Signed-off-by: gabrik <[email protected]> * chore: format Signed-off-by: gabrik <[email protected]> --------- Signed-off-by: gabrik <[email protected]>
eclipse-zenoh · Apr 8, 2024 · 0926dd3 · 0926dd3
1 parent b2ef3dd
commit 0926dd3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/io/zenoh-transport/src/unicast/universal/link.rs b/io/zenoh-transport/src/unicast/universal/link.rs
@@ -260,7 +260,8 @@ async fn rx_task(
                 let batch = batch.map_err(|_| zerror!("{}: expired after {} milliseconds", link, lease.as_millis()))??;
                 #[cfg(feature = "stats")]
                 {
-                    transport.stats.inc_rx_bytes(2 + n); // Account for the batch len encoding (16 bits)
+
+                    transport.stats.inc_rx_bytes(2 + batch.len()); // Account for the batch len encoding (16 bits)
                 }
                 transport.read_messages(batch, &l)?;
             }