niklas/rmw_cyclonedds
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update rmw_publish_serialized_message() error returns (#240)

Browse source 
Signed-off-by: lobotuerk <jtlorente@ekumenlabs.com>
This commit is contained in:
Lobotuerk 2020-09-11 16:43:13 -03:00 • committed by Alejandro Hernández Cordero
parent 3160c181f7
commit c610402b46
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
rmw_cyclonedds_cpp/src/rmw_node.cpp
View file

@ -1529,9 +1529,15 @@ extern "C" rmw_ret_t rmw_publish_serialized_message(
const rmw_serialized_message_t * serialized_message, rmw_publisher_allocation_t * allocation) const rmw_serialized_message_t * serialized_message, rmw_publisher_allocation_t * allocation)
{ {
static_cast<void>(allocation); // unused static_cast<void>(allocation); // unused
RET_NULL(publisher); RMW_CHECK_FOR_NULL_WITH_MSG(
RET_WRONG_IMPLID(publisher); publisher, "publisher handle is null",
RET_NULL(serialized_message); return RMW_RET_INVALID_ARGUMENT);
RMW_CHECK_TYPE_IDENTIFIERS_MATCH(
publisher, publisher->implementation_identifier, eclipse_cyclonedds_identifier,
return RMW_RET_INCORRECT_RMW_IMPLEMENTATION);
RMW_CHECK_FOR_NULL_WITH_MSG(
serialized_message, "serialized message handle is null",
return RMW_RET_INVALID_ARGUMENT);
auto pub = static_cast<CddsPublisher *>(publisher->data); auto pub = static_cast<CddsPublisher *>(publisher->data);
struct ddsi_serdata * d = serdata_rmw_from_serialized_message( struct ddsi_serdata * d = serdata_rmw_from_serialized_message(
pub->sertopic, serialized_message->buffer, serialized_message->buffer_length); pub->sertopic, serialized_message->buffer, serialized_message->buffer_length);