Home
last modified time | relevance | path

Searched refs:read_suspended (Results 1 – 7 of 7) sorted by relevance

/external/libevent/
Dbufferevent_ratelim.c207 (is_write ? (g)->write_suspended : (g)->read_suspended) in bufferevent_get_rlim_max_()
288 } else if (bev->read_suspended & BEV_SUSPEND_BW) { in bufferevent_decrement_read_buckets_()
301 } else if (bev->rate_limiting->group->read_suspended) { in bufferevent_decrement_read_buckets_()
327 if (!(bev->read_suspended & BEV_SUSPEND_BW)) in bufferevent_decrement_write_buckets_()
354 g->read_suspended = 1; in bev_group_suspend_reading_()
415 if ((bev->read_suspended & BEV_SUSPEND_BW)) { in bev_refill_callback_()
493 g->read_suspended = 0; in bev_group_unsuspend_reading_()
543 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in bev_group_refill_callback_()
768 rsuspend = g->read_suspended; in bufferevent_add_to_rate_limit_group()
1018 if (!(bevp->read_suspended & BEV_SUSPEND_BW)) in bufferevent_decrement_write_limit()
Dbufferevent.c72 if (!bufev_private->read_suspended) in bufferevent_suspend_read_()
74 bufev_private->read_suspended |= what; in bufferevent_suspend_read_()
84 bufev_private->read_suspended &= ~what; in bufferevent_unsuspend_read_()
85 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
468 if (bufev_private->read_suspended) in bufferevent_enable()
954 if ((enabled & EV_READ) && !bev_p->read_suspended && in bufferevent_generic_adj_timeouts_()
Dbufferevent-internal.h88 unsigned read_suspended : 1; member
182 bufferevent_suspend_flags read_suspended; member
Dbufferevent_openssl.c588 if (bev_ssl->bev.read_suspended) in do_read()
600 if (bev_ssl->bev.read_suspended) in do_read()
752 if (bev->bev.read_suspended) { in bytes_to_read()
804 if (bev_ssl->bev.read_suspended) in consider_reading()
843 if (bev_ssl->bev.read_suspended || in consider_reading()
Dbufferevent_pair.c200 !dst->bev.read_suspended && in be_pair_wants_to_talk()
Dbufferevent_async.c265 if (beva->bev.read_suspended) { in bev_async_consider_reading()
Dbufferevent_sock.c184 if (bufev_p->read_suspended) in bufferevent_readcb()