unused variables

viacheslauK · viacheslauK · commit 51c61cee4f06 · 2026-03-04T14:39:43.000+03:00
diff --git a/modules/mqtt_streaming_module/include/mqtt_streaming_module/atomic_signal_atomic_sample_handler.h b/modules/mqtt_streaming_module/include/mqtt_streaming_module/atomic_signal_atomic_sample_handler.h
@@ -28,7 +28,7 @@ class AtomicSignalAtomicSampleHandler : public HandlerBase
 
     MqttData processSignalContexts(std::vector<SignalContext>& signalContexts) override;
     ProcedureStatus validateSignalContexts(const std::vector<SignalContext>& signalContexts) const override;
-    ProcedureStatus signalListChanged(std::vector<SignalContext>& signalContexts) override
+    ProcedureStatus signalListChanged(std::vector<SignalContext>&) override
     {
         return ProcedureStatus{true, {}};
     };
diff --git a/modules/mqtt_streaming_module/include/mqtt_streaming_module/status_helper.h b/modules/mqtt_streaming_module/include/mqtt_streaming_module/status_helper.h
@@ -50,6 +50,7 @@ class StatusHelper
                                       const std::vector<std::pair<T, std::string>>& statusMap,
                                       TypeManagerPtr typeManager)
     {
+        (void)statusName;
         if (!typeManager.hasType(typeName))
         {
             auto list = List<IString>();
diff --git a/modules/mqtt_streaming_module/src/atomic_signal_atomic_sample_handler.cpp b/modules/mqtt_streaming_module/src/atomic_signal_atomic_sample_handler.cpp
@@ -119,9 +119,9 @@ MqttData AtomicSignalAtomicSampleHandler::processSignalContext(SignalContext& si
     return messages;
 }
 
-void AtomicSignalAtomicSampleHandler::processSignalDescriptorChanged(SignalContext& signalCtx,
-                                                   const DataDescriptorPtr& valueSigDesc,
-                                                   const DataDescriptorPtr& domainSigDesc)
+void AtomicSignalAtomicSampleHandler::processSignalDescriptorChanged(SignalContext&,
+                                                   const DataDescriptorPtr&,
+                                                   const DataDescriptorPtr&)
 {
 }
 
diff --git a/modules/mqtt_streaming_module/src/atomic_signal_sample_arr_handler.cpp b/modules/mqtt_streaming_module/src/atomic_signal_sample_arr_handler.cpp
@@ -107,8 +107,8 @@ std::pair<DataPacketPtr, size_t> AtomicSignalSampleArrayHandler::getSample(Signa
 }
 
 void AtomicSignalSampleArrayHandler::processSignalDescriptorChanged(SignalContext& signalCtx,
-                                                                    const DataDescriptorPtr& valueSigDesc,
-                                                                    const DataDescriptorPtr& domainSigDesc)
+                                                                    const DataDescriptorPtr&,
+                                                                    const DataDescriptorPtr&)
 {
     signalBuffers[signalCtx.inputPort.getSignal().getGlobalId().toStdString()].clear();
 }
diff --git a/modules/mqtt_streaming_module/src/group_signal_shared_ts_handler.cpp b/modules/mqtt_streaming_module/src/group_signal_shared_ts_handler.cpp
@@ -228,7 +228,7 @@ ProcedureStatus GroupSignalSharedTsHandler::signalListChanged(std::vector<Signal
     return status;
 }
 
-ListPtr<IString> GroupSignalSharedTsHandler::getTopics(const std::vector<SignalContext>& signalContexts)
+ListPtr<IString> GroupSignalSharedTsHandler::getTopics(const std::vector<SignalContext>&)
 {
     auto res = List<IString>(String(buildTopicName()));
     return res;
diff --git a/modules/mqtt_streaming_module/src/mqtt_json_decoder_fb_impl.cpp b/modules/mqtt_streaming_module/src/mqtt_json_decoder_fb_impl.cpp
@@ -74,7 +74,7 @@ void MqttJsonDecoderFbImpl::initProperties(const PropertyObjectPtr& config)
                 objPtr.addProperty(internalProp.clone());
                 objPtr.setPropertyValue(propName, prop.getValue());
                 objPtr.getOnPropertyValueWrite(prop.getName()) +=
-                    [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args) { propertyChanged(); };
+                    [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&) { propertyChanged(); };
             }
         }
         else
