From b2099dd12b2dc38fdce9b7764d7724faf7f325cd Mon Sep 17 00:00:00 2001 From: elianalf <62831776+elianalf@users.noreply.github.com> Date: Wed, 17 Jul 2024 11:03:42 +0200 Subject: [PATCH] Refs #21185: Change on_data_writer_discovery after refactor Signed-off-by: elianalf <62831776+elianalf@users.noreply.github.com> --- examples/cpp/flow_control/SubscriberApp.cpp | 39 +++++++++++---------- examples/cpp/flow_control/SubscriberApp.hpp | 3 +- 2 files changed, 22 insertions(+), 20 deletions(-) diff --git a/examples/cpp/flow_control/SubscriberApp.cpp b/examples/cpp/flow_control/SubscriberApp.cpp index 73fe30b93ff..62e5deb6570 100644 --- a/examples/cpp/flow_control/SubscriberApp.cpp +++ b/examples/cpp/flow_control/SubscriberApp.cpp @@ -165,51 +165,52 @@ void SubscriberApp::on_data_available( void SubscriberApp::on_data_writer_discovery( DomainParticipant* /*participant*/, - eprosima::fastdds::rtps::WriterDiscoveryInfo&& info, + eprosima::fastdds::rtps::WriterDiscoveryStatus status, + const eprosima::fastdds::dds::PublicationBuiltinTopicData& info, bool& /*should_be_ignored*/) { std::vector slow_writer_id = {0}; std::vector fast_writer_id = {1}; - if (info.info.m_qos.m_userData.data_vec() == fast_writer_id) + if (info.user_data.data_vec() == fast_writer_id) { - if (info.status == - eprosima::fastdds::rtps::WriterDiscoveryInfo::DISCOVERY_STATUS::DISCOVERED_WRITER) + if (status == + eprosima::fastdds::rtps::WriterDiscoveryStatus::DISCOVERED_WRITER) { - fast_writer_guid.push_back(info.info.guid()); + fast_writer_guid.push_back(info.guid); - std::cout << "Fast writer with id " << info.info.guid() << " matched" << std::endl; + std::cout << "Fast writer with id " << info.guid << " matched" << std::endl; } - else if (info.status == - eprosima::fastdds::rtps::WriterDiscoveryInfo::DISCOVERY_STATUS::REMOVED_WRITER) + else if (status == + eprosima::fastdds::rtps::WriterDiscoveryStatus::REMOVED_WRITER) { - auto it = std::find(fast_writer_guid.begin(), fast_writer_guid.end(), info.info.guid()); + auto it = std::find(fast_writer_guid.begin(), fast_writer_guid.end(), info.guid); if (it != fast_writer_guid.end()) { fast_writer_guid.erase(it); - std::cout << "Fast writer with id " << info.info.guid() << " removed" << std::endl; + std::cout << "Fast writer with id " << info.guid << " removed" << std::endl; } } } - else if (info.info.m_qos.m_userData.data_vec() == slow_writer_id) + else if (info.user_data.data_vec() == slow_writer_id) { - if (info.status == - eprosima::fastdds::rtps::WriterDiscoveryInfo::DISCOVERY_STATUS::DISCOVERED_WRITER) + if (status == + eprosima::fastdds::rtps::WriterDiscoveryStatus::DISCOVERED_WRITER) { - slow_writer_guid.push_back(info.info.guid()); + slow_writer_guid.push_back(info.guid); - std::cout << "Slow writer with id " << info.info.guid() << " matched" << std::endl; + std::cout << "Slow writer with id " << info.guid << " matched" << std::endl; } - else if (info.status == - eprosima::fastdds::rtps::WriterDiscoveryInfo::DISCOVERY_STATUS::REMOVED_WRITER) + else if (status == + eprosima::fastdds::rtps::WriterDiscoveryStatus::REMOVED_WRITER) { - auto it = std::find(slow_writer_guid.begin(), slow_writer_guid.end(), info.info.guid()); + auto it = std::find(slow_writer_guid.begin(), slow_writer_guid.end(), info.guid); if (it != slow_writer_guid.end()) { slow_writer_guid.erase(it); - std::cout << "Slow writer with id " << info.info.guid() << " removed" << std::endl; + std::cout << "Slow writer with id " << info.guid << " removed" << std::endl; } } } diff --git a/examples/cpp/flow_control/SubscriberApp.hpp b/examples/cpp/flow_control/SubscriberApp.hpp index 753cd963259..53a5b35ee68 100644 --- a/examples/cpp/flow_control/SubscriberApp.hpp +++ b/examples/cpp/flow_control/SubscriberApp.hpp @@ -64,7 +64,8 @@ class SubscriberApp : public Application, public DomainParticipantListener void on_data_writer_discovery( DomainParticipant* participant, - eprosima::fastdds::rtps::WriterDiscoveryInfo&& info, + eprosima::fastdds::rtps::WriterDiscoveryStatus status, + const eprosima::fastdds::dds::PublicationBuiltinTopicData& info, bool& should_be_ignored) override; //! Run subscriber