| /external/libevent/include/event2/ |
| bufferevent_struct.h | 84 struct event ev_write; member in struct:bufferevent
107 /** Events that are currently enabled: currently EV_READ and EV_WRITE
|
| /external/libevent/ |
| bufferevent_sock.c | 134 (bufev->enabled & EV_WRITE) &&
135 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
139 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) {
242 * event==EV_TIMEOUT|EV_WRITE, we can safely ignore the
261 event_del(&bufev->ev_write);
270 event_del(&bufev->ev_write);
279 if (!(bufev->enabled & EV_WRITE) ||
281 event_del(&bufev->ev_write);
315 event_del(&bufev->ev_write);
[all...] |
| bufferevent_openssl.c | 379 * ev_read and ev_write) start reading. Take the read-blocked-on-write flag
393 r = bufferevent_add_event_(&bev->ev_write,
400 * ev_read and ev_write) start writing. Take the write-blocked-on-read flag
413 r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write);
445 event_del(&bev->ev_write);
473 if (!(bev->enabled & EV_WRITE))
489 if (bev->enabled & EV_WRITE)
723 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS);
874 while ((bev_ssl->bev.bev.enabled & EV_WRITE) &&
890 event_del(&bev_ssl->bev.bev.ev_write);
[all...] |
| bufferevent-internal.h | 268 /** Enables one or more of EV_READ|EV_WRITE on a bufferevent. Does
274 /** Disables one or more of EV_READ|EV_WRITE on a bufferevent. Does
340 first resets 'connecting' flag to force EV_WRITE down for sure.
346 @param event any combination of EV_READ | EV_WRITE.
395 if ((iotype & EV_WRITE) && ((options & BEV_TRIG_IGNORE_WATERMARKS) ||
406 * anything else with ev_read and ev_write, to handle timeouts.
408 /** Internal use: Set up the ev_read and ev_write callbacks so that
415 * that enabled EV_READ or EV_WRITE, or that disables EV_READ or EV_WRITE. */
436 event_add(&(bev)->ev_write, &(bev)->timeout_write);
[all...] |
| bufferevent.c | 97 bufev->be_ops->disable(bufev, EV_WRITE);
109 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE))
110 bufev->be_ops->enable(bufev, EV_WRITE);
322 * Set to EV_WRITE so that using bufferevent_write is going to
326 bufev->enabled = EV_WRITE;
471 impl_events &= ~EV_WRITE;
577 if (events & EV_WRITE) {
621 if (events == EV_WRITE) {
705 cbs[1] = &bufev->ev_write.ev_evcallback;
933 bufferevent_disable(bev, EV_WRITE);
[all...] |
| /external/libevent/test/ |
| regress_ssl.c | 252 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0);
288 bufferevent_enable(bev, EV_WRITE);
299 bufferevent_disable(bev, EV_WRITE);
469 bufferevent_enable(bev1, EV_READ|EV_WRITE);
470 bufferevent_enable(bev2, EV_READ|EV_WRITE);
491 bufferevent_enable(bev1, EV_READ|EV_WRITE);
492 bufferevent_disable(bev2, EV_READ|EV_WRITE);
516 bufferevent_enable(bev, EV_READ|EV_WRITE);
546 bufferevent_disable(bev, EV_READ|EV_WRITE);
548 bufferevent_enable(bev, EV_READ|EV_WRITE);
[all...] |
| regress_bufferevent.c | 168 tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE);
169 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ);
176 tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0);
420 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL);
435 bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000);
437 bufferevent_getwatermark(bev1, EV_WRITE, &low, &high);
442 int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high);
454 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL));
607 bufferevent_disable(bev,EV_READ|EV_WRITE);
[all...] |
