Home
last modified time | relevance | path

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

1234

/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_et.c110 ev = event_new(base, xpair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
157 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
159 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
165 tt_int_op(EV_READ, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
166 tt_int_op(0, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
172 tt_int_op(EV_READ, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
173 tt_int_op(0, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
231 read_ev = event_new(base, xpair[1], EV_READ|EV_ET|EV_PERSIST, in test_edge_triggered_multiple_events()
H A Dregress.c313 event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); in test_simpleread()
358 event_set(&one, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
361 event_set(&two, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
435 rev = event_new(base, pair1[1], EV_READ, record_event_cb, in test_simpleclose_rw()
453 tt_int_op(got_read_on_close, ==, EV_READ); in test_simpleclose_rw()
545 event_set(&ev2, pair[1], EV_READ, multiple_read_cb, &ev2); in test_multiple()
574 event_set(&ev2, pair[1], EV_READ|EV_PERSIST, multiple_read_cb, &ev2); in test_persistent()
599 event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1); in test_combined()
601 event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2); in test_combined()
704 event_active(ev, EV_READ, 1); in activate_cb()
[all …]
H A Dregress_bufferevent.c118 bufferevent_disable(bev, EV_READ); in readcb()
182 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
183 bufferevent_enable(bev2, EV_READ); in test_bufferevent_impl()
186 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
386 bufferevent_disable(bev, EV_READ); in wm_readcb()
431 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
432 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
435 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
444 bufferevent_setwatermark(bev2, EV_READ, 10, 20); in test_bufferevent_watermarks_impl()
446 bufferevent_getwatermark(bev2, EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
[all …]
H A Dtest-dumpevents.c114 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
116 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
145 event_active(ev[10], EV_READ, 1); in main()
146 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
147 event_active(ev[1], EV_READ, 1); in main()
H A Dregress_ssl.c352 bufferevent_disable(bev, EV_READ); in respond_to_number()
363 bufferevent_enable(bev, EV_READ); in done_writing_cb()
527 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
528 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
549 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
550 bufferevent_disable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
577 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb_deferred()
605 bufferevent_disable(bev, EV_READ|EV_WRITE); in acceptcb()
607 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
791 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
[all …]
H A Dregress_zlib.c255 bufferevent_disable(bev, EV_READ); in readcb()
317 bufferevent_disable(bev1, EV_READ); in test_bufferevent_zlib()
320 bufferevent_enable(bev2, EV_READ); in test_bufferevent_zlib()
/netbsd-src/external/bsd/unbound/dist/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 …]
/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent_pair.c190 bufferevent_trigger_nolock_(dst, EV_READ, 0); in be_pair_transfer()
202 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
235 if (events & EV_READ) { in be_pair_enable()
242 if ((events & EV_READ) && partner && in be_pair_enable()
258 if (events & EV_READ) { in be_pair_disable()
324 if ((iotype & EV_READ) != 0) in be_pair_flush()
332 if (iotype & EV_READ) in be_pair_flush()
H A Devport.c101 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
345 res = EV_READ | EV_WRITE; in evport_dispatch()
348 res |= EV_READ; in evport_dispatch()
357 res |= EV_READ|EV_WRITE; in evport_dispatch()
407 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
426 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Devmap.c305 old |= EV_READ; in evmap_io_add_()
311 if (ev->ev_events & EV_READ) { in evmap_io_add_()
313 res |= EV_READ; in evmap_io_add_()
383 old |= EV_READ; in evmap_io_del_()
389 if (ev->ev_events & EV_READ) { in evmap_io_del_()
391 res |= EV_READ; in evmap_io_del_()
623 events |= EV_READ;
888 if (events & (EV_READ|EV_SIGNAL))
929 if (events & (EV_READ|EV_SIGNAL)) {
930 if (!(change->old_events & (EV_READ | EV_SIGNAL)))
[all …]
H A Dbufferevent_openssl.c479 if (bev->enabled & EV_READ) in clear_rbow()
491 if (!(bev->enabled & EV_READ)) in clear_wbor()
755 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
845 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
851 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
870 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
998 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
1006 EV_READ|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1111 EV_READ|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1165 if (events & EV_READ) in be_openssl_enable()
[all …]
H A Dpoll.c218 res |= EV_READ; in poll_dispatch()
241 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_add()
282 if (events & EV_READ) in poll_add()
304 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_del()
314 if (events & EV_READ) in poll_del()
H A Ddevpoll.c215 which |= EV_READ; in devpoll_dispatch()
245 if (events & EV_READ) in devpoll_add()
264 if (events & EV_READ) in devpoll_del()
288 } else if ((res & POLLOUT) && (old & EV_READ)) { in devpoll_del()
H A Dbufferevent_filter.c225 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
282 if (event & EV_READ) { in be_filter_enable()
296 if (event & EV_READ) { in be_filter_disable()
315 if (!(bev->enabled & EV_READ) || in be_filter_process_input()
332 (bev->enabled & EV_READ) && in be_filter_process_input()
469 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in be_filter_read_nolock_()
585 if (iotype & EV_READ) { in be_filter_flush()
H A Dbufferevent.c76 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
87 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
88 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
129 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
134 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
494 impl_events &= ~EV_READ; in bufferevent_enable()
609 if (events & EV_READ) { in bufferevent_setwatermark()
658 if (events == EV_READ) { in bufferevent_getwatermark()
950 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
979 if ((enabled & EV_READ) && !bev_p->read_suspended && in bufferevent_generic_adj_timeouts_()
[all …]
H A Dbufferevent_sock.c217 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in bufferevent_readcb()
225 bufferevent_disable(bufev, EV_READ); in bufferevent_readcb()
370 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in bufferevent_socket_new()
446 bufferevent_disable(bev, EV_WRITE|EV_READ); in bufferevent_socket_connect()
573 if (event & EV_READ && in be_socket_enable()
586 if (event & EV_READ) { in be_socket_disable()
636 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in be_socket_setfd()
H A Depoll.c388 if (events & EV_READ) in epoll_nochangelist_add()
409 if (events & EV_READ) in epoll_nochangelist_del()
493 ev = EV_READ | EV_WRITE; in epoll_dispatch()
495 ev = EV_READ | EV_WRITE; in epoll_dispatch()
498 ev |= EV_READ; in epoll_dispatch()
H A Dwin32select.c232 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
236 if (events & EV_READ) { in win32_add()
256 if (events & EV_READ) in win32_del()
344 evmap_io_active_(base, s, EV_READ); in win32_dispatch()
H A Dselect.c200 res |= EV_READ; in select_dispatch()
288 if (events & EV_READ) in select_add()
315 if (events & EV_READ) in select_del()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/test/
H A Dtest-dumpevents.c113 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
115 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
144 event_active(ev[10], EV_READ, 1); in main()
145 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
146 event_active(ev[1], EV_READ, 1); in main()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/
H A Devport.c100 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
344 res = EV_READ | EV_WRITE; in evport_dispatch()
347 res |= EV_READ; in evport_dispatch()
356 res |= EV_READ|EV_WRITE; in evport_dispatch()
406 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
425 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Ddevpoll.c214 which |= EV_READ; in devpoll_dispatch()
244 if (events & EV_READ) in devpoll_add()
263 if (events & EV_READ) in devpoll_del()
287 } else if ((res & POLLOUT) && (old & EV_READ)) { in devpoll_del()
/netbsd-src/external/bsd/libevent/dist/sample/
H A Dle-proxy.c76 bufferevent_disable(bev, EV_READ); in readcb()
90 bufferevent_enable(partner, EV_READ); in drained_writecb()
137 bufferevent_disable(partner, EV_READ); in eventcb()
207 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
208 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
/netbsd-src/external/bsd/nsd/dist/
H A Dipc.c64 if (!(event & EV_READ)) { in child_handle_parent_command()
577 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ); in xfrd_send_shutdown_req()
591 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ); in xfrd_send_quit_req()
616 if ((event & EV_READ)) in xfrd_handle_ipc()
625 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ); in xfrd_handle_ipc()
642 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ); in xfrd_handle_ipc()
738 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ|EV_WRITE); in xfrd_handle_ipc_read()
764 ipc_xfrd_set_listening(xfrd, EV_PERSIST|EV_READ|EV_WRITE); in xfrd_handle_ipc_read()
H A Dverify.c140 assert(event & EV_READ); in verify_handle_stream()
185 verify_handle_stream(stream->fd, EV_READ, verifier); in close_stream()
297 assert(event & EV_READ); in verify_handle_exit()
374 assert(event & (EV_READ in verify_handle_command()
512 EV_READ|EV_PERSIST, in verify_zone()
528 EV_READ|EV_PERSIST, in verify_zone()

1234