diff --git a/zenoh-plugin-ros2dds/src/route_publisher.rs b/zenoh-plugin-ros2dds/src/route_publisher.rs index 8116b09..1066e4e 100644 --- a/zenoh-plugin-ros2dds/src/route_publisher.rs +++ b/zenoh-plugin-ros2dds/src/route_publisher.rs @@ -219,6 +219,7 @@ impl RoutePublisher<'_> { let publisher = publisher.clone(); move |status| { + log::debug!("{route_id} MatchingStatus changed: {status:?}"); if status.matching_subscribers() { if let Err(e) = activate_dds_reader( &dds_reader, @@ -397,6 +398,7 @@ fn activate_dds_reader( type_info: &Option>, publisher: &Arc>, ) -> Result<(), String> { + log::debug!("{route_id}: create Reader with {reader_qos:?}"); let topic_name: String = format!("rt{}", ros2_name); let type_name = ros2_message_type_to_dds_type(ros2_type); let read_period = get_read_period(&context.config, ros2_name); @@ -436,6 +438,7 @@ fn deactivate_dds_reader( route_id: &str, ros_discovery_mgr: &Arc, ) { + log::debug!("{route_id}: delete Reader"); let reader = dds_reader.swap(DDS_ENTITY_NULL, Ordering::Relaxed); if reader != DDS_ENTITY_NULL { // remove reader's GID from ros_discovery_info message diff --git a/zenoh-plugin-ros2dds/src/route_subscriber.rs b/zenoh-plugin-ros2dds/src/route_subscriber.rs index 6ae477b..5c03cd5 100644 --- a/zenoh-plugin-ros2dds/src/route_subscriber.rs +++ b/zenoh-plugin-ros2dds/src/route_subscriber.rs @@ -84,6 +84,7 @@ impl Drop for RouteSubscriber<'_> { Err(e) => log::warn!("{self}: {e}"), } + log::debug!("{self}: delete Writer"); if let Err(e) = delete_dds_entity(self.dds_writer) { log::warn!("{}: error deleting DDS Reader: {}", self, e); } @@ -117,6 +118,7 @@ impl RouteSubscriber<'_> { let type_name = ros2_message_type_to_dds_type(&ros2_type); let queries_timeout = context.config.get_queries_timeout_tl_sub(&ros2_name); + log::debug!("Route Subscriber ({zenoh_key_expr} -> {ros2_name}): create Writer with {writer_qos:?}"); let dds_writer = create_dds_writer( context.participant, topic_name,