Searched refs:rate_limit (Results 1 – 5 of 5) sorted by relevance
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_()655 ev_token_bucket_init_(&g->rate_limit, cfg, tick, 0); in bufferevent_rate_limit_group_new()686 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) in bufferevent_rate_limit_group_set_cfg()[all …]
83 struct ev_token_bucket rate_limit; member
443 __u32 rate_limit; /* messages rate limit (per second) */ member
742 __u32 rate_limit; member
3987 static int get_qstep_adj(int rate_excess, int rate_limit) { argument3989 rate_limit ? ((rate_excess + rate_limit / 2) / rate_limit) : INT_MAX;