• Home
  • Raw
  • Download

Lines Matching refs:read_limit

60 		if (bucket->read_limit > (ev_int64_t) cfg->read_maximum)  in ev_token_bucket_init()
61 bucket->read_limit = cfg->read_maximum; in ev_token_bucket_init()
65 bucket->read_limit = cfg->read_rate; in ev_token_bucket_init()
95 if ((cfg->read_maximum - bucket->read_limit) / n_ticks < cfg->read_rate) in ev_token_bucket_update()
96 bucket->read_limit = cfg->read_maximum; in ev_token_bucket_update()
98 bucket->read_limit += n_ticks * cfg->read_rate; in ev_token_bucket_update()
206 (is_write ? (x).write_limit : (x).read_limit) in _bufferevent_get_rlim_max()
284 bev->rate_limiting->limit.read_limit -= bytes; in _bufferevent_decrement_read_buckets()
285 if (bev->rate_limiting->limit.read_limit <= 0) { in _bufferevent_decrement_read_buckets()
299 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in _bufferevent_decrement_read_buckets()
301 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { in _bufferevent_decrement_read_buckets()
418 if (bev->rate_limiting->limit.read_limit > 0) in _bev_refill_callback()
542 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in _bev_group_refill_callback()
614 if (rlim->limit.read_limit > 0) { in bufferevent_set_rate_limit()
682 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) in bufferevent_rate_limit_group_set_cfg()
683 g->rate_limit.read_limit = cfg->read_maximum; in bufferevent_rate_limit_group_set_cfg()
826 r = bevp->rate_limiting->limit.read_limit; in bufferevent_get_read_limit()
882 r = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_get_read_limit()
909 old_limit = bevp->rate_limiting->limit.read_limit; in bufferevent_decrement_read_limit()
911 new_limit = (bevp->rate_limiting->limit.read_limit -= decr); in bufferevent_decrement_read_limit()
963 old_limit = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_decrement_read()
964 new_limit = (grp->rate_limit.read_limit -= decr); in bufferevent_rate_limit_group_decrement_read()