Introduce new function, verify_parities(), to check if parities matches
for full stripe which all data stripes matches with their csum.

Caller should fill the scrub_full_stripe structure properly before
calling this function.

Signed-off-by: Qu Wenruo <quwen...@cn.fujitsu.com>
---
 scrub.c | 69 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 69 insertions(+)

diff --git a/scrub.c b/scrub.c
index 1944f216..ef391ad1 100644
--- a/scrub.c
+++ b/scrub.c
@@ -26,6 +26,7 @@
 #include "disk-io.h"
 #include "utils.h"
 #include "kernel-lib/bitops.h"
+#include "kernel-lib/raid56.h"
 
 /*
  * For parity based profile(RAID56)
@@ -756,3 +757,71 @@ out:
        btrfs_free_path(path);
        return ret;
 }
+
+/*
+ * Verify parities for RAID56
+ * Caller must fill @fstripe before calling this function
+ *
+ * Return 0 for parities matches.
+ * Return >0 for P or Q mismatch
+ * Return <0 for fatal error
+ */
+static int verify_parities(struct btrfs_fs_info *fs_info,
+                          struct btrfs_scrub_progress *scrub_ctx,
+                          struct scrub_full_stripe *fstripe)
+{
+       void **ptrs;
+       void *ondisk_p = NULL;
+       void *ondisk_q = NULL;
+       void *buf_p;
+       void *buf_q;
+       int nr_stripes = fstripe->nr_stripes;
+       int stripe_len = BTRFS_STRIPE_LEN;
+       int i;
+       int ret = 0;
+
+       ptrs = malloc(sizeof(void *) * fstripe->nr_stripes);
+       buf_p = malloc(fstripe->stripe_len);
+       buf_q = malloc(fstripe->stripe_len);
+       if (!ptrs || !buf_p || !buf_q) {
+               ret = -ENOMEM;
+               goto out;
+       }
+
+       for (i = 0; i < fstripe->nr_stripes; i++) {
+               struct scrub_stripe *stripe = &fstripe->stripes[i];
+
+               if (stripe->logical == BTRFS_RAID5_P_STRIPE) {
+                       ondisk_p = stripe->data;
+                       ptrs[i] = buf_p;
+                       continue;
+               } else if (stripe->logical == BTRFS_RAID6_Q_STRIPE) {
+                       ondisk_q = stripe->data;
+                       ptrs[i] = buf_q;
+                       continue;
+               } else {
+                       ptrs[i] = stripe->data;
+                       continue;
+               }
+       }
+       /* RAID6 */
+       if (ondisk_q) {
+               raid6_gen_syndrome(nr_stripes, stripe_len, ptrs);
+
+               if (memcmp(ondisk_q, ptrs[nr_stripes - 1], stripe_len) != 0 ||
+                   memcmp(ondisk_p, ptrs[nr_stripes - 2], stripe_len))
+                       ret = 1;
+       } else {
+               ret = raid5_gen_result(nr_stripes, stripe_len, nr_stripes - 1,
+                                       ptrs);
+               if (ret < 0)
+                       goto out;
+               if (memcmp(ondisk_p, ptrs[nr_stripes - 1], stripe_len) != 0)
+                       ret = 1;
+       }
+out:
+       free(buf_p);
+       free(buf_q);
+       free(ptrs);
+       return ret;
+}
-- 
2.13.0



--
To unsubscribe from this list: send the line "unsubscribe linux-btrfs" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html

Reply via email to