Home
last modified time | relevance | path

Searched refs:EV_READ (Results 1 – 25 of 117) sorted by relevance

12345

/freebsd-14.2/contrib/ntp/sntp/libevent/test/
H A Dregress_et.c106 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
153 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
155 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
161 tt_int_op(EV_READ, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
162 tt_int_op(0, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
168 tt_int_op(EV_READ, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
169 tt_int_op(0, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
227 read_ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, in test_edge_triggered_multiple_events()
H A Dregress_bufferevent.c114 bufferevent_disable(bev, EV_READ); in readcb()
178 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
179 bufferevent_enable(bev2, EV_READ); in test_bufferevent_impl()
382 bufferevent_disable(bev, EV_READ); in wm_readcb()
428 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
589 bufferevent_enable(bev2, EV_READ); in test_bufferevent_filters_impl()
692 bufferevent_enable(bev, EV_READ); in reader_eventcb()
782 bufferevent_enable(bev1, EV_READ); in test_bufferevent_connect()
783 bufferevent_enable(bev2, EV_READ); in test_bufferevent_connect()
1132 bufferevent_trigger(bev, EV_READ, in trigger_readcb()
[all …]
H A Dregress.c700 event_active(ev, EV_READ, 1); in activate_cb()
1466 ==, EV_READ); in test_manipulate_active_events()
1471 ==, EV_READ|EV_WRITE); in test_manipulate_active_events()
1495 event_active(ev, EV_READ, 1); in test_event_new_selfarg()
1510 event_active(&ev, EV_READ, 1); in test_event_assign_selfarg()
1559 event_active(&ev, EV_READ, 1); in test_event_base_get_num_events()
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()
2338 if (event & EV_READ) in test_multiple_cb()
2939 tt_int_op(i, ==, EV_READ); in test_event_closed_fd_poll()
[all …]
H A Dtest-dumpevents.c111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
142 event_active(ev[10], EV_READ, 1); in main()
143 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
144 event_active(ev[1], EV_READ, 1); in main()
H A Dregress_ssl.c349 bufferevent_disable(bev, EV_READ); in respond_to_number()
360 bufferevent_enable(bev, EV_READ); in done_writing_cb()
525 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
526 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
547 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
575 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb_deferred()
603 bufferevent_disable(bev, EV_READ|EV_WRITE); in acceptcb()
605 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
789 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
824 bufferevent_disable(bev, EV_READ); in wm_transfer()
[all …]
/freebsd-14.2/contrib/libevent/test/
H A Dregress_et.c106 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
153 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
155 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
161 tt_int_op(EV_READ, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
162 tt_int_op(0, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
168 tt_int_op(EV_READ, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
169 tt_int_op(0, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
227 read_ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, in test_edge_triggered_multiple_events()
H A Dregress_bufferevent.c114 bufferevent_disable(bev, EV_READ); in readcb()
178 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
179 bufferevent_enable(bev2, EV_READ); in test_bufferevent_impl()
382 bufferevent_disable(bev, EV_READ); in wm_readcb()
428 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
589 bufferevent_enable(bev2, EV_READ); in test_bufferevent_filters_impl()
692 bufferevent_enable(bev, EV_READ); in reader_eventcb()
782 bufferevent_enable(bev1, EV_READ); in test_bufferevent_connect()
783 bufferevent_enable(bev2, EV_READ); in test_bufferevent_connect()
1132 bufferevent_trigger(bev, EV_READ, in trigger_readcb()
[all …]
H A Dregress.c700 event_active(ev, EV_READ, 1); in activate_cb()
1466 ==, EV_READ); in test_manipulate_active_events()
1471 ==, EV_READ|EV_WRITE); in test_manipulate_active_events()
1495 event_active(ev, EV_READ, 1); in test_event_new_selfarg()
1510 event_active(&ev, EV_READ, 1); in test_event_assign_selfarg()
1559 event_active(&ev, EV_READ, 1); in test_event_base_get_num_events()
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()
2338 if (event & EV_READ) in test_multiple_cb()
2939 tt_int_op(i, ==, EV_READ); in test_event_closed_fd_poll()
[all …]
H A Dtest-dumpevents.c111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
142 event_active(ev[10], EV_READ, 1); in main()
143 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
144 event_active(ev[1], EV_READ, 1); in main()
H A Dregress_ssl.c349 bufferevent_disable(bev, EV_READ); in respond_to_number()
360 bufferevent_enable(bev, EV_READ); in done_writing_cb()
525 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
526 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
547 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
575 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb_deferred()
603 bufferevent_disable(bev, EV_READ|EV_WRITE); in acceptcb()
605 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
789 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
824 bufferevent_disable(bev, EV_READ); in wm_transfer()
[all …]
/freebsd-14.2/contrib/unbound/util/
H A Dwinsock_event.c345 bits |= EV_READ; in handle_select()
357 bits |= EV_READ; in handle_select()
364 bits |= EV_READ; in handle_select()
370 bits |= EV_READ; in handle_select()
376 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
402 (bits&EV_READ)?" EV_READ":"", in handle_select()
496 (ev->ev_events&EV_READ)?" EV_READ":"", in event_add()
516 if( (ev->ev_events&EV_READ) ) in event_add()
578 (ev->ev_events&EV_READ)?" EV_READ":"", in event_del()
649 eventbits==EV_READ?"EV_READ":"EV_WRITE"); in winsock_tcp_wouldblock()
[all …]
/freebsd-14.2/contrib/ntp/sntp/libevent/
H A Dbufferevent_pair.c187 bufferevent_trigger_nolock_(dst, EV_READ, 0); in be_pair_transfer()
199 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
232 if (events & EV_READ) { in be_pair_enable()
239 if ((events & EV_READ) && partner && in be_pair_enable()
255 if (events & EV_READ) { in be_pair_disable()
321 if ((iotype & EV_READ) != 0) in be_pair_flush()
329 if (iotype & EV_READ) in be_pair_flush()
H A Devport.c98 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
342 res = EV_READ | EV_WRITE; in evport_dispatch()
345 res |= EV_READ; in evport_dispatch()
354 res |= EV_READ|EV_WRITE; in evport_dispatch()
404 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
423 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Devmap.c301 old |= EV_READ; in evmap_io_add_()
307 if (ev->ev_events & EV_READ) { in evmap_io_add_()
309 res |= EV_READ; in evmap_io_add_()
379 old |= EV_READ; in evmap_io_del_()
385 if (ev->ev_events & EV_READ) { in evmap_io_del_()
387 res |= EV_READ; in evmap_io_del_()
619 events |= EV_READ;
884 if (events & (EV_READ|EV_SIGNAL))
925 if (events & (EV_READ|EV_SIGNAL)) {
926 if (!(change->old_events & (EV_READ | EV_SIGNAL)))
[all …]
H A Dpoll.c215 res |= EV_READ; in poll_dispatch()
238 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_add()
279 if (events & EV_READ) in poll_add()
301 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_del()
311 if (events & EV_READ) in poll_del()
H A Dbufferevent_openssl.c476 if (bev->enabled & EV_READ) in clear_rbow()
488 if (!(bev->enabled & EV_READ)) in clear_wbor()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
848 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
1003 EV_READ|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1108 EV_READ|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1162 if (events & EV_READ) in be_openssl_enable()
1168 if (events & EV_READ) in be_openssl_enable()
1173 if (events & EV_READ) in be_openssl_enable()
1186 if (events & EV_READ) in be_openssl_disable()
[all …]
H A Ddevpoll.c212 which |= EV_READ; in devpoll_dispatch()
242 if (events & EV_READ) in devpoll_add()
261 if (events & EV_READ) in devpoll_del()
285 } else if ((res & POLLOUT) && (old & EV_READ)) { in devpoll_del()
/freebsd-14.2/contrib/libevent/
H A Dbufferevent_pair.c187 bufferevent_trigger_nolock_(dst, EV_READ, 0); in be_pair_transfer()
199 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
232 if (events & EV_READ) { in be_pair_enable()
239 if ((events & EV_READ) && partner && in be_pair_enable()
255 if (events & EV_READ) { in be_pair_disable()
321 if ((iotype & EV_READ) != 0) in be_pair_flush()
329 if (iotype & EV_READ) in be_pair_flush()
H A Devport.c98 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
342 res = EV_READ | EV_WRITE; in evport_dispatch()
345 res |= EV_READ; in evport_dispatch()
354 res |= EV_READ|EV_WRITE; in evport_dispatch()
404 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
423 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Devmap.c301 old |= EV_READ; in evmap_io_add_()
307 if (ev->ev_events & EV_READ) { in evmap_io_add_()
309 res |= EV_READ; in evmap_io_add_()
379 old |= EV_READ; in evmap_io_del_()
385 if (ev->ev_events & EV_READ) { in evmap_io_del_()
387 res |= EV_READ; in evmap_io_del_()
619 events |= EV_READ;
884 if (events & (EV_READ|EV_SIGNAL))
925 if (events & (EV_READ|EV_SIGNAL)) {
926 if (!(change->old_events & (EV_READ | EV_SIGNAL)))
[all …]
H A Dpoll.c215 res |= EV_READ; in poll_dispatch()
238 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_add()
279 if (events & EV_READ) in poll_add()
301 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_del()
311 if (events & EV_READ) in poll_del()
H A Dbufferevent_openssl.c476 if (bev->enabled & EV_READ) in clear_rbow()
488 if (!(bev->enabled & EV_READ)) in clear_wbor()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
848 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
1003 EV_READ|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1108 EV_READ|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1162 if (events & EV_READ) in be_openssl_enable()
1168 if (events & EV_READ) in be_openssl_enable()
1173 if (events & EV_READ) in be_openssl_enable()
1186 if (events & EV_READ) in be_openssl_disable()
[all …]
/freebsd-14.2/contrib/ntp/sntp/libevent/sample/
H A Dle-proxy.c75 bufferevent_disable(bev, EV_READ); in readcb()
89 bufferevent_enable(partner, EV_READ); in drained_writecb()
136 bufferevent_disable(partner, EV_READ); in eventcb()
206 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
207 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
/freebsd-14.2/contrib/libevent/sample/
H A Dle-proxy.c75 bufferevent_disable(bev, EV_READ); in readcb()
89 bufferevent_enable(partner, EV_READ); in drained_writecb()
136 bufferevent_disable(partner, EV_READ); in eventcb()
206 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
207 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
/freebsd-14.2/contrib/pf/libevent/
H A Dpoll.c131 assert(ev->ev_events & EV_READ); in poll_check_ok()
189 res |= EV_READ; in poll_dispatch()
223 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_add()
306 if (ev->ev_events & EV_READ) { in poll_add()
329 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_del()
339 if (ev->ev_events & EV_READ) { in poll_del()

12345