Lines Matching defs:ev
217 struct event *ev;
227 for (ev = TAILQ_FIRST(&base->eventqueue); ev; ) {
228 struct event *next = TAILQ_NEXT(ev, ev_next);
229 if (!(ev->ev_flags & EVLIST_INTERNAL)) {
230 event_del(ev);
233 ev = next;
235 while ((ev = min_heap_top(&base->timeheap)) != NULL) {
236 event_del(ev);
241 for (ev = TAILQ_FIRST(base->activequeues[i]); ev; ) {
242 struct event *next = TAILQ_NEXT(ev, ev_active_next);
243 if (!(ev->ev_flags & EVLIST_INTERNAL)) {
244 event_del(ev);
247 ev = next;
280 struct event *ev;
305 TAILQ_FOREACH(ev, &base->eventqueue, ev_next) {
306 if (evsel->add(evbase, ev) == -1)
369 struct event *ev;
383 for (ev = TAILQ_FIRST(activeq); ev; ev = TAILQ_FIRST(activeq)) {
384 if (ev->ev_events & EV_PERSIST)
385 event_queue_remove(base, ev, EVLIST_ACTIVE);
387 event_del(ev);
390 ncalls = ev->ev_ncalls;
391 ev->ev_pncalls = &ncalls;
394 ev->ev_ncalls = ncalls;
395 (*ev->ev_callback)((int)ev->ev_fd, ev->ev_res, ev->ev_arg);
564 struct event ev;
614 evtimer_set(&eonce->ev, event_once_cb, eonce);
618 event_set(&eonce->ev, fd, events, event_once_cb, eonce);
625 res = event_base_set(base, &eonce->ev);
627 res = event_add(&eonce->ev, tv);
637 event_set(struct event *ev, int fd, short events,
641 ev->ev_base = current_base;
643 ev->ev_callback = callback;
644 ev->ev_arg = arg;
645 ev->ev_fd = fd;
646 ev->ev_events = events;
647 ev->ev_res = 0;
648 ev->ev_flags = EVLIST_INIT;
649 ev->ev_ncalls = 0;
650 ev->ev_pncalls = NULL;
652 min_heap_elem_init(ev);
656 ev->ev_pri = current_base->nactivequeues/2;
660 event_base_set(struct event_base *base, struct event *ev)
663 if (ev->ev_flags != EVLIST_INIT)
666 ev->ev_base = base;
667 ev->ev_pri = base->nactivequeues/2;
678 event_priority_set(struct event *ev, int pri)
680 if (ev->ev_flags & EVLIST_ACTIVE)
682 if (pri < 0 || pri >= ev->ev_base->nactivequeues)
685 ev->ev_pri = pri;
695 event_pending(struct event *ev, short event, struct timeval *tv)
700 if (ev->ev_flags & EVLIST_INSERTED)
701 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL));
702 if (ev->ev_flags & EVLIST_ACTIVE)
703 flags |= ev->ev_res;
704 if (ev->ev_flags & EVLIST_TIMEOUT)
711 gettime(ev->ev_base, &now);
712 evutil_timersub(&ev->ev_timeout, &now, &res);
722 event_add(struct event *ev, const struct timeval *tv)
724 struct event_base *base = ev->ev_base;
731 ev,
732 ev->ev_events & EV_READ ? "EV_READ " : " ",
733 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ",
735 ev->ev_callback));
737 assert(!(ev->ev_flags & ~EVLIST_ALL));
743 if (tv != NULL && !(ev->ev_flags & EVLIST_TIMEOUT)) {
749 if ((ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)) &&
750 !(ev->ev_flags & (EVLIST_INSERTED|EVLIST_ACTIVE))) {
751 res = evsel->add(evbase, ev);
753 event_queue_insert(base, ev, EVLIST_INSERTED);
767 if (ev->ev_flags & EVLIST_TIMEOUT)
768 event_queue_remove(base, ev, EVLIST_TIMEOUT);
773 if ((ev->ev_flags & EVLIST_ACTIVE) &&
774 (ev->ev_res & EV_TIMEOUT)) {
778 if (ev->ev_ncalls && ev->ev_pncalls) {
780 *ev->ev_pncalls = 0;
783 event_queue_remove(base, ev, EVLIST_ACTIVE);
787 evutil_timeradd(&now, tv, &ev->ev_timeout);
791 tv->tv_sec, ev->ev_callback));
793 event_queue_insert(base, ev, EVLIST_TIMEOUT);
800 event_del(struct event *ev)
807 ev, ev->ev_callback));
810 if (ev->ev_base == NULL)
813 base = ev->ev_base;
817 assert(!(ev->ev_flags & ~EVLIST_ALL));
820 if (ev->ev_ncalls && ev->ev_pncalls) {
822 *ev->ev_pncalls = 0;
825 if (ev->ev_flags & EVLIST_TIMEOUT)
826 event_queue_remove(base, ev, EVLIST_TIMEOUT);
828 if (ev->ev_flags & EVLIST_ACTIVE)
829 event_queue_remove(base, ev, EVLIST_ACTIVE);
831 if (ev->ev_flags & EVLIST_INSERTED) {
832 event_queue_remove(base, ev, EVLIST_INSERTED);
833 return (evsel->del(evbase, ev));
840 event_active(struct event *ev, int res, short ncalls)
843 if (ev->ev_flags & EVLIST_ACTIVE) {
844 ev->ev_res |= res;
848 ev->ev_res = res;
849 ev->ev_ncalls = ncalls;
850 ev->ev_pncalls = NULL;
851 event_queue_insert(ev->ev_base, ev, EVLIST_ACTIVE);
858 struct event *ev;
861 if ((ev = min_heap_top(&base->timeheap)) == NULL) {
870 if (evutil_timercmp(&ev->ev_timeout, &now, <=)) {
875 evutil_timersub(&ev->ev_timeout, &now, tv);
929 struct event *ev;
936 while ((ev = min_heap_top(&base->timeheap))) {
937 if (evutil_timercmp(&ev->ev_timeout, &now, >))
941 event_del(ev);
944 ev->ev_callback));
945 event_active(ev, EV_TIMEOUT, 1);
950 event_queue_remove(struct event_base *base, struct event *ev, int queue)
952 if (!(ev->ev_flags & queue))
954 ev, ev->ev_fd, queue);
956 if (~ev->ev_flags & EVLIST_INTERNAL)
959 ev->ev_flags &= ~queue;
962 TAILQ_REMOVE(&base->eventqueue, ev, ev_next);
966 TAILQ_REMOVE(base->activequeues[ev->ev_pri],
967 ev, ev_active_next);
970 min_heap_erase(&base->timeheap, ev);
978 event_queue_insert(struct event_base *base, struct event *ev, int queue)
980 if (ev->ev_flags & queue) {
986 ev, ev->ev_fd, queue);
989 if (~ev->ev_flags & EVLIST_INTERNAL)
992 ev->ev_flags |= queue;
995 TAILQ_INSERT_TAIL(&base->eventqueue, ev, ev_next);
999 TAILQ_INSERT_TAIL(base->activequeues[ev->ev_pri],
1000 ev,ev_active_next);
1003 min_heap_push(&base->timeheap, ev);