From patchwork Mon Dec 13 07:22:19 2010 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Shaohua Li X-Patchwork-Id: 405062 Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by demeter1.kernel.org (8.14.4/8.14.3) with ESMTP id oBD7MfmU028607 for ; Mon, 13 Dec 2010 07:22:41 GMT Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S932379Ab0LMHW1 (ORCPT ); Mon, 13 Dec 2010 02:22:27 -0500 Received: from mga03.intel.com ([143.182.124.21]:31109 "EHLO mga03.intel.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S932206Ab0LMHWZ (ORCPT ); Mon, 13 Dec 2010 02:22:25 -0500 Received: from azsmga001.ch.intel.com ([10.2.17.19]) by azsmga101.ch.intel.com with ESMTP; 12 Dec 2010 23:22:24 -0800 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="4.59,335,1288594800"; d="scan'208";a="360764977" Received: from sli10-conroe.sh.intel.com (HELO [10.239.36.47]) ([10.239.36.47]) by azsmga001.ch.intel.com with ESMTP; 12 Dec 2010 23:22:23 -0800 Subject: [RFC 5/5] validate extent_buffer if it's readahead in btrfs From: Shaohua Li To: "linux-btrfs@vger.kernel.org" , "linux-fsdevel@vger.kernel.org" Cc: Chris Mason , Christoph Hellwig , Arjan van de Ven , Andrew Morton Date: Mon, 13 Dec 2010 15:22:19 +0800 Message-ID: <1292224939.2323.454.camel@sli10-conroe> Mime-Version: 1.0 X-Mailer: Evolution 2.30.3 Sender: linux-btrfs-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: linux-btrfs@vger.kernel.org X-Greylist: IP, sender and recipient auto-whitelisted, not delayed by milter-greylist-4.2.3 (demeter1.kernel.org [140.211.167.41]); Mon, 13 Dec 2010 07:22:42 +0000 (UTC) Index: linux/fs/btrfs/disk-io.c =================================================================== --- linux.orig/fs/btrfs/disk-io.c 2010-12-07 14:53:54.000000000 +0800 +++ linux/fs/btrfs/disk-io.c 2010-12-07 14:53:59.000000000 +0800 @@ -406,30 +406,18 @@ void btrfs_set_buffer_lockdep_class(stru } #endif -static int btree_readpage_end_io_hook(struct page *page, u64 start, u64 end, - struct extent_state *state) +int btree_validate_extent_buffer(struct btrfs_root *root, + struct extent_buffer *eb) { - struct extent_io_tree *tree; + int ret = 0; u64 found_start; int found_level; - unsigned long len; - struct extent_buffer *eb; - struct btrfs_root *root = BTRFS_I(page->mapping->host)->root; - int ret = 0; - - tree = &BTRFS_I(page->mapping->host)->io_tree; - if (page->private == EXTENT_PAGE_PRIVATE) - goto out; - if (!page->private) - goto out; - len = page->private >> 2; - WARN_ON(len == 0); - - eb = alloc_extent_buffer(tree, start, len, page, GFP_NOFS); + if (!test_bit(EXTENT_BUFFER_UNCHECKED, &eb->bflags)) + return 0; found_start = btrfs_header_bytenr(eb); - if (found_start != start) { + if (found_start != eb->start) { if (printk_ratelimit()) { printk(KERN_INFO "btrfs bad tree block start " "%llu %llu\n", @@ -439,13 +427,7 @@ static int btree_readpage_end_io_hook(st ret = -EIO; goto err; } - if (eb->first_page != page) { - printk(KERN_INFO "btrfs bad first page %lu %lu\n", - eb->first_page->index, page->index); - WARN_ON(1); - ret = -EIO; - goto err; - } + if (check_tree_block_fsid(root, eb)) { if (printk_ratelimit()) { printk(KERN_INFO "btrfs bad fsid on block %llu\n", @@ -461,6 +443,41 @@ static int btree_readpage_end_io_hook(st ret = csum_tree_block(root, eb, 1); if (ret) ret = -EIO; +err: + if (ret == 0) + clear_bit(EXTENT_BUFFER_UNCHECKED, &eb->bflags); + return ret; +} + +static int btree_readpage_end_io_hook(struct page *page, u64 start, u64 end, + struct extent_state *state) +{ + struct extent_io_tree *tree; + unsigned long len; + struct extent_buffer *eb; + struct btrfs_root *root = BTRFS_I(page->mapping->host)->root; + int ret = 0; + + tree = &BTRFS_I(page->mapping->host)->io_tree; + if (page->private == EXTENT_PAGE_PRIVATE) + goto out; + if (!page->private) + goto out; + + len = page->private >> 2; + WARN_ON(len == 0); + + eb = alloc_extent_buffer(tree, start, len, page, GFP_NOFS); + + if (eb->first_page != page) { + printk(KERN_INFO "btrfs bad first page %lu %lu\n", + eb->first_page->index, page->index); + WARN_ON(1); + ret = -EIO; + goto err; + } + + ret = btree_validate_extent_buffer(root, eb); end = min_t(u64, eb->len, PAGE_CACHE_SIZE); end = eb->start + end - 1; Index: linux/fs/btrfs/disk-io.h =================================================================== --- linux.orig/fs/btrfs/disk-io.h 2010-12-07 13:45:05.000000000 +0800 +++ linux/fs/btrfs/disk-io.h 2010-12-07 14:53:59.000000000 +0800 @@ -36,6 +36,8 @@ static inline u64 btrfs_sb_offset(int mi struct btrfs_device; struct btrfs_fs_devices; +int btree_validate_extent_buffer(struct btrfs_root *root, + struct extent_buffer *eb); struct extent_buffer *read_tree_block(struct btrfs_root *root, u64 bytenr, u32 blocksize, u64 parent_transid); int readahead_tree_block(struct btrfs_root *root, u64 bytenr, u32 blocksize, Index: linux/fs/btrfs/extent_io.c =================================================================== --- linux.orig/fs/btrfs/extent_io.c 2010-12-07 13:45:05.000000000 +0800 +++ linux/fs/btrfs/extent_io.c 2010-12-07 14:53:59.000000000 +0800 @@ -14,6 +14,7 @@ #include "extent_map.h" #include "compat.h" #include "ctree.h" +#include "disk-io.h" #include "btrfs_inode.h" static struct kmem_cache *extent_state_cache; @@ -3189,6 +3190,7 @@ struct extent_buffer *alloc_extent_buffe uptodate = 0; unlock_page(p); } + set_bit(EXTENT_BUFFER_UNCHECKED, &eb->bflags); if (uptodate) set_bit(EXTENT_BUFFER_UPTODATE, &eb->bflags); @@ -3419,9 +3421,10 @@ int read_extent_buffer_pages(struct exte unsigned long num_pages; struct bio *bio = NULL; unsigned long bio_flags = 0; + struct btrfs_root *root = BTRFS_I(tree->mapping->host)->root; if (test_bit(EXTENT_BUFFER_UPTODATE, &eb->bflags)) - return 0; + goto out; if (test_range_bit(tree, eb->start, eb->start + eb->len - 1, EXTENT_UPTODATE, 1, NULL)) { @@ -3486,8 +3489,10 @@ int read_extent_buffer_pages(struct exte ret = -EIO; } - if (!ret) + if (!ret) { set_bit(EXTENT_BUFFER_UPTODATE, &eb->bflags); + goto out; + } return ret; unlock_exit: @@ -3498,6 +3503,11 @@ unlock_exit: unlock_page(page); locked_pages--; } +out: + if (!ret && test_bit(EXTENT_BUFFER_UNCHECKED, &eb->bflags) && + test_bit(EXTENT_BUFFER_UPTODATE, &eb->bflags)) + return btree_validate_extent_buffer(root, eb); + return ret; } Index: linux/fs/btrfs/extent_io.h =================================================================== --- linux.orig/fs/btrfs/extent_io.h 2010-12-07 13:45:05.000000000 +0800 +++ linux/fs/btrfs/extent_io.h 2010-12-07 14:53:59.000000000 +0800 @@ -27,6 +27,7 @@ #define EXTENT_BUFFER_UPTODATE 0 #define EXTENT_BUFFER_BLOCKING 1 #define EXTENT_BUFFER_DIRTY 2 +#define EXTENT_BUFFER_UNCHECKED 3 /* these are flags for extent_clear_unlock_delalloc */ #define EXTENT_CLEAR_UNLOCK_PAGE 0x1 Index: linux/fs/btrfs/extent-tree.c =================================================================== --- linux.orig/fs/btrfs/extent-tree.c 2010-12-07 13:45:05.000000000 +0800 +++ linux/fs/btrfs/extent-tree.c 2010-12-07 14:53:59.000000000 +0800 @@ -5573,6 +5573,7 @@ struct extent_buffer *btrfs_init_new_buf clean_tree_block(trans, root, buf); btrfs_set_lock_blocking(buf); + clear_bit(EXTENT_BUFFER_UNCHECKED, &buf->bflags); btrfs_set_buffer_uptodate(buf); if (root->root_key.objectid == BTRFS_TREE_LOG_OBJECTID) {