Loading kernel/sched_rt.c +16 −24 Original line number Diff line number Diff line Loading @@ -550,30 +550,28 @@ static void update_curr_rt(struct rq *rq) static inline void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) { WARN_ON(!rt_prio(rt_se_prio(rt_se))); rt_rq->rt_nr_running++; #if defined CONFIG_SMP || defined CONFIG_RT_GROUP_SCHED if (rt_se_prio(rt_se) < rt_rq->highest_prio) { int prio = rt_se_prio(rt_se); #ifdef CONFIG_SMP struct rq *rq = rq_of_rt_rq(rt_rq); #endif rt_rq->highest_prio = rt_se_prio(rt_se); WARN_ON(!rt_prio(prio)); rt_rq->rt_nr_running++; #if defined CONFIG_SMP || defined CONFIG_RT_GROUP_SCHED if (prio < rt_rq->highest_prio) { rt_rq->highest_prio = prio; #ifdef CONFIG_SMP if (rq->online) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_se_prio(rt_se)); cpupri_set(&rq->rd->cpupri, rq->cpu, prio); #endif } #endif #ifdef CONFIG_SMP if (rt_se->nr_cpus_allowed > 1) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rt_se->nr_cpus_allowed > 1) rq->rt.rt_nr_migratory++; } update_rt_migration(rq_of_rt_rq(rt_rq)); update_rt_migration(rq); #endif #ifdef CONFIG_RT_GROUP_SCHED if (rt_se_boosted(rt_se)) Loading @@ -590,6 +588,7 @@ static inline void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) { #ifdef CONFIG_SMP struct rq *rq = rq_of_rt_rq(rt_rq); int highest_prio = rt_rq->highest_prio; #endif Loading @@ -611,20 +610,13 @@ void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) rt_rq->highest_prio = MAX_RT_PRIO; #endif #ifdef CONFIG_SMP if (rt_se->nr_cpus_allowed > 1) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rt_se->nr_cpus_allowed > 1) rq->rt.rt_nr_migratory--; } if (rt_rq->highest_prio != highest_prio) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rq->online && rt_rq->highest_prio != highest_prio) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio); if (rq->online) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio); } update_rt_migration(rq_of_rt_rq(rt_rq)); update_rt_migration(rq); #endif /* CONFIG_SMP */ #ifdef CONFIG_RT_GROUP_SCHED if (rt_se_boosted(rt_se)) Loading Loading
kernel/sched_rt.c +16 −24 Original line number Diff line number Diff line Loading @@ -550,30 +550,28 @@ static void update_curr_rt(struct rq *rq) static inline void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) { WARN_ON(!rt_prio(rt_se_prio(rt_se))); rt_rq->rt_nr_running++; #if defined CONFIG_SMP || defined CONFIG_RT_GROUP_SCHED if (rt_se_prio(rt_se) < rt_rq->highest_prio) { int prio = rt_se_prio(rt_se); #ifdef CONFIG_SMP struct rq *rq = rq_of_rt_rq(rt_rq); #endif rt_rq->highest_prio = rt_se_prio(rt_se); WARN_ON(!rt_prio(prio)); rt_rq->rt_nr_running++; #if defined CONFIG_SMP || defined CONFIG_RT_GROUP_SCHED if (prio < rt_rq->highest_prio) { rt_rq->highest_prio = prio; #ifdef CONFIG_SMP if (rq->online) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_se_prio(rt_se)); cpupri_set(&rq->rd->cpupri, rq->cpu, prio); #endif } #endif #ifdef CONFIG_SMP if (rt_se->nr_cpus_allowed > 1) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rt_se->nr_cpus_allowed > 1) rq->rt.rt_nr_migratory++; } update_rt_migration(rq_of_rt_rq(rt_rq)); update_rt_migration(rq); #endif #ifdef CONFIG_RT_GROUP_SCHED if (rt_se_boosted(rt_se)) Loading @@ -590,6 +588,7 @@ static inline void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) { #ifdef CONFIG_SMP struct rq *rq = rq_of_rt_rq(rt_rq); int highest_prio = rt_rq->highest_prio; #endif Loading @@ -611,20 +610,13 @@ void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq) rt_rq->highest_prio = MAX_RT_PRIO; #endif #ifdef CONFIG_SMP if (rt_se->nr_cpus_allowed > 1) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rt_se->nr_cpus_allowed > 1) rq->rt.rt_nr_migratory--; } if (rt_rq->highest_prio != highest_prio) { struct rq *rq = rq_of_rt_rq(rt_rq); if (rq->online && rt_rq->highest_prio != highest_prio) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio); if (rq->online) cpupri_set(&rq->rd->cpupri, rq->cpu, rt_rq->highest_prio); } update_rt_migration(rq_of_rt_rq(rt_rq)); update_rt_migration(rq); #endif /* CONFIG_SMP */ #ifdef CONFIG_RT_GROUP_SCHED if (rt_se_boosted(rt_se)) Loading