Lines Matching refs:rt_rq

78 void init_rt_rq(struct rt_rq *rt_rq)  in init_rt_rq()  argument
83 array = &rt_rq->active; in init_rt_rq()
92 rt_rq->highest_prio.curr = MAX_RT_PRIO; in init_rt_rq()
93 rt_rq->highest_prio.next = MAX_RT_PRIO; in init_rt_rq()
94 rt_rq->rt_nr_migratory = 0; in init_rt_rq()
95 rt_rq->overloaded = 0; in init_rt_rq()
96 plist_head_init(&rt_rq->pushable_tasks); in init_rt_rq()
99 rt_rq->rt_queued = 0; in init_rt_rq()
101 rt_rq->rt_time = 0; in init_rt_rq()
102 rt_rq->rt_throttled = 0; in init_rt_rq()
103 rt_rq->rt_runtime = 0; in init_rt_rq()
104 raw_spin_lock_init(&rt_rq->rt_runtime_lock); in init_rt_rq()
123 static inline struct rq *rq_of_rt_rq(struct rt_rq *rt_rq) in rq_of_rt_rq() argument
125 return rt_rq->rq; in rq_of_rt_rq()
128 static inline struct rt_rq *rt_rq_of_se(struct sched_rt_entity *rt_se) in rt_rq_of_se()
130 return rt_se->rt_rq; in rt_rq_of_se()
135 struct rt_rq *rt_rq = rt_se->rt_rq; in rq_of_rt_se() local
137 return rt_rq->rq; in rq_of_rt_se()
148 if (tg->rt_rq) in free_rt_sched_group()
149 kfree(tg->rt_rq[i]); in free_rt_sched_group()
154 kfree(tg->rt_rq); in free_rt_sched_group()
158 void init_tg_rt_entry(struct task_group *tg, struct rt_rq *rt_rq, in init_tg_rt_entry() argument
164 rt_rq->highest_prio.curr = MAX_RT_PRIO; in init_tg_rt_entry()
165 rt_rq->rt_nr_boosted = 0; in init_tg_rt_entry()
166 rt_rq->rq = rq; in init_tg_rt_entry()
167 rt_rq->tg = tg; in init_tg_rt_entry()
169 tg->rt_rq[cpu] = rt_rq; in init_tg_rt_entry()
176 rt_se->rt_rq = &rq->rt; in init_tg_rt_entry()
178 rt_se->rt_rq = parent->my_q; in init_tg_rt_entry()
180 rt_se->my_q = rt_rq; in init_tg_rt_entry()
187 struct rt_rq *rt_rq; in alloc_rt_sched_group() local
191 tg->rt_rq = kcalloc(nr_cpu_ids, sizeof(rt_rq), GFP_KERNEL); in alloc_rt_sched_group()
192 if (!tg->rt_rq) in alloc_rt_sched_group()
202 rt_rq = kzalloc_node(sizeof(struct rt_rq), in alloc_rt_sched_group()
204 if (!rt_rq) in alloc_rt_sched_group()
212 init_rt_rq(rt_rq); in alloc_rt_sched_group()
213 rt_rq->rt_runtime = tg->rt_bandwidth.rt_runtime; in alloc_rt_sched_group()
214 init_tg_rt_entry(tg, rt_rq, rt_se, i, parent->rt_se[i]); in alloc_rt_sched_group()
220 kfree(rt_rq); in alloc_rt_sched_group()
234 static inline struct rq *rq_of_rt_rq(struct rt_rq *rt_rq) in rq_of_rt_rq() argument
236 return container_of(rt_rq, struct rq, rt); in rq_of_rt_rq()
246 static inline struct rt_rq *rt_rq_of_se(struct sched_rt_entity *rt_se) in rt_rq_of_se()
305 static void update_rt_migration(struct rt_rq *rt_rq) in update_rt_migration() argument
307 if (rt_rq->rt_nr_migratory && rt_rq->rt_nr_total > 1) { in update_rt_migration()
308 if (!rt_rq->overloaded) { in update_rt_migration()
309 rt_set_overload(rq_of_rt_rq(rt_rq)); in update_rt_migration()
310 rt_rq->overloaded = 1; in update_rt_migration()
312 } else if (rt_rq->overloaded) { in update_rt_migration()
313 rt_clear_overload(rq_of_rt_rq(rt_rq)); in update_rt_migration()
314 rt_rq->overloaded = 0; in update_rt_migration()
318 static void inc_rt_migration(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in inc_rt_migration() argument
326 rt_rq = &rq_of_rt_rq(rt_rq)->rt; in inc_rt_migration()
328 rt_rq->rt_nr_total++; in inc_rt_migration()
330 rt_rq->rt_nr_migratory++; in inc_rt_migration()
332 update_rt_migration(rt_rq); in inc_rt_migration()
335 static void dec_rt_migration(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in dec_rt_migration() argument
343 rt_rq = &rq_of_rt_rq(rt_rq)->rt; in dec_rt_migration()
345 rt_rq->rt_nr_total--; in dec_rt_migration()
347 rt_rq->rt_nr_migratory--; in dec_rt_migration()
349 update_rt_migration(rt_rq); in dec_rt_migration()
411 void inc_rt_migration(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in inc_rt_migration() argument
416 void dec_rt_migration(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in dec_rt_migration() argument
434 static void enqueue_top_rt_rq(struct rt_rq *rt_rq);
435 static void dequeue_top_rt_rq(struct rt_rq *rt_rq);
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 *curr = rq_of_rt_rq(rt_rq)->curr; 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 < curr->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); 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()
606 static inline u64 sched_rt_runtime(struct rt_rq *rt_rq) in sched_rt_runtime() argument
608 return rt_rq->rt_runtime; in sched_rt_runtime()
611 static inline u64 sched_rt_period(struct rt_rq *rt_rq) in sched_rt_period() argument
616 typedef struct rt_rq *rt_rq_iter_t;
618 #define for_each_rt_rq(rt_rq, iter, rq) \ argument
619 for ((void) iter, rt_rq = &rq->rt; rt_rq; rt_rq = NULL)
624 static inline struct rt_rq *group_rt_rq(struct sched_rt_entity *rt_se) in group_rt_rq()
629 static inline void sched_rt_rq_enqueue(struct rt_rq *rt_rq) in sched_rt_rq_enqueue() argument
631 struct rq *rq = rq_of_rt_rq(rt_rq); in sched_rt_rq_enqueue()
633 if (!rt_rq->rt_nr_running) in sched_rt_rq_enqueue()
636 enqueue_top_rt_rq(rt_rq); in sched_rt_rq_enqueue()
640 static inline void sched_rt_rq_dequeue(struct rt_rq *rt_rq) in sched_rt_rq_dequeue() argument
642 dequeue_top_rt_rq(rt_rq); in sched_rt_rq_dequeue()
645 static inline int rt_rq_throttled(struct rt_rq *rt_rq) in rt_rq_throttled() argument
647 return rt_rq->rt_throttled; in rt_rq_throttled()
656 struct rt_rq *sched_rt_period_rt_rq(struct rt_bandwidth *rt_b, int cpu) in sched_rt_period_rt_rq()
661 static inline struct rt_bandwidth *sched_rt_bandwidth(struct rt_rq *rt_rq) in sched_rt_bandwidth() argument
668 bool sched_rt_bandwidth_account(struct rt_rq *rt_rq) in sched_rt_bandwidth_account() argument
670 struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq); in sched_rt_bandwidth_account()
673 rt_rq->rt_time < rt_b->rt_runtime); in sched_rt_bandwidth_account()
680 static void do_balance_runtime(struct rt_rq *rt_rq) in do_balance_runtime() argument
682 struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq); in do_balance_runtime()
683 struct root_domain *rd = rq_of_rt_rq(rt_rq)->rd; in do_balance_runtime()
692 struct rt_rq *iter = sched_rt_period_rt_rq(rt_b, i); in do_balance_runtime()
695 if (iter == rt_rq) in do_balance_runtime()
714 if (rt_rq->rt_runtime + diff > rt_period) in do_balance_runtime()
715 diff = rt_period - rt_rq->rt_runtime; in do_balance_runtime()
717 rt_rq->rt_runtime += diff; in do_balance_runtime()
718 if (rt_rq->rt_runtime == rt_period) { in do_balance_runtime()
736 struct rt_rq *rt_rq; in __disable_runtime() local
741 for_each_rt_rq(rt_rq, iter, rq) { in __disable_runtime()
742 struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq); in __disable_runtime()
747 raw_spin_lock(&rt_rq->rt_runtime_lock); in __disable_runtime()
753 if (rt_rq->rt_runtime == RUNTIME_INF || in __disable_runtime()
754 rt_rq->rt_runtime == rt_b->rt_runtime) in __disable_runtime()
756 raw_spin_unlock(&rt_rq->rt_runtime_lock); in __disable_runtime()
763 want = rt_b->rt_runtime - rt_rq->rt_runtime; in __disable_runtime()
769 struct rt_rq *iter = sched_rt_period_rt_rq(rt_b, i); in __disable_runtime()
775 if (iter == rt_rq || iter->rt_runtime == RUNTIME_INF) in __disable_runtime()
793 raw_spin_lock(&rt_rq->rt_runtime_lock); in __disable_runtime()
804 rt_rq->rt_runtime = RUNTIME_INF; in __disable_runtime()
805 rt_rq->rt_throttled = 0; in __disable_runtime()
806 raw_spin_unlock(&rt_rq->rt_runtime_lock); in __disable_runtime()
810 sched_rt_rq_enqueue(rt_rq); in __disable_runtime()
817 struct rt_rq *rt_rq; in __enable_runtime() local
825 for_each_rt_rq(rt_rq, iter, rq) { in __enable_runtime()
826 struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq); in __enable_runtime()
829 raw_spin_lock(&rt_rq->rt_runtime_lock); in __enable_runtime()
830 rt_rq->rt_runtime = rt_b->rt_runtime; in __enable_runtime()
831 rt_rq->rt_time = 0; in __enable_runtime()
832 rt_rq->rt_throttled = 0; in __enable_runtime()
833 raw_spin_unlock(&rt_rq->rt_runtime_lock); in __enable_runtime()
838 static void balance_runtime(struct rt_rq *rt_rq) in balance_runtime() argument
843 if (rt_rq->rt_time > rt_rq->rt_runtime) { in balance_runtime()
844 raw_spin_unlock(&rt_rq->rt_runtime_lock); in balance_runtime()
845 do_balance_runtime(rt_rq); in balance_runtime()
846 raw_spin_lock(&rt_rq->rt_runtime_lock); in balance_runtime()
850 static inline void balance_runtime(struct rt_rq *rt_rq) {} in balance_runtime() argument
874 struct rt_rq *rt_rq = sched_rt_period_rt_rq(rt_b, i); in do_sched_rt_period_timer() local
875 struct rq *rq = rq_of_rt_rq(rt_rq); in do_sched_rt_period_timer()
882 raw_spin_lock(&rt_rq->rt_runtime_lock); in do_sched_rt_period_timer()
883 if (!sched_feat(RT_RUNTIME_SHARE) && rt_rq->rt_runtime != RUNTIME_INF) in do_sched_rt_period_timer()
884 rt_rq->rt_runtime = rt_b->rt_runtime; in do_sched_rt_period_timer()
885 skip = !rt_rq->rt_time && !rt_rq->rt_nr_running; in do_sched_rt_period_timer()
886 raw_spin_unlock(&rt_rq->rt_runtime_lock); in do_sched_rt_period_timer()
893 if (rt_rq->rt_time) { in do_sched_rt_period_timer()
896 raw_spin_lock(&rt_rq->rt_runtime_lock); in do_sched_rt_period_timer()
897 if (rt_rq->rt_throttled) in do_sched_rt_period_timer()
898 balance_runtime(rt_rq); in do_sched_rt_period_timer()
899 runtime = rt_rq->rt_runtime; in do_sched_rt_period_timer()
900 rt_rq->rt_time -= min(rt_rq->rt_time, overrun*runtime); in do_sched_rt_period_timer()
901 if (rt_rq->rt_throttled && rt_rq->rt_time < runtime) { in do_sched_rt_period_timer()
902 rt_rq->rt_throttled = 0; in do_sched_rt_period_timer()
912 if (rt_rq->rt_nr_running && rq->curr == rq->idle) in do_sched_rt_period_timer()
915 if (rt_rq->rt_time || rt_rq->rt_nr_running) in do_sched_rt_period_timer()
917 raw_spin_unlock(&rt_rq->rt_runtime_lock); in do_sched_rt_period_timer()
918 } else if (rt_rq->rt_nr_running) { in do_sched_rt_period_timer()
920 if (!rt_rq_throttled(rt_rq)) in do_sched_rt_period_timer()
923 if (rt_rq->rt_throttled) in do_sched_rt_period_timer()
927 sched_rt_rq_enqueue(rt_rq); in do_sched_rt_period_timer()
940 struct rt_rq *rt_rq = group_rt_rq(rt_se); in rt_se_prio() local
942 if (rt_rq) in rt_se_prio()
943 return rt_rq->highest_prio.curr; in rt_se_prio()
949 static int sched_rt_runtime_exceeded(struct rt_rq *rt_rq) in sched_rt_runtime_exceeded() argument
951 u64 runtime = sched_rt_runtime(rt_rq); in sched_rt_runtime_exceeded()
953 if (rt_rq->rt_throttled) in sched_rt_runtime_exceeded()
954 return rt_rq_throttled(rt_rq); in sched_rt_runtime_exceeded()
956 if (runtime >= sched_rt_period(rt_rq)) in sched_rt_runtime_exceeded()
959 balance_runtime(rt_rq); in sched_rt_runtime_exceeded()
960 runtime = sched_rt_runtime(rt_rq); in sched_rt_runtime_exceeded()
964 if (rt_rq->rt_time > runtime) { in sched_rt_runtime_exceeded()
965 struct rt_bandwidth *rt_b = sched_rt_bandwidth(rt_rq); in sched_rt_runtime_exceeded()
972 rt_rq->rt_throttled = 1; in sched_rt_runtime_exceeded()
980 rt_rq->rt_time = 0; in sched_rt_runtime_exceeded()
983 if (rt_rq_throttled(rt_rq)) { in sched_rt_runtime_exceeded()
984 sched_rt_rq_dequeue(rt_rq); in sched_rt_runtime_exceeded()
1024 struct rt_rq *rt_rq = rt_rq_of_se(rt_se); in update_curr_rt() local
1026 if (sched_rt_runtime(rt_rq) != RUNTIME_INF) { in update_curr_rt()
1027 raw_spin_lock(&rt_rq->rt_runtime_lock); in update_curr_rt()
1028 rt_rq->rt_time += delta_exec; in update_curr_rt()
1029 if (sched_rt_runtime_exceeded(rt_rq)) in update_curr_rt()
1031 raw_spin_unlock(&rt_rq->rt_runtime_lock); in update_curr_rt()
1037 dequeue_top_rt_rq(struct rt_rq *rt_rq) in dequeue_top_rt_rq() argument
1039 struct rq *rq = rq_of_rt_rq(rt_rq); in dequeue_top_rt_rq()
1041 BUG_ON(&rq->rt != rt_rq); in dequeue_top_rt_rq()
1043 if (!rt_rq->rt_queued) in dequeue_top_rt_rq()
1048 sub_nr_running(rq, rt_rq->rt_nr_running); in dequeue_top_rt_rq()
1049 rt_rq->rt_queued = 0; in dequeue_top_rt_rq()
1054 enqueue_top_rt_rq(struct rt_rq *rt_rq) in enqueue_top_rt_rq() argument
1056 struct rq *rq = rq_of_rt_rq(rt_rq); in enqueue_top_rt_rq()
1058 BUG_ON(&rq->rt != rt_rq); in enqueue_top_rt_rq()
1060 if (rt_rq->rt_queued) in enqueue_top_rt_rq()
1063 if (rt_rq_throttled(rt_rq)) in enqueue_top_rt_rq()
1066 if (rt_rq->rt_nr_running) { in enqueue_top_rt_rq()
1067 add_nr_running(rq, rt_rq->rt_nr_running); in enqueue_top_rt_rq()
1068 rt_rq->rt_queued = 1; in enqueue_top_rt_rq()
1078 inc_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) in inc_rt_prio_smp() argument
1080 struct rq *rq = rq_of_rt_rq(rt_rq); in inc_rt_prio_smp()
1086 if (&rq->rt != rt_rq) in inc_rt_prio_smp()
1094 dec_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) in dec_rt_prio_smp() argument
1096 struct rq *rq = rq_of_rt_rq(rt_rq); in dec_rt_prio_smp()
1102 if (&rq->rt != rt_rq) in dec_rt_prio_smp()
1105 if (rq->online && rt_rq->highest_prio.curr != prev_prio) in dec_rt_prio_smp()
1106 cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio.curr); in dec_rt_prio_smp()
1112 void inc_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) {} in inc_rt_prio_smp() argument
1114 void dec_rt_prio_smp(struct rt_rq *rt_rq, int prio, int prev_prio) {} in dec_rt_prio_smp() argument
1120 inc_rt_prio(struct rt_rq *rt_rq, int prio) in inc_rt_prio() argument
1122 int prev_prio = rt_rq->highest_prio.curr; in inc_rt_prio()
1125 rt_rq->highest_prio.curr = prio; in inc_rt_prio()
1127 inc_rt_prio_smp(rt_rq, prio, prev_prio); in inc_rt_prio()
1131 dec_rt_prio(struct rt_rq *rt_rq, int prio) in dec_rt_prio() argument
1133 int prev_prio = rt_rq->highest_prio.curr; in dec_rt_prio()
1135 if (rt_rq->rt_nr_running) { in dec_rt_prio()
1144 struct rt_prio_array *array = &rt_rq->active; in dec_rt_prio()
1146 rt_rq->highest_prio.curr = in dec_rt_prio()
1151 rt_rq->highest_prio.curr = MAX_RT_PRIO; in dec_rt_prio()
1153 dec_rt_prio_smp(rt_rq, prio, prev_prio); in dec_rt_prio()
1158 static inline void inc_rt_prio(struct rt_rq *rt_rq, int prio) {} in inc_rt_prio() argument
1159 static inline void dec_rt_prio(struct rt_rq *rt_rq, int prio) {} in dec_rt_prio() argument
1166 inc_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in inc_rt_group() argument
1169 rt_rq->rt_nr_boosted++; in inc_rt_group()
1171 if (rt_rq->tg) in inc_rt_group()
1172 start_rt_bandwidth(&rt_rq->tg->rt_bandwidth); in inc_rt_group()
1176 dec_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in dec_rt_group() argument
1179 rt_rq->rt_nr_boosted--; in dec_rt_group()
1181 WARN_ON(!rt_rq->rt_nr_running && rt_rq->rt_nr_boosted); in dec_rt_group()
1187 inc_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in inc_rt_group() argument
1193 void dec_rt_group(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) {} in dec_rt_group() argument
1200 struct rt_rq *group_rq = group_rt_rq(rt_se); in rt_se_nr_running()
1211 struct rt_rq *group_rq = group_rt_rq(rt_se); in rt_se_rr_nr_running()
1223 void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in inc_rt_tasks() argument
1228 rt_rq->rt_nr_running += rt_se_nr_running(rt_se); in inc_rt_tasks()
1229 rt_rq->rr_nr_running += rt_se_rr_nr_running(rt_se); in inc_rt_tasks()
1231 inc_rt_prio(rt_rq, prio); in inc_rt_tasks()
1232 inc_rt_migration(rt_se, rt_rq); in inc_rt_tasks()
1233 inc_rt_group(rt_se, rt_rq); in inc_rt_tasks()
1237 void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) in dec_rt_tasks() argument
1240 WARN_ON(!rt_rq->rt_nr_running); in dec_rt_tasks()
1241 rt_rq->rt_nr_running -= rt_se_nr_running(rt_se); in dec_rt_tasks()
1242 rt_rq->rr_nr_running -= rt_se_rr_nr_running(rt_se); in dec_rt_tasks()
1244 dec_rt_prio(rt_rq, rt_se_prio(rt_se)); in dec_rt_tasks()
1245 dec_rt_migration(rt_se, rt_rq); in dec_rt_tasks()
1246 dec_rt_group(rt_se, rt_rq); in dec_rt_tasks()
1274 struct rt_rq *rt_rq = rt_rq_of_se(rt_se); in __enqueue_rt_entity() local
1275 struct rt_prio_array *array = &rt_rq->active; in __enqueue_rt_entity()
1276 struct rt_rq *group_rq = group_rt_rq(rt_se); in __enqueue_rt_entity()
1303 inc_rt_tasks(rt_se, rt_rq); in __enqueue_rt_entity()
1308 struct rt_rq *rt_rq = rt_rq_of_se(rt_se); in __dequeue_rt_entity() local
1309 struct rt_prio_array *array = &rt_rq->active; in __dequeue_rt_entity()
1317 dec_rt_tasks(rt_se, rt_rq); in __dequeue_rt_entity()
1358 struct rt_rq *rt_rq = group_rt_rq(rt_se); in dequeue_rt_entity() local
1360 if (rt_rq && rt_rq->rt_nr_running) in dequeue_rt_entity()
1398 requeue_rt_entity(struct rt_rq *rt_rq, struct sched_rt_entity *rt_se, int head) in requeue_rt_entity() argument
1401 struct rt_prio_array *array = &rt_rq->active; in requeue_rt_entity()
1414 struct rt_rq *rt_rq; in requeue_task_rt() local
1417 rt_rq = rt_rq_of_se(rt_se); in requeue_task_rt()
1418 requeue_rt_entity(rt_rq, rt_se, head); in requeue_task_rt()
1597 struct rt_rq *rt_rq) in pick_next_rt_entity() argument
1599 struct rt_prio_array *array = &rt_rq->active; in pick_next_rt_entity()
1616 struct rt_rq *rt_rq = &rq->rt; in _pick_next_task_rt() local
1619 rt_se = pick_next_rt_entity(rq, rt_rq); in _pick_next_task_rt()
1621 rt_rq = group_rt_rq(rt_se); in _pick_next_task_rt()
1622 } while (rt_rq); in _pick_next_task_rt()
2606 struct rt_rq *rt_rq = tg->rt_rq[i]; in tg_set_rt_bandwidth() local
2608 raw_spin_lock(&rt_rq->rt_runtime_lock); in tg_set_rt_bandwidth()
2609 rt_rq->rt_runtime = rt_runtime; in tg_set_rt_bandwidth()
2610 raw_spin_unlock(&rt_rq->rt_runtime_lock); in tg_set_rt_bandwidth()
2695 struct rt_rq *rt_rq = &cpu_rq(i)->rt; in sched_rt_global_constraints() local
2697 raw_spin_lock(&rt_rq->rt_runtime_lock); in sched_rt_global_constraints()
2698 rt_rq->rt_runtime = global_rt_runtime(); in sched_rt_global_constraints()
2699 raw_spin_unlock(&rt_rq->rt_runtime_lock); in sched_rt_global_constraints()
2792 struct rt_rq *rt_rq; in print_rt_stats() local
2795 for_each_rt_rq(rt_rq, iter, cpu_rq(cpu)) in print_rt_stats()
2796 print_rt_rq(m, cpu, rt_rq); in print_rt_stats()