From b80402baf069de7a6d5b0705f503bab22873a9f4 Mon Sep 17 00:00:00 2001 From: "Roger A. Light" Date: Mon, 17 Nov 2014 20:20:50 +0000 Subject: [PATCH] Only track inflight messages for outgoing messages. --- lib/messages_mosq.c | 3 --- 1 file changed, 3 deletions(-) diff --git a/lib/messages_mosq.c b/lib/messages_mosq.c index 84afda76..eb10dcab 100644 --- a/lib/messages_mosq.c +++ b/lib/messages_mosq.c @@ -277,9 +277,6 @@ int _mosquitto_message_remove(struct mosquitto *mosq, uint16_t mid, enum mosquit }else if(!mosq->in_messages){ mosq->in_messages_last = NULL; } - if(cur->msg.qos == 2){ - mosq->inflight_messages--; - } found = true; break; }