Lines Matching refs:ev
273 evmap_io_add_(struct event_base *base, evutil_socket_t fd, struct event *ev) in evmap_io_add_() argument
282 EVUTIL_ASSERT(fd == ev->ev_fd); in evmap_io_add_()
307 if (ev->ev_events & EV_READ) { in evmap_io_add_()
311 if (ev->ev_events & EV_WRITE) { in evmap_io_add_()
315 if (ev->ev_events & EV_CLOSED) { in evmap_io_add_()
326 (old_ev->ev_events&EV_ET) != (ev->ev_events&EV_ET)) { in evmap_io_add_()
337 if (evsel->add(base, ev->ev_fd, in evmap_io_add_()
338 old, (ev->ev_events & EV_ET) | res, extra) == -1) in evmap_io_add_()
346 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next); in evmap_io_add_()
354 evmap_io_del_(struct event_base *base, evutil_socket_t fd, struct event *ev) in evmap_io_del_() argument
365 EVUTIL_ASSERT(fd == ev->ev_fd); in evmap_io_del_()
385 if (ev->ev_events & EV_READ) { in evmap_io_del_()
390 if (ev->ev_events & EV_WRITE) { in evmap_io_del_()
395 if (ev->ev_events & EV_CLOSED) { in evmap_io_del_()
403 if (evsel->del(base, ev->ev_fd, in evmap_io_del_()
404 old, (ev->ev_events & EV_ET) | res, extra) == -1) { in evmap_io_del_()
414 LIST_REMOVE(ev, ev_io_next); in evmap_io_del_()
424 struct event *ev; in evmap_io_active_() local
434 LIST_FOREACH(ev, &ctx->events, ev_io_next) { in evmap_io_active_()
435 if (ev->ev_events & (events & ~EV_ET)) in evmap_io_active_()
436 event_active_nolock_(ev, ev->ev_events & events, 1); in evmap_io_active_()
450 evmap_signal_add_(struct event_base *base, int sig, struct event *ev) in evmap_signal_add_() argument
468 if (evsel->add(base, ev->ev_fd, 0, EV_SIGNAL, NULL) in evmap_signal_add_()
473 LIST_INSERT_HEAD(&ctx->events, ev, ev_signal_next); in evmap_signal_add_()
479 evmap_signal_del_(struct event_base *base, int sig, struct event *ev) in evmap_signal_del_() argument
490 LIST_REMOVE(ev, ev_signal_next); in evmap_signal_del_()
493 if (evsel->del(base, ev->ev_fd, 0, EV_SIGNAL, NULL) == -1) in evmap_signal_del_()
505 struct event *ev; in evmap_signal_active_() local
513 LIST_FOREACH(ev, &ctx->events, ev_signal_next) in evmap_signal_active_()
514 event_active_nolock_(ev, EV_SIGNAL, ncalls); in evmap_signal_active_()
614 struct event *ev; local
627 (ev = LIST_FIRST(&ctx->events)) &&
628 (ev->ev_events & EV_ET))
670 struct event *ev; local
671 while ((ev = LIST_FIRST(dlist)))
672 event_del(ev);
955 struct event *ev; local
962 LIST_FOREACH(ev, &io_info->events, ev_io_next) {
963 EVUTIL_ASSERT(ev->ev_flags & EVLIST_INSERTED);
964 EVUTIL_ASSERT(ev->ev_fd == fd);
965 EVUTIL_ASSERT(!(ev->ev_events & EV_SIGNAL));
966 EVUTIL_ASSERT((ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED)));
967 if (ev->ev_events & EV_READ)
969 if (ev->ev_events & EV_WRITE)
971 if (ev->ev_events & EV_CLOSED)
988 struct event *ev; local
992 LIST_FOREACH(ev, &sig_info->events, ev_io_next) {
993 EVUTIL_ASSERT(ev->ev_flags & EVLIST_INSERTED);
994 EVUTIL_ASSERT(ev->ev_fd == signum);
995 EVUTIL_ASSERT((ev->ev_events & EV_SIGNAL));
996 EVUTIL_ASSERT(!(ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED)));
1025 struct event *ev; local
1027 LIST_FOREACH(ev, &io_info->events, ev_io_next) {
1028 if ((r = h->fn(base, ev, h->arg)))
1040 struct event *ev; local
1043 LIST_FOREACH(ev, &sig_info->events, ev_signal_next) {
1044 if ((r = h->fn(base, ev, h->arg)))