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

add ventilation bypass

Browse Source
This commit is contained in:
MichaelDvP
2023-06-04 15:32:43 +02:00
parent cbc9607b26
commit 181b672c1a
6 changed files with 76 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lib/espMqttClient/src/MqttClient.cpp
View File

@@ -577,7 +577,7 @@ void MqttClient::_onPubrec() {
while (it) {
// PUBRECs come in the order PUBs are sent. So we only check the first PUB packet in outbox
// if it doesn't match the ID, return
if ((it.get()->packet.packetType()) == PacketType.PUBLISH) {
if ((it.get()->packet.packetType()) == PacketType.PUBLISH || (it.get()->packet.packetType()) == PacketType.PUBREL) {
if (it.get()->packet.packetId() == idToMatch) {
if (!_addPacket(PacketType.PUBREL, idToMatch)) {
emc_log_e("Could not create PUBREL packet");
@@ -707,7 +707,9 @@ uint16_t MqttClient::getQueue() const {
espMqttClientInternals::Outbox<OutgoingPacket>::Iterator it = _outbox.front();
uint16_t count = 0;
while (it) {
++count;
if (it.get()->packet.packetType() == PacketType.PUBLISH) {
++count;
}
++it;
}
EMC_SEMAPHORE_GIVE();