12e635a27SChris Mason #include <linux/module.h> 21e1d2701SChris Mason #include "ctree.h" 3dee26a9fSChris Mason #include "disk-io.h" 49f5fae2fSChris Mason #include "transaction.h" 51e1d2701SChris Mason 66567e837SChris Mason #define MAX_CSUM_ITEMS(r) ((((BTRFS_LEAF_DATA_SIZE(r) - \ 76567e837SChris Mason sizeof(struct btrfs_item)) / \ 86567e837SChris Mason sizeof(struct btrfs_csum_item)) - 1)) 9*b18c6685SChris Mason int btrfs_insert_file_extent(struct btrfs_trans_handle *trans, 10dee26a9fSChris Mason struct btrfs_root *root, 11*b18c6685SChris Mason u64 objectid, u64 pos, 12*b18c6685SChris Mason u64 offset, u64 num_blocks) 139f5fae2fSChris Mason { 14dee26a9fSChris Mason int ret = 0; 15dee26a9fSChris Mason struct btrfs_file_extent_item *item; 16dee26a9fSChris Mason struct btrfs_key file_key; 175caf2a00SChris Mason struct btrfs_path *path; 18dee26a9fSChris Mason 195caf2a00SChris Mason path = btrfs_alloc_path(); 205caf2a00SChris Mason BUG_ON(!path); 215caf2a00SChris Mason btrfs_init_path(path); 22*b18c6685SChris Mason /* 23dee26a9fSChris Mason ret = btrfs_alloc_extent(trans, root, num_blocks, hint_block, 24d0dbc624SChris Mason (u64)-1, &ins); 25*b18c6685SChris Mason */ 26dee26a9fSChris Mason BUG_ON(ret); 27dee26a9fSChris Mason file_key.objectid = objectid; 28*b18c6685SChris Mason file_key.offset = pos; 29dee26a9fSChris Mason file_key.flags = 0; 30dee26a9fSChris Mason btrfs_set_key_type(&file_key, BTRFS_EXTENT_DATA_KEY); 31dee26a9fSChris Mason 325caf2a00SChris Mason ret = btrfs_insert_empty_item(trans, root, path, &file_key, 33dee26a9fSChris Mason sizeof(*item)); 349773a788SChris Mason BUG_ON(ret); 355caf2a00SChris Mason item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]), path->slots[0], 36dee26a9fSChris Mason struct btrfs_file_extent_item); 37*b18c6685SChris Mason btrfs_set_file_extent_disk_blocknr(item, offset); 38*b18c6685SChris Mason btrfs_set_file_extent_disk_num_blocks(item, num_blocks); 39dee26a9fSChris Mason btrfs_set_file_extent_offset(item, 0); 40*b18c6685SChris Mason btrfs_set_file_extent_num_blocks(item, num_blocks); 4171951f35SChris Mason btrfs_set_file_extent_generation(item, trans->transid); 425caf2a00SChris Mason btrfs_mark_buffer_dirty(path->nodes[0]); 435caf2a00SChris Mason btrfs_release_path(root, path); 445caf2a00SChris Mason btrfs_free_path(path); 459f5fae2fSChris Mason return 0; 469f5fae2fSChris Mason } 47dee26a9fSChris Mason 48*b18c6685SChris Mason struct btrfs_csum_item *btrfs_lookup_csum(struct btrfs_trans_handle *trans, 49*b18c6685SChris Mason struct btrfs_root *root, 506567e837SChris Mason struct btrfs_path *path, 51*b18c6685SChris Mason u64 objectid, u64 offset, 52*b18c6685SChris Mason int cow) 536567e837SChris Mason { 546567e837SChris Mason int ret; 556567e837SChris Mason struct btrfs_key file_key; 566567e837SChris Mason struct btrfs_key found_key; 576567e837SChris Mason struct btrfs_csum_item *item; 586567e837SChris Mason struct btrfs_leaf *leaf; 596567e837SChris Mason u64 csum_offset = 0; 606567e837SChris Mason 616567e837SChris Mason file_key.objectid = objectid; 626567e837SChris Mason file_key.offset = offset; 636567e837SChris Mason file_key.flags = 0; 646567e837SChris Mason btrfs_set_key_type(&file_key, BTRFS_CSUM_ITEM_KEY); 65*b18c6685SChris Mason printk("__lookup for %Lu\n", offset); 66*b18c6685SChris Mason ret = btrfs_search_slot(trans, root, &file_key, path, 0, cow); 676567e837SChris Mason if (ret < 0) 686567e837SChris Mason goto fail; 696567e837SChris Mason leaf = btrfs_buffer_leaf(path->nodes[0]); 706567e837SChris Mason if (ret > 0) { 716567e837SChris Mason ret = 1; 72*b18c6685SChris Mason if (path->slots[0] == 0) { 73*b18c6685SChris Mason printk("fail1\n"); 746567e837SChris Mason goto fail; 75*b18c6685SChris Mason } 766567e837SChris Mason path->slots[0]--; 776567e837SChris Mason btrfs_disk_key_to_cpu(&found_key, 786567e837SChris Mason &leaf->items[path->slots[0]].key); 796567e837SChris Mason if (btrfs_key_type(&found_key) != BTRFS_CSUM_ITEM_KEY || 806567e837SChris Mason found_key.objectid != objectid) { 81*b18c6685SChris Mason printk("fail2 type %u %Lu %Lu\n", btrfs_key_type(&found_key), found_key.objectid, objectid); 826567e837SChris Mason goto fail; 836567e837SChris Mason } 846567e837SChris Mason csum_offset = (offset - found_key.offset) >> 856567e837SChris Mason root->fs_info->sb->s_blocksize_bits; 866567e837SChris Mason if (csum_offset >= 876567e837SChris Mason btrfs_item_size(leaf->items + path->slots[0]) / 886567e837SChris Mason sizeof(struct btrfs_csum_item)) { 89*b18c6685SChris Mason printk("fail3, csum offset %lu size %u\n", csum_offset, btrfs_item_size(leaf->items + path->slots[0]) / sizeof(struct btrfs_csum_item)); 906567e837SChris Mason goto fail; 916567e837SChris Mason } 926567e837SChris Mason } 936567e837SChris Mason item = btrfs_item_ptr(leaf, path->slots[0], struct btrfs_csum_item); 946567e837SChris Mason item += csum_offset; 956567e837SChris Mason return item; 966567e837SChris Mason fail: 976567e837SChris Mason if (ret > 0) 98*b18c6685SChris Mason ret = -ENOENT; 996567e837SChris Mason return ERR_PTR(ret); 1006567e837SChris Mason } 1016567e837SChris Mason 1026567e837SChris Mason 103dee26a9fSChris Mason int btrfs_lookup_file_extent(struct btrfs_trans_handle *trans, 104dee26a9fSChris Mason struct btrfs_root *root, 105dee26a9fSChris Mason struct btrfs_path *path, u64 objectid, 1069773a788SChris Mason u64 offset, int mod) 107dee26a9fSChris Mason { 108dee26a9fSChris Mason int ret; 109dee26a9fSChris Mason struct btrfs_key file_key; 110dee26a9fSChris Mason int ins_len = mod < 0 ? -1 : 0; 111dee26a9fSChris Mason int cow = mod != 0; 1126567e837SChris Mason struct btrfs_csum_item *csum_item; 113dee26a9fSChris Mason 114*b18c6685SChris Mason csum_item = btrfs_lookup_csum(trans, root, path, objectid, offset, 0); 1156567e837SChris Mason if (IS_ERR(csum_item)) 1166567e837SChris Mason return PTR_ERR(csum_item); 117dee26a9fSChris Mason file_key.objectid = objectid; 1186567e837SChris Mason file_key.offset = btrfs_csum_extent_offset(csum_item); 119dee26a9fSChris Mason file_key.flags = 0; 120dee26a9fSChris Mason btrfs_set_key_type(&file_key, BTRFS_EXTENT_DATA_KEY); 1216567e837SChris Mason btrfs_release_path(root, path); 122*b18c6685SChris Mason printk("lookup file extent searches for %Lu\n", file_key.offset); 123dee26a9fSChris Mason ret = btrfs_search_slot(trans, root, &file_key, path, ins_len, cow); 124*b18c6685SChris Mason printk("ret is %d\n", ret); 125dee26a9fSChris Mason return ret; 126dee26a9fSChris Mason } 127f254e52cSChris Mason 128f254e52cSChris Mason int btrfs_csum_file_block(struct btrfs_trans_handle *trans, 129f254e52cSChris Mason struct btrfs_root *root, 130f254e52cSChris Mason u64 objectid, u64 offset, 1316567e837SChris Mason u64 extent_offset, 132f254e52cSChris Mason char *data, size_t len) 133f254e52cSChris Mason { 134f254e52cSChris Mason int ret; 135f254e52cSChris Mason struct btrfs_key file_key; 1366567e837SChris Mason struct btrfs_key found_key; 1375caf2a00SChris Mason struct btrfs_path *path; 138f254e52cSChris Mason struct btrfs_csum_item *item; 1396567e837SChris Mason struct btrfs_leaf *leaf; 1406567e837SChris Mason u64 csum_offset; 141f254e52cSChris Mason 1425caf2a00SChris Mason path = btrfs_alloc_path(); 1435caf2a00SChris Mason BUG_ON(!path); 1445caf2a00SChris Mason btrfs_init_path(path); 145*b18c6685SChris Mason 146*b18c6685SChris Mason item = btrfs_lookup_csum(trans, root, path, objectid, offset, 0); 147*b18c6685SChris Mason if (!IS_ERR(item)) 148*b18c6685SChris Mason goto found; 149*b18c6685SChris Mason btrfs_release_path(root, path); 150f254e52cSChris Mason file_key.objectid = objectid; 151f254e52cSChris Mason file_key.offset = offset; 152f254e52cSChris Mason file_key.flags = 0; 153f254e52cSChris Mason btrfs_set_key_type(&file_key, BTRFS_CSUM_ITEM_KEY); 154*b18c6685SChris Mason printk("searching for csum %Lu %Lu\n", objectid, offset); 1556567e837SChris Mason ret = btrfs_search_slot(trans, root, &file_key, path, 1566567e837SChris Mason sizeof(struct btrfs_csum_item), 1); 157*b18c6685SChris Mason printk("ret %d\n", ret); 1586567e837SChris Mason if (ret < 0) 1596567e837SChris Mason goto fail; 1606567e837SChris Mason if (ret == 0) { 161*b18c6685SChris Mason BUG(); 1626567e837SChris Mason } 1636567e837SChris Mason if (path->slots[0] == 0) { 1646567e837SChris Mason btrfs_release_path(root, path); 1656567e837SChris Mason goto insert; 1666567e837SChris Mason } 1676567e837SChris Mason path->slots[0]--; 1686567e837SChris Mason leaf = btrfs_buffer_leaf(path->nodes[0]); 1696567e837SChris Mason btrfs_disk_key_to_cpu(&found_key, &leaf->items[path->slots[0]].key); 170*b18c6685SChris Mason printk("found key %Lu %Lu %u\n", found_key.objectid, found_key.offset, found_key.flags); 1716567e837SChris Mason csum_offset = (offset - found_key.offset) >> 1726567e837SChris Mason root->fs_info->sb->s_blocksize_bits; 173*b18c6685SChris Mason printk("csum_offset %Lu\n", csum_offset); 1746567e837SChris Mason if (btrfs_key_type(&found_key) != BTRFS_CSUM_ITEM_KEY || 1756567e837SChris Mason found_key.objectid != objectid || 1766567e837SChris Mason csum_offset >= MAX_CSUM_ITEMS(root)) { 1776567e837SChris Mason btrfs_release_path(root, path); 178*b18c6685SChris Mason printk("insert1\n"); 1796567e837SChris Mason goto insert; 1806567e837SChris Mason } 1816567e837SChris Mason if (csum_offset >= btrfs_item_size(leaf->items + path->slots[0]) / 1826567e837SChris Mason sizeof(struct btrfs_csum_item)) { 1836567e837SChris Mason ret = btrfs_extend_item(trans, root, path, 1846567e837SChris Mason sizeof(struct btrfs_csum_item)); 1856567e837SChris Mason BUG_ON(ret); 186*b18c6685SChris Mason printk("item extended\n"); 1876567e837SChris Mason goto csum; 1886567e837SChris Mason } 1896567e837SChris Mason 1906567e837SChris Mason insert: 1916567e837SChris Mason csum_offset = 0; 192*b18c6685SChris Mason printk("inserting item %Lu %Lu %u\n", file_key.objectid, file_key.offset, file_key.flags); 1935caf2a00SChris Mason ret = btrfs_insert_empty_item(trans, root, path, &file_key, 1946567e837SChris Mason sizeof(struct btrfs_csum_item)); 195f254e52cSChris Mason if (ret != 0 && ret != -EEXIST) 196f254e52cSChris Mason goto fail; 1976567e837SChris Mason csum: 1985caf2a00SChris Mason item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]), path->slots[0], 199f254e52cSChris Mason struct btrfs_csum_item); 200f254e52cSChris Mason ret = 0; 2016567e837SChris Mason item += csum_offset; 202*b18c6685SChris Mason found: 203f254e52cSChris Mason ret = btrfs_csum_data(root, data, len, item->csum); 2046567e837SChris Mason btrfs_set_csum_extent_offset(item, extent_offset); 2055caf2a00SChris Mason btrfs_mark_buffer_dirty(path->nodes[0]); 206f254e52cSChris Mason fail: 2075caf2a00SChris Mason btrfs_release_path(root, path); 2085caf2a00SChris Mason btrfs_free_path(path); 209*b18c6685SChris Mason printk("return ret %d\n", ret); 210f254e52cSChris Mason return ret; 211f254e52cSChris Mason } 212f254e52cSChris Mason 213f254e52cSChris Mason int btrfs_csum_verify_file_block(struct btrfs_root *root, 214f254e52cSChris Mason u64 objectid, u64 offset, 215f254e52cSChris Mason char *data, size_t len) 216f254e52cSChris Mason { 217f254e52cSChris Mason int ret; 218f254e52cSChris Mason struct btrfs_key file_key; 2195caf2a00SChris Mason struct btrfs_path *path; 220f254e52cSChris Mason struct btrfs_csum_item *item; 221f254e52cSChris Mason char result[BTRFS_CSUM_SIZE]; 222f254e52cSChris Mason 2235caf2a00SChris Mason path = btrfs_alloc_path(); 2245caf2a00SChris Mason BUG_ON(!path); 2255caf2a00SChris Mason btrfs_init_path(path); 226f254e52cSChris Mason file_key.objectid = objectid; 227f254e52cSChris Mason file_key.offset = offset; 228f254e52cSChris Mason file_key.flags = 0; 229f254e52cSChris Mason btrfs_set_key_type(&file_key, BTRFS_CSUM_ITEM_KEY); 2302da566edSChris Mason mutex_lock(&root->fs_info->fs_mutex); 2316567e837SChris Mason 232*b18c6685SChris Mason item = btrfs_lookup_csum(NULL, root, path, objectid, offset, 0); 2336567e837SChris Mason if (IS_ERR(item)) { 2346567e837SChris Mason ret = PTR_ERR(item); 235f254e52cSChris Mason goto fail; 2366567e837SChris Mason } 2376567e837SChris Mason 238f254e52cSChris Mason ret = btrfs_csum_data(root, data, len, result); 239f254e52cSChris Mason WARN_ON(ret); 240f254e52cSChris Mason if (memcmp(result, item->csum, BTRFS_CSUM_SIZE)) 241f254e52cSChris Mason ret = 1; 242f254e52cSChris Mason fail: 2435caf2a00SChris Mason btrfs_release_path(root, path); 2445caf2a00SChris Mason btrfs_free_path(path); 2452da566edSChris Mason mutex_unlock(&root->fs_info->fs_mutex); 246f254e52cSChris Mason return ret; 247f254e52cSChris Mason } 248f254e52cSChris Mason 249