Lines Matching refs:events
76 struct kevent *events;
139 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent));
140 if (kqueueop->events == NULL)
151 * stick an error in events[0]. If kqueue is broken, then
155 kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 ||
156 (int)kqueueop->events[0].ident != -1 ||
157 !(kqueueop->events[0].flags & EV_ERROR)) {
241 newresult = mm_realloc(kqop->events,
245 kqop->events = newresult;
257 struct kevent *events = kqop->events;
281 /* Make sure that 'events' is at least as long as the list of changes:
283 * value from kevent() rather than as EV_ERROR events in the events
287 * retrying with a smaller changes array or a larger events array,
297 events = kqop->events;
303 events, kqop->events_size, ts_p);
324 if (events[i].flags & EV_ERROR) {
325 switch (events[i].data) {
328 * watching any events on this fd. That can
345 * all the registered events are also removed.
367 /* Report read events, if we're listening for
371 if (events[i].udata) {
384 errno = events[i].data;
387 } else if (events[i].filter == EVFILT_READ) {
389 } else if (events[i].filter == EVFILT_WRITE) {
391 } else if (events[i].filter == EVFILT_SIGNAL) {
394 } else if (events[i].filter == EVFILT_USER) {
402 if (events[i].filter == EVFILT_SIGNAL) {
403 evmap_signal_active_(base, events[i].ident, 1);
405 evmap_io_active_(base, events[i].ident, which | EV_ET);
410 /* We used all the events space that we have. Maybe we should
423 if (kqop->events)
424 mm_free(kqop->events);
441 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p)
474 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p)
489 /* Because we insert signal events
