Home
last modified time | relevance | path

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

12

/external/libevent/
Dbufferevent_sock.c111 (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 …]
Devport.c103 #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()
Dbufferevent_filter.c208 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()
Dpoll.c200 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()
Depoll.c211 } 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()
Ddevpoll.c211 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()
Dbufferevent_pair.c203 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()
Devmap.c292 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)) {
Dbufferevent_openssl.c463 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 …]
Dwin32select.c223 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()
Dbufferevent.c96 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()
Dselect.c188 res |= EV_WRITE; in select_dispatch()
276 if (events & EV_WRITE) in select_add()
304 if (events & EV_WRITE) in select_del()
Dbufferevent_async.c193 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()
Devent.c866 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 …]
Dkqueue.c374 which |= EV_WRITE; in kq_dispatch()
Dhttp.c395 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()
Devdns.c1465 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/
Dmessage_pump_libevent.cc160 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/
Dhiperfifo.c188 (kind & EV_WRITE ? CURL_CSELECT_OUT : 0); in event_cb()
236 (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0)|EV_PERSIST; in setsock()
Devhiperfifo.c208 (revents&EV_WRITE?CURL_POLL_OUT:0); in event_cb()
250 int kind = (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0); in setsock()
/external/libweave/examples/provider/
Devent_task_runner.cc33 flags |= (what & kWriteable) ? EV_WRITE : 0; in AddIoCompletionTask()
/external/libevent/include/event2/
Devent.h735 #define EV_WRITE 0x04 macro
/external/tlsdate/src/
Ddbus.c46 events |= EV_WRITE; in dbus_to_event()
57 if (events & EV_WRITE) in event_to_dbus()
Dutil.c411 if (event_pending (e, EV_READ|EV_WRITE|EV_TIMEOUT|EV_SIGNAL, NULL)) in trigger_event()
Dtlsdated.c562 EV_READ|EV_WRITE, action_sync_and_save, in main()

12