From b2e29ffdb8d9201b1ad2b56a81d6cb1ecd274521 Mon Sep 17 00:00:00 2001 From: Chen Lihui Date: Fri, 18 Mar 2022 09:27:19 +0800 Subject: [PATCH 1/2] add stub for content filtered topic Signed-off-by: Chen Lihui --- rmw_connextdds/src/rmw_api_impl_ndds.cpp | 26 +++++++++++++++++++ .../src/rmw_api_impl_rtime.cpp | 26 +++++++++++++++++++ 2 files changed, 52 insertions(+) diff --git a/rmw_connextdds/src/rmw_api_impl_ndds.cpp b/rmw_connextdds/src/rmw_api_impl_ndds.cpp index 49f8c6f1..79c5c829 100644 --- a/rmw_connextdds/src/rmw_api_impl_ndds.cpp +++ b/rmw_connextdds/src/rmw_api_impl_ndds.cpp @@ -717,6 +717,32 @@ rmw_subscription_get_actual_qos( } +rmw_ret_t +rmw_subscription_set_content_filter( + rmw_subscription_t * subscription, + const rmw_subscription_content_filter_options_t * options) +{ + UNUSED_ARG(subscription); + UNUSED_ARG(options); + RMW_CONNEXT_LOG_NOT_IMPLEMENTED + return RMW_RET_UNSUPPORTED; +} + + +rmw_ret_t +rmw_subscription_get_content_filter( + const rmw_subscription_t * subscription, + rcutils_allocator_t * allocator, + rmw_subscription_content_filter_options_t * options) +{ + UNUSED_ARG(subscription); + UNUSED_ARG(allocator); + UNUSED_ARG(options); + RMW_CONNEXT_LOG_NOT_IMPLEMENTED + return RMW_RET_UNSUPPORTED; +} + + rmw_ret_t rmw_destroy_subscription( rmw_node_t * node, diff --git a/rmw_connextddsmicro/src/rmw_api_impl_rtime.cpp b/rmw_connextddsmicro/src/rmw_api_impl_rtime.cpp index 9f6b6434..41edb81e 100644 --- a/rmw_connextddsmicro/src/rmw_api_impl_rtime.cpp +++ b/rmw_connextddsmicro/src/rmw_api_impl_rtime.cpp @@ -717,6 +717,32 @@ rmw_subscription_get_actual_qos( } +rmw_ret_t +rmw_subscription_set_content_filter( + rmw_subscription_t * subscription, + const rmw_subscription_content_filter_options_t * options) +{ + UNUSED_ARG(subscription); + UNUSED_ARG(options); + RMW_CONNEXT_LOG_NOT_IMPLEMENTED + return RMW_RET_UNSUPPORTED; +} + + +rmw_ret_t +rmw_subscription_get_content_filter( + const rmw_subscription_t * subscription, + rcutils_allocator_t * allocator, + rmw_subscription_content_filter_options_t * options) +{ + UNUSED_ARG(subscription); + UNUSED_ARG(allocator); + UNUSED_ARG(options); + RMW_CONNEXT_LOG_NOT_IMPLEMENTED + return RMW_RET_UNSUPPORTED; +} + + rmw_ret_t rmw_destroy_subscription( rmw_node_t * node, From 1a820ff4649d964d9a53f80c14d4561f7769718c Mon Sep 17 00:00:00 2001 From: Chen Lihui Date: Fri, 18 Mar 2022 09:47:53 +0800 Subject: [PATCH 2/2] update false for the cft flag Signed-off-by: Chen Lihui --- rmw_connextdds_common/src/common/rmw_impl.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/rmw_connextdds_common/src/common/rmw_impl.cpp b/rmw_connextdds_common/src/common/rmw_impl.cpp index a74a9010..d55aa54d 100644 --- a/rmw_connextdds_common/src/common/rmw_impl.cpp +++ b/rmw_connextdds_common/src/common/rmw_impl.cpp @@ -1815,6 +1815,7 @@ rmw_connextdds_create_subscriber( topic_name_len + 1); rmw_subscriber->options = *subscriber_options; rmw_subscriber->can_loan_messages = false; + rmw_subscriber->is_cft_enabled = false; if (!internal) { if (RMW_RET_OK != rmw_sub_impl->enable()) {