Add log for better trace

zenoh-ext/src/advanced_cache.rs

@@ -227,7 +227,7 @@
             Some(Err(e)) => bail!("Invalid key expression for queryable_suffix: {}", e),
         };
         tracing::debug!(
-            "Create AdvancedCache on {} with max_samples={:?}",
+            "Create AdvancedCache{{key_expr: {}, max_samples: {:?}}}",
             &key_expr,
             conf.history,
         );
@@ -241,6 +241,7 @@
             .callback({
                 let cache = cache.clone();
                 move |query| {
+                    tracing::trace!("AdvancedCache{{}} Handle query {}", query.selector());
                     let range = query
                         .parameters()
                         .get("_sn")
@@ -286,7 +287,14 @@
                                     )
                                     .wait()
                                 {
-                                    tracing::warn!("Error replying to query: {}", e);
+                                    tracing::warn!("AdvancedCache{{}} Error replying to query: {}", e);
+                                } else {
+                                    tracing::trace!(
+                                        "AdvancedCache{{}} Replied to query {} with Sample{{info:{:?}, ts:{:?}}}",
+                                        query.selector(),
+                                        sample.source_info(),
+                                        sample.timestamp()
+                                    );
                                 }
                             }
                         } else {
@@ -318,13 +326,20 @@
                                         )
                                         .wait()
                                     {
-                                        tracing::warn!("Error replying to query: {}", e);
+                                        tracing::warn!("AdvancedCache{{}} Error replying to query: {}", e);
+                                    } else {
+                                        tracing::trace!(
+                                            "AdvancedCache{{}} Replied to query {} with Sample{{info:{:?}, ts:{:?}}}",
+                                            query.selector(),
+                                            sample.source_info(),
+                                            sample.timestamp()
+                                        );
                                     }
                                 }
                             }
                         }
                     } else {
-                        tracing::error!("Unable to take AdvancedPublisher cache read lock");
+                        tracing::error!("AdvancedCache{{}} Unable to take AdvancedPublisher cache read lock");
                     }
                 }
             })
@@ -357,7 +372,7 @@
             }
             queue.push_back(sample);
         } else {
-            tracing::error!("Unable to take AdvancedPublisher cache write lock");
+            tracing::error!("AdvancedCache{{}} Unable to take AdvancedPublisher cache write lock");
         }
     }
 }

zenoh-ext/src/advanced_publisher.rs

@@ -302,6 +302,7 @@
             Some(meta) => Some(meta?),
             None => None,
         };
+        tracing::debug!("Create AdvancedPublisher{{key_expr: {}}}", &key_expr);
 
         let publisher = conf
             .session
@@ -323,7 +324,7 @@
         };
         let suffix = match meta {
             Some(meta) => suffix / &meta,
-            // We need this empty chunk because af a routing matching bug
+            // We need this empty chunk because of a routing matching bug
             _ => suffix / KE_EMPTY,
         };
 
@@ -354,6 +355,11 @@
         };
 
         let token = if conf.liveliness {
+            tracing::debug!(
+                "AdvancedPublisher{{key_expr: {}}}: Declare liveliness token {}",
+                key_expr,
+                &key_expr / &suffix,
+            );
             Some(
                 conf.session
                     .liveliness()
@@ -368,6 +374,13 @@
             conf.miss_config.as_ref().and_then(|c| c.state_publisher)
         {
             if let Some(seqnum) = seqnum.as_ref() {
+                tracing::debug!(
+                    "AdvancedPublisher{{key_expr: {}}}: Enable {}heartbeat on {} with period {:?}",
+                    key_expr,
+                    if sporadic { "sporadic " } else { "" },
+                    &key_expr / &suffix,
+                    period
+                );
                 let seqnum = seqnum.clone();
                 if !sporadic {
                     let publisher = conf.session.declare_publisher(&key_expr / &suffix).wait()?;
@@ -475,10 +488,16 @@
     {
         let mut builder = self.publisher.put(payload);
         if let Some(seqnum) = &self.seqnum {
-            builder = builder.source_info(SourceInfo::new(
+            let info = SourceInfo::new(
                 Some(self.publisher.id()),
                 Some(seqnum.fetch_add(1, Ordering::Relaxed)),
-            ));
+            );
+            tracing::trace!(
+                "AdvancedPublisher{{key_expr: {}}}: Put data with {:?}",
+                self.publisher.key_expr(),
+                info
+            );
+            builder = builder.source_info(info);
         }
         if let Some(hlc) = self.publisher.session().hlc() {
             builder = builder.timestamp(hlc.new_timestamp());
@@ -590,6 +609,10 @@
     /// ```
     #[zenoh_macros::unstable]
     pub fn undeclare(self) -> impl Resolve<ZResult<()>> + 'a {
+        tracing::debug!(
+            "AdvancedPublisher{{key_expr: {}}}: : Undeclare",
+            self.key_expr()
+        );
         self.publisher.undeclare()
     }
 }