Lines Matching refs:rate_limit
249 share = LIM(g->rate_limit) / g->n_members; in _bufferevent_get_rlim_max()
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()
337 bev->rate_limiting->group->rate_limit.write_limit -= bytes; in _bufferevent_decrement_write_buckets()
339 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { in _bufferevent_decrement_write_buckets()
539 ev_token_bucket_update(&g->rate_limit, &g->rate_limit_cfg, tick); in _bev_group_refill_callback()
542 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in _bev_group_refill_callback()
546 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ in _bev_group_refill_callback()
654 ev_token_bucket_init(&g->rate_limit, cfg, tick, 0); in bufferevent_rate_limit_group_new()
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()
684 if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum) in bufferevent_rate_limit_group_set_cfg()
685 g->rate_limit.write_limit = cfg->write_maximum; in bufferevent_rate_limit_group_set_cfg()
882 r = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_get_read_limit()
895 r = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_get_write_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()
983 old_limit = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_decrement_write()
984 new_limit = (grp->rate_limit.write_limit -= decr); in bufferevent_rate_limit_group_decrement_write()