Lines Matching full:events

81 	struct kevent *events;  member
144 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent)); in kq_init()
145 if (kqueueop->events == NULL) in kq_init()
156 * stick an error in events[0]. If kqueue is broken, then in kq_init()
160 kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 || in kq_init()
161 (int)kqueueop->events[0].ident != -1 || in kq_init()
162 !(kqueueop->events[0].flags & EV_ERROR)) { in kq_init()
254 newresult = mm_realloc(kqop->events, in kq_grow_events()
258 kqop->events = newresult; in kq_grow_events()
270 struct kevent *events = kqop->events; in kq_dispatch() local
294 /* Make sure that 'events' is at least as long as the list of changes: in kq_dispatch()
296 * value from kevent() rather than as EV_ERROR events in the events in kq_dispatch()
300 * retrying with a smaller changes array or a larger events array, in kq_dispatch()
310 events = kqop->events; in kq_dispatch()
316 events, kqop->events_size, ts_p); in kq_dispatch()
337 if (events[i].flags & EV_ERROR) { in kq_dispatch()
338 switch (events[i].data) { in kq_dispatch()
341 * watching any events on this fd. That can in kq_dispatch()
358 * all the registered events are also removed. in kq_dispatch()
380 /* Report read events, if we're listening for in kq_dispatch()
384 if (events[i].udata) { in kq_dispatch()
397 errno = events[i].data; in kq_dispatch()
400 } else if (events[i].filter == EVFILT_READ) { in kq_dispatch()
402 } else if (events[i].filter == EVFILT_WRITE) { in kq_dispatch()
404 } else if (events[i].filter == EVFILT_SIGNAL) { in kq_dispatch()
407 } else if (events[i].filter == EVFILT_USER) { in kq_dispatch()
415 if (events[i].filter == EVFILT_SIGNAL) { in kq_dispatch()
416 evmap_signal_active_(base, events[i].ident, 1); in kq_dispatch()
418 evmap_io_active_(base, events[i].ident, which | EV_ET); in kq_dispatch()
423 /* We used all the events space that we have. Maybe we should in kq_dispatch()
436 if (kqop->events) in kqop_free()
437 mm_free(kqop->events); in kqop_free()
454 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p) in kq_sig_add() argument
487 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p) in kq_sig_del() argument
502 /* Because we insert signal events in kq_sig_del()