md: use separate work_struct for md_start_sync()
authorYu Kuai <yukuai3@huawei.com>
Fri, 25 Aug 2023 03:16:16 +0000 (11:16 +0800)
committerSong Liu <song@kernel.org>
Fri, 22 Sep 2023 17:28:24 +0000 (10:28 -0700)
It's a little weird to borrow 'del_work' for md_start_sync(), declare
a new work_struct 'sync_work' for md_start_sync().

Signed-off-by: Yu Kuai <yukuai3@huawei.com>
Reviewed-by: Xiao Ni <xni@redhat.com>
Signed-off-by: Song Liu <song@kernel.org>
Link: https://lore.kernel.org/r/20230825031622.1530464-2-yukuai1@huaweicloud.com
drivers/md/md.c
drivers/md/md.h

index a104a025084dc726056c42b0b1a0dd37ea774803..fb9aae4accb0347ec0c92fd74763334c7afb989d 100644 (file)
@@ -631,13 +631,13 @@ void mddev_put(struct mddev *mddev)
                 * flush_workqueue() after mddev_find will succeed in waiting
                 * for the work to be done.
                 */
-               INIT_WORK(&mddev->del_work, mddev_delayed_delete);
                queue_work(md_misc_wq, &mddev->del_work);
        }
        spin_unlock(&all_mddevs_lock);
 }
 
 static void md_safemode_timeout(struct timer_list *t);
+static void md_start_sync(struct work_struct *ws);
 
 void mddev_init(struct mddev *mddev)
 {
@@ -662,6 +662,9 @@ void mddev_init(struct mddev *mddev)
        mddev->resync_min = 0;
        mddev->resync_max = MaxSector;
        mddev->level = LEVEL_NONE;
+
+       INIT_WORK(&mddev->sync_work, md_start_sync);
+       INIT_WORK(&mddev->del_work, mddev_delayed_delete);
 }
 EXPORT_SYMBOL_GPL(mddev_init);
 
@@ -9256,7 +9259,7 @@ no_add:
 
 static void md_start_sync(struct work_struct *ws)
 {
-       struct mddev *mddev = container_of(ws, struct mddev, del_work);
+       struct mddev *mddev = container_of(ws, struct mddev, sync_work);
 
        rcu_assign_pointer(mddev->sync_thread,
                           md_register_thread(md_do_sync, mddev, "resync"));
@@ -9469,8 +9472,7 @@ void md_check_recovery(struct mddev *mddev)
                                 */
                                md_bitmap_write_all(mddev->bitmap);
                        }
-                       INIT_WORK(&mddev->del_work, md_start_sync);
-                       queue_work(md_misc_wq, &mddev->del_work);
+                       queue_work(md_misc_wq, &mddev->sync_work);
                        goto unlock;
                }
        not_running:
index 7c9c13abd7cac00e36b5b2b44784735a645afeca..d8c8b8c532bb43b4761aaa4c530dbc3f1ad1c5ad 100644 (file)
@@ -453,7 +453,10 @@ struct mddev {
        struct kernfs_node              *sysfs_degraded;        /*handle for 'degraded' */
        struct kernfs_node              *sysfs_level;           /*handle for 'level' */
 
-       struct work_struct del_work;    /* used for delayed sysfs removal */
+       /* used for delayed sysfs removal */
+       struct work_struct del_work;
+       /* used for register new sync thread */
+       struct work_struct sync_work;
 
        /* "lock" protects:
         *   flush_bio transition from NULL to !NULL