Home
last modified time | relevance | path

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

12

/external/libevent/test/
Dregress_et.c121 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
172 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
174 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
180 tt_int_op(EV_READ, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
181 tt_int_op(0, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
187 tt_int_op(EV_READ, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
188 tt_int_op(0, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
Dregress.c311 event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); in test_simpleread()
356 event_set(&one, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
359 event_set(&two, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
433 rev = event_new(base, pair1[1], EV_READ, record_event_cb, in test_simpleclose()
451 tt_int_op(got_read_on_close, ==, EV_READ); in test_simpleclose()
493 event_set(&ev2, pair[1], EV_READ, multiple_read_cb, &ev2); in test_multiple()
522 event_set(&ev2, pair[1], EV_READ|EV_PERSIST, multiple_read_cb, &ev2); in test_persistent()
547 event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1); in test_combined()
549 event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2); in test_combined()
652 event_active(ev, EV_READ, 1); in activate_cb()
[all …]
Dregress_bufferevent.c101 bufferevent_disable(bev, EV_READ); in readcb()
165 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
166 bufferevent_enable(bev2, EV_READ); in test_bufferevent_impl()
169 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
369 bufferevent_disable(bev, EV_READ); in wm_readcb()
414 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
415 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
418 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
427 bufferevent_setwatermark(bev2, EV_READ, 10, 20); in test_bufferevent_watermarks_impl()
429 bufferevent_getwatermark(bev2, EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
[all …]
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()
Dregress_ssl.c289 bufferevent_disable(bev, EV_READ); in respond_to_number()
300 bufferevent_enable(bev, EV_READ); in done_writing_cb()
469 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
470 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
491 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
492 bufferevent_disable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
516 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb_deferred()
546 bufferevent_disable(bev, EV_READ|EV_WRITE); in acceptcb()
548 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
726 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
Dtest-ratelim.c141 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
153 bufferevent_disable(bev, EV_READ); in echo_readcb()
161 bufferevent_enable(bev, EV_READ); in echo_writecb()
194 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
352 bufferevent_enable(bevs[i], EV_READ|EV_WRITE); in test_ratelimiting()
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()
Dtest-fdleak.c113 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
200 bufferevent_enable(bev, EV_READ); in client_event_cb()
Dbench_httpclient.c109 bufferevent_disable(b, EV_READ|EV_WRITE); in errorcb()
168 bufferevent_enable(b, EV_READ|EV_WRITE); in launch_request()
/external/libevent/
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()
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()
Devmap.c294 old |= EV_READ; in evmap_io_add_()
300 if (ev->ev_events & EV_READ) { in evmap_io_add_()
302 res |= EV_READ; in evmap_io_add_()
372 old |= EV_READ; in evmap_io_del_()
378 if (ev->ev_events & EV_READ) { in evmap_io_del_()
380 res |= EV_READ; in evmap_io_del_()
608 events |= EV_READ;
872 if (events & (EV_READ|EV_SIGNAL)) {
918 if (events & (EV_READ|EV_SIGNAL)) {
919 if (!(change->old_events & (EV_READ | EV_SIGNAL)))
[all …]
Dpoll.c204 res |= EV_READ; in poll_dispatch()
225 if (!(events & (EV_READ|EV_WRITE))) in poll_add()
266 if (events & EV_READ) in poll_add()
286 if (!(events & (EV_READ|EV_WRITE))) in poll_del()
296 if (events & EV_READ) in poll_del()
Dbufferevent_openssl.c475 if (bev->enabled & EV_READ) in clear_rbow()
487 if (!(bev->enabled & EV_READ)) in clear_wbor()
748 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
838 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
844 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
863 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
991 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
999 EV_READ|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1104 EV_READ|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1158 if (events & EV_READ) in be_openssl_enable()
[all …]
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()
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()
Dbufferevent_sock.c212 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in bufferevent_readcb()
220 bufferevent_disable(bufev, EV_READ); in bufferevent_readcb()
366 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()
578 if (event & EV_READ && in be_socket_enable()
592 if (event & EV_READ) { in be_socket_disable()
644 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in be_socket_setfd()
Dbufferevent.c73 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
85 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
86 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
469 impl_events &= ~EV_READ; in bufferevent_enable()
582 if (events & EV_READ) { in bufferevent_setwatermark()
631 if (events == EV_READ) { in bufferevent_getwatermark()
924 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
954 if ((enabled & EV_READ) && !bev_p->read_suspended && in bufferevent_generic_adj_timeouts_()
975 if (event_pending(&bev->ev_read, EV_READ, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
Dselect.c197 res |= EV_READ; in select_dispatch()
285 if (events & EV_READ) in select_add()
312 if (events & EV_READ) in select_del()
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()
339 evmap_io_active_(base, s, EV_READ); in win32_dispatch()
Depoll.c385 if (events & EV_READ) in epoll_nochangelist_add()
405 if (events & EV_READ) in epoll_nochangelist_del()
487 ev = EV_READ | EV_WRITE; in epoll_dispatch()
490 ev |= EV_READ; in epoll_dispatch()
Dbufferevent_async.c241 if (!beva->ok || !(bev->enabled&EV_READ)) { in bev_async_consider_reading()
335 if (what & EV_READ) in be_async_enable()
343 if (what & EV_READ) in be_async_enable()
358 if (what & EV_READ) { in be_async_disable()
462 bufferevent_trigger_nolock_(bev, EV_READ, 0); in read_complete()
/external/libchrome/base/message_loop/
Dmessage_pump_libevent.cc142 event_mask |= EV_READ; in WatchFileDescriptor()
154 int old_interest_mask = evt->ev_events & (EV_READ | EV_WRITE | EV_PERSIST); in WatchFileDescriptor()
294 event_set(wakeup_event_, wakeup_pipe_out_, EV_READ | EV_PERSIST, in Init()
318 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) { in OnLibeventNotification()
330 } else if (flags & EV_READ) { in OnLibeventNotification()
/external/libevent/sample/
Dle-proxy.c74 bufferevent_disable(bev, EV_READ); in readcb()
88 bufferevent_enable(partner, EV_READ); in drained_writecb()
135 bufferevent_disable(partner, EV_READ); in eventcb()
204 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
205 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
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