rate_limiting     193 opal/mca/event/libevent2022/libevent/bufferevent-internal.h 	struct bufferevent_rate_limit *rate_limiting;
rate_limiting     631 opal/mca/event/libevent2022/libevent/bufferevent.c 	if (bufev_private->rate_limiting) {
rate_limiting     632 opal/mca/event/libevent2022/libevent/bufferevent.c 		if (bufev_private->rate_limiting->group)
rate_limiting     634 opal/mca/event/libevent2022/libevent/bufferevent.c 		if (event_initialized(&bufev_private->rate_limiting->refill_bucket_event))
rate_limiting     635 opal/mca/event/libevent2022/libevent/bufferevent.c 			event_del(&bufev_private->rate_limiting->refill_bucket_event);
rate_limiting     636 opal/mca/event/libevent2022/libevent/bufferevent.c 		event_debug_unassign(&bufev_private->rate_limiting->refill_bucket_event);
rate_limiting     637 opal/mca/event/libevent2022/libevent/bufferevent.c 		mm_free(bufev_private->rate_limiting);
rate_limiting     638 opal/mca/event/libevent2022/libevent/bufferevent.c 		bufev_private->rate_limiting = NULL;
rate_limiting     119 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	tick = ev_token_bucket_get_tick(&now, bev->rate_limiting->cfg);
rate_limiting     120 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (tick != bev->rate_limiting->limit.last_updated)
rate_limiting     121 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		ev_token_bucket_update(&bev->rate_limiting->limit,
rate_limiting     122 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bev->rate_limiting->cfg, tick);
rate_limiting     218 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bev->rate_limiting)
rate_limiting     226 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->cfg) {
rate_limiting     228 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		max_so_far = LIM(bev->rate_limiting->limit);
rate_limiting     230 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->group) {
rate_limiting     232 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bev->rate_limiting->group;
rate_limiting     280 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bev->rate_limiting)
rate_limiting     283 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->cfg) {
rate_limiting     284 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->limit.read_limit -= bytes;
rate_limiting     285 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->limit.read_limit <= 0) {
rate_limiting     287 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			if (event_add(&bev->rate_limiting->refill_bucket_event,
rate_limiting     288 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 				&bev->rate_limiting->cfg->tick_timeout) < 0)
rate_limiting     292 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 				event_del(&bev->rate_limiting->refill_bucket_event);
rate_limiting     297 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->group) {
rate_limiting     298 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		LOCK_GROUP(bev->rate_limiting->group);
rate_limiting     299 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->group->rate_limit.read_limit -= bytes;
rate_limiting     300 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->group->total_read += bytes;
rate_limiting     301 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->group->rate_limit.read_limit <= 0) {
rate_limiting     302 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			_bev_group_suspend_reading(bev->rate_limiting->group);
rate_limiting     303 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		} else if (bev->rate_limiting->group->read_suspended) {
rate_limiting     304 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			_bev_group_unsuspend_reading(bev->rate_limiting->group);
rate_limiting     306 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		UNLOCK_GROUP(bev->rate_limiting->group);
rate_limiting     318 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bev->rate_limiting)
rate_limiting     321 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->cfg) {
rate_limiting     322 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->limit.write_limit -= bytes;
rate_limiting     323 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->limit.write_limit <= 0) {
rate_limiting     325 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			if (event_add(&bev->rate_limiting->refill_bucket_event,
rate_limiting     326 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 				&bev->rate_limiting->cfg->tick_timeout) < 0)
rate_limiting     330 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 				event_del(&bev->rate_limiting->refill_bucket_event);
rate_limiting     335 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bev->rate_limiting->group) {
rate_limiting     336 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		LOCK_GROUP(bev->rate_limiting->group);
rate_limiting     337 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->group->rate_limit.write_limit -= bytes;
rate_limiting     338 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev->rate_limiting->group->total_written += bytes;
rate_limiting     339 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->group->rate_limit.write_limit <= 0) {
rate_limiting     340 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			_bev_group_suspend_writing(bev->rate_limiting->group);
rate_limiting     341 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		} else if (bev->rate_limiting->group->write_suspended) {
rate_limiting     342 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			_bev_group_unsuspend_writing(bev->rate_limiting->group);
rate_limiting     344 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		UNLOCK_GROUP(bev->rate_limiting->group);
rate_limiting     365 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	TAILQ_FOREACH(bev, &g->members, rate_limiting->next_in_group) {
rate_limiting     383 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	TAILQ_FOREACH(bev, &g->members, rate_limiting->next_in_group) {
rate_limiting     403 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bev->rate_limiting || !bev->rate_limiting->cfg) {
rate_limiting     411 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	    bev->rate_limiting->cfg);
rate_limiting     412 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	ev_token_bucket_update(&bev->rate_limiting->limit,
rate_limiting     413 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	    bev->rate_limiting->cfg,
rate_limiting     418 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->limit.read_limit > 0)
rate_limiting     424 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bev->rate_limiting->limit.write_limit > 0)
rate_limiting     437 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		event_add(&bev->rate_limiting->refill_bucket_event,
rate_limiting     438 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    &bev->rate_limiting->cfg->tick_timeout);
rate_limiting     461 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bev = TAILQ_NEXT(bev, rate_limiting->next_in_group);
rate_limiting     477 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bev = TAILQ_NEXT(bev, rate_limiting->next_in_group)) { \
rate_limiting     481 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bev = TAILQ_NEXT(bev, rate_limiting->next_in_group)) { \
rate_limiting     574 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bevp->rate_limiting) {
rate_limiting     575 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			rlim = bevp->rate_limiting;
rate_limiting     589 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {
rate_limiting     594 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting == NULL) {
rate_limiting     598 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting = rlim;
rate_limiting     600 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		rlim = bevp->rate_limiting;
rate_limiting     740 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bevp->rate_limiting) {
rate_limiting     749 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting = rlim;
rate_limiting     752 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting->group == g) {
rate_limiting     756 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting->group)
rate_limiting     760 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp->rate_limiting->group = g;
rate_limiting     762 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	TAILQ_INSERT_TAIL(&g->members, bevp, rate_limiting->next_in_group);
rate_limiting     791 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->group) {
rate_limiting     793 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bevp->rate_limiting->group;
rate_limiting     795 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting->group = NULL;
rate_limiting     797 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		TAILQ_REMOVE(&g->members, bevp, rate_limiting->next_in_group);
rate_limiting     824 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
rate_limiting     826 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		r = bevp->rate_limiting->limit.read_limit;
rate_limiting     843 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
rate_limiting     845 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		r = bevp->rate_limiting->limit.write_limit;
rate_limiting     908 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
rate_limiting     909 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	old_limit = bevp->rate_limiting->limit.read_limit;
rate_limiting     911 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	new_limit = (bevp->rate_limiting->limit.read_limit -= decr);
rate_limiting     914 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (event_add(&bevp->rate_limiting->refill_bucket_event,
rate_limiting     915 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			&bevp->rate_limiting->cfg->tick_timeout) < 0)
rate_limiting     919 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			event_del(&bevp->rate_limiting->refill_bucket_event);
rate_limiting     937 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
rate_limiting     938 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	old_limit = bevp->rate_limiting->limit.write_limit;
rate_limiting     940 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	new_limit = (bevp->rate_limiting->limit.write_limit -= decr);
rate_limiting     943 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (event_add(&bevp->rate_limiting->refill_bucket_event,
rate_limiting     944 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			&bevp->rate_limiting->cfg->tick_timeout) < 0)
rate_limiting     948 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			event_del(&bevp->rate_limiting->refill_bucket_event);