Commit aa8e1665282910d9900c900a5c3901ed9366bb1b
1 parent
23eea783
Fix not counting the non-packet-copy QoS path
Showing
1 changed file
with
1 additions
and
1 deletions
session.cpp
| @@ -231,7 +231,7 @@ void Session::writePacket(MqttPacket &packet, char max_qos, std::shared_ptr<Mqtt | @@ -231,7 +231,7 @@ void Session::writePacket(MqttPacket &packet, char max_qos, std::shared_ptr<Mqtt | ||
| 231 | 231 | ||
| 232 | qosInFlightCounter++; | 232 | qosInFlightCounter++; |
| 233 | assert(c); // with requiresRetransmission==false, there must be a client. | 233 | assert(c); // with requiresRetransmission==false, there must be a client. |
| 234 | - c->writeMqttPacketAndBlameThisClient(packet); | 234 | + count += c->writeMqttPacketAndBlameThisClient(packet); |
| 235 | } | 235 | } |
| 236 | } | 236 | } |
| 237 | } | 237 | } |