diff --git a/rmw_connext_cpp/src/rmw_subscription.cpp b/rmw_connext_cpp/src/rmw_subscription.cpp index a6b656dc..2a66f4b3 100644 --- a/rmw_connext_cpp/src/rmw_subscription.cpp +++ b/rmw_connext_cpp/src/rmw_subscription.cpp @@ -269,6 +269,7 @@ rmw_create_subscription( #endif subscription->can_loan_messages = false; + subscription->is_cft_supported = false; return subscription; fail: if (topic_str) { @@ -392,6 +393,34 @@ rmw_subscription_get_actual_qos( return RMW_RET_OK; } +rmw_ret_t +rmw_subscription_set_cft_expression_parameters( + rmw_subscription_t * subscription, + const char * filter_expression, + const rcutils_string_array_t * expression_parameters) +{ + // Unused in current implementation. + (void) subscription; + (void) filter_expression; + (void) expression_parameters; + RMW_SET_ERROR_MSG("unimplemented"); + return RMW_RET_UNSUPPORTED; +} + +rmw_ret_t +rmw_subscription_get_cft_expression_parameters( + const rmw_subscription_t * subscription, + char ** filter_expression, + rcutils_string_array_t * expression_parameters) +{ + // Unused in current implementation. + (void) subscription; + (void) filter_expression; + (void) expression_parameters; + RMW_SET_ERROR_MSG("unimplemented"); + return RMW_RET_UNSUPPORTED; +} + rmw_ret_t rmw_destroy_subscription(rmw_node_t * node, rmw_subscription_t * subscription) { diff --git a/rmw_connext_dynamic_cpp/src/functions.cpp b/rmw_connext_dynamic_cpp/src/functions.cpp index fad7787b..a5630927 100644 --- a/rmw_connext_dynamic_cpp/src/functions.cpp +++ b/rmw_connext_dynamic_cpp/src/functions.cpp @@ -1182,6 +1182,7 @@ rmw_create_subscription( node_info->subscriber_listener->trigger_graph_guard_condition(); subscription->can_loan_messages = false; + subscription->is_cft_supported = false; return subscription; fail: // Something has gone wrong, unroll what has been done.