aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/base/dd.c
diff options
context:
space:
mode:
authorBhaktipriya Shridhar <bhaktipriya96@gmail.com>2016-08-30 13:15:34 -0400
committerGreg Kroah-Hartman <gregkh@linuxfoundation.org>2016-09-02 09:08:02 -0400
commit2c507e464f791327c94d17a0137f00b4717744fc (patch)
tree1e4f42cd773658a9199c731123a96207d4bb35a0 /drivers/base/dd.c
parent775115c06091fcfa1189a50aca488fa596839617 (diff)
device core: Remove deprecated create_singlethread_workqueue
The workqueue "deferred_wq" queues a single work item &deferred_probe_work and hence doesn't require ordering. It is involved in probing devices and is not being used on a memory reclaim path. Hence, it has been converted to use system_wq. System workqueues have been able to handle high level of concurrency for a long time now and hence it's not required to have a singlethreaded workqueue just to gain concurrency. Unlike a dedicated per-cpu workqueue created with create_singlethread_workqueue(), system_wq allows multiple work items to overlap executions even on the same CPU; however, a per-cpu workqueue doesn't have any CPU locality or global ordering guarantee unless the target CPU is explicitly specified and thus the increase of local concurrency shouldn't make any difference. The work item has been flushed in driver_probe_done() to ensure that there are no pending tasks while disconnecting the driver. Signed-off-by: Bhaktipriya Shridhar <bhaktipriya96@gmail.com> Acked-by: Tejun Heo <tj@kernel.org> Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
Diffstat (limited to 'drivers/base/dd.c')
-rw-r--r--drivers/base/dd.c12
1 files changed, 3 insertions, 9 deletions
diff --git a/drivers/base/dd.c b/drivers/base/dd.c
index 4910e6db2a34..d22a7260f42b 100644
--- a/drivers/base/dd.c
+++ b/drivers/base/dd.c
@@ -51,7 +51,6 @@
51static DEFINE_MUTEX(deferred_probe_mutex); 51static DEFINE_MUTEX(deferred_probe_mutex);
52static LIST_HEAD(deferred_probe_pending_list); 52static LIST_HEAD(deferred_probe_pending_list);
53static LIST_HEAD(deferred_probe_active_list); 53static LIST_HEAD(deferred_probe_active_list);
54static struct workqueue_struct *deferred_wq;
55static atomic_t deferred_trigger_count = ATOMIC_INIT(0); 54static atomic_t deferred_trigger_count = ATOMIC_INIT(0);
56 55
57/* 56/*
@@ -175,7 +174,7 @@ static void driver_deferred_probe_trigger(void)
175 * Kick the re-probe thread. It may already be scheduled, but it is 174 * Kick the re-probe thread. It may already be scheduled, but it is
176 * safe to kick it again. 175 * safe to kick it again.
177 */ 176 */
178 queue_work(deferred_wq, &deferred_probe_work); 177 schedule_work(&deferred_probe_work);
179} 178}
180 179
181/** 180/**
@@ -211,14 +210,10 @@ void device_unblock_probing(void)
211 */ 210 */
212static int deferred_probe_initcall(void) 211static int deferred_probe_initcall(void)
213{ 212{
214 deferred_wq = create_singlethread_workqueue("deferwq");
215 if (WARN_ON(!deferred_wq))
216 return -ENOMEM;
217
218 driver_deferred_probe_enable = true; 213 driver_deferred_probe_enable = true;
219 driver_deferred_probe_trigger(); 214 driver_deferred_probe_trigger();
220 /* Sort as many dependencies as possible before exiting initcalls */ 215 /* Sort as many dependencies as possible before exiting initcalls */
221 flush_workqueue(deferred_wq); 216 flush_work(&deferred_probe_work);
222 return 0; 217 return 0;
223} 218}
224late_initcall(deferred_probe_initcall); 219late_initcall(deferred_probe_initcall);
@@ -481,8 +476,7 @@ int driver_probe_done(void)
481void wait_for_device_probe(void) 476void wait_for_device_probe(void)
482{ 477{
483 /* wait for the deferred probe workqueue to finish */ 478 /* wait for the deferred probe workqueue to finish */
484 if (driver_deferred_probe_enable) 479 flush_work(&deferred_probe_work);
485 flush_workqueue(deferred_wq);
486 480
487 /* wait for the known devices to complete their probing */ 481 /* wait for the known devices to complete their probing */
488 wait_event(probe_waitqueue, atomic_read(&probe_count) == 0); 482 wait_event(probe_waitqueue, atomic_read(&probe_count) == 0);