102 	struct event *ev;  member
155 	event_del(arg->ev);  in basic_read_cb()
179 	struct event *ev = arg;  in multiple_write_cb()  local
190 			event_del(ev);  in multiple_write_cb()
199 			event_del(ev);  in multiple_write_cb()
204 		if (event_add(ev, NULL) == -1)  in multiple_write_cb()
212 	struct event *ev = arg;  in multiple_read_cb()  local
220 			event_del(ev);  in multiple_read_cb()
226 		if (event_add(ev, NULL) == -1)  in multiple_read_cb()
238 	struct event ev;  member
256 	if (event_add(&both->ev, NULL) == -1)  in combined_read_cb()
282 	if (event_add(&both->ev, NULL) == -1)  in combined_write_cb()
298 	struct event ev;  in test_simpleread()  local
309 	event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev);  in test_simpleread()
310 	if (event_add(&ev, NULL) == -1)  in test_simpleread()
320 	struct event ev;  in test_simplewrite()  local
325 	event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev);  in test_simplewrite()
326 	if (event_add(&ev, NULL) == -1)  in test_simplewrite()
482 	struct event *ev = NULL;  in test_simpleclose()  local
492 	ev = event_new(base, pair[0], events, record_event_cb, &got_event);  in test_simpleclose()
493 	tt_assert(ev);  in test_simpleclose()
494 	tt_assert(!event_add(ev, NULL));  in test_simpleclose()
519 	if (ev)  in test_simpleclose()
520 		event_free(ev);  in test_simpleclose()
526 	struct event ev, ev2;  in test_multiple()  local
538 	event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev);  in test_multiple()
539 	if (event_add(&ev, NULL) == -1)  in test_multiple()
555 	struct event ev, ev2;  in test_persistent()  local
567 	event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev);  in test_persistent()
568 	if (event_add(&ev, NULL) == -1)  in test_persistent()
595 	event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1);  in test_combined()
596 	event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1);  in test_combined()
597 	event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2);  in test_combined()
598 	event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2);  in test_combined()
599 	tt_assert(event_add(&r1.ev, NULL) != -1);  in test_combined()
600 	tt_assert(!event_add(&w1.ev, NULL));  in test_combined()
601 	tt_assert(!event_add(&r2.ev, NULL));  in test_combined()
602 	tt_assert(!event_add(&w2.ev, NULL));  in test_combined()
616 	struct event ev;  in test_simpletimeout()  local
623 	evtimer_set(&ev, timeout_cb, NULL);  in test_simpletimeout()
624 	evtimer_add(&ev, &tv);  in test_simpletimeout()
653 	struct event ev;  in test_persistent_timeout()  local
659 	event_assign(&ev, global_base, -1, EV_TIMEOUT|EV_PERSIST,  in test_persistent_timeout()
661 	event_add(&ev, &tv);  in test_persistent_timeout()
665 	event_del(&ev);  in test_persistent_timeout()
672 	struct event ev;  in test_persistent_timeout_jump()  local
678 	event_assign(&ev, data->base, -1, EV_PERSIST, periodic_timeout_cb, &count);  in test_persistent_timeout_jump()
679 	event_add(&ev, &msec100);  in test_persistent_timeout_jump()
687 	event_del(&ev);  in test_persistent_timeout_jump()
699 	struct event *ev = arg;  in activate_cb()  local
700 	event_active(ev, EV_READ, 1);  in activate_cb()
718 	struct event ev;  in test_persistent_active_timeout()  local
728 	event_assign(&ev, base, -1, EV_TIMEOUT|EV_PERSIST,  in test_persistent_active_timeout()
730 	event_add(&ev, &tv);  in test_persistent_active_timeout()
734 	event_base_once(base, -1, EV_TIMEOUT, activate_cb, &ev, &tv2);  in test_persistent_active_timeout()
754 	event_del(&ev);  in test_persistent_active_timeout()
758 	struct event ev;  member
771 		event_del(&ti->ev);  in common_timeout_cb()
812 		event_assign(&info[i].ev, base, -1, EV_TIMEOUT|EV_PERSIST,  in test_common_timeout()
819 				event_add(&info[i].ev, ms_200);  in test_common_timeout()
820 				event_add(&info[i].ev, &tmp_100_ms);  in test_common_timeout()
823 				event_add(&info[i].ev, &tmp_200_ms);  in test_common_timeout()
824 				event_add(&info[i].ev, ms_100);  in test_common_timeout()
827 				event_add(&info[i].ev, ms_200);  in test_common_timeout()
828 				event_add(&info[i].ev, ms_100);  in test_common_timeout()
830 				event_add(&info[i].ev, ms_100);  in test_common_timeout()
833 			event_add(&info[i].ev, ms_200);  in test_common_timeout()
855 			event_add(&info[i].ev, ms_100);  in test_common_timeout()
857 			event_add(&info[i].ev, ms_200);  in test_common_timeout()
927 	struct event ev, sig_ev, usr_ev, existing_ev;  in test_fork()  local
951 	event_set(&ev, pair[1], EV_READ, simple_child_read_cb, &ev);  in test_fork()
952 	if (event_add(&ev, NULL) == -1)  in test_fork()
1056 	struct event ev;  in test_del_wait()  local
1061 	event_set(&ev, pair[1], EV_READ|EV_PERSIST, del_wait_cb, &ev);  in test_del_wait()
1062 	event_add(&ev, NULL);  in test_del_wait()
1078 		event_del(&ev);  in test_del_wait()
1100 	struct event ev;  in test_del_notify()  local
1105 	event_set(&ev, -1, EV_READ, null_cb, &ev);  in test_del_notify()
1106 	event_add(&ev, NULL);  in test_del_notify()
1115 	event_del(&ev);  in test_del_notify()
1129 	struct event *ev = arg;  in signal_cb()  local
1131 	evsignal_del(ev);  in signal_cb()
1138 	struct event ev;  in test_simplesignal_impl()  local
1141 	evsignal_set(&ev, SIGALRM, signal_cb, &ev);  in test_simplesignal_impl()
1142 	evsignal_add(&ev, NULL);  in test_simplesignal_impl()
1145 		evsignal_del(&ev);  in test_simplesignal_impl()
1146 		evsignal_add(&ev, NULL);  in test_simplesignal_impl()
1157 	if (evsignal_del(&ev) == -1)  in test_simplesignal_impl()
1211 	struct event ev;  in test_immediatesignal()  local
1214 	evsignal_set(&ev, SIGUSR1, signal_cb, &ev);  in test_immediatesignal()
1215 	evsignal_add(&ev, NULL);  in test_immediatesignal()
1218 	evsignal_del(&ev);  in test_immediatesignal()
1226 	struct event ev;  in test_signal_dealloc()  local
1228 	evsignal_set(&ev, SIGUSR1, signal_cb, &ev);  in test_signal_dealloc()
1229 	evsignal_add(&ev, NULL);  in test_signal_dealloc()
1230 	evsignal_del(&ev);  in test_signal_dealloc()
1319 	struct event ev;  in test_signal_assert()  local
1323 	evsignal_set(&ev, SIGCONT, signal_cb, &ev);  in test_signal_assert()
1324 	evsignal_add(&ev, NULL);  in test_signal_assert()
1329 	evsignal_del(&ev);  in test_signal_assert()
1354 	struct event ev;  in test_signal_restore()  local
1371 	evsignal_set(&ev, SIGUSR1, signal_cb, &ev);  in test_signal_restore()
1372 	evsignal_add(&ev, NULL);  in test_signal_restore()
1373 	evsignal_del(&ev);  in test_signal_restore()
1413 	struct event ev, ev_timer;  in test_signal_while_processing()  local
1420 	signal_set(&ev, SIGUSR1, signal_cb_swp, NULL);  in test_signal_while_processing()
1421 	signal_add(&ev, NULL);  in test_signal_while_processing()
1480 	struct event *ev = arg;  in event_selfarg_cb()  local
1481 	struct event_base *base = event_get_base(ev);  in event_selfarg_cb()
1484 	tt_want(ev == event_base_get_running_event(base));  in event_selfarg_cb()
1492 	struct event *ev = event_new(base, -1, EV_READ, event_selfarg_cb,  in test_event_new_selfarg()  local
1495 	event_active(ev, EV_READ, 1);  in test_event_new_selfarg()
1498 	event_free(ev);  in test_event_new_selfarg()
1506 	struct event ev;  in test_event_assign_selfarg()  local
1508 	event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,  in test_event_assign_selfarg()
1510 	event_active(&ev, EV_READ, 1);  in test_event_assign_selfarg()
1519 	struct event ev;  in test_event_base_get_num_events()  local
1530 	event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,  in test_event_base_get_num_events()
1533 	event_add(&ev, &qsec);  in test_event_base_get_num_events()
1559 	event_active(&ev, EV_READ, 1);  in test_event_base_get_num_events()
1643 	struct event ev;  in test_event_base_get_max_events()  local
1655 	event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,  in test_event_base_get_max_events()
1660 	event_add(&ev, &qsec);  in test_event_base_get_max_events()
1690 	event_active(&ev, EV_READ, 1);  in test_event_base_get_max_events()
1785 	struct event ev;  in test_bad_assign()  local
1788 	r = event_assign(&ev, NULL, -1, EV_SIGNAL|EV_READ, dummy_read_cb, NULL);  in test_bad_assign()
1816 	struct event ev;  in test_bad_reentrant()  local
1818 	event_assign(&ev, base, -1,  in test_bad_reentrant()
1821 	event_active(&ev, EV_WRITE, 1);  in test_bad_reentrant()
1930 	struct event **ev;  member
1944 	if(2 == rntp->count) event_del(rntp->ev[0]);  in read_not_timeout_cb()
1954 	struct event *ev[5];  in test_event_remove_timeout()  local
1960 	struct read_not_timeout_param rntp = { ev, 0, 0 };  in test_event_remove_timeout()
1964 	ev[0] = event_new(base, data->pair[0], EV_READ|EV_PERSIST,  in test_event_remove_timeout()
1966 	ev[1] = evtimer_new(base, incr_arg_cb, &ev1_fired);  in test_event_remove_timeout()
1967 	ev[2] = evtimer_new(base, remove_timers_cb, ev);  in test_event_remove_timeout()
1968 	ev[3] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);  in test_event_remove_timeout()
1969 	ev[4] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);  in test_event_remove_timeout()
1971 	event_add(ev[2], &ms25); /* remove timers */  in test_event_remove_timeout()
1972 	event_add(ev[4], &ms40); /* write to test if timer re-activates */  in test_event_remove_timeout()
1973 	event_add(ev[0], &ms75); /* read */  in test_event_remove_timeout()
1974 	event_add(ev[1], &ms75); /* timer */  in test_event_remove_timeout()
1975 	event_add(ev[3], &ms125); /* timeout. */  in test_event_remove_timeout()
1985 	event_free(ev[0]);  in test_event_remove_timeout()
1986 	event_free(ev[1]);  in test_event_remove_timeout()
1987 	event_free(ev[2]);  in test_event_remove_timeout()
1988 	event_free(ev[3]);  in test_event_remove_timeout()
1989 	event_free(ev[4]);  in test_event_remove_timeout()
2017 	args.ev = &ev1;  in test_event_base_new()
2037 	struct event ev;  in test_loopexit()  local
2043 	evtimer_set(&ev, timeout_cb, NULL);  in test_loopexit()
2044 	evtimer_add(&ev, &tv);  in test_loopexit()
2054 	evtimer_del(&ev);  in test_loopexit()
2201 	struct event ev;  member
2219 	event_add(&pri->ev, &tv);  in test_priorities_cb()
2235 	timeout_set(&one.ev, test_priorities_cb, &one);  in test_priorities_impl()
2236 	if (event_priority_set(&one.ev, 0) == -1) {  in test_priorities_impl()
2241 	timeout_set(&two.ev, test_priorities_cb, &two);  in test_priorities_impl()
2242 	if (event_priority_set(&two.ev, npriorities - 1) == -1) {  in test_priorities_impl()
2249 	if (event_add(&one.ev, &tv) == -1)  in test_priorities_impl()
2251 	if (event_add(&two.ev, &tv) == -1)  in test_priorities_impl()
2256 	event_del(&one.ev);  in test_priorities_impl()
2257 	event_del(&two.ev);  in test_priorities_impl()
2402 	struct event ev;  in test_want_only_once()  local
2417 	event_set(&ev, pair[1], EV_READ, read_once_cb, &ev);  in test_want_only_once()
2418 	if (event_add(&ev, NULL) == -1)  in test_want_only_once()
3096 	struct event *ev[MANY];  in test_many_events()  local
3106 	memset(ev, 0, sizeof(ev));  in test_many_events()
3117 		ev[i] = event_new(base, sock[i], EV_WRITE|evflags,  in test_many_events()
3119 		event_add(ev[i], NULL);  in test_many_events()
3135 		if (ev[i])  in test_many_events()
3136 			event_free(ev[i]);  in test_many_events()
3184 	const struct event *ev;  member
3188 foreach_count_cb(const struct event_base *base, const struct event *ev, void *arg)  in foreach_count_cb()  argument
3190 	struct foreach_helper *h = event_get_callback_arg(ev);  in foreach_count_cb()
3192 	if (event_get_callback(ev) != timeout_cb)  in foreach_count_cb()
3194 	tt_ptr_op(event_get_base(ev), ==, base);  in foreach_count_cb()
3196 	h->ev = ev;  in foreach_count_cb()
3204 foreach_find_cb(const struct event_base *base, const struct event *ev, void *arg)  in foreach_find_cb()  argument
3207 	struct foreach_helper *h = event_get_callback_arg(ev);  in foreach_find_cb()
3208 	if (event_get_callback(ev) != timeout_cb)  in foreach_find_cb()
3211 		*ev_out = ev;  in foreach_find_cb()
3222 	struct event *ev[5];  in test_event_foreach()  local
3230 		visited[i].ev = NULL;  in test_event_foreach()
3231 		ev[i] = event_new(base, -1, 0, timeout_cb, &visited[i]);  in test_event_foreach()
3237 	event_add(ev[0], &ten_sec);  in test_event_foreach()
3238 	event_add(ev[1], &ten_sec);  in test_event_foreach()
3239 	event_active(ev[1], EV_TIMEOUT, 1);  in test_event_foreach()
3240 	event_active(ev[2], EV_TIMEOUT, 1);  in test_event_foreach()
3241 	event_add(ev[3], &ten_sec);  in test_event_foreach()
3250 	tt_ptr_op(ev[0], ==, visited[0].ev);  in test_event_foreach()
3251 	tt_ptr_op(ev[1], ==, visited[1].ev);  in test_event_foreach()
3252 	tt_ptr_op(ev[2], ==, visited[2].ev);  in test_event_foreach()
3253 	tt_ptr_op(ev[3], ==, visited[3].ev);  in test_event_foreach()
3258 	tt_ptr_op(ev_found, ==, ev[2]);  in test_event_foreach()
3262 		event_free(ev[i]);  in test_event_foreach()