cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-08-04 01:36:23 -04:00
Code Issues Packages Projects Releases Wiki Activity

Functions to manipulate existing rate limiting groups.

Browse Source 
This patch adds a function to change the current rate limit of a rate
limiting group, and another to free an empty rate limiting group.
This commit is contained in:
Nick Mathewson 2010-03-12 00:46:39 -05:00
parent cdd4c4905b
commit ee41aca63e
2 changed files with 53 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
bufferevent_ratelim.c
View File

@ -614,6 +614,46 @@ bufferevent_rate_limit_group_new(struct event_base *base,
return g; return g;
} }
int
bufferevent_rate_limit_group_set_cfg(
struct bufferevent_rate_limit_group *g,
const struct ev_token_bucket_cfg *cfg)
{
int same_tick;
if (!g || !cfg)
return -1;
LOCK_GROUP(g);
same_tick = evutil_timercmp(
&g->rate_limit_cfg.tick_timeout, &cfg->tick_timeout, ==);
memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg));
if (g->rate_limit.read_limit > cfg->read_maximum)
g->rate_limit.read_limit = cfg->read_maximum;
if (g->rate_limit.write_limit > cfg->write_maximum)
g->rate_limit.write_limit = cfg->write_maximum;
if (!same_tick) {
/* This can cause a hiccup in the schedule */
event_add(&g->master_refill_event, &cfg->tick_timeout);
}
UNLOCK_GROUP(g);
return 0;
}
void
bufferevent_rate_limit_group_free(struct bufferevent_rate_limit_group *g)
{
LOCK_GROUP(g);
EVUTIL_ASSERT(0 == g->n_members);
event_del(&g->master_refill_event);
UNLOCK_GROUP(g);
EVTHREAD_FREE_LOCK(g->lock, EVTHREAD_LOCKTYPE_RECURSIVE);
mm_free(g);
}
int int
bufferevent_add_to_rate_limit_group(struct bufferevent *bev, bufferevent_add_to_rate_limit_group(struct bufferevent *bev,
struct bufferevent_rate_limit_group *g) struct bufferevent_rate_limit_group *g)

15
include/event2/bufferevent.h
View File

@ -585,8 +585,19 @@ int bufferevent_set_rate_limit(struct bufferevent *bev,
struct bufferevent_rate_limit_group *bufferevent_rate_limit_group_new( struct bufferevent_rate_limit_group *bufferevent_rate_limit_group_new(
struct event_base *base, struct event_base *base,
const struct ev_token_bucket_cfg *cfg); const struct ev_token_bucket_cfg *cfg);
/*XXX we need a bufferevent_rate_limit_group_set_cfg */ /**
/*XXX we need a bufferevent_rate_limit_group_free */ Change the rate-limiting settings for a given rate-limiting group.
Return 0 on success, -1 on failure.
*/
int bufferevent_rate_limit_group_set_cfg(
struct bufferevent_rate_limit_group *,
const struct ev_token_bucket_cfg *);
/**
Free a rate-limiting group. The group must have no members when
this function is called.
*/
void bufferevent_rate_limit_group_free(struct bufferevent_rate_limit_group *);
/** /**
Add 'bev' to the list of bufferevents whose aggregate reading and writing Add 'bev' to the list of bufferevents whose aggregate reading and writing