md: factor out a helper to choose sync action from md_check_recovery()
authorYu Kuai <yukuai3@huawei.com>
Fri, 25 Aug 2023 03:16:17 +0000 (11:16 +0800)
committerSong Liu <song@kernel.org>
Fri, 22 Sep 2023 17:28:25 +0000 (10:28 -0700)
There are no functional changes, on the one hand make the code cleaner,
on the other hand prevent following checkpatch error in the next patch to
delay choosing sync action to md_start_sync().

ERROR: do not use assignment in if condition
+       } else if ((spares = remove_and_add_spares(mddev, NULL))) {

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-3-yukuai1@huaweicloud.com
drivers/md/md.c

index fb9aae4accb0347ec0c92fd74763334c7afb989d..e6118755fca14846128103b1788bb6ba79719512 100644 (file)
@@ -9257,6 +9257,50 @@ no_add:
        return spares;
 }
 
+static bool md_choose_sync_action(struct mddev *mddev, int *spares)
+{
+       /* Check if reshape is in progress first. */
+       if (mddev->reshape_position != MaxSector) {
+               if (mddev->pers->check_reshape == NULL ||
+                   mddev->pers->check_reshape(mddev) != 0)
+                       return false;
+
+               set_bit(MD_RECOVERY_RESHAPE, &mddev->recovery);
+               clear_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
+               return true;
+       }
+
+       /*
+        * Remove any failed drives, then add spares if possible. Spares are
+        * also removed and re-added, to allow the personality to fail the
+        * re-add.
+        */
+       *spares = remove_and_add_spares(mddev, NULL);
+       if (*spares) {
+               clear_bit(MD_RECOVERY_SYNC, &mddev->recovery);
+               clear_bit(MD_RECOVERY_CHECK, &mddev->recovery);
+               clear_bit(MD_RECOVERY_REQUESTED, &mddev->recovery);
+
+               /* Start new recovery. */
+               set_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
+               return true;
+       }
+
+       /* Check if recovery is in progress. */
+       if (mddev->recovery_cp < MaxSector) {
+               set_bit(MD_RECOVERY_SYNC, &mddev->recovery);
+               clear_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
+               return true;
+       }
+
+       /* Delay to choose resync/check/repair in md_do_sync(). */
+       if (test_bit(MD_RECOVERY_SYNC, &mddev->recovery))
+               return true;
+
+       /* Nothing to be done */
+       return false;
+}
+
 static void md_start_sync(struct work_struct *ws)
 {
        struct mddev *mddev = container_of(ws, struct mddev, sync_work);
@@ -9438,32 +9482,8 @@ void md_check_recovery(struct mddev *mddev)
                if (!test_and_clear_bit(MD_RECOVERY_NEEDED, &mddev->recovery) ||
                    test_bit(MD_RECOVERY_FROZEN, &mddev->recovery))
                        goto not_running;
-               /* no recovery is running.
-                * remove any failed drives, then
-                * add spares if possible.
-                * Spares are also removed and re-added, to allow
-                * the personality to fail the re-add.
-                */
-
-               if (mddev->reshape_position != MaxSector) {
-                       if (mddev->pers->check_reshape == NULL ||
-                           mddev->pers->check_reshape(mddev) != 0)
-                               /* Cannot proceed */
-                               goto not_running;
-                       set_bit(MD_RECOVERY_RESHAPE, &mddev->recovery);
-                       clear_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
-               } else if ((spares = remove_and_add_spares(mddev, NULL))) {
-                       clear_bit(MD_RECOVERY_SYNC, &mddev->recovery);
-                       clear_bit(MD_RECOVERY_CHECK, &mddev->recovery);
-                       clear_bit(MD_RECOVERY_REQUESTED, &mddev->recovery);
-                       set_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
-               } else if (mddev->recovery_cp < MaxSector) {
-                       set_bit(MD_RECOVERY_SYNC, &mddev->recovery);
-                       clear_bit(MD_RECOVERY_RECOVER, &mddev->recovery);
-               } else if (!test_bit(MD_RECOVERY_SYNC, &mddev->recovery))
-                       /* nothing to be done ... */
+               if (!md_choose_sync_action(mddev, &spares))
                        goto not_running;
-
                if (mddev->pers->sync_request) {
                        if (spares) {
                                /* We are adding a device or devices to an array