diff --git a/modules/mqtt_streaming_module/src/mqtt_publisher_fb_impl.cpp b/modules/mqtt_streaming_module/src/mqtt_publisher_fb_impl.cpp
@@ -162,7 +162,7 @@ PublisherFbConfig MqttPublisherFbImpl::getFbConfig() const
     return config;
 }
 
-void MqttPublisherFbImpl::onConnected(const InputPortPtr& inputPort)
+void MqttPublisherFbImpl::onConnected(const InputPortPtr&)
 {
     auto lock = this->getRecursiveConfigLock();
     auto lockProcessing = std::scoped_lock(processingMutex);
@@ -174,7 +174,7 @@ void MqttPublisherFbImpl::onConnected(const InputPortPtr& inputPort)
     updateStatuses();
 }
 
-void MqttPublisherFbImpl::onDisconnected(const InputPortPtr& inputPort)
+void MqttPublisherFbImpl::onDisconnected(const InputPortPtr&)
 {
     auto lock = this->getRecursiveConfigLock();
     auto lockProcessing = std::scoped_lock(processingMutex);
@@ -410,7 +410,7 @@ void MqttPublisherFbImpl::initProperties(const PropertyObjectPtr& config)
             {
                 objPtr.addProperty(internalProp.clone());
                 objPtr.setPropertyValue(propName, prop.getValue());
-                objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args)
+                objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&)
                 { propertyChanged(); };
             }
         }
diff --git a/modules/mqtt_streaming_module/src/mqtt_streaming_module_impl.cpp b/modules/mqtt_streaming_module/src/mqtt_streaming_module_impl.cpp
@@ -41,6 +41,8 @@ MqttStreamingModule::onCreateFunctionBlock(const StringPtr& id,
                                            const StringPtr& localId,
                                            const PropertyObjectPtr& config)
 {
+    (void)id;
+    (void)localId;
     if (!context.assigned())
         DAQ_THROW_EXCEPTION(InvalidParameterException, "Context is not available.");
 
diff --git a/modules/mqtt_streaming_module/src/mqtt_subscriber_fb_impl.cpp b/modules/mqtt_streaming_module/src/mqtt_subscriber_fb_impl.cpp
@@ -48,7 +48,7 @@ void MqttSubscriberFbImpl::removed()
     unsubscribeFromTopic();
 }
 
-void MqttSubscriberFbImpl::onSignalsMessage(const mqtt::MqttAsyncClient& subscriber, const mqtt::MqttMessage& msg)
+void MqttSubscriberFbImpl::onSignalsMessage(const mqtt::MqttAsyncClient&, const mqtt::MqttMessage& msg)
 {
     processMessage(msg);
 }
@@ -80,7 +80,7 @@ void MqttSubscriberFbImpl::initProperties(const PropertyObjectPtr& config)
                 {
                     objPtr.addProperty(internalProp.clone());
                     objPtr.setPropertyValue(propName, prop.getValue());
-                    objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args)
+                    objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&)
                     { propertyChanged(); };
                 }
             }
diff --git a/modules/mqtt_streaming_module/src/signal_arr_atomic_sample_handler.cpp b/modules/mqtt_streaming_module/src/signal_arr_atomic_sample_handler.cpp
@@ -116,12 +116,12 @@ ProcedureStatus SignalArrayAtomicSampleHandler::validateSignalContexts(const std
     return status;
 }
 
