implement matched_publications

eclipse-cyclonedds · Feb 3, 2025 · d141472 · d141472
1 parent 6e1f116
commit d141472
Showing 1 changed file with 18 additions and 1 deletion.
diff --git a/src/ddscxx/src/org/eclipse/cyclonedds/sub/AnyDataReaderDelegate.cpp b/src/ddscxx/src/org/eclipse/cyclonedds/sub/AnyDataReaderDelegate.cpp
@@ -567,8 +567,25 @@ AnyDataReaderDelegate::subscription_matched_status()
 ::dds::core::InstanceHandleSeq
 AnyDataReaderDelegate::matched_publications()
 {
-    ISOCPP_THROW_EXCEPTION(ISOCPP_UNSUPPORTED_ERROR, "Function not currently supported");
     ::dds::core::InstanceHandleSeq handleSeq;
+    dds_return_t rc;
+
+    dds_subscription_matched_status_t status;
+    rc = dds_get_subscription_matched_status (ddsc_entity, &status);
+    ISOCPP_DDSC_RESULT_CHECK_AND_THROW(rc, "dds_get_subscription_matched_status failed.");
+
+    if (status.current_count > 0) {
+        std::vector<dds_instance_handle_t> ddsc_instance_handles;
+        ddsc_instance_handles.resize(status.current_count);
+
+        rc = dds_get_matched_publications(ddsc_entity, ddsc_instance_handles.data(), ddsc_instance_handles.size());
+        ISOCPP_DDSC_RESULT_CHECK_AND_THROW(rc, "dds_get_matched_publications failed.");
+
+        for (const auto& handle : ddsc_instance_handles) {
+            handleSeq.push_back(::dds::core::InstanceHandle(handle));
+        }
+    }
+
     return handleSeq;
 }