diff options
author | Ingo Molnar <mingo@kernel.org> | 2012-12-08 09:25:06 -0500 |
---|---|---|
committer | Ingo Molnar <mingo@kernel.org> | 2012-12-08 09:25:06 -0500 |
commit | f0b9abfb044649bc452fb2fb975ff2fd599cc6a3 (patch) | |
tree | 7800081c5cb16a4dfee1e57a70f3be90f7b50d9a /kernel/workqueue.c | |
parent | adc1ef1e37358d3c17d1a74a58b2e104fc0bda15 (diff) | |
parent | 1b3c393cd43f22ead8a6a2f839efc6df8ebd7465 (diff) |
Merge branch 'linus' into perf/core
Conflicts:
tools/perf/Makefile
tools/perf/builtin-test.c
tools/perf/perf.h
tools/perf/tests/parse-events.c
tools/perf/util/evsel.h
Signed-off-by: Ingo Molnar <mingo@kernel.org>
Diffstat (limited to 'kernel/workqueue.c')
-rw-r--r-- | kernel/workqueue.c | 24 |
1 files changed, 17 insertions, 7 deletions
diff --git a/kernel/workqueue.c b/kernel/workqueue.c index d951daa0ca9a..1dae900df798 100644 --- a/kernel/workqueue.c +++ b/kernel/workqueue.c | |||
@@ -1361,8 +1361,19 @@ static void __queue_delayed_work(int cpu, struct workqueue_struct *wq, | |||
1361 | 1361 | ||
1362 | WARN_ON_ONCE(timer->function != delayed_work_timer_fn || | 1362 | WARN_ON_ONCE(timer->function != delayed_work_timer_fn || |
1363 | timer->data != (unsigned long)dwork); | 1363 | timer->data != (unsigned long)dwork); |
1364 | BUG_ON(timer_pending(timer)); | 1364 | WARN_ON_ONCE(timer_pending(timer)); |
1365 | BUG_ON(!list_empty(&work->entry)); | 1365 | WARN_ON_ONCE(!list_empty(&work->entry)); |
1366 | |||
1367 | /* | ||
1368 | * If @delay is 0, queue @dwork->work immediately. This is for | ||
1369 | * both optimization and correctness. The earliest @timer can | ||
1370 | * expire is on the closest next tick and delayed_work users depend | ||
1371 | * on that there's no such delay when @delay is 0. | ||
1372 | */ | ||
1373 | if (!delay) { | ||
1374 | __queue_work(cpu, wq, &dwork->work); | ||
1375 | return; | ||
1376 | } | ||
1366 | 1377 | ||
1367 | timer_stats_timer_set_start_info(&dwork->timer); | 1378 | timer_stats_timer_set_start_info(&dwork->timer); |
1368 | 1379 | ||
@@ -1417,9 +1428,6 @@ bool queue_delayed_work_on(int cpu, struct workqueue_struct *wq, | |||
1417 | bool ret = false; | 1428 | bool ret = false; |
1418 | unsigned long flags; | 1429 | unsigned long flags; |
1419 | 1430 | ||
1420 | if (!delay) | ||
1421 | return queue_work_on(cpu, wq, &dwork->work); | ||
1422 | |||
1423 | /* read the comment in __queue_work() */ | 1431 | /* read the comment in __queue_work() */ |
1424 | local_irq_save(flags); | 1432 | local_irq_save(flags); |
1425 | 1433 | ||
@@ -2407,8 +2415,10 @@ static int rescuer_thread(void *__wq) | |||
2407 | repeat: | 2415 | repeat: |
2408 | set_current_state(TASK_INTERRUPTIBLE); | 2416 | set_current_state(TASK_INTERRUPTIBLE); |
2409 | 2417 | ||
2410 | if (kthread_should_stop()) | 2418 | if (kthread_should_stop()) { |
2419 | __set_current_state(TASK_RUNNING); | ||
2411 | return 0; | 2420 | return 0; |
2421 | } | ||
2412 | 2422 | ||
2413 | /* | 2423 | /* |
2414 | * See whether any cpu is asking for help. Unbounded | 2424 | * See whether any cpu is asking for help. Unbounded |
@@ -2982,7 +2992,7 @@ bool cancel_delayed_work(struct delayed_work *dwork) | |||
2982 | 2992 | ||
2983 | set_work_cpu_and_clear_pending(&dwork->work, work_cpu(&dwork->work)); | 2993 | set_work_cpu_and_clear_pending(&dwork->work, work_cpu(&dwork->work)); |
2984 | local_irq_restore(flags); | 2994 | local_irq_restore(flags); |
2985 | return true; | 2995 | return ret; |
2986 | } | 2996 | } |
2987 | EXPORT_SYMBOL(cancel_delayed_work); | 2997 | EXPORT_SYMBOL(cancel_delayed_work); |
2988 | 2998 | ||