diff --git a/lib/net_mosq.c b/lib/net_mosq.c index a22bc5a5..9f357ea9 100644 --- a/lib/net_mosq.c +++ b/lib/net_mosq.c @@ -747,6 +747,7 @@ int _mosquitto_packet_write(struct mosquitto *mosq) pthread_mutex_unlock(&mosq->out_packet_mutex); if(mosq->state == mosq_cs_connect_pending){ + pthread_mutex_unlock(&mosq->current_out_packet_mutex); return MOSQ_ERR_SUCCESS; }