andry/EMS-ESP32
1
0
Fork 0
mirror of https://github.com/emsesp/EMS-ESP32.git synced 2025-12-07 08:19:52 +03:00
Code Issues Packages Projects Releases Wiki Activity

latest asyncmqttclient dev changes - to safeguard against stuck connections

Browse Source
This commit is contained in:
proddy
2021-07-21 16:25:42 +02:00
parent a95837404a
commit 2fda59d7db
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/async-mqtt-client/src/AsyncMqttClient.cpp
View File

@@ -199,6 +199,8 @@ void AsyncMqttClient::_clear() {
_clearQueue(true); // keep session data for now _clearQueue(true); // keep session data for now
_parsingInformation.bufferState = AsyncMqttClientInternals::BufferState::NONE; _parsingInformation.bufferState = AsyncMqttClientInternals::BufferState::NONE;
_client.setRxTimeout(0);
} }
/* TCP */ /* TCP */
@@ -286,6 +288,7 @@ void AsyncMqttClient::_onData(char* data, size_t len) {
case AsyncMqttClientInternals::PacketType.CONNACK: case AsyncMqttClientInternals::PacketType.CONNACK:
log_i("rcv CONNACK"); log_i("rcv CONNACK");
_currentParsedPacket = new AsyncMqttClientInternals::ConnAckPacket(&_parsingInformation, std::bind(&AsyncMqttClient::_onConnAck, this, std::placeholders::_1, std::placeholders::_2)); _currentParsedPacket = new AsyncMqttClientInternals::ConnAckPacket(&_parsingInformation, std::bind(&AsyncMqttClient::_onConnAck, this, std::placeholders::_1, std::placeholders::_2));
_client.setRxTimeout(0);
break; break;
case AsyncMqttClientInternals::PacketType.PINGRESP: case AsyncMqttClientInternals::PacketType.PINGRESP:
log_i("rcv PINGRESP"); log_i("rcv PINGRESP");
@@ -708,6 +711,8 @@ void AsyncMqttClient::connect() {
log_i("CONNECTING"); log_i("CONNECTING");
_state = CONNECTING; _state = CONNECTING;
_client.setRxTimeout(_keepAlive);
#if ASYNC_TCP_SSL_ENABLED #if ASYNC_TCP_SSL_ENABLED
if (_useIp) { if (_useIp) {
_client.connect(_ip, _port, _secure); _client.connect(_ip, _port, _secure);