Home
last modified time | relevance | path

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

12

/external/libevent/
Devport.c102 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
343 res = EV_READ | EV_WRITE; in evport_dispatch()
346 res |= EV_READ; in evport_dispatch()
355 res |= EV_READ|EV_WRITE; in evport_dispatch()
431 if (events & EV_READ) in evport_del()
432 fdi->fdi_what &= ~EV_READ; in evport_del()
453 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
Depoll.c204 } else if (ch->old_events & EV_READ) { in epoll_apply_one_change()
250 if (ch->old_events & EV_READ) { in epoll_apply_one_change()
362 if (events & EV_READ) in epoll_nochangelist_add()
379 if (events & EV_READ) in epoll_nochangelist_del()
428 ev = EV_READ | EV_WRITE; in epoll_dispatch()
431 ev |= EV_READ; in epoll_dispatch()
Dpoll.c198 res |= EV_READ; in poll_dispatch()
219 if (!(events & (EV_READ|EV_WRITE))) in poll_add()
260 if (events & EV_READ) in poll_add()
280 if (!(events & (EV_READ|EV_WRITE))) in poll_del()
290 if (events & EV_READ) in poll_del()
Dbufferevent_openssl.c465 if (bev->enabled & EV_READ) in clear_rbow()
477 if (!(bev->enabled & EV_READ)) in clear_wbor()
733 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
832 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
971 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
977 EV_READ|EV_PERSIST, be_openssl_readeventcb, bev_ssl); in set_open_callbacks()
1079 EV_READ|EV_PERSIST, be_openssl_handshakeeventcb, bev_ssl); in set_handshake_callbacks()
1135 if (events & EV_READ) in be_openssl_enable()
1141 if (events & EV_READ) in be_openssl_enable()
1146 if (events & EV_READ) in be_openssl_enable()
[all …]
Ddevpoll.c209 which |= EV_READ; in devpoll_dispatch()
239 if (events & EV_READ) in devpoll_add()
258 if (events & EV_READ) in devpoll_del()
282 } else if ((res & POLLOUT) && (old & EV_READ)) { in devpoll_del()
Dbufferevent_filter.c208 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
254 if (event & EV_READ) { in be_filter_enable()
268 if (event & EV_READ) { in be_filter_disable()
287 if (!(bev->enabled & EV_READ) || in be_filter_process_input()
304 (bev->enabled & EV_READ) && in be_filter_process_input()
480 if (iotype & EV_READ) { in be_filter_flush()
Devmap.c290 old |= EV_READ; in evmap_io_add()
294 if (ev->ev_events & EV_READ) { in evmap_io_add()
296 res |= EV_READ; in evmap_io_add()
360 old |= EV_READ; in evmap_io_del()
364 if (ev->ev_events & EV_READ) { in evmap_io_del()
366 res |= EV_READ; in evmap_io_del()
664 if (events & (EV_READ|EV_SIGNAL)) { in event_changelist_add()
709 if (events & (EV_READ|EV_SIGNAL)) { in event_changelist_del()
710 if (!(change->old_events & (EV_READ | EV_SIGNAL)) && in event_changelist_del()
784 if (ev->ev_events & (EV_READ|EV_WRITE)) {
Dbufferevent_pair.c204 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
237 if (events & EV_READ) { in be_pair_enable()
244 if ((events & EV_READ) && partner && in be_pair_enable()
260 if (events & EV_READ) { in be_pair_disable()
296 if ((iotype & EV_READ) != 0) in be_pair_flush()
Dbufferevent_sock.c194 bufferevent_disable(bufev, EV_READ); in bufferevent_readcb()
340 EV_READ|EV_PERSIST, bufferevent_readcb, bufev); in bufferevent_socket_new()
553 if (event & EV_READ) { in be_socket_enable()
569 if (event & EV_READ) { in be_socket_disable()
602 if (event_pending(&bufev->ev_read, EV_READ, NULL)) in be_socket_adj_timeouts()
630 EV_READ|EV_PERSIST, bufferevent_readcb, bufev); in be_socket_setfd()
Dselect.c186 res |= EV_READ; in select_dispatch()
274 if (events & EV_READ) in select_add()
301 if (events & EV_READ) in select_del()
Dwin32select.c223 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
227 if (events & EV_READ) { in win32_add()
247 if (events & EV_READ) in win32_del()
332 evmap_io_active(base, s, EV_READ); in win32_dispatch()
Dbufferevent.c72 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read()
84 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read()
85 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read()
416 impl_events &= ~EV_READ; in bufferevent_enable()
529 if (events & EV_READ) { in bufferevent_setwatermark()
796 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
837 if ((enabled & EV_READ) && !bev_p->read_suspended && in _bufferevent_generic_adj_timeouts()
Dbufferevent_async.c239 if (!beva->ok || !(bev->enabled&EV_READ)) { in bev_async_consider_reading()
333 if (what & EV_READ) in be_async_enable()
341 if (what & EV_READ) in be_async_enable()
356 if (what & EV_READ) { in be_async_disable()
Devent.c866 if (ev->ev_events & (EV_READ|EV_WRITE)) { in event_reinit()
1349 ev->ev_res & EV_READ ? "EV_READ " : " ", 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()
2059 ev->ev_events & EV_READ ? "EV_READ " : " ", 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.c358 which |= EV_READ; in kq_dispatch()
372 which |= EV_READ; in kq_dispatch()
/external/tlsdate/src/events/
Droute_up.c27 if (what != EV_READ) in action_stdin_wakeup()
44 if (what & EV_READ) in action_netlink_ready()
81 EV_READ|EV_PERSIST, handler, state); in setup_event_route_up()
Dsave.c33 if (what & EV_READ) in action_sync_and_save()
Dtlsdate_status.c130 EV_READ, in setup_tlsdate_status()
Dtime_set.c141 event = event_new (state->base, from_fds[0], EV_READ|EV_PERSIST, in setup_time_setter()
/external/libchrome/base/message_loop/
Dmessage_pump_libevent.cc157 event_mask |= EV_READ; in WatchFileDescriptor()
170 (EV_READ | EV_WRITE | EV_PERSIST); in WatchFileDescriptor()
336 event_set(wakeup_event_, wakeup_pipe_out_, EV_READ | EV_PERSIST, in Init()
358 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) { in OnLibeventNotification()
370 } else if (flags & EV_READ) { in OnLibeventNotification()
/external/curl/docs/examples/
Dhiperfifo.c183 (kind & EV_READ ? CURL_CSELECT_IN : 0) | in event_cb()
232 (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0)|EV_PERSIST; in setsock()
393 g->fifo_event = event_new(g->evbase, sockfd, EV_READ|EV_PERSIST, fifo_cb, g); in init_fifo()
Devhiperfifo.c191 int action = (revents&EV_READ?CURL_POLL_IN:0)| in event_cb()
235 int kind = (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0); in setsock()
409 ev_io_init(&g->fifo_event, fifo_cb, sockfd, EV_READ); in init_fifo()
/external/libweave/examples/provider/
Devent_task_runner.cc32 flags |= (what & kReadable) ? EV_READ : 0; in AddIoCompletionTask()
/external/tlsdate/src/
Ddbus.c44 events |= EV_READ; in dbus_to_event()
55 if (events & EV_READ) in event_to_dbus()
/external/libevent/include/event2/
Devent.h733 #define EV_READ 0x02 macro

12