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