sntp/libevent/evmap.c

55 /** An entry for an evmap_io list: notes all the events that want to read or
59 	struct event_dlist events;
65 /* An entry for an evmap_signal list: notes all the events that want to know
68 	struct event_dlist events;
256 	LIST_INIT(&entry->events);
313 		event_warnx("Too many events reading or writing on fd %d",
318 	    (old_ev = LIST_FIRST(&ctx->events)) &&
321 		    " events on fd %d", (int)fd);
339 	LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next);
412 evmap_io_active_(struct event_base *base, evutil_socket_t fd, short events)
426 	LIST_FOREACH(ev, &ctx->events, ev_io_next) {
427 		if (ev->ev_events & events)
428 			event_active_nolock_(ev, ev->ev_events & events, 1);
437 	LIST_INIT(&entry->events);
456 	if (LIST_EMPTY(&ctx->events)) {
462 	LIST_INSERT_HEAD(&ctx->events, ev, ev_signal_next);
481 	if (LIST_FIRST(&ctx->events) == NULL) {
502 	LIST_FOREACH(ev, &ctx->events, ev_signal_next)
522  * for which we could have EV_READ or EV_WRITE events.  For each such fd, call
525  * is an evmap_io structure containing a list of events pending on the
564  * event_base for which we could have signal events.  For each such signal,
567  * is an evmap_signal structure containing a list of events pending on the
593  * pending events, with the appropriate combination of EV_READ, EV_WRITE, and
602 	short events = 0;
608 		events |= EV_READ;
610 		events |= EV_WRITE;
612 		events |= EV_CLOSED;
615 	if (events &&
616 	    (ev = LIST_FIRST(&ctx->events)) &&
618 		events |= EV_ET;
619 	if (evsel->add(base, fd, 0, events, extra) == -1)
626  * have pending events.  */
634 	if (!LIST_EMPTY(&ctx->events)) {
670 	return delete_all_in_dlist(&io_info->events);
678 	return delete_all_in_dlist(&sig_info->events);
855 event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events,
872 	if (events & (EV_READ|EV_SIGNAL)) {
874 		    (events & (EV_ET|EV_PERSIST|EV_SIGNAL));
876 	if (events & EV_WRITE) {
878 		    (events & (EV_ET|EV_PERSIST|EV_SIGNAL));
880 	if (events & EV_CLOSED) {
882 		    (events & (EV_ET|EV_PERSIST|EV_SIGNAL));
890 event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events,
914 	   As this stands, it also lets through deletions of events that are
918 	if (events & (EV_READ|EV_SIGNAL)) {
924 	if (events & EV_WRITE) {
930 	if (events & EV_CLOSED) {
941 /* Helper for evmap_check_integrity_: verify that all of the events pending on
953 	EVUTIL_ASSERT_LIST_OK(&io_info->events, event, ev_io_next);
955 	LIST_FOREACH(ev, &io_info->events, ev_io_next) {
975 /* Helper for evmap_check_integrity_: verify that all of the events pending
983 	EVUTIL_ASSERT_LIST_OK(&sig_info->events, event, ev_signal_next);
985 	LIST_FOREACH(ev, &sig_info->events, ev_io_next) {
1020 	LIST_FOREACH(ev, &io_info->events, ev_io_next) {
1036 	LIST_FOREACH(ev, &sig_info->events, ev_signal_next) {