Commit da19ab51 authored by Steven Rostedt's avatar Steven Rostedt Committed by Ingo Molnar

sched: Check for pushing rt tasks after all scheduling

The current method for pushing RT tasks after scheduling only
happens after a context switch. But we found cases where a task
is set up on a run queue to be pushed but the push never
happens because the schedule chooses the same task.

This bug was found with the help of Gregory Haskins and the use
of ftrace (trace_printk). It tooks several days for both of us
analyzing the code and the trace output to find this.
Signed-off-by: default avatarSteven Rostedt <srostedt@redhat.com>
Signed-off-by: default avatarPeter Zijlstra <a.p.zijlstra@chello.nl>
LKML-Reference: <20090729042526.205923666@goodmis.org>
Signed-off-by: default avatarIngo Molnar <mingo@elte.hu>
parent e7097159
...@@ -2839,14 +2839,14 @@ prepare_task_switch(struct rq *rq, struct task_struct *prev, ...@@ -2839,14 +2839,14 @@ prepare_task_switch(struct rq *rq, struct task_struct *prev,
* with the lock held can cause deadlocks; see schedule() for * with the lock held can cause deadlocks; see schedule() for
* details.) * details.)
*/ */
static void finish_task_switch(struct rq *rq, struct task_struct *prev) static int finish_task_switch(struct rq *rq, struct task_struct *prev)
__releases(rq->lock) __releases(rq->lock)
{ {
struct mm_struct *mm = rq->prev_mm; struct mm_struct *mm = rq->prev_mm;
long prev_state; long prev_state;
#ifdef CONFIG_SMP
int post_schedule = 0; int post_schedule = 0;
#ifdef CONFIG_SMP
if (current->sched_class->needs_post_schedule) if (current->sched_class->needs_post_schedule)
post_schedule = current->sched_class->needs_post_schedule(rq); post_schedule = current->sched_class->needs_post_schedule(rq);
#endif #endif
...@@ -2868,10 +2868,6 @@ static void finish_task_switch(struct rq *rq, struct task_struct *prev) ...@@ -2868,10 +2868,6 @@ static void finish_task_switch(struct rq *rq, struct task_struct *prev)
finish_arch_switch(prev); finish_arch_switch(prev);
perf_counter_task_sched_in(current, cpu_of(rq)); perf_counter_task_sched_in(current, cpu_of(rq));
finish_lock_switch(rq, prev); finish_lock_switch(rq, prev);
#ifdef CONFIG_SMP
if (post_schedule)
current->sched_class->post_schedule(rq);
#endif
fire_sched_in_preempt_notifiers(current); fire_sched_in_preempt_notifiers(current);
if (mm) if (mm)
...@@ -2884,6 +2880,8 @@ static void finish_task_switch(struct rq *rq, struct task_struct *prev) ...@@ -2884,6 +2880,8 @@ static void finish_task_switch(struct rq *rq, struct task_struct *prev)
kprobe_flush_task(prev); kprobe_flush_task(prev);
put_task_struct(prev); put_task_struct(prev);
} }
return post_schedule;
} }
/** /**
...@@ -2894,8 +2892,15 @@ asmlinkage void schedule_tail(struct task_struct *prev) ...@@ -2894,8 +2892,15 @@ asmlinkage void schedule_tail(struct task_struct *prev)
__releases(rq->lock) __releases(rq->lock)
{ {
struct rq *rq = this_rq(); struct rq *rq = this_rq();
int post_schedule;
post_schedule = finish_task_switch(rq, prev);
#ifdef CONFIG_SMP
if (post_schedule)
current->sched_class->post_schedule(rq);
#endif
finish_task_switch(rq, prev);
#ifdef __ARCH_WANT_UNLOCKED_CTXSW #ifdef __ARCH_WANT_UNLOCKED_CTXSW
/* In this case, finish_task_switch does not reenable preemption */ /* In this case, finish_task_switch does not reenable preemption */
preempt_enable(); preempt_enable();
...@@ -2908,7 +2913,7 @@ asmlinkage void schedule_tail(struct task_struct *prev) ...@@ -2908,7 +2913,7 @@ asmlinkage void schedule_tail(struct task_struct *prev)
* context_switch - switch to the new MM and the new * context_switch - switch to the new MM and the new
* thread's register state. * thread's register state.
*/ */
static inline void static inline int
context_switch(struct rq *rq, struct task_struct *prev, context_switch(struct rq *rq, struct task_struct *prev,
struct task_struct *next) struct task_struct *next)
{ {
...@@ -2955,7 +2960,7 @@ context_switch(struct rq *rq, struct task_struct *prev, ...@@ -2955,7 +2960,7 @@ context_switch(struct rq *rq, struct task_struct *prev,
* CPUs since it called schedule(), thus the 'rq' on its stack * CPUs since it called schedule(), thus the 'rq' on its stack
* frame will be invalid. * frame will be invalid.
*/ */
finish_task_switch(this_rq(), prev); return finish_task_switch(this_rq(), prev);
} }
/* /*
...@@ -5366,6 +5371,7 @@ asmlinkage void __sched schedule(void) ...@@ -5366,6 +5371,7 @@ asmlinkage void __sched schedule(void)
{ {
struct task_struct *prev, *next; struct task_struct *prev, *next;
unsigned long *switch_count; unsigned long *switch_count;
int post_schedule = 0;
struct rq *rq; struct rq *rq;
int cpu; int cpu;
...@@ -5416,15 +5422,25 @@ need_resched_nonpreemptible: ...@@ -5416,15 +5422,25 @@ need_resched_nonpreemptible:
rq->curr = next; rq->curr = next;
++*switch_count; ++*switch_count;
context_switch(rq, prev, next); /* unlocks the rq */ post_schedule = context_switch(rq, prev, next); /* unlocks the rq */
/* /*
* the context switch might have flipped the stack from under * the context switch might have flipped the stack from under
* us, hence refresh the local variables. * us, hence refresh the local variables.
*/ */
cpu = smp_processor_id(); cpu = smp_processor_id();
rq = cpu_rq(cpu); rq = cpu_rq(cpu);
} else } else {
#ifdef CONFIG_SMP
if (current->sched_class->needs_post_schedule)
post_schedule = current->sched_class->needs_post_schedule(rq);
#endif
spin_unlock_irq(&rq->lock); spin_unlock_irq(&rq->lock);
}
#ifdef CONFIG_SMP
if (post_schedule)
current->sched_class->post_schedule(rq);
#endif
if (unlikely(reacquire_kernel_lock(current) < 0)) if (unlikely(reacquire_kernel_lock(current) < 0))
goto need_resched_nonpreemptible; goto need_resched_nonpreemptible;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment