Fix wrong usage of condition_variable [11927] (#2039)

* Refs #11676. Fix wrong usage of condition_variable Signed-off-by: Ricardo González Moreno <ricardo@richiware.dev> * Apply suggestion Co-authored-by: Miguel Company <miguelcompany@eprosima.com> Co-authored-by: Miguel Company <miguelcompany@eprosima.com>
eProsima · Jul 5, 2021 · eceb80e · eceb80e
1 parent 163380d
commit eceb80e
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())