Commit 73dbbddd8af8ae260f68308e408a94f292cc1d71

Authored by Wiebe Cazemier
1 parent fc709a32

Debug log line for QoS queue

Showing 1 changed file with 4 additions and 0 deletions
session.cpp
... ... @@ -96,6 +96,10 @@ void Session::writePacket(const MqttPacket &packet, char max_qos)
96 96 // should be acked in order.
97 97 void Session::clearQosMessage(uint16_t packet_id)
98 98 {
  99 +#ifndef NDEBUG
  100 + logger->logf(LOG_DEBUG, "Clearing QoS message for '%s', packet id '%d'. Left in queue: %d", client_id.c_str(), packet_id, qosPacketQueue.size());
  101 +#endif
  102 +
99 103 std::lock_guard<std::mutex> locker(qosQueueMutex);
100 104  
101 105 auto it = qosPacketQueue.begin();
... ...