| /external/libevent/ |
| evport.c | 99 short fdi_what; /* combinations of EV_READ and EV_WRITE */
102 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
343 res = EV_READ | EV_WRITE;
346 res |= EV_READ;
355 res |= EV_READ|EV_WRITE;
431 if (events & EV_READ)
432 fdi->fdi_what &= ~EV_READ;
453 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) {
|
| bufferevent_pair.c | 204 (downcast(dst)->enabled & EV_READ) &&
237 if (events & EV_READ) {
244 if ((events & EV_READ) && partner &&
260 if (events & EV_READ) {
296 if ((iotype & EV_READ) != 0)
|
| poll.c | 198 res |= EV_READ;
219 if (!(events & (EV_READ|EV_WRITE)))
260 if (events & EV_READ)
280 if (!(events & (EV_READ|EV_WRITE)))
290 if (events & EV_READ)
|
| epoll.c | 204 } else if (ch->old_events & EV_READ) {
250 if (ch->old_events & EV_READ) {
362 if (events & EV_READ)
379 if (events & EV_READ)
428 ev = EV_READ | EV_WRITE;
431 ev |= EV_READ;
|
| bufferevent_openssl.c | 373 * ev_read and ev_write) start reading. Take the read-blocked-on-write flag
385 r = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read);
394 * ev_read and ev_write) start writing. Take the write-blocked-on-read flag
406 r = _bufferevent_add_event(&bev->ev_read,
422 event_del(&bev->ev_read);
465 if (bev->enabled & EV_READ)
477 if (!(bev->enabled & EV_READ))
733 if (! (bev->bev.bev.enabled & EV_READ)) {
832 !(bev_ssl->bev.bev.enabled & EV_READ)) {
833 event_del(&bev_ssl->bev.bev.ev_read);
[all...] |
| devpoll.c | 209 which |= EV_READ;
239 if (events & EV_READ)
258 if (events & EV_READ)
282 } else if ((res & POLLOUT) && (old & EV_READ)) {
|
| evmap.c | 290 old |= EV_READ;
294 if (ev->ev_events & EV_READ) {
296 res |= EV_READ;
360 old |= EV_READ;
364 if (ev->ev_events & EV_READ) {
366 res |= EV_READ;
664 if (events & (EV_READ|EV_SIGNAL)) {
709 if (events & (EV_READ|EV_SIGNAL)) {
710 if (!(change->old_events & (EV_READ | EV_SIGNAL)) &&
784 if (ev->ev_events & (EV_READ|EV_WRITE))
[all...] |
| bufferevent_filter.c | 208 bufferevent_enable(underlying, EV_READ|EV_WRITE);
254 if (event & EV_READ) {
268 if (event & EV_READ) {
287 if (!(bev->enabled & EV_READ) ||
304 (bev->enabled & EV_READ) &&
480 if (iotype & EV_READ) {
|
| win32select.c | 223 if (!(events & (EV_READ|EV_WRITE)))
227 if (events & EV_READ) {
247 if (events & EV_READ)
332 evmap_io_active(base, s, EV_READ);
|
| select.c | 186 res |= EV_READ;
274 if (events & EV_READ)
301 if (events & EV_READ)
|
| bufferevent_sock.c | 137 * event==EV_TIMEOUT|EV_READ, we can safely ignore the
194 bufferevent_disable(bufev, EV_READ);
236 event_del(&bufev->ev_read);
339 event_assign(&bufev->ev_read, bufev->ev_base, fd,
340 EV_READ|EV_PERSIST, bufferevent_readcb, bufev);
553 if (event & EV_READ) {
554 if (be_socket_add(&bufev->ev_read,&bufev->timeout_read) == -1)
569 if (event & EV_READ) {
570 if (event_del(&bufev->ev_read) == -1)
589 fd = event_get_fd(&bufev->ev_read);
[all...] |
| bufferevent.c | 72 bufev->be_ops->disable(bufev, EV_READ);
84 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ))
85 bufev->be_ops->enable(bufev, EV_READ);
416 impl_events &= ~EV_READ;
529 if (events & EV_READ) {
641 event_debug_unassign(&bufev->ev_read);
796 bufferevent_disable(bev, EV_READ);
813 evtimer_assign(&bev->ev_read, bev->ev_base,
823 r1 = event_del(&bev->ev_read);
837 if ((enabled & EV_READ) && !bev_p->read_suspended &
[all...] |
| bufferevent_async.c | 239 if (!beva->ok || !(bev->enabled&EV_READ)) {
333 if (what & EV_READ)
341 if (what & EV_READ)
356 if (what & EV_READ) {
|
| kqueue.c | 358 which |= EV_READ;
372 which |= EV_READ;
|
| event.c | 866 if (ev->ev_events & (EV_READ|EV_WRITE)) {
[all...] |
| /external/libchrome/base/message_loop/ |
| message_pump_libevent.cc | 149 event_mask |= EV_READ;
162 (EV_READ | EV_WRITE | EV_PERSIST);
311 event_set(wakeup_event_, wakeup_pipe_out_, EV_READ | EV_PERSIST,
333 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) {
345 } else if (flags & EV_READ) {
|
| /system/core/debuggerd/tombstoned/ |
| tombstoned.cpp | 150 event_assign(crash->crash_event, base, crash->crash_fd, EV_TIMEOUT | EV_READ,
176 event* crash_event = event_new(base, sockfd, EV_TIMEOUT | EV_READ, crash_request_cb, crash);
190 } else if ((ev & EV_READ) == 0) {
234 if ((ev & EV_READ) == 0) {
|
| intercept_manager.cpp | 78 } else if ((ev & EV_READ) == 0) {
145 event_assign(intercept->intercept_event, intercept_manager->base, sockfd, EV_READ | EV_TIMEOUT,
167 event_new(base, sockfd, EV_TIMEOUT | EV_READ, intercept_request_cb, intercept);
|
| /external/curl/docs/examples/ |
| hiperfifo.c | 187 (kind & EV_READ ? CURL_CSELECT_IN : 0) |
236 (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0)|EV_PERSIST;
399 g->fifo_event = event_new(g->evbase, sockfd, EV_READ|EV_PERSIST, fifo_cb, g);
|
| evhiperfifo.c | 207 int action = (revents&EV_READ?CURL_POLL_IN:0)|
250 int kind = (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0);
417 ev_io_init(&g->fifo_event, fifo_cb, sockfd, EV_READ);
|
| /system/extras/simpleperf/ |
| IOEventLoop.cpp | 82 return AddEvent(fd, EV_READ | EV_PERSIST, nullptr, callback);
|
| /bionic/libc/upstream-netbsd/lib/libc/include/isc/ |
| eventlib.h | 77 #define EV_READ 1
|
| /bionic/libc/upstream-netbsd/lib/libc/isc/ |
| eventlib_p.h | 48 #define EV_MASK_ALL (EV_READ | EV_WRITE | EV_EXCEPT)
|
| ev_streams.c | 113 if (evSelectFD(opaqueCtx, fd, EV_READ, readable, new, &new->file) < 0)
|
| /external/libevent/include/event2/ |
| event.h | 733 #define EV_READ 0x02
801 If events contains one of EV_READ, EV_WRITE, or EV_READ|EV_WRITE, then
812 The EV_ET flag is compatible with EV_READ and EV_WRITE, and supported
824 EV_READ, EV_WRITE, or EV_SIGNAL. Here the EV_TIMEOUT flag indicates
831 @param events desired events to monitor: bitfield of EV_READ, EV_WRITE,
[all...] |
