Lines Matching refs:rlim

565 	struct bufferevent_rate_limit *rlim;  in bufferevent_set_rate_limit()  local
575 rlim = bevp->rate_limiting; in bufferevent_set_rate_limit()
576 rlim->cfg = NULL; in bufferevent_set_rate_limit()
579 if (event_initialized(&rlim->refill_bucket_event)) in bufferevent_set_rate_limit()
580 event_del(&rlim->refill_bucket_event); in bufferevent_set_rate_limit()
595 rlim = mm_calloc(1, sizeof(struct bufferevent_rate_limit)); in bufferevent_set_rate_limit()
596 if (!rlim) in bufferevent_set_rate_limit()
598 bevp->rate_limiting = rlim; in bufferevent_set_rate_limit()
600 rlim = bevp->rate_limiting; 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()
608 EVUTIL_ASSERT(event_initialized(&rlim->refill_bucket_event)); in bufferevent_set_rate_limit()
609 event_del(&rlim->refill_bucket_event); in bufferevent_set_rate_limit()
611 event_assign(&rlim->refill_bucket_event, bev->ev_base, in bufferevent_set_rate_limit()
614 if (rlim->limit.read_limit > 0) { in bufferevent_set_rate_limit()
620 if (rlim->limit.write_limit > 0) { in bufferevent_set_rate_limit()
628 event_add(&rlim->refill_bucket_event, &cfg->tick_timeout); in bufferevent_set_rate_limit()
743 struct bufferevent_rate_limit *rlim; in bufferevent_add_to_rate_limit_group() local
744 rlim = mm_calloc(1, sizeof(struct bufferevent_rate_limit)); in bufferevent_add_to_rate_limit_group()
745 if (!rlim) { in bufferevent_add_to_rate_limit_group()
749 event_assign(&rlim->refill_bucket_event, bev->ev_base, in bufferevent_add_to_rate_limit_group()
751 bevp->rate_limiting = rlim; in bufferevent_add_to_rate_limit_group()