61 		if (bucket->read_limit > (ev_int64_t) cfg->read_maximum)  in ev_token_bucket_init_()
62 			bucket->read_limit = cfg->read_maximum;  in ev_token_bucket_init_()
66 		bucket->read_limit = cfg->read_rate;  in ev_token_bucket_init_()
96 	if ((cfg->read_maximum - bucket->read_limit) / n_ticks < cfg->read_rate)  in ev_token_bucket_update_()
97 		bucket->read_limit = cfg->read_maximum;  in ev_token_bucket_update_()
99 		bucket->read_limit += n_ticks * cfg->read_rate;  in ev_token_bucket_update_()
204 	(is_write ? (x).write_limit : (x).read_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_()
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_()
416 		if (bev->rate_limiting->limit.read_limit > 0)  in bev_refill_callback_()
543 	    (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) {  in bev_group_refill_callback_()
615 	if (rlim->limit.read_limit > 0) {  in bufferevent_set_rate_limit()
686 	if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum)  in bufferevent_rate_limit_group_set_cfg()
687 		g->rate_limit.read_limit = cfg->read_maximum;  in bufferevent_rate_limit_group_set_cfg()
830 		r = bevp->rate_limiting->limit.read_limit;  in bufferevent_get_read_limit()
953 	r = grp->rate_limit.read_limit;  in bufferevent_rate_limit_group_get_read_limit()
980 	old_limit = bevp->rate_limiting->limit.read_limit;  in bufferevent_decrement_read_limit()
982 	new_limit = (bevp->rate_limiting->limit.read_limit -= decr);  in bufferevent_decrement_read_limit()
1034 	old_limit = grp->rate_limit.read_limit;  in bufferevent_rate_limit_group_decrement_read()
1035 	new_limit = (grp->rate_limit.read_limit -= decr);  in bufferevent_rate_limit_group_decrement_read()