/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...] |