sntp/libevent/bufferevent_ratelim.c

563 	struct bufferevent_private *bevp =
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;
613 	    -1, EV_FINALIZE, bev_refill_callback_, bevp);
740 	struct bufferevent_private *bevp =
744 	if (!bevp->rate_limiting) {
752 		    -1, EV_FINALIZE, bev_refill_callback_, bevp);
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);
792 	struct bufferevent_private *bevp =
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);
825 	struct bufferevent_private *bevp;
827 	bevp = BEV_UPCAST(bev);
828 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
829 		bufferevent_update_buckets(bevp);
830 		r = bevp->rate_limiting->limit.read_limit;
844 	struct bufferevent_private *bevp;
846 	bevp = BEV_UPCAST(bev);
847 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
848 		bufferevent_update_buckets(bevp);
849 		r = bevp->rate_limiting->limit.write_limit;
860 	struct bufferevent_private *bevp;
862 	bevp = BEV_UPCAST(bev);
864 		bevp->max_single_read = MAX_SINGLE_READ_DEFAULT;
866 		bevp->max_single_read = size;
874 	struct bufferevent_private *bevp;
876 	bevp = BEV_UPCAST(bev);
878 		bevp->max_single_write = MAX_SINGLE_WRITE_DEFAULT;
880 		bevp->max_single_write = size;
976 	struct bufferevent_private *bevp;
978 	bevp = BEV_UPCAST(bev);
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)
989 		if (!(bevp->write_suspended & BEV_SUSPEND_BW))
990 			event_del(&bevp->rate_limiting->refill_bucket_event);
1005 	struct bufferevent_private *bevp;
1007 	bevp = BEV_UPCAST(bev);
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)
1018 		if (!(bevp->read_suspended & BEV_SUSPEND_BW))
1019 			event_del(&bevp->rate_limiting->refill_bucket_event);