Refs #21313: Fix failing tests

Signed-off-by: eduponz <eduardoponz@eprosima.com>
eProsima · Jul 24, 2024 · 6bc41e5 · 6bc41e5
1 parent 1aa76e4
commit 6bc41e5
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/test/mock/rtps/RTPSParticipantImpl/rtps/participant/RTPSParticipantImpl.h b/test/mock/rtps/RTPSParticipantImpl/rtps/participant/RTPSParticipantImpl.h
@@ -181,7 +181,10 @@ class RTPSParticipantImpl
         bool ret = createWriter_mock(writer, param, hist, listen, entityId, isBuiltin);
         if (*writer != nullptr)
         {
+            (*writer)->history_ = hist;
+
             auto guid = generate_endpoint_guid();
+            (*writer)->m_guid = guid;
             endpoints_.emplace(guid, *writer);
         }
         return ret;
@@ -199,7 +202,10 @@ class RTPSParticipantImpl
         bool ret = createWriter_mock(writer, param, hist, listen, entityId, isBuiltin);
         if (*writer != nullptr)
         {
+            (*writer)->history_ = hist;
+
             auto guid = generate_endpoint_guid();
+            (*writer)->m_guid = guid;
             endpoints_.emplace(guid, *writer);
         }
         return ret;
@@ -217,7 +223,11 @@ class RTPSParticipantImpl
         bool ret = createReader_mock(reader, param, hist, listen, entityId, isBuiltin, enable);
         if (*reader != nullptr)
         {
+            (*reader)->history_ = hist;
+            fastdds::rtps::BaseReader::downcast(*reader)->listener_ = listen;
+
             auto guid = generate_endpoint_guid();
+            (*reader)->m_guid = guid;
             endpoints_.emplace(guid, *reader);
         }
         return ret;
@@ -236,7 +246,11 @@ class RTPSParticipantImpl
         bool ret = createReader_mock(reader, param, hist, listen, entityId, isBuiltin, enable);
         if (*reader != nullptr)
         {
+            (*reader)->history_ = hist;
+            fastdds::rtps::BaseReader::downcast(*reader)->listener_ = listen;
+
             auto guid = generate_endpoint_guid();
+            (*reader)->m_guid = guid;
             endpoints_.emplace(guid, *reader);
         }
         return ret;

diff --git a/test/unittest/rtps/flowcontrol/CMakeLists.txt b/test/unittest/rtps/flowcontrol/CMakeLists.txt
@@ -50,6 +50,8 @@ target_compile_definitions(FlowControllerFactoryTests PRIVATE
 target_include_directories(FlowControllerFactoryTests PRIVATE
     ${Asio_INCLUDE_DIR}
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSWriter
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/Endpoint
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSReader
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSMessageGroup
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSParticipantImpl
     ${PROJECT_SOURCE_DIR}/include ${PROJECT_BINARY_DIR}/include
@@ -86,6 +88,8 @@ target_compile_definitions(FlowControllerPublishModesTests PRIVATE
 target_include_directories(FlowControllerPublishModesTests PRIVATE
     ${Asio_INCLUDE_DIR}
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSWriter
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/Endpoint
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSReader
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSMessageGroup
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSParticipantImpl
     ${PROJECT_SOURCE_DIR}/include ${PROJECT_BINARY_DIR}/include
@@ -118,6 +122,8 @@ target_compile_definitions(FlowControllerSchedulersTests PRIVATE
 target_include_directories(FlowControllerSchedulersTests PRIVATE
     ${Asio_INCLUDE_DIR}
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSWriter
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/Endpoint
+    ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSReader
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSMessageGroup
     ${PROJECT_SOURCE_DIR}/test/mock/rtps/RTPSParticipantImpl
     ${PROJECT_SOURCE_DIR}/include ${PROJECT_BINARY_DIR}/include