Searched refs:rate_limiting (Results 1 – 3 of 3) sorted by relevance
119 tick = ev_token_bucket_get_tick(&now, bev->rate_limiting->cfg); in bufferevent_update_buckets()120 if (tick != bev->rate_limiting->limit.last_updated) in bufferevent_update_buckets()121 ev_token_bucket_update(&bev->rate_limiting->limit, in bufferevent_update_buckets()122 bev->rate_limiting->cfg, tick); in bufferevent_update_buckets()218 if (!bev->rate_limiting) in _bufferevent_get_rlim_max()226 if (bev->rate_limiting->cfg) { in _bufferevent_get_rlim_max()228 max_so_far = LIM(bev->rate_limiting->limit); in _bufferevent_get_rlim_max()230 if (bev->rate_limiting->group) { in _bufferevent_get_rlim_max()232 bev->rate_limiting->group; in _bufferevent_get_rlim_max()280 if (!bev->rate_limiting) in _bufferevent_decrement_read_buckets()[all …]
631 if (bufev_private->rate_limiting) { in _bufferevent_decref_and_unlock()632 if (bufev_private->rate_limiting->group) in _bufferevent_decref_and_unlock()634 if (event_initialized(&bufev_private->rate_limiting->refill_bucket_event)) in _bufferevent_decref_and_unlock()635 event_del(&bufev_private->rate_limiting->refill_bucket_event); in _bufferevent_decref_and_unlock()636 event_debug_unassign(&bufev_private->rate_limiting->refill_bucket_event); in _bufferevent_decref_and_unlock()637 mm_free(bufev_private->rate_limiting); in _bufferevent_decref_and_unlock()638 bufev_private->rate_limiting = NULL; in _bufferevent_decref_and_unlock()
193 struct bufferevent_rate_limit *rate_limiting; member