Only track inflight messages for outgoing messages.

11 years ago · b80402baf0
parent 41f5d1fd43
commit b80402baf0
1 changed files with 0 additions and 3 deletions
--- 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;
 			}