Lines Matching refs:EV_READ
309 event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); in test_simpleread()
354 event_set(&one, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
357 event_set(&two, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
431 rev = event_new(base, pair1[1], EV_READ, record_event_cb, in test_simpleclose_rw()
449 tt_int_op(got_read_on_close, ==, EV_READ); in test_simpleclose_rw()
541 event_set(&ev2, pair[1], EV_READ, multiple_read_cb, &ev2); in test_multiple()
570 event_set(&ev2, pair[1], EV_READ|EV_PERSIST, multiple_read_cb, &ev2); in test_persistent()
595 event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1); in test_combined()
597 event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2); in test_combined()
700 event_active(ev, EV_READ, 1); in activate_cb()
747 tt_int_op(res.events[0], ==, EV_READ); in test_persistent_active_timeout()
951 event_set(&ev, pair[1], EV_READ, simple_child_read_cb, &ev); in test_fork()
1061 event_set(&ev, pair[1], EV_READ|EV_PERSIST, del_wait_cb, &ev); in test_del_wait()
1105 event_set(&ev, -1, EV_READ, null_cb, &ev); in test_del_notify()
1441 event_assign(&ev1, base1, data->pair[1], EV_READ, dummy_read_cb, NULL); in test_free_active_base()
1448 event_active(&ev1, EV_READ, 1); in test_free_active_base()
1464 event_active(&ev1, EV_READ, 1); in test_manipulate_active_events()
1465 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
1466 ==, EV_READ); in test_manipulate_active_events()
1470 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
1471 ==, EV_READ|EV_WRITE); in test_manipulate_active_events()
1492 struct event *ev = event_new(base, -1, EV_READ, event_selfarg_cb, in test_event_new_selfarg()
1495 event_active(ev, EV_READ, 1); in test_event_new_selfarg()
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()
1530 event_assign(&ev, base, -1, EV_READ, event_selfarg_cb, in test_event_base_get_num_events()
1559 event_active(&ev, EV_READ, 1); in test_event_base_get_num_events()
1655 event_assign(&ev, base, -1, EV_READ, event_selfarg_cb, in test_event_base_get_max_events()
1657 event_assign(&ev2, base, -1, EV_READ, event_selfarg_cb, in test_event_base_get_max_events()
1690 event_active(&ev, EV_READ, 1); in test_event_base_get_max_events()
1788 r = event_assign(&ev, NULL, -1, EV_SIGNAL|EV_READ, dummy_read_cb, NULL); in test_bad_assign()
1854 event_active_later_(ev_activate, EV_READ); in activate_other_event_cb()
1864 ev1 = event_new(data->base, data->pair[0], EV_READ|EV_PERSIST, read_and_drain_cb, NULL); in test_active_later()
1870 event_active_later_(&ev3, EV_READ); in test_active_later()
1886 event_active_later_(&ev4, EV_READ); in test_active_later()
1887 event_active(&ev4, EV_READ, 1); /* This should make the event in test_active_later()
1894 event_active_later_(&ev3, EV_READ); in test_active_later()
1964 ev[0] = event_new(base, data->pair[0], EV_READ|EV_PERSIST, in test_event_remove_timeout()
1981 tt_int_op(rntp.events, ==, EV_READ); in test_event_remove_timeout()
2020 EV_READ|EV_PERSIST, basic_read_cb, &args); in test_event_base_new()
2170 tt_assert(!event_assign(&ev1, data->base, data->pair[0], EV_READ, re_add_read_cb, &ev2)); in test_nonpersist_readd()
2171 tt_assert(!event_assign(&ev2, data->base, data->pair[1], EV_READ, re_add_read_cb, &ev1)); in test_nonpersist_readd()
2188 tt_assert(event_pending(&ev1, EV_READ, NULL) && !event_pending(&ev2, EV_READ, NULL)); in test_nonpersist_readd()
2190 tt_assert(event_pending(&ev2, EV_READ, NULL) && !event_pending(&ev1, EV_READ, NULL)); in test_nonpersist_readd()
2295 event_active(&pai_events[1], EV_READ, 1); in prio_active_inversion_cb()
2338 if (event & EV_READ) in test_multiple_cb()
2351 event_set(&e1, pair[0], EV_READ, test_multiple_cb, NULL); in test_multiple_events_for_same_fd()
2417 event_set(&ev, pair[1], EV_READ, read_once_cb, &ev); in test_want_only_once()
2771 tt_int_op(event, ==, EV_READ); in read_called_once_cb()
2805 r = event_base_once(data->base, data->pair[0], EV_READ, in test_event_once()
2869 r = event_new(data->base, data->pair[0], EV_READ, simple_read_cb, in test_event_pending()
2883 tt_assert( event_pending(r, EV_READ, NULL)); in test_event_pending()
2886 tt_assert( event_pending(r, EV_READ|EV_WRITE, NULL)); in test_event_pending()
2929 e = event_new(data->base, data->pair[0], EV_READ, dfd_cb, &i); in test_event_closed_fd_poll()
2935 tt_assert(event_pending(e, EV_READ, NULL)); in test_event_closed_fd_poll()
2939 tt_int_op(i, ==, EV_READ); in test_event_closed_fd_poll()
2970 ev1 = event_new(base, fd, EV_READ|EV_PERSIST, dfd_cb, &ev1_got); in test_dup_fd()
2971 ev2 = event_new(base, dfd, EV_READ|EV_PERSIST, dfd_cb, &ev2_got); in test_dup_fd()
2976 tt_int_op(ev1_got, ==, EV_READ); in test_dup_fd()
2977 tt_int_op(ev2_got, ==, EV_READ); in test_dup_fd()
2986 tt_want_int_op(ev1_got, ==, EV_READ); in test_dup_fd()
3000 tt_want_int_op(ev1_got, ==, EV_READ); in test_dup_fd()
3165 ev1 = event_new(base, data->pair[1], EV_READ, dummy_read_cb, (void*)str); in test_get_assignment()
3170 tt_int_op(what, ==, EV_READ); in test_get_assignment()
3375 ev3 = event_new(base, INT_MAX, EV_READ, dummy_read_cb, (void *)base); in test_evmap_invalid_slots()
3376 ev4 = event_new(base, INT_MAX / 2, EV_READ, dummy_read_cb, (void *)base); in test_evmap_invalid_slots()
3408 event_base_active_by_fd(base, 1000, EV_READ); in test_active_by_fd()
3411 event_base_active_by_fd(base, -1, EV_READ); in test_active_by_fd()
3420 ev1 = event_new(base, data->pair[0], EV_READ, tabf_cb, &e1); in test_active_by_fd()
3422 ev3 = event_new(base, data->pair[1], EV_READ, tabf_cb, &e3); in test_active_by_fd()
3423 ev4 = event_new(base, data->pair[1], EV_READ, tabf_cb, &e4); in test_active_by_fd()
3444 event_base_active_by_fd(base, data->pair[1], EV_READ); in test_active_by_fd()
3456 tt_int_op(e3, ==, EV_READ | 0x10000); in test_active_by_fd()
3458 tt_int_op((e4 & ~EV_WRITE), ==, EV_READ | EV_TIMEOUT | 0x10000); in test_active_by_fd()