ee274e64f9
Patched until new upstream release is available. Patch sourced from upstream. Signed-off-by: Karl Palsson <karlp@remake.is>
12 lines
546 B
Diff
12 lines
546 B
Diff
diff --git a/lib/mosquitto.c b/lib/mosquitto.c
|
|
index bd9dbd3..7314248 100644
|
|
--- a/lib/mosquitto.c
|
|
+++ b/lib/mosquitto.c
|
|
@@ -594,7 +594,6 @@ int mosquitto_publish(struct mosquitto *mosq, int *mid, const char *topic, int p
|
|
pthread_mutex_lock(&mosq->out_message_mutex);
|
|
_mosquitto_message_queue(mosq, message, mosq_md_out);
|
|
if(mosq->max_inflight_messages == 0 || mosq->inflight_messages < mosq->max_inflight_messages){
|
|
- mosq->inflight_messages++;
|
|
if(qos == 1){
|
|
message->state = mosq_ms_wait_for_puback;
|
|
}else if(qos == 2){
|