Fix wrong usage of condition_variable (#2039)

Signed-off-by: Ricardo González Moreno <ricardo@richiware.dev> Signed-off-by: Miguel Company <miguelcompany@eprosima.com>
eProsima · Jul 2, 2021 · 9ee08b8 · 9ee08b8
1 parent 8c381ac
commit 9ee08b8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/test/blackbox/api/dds-pim/PubSubReader.hpp b/test/blackbox/api/dds-pim/PubSubReader.hpp
@@ -159,7 +159,10 @@ class PubSubReader
                 eprosima::fastdds::dds::DataReader* datareader) override
         {
             ASSERT_NE(datareader, nullptr);
-            reader_.message_receive_count_.fetch_add(1);
+            {
+                std::lock_guard<std::mutex> guard(reader_.message_receive_mutex_);
+                reader_.message_receive_count_.fetch_add(1);
+            }
             reader_.message_receive_cv_.notify_one();
 
             if (reader_.receiving_.load())