/external/libevent/ |
D | bufferevent_sock.c | 111 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb() 112 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb() 252 if (!(bufev->enabled & EV_WRITE) || in bufferevent_writecb() 309 bufferevent_disable(bufev, EV_WRITE); in bufferevent_writecb() 342 EV_WRITE|EV_PERSIST, bufferevent_writecb, bufev); in bufferevent_socket_new() 402 EV_WRITE|EV_PERSIST, bufferevent_writecb, bev); in bufferevent_socket_connect() 407 if (! be_socket_enable(bev, EV_WRITE)) { in bufferevent_socket_connect() 416 event_active(&bev->ev_write, EV_WRITE, 1); in bufferevent_socket_connect() 422 event_active(&bev->ev_write, EV_WRITE, 1); in bufferevent_socket_connect() 557 if (event & EV_WRITE) { in be_socket_enable() [all …]
|
D | evport.c | 103 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE) 343 res = EV_READ | EV_WRITE; in evport_dispatch() 348 res |= EV_WRITE; in evport_dispatch() 355 res |= EV_READ|EV_WRITE; in evport_dispatch() 433 if (events & EV_WRITE) in evport_del() 434 fdi->fdi_what &= ~EV_WRITE; in evport_del() 453 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
|
D | bufferevent_filter.c | 208 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new() 251 if (event & EV_WRITE) in be_filter_enable() 266 if (event & EV_WRITE) in be_filter_disable() 331 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output() 363 (bufev->enabled & EV_WRITE) && in be_filter_process_output() 376 (bufev->enabled & EV_WRITE) && in be_filter_process_output() 483 if (iotype & EV_WRITE) { in be_filter_flush()
|
D | epoll.c | 211 } else if (ch->old_events & EV_WRITE) { in epoll_apply_one_change() 243 } else if (ch->old_events & EV_WRITE) { in epoll_apply_one_change() 359 if (events & EV_WRITE) in epoll_nochangelist_add() 377 if (events & EV_WRITE) in epoll_nochangelist_del() 428 ev = EV_READ | EV_WRITE; in epoll_dispatch() 433 ev |= EV_WRITE; in epoll_dispatch()
|
D | poll.c | 200 res |= EV_WRITE; in poll_dispatch() 219 if (!(events & (EV_READ|EV_WRITE))) in poll_add() 258 if (events & EV_WRITE) in poll_add() 280 if (!(events & (EV_READ|EV_WRITE))) in poll_del() 292 if (events & EV_WRITE) in poll_del()
|
D | devpoll.c | 211 which |= EV_WRITE; in devpoll_dispatch() 241 if (events & EV_WRITE) in devpoll_add() 260 if (events & EV_WRITE) in devpoll_del() 279 if ((res & POLLIN) && (old & EV_WRITE)) { in devpoll_del()
|
D | evmap.c | 292 old |= EV_WRITE; in evmap_io_add() 298 if (ev->ev_events & EV_WRITE) { in evmap_io_add() 300 res |= EV_WRITE; in evmap_io_add() 362 old |= EV_WRITE; in evmap_io_del() 369 if (ev->ev_events & EV_WRITE) { in evmap_io_del() 371 res |= EV_WRITE; in evmap_io_del() 668 if (events & EV_WRITE) { in event_changelist_add() 716 if (events & EV_WRITE) { in event_changelist_del() 717 if (!(change->old_events & EV_WRITE) && in event_changelist_del() 784 if (ev->ev_events & (EV_READ|EV_WRITE)) {
|
D | bufferevent_pair.c | 203 return (downcast(src)->enabled & EV_WRITE) && in be_pair_wants_to_talk() 240 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable() 249 if ((events & EV_WRITE) && partner && in be_pair_enable() 263 if (events & EV_WRITE) in be_pair_disable() 299 if ((iotype & EV_WRITE) != 0) in be_pair_flush()
|
D | bufferevent_openssl.c | 463 if (!(bev->enabled & EV_WRITE)) in clear_rbow() 479 if (bev->enabled & EV_WRITE) in clear_wbor() 865 while ((bev_ssl->bev.bev.enabled & EV_WRITE) && in consider_writing() 883 !(bev_ssl->bev.bev.enabled & EV_WRITE)) { in consider_writing() 972 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks() 979 EV_WRITE|EV_PERSIST, be_openssl_writeeventcb, bev_ssl); in set_open_callbacks() 1081 EV_WRITE|EV_PERSIST, be_openssl_handshakeeventcb, bev_ssl); in set_handshake_callbacks() 1137 if (events & EV_WRITE) in be_openssl_enable() 1143 if (events & EV_WRITE) in be_openssl_enable() 1148 if (events & EV_WRITE) in be_openssl_enable() [all …]
|
D | win32select.c | 223 if (!(events & (EV_READ|EV_WRITE))) in win32_add() 231 if (events & EV_WRITE) { in win32_add() 249 if (events & EV_WRITE) in win32_del() 341 evmap_io_active(base, s, EV_WRITE); in win32_dispatch() 351 evmap_io_active(base, s, EV_WRITE); in win32_dispatch()
|
D | bufferevent.c | 96 bufev->be_ops->disable(bufev, EV_WRITE); in bufferevent_suspend_write() 108 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) in bufferevent_unsuspend_write() 109 bufev->be_ops->enable(bufev, EV_WRITE); in bufferevent_unsuspend_write() 305 bufev->enabled = EV_WRITE; in bufferevent_init_common() 418 impl_events &= ~EV_WRITE; in bufferevent_enable() 524 if (events & EV_WRITE) { in bufferevent_setwatermark() 805 bufferevent_disable(bev, EV_WRITE); in bufferevent_generic_write_timeout_cb() 843 if ((enabled & EV_WRITE) && !bev_p->write_suspended && in _bufferevent_generic_adj_timeouts()
|
D | select.c | 188 res |= EV_WRITE; in select_dispatch() 276 if (events & EV_WRITE) in select_add() 304 if (events & EV_WRITE) in select_del()
|
D | bufferevent_async.c | 193 if (!beva->ok || !(bev->enabled&EV_WRITE) || in bev_async_consider_writing() 335 if (what & EV_WRITE) in be_async_enable() 343 if (what & EV_WRITE) in be_async_enable() 360 if (what & EV_WRITE) { in be_async_disable()
|
D | event.c | 866 if (ev->ev_events & (EV_READ|EV_WRITE)) { in event_reinit() 1350 ev->ev_res & EV_WRITE ? "EV_WRITE " : " ", in event_process_active_single_queue() 1715 } else if (events & (EV_READ|EV_WRITE)) { in event_base_once() 1716 events &= EV_READ|EV_WRITE; in event_base_once() 1755 if ((events & (EV_READ|EV_WRITE)) != 0) { in event_assign() 1880 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)); in event_pending() 1886 event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_SIGNAL); in event_pending() 2060 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", in event_add_internal() 2088 if ((ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)) && in event_add_internal() 2090 if (ev->ev_events & (EV_READ|EV_WRITE)) in event_add_internal() [all …]
|
D | kqueue.c | 374 which |= EV_WRITE; in kq_dispatch()
|
D | http.c | 395 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_write_buffer() 401 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done() 408 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue() 706 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_fail() 1235 bufferevent_disable_hard(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_reset() 2212 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_connection_connect() 2325 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_read()
|
D | evdns.c | 1465 ns->socket, EV_READ | (waiting ? EV_WRITE : 0) | EV_PERSIST, in nameserver_write_waiting() 1485 if (events & EV_WRITE) { in nameserver_ready_callback() 1505 if (events & EV_WRITE) { in server_port_ready_callback() 2005 …event_assign(&port->event, port->event_base, port->socket, (port->closing?0:EV_READ) | EV_WRITE | … in evdns_server_request_respond()
|
/external/libchrome/base/message_loop/ |
D | message_pump_libevent.cc | 160 event_mask |= EV_WRITE; in WatchFileDescriptor() 170 (EV_READ | EV_WRITE | EV_PERSIST); in WatchFileDescriptor() 358 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) { in OnLibeventNotification() 368 } else if (flags & EV_WRITE) { in OnLibeventNotification()
|
/external/curl/docs/examples/ |
D | hiperfifo.c | 184 (kind & EV_WRITE ? CURL_CSELECT_OUT : 0); in event_cb() 232 (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0)|EV_PERSIST; in setsock()
|
D | evhiperfifo.c | 192 (revents&EV_WRITE?CURL_POLL_OUT:0); in event_cb() 235 int kind = (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0); in setsock()
|
/external/libweave/examples/provider/ |
D | event_task_runner.cc | 33 flags |= (what & kWriteable) ? EV_WRITE : 0; in AddIoCompletionTask()
|
/external/tlsdate/src/ |
D | dbus.c | 46 events |= EV_WRITE; in dbus_to_event() 57 if (events & EV_WRITE) in event_to_dbus()
|
D | util.c | 411 if (event_pending (e, EV_READ|EV_WRITE|EV_TIMEOUT|EV_SIGNAL, NULL)) in trigger_event()
|
D | tlsdated.c | 562 EV_READ|EV_WRITE, action_sync_and_save, in main()
|
/external/libevent/include/event2/ |
D | event.h | 735 #define EV_WRITE 0x04 macro
|