diff --git a/rmw_fastrtps_shared_cpp/src/qos.cpp b/rmw_fastrtps_shared_cpp/src/qos.cpp index 40f4c3711..29ace69cd 100644 --- a/rmw_fastrtps_shared_cpp/src/qos.cpp +++ b/rmw_fastrtps_shared_cpp/src/qos.cpp @@ -161,10 +161,9 @@ bool is_valid_qos(const rmw_qos_profile_t & qos_policies) { if (qos_policies.liveliness == RMW_QOS_POLICY_LIVELINESS_MANUAL_BY_NODE || - qos_policies.liveliness == RMW_QOS_POLICY_LIVELINESS_MANUAL_BY_TOPIC || - !is_time_default(qos_policies.liveliness_lease_duration)) + && !is_time_default(qos_policies.liveliness_lease_duration)) { - RMW_SET_ERROR_MSG("Liveliness QoS is not yet supported for fastrtps."); + RMW_SET_ERROR_MSG("Liveliness policy MANUAL_BY_NODE is not yet supported for fastrtps."); return false; } return true; diff --git a/rmw_fastrtps_shared_cpp/src/rmw_publisher.cpp b/rmw_fastrtps_shared_cpp/src/rmw_publisher.cpp index 0186ce214..6d2da5c7f 100644 --- a/rmw_fastrtps_shared_cpp/src/rmw_publisher.cpp +++ b/rmw_fastrtps_shared_cpp/src/rmw_publisher.cpp @@ -121,10 +121,8 @@ __rmw_publisher_assert_liveliness( return RMW_RET_ERROR; } - // info->publisher_->assert_liveliness(); - RMW_SET_ERROR_MSG("assert_liveliness() of publisher is currently not supported"); - - return RMW_RET_UNSUPPORTED; + info->publisher_->assert_liveliness(); + return RMW_RET_OK; } rmw_ret_t