sntp/libevent/kqueue.c

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;
280 	/* Make sure that 'events' is at least as long as the list of changes:
282 	 * value from kevent() rather than as EV_ERROR events in the events
286 	 * retrying with a smaller changes array or a larger events array,
296 		events = kqop->events;
302 	    events, kqop->events_size, ts_p);
323 		if (events[i].flags & EV_ERROR) {
324 			switch (events[i].data) {
327 			 * watching any events on this fd.  That can
344 			 * all the registered events are also removed.
366 				/* Report read events, if we're listening for
370 				if (events[i].udata) {
383 				errno = events[i].data;
386 		} else if (events[i].filter == EVFILT_READ) {
388 		} else if (events[i].filter == EVFILT_WRITE) {
390 		} else if (events[i].filter == EVFILT_SIGNAL) {
393 		} else if (events[i].filter == EVFILT_USER) {
401 		if (events[i].filter == EVFILT_SIGNAL) {
402 			evmap_signal_active_(base, events[i].ident, 1);
404 			evmap_io_active_(base, events[i].ident, which | EV_ET);
409 		/* We used all the events space that we have. Maybe we should
422 	if (kqop->events)
423 		mm_free(kqop->events);
440 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p)
473 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p)
488 	/* Because we insert signal events