diff --git a/MQTTSNClient/src/MQTTSNClient.h b/MQTTSNClient/src/MQTTSNClient.h index 674d2f4..cc3385d 100644 --- a/MQTTSNClient/src/MQTTSNClient.h +++ b/MQTTSNClient/src/MQTTSNClient.h @@ -390,7 +390,7 @@ int MQTTSN::Client::readPacket(Timer& timer) int lenlen = 0; int datalen = 0; - #define MQTTSN_MIN_PACKET_LENGTH 3 + #define MQTTSN_MIN_PACKET_LENGTH 2 // 1. read the packet, datagram style if ((len = ipstack.read(readbuf, MAX_PACKET_SIZE, timer.left_ms())) < MQTTSN_MIN_PACKET_LENGTH) goto exit; diff --git a/MQTTSNPacket/src/MQTTSNPacket.c b/MQTTSNPacket/src/MQTTSNPacket.c index b367332..e6e8d8f 100644 --- a/MQTTSNPacket/src/MQTTSNPacket.c +++ b/MQTTSNPacket/src/MQTTSNPacket.c @@ -248,7 +248,7 @@ int MQTTSNstrlen(MQTTSNString MQTTSNString) int MQTTSNPacket_read(unsigned char* buf, int buflen, int (*getfn)(unsigned char*, int)) { int rc = MQTTSNPACKET_READ_ERROR; - const int MQTTSN_MIN_PACKET_LENGTH = 3; + const int MQTTSN_MIN_PACKET_LENGTH = 2; int len = 0; /* the length of the whole packet including length field */ int lenlen = 0; int datalen = 0;