mirrors
/
janet
mirror of https://github.com/janet-lang/janet
1
0
Fork 0
Code Issues 1 Releases Wiki Activity

Update kqueue

This commit is contained in:
Calvin Rose 2023-10-06 01:33:51 -05:00
parent 73291a30a0
commit d07f01d7cb
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/core/ev.c
View File

@ -1720,19 +1720,25 @@ void janet_loop1_impl(int has_timeout, JanetTimestamp timeout) {
if (rf) { if (rf) {
if (rf->ev_callback && has_err) { if (rf->ev_callback && has_err) {
rf->ev_callback(rf, JANET_ASYNC_EVENT_ERR); rf->ev_callback(rf, JANET_ASYNC_EVENT_ERR);
} else if (rf->ev_callback && (filt == EVFILT_READ)) { } else {
rf->ev_callback(rf, JANET_ASYNC_EVENT_READ); if (rf->ev_callback && (filt == EVFILT_READ)) {
} else if (rf->ev_callback && has_hup) { rf->ev_callback(rf, JANET_ASYNC_EVENT_READ);
rf->ev_callback(rf, JANET_ASYNC_EVENT_HUP); }
if (rf->ev_callback && has_hup) {
rf->ev_callback(rf, JANET_ASYNC_EVENT_HUP);
}
} }
} }
if (wf) { if (wf) {
if (wf->ev_callback && has_err) { if (wf->ev_callback && has_err) {
wf->ev_callback(wf, JANET_ASYNC_EVENT_ERR); wf->ev_callback(wf, JANET_ASYNC_EVENT_ERR);
} else if (wf->ev_callback && (filt == EVFILT_WRITE)) { } else {
wf->ev_callback(wf, JANET_ASYNC_EVENT_WRITE); if (wf->ev_callback && (filt == EVFILT_WRITE)) {
} else if (wf->ev_callback && has_hup) { wf->ev_callback(wf, JANET_ASYNC_EVENT_WRITE);
wf->ev_callback(wf, JANET_ASYNC_EVENT_HUP); }
if (wf->ev_callback && has_hup) {
wf->ev_callback(wf, JANET_ASYNC_EVENT_HUP);
}
} }
} }
janet_stream_checktoclose(stream); janet_stream_checktoclose(stream);