We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a7f3f4c commit fbe9470Copy full SHA for fbe9470
1 file changed
src/mux_kqueue.c
@@ -185,11 +185,10 @@ int mux_kqueue__handle(void)
185
for(int i=0; i<event_count; i++){
186
context = event_list[i].udata;
187
if(context->ident == id_client){
188
+ loop_handle_reads_writes(context, event_list[i].filter);
189
if(event_list[i].flags & (EV_EOF | EV_ERROR)){
190
do_disconnect(context, MOSQ_ERR_CONN_LOST);
- continue;
191
}
192
- loop_handle_reads_writes(context, event_list[i].filter);
193
}else if(context->ident == id_listener){
194
listensock = event_list[i].udata;
195
0 commit comments