mqtt subscriber fb: component status protection

Author: viacheslauK

modules/mqtt_streaming_module/include/mqtt_streaming_module/mqtt_subscriber_fb_impl.h

@@ -86,6 +86,7 @@ class MqttSubscriberFbImpl final : public FunctionBlock
     std::mutex queueMutex;
     std::condition_variable queueCv;
     mutable std::recursive_mutex processingMutex;
+    std::mutex componentStatusMutex;
 
     DAQ_MQTT_STREAM_MODULE_API void onSignalsMessage(const mqtt::MqttAsyncClient& subscriber, const mqtt::MqttMessage& msg);
 

modules/mqtt_streaming_module/src/mqtt_subscriber_fb_impl.cpp

@@ -101,6 +101,8 @@ void MqttSubscriberFbImpl::updateStatuses()
     if (!statuses->isUpdated())
         return;
 
+    std::scoped_lock lock(componentStatusMutex);
+
     if (!jsonConfigErr.ok())
     {
         setComponentStatusWithMessage(ComponentStatus::Error, jsonConfigErr.buildStatusMessage());
@@ -508,7 +510,6 @@ void MqttSubscriberFbImpl::processMessageImpl(const mqtt::MqttMessage& msg, cons
             decoderFb->processMessage(jsonObjStr, epochTime);
         }
     }
-    updateStatuses();
 }
 
 void MqttSubscriberFbImpl::processingLoop()