Enforce atomic barrier to disable callbacks

Author: Miguel Barro

test/performance/throughput/ThroughputPublisher.hpp

@@ -166,13 +166,14 @@ class ThroughputPublisher
     class DataWriterListener : public eprosima::fastdds::dds::DataWriterListener
     {
         ThroughputPublisher& throughput_publisher_;
-        int matched_ = 0;
+        std::atomic_int matched_;
 
     public:
 
         DataWriterListener(
                 ThroughputPublisher& throughput_publisher)
             : throughput_publisher_(throughput_publisher)
+            , matched_(0)
         {
         }
 
@@ -197,13 +198,14 @@ class ThroughputPublisher
     class CommandWriterListener : public eprosima::fastdds::dds::DataWriterListener
     {
         ThroughputPublisher& throughput_publisher_;
-        int matched_ = 0;
+        std::atomic_int matched_;
 
     public:
 
         CommandWriterListener(
                 ThroughputPublisher& throughput_publisher)
             : throughput_publisher_(throughput_publisher)
+            , matched_(0)
         {
         }
 
@@ -227,13 +229,14 @@ class ThroughputPublisher
     class CommandReaderListener : public eprosima::fastdds::dds::DataReaderListener
     {
         ThroughputPublisher& throughput_publisher_;
-        int matched_ = 0;
+        std::atomic_int matched_;
 
     public:
 
         CommandReaderListener(
                 ThroughputPublisher& throughput_publisher)
             : throughput_publisher_(throughput_publisher)
+            , matched_(0)
         {
         }
 

test/performance/throughput/ThroughputSubscriber.hpp

@@ -144,14 +144,15 @@ class ThroughputSubscriber
         uint32_t last_seq_num_ = 0;
         uint32_t lost_samples_ = 0;
         eprosima::fastdds::dds::SampleInfo info_;
-        int matched_ = 0;
-        bool enable_ = false;
+        std::atomic_int matched_;
+        std::atomic_bool enable_;
 
     public:
 
         DataReaderListener(
                 ThroughputSubscriber& throughput_subscriber)
             : throughput_subscriber_(throughput_subscriber)
+            , matched_(0)
         {
         }
 
@@ -182,13 +183,14 @@ class ThroughputSubscriber
     class CommandReaderListener : public eprosima::fastdds::dds::DataReaderListener
     {
         ThroughputSubscriber& throughput_subscriber_;
-        int matched_ = 0;
+        std::atomic_int matched_;
 
     public:
 
         CommandReaderListener(
                 ThroughputSubscriber& throughput_subscriber)
             : throughput_subscriber_(throughput_subscriber)
+            , matched_(0)
         {
         }
 
@@ -212,13 +214,14 @@ class ThroughputSubscriber
     class CommandWriterListener : public eprosima::fastdds::dds::DataWriterListener
     {
         ThroughputSubscriber& throughput_subscriber_;
-        int matched_ = 0;
+        std::atomic_int matched_;
 
     public:
 
         CommandWriterListener(
                 ThroughputSubscriber& throughput_subscriber)
             : throughput_subscriber_(throughput_subscriber)
+            , matched_(0)
         {
         }