Lines Matching refs:rate_limit
249 share = LIM(g->rate_limit) / g->n_members;
299 bev->rate_limiting->group->rate_limit.read_limit -= bytes;
301 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) {
337 bev->rate_limiting->group->rate_limit.write_limit -= bytes;
339 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) {
539 ev_token_bucket_update(&g->rate_limit, &g->rate_limit_cfg, tick);
542 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) {
546 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){
654 ev_token_bucket_init(&g->rate_limit, cfg, tick, 0);
682 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum)
683 g->rate_limit.read_limit = cfg->read_maximum;
684 if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum)
685 g->rate_limit.write_limit = cfg->write_maximum;
882 r = grp->rate_limit.read_limit;
895 r = grp->rate_limit.write_limit;
963 old_limit = grp->rate_limit.read_limit;
964 new_limit = (grp->rate_limit.read_limit -= decr);
983 old_limit = grp->rate_limit.write_limit;
984 new_limit = (grp->rate_limit.write_limit -= decr);