|
@@ -1141,6 +1141,20 @@ unsigned int rt_se_nr_running(struct sched_rt_entity *rt_se)
|
|
|
return 1;
|
|
|
}
|
|
|
|
|
|
+static inline
|
|
|
+unsigned int rt_se_rr_nr_running(struct sched_rt_entity *rt_se)
|
|
|
+{
|
|
|
+ struct rt_rq *group_rq = group_rt_rq(rt_se);
|
|
|
+ struct task_struct *tsk;
|
|
|
+
|
|
|
+ if (group_rq)
|
|
|
+ return group_rq->rr_nr_running;
|
|
|
+
|
|
|
+ tsk = rt_task_of(rt_se);
|
|
|
+
|
|
|
+ return (tsk->policy == SCHED_RR) ? 1 : 0;
|
|
|
+}
|
|
|
+
|
|
|
static inline
|
|
|
void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)
|
|
|
{
|
|
@@ -1148,6 +1162,7 @@ void inc_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)
|
|
|
|
|
|
WARN_ON(!rt_prio(prio));
|
|
|
rt_rq->rt_nr_running += rt_se_nr_running(rt_se);
|
|
|
+ rt_rq->rr_nr_running += rt_se_rr_nr_running(rt_se);
|
|
|
|
|
|
inc_rt_prio(rt_rq, prio);
|
|
|
inc_rt_migration(rt_se, rt_rq);
|
|
@@ -1160,6 +1175,7 @@ void dec_rt_tasks(struct sched_rt_entity *rt_se, struct rt_rq *rt_rq)
|
|
|
WARN_ON(!rt_prio(rt_se_prio(rt_se)));
|
|
|
WARN_ON(!rt_rq->rt_nr_running);
|
|
|
rt_rq->rt_nr_running -= rt_se_nr_running(rt_se);
|
|
|
+ rt_rq->rr_nr_running -= rt_se_rr_nr_running(rt_se);
|
|
|
|
|
|
dec_rt_prio(rt_rq, rt_se_prio(rt_se));
|
|
|
dec_rt_migration(rt_se, rt_rq);
|