Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 3 additions & 21 deletions rmw_cyclonedds_cpp/src/rmw_node.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1140,6 +1140,7 @@ extern "C" rmw_publisher_t * rmw_create_publisher(
memcpy(const_cast<char *>(rmw_publisher->topic_name), topic_name, strlen(topic_name) + 1);
#if RMW_VERSION_GTE(0, 8, 1)
rmw_publisher->options = *publisher_options;
rmw_publisher->can_loan_messages = false;
#endif
return rmw_publisher;
fail_topic_name:
Expand Down Expand Up @@ -1237,16 +1238,6 @@ extern "C" rmw_ret_t rmw_return_loaned_message_from_publisher(
return RMW_RET_UNSUPPORTED;
}

extern "C" rmw_ret_t rmw_return_loaned_message(
const rmw_publisher_t * publisher,
void * loaned_message)
{
/* https://github.com/ros2/rmw/pull/192 replaces this one with
rmw_return_loaned_message_from_publisher, but until that PR is accepted, this one is
needed to make things build & work */
return rmw_return_loaned_message_from_publisher(publisher, loaned_message);
}

extern "C" rmw_ret_t rmw_destroy_publisher(rmw_node_t * node, rmw_publisher_t * publisher)
{
RET_WRONG_IMPLID(node);
Expand Down Expand Up @@ -1381,6 +1372,7 @@ extern "C" rmw_subscription_t * rmw_create_subscription(
memcpy(const_cast<char *>(rmw_subscription->topic_name), topic_name, strlen(topic_name) + 1);
#if RMW_VERSION_GTE(0, 8, 1)
rmw_subscription->options = *subscription_options;
rmw_subscription->can_loan_messages = false;
#endif
return rmw_subscription;
fail_topic_name:
Expand Down Expand Up @@ -1599,20 +1591,10 @@ extern "C" rmw_ret_t rmw_return_loaned_message_from_subscription(
(void) loaned_message;

RMW_SET_ERROR_MSG(
"rmw_release_loaned_message_from_subscription not implemented for rmw_cyclonedds_cpp");
"rmw_return_loaned_message_from_subscription not implemented for rmw_cyclonedds_cpp");
return RMW_RET_UNSUPPORTED;
}

extern "C" rmw_ret_t rmw_release_loaned_message(
const rmw_subscription_t * subscription,
void * loaned_message)
{
/* https://github.com/ros2/rmw/pull/192 replaces this one with
rmw_return_loaned_message_from_subscription, but until that PR is accepted, this one
is needed to make things build & work */
return rmw_return_loaned_message_from_subscription(subscription, loaned_message);
}

extern "C" rmw_ret_t rmw_take_event(
const rmw_event_t * event_handle, void * event_info,
bool * taken)
Expand Down