|
@@ -6613,7 +6613,7 @@ static int wake_cap(struct task_struct *p, int cpu, int prev_cpu)
|
|
|
static int
|
|
static int
|
|
|
select_task_rq_fair(struct task_struct *p, int prev_cpu, int sd_flag, int wake_flags)
|
|
select_task_rq_fair(struct task_struct *p, int prev_cpu, int sd_flag, int wake_flags)
|
|
|
{
|
|
{
|
|
|
- struct sched_domain *tmp, *affine_sd = NULL, *sd = NULL;
|
|
|
|
|
|
|
+ struct sched_domain *tmp, *sd = NULL;
|
|
|
int cpu = smp_processor_id();
|
|
int cpu = smp_processor_id();
|
|
|
int new_cpu = prev_cpu;
|
|
int new_cpu = prev_cpu;
|
|
|
int want_affine = 0;
|
|
int want_affine = 0;
|
|
@@ -6636,7 +6636,10 @@ select_task_rq_fair(struct task_struct *p, int prev_cpu, int sd_flag, int wake_f
|
|
|
*/
|
|
*/
|
|
|
if (want_affine && (tmp->flags & SD_WAKE_AFFINE) &&
|
|
if (want_affine && (tmp->flags & SD_WAKE_AFFINE) &&
|
|
|
cpumask_test_cpu(prev_cpu, sched_domain_span(tmp))) {
|
|
cpumask_test_cpu(prev_cpu, sched_domain_span(tmp))) {
|
|
|
- affine_sd = tmp;
|
|
|
|
|
|
|
+ if (cpu != prev_cpu)
|
|
|
|
|
+ new_cpu = wake_affine(tmp, p, cpu, prev_cpu, sync);
|
|
|
|
|
+
|
|
|
|
|
+ sd = NULL; /* Prefer wake_affine over balance flags */
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -6646,33 +6649,25 @@ select_task_rq_fair(struct task_struct *p, int prev_cpu, int sd_flag, int wake_f
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if (affine_sd) {
|
|
|
|
|
- sd = NULL; /* Prefer wake_affine over balance flags */
|
|
|
|
|
- if (cpu == prev_cpu)
|
|
|
|
|
- goto pick_cpu;
|
|
|
|
|
-
|
|
|
|
|
- new_cpu = wake_affine(affine_sd, p, cpu, prev_cpu, sync);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if (unlikely(sd)) {
|
|
|
|
|
+ /* Slow path */
|
|
|
|
|
|
|
|
- if (sd && !(sd_flag & SD_BALANCE_FORK)) {
|
|
|
|
|
/*
|
|
/*
|
|
|
* We're going to need the task's util for capacity_spare_wake
|
|
* We're going to need the task's util for capacity_spare_wake
|
|
|
* in find_idlest_group. Sync it up to prev_cpu's
|
|
* in find_idlest_group. Sync it up to prev_cpu's
|
|
|
* last_update_time.
|
|
* last_update_time.
|
|
|
*/
|
|
*/
|
|
|
- sync_entity_load_avg(&p->se);
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- if (!sd) {
|
|
|
|
|
-pick_cpu:
|
|
|
|
|
- if (sd_flag & SD_BALANCE_WAKE) { /* XXX always ? */
|
|
|
|
|
- new_cpu = select_idle_sibling(p, prev_cpu, new_cpu);
|
|
|
|
|
|
|
+ if (!(sd_flag & SD_BALANCE_FORK))
|
|
|
|
|
+ sync_entity_load_avg(&p->se);
|
|
|
|
|
|
|
|
- if (want_affine)
|
|
|
|
|
- current->recent_used_cpu = cpu;
|
|
|
|
|
- }
|
|
|
|
|
- } else {
|
|
|
|
|
new_cpu = find_idlest_cpu(sd, p, cpu, prev_cpu, sd_flag);
|
|
new_cpu = find_idlest_cpu(sd, p, cpu, prev_cpu, sd_flag);
|
|
|
|
|
+ } else if (sd_flag & SD_BALANCE_WAKE) { /* XXX always ? */
|
|
|
|
|
+ /* Fast path */
|
|
|
|
|
+
|
|
|
|
|
+ new_cpu = select_idle_sibling(p, prev_cpu, new_cpu);
|
|
|
|
|
+
|
|
|
|
|
+ if (want_affine)
|
|
|
|
|
+ current->recent_used_cpu = cpu;
|
|
|
}
|
|
}
|
|
|
rcu_read_unlock();
|
|
rcu_read_unlock();
|
|
|
|
|
|