sntp/libevent/bufferevent_ratelim.c

51     const struct ev_token_bucket_cfg *cfg,
61 		if (bucket->read_limit > (ev_int64_t) cfg->read_maximum)
62 			bucket->read_limit = cfg->read_maximum;
63 		if (bucket->write_limit > (ev_int64_t) cfg->write_maximum)
64 			bucket->write_limit = cfg->write_maximum;
66 		bucket->read_limit = cfg->read_rate;
67 		bucket->write_limit = cfg->write_rate;
75     const struct ev_token_bucket_cfg *cfg,
88 		bucket->limit += n_ticks * cfg->rate;
90 		if (bucket->limit > cfg->maximum)
91 			bucket->limit = cfg->maximum;
96 	if ((cfg->read_maximum - bucket->read_limit) / n_ticks < cfg->read_rate)
97 		bucket->read_limit = cfg->read_maximum;
99 		bucket->read_limit += n_ticks * cfg->read_rate;
102 	if ((cfg->write_maximum - bucket->write_limit) / n_ticks < cfg->write_rate)
103 		bucket->write_limit = cfg->write_maximum;
105 		bucket->write_limit += n_ticks * cfg->write_rate;
120 	tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);
123 		    bev->rate_limiting->cfg, tick);
128     const struct ev_token_bucket_cfg *cfg)
139 	return (unsigned)(msec / cfg->msec_per_tick);
176 ev_token_bucket_cfg_free(struct ev_token_bucket_cfg *cfg)
178 	mm_free(cfg);
224 	if (bev->rate_limiting->cfg) {
281 	if (bev->rate_limiting->cfg) {
286 				&bev->rate_limiting->cfg->tick_timeout) < 0)
319 	if (bev->rate_limiting->cfg) {
324 				&bev->rate_limiting->cfg->tick_timeout) < 0)
401 	if (!bev->rate_limiting || !bev->rate_limiting->cfg) {
409 	    bev->rate_limiting->cfg);
411 	    bev->rate_limiting->cfg,
436 		    &bev->rate_limiting->cfg->tick_timeout);
561     struct ev_token_bucket_cfg *cfg)
570 	/* XXX reference-count cfg */
574 	if (cfg == NULL) {
577 			rlim->cfg = NULL;
588 	tick = ev_token_bucket_get_tick_(&now, cfg);
590 	if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {
603 	reinit = rlim->cfg != NULL;
605 	rlim->cfg = cfg;
606 	ev_token_bucket_init_(&rlim->limit, cfg, tick, reinit);
629 		event_add(&rlim->refill_bucket_event, &cfg->tick_timeout);
640     const struct ev_token_bucket_cfg *cfg)
647 	tick = ev_token_bucket_get_tick_(&now, cfg);
652 	memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg));
655 	ev_token_bucket_init_(&g->rate_limit, cfg, tick, 0);
660 	event_add(&g->master_refill_event, &cfg->tick_timeout);
675 	const struct ev_token_bucket_cfg *cfg)
678 	if (!g || !cfg)
683 		&g->rate_limit_cfg.tick_timeout, &cfg->tick_timeout, ==);
684 	memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg));
686 	if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum)
687 		g->rate_limit.read_limit = cfg->read_maximum;
688 	if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum)
689 		g->rate_limit.write_limit = cfg->write_maximum;
693 		event_add(&g->master_refill_event, &cfg->tick_timeout);
828 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
847 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
930 	struct ev_token_bucket_cfg *cfg;
935 		cfg = bufev_private->rate_limiting->cfg;
937 		cfg = NULL;
942 	return cfg;
979 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
986 			&bevp->rate_limiting->cfg->tick_timeout) < 0)
1008 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
1015 			&bevp->rate_limiting->cfg->tick_timeout) < 0)