Lines Matching refs:rate_limit
247 share = LIM(g->rate_limit) / g->n_members; in bufferevent_get_rlim_max_()
297 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()
299 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()
335 bev->rate_limiting->group->rate_limit.write_limit -= bytes; in bufferevent_decrement_write_buckets_()
337 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { in bufferevent_decrement_write_buckets_()
540 ev_token_bucket_update_(&g->rate_limit, &g->rate_limit_cfg, tick); in bev_group_refill_callback_()
543 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in bev_group_refill_callback_()
547 (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()
685 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) in bufferevent_rate_limit_group_set_cfg()
686 g->rate_limit.read_limit = cfg->read_maximum; in bufferevent_rate_limit_group_set_cfg()
687 if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum) in bufferevent_rate_limit_group_set_cfg()
688 g->rate_limit.write_limit = cfg->write_maximum; in bufferevent_rate_limit_group_set_cfg()
950 r = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_get_read_limit()
963 r = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_get_write_limit()
1031 old_limit = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_decrement_read()
1032 new_limit = (grp->rate_limit.read_limit -= decr); in bufferevent_rate_limit_group_decrement_read()
1051 old_limit = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_decrement_write()
1052 new_limit = (grp->rate_limit.write_limit -= decr); in bufferevent_rate_limit_group_decrement_write()