xfs
[Top] [All Lists]

[PATCH 055/145] xfs_logprint: support rmap redo items

To: david@xxxxxxxxxxxxx, darrick.wong@xxxxxxxxxx
Subject: [PATCH 055/145] xfs_logprint: support rmap redo items
From: "Darrick J. Wong" <darrick.wong@xxxxxxxxxx>
Date: Thu, 16 Jun 2016 18:36:31 -0700
Cc: xfs@xxxxxxxxxxx
Delivered-to: xfs@xxxxxxxxxxx
In-reply-to: <146612704434.16048.12932915166928562654.stgit@xxxxxxxxxxxxxxxx>
References: <146612704434.16048.12932915166928562654.stgit@xxxxxxxxxxxxxxxx>
User-agent: StGit/0.17.1-dirty
Print reverse mapping update redo items.

Signed-off-by: Darrick J. Wong <darrick.wong@xxxxxxxxxx>
---
 logprint/log_misc.c      |   11 +++
 logprint/log_print_all.c |   12 ++++
 logprint/log_redo.c      |  152 ++++++++++++++++++++++++++++++++++++++++++++++
 logprint/logprint.h      |    5 ++
 4 files changed, 180 insertions(+)


diff --git a/logprint/log_misc.c b/logprint/log_misc.c
index 57d397c..479fc14 100644
--- a/logprint/log_misc.c
+++ b/logprint/log_misc.c
@@ -993,6 +993,17 @@ xlog_print_record(
                                        be32_to_cpu(op_head->oh_len));
                        break;
                    }
