arduino/Adafruit_MQTT_Library
1
0
Fork 0
mirror of https://github.com/adafruit/Adafruit_MQTT_Library.git synced 2025-11-03 11:53:11 +03:00
Code Activity

MQTT with QOS 1 or 2 forbids a packet ID of 0.

Browse Source
This commit is contained in:
Dan Lizotte
2021-04-02 18:09:40 -04:00
parent f63a37b6fb
commit 4f76558624
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
Adafruit_MQTT.cpp
View File

@@ -116,7 +116,7 @@ Adafruit_MQTT::Adafruit_MQTT(const char *server, uint16_t port, const char *cid,
will_qos = 0;
will_retain = 0;
packet_id_counter = 0;
packet_id_counter = 1; // MQTT spec forbids packet id of 0 if QOS=1
}
Adafruit_MQTT::Adafruit_MQTT(const char *server, uint16_t port,
@@ -137,7 +137,7 @@ Adafruit_MQTT::Adafruit_MQTT(const char *server, uint16_t port,
will_qos = 0;
will_retain = 0;
packet_id_counter = 0;
packet_id_counter = 1; // MQTT spec forbids packet id of 0 if QOS=1
}
int8_t Adafruit_MQTT::connect() {
@@ -342,7 +342,7 @@ bool Adafruit_MQTT::publish(const char *topic, uint8_t *data, uint16_t bLen,
// we increment the packet_id_counter right after publishing so inc here too
// to match
packnum++;
packnum = packnum + 1 + (packnum + 1 == 0); //Skip zero
if (packnum != packet_id_counter)
return false;
}
@@ -709,8 +709,8 @@ uint16_t Adafruit_MQTT::publishPacket(uint8_t *packet, const char *topic,
p[1] = packet_id_counter & 0xFF;
p += 2;
// increment the packet id
packet_id_counter++;
// increment the packet id, skipping 0
packet_id_counter = packet_id_counter + 1 + (packet_id_counter + 1 == 0);
}
memmove(p, data, bLen);
@@ -735,8 +735,8 @@ uint8_t Adafruit_MQTT::subscribePacket(uint8_t *packet, const char *topic,
p[1] = packet_id_counter & 0xFF;
p += 2;
// increment the packet id
packet_id_counter++;
// increment the packet id, skipping 0
packet_id_counter = packet_id_counter + 1 + (packet_id_counter + 1 == 0);
p = stringprint(p, topic);
@@ -764,8 +764,8 @@ uint8_t Adafruit_MQTT::unsubscribePacket(uint8_t *packet, const char *topic) {
p[1] = packet_id_counter & 0xFF;
p += 2;
// increment the packet id
packet_id_counter++;
// increment the packet id, skipping 0
packet_id_counter = packet_id_counter + 1 + (packet_id_counter + 1 == 0);
p = stringprint(p, topic);