diff --git a/lib/net_mosq.c b/lib/net_mosq.c index e8097b6d..1aee1dd0 100644 --- a/lib/net_mosq.c +++ b/lib/net_mosq.c @@ -871,7 +871,11 @@ int _mosquitto_packet_write(struct mosquitto *mosq) } pthread_mutex_unlock(&mosq->out_packet_mutex); +#if defined(WITH_TLS) && !defined(WITH_BROKER) + if((mosq->state == mosq_cs_connect_pending)||mosq->want_connect){ +#else if(mosq->state == mosq_cs_connect_pending){ +#endif pthread_mutex_unlock(&mosq->current_out_packet_mutex); return MOSQ_ERR_SUCCESS; }