Lines Matching refs:rate_limiting
120 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);
121 if (tick != bev->rate_limiting->limit.last_updated)
122 ev_token_bucket_update_(&bev->rate_limiting->limit,
123 bev->rate_limiting->cfg, tick);
216 if (!bev->rate_limiting)
224 if (bev->rate_limiting->cfg) {
226 max_so_far = LIM(bev->rate_limiting->limit);
228 if (bev->rate_limiting->group) {
230 bev->rate_limiting->group;
278 if (!bev->rate_limiting)
281 if (bev->rate_limiting->cfg) {
282 bev->rate_limiting->limit.read_limit -= bytes;
283 if (bev->rate_limiting->limit.read_limit <= 0) {
285 if (event_add(&bev->rate_limiting->refill_bucket_event,
286 &bev->rate_limiting->cfg->tick_timeout) < 0)
290 event_del(&bev->rate_limiting->refill_bucket_event);
295 if (bev->rate_limiting->group) {
296 LOCK_GROUP(bev->rate_limiting->group);
297 bev->rate_limiting->group->rate_limit.read_limit -= bytes;
298 bev->rate_limiting->group->total_read += bytes;
299 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) {
300 bev_group_suspend_reading_(bev->rate_limiting->group);
301 } else if (bev->rate_limiting->group->read_suspended) {
302 bev_group_unsuspend_reading_(bev->rate_limiting->group);
304 UNLOCK_GROUP(bev->rate_limiting->group);
316 if (!bev->rate_limiting)
319 if (bev->rate_limiting->cfg) {
320 bev->rate_limiting->limit.write_limit -= bytes;
321 if (bev->rate_limiting->limit.write_limit <= 0) {
323 if (event_add(&bev->rate_limiting->refill_bucket_event,
324 &bev->rate_limiting->cfg->tick_timeout) < 0)
328 event_del(&bev->rate_limiting->refill_bucket_event);
333 if (bev->rate_limiting->group) {
334 LOCK_GROUP(bev->rate_limiting->group);
335 bev->rate_limiting->group->rate_limit.write_limit -= bytes;
336 bev->rate_limiting->group->total_written += bytes;
337 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) {
338 bev_group_suspend_writing_(bev->rate_limiting->group);
339 } else if (bev->rate_limiting->group->write_suspended) {
340 bev_group_unsuspend_writing_(bev->rate_limiting->group);
342 UNLOCK_GROUP(bev->rate_limiting->group);
363 LIST_FOREACH(bev, &g->members, rate_limiting->next_in_group) {
381 LIST_FOREACH(bev, &g->members, rate_limiting->next_in_group) {
401 if (!bev->rate_limiting || !bev->rate_limiting->cfg) {
409 bev->rate_limiting->cfg);
410 ev_token_bucket_update_(&bev->rate_limiting->limit,
411 bev->rate_limiting->cfg,
416 if (bev->rate_limiting->limit.read_limit > 0)
422 if (bev->rate_limiting->limit.write_limit > 0)
435 event_add(&bev->rate_limiting->refill_bucket_event,
436 &bev->rate_limiting->cfg->tick_timeout);
462 bev = LIST_NEXT(bev, rate_limiting->next_in_group);
478 bev = LIST_NEXT(bev, rate_limiting->next_in_group)) { \
482 bev = LIST_NEXT(bev, rate_limiting->next_in_group)) { \
575 if (bevp->rate_limiting) {
576 rlim = bevp->rate_limiting;
590 if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {
595 if (bevp->rate_limiting == NULL) {
599 bevp->rate_limiting = rlim;
601 rlim = bevp->rate_limiting;
744 if (!bevp->rate_limiting) {
753 bevp->rate_limiting = rlim;
756 if (bevp->rate_limiting->group == g) {
760 if (bevp->rate_limiting->group)
764 bevp->rate_limiting->group = g;
766 LIST_INSERT_HEAD(&g->members, bevp, rate_limiting->next_in_group);
795 if (bevp->rate_limiting && bevp->rate_limiting->group) {
797 bevp->rate_limiting->group;
799 bevp->rate_limiting->group = NULL;
801 LIST_REMOVE(bevp, rate_limiting->next_in_group);
828 if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
830 r = bevp->rate_limiting->limit.read_limit;
847 if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
849 r = bevp->rate_limiting->limit.write_limit;
934 if (bufev_private->rate_limiting) {
935 cfg = bufev_private->rate_limiting->cfg;
979 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
980 old_limit = bevp->rate_limiting->limit.read_limit;
982 new_limit = (bevp->rate_limiting->limit.read_limit -= decr);
985 if (event_add(&bevp->rate_limiting->refill_bucket_event,
986 &bevp->rate_limiting->cfg->tick_timeout) < 0)
990 event_del(&bevp->rate_limiting->refill_bucket_event);
1008 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
1009 old_limit = bevp->rate_limiting->limit.write_limit;
1011 new_limit = (bevp->rate_limiting->limit.write_limit -= decr);
1014 if (event_add(&bevp->rate_limiting->refill_bucket_event,
1015 &bevp->rate_limiting->cfg->tick_timeout) < 0)
1019 event_del(&bevp->rate_limiting->refill_bucket_event);
1087 bev->rate_limiting = NULL;