Skip to content

Commit 54ec751

Browse files
committed
Fix incorrectly increasing quota on PUBCOMP of stray IDs
1 parent 5d21e6c commit 54ec751

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

session.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -404,9 +404,10 @@ void Session::removeOutgoingQoS2MessageId(u_int16_t packet_id)
404404

405405
const auto it = qos_locked->outgoingQoS2MessageIds.find(packet_id);
406406
if (it != qos_locked->outgoingQoS2MessageIds.end())
407+
{
407408
qos_locked->outgoingQoS2MessageIds.erase(it);
408-
409-
qos_locked->increaseFlowControlQuota();
409+
qos_locked->increaseFlowControlQuota();
410+
}
410411
}
411412

412413
void Session::increaseFlowControlQuotaLocked()

0 commit comments

Comments
 (0)