xfs: validate dabtree node buffer owners

Source kernel commit: d44bea9b41ca25f91fd9f25ed2cc3bb2f6dab4bc

Check the owner field of dabtree node blocks.

Signed-off-by: Darrick J. Wong <djwong@kernel.org>
Reviewed-by: Christoph Hellwig <hch@lst.de>

diff --git a/libxfs/xfs_da_btree.c b/libxfs/xfs_da_btree.c
index 28fd87c2db2247671528e1e1ea39a216ad4b6275..c221cbba4231bc97bc37e7ab815e7254f9410b1b 100644 (file)
--- a/libxfs/xfs_da_btree.c
+++ b/libxfs/xfs_da_btree.c
@@ -248,6 +248,26 @@ xfs_da3_node_verify(
        return NULL;
 }
 
+xfs_failaddr_t
+xfs_da3_node_header_check(
+       struct xfs_buf          *bp,
+       xfs_ino_t               owner)
+{
+       struct xfs_mount        *mp = bp->b_mount;
+
+       if (xfs_has_crc(mp)) {
+               struct xfs_da3_blkinfo *hdr3 = bp->b_addr;
+
+               if (hdr3->hdr.magic != cpu_to_be16(XFS_DA3_NODE_MAGIC))
+                       return __this_address;
+
+               if (be64_to_cpu(hdr3->owner) != owner)
+                       return __this_address;
+       }
+
+       return NULL;
+}
+
 xfs_failaddr_t
 xfs_da3_header_check(
        struct xfs_buf          *bp,
@@ -262,6 +282,8 @@ xfs_da3_header_check(
        switch (hdr->magic) {
        case cpu_to_be16(XFS_ATTR3_LEAF_MAGIC):
                return xfs_attr3_leaf_header_check(bp, owner);
+       case cpu_to_be16(XFS_DA3_NODE_MAGIC):
+               return xfs_da3_node_header_check(bp, owner);
        }
 
        return NULL;
@@ -1214,6 +1236,7 @@ xfs_da3_root_join(
        struct xfs_da3_icnode_hdr oldroothdr;
        int                     error;
        struct xfs_inode        *dp = state->args->dp;
+       xfs_failaddr_t          fa;
 
        trace_xfs_da_root_join(state->args);
 
@@ -1240,6 +1263,13 @@ xfs_da3_root_join(
        error = xfs_da3_node_read(args->trans, dp, child, &bp, args->whichfork);
        if (error)
                return error;
+       fa = xfs_da3_header_check(bp, args->owner);
+       if (fa) {
+               __xfs_buf_mark_corrupt(bp, fa);
+               xfs_trans_brelse(args->trans, bp);
+               xfs_da_mark_sick(args);
+               return -EFSCORRUPTED;
+       }
        xfs_da_blkinfo_onlychild_validate(bp->b_addr, oldroothdr.level);
 
        /*
@@ -1274,6 +1304,7 @@ xfs_da3_node_toosmall(
        struct xfs_da_blkinfo   *info;
        xfs_dablk_t             blkno;
        struct xfs_buf          *bp;
+       xfs_failaddr_t          fa;
        struct xfs_da3_icnode_hdr nodehdr;
        int                     count;
        int                     forward;
@@ -1348,6 +1379,13 @@ xfs_da3_node_toosmall(
                                state->args->whichfork);
                if (error)
                        return error;
+               fa = xfs_da3_node_header_check(bp, state->args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(bp, fa);
+                       xfs_trans_brelse(state->args->trans, bp);
+                       xfs_da_mark_sick(state->args);
+                       return -EFSCORRUPTED;
+               }
 
                node = bp->b_addr;
                xfs_da3_node_hdr_from_disk(dp->i_mount, &thdr, node);
@@ -1670,6 +1708,13 @@ xfs_da3_node_lookup_int(
                        return -EFSCORRUPTED;
                }
 
+               fa = xfs_da3_node_header_check(blk->bp, args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(blk->bp, fa);
+                       xfs_da_mark_sick(args);
+                       return -EFSCORRUPTED;
+               }
+
                blk->magic = XFS_DA_NODE_MAGIC;
 
                /*
@@ -1842,6 +1887,7 @@ xfs_da3_blk_link(
        struct xfs_da_blkinfo   *tmp_info;
        struct xfs_da_args      *args;
        struct xfs_buf          *bp;
+       xfs_failaddr_t          fa;
        int                     before = 0;
        int                     error;
        struct xfs_inode        *dp = state->args->dp;
@@ -1885,6 +1931,13 @@ xfs_da3_blk_link(
                                                &bp, args->whichfork);
                        if (error)
                                return error;
+                       fa = xfs_da3_header_check(bp, args->owner);
+                       if (fa) {
+                               __xfs_buf_mark_corrupt(bp, fa);
+                               xfs_trans_brelse(args->trans, bp);
+                               xfs_da_mark_sick(args);
+                               return -EFSCORRUPTED;
+                       }
                        ASSERT(bp != NULL);
                        tmp_info = bp->b_addr;
                        ASSERT(tmp_info->magic == old_info->magic);
@@ -1906,6 +1959,13 @@ xfs_da3_blk_link(
                                                &bp, args->whichfork);
                        if (error)
                                return error;
+                       fa = xfs_da3_header_check(bp, args->owner);
+                       if (fa) {
+                               __xfs_buf_mark_corrupt(bp, fa);
+                               xfs_trans_brelse(args->trans, bp);
+                               xfs_da_mark_sick(args);
+                               return -EFSCORRUPTED;
+                       }
                        ASSERT(bp != NULL);
                        tmp_info = bp->b_addr;
                        ASSERT(tmp_info->magic == old_info->magic);
@@ -1935,6 +1995,7 @@ xfs_da3_blk_unlink(
        struct xfs_da_blkinfo   *tmp_info;
        struct xfs_da_args      *args;
        struct xfs_buf          *bp;
+       xfs_failaddr_t          fa;
        int                     error;
 
        /*
@@ -1965,6 +2026,13 @@ xfs_da3_blk_unlink(
                                                &bp, args->whichfork);
                        if (error)
                                return error;
+                       fa = xfs_da3_header_check(bp, args->owner);
+                       if (fa) {
+                               __xfs_buf_mark_corrupt(bp, fa);
+                               xfs_trans_brelse(args->trans, bp);
+                               xfs_da_mark_sick(args);
+                               return -EFSCORRUPTED;
+                       }
                        ASSERT(bp != NULL);
                        tmp_info = bp->b_addr;
                        ASSERT(tmp_info->magic == save_info->magic);
@@ -1982,6 +2050,13 @@ xfs_da3_blk_unlink(
                                                &bp, args->whichfork);
                        if (error)
                                return error;
+                       fa = xfs_da3_header_check(bp, args->owner);
+                       if (fa) {
+                               __xfs_buf_mark_corrupt(bp, fa);
+                               xfs_trans_brelse(args->trans, bp);
+                               xfs_da_mark_sick(args);
+                               return -EFSCORRUPTED;
+                       }
                        ASSERT(bp != NULL);
                        tmp_info = bp->b_addr;
                        ASSERT(tmp_info->magic == save_info->magic);
@@ -2097,6 +2172,12 @@ xfs_da3_path_shift(
                switch (be16_to_cpu(info->magic)) {
                case XFS_DA_NODE_MAGIC:
                case XFS_DA3_NODE_MAGIC:
+                       fa = xfs_da3_node_header_check(blk->bp, args->owner);
+                       if (fa) {
+                               __xfs_buf_mark_corrupt(blk->bp, fa);
+                               xfs_da_mark_sick(args);
+                               return -EFSCORRUPTED;
+                       }
                        blk->magic = XFS_DA_NODE_MAGIC;
                        xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr,
                                                   bp->b_addr);
@@ -2402,6 +2483,13 @@ xfs_da3_swap_lastblock(
                error = xfs_da3_node_read(tp, dp, sib_blkno, &sib_buf, w);
                if (error)
                        goto done;
+               fa = xfs_da3_header_check(sib_buf, args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(sib_buf, fa);
+                       xfs_da_mark_sick(args);
+                       error = -EFSCORRUPTED;
+                       goto done;
+               }
                sib_info = sib_buf->b_addr;
                if (XFS_IS_CORRUPT(mp,
                                   be32_to_cpu(sib_info->forw) != last_blkno ||
@@ -2423,6 +2511,13 @@ xfs_da3_swap_lastblock(
                error = xfs_da3_node_read(tp, dp, sib_blkno, &sib_buf, w);
                if (error)
                        goto done;
+               fa = xfs_da3_header_check(sib_buf, args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(sib_buf, fa);
+                       xfs_da_mark_sick(args);
+                       error = -EFSCORRUPTED;
+                       goto done;
+               }
                sib_info = sib_buf->b_addr;
                if (XFS_IS_CORRUPT(mp,
                                   be32_to_cpu(sib_info->back) != last_blkno ||
@@ -2446,6 +2541,13 @@ xfs_da3_swap_lastblock(
                error = xfs_da3_node_read(tp, dp, par_blkno, &par_buf, w);
                if (error)
                        goto done;
+               fa = xfs_da3_node_header_check(par_buf, args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(par_buf, fa);
+                       xfs_da_mark_sick(args);
+                       error = -EFSCORRUPTED;
+                       goto done;
+               }
                par_node = par_buf->b_addr;
                xfs_da3_node_hdr_from_disk(dp->i_mount, &par_hdr, par_node);
                if (XFS_IS_CORRUPT(mp,
@@ -2495,6 +2597,13 @@ xfs_da3_swap_lastblock(
                error = xfs_da3_node_read(tp, dp, par_blkno, &par_buf, w);
                if (error)
                        goto done;
+               fa = xfs_da3_node_header_check(par_buf, args->owner);
+               if (fa) {
+                       __xfs_buf_mark_corrupt(par_buf, fa);
+                       xfs_da_mark_sick(args);
+                       error = -EFSCORRUPTED;
+                       goto done;
+               }
                par_node = par_buf->b_addr;
                xfs_da3_node_hdr_from_disk(dp->i_mount, &par_hdr, par_node);
                if (XFS_IS_CORRUPT(mp, par_hdr.level != level)) {

diff --git a/libxfs/xfs_da_btree.h b/libxfs/xfs_da_btree.h
index 99618e0c8a72b7f4ae8ccda4447030d9f07e1ceb..7a004786ee0a2fdd5ecdba07231e0b0911aac02a 100644 (file)
--- a/libxfs/xfs_da_btree.h
+++ b/libxfs/xfs_da_btree.h
@@ -237,6 +237,7 @@ void        xfs_da3_node_hdr_from_disk(struct xfs_mount *mp,
 void   xfs_da3_node_hdr_to_disk(struct xfs_mount *mp,
                struct xfs_da_intnode *to, struct xfs_da3_icnode_hdr *from);
 xfs_failaddr_t xfs_da3_header_check(struct xfs_buf *bp, xfs_ino_t owner);
+xfs_failaddr_t xfs_da3_node_header_check(struct xfs_buf *bp, xfs_ino_t owner);
 
 extern struct kmem_cache       *xfs_da_state_cache;