Home
last modified time | relevance | path

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

12

/libevent-2.1.12/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 …]
H A Dregress_zlib.c252 bufferevent_disable(bev, EV_READ); in readcb()
314 bufferevent_disable(bev1, EV_READ); in test_bufferevent_zlib()
317 bufferevent_enable(bev2, EV_READ); in test_bufferevent_zlib()
H A Dtest-ratelim.c157 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
169 bufferevent_disable(bev, EV_READ); in echo_readcb()
177 bufferevent_enable(bev, EV_READ); in echo_writecb()
210 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
437 bufferevent_enable(bevs[i], EV_READ|EV_WRITE); in test_ratelimiting()
H A Dtest-fdleak.c115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
203 bufferevent_enable(bev, EV_READ); in client_event_cb()
H A Dbench_httpclient.c109 bufferevent_disable(b, EV_READ|EV_WRITE); in errorcb()
168 bufferevent_enable(b, EV_READ|EV_WRITE); in launch_request()
H A Dtest-eof.c109 event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); in main()
/libevent-2.1.12/
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()
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 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()
H A Dbufferevent_filter.c222 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
279 if (event & EV_READ) { in be_filter_enable()
293 if (event & EV_READ) { in be_filter_disable()
312 if (!(bev->enabled & EV_READ) || in be_filter_process_input()
329 (bev->enabled & EV_READ) && in be_filter_process_input()
466 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in be_filter_read_nolock_()
582 if (iotype & EV_READ) { in be_filter_flush()
H A Dbufferevent.c72 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
83 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
84 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
125 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
130 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
490 impl_events &= ~EV_READ; in bufferevent_enable()
605 if (events & EV_READ) { in bufferevent_setwatermark()
654 if (events == EV_READ) { in bufferevent_getwatermark()
946 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
975 if ((enabled & EV_READ) && !bev_p->read_suspended && in bufferevent_generic_adj_timeouts_()
[all …]
H A Dbufferevent_sock.c214 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in bufferevent_readcb()
222 bufferevent_disable(bufev, EV_READ); in bufferevent_readcb()
367 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in bufferevent_socket_new()
443 bufferevent_disable(bev, EV_WRITE|EV_READ); in bufferevent_socket_connect()
570 if (event & EV_READ && in be_socket_enable()
583 if (event & EV_READ) { in be_socket_disable()
633 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in be_socket_setfd()
H A Depoll.c385 if (events & EV_READ) in epoll_nochangelist_add()
406 if (events & EV_READ) in epoll_nochangelist_del()
490 ev = EV_READ | EV_WRITE; in epoll_dispatch()
492 ev = EV_READ | EV_WRITE; in epoll_dispatch()
495 ev |= EV_READ; in epoll_dispatch()
H A Dselect.c197 res |= EV_READ; in select_dispatch()
285 if (events & EV_READ) in select_add()
312 if (events & EV_READ) in select_del()
H A Dwin32select.c229 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
233 if (events & EV_READ) { in win32_add()
253 if (events & EV_READ) in win32_del()
341 evmap_io_active_(base, s, EV_READ); in win32_dispatch()
H A Dbufferevent_async.c263 if (!beva->ok || !(bev->enabled&EV_READ)) { in bev_async_consider_reading()
357 if (what & EV_READ) in be_async_enable()
365 if (what & EV_READ) in be_async_enable()
380 if (what & EV_READ) { in be_async_disable()
483 be_async_trigger_nolock(bev, EV_READ, 0); in read_complete()
/libevent-2.1.12/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()
H A Devent-read-fifo.c137 evfifo = event_new(base, (evutil_socket_t)socket, EV_READ|EV_PERSIST, fifo_read, in main()
144 evfifo = event_new(base, socket, EV_READ|EV_PERSIST, fifo_read, in main()

12