diff options
-rw-r--r-- | kernel/rcutree.c | 24 | ||||
-rw-r--r-- | kernel/rcutree_plugin.h | 8 |
2 files changed, 24 insertions, 8 deletions
diff --git a/kernel/rcutree.c b/kernel/rcutree.c index 28fd92a9e0d0..51eef4193e7c 100644 --- a/kernel/rcutree.c +++ b/kernel/rcutree.c | |||
@@ -95,7 +95,7 @@ static DEFINE_PER_CPU(wait_queue_head_t, rcu_cpu_wq); | |||
95 | static DEFINE_PER_CPU(char, rcu_cpu_has_work); | 95 | static DEFINE_PER_CPU(char, rcu_cpu_has_work); |
96 | static char rcu_kthreads_spawnable; | 96 | static char rcu_kthreads_spawnable; |
97 | 97 | ||
98 | static void rcu_node_kthread_setaffinity(struct rcu_node *rnp); | 98 | static void rcu_node_kthread_setaffinity(struct rcu_node *rnp, int outgoingcpu); |
99 | static void invoke_rcu_cpu_kthread(void); | 99 | static void invoke_rcu_cpu_kthread(void); |
100 | 100 | ||
101 | #define RCU_KTHREAD_PRIO 1 /* RT priority for per-CPU kthreads. */ | 101 | #define RCU_KTHREAD_PRIO 1 /* RT priority for per-CPU kthreads. */ |
@@ -1099,7 +1099,7 @@ static void __rcu_offline_cpu(int cpu, struct rcu_state *rsp) | |||
1099 | kthread_stop(t); | 1099 | kthread_stop(t); |
1100 | rcu_stop_boost_kthread(rnp); | 1100 | rcu_stop_boost_kthread(rnp); |
1101 | } else | 1101 | } else |
1102 | rcu_node_kthread_setaffinity(rnp); | 1102 | rcu_node_kthread_setaffinity(rnp, -1); |
1103 | } | 1103 | } |
1104 | 1104 | ||
1105 | /* | 1105 | /* |
@@ -1644,8 +1644,12 @@ static int rcu_node_kthread(void *arg) | |||
1644 | * Set the per-rcu_node kthread's affinity to cover all CPUs that are | 1644 | * Set the per-rcu_node kthread's affinity to cover all CPUs that are |
1645 | * served by the rcu_node in question. The CPU hotplug lock is still | 1645 | * served by the rcu_node in question. The CPU hotplug lock is still |
1646 | * held, so the value of rnp->qsmaskinit will be stable. | 1646 | * held, so the value of rnp->qsmaskinit will be stable. |
1647 | * | ||
1648 | * We don't include outgoingcpu in the affinity set, use -1 if there is | ||
1649 | * no outgoing CPU. If there are no CPUs left in the affinity set, | ||
1650 | * this function allows the kthread to execute on any CPU. | ||
1647 | */ | 1651 | */ |
1648 | static void rcu_node_kthread_setaffinity(struct rcu_node *rnp) | 1652 | static void rcu_node_kthread_setaffinity(struct rcu_node *rnp, int outgoingcpu) |
1649 | { | 1653 | { |
1650 | cpumask_var_t cm; | 1654 | cpumask_var_t cm; |
1651 | int cpu; | 1655 | int cpu; |
@@ -1657,8 +1661,14 @@ static void rcu_node_kthread_setaffinity(struct rcu_node *rnp) | |||
1657 | return; | 1661 | return; |
1658 | cpumask_clear(cm); | 1662 | cpumask_clear(cm); |
1659 | for (cpu = rnp->grplo; cpu <= rnp->grphi; cpu++, mask >>= 1) | 1663 | for (cpu = rnp->grplo; cpu <= rnp->grphi; cpu++, mask >>= 1) |
1660 | if (mask & 0x1) | 1664 | if ((mask & 0x1) && cpu != outgoingcpu) |
1661 | cpumask_set_cpu(cpu, cm); | 1665 | cpumask_set_cpu(cpu, cm); |
1666 | if (cpumask_weight(cm) == 0) { | ||
1667 | cpumask_setall(cm); | ||
1668 | for (cpu = rnp->grplo; cpu <= rnp->grphi; cpu++) | ||
1669 | cpumask_clear_cpu(cpu, cm); | ||
1670 | WARN_ON_ONCE(cpumask_weight(cm) == 0); | ||
1671 | } | ||
1662 | set_cpus_allowed_ptr(rnp->node_kthread_task, cm); | 1672 | set_cpus_allowed_ptr(rnp->node_kthread_task, cm); |
1663 | rcu_boost_kthread_setaffinity(rnp, cm); | 1673 | rcu_boost_kthread_setaffinity(rnp, cm); |
1664 | free_cpumask_var(cm); | 1674 | free_cpumask_var(cm); |
@@ -2154,7 +2164,11 @@ static int __cpuinit rcu_cpu_notify(struct notifier_block *self, | |||
2154 | rcu_online_kthreads(cpu); | 2164 | rcu_online_kthreads(cpu); |
2155 | break; | 2165 | break; |
2156 | case CPU_ONLINE: | 2166 | case CPU_ONLINE: |
2157 | rcu_node_kthread_setaffinity(rnp); | 2167 | case CPU_DOWN_FAILED: |
2168 | rcu_node_kthread_setaffinity(rnp, -1); | ||
2169 | break; | ||
2170 | case CPU_DOWN_PREPARE: | ||
2171 | rcu_node_kthread_setaffinity(rnp, cpu); | ||
2158 | break; | 2172 | break; |
2159 | case CPU_DYING: | 2173 | case CPU_DYING: |
2160 | case CPU_DYING_FROZEN: | 2174 | case CPU_DYING_FROZEN: |
diff --git a/kernel/rcutree_plugin.h b/kernel/rcutree_plugin.h index 5964f82e2d96..4e486255df63 100644 --- a/kernel/rcutree_plugin.h +++ b/kernel/rcutree_plugin.h | |||
@@ -1212,17 +1212,19 @@ static void rcu_initiate_boost(struct rcu_node *rnp) | |||
1212 | } | 1212 | } |
1213 | } | 1213 | } |
1214 | 1214 | ||
1215 | /* | ||
1216 | * Set the affinity of the boost kthread. The CPU-hotplug locks are | ||
1217 | * held, so no one should be messing with the existence of the boost | ||
1218 | * kthread. | ||
1219 | */ | ||
1215 | static void rcu_boost_kthread_setaffinity(struct rcu_node *rnp, | 1220 | static void rcu_boost_kthread_setaffinity(struct rcu_node *rnp, |
1216 | cpumask_var_t cm) | 1221 | cpumask_var_t cm) |
1217 | { | 1222 | { |
1218 | unsigned long flags; | ||
1219 | struct task_struct *t; | 1223 | struct task_struct *t; |
1220 | 1224 | ||
1221 | raw_spin_lock_irqsave(&rnp->lock, flags); | ||
1222 | t = rnp->boost_kthread_task; | 1225 | t = rnp->boost_kthread_task; |
1223 | if (t != NULL) | 1226 | if (t != NULL) |
1224 | set_cpus_allowed_ptr(rnp->boost_kthread_task, cm); | 1227 | set_cpus_allowed_ptr(rnp->boost_kthread_task, cm); |
1225 | raw_spin_unlock_irqrestore(&rnp->lock, flags); | ||
1226 | } | 1228 | } |
1227 | 1229 | ||
1228 | #define RCU_BOOST_DELAY_JIFFIES DIV_ROUND_UP(CONFIG_RCU_BOOST_DELAY * HZ, 1000) | 1230 | #define RCU_BOOST_DELAY_JIFFIES DIV_ROUND_UP(CONFIG_RCU_BOOST_DELAY * HZ, 1000) |