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

Try to capture more events in kqueue.

This commit is contained in:
Calvin Rose 2023-10-08 10:52:27 -05:00
parent dc301305de
commit 555e0c0b85
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/core/ev.c
View File

@ -1628,7 +1628,6 @@ void janet_ev_deinit(void) {
* https://github.com/wahern/cqueues/blob/master/src/lib/kpoll.c * https://github.com/wahern/cqueues/blob/master/src/lib/kpoll.c
* NetBSD uses intptr_t while others use void * for .udata */ * NetBSD uses intptr_t while others use void * for .udata */
#define EV_SETx(ev, a, b, c, d, e, f) EV_SET((ev), (a), (b), (c), (d), (e), ((__typeof__((ev)->udata))(f))) #define EV_SETx(ev, a, b, c, d, e, f) EV_SET((ev), (a), (b), (c), (d), (e), ((__typeof__((ev)->udata))(f)))
#define JANET_KQUEUE_TF (EV_ADD | EV_ENABLE | EV_CLEAR | EV_ONESHOT)
#define JANET_KQUEUE_MIN_INTERVAL 0 #define JANET_KQUEUE_MIN_INTERVAL 0
/* NOTE: /* NOTE:
@ -1716,16 +1715,15 @@ void janet_loop1_impl(int has_timeout, JanetTimestamp timeout) {
if (!f) continue; if (!f) continue;
if (f->ev_callback && has_err) { if (f->ev_callback && has_err) {
f->ev_callback(f, JANET_ASYNC_EVENT_ERR); f->ev_callback(f, JANET_ASYNC_EVENT_ERR);
} else { }
if (f->ev_callback && (filt == EVFILT_READ) && f == stream->read_fiber) { if (f->ev_callback && (filt == EVFILT_READ) && f == stream->read_fiber) {
f->ev_callback(f, JANET_ASYNC_EVENT_READ); f->ev_callback(f, JANET_ASYNC_EVENT_READ);
} }
if (f->ev_callback && (filt == EVFILT_WRITE) && f == stream->write_fiber) { if (f->ev_callback && (filt == EVFILT_WRITE) && f == stream->write_fiber) {
f->ev_callback(f, JANET_ASYNC_EVENT_WRITE); f->ev_callback(f, JANET_ASYNC_EVENT_WRITE);
} }
if (f->ev_callback && has_hup) { if (f->ev_callback && has_hup) {
f->ev_callback(f, JANET_ASYNC_EVENT_HUP); f->ev_callback(f, JANET_ASYNC_EVENT_HUP);
}
} }
} }
janet_stream_checktoclose(stream); janet_stream_checktoclose(stream);