+                   case XFS_LI_RUI: {
+                       skip = xlog_print_trans_rui(&ptr,
+                                       be32_to_cpu(op_head->oh_len),
+                                       continued);
+                       break;
+                   }
+                   case XFS_LI_RUD: {
+                       skip = xlog_print_trans_rud(&ptr,
+                                       be32_to_cpu(op_head->oh_len));
+                       break;
+                   }
                    case XFS_LI_QUOTAOFF: {
                        skip = xlog_print_trans_qoff(&ptr,
                                        be32_to_cpu(op_head->oh_len));
diff --git a/logprint/log_print_all.c b/logprint/log_print_all.c
index 4d92c3b..0fe354b 100644
--- a/logprint/log_print_all.c
+++ b/logprint/log_print_all.c
@@ -408,6 +408,12 @@ xlog_recover_print_logitem(
        case XFS_LI_EFI:
                xlog_recover_print_efi(item);
                break;
+       case XFS_LI_RUD:
+               xlog_recover_print_rud(item);
+               break;
+       case XFS_LI_RUI:
+               xlog_recover_print_rui(item);
+               break;
        case XFS_LI_DQUOT:
                xlog_recover_print_dquot(item);
                break;
@@ -442,6 +448,12 @@ xlog_recover_print_item(
        case XFS_LI_EFI:
                printf("EFI");
                break;
+       case XFS_LI_RUD:
+               printf("RUD");
+               break;
+       case XFS_LI_RUI:
+               printf("RUI");
+               break;
        case XFS_LI_DQUOT:
                printf("DQ ");
                break;
diff --git a/logprint/log_redo.c b/logprint/log_redo.c
index d60cc1b..717dccd 100644
--- a/logprint/log_redo.c
+++ b/logprint/log_redo.c
@@ -229,3 +229,155 @@ xlog_recover_print_efd(
                f->efd_size, f->efd_nextents,
                (unsigned long long)f->efd_efi_id);
 }
+
+/* Reverse Mapping Update Items */
+
+static int
+xfs_rui_copy_format(
+       char                      *buf,
+       uint                      len,
+       struct xfs_rui_log_format *dst_fmt,
+       int                       continued)
+{
+       uint nextents = ((struct xfs_rui_log_format *)buf)->rui_nextents;
+       uint dst_len = sizeof(struct xfs_rui_log_format) +
+                       (nextents - 1) * sizeof(struct xfs_map_extent);
+
+       if (len == dst_len || continued) {
+               memcpy((char *)dst_fmt, buf, len);
+               return 0;
+       }
+       fprintf(stderr, _("%s: bad size of RUI format: %u; expected %u; 
nextents = %u\n"),
+               progname, len, dst_len, nextents);
+       return 1;
+}
+
+int
+xlog_print_trans_rui(
+       char                    **ptr,
+       uint                    src_len,
+       int                     continued)
+{
+       struct xfs_rui_log_format       *src_f, *f = NULL;
+       uint                    dst_len;
+       uint                    nextents;
+       struct xfs_map_extent   *ex;
+       int                     i;
+       int                     error = 0;
+       int                     core_size;
+
+       core_size = offsetof(struct xfs_rui_log_format, rui_extents);
+
+       /*
+        * memmove to ensure 8-byte alignment for the long longs in
+        * struct xfs_rui_log_format structure
+        */
+       src_f = malloc(src_len);
+       if (src_f == NULL) {
+               fprintf(stderr, _("%s: %s: malloc failed\n"),
+                       progname, __func__);
+               exit(1);
+       }
+       memmove((char*)src_f, *ptr, src_len);
+       *ptr += src_len;
+
+       /* convert to native format */
+       nextents = src_f->rui_nextents;
+       dst_len = sizeof(struct xfs_rui_log_format) +
+                       (nextents - 1) * sizeof(struct xfs_map_extent);
+
+       if (continued && src_len < core_size) {
+               printf(_("RUI: Not enough data to decode further\n"));
+               error = 1;
+               goto error;
+       }
+
+       f = malloc(dst_len);
+       if (f == NULL) {
+               fprintf(stderr, _("%s: %s: malloc failed\n"),
+                       progname, __func__);
+               exit(1);
+       }
+       if (xfs_rui_copy_format((char *)src_f, src_len, f, continued)) {
+               error = 1;
+               goto error;
+       }
+
+       printf(_("RUI:  #regs: %d       num_extents: %d  id: 0x%llx\n"),
+               f->rui_size, f->rui_nextents, (unsigned long long)f->rui_id);
+
+       if (continued) {
+               printf(_("RUI extent data skipped (CONTINUE set, no space)\n"));
+               goto error;
+       }
+
+       ex = f->rui_extents;
+       for (i=0; i < f->rui_nextents; i++) {
+               printf("(s: 0x%llx, l: %d, own: %lld, off: %llu, f: 0x%x) ",
+                       (unsigned long long)ex->me_startblock, ex->me_len,
+                       (long long)ex->me_owner,
+                       (unsigned long long)ex->me_startoff, ex->me_flags);
+               printf("\n");
+               ex++;
+       }
+error:
+       free(src_f);
+       free(f);
+       return error;
+}
+
+void
+xlog_recover_print_rui(
+       struct xlog_recover_item        *item)
+{
+       char                            *src_f;
+       uint                            src_len;
+
+       src_f = item->ri_buf[0].i_addr;
+       src_len = item->ri_buf[0].i_len;
+
+       xlog_print_trans_rui(&src_f, src_len, 0);
+}
+
+int
+xlog_print_trans_rud(
+       char                            **ptr,
+       uint                            len)
+{
+       struct xfs_rud_log_format       *f;
+       struct xfs_rud_log_format       lbuf;
+
+       /* size without extents at end */
+       uint core_size = sizeof(struct xfs_rud_log_format) -
+               sizeof(struct xfs_map_extent);
+
+       /*
+        * memmove to ensure 8-byte alignment for the long longs in
+        * xfs_efd_log_format_t structure
+        */
+       memmove(&lbuf, *ptr, MIN(core_size, len));
+       f = &lbuf;
+       *ptr += len;
+       if (len >= core_size) {
+               printf(_("RUD:  #regs: %d       num_extents: %d  id: 0x%llx\n"),
+                       f->rud_size, f->rud_nextents,
+                       (unsigned long long)f->rud_rui_id);
+
+               /* don't print extents as they are not used */
+
+               return 0;
+       } else {
+               printf(_("RUD: Not enough data to decode further\n"));
+               return 1;
+       }
+}
+
+void
+xlog_recover_print_rud(
+       struct xlog_recover_item        *item)
+{
+       char                            *f;
+
+       f = item->ri_buf[0].i_addr;
+       xlog_print_trans_rud(&f, sizeof(struct xfs_rud_log_format));
+}
diff --git a/logprint/logprint.h b/logprint/logprint.h
index 517e852..0c03c08 100644
--- a/logprint/logprint.h
+++ b/logprint/logprint.h
@@ -51,4 +51,9 @@ extern void xlog_recover_print_efi(xlog_recover_item_t *item);
 extern int xlog_print_trans_efd(char **ptr, uint len);
 extern void xlog_recover_print_efd(xlog_recover_item_t *item);
 
+extern int xlog_print_trans_rui(char **ptr, uint src_len, int continued);
+extern void xlog_recover_print_rui(struct xlog_recover_item *item);
+extern int xlog_print_trans_rud(char **ptr, uint len);
+extern void xlog_recover_print_rud(struct xlog_recover_item *item);
+
 #endif /* LOGPRINT_H */

<Prev in Thread] Current Thread [Next in Thread>