add stub for content filtered topic (#77)

* add stub for content filtered topic Signed-off-by: Chen Lihui <lihui.chen@sony.com>
ros2 · Mar 21, 2022 · 898e570 · 898e570
1 parent fd02f99
commit 898e570
Show file tree

Hide file tree

Showing 3 changed files with 53 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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,