/external/libevent/ |
D | bufferevent_sock.c | 137 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb() 138 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb() 280 if (!(bufev->enabled & EV_WRITE) || in bufferevent_writecb() 324 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0); in bufferevent_writecb() 336 bufferevent_disable(bufev, EV_WRITE); in bufferevent_writecb() 369 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev); in bufferevent_socket_new() 424 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev); in bufferevent_socket_connect() 429 if (! be_socket_enable(bev, EV_WRITE)) { in bufferevent_socket_connect() 438 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in bufferevent_socket_connect() 443 bufferevent_disable(bev, EV_WRITE|EV_READ); in bufferevent_socket_connect() [all …]
|
D | bufferevent_pair.c | 188 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()
|
D | evport.c | 99 #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()
|
D | evmap.c | 303 old |= EV_WRITE; in evmap_io_add_() 311 if (ev->ev_events & EV_WRITE) { in evmap_io_add_() 313 res |= EV_WRITE; in evmap_io_add_() 381 old |= EV_WRITE; in evmap_io_del_() 390 if (ev->ev_events & EV_WRITE) { in evmap_io_del_() 392 res |= EV_WRITE; in evmap_io_del_() 621 events |= EV_WRITE; 886 if (events & EV_WRITE) 931 if (events & EV_WRITE) { 932 if (!(change->old_events & EV_WRITE)) [all …]
|
D | bufferevent_filter.c | 222 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()
|
D | poll.c | 206 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()
|
D | devpoll.c | 214 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()
|
D | bufferevent_openssl.c | 474 if (!(bev->enabled & EV_WRITE)) in clear_rbow() 490 if (bev->enabled & EV_WRITE) in clear_wbor() 727 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in do_write() 878 while ((bev_ssl->bev.bev.enabled & EV_WRITE) && in consider_writing() 896 !(bev_ssl->bev.bev.enabled & EV_WRITE)) { in consider_writing() 996 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks() 1006 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_open_callbacks() 1111 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks() 1164 if (events & EV_WRITE) in be_openssl_enable() 1170 if (events & EV_WRITE) in be_openssl_enable() [all …]
|
D | win32select.c | 229 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() 351 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch() 362 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch()
|
D | bufferevent.c | 94 bufev->be_ops->disable(bufev, EV_WRITE); in bufferevent_suspend_write_() 105 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) in bufferevent_unsuspend_write_() 106 bufev->be_ops->enable(bufev, EV_WRITE); in bufferevent_unsuspend_write_() 343 bufev->enabled = EV_WRITE; in bufferevent_init_common_() 492 impl_events &= ~EV_WRITE; in bufferevent_enable() 600 if (events & EV_WRITE) { in bufferevent_setwatermark() 644 if (events == EV_WRITE) { in bufferevent_getwatermark() 955 bufferevent_disable(bev, EV_WRITE); in bufferevent_generic_write_timeout_cb() 981 if ((enabled & EV_WRITE) && !bev_p->write_suspended && in bufferevent_generic_adj_timeouts_() 1004 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
|
D | select.c | 199 res |= EV_WRITE; in select_dispatch() 287 if (events & EV_WRITE) in select_add() 315 if (events & EV_WRITE) in select_del()
|
D | epoll.c | 382 if (events & EV_WRITE) in epoll_nochangelist_add() 403 if (events & EV_WRITE) in epoll_nochangelist_del() 490 ev = EV_READ | EV_WRITE; in epoll_dispatch() 495 ev |= EV_WRITE; in epoll_dispatch()
|
D | bufferevent_async.c | 217 if (!beva->ok || !(bev->enabled&EV_WRITE) || in bev_async_consider_writing() 359 if (what & EV_WRITE) in be_async_enable() 367 if (what & EV_WRITE) in be_async_enable() 384 if (what & EV_WRITE) { in be_async_disable() 526 be_async_trigger_nolock(bev, EV_WRITE, 0); in write_complete()
|
D | event.c | 1662 ev->ev_res & EV_WRITE ? "EV_WRITE " : " ", in event_process_active_single_queue() 2076 if ((events & (EV_TIMEOUT|EV_SIGNAL|EV_READ|EV_WRITE|EV_CLOSED)) == EV_TIMEOUT) { in event_base_once() 2086 } else if (events & (EV_READ|EV_WRITE|EV_CLOSED)) { in event_base_once() 2087 events &= EV_READ|EV_WRITE|EV_CLOSED; in event_base_once() 2139 if ((events & (EV_READ|EV_WRITE|EV_CLOSED)) != 0) { in event_assign() 2391 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL)); in event_pending() 2397 event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL); in event_pending() 2615 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", in event_add_nolock_() 2650 if ((ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL)) && in event_add_nolock_() 2652 if (ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED)) in event_add_nolock_() [all …]
|
/external/libchrome/base/message_loop/ |
D | message_pump_libevent.cc | 145 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/test/ |
D | regress_ssl.c | 348 bufferevent_enable(bev, EV_WRITE); in respond_to_number() 359 bufferevent_disable(bev, EV_WRITE); 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 …]
|
D | regress_bufferevent.c | 168 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 …]
|
D | test-dumpevents.c | 110 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()
|
D | regress.c | 328 event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev); in test_simplewrite() 437 wev = event_new(base, pair2[1], EV_WRITE, record_event_cb, in test_simpleclose() 453 tt_int_op(got_write_on_close, ==, EV_WRITE); in test_simpleclose() 491 event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev); in test_multiple() 520 event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev); in test_persistent() 549 event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1); in test_combined() 551 event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2); in test_combined() 1418 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events() 1422 event_active(&ev1, EV_WRITE, 1); in test_manipulate_active_events() 1423 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events() [all …]
|
D | bench_httpclient.c | 109 bufferevent_disable(b, EV_READ|EV_WRITE); in errorcb() 168 bufferevent_enable(b, EV_READ|EV_WRITE); in launch_request()
|
D | test-weof.c | 106 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main()
|
D | regress_zlib.c | 315 bufferevent_enable(bev1, EV_WRITE); in test_bufferevent_zlib() 327 bufferevent_flush(bev1, EV_WRITE, BEV_FINISHED); in test_bufferevent_zlib()
|
D | test-ratelim.c | 141 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/libevent/sample/ |
D | le-proxy.c | 73 bufferevent_setwatermark(partner, EV_WRITE, MAX_OUTPUT/2, in readcb() 87 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); in drained_writecb() 206 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb() 207 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
|
/external/curl/docs/examples/ |
D | multi-event.c | 130 if(event & EV_WRITE) in curl_perform() 183 events |= EV_WRITE; in handle_socket()
|