Fix for MQTT reconnection problems

MyIgel · fooker · commit 6b69a65bc5b1 · 2018-07-22T18:26:11.000+02:00
diff --git a/framework/managers/MqttConnectionManager.cpp b/framework/managers/MqttConnectionManager.cpp
@@ -61,8 +61,12 @@ void MqttConnectionManager::onDisconnected(TcpClient &client, bool flag) {
         LOG.log("Unreachable");
     }
 
-    this->state.set(State::DISCONNECTED);
-    this->reconnectTimer.start();
+    if (this->state == State::CONNECTED) {
+        this->state.set(State::DISCONNECTED);
+        this->reconnectTimer.start();
+    } else {
+        LOG.log("Error: Ignored disconnect while connecting");
+    }
 }
 
 void MqttConnectionManager::onMessageReceived(const String topic, const String message) {

Original file line number	Diff line number	Diff line change
`@@ -61,8 +61,12 @@ void MqttConnectionManager::onDisconnected(TcpClient &client, bool flag) {`
`61`	`61`	`LOG.log("Unreachable");`
`62`	`62`	`}`
`63`	`63`
`64`		`- this->state.set(State::DISCONNECTED);`
`65`		`- this->reconnectTimer.start();`
	`64`	`+ if (this->state == State::CONNECTED) {`
	`65`	`+ this->state.set(State::DISCONNECTED);`
	`66`	`+ this->reconnectTimer.start();`
	`67`	`+ } else {`
	`68`	`+ LOG.log("Error: Ignored disconnect while connecting");`
	`69`	`+ }`
`66`	`70`	`}`
`67`	`71`
`68`	`72`	`void MqttConnectionManager::onMessageReceived(const String topic, const String message) {`