diff --git a/.settings/language.settings.xml b/.settings/language.settings.xml index 5aca929..7d5c34b 100644 --- a/.settings/language.settings.xml +++ b/.settings/language.settings.xml @@ -11,7 +11,7 @@ - + @@ -33,7 +33,7 @@ - + diff --git a/MQTTSNGateway/src/MQTTGWConnectionHandler.cpp b/MQTTSNGateway/src/MQTTGWConnectionHandler.cpp index 303bfe2..47ad782 100644 --- a/MQTTSNGateway/src/MQTTGWConnectionHandler.cpp +++ b/MQTTSNGateway/src/MQTTGWConnectionHandler.cpp @@ -90,13 +90,10 @@ void MQTTGWConnectionHandler::handlePingresp(Client* client, MQTTGWPacket* packe void MQTTGWConnectionHandler::handleDisconnect(Client* client, MQTTGWPacket* packet) { - if ( !client->isSleep() ) - { MQTTSNPacket* snPacket = new MQTTSNPacket(); snPacket->setDISCONNECT(0); client->disconnected(); client->getNetwork()->close(); Event* ev1 = new Event(); ev1->setClientSendEvent(client, snPacket); - } } diff --git a/MQTTSNGateway/src/MQTTSNGWClientRecvTask.cpp b/MQTTSNGateway/src/MQTTSNGWClientRecvTask.cpp index b927532..78b8c4b 100644 --- a/MQTTSNGateway/src/MQTTSNGWClientRecvTask.cpp +++ b/MQTTSNGateway/src/MQTTSNGWClientRecvTask.cpp @@ -262,7 +262,7 @@ void ClientRecvTask::log(Client* client, MQTTSNPacket* packet, MQTTSNString* id) void ClientRecvTask::log(const char* clientId, MQTTSNPacket* packet) { - char pbuf[SIZE_OF_LOG_PACKET * 3]; + char pbuf[ (SIZE_OF_LOG_PACKET + 3) * 3]; char msgId[6]; switch (packet->getType()) diff --git a/MQTTSNGateway/src/MQTTSNGWClientSendTask.cpp b/MQTTSNGateway/src/MQTTSNGWClientSendTask.cpp index 788d024..478f6fc 100644 --- a/MQTTSNGateway/src/MQTTSNGWClientSendTask.cpp +++ b/MQTTSNGateway/src/MQTTSNGWClientSendTask.cpp @@ -84,7 +84,7 @@ void ClientSendTask::run() void ClientSendTask::log(Client* client, MQTTSNPacket* packet) { - char pbuf[SIZE_OF_LOG_PACKET * 3]; + char pbuf[(SIZE_OF_LOG_PACKET + 3) * 3]; char msgId[6]; const char* clientId = client ? (const char*)client->getClientId() : UNKNOWNCL ; diff --git a/MQTTSNGateway/src/MQTTSNGWPacket.cpp b/MQTTSNGateway/src/MQTTSNGWPacket.cpp index 998eaf1..1494a2c 100644 --- a/MQTTSNGateway/src/MQTTSNGWPacket.cpp +++ b/MQTTSNGateway/src/MQTTSNGWPacket.cpp @@ -428,7 +428,7 @@ char* MQTTSNPacket::print(char* pbuf) int i = MQTTSNPacket_decode(_buf, _bufLen, &value); int size = _bufLen > SIZE_OF_LOG_PACKET ? SIZE_OF_LOG_PACKET : _bufLen; - for (; i < size; i++) + for (i = 0; i < size; i++) { sprintf(*pptr, " %02X", *(_buf + i)); *pptr += 3; diff --git a/MQTTSNGateway/src/MQTTSNGWVersion.h b/MQTTSNGateway/src/MQTTSNGWVersion.h index 1fd764c..ff9d6e1 100644 --- a/MQTTSNGateway/src/MQTTSNGWVersion.h +++ b/MQTTSNGateway/src/MQTTSNGWVersion.h @@ -17,6 +17,6 @@ #ifndef MQTTSNGWVERSION_H_IN_ #define MQTTSNGWVERSION_H_IN_ -#define PAHO_GATEWAY_VERSION "1.3.0" +#define PAHO_GATEWAY_VERSION "1.3.1" #endif /* MQTTSNGWVERSION_H_IN_ */