-ProcedureStatus SignalArrayAtomicSampleHandler::signalListChanged(std::vector<SignalContext>& signalContexts)
+ProcedureStatus SignalArrayAtomicSampleHandler::signalListChanged(std::vector<SignalContext>&)
 {
     return ProcedureStatus{true, {}};
 }
 
-ListPtr<IString> SignalArrayAtomicSampleHandler::getTopics(const std::vector<SignalContext>& signalContexts)
+ListPtr<IString> SignalArrayAtomicSampleHandler::getTopics(const std::vector<SignalContext>&)
 {
     auto res = List<IString>(String(buildTopicName()));
     return res;
diff --git a/shared/mqtt_streaming_protocol/src/MqttAsyncClient.cpp b/shared/mqtt_streaming_protocol/src/MqttAsyncClient.cpp
@@ -278,6 +278,7 @@ void MqttAsyncClient::onDeliveryCompleted(void* context, MQTTAsync_token token)
 
 void MqttAsyncClient::onConnected(void* context, char* cause)
 {
+    (void)cause;
     if (context != nullptr)
     {
         auto clienttInst = (MqttAsyncClient*)context;
@@ -304,6 +305,7 @@ void MqttAsyncClient::onConnectionLost(void* context, char* cause)
 
 int MqttAsyncClient::onMsgArrived(void* context, char* topicName, int topicLen, MQTTAsync_message* message)
 {
+    (void)topicLen;
     if (context != nullptr && message != nullptr)
     {
         MqttAsyncClient* client = (MqttAsyncClient*)context;
@@ -354,6 +356,7 @@ void MqttAsyncClient::onSendFailure(void* context, MQTTAsync_failureData* data)
 
 void MqttAsyncClient::onConnectSuccess(void* context, MQTTAsync_successData* data)
 {
+    (void)data;
     // TODO : check when this is called
     if (context != nullptr)
     {
@@ -364,6 +367,7 @@ void MqttAsyncClient::onConnectSuccess(void* context, MQTTAsync_successData* dat
 
 void MqttAsyncClient::onConnectFailure(void* context, MQTTAsync_failureData* data)
 {
+    (void)data;
     // TODO : check when this is called
     if (context != nullptr)
     {
@@ -374,6 +378,7 @@ void MqttAsyncClient::onConnectFailure(void* context, MQTTAsync_failureData* dat
 
 void MqttAsyncClient::onDisconnectSuccess(void* context, MQTTAsync_successData* data)
 {
+    (void)data;
     // TODO : check when this is called
     if (context != nullptr)
     {
@@ -388,6 +393,7 @@ void MqttAsyncClient::onDisconnectSuccess(void* context, MQTTAsync_successData*
 
 void MqttAsyncClient::onDisconnectFailure(void* context, MQTTAsync_failureData* data)
 {
+    (void)data;
     // TODO : check when this is called
     if (context != nullptr)
     {
@@ -402,10 +408,14 @@ void MqttAsyncClient::onDisconnectFailure(void* context, MQTTAsync_failureData*
 
 void MqttAsyncClient::onSubscribeSuccess(void* context, MQTTAsync_successData* response)
 {
+    (void)context;
+    (void)response;
 }
 
 void MqttAsyncClient::onSubscribeFailure(void* context, MQTTAsync_failureData* response)
 {
+    (void)context;
+    (void)response;
 }
 
 void MqttAsyncClient::onUnsubscribeSuccess(void* context, MQTTAsync_successData* response)
diff --git a/shared/mqtt_streaming_protocol/tests/MqttAsyncClientWrapper.cpp b/shared/mqtt_streaming_protocol/tests/MqttAsyncClientWrapper.cpp
@@ -143,7 +143,7 @@ void MqttAsyncClientWrapper::expectMsgs(const std::string& topic,
                                         std::atomic<bool>& done)
 {
     instance->setMessageArrivedCb(topic,
-                                  [topic, &done, &msgs, &promise, i = size_t(0)](const mqtt::MqttAsyncClient& subscriber,
+                                  [topic, &done, &msgs, &promise, i = size_t(0)](const mqtt::MqttAsyncClient&,
                                                                          mqtt::MqttMessage& receivedMsg) mutable
                                   {
                                       const auto receivedStr = receivedMsg.toString();
@@ -163,7 +163,7 @@ void MqttAsyncClientWrapper::expectMultiMsgs(const std::string& topic,
                                         std::atomic<bool>& done)
 {
     instance->setMessageArrivedCb(topic,
-                                  [topic, &done, localMsgs = msgs, &promise](const mqtt::MqttAsyncClient& subscriber,
+                                  [topic, &done, localMsgs = msgs, &promise](const mqtt::MqttAsyncClient&,
                                                                                  mqtt::MqttMessage& receivedMsg) mutable
                                   {
                                       const auto receivedStr = receivedMsg.toString();
diff --git a/shared/mqtt_streaming_protocol/tests/test_mqtt_streaming_protocol.cpp b/shared/mqtt_streaming_protocol/tests/test_mqtt_streaming_protocol.cpp
@@ -129,6 +129,7 @@ TEST_F(MqttStreamingProtocolTest, PublishingWithoutDataControl)
     std::promise<bool> sendPromise;
     auto sendFuture = sendPromise.get_future();
     instance->setSentCb([promise = &sendPromise, token = &result.token, &sendDone](int receivedToken, bool result) {
+        (void)result;
         bool expected = false;
         if (receivedToken == *token) {
             if (sendDone.compare_exchange_strong(expected, true)) {
@@ -207,9 +208,8 @@ TEST_F(MqttStreamingProtocolTest, PublishingRetainedWithReceivingControl)
     std::atomic<bool> done{false};
     subscriber.instance
         ->setMessageArrivedCb(msg.getTopic(),
-                              [&msg,
-                               &done,
-                               promise = &receivedPromise](const mqtt::MqttAsyncClient &subscriber,
+                              [&done,
+                               promise = &receivedPromise](const mqtt::MqttAsyncClient &,
                                                            mqtt::MqttMessage &receivedMsg) {
                                   if (receivedMsg.getData().empty()) {
                                       return;
@@ -250,9 +250,8 @@ TEST_F(MqttStreamingProtocolTest, PublishingWithReceivingControl)
     std::atomic<bool> done{false};
     subscriber.instance
         ->setMessageArrivedCb(msg.getTopic(),
-                              [&msg,
-                               &done,
-                               promise = &receivedPromise](const mqtt::MqttAsyncClient &subscriber,
+                              [&done,
+                               promise = &receivedPromise](const mqtt::MqttAsyncClient &,
                                                            mqtt::MqttMessage &receivedMsg) {
                                   if (receivedMsg.getData().empty()) {
                                       return;

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@ class AtomicSignalAtomicSampleHandler : public HandlerBase`
`28`	`28`
`29`	`29`	`MqttData processSignalContexts(std::vector<SignalContext>& signalContexts) override;`
`30`	`30`	`ProcedureStatus validateSignalContexts(const std::vector<SignalContext>& signalContexts) const override;`
`31`		`- ProcedureStatus signalListChanged(std::vector<SignalContext>& signalContexts) override`
	`31`	`+ ProcedureStatus signalListChanged(std::vector<SignalContext>&) override`
`32`	`32`	`{`
`33`	`33`	`return ProcedureStatus{true, {}};`
`34`	`34`	`};`
Original file line number	Diff line number	Diff line change
`@@ -50,6 +50,7 @@ class StatusHelper`
`50`	`50`	`const std::vector<std::pair<T, std::string>>& statusMap,`
`51`	`51`	`TypeManagerPtr typeManager)`
`52`	`52`	`{`
	`53`	`+ (void)statusName;`
`53`	`54`	`if (!typeManager.hasType(typeName))`
`54`	`55`	`{`
`55`	`56`	`auto list = List<IString>();`
Original file line number	Diff line number	Diff line change
`@@ -119,9 +119,9 @@ MqttData AtomicSignalAtomicSampleHandler::processSignalContext(SignalContext& si`
`119`	`119`	`return messages;`
`120`	`120`	`}`
`121`	`121`
`122`		`-void AtomicSignalAtomicSampleHandler::processSignalDescriptorChanged(SignalContext& signalCtx,`
`123`		`- const DataDescriptorPtr& valueSigDesc,`
`124`		`- const DataDescriptorPtr& domainSigDesc)`
	`122`	`+void AtomicSignalAtomicSampleHandler::processSignalDescriptorChanged(SignalContext&,`
	`123`	`+ const DataDescriptorPtr&,`
	`124`	`+ const DataDescriptorPtr&)`
`125`	`125`	`{`
`126`	`126`	`}`
`127`	`127`
Original file line number	Diff line number	Diff line change
`@@ -107,8 +107,8 @@ std::pair<DataPacketPtr, size_t> AtomicSignalSampleArrayHandler::getSample(Signa`
`107`	`107`	`}`
`108`	`108`
`109`	`109`	`void AtomicSignalSampleArrayHandler::processSignalDescriptorChanged(SignalContext& signalCtx,`
`110`		`- const DataDescriptorPtr& valueSigDesc,`
`111`		`- const DataDescriptorPtr& domainSigDesc)`
	`110`	`+ const DataDescriptorPtr&,`
	`111`	`+ const DataDescriptorPtr&)`
`112`	`112`	`{`
`113`	`113`	`signalBuffers[signalCtx.inputPort.getSignal().getGlobalId().toStdString()].clear();`
`114`	`114`	`}`
Original file line number	Diff line number	Diff line change
`@@ -228,7 +228,7 @@ ProcedureStatus GroupSignalSharedTsHandler::signalListChanged(std::vector<Signal`
`228`	`228`	`return status;`
`229`	`229`	`}`
`230`	`230`
`231`		`-ListPtr<IString> GroupSignalSharedTsHandler::getTopics(const std::vector<SignalContext>& signalContexts)`
	`231`	`+ListPtr<IString> GroupSignalSharedTsHandler::getTopics(const std::vector<SignalContext>&)`
`232`	`232`	`{`
`233`	`233`	`auto res = List<IString>(String(buildTopicName()));`
`234`	`234`	`return res;`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ void MqttJsonDecoderFbImpl::initProperties(const PropertyObjectPtr& config)`
`74`	`74`	`objPtr.addProperty(internalProp.clone());`
`75`	`75`	`objPtr.setPropertyValue(propName, prop.getValue());`
`76`	`76`	`objPtr.getOnPropertyValueWrite(prop.getName()) +=`
`77`		`- [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args) { propertyChanged(); };`
	`77`	`+ [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&) { propertyChanged(); };`
`78`	`78`	`}`
`79`	`79`	`}`
`80`	`80`	`else`
Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ PublisherFbConfig MqttPublisherFbImpl::getFbConfig() const`
`162`	`162`	`return config;`
`163`	`163`	`}`
`164`	`164`
`165`		`-void MqttPublisherFbImpl::onConnected(const InputPortPtr& inputPort)`
	`165`	`+void MqttPublisherFbImpl::onConnected(const InputPortPtr&)`
`166`	`166`	`{`
`167`	`167`	`auto lock = this->getRecursiveConfigLock();`
`168`	`168`	`auto lockProcessing = std::scoped_lock(processingMutex);`
`@@ -174,7 +174,7 @@ void MqttPublisherFbImpl::onConnected(const InputPortPtr& inputPort)`
`174`	`174`	`updateStatuses();`
`175`	`175`	`}`
`176`	`176`
`177`		`-void MqttPublisherFbImpl::onDisconnected(const InputPortPtr& inputPort)`
	`177`	`+void MqttPublisherFbImpl::onDisconnected(const InputPortPtr&)`
`178`	`178`	`{`
`179`	`179`	`auto lock = this->getRecursiveConfigLock();`
`180`	`180`	`auto lockProcessing = std::scoped_lock(processingMutex);`
`@@ -410,7 +410,7 @@ void MqttPublisherFbImpl::initProperties(const PropertyObjectPtr& config)`
`410`	`410`	`{`
`411`	`411`	`objPtr.addProperty(internalProp.clone());`
`412`	`412`	`objPtr.setPropertyValue(propName, prop.getValue());`
`413`		`- objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args)`
	`413`	`+ objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&)`
`414`	`414`	`{ propertyChanged(); };`
`415`	`415`	`}`
`416`	`416`	`}`
Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,8 @@ MqttStreamingModule::onCreateFunctionBlock(const StringPtr& id,`
`41`	`41`	`const StringPtr& localId,`
`42`	`42`	`const PropertyObjectPtr& config)`
`43`	`43`	`{`
	`44`	`+ (void)id;`
	`45`	`+ (void)localId;`
`44`	`46`	`if (!context.assigned())`
`45`	`47`	`DAQ_THROW_EXCEPTION(InvalidParameterException, "Context is not available.");`
`46`	`48`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ void MqttSubscriberFbImpl::removed()`
`48`	`48`	`unsubscribeFromTopic();`
`49`	`49`	`}`
`50`	`50`
`51`		`-void MqttSubscriberFbImpl::onSignalsMessage(const mqtt::MqttAsyncClient& subscriber, const mqtt::MqttMessage& msg)`
	`51`	`+void MqttSubscriberFbImpl::onSignalsMessage(const mqtt::MqttAsyncClient&, const mqtt::MqttMessage& msg)`
`52`	`52`	`{`
`53`	`53`	`processMessage(msg);`
`54`	`54`	`}`
`@@ -80,7 +80,7 @@ void MqttSubscriberFbImpl::initProperties(const PropertyObjectPtr& config)`
`80`	`80`	`{`
`81`	`81`	`objPtr.addProperty(internalProp.clone());`
`82`	`82`	`objPtr.setPropertyValue(propName, prop.getValue());`
`83`		`- objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr& obj, PropertyValueEventArgsPtr& args)`
	`83`	`+ objPtr.getOnPropertyValueWrite(prop.getName()) += [this](PropertyObjectPtr&, PropertyValueEventArgsPtr&)`
`84`	`84`	`{ propertyChanged(); };`
`85`	`85`	`}`
`86`	`86`	`}`
Original file line number	Diff line number	Diff line change
`@@ -116,12 +116,12 @@ ProcedureStatus SignalArrayAtomicSampleHandler::validateSignalContexts(const std`
`116`	`116`	`return status;`
`117`	`117`	`}`
`118`	`118`
`119`		`-ProcedureStatus SignalArrayAtomicSampleHandler::signalListChanged(std::vector<SignalContext>& signalContexts)`
	`119`	`+ProcedureStatus SignalArrayAtomicSampleHandler::signalListChanged(std::vector<SignalContext>&)`
`120`	`120`	`{`
`121`	`121`	`return ProcedureStatus{true, {}};`
`122`	`122`	`}`
`123`	`123`
`124`		`-ListPtr<IString> SignalArrayAtomicSampleHandler::getTopics(const std::vector<SignalContext>& signalContexts)`
	`124`	`+ListPtr<IString> SignalArrayAtomicSampleHandler::getTopics(const std::vector<SignalContext>&)`
`125`	`125`	`{`
`126`	`126`	`auto res = List<IString>(String(buildTopicName()));`
`127`	`127`	`return res;`