65 void init_rt_rq(struct rt_rq *rt_rq)  in init_rt_rq()  argument
70 	array = &rt_rq->active;  in init_rt_rq()
79 	rt_rq->highest_prio.curr = MAX_RT_PRIO-1;  in init_rt_rq()
80 	rt_rq->highest_prio.next = MAX_RT_PRIO-1;  in init_rt_rq()
81 	rt_rq->overloaded = 0;  in init_rt_rq()
82 	plist_head_init(&rt_rq->pushable_tasks);  in init_rt_rq()
85 	rt_rq->rt_queued = 0;  in init_rt_rq()
88 	rt_rq->rt_time = 0;  in init_rt_rq()
89 	rt_rq->rt_throttled = 0;  in init_rt_rq()
90 	rt_rq->rt_runtime = 0;  in init_rt_rq()
91 	raw_spin_lock_init(&rt_rq->rt_runtime_lock);  in init_rt_rq()
176 static inline struct rq *rq_of_rt_rq(struct rt_rq *rt_rq)  in rq_of_rt_rq()  argument
178 	return rt_rq->rq;  in rq_of_rt_rq()
181 static inline struct rt_rq *rt_rq_of_se(struct sched_rt_entity *rt_se)  in rt_rq_of_se()
183 	return rt_se->rt_rq;  in rt_rq_of_se()
188 	struct rt_rq *rt_rq = rt_se->rt_rq;  in rq_of_rt_se()  local
190 	return rt_rq->rq;  in rq_of_rt_se()
204 		if (tg->rt_rq)  in free_rt_sched_group()
205 			kfree(tg->rt_rq[i]);  in free_rt_sched_group()
210 	kfree(tg->rt_rq);  in free_rt_sched_group()
214 void init_tg_rt_entry(struct task_group *tg, struct rt_rq *rt_rq,  in init_tg_rt_entry()  argument
220 	rt_rq->highest_prio.curr = MAX_RT_PRIO-1;  in init_tg_rt_entry()
221 	rt_rq->rt_nr_boosted = 0;  in init_tg_rt_entry()
222 	rt_rq->rq = rq;  in init_tg_rt_entry()
223 	rt_rq->tg = tg;  in init_tg_rt_entry()
225 	tg->rt_rq[cpu] = rt_rq;  in init_tg_rt_entry()
232 		rt_se->rt_rq = &rq->rt;  in init_tg_rt_entry()
234 		rt_se->rt_rq = parent->my_q;  in init_tg_rt_entry()
236 	rt_se->my_q = rt_rq;  in init_tg_rt_entry()
243 	struct rt_rq *rt_rq;  in alloc_rt_sched_group()  local
247 	tg->rt_rq = kcalloc(nr_cpu_ids, sizeof(rt_rq), GFP_KERNEL);  in alloc_rt_sched_group()
248 	if (!tg->rt_rq)  in alloc_rt_sched_group()
257 		rt_rq = kzalloc_node(sizeof(struct rt_rq),  in alloc_rt_sched_group()
259 		if (!rt_rq)  in alloc_rt_sched_group()
267 		init_rt_rq(rt_rq);  in alloc_rt_sched_group()
268 		rt_rq->rt_runtime = tg->rt_bandwidth.rt_runtime;  in alloc_rt_sched_group()
269 		init_tg_rt_entry(tg, rt_rq, rt_se, i, parent->rt_se[i]);  in alloc_rt_sched_group()
275 	kfree(rt_rq);  in alloc_rt_sched_group()
289 static inline struct rq *rq_of_rt_rq(struct rt_rq *rt_rq)  in rq_of_rt_rq()  argument
291 	return container_of(rt_rq, struct rq, rt);  in rq_of_rt_rq()
301 static inline struct rt_rq *rt_rq_of_se(struct sched_rt_entity *rt_se)  in rt_rq_of_se()
434 static void enqueue_top_rt_rq(struct rt_rq *rt_rq);
435 static void dequeue_top_rt_rq(struct rt_rq *rt_rq, unsigned int count);
483 static inline u64 sched_rt_runtime(struct rt_rq *rt_rq)  in sched_rt_runtime()  argument
485 	if (!rt_rq->tg)  in sched_rt_runtime()
488 	return rt_rq->rt_runtime;  in sched_rt_runtime()
491 static inline u64 sched_rt_period(struct rt_rq *rt_rq)  in sched_rt_period()  argument
493 	return ktime_to_ns(rt_rq->tg->rt_bandwidth.rt_period);  in sched_rt_period()
511 #define for_each_rt_rq(rt_rq, iter, rq)					\  argument
514 		(rt_rq = iter->rt_rq[cpu_of(rq)]);)
519 static inline struct rt_rq *group_rt_rq(struct sched_rt_entity *rt_se)  in group_rt_rq()
527 static void sched_rt_rq_enqueue(struct rt_rq *rt_rq)  in sched_rt_rq_enqueue()  argument
529 	struct task_struct *donor = rq_of_rt_rq(rt_rq)->donor;  in sched_rt_rq_enqueue()
530 	struct rq *rq = rq_of_rt_rq(rt_rq);  in sched_rt_rq_enqueue()
535 	rt_se = rt_rq->tg->rt_se[cpu];  in sched_rt_rq_enqueue()
537 	if (rt_rq->rt_nr_running) {  in sched_rt_rq_enqueue()
539 			enqueue_top_rt_rq(rt_rq);  in sched_rt_rq_enqueue()
543 		if (rt_rq->highest_prio.curr < donor->prio)  in sched_rt_rq_enqueue()
548 static void sched_rt_rq_dequeue(struct rt_rq *rt_rq)  in sched_rt_rq_dequeue()  argument
551 	int cpu = cpu_of(rq_of_rt_rq(rt_rq));  in sched_rt_rq_dequeue()
553 	rt_se = rt_rq->tg->rt_se[cpu];  in sched_rt_rq_dequeue()
556 		dequeue_top_rt_rq(rt_rq, rt_rq->rt_nr_running);  in sched_rt_rq_dequeue()
558 		cpufreq_update_util(rq_of_rt_rq(rt_rq), 0);  in sched_rt_rq_dequeue()
564 static inline int rt_rq_throttled(struct rt_rq *rt_rq)  in rt_rq_throttled()  argument
566 	return rt_rq->rt_throttled && !rt_rq->rt_nr_boosted;  in rt_rq_throttled()
571 	struct rt_rq *rt_rq = group_rt_rq(rt_se);  in rt_se_boosted()  local
574 	if (rt_rq)  in rt_se_boosted()
575 		return !!rt_rq->rt_nr_boosted;  in rt_se_boosted()
594 struct rt_rq *sched_rt_period_rt_rq(struct rt_bandwidth *rt_b, int cpu)  in sched_rt_period_rt_rq()
596 	return container_of(rt_b, struct task_group, rt_bandwidth)->rt_rq[cpu];  in sched_rt_period_rt_rq()
599 static inline struct rt_bandwidth *sched_rt_bandwidth(struct rt_rq *rt_rq)  in sched_rt_bandwidth()  argument
601 	return &rt_rq->tg->rt_bandwidth;  in sched_rt_bandwidth()
604 bool sched_rt_bandwidth_account(struct rt_rq *rt_rq)  in sched_rt_bandwidth_account()  argument
606 	struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq);  in sched_rt_bandwidth_account()
609 		rt_rq->rt_time < rt_b->rt_runtime);  in sched_rt_bandwidth_account()
616 static void do_balance_runtime(struct rt_rq *rt_rq)  in do_balance_runtime()  argument
618 	struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq);  in do_balance_runtime()
619 	struct root_domain *rd = rq_of_rt_rq(rt_rq)->rd;  in do_balance_runtime()
628 		struct rt_rq *iter = sched_rt_period_rt_rq(rt_b, i);  in do_balance_runtime()
631 		if (iter == rt_rq)  in do_balance_runtime()
650 			if (rt_rq->rt_runtime + diff > rt_period)  in do_balance_runtime()
651 				diff = rt_period - rt_rq->rt_runtime;  in do_balance_runtime()
653 			rt_rq->rt_runtime += diff;  in do_balance_runtime()
654 			if (rt_rq->rt_runtime == rt_period) {  in do_balance_runtime()
672 	struct rt_rq *rt_rq;  in __disable_runtime()  local
677 	for_each_rt_rq(rt_rq, iter, rq) {  in __disable_runtime()
678 		struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq);  in __disable_runtime()
683 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in __disable_runtime()
689 		if (rt_rq->rt_runtime == RUNTIME_INF ||  in __disable_runtime()
690 				rt_rq->rt_runtime == rt_b->rt_runtime)  in __disable_runtime()
692 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in __disable_runtime()
699 		want = rt_b->rt_runtime - rt_rq->rt_runtime;  in __disable_runtime()
705 			struct rt_rq *iter = sched_rt_period_rt_rq(rt_b, i);  in __disable_runtime()
711 			if (iter == rt_rq || iter->rt_runtime == RUNTIME_INF)  in __disable_runtime()
729 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in __disable_runtime()
740 		rt_rq->rt_runtime = RUNTIME_INF;  in __disable_runtime()
741 		rt_rq->rt_throttled = 0;  in __disable_runtime()
742 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in __disable_runtime()
746 		sched_rt_rq_enqueue(rt_rq);  in __disable_runtime()
753 	struct rt_rq *rt_rq;  in __enable_runtime()  local
761 	for_each_rt_rq(rt_rq, iter, rq) {  in __enable_runtime()
762 		struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq);  in __enable_runtime()
765 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in __enable_runtime()
766 		rt_rq->rt_runtime = rt_b->rt_runtime;  in __enable_runtime()
767 		rt_rq->rt_time = 0;  in __enable_runtime()
768 		rt_rq->rt_throttled = 0;  in __enable_runtime()
769 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in __enable_runtime()
774 static void balance_runtime(struct rt_rq *rt_rq)  in balance_runtime()  argument
779 	if (rt_rq->rt_time > rt_rq->rt_runtime) {  in balance_runtime()
780 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in balance_runtime()
781 		do_balance_runtime(rt_rq);  in balance_runtime()
782 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in balance_runtime()
786 static inline void balance_runtime(struct rt_rq *rt_rq) {}  in balance_runtime()  argument
810 		struct rt_rq *rt_rq = sched_rt_period_rt_rq(rt_b, i);  in do_sched_rt_period_timer()  local
811 		struct rq *rq = rq_of_rt_rq(rt_rq);  in do_sched_rt_period_timer()
819 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in do_sched_rt_period_timer()
820 		if (!sched_feat(RT_RUNTIME_SHARE) && rt_rq->rt_runtime != RUNTIME_INF)  in do_sched_rt_period_timer()
821 			rt_rq->rt_runtime = rt_b->rt_runtime;  in do_sched_rt_period_timer()
822 		skip = !rt_rq->rt_time && !rt_rq->rt_nr_running;  in do_sched_rt_period_timer()
823 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in do_sched_rt_period_timer()
830 		if (rt_rq->rt_time) {  in do_sched_rt_period_timer()
833 			raw_spin_lock(&rt_rq->rt_runtime_lock);  in do_sched_rt_period_timer()
834 			if (rt_rq->rt_throttled)  in do_sched_rt_period_timer()
835 				balance_runtime(rt_rq);  in do_sched_rt_period_timer()
836 			runtime = rt_rq->rt_runtime;  in do_sched_rt_period_timer()
837 			rt_rq->rt_time -= min(rt_rq->rt_time, overrun*runtime);  in do_sched_rt_period_timer()
838 			if (rt_rq->rt_throttled && rt_rq->rt_time < runtime) {  in do_sched_rt_period_timer()
839 				rt_rq->rt_throttled = 0;  in do_sched_rt_period_timer()
849 				if (rt_rq->rt_nr_running && rq->curr == rq->idle)  in do_sched_rt_period_timer()
852 			if (rt_rq->rt_time || rt_rq->rt_nr_running)  in do_sched_rt_period_timer()
854 			raw_spin_unlock(&rt_rq->rt_runtime_lock);  in do_sched_rt_period_timer()
855 		} else if (rt_rq->rt_nr_running) {  in do_sched_rt_period_timer()
857 			if (!rt_rq_throttled(rt_rq))  in do_sched_rt_period_timer()
860 		if (rt_rq->rt_throttled)  in do_sched_rt_period_timer()
864 			sched_rt_rq_enqueue(rt_rq);  in do_sched_rt_period_timer()
874 static int sched_rt_runtime_exceeded(struct rt_rq *rt_rq)  in sched_rt_runtime_exceeded()  argument
876 	u64 runtime = sched_rt_runtime(rt_rq);  in sched_rt_runtime_exceeded()
878 	if (rt_rq->rt_throttled)  in sched_rt_runtime_exceeded()
879 		return rt_rq_throttled(rt_rq);  in sched_rt_runtime_exceeded()
881 	if (runtime >= sched_rt_period(rt_rq))  in sched_rt_runtime_exceeded()
884 	balance_runtime(rt_rq);  in sched_rt_runtime_exceeded()
885 	runtime = sched_rt_runtime(rt_rq);  in sched_rt_runtime_exceeded()
889 	if (rt_rq->rt_time > runtime) {  in sched_rt_runtime_exceeded()
890 		struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq);  in sched_rt_runtime_exceeded()
897 			rt_rq->rt_throttled = 1;  in sched_rt_runtime_exceeded()
905 			rt_rq->rt_time = 0;  in sched_rt_runtime_exceeded()
908 		if (rt_rq_throttled(rt_rq)) {  in sched_rt_runtime_exceeded()
909 			sched_rt_rq_dequeue(rt_rq);  in sched_rt_runtime_exceeded()
919 typedef struct rt_rq *rt_rq_iter_t;
921 #define for_each_rt_rq(rt_rq, iter, rq) \  argument
922 	for ((void) iter, rt_rq = &rq->rt; rt_rq; rt_rq = NULL)
927 static inline struct rt_rq *group_rt_rq(struct sched_rt_entity *rt_se)  in group_rt_rq()
932 static inline void sched_rt_rq_enqueue(struct rt_rq *rt_rq)  in sched_rt_rq_enqueue()  argument
934 	struct rq *rq = rq_of_rt_rq(rt_rq);  in sched_rt_rq_enqueue()
936 	if (!rt_rq->rt_nr_running)  in sched_rt_rq_enqueue()
939 	enqueue_top_rt_rq(rt_rq);  in sched_rt_rq_enqueue()
943 static inline void sched_rt_rq_dequeue(struct rt_rq *rt_rq)  in sched_rt_rq_dequeue()  argument
945 	dequeue_top_rt_rq(rt_rq, rt_rq->rt_nr_running);  in sched_rt_rq_dequeue()
948 static inline int rt_rq_throttled(struct rt_rq *rt_rq)  in rt_rq_throttled()  argument
959 struct rt_rq *sched_rt_period_rt_rq(struct rt_bandwidth *rt_b, int cpu)  in sched_rt_period_rt_rq()
974 	struct rt_rq *rt_rq = group_rt_rq(rt_se);  in rt_se_prio()  local
976 	if (rt_rq)  in rt_se_prio()
977 		return rt_rq->highest_prio.curr;  in rt_se_prio()
1006 		struct rt_rq *rt_rq = rt_rq_of_se(rt_se);  in update_curr_rt()  local
1009 		if (sched_rt_runtime(rt_rq) != RUNTIME_INF) {  in update_curr_rt()
1010 			raw_spin_lock(&rt_rq->rt_runtime_lock);  in update_curr_rt()
1011 			rt_rq->rt_time += delta_exec;  in update_curr_rt()
1012 			exceeded = sched_rt_runtime_exceeded(rt_rq);  in update_curr_rt()
1015 			raw_spin_unlock(&rt_rq->rt_runtime_lock);  in update_curr_rt()
1017 				do_start_rt_bandwidth(sched_rt_bandwidth(rt_rq));  in update_curr_rt()
1024 dequeue_top_rt_rq(struct rt_rq *rt_rq, unsigned int count)  in dequeue_top_rt_rq()  argument
1026 	struct rq *rq = rq_of_rt_rq(rt_rq);  in dequeue_top_rt_rq()
1028 	BUG_ON(&rq->rt != rt_rq);  in dequeue_top_rt_rq()
1030 	if (!rt_rq->rt_queued)  in dequeue_top_rt_rq()
1036 	rt_rq->rt_queued = 0;  in dequeue_top_rt_rq()
1041 enqueue_top_rt_rq(struct rt_rq *rt_rq)  in enqueue_top_rt_rq()  argument
1043 	struct rq *rq = rq_of_rt_rq(rt_rq);  in enqueue_top_rt_rq()
1045 	BUG_ON(&rq->rt != rt_rq);  in enqueue_top_rt_rq()
1047 	if (rt_rq->rt_queued)  in enqueue_top_rt_rq()
1050 	if (rt_rq_throttled(rt_rq))  in enqueue_top_rt_rq()
1053 	if (rt_rq->rt_nr_running) {  in enqueue_top_rt_rq()
1054 		add_nr_running(rq, rt_rq->rt_nr_running);  in enqueue_top_rt_rq()
1055 		rt_rq->rt_queued = 1;  in enqueue_top_rt_rq()
1065 inc_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio)  in inc_rt_prio_smp()  argument
1067 	struct rq *rq = rq_of_rt_rq(rt_rq);  in inc_rt_prio_smp()
1073 	if (&rq->rt != rt_rq)  in inc_rt_prio_smp()
1081 dec_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio)  in dec_rt_prio_smp()  argument
1083 	struct rq *rq = rq_of_rt_rq(rt_rq);  in dec_rt_prio_smp()
1089 	if (&rq->rt != rt_rq)  in dec_rt_prio_smp()
1092 	if (rq->online && rt_rq->highest_prio.curr != prev_prio)  in dec_rt_prio_smp()
1093 		cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio.curr);  in dec_rt_prio_smp()
1099 void inc_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) {}  in inc_rt_prio_smp()  argument
1101 void dec_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) {}  in dec_rt_prio_smp()  argument
1107 inc_rt_prio(struct rt_rq *rt_rq, int prio)  in inc_rt_prio()  argument
1109 	int prev_prio = rt_rq->highest_prio.curr;  in inc_rt_prio()
1112 		rt_rq->highest_prio.curr = prio;  in inc_rt_prio()
1114 	inc_rt_prio_smp(rt_rq, prio, prev_prio);  in inc_rt_prio()
1118 dec_rt_prio(struct rt_rq *rt_rq, int prio)  in dec_rt_prio()  argument
1120 	int prev_prio = rt_rq->highest_prio.curr;  in dec_rt_prio()
1122 	if (rt_rq->rt_nr_running) {  in dec_rt_prio()
1131 			struct rt_prio_array *array = &rt_rq->active;  in dec_rt_prio()
1133 			rt_rq->highest_prio.curr =  in dec_rt_prio()
1138 		rt_rq->highest_prio.curr = MAX_RT_PRIO-1;  in dec_rt_prio()
1141 	dec_rt_prio_smp(rt_rq, prio, prev_prio);  in dec_rt_prio()
1146 static inline void inc_rt_prio(struct rt_rq *rt_rq, int prio) {}  in inc_rt_prio()  argument
1147 static inline void dec_rt_prio(struct rt_rq *rt_rq, int prio) {}  in dec_rt_prio()  argument
1154 inc_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)  in inc_rt_group()  argument
1157 		rt_rq->rt_nr_boosted++;  in inc_rt_group()
1159 	if (rt_rq->tg)  in inc_rt_group()
1160 		start_rt_bandwidth(&rt_rq->tg->rt_bandwidth);  in inc_rt_group()
1164 dec_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)  in dec_rt_group()  argument
1167 		rt_rq->rt_nr_boosted--;  in dec_rt_group()
1169 	WARN_ON(!rt_rq->rt_nr_running && rt_rq->rt_nr_boosted);  in dec_rt_group()
1175 inc_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)  in inc_rt_group()  argument
1180 void dec_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) {}  in dec_rt_group()  argument
1187 	struct rt_rq *group_rq = group_rt_rq(rt_se);  in rt_se_nr_running()
1198 	struct rt_rq *group_rq = group_rt_rq(rt_se);  in rt_se_rr_nr_running()
1210 void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)  in inc_rt_tasks()  argument
1215 	rt_rq->rt_nr_running += rt_se_nr_running(rt_se);  in inc_rt_tasks()
1216 	rt_rq->rr_nr_running += rt_se_rr_nr_running(rt_se);  in inc_rt_tasks()
1218 	inc_rt_prio(rt_rq, prio);  in inc_rt_tasks()
1219 	inc_rt_group(rt_se, rt_rq);  in inc_rt_tasks()
1223 void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)  in dec_rt_tasks()  argument
1226 	WARN_ON(!rt_rq->rt_nr_running);  in dec_rt_tasks()
1227 	rt_rq->rt_nr_running -= rt_se_nr_running(rt_se);  in dec_rt_tasks()
1228 	rt_rq->rr_nr_running -= rt_se_rr_nr_running(rt_se);  in dec_rt_tasks()
1230 	dec_rt_prio(rt_rq, rt_se_prio(rt_se));  in dec_rt_tasks()
1231 	dec_rt_group(rt_se, rt_rq);  in dec_rt_tasks()
1270 update_stats_wait_start_rt(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se)  in update_stats_wait_start_rt()  argument
1285 	__update_stats_wait_start(rq_of_rt_rq(rt_rq), p, stats);  in update_stats_wait_start_rt()
1289 update_stats_enqueue_sleeper_rt(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se)  in update_stats_enqueue_sleeper_rt()  argument
1304 	__update_stats_enqueue_sleeper(rq_of_rt_rq(rt_rq), p, stats);  in update_stats_enqueue_sleeper_rt()
1308 update_stats_enqueue_rt(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se,  in update_stats_enqueue_rt()  argument
1315 		update_stats_enqueue_sleeper_rt(rt_rq, rt_se);  in update_stats_enqueue_rt()
1319 update_stats_wait_end_rt(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se)  in update_stats_wait_end_rt()  argument
1334 	__update_stats_wait_end(rq_of_rt_rq(rt_rq), p, stats);  in update_stats_wait_end_rt()
1338 update_stats_dequeue_rt(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se,  in update_stats_dequeue_rt()  argument
1355 					rq_clock(rq_of_rt_rq(rt_rq)));  in update_stats_dequeue_rt()
1359 					rq_clock(rq_of_rt_rq(rt_rq)));  in update_stats_dequeue_rt()
1365 	struct rt_rq *rt_rq = rt_rq_of_se(rt_se);  in __enqueue_rt_entity()  local
1366 	struct rt_prio_array *array = &rt_rq->active;  in __enqueue_rt_entity()
1367 	struct rt_rq *group_rq = group_rt_rq(rt_se);  in __enqueue_rt_entity()
1394 	inc_rt_tasks(rt_se, rt_rq);  in __enqueue_rt_entity()
1399 	struct rt_rq *rt_rq = rt_rq_of_se(rt_se);  in __dequeue_rt_entity()  local
1400 	struct rt_prio_array *array = &rt_rq->active;  in __dequeue_rt_entity()
1408 	dec_rt_tasks(rt_se, rt_rq);  in __dequeue_rt_entity()
1456 		struct rt_rq *rt_rq = group_rt_rq(rt_se);  in dequeue_rt_entity()  local
1458 		if (rt_rq && rt_rq->rt_nr_running)  in dequeue_rt_entity()
1501 requeue_rt_entity(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se, int head)  in requeue_rt_entity()  argument
1504 		struct rt_prio_array *array = &rt_rq->active;  in requeue_rt_entity()
1517 	struct rt_rq *rt_rq;  in requeue_task_rt()  local
1520 		rt_rq = rt_rq_of_se(rt_se);  in requeue_task_rt()
1521 		requeue_rt_entity(rt_rq, rt_se, head);  in requeue_task_rt()
1680 	struct rt_rq *rt_rq = &rq->rt;  in set_next_task_rt()  local
1684 		update_stats_wait_end_rt(rt_rq, rt_se);  in set_next_task_rt()
1703 static struct sched_rt_entity *pick_next_rt_entity(struct rt_rq *rt_rq)  in pick_next_rt_entity()  argument
1705 	struct rt_prio_array *array = &rt_rq->active;  in pick_next_rt_entity()
1724 	struct rt_rq *rt_rq  = &rq->rt;  in _pick_next_task_rt()  local
1727 		rt_se = pick_next_rt_entity(rt_rq);  in _pick_next_task_rt()
1730 		rt_rq = group_rt_rq(rt_se);  in _pick_next_task_rt()
1731 	} while (rt_rq);  in _pick_next_task_rt()
1751 	struct rt_rq *rt_rq = &rq->rt;  in put_prev_task_rt()  local
1754 		update_stats_wait_start_rt(rt_rq, rt_se);  in put_prev_task_rt()
2603 	struct rt_rq *rt_rq;  in task_is_throttled_rt()  local
2606 	rt_rq = task_group(p)->rt_rq[cpu];  in task_is_throttled_rt()
2608 	rt_rq = &cpu_rq(cpu)->rt;  in task_is_throttled_rt()
2611 	return rt_rq_throttled(rt_rq);  in task_is_throttled_rt()
2794 		struct rt_rq *rt_rq = tg->rt_rq[i];  in tg_set_rt_bandwidth()  local
2796 		raw_spin_lock(&rt_rq->rt_runtime_lock);  in tg_set_rt_bandwidth()
2797 		rt_rq->rt_runtime = rt_runtime;  in tg_set_rt_bandwidth()
2798 		raw_spin_unlock(&rt_rq->rt_runtime_lock);  in tg_set_rt_bandwidth()
2973 	struct rt_rq *rt_rq;  in print_rt_stats()  local
2976 	for_each_rt_rq(rt_rq, iter, cpu_rq(cpu))  in print_rt_stats()
2977 		print_rt_rq(m, cpu, rt_rq);  in print_rt_stats()