Home
last modified time | relevance | path

Searched refs:EV_WRITE (Results 1 – 25 of 42) sorted by relevance

12

/external/libevent/
Dbufferevent_sock.c134 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb()
135 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
279 if (!(bufev->enabled & EV_WRITE) || in bufferevent_writecb()
323 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0); in bufferevent_writecb()
335 bufferevent_disable(bufev, EV_WRITE); in bufferevent_writecb()
368 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev); in bufferevent_socket_new()
427 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev); in bufferevent_socket_connect()
432 if (! be_socket_enable(bev, EV_WRITE)) { in bufferevent_socket_connect()
441 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in bufferevent_socket_connect()
446 bufferevent_disable(bev, EV_WRITE|EV_READ); in bufferevent_socket_connect()
[all …]
Dbufferevent_pair.c188 bufferevent_trigger_nolock_(src, EV_WRITE, 0); in be_pair_transfer()
198 return (downcast(src)->enabled & EV_WRITE) && in be_pair_wants_to_talk()
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
244 if ((events & EV_WRITE) && partner && in be_pair_enable()
258 if (events & EV_WRITE) { in be_pair_disable()
324 if ((iotype & EV_WRITE) != 0) in be_pair_flush()
331 if (iotype & EV_WRITE) in be_pair_flush()
Devport.c99 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE)
342 res = EV_READ | EV_WRITE; in evport_dispatch()
347 res |= EV_WRITE; 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.c296 old |= EV_WRITE; in evmap_io_add_()
304 if (ev->ev_events & EV_WRITE) { in evmap_io_add_()
306 res |= EV_WRITE; in evmap_io_add_()
374 old |= EV_WRITE; in evmap_io_del_()
383 if (ev->ev_events & EV_WRITE) { in evmap_io_del_()
385 res |= EV_WRITE; in evmap_io_del_()
610 events |= EV_WRITE;
876 if (events & EV_WRITE) {
924 if (events & EV_WRITE) {
925 if (!(change->old_events & EV_WRITE))
[all …]
Dbufferevent_filter.c222 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
276 if (event & EV_WRITE) in be_filter_enable()
291 if (event & EV_WRITE) in be_filter_disable()
356 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
389 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
398 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0); in be_filter_process_output()
401 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
585 if (iotype & EV_WRITE) { in be_filter_flush()
Dpoll.c206 res |= EV_WRITE; in poll_dispatch()
225 if (!(events & (EV_READ|EV_WRITE))) in poll_add()
264 if (events & EV_WRITE) in poll_add()
286 if (!(events & (EV_READ|EV_WRITE))) in poll_del()
298 if (events & EV_WRITE) in poll_del()
Ddevpoll.c214 which |= EV_WRITE; in devpoll_dispatch()
244 if (events & EV_WRITE) in devpoll_add()
263 if (events & EV_WRITE) in devpoll_del()
282 if ((res & POLLIN) && (old & EV_WRITE)) { in devpoll_del()
Dbufferevent_openssl.c473 if (!(bev->enabled & EV_WRITE)) in clear_rbow()
489 if (bev->enabled & EV_WRITE) in clear_wbor()
723 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in do_write()
874 while ((bev_ssl->bev.bev.enabled & EV_WRITE) && in consider_writing()
892 !(bev_ssl->bev.bev.enabled & EV_WRITE)) { in consider_writing()
992 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks()
1002 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1107 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1160 if (events & EV_WRITE) in be_openssl_enable()
1166 if (events & EV_WRITE) in be_openssl_enable()
[all …]
Dbufferevent.c97 bufev->be_ops->disable(bufev, EV_WRITE); in bufferevent_suspend_write_()
109 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) in bufferevent_unsuspend_write_()
110 bufev->be_ops->enable(bufev, EV_WRITE); in bufferevent_unsuspend_write_()
326 bufev->enabled = EV_WRITE; in bufferevent_init_common_()
471 impl_events &= ~EV_WRITE; in bufferevent_enable()
577 if (events & EV_WRITE) { in bufferevent_setwatermark()
621 if (events == EV_WRITE) { in bufferevent_getwatermark()
933 bufferevent_disable(bev, EV_WRITE); in bufferevent_generic_write_timeout_cb()
960 if ((enabled & EV_WRITE) && !bev_p->write_suspended && in bufferevent_generic_adj_timeouts_()
983 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
Dwin32select.c229 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
237 if (events & EV_WRITE) { in win32_add()
255 if (events & EV_WRITE) in win32_del()
349 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch()
360 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch()
Dselect.c199 res |= EV_WRITE; in select_dispatch()
287 if (events & EV_WRITE) in select_add()
315 if (events & EV_WRITE) in select_del()
Depoll.c382 if (events & EV_WRITE) in epoll_nochangelist_add()
403 if (events & EV_WRITE) in epoll_nochangelist_del()
487 ev = EV_READ | EV_WRITE; in epoll_dispatch()
492 ev |= EV_WRITE; in epoll_dispatch()
Dbufferevent_async.c195 if (!beva->ok || !(bev->enabled&EV_WRITE) || in bev_async_consider_writing()
337 if (what & EV_WRITE) in be_async_enable()
345 if (what & EV_WRITE) in be_async_enable()
362 if (what & EV_WRITE) { in be_async_disable()
505 bufferevent_trigger_nolock_(bev, EV_WRITE, 0); in write_complete()
Devent.c1613 ev->ev_res & EV_WRITE ? "EV_WRITE " : " ", in event_process_active_single_queue()
2025 if ((events & (EV_TIMEOUT|EV_SIGNAL|EV_READ|EV_WRITE|EV_CLOSED)) == EV_TIMEOUT) { in event_base_once()
2035 } else if (events & (EV_READ|EV_WRITE|EV_CLOSED)) { in event_base_once()
2036 events &= EV_READ|EV_WRITE|EV_CLOSED; in event_base_once()
2086 if ((events & (EV_READ|EV_WRITE|EV_CLOSED)) != 0) { in event_assign()
2338 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL)); in event_pending()
2344 event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL); in event_pending()
2562 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", in event_add_nolock_()
2597 if ((ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL)) && in event_add_nolock_()
2599 if (ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED)) in event_add_nolock_()
[all …]
/external/libevent/test/
Dregress_ssl.c288 bufferevent_enable(bev, EV_WRITE); in respond_to_number()
299 bufferevent_disable(bev, EV_WRITE); 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()
Dregress_bufferevent.c168 tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE); in test_bufferevent_impl()
169 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
176 tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0); in test_bufferevent_impl()
420 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL); in test_bufferevent_watermarks_impl()
435 bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000); in test_bufferevent_watermarks_impl()
437 bufferevent_getwatermark(bev1, EV_WRITE, &low, &high); in test_bufferevent_watermarks_impl()
442 int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
454 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL)); in test_bufferevent_watermarks_impl()
607 bufferevent_disable(bev,EV_READ|EV_WRITE); in sender_writecb()
809 bufferevent_enable(bev, EV_READ|EV_WRITE); in test_bufferevent_connect_fail_eventcb()
[all …]
Dtest-dumpevents.c110 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
112 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
143 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
Dregress.c327 event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev); in test_simplewrite()
436 wev = event_new(base, pair2[1], EV_WRITE, record_event_cb, in test_simpleclose()
452 tt_int_op(got_write_on_close, ==, EV_WRITE); in test_simpleclose()
490 event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev); in test_multiple()
519 event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev); in test_persistent()
548 event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1); in test_combined()
550 event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2); in test_combined()
1383 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
1387 event_active(&ev1, EV_WRITE, 1); in test_manipulate_active_events()
1388 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
[all …]
Dbench_httpclient.c109 bufferevent_disable(b, EV_READ|EV_WRITE); in errorcb()
168 bufferevent_enable(b, EV_READ|EV_WRITE); in launch_request()
Dregress_zlib.c315 bufferevent_enable(bev1, EV_WRITE); in test_bufferevent_zlib()
327 bufferevent_flush(bev1, EV_WRITE, BEV_FINISHED); in test_bufferevent_zlib()
Dtest-weof.c106 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main()
Dtest-ratelim.c141 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
194 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
352 bufferevent_enable(bevs[i], EV_READ|EV_WRITE); in test_ratelimiting()
/external/libchrome/base/message_loop/
Dmessage_pump_libevent.cc145 event_mask |= EV_WRITE; in WatchFileDescriptor()
154 int old_interest_mask = evt->ev_events & (EV_READ | EV_WRITE | EV_PERSIST); in WatchFileDescriptor()
318 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) { in OnLibeventNotification()
328 } else if (flags & EV_WRITE) { in OnLibeventNotification()
/external/libevent/sample/
Dle-proxy.c72 bufferevent_setwatermark(partner, EV_WRITE, MAX_OUTPUT/2, in readcb()
86 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); in drained_writecb()
204 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
205 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
Dhello-world.c102 bufferevent_enable(bev, EV_WRITE); in listener_cb()

12