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