Mirrors_Framework/mosquitto
1
0
Fork 0
mirror of https://github.com/eclipse-mosquitto/mosquitto.git synced 2026-09-25 19:34:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

Ensure all websockets outgoing buffer is used.

Browse Source
This commit is contained in:
Roger A. Light
2020-09-02 22:24:29 +01:00
parent bab8cc2a6b
commit 219f2c20d2
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/websockets.c
+5 -3
View File
@@ -274,8 +274,10 @@ static int callback_mqtt(struct libwebsocket_context *context,
return -1;
}
db__message_write_queued_out(db, mosq);
db__message_write_inflight_out_latest(db, mosq);
rc = db__message_write_inflight_out_latest(db, mosq);
if(rc) return -1;
rc = db__message_write_queued_out(db, mosq);
if(rc) return -1;
if(mosq->out_packet && !mosq->current_out_packet){
mosq->current_out_packet = mosq->out_packet;
@@ -285,7 +287,7 @@ static int callback_mqtt(struct libwebsocket_context *context,
}
}
if(mosq->current_out_packet && !lws_send_pipe_choked(mosq->wsi)){
while(mosq->current_out_packet && !lws_send_pipe_choked(mosq->wsi)){
packet = mosq->current_out_packet;
if(packet->pos == 0 && packet->to_process == packet->packet_length){