readers_ as InternalReader

EugenioCollado · EugenioCollado · commit 0d64c22f89c7 · 2025-10-17T09:24:27.000+02:00
Signed-off-by: Eugenio Collado &lt;eugeniocollado@eprosima.com&gt;
diff --git a/ddsenabler_participants/include/ddsenabler_participants/EnablerParticipant.hpp b/ddsenabler_participants/include/ddsenabler_participants/EnablerParticipant.hpp
@@ -164,7 +164,7 @@ class EnablerParticipant : public ddspipe::participants::SchemaParticipant
     bool revoke_service_nts_(
             const std::string& service_name);
 
-    std::map<ddspipe::core::types::DdsTopic, std::shared_ptr<ddspipe::core::IReader>> readers_;
+    std::map<ddspipe::core::types::DdsTopic, std::shared_ptr<ddspipe::participants::InternalReader>> readers_;
 
     std::map<std::string, std::shared_ptr<ServiceDiscovered>> services_;
 
diff --git a/ddsenabler_participants/src/cpp/EnablerParticipant.cpp b/ddsenabler_participants/src/cpp/EnablerParticipant.cpp
@@ -90,7 +90,7 @@ std::shared_ptr<IReader> EnablerParticipant::create_reader(
         return std::make_shared<BlankReader>();
     }
 
-    std::shared_ptr<IReader> reader;
+    std::shared_ptr<InternalReader> reader;
     {
         std::lock_guard<std::mutex> lck(mtx_);
         auto dds_topic = dynamic_cast<const DdsTopic&>(topic);

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ std::shared_ptr<IReader> EnablerParticipant::create_reader(`
`90`	`90`	`return std::make_shared<BlankReader>();`
`91`	`91`	`}`
`92`	`92`
`93`		`- std::shared_ptr<IReader> reader;`
	`93`	`+ std::shared_ptr<InternalReader> reader;`
`94`	`94`	`{`
`95`	`95`	`std::lock_guard<std::mutex> lck(mtx_);`
`96`	`96`	`auto dds_topic = dynamic_cast<const DdsTopic&>(topic);`