aboutsummaryrefslogtreecommitdiffstats
path: root/kernel/sched
diff options
context:
space:
mode:
authorPeter Zijlstra <peterz@infradead.org>2013-10-11 08:38:20 -0400
committerIngo Molnar <mingo@kernel.org>2013-10-16 08:22:16 -0400
commit6acce3ef84520537f8a09a12c9ddbe814a584dd2 (patch)
treeb4e117df4a57be6a040529c148480227c3d100cc /kernel/sched
parent746023159c40c523b08a3bc3d213dac212385895 (diff)
sched: Remove get_online_cpus() usage
Remove get_online_cpus() usage from the scheduler; there's 4 sites that use it: - sched_init_smp(); where its completely superfluous since we're in 'early' boot and there simply cannot be any hotplugging. - sched_getaffinity(); we already take a raw spinlock to protect the task cpus_allowed mask, this disables preemption and therefore also stabilizes cpu_online_mask as that's modified using stop_machine. However switch to active mask for symmetry with sched_setaffinity()/set_cpus_allowed_ptr(). We guarantee active mask stability by inserting sync_rcu/sched() into _cpu_down. - sched_setaffinity(); we don't appear to need get_online_cpus() either, there's two sites where hotplug appears relevant: * cpuset_cpus_allowed(); for the !cpuset case we use possible_mask, for the cpuset case we hold task_lock, which is a spinlock and thus for mainline disables preemption (might cause pain on RT). * set_cpus_allowed_ptr(); Holds all scheduler locks and thus has preemption properly disabled; also it already deals with hotplug races explicitly where it releases them. - migrate_swap(); we can make stop_two_cpus() do the heavy lifting for us with a little trickery. By adding a sync_sched/rcu() after the CPU_DOWN_PREPARE notifier we can provide preempt/rcu guarantees for cpu_active_mask. Use these to validate that both our cpus are active when queueing the stop work before we queue the stop_machine works for take_cpu_down(). Signed-off-by: Peter Zijlstra <peterz@infradead.org> Cc: "Srivatsa S. Bhat" <srivatsa.bhat@linux.vnet.ibm.com> Cc: Paul McKenney <paulmck@linux.vnet.ibm.com> Cc: Mel Gorman <mgorman@suse.de> Cc: Rik van Riel <riel@redhat.com> Cc: Srikar Dronamraju <srikar@linux.vnet.ibm.com> Cc: Andrea Arcangeli <aarcange@redhat.com> Cc: Johannes Weiner <hannes@cmpxchg.org> Cc: Linus Torvalds <torvalds@linux-foundation.org> Cc: Andrew Morton <akpm@linux-foundation.org> Cc: Steven Rostedt <rostedt@goodmis.org> Cc: Oleg Nesterov <oleg@redhat.com> Link: http://lkml.kernel.org/r/20131011123820.GV3081@twins.programming.kicks-ass.net Signed-off-by: Ingo Molnar <mingo@kernel.org>
Diffstat (limited to 'kernel/sched')
-rw-r--r--kernel/sched/core.c20
1 files changed, 10 insertions, 10 deletions
diff --git a/kernel/sched/core.c b/kernel/sched/core.c
index a972acd468b0..c06b8d345fae 100644
--- a/kernel/sched/core.c
+++ b/kernel/sched/core.c
@@ -1085,8 +1085,6 @@ int migrate_swap(struct task_struct *cur, struct task_struct *p)
1085 struct migration_swap_arg arg; 1085 struct migration_swap_arg arg;
1086 int ret = -EINVAL; 1086 int ret = -EINVAL;
1087 1087
1088 get_online_cpus();
1089
1090 arg = (struct migration_swap_arg){ 1088 arg = (struct migration_swap_arg){
1091 .src_task = cur, 1089 .src_task = cur,
1092 .src_cpu = task_cpu(cur), 1090 .src_cpu = task_cpu(cur),
@@ -1097,6 +1095,10 @@ int migrate_swap(struct task_struct *cur, struct task_struct *p)
1097 if (arg.src_cpu == arg.dst_cpu) 1095 if (arg.src_cpu == arg.dst_cpu)
1098 goto out; 1096 goto out;
1099 1097
1098 /*
1099 * These three tests are all lockless; this is OK since all of them
1100 * will be re-checked with proper locks held further down the line.
1101 */
1100 if (!cpu_active(arg.src_cpu) || !cpu_active(arg.dst_cpu)) 1102 if (!cpu_active(arg.src_cpu) || !cpu_active(arg.dst_cpu))
1101 goto out; 1103 goto out;
1102 1104
@@ -1109,7 +1111,6 @@ int migrate_swap(struct task_struct *cur, struct task_struct *p)
1109 ret = stop_two_cpus(arg.dst_cpu, arg.src_cpu, migrate_swap_stop, &arg); 1111 ret = stop_two_cpus(arg.dst_cpu, arg.src_cpu, migrate_swap_stop, &arg);
1110 1112
1111out: 1113out:
1112 put_online_cpus();
1113 return ret; 1114 return ret;
1114} 1115}
1115 1116
@@ -3710,7 +3711,6 @@ long sched_setaffinity(pid_t pid, const struct cpumask *in_mask)
3710 struct task_struct *p; 3711 struct task_struct *p;
3711 int retval; 3712 int retval;
3712 3713
3713 get_online_cpus();
3714 rcu_read_lock(); 3714 rcu_read_lock();
3715 3715
3716 p = find_process_by_pid(pid); 3716 p = find_process_by_pid(pid);
@@ -3773,7 +3773,6 @@ out_free_cpus_allowed:
3773 free_cpumask_var(cpus_allowed); 3773 free_cpumask_var(cpus_allowed);
3774out_put_task: 3774out_put_task:
3775 put_task_struct(p); 3775 put_task_struct(p);
3776 put_online_cpus();
3777 return retval; 3776 return retval;
3778} 3777}
3779 3778
@@ -3818,7 +3817,6 @@ long sched_getaffinity(pid_t pid, struct cpumask *mask)
3818 unsigned long flags; 3817 unsigned long flags;
3819 int retval; 3818 int retval;
3820 3819
3821 get_online_cpus();
3822 rcu_read_lock(); 3820 rcu_read_lock();
3823 3821
3824 retval = -ESRCH; 3822 retval = -ESRCH;
@@ -3831,12 +3829,11 @@ long sched_getaffinity(pid_t pid, struct cpumask *mask)
3831 goto out_unlock; 3829 goto out_unlock;
3832 3830
3833 raw_spin_lock_irqsave(&p->pi_lock, flags); 3831 raw_spin_lock_irqsave(&p->pi_lock, flags);
3834 cpumask_and(mask, &p->cpus_allowed, cpu_online_mask); 3832 cpumask_and(mask, &p->cpus_allowed, cpu_active_mask);
3835 raw_spin_unlock_irqrestore(&p->pi_lock, flags); 3833 raw_spin_unlock_irqrestore(&p->pi_lock, flags);
3836 3834
3837out_unlock: 3835out_unlock:
3838 rcu_read_unlock(); 3836 rcu_read_unlock();
3839 put_online_cpus();
3840 3837
3841 return retval; 3838 return retval;
3842} 3839}
@@ -6494,14 +6491,17 @@ void __init sched_init_smp(void)
6494 6491
6495 sched_init_numa(); 6492 sched_init_numa();
6496 6493
6497 get_online_cpus(); 6494 /*
6495 * There's no userspace yet to cause hotplug operations; hence all the
6496 * cpu masks are stable and all blatant races in the below code cannot
6497 * happen.
6498 */
6498 mutex_lock(&sched_domains_mutex); 6499 mutex_lock(&sched_domains_mutex);
6499 init_sched_domains(cpu_active_mask); 6500 init_sched_domains(cpu_active_mask);
6500 cpumask_andnot(non_isolated_cpus, cpu_possible_mask, cpu_isolated_map); 6501 cpumask_andnot(non_isolated_cpus, cpu_possible_mask, cpu_isolated_map);
6501 if (cpumask_empty(non_isolated_cpus)) 6502 if (cpumask_empty(non_isolated_cpus))
6502 cpumask_set_cpu(smp_processor_id(), non_isolated_cpus); 6503 cpumask_set_cpu(smp_processor_id(), non_isolated_cpus);
6503 mutex_unlock(&sched_domains_mutex); 6504 mutex_unlock(&sched_domains_mutex);
6504 put_online_cpus();
6505 6505
6506 hotcpu_notifier(sched_domains_numa_masks_update, CPU_PRI_SCHED_ACTIVE); 6506 hotcpu_notifier(sched_domains_numa_masks_update, CPU_PRI_SCHED_ACTIVE);
6507 hotcpu_notifier(cpuset_cpu_active, CPU_PRI_CPUSET_ACTIVE); 6507 hotcpu_notifier(cpuset_cpu_active, CPU_PRI_CPUSET_ACTIVE);