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_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()) { 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,