Close websockets connection if we are set to disconnecting.

This commit is contained in:
Roger A. Light
2014-06-26 22:13:22 +01:00
parent 482d604598
commit 7f18ced0b4
+4
View File
@@ -138,6 +138,10 @@ static int callback_mqtt(struct libwebsocket_context *context,
case LWS_CALLBACK_SERVER_WRITEABLE:
mosq = u->mosq;
if(mosq->state == mosq_cs_disconnecting){
return -1;
}
if(mosq->out_packet && !mosq->current_out_packet){
mosq->current_out_packet = mosq->out_packet;
mosq->out_packet = mosq->out_packet->next;