Home
last modified time | relevance | path

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

12345

/freebsd/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()
182 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
382 bufferevent_disable(bev, EV_READ); in wm_readcb()
427 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
428 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
431 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
440 bufferevent_setwatermark(bev2, EV_READ, 10, 20); in test_bufferevent_watermarks_impl()
442 bufferevent_getwatermark(bev2, EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
[all …]
H A Dregress.c309 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()
[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()
548 bufferevent_disable(bev2, 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()
[all …]
/freebsd/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()
182 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
382 bufferevent_disable(bev, EV_READ); in wm_readcb()
427 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
428 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
431 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
440 bufferevent_setwatermark(bev2, EV_READ, 10, 20); in test_bufferevent_watermarks_impl()
442 bufferevent_getwatermark(bev2, EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
[all …]
H A Dregress.c309 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()
[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()
548 bufferevent_disable(bev2, 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()
[all …]
/freebsd/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()
388 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
402 (bits&EV_READ)?" EV_READ":"", in handle_select()
415 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
496 (ev->ev_events&EV_READ)?" EV_READ":"", in event_add()
506 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
[all …]
/freebsd/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 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()
842 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
848 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
867 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
995 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
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()
[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 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/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 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()
842 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
848 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
867 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
995 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
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()
[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()
/freebsd/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/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/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