sntp/libevent/kqueue.c

78 	struct kevent *events;
141 	kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent));
142 	if (kqueueop->events == NULL)
153 	 * stick an error in events[0].  If kqueue is broken, then
157 		kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 ||
158 	    (int)kqueueop->events[0].ident != -1 ||
159 	    kqueueop->events[0].flags != EV_ERROR) {
243 	newresult = mm_realloc(kqop->events,
247 		kqop->events = newresult;
259 	struct kevent *events = kqop->events;
282 	/* Make sure that 'events' is at least as long as the list of changes:
284 	 * value from kevent() rather than as EV_ERROR events in the events
288 	 * retrying with a smaller changes array or a larger events array,
298 		events = kqop->events;
304 	    events, kqop->events_size, ts_p);
325 		if (events[i].flags & EV_ERROR) {
326 			switch (events[i].data) {
329 			 * watching any events on this fd.  That can
346 			 * all the registered events are also removed.
368 				/* Report read events, if we're listening for
372 				if (events[i].udata) {
385 				errno = events[i].data;
388 		} else if (events[i].filter == EVFILT_READ) {
390 		} else if (events[i].filter == EVFILT_WRITE) {
392 		} else if (events[i].filter == EVFILT_SIGNAL) {
395 		} else if (events[i].filter == EVFILT_USER) {
403 		if (events[i].filter == EVFILT_SIGNAL) {
404 			evmap_signal_active_(base, events[i].ident, 1);
406 			evmap_io_active_(base, events[i].ident, which | EV_ET);
411 		/* We used all the events space that we have. Maybe we should
424 	if (kqop->events)
425 		mm_free(kqop->events);
442 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p)
475 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p)
490 	/* Because we insert signal events