[21710] DataWriter/Reader get_matched_publication/subscription() Test implementation

include/fastdds/rtps/participant/RTPSParticipant.h

@@ -54,6 +54,8 @@ namespace dds {
 namespace builtin {
 
 class TypeLookupManager;
+struct PublicationBuiltinTopicData;
+struct SubscriptionBuiltinTopicData;
 
 } // namespace builtin
 } // namespace dds
@@ -306,6 +308,30 @@ class RTPS_DllAPI RTPSParticipant
      */
     std::vector<fastdds::rtps::TransportNetmaskFilterInfo> get_netmask_filter_info() const;
 
+    /**
+     * @brief Fills the provided PublicationBuiltinTopicData with the information of the
+     * writer identified by writer_guid.
+     *
+     * @param[out] data PublicationBuiltinTopicData to fill.
+     * @param[in] writer_guid GUID of the writer to get the information from.
+     * @return True if the writer was found and the data was filled.
+     */
+    bool get_publication_info(
+            fastdds::dds::builtin::PublicationBuiltinTopicData& data,
+            const GUID_t& writer_guid) const;
+
+    /**
+     * @brief Fills the provided SubscriptionBuiltinTopicData with the information of the
+     * reader identified by reader_guid.
+     *
+     * @param[out] data SubscriptionBuiltinTopicData to fill.
+     * @param[in] reader_guid GUID of the reader to get the information from.
+     * @return True if the reader was found and the data was filled.
+     */
+    bool get_subscription_info(
+            fastdds::dds::builtin::SubscriptionBuiltinTopicData& data,
+            const GUID_t& reader_guid) const;
+
 #if HAVE_SECURITY
 
     /**

include/fastdds/rtps/reader/RTPSReader.h

@@ -276,6 +276,15 @@ class RTPSReader
         data_filter_ = filter;
     }
 
+    /**
+     * @brief Fills the provided vector with the GUIDs of the matched writers.
+     *
+     * @param[out] guids Vector to be filled with the GUIDs of the matched writers.
+     * @return True if the operation was successful.
+     */
+    RTPS_DllAPI bool matched_writers_guids(
+            std::vector<GUID_t>& guids) const;
+
     /*!
      * @brief Returns there is a clean state with all Writers.
      * It occurs when the Reader received all samples sent by Writers. In other words,

include/fastdds/rtps/writer/RTPSWriter.h

@@ -317,6 +317,15 @@ class RTPSWriter
         return false;
     }
 
+    /**
+     * @brief Fills the provided vector with the GUIDs of the matched readers.
+     *
+     * @param[out] guids Vector to be filled with the GUIDs of the matched readers.
+     * @return True if the operation was successful.
+     */
+    RTPS_DllAPI bool matched_readers_guids(
+            std::vector<GUID_t>& guids) const;
+
     /**
      * Tries to remove a change waiting a maximum of the provided microseconds.
      * @param max_blocking_time_point Maximum time to wait for.

src/cpp/rtps/participant/RTPSParticipant.cpp

@@ -201,6 +201,20 @@ std::vector<fastdds::rtps::TransportNetmaskFilterInfo> RTPSParticipant::get_netm
     return mp_impl->get_netmask_filter_info();
 }
 
+bool RTPSParticipant::get_publication_info(
+        fastdds::dds::builtin::PublicationBuiltinTopicData&,
+        const GUID_t&) const
+{
+    return false;
+}
+
+bool RTPSParticipant::get_subscription_info(
+        fastdds::dds::builtin::SubscriptionBuiltinTopicData&,
+        const GUID_t&) const
+{
+    return false;
+}
+
 #if HAVE_SECURITY
 
 bool RTPSParticipant::is_security_enabled_for_writer(

src/cpp/rtps/reader/RTPSReader.cpp

@@ -435,6 +435,12 @@ bool RTPSReader::is_sample_valid(
     return true;
 }
 
+bool RTPSReader::matched_writers_guids(
+        std::vector<GUID_t>&) const
+{
+    return false;
+}
+
 #ifdef FASTDDS_STATISTICS
 
 bool RTPSReader::add_statistics_listener(

src/cpp/rtps/writer/RTPSWriter.cpp

@@ -462,6 +462,12 @@ bool RTPSWriter::send_nts(
                    locator_selector.locator_selector.end(), max_blocking_time_point);
 }
 
+bool RTPSWriter::matched_readers_guids(
+        std::vector<GUID_t>&) const
+{
+    return false;
+}
+
 #ifdef FASTDDS_STATISTICS
 
 bool RTPSWriter::add_statistics_listener(