Skip to content

Commit

Permalink
Update to new locator getters interface.
Browse files Browse the repository at this point in the history
Signed-off-by: Miguel Company <MiguelCompany@eprosima.com>
  • Loading branch information
MiguelCompany committed Feb 19, 2021
1 parent ec6fd3c commit 1c8093a
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions rmw_fastrtps_shared_cpp/src/rmw_get_endpoint_network_flow.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ namespace rmw_fastrtps_shared_cpp
{

using Locator_t = eprosima::fastrtps::rtps::Locator_t;
using LocatorList_t = eprosima::fastrtps::rtps::LocatorList_t;
using IPLocator = eprosima::fastrtps::rtps::IPLocator;

rmw_ret_t fill_network_flow(rmw_network_flow_t*, const Locator_t &);
Expand All @@ -38,7 +39,8 @@ __rmw_publisher_get_network_flow(
// Retrieve the sender locators
CustomPublisherInfo * data =
static_cast<CustomPublisherInfo *>(publisher->data);
auto locators = data->publisher_->get_locators();
LocatorList_t locators;
data->publisher_->get_sending_locators(locators);

if (locators.empty())
{
Expand Down Expand Up @@ -100,7 +102,8 @@ __rmw_subscription_get_network_flow(
// Retrieve the listener locators
CustomSubscriberInfo * data =
static_cast<CustomSubscriberInfo*>(subscription->data);
auto locators = data->subscriber_->get_locators();
LocatorList_t locators;
data->subscriber_->get_listening_locators(locators);

if (locators.empty())
{
Expand Down

0 comments on commit 1c8093a

Please sign in to comment.