Only increment inflight msgs when limit not reached.

10 years ago · fd6a6cac14
parent 11b70d0a95
commit fd6a6cac14
1 changed files with 3 additions and 3 deletions
--- a/lib/messages_mosq.c
+++ b/lib/messages_mosq.c
@ -192,10 +192,10 @@ void _mosquitto_messages_reconnect_reset(struct mosquitto *mosq)
 		mosq->out_queue_len++;
 		message->timestamp = 0;

-		if(message->msg.qos > 0){
-			mosq->inflight_messages++;
-		}
 		if(mosq->max_inflight_messages == 0 || mosq->inflight_messages < mosq->max_inflight_messages){
+			if(message->msg.qos > 0){
+				mosq->inflight_messages++;
+			}
 			if(message->msg.qos == 1){
 				message->state = mosq_ms_wait_for_puback;
 			}else if(message->msg.qos == 2){