Searched refs:read_suspended (Results 1 – 7 of 7) sorted by relevance
209 (is_write ? (g)->write_suspended : (g)->read_suspended) in _bufferevent_get_rlim_max()290 } else if (bev->read_suspended & BEV_SUSPEND_BW) { in _bufferevent_decrement_read_buckets()303 } else if (bev->rate_limiting->group->read_suspended) { in _bufferevent_decrement_read_buckets()329 if (!(bev->read_suspended & BEV_SUSPEND_BW)) in _bufferevent_decrement_write_buckets()356 g->read_suspended = 1; in _bev_group_suspend_reading()417 if ((bev->read_suspended & BEV_SUSPEND_BW)) { in _bev_refill_callback()492 g->read_suspended = 0; in _bev_group_unsuspend_reading()542 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in _bev_group_refill_callback()764 rsuspend = g->read_suspended; in bufferevent_add_to_rate_limit_group()947 if (!(bevp->read_suspended & BEV_SUSPEND_BW)) in bufferevent_decrement_write_limit()
71 if (!bufev_private->read_suspended) in bufferevent_suspend_read()73 bufev_private->read_suspended |= what; in bufferevent_suspend_read()83 bufev_private->read_suspended &= ~what; in bufferevent_unsuspend_read()84 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read()415 if (bufev_private->read_suspended) in bufferevent_enable()837 if ((enabled & EV_READ) && !bev_p->read_suspended && in _bufferevent_generic_adj_timeouts()
75 unsigned read_suspended : 1; member165 bufferevent_suspend_flags read_suspended; member
574 if (bev_ssl->bev.read_suspended) in do_read()586 if (bev_ssl->bev.read_suspended) in do_read()737 if (bev->bev.read_suspended) { in bytes_to_read()789 if (bev_ssl->bev.read_suspended) in consider_reading()831 if (bev_ssl->bev.read_suspended || in consider_reading()
205 !dst->bev.read_suspended && in be_pair_wants_to_talk()
161 if (bufev_p->read_suspended) in bufferevent_readcb()
263 if (beva->bev.read_suspended) { in bev_async_consider_reading()