Reset last RX to mills() after client connect

sandeepmistry · sandeepmistry · commit 383a2cae7b9c · 2019-01-11T16:22:03.000-05:00
diff --git a/src/MqttClient.cpp b/src/MqttClient.cpp
@@ -785,7 +785,6 @@ int MqttClient::connect(IPAddress ip, const char* host, uint16_t port)
   _rxState = MQTT_CLIENT_RX_STATE_READ_TYPE;
   _connected = false;
   _txPacketId = 0x0000;
-  _lastRx = 0;
 
   if (host) {
     if (!_client->connect(host, port)) {
@@ -799,6 +798,8 @@ int MqttClient::connect(IPAddress ip, const char* host, uint16_t port)
     }
   }
 
+  _lastRx = millis();
+
   String id = _id;
   int idLength = id.length();
   int usernameLength = _username.length();

Original file line number	Diff line number	Diff line change
`@@ -785,7 +785,6 @@ int MqttClient::connect(IPAddress ip, const char* host, uint16_t port)`
`785`	`785`	`_rxState = MQTT_CLIENT_RX_STATE_READ_TYPE;`
`786`	`786`	`_connected = false;`
`787`	`787`	`_txPacketId = 0x0000;`
`788`		`- _lastRx = 0;`
`789`	`788`
`790`	`789`	`if (host) {`
`791`	`790`	`if (!_client->connect(host, port)) {`
`@@ -799,6 +798,8 @@ int MqttClient::connect(IPAddress ip, const char* host, uint16_t port)`
`799`	`798`	`}`
`800`	`799`	`}`
`801`	`800`
	`801`	`+ _lastRx = millis();`
	`802`	`+`
`802`	`803`	`String id = _id;`
`803`	`804`	`int idLength = id.length();`
`804`	`805`	`int usernameLength = _username.length();`