workqueues: schedule_on_each_cpu: use flush_work()
Change schedule_on_each_cpu() to use flush_work() instead of flush_workqueue(), this way we don't wait for other work_struct's which can be queued meanwhile. Signed-off-by: Oleg Nesterov <oleg@tv-sign.ru> Cc: Jarek Poplawski <jarkao2@gmail.com> Cc: Max Krasnyansky <maxk@qualcomm.com> Cc: Peter Zijlstra <peterz@infradead.org> Signed-off-by: Andrew Morton <akpm@linux-foundation.org> Signed-off-by: Linus Torvalds <torvalds@linux-foundation.org>
This commit is contained in:
parent
db70089722
commit
8616a89ab7
|
@ -690,7 +690,8 @@ int schedule_on_each_cpu(work_func_t func)
|
||||||
set_bit(WORK_STRUCT_PENDING, work_data_bits(work));
|
set_bit(WORK_STRUCT_PENDING, work_data_bits(work));
|
||||||
__queue_work(per_cpu_ptr(keventd_wq->cpu_wq, cpu), work);
|
__queue_work(per_cpu_ptr(keventd_wq->cpu_wq, cpu), work);
|
||||||
}
|
}
|
||||||
flush_workqueue(keventd_wq);
|
for_each_online_cpu(cpu)
|
||||||
|
flush_work(per_cpu_ptr(works, cpu));
|
||||||
put_online_cpus();
|
put_online_cpus();
|
||||||
free_percpu(works);
|
free_percpu(works);
|
||||||
return 0;
|
return 0;
|
||||||
|
|
Loading…
Reference in a new issue