| /external/libevent/ |
| evport.c | 99 short fdi_what; /* combinations of EV_READ and EV_WRITE */
103 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE)
343 res = EV_READ | EV_WRITE;
348 res |= EV_WRITE;
355 res |= EV_READ|EV_WRITE;
433 if (events & EV_WRITE)
434 fdi->fdi_what &= ~EV_WRITE;
453 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) {
|
| bufferevent_sock.c | 111 (bufev->enabled & EV_WRITE) &&
112 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
116 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) {
216 * event==EV_TIMEOUT|EV_WRITE, we can safely ignore the
235 event_del(&bufev->ev_write);
243 event_del(&bufev->ev_write);
252 if (!(bufev->enabled & EV_WRITE) ||
254 event_del(&bufev->ev_write);
288 event_del(&bufev->ev_write);
[all...] |
| bufferevent_pair.c | 203 return (downcast(src)->enabled & EV_WRITE) &&
240 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output))
249 if ((events & EV_WRITE) && partner &&
263 if (events & EV_WRITE)
299 if ((iotype & EV_WRITE) != 0)
|
| poll.c | 200 res |= EV_WRITE;
219 if (!(events & (EV_READ|EV_WRITE)))
258 if (events & EV_WRITE)
280 if (!(events & (EV_READ|EV_WRITE)))
292 if (events & EV_WRITE)
|
| epoll.c | 211 } else if (ch->old_events & EV_WRITE) {
243 } else if (ch->old_events & EV_WRITE) {
359 if (events & EV_WRITE)
377 if (events & EV_WRITE)
428 ev = EV_READ | EV_WRITE;
433 ev |= EV_WRITE;
|
| devpoll.c | 211 which |= EV_WRITE;
241 if (events & EV_WRITE)
260 if (events & EV_WRITE)
279 if ((res & POLLIN) && (old & EV_WRITE)) {
|
| bufferevent_filter.c | 208 bufferevent_enable(underlying, EV_READ|EV_WRITE);
251 if (event & EV_WRITE)
266 if (event & EV_WRITE)
331 if (!(bufev->enabled & EV_WRITE) ||
363 (bufev->enabled & EV_WRITE) &&
376 (bufev->enabled & EV_WRITE) &&
483 if (iotype & EV_WRITE) {
|
| evmap.c | 292 old |= EV_WRITE;
298 if (ev->ev_events & EV_WRITE) {
300 res |= EV_WRITE;
362 old |= EV_WRITE;
369 if (ev->ev_events & EV_WRITE) {
371 res |= EV_WRITE;
668 if (events & EV_WRITE) {
716 if (events & EV_WRITE) {
717 if (!(change->old_events & EV_WRITE) &&
784 if (ev->ev_events & (EV_READ|EV_WRITE)) {
[all...] |
| win32select.c | 223 if (!(events & (EV_READ|EV_WRITE)))
231 if (events & EV_WRITE) {
249 if (events & EV_WRITE)
341 evmap_io_active(base, s, EV_WRITE);
351 evmap_io_active(base, s, EV_WRITE);
|
| bufferevent_openssl.c | 373 * ev_read and ev_write) start reading. Take the read-blocked-on-write flag
387 r = _bufferevent_add_event(&bev->ev_write,
394 * ev_read and ev_write) start writing. Take the write-blocked-on-read flag
404 r = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write);
435 event_del(&bev->ev_write);
463 if (!(bev->enabled & EV_WRITE))
479 if (bev->enabled & EV_WRITE)
865 while ((bev_ssl->bev.bev.enabled & EV_WRITE) &&
881 event_del(&bev_ssl->bev.bev.ev_write);
883 !(bev_ssl->bev.bev.enabled & EV_WRITE)) {
[all...] |
| select.c | 188 res |= EV_WRITE;
276 if (events & EV_WRITE)
304 if (events & EV_WRITE)
|
| bufferevent.c | 96 bufev->be_ops->disable(bufev, EV_WRITE);
108 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE))
109 bufev->be_ops->enable(bufev, EV_WRITE);
301 * Set to EV_WRITE so that using bufferevent_write is going to
305 bufev->enabled = EV_WRITE;
418 impl_events &= ~EV_WRITE;
524 if (events & EV_WRITE) {
642 event_debug_unassign(&bufev->ev_write);
805 bufferevent_disable(bev, EV_WRITE);
815 evtimer_assign(&bev->ev_write, bev->ev_base
[all...] |
| bufferevent_async.c | 193 if (!beva->ok || !(bev->enabled&EV_WRITE) ||
335 if (what & EV_WRITE)
343 if (what & EV_WRITE)
360 if (what & EV_WRITE) {
387 if (event_initialized(&bev->ev_write)) {
388 event_del(&bev->ev_write);
|
| event.c | 866 if (ev->ev_events & (EV_READ|EV_WRITE)) {
[all...] |
| kqueue.c | 374 which |= EV_WRITE;
|
| http.c | 395 bufferevent_enable(evcon->bufev, EV_WRITE);
401 bufferevent_disable(evcon->bufev, EV_WRITE);
408 bufferevent_enable(evcon->bufev, EV_WRITE);
706 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE);
[all...] |
| evdns.c | 235 char write_waiting; /* true if we are waiting for EV_WRITE events */
[all...] |
| /external/libchrome/base/message_loop/ |
| message_pump_libevent.cc | 152 event_mask |= EV_WRITE;
162 (EV_READ | EV_WRITE | EV_PERSIST);
333 if ((flags & (EV_READ | EV_WRITE)) == (EV_READ | EV_WRITE)) {
343 } else if (flags & EV_WRITE) {
|
| /system/extras/simpleperf/ |
| IOEventLoop.cpp | 90 return AddEvent(fd, EV_WRITE | EV_PERSIST, nullptr, callback);
|
| /external/curl/docs/examples/ |
| hiperfifo.c | 188 (kind & EV_WRITE ? CURL_CSELECT_OUT : 0);
236 (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0)|EV_PERSIST;
|
| evhiperfifo.c | 208 (revents&EV_WRITE?CURL_POLL_OUT:0);
250 int kind = (act&CURL_POLL_IN?EV_READ:0)|(act&CURL_POLL_OUT?EV_WRITE:0);
|
| /bionic/libc/upstream-netbsd/lib/libc/include/isc/ |
| eventlib.h | 78 #define EV_WRITE 2
|
| /bionic/libc/upstream-netbsd/lib/libc/isc/ |
| eventlib_p.h | 48 #define EV_MASK_ALL (EV_READ | EV_WRITE | EV_EXCEPT)
|
| ev_streams.c | 79 if (evSelectFD(opaqueCtx, fd, EV_WRITE, writable, new, &new->file) < 0)
|
| /external/libevent/include/event2/ |
| event.h | 735 #define EV_WRITE 0x04
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...] |
