51     const struct ev_token_bucket_cfg *cfg,  in ev_token_bucket_init_()  argument
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_()
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_()
66 		bucket->read_limit = cfg->read_rate;  in ev_token_bucket_init_()
67 		bucket->write_limit = cfg->write_rate;  in ev_token_bucket_init_()
75     const struct ev_token_bucket_cfg *cfg,  in ev_token_bucket_update_()  argument
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_()
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_()
120 	tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);  in bufferevent_update_buckets()
123 		    bev->rate_limiting->cfg, tick);  in bufferevent_update_buckets()
128     const struct ev_token_bucket_cfg *cfg)  in ev_token_bucket_get_tick_()  argument
139 	return (unsigned)(msec / cfg->msec_per_tick);  in ev_token_bucket_get_tick_()
176 ev_token_bucket_cfg_free(struct ev_token_bucket_cfg *cfg)  in ev_token_bucket_cfg_free()  argument
178 	mm_free(cfg);  in ev_token_bucket_cfg_free()
224 	if (bev->rate_limiting->cfg) {  in bufferevent_get_rlim_max_()
281 	if (bev->rate_limiting->cfg) {  in bufferevent_decrement_read_buckets_()
286 				&bev->rate_limiting->cfg->tick_timeout) < 0)  in bufferevent_decrement_read_buckets_()
319 	if (bev->rate_limiting->cfg) {  in bufferevent_decrement_write_buckets_()
324 				&bev->rate_limiting->cfg->tick_timeout) < 0)  in bufferevent_decrement_write_buckets_()
401 	if (!bev->rate_limiting || !bev->rate_limiting->cfg) {  in bev_refill_callback_()
409 	    bev->rate_limiting->cfg);  in bev_refill_callback_()
411 	    bev->rate_limiting->cfg,  in bev_refill_callback_()
436 		    &bev->rate_limiting->cfg->tick_timeout);  in bev_refill_callback_()
561     struct ev_token_bucket_cfg *cfg)  in bufferevent_set_rate_limit()  argument
573 	if (cfg == NULL) {  in bufferevent_set_rate_limit()
576 			rlim->cfg = NULL;  in bufferevent_set_rate_limit()
587 	tick = ev_token_bucket_get_tick_(&now, cfg);  in bufferevent_set_rate_limit()
589 	if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {  in bufferevent_set_rate_limit()
602 	reinit = rlim->cfg != NULL;  in bufferevent_set_rate_limit()
604 	rlim->cfg = cfg;  in bufferevent_set_rate_limit()
605 	ev_token_bucket_init_(&rlim->limit, cfg, tick, reinit);  in bufferevent_set_rate_limit()
628 		event_add(&rlim->refill_bucket_event, &cfg->tick_timeout);  in bufferevent_set_rate_limit()
639     const struct ev_token_bucket_cfg *cfg)  in bufferevent_rate_limit_group_new()  argument
646 	tick = ev_token_bucket_get_tick_(&now, cfg);  in bufferevent_rate_limit_group_new()
651 	memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg));  in bufferevent_rate_limit_group_new()
654 	ev_token_bucket_init_(&g->rate_limit, cfg, tick, 0);  in bufferevent_rate_limit_group_new()
659 	event_add(&g->master_refill_event, &cfg->tick_timeout);  in bufferevent_rate_limit_group_new()
674 	const struct ev_token_bucket_cfg *cfg)  in bufferevent_rate_limit_group_set_cfg()  argument
677 	if (!g || !cfg)  in bufferevent_rate_limit_group_set_cfg()
682 		&g->rate_limit_cfg.tick_timeout, &cfg->tick_timeout, ==);  in bufferevent_rate_limit_group_set_cfg()
683 	memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg));  in bufferevent_rate_limit_group_set_cfg()
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()
692 		event_add(&g->master_refill_event, &cfg->tick_timeout);  in bufferevent_rate_limit_group_set_cfg()
825 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {  in bufferevent_get_read_limit()
844 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {  in bufferevent_get_write_limit()
927 	struct ev_token_bucket_cfg *cfg;  in bufferevent_get_token_bucket_cfg()  local
932 		cfg = bufev_private->rate_limiting->cfg;  in bufferevent_get_token_bucket_cfg()
934 		cfg = NULL;  in bufferevent_get_token_bucket_cfg()
939 	return cfg;  in bufferevent_get_token_bucket_cfg()
976 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);  in bufferevent_decrement_read_limit()
983 			&bevp->rate_limiting->cfg->tick_timeout) < 0)  in bufferevent_decrement_read_limit()
1005 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);  in bufferevent_decrement_write_limit()
1012 			&bevp->rate_limiting->cfg->tick_timeout) < 0)  in bufferevent_decrement_write_limit()