From f00916bf9e41de24940714c57777eed8f4af19e2 Mon Sep 17 00:00:00 2001 From: ChenYing Kuo Date: Fri, 22 Nov 2024 15:49:11 +0800 Subject: [PATCH 1/2] Add trace log while dropping the messages. Signed-off-by: ChenYing Kuo --- io/zenoh-transport/src/common/pipeline.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/io/zenoh-transport/src/common/pipeline.rs b/io/zenoh-transport/src/common/pipeline.rs index 054a5e0a1..c42f6bc5c 100644 --- a/io/zenoh-transport/src/common/pipeline.rs +++ b/io/zenoh-transport/src/common/pipeline.rs @@ -235,6 +235,10 @@ impl StageIn { // Still no available batch. // Restore the sequence number and drop the message $($restore_sn)? + tracing::trace!( + "Zenoh message dropped because it's over the deadline {:?}", + deadline.lazy_deadline.wait_time + ); return false; } c_guard = self.mutex.current(); From c3d1c992aa1db18738dbf4b6a7f3a145f2b52d0e Mon Sep 17 00:00:00 2001 From: ChenYing Kuo Date: Fri, 22 Nov 2024 18:04:52 +0800 Subject: [PATCH 2/2] Also show the msg. Signed-off-by: ChenYing Kuo --- io/zenoh-transport/src/common/pipeline.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/io/zenoh-transport/src/common/pipeline.rs b/io/zenoh-transport/src/common/pipeline.rs index c42f6bc5c..1ed4ef266 100644 --- a/io/zenoh-transport/src/common/pipeline.rs +++ b/io/zenoh-transport/src/common/pipeline.rs @@ -236,8 +236,8 @@ impl StageIn { // Restore the sequence number and drop the message $($restore_sn)? tracing::trace!( - "Zenoh message dropped because it's over the deadline {:?}", - deadline.lazy_deadline.wait_time + "Zenoh message dropped because it's over the deadline {:?}: {:?}", + deadline.lazy_deadline.wait_time, msg ); return false; }