Use InternalWriter from DDS-Pipe (#114)

Signed-off-by: Juan Lopez Fernandez <[email protected]>
eProsima · Dec 19, 2024 · b0a3937 · b0a3937
1 parent 205685c
commit b0a3937
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 89 deletions.
diff --git a/fastddsspy_participants/include/fastddsspy_participants/participant/SpyParticipant.hpp b/fastddsspy_participants/include/fastddsspy_participants/participant/SpyParticipant.hpp
@@ -17,10 +17,10 @@
 #include <cpp_utils/types/Atomicable.hpp>
 
 #include <ddspipe_participants/participant/dynamic_types/SchemaParticipant.hpp>
+#include <ddspipe_participants/writer/auxiliar/InternalWriter.hpp>
 
 #include <fastddsspy_participants/library/library_dll.h>
 #include <fastddsspy_participants/types/ParticipantInfo.hpp>
-#include <fastddsspy_participants/writer/InternalWriter.hpp>
 #include <fastddsspy_participants/model/SpyModel.hpp>
 
 namespace eprosima {
@@ -56,9 +56,9 @@ class SpyParticipant : public ddspipe::participants::SchemaParticipant
             const ddspipe::core::IRoutingData& data);
 
     //! Participants Internal Reader
-    std::shared_ptr<InternalWriter> participants_writer_;
+    std::shared_ptr<ddspipe::participants::InternalWriter> participants_writer_;
 
-    std::shared_ptr<InternalWriter> endpoints_writer_;
+    std::shared_ptr<ddspipe::participants::InternalWriter> endpoints_writer_;
 
     std::shared_ptr<SpyModel> model_;
 };

diff --git a/fastddsspy_participants/include/fastddsspy_participants/writer/InternalWriter.hpp b/fastddsspy_participants/include/fastddsspy_participants/writer/InternalWriter.hpp
diff --git a/fastddsspy_participants/src/cpp/participant/SpyParticipant.cpp b/fastddsspy_participants/src/cpp/participant/SpyParticipant.cpp
@@ -36,7 +36,7 @@ SpyParticipant::SpyParticipant(
                 return this->new_participant_info_(data);
             };
 
-    participants_writer_ = std::make_shared<InternalWriter>(
+    participants_writer_ = std::make_shared<ddspipe::participants::InternalWriter>(
         participant_configuration->id,
         participant_callback);
 
@@ -45,7 +45,7 @@ SpyParticipant::SpyParticipant(
                 return this->new_endpoint_info_(data);
             };
 
-    endpoints_writer_ = std::make_shared<InternalWriter>(
+    endpoints_writer_ = std::make_shared<ddspipe::participants::InternalWriter>(
         participant_configuration->id,
         endpoint_callback);
 }

diff --git a/fastddsspy_participants/src/cpp/writer/InternalWriter.cpp b/fastddsspy_participants/src/cpp/writer/InternalWriter.cpp