From e310092f4488f413a835673537725def4c45de8d Mon Sep 17 00:00:00 2001
From: "Roger A. Light" <roger@atchoo.org>
Date: Sun, 8 Mar 2015 22:06:20 +0000
Subject: [PATCH] [461620] Inflight limits should only apply to outgoing
 messages.

Bug: https://bugs.eclipse.org/bugs/show_bug.cgi?id=461620
---
 ChangeLog.txt       | 3 +++
 lib/messages_mosq.c | 4 ++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/ChangeLog.txt b/ChangeLog.txt
index 10fdeaa4..1cb58adb 100644
--- a/ChangeLog.txt
+++ b/ChangeLog.txt
@@ -1,6 +1,9 @@
 Broker:
 - Fix possible crash when using pattern ACLs.
 
+Client library:
+- Inflight limits should only apply to outgoing messages. Closes #461620.
+
 
 1.4 - 20150218
 ==============
diff --git a/lib/messages_mosq.c b/lib/messages_mosq.c
index 7b9d9577..24598bbe 100644
--- a/lib/messages_mosq.c
+++ b/lib/messages_mosq.c
@@ -121,11 +121,11 @@ void _mosquitto_message_queue(struct mosquitto *mosq, struct mosquitto_message_a
 			mosq->out_messages = message;
 		}
 		mosq->out_messages_last = message;
-	}else{
-		mosq->in_queue_len++;
 		if(message->msg.qos > 0 && (mosq->max_inflight_messages == 0 || mosq->inflight_messages < mosq->max_inflight_messages)){
 			mosq->inflight_messages++;
 		}
+	}else{
+		mosq->in_queue_len++;
 		message->next = NULL;
 		if(mosq->in_messages_last){
 			mosq->in_messages_last->next = message;