Lines Matching refs:bevp
562 struct bufferevent_private *bevp =
574 if (bevp->rate_limiting) {
575 rlim = bevp->rate_limiting;
589 if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {
594 if (bevp->rate_limiting == NULL) {
598 bevp->rate_limiting = rlim;
600 rlim = bevp->rate_limiting;
612 _bev_refill_callback, bevp);
736 struct bufferevent_private *bevp =
740 if (!bevp->rate_limiting) {
748 _bev_refill_callback, bevp);
749 bevp->rate_limiting = rlim;
752 if (bevp->rate_limiting->group == g) {
756 if (bevp->rate_limiting->group)
760 bevp->rate_limiting->group = g;
762 TAILQ_INSERT_TAIL(&g->members, bevp, rate_limiting->next_in_group);
788 struct bufferevent_private *bevp =
791 if (bevp->rate_limiting && bevp->rate_limiting->group) {
793 bevp->rate_limiting->group;
795 bevp->rate_limiting->group = NULL;
797 TAILQ_REMOVE(&g->members, bevp, rate_limiting->next_in_group);
821 struct bufferevent_private *bevp;
823 bevp = BEV_UPCAST(bev);
824 if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
825 bufferevent_update_buckets(bevp);
826 r = bevp->rate_limiting->limit.read_limit;
840 struct bufferevent_private *bevp;
842 bevp = BEV_UPCAST(bev);
843 if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
844 bufferevent_update_buckets(bevp);
845 r = bevp->rate_limiting->limit.write_limit;
905 struct bufferevent_private *bevp;
907 bevp = BEV_UPCAST(bev);
908 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
909 old_limit = bevp->rate_limiting->limit.read_limit;
911 new_limit = (bevp->rate_limiting->limit.read_limit -= decr);
914 if (event_add(&bevp->rate_limiting->refill_bucket_event,
915 &bevp->rate_limiting->cfg->tick_timeout) < 0)
918 if (!(bevp->write_suspended & BEV_SUSPEND_BW))
919 event_del(&bevp->rate_limiting->refill_bucket_event);
934 struct bufferevent_private *bevp;
936 bevp = BEV_UPCAST(bev);
937 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
938 old_limit = bevp->rate_limiting->limit.write_limit;
940 new_limit = (bevp->rate_limiting->limit.write_limit -= decr);
943 if (event_add(&bevp->rate_limiting->refill_bucket_event,
944 &bevp->rate_limiting->cfg->tick_timeout) < 0)
947 if (!(bevp->read_suspended & BEV_SUSPEND_BW))
948 event_del(&bevp->rate_limiting->refill_bucket_event);