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

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

diff --git a/check/scrub.c b/check/scrub.c
index f29effa..d8182d6 100644
--- a/check/scrub.c
+++ b/check/scrub.c
@@ -408,3 +408,62 @@ out:
        btrfs_free_path(path);
        return ret;
 }
+
+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;
+
+       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) ||
+                   memcmp(ondisk_p, ptrs[nr_stripes - 2], stripe_len))
+                       ret = -EIO;
+       } 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))
+                       ret = -EIO;
+       }
+out:
+       free(buf_p);
+       free(buf_q);
+       free(ptrs);
+       return ret;
+}
-- 
2.10.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