bevp              261 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_IS_SOCKET(bevp) ((bevp)->be_ops == &bufferevent_ops_socket)
bevp              262 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_IS_FILTER(bevp) ((bevp)->be_ops == &bufferevent_ops_filter)
bevp              263 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_IS_PAIR(bevp) ((bevp)->be_ops == &bufferevent_ops_pair)
bevp              267 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_IS_ASYNC(bevp) ((bevp)->be_ops == &bufferevent_ops_async)
bevp              269 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_IS_ASYNC(bevp) 0
bevp              210 opal/mca/event/libevent2022/libevent/bufferevent.c #define SCHEDULE_DEFERRED(bevp)						\
bevp              212 opal/mca/event/libevent2022/libevent/bufferevent.c 		bufferevent_incref(&(bevp)->bev);			\
bevp              214 opal/mca/event/libevent2022/libevent/bufferevent.c 			event_base_get_deferred_cb_queue((bevp)->bev.ev_base), \
bevp              215 opal/mca/event/libevent2022/libevent/bufferevent.c 			&(bevp)->deferred);				\
bevp               69 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 	struct bufferevent_pair *bevp;
bevp               71 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 	bevp = upcast(b);
bevp               72 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 	if (bevp->partner)
bevp               73 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 		_bufferevent_incref_and_lock(downcast(bevp->partner));
bevp               79 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 	struct bufferevent_pair *bevp = upcast(b);
bevp               80 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 	if (bevp->partner)
bevp               81 opal/mca/event/libevent2022/libevent/bufferevent_pair.c 		_bufferevent_decref_and_unlock(downcast(bevp->partner));
bevp              562 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp =
bevp              574 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (bevp->rate_limiting) {
bevp              575 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			rlim = bevp->rate_limiting;
bevp              589 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) {
bevp              594 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting == NULL) {
bevp              598 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting = rlim;
bevp              600 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		rlim = bevp->rate_limiting;
bevp              612 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	    _bev_refill_callback, bevp);
bevp              736 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp =
bevp              740 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (!bevp->rate_limiting) {
bevp              748 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    _bev_refill_callback, bevp);
bevp              749 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting = rlim;
bevp              752 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting->group == g) {
bevp              756 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting->group)
bevp              760 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp->rate_limiting->group = g;
bevp              762 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	TAILQ_INSERT_TAIL(&g->members, bevp, rate_limiting->next_in_group);
bevp              788 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp =
bevp              791 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->group) {
bevp              793 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		    bevp->rate_limiting->group;
bevp              795 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bevp->rate_limiting->group = NULL;
bevp              797 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		TAILQ_REMOVE(&g->members, bevp, rate_limiting->next_in_group);
bevp              821 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp;
bevp              823 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp = BEV_UPCAST(bev);
bevp              824 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
bevp              825 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bufferevent_update_buckets(bevp);
bevp              826 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		r = bevp->rate_limiting->limit.read_limit;
bevp              840 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp;
bevp              842 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp = BEV_UPCAST(bev);
bevp              843 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	if (bevp->rate_limiting && bevp->rate_limiting->cfg) {
bevp              844 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		bufferevent_update_buckets(bevp);
bevp              845 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		r = bevp->rate_limiting->limit.write_limit;
bevp              905 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp;
bevp              907 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp = BEV_UPCAST(bev);
bevp              908 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
bevp              909 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	old_limit = bevp->rate_limiting->limit.read_limit;
bevp              911 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	new_limit = (bevp->rate_limiting->limit.read_limit -= decr);
bevp              914 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (event_add(&bevp->rate_limiting->refill_bucket_event,
bevp              915 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			&bevp->rate_limiting->cfg->tick_timeout) < 0)
bevp              918 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (!(bevp->write_suspended & BEV_SUSPEND_BW))
bevp              919 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			event_del(&bevp->rate_limiting->refill_bucket_event);
bevp              934 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	struct bufferevent_private *bevp;
bevp              936 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	bevp = BEV_UPCAST(bev);
bevp              937 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg);
bevp              938 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	old_limit = bevp->rate_limiting->limit.write_limit;
bevp              940 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 	new_limit = (bevp->rate_limiting->limit.write_limit -= decr);
bevp              943 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (event_add(&bevp->rate_limiting->refill_bucket_event,
bevp              944 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			&bevp->rate_limiting->cfg->tick_timeout) < 0)
bevp              947 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 		if (!(bevp->read_suspended & BEV_SUSPEND_BW))
bevp              948 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c 			event_del(&bevp->rate_limiting->refill_bucket_event);