@@ -2869,6 +2869,7 @@ static rmw_subscription_t * create_subscription(
2869
2869
memcpy (const_cast <char *>(rmw_subscription->topic_name ), topic_name, strlen (topic_name) + 1 );
2870
2870
rmw_subscription->options = *subscription_options;
2871
2871
rmw_subscription->can_loan_messages = sub->is_loaning_available ;
2872
+ rmw_subscription->is_cft_enabled = false ;
2872
2873
2873
2874
cleanup_subscription.cancel ();
2874
2875
cleanup_rmw_subscription.cancel ();
@@ -2994,6 +2995,30 @@ extern "C" rmw_ret_t rmw_subscription_get_actual_qos(
2994
2995
return RMW_RET_ERROR;
2995
2996
}
2996
2997
2998
+ extern " C" rmw_ret_t rmw_subscription_set_content_filter (
2999
+ rmw_subscription_t * subscription,
3000
+ const rmw_subscription_content_filter_options_t * options)
3001
+ {
3002
+ static_cast <void >(subscription);
3003
+ static_cast <void >(options);
3004
+
3005
+ RMW_SET_ERROR_MSG (" rmw_subscription_set_content_filter: unimplemented" );
3006
+ return RMW_RET_UNSUPPORTED;
3007
+ }
3008
+
3009
+ extern " C" rmw_ret_t rmw_subscription_get_content_filter (
3010
+ const rmw_subscription_t * subscription,
3011
+ rcutils_allocator_t * allocator,
3012
+ rmw_subscription_content_filter_options_t * options)
3013
+ {
3014
+ static_cast <void >(subscription);
3015
+ static_cast <void >(allocator);
3016
+ static_cast <void >(options);
3017
+
3018
+ RMW_SET_ERROR_MSG (" rmw_subscription_get_content_filter: unimplemented" );
3019
+ return RMW_RET_UNSUPPORTED;
3020
+ }
3021
+
2997
3022
static rmw_ret_t destroy_subscription (rmw_subscription_t * subscription)
2998
3023
{
2999
3024
rmw_ret_t ret = RMW_RET_OK;
0 commit comments