Refs #21293: Temptative fix

Signed-off-by: Mario Dominguez <[email protected]>
eProsima · Jul 9, 2024 · 18b7f62 · 18b7f62
1 parent 4a5cfec
commit 18b7f62
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/src/cpp/rtps/writer/ReaderLocator.cpp b/src/cpp/rtps/writer/ReaderLocator.cpp
@@ -207,9 +207,9 @@ bool ReaderLocator::send(
     return true;
 }
 
-BaseReader* ReaderLocator::local_reader()
+BaseReader* ReaderLocator::local_reader(bool force_update)
 {
-    if (!local_reader_)
+    if (!local_reader_ || force_update)
     {
         local_reader_ = RTPSDomainImpl::find_local_reader(general_locator_info_.remote_guid);
     }

diff --git a/src/cpp/rtps/writer/ReaderLocator.hpp b/src/cpp/rtps/writer/ReaderLocator.hpp
@@ -67,7 +67,7 @@ class ReaderLocator : public RTPSMessageSenderInterface
         return is_local_reader_;
     }
 
-    BaseReader* local_reader();
+    BaseReader* local_reader(bool force_upload = false);
 
     void local_reader(
             BaseReader* local_reader)

diff --git a/src/cpp/rtps/writer/ReaderProxy.hpp b/src/cpp/rtps/writer/ReaderProxy.hpp
@@ -290,9 +290,9 @@ class ReaderProxy
      * Get the local reader on the same process (if any).
      * @return The local reader on the same process.
      */
-    inline BaseReader* local_reader()
+    inline BaseReader* local_reader(bool force_update = false)
     {
-        return locator_info_.local_reader();
+        return locator_info_.local_reader(force_update);
     }
 
     /**

diff --git a/src/cpp/rtps/writer/StatefulWriter.cpp b/src/cpp/rtps/writer/StatefulWriter.cpp
@@ -402,7 +402,7 @@ bool StatefulWriter::intraprocess_delivery(
         CacheChange_t* change,
         ReaderProxy* reader_proxy)
 {
-    BaseReader* reader = reader_proxy->local_reader();
+    BaseReader* reader = reader_proxy->local_reader(true);
     if (reader)
     {
         if (change->write_params.related_sample_identity() != SampleIdentity::unknown())

diff --git a/test/mock/rtps/ReaderLocator/rtps/writer/ReaderLocator.hpp b/test/mock/rtps/ReaderLocator/rtps/writer/ReaderLocator.hpp
@@ -202,7 +202,7 @@ class ReaderLocator : public RTPSMessageSenderInterface
         return false;
     }
 
-    BaseReader* local_reader()
+    BaseReader* local_reader(bool /*force_update*/)
     {
         return nullptr;
     }