Refs 16192. Allowing wait without previous notification

Signed-off-by: Miguel Barro <miguelbarro@eprosima.com>
eProsima · Nov 21, 2022 · aa260da · aa260da
1 parent b95d811
commit aa260da
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/cpp/fastdds/core/condition/WaitSetImpl.cpp b/src/cpp/fastdds/core/condition/WaitSetImpl.cpp
@@ -104,7 +104,7 @@ ReturnCode_t WaitSetImpl::wait(
 {
     std::unique_lock<std::mutex> lock(mutex_);
     // last notification processed
-    unsigned int old_counter = 0;
+    unsigned int old_counter = notifications_ - 1;
 
     if (is_waiting_)
     {

diff --git a/src/cpp/fastdds/core/condition/WaitSetImpl.hpp b/src/cpp/fastdds/core/condition/WaitSetImpl.hpp
@@ -114,7 +114,7 @@ struct WaitSetImpl
     std::condition_variable cond_;
     eprosima::utilities::collections::unordered_vector<const Condition*> entries_;
     bool is_waiting_ = false;
-    std::atomic_uint notifications_ = {0};
+    std::atomic_uint notifications_ = {1};
 };
 
 }  // namespace detail