Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 76162
b: refs/heads/master
c: 9a897c5
h: refs/heads/master
v: v3
  • Loading branch information
Steven Rostedt authored and Ingo Molnar committed Jan 25, 2008
1 parent 4896b4f commit ca4b9cf
Show file tree
Hide file tree
Showing 4 changed files with 27 additions and 15 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 4bf0b77158d581c952af237aec79d0604b78fe27
refs/heads/master: 9a897c5a6701bcb6f099f7ca20194999102729fd
3 changes: 3 additions & 0 deletions trunk/include/linux/sched.h
Original file line number Diff line number Diff line change
Expand Up @@ -843,6 +843,9 @@ struct sched_class {
int (*move_one_task) (struct rq *this_rq, int this_cpu,
struct rq *busiest, struct sched_domain *sd,
enum cpu_idle_type idle);
void (*pre_schedule) (struct rq *this_rq, struct task_struct *task);
void (*post_schedule) (struct rq *this_rq);
void (*task_wake_up) (struct rq *this_rq, struct task_struct *task);
#endif

void (*set_curr_task) (struct rq *rq);
Expand Down
20 changes: 16 additions & 4 deletions trunk/kernel/sched.c
Original file line number Diff line number Diff line change
Expand Up @@ -1625,7 +1625,10 @@ static int try_to_wake_up(struct task_struct *p, unsigned int state, int sync)

out_running:
p->state = TASK_RUNNING;
wakeup_balance_rt(rq, p);
#ifdef CONFIG_SMP
if (p->sched_class->task_wake_up)
p->sched_class->task_wake_up(rq, p);
#endif
out:
task_rq_unlock(rq, &flags);

Expand Down Expand Up @@ -1748,7 +1751,10 @@ void fastcall wake_up_new_task(struct task_struct *p, unsigned long clone_flags)
inc_nr_running(p, rq);
}
check_preempt_curr(rq, p);
wakeup_balance_rt(rq, p);
#ifdef CONFIG_SMP
if (p->sched_class->task_wake_up)
p->sched_class->task_wake_up(rq, p);
#endif
task_rq_unlock(rq, &flags);
}

Expand Down Expand Up @@ -1869,7 +1875,10 @@ static void finish_task_switch(struct rq *rq, struct task_struct *prev)
prev_state = prev->state;
finish_arch_switch(prev);
finish_lock_switch(rq, prev);
schedule_tail_balance_rt(rq);
#ifdef CONFIG_SMP
if (current->sched_class->post_schedule)
current->sched_class->post_schedule(rq);
#endif

fire_sched_in_preempt_notifiers(current);
if (mm)
Expand Down Expand Up @@ -3638,7 +3647,10 @@ asmlinkage void __sched schedule(void)
switch_count = &prev->nvcsw;
}

schedule_balance_rt(rq, prev);
#ifdef CONFIG_SMP
if (prev->sched_class->pre_schedule)
prev->sched_class->pre_schedule(rq, prev);
#endif

if (unlikely(!rq->nr_running))
idle_balance(cpu, rq);
Expand Down
17 changes: 7 additions & 10 deletions trunk/kernel/sched_rt.c
Original file line number Diff line number Diff line change
Expand Up @@ -689,14 +689,14 @@ static int pull_rt_task(struct rq *this_rq)
return ret;
}

static void schedule_balance_rt(struct rq *rq, struct task_struct *prev)
static void pre_schedule_rt(struct rq *rq, struct task_struct *prev)
{
/* Try to pull RT tasks here if we lower this rq's prio */
if (unlikely(rt_task(prev)) && rq->rt.highest_prio > prev->prio)
pull_rt_task(rq);
}

static void schedule_tail_balance_rt(struct rq *rq)
static void post_schedule_rt(struct rq *rq)
{
/*
* If we have more than one rt_task queued, then
Expand All @@ -713,10 +713,9 @@ static void schedule_tail_balance_rt(struct rq *rq)
}


static void wakeup_balance_rt(struct rq *rq, struct task_struct *p)
static void task_wake_up_rt(struct rq *rq, struct task_struct *p)
{
if (unlikely(rt_task(p)) &&
!task_running(rq, p) &&
if (!task_running(rq, p) &&
(p->prio >= rq->rt.highest_prio) &&
rq->rt.overloaded)
push_rt_tasks(rq);
Expand Down Expand Up @@ -780,11 +779,6 @@ static void leave_domain_rt(struct rq *rq)
if (rq->rt.overloaded)
rt_clear_overload(rq);
}

#else /* CONFIG_SMP */
# define schedule_tail_balance_rt(rq) do { } while (0)
# define schedule_balance_rt(rq, prev) do { } while (0)
# define wakeup_balance_rt(rq, p) do { } while (0)
#endif /* CONFIG_SMP */

static void task_tick_rt(struct rq *rq, struct task_struct *p)
Expand Down Expand Up @@ -840,6 +834,9 @@ const struct sched_class rt_sched_class = {
.set_cpus_allowed = set_cpus_allowed_rt,
.join_domain = join_domain_rt,
.leave_domain = leave_domain_rt,
.pre_schedule = pre_schedule_rt,
.post_schedule = post_schedule_rt,
.task_wake_up = task_wake_up_rt,
#endif

.set_curr_task = set_curr_task_rt,
Expand Down

0 comments on commit ca4b9cf

Please sign in to comment.