Lines Matching refs:limit
121 if (tick != bev->rate_limiting->limit.last_updated) in bufferevent_update_buckets()
122 ev_token_bucket_update_(&bev->rate_limiting->limit, in bufferevent_update_buckets()
226 max_so_far = LIM(bev->rate_limiting->limit); in bufferevent_get_rlim_max_()
282 bev->rate_limiting->limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()
283 if (bev->rate_limiting->limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()
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_()
410 ev_token_bucket_update_(&bev->rate_limiting->limit, in bev_refill_callback_()
416 if (bev->rate_limiting->limit.read_limit > 0) in bev_refill_callback_()
422 if (bev->rate_limiting->limit.write_limit > 0) in bev_refill_callback_()
605 ev_token_bucket_init_(&rlim->limit, cfg, tick, reinit); in bufferevent_set_rate_limit()
614 if (rlim->limit.read_limit > 0) { in bufferevent_set_rate_limit()
620 if (rlim->limit.write_limit > 0) { in bufferevent_set_rate_limit()
827 r = bevp->rate_limiting->limit.read_limit; in bufferevent_get_read_limit()
846 r = bevp->rate_limiting->limit.write_limit; in bufferevent_get_write_limit()
977 old_limit = bevp->rate_limiting->limit.read_limit; in bufferevent_decrement_read_limit()
979 new_limit = (bevp->rate_limiting->limit.read_limit -= decr); in bufferevent_decrement_read_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()