pf/libevent/event.c

289 	struct event *ev;
306 	for (ev = TAILQ_FIRST(activeq); ev; ev = TAILQ_FIRST(activeq)) {
307 		event_queue_remove(base, ev, EVLIST_ACTIVE);
310 		ncalls = ev->ev_ncalls;
311 		ev->ev_pncalls = &ncalls;
314 			ev->ev_ncalls = ncalls;
315 			(*ev->ev_callback)((int)ev->ev_fd, ev->ev_res, ev->ev_arg);
445 	struct event ev;
488 		evtimer_set(&eonce->ev, event_once_cb, eonce);
492 		event_set(&eonce->ev, fd, events, event_once_cb, eonce);
499 	res = event_add(&eonce->ev, tv);
509 event_set(struct event *ev, int fd, short events,
513 	ev->ev_base = current_base;
515 	ev->ev_callback = callback;
516 	ev->ev_arg = arg;
517 	ev->ev_fd = fd;
518 	ev->ev_events = events;
519 	ev->ev_flags = EVLIST_INIT;
520 	ev->ev_ncalls = 0;
521 	ev->ev_pncalls = NULL;
524 	ev->ev_pri = current_base->nactivequeues/2;
528 event_base_set(struct event_base *base, struct event *ev)
531 	if (ev->ev_flags != EVLIST_INIT)
534 	ev->ev_base = base;
535 	ev->ev_pri = base->nactivequeues/2;
546 event_priority_set(struct event *ev, int pri)
548 	if (ev->ev_flags & EVLIST_ACTIVE)
550 	if (pri < 0 || pri >= ev->ev_base->nactivequeues)
553 	ev->ev_pri = pri;
563 event_pending(struct event *ev, short event, struct timeval *tv)
568 	if (ev->ev_flags & EVLIST_INSERTED)
569 		flags |= (ev->ev_events & (EV_READ|EV_WRITE));
570 	if (ev->ev_flags & EVLIST_ACTIVE)
571 		flags |= ev->ev_res;
572 	if (ev->ev_flags & EVLIST_TIMEOUT)
574 	if (ev->ev_flags & EVLIST_SIGNAL)
582 		timersub(&ev->ev_timeout, &now, &res);
592 event_add(struct event *ev, struct timeval *tv)
594 	struct event_base *base = ev->ev_base;
600 		 ev,
601 		 ev->ev_events & EV_READ ? "EV_READ " : " ",
602 		 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ",
604 		 ev->ev_callback));
606 	assert(!(ev->ev_flags & ~EVLIST_ALL));
611 		if (ev->ev_flags & EVLIST_TIMEOUT)
612 			event_queue_remove(base, ev, EVLIST_TIMEOUT);
617 		if ((ev->ev_flags & EVLIST_ACTIVE) &&
618 		    (ev->ev_res & EV_TIMEOUT)) {
622 			if (ev->ev_ncalls && ev->ev_pncalls) {
624 				*ev->ev_pncalls = 0;
627 			event_queue_remove(base, ev, EVLIST_ACTIVE);
631 		timeradd(&now, tv, &ev->ev_timeout);
635 			 tv->tv_sec, ev->ev_callback));
637 		event_queue_insert(base, ev, EVLIST_TIMEOUT);
640 	if ((ev->ev_events & (EV_READ|EV_WRITE)) &&
641 	    !(ev->ev_flags & (EVLIST_INSERTED|EVLIST_ACTIVE))) {
642 		event_queue_insert(base, ev, EVLIST_INSERTED);
644 		return (evsel->add(evbase, ev));
645 	} else if ((ev->ev_events & EV_SIGNAL) &&
646 	    !(ev->ev_flags & EVLIST_SIGNAL)) {
647 		event_queue_insert(base, ev, EVLIST_SIGNAL);
649 		return (evsel->add(evbase, ev));
656 event_del(struct event *ev)
663 		 ev, ev->ev_callback));
666 	if (ev->ev_base == NULL)
669 	base = ev->ev_base;
673 	assert(!(ev->ev_flags & ~EVLIST_ALL));
676 	if (ev->ev_ncalls && ev->ev_pncalls) {
678 		*ev->ev_pncalls = 0;
681 	if (ev->ev_flags & EVLIST_TIMEOUT)
682 		event_queue_remove(base, ev, EVLIST_TIMEOUT);
684 	if (ev->ev_flags & EVLIST_ACTIVE)
685 		event_queue_remove(base, ev, EVLIST_ACTIVE);
687 	if (ev->ev_flags & EVLIST_INSERTED) {
688 		event_queue_remove(base, ev, EVLIST_INSERTED);
689 		return (evsel->del(evbase, ev));
690 	} else if (ev->ev_flags & EVLIST_SIGNAL) {
691 		event_queue_remove(base, ev, EVLIST_SIGNAL);
692 		return (evsel->del(evbase, ev));
699 event_active(struct event *ev, int res, short ncalls)
702 	if (ev->ev_flags & EVLIST_ACTIVE) {
703 		ev->ev_res |= res;
707 	ev->ev_res = res;
708 	ev->ev_ncalls = ncalls;
709 	ev->ev_pncalls = NULL;
710 	event_queue_insert(ev->ev_base, ev, EVLIST_ACTIVE);
719 	struct event *ev;
721 	if ((ev = RB_MIN(event_tree, &base->timetree)) == NULL) {
729 	if (timercmp(&ev->ev_timeout, &now, <=)) {
734 	timersub(&ev->ev_timeout, &now, tv);
746 	struct event *ev;
752 	RB_FOREACH(ev, event_tree, &base->timetree)
753 		timersub(&ev->ev_timeout, off, &ev->ev_timeout);
760 	struct event *ev, *next;
764 	for (ev = RB_MIN(event_tree, &base->timetree); ev; ev = next) {
765 		if (timercmp(&ev->ev_timeout, &now, >))
767 		next = RB_NEXT(event_tree, &base->timetree, ev);
769 		event_queue_remove(base, ev, EVLIST_TIMEOUT);
772 		event_del(ev);
775 			 ev->ev_callback));
776 		event_active(ev, EV_TIMEOUT, 1);
781 event_queue_remove(struct event_base *base, struct event *ev, int queue)
785 	if (!(ev->ev_flags & queue))
787 			   ev, ev->ev_fd, queue);
789 	if (ev->ev_flags & EVLIST_INTERNAL)
795 	ev->ev_flags &= ~queue;
800 		TAILQ_REMOVE(base->activequeues[ev->ev_pri],
801 		    ev, ev_active_next);
804 		TAILQ_REMOVE(&signalqueue, ev, ev_signal_next);
807 		RB_REMOVE(event_tree, &base->timetree, ev);
810 		TAILQ_REMOVE(&base->eventqueue, ev, ev_next);
818 event_queue_insert(struct event_base *base, struct event *ev, int queue)
822 	if (ev->ev_flags & queue) {
828 			   ev, ev->ev_fd, queue);
831 	if (ev->ev_flags & EVLIST_INTERNAL)
837 	ev->ev_flags |= queue;
842 		TAILQ_INSERT_TAIL(base->activequeues[ev->ev_pri],
843 		    ev,ev_active_next);
846 		TAILQ_INSERT_TAIL(&signalqueue, ev, ev_signal_next);
849 		struct event *tmp = RB_INSERT(event_tree, &base->timetree, ev);
854 		TAILQ_INSERT_TAIL(&base->eventqueue, ev, ev_next);