Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add rmw listener apis #44

Merged
merged 7 commits into from
Feb 24, 2022
Merged

Add rmw listener apis #44

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
0a2d29f
Add stubs for setting listener callbacks
Apr 23, 2021
11dca3f
Merge pull request #1 from mauropasse/mauro/add-rmw-listener-apis
Apr 26, 2021
b8e3317
Address PR suggestions
Apr 27, 2021
3bbdf0b
Merge pull request #2 from mauropasse/mauro/add-rmw-listener-apis
May 5, 2021
b56702c
Merge remote-tracking branch 'upstream/master' into irobot/add-rmw-li…
Feb 9, 2022
4a3cdbc
Fix linter issues
Feb 10, 2022
8ca1184
Merge pull request #3 from mauropasse/irobot/add-rmw-listener-apis-fixes
alsora Feb 10, 2022
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
51 changes: 51 additions & 0 deletions rmw_connextdds/src/rmw_api_impl_ndds.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -120,6 +120,18 @@ rmw_take_event(
return rmw_api_connextdds_take_event(event_handle, event_info, taken);
}

rmw_ret_t
rmw_event_set_callback(
rmw_event_t * event,
rmw_event_callback_t callback,
const void * user_data)
{
(void)event;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_event_set_callback not implemented");
return RMW_RET_UNSUPPORTED;
}
/*****************************************************************************
* Info API
*****************************************************************************/
Expand Down Expand Up @@ -583,6 +595,33 @@ rmw_destroy_service(
{
return rmw_api_connextdds_destroy_service(node, service);
}

rmw_ret_t
rmw_service_set_on_new_request_callback(
rmw_service_t * rmw_service,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_service;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_service_set_on_new_request_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

rmw_ret_t
rmw_client_set_on_new_response_callback(
rmw_client_t * rmw_client,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_client;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_client_set_on_new_response_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

/*****************************************************************************
* Subscription API
*****************************************************************************/
Expand Down Expand Up @@ -743,6 +782,18 @@ rmw_return_loaned_message_from_subscription(
subscription, loaned_message);
}

rmw_ret_t rmw_subscription_set_on_new_message_callback(
rmw_subscription_t * rmw_subscription,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_subscription;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_subscription_set_on_new_message_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

/*****************************************************************************
* WaitSet API
*****************************************************************************/
Expand Down
51 changes: 51 additions & 0 deletions rmw_connextddsmicro/src/rmw_api_impl_rtime.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -120,6 +120,19 @@ rmw_take_event(
return rmw_api_connextdds_take_event(event_handle, event_info, taken);
}

rmw_ret_t
rmw_event_set_callback(
rmw_event_t * event,
rmw_event_callback_t callback,
const void * user_data)
{
(void)event;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_event_set_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

/*****************************************************************************
* Info API
*****************************************************************************/
Expand Down Expand Up @@ -583,6 +596,33 @@ rmw_destroy_service(
{
return rmw_api_connextdds_destroy_service(node, service);
}

rmw_ret_t
rmw_service_set_on_new_request_callback(
rmw_service_t * rmw_service,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_service;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_service_set_on_new_request_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

rmw_ret_t
rmw_client_set_on_new_response_callback(
rmw_client_t * rmw_client,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_client;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_client_set_on_new_response_callback not implemented");
return RMW_RET_UNSUPPORTED;
}

/*****************************************************************************
* Subscription API
*****************************************************************************/
Expand Down Expand Up @@ -743,6 +783,17 @@ rmw_return_loaned_message_from_subscription(
subscription, loaned_message);
}

rmw_ret_t rmw_subscription_set_on_new_message_callback(
rmw_subscription_t * rmw_subscription,
rmw_event_callback_t callback,
const void * user_data)
{
(void)rmw_subscription;
(void)callback;
(void)user_data;
RMW_SET_ERROR_MSG("rmw_subscription_set_on_new_message_callback not implemented");
return RMW_RET_UNSUPPORTED;
}
/*****************************************************************************
* WaitSet API
*****************************************************************************/
Expand Down