From b8c410c34b385042b3ab3807ba5bfd5dd457f218 Mon Sep 17 00:00:00 2001 From: h-suzuki-isp <146712054+h-suzuki-isp@users.noreply.github.com> Date: Tue, 2 Apr 2024 02:11:56 +0900 Subject: [PATCH] Add: tracepoint for subscribe serialized_message (#145) * Add: tracepoint for take_serialized_message Signed-off-by: h-suzuki * Fix: TRACETOOLS_TRACEPOINT args Signed-off-by: h-suzuki * Update rmw_connextdds_common/src/common/rmw_subscription.cpp Co-authored-by: Christophe Bedard Signed-off-by: h-suzuki-isp <146712054+h-suzuki-isp@users.noreply.github.com> * Update rmw_connextdds_common/src/common/rmw_subscription.cpp Co-authored-by: Christophe Bedard Signed-off-by: h-suzuki-isp <146712054+h-suzuki-isp@users.noreply.github.com> --------- Signed-off-by: h-suzuki Signed-off-by: h-suzuki-isp <146712054+h-suzuki-isp@users.noreply.github.com> Co-authored-by: Christophe Bedard --- .../src/common/rmw_subscription.cpp | 22 +++++++++++++++++-- 1 file changed, 20 insertions(+), 2 deletions(-) diff --git a/rmw_connextdds_common/src/common/rmw_subscription.cpp b/rmw_connextdds_common/src/common/rmw_subscription.cpp index 8c667ee8..601bcd4a 100644 --- a/rmw_connextdds_common/src/common/rmw_subscription.cpp +++ b/rmw_connextdds_common/src/common/rmw_subscription.cpp @@ -386,7 +386,16 @@ rmw_api_connextdds_take_serialized_message( RMW_Connext_Subscriber * const sub_impl = reinterpret_cast(subscription->data); - return sub_impl->take_serialized(serialized_message, nullptr, taken); + rmw_ret_t rc = sub_impl->take_serialized(serialized_message, nullptr, taken); + + TRACETOOLS_TRACEPOINT( + rmw_take, + subscription, + serialized_message, + 0LL, + *taken); + + return rc; } @@ -413,7 +422,16 @@ rmw_api_connextdds_take_serialized_message_with_info( RMW_Connext_Subscriber * const sub_impl = reinterpret_cast(subscription->data); - return sub_impl->take_serialized(serialized_message, message_info, taken); + rmw_ret_t rc = sub_impl->take_serialized(serialized_message, message_info, taken); + + TRACETOOLS_TRACEPOINT( + rmw_take, + subscription, + serialized_message, + (message_info ? message_info->source_timestamp : 0LL), + *taken); + + return rc; }