3 files changed, 13 insertions, 23 deletions

diff --git a/block/blk-core.c b/block/blk-core.c
index ee3cb3a5e278..d2da64170513 100644
--- a/block/blk-core.c
+++ b/block/blk-core.c
@@ -262,7 +262,7 @@ EXPORT_SYMBOL(blk_start_queue);
  **/
 void blk_stop_queue(struct request_queue *q)
 {
-        __cancel_delayed_work(&q->delay_work);
+        cancel_delayed_work(&q->delay_work);
         queue_flag_set(QUEUE_FLAG_STOPPED, q);
 }
 EXPORT_SYMBOL(blk_stop_queue);
@@ -319,10 +319,8 @@ EXPORT_SYMBOL(__blk_run_queue);
  */
 void blk_run_queue_async(struct request_queue *q)
 {
-        if (likely(!blk_queue_stopped(q))) {
-                __cancel_delayed_work(&q->delay_work);
-                queue_delayed_work(kblockd_workqueue, &q->delay_work, 0);
-        }
+        if (likely(!blk_queue_stopped(q)))
+                mod_delayed_work(kblockd_workqueue, &q->delay_work, 0);
 }
 EXPORT_SYMBOL(blk_run_queue_async);
 
diff --git a/block/blk-throttle.c b/block/blk-throttle.c
index e287c19908c8..a9664fa0b609 100644
--- a/block/blk-throttle.c
+++ b/block/blk-throttle.c
@@ -180,7 +180,7 @@ static inline unsigned int total_nr_queued(struct throtl_data *td)
 
 /*
  * Worker for allocating per cpu stat for tgs. This is scheduled on the
- * system_nrt_wq once there are some groups on the alloc_list waiting for
+ * system_wq once there are some groups on the alloc_list waiting for
  * allocation.
  */
 static void tg_stats_alloc_fn(struct work_struct *work)
@@ -194,8 +194,7 @@ alloc_stats:
                 stats_cpu = alloc_percpu(struct tg_stats_cpu);
                 if (!stats_cpu) {
                         /* allocation failed, try again after some time */
-                        queue_delayed_work(system_nrt_wq, dwork,
-                                           msecs_to_jiffies(10));
+                        schedule_delayed_work(dwork, msecs_to_jiffies(10));
                         return;
                 }
         }
@@ -238,7 +237,7 @@ static void throtl_pd_init(struct blkcg_gq *blkg)
          */
         spin_lock_irqsave(&tg_stats_alloc_lock, flags);
         list_add(&tg->stats_alloc_node, &tg_stats_alloc_list);
-        queue_delayed_work(system_nrt_wq, &tg_stats_alloc_work, 0);
+        schedule_delayed_work(&tg_stats_alloc_work, 0);
         spin_unlock_irqrestore(&tg_stats_alloc_lock, flags);
 }
 
@@ -930,12 +929,7 @@ throtl_schedule_delayed_work(struct throtl_data *td, unsigned long delay)
 
         /* schedule work if limits changed even if no bio is queued */
         if (total_nr_queued(td) || td->limits_changed) {
-                /*
-                 * We might have a work scheduled to be executed in future.
-                 * Cancel that and schedule a new one.
-                 */
-                __cancel_delayed_work(dwork);
-                queue_delayed_work(kthrotld_workqueue, dwork, delay);
+                mod_delayed_work(kthrotld_workqueue, dwork, delay);
                 throtl_log(td, "schedule work. delay=%lu jiffies=%lu",
                                 delay, jiffies);
         }
diff --git a/block/genhd.c b/block/genhd.c
index d839723303c8..6cace663a80e 100644
--- a/block/genhd.c
+++ b/block/genhd.c
@@ -1490,9 +1490,9 @@ static void __disk_unblock_events(struct gendisk *disk, bool check_now)
         intv = disk_events_poll_jiffies(disk);
         set_timer_slack(&ev->dwork.timer, intv / 4);
         if (check_now)
-                queue_delayed_work(system_nrt_freezable_wq, &ev->dwork, 0);
+                queue_delayed_work(system_freezable_wq, &ev->dwork, 0);
         else if (intv)
-                queue_delayed_work(system_nrt_freezable_wq, &ev->dwork, intv);
+                queue_delayed_work(system_freezable_wq, &ev->dwork, intv);
 out_unlock:
         spin_unlock_irqrestore(&ev->lock, flags);
 }
@@ -1534,10 +1534,8 @@ void disk_flush_events(struct gendisk *disk, unsigned int mask)
 
         spin_lock_irq(&ev->lock);
         ev->clearing |= mask;
-        if (!ev->block) {
-                cancel_delayed_work(&ev->dwork);
-                queue_delayed_work(system_nrt_freezable_wq, &ev->dwork, 0);
-        }
+        if (!ev->block)
+                mod_delayed_work(system_freezable_wq, &ev->dwork, 0);
         spin_unlock_irq(&ev->lock);
 }
 
@@ -1573,7 +1571,7 @@ unsigned int disk_clear_events(struct gendisk *disk, unsigned int mask)
 
         /* uncondtionally schedule event check and wait for it to finish */
         disk_block_events(disk);
-        queue_delayed_work(system_nrt_freezable_wq, &ev->dwork, 0);
+        queue_delayed_work(system_freezable_wq, &ev->dwork, 0);
         flush_delayed_work(&ev->dwork);
         __disk_unblock_events(disk, false);
 
@@ -1610,7 +1608,7 @@ static void disk_events_workfn(struct work_struct *work)
 
         intv = disk_events_poll_jiffies(disk);
         if (!ev->block && intv)
-                queue_delayed_work(system_nrt_freezable_wq, &ev->dwork, intv);
+                queue_delayed_work(system_freezable_wq, &ev->dwork, intv);
 
         spin_unlock_irq(&ev->lock);