Lines Matching refs:write_limit
63 if (bucket->write_limit > (ev_int64_t) cfg->write_maximum) in ev_token_bucket_init_()
64 bucket->write_limit = cfg->write_maximum; in ev_token_bucket_init_()
67 bucket->write_limit = cfg->write_rate; in ev_token_bucket_init_()
102 if ((cfg->write_maximum - bucket->write_limit) / n_ticks < cfg->write_rate) in ev_token_bucket_update_()
103 bucket->write_limit = cfg->write_maximum; in ev_token_bucket_update_()
105 bucket->write_limit += n_ticks * cfg->write_rate; in ev_token_bucket_update_()
204 (is_write ? (x).write_limit : (x).read_limit) in bufferevent_get_rlim_max_()
320 bev->rate_limiting->limit.write_limit -= bytes; in bufferevent_decrement_write_buckets_()
321 if (bev->rate_limiting->limit.write_limit <= 0) { in bufferevent_decrement_write_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_()
422 if (bev->rate_limiting->limit.write_limit > 0) in bev_refill_callback_()
547 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ in bev_group_refill_callback_()
620 if (rlim->limit.write_limit > 0) { in bufferevent_set_rate_limit()
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()
846 r = bevp->rate_limiting->limit.write_limit; in bufferevent_get_write_limit()
963 r = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_get_write_limit()
1006 old_limit = bevp->rate_limiting->limit.write_limit; in bufferevent_decrement_write_limit()
1008 new_limit = (bevp->rate_limiting->limit.write_limit -= decr); in bufferevent_decrement_write_limit()
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()