diff options
Diffstat (limited to 'kernel/sched.c')
-rw-r--r-- | kernel/sched.c | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/kernel/sched.c b/kernel/sched.c index 2a107e4ad5ed..e195a4229418 100644 --- a/kernel/sched.c +++ b/kernel/sched.c | |||
@@ -472,6 +472,12 @@ const_debug unsigned int sysctl_sched_features = | |||
472 | #define sched_feat(x) (sysctl_sched_features & SCHED_FEAT_##x) | 472 | #define sched_feat(x) (sysctl_sched_features & SCHED_FEAT_##x) |
473 | 473 | ||
474 | /* | 474 | /* |
475 | * Number of tasks to iterate in a single balance run. | ||
476 | * Limited because this is done with IRQs disabled. | ||
477 | */ | ||
478 | const_debug unsigned int sysctl_sched_nr_migrate = 32; | ||
479 | |||
480 | /* | ||
475 | * For kernel-internal use: high-speed (but slightly incorrect) per-cpu | 481 | * For kernel-internal use: high-speed (but slightly incorrect) per-cpu |
476 | * clock constructed from sched_clock(): | 482 | * clock constructed from sched_clock(): |
477 | */ | 483 | */ |
@@ -2235,7 +2241,7 @@ balance_tasks(struct rq *this_rq, int this_cpu, struct rq *busiest, | |||
2235 | enum cpu_idle_type idle, int *all_pinned, | 2241 | enum cpu_idle_type idle, int *all_pinned, |
2236 | int *this_best_prio, struct rq_iterator *iterator) | 2242 | int *this_best_prio, struct rq_iterator *iterator) |
2237 | { | 2243 | { |
2238 | int pulled = 0, pinned = 0, skip_for_load; | 2244 | int loops = 0, pulled = 0, pinned = 0, skip_for_load; |
2239 | struct task_struct *p; | 2245 | struct task_struct *p; |
2240 | long rem_load_move = max_load_move; | 2246 | long rem_load_move = max_load_move; |
2241 | 2247 | ||
@@ -2249,10 +2255,10 @@ balance_tasks(struct rq *this_rq, int this_cpu, struct rq *busiest, | |||
2249 | */ | 2255 | */ |
2250 | p = iterator->start(iterator->arg); | 2256 | p = iterator->start(iterator->arg); |
2251 | next: | 2257 | next: |
2252 | if (!p) | 2258 | if (!p || loops++ > sysctl_sched_nr_migrate) |
2253 | goto out; | 2259 | goto out; |
2254 | /* | 2260 | /* |
2255 | * To help distribute high priority tasks accross CPUs we don't | 2261 | * To help distribute high priority tasks across CPUs we don't |
2256 | * skip a task if it will be the highest priority task (i.e. smallest | 2262 | * skip a task if it will be the highest priority task (i.e. smallest |
2257 | * prio value) on its new queue regardless of its load weight | 2263 | * prio value) on its new queue regardless of its load weight |
2258 | */ | 2264 | */ |
@@ -2269,8 +2275,7 @@ next: | |||
2269 | rem_load_move -= p->se.load.weight; | 2275 | rem_load_move -= p->se.load.weight; |
2270 | 2276 | ||
2271 | /* | 2277 | /* |
2272 | * We only want to steal up to the prescribed number of tasks | 2278 | * We only want to steal up to the prescribed amount of weighted load. |
2273 | * and the prescribed amount of weighted load. | ||
2274 | */ | 2279 | */ |
2275 | if (rem_load_move > 0) { | 2280 | if (rem_load_move > 0) { |
2276 | if (p->prio < *this_best_prio) | 2281 | if (p->prio < *this_best_prio) |