16cbd5570SChris Mason /* 2d352ac68SChris Mason * Copyright (C) 2007,2008 Oracle. All rights reserved. 36cbd5570SChris Mason * 46cbd5570SChris Mason * This program is free software; you can redistribute it and/or 56cbd5570SChris Mason * modify it under the terms of the GNU General Public 66cbd5570SChris Mason * License v2 as published by the Free Software Foundation. 76cbd5570SChris Mason * 86cbd5570SChris Mason * This program is distributed in the hope that it will be useful, 96cbd5570SChris Mason * but WITHOUT ANY WARRANTY; without even the implied warranty of 106cbd5570SChris Mason * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 116cbd5570SChris Mason * General Public License for more details. 126cbd5570SChris Mason * 136cbd5570SChris Mason * You should have received a copy of the GNU General Public 146cbd5570SChris Mason * License along with this program; if not, write to the 156cbd5570SChris Mason * Free Software Foundation, Inc., 59 Temple Place - Suite 330, 166cbd5570SChris Mason * Boston, MA 021110-1307, USA. 176cbd5570SChris Mason */ 186cbd5570SChris Mason 19a6b6e75eSChris Mason #include <linux/sched.h> 20eb60ceacSChris Mason #include "ctree.h" 21eb60ceacSChris Mason #include "disk-io.h" 227f5c1516SChris Mason #include "transaction.h" 235f39d397SChris Mason #include "print-tree.h" 24925baeddSChris Mason #include "locking.h" 259a8dd150SChris Mason 26e089f05cSChris Mason static int split_node(struct btrfs_trans_handle *trans, struct btrfs_root 27e089f05cSChris Mason *root, struct btrfs_path *path, int level); 28e089f05cSChris Mason static int split_leaf(struct btrfs_trans_handle *trans, struct btrfs_root 29d4dbff95SChris Mason *root, struct btrfs_key *ins_key, 30cc0c5538SChris Mason struct btrfs_path *path, int data_size, int extend); 315f39d397SChris Mason static int push_node_left(struct btrfs_trans_handle *trans, 325f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *dst, 33971a1f66SChris Mason struct extent_buffer *src, int empty); 345f39d397SChris Mason static int balance_node_right(struct btrfs_trans_handle *trans, 355f39d397SChris Mason struct btrfs_root *root, 365f39d397SChris Mason struct extent_buffer *dst_buf, 375f39d397SChris Mason struct extent_buffer *src_buf); 38e089f05cSChris Mason static int del_ptr(struct btrfs_trans_handle *trans, struct btrfs_root *root, 39e089f05cSChris Mason struct btrfs_path *path, int level, int slot); 40d97e63b6SChris Mason 412c90e5d6SChris Mason struct btrfs_path *btrfs_alloc_path(void) 422c90e5d6SChris Mason { 43df24a2b9SChris Mason struct btrfs_path *path; 44e00f7308SJeff Mahoney path = kmem_cache_zalloc(btrfs_path_cachep, GFP_NOFS); 45e00f7308SJeff Mahoney if (path) 462cc58cf2SChris Mason path->reada = 1; 47df24a2b9SChris Mason return path; 482c90e5d6SChris Mason } 492c90e5d6SChris Mason 50b4ce94deSChris Mason /* 51b4ce94deSChris Mason * set all locked nodes in the path to blocking locks. This should 52b4ce94deSChris Mason * be done before scheduling 53b4ce94deSChris Mason */ 54b4ce94deSChris Mason noinline void btrfs_set_path_blocking(struct btrfs_path *p) 55b4ce94deSChris Mason { 56b4ce94deSChris Mason int i; 57b4ce94deSChris Mason for (i = 0; i < BTRFS_MAX_LEVEL; i++) { 58b4ce94deSChris Mason if (p->nodes[i] && p->locks[i]) 59b4ce94deSChris Mason btrfs_set_lock_blocking(p->nodes[i]); 60b4ce94deSChris Mason } 61b4ce94deSChris Mason } 62b4ce94deSChris Mason 63b4ce94deSChris Mason /* 64b4ce94deSChris Mason * reset all the locked nodes in the patch to spinning locks. 654008c04aSChris Mason * 664008c04aSChris Mason * held is used to keep lockdep happy, when lockdep is enabled 674008c04aSChris Mason * we set held to a blocking lock before we go around and 684008c04aSChris Mason * retake all the spinlocks in the path. You can safely use NULL 694008c04aSChris Mason * for held 70b4ce94deSChris Mason */ 714008c04aSChris Mason noinline void btrfs_clear_path_blocking(struct btrfs_path *p, 724008c04aSChris Mason struct extent_buffer *held) 73b4ce94deSChris Mason { 74b4ce94deSChris Mason int i; 754008c04aSChris Mason 764008c04aSChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 774008c04aSChris Mason /* lockdep really cares that we take all of these spinlocks 784008c04aSChris Mason * in the right order. If any of the locks in the path are not 794008c04aSChris Mason * currently blocking, it is going to complain. So, make really 804008c04aSChris Mason * really sure by forcing the path to blocking before we clear 814008c04aSChris Mason * the path blocking. 824008c04aSChris Mason */ 834008c04aSChris Mason if (held) 844008c04aSChris Mason btrfs_set_lock_blocking(held); 854008c04aSChris Mason btrfs_set_path_blocking(p); 864008c04aSChris Mason #endif 874008c04aSChris Mason 884008c04aSChris Mason for (i = BTRFS_MAX_LEVEL - 1; i >= 0; i--) { 89b4ce94deSChris Mason if (p->nodes[i] && p->locks[i]) 90b4ce94deSChris Mason btrfs_clear_lock_blocking(p->nodes[i]); 91b4ce94deSChris Mason } 924008c04aSChris Mason 934008c04aSChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 944008c04aSChris Mason if (held) 954008c04aSChris Mason btrfs_clear_lock_blocking(held); 964008c04aSChris Mason #endif 97b4ce94deSChris Mason } 98b4ce94deSChris Mason 99d352ac68SChris Mason /* this also releases the path */ 1002c90e5d6SChris Mason void btrfs_free_path(struct btrfs_path *p) 1012c90e5d6SChris Mason { 102df24a2b9SChris Mason btrfs_release_path(NULL, p); 1032c90e5d6SChris Mason kmem_cache_free(btrfs_path_cachep, p); 1042c90e5d6SChris Mason } 1052c90e5d6SChris Mason 106d352ac68SChris Mason /* 107d352ac68SChris Mason * path release drops references on the extent buffers in the path 108d352ac68SChris Mason * and it drops any locks held by this path 109d352ac68SChris Mason * 110d352ac68SChris Mason * It is safe to call this on paths that no locks or extent buffers held. 111d352ac68SChris Mason */ 112d397712bSChris Mason noinline void btrfs_release_path(struct btrfs_root *root, struct btrfs_path *p) 113eb60ceacSChris Mason { 114eb60ceacSChris Mason int i; 115a2135011SChris Mason 116234b63a0SChris Mason for (i = 0; i < BTRFS_MAX_LEVEL; i++) { 1173f157a2fSChris Mason p->slots[i] = 0; 118eb60ceacSChris Mason if (!p->nodes[i]) 119925baeddSChris Mason continue; 120925baeddSChris Mason if (p->locks[i]) { 121925baeddSChris Mason btrfs_tree_unlock(p->nodes[i]); 122925baeddSChris Mason p->locks[i] = 0; 123925baeddSChris Mason } 1245f39d397SChris Mason free_extent_buffer(p->nodes[i]); 1253f157a2fSChris Mason p->nodes[i] = NULL; 126eb60ceacSChris Mason } 127eb60ceacSChris Mason } 128eb60ceacSChris Mason 129d352ac68SChris Mason /* 130d352ac68SChris Mason * safely gets a reference on the root node of a tree. A lock 131d352ac68SChris Mason * is not taken, so a concurrent writer may put a different node 132d352ac68SChris Mason * at the root of the tree. See btrfs_lock_root_node for the 133d352ac68SChris Mason * looping required. 134d352ac68SChris Mason * 135d352ac68SChris Mason * The extent buffer returned by this has a reference taken, so 136d352ac68SChris Mason * it won't disappear. It may stop being the root of the tree 137d352ac68SChris Mason * at any time because there are no locks held. 138d352ac68SChris Mason */ 139925baeddSChris Mason struct extent_buffer *btrfs_root_node(struct btrfs_root *root) 140925baeddSChris Mason { 141925baeddSChris Mason struct extent_buffer *eb; 142925baeddSChris Mason spin_lock(&root->node_lock); 143925baeddSChris Mason eb = root->node; 144925baeddSChris Mason extent_buffer_get(eb); 145925baeddSChris Mason spin_unlock(&root->node_lock); 146925baeddSChris Mason return eb; 147925baeddSChris Mason } 148925baeddSChris Mason 149d352ac68SChris Mason /* loop around taking references on and locking the root node of the 150d352ac68SChris Mason * tree until you end up with a lock on the root. A locked buffer 151d352ac68SChris Mason * is returned, with a reference held. 152d352ac68SChris Mason */ 153925baeddSChris Mason struct extent_buffer *btrfs_lock_root_node(struct btrfs_root *root) 154925baeddSChris Mason { 155925baeddSChris Mason struct extent_buffer *eb; 156925baeddSChris Mason 157925baeddSChris Mason while (1) { 158925baeddSChris Mason eb = btrfs_root_node(root); 159925baeddSChris Mason btrfs_tree_lock(eb); 160925baeddSChris Mason 161925baeddSChris Mason spin_lock(&root->node_lock); 162925baeddSChris Mason if (eb == root->node) { 163925baeddSChris Mason spin_unlock(&root->node_lock); 164925baeddSChris Mason break; 165925baeddSChris Mason } 166925baeddSChris Mason spin_unlock(&root->node_lock); 167925baeddSChris Mason 168925baeddSChris Mason btrfs_tree_unlock(eb); 169925baeddSChris Mason free_extent_buffer(eb); 170925baeddSChris Mason } 171925baeddSChris Mason return eb; 172925baeddSChris Mason } 173925baeddSChris Mason 174d352ac68SChris Mason /* cowonly root (everything not a reference counted cow subvolume), just get 175d352ac68SChris Mason * put onto a simple dirty list. transaction.c walks this to make sure they 176d352ac68SChris Mason * get properly updated on disk. 177d352ac68SChris Mason */ 1780b86a832SChris Mason static void add_root_to_dirty_list(struct btrfs_root *root) 1790b86a832SChris Mason { 1800b86a832SChris Mason if (root->track_dirty && list_empty(&root->dirty_list)) { 1810b86a832SChris Mason list_add(&root->dirty_list, 1820b86a832SChris Mason &root->fs_info->dirty_cowonly_roots); 1830b86a832SChris Mason } 1840b86a832SChris Mason } 1850b86a832SChris Mason 186d352ac68SChris Mason /* 187d352ac68SChris Mason * used by snapshot creation to make a copy of a root for a tree with 188d352ac68SChris Mason * a given objectid. The buffer with the new root node is returned in 189d352ac68SChris Mason * cow_ret, and this func returns zero on success or a negative error code. 190d352ac68SChris Mason */ 191be20aa9dSChris Mason int btrfs_copy_root(struct btrfs_trans_handle *trans, 192be20aa9dSChris Mason struct btrfs_root *root, 193be20aa9dSChris Mason struct extent_buffer *buf, 194be20aa9dSChris Mason struct extent_buffer **cow_ret, u64 new_root_objectid) 195be20aa9dSChris Mason { 196be20aa9dSChris Mason struct extent_buffer *cow; 197be20aa9dSChris Mason u32 nritems; 198be20aa9dSChris Mason int ret = 0; 199be20aa9dSChris Mason int level; 2004aec2b52SChris Mason struct btrfs_root *new_root; 201be20aa9dSChris Mason 2024aec2b52SChris Mason new_root = kmalloc(sizeof(*new_root), GFP_NOFS); 2034aec2b52SChris Mason if (!new_root) 2044aec2b52SChris Mason return -ENOMEM; 2054aec2b52SChris Mason 2064aec2b52SChris Mason memcpy(new_root, root, sizeof(*new_root)); 2074aec2b52SChris Mason new_root->root_key.objectid = new_root_objectid; 208be20aa9dSChris Mason 209be20aa9dSChris Mason WARN_ON(root->ref_cows && trans->transid != 210be20aa9dSChris Mason root->fs_info->running_transaction->transid); 211be20aa9dSChris Mason WARN_ON(root->ref_cows && trans->transid != root->last_trans); 212be20aa9dSChris Mason 213be20aa9dSChris Mason level = btrfs_header_level(buf); 214be20aa9dSChris Mason nritems = btrfs_header_nritems(buf); 21531840ae1SZheng Yan 21631840ae1SZheng Yan cow = btrfs_alloc_free_block(trans, new_root, buf->len, 0, 21731840ae1SZheng Yan new_root_objectid, trans->transid, 218be20aa9dSChris Mason level, buf->start, 0); 2194aec2b52SChris Mason if (IS_ERR(cow)) { 2204aec2b52SChris Mason kfree(new_root); 221be20aa9dSChris Mason return PTR_ERR(cow); 2224aec2b52SChris Mason } 223be20aa9dSChris Mason 224be20aa9dSChris Mason copy_extent_buffer(cow, buf, 0, 0, cow->len); 225be20aa9dSChris Mason btrfs_set_header_bytenr(cow, cow->start); 226be20aa9dSChris Mason btrfs_set_header_generation(cow, trans->transid); 227be20aa9dSChris Mason btrfs_set_header_owner(cow, new_root_objectid); 22863b10fc4SChris Mason btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN); 229be20aa9dSChris Mason 2302b82032cSYan Zheng write_extent_buffer(cow, root->fs_info->fsid, 2312b82032cSYan Zheng (unsigned long)btrfs_header_fsid(cow), 2322b82032cSYan Zheng BTRFS_FSID_SIZE); 2332b82032cSYan Zheng 234be20aa9dSChris Mason WARN_ON(btrfs_header_generation(buf) > trans->transid); 23531840ae1SZheng Yan ret = btrfs_inc_ref(trans, new_root, buf, cow, NULL); 2364aec2b52SChris Mason kfree(new_root); 2374aec2b52SChris Mason 238be20aa9dSChris Mason if (ret) 239be20aa9dSChris Mason return ret; 240be20aa9dSChris Mason 241be20aa9dSChris Mason btrfs_mark_buffer_dirty(cow); 242be20aa9dSChris Mason *cow_ret = cow; 243be20aa9dSChris Mason return 0; 244be20aa9dSChris Mason } 245be20aa9dSChris Mason 246d352ac68SChris Mason /* 247d397712bSChris Mason * does the dirty work in cow of a single block. The parent block (if 248d397712bSChris Mason * supplied) is updated to point to the new cow copy. The new buffer is marked 249d397712bSChris Mason * dirty and returned locked. If you modify the block it needs to be marked 250d397712bSChris Mason * dirty again. 251d352ac68SChris Mason * 252d352ac68SChris Mason * search_start -- an allocation hint for the new block 253d352ac68SChris Mason * 254d397712bSChris Mason * empty_size -- a hint that you plan on doing more cow. This is the size in 255d397712bSChris Mason * bytes the allocator should try to find free next to the block it returns. 256d397712bSChris Mason * This is just a hint and may be ignored by the allocator. 257d352ac68SChris Mason */ 258d397712bSChris Mason static noinline int __btrfs_cow_block(struct btrfs_trans_handle *trans, 2595f39d397SChris Mason struct btrfs_root *root, 2605f39d397SChris Mason struct extent_buffer *buf, 2615f39d397SChris Mason struct extent_buffer *parent, int parent_slot, 2625f39d397SChris Mason struct extent_buffer **cow_ret, 2639fa8cfe7SChris Mason u64 search_start, u64 empty_size) 2646702ed49SChris Mason { 26531840ae1SZheng Yan u64 parent_start; 2665f39d397SChris Mason struct extent_buffer *cow; 2677bb86316SChris Mason u32 nritems; 2686702ed49SChris Mason int ret = 0; 2697bb86316SChris Mason int level; 270925baeddSChris Mason int unlock_orig = 0; 2716702ed49SChris Mason 272925baeddSChris Mason if (*cow_ret == buf) 273925baeddSChris Mason unlock_orig = 1; 274925baeddSChris Mason 275b9447ef8SChris Mason btrfs_assert_tree_locked(buf); 276925baeddSChris Mason 27731840ae1SZheng Yan if (parent) 27831840ae1SZheng Yan parent_start = parent->start; 27931840ae1SZheng Yan else 28031840ae1SZheng Yan parent_start = 0; 28131840ae1SZheng Yan 2827bb86316SChris Mason WARN_ON(root->ref_cows && trans->transid != 2837bb86316SChris Mason root->fs_info->running_transaction->transid); 2846702ed49SChris Mason WARN_ON(root->ref_cows && trans->transid != root->last_trans); 2855f39d397SChris Mason 2867bb86316SChris Mason level = btrfs_header_level(buf); 2877bb86316SChris Mason nritems = btrfs_header_nritems(buf); 28831840ae1SZheng Yan 289925baeddSChris Mason cow = btrfs_alloc_free_block(trans, root, buf->len, 2909fa8cfe7SChris Mason parent_start, root->root_key.objectid, 29131840ae1SZheng Yan trans->transid, level, 29231840ae1SZheng Yan search_start, empty_size); 2936702ed49SChris Mason if (IS_ERR(cow)) 2946702ed49SChris Mason return PTR_ERR(cow); 2956702ed49SChris Mason 296b4ce94deSChris Mason /* cow is set to blocking by btrfs_init_new_buffer */ 297b4ce94deSChris Mason 2985f39d397SChris Mason copy_extent_buffer(cow, buf, 0, 0, cow->len); 299db94535dSChris Mason btrfs_set_header_bytenr(cow, cow->start); 3005f39d397SChris Mason btrfs_set_header_generation(cow, trans->transid); 3015f39d397SChris Mason btrfs_set_header_owner(cow, root->root_key.objectid); 30263b10fc4SChris Mason btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN); 3036702ed49SChris Mason 3042b82032cSYan Zheng write_extent_buffer(cow, root->fs_info->fsid, 3052b82032cSYan Zheng (unsigned long)btrfs_header_fsid(cow), 3062b82032cSYan Zheng BTRFS_FSID_SIZE); 3072b82032cSYan Zheng 3085f39d397SChris Mason WARN_ON(btrfs_header_generation(buf) > trans->transid); 3095f39d397SChris Mason if (btrfs_header_generation(buf) != trans->transid) { 31031840ae1SZheng Yan u32 nr_extents; 31131840ae1SZheng Yan ret = btrfs_inc_ref(trans, root, buf, cow, &nr_extents); 3126702ed49SChris Mason if (ret) 3136702ed49SChris Mason return ret; 31431840ae1SZheng Yan 31531840ae1SZheng Yan ret = btrfs_cache_ref(trans, root, buf, nr_extents); 31631840ae1SZheng Yan WARN_ON(ret); 3171a40e23bSZheng Yan } else if (btrfs_header_owner(buf) == BTRFS_TREE_RELOC_OBJECTID) { 3181a40e23bSZheng Yan /* 3191a40e23bSZheng Yan * There are only two places that can drop reference to 3201a40e23bSZheng Yan * tree blocks owned by living reloc trees, one is here, 321f82d02d9SYan Zheng * the other place is btrfs_drop_subtree. In both places, 3221a40e23bSZheng Yan * we check reference count while tree block is locked. 3231a40e23bSZheng Yan * Furthermore, if reference count is one, it won't get 3241a40e23bSZheng Yan * increased by someone else. 3251a40e23bSZheng Yan */ 3261a40e23bSZheng Yan u32 refs; 3271a40e23bSZheng Yan ret = btrfs_lookup_extent_ref(trans, root, buf->start, 3281a40e23bSZheng Yan buf->len, &refs); 3291a40e23bSZheng Yan BUG_ON(ret); 3301a40e23bSZheng Yan if (refs == 1) { 3311a40e23bSZheng Yan ret = btrfs_update_ref(trans, root, buf, cow, 3321a40e23bSZheng Yan 0, nritems); 3331a40e23bSZheng Yan clean_tree_block(trans, root, buf); 3341a40e23bSZheng Yan } else { 3351a40e23bSZheng Yan ret = btrfs_inc_ref(trans, root, buf, cow, NULL); 3361a40e23bSZheng Yan } 3371a40e23bSZheng Yan BUG_ON(ret); 3386702ed49SChris Mason } else { 33931840ae1SZheng Yan ret = btrfs_update_ref(trans, root, buf, cow, 0, nritems); 34031840ae1SZheng Yan if (ret) 34131840ae1SZheng Yan return ret; 3426702ed49SChris Mason clean_tree_block(trans, root, buf); 3436702ed49SChris Mason } 3446702ed49SChris Mason 3451a40e23bSZheng Yan if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) { 3461a40e23bSZheng Yan ret = btrfs_reloc_tree_cache_ref(trans, root, cow, buf->start); 3471a40e23bSZheng Yan WARN_ON(ret); 3481a40e23bSZheng Yan } 3491a40e23bSZheng Yan 3506702ed49SChris Mason if (buf == root->node) { 351925baeddSChris Mason WARN_ON(parent && parent != buf); 352925baeddSChris Mason 353925baeddSChris Mason spin_lock(&root->node_lock); 3546702ed49SChris Mason root->node = cow; 3555f39d397SChris Mason extent_buffer_get(cow); 356925baeddSChris Mason spin_unlock(&root->node_lock); 357925baeddSChris Mason 3586702ed49SChris Mason if (buf != root->commit_root) { 359db94535dSChris Mason btrfs_free_extent(trans, root, buf->start, 36031840ae1SZheng Yan buf->len, buf->start, 36131840ae1SZheng Yan root->root_key.objectid, 36231840ae1SZheng Yan btrfs_header_generation(buf), 3633bb1a1bcSYan Zheng level, 1); 3646702ed49SChris Mason } 3655f39d397SChris Mason free_extent_buffer(buf); 3660b86a832SChris Mason add_root_to_dirty_list(root); 3676702ed49SChris Mason } else { 3685f39d397SChris Mason btrfs_set_node_blockptr(parent, parent_slot, 369db94535dSChris Mason cow->start); 37074493f7aSChris Mason WARN_ON(trans->transid == 0); 37174493f7aSChris Mason btrfs_set_node_ptr_generation(parent, parent_slot, 37274493f7aSChris Mason trans->transid); 3736702ed49SChris Mason btrfs_mark_buffer_dirty(parent); 3745f39d397SChris Mason WARN_ON(btrfs_header_generation(parent) != trans->transid); 3757bb86316SChris Mason btrfs_free_extent(trans, root, buf->start, buf->len, 37631840ae1SZheng Yan parent_start, btrfs_header_owner(parent), 3773bb1a1bcSYan Zheng btrfs_header_generation(parent), level, 1); 3786702ed49SChris Mason } 379925baeddSChris Mason if (unlock_orig) 380925baeddSChris Mason btrfs_tree_unlock(buf); 3815f39d397SChris Mason free_extent_buffer(buf); 3826702ed49SChris Mason btrfs_mark_buffer_dirty(cow); 3836702ed49SChris Mason *cow_ret = cow; 3846702ed49SChris Mason return 0; 3856702ed49SChris Mason } 3866702ed49SChris Mason 387d352ac68SChris Mason /* 388d352ac68SChris Mason * cows a single block, see __btrfs_cow_block for the real work. 389d352ac68SChris Mason * This version of it has extra checks so that a block isn't cow'd more than 390d352ac68SChris Mason * once per transaction, as long as it hasn't been written yet 391d352ac68SChris Mason */ 392d397712bSChris Mason noinline int btrfs_cow_block(struct btrfs_trans_handle *trans, 3935f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *buf, 3945f39d397SChris Mason struct extent_buffer *parent, int parent_slot, 3959fa8cfe7SChris Mason struct extent_buffer **cow_ret) 39602217ed2SChris Mason { 3976702ed49SChris Mason u64 search_start; 398f510cfecSChris Mason int ret; 399dc17ff8fSChris Mason 400ccd467d6SChris Mason if (trans->transaction != root->fs_info->running_transaction) { 401d397712bSChris Mason printk(KERN_CRIT "trans %llu running %llu\n", 402d397712bSChris Mason (unsigned long long)trans->transid, 403d397712bSChris Mason (unsigned long long) 404ccd467d6SChris Mason root->fs_info->running_transaction->transid); 405ccd467d6SChris Mason WARN_ON(1); 406ccd467d6SChris Mason } 407ccd467d6SChris Mason if (trans->transid != root->fs_info->generation) { 408d397712bSChris Mason printk(KERN_CRIT "trans %llu running %llu\n", 409d397712bSChris Mason (unsigned long long)trans->transid, 410d397712bSChris Mason (unsigned long long)root->fs_info->generation); 411ccd467d6SChris Mason WARN_ON(1); 412ccd467d6SChris Mason } 413dc17ff8fSChris Mason 4145b21f2edSZheng Yan if (btrfs_header_generation(buf) == trans->transid && 4155b21f2edSZheng Yan btrfs_header_owner(buf) == root->root_key.objectid && 41663b10fc4SChris Mason !btrfs_header_flag(buf, BTRFS_HEADER_FLAG_WRITTEN)) { 41702217ed2SChris Mason *cow_ret = buf; 41802217ed2SChris Mason return 0; 41902217ed2SChris Mason } 420c487685dSChris Mason 4210b86a832SChris Mason search_start = buf->start & ~((u64)(1024 * 1024 * 1024) - 1); 422b4ce94deSChris Mason 423b4ce94deSChris Mason if (parent) 424b4ce94deSChris Mason btrfs_set_lock_blocking(parent); 425b4ce94deSChris Mason btrfs_set_lock_blocking(buf); 426b4ce94deSChris Mason 427f510cfecSChris Mason ret = __btrfs_cow_block(trans, root, buf, parent, 4289fa8cfe7SChris Mason parent_slot, cow_ret, search_start, 0); 429f510cfecSChris Mason return ret; 4302c90e5d6SChris Mason } 4316702ed49SChris Mason 432d352ac68SChris Mason /* 433d352ac68SChris Mason * helper function for defrag to decide if two blocks pointed to by a 434d352ac68SChris Mason * node are actually close by 435d352ac68SChris Mason */ 4366b80053dSChris Mason static int close_blocks(u64 blocknr, u64 other, u32 blocksize) 4376702ed49SChris Mason { 4386b80053dSChris Mason if (blocknr < other && other - (blocknr + blocksize) < 32768) 4396702ed49SChris Mason return 1; 4406b80053dSChris Mason if (blocknr > other && blocknr - (other + blocksize) < 32768) 4416702ed49SChris Mason return 1; 44202217ed2SChris Mason return 0; 44302217ed2SChris Mason } 44402217ed2SChris Mason 445081e9573SChris Mason /* 446081e9573SChris Mason * compare two keys in a memcmp fashion 447081e9573SChris Mason */ 448081e9573SChris Mason static int comp_keys(struct btrfs_disk_key *disk, struct btrfs_key *k2) 449081e9573SChris Mason { 450081e9573SChris Mason struct btrfs_key k1; 451081e9573SChris Mason 452081e9573SChris Mason btrfs_disk_key_to_cpu(&k1, disk); 453081e9573SChris Mason 454081e9573SChris Mason if (k1.objectid > k2->objectid) 455081e9573SChris Mason return 1; 456081e9573SChris Mason if (k1.objectid < k2->objectid) 457081e9573SChris Mason return -1; 458081e9573SChris Mason if (k1.type > k2->type) 459081e9573SChris Mason return 1; 460081e9573SChris Mason if (k1.type < k2->type) 461081e9573SChris Mason return -1; 462081e9573SChris Mason if (k1.offset > k2->offset) 463081e9573SChris Mason return 1; 464081e9573SChris Mason if (k1.offset < k2->offset) 465081e9573SChris Mason return -1; 466081e9573SChris Mason return 0; 467081e9573SChris Mason } 468081e9573SChris Mason 469f3465ca4SJosef Bacik /* 470f3465ca4SJosef Bacik * same as comp_keys only with two btrfs_key's 471f3465ca4SJosef Bacik */ 472f3465ca4SJosef Bacik static int comp_cpu_keys(struct btrfs_key *k1, struct btrfs_key *k2) 473f3465ca4SJosef Bacik { 474f3465ca4SJosef Bacik if (k1->objectid > k2->objectid) 475f3465ca4SJosef Bacik return 1; 476f3465ca4SJosef Bacik if (k1->objectid < k2->objectid) 477f3465ca4SJosef Bacik return -1; 478f3465ca4SJosef Bacik if (k1->type > k2->type) 479f3465ca4SJosef Bacik return 1; 480f3465ca4SJosef Bacik if (k1->type < k2->type) 481f3465ca4SJosef Bacik return -1; 482f3465ca4SJosef Bacik if (k1->offset > k2->offset) 483f3465ca4SJosef Bacik return 1; 484f3465ca4SJosef Bacik if (k1->offset < k2->offset) 485f3465ca4SJosef Bacik return -1; 486f3465ca4SJosef Bacik return 0; 487f3465ca4SJosef Bacik } 488081e9573SChris Mason 489d352ac68SChris Mason /* 490d352ac68SChris Mason * this is used by the defrag code to go through all the 491d352ac68SChris Mason * leaves pointed to by a node and reallocate them so that 492d352ac68SChris Mason * disk order is close to key order 493d352ac68SChris Mason */ 4946702ed49SChris Mason int btrfs_realloc_node(struct btrfs_trans_handle *trans, 4955f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *parent, 496a6b6e75eSChris Mason int start_slot, int cache_only, u64 *last_ret, 497a6b6e75eSChris Mason struct btrfs_key *progress) 4986702ed49SChris Mason { 4996b80053dSChris Mason struct extent_buffer *cur; 5006702ed49SChris Mason u64 blocknr; 501ca7a79adSChris Mason u64 gen; 502e9d0b13bSChris Mason u64 search_start = *last_ret; 503e9d0b13bSChris Mason u64 last_block = 0; 5046702ed49SChris Mason u64 other; 5056702ed49SChris Mason u32 parent_nritems; 5066702ed49SChris Mason int end_slot; 5076702ed49SChris Mason int i; 5086702ed49SChris Mason int err = 0; 509f2183bdeSChris Mason int parent_level; 5106b80053dSChris Mason int uptodate; 5116b80053dSChris Mason u32 blocksize; 512081e9573SChris Mason int progress_passed = 0; 513081e9573SChris Mason struct btrfs_disk_key disk_key; 5146702ed49SChris Mason 5155708b959SChris Mason parent_level = btrfs_header_level(parent); 5165708b959SChris Mason if (cache_only && parent_level != 1) 5175708b959SChris Mason return 0; 5185708b959SChris Mason 519d397712bSChris Mason if (trans->transaction != root->fs_info->running_transaction) 5206702ed49SChris Mason WARN_ON(1); 521d397712bSChris Mason if (trans->transid != root->fs_info->generation) 5226702ed49SChris Mason WARN_ON(1); 52386479a04SChris Mason 5246b80053dSChris Mason parent_nritems = btrfs_header_nritems(parent); 5256b80053dSChris Mason blocksize = btrfs_level_size(root, parent_level - 1); 5266702ed49SChris Mason end_slot = parent_nritems; 5276702ed49SChris Mason 5286702ed49SChris Mason if (parent_nritems == 1) 5296702ed49SChris Mason return 0; 5306702ed49SChris Mason 531b4ce94deSChris Mason btrfs_set_lock_blocking(parent); 532b4ce94deSChris Mason 5336702ed49SChris Mason for (i = start_slot; i < end_slot; i++) { 5346702ed49SChris Mason int close = 1; 535a6b6e75eSChris Mason 5365708b959SChris Mason if (!parent->map_token) { 5375708b959SChris Mason map_extent_buffer(parent, 5385708b959SChris Mason btrfs_node_key_ptr_offset(i), 5395708b959SChris Mason sizeof(struct btrfs_key_ptr), 5405708b959SChris Mason &parent->map_token, &parent->kaddr, 5415708b959SChris Mason &parent->map_start, &parent->map_len, 5425708b959SChris Mason KM_USER1); 5435708b959SChris Mason } 544081e9573SChris Mason btrfs_node_key(parent, &disk_key, i); 545081e9573SChris Mason if (!progress_passed && comp_keys(&disk_key, progress) < 0) 546081e9573SChris Mason continue; 547081e9573SChris Mason 548081e9573SChris Mason progress_passed = 1; 5496b80053dSChris Mason blocknr = btrfs_node_blockptr(parent, i); 550ca7a79adSChris Mason gen = btrfs_node_ptr_generation(parent, i); 551e9d0b13bSChris Mason if (last_block == 0) 552e9d0b13bSChris Mason last_block = blocknr; 5535708b959SChris Mason 5546702ed49SChris Mason if (i > 0) { 5556b80053dSChris Mason other = btrfs_node_blockptr(parent, i - 1); 5566b80053dSChris Mason close = close_blocks(blocknr, other, blocksize); 5576702ed49SChris Mason } 5580ef3e66bSChris Mason if (!close && i < end_slot - 2) { 5596b80053dSChris Mason other = btrfs_node_blockptr(parent, i + 1); 5606b80053dSChris Mason close = close_blocks(blocknr, other, blocksize); 5616702ed49SChris Mason } 562e9d0b13bSChris Mason if (close) { 563e9d0b13bSChris Mason last_block = blocknr; 5646702ed49SChris Mason continue; 565e9d0b13bSChris Mason } 5665708b959SChris Mason if (parent->map_token) { 5675708b959SChris Mason unmap_extent_buffer(parent, parent->map_token, 5685708b959SChris Mason KM_USER1); 5695708b959SChris Mason parent->map_token = NULL; 5705708b959SChris Mason } 5716702ed49SChris Mason 5726b80053dSChris Mason cur = btrfs_find_tree_block(root, blocknr, blocksize); 5736b80053dSChris Mason if (cur) 5741259ab75SChris Mason uptodate = btrfs_buffer_uptodate(cur, gen); 5756b80053dSChris Mason else 5766b80053dSChris Mason uptodate = 0; 5775708b959SChris Mason if (!cur || !uptodate) { 5786702ed49SChris Mason if (cache_only) { 5796b80053dSChris Mason free_extent_buffer(cur); 5806702ed49SChris Mason continue; 5816702ed49SChris Mason } 5826b80053dSChris Mason if (!cur) { 5836b80053dSChris Mason cur = read_tree_block(root, blocknr, 584ca7a79adSChris Mason blocksize, gen); 5856b80053dSChris Mason } else if (!uptodate) { 586ca7a79adSChris Mason btrfs_read_buffer(cur, gen); 5876702ed49SChris Mason } 588f2183bdeSChris Mason } 589e9d0b13bSChris Mason if (search_start == 0) 5906b80053dSChris Mason search_start = last_block; 591e9d0b13bSChris Mason 592e7a84565SChris Mason btrfs_tree_lock(cur); 593b4ce94deSChris Mason btrfs_set_lock_blocking(cur); 5946b80053dSChris Mason err = __btrfs_cow_block(trans, root, cur, parent, i, 595e7a84565SChris Mason &cur, search_start, 5966b80053dSChris Mason min(16 * blocksize, 5979fa8cfe7SChris Mason (end_slot - i) * blocksize)); 598252c38f0SYan if (err) { 599e7a84565SChris Mason btrfs_tree_unlock(cur); 6006b80053dSChris Mason free_extent_buffer(cur); 6016702ed49SChris Mason break; 602252c38f0SYan } 603e7a84565SChris Mason search_start = cur->start; 604e7a84565SChris Mason last_block = cur->start; 605f2183bdeSChris Mason *last_ret = search_start; 606e7a84565SChris Mason btrfs_tree_unlock(cur); 607e7a84565SChris Mason free_extent_buffer(cur); 6086702ed49SChris Mason } 6095708b959SChris Mason if (parent->map_token) { 6105708b959SChris Mason unmap_extent_buffer(parent, parent->map_token, 6115708b959SChris Mason KM_USER1); 6125708b959SChris Mason parent->map_token = NULL; 6135708b959SChris Mason } 6146702ed49SChris Mason return err; 6156702ed49SChris Mason } 6166702ed49SChris Mason 61774123bd7SChris Mason /* 61874123bd7SChris Mason * The leaf data grows from end-to-front in the node. 61974123bd7SChris Mason * this returns the address of the start of the last item, 62074123bd7SChris Mason * which is the stop of the leaf data stack 62174123bd7SChris Mason */ 622123abc88SChris Mason static inline unsigned int leaf_data_end(struct btrfs_root *root, 6235f39d397SChris Mason struct extent_buffer *leaf) 624be0e5c09SChris Mason { 6255f39d397SChris Mason u32 nr = btrfs_header_nritems(leaf); 626be0e5c09SChris Mason if (nr == 0) 627123abc88SChris Mason return BTRFS_LEAF_DATA_SIZE(root); 6285f39d397SChris Mason return btrfs_item_offset_nr(leaf, nr - 1); 629be0e5c09SChris Mason } 630be0e5c09SChris Mason 631d352ac68SChris Mason /* 632d352ac68SChris Mason * extra debugging checks to make sure all the items in a key are 633d352ac68SChris Mason * well formed and in the proper order 634d352ac68SChris Mason */ 635123abc88SChris Mason static int check_node(struct btrfs_root *root, struct btrfs_path *path, 636123abc88SChris Mason int level) 637aa5d6bedSChris Mason { 6385f39d397SChris Mason struct extent_buffer *parent = NULL; 6395f39d397SChris Mason struct extent_buffer *node = path->nodes[level]; 6405f39d397SChris Mason struct btrfs_disk_key parent_key; 6415f39d397SChris Mason struct btrfs_disk_key node_key; 642aa5d6bedSChris Mason int parent_slot; 6438d7be552SChris Mason int slot; 6448d7be552SChris Mason struct btrfs_key cpukey; 6455f39d397SChris Mason u32 nritems = btrfs_header_nritems(node); 646aa5d6bedSChris Mason 647aa5d6bedSChris Mason if (path->nodes[level + 1]) 6485f39d397SChris Mason parent = path->nodes[level + 1]; 649a1f39630SAneesh 6508d7be552SChris Mason slot = path->slots[level]; 6517518a238SChris Mason BUG_ON(nritems == 0); 6527518a238SChris Mason if (parent) { 653a1f39630SAneesh parent_slot = path->slots[level + 1]; 6545f39d397SChris Mason btrfs_node_key(parent, &parent_key, parent_slot); 6555f39d397SChris Mason btrfs_node_key(node, &node_key, 0); 6565f39d397SChris Mason BUG_ON(memcmp(&parent_key, &node_key, 657e2fa7227SChris Mason sizeof(struct btrfs_disk_key))); 6581d4f8a0cSChris Mason BUG_ON(btrfs_node_blockptr(parent, parent_slot) != 659db94535dSChris Mason btrfs_header_bytenr(node)); 660aa5d6bedSChris Mason } 661123abc88SChris Mason BUG_ON(nritems > BTRFS_NODEPTRS_PER_BLOCK(root)); 6628d7be552SChris Mason if (slot != 0) { 6635f39d397SChris Mason btrfs_node_key_to_cpu(node, &cpukey, slot - 1); 6645f39d397SChris Mason btrfs_node_key(node, &node_key, slot); 6655f39d397SChris Mason BUG_ON(comp_keys(&node_key, &cpukey) <= 0); 6668d7be552SChris Mason } 6678d7be552SChris Mason if (slot < nritems - 1) { 6685f39d397SChris Mason btrfs_node_key_to_cpu(node, &cpukey, slot + 1); 6695f39d397SChris Mason btrfs_node_key(node, &node_key, slot); 6705f39d397SChris Mason BUG_ON(comp_keys(&node_key, &cpukey) >= 0); 671aa5d6bedSChris Mason } 672aa5d6bedSChris Mason return 0; 673aa5d6bedSChris Mason } 674aa5d6bedSChris Mason 675d352ac68SChris Mason /* 676d352ac68SChris Mason * extra checking to make sure all the items in a leaf are 677d352ac68SChris Mason * well formed and in the proper order 678d352ac68SChris Mason */ 679123abc88SChris Mason static int check_leaf(struct btrfs_root *root, struct btrfs_path *path, 680123abc88SChris Mason int level) 681aa5d6bedSChris Mason { 6825f39d397SChris Mason struct extent_buffer *leaf = path->nodes[level]; 6835f39d397SChris Mason struct extent_buffer *parent = NULL; 684aa5d6bedSChris Mason int parent_slot; 6858d7be552SChris Mason struct btrfs_key cpukey; 6865f39d397SChris Mason struct btrfs_disk_key parent_key; 6875f39d397SChris Mason struct btrfs_disk_key leaf_key; 6885f39d397SChris Mason int slot = path->slots[0]; 6898d7be552SChris Mason 6905f39d397SChris Mason u32 nritems = btrfs_header_nritems(leaf); 691aa5d6bedSChris Mason 692aa5d6bedSChris Mason if (path->nodes[level + 1]) 6935f39d397SChris Mason parent = path->nodes[level + 1]; 6947518a238SChris Mason 6957518a238SChris Mason if (nritems == 0) 6967518a238SChris Mason return 0; 6977518a238SChris Mason 6987518a238SChris Mason if (parent) { 699a1f39630SAneesh parent_slot = path->slots[level + 1]; 7005f39d397SChris Mason btrfs_node_key(parent, &parent_key, parent_slot); 7015f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, 0); 7026702ed49SChris Mason 7035f39d397SChris Mason BUG_ON(memcmp(&parent_key, &leaf_key, 704e2fa7227SChris Mason sizeof(struct btrfs_disk_key))); 7051d4f8a0cSChris Mason BUG_ON(btrfs_node_blockptr(parent, parent_slot) != 706db94535dSChris Mason btrfs_header_bytenr(leaf)); 707aa5d6bedSChris Mason } 7085f39d397SChris Mason if (slot != 0 && slot < nritems - 1) { 7095f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, slot); 7105f39d397SChris Mason btrfs_item_key_to_cpu(leaf, &cpukey, slot - 1); 7115f39d397SChris Mason if (comp_keys(&leaf_key, &cpukey) <= 0) { 7125f39d397SChris Mason btrfs_print_leaf(root, leaf); 713d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad key\n", slot); 7145f39d397SChris Mason BUG_ON(1); 7155f39d397SChris Mason } 7165f39d397SChris Mason if (btrfs_item_offset_nr(leaf, slot - 1) != 7175f39d397SChris Mason btrfs_item_end_nr(leaf, slot)) { 7185f39d397SChris Mason btrfs_print_leaf(root, leaf); 719d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad\n", slot); 7205f39d397SChris Mason BUG_ON(1); 7215f39d397SChris Mason } 722aa5d6bedSChris Mason } 7238d7be552SChris Mason if (slot < nritems - 1) { 7245f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, slot); 7255f39d397SChris Mason btrfs_item_key_to_cpu(leaf, &cpukey, slot + 1); 7265f39d397SChris Mason BUG_ON(comp_keys(&leaf_key, &cpukey) >= 0); 7275f39d397SChris Mason if (btrfs_item_offset_nr(leaf, slot) != 7285f39d397SChris Mason btrfs_item_end_nr(leaf, slot + 1)) { 7295f39d397SChris Mason btrfs_print_leaf(root, leaf); 730d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad\n", slot); 7315f39d397SChris Mason BUG_ON(1); 732aa5d6bedSChris Mason } 7335f39d397SChris Mason } 7345f39d397SChris Mason BUG_ON(btrfs_item_offset_nr(leaf, 0) + 7355f39d397SChris Mason btrfs_item_size_nr(leaf, 0) != BTRFS_LEAF_DATA_SIZE(root)); 736aa5d6bedSChris Mason return 0; 737aa5d6bedSChris Mason } 738aa5d6bedSChris Mason 739d397712bSChris Mason static noinline int check_block(struct btrfs_root *root, 74098ed5174SChris Mason struct btrfs_path *path, int level) 741aa5d6bedSChris Mason { 74285d824c4SChris Mason return 0; 743aa5d6bedSChris Mason if (level == 0) 744123abc88SChris Mason return check_leaf(root, path, level); 745123abc88SChris Mason return check_node(root, path, level); 746aa5d6bedSChris Mason } 747aa5d6bedSChris Mason 74874123bd7SChris Mason /* 7495f39d397SChris Mason * search for key in the extent_buffer. The items start at offset p, 7505f39d397SChris Mason * and they are item_size apart. There are 'max' items in p. 7515f39d397SChris Mason * 75274123bd7SChris Mason * the slot in the array is returned via slot, and it points to 75374123bd7SChris Mason * the place where you would insert key if it is not found in 75474123bd7SChris Mason * the array. 75574123bd7SChris Mason * 75674123bd7SChris Mason * slot may point to max if the key is bigger than all of the keys 75774123bd7SChris Mason */ 758e02119d5SChris Mason static noinline int generic_bin_search(struct extent_buffer *eb, 759e02119d5SChris Mason unsigned long p, 7605f39d397SChris Mason int item_size, struct btrfs_key *key, 761be0e5c09SChris Mason int max, int *slot) 762be0e5c09SChris Mason { 763be0e5c09SChris Mason int low = 0; 764be0e5c09SChris Mason int high = max; 765be0e5c09SChris Mason int mid; 766be0e5c09SChris Mason int ret; 767479965d6SChris Mason struct btrfs_disk_key *tmp = NULL; 7685f39d397SChris Mason struct btrfs_disk_key unaligned; 7695f39d397SChris Mason unsigned long offset; 7705f39d397SChris Mason char *map_token = NULL; 7715f39d397SChris Mason char *kaddr = NULL; 7725f39d397SChris Mason unsigned long map_start = 0; 7735f39d397SChris Mason unsigned long map_len = 0; 774479965d6SChris Mason int err; 775be0e5c09SChris Mason 776be0e5c09SChris Mason while (low < high) { 777be0e5c09SChris Mason mid = (low + high) / 2; 7785f39d397SChris Mason offset = p + mid * item_size; 7795f39d397SChris Mason 7805f39d397SChris Mason if (!map_token || offset < map_start || 7815f39d397SChris Mason (offset + sizeof(struct btrfs_disk_key)) > 7825f39d397SChris Mason map_start + map_len) { 783479965d6SChris Mason if (map_token) { 7845f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 785479965d6SChris Mason map_token = NULL; 786479965d6SChris Mason } 787934d375bSChris Mason 788934d375bSChris Mason err = map_private_extent_buffer(eb, offset, 789479965d6SChris Mason sizeof(struct btrfs_disk_key), 790479965d6SChris Mason &map_token, &kaddr, 7915f39d397SChris Mason &map_start, &map_len, KM_USER0); 7925f39d397SChris Mason 793479965d6SChris Mason if (!err) { 794479965d6SChris Mason tmp = (struct btrfs_disk_key *)(kaddr + offset - 795479965d6SChris Mason map_start); 796479965d6SChris Mason } else { 7975f39d397SChris Mason read_extent_buffer(eb, &unaligned, 7985f39d397SChris Mason offset, sizeof(unaligned)); 7995f39d397SChris Mason tmp = &unaligned; 800479965d6SChris Mason } 801479965d6SChris Mason 8025f39d397SChris Mason } else { 8035f39d397SChris Mason tmp = (struct btrfs_disk_key *)(kaddr + offset - 8045f39d397SChris Mason map_start); 8055f39d397SChris Mason } 806be0e5c09SChris Mason ret = comp_keys(tmp, key); 807be0e5c09SChris Mason 808be0e5c09SChris Mason if (ret < 0) 809be0e5c09SChris Mason low = mid + 1; 810be0e5c09SChris Mason else if (ret > 0) 811be0e5c09SChris Mason high = mid; 812be0e5c09SChris Mason else { 813be0e5c09SChris Mason *slot = mid; 814479965d6SChris Mason if (map_token) 8155f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 816be0e5c09SChris Mason return 0; 817be0e5c09SChris Mason } 818be0e5c09SChris Mason } 819be0e5c09SChris Mason *slot = low; 8205f39d397SChris Mason if (map_token) 8215f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 822be0e5c09SChris Mason return 1; 823be0e5c09SChris Mason } 824be0e5c09SChris Mason 82597571fd0SChris Mason /* 82697571fd0SChris Mason * simple bin_search frontend that does the right thing for 82797571fd0SChris Mason * leaves vs nodes 82897571fd0SChris Mason */ 8295f39d397SChris Mason static int bin_search(struct extent_buffer *eb, struct btrfs_key *key, 8305f39d397SChris Mason int level, int *slot) 831be0e5c09SChris Mason { 8325f39d397SChris Mason if (level == 0) { 8335f39d397SChris Mason return generic_bin_search(eb, 8345f39d397SChris Mason offsetof(struct btrfs_leaf, items), 8350783fcfcSChris Mason sizeof(struct btrfs_item), 8365f39d397SChris Mason key, btrfs_header_nritems(eb), 8377518a238SChris Mason slot); 838be0e5c09SChris Mason } else { 8395f39d397SChris Mason return generic_bin_search(eb, 8405f39d397SChris Mason offsetof(struct btrfs_node, ptrs), 841123abc88SChris Mason sizeof(struct btrfs_key_ptr), 8425f39d397SChris Mason key, btrfs_header_nritems(eb), 8437518a238SChris Mason slot); 844be0e5c09SChris Mason } 845be0e5c09SChris Mason return -1; 846be0e5c09SChris Mason } 847be0e5c09SChris Mason 848d352ac68SChris Mason /* given a node and slot number, this reads the blocks it points to. The 849d352ac68SChris Mason * extent buffer is returned with a reference taken (but unlocked). 850d352ac68SChris Mason * NULL is returned on error. 851d352ac68SChris Mason */ 852e02119d5SChris Mason static noinline struct extent_buffer *read_node_slot(struct btrfs_root *root, 8535f39d397SChris Mason struct extent_buffer *parent, int slot) 854bb803951SChris Mason { 855ca7a79adSChris Mason int level = btrfs_header_level(parent); 856bb803951SChris Mason if (slot < 0) 857bb803951SChris Mason return NULL; 8585f39d397SChris Mason if (slot >= btrfs_header_nritems(parent)) 859bb803951SChris Mason return NULL; 860ca7a79adSChris Mason 861ca7a79adSChris Mason BUG_ON(level == 0); 862ca7a79adSChris Mason 863db94535dSChris Mason return read_tree_block(root, btrfs_node_blockptr(parent, slot), 864ca7a79adSChris Mason btrfs_level_size(root, level - 1), 865ca7a79adSChris Mason btrfs_node_ptr_generation(parent, slot)); 866bb803951SChris Mason } 867bb803951SChris Mason 868d352ac68SChris Mason /* 869d352ac68SChris Mason * node level balancing, used to make sure nodes are in proper order for 870d352ac68SChris Mason * item deletion. We balance from the top down, so we have to make sure 871d352ac68SChris Mason * that a deletion won't leave an node completely empty later on. 872d352ac68SChris Mason */ 873e02119d5SChris Mason static noinline int balance_level(struct btrfs_trans_handle *trans, 87498ed5174SChris Mason struct btrfs_root *root, 87598ed5174SChris Mason struct btrfs_path *path, int level) 876bb803951SChris Mason { 8775f39d397SChris Mason struct extent_buffer *right = NULL; 8785f39d397SChris Mason struct extent_buffer *mid; 8795f39d397SChris Mason struct extent_buffer *left = NULL; 8805f39d397SChris Mason struct extent_buffer *parent = NULL; 881bb803951SChris Mason int ret = 0; 882bb803951SChris Mason int wret; 883bb803951SChris Mason int pslot; 884bb803951SChris Mason int orig_slot = path->slots[level]; 88554aa1f4dSChris Mason int err_on_enospc = 0; 88679f95c82SChris Mason u64 orig_ptr; 887bb803951SChris Mason 888bb803951SChris Mason if (level == 0) 889bb803951SChris Mason return 0; 890bb803951SChris Mason 8915f39d397SChris Mason mid = path->nodes[level]; 892b4ce94deSChris Mason 893925baeddSChris Mason WARN_ON(!path->locks[level]); 8947bb86316SChris Mason WARN_ON(btrfs_header_generation(mid) != trans->transid); 8957bb86316SChris Mason 8961d4f8a0cSChris Mason orig_ptr = btrfs_node_blockptr(mid, orig_slot); 89779f95c82SChris Mason 898234b63a0SChris Mason if (level < BTRFS_MAX_LEVEL - 1) 8995f39d397SChris Mason parent = path->nodes[level + 1]; 900bb803951SChris Mason pslot = path->slots[level + 1]; 901bb803951SChris Mason 90240689478SChris Mason /* 90340689478SChris Mason * deal with the case where there is only one pointer in the root 90440689478SChris Mason * by promoting the node below to a root 90540689478SChris Mason */ 9065f39d397SChris Mason if (!parent) { 9075f39d397SChris Mason struct extent_buffer *child; 908bb803951SChris Mason 9095f39d397SChris Mason if (btrfs_header_nritems(mid) != 1) 910bb803951SChris Mason return 0; 911bb803951SChris Mason 912bb803951SChris Mason /* promote the child to a root */ 9135f39d397SChris Mason child = read_node_slot(root, mid, 0); 9147951f3ceSJeff Mahoney BUG_ON(!child); 915925baeddSChris Mason btrfs_tree_lock(child); 916b4ce94deSChris Mason btrfs_set_lock_blocking(child); 9179fa8cfe7SChris Mason ret = btrfs_cow_block(trans, root, child, mid, 0, &child); 9182f375ab9SYan BUG_ON(ret); 9192f375ab9SYan 920925baeddSChris Mason spin_lock(&root->node_lock); 921bb803951SChris Mason root->node = child; 922925baeddSChris Mason spin_unlock(&root->node_lock); 923925baeddSChris Mason 92431840ae1SZheng Yan ret = btrfs_update_extent_ref(trans, root, child->start, 92556bec294SChris Mason child->len, 92631840ae1SZheng Yan mid->start, child->start, 92731840ae1SZheng Yan root->root_key.objectid, 9283bb1a1bcSYan Zheng trans->transid, level - 1); 92931840ae1SZheng Yan BUG_ON(ret); 93031840ae1SZheng Yan 9310b86a832SChris Mason add_root_to_dirty_list(root); 932925baeddSChris Mason btrfs_tree_unlock(child); 933b4ce94deSChris Mason 934925baeddSChris Mason path->locks[level] = 0; 935bb803951SChris Mason path->nodes[level] = NULL; 9365f39d397SChris Mason clean_tree_block(trans, root, mid); 937925baeddSChris Mason btrfs_tree_unlock(mid); 938bb803951SChris Mason /* once for the path */ 9395f39d397SChris Mason free_extent_buffer(mid); 9407bb86316SChris Mason ret = btrfs_free_extent(trans, root, mid->start, mid->len, 94131840ae1SZheng Yan mid->start, root->root_key.objectid, 9423bb1a1bcSYan Zheng btrfs_header_generation(mid), 9433bb1a1bcSYan Zheng level, 1); 944bb803951SChris Mason /* once for the root ptr */ 9455f39d397SChris Mason free_extent_buffer(mid); 946db94535dSChris Mason return ret; 947bb803951SChris Mason } 9485f39d397SChris Mason if (btrfs_header_nritems(mid) > 949123abc88SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) / 4) 950bb803951SChris Mason return 0; 951bb803951SChris Mason 952a4b6e07dSChris Mason if (trans->transaction->delayed_refs.flushing && 953a4b6e07dSChris Mason btrfs_header_nritems(mid) > 2) 954a4b6e07dSChris Mason return 0; 955a4b6e07dSChris Mason 9565f39d397SChris Mason if (btrfs_header_nritems(mid) < 2) 95754aa1f4dSChris Mason err_on_enospc = 1; 95854aa1f4dSChris Mason 9595f39d397SChris Mason left = read_node_slot(root, parent, pslot - 1); 9605f39d397SChris Mason if (left) { 961925baeddSChris Mason btrfs_tree_lock(left); 962b4ce94deSChris Mason btrfs_set_lock_blocking(left); 9635f39d397SChris Mason wret = btrfs_cow_block(trans, root, left, 9649fa8cfe7SChris Mason parent, pslot - 1, &left); 96554aa1f4dSChris Mason if (wret) { 96654aa1f4dSChris Mason ret = wret; 96754aa1f4dSChris Mason goto enospc; 96854aa1f4dSChris Mason } 9692cc58cf2SChris Mason } 9705f39d397SChris Mason right = read_node_slot(root, parent, pslot + 1); 9715f39d397SChris Mason if (right) { 972925baeddSChris Mason btrfs_tree_lock(right); 973b4ce94deSChris Mason btrfs_set_lock_blocking(right); 9745f39d397SChris Mason wret = btrfs_cow_block(trans, root, right, 9759fa8cfe7SChris Mason parent, pslot + 1, &right); 9762cc58cf2SChris Mason if (wret) { 9772cc58cf2SChris Mason ret = wret; 9782cc58cf2SChris Mason goto enospc; 9792cc58cf2SChris Mason } 9802cc58cf2SChris Mason } 9812cc58cf2SChris Mason 9822cc58cf2SChris Mason /* first, try to make some room in the middle buffer */ 9835f39d397SChris Mason if (left) { 9845f39d397SChris Mason orig_slot += btrfs_header_nritems(left); 985bce4eae9SChris Mason wret = push_node_left(trans, root, left, mid, 1); 98679f95c82SChris Mason if (wret < 0) 98779f95c82SChris Mason ret = wret; 9885f39d397SChris Mason if (btrfs_header_nritems(mid) < 2) 98954aa1f4dSChris Mason err_on_enospc = 1; 990bb803951SChris Mason } 99179f95c82SChris Mason 99279f95c82SChris Mason /* 99379f95c82SChris Mason * then try to empty the right most buffer into the middle 99479f95c82SChris Mason */ 9955f39d397SChris Mason if (right) { 996971a1f66SChris Mason wret = push_node_left(trans, root, mid, right, 1); 99754aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 99879f95c82SChris Mason ret = wret; 9995f39d397SChris Mason if (btrfs_header_nritems(right) == 0) { 1000db94535dSChris Mason u64 bytenr = right->start; 10017bb86316SChris Mason u64 generation = btrfs_header_generation(parent); 1002db94535dSChris Mason u32 blocksize = right->len; 1003db94535dSChris Mason 10045f39d397SChris Mason clean_tree_block(trans, root, right); 1005925baeddSChris Mason btrfs_tree_unlock(right); 10065f39d397SChris Mason free_extent_buffer(right); 1007bb803951SChris Mason right = NULL; 1008e089f05cSChris Mason wret = del_ptr(trans, root, path, level + 1, pslot + 1009e089f05cSChris Mason 1); 1010bb803951SChris Mason if (wret) 1011bb803951SChris Mason ret = wret; 1012db94535dSChris Mason wret = btrfs_free_extent(trans, root, bytenr, 101331840ae1SZheng Yan blocksize, parent->start, 10147bb86316SChris Mason btrfs_header_owner(parent), 10153bb1a1bcSYan Zheng generation, level, 1); 1016bb803951SChris Mason if (wret) 1017bb803951SChris Mason ret = wret; 1018bb803951SChris Mason } else { 10195f39d397SChris Mason struct btrfs_disk_key right_key; 10205f39d397SChris Mason btrfs_node_key(right, &right_key, 0); 10215f39d397SChris Mason btrfs_set_node_key(parent, &right_key, pslot + 1); 10225f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 1023bb803951SChris Mason } 1024bb803951SChris Mason } 10255f39d397SChris Mason if (btrfs_header_nritems(mid) == 1) { 102679f95c82SChris Mason /* 102779f95c82SChris Mason * we're not allowed to leave a node with one item in the 102879f95c82SChris Mason * tree during a delete. A deletion from lower in the tree 102979f95c82SChris Mason * could try to delete the only pointer in this node. 103079f95c82SChris Mason * So, pull some keys from the left. 103179f95c82SChris Mason * There has to be a left pointer at this point because 103279f95c82SChris Mason * otherwise we would have pulled some pointers from the 103379f95c82SChris Mason * right 103479f95c82SChris Mason */ 10355f39d397SChris Mason BUG_ON(!left); 10365f39d397SChris Mason wret = balance_node_right(trans, root, mid, left); 103754aa1f4dSChris Mason if (wret < 0) { 103879f95c82SChris Mason ret = wret; 103954aa1f4dSChris Mason goto enospc; 104054aa1f4dSChris Mason } 1041bce4eae9SChris Mason if (wret == 1) { 1042bce4eae9SChris Mason wret = push_node_left(trans, root, left, mid, 1); 1043bce4eae9SChris Mason if (wret < 0) 1044bce4eae9SChris Mason ret = wret; 1045bce4eae9SChris Mason } 104679f95c82SChris Mason BUG_ON(wret == 1); 104779f95c82SChris Mason } 10485f39d397SChris Mason if (btrfs_header_nritems(mid) == 0) { 104979f95c82SChris Mason /* we've managed to empty the middle node, drop it */ 10507bb86316SChris Mason u64 root_gen = btrfs_header_generation(parent); 1051db94535dSChris Mason u64 bytenr = mid->start; 1052db94535dSChris Mason u32 blocksize = mid->len; 1053925baeddSChris Mason 10545f39d397SChris Mason clean_tree_block(trans, root, mid); 1055925baeddSChris Mason btrfs_tree_unlock(mid); 10565f39d397SChris Mason free_extent_buffer(mid); 1057bb803951SChris Mason mid = NULL; 1058e089f05cSChris Mason wret = del_ptr(trans, root, path, level + 1, pslot); 1059bb803951SChris Mason if (wret) 1060bb803951SChris Mason ret = wret; 10617bb86316SChris Mason wret = btrfs_free_extent(trans, root, bytenr, blocksize, 106231840ae1SZheng Yan parent->start, 10637bb86316SChris Mason btrfs_header_owner(parent), 10643bb1a1bcSYan Zheng root_gen, level, 1); 1065bb803951SChris Mason if (wret) 1066bb803951SChris Mason ret = wret; 106779f95c82SChris Mason } else { 106879f95c82SChris Mason /* update the parent key to reflect our changes */ 10695f39d397SChris Mason struct btrfs_disk_key mid_key; 10705f39d397SChris Mason btrfs_node_key(mid, &mid_key, 0); 10715f39d397SChris Mason btrfs_set_node_key(parent, &mid_key, pslot); 10725f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 107379f95c82SChris Mason } 1074bb803951SChris Mason 107579f95c82SChris Mason /* update the path */ 10765f39d397SChris Mason if (left) { 10775f39d397SChris Mason if (btrfs_header_nritems(left) > orig_slot) { 10785f39d397SChris Mason extent_buffer_get(left); 1079925baeddSChris Mason /* left was locked after cow */ 10805f39d397SChris Mason path->nodes[level] = left; 1081bb803951SChris Mason path->slots[level + 1] -= 1; 1082bb803951SChris Mason path->slots[level] = orig_slot; 1083925baeddSChris Mason if (mid) { 1084925baeddSChris Mason btrfs_tree_unlock(mid); 10855f39d397SChris Mason free_extent_buffer(mid); 1086925baeddSChris Mason } 1087bb803951SChris Mason } else { 10885f39d397SChris Mason orig_slot -= btrfs_header_nritems(left); 1089bb803951SChris Mason path->slots[level] = orig_slot; 1090bb803951SChris Mason } 1091bb803951SChris Mason } 109279f95c82SChris Mason /* double check we haven't messed things up */ 1093123abc88SChris Mason check_block(root, path, level); 1094e20d96d6SChris Mason if (orig_ptr != 10955f39d397SChris Mason btrfs_node_blockptr(path->nodes[level], path->slots[level])) 109679f95c82SChris Mason BUG(); 109754aa1f4dSChris Mason enospc: 1098925baeddSChris Mason if (right) { 1099925baeddSChris Mason btrfs_tree_unlock(right); 11005f39d397SChris Mason free_extent_buffer(right); 1101925baeddSChris Mason } 1102925baeddSChris Mason if (left) { 1103925baeddSChris Mason if (path->nodes[level] != left) 1104925baeddSChris Mason btrfs_tree_unlock(left); 11055f39d397SChris Mason free_extent_buffer(left); 1106925baeddSChris Mason } 1107bb803951SChris Mason return ret; 1108bb803951SChris Mason } 1109bb803951SChris Mason 1110d352ac68SChris Mason /* Node balancing for insertion. Here we only split or push nodes around 1111d352ac68SChris Mason * when they are completely full. This is also done top down, so we 1112d352ac68SChris Mason * have to be pessimistic. 1113d352ac68SChris Mason */ 1114d397712bSChris Mason static noinline int push_nodes_for_insert(struct btrfs_trans_handle *trans, 1115e66f709bSChris Mason struct btrfs_root *root, 1116e66f709bSChris Mason struct btrfs_path *path, int level) 1117e66f709bSChris Mason { 11185f39d397SChris Mason struct extent_buffer *right = NULL; 11195f39d397SChris Mason struct extent_buffer *mid; 11205f39d397SChris Mason struct extent_buffer *left = NULL; 11215f39d397SChris Mason struct extent_buffer *parent = NULL; 1122e66f709bSChris Mason int ret = 0; 1123e66f709bSChris Mason int wret; 1124e66f709bSChris Mason int pslot; 1125e66f709bSChris Mason int orig_slot = path->slots[level]; 1126e66f709bSChris Mason u64 orig_ptr; 1127e66f709bSChris Mason 1128e66f709bSChris Mason if (level == 0) 1129e66f709bSChris Mason return 1; 1130e66f709bSChris Mason 11315f39d397SChris Mason mid = path->nodes[level]; 11327bb86316SChris Mason WARN_ON(btrfs_header_generation(mid) != trans->transid); 1133e66f709bSChris Mason orig_ptr = btrfs_node_blockptr(mid, orig_slot); 1134e66f709bSChris Mason 1135e66f709bSChris Mason if (level < BTRFS_MAX_LEVEL - 1) 11365f39d397SChris Mason parent = path->nodes[level + 1]; 1137e66f709bSChris Mason pslot = path->slots[level + 1]; 1138e66f709bSChris Mason 11395f39d397SChris Mason if (!parent) 1140e66f709bSChris Mason return 1; 1141e66f709bSChris Mason 11425f39d397SChris Mason left = read_node_slot(root, parent, pslot - 1); 1143e66f709bSChris Mason 1144e66f709bSChris Mason /* first, try to make some room in the middle buffer */ 11455f39d397SChris Mason if (left) { 1146e66f709bSChris Mason u32 left_nr; 1147925baeddSChris Mason 1148925baeddSChris Mason btrfs_tree_lock(left); 1149b4ce94deSChris Mason btrfs_set_lock_blocking(left); 1150b4ce94deSChris Mason 11515f39d397SChris Mason left_nr = btrfs_header_nritems(left); 115233ade1f8SChris Mason if (left_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) { 115333ade1f8SChris Mason wret = 1; 115433ade1f8SChris Mason } else { 11555f39d397SChris Mason ret = btrfs_cow_block(trans, root, left, parent, 11569fa8cfe7SChris Mason pslot - 1, &left); 115754aa1f4dSChris Mason if (ret) 115854aa1f4dSChris Mason wret = 1; 115954aa1f4dSChris Mason else { 116054aa1f4dSChris Mason wret = push_node_left(trans, root, 1161971a1f66SChris Mason left, mid, 0); 116254aa1f4dSChris Mason } 116333ade1f8SChris Mason } 1164e66f709bSChris Mason if (wret < 0) 1165e66f709bSChris Mason ret = wret; 1166e66f709bSChris Mason if (wret == 0) { 11675f39d397SChris Mason struct btrfs_disk_key disk_key; 1168e66f709bSChris Mason orig_slot += left_nr; 11695f39d397SChris Mason btrfs_node_key(mid, &disk_key, 0); 11705f39d397SChris Mason btrfs_set_node_key(parent, &disk_key, pslot); 11715f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 11725f39d397SChris Mason if (btrfs_header_nritems(left) > orig_slot) { 11735f39d397SChris Mason path->nodes[level] = left; 1174e66f709bSChris Mason path->slots[level + 1] -= 1; 1175e66f709bSChris Mason path->slots[level] = orig_slot; 1176925baeddSChris Mason btrfs_tree_unlock(mid); 11775f39d397SChris Mason free_extent_buffer(mid); 1178e66f709bSChris Mason } else { 1179e66f709bSChris Mason orig_slot -= 11805f39d397SChris Mason btrfs_header_nritems(left); 1181e66f709bSChris Mason path->slots[level] = orig_slot; 1182925baeddSChris Mason btrfs_tree_unlock(left); 11835f39d397SChris Mason free_extent_buffer(left); 1184e66f709bSChris Mason } 1185e66f709bSChris Mason return 0; 1186e66f709bSChris Mason } 1187925baeddSChris Mason btrfs_tree_unlock(left); 11885f39d397SChris Mason free_extent_buffer(left); 1189e66f709bSChris Mason } 11905f39d397SChris Mason right = read_node_slot(root, parent, pslot + 1); 1191e66f709bSChris Mason 1192e66f709bSChris Mason /* 1193e66f709bSChris Mason * then try to empty the right most buffer into the middle 1194e66f709bSChris Mason */ 11955f39d397SChris Mason if (right) { 119633ade1f8SChris Mason u32 right_nr; 1197b4ce94deSChris Mason 1198925baeddSChris Mason btrfs_tree_lock(right); 1199b4ce94deSChris Mason btrfs_set_lock_blocking(right); 1200b4ce94deSChris Mason 12015f39d397SChris Mason right_nr = btrfs_header_nritems(right); 120233ade1f8SChris Mason if (right_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) { 120333ade1f8SChris Mason wret = 1; 120433ade1f8SChris Mason } else { 12055f39d397SChris Mason ret = btrfs_cow_block(trans, root, right, 12065f39d397SChris Mason parent, pslot + 1, 12079fa8cfe7SChris Mason &right); 120854aa1f4dSChris Mason if (ret) 120954aa1f4dSChris Mason wret = 1; 121054aa1f4dSChris Mason else { 121133ade1f8SChris Mason wret = balance_node_right(trans, root, 12125f39d397SChris Mason right, mid); 121333ade1f8SChris Mason } 121454aa1f4dSChris Mason } 1215e66f709bSChris Mason if (wret < 0) 1216e66f709bSChris Mason ret = wret; 1217e66f709bSChris Mason if (wret == 0) { 12185f39d397SChris Mason struct btrfs_disk_key disk_key; 12195f39d397SChris Mason 12205f39d397SChris Mason btrfs_node_key(right, &disk_key, 0); 12215f39d397SChris Mason btrfs_set_node_key(parent, &disk_key, pslot + 1); 12225f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 12235f39d397SChris Mason 12245f39d397SChris Mason if (btrfs_header_nritems(mid) <= orig_slot) { 12255f39d397SChris Mason path->nodes[level] = right; 1226e66f709bSChris Mason path->slots[level + 1] += 1; 1227e66f709bSChris Mason path->slots[level] = orig_slot - 12285f39d397SChris Mason btrfs_header_nritems(mid); 1229925baeddSChris Mason btrfs_tree_unlock(mid); 12305f39d397SChris Mason free_extent_buffer(mid); 1231e66f709bSChris Mason } else { 1232925baeddSChris Mason btrfs_tree_unlock(right); 12335f39d397SChris Mason free_extent_buffer(right); 1234e66f709bSChris Mason } 1235e66f709bSChris Mason return 0; 1236e66f709bSChris Mason } 1237925baeddSChris Mason btrfs_tree_unlock(right); 12385f39d397SChris Mason free_extent_buffer(right); 1239e66f709bSChris Mason } 1240e66f709bSChris Mason return 1; 1241e66f709bSChris Mason } 1242e66f709bSChris Mason 124374123bd7SChris Mason /* 1244d352ac68SChris Mason * readahead one full node of leaves, finding things that are close 1245d352ac68SChris Mason * to the block in 'slot', and triggering ra on them. 12463c69faecSChris Mason */ 1247c8c42864SChris Mason static void reada_for_search(struct btrfs_root *root, 1248e02119d5SChris Mason struct btrfs_path *path, 124901f46658SChris Mason int level, int slot, u64 objectid) 12503c69faecSChris Mason { 12515f39d397SChris Mason struct extent_buffer *node; 125201f46658SChris Mason struct btrfs_disk_key disk_key; 12533c69faecSChris Mason u32 nritems; 12543c69faecSChris Mason u64 search; 1255a7175319SChris Mason u64 target; 12566b80053dSChris Mason u64 nread = 0; 12573c69faecSChris Mason int direction = path->reada; 12585f39d397SChris Mason struct extent_buffer *eb; 12596b80053dSChris Mason u32 nr; 12606b80053dSChris Mason u32 blocksize; 12616b80053dSChris Mason u32 nscan = 0; 1262db94535dSChris Mason 1263a6b6e75eSChris Mason if (level != 1) 12643c69faecSChris Mason return; 12653c69faecSChris Mason 12666702ed49SChris Mason if (!path->nodes[level]) 12676702ed49SChris Mason return; 12686702ed49SChris Mason 12695f39d397SChris Mason node = path->nodes[level]; 1270925baeddSChris Mason 12713c69faecSChris Mason search = btrfs_node_blockptr(node, slot); 12726b80053dSChris Mason blocksize = btrfs_level_size(root, level - 1); 12736b80053dSChris Mason eb = btrfs_find_tree_block(root, search, blocksize); 12745f39d397SChris Mason if (eb) { 12755f39d397SChris Mason free_extent_buffer(eb); 12763c69faecSChris Mason return; 12773c69faecSChris Mason } 12783c69faecSChris Mason 1279a7175319SChris Mason target = search; 12806b80053dSChris Mason 12815f39d397SChris Mason nritems = btrfs_header_nritems(node); 12826b80053dSChris Mason nr = slot; 12833c69faecSChris Mason while (1) { 12846b80053dSChris Mason if (direction < 0) { 12856b80053dSChris Mason if (nr == 0) 12863c69faecSChris Mason break; 12876b80053dSChris Mason nr--; 12886b80053dSChris Mason } else if (direction > 0) { 12896b80053dSChris Mason nr++; 12906b80053dSChris Mason if (nr >= nritems) 12916b80053dSChris Mason break; 12923c69faecSChris Mason } 129301f46658SChris Mason if (path->reada < 0 && objectid) { 129401f46658SChris Mason btrfs_node_key(node, &disk_key, nr); 129501f46658SChris Mason if (btrfs_disk_key_objectid(&disk_key) != objectid) 129601f46658SChris Mason break; 129701f46658SChris Mason } 12986b80053dSChris Mason search = btrfs_node_blockptr(node, nr); 1299a7175319SChris Mason if ((search <= target && target - search <= 65536) || 1300a7175319SChris Mason (search > target && search - target <= 65536)) { 1301ca7a79adSChris Mason readahead_tree_block(root, search, blocksize, 1302ca7a79adSChris Mason btrfs_node_ptr_generation(node, nr)); 13036b80053dSChris Mason nread += blocksize; 13043c69faecSChris Mason } 13056b80053dSChris Mason nscan++; 1306a7175319SChris Mason if ((nread > 65536 || nscan > 32)) 13076b80053dSChris Mason break; 13083c69faecSChris Mason } 13093c69faecSChris Mason } 1310925baeddSChris Mason 1311d352ac68SChris Mason /* 1312b4ce94deSChris Mason * returns -EAGAIN if it had to drop the path, or zero if everything was in 1313b4ce94deSChris Mason * cache 1314b4ce94deSChris Mason */ 1315b4ce94deSChris Mason static noinline int reada_for_balance(struct btrfs_root *root, 1316b4ce94deSChris Mason struct btrfs_path *path, int level) 1317b4ce94deSChris Mason { 1318b4ce94deSChris Mason int slot; 1319b4ce94deSChris Mason int nritems; 1320b4ce94deSChris Mason struct extent_buffer *parent; 1321b4ce94deSChris Mason struct extent_buffer *eb; 1322b4ce94deSChris Mason u64 gen; 1323b4ce94deSChris Mason u64 block1 = 0; 1324b4ce94deSChris Mason u64 block2 = 0; 1325b4ce94deSChris Mason int ret = 0; 1326b4ce94deSChris Mason int blocksize; 1327b4ce94deSChris Mason 13288c594ea8SChris Mason parent = path->nodes[level + 1]; 1329b4ce94deSChris Mason if (!parent) 1330b4ce94deSChris Mason return 0; 1331b4ce94deSChris Mason 1332b4ce94deSChris Mason nritems = btrfs_header_nritems(parent); 13338c594ea8SChris Mason slot = path->slots[level + 1]; 1334b4ce94deSChris Mason blocksize = btrfs_level_size(root, level); 1335b4ce94deSChris Mason 1336b4ce94deSChris Mason if (slot > 0) { 1337b4ce94deSChris Mason block1 = btrfs_node_blockptr(parent, slot - 1); 1338b4ce94deSChris Mason gen = btrfs_node_ptr_generation(parent, slot - 1); 1339b4ce94deSChris Mason eb = btrfs_find_tree_block(root, block1, blocksize); 1340b4ce94deSChris Mason if (eb && btrfs_buffer_uptodate(eb, gen)) 1341b4ce94deSChris Mason block1 = 0; 1342b4ce94deSChris Mason free_extent_buffer(eb); 1343b4ce94deSChris Mason } 13448c594ea8SChris Mason if (slot + 1 < nritems) { 1345b4ce94deSChris Mason block2 = btrfs_node_blockptr(parent, slot + 1); 1346b4ce94deSChris Mason gen = btrfs_node_ptr_generation(parent, slot + 1); 1347b4ce94deSChris Mason eb = btrfs_find_tree_block(root, block2, blocksize); 1348b4ce94deSChris Mason if (eb && btrfs_buffer_uptodate(eb, gen)) 1349b4ce94deSChris Mason block2 = 0; 1350b4ce94deSChris Mason free_extent_buffer(eb); 1351b4ce94deSChris Mason } 1352b4ce94deSChris Mason if (block1 || block2) { 1353b4ce94deSChris Mason ret = -EAGAIN; 13548c594ea8SChris Mason 13558c594ea8SChris Mason /* release the whole path */ 1356b4ce94deSChris Mason btrfs_release_path(root, path); 13578c594ea8SChris Mason 13588c594ea8SChris Mason /* read the blocks */ 1359b4ce94deSChris Mason if (block1) 1360b4ce94deSChris Mason readahead_tree_block(root, block1, blocksize, 0); 1361b4ce94deSChris Mason if (block2) 1362b4ce94deSChris Mason readahead_tree_block(root, block2, blocksize, 0); 1363b4ce94deSChris Mason 1364b4ce94deSChris Mason if (block1) { 1365b4ce94deSChris Mason eb = read_tree_block(root, block1, blocksize, 0); 1366b4ce94deSChris Mason free_extent_buffer(eb); 1367b4ce94deSChris Mason } 13688c594ea8SChris Mason if (block2) { 1369b4ce94deSChris Mason eb = read_tree_block(root, block2, blocksize, 0); 1370b4ce94deSChris Mason free_extent_buffer(eb); 1371b4ce94deSChris Mason } 1372b4ce94deSChris Mason } 1373b4ce94deSChris Mason return ret; 1374b4ce94deSChris Mason } 1375b4ce94deSChris Mason 1376b4ce94deSChris Mason 1377b4ce94deSChris Mason /* 1378d397712bSChris Mason * when we walk down the tree, it is usually safe to unlock the higher layers 1379d397712bSChris Mason * in the tree. The exceptions are when our path goes through slot 0, because 1380d397712bSChris Mason * operations on the tree might require changing key pointers higher up in the 1381d397712bSChris Mason * tree. 1382d352ac68SChris Mason * 1383d397712bSChris Mason * callers might also have set path->keep_locks, which tells this code to keep 1384d397712bSChris Mason * the lock if the path points to the last slot in the block. This is part of 1385d397712bSChris Mason * walking through the tree, and selecting the next slot in the higher block. 1386d352ac68SChris Mason * 1387d397712bSChris Mason * lowest_unlock sets the lowest level in the tree we're allowed to unlock. so 1388d397712bSChris Mason * if lowest_unlock is 1, level 0 won't be unlocked 1389d352ac68SChris Mason */ 1390e02119d5SChris Mason static noinline void unlock_up(struct btrfs_path *path, int level, 1391e02119d5SChris Mason int lowest_unlock) 1392925baeddSChris Mason { 1393925baeddSChris Mason int i; 1394925baeddSChris Mason int skip_level = level; 1395051e1b9fSChris Mason int no_skips = 0; 1396925baeddSChris Mason struct extent_buffer *t; 1397925baeddSChris Mason 1398925baeddSChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1399925baeddSChris Mason if (!path->nodes[i]) 1400925baeddSChris Mason break; 1401925baeddSChris Mason if (!path->locks[i]) 1402925baeddSChris Mason break; 1403051e1b9fSChris Mason if (!no_skips && path->slots[i] == 0) { 1404925baeddSChris Mason skip_level = i + 1; 1405925baeddSChris Mason continue; 1406925baeddSChris Mason } 1407051e1b9fSChris Mason if (!no_skips && path->keep_locks) { 1408925baeddSChris Mason u32 nritems; 1409925baeddSChris Mason t = path->nodes[i]; 1410925baeddSChris Mason nritems = btrfs_header_nritems(t); 1411051e1b9fSChris Mason if (nritems < 1 || path->slots[i] >= nritems - 1) { 1412925baeddSChris Mason skip_level = i + 1; 1413925baeddSChris Mason continue; 1414925baeddSChris Mason } 1415925baeddSChris Mason } 1416051e1b9fSChris Mason if (skip_level < i && i >= lowest_unlock) 1417051e1b9fSChris Mason no_skips = 1; 1418051e1b9fSChris Mason 1419925baeddSChris Mason t = path->nodes[i]; 1420925baeddSChris Mason if (i >= lowest_unlock && i > skip_level && path->locks[i]) { 1421925baeddSChris Mason btrfs_tree_unlock(t); 1422925baeddSChris Mason path->locks[i] = 0; 1423925baeddSChris Mason } 1424925baeddSChris Mason } 1425925baeddSChris Mason } 1426925baeddSChris Mason 14273c69faecSChris Mason /* 1428b4ce94deSChris Mason * This releases any locks held in the path starting at level and 1429b4ce94deSChris Mason * going all the way up to the root. 1430b4ce94deSChris Mason * 1431b4ce94deSChris Mason * btrfs_search_slot will keep the lock held on higher nodes in a few 1432b4ce94deSChris Mason * corner cases, such as COW of the block at slot zero in the node. This 1433b4ce94deSChris Mason * ignores those rules, and it should only be called when there are no 1434b4ce94deSChris Mason * more updates to be done higher up in the tree. 1435b4ce94deSChris Mason */ 1436b4ce94deSChris Mason noinline void btrfs_unlock_up_safe(struct btrfs_path *path, int level) 1437b4ce94deSChris Mason { 1438b4ce94deSChris Mason int i; 1439b4ce94deSChris Mason 1440b4ce94deSChris Mason if (path->keep_locks || path->lowest_level) 1441b4ce94deSChris Mason return; 1442b4ce94deSChris Mason 1443b4ce94deSChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1444b4ce94deSChris Mason if (!path->nodes[i]) 144512f4daccSChris Mason continue; 1446b4ce94deSChris Mason if (!path->locks[i]) 144712f4daccSChris Mason continue; 1448b4ce94deSChris Mason btrfs_tree_unlock(path->nodes[i]); 1449b4ce94deSChris Mason path->locks[i] = 0; 1450b4ce94deSChris Mason } 1451b4ce94deSChris Mason } 1452b4ce94deSChris Mason 1453b4ce94deSChris Mason /* 1454c8c42864SChris Mason * helper function for btrfs_search_slot. The goal is to find a block 1455c8c42864SChris Mason * in cache without setting the path to blocking. If we find the block 1456c8c42864SChris Mason * we return zero and the path is unchanged. 1457c8c42864SChris Mason * 1458c8c42864SChris Mason * If we can't find the block, we set the path blocking and do some 1459c8c42864SChris Mason * reada. -EAGAIN is returned and the search must be repeated. 1460c8c42864SChris Mason */ 1461c8c42864SChris Mason static int 1462c8c42864SChris Mason read_block_for_search(struct btrfs_trans_handle *trans, 1463c8c42864SChris Mason struct btrfs_root *root, struct btrfs_path *p, 1464c8c42864SChris Mason struct extent_buffer **eb_ret, int level, int slot, 1465c8c42864SChris Mason struct btrfs_key *key) 1466c8c42864SChris Mason { 1467c8c42864SChris Mason u64 blocknr; 1468c8c42864SChris Mason u64 gen; 1469c8c42864SChris Mason u32 blocksize; 1470c8c42864SChris Mason struct extent_buffer *b = *eb_ret; 1471c8c42864SChris Mason struct extent_buffer *tmp; 1472*76a05b35SChris Mason int ret; 1473c8c42864SChris Mason 1474c8c42864SChris Mason blocknr = btrfs_node_blockptr(b, slot); 1475c8c42864SChris Mason gen = btrfs_node_ptr_generation(b, slot); 1476c8c42864SChris Mason blocksize = btrfs_level_size(root, level - 1); 1477c8c42864SChris Mason 1478c8c42864SChris Mason tmp = btrfs_find_tree_block(root, blocknr, blocksize); 1479c8c42864SChris Mason if (tmp && btrfs_buffer_uptodate(tmp, gen)) { 1480*76a05b35SChris Mason /* 1481*76a05b35SChris Mason * we found an up to date block without sleeping, return 1482*76a05b35SChris Mason * right away 1483*76a05b35SChris Mason */ 1484c8c42864SChris Mason *eb_ret = tmp; 1485c8c42864SChris Mason return 0; 1486c8c42864SChris Mason } 1487c8c42864SChris Mason 1488c8c42864SChris Mason /* 1489c8c42864SChris Mason * reduce lock contention at high levels 1490c8c42864SChris Mason * of the btree by dropping locks before 1491*76a05b35SChris Mason * we read. Don't release the lock on the current 1492*76a05b35SChris Mason * level because we need to walk this node to figure 1493*76a05b35SChris Mason * out which blocks to read. 1494c8c42864SChris Mason */ 14958c594ea8SChris Mason btrfs_unlock_up_safe(p, level + 1); 14968c594ea8SChris Mason btrfs_set_path_blocking(p); 14978c594ea8SChris Mason 1498c8c42864SChris Mason if (tmp) 1499c8c42864SChris Mason free_extent_buffer(tmp); 1500c8c42864SChris Mason if (p->reada) 1501c8c42864SChris Mason reada_for_search(root, p, level, slot, key->objectid); 1502c8c42864SChris Mason 15038c594ea8SChris Mason btrfs_release_path(NULL, p); 1504*76a05b35SChris Mason 1505*76a05b35SChris Mason ret = -EAGAIN; 1506c8c42864SChris Mason tmp = read_tree_block(root, blocknr, blocksize, gen); 1507*76a05b35SChris Mason if (tmp) { 1508*76a05b35SChris Mason /* 1509*76a05b35SChris Mason * If the read above didn't mark this buffer up to date, 1510*76a05b35SChris Mason * it will never end up being up to date. Set ret to EIO now 1511*76a05b35SChris Mason * and give up so that our caller doesn't loop forever 1512*76a05b35SChris Mason * on our EAGAINs. 1513*76a05b35SChris Mason */ 1514*76a05b35SChris Mason if (!btrfs_buffer_uptodate(tmp, 0)) 1515*76a05b35SChris Mason ret = -EIO; 1516c8c42864SChris Mason free_extent_buffer(tmp); 1517*76a05b35SChris Mason } 1518*76a05b35SChris Mason return ret; 1519c8c42864SChris Mason } 1520c8c42864SChris Mason 1521c8c42864SChris Mason /* 1522c8c42864SChris Mason * helper function for btrfs_search_slot. This does all of the checks 1523c8c42864SChris Mason * for node-level blocks and does any balancing required based on 1524c8c42864SChris Mason * the ins_len. 1525c8c42864SChris Mason * 1526c8c42864SChris Mason * If no extra work was required, zero is returned. If we had to 1527c8c42864SChris Mason * drop the path, -EAGAIN is returned and btrfs_search_slot must 1528c8c42864SChris Mason * start over 1529c8c42864SChris Mason */ 1530c8c42864SChris Mason static int 1531c8c42864SChris Mason setup_nodes_for_search(struct btrfs_trans_handle *trans, 1532c8c42864SChris Mason struct btrfs_root *root, struct btrfs_path *p, 1533c8c42864SChris Mason struct extent_buffer *b, int level, int ins_len) 1534c8c42864SChris Mason { 1535c8c42864SChris Mason int ret; 1536c8c42864SChris Mason if ((p->search_for_split || ins_len > 0) && btrfs_header_nritems(b) >= 1537c8c42864SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) - 3) { 1538c8c42864SChris Mason int sret; 1539c8c42864SChris Mason 1540c8c42864SChris Mason sret = reada_for_balance(root, p, level); 1541c8c42864SChris Mason if (sret) 1542c8c42864SChris Mason goto again; 1543c8c42864SChris Mason 1544c8c42864SChris Mason btrfs_set_path_blocking(p); 1545c8c42864SChris Mason sret = split_node(trans, root, p, level); 1546c8c42864SChris Mason btrfs_clear_path_blocking(p, NULL); 1547c8c42864SChris Mason 1548c8c42864SChris Mason BUG_ON(sret > 0); 1549c8c42864SChris Mason if (sret) { 1550c8c42864SChris Mason ret = sret; 1551c8c42864SChris Mason goto done; 1552c8c42864SChris Mason } 1553c8c42864SChris Mason b = p->nodes[level]; 1554c8c42864SChris Mason } else if (ins_len < 0 && btrfs_header_nritems(b) < 1555c8c42864SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) / 4) { 1556c8c42864SChris Mason int sret; 1557c8c42864SChris Mason 1558c8c42864SChris Mason sret = reada_for_balance(root, p, level); 1559c8c42864SChris Mason if (sret) 1560c8c42864SChris Mason goto again; 1561c8c42864SChris Mason 1562c8c42864SChris Mason btrfs_set_path_blocking(p); 1563c8c42864SChris Mason sret = balance_level(trans, root, p, level); 1564c8c42864SChris Mason btrfs_clear_path_blocking(p, NULL); 1565c8c42864SChris Mason 1566c8c42864SChris Mason if (sret) { 1567c8c42864SChris Mason ret = sret; 1568c8c42864SChris Mason goto done; 1569c8c42864SChris Mason } 1570c8c42864SChris Mason b = p->nodes[level]; 1571c8c42864SChris Mason if (!b) { 1572c8c42864SChris Mason btrfs_release_path(NULL, p); 1573c8c42864SChris Mason goto again; 1574c8c42864SChris Mason } 1575c8c42864SChris Mason BUG_ON(btrfs_header_nritems(b) == 1); 1576c8c42864SChris Mason } 1577c8c42864SChris Mason return 0; 1578c8c42864SChris Mason 1579c8c42864SChris Mason again: 1580c8c42864SChris Mason ret = -EAGAIN; 1581c8c42864SChris Mason done: 1582c8c42864SChris Mason return ret; 1583c8c42864SChris Mason } 1584c8c42864SChris Mason 1585c8c42864SChris Mason /* 158674123bd7SChris Mason * look for key in the tree. path is filled in with nodes along the way 158774123bd7SChris Mason * if key is found, we return zero and you can find the item in the leaf 158874123bd7SChris Mason * level of the path (level 0) 158974123bd7SChris Mason * 159074123bd7SChris Mason * If the key isn't found, the path points to the slot where it should 1591aa5d6bedSChris Mason * be inserted, and 1 is returned. If there are other errors during the 1592aa5d6bedSChris Mason * search a negative error number is returned. 159397571fd0SChris Mason * 159497571fd0SChris Mason * if ins_len > 0, nodes and leaves will be split as we walk down the 159597571fd0SChris Mason * tree. if ins_len < 0, nodes will be merged as we walk down the tree (if 159697571fd0SChris Mason * possible) 159774123bd7SChris Mason */ 1598e089f05cSChris Mason int btrfs_search_slot(struct btrfs_trans_handle *trans, struct btrfs_root 1599e089f05cSChris Mason *root, struct btrfs_key *key, struct btrfs_path *p, int 1600e089f05cSChris Mason ins_len, int cow) 1601be0e5c09SChris Mason { 16025f39d397SChris Mason struct extent_buffer *b; 1603be0e5c09SChris Mason int slot; 1604be0e5c09SChris Mason int ret; 1605be0e5c09SChris Mason int level; 1606925baeddSChris Mason int lowest_unlock = 1; 16079f3a7427SChris Mason u8 lowest_level = 0; 16089f3a7427SChris Mason 16096702ed49SChris Mason lowest_level = p->lowest_level; 1610323ac95bSChris Mason WARN_ON(lowest_level && ins_len > 0); 161122b0ebdaSChris Mason WARN_ON(p->nodes[0] != NULL); 161225179201SJosef Bacik 1613925baeddSChris Mason if (ins_len < 0) 1614925baeddSChris Mason lowest_unlock = 2; 161565b51a00SChris Mason 1616bb803951SChris Mason again: 16175cd57b2cSChris Mason if (p->skip_locking) 16185cd57b2cSChris Mason b = btrfs_root_node(root); 16195cd57b2cSChris Mason else 1620925baeddSChris Mason b = btrfs_lock_root_node(root); 1621925baeddSChris Mason 1622eb60ceacSChris Mason while (b) { 16235f39d397SChris Mason level = btrfs_header_level(b); 162465b51a00SChris Mason 162565b51a00SChris Mason /* 162665b51a00SChris Mason * setup the path here so we can release it under lock 162765b51a00SChris Mason * contention with the cow code 162865b51a00SChris Mason */ 162965b51a00SChris Mason p->nodes[level] = b; 163065b51a00SChris Mason if (!p->skip_locking) 163165b51a00SChris Mason p->locks[level] = 1; 163265b51a00SChris Mason 163302217ed2SChris Mason if (cow) { 163402217ed2SChris Mason int wret; 163565b51a00SChris Mason 1636c8c42864SChris Mason /* 1637c8c42864SChris Mason * if we don't really need to cow this block 1638c8c42864SChris Mason * then we don't want to set the path blocking, 1639c8c42864SChris Mason * so we test it here 1640c8c42864SChris Mason */ 164165b51a00SChris Mason if (btrfs_header_generation(b) == trans->transid && 16425b21f2edSZheng Yan btrfs_header_owner(b) == root->root_key.objectid && 164365b51a00SChris Mason !btrfs_header_flag(b, BTRFS_HEADER_FLAG_WRITTEN)) { 164465b51a00SChris Mason goto cow_done; 164565b51a00SChris Mason } 1646b4ce94deSChris Mason btrfs_set_path_blocking(p); 1647b4ce94deSChris Mason 1648e20d96d6SChris Mason wret = btrfs_cow_block(trans, root, b, 1649e20d96d6SChris Mason p->nodes[level + 1], 16509fa8cfe7SChris Mason p->slots[level + 1], &b); 165154aa1f4dSChris Mason if (wret) { 16525f39d397SChris Mason free_extent_buffer(b); 165365b51a00SChris Mason ret = wret; 165465b51a00SChris Mason goto done; 165554aa1f4dSChris Mason } 165602217ed2SChris Mason } 165765b51a00SChris Mason cow_done: 165802217ed2SChris Mason BUG_ON(!cow && ins_len); 16595f39d397SChris Mason if (level != btrfs_header_level(b)) 16602c90e5d6SChris Mason WARN_ON(1); 16615f39d397SChris Mason level = btrfs_header_level(b); 166265b51a00SChris Mason 1663eb60ceacSChris Mason p->nodes[level] = b; 16645cd57b2cSChris Mason if (!p->skip_locking) 1665925baeddSChris Mason p->locks[level] = 1; 166665b51a00SChris Mason 16674008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 1668b4ce94deSChris Mason 1669b4ce94deSChris Mason /* 1670b4ce94deSChris Mason * we have a lock on b and as long as we aren't changing 1671b4ce94deSChris Mason * the tree, there is no way to for the items in b to change. 1672b4ce94deSChris Mason * It is safe to drop the lock on our parent before we 1673b4ce94deSChris Mason * go through the expensive btree search on b. 1674b4ce94deSChris Mason * 1675b4ce94deSChris Mason * If cow is true, then we might be changing slot zero, 1676b4ce94deSChris Mason * which may require changing the parent. So, we can't 1677b4ce94deSChris Mason * drop the lock until after we know which slot we're 1678b4ce94deSChris Mason * operating on. 1679b4ce94deSChris Mason */ 1680b4ce94deSChris Mason if (!cow) 1681b4ce94deSChris Mason btrfs_unlock_up_safe(p, level + 1); 1682b4ce94deSChris Mason 1683123abc88SChris Mason ret = check_block(root, p, level); 168465b51a00SChris Mason if (ret) { 168565b51a00SChris Mason ret = -1; 168665b51a00SChris Mason goto done; 168765b51a00SChris Mason } 1688925baeddSChris Mason 16895f39d397SChris Mason ret = bin_search(b, key, level, &slot); 1690b4ce94deSChris Mason 16915f39d397SChris Mason if (level != 0) { 1692be0e5c09SChris Mason if (ret && slot > 0) 1693be0e5c09SChris Mason slot -= 1; 1694be0e5c09SChris Mason p->slots[level] = slot; 1695c8c42864SChris Mason ret = setup_nodes_for_search(trans, root, p, b, level, 1696c8c42864SChris Mason ins_len); 1697c8c42864SChris Mason if (ret == -EAGAIN) 1698b4ce94deSChris Mason goto again; 1699c8c42864SChris Mason else if (ret) 170065b51a00SChris Mason goto done; 17015c680ed6SChris Mason b = p->nodes[level]; 17025c680ed6SChris Mason slot = p->slots[level]; 1703b4ce94deSChris Mason 1704f9efa9c7SChris Mason unlock_up(p, level, lowest_unlock); 1705f9efa9c7SChris Mason 17069f3a7427SChris Mason /* this is only true while dropping a snapshot */ 1707925baeddSChris Mason if (level == lowest_level) { 17085b21f2edSZheng Yan ret = 0; 17095b21f2edSZheng Yan goto done; 1710925baeddSChris Mason } 1711ca7a79adSChris Mason 1712c8c42864SChris Mason ret = read_block_for_search(trans, root, p, 1713c8c42864SChris Mason &b, level, slot, key); 1714c8c42864SChris Mason if (ret == -EAGAIN) 1715051e1b9fSChris Mason goto again; 1716c8c42864SChris Mason 1717*76a05b35SChris Mason if (ret == -EIO) 1718*76a05b35SChris Mason goto done; 1719*76a05b35SChris Mason 1720b4ce94deSChris Mason if (!p->skip_locking) { 1721b4ce94deSChris Mason int lret; 1722b4ce94deSChris Mason 17234008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 1724b4ce94deSChris Mason lret = btrfs_try_spin_lock(b); 1725b4ce94deSChris Mason 1726b4ce94deSChris Mason if (!lret) { 1727b4ce94deSChris Mason btrfs_set_path_blocking(p); 1728925baeddSChris Mason btrfs_tree_lock(b); 17294008c04aSChris Mason btrfs_clear_path_blocking(p, b); 1730b4ce94deSChris Mason } 1731b4ce94deSChris Mason } 1732be0e5c09SChris Mason } else { 1733be0e5c09SChris Mason p->slots[level] = slot; 173487b29b20SYan Zheng if (ins_len > 0 && 173587b29b20SYan Zheng btrfs_leaf_free_space(root, b) < ins_len) { 1736b4ce94deSChris Mason int sret; 1737b4ce94deSChris Mason 1738b4ce94deSChris Mason btrfs_set_path_blocking(p); 1739b4ce94deSChris Mason sret = split_leaf(trans, root, key, 1740cc0c5538SChris Mason p, ins_len, ret == 0); 17414008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 1742b4ce94deSChris Mason 17435c680ed6SChris Mason BUG_ON(sret > 0); 174465b51a00SChris Mason if (sret) { 174565b51a00SChris Mason ret = sret; 174665b51a00SChris Mason goto done; 174765b51a00SChris Mason } 17485c680ed6SChris Mason } 1749459931ecSChris Mason if (!p->search_for_split) 1750925baeddSChris Mason unlock_up(p, level, lowest_unlock); 175165b51a00SChris Mason goto done; 175265b51a00SChris Mason } 175365b51a00SChris Mason } 175465b51a00SChris Mason ret = 1; 175565b51a00SChris Mason done: 1756b4ce94deSChris Mason /* 1757b4ce94deSChris Mason * we don't really know what they plan on doing with the path 1758b4ce94deSChris Mason * from here on, so for now just mark it as blocking 1759b4ce94deSChris Mason */ 1760b9473439SChris Mason if (!p->leave_spinning) 1761b4ce94deSChris Mason btrfs_set_path_blocking(p); 1762*76a05b35SChris Mason if (ret < 0) 1763*76a05b35SChris Mason btrfs_release_path(root, p); 1764be0e5c09SChris Mason return ret; 1765be0e5c09SChris Mason } 1766be0e5c09SChris Mason 17671a40e23bSZheng Yan int btrfs_merge_path(struct btrfs_trans_handle *trans, 17681a40e23bSZheng Yan struct btrfs_root *root, 17691a40e23bSZheng Yan struct btrfs_key *node_keys, 17701a40e23bSZheng Yan u64 *nodes, int lowest_level) 17711a40e23bSZheng Yan { 17721a40e23bSZheng Yan struct extent_buffer *eb; 17731a40e23bSZheng Yan struct extent_buffer *parent; 17741a40e23bSZheng Yan struct btrfs_key key; 17751a40e23bSZheng Yan u64 bytenr; 17761a40e23bSZheng Yan u64 generation; 17771a40e23bSZheng Yan u32 blocksize; 17781a40e23bSZheng Yan int level; 17791a40e23bSZheng Yan int slot; 17801a40e23bSZheng Yan int key_match; 17811a40e23bSZheng Yan int ret; 17821a40e23bSZheng Yan 17831a40e23bSZheng Yan eb = btrfs_lock_root_node(root); 17849fa8cfe7SChris Mason ret = btrfs_cow_block(trans, root, eb, NULL, 0, &eb); 17851a40e23bSZheng Yan BUG_ON(ret); 17861a40e23bSZheng Yan 1787b4ce94deSChris Mason btrfs_set_lock_blocking(eb); 1788b4ce94deSChris Mason 17891a40e23bSZheng Yan parent = eb; 17901a40e23bSZheng Yan while (1) { 17911a40e23bSZheng Yan level = btrfs_header_level(parent); 17921a40e23bSZheng Yan if (level == 0 || level <= lowest_level) 17931a40e23bSZheng Yan break; 17941a40e23bSZheng Yan 17951a40e23bSZheng Yan ret = bin_search(parent, &node_keys[lowest_level], level, 17961a40e23bSZheng Yan &slot); 17971a40e23bSZheng Yan if (ret && slot > 0) 17981a40e23bSZheng Yan slot--; 17991a40e23bSZheng Yan 18001a40e23bSZheng Yan bytenr = btrfs_node_blockptr(parent, slot); 18011a40e23bSZheng Yan if (nodes[level - 1] == bytenr) 18021a40e23bSZheng Yan break; 18031a40e23bSZheng Yan 18041a40e23bSZheng Yan blocksize = btrfs_level_size(root, level - 1); 18051a40e23bSZheng Yan generation = btrfs_node_ptr_generation(parent, slot); 18061a40e23bSZheng Yan btrfs_node_key_to_cpu(eb, &key, slot); 18071a40e23bSZheng Yan key_match = !memcmp(&key, &node_keys[level - 1], sizeof(key)); 18081a40e23bSZheng Yan 1809f82d02d9SYan Zheng if (generation == trans->transid) { 18101a40e23bSZheng Yan eb = read_tree_block(root, bytenr, blocksize, 18111a40e23bSZheng Yan generation); 18121a40e23bSZheng Yan btrfs_tree_lock(eb); 1813b4ce94deSChris Mason btrfs_set_lock_blocking(eb); 1814f82d02d9SYan Zheng } 1815f82d02d9SYan Zheng 1816f82d02d9SYan Zheng /* 1817f82d02d9SYan Zheng * if node keys match and node pointer hasn't been modified 1818f82d02d9SYan Zheng * in the running transaction, we can merge the path. for 1819f82d02d9SYan Zheng * blocks owened by reloc trees, the node pointer check is 1820f82d02d9SYan Zheng * skipped, this is because these blocks are fully controlled 1821f82d02d9SYan Zheng * by the space balance code, no one else can modify them. 1822f82d02d9SYan Zheng */ 1823f82d02d9SYan Zheng if (!nodes[level - 1] || !key_match || 1824f82d02d9SYan Zheng (generation == trans->transid && 1825f82d02d9SYan Zheng btrfs_header_owner(eb) != BTRFS_TREE_RELOC_OBJECTID)) { 1826f82d02d9SYan Zheng if (level == 1 || level == lowest_level + 1) { 1827f82d02d9SYan Zheng if (generation == trans->transid) { 1828f82d02d9SYan Zheng btrfs_tree_unlock(eb); 1829f82d02d9SYan Zheng free_extent_buffer(eb); 1830f82d02d9SYan Zheng } 1831f82d02d9SYan Zheng break; 1832f82d02d9SYan Zheng } 1833f82d02d9SYan Zheng 1834f82d02d9SYan Zheng if (generation != trans->transid) { 1835f82d02d9SYan Zheng eb = read_tree_block(root, bytenr, blocksize, 1836f82d02d9SYan Zheng generation); 1837f82d02d9SYan Zheng btrfs_tree_lock(eb); 1838b4ce94deSChris Mason btrfs_set_lock_blocking(eb); 1839f82d02d9SYan Zheng } 18401a40e23bSZheng Yan 18411a40e23bSZheng Yan ret = btrfs_cow_block(trans, root, eb, parent, slot, 18429fa8cfe7SChris Mason &eb); 18431a40e23bSZheng Yan BUG_ON(ret); 18441a40e23bSZheng Yan 1845f82d02d9SYan Zheng if (root->root_key.objectid == 1846f82d02d9SYan Zheng BTRFS_TREE_RELOC_OBJECTID) { 1847f82d02d9SYan Zheng if (!nodes[level - 1]) { 1848f82d02d9SYan Zheng nodes[level - 1] = eb->start; 1849f82d02d9SYan Zheng memcpy(&node_keys[level - 1], &key, 1850f82d02d9SYan Zheng sizeof(node_keys[0])); 1851f82d02d9SYan Zheng } else { 1852f82d02d9SYan Zheng WARN_ON(1); 1853f82d02d9SYan Zheng } 1854f82d02d9SYan Zheng } 1855f82d02d9SYan Zheng 18561a40e23bSZheng Yan btrfs_tree_unlock(parent); 18571a40e23bSZheng Yan free_extent_buffer(parent); 18581a40e23bSZheng Yan parent = eb; 18591a40e23bSZheng Yan continue; 18601a40e23bSZheng Yan } 18611a40e23bSZheng Yan 18621a40e23bSZheng Yan btrfs_set_node_blockptr(parent, slot, nodes[level - 1]); 18631a40e23bSZheng Yan btrfs_set_node_ptr_generation(parent, slot, trans->transid); 18641a40e23bSZheng Yan btrfs_mark_buffer_dirty(parent); 18651a40e23bSZheng Yan 18661a40e23bSZheng Yan ret = btrfs_inc_extent_ref(trans, root, 18671a40e23bSZheng Yan nodes[level - 1], 18681a40e23bSZheng Yan blocksize, parent->start, 18691a40e23bSZheng Yan btrfs_header_owner(parent), 18701a40e23bSZheng Yan btrfs_header_generation(parent), 18713bb1a1bcSYan Zheng level - 1); 18721a40e23bSZheng Yan BUG_ON(ret); 1873f82d02d9SYan Zheng 1874f82d02d9SYan Zheng /* 1875f82d02d9SYan Zheng * If the block was created in the running transaction, 1876f82d02d9SYan Zheng * it's possible this is the last reference to it, so we 1877f82d02d9SYan Zheng * should drop the subtree. 1878f82d02d9SYan Zheng */ 1879f82d02d9SYan Zheng if (generation == trans->transid) { 1880f82d02d9SYan Zheng ret = btrfs_drop_subtree(trans, root, eb, parent); 1881f82d02d9SYan Zheng BUG_ON(ret); 1882f82d02d9SYan Zheng btrfs_tree_unlock(eb); 1883f82d02d9SYan Zheng free_extent_buffer(eb); 1884f82d02d9SYan Zheng } else { 18851a40e23bSZheng Yan ret = btrfs_free_extent(trans, root, bytenr, 18861a40e23bSZheng Yan blocksize, parent->start, 18871a40e23bSZheng Yan btrfs_header_owner(parent), 18881a40e23bSZheng Yan btrfs_header_generation(parent), 18893bb1a1bcSYan Zheng level - 1, 1); 18901a40e23bSZheng Yan BUG_ON(ret); 18911a40e23bSZheng Yan } 18921a40e23bSZheng Yan break; 18931a40e23bSZheng Yan } 18941a40e23bSZheng Yan btrfs_tree_unlock(parent); 18951a40e23bSZheng Yan free_extent_buffer(parent); 18961a40e23bSZheng Yan return 0; 18971a40e23bSZheng Yan } 18981a40e23bSZheng Yan 189974123bd7SChris Mason /* 190074123bd7SChris Mason * adjust the pointers going up the tree, starting at level 190174123bd7SChris Mason * making sure the right key of each node is points to 'key'. 190274123bd7SChris Mason * This is used after shifting pointers to the left, so it stops 190374123bd7SChris Mason * fixing up pointers when a given leaf/node is not in slot 0 of the 190474123bd7SChris Mason * higher levels 1905aa5d6bedSChris Mason * 1906aa5d6bedSChris Mason * If this fails to write a tree block, it returns -1, but continues 1907aa5d6bedSChris Mason * fixing up the blocks in ram so the tree is consistent. 190874123bd7SChris Mason */ 19095f39d397SChris Mason static int fixup_low_keys(struct btrfs_trans_handle *trans, 19105f39d397SChris Mason struct btrfs_root *root, struct btrfs_path *path, 19115f39d397SChris Mason struct btrfs_disk_key *key, int level) 1912be0e5c09SChris Mason { 1913be0e5c09SChris Mason int i; 1914aa5d6bedSChris Mason int ret = 0; 19155f39d397SChris Mason struct extent_buffer *t; 19165f39d397SChris Mason 1917234b63a0SChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1918be0e5c09SChris Mason int tslot = path->slots[i]; 1919eb60ceacSChris Mason if (!path->nodes[i]) 1920be0e5c09SChris Mason break; 19215f39d397SChris Mason t = path->nodes[i]; 19225f39d397SChris Mason btrfs_set_node_key(t, key, tslot); 1923d6025579SChris Mason btrfs_mark_buffer_dirty(path->nodes[i]); 1924be0e5c09SChris Mason if (tslot != 0) 1925be0e5c09SChris Mason break; 1926be0e5c09SChris Mason } 1927aa5d6bedSChris Mason return ret; 1928be0e5c09SChris Mason } 1929be0e5c09SChris Mason 193074123bd7SChris Mason /* 193131840ae1SZheng Yan * update item key. 193231840ae1SZheng Yan * 193331840ae1SZheng Yan * This function isn't completely safe. It's the caller's responsibility 193431840ae1SZheng Yan * that the new key won't break the order 193531840ae1SZheng Yan */ 193631840ae1SZheng Yan int btrfs_set_item_key_safe(struct btrfs_trans_handle *trans, 193731840ae1SZheng Yan struct btrfs_root *root, struct btrfs_path *path, 193831840ae1SZheng Yan struct btrfs_key *new_key) 193931840ae1SZheng Yan { 194031840ae1SZheng Yan struct btrfs_disk_key disk_key; 194131840ae1SZheng Yan struct extent_buffer *eb; 194231840ae1SZheng Yan int slot; 194331840ae1SZheng Yan 194431840ae1SZheng Yan eb = path->nodes[0]; 194531840ae1SZheng Yan slot = path->slots[0]; 194631840ae1SZheng Yan if (slot > 0) { 194731840ae1SZheng Yan btrfs_item_key(eb, &disk_key, slot - 1); 194831840ae1SZheng Yan if (comp_keys(&disk_key, new_key) >= 0) 194931840ae1SZheng Yan return -1; 195031840ae1SZheng Yan } 195131840ae1SZheng Yan if (slot < btrfs_header_nritems(eb) - 1) { 195231840ae1SZheng Yan btrfs_item_key(eb, &disk_key, slot + 1); 195331840ae1SZheng Yan if (comp_keys(&disk_key, new_key) <= 0) 195431840ae1SZheng Yan return -1; 195531840ae1SZheng Yan } 195631840ae1SZheng Yan 195731840ae1SZheng Yan btrfs_cpu_key_to_disk(&disk_key, new_key); 195831840ae1SZheng Yan btrfs_set_item_key(eb, &disk_key, slot); 195931840ae1SZheng Yan btrfs_mark_buffer_dirty(eb); 196031840ae1SZheng Yan if (slot == 0) 196131840ae1SZheng Yan fixup_low_keys(trans, root, path, &disk_key, 1); 196231840ae1SZheng Yan return 0; 196331840ae1SZheng Yan } 196431840ae1SZheng Yan 196531840ae1SZheng Yan /* 196674123bd7SChris Mason * try to push data from one node into the next node left in the 196779f95c82SChris Mason * tree. 1968aa5d6bedSChris Mason * 1969aa5d6bedSChris Mason * returns 0 if some ptrs were pushed left, < 0 if there was some horrible 1970aa5d6bedSChris Mason * error, and > 0 if there was no room in the left hand block. 197174123bd7SChris Mason */ 197298ed5174SChris Mason static int push_node_left(struct btrfs_trans_handle *trans, 197398ed5174SChris Mason struct btrfs_root *root, struct extent_buffer *dst, 1974971a1f66SChris Mason struct extent_buffer *src, int empty) 1975be0e5c09SChris Mason { 1976be0e5c09SChris Mason int push_items = 0; 1977bb803951SChris Mason int src_nritems; 1978bb803951SChris Mason int dst_nritems; 1979aa5d6bedSChris Mason int ret = 0; 1980be0e5c09SChris Mason 19815f39d397SChris Mason src_nritems = btrfs_header_nritems(src); 19825f39d397SChris Mason dst_nritems = btrfs_header_nritems(dst); 1983123abc88SChris Mason push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems; 19847bb86316SChris Mason WARN_ON(btrfs_header_generation(src) != trans->transid); 19857bb86316SChris Mason WARN_ON(btrfs_header_generation(dst) != trans->transid); 198654aa1f4dSChris Mason 1987bce4eae9SChris Mason if (!empty && src_nritems <= 8) 1988971a1f66SChris Mason return 1; 1989971a1f66SChris Mason 1990d397712bSChris Mason if (push_items <= 0) 1991be0e5c09SChris Mason return 1; 1992be0e5c09SChris Mason 1993bce4eae9SChris Mason if (empty) { 1994971a1f66SChris Mason push_items = min(src_nritems, push_items); 1995bce4eae9SChris Mason if (push_items < src_nritems) { 1996bce4eae9SChris Mason /* leave at least 8 pointers in the node if 1997bce4eae9SChris Mason * we aren't going to empty it 1998bce4eae9SChris Mason */ 1999bce4eae9SChris Mason if (src_nritems - push_items < 8) { 2000bce4eae9SChris Mason if (push_items <= 8) 2001bce4eae9SChris Mason return 1; 2002bce4eae9SChris Mason push_items -= 8; 2003bce4eae9SChris Mason } 2004bce4eae9SChris Mason } 2005bce4eae9SChris Mason } else 2006bce4eae9SChris Mason push_items = min(src_nritems - 8, push_items); 200779f95c82SChris Mason 20085f39d397SChris Mason copy_extent_buffer(dst, src, 20095f39d397SChris Mason btrfs_node_key_ptr_offset(dst_nritems), 20105f39d397SChris Mason btrfs_node_key_ptr_offset(0), 2011123abc88SChris Mason push_items * sizeof(struct btrfs_key_ptr)); 20125f39d397SChris Mason 2013bb803951SChris Mason if (push_items < src_nritems) { 20145f39d397SChris Mason memmove_extent_buffer(src, btrfs_node_key_ptr_offset(0), 20155f39d397SChris Mason btrfs_node_key_ptr_offset(push_items), 2016e2fa7227SChris Mason (src_nritems - push_items) * 2017123abc88SChris Mason sizeof(struct btrfs_key_ptr)); 2018bb803951SChris Mason } 20195f39d397SChris Mason btrfs_set_header_nritems(src, src_nritems - push_items); 20205f39d397SChris Mason btrfs_set_header_nritems(dst, dst_nritems + push_items); 20215f39d397SChris Mason btrfs_mark_buffer_dirty(src); 20225f39d397SChris Mason btrfs_mark_buffer_dirty(dst); 202331840ae1SZheng Yan 202431840ae1SZheng Yan ret = btrfs_update_ref(trans, root, src, dst, dst_nritems, push_items); 202531840ae1SZheng Yan BUG_ON(ret); 202631840ae1SZheng Yan 2027bb803951SChris Mason return ret; 2028be0e5c09SChris Mason } 2029be0e5c09SChris Mason 203097571fd0SChris Mason /* 203179f95c82SChris Mason * try to push data from one node into the next node right in the 203279f95c82SChris Mason * tree. 203379f95c82SChris Mason * 203479f95c82SChris Mason * returns 0 if some ptrs were pushed, < 0 if there was some horrible 203579f95c82SChris Mason * error, and > 0 if there was no room in the right hand block. 203679f95c82SChris Mason * 203779f95c82SChris Mason * this will only push up to 1/2 the contents of the left node over 203879f95c82SChris Mason */ 20395f39d397SChris Mason static int balance_node_right(struct btrfs_trans_handle *trans, 20405f39d397SChris Mason struct btrfs_root *root, 20415f39d397SChris Mason struct extent_buffer *dst, 20425f39d397SChris Mason struct extent_buffer *src) 204379f95c82SChris Mason { 204479f95c82SChris Mason int push_items = 0; 204579f95c82SChris Mason int max_push; 204679f95c82SChris Mason int src_nritems; 204779f95c82SChris Mason int dst_nritems; 204879f95c82SChris Mason int ret = 0; 204979f95c82SChris Mason 20507bb86316SChris Mason WARN_ON(btrfs_header_generation(src) != trans->transid); 20517bb86316SChris Mason WARN_ON(btrfs_header_generation(dst) != trans->transid); 20527bb86316SChris Mason 20535f39d397SChris Mason src_nritems = btrfs_header_nritems(src); 20545f39d397SChris Mason dst_nritems = btrfs_header_nritems(dst); 2055123abc88SChris Mason push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems; 2056d397712bSChris Mason if (push_items <= 0) 205779f95c82SChris Mason return 1; 2058bce4eae9SChris Mason 2059d397712bSChris Mason if (src_nritems < 4) 2060bce4eae9SChris Mason return 1; 206179f95c82SChris Mason 206279f95c82SChris Mason max_push = src_nritems / 2 + 1; 206379f95c82SChris Mason /* don't try to empty the node */ 2064d397712bSChris Mason if (max_push >= src_nritems) 206579f95c82SChris Mason return 1; 2066252c38f0SYan 206779f95c82SChris Mason if (max_push < push_items) 206879f95c82SChris Mason push_items = max_push; 206979f95c82SChris Mason 20705f39d397SChris Mason memmove_extent_buffer(dst, btrfs_node_key_ptr_offset(push_items), 20715f39d397SChris Mason btrfs_node_key_ptr_offset(0), 20725f39d397SChris Mason (dst_nritems) * 20735f39d397SChris Mason sizeof(struct btrfs_key_ptr)); 2074d6025579SChris Mason 20755f39d397SChris Mason copy_extent_buffer(dst, src, 20765f39d397SChris Mason btrfs_node_key_ptr_offset(0), 20775f39d397SChris Mason btrfs_node_key_ptr_offset(src_nritems - push_items), 2078123abc88SChris Mason push_items * sizeof(struct btrfs_key_ptr)); 207979f95c82SChris Mason 20805f39d397SChris Mason btrfs_set_header_nritems(src, src_nritems - push_items); 20815f39d397SChris Mason btrfs_set_header_nritems(dst, dst_nritems + push_items); 208279f95c82SChris Mason 20835f39d397SChris Mason btrfs_mark_buffer_dirty(src); 20845f39d397SChris Mason btrfs_mark_buffer_dirty(dst); 208531840ae1SZheng Yan 208631840ae1SZheng Yan ret = btrfs_update_ref(trans, root, src, dst, 0, push_items); 208731840ae1SZheng Yan BUG_ON(ret); 208831840ae1SZheng Yan 208979f95c82SChris Mason return ret; 209079f95c82SChris Mason } 209179f95c82SChris Mason 209279f95c82SChris Mason /* 209397571fd0SChris Mason * helper function to insert a new root level in the tree. 209497571fd0SChris Mason * A new node is allocated, and a single item is inserted to 209597571fd0SChris Mason * point to the existing root 2096aa5d6bedSChris Mason * 2097aa5d6bedSChris Mason * returns zero on success or < 0 on failure. 209897571fd0SChris Mason */ 2099d397712bSChris Mason static noinline int insert_new_root(struct btrfs_trans_handle *trans, 21005f39d397SChris Mason struct btrfs_root *root, 21015f39d397SChris Mason struct btrfs_path *path, int level) 210274123bd7SChris Mason { 21037bb86316SChris Mason u64 lower_gen; 21045f39d397SChris Mason struct extent_buffer *lower; 21055f39d397SChris Mason struct extent_buffer *c; 2106925baeddSChris Mason struct extent_buffer *old; 21075f39d397SChris Mason struct btrfs_disk_key lower_key; 210831840ae1SZheng Yan int ret; 21095c680ed6SChris Mason 21105c680ed6SChris Mason BUG_ON(path->nodes[level]); 21115c680ed6SChris Mason BUG_ON(path->nodes[level-1] != root->node); 21125c680ed6SChris Mason 21137bb86316SChris Mason lower = path->nodes[level-1]; 21147bb86316SChris Mason if (level == 1) 21157bb86316SChris Mason btrfs_item_key(lower, &lower_key, 0); 21167bb86316SChris Mason else 21177bb86316SChris Mason btrfs_node_key(lower, &lower_key, 0); 21187bb86316SChris Mason 211931840ae1SZheng Yan c = btrfs_alloc_free_block(trans, root, root->nodesize, 0, 212031840ae1SZheng Yan root->root_key.objectid, trans->transid, 2121ad3d81baSChristoph Hellwig level, root->node->start, 0); 21225f39d397SChris Mason if (IS_ERR(c)) 21235f39d397SChris Mason return PTR_ERR(c); 2124925baeddSChris Mason 21255f39d397SChris Mason memset_extent_buffer(c, 0, 0, root->nodesize); 21265f39d397SChris Mason btrfs_set_header_nritems(c, 1); 21275f39d397SChris Mason btrfs_set_header_level(c, level); 2128db94535dSChris Mason btrfs_set_header_bytenr(c, c->start); 21295f39d397SChris Mason btrfs_set_header_generation(c, trans->transid); 21305f39d397SChris Mason btrfs_set_header_owner(c, root->root_key.objectid); 2131d5719762SChris Mason 21325f39d397SChris Mason write_extent_buffer(c, root->fs_info->fsid, 21335f39d397SChris Mason (unsigned long)btrfs_header_fsid(c), 21345f39d397SChris Mason BTRFS_FSID_SIZE); 2135e17cade2SChris Mason 2136e17cade2SChris Mason write_extent_buffer(c, root->fs_info->chunk_tree_uuid, 2137e17cade2SChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(c), 2138e17cade2SChris Mason BTRFS_UUID_SIZE); 2139e17cade2SChris Mason 21405f39d397SChris Mason btrfs_set_node_key(c, &lower_key, 0); 2141db94535dSChris Mason btrfs_set_node_blockptr(c, 0, lower->start); 21427bb86316SChris Mason lower_gen = btrfs_header_generation(lower); 214331840ae1SZheng Yan WARN_ON(lower_gen != trans->transid); 21447bb86316SChris Mason 21457bb86316SChris Mason btrfs_set_node_ptr_generation(c, 0, lower_gen); 21465f39d397SChris Mason 21475f39d397SChris Mason btrfs_mark_buffer_dirty(c); 2148d5719762SChris Mason 2149925baeddSChris Mason spin_lock(&root->node_lock); 2150925baeddSChris Mason old = root->node; 21515f39d397SChris Mason root->node = c; 2152925baeddSChris Mason spin_unlock(&root->node_lock); 2153925baeddSChris Mason 215431840ae1SZheng Yan ret = btrfs_update_extent_ref(trans, root, lower->start, 215556bec294SChris Mason lower->len, lower->start, c->start, 215631840ae1SZheng Yan root->root_key.objectid, 21573bb1a1bcSYan Zheng trans->transid, level - 1); 215831840ae1SZheng Yan BUG_ON(ret); 215931840ae1SZheng Yan 2160925baeddSChris Mason /* the super has an extra ref to root->node */ 2161925baeddSChris Mason free_extent_buffer(old); 2162925baeddSChris Mason 21630b86a832SChris Mason add_root_to_dirty_list(root); 21645f39d397SChris Mason extent_buffer_get(c); 21655f39d397SChris Mason path->nodes[level] = c; 2166925baeddSChris Mason path->locks[level] = 1; 216774123bd7SChris Mason path->slots[level] = 0; 216874123bd7SChris Mason return 0; 216974123bd7SChris Mason } 21705c680ed6SChris Mason 21715c680ed6SChris Mason /* 21725c680ed6SChris Mason * worker function to insert a single pointer in a node. 21735c680ed6SChris Mason * the node should have enough room for the pointer already 217497571fd0SChris Mason * 21755c680ed6SChris Mason * slot and level indicate where you want the key to go, and 21765c680ed6SChris Mason * blocknr is the block the key points to. 2177aa5d6bedSChris Mason * 2178aa5d6bedSChris Mason * returns zero on success and < 0 on any error 21795c680ed6SChris Mason */ 2180e089f05cSChris Mason static int insert_ptr(struct btrfs_trans_handle *trans, struct btrfs_root 2181e089f05cSChris Mason *root, struct btrfs_path *path, struct btrfs_disk_key 2182db94535dSChris Mason *key, u64 bytenr, int slot, int level) 21835c680ed6SChris Mason { 21845f39d397SChris Mason struct extent_buffer *lower; 21855c680ed6SChris Mason int nritems; 21865c680ed6SChris Mason 21875c680ed6SChris Mason BUG_ON(!path->nodes[level]); 21885f39d397SChris Mason lower = path->nodes[level]; 21895f39d397SChris Mason nritems = btrfs_header_nritems(lower); 2190c293498bSStoyan Gaydarov BUG_ON(slot > nritems); 2191123abc88SChris Mason if (nritems == BTRFS_NODEPTRS_PER_BLOCK(root)) 219274123bd7SChris Mason BUG(); 219374123bd7SChris Mason if (slot != nritems) { 21945f39d397SChris Mason memmove_extent_buffer(lower, 21955f39d397SChris Mason btrfs_node_key_ptr_offset(slot + 1), 21965f39d397SChris Mason btrfs_node_key_ptr_offset(slot), 2197123abc88SChris Mason (nritems - slot) * sizeof(struct btrfs_key_ptr)); 219874123bd7SChris Mason } 21995f39d397SChris Mason btrfs_set_node_key(lower, key, slot); 2200db94535dSChris Mason btrfs_set_node_blockptr(lower, slot, bytenr); 220174493f7aSChris Mason WARN_ON(trans->transid == 0); 220274493f7aSChris Mason btrfs_set_node_ptr_generation(lower, slot, trans->transid); 22035f39d397SChris Mason btrfs_set_header_nritems(lower, nritems + 1); 22045f39d397SChris Mason btrfs_mark_buffer_dirty(lower); 220574123bd7SChris Mason return 0; 220674123bd7SChris Mason } 220774123bd7SChris Mason 220897571fd0SChris Mason /* 220997571fd0SChris Mason * split the node at the specified level in path in two. 221097571fd0SChris Mason * The path is corrected to point to the appropriate node after the split 221197571fd0SChris Mason * 221297571fd0SChris Mason * Before splitting this tries to make some room in the node by pushing 221397571fd0SChris Mason * left and right, if either one works, it returns right away. 2214aa5d6bedSChris Mason * 2215aa5d6bedSChris Mason * returns 0 on success and < 0 on failure 221697571fd0SChris Mason */ 2217e02119d5SChris Mason static noinline int split_node(struct btrfs_trans_handle *trans, 2218e02119d5SChris Mason struct btrfs_root *root, 2219e02119d5SChris Mason struct btrfs_path *path, int level) 2220be0e5c09SChris Mason { 22215f39d397SChris Mason struct extent_buffer *c; 22225f39d397SChris Mason struct extent_buffer *split; 22235f39d397SChris Mason struct btrfs_disk_key disk_key; 2224be0e5c09SChris Mason int mid; 22255c680ed6SChris Mason int ret; 2226aa5d6bedSChris Mason int wret; 22277518a238SChris Mason u32 c_nritems; 2228be0e5c09SChris Mason 22295f39d397SChris Mason c = path->nodes[level]; 22307bb86316SChris Mason WARN_ON(btrfs_header_generation(c) != trans->transid); 22315f39d397SChris Mason if (c == root->node) { 22325c680ed6SChris Mason /* trying to split the root, lets make a new one */ 2233e089f05cSChris Mason ret = insert_new_root(trans, root, path, level + 1); 22345c680ed6SChris Mason if (ret) 22355c680ed6SChris Mason return ret; 2236a4b6e07dSChris Mason } else if (!trans->transaction->delayed_refs.flushing) { 2237e66f709bSChris Mason ret = push_nodes_for_insert(trans, root, path, level); 22385f39d397SChris Mason c = path->nodes[level]; 22395f39d397SChris Mason if (!ret && btrfs_header_nritems(c) < 2240c448acf0SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) - 3) 2241e66f709bSChris Mason return 0; 224254aa1f4dSChris Mason if (ret < 0) 224354aa1f4dSChris Mason return ret; 22445c680ed6SChris Mason } 2245e66f709bSChris Mason 22465f39d397SChris Mason c_nritems = btrfs_header_nritems(c); 22477bb86316SChris Mason 2248925baeddSChris Mason split = btrfs_alloc_free_block(trans, root, root->nodesize, 224931840ae1SZheng Yan path->nodes[level + 1]->start, 22507bb86316SChris Mason root->root_key.objectid, 225131840ae1SZheng Yan trans->transid, level, c->start, 0); 22525f39d397SChris Mason if (IS_ERR(split)) 22535f39d397SChris Mason return PTR_ERR(split); 225454aa1f4dSChris Mason 22555f39d397SChris Mason btrfs_set_header_flags(split, btrfs_header_flags(c)); 22565f39d397SChris Mason btrfs_set_header_level(split, btrfs_header_level(c)); 2257db94535dSChris Mason btrfs_set_header_bytenr(split, split->start); 22585f39d397SChris Mason btrfs_set_header_generation(split, trans->transid); 22595f39d397SChris Mason btrfs_set_header_owner(split, root->root_key.objectid); 226063b10fc4SChris Mason btrfs_set_header_flags(split, 0); 22615f39d397SChris Mason write_extent_buffer(split, root->fs_info->fsid, 22625f39d397SChris Mason (unsigned long)btrfs_header_fsid(split), 22635f39d397SChris Mason BTRFS_FSID_SIZE); 2264e17cade2SChris Mason write_extent_buffer(split, root->fs_info->chunk_tree_uuid, 2265e17cade2SChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(split), 2266e17cade2SChris Mason BTRFS_UUID_SIZE); 22675f39d397SChris Mason 22687518a238SChris Mason mid = (c_nritems + 1) / 2; 22695f39d397SChris Mason 22705f39d397SChris Mason copy_extent_buffer(split, c, 22715f39d397SChris Mason btrfs_node_key_ptr_offset(0), 22725f39d397SChris Mason btrfs_node_key_ptr_offset(mid), 2273123abc88SChris Mason (c_nritems - mid) * sizeof(struct btrfs_key_ptr)); 22745f39d397SChris Mason btrfs_set_header_nritems(split, c_nritems - mid); 22755f39d397SChris Mason btrfs_set_header_nritems(c, mid); 2276aa5d6bedSChris Mason ret = 0; 2277aa5d6bedSChris Mason 22785f39d397SChris Mason btrfs_mark_buffer_dirty(c); 22795f39d397SChris Mason btrfs_mark_buffer_dirty(split); 22805f39d397SChris Mason 22815f39d397SChris Mason btrfs_node_key(split, &disk_key, 0); 2282db94535dSChris Mason wret = insert_ptr(trans, root, path, &disk_key, split->start, 22835f39d397SChris Mason path->slots[level + 1] + 1, 2284123abc88SChris Mason level + 1); 2285aa5d6bedSChris Mason if (wret) 2286aa5d6bedSChris Mason ret = wret; 2287aa5d6bedSChris Mason 228831840ae1SZheng Yan ret = btrfs_update_ref(trans, root, c, split, 0, c_nritems - mid); 228931840ae1SZheng Yan BUG_ON(ret); 229031840ae1SZheng Yan 22915de08d7dSChris Mason if (path->slots[level] >= mid) { 22925c680ed6SChris Mason path->slots[level] -= mid; 2293925baeddSChris Mason btrfs_tree_unlock(c); 22945f39d397SChris Mason free_extent_buffer(c); 22955f39d397SChris Mason path->nodes[level] = split; 22965c680ed6SChris Mason path->slots[level + 1] += 1; 2297eb60ceacSChris Mason } else { 2298925baeddSChris Mason btrfs_tree_unlock(split); 22995f39d397SChris Mason free_extent_buffer(split); 2300be0e5c09SChris Mason } 2301aa5d6bedSChris Mason return ret; 2302be0e5c09SChris Mason } 2303be0e5c09SChris Mason 230474123bd7SChris Mason /* 230574123bd7SChris Mason * how many bytes are required to store the items in a leaf. start 230674123bd7SChris Mason * and nr indicate which items in the leaf to check. This totals up the 230774123bd7SChris Mason * space used both by the item structs and the item data 230874123bd7SChris Mason */ 23095f39d397SChris Mason static int leaf_space_used(struct extent_buffer *l, int start, int nr) 2310be0e5c09SChris Mason { 2311be0e5c09SChris Mason int data_len; 23125f39d397SChris Mason int nritems = btrfs_header_nritems(l); 2313d4dbff95SChris Mason int end = min(nritems, start + nr) - 1; 2314be0e5c09SChris Mason 2315be0e5c09SChris Mason if (!nr) 2316be0e5c09SChris Mason return 0; 23175f39d397SChris Mason data_len = btrfs_item_end_nr(l, start); 23185f39d397SChris Mason data_len = data_len - btrfs_item_offset_nr(l, end); 23190783fcfcSChris Mason data_len += sizeof(struct btrfs_item) * nr; 2320d4dbff95SChris Mason WARN_ON(data_len < 0); 2321be0e5c09SChris Mason return data_len; 2322be0e5c09SChris Mason } 2323be0e5c09SChris Mason 232474123bd7SChris Mason /* 2325d4dbff95SChris Mason * The space between the end of the leaf items and 2326d4dbff95SChris Mason * the start of the leaf data. IOW, how much room 2327d4dbff95SChris Mason * the leaf has left for both items and data 2328d4dbff95SChris Mason */ 2329d397712bSChris Mason noinline int btrfs_leaf_free_space(struct btrfs_root *root, 2330e02119d5SChris Mason struct extent_buffer *leaf) 2331d4dbff95SChris Mason { 23325f39d397SChris Mason int nritems = btrfs_header_nritems(leaf); 23335f39d397SChris Mason int ret; 23345f39d397SChris Mason ret = BTRFS_LEAF_DATA_SIZE(root) - leaf_space_used(leaf, 0, nritems); 23355f39d397SChris Mason if (ret < 0) { 2336d397712bSChris Mason printk(KERN_CRIT "leaf free space ret %d, leaf data size %lu, " 2337d397712bSChris Mason "used %d nritems %d\n", 2338ae2f5411SJens Axboe ret, (unsigned long) BTRFS_LEAF_DATA_SIZE(root), 23395f39d397SChris Mason leaf_space_used(leaf, 0, nritems), nritems); 23405f39d397SChris Mason } 23415f39d397SChris Mason return ret; 2342d4dbff95SChris Mason } 2343d4dbff95SChris Mason 234444871b1bSChris Mason static noinline int __push_leaf_right(struct btrfs_trans_handle *trans, 234544871b1bSChris Mason struct btrfs_root *root, 234644871b1bSChris Mason struct btrfs_path *path, 234744871b1bSChris Mason int data_size, int empty, 234844871b1bSChris Mason struct extent_buffer *right, 234944871b1bSChris Mason int free_space, u32 left_nritems) 235000ec4c51SChris Mason { 23515f39d397SChris Mason struct extent_buffer *left = path->nodes[0]; 235244871b1bSChris Mason struct extent_buffer *upper = path->nodes[1]; 23535f39d397SChris Mason struct btrfs_disk_key disk_key; 235400ec4c51SChris Mason int slot; 235534a38218SChris Mason u32 i; 235600ec4c51SChris Mason int push_space = 0; 235700ec4c51SChris Mason int push_items = 0; 23580783fcfcSChris Mason struct btrfs_item *item; 235934a38218SChris Mason u32 nr; 23607518a238SChris Mason u32 right_nritems; 23615f39d397SChris Mason u32 data_end; 2362db94535dSChris Mason u32 this_item_size; 236354aa1f4dSChris Mason int ret; 236400ec4c51SChris Mason 236534a38218SChris Mason if (empty) 236634a38218SChris Mason nr = 0; 236734a38218SChris Mason else 236834a38218SChris Mason nr = 1; 236934a38218SChris Mason 237031840ae1SZheng Yan if (path->slots[0] >= left_nritems) 237187b29b20SYan Zheng push_space += data_size; 237231840ae1SZheng Yan 237344871b1bSChris Mason slot = path->slots[1]; 237434a38218SChris Mason i = left_nritems - 1; 237534a38218SChris Mason while (i >= nr) { 23765f39d397SChris Mason item = btrfs_item_nr(left, i); 2377db94535dSChris Mason 237831840ae1SZheng Yan if (!empty && push_items > 0) { 237931840ae1SZheng Yan if (path->slots[0] > i) 238031840ae1SZheng Yan break; 238131840ae1SZheng Yan if (path->slots[0] == i) { 238231840ae1SZheng Yan int space = btrfs_leaf_free_space(root, left); 238331840ae1SZheng Yan if (space + push_space * 2 > free_space) 238431840ae1SZheng Yan break; 238531840ae1SZheng Yan } 238631840ae1SZheng Yan } 238731840ae1SZheng Yan 238800ec4c51SChris Mason if (path->slots[0] == i) 238987b29b20SYan Zheng push_space += data_size; 2390db94535dSChris Mason 2391db94535dSChris Mason if (!left->map_token) { 2392db94535dSChris Mason map_extent_buffer(left, (unsigned long)item, 2393db94535dSChris Mason sizeof(struct btrfs_item), 2394db94535dSChris Mason &left->map_token, &left->kaddr, 2395db94535dSChris Mason &left->map_start, &left->map_len, 2396db94535dSChris Mason KM_USER1); 2397db94535dSChris Mason } 2398db94535dSChris Mason 2399db94535dSChris Mason this_item_size = btrfs_item_size(left, item); 2400db94535dSChris Mason if (this_item_size + sizeof(*item) + push_space > free_space) 240100ec4c51SChris Mason break; 240231840ae1SZheng Yan 240300ec4c51SChris Mason push_items++; 2404db94535dSChris Mason push_space += this_item_size + sizeof(*item); 240534a38218SChris Mason if (i == 0) 240634a38218SChris Mason break; 240734a38218SChris Mason i--; 2408db94535dSChris Mason } 2409db94535dSChris Mason if (left->map_token) { 2410db94535dSChris Mason unmap_extent_buffer(left, left->map_token, KM_USER1); 2411db94535dSChris Mason left->map_token = NULL; 241200ec4c51SChris Mason } 24135f39d397SChris Mason 2414925baeddSChris Mason if (push_items == 0) 2415925baeddSChris Mason goto out_unlock; 24165f39d397SChris Mason 241734a38218SChris Mason if (!empty && push_items == left_nritems) 2418a429e513SChris Mason WARN_ON(1); 24195f39d397SChris Mason 242000ec4c51SChris Mason /* push left to right */ 24215f39d397SChris Mason right_nritems = btrfs_header_nritems(right); 242234a38218SChris Mason 24235f39d397SChris Mason push_space = btrfs_item_end_nr(left, left_nritems - push_items); 2424123abc88SChris Mason push_space -= leaf_data_end(root, left); 24255f39d397SChris Mason 242600ec4c51SChris Mason /* make room in the right data area */ 24275f39d397SChris Mason data_end = leaf_data_end(root, right); 24285f39d397SChris Mason memmove_extent_buffer(right, 24295f39d397SChris Mason btrfs_leaf_data(right) + data_end - push_space, 24305f39d397SChris Mason btrfs_leaf_data(right) + data_end, 24315f39d397SChris Mason BTRFS_LEAF_DATA_SIZE(root) - data_end); 24325f39d397SChris Mason 243300ec4c51SChris Mason /* copy from the left data area */ 24345f39d397SChris Mason copy_extent_buffer(right, left, btrfs_leaf_data(right) + 2435d6025579SChris Mason BTRFS_LEAF_DATA_SIZE(root) - push_space, 2436d6025579SChris Mason btrfs_leaf_data(left) + leaf_data_end(root, left), 2437d6025579SChris Mason push_space); 24385f39d397SChris Mason 24395f39d397SChris Mason memmove_extent_buffer(right, btrfs_item_nr_offset(push_items), 24405f39d397SChris Mason btrfs_item_nr_offset(0), 24410783fcfcSChris Mason right_nritems * sizeof(struct btrfs_item)); 24425f39d397SChris Mason 244300ec4c51SChris Mason /* copy the items from left to right */ 24445f39d397SChris Mason copy_extent_buffer(right, left, btrfs_item_nr_offset(0), 24455f39d397SChris Mason btrfs_item_nr_offset(left_nritems - push_items), 24460783fcfcSChris Mason push_items * sizeof(struct btrfs_item)); 244700ec4c51SChris Mason 244800ec4c51SChris Mason /* update the item pointers */ 24497518a238SChris Mason right_nritems += push_items; 24505f39d397SChris Mason btrfs_set_header_nritems(right, right_nritems); 2451123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root); 24527518a238SChris Mason for (i = 0; i < right_nritems; i++) { 24535f39d397SChris Mason item = btrfs_item_nr(right, i); 2454db94535dSChris Mason if (!right->map_token) { 2455db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2456db94535dSChris Mason sizeof(struct btrfs_item), 2457db94535dSChris Mason &right->map_token, &right->kaddr, 2458db94535dSChris Mason &right->map_start, &right->map_len, 2459db94535dSChris Mason KM_USER1); 2460db94535dSChris Mason } 2461db94535dSChris Mason push_space -= btrfs_item_size(right, item); 2462db94535dSChris Mason btrfs_set_item_offset(right, item, push_space); 2463db94535dSChris Mason } 2464db94535dSChris Mason 2465db94535dSChris Mason if (right->map_token) { 2466db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2467db94535dSChris Mason right->map_token = NULL; 246800ec4c51SChris Mason } 24697518a238SChris Mason left_nritems -= push_items; 24705f39d397SChris Mason btrfs_set_header_nritems(left, left_nritems); 247100ec4c51SChris Mason 247234a38218SChris Mason if (left_nritems) 24735f39d397SChris Mason btrfs_mark_buffer_dirty(left); 24745f39d397SChris Mason btrfs_mark_buffer_dirty(right); 2475a429e513SChris Mason 247631840ae1SZheng Yan ret = btrfs_update_ref(trans, root, left, right, 0, push_items); 247731840ae1SZheng Yan BUG_ON(ret); 247831840ae1SZheng Yan 24795f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 24805f39d397SChris Mason btrfs_set_node_key(upper, &disk_key, slot + 1); 2481d6025579SChris Mason btrfs_mark_buffer_dirty(upper); 248202217ed2SChris Mason 248300ec4c51SChris Mason /* then fixup the leaf pointer in the path */ 24847518a238SChris Mason if (path->slots[0] >= left_nritems) { 24857518a238SChris Mason path->slots[0] -= left_nritems; 2486925baeddSChris Mason if (btrfs_header_nritems(path->nodes[0]) == 0) 2487925baeddSChris Mason clean_tree_block(trans, root, path->nodes[0]); 2488925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 24895f39d397SChris Mason free_extent_buffer(path->nodes[0]); 24905f39d397SChris Mason path->nodes[0] = right; 249100ec4c51SChris Mason path->slots[1] += 1; 249200ec4c51SChris Mason } else { 2493925baeddSChris Mason btrfs_tree_unlock(right); 24945f39d397SChris Mason free_extent_buffer(right); 249500ec4c51SChris Mason } 249600ec4c51SChris Mason return 0; 2497925baeddSChris Mason 2498925baeddSChris Mason out_unlock: 2499925baeddSChris Mason btrfs_tree_unlock(right); 2500925baeddSChris Mason free_extent_buffer(right); 2501925baeddSChris Mason return 1; 250200ec4c51SChris Mason } 2503925baeddSChris Mason 250400ec4c51SChris Mason /* 250544871b1bSChris Mason * push some data in the path leaf to the right, trying to free up at 250674123bd7SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 250744871b1bSChris Mason * 250844871b1bSChris Mason * returns 1 if the push failed because the other node didn't have enough 250944871b1bSChris Mason * room, 0 if everything worked out and < 0 if there were major errors. 251074123bd7SChris Mason */ 251144871b1bSChris Mason static int push_leaf_right(struct btrfs_trans_handle *trans, struct btrfs_root 251234a38218SChris Mason *root, struct btrfs_path *path, int data_size, 251334a38218SChris Mason int empty) 2514be0e5c09SChris Mason { 251544871b1bSChris Mason struct extent_buffer *left = path->nodes[0]; 251644871b1bSChris Mason struct extent_buffer *right; 251744871b1bSChris Mason struct extent_buffer *upper; 251844871b1bSChris Mason int slot; 251944871b1bSChris Mason int free_space; 252044871b1bSChris Mason u32 left_nritems; 252144871b1bSChris Mason int ret; 252244871b1bSChris Mason 252344871b1bSChris Mason if (!path->nodes[1]) 252444871b1bSChris Mason return 1; 252544871b1bSChris Mason 252644871b1bSChris Mason slot = path->slots[1]; 252744871b1bSChris Mason upper = path->nodes[1]; 252844871b1bSChris Mason if (slot >= btrfs_header_nritems(upper) - 1) 252944871b1bSChris Mason return 1; 253044871b1bSChris Mason 253144871b1bSChris Mason btrfs_assert_tree_locked(path->nodes[1]); 253244871b1bSChris Mason 253344871b1bSChris Mason right = read_node_slot(root, upper, slot + 1); 253444871b1bSChris Mason btrfs_tree_lock(right); 253544871b1bSChris Mason btrfs_set_lock_blocking(right); 253644871b1bSChris Mason 253744871b1bSChris Mason free_space = btrfs_leaf_free_space(root, right); 253844871b1bSChris Mason if (free_space < data_size) 253944871b1bSChris Mason goto out_unlock; 254044871b1bSChris Mason 254144871b1bSChris Mason /* cow and double check */ 254244871b1bSChris Mason ret = btrfs_cow_block(trans, root, right, upper, 254344871b1bSChris Mason slot + 1, &right); 254444871b1bSChris Mason if (ret) 254544871b1bSChris Mason goto out_unlock; 254644871b1bSChris Mason 254744871b1bSChris Mason free_space = btrfs_leaf_free_space(root, right); 254844871b1bSChris Mason if (free_space < data_size) 254944871b1bSChris Mason goto out_unlock; 255044871b1bSChris Mason 255144871b1bSChris Mason left_nritems = btrfs_header_nritems(left); 255244871b1bSChris Mason if (left_nritems == 0) 255344871b1bSChris Mason goto out_unlock; 255444871b1bSChris Mason 255544871b1bSChris Mason return __push_leaf_right(trans, root, path, data_size, empty, 255644871b1bSChris Mason right, free_space, left_nritems); 255744871b1bSChris Mason out_unlock: 255844871b1bSChris Mason btrfs_tree_unlock(right); 255944871b1bSChris Mason free_extent_buffer(right); 256044871b1bSChris Mason return 1; 256144871b1bSChris Mason } 256244871b1bSChris Mason 256344871b1bSChris Mason /* 256444871b1bSChris Mason * push some data in the path leaf to the left, trying to free up at 256544871b1bSChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 256644871b1bSChris Mason */ 256744871b1bSChris Mason static noinline int __push_leaf_left(struct btrfs_trans_handle *trans, 256844871b1bSChris Mason struct btrfs_root *root, 256944871b1bSChris Mason struct btrfs_path *path, int data_size, 257044871b1bSChris Mason int empty, struct extent_buffer *left, 257144871b1bSChris Mason int free_space, int right_nritems) 257244871b1bSChris Mason { 25735f39d397SChris Mason struct btrfs_disk_key disk_key; 25745f39d397SChris Mason struct extent_buffer *right = path->nodes[0]; 2575be0e5c09SChris Mason int slot; 2576be0e5c09SChris Mason int i; 2577be0e5c09SChris Mason int push_space = 0; 2578be0e5c09SChris Mason int push_items = 0; 25790783fcfcSChris Mason struct btrfs_item *item; 25807518a238SChris Mason u32 old_left_nritems; 258134a38218SChris Mason u32 nr; 2582aa5d6bedSChris Mason int ret = 0; 2583aa5d6bedSChris Mason int wret; 2584db94535dSChris Mason u32 this_item_size; 2585db94535dSChris Mason u32 old_left_item_size; 2586be0e5c09SChris Mason 2587be0e5c09SChris Mason slot = path->slots[1]; 258802217ed2SChris Mason 258934a38218SChris Mason if (empty) 259034a38218SChris Mason nr = right_nritems; 259134a38218SChris Mason else 259234a38218SChris Mason nr = right_nritems - 1; 259334a38218SChris Mason 259434a38218SChris Mason for (i = 0; i < nr; i++) { 25955f39d397SChris Mason item = btrfs_item_nr(right, i); 2596db94535dSChris Mason if (!right->map_token) { 2597db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2598db94535dSChris Mason sizeof(struct btrfs_item), 2599db94535dSChris Mason &right->map_token, &right->kaddr, 2600db94535dSChris Mason &right->map_start, &right->map_len, 2601db94535dSChris Mason KM_USER1); 2602db94535dSChris Mason } 2603db94535dSChris Mason 260431840ae1SZheng Yan if (!empty && push_items > 0) { 260531840ae1SZheng Yan if (path->slots[0] < i) 260631840ae1SZheng Yan break; 260731840ae1SZheng Yan if (path->slots[0] == i) { 260831840ae1SZheng Yan int space = btrfs_leaf_free_space(root, right); 260931840ae1SZheng Yan if (space + push_space * 2 > free_space) 261031840ae1SZheng Yan break; 261131840ae1SZheng Yan } 261231840ae1SZheng Yan } 261331840ae1SZheng Yan 2614be0e5c09SChris Mason if (path->slots[0] == i) 261587b29b20SYan Zheng push_space += data_size; 2616db94535dSChris Mason 2617db94535dSChris Mason this_item_size = btrfs_item_size(right, item); 2618db94535dSChris Mason if (this_item_size + sizeof(*item) + push_space > free_space) 2619be0e5c09SChris Mason break; 2620db94535dSChris Mason 2621be0e5c09SChris Mason push_items++; 2622db94535dSChris Mason push_space += this_item_size + sizeof(*item); 2623be0e5c09SChris Mason } 2624db94535dSChris Mason 2625db94535dSChris Mason if (right->map_token) { 2626db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2627db94535dSChris Mason right->map_token = NULL; 2628db94535dSChris Mason } 2629db94535dSChris Mason 2630be0e5c09SChris Mason if (push_items == 0) { 2631925baeddSChris Mason ret = 1; 2632925baeddSChris Mason goto out; 2633be0e5c09SChris Mason } 263434a38218SChris Mason if (!empty && push_items == btrfs_header_nritems(right)) 2635a429e513SChris Mason WARN_ON(1); 26365f39d397SChris Mason 2637be0e5c09SChris Mason /* push data from right to left */ 26385f39d397SChris Mason copy_extent_buffer(left, right, 26395f39d397SChris Mason btrfs_item_nr_offset(btrfs_header_nritems(left)), 26405f39d397SChris Mason btrfs_item_nr_offset(0), 26415f39d397SChris Mason push_items * sizeof(struct btrfs_item)); 26425f39d397SChris Mason 2643123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root) - 26445f39d397SChris Mason btrfs_item_offset_nr(right, push_items - 1); 26455f39d397SChris Mason 26465f39d397SChris Mason copy_extent_buffer(left, right, btrfs_leaf_data(left) + 2647d6025579SChris Mason leaf_data_end(root, left) - push_space, 2648123abc88SChris Mason btrfs_leaf_data(right) + 26495f39d397SChris Mason btrfs_item_offset_nr(right, push_items - 1), 2650be0e5c09SChris Mason push_space); 26515f39d397SChris Mason old_left_nritems = btrfs_header_nritems(left); 265287b29b20SYan Zheng BUG_ON(old_left_nritems <= 0); 2653eb60ceacSChris Mason 2654db94535dSChris Mason old_left_item_size = btrfs_item_offset_nr(left, old_left_nritems - 1); 2655be0e5c09SChris Mason for (i = old_left_nritems; i < old_left_nritems + push_items; i++) { 26565f39d397SChris Mason u32 ioff; 2657db94535dSChris Mason 26585f39d397SChris Mason item = btrfs_item_nr(left, i); 2659db94535dSChris Mason if (!left->map_token) { 2660db94535dSChris Mason map_extent_buffer(left, (unsigned long)item, 2661db94535dSChris Mason sizeof(struct btrfs_item), 2662db94535dSChris Mason &left->map_token, &left->kaddr, 2663db94535dSChris Mason &left->map_start, &left->map_len, 2664db94535dSChris Mason KM_USER1); 2665db94535dSChris Mason } 2666db94535dSChris Mason 26675f39d397SChris Mason ioff = btrfs_item_offset(left, item); 26685f39d397SChris Mason btrfs_set_item_offset(left, item, 2669db94535dSChris Mason ioff - (BTRFS_LEAF_DATA_SIZE(root) - old_left_item_size)); 2670be0e5c09SChris Mason } 26715f39d397SChris Mason btrfs_set_header_nritems(left, old_left_nritems + push_items); 2672db94535dSChris Mason if (left->map_token) { 2673db94535dSChris Mason unmap_extent_buffer(left, left->map_token, KM_USER1); 2674db94535dSChris Mason left->map_token = NULL; 2675db94535dSChris Mason } 2676be0e5c09SChris Mason 2677be0e5c09SChris Mason /* fixup right node */ 267834a38218SChris Mason if (push_items > right_nritems) { 2679d397712bSChris Mason printk(KERN_CRIT "push items %d nr %u\n", push_items, 2680d397712bSChris Mason right_nritems); 268134a38218SChris Mason WARN_ON(1); 268234a38218SChris Mason } 268334a38218SChris Mason 268434a38218SChris Mason if (push_items < right_nritems) { 26855f39d397SChris Mason push_space = btrfs_item_offset_nr(right, push_items - 1) - 2686123abc88SChris Mason leaf_data_end(root, right); 26875f39d397SChris Mason memmove_extent_buffer(right, btrfs_leaf_data(right) + 2688d6025579SChris Mason BTRFS_LEAF_DATA_SIZE(root) - push_space, 2689d6025579SChris Mason btrfs_leaf_data(right) + 2690123abc88SChris Mason leaf_data_end(root, right), push_space); 26915f39d397SChris Mason 26925f39d397SChris Mason memmove_extent_buffer(right, btrfs_item_nr_offset(0), 26935f39d397SChris Mason btrfs_item_nr_offset(push_items), 26945f39d397SChris Mason (btrfs_header_nritems(right) - push_items) * 26950783fcfcSChris Mason sizeof(struct btrfs_item)); 269634a38218SChris Mason } 2697eef1c494SYan right_nritems -= push_items; 2698eef1c494SYan btrfs_set_header_nritems(right, right_nritems); 2699123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root); 27005f39d397SChris Mason for (i = 0; i < right_nritems; i++) { 27015f39d397SChris Mason item = btrfs_item_nr(right, i); 2702db94535dSChris Mason 2703db94535dSChris Mason if (!right->map_token) { 2704db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2705db94535dSChris Mason sizeof(struct btrfs_item), 2706db94535dSChris Mason &right->map_token, &right->kaddr, 2707db94535dSChris Mason &right->map_start, &right->map_len, 2708db94535dSChris Mason KM_USER1); 2709db94535dSChris Mason } 2710db94535dSChris Mason 2711db94535dSChris Mason push_space = push_space - btrfs_item_size(right, item); 2712db94535dSChris Mason btrfs_set_item_offset(right, item, push_space); 2713db94535dSChris Mason } 2714db94535dSChris Mason if (right->map_token) { 2715db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2716db94535dSChris Mason right->map_token = NULL; 2717be0e5c09SChris Mason } 2718eb60ceacSChris Mason 27195f39d397SChris Mason btrfs_mark_buffer_dirty(left); 272034a38218SChris Mason if (right_nritems) 27215f39d397SChris Mason btrfs_mark_buffer_dirty(right); 2722098f59c2SChris Mason 272331840ae1SZheng Yan ret = btrfs_update_ref(trans, root, right, left, 272431840ae1SZheng Yan old_left_nritems, push_items); 272531840ae1SZheng Yan BUG_ON(ret); 272631840ae1SZheng Yan 27275f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 27285f39d397SChris Mason wret = fixup_low_keys(trans, root, path, &disk_key, 1); 2729aa5d6bedSChris Mason if (wret) 2730aa5d6bedSChris Mason ret = wret; 2731be0e5c09SChris Mason 2732be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 2733be0e5c09SChris Mason if (path->slots[0] < push_items) { 2734be0e5c09SChris Mason path->slots[0] += old_left_nritems; 2735925baeddSChris Mason if (btrfs_header_nritems(path->nodes[0]) == 0) 2736925baeddSChris Mason clean_tree_block(trans, root, path->nodes[0]); 2737925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 27385f39d397SChris Mason free_extent_buffer(path->nodes[0]); 27395f39d397SChris Mason path->nodes[0] = left; 2740be0e5c09SChris Mason path->slots[1] -= 1; 2741be0e5c09SChris Mason } else { 2742925baeddSChris Mason btrfs_tree_unlock(left); 27435f39d397SChris Mason free_extent_buffer(left); 2744be0e5c09SChris Mason path->slots[0] -= push_items; 2745be0e5c09SChris Mason } 2746eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 2747aa5d6bedSChris Mason return ret; 2748925baeddSChris Mason out: 2749925baeddSChris Mason btrfs_tree_unlock(left); 2750925baeddSChris Mason free_extent_buffer(left); 2751925baeddSChris Mason return ret; 2752be0e5c09SChris Mason } 2753be0e5c09SChris Mason 275474123bd7SChris Mason /* 275544871b1bSChris Mason * push some data in the path leaf to the left, trying to free up at 275644871b1bSChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 275744871b1bSChris Mason */ 275844871b1bSChris Mason static int push_leaf_left(struct btrfs_trans_handle *trans, struct btrfs_root 275944871b1bSChris Mason *root, struct btrfs_path *path, int data_size, 276044871b1bSChris Mason int empty) 276144871b1bSChris Mason { 276244871b1bSChris Mason struct extent_buffer *right = path->nodes[0]; 276344871b1bSChris Mason struct extent_buffer *left; 276444871b1bSChris Mason int slot; 276544871b1bSChris Mason int free_space; 276644871b1bSChris Mason u32 right_nritems; 276744871b1bSChris Mason int ret = 0; 276844871b1bSChris Mason 276944871b1bSChris Mason slot = path->slots[1]; 277044871b1bSChris Mason if (slot == 0) 277144871b1bSChris Mason return 1; 277244871b1bSChris Mason if (!path->nodes[1]) 277344871b1bSChris Mason return 1; 277444871b1bSChris Mason 277544871b1bSChris Mason right_nritems = btrfs_header_nritems(right); 277644871b1bSChris Mason if (right_nritems == 0) 277744871b1bSChris Mason return 1; 277844871b1bSChris Mason 277944871b1bSChris Mason btrfs_assert_tree_locked(path->nodes[1]); 278044871b1bSChris Mason 278144871b1bSChris Mason left = read_node_slot(root, path->nodes[1], slot - 1); 278244871b1bSChris Mason btrfs_tree_lock(left); 278344871b1bSChris Mason btrfs_set_lock_blocking(left); 278444871b1bSChris Mason 278544871b1bSChris Mason free_space = btrfs_leaf_free_space(root, left); 278644871b1bSChris Mason if (free_space < data_size) { 278744871b1bSChris Mason ret = 1; 278844871b1bSChris Mason goto out; 278944871b1bSChris Mason } 279044871b1bSChris Mason 279144871b1bSChris Mason /* cow and double check */ 279244871b1bSChris Mason ret = btrfs_cow_block(trans, root, left, 279344871b1bSChris Mason path->nodes[1], slot - 1, &left); 279444871b1bSChris Mason if (ret) { 279544871b1bSChris Mason /* we hit -ENOSPC, but it isn't fatal here */ 279644871b1bSChris Mason ret = 1; 279744871b1bSChris Mason goto out; 279844871b1bSChris Mason } 279944871b1bSChris Mason 280044871b1bSChris Mason free_space = btrfs_leaf_free_space(root, left); 280144871b1bSChris Mason if (free_space < data_size) { 280244871b1bSChris Mason ret = 1; 280344871b1bSChris Mason goto out; 280444871b1bSChris Mason } 280544871b1bSChris Mason 280644871b1bSChris Mason return __push_leaf_left(trans, root, path, data_size, 280744871b1bSChris Mason empty, left, free_space, right_nritems); 280844871b1bSChris Mason out: 280944871b1bSChris Mason btrfs_tree_unlock(left); 281044871b1bSChris Mason free_extent_buffer(left); 281144871b1bSChris Mason return ret; 281244871b1bSChris Mason } 281344871b1bSChris Mason 281444871b1bSChris Mason /* 281574123bd7SChris Mason * split the path's leaf in two, making sure there is at least data_size 281674123bd7SChris Mason * available for the resulting leaf level of the path. 2817aa5d6bedSChris Mason * 2818aa5d6bedSChris Mason * returns 0 if all went well and < 0 on failure. 281974123bd7SChris Mason */ 282044871b1bSChris Mason static noinline int copy_for_split(struct btrfs_trans_handle *trans, 2821e02119d5SChris Mason struct btrfs_root *root, 282244871b1bSChris Mason struct btrfs_path *path, 282344871b1bSChris Mason struct extent_buffer *l, 282444871b1bSChris Mason struct extent_buffer *right, 282544871b1bSChris Mason int slot, int mid, int nritems) 2826be0e5c09SChris Mason { 2827be0e5c09SChris Mason int data_copy_size; 2828be0e5c09SChris Mason int rt_data_off; 2829be0e5c09SChris Mason int i; 2830d4dbff95SChris Mason int ret = 0; 2831aa5d6bedSChris Mason int wret; 2832d4dbff95SChris Mason struct btrfs_disk_key disk_key; 2833be0e5c09SChris Mason 28345f39d397SChris Mason nritems = nritems - mid; 28355f39d397SChris Mason btrfs_set_header_nritems(right, nritems); 28365f39d397SChris Mason data_copy_size = btrfs_item_end_nr(l, mid) - leaf_data_end(root, l); 28375f39d397SChris Mason 28385f39d397SChris Mason copy_extent_buffer(right, l, btrfs_item_nr_offset(0), 28395f39d397SChris Mason btrfs_item_nr_offset(mid), 28405f39d397SChris Mason nritems * sizeof(struct btrfs_item)); 28415f39d397SChris Mason 28425f39d397SChris Mason copy_extent_buffer(right, l, 2843d6025579SChris Mason btrfs_leaf_data(right) + BTRFS_LEAF_DATA_SIZE(root) - 2844123abc88SChris Mason data_copy_size, btrfs_leaf_data(l) + 2845123abc88SChris Mason leaf_data_end(root, l), data_copy_size); 284674123bd7SChris Mason 28475f39d397SChris Mason rt_data_off = BTRFS_LEAF_DATA_SIZE(root) - 28485f39d397SChris Mason btrfs_item_end_nr(l, mid); 28495f39d397SChris Mason 28505f39d397SChris Mason for (i = 0; i < nritems; i++) { 28515f39d397SChris Mason struct btrfs_item *item = btrfs_item_nr(right, i); 2852db94535dSChris Mason u32 ioff; 2853db94535dSChris Mason 2854db94535dSChris Mason if (!right->map_token) { 2855db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2856db94535dSChris Mason sizeof(struct btrfs_item), 2857db94535dSChris Mason &right->map_token, &right->kaddr, 2858db94535dSChris Mason &right->map_start, &right->map_len, 2859db94535dSChris Mason KM_USER1); 2860db94535dSChris Mason } 2861db94535dSChris Mason 2862db94535dSChris Mason ioff = btrfs_item_offset(right, item); 28635f39d397SChris Mason btrfs_set_item_offset(right, item, ioff + rt_data_off); 28640783fcfcSChris Mason } 286574123bd7SChris Mason 2866db94535dSChris Mason if (right->map_token) { 2867db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2868db94535dSChris Mason right->map_token = NULL; 2869db94535dSChris Mason } 2870db94535dSChris Mason 28715f39d397SChris Mason btrfs_set_header_nritems(l, mid); 2872aa5d6bedSChris Mason ret = 0; 28735f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 2874db94535dSChris Mason wret = insert_ptr(trans, root, path, &disk_key, right->start, 2875db94535dSChris Mason path->slots[1] + 1, 1); 2876aa5d6bedSChris Mason if (wret) 2877aa5d6bedSChris Mason ret = wret; 28785f39d397SChris Mason 28795f39d397SChris Mason btrfs_mark_buffer_dirty(right); 28805f39d397SChris Mason btrfs_mark_buffer_dirty(l); 2881eb60ceacSChris Mason BUG_ON(path->slots[0] != slot); 28825f39d397SChris Mason 288331840ae1SZheng Yan ret = btrfs_update_ref(trans, root, l, right, 0, nritems); 288431840ae1SZheng Yan BUG_ON(ret); 288531840ae1SZheng Yan 2886be0e5c09SChris Mason if (mid <= slot) { 2887925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 28885f39d397SChris Mason free_extent_buffer(path->nodes[0]); 28895f39d397SChris Mason path->nodes[0] = right; 2890be0e5c09SChris Mason path->slots[0] -= mid; 2891be0e5c09SChris Mason path->slots[1] += 1; 2892925baeddSChris Mason } else { 2893925baeddSChris Mason btrfs_tree_unlock(right); 28945f39d397SChris Mason free_extent_buffer(right); 2895925baeddSChris Mason } 28965f39d397SChris Mason 2897eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 2898d4dbff95SChris Mason 289944871b1bSChris Mason return ret; 290044871b1bSChris Mason } 290144871b1bSChris Mason 290244871b1bSChris Mason /* 290344871b1bSChris Mason * split the path's leaf in two, making sure there is at least data_size 290444871b1bSChris Mason * available for the resulting leaf level of the path. 290544871b1bSChris Mason * 290644871b1bSChris Mason * returns 0 if all went well and < 0 on failure. 290744871b1bSChris Mason */ 290844871b1bSChris Mason static noinline int split_leaf(struct btrfs_trans_handle *trans, 290944871b1bSChris Mason struct btrfs_root *root, 291044871b1bSChris Mason struct btrfs_key *ins_key, 291144871b1bSChris Mason struct btrfs_path *path, int data_size, 291244871b1bSChris Mason int extend) 291344871b1bSChris Mason { 291444871b1bSChris Mason struct extent_buffer *l; 291544871b1bSChris Mason u32 nritems; 291644871b1bSChris Mason int mid; 291744871b1bSChris Mason int slot; 291844871b1bSChris Mason struct extent_buffer *right; 291944871b1bSChris Mason int ret = 0; 292044871b1bSChris Mason int wret; 292144871b1bSChris Mason int double_split; 292244871b1bSChris Mason int num_doubles = 0; 292344871b1bSChris Mason 292444871b1bSChris Mason /* first try to make some room by pushing left and right */ 2925a4b6e07dSChris Mason if (data_size && ins_key->type != BTRFS_DIR_ITEM_KEY && 2926a4b6e07dSChris Mason !trans->transaction->delayed_refs.flushing) { 292744871b1bSChris Mason wret = push_leaf_right(trans, root, path, data_size, 0); 292844871b1bSChris Mason if (wret < 0) 292944871b1bSChris Mason return wret; 293044871b1bSChris Mason if (wret) { 293144871b1bSChris Mason wret = push_leaf_left(trans, root, path, data_size, 0); 293244871b1bSChris Mason if (wret < 0) 293344871b1bSChris Mason return wret; 293444871b1bSChris Mason } 293544871b1bSChris Mason l = path->nodes[0]; 293644871b1bSChris Mason 293744871b1bSChris Mason /* did the pushes work? */ 293844871b1bSChris Mason if (btrfs_leaf_free_space(root, l) >= data_size) 293944871b1bSChris Mason return 0; 294044871b1bSChris Mason } 294144871b1bSChris Mason 294244871b1bSChris Mason if (!path->nodes[1]) { 294344871b1bSChris Mason ret = insert_new_root(trans, root, path, 1); 294444871b1bSChris Mason if (ret) 294544871b1bSChris Mason return ret; 294644871b1bSChris Mason } 294744871b1bSChris Mason again: 294844871b1bSChris Mason double_split = 0; 294944871b1bSChris Mason l = path->nodes[0]; 295044871b1bSChris Mason slot = path->slots[0]; 295144871b1bSChris Mason nritems = btrfs_header_nritems(l); 295244871b1bSChris Mason mid = (nritems + 1) / 2; 295344871b1bSChris Mason 295444871b1bSChris Mason right = btrfs_alloc_free_block(trans, root, root->leafsize, 295544871b1bSChris Mason path->nodes[1]->start, 295644871b1bSChris Mason root->root_key.objectid, 295744871b1bSChris Mason trans->transid, 0, l->start, 0); 295844871b1bSChris Mason if (IS_ERR(right)) { 295944871b1bSChris Mason BUG_ON(1); 296044871b1bSChris Mason return PTR_ERR(right); 296144871b1bSChris Mason } 296244871b1bSChris Mason 296344871b1bSChris Mason memset_extent_buffer(right, 0, 0, sizeof(struct btrfs_header)); 296444871b1bSChris Mason btrfs_set_header_bytenr(right, right->start); 296544871b1bSChris Mason btrfs_set_header_generation(right, trans->transid); 296644871b1bSChris Mason btrfs_set_header_owner(right, root->root_key.objectid); 296744871b1bSChris Mason btrfs_set_header_level(right, 0); 296844871b1bSChris Mason write_extent_buffer(right, root->fs_info->fsid, 296944871b1bSChris Mason (unsigned long)btrfs_header_fsid(right), 297044871b1bSChris Mason BTRFS_FSID_SIZE); 297144871b1bSChris Mason 297244871b1bSChris Mason write_extent_buffer(right, root->fs_info->chunk_tree_uuid, 297344871b1bSChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(right), 297444871b1bSChris Mason BTRFS_UUID_SIZE); 297544871b1bSChris Mason 297644871b1bSChris Mason if (mid <= slot) { 297744871b1bSChris Mason if (nritems == 1 || 297844871b1bSChris Mason leaf_space_used(l, mid, nritems - mid) + data_size > 297944871b1bSChris Mason BTRFS_LEAF_DATA_SIZE(root)) { 298044871b1bSChris Mason if (slot >= nritems) { 298144871b1bSChris Mason struct btrfs_disk_key disk_key; 298244871b1bSChris Mason 298344871b1bSChris Mason btrfs_cpu_key_to_disk(&disk_key, ins_key); 298444871b1bSChris Mason btrfs_set_header_nritems(right, 0); 298544871b1bSChris Mason wret = insert_ptr(trans, root, path, 298644871b1bSChris Mason &disk_key, right->start, 298744871b1bSChris Mason path->slots[1] + 1, 1); 298844871b1bSChris Mason if (wret) 298944871b1bSChris Mason ret = wret; 299044871b1bSChris Mason 299144871b1bSChris Mason btrfs_tree_unlock(path->nodes[0]); 299244871b1bSChris Mason free_extent_buffer(path->nodes[0]); 299344871b1bSChris Mason path->nodes[0] = right; 299444871b1bSChris Mason path->slots[0] = 0; 299544871b1bSChris Mason path->slots[1] += 1; 299644871b1bSChris Mason btrfs_mark_buffer_dirty(right); 299744871b1bSChris Mason return ret; 299844871b1bSChris Mason } 299944871b1bSChris Mason mid = slot; 300044871b1bSChris Mason if (mid != nritems && 300144871b1bSChris Mason leaf_space_used(l, mid, nritems - mid) + 300244871b1bSChris Mason data_size > BTRFS_LEAF_DATA_SIZE(root)) { 300344871b1bSChris Mason double_split = 1; 300444871b1bSChris Mason } 300544871b1bSChris Mason } 300644871b1bSChris Mason } else { 300744871b1bSChris Mason if (leaf_space_used(l, 0, mid) + data_size > 300844871b1bSChris Mason BTRFS_LEAF_DATA_SIZE(root)) { 300944871b1bSChris Mason if (!extend && data_size && slot == 0) { 301044871b1bSChris Mason struct btrfs_disk_key disk_key; 301144871b1bSChris Mason 301244871b1bSChris Mason btrfs_cpu_key_to_disk(&disk_key, ins_key); 301344871b1bSChris Mason btrfs_set_header_nritems(right, 0); 301444871b1bSChris Mason wret = insert_ptr(trans, root, path, 301544871b1bSChris Mason &disk_key, 301644871b1bSChris Mason right->start, 301744871b1bSChris Mason path->slots[1], 1); 301844871b1bSChris Mason if (wret) 301944871b1bSChris Mason ret = wret; 302044871b1bSChris Mason btrfs_tree_unlock(path->nodes[0]); 302144871b1bSChris Mason free_extent_buffer(path->nodes[0]); 302244871b1bSChris Mason path->nodes[0] = right; 302344871b1bSChris Mason path->slots[0] = 0; 302444871b1bSChris Mason if (path->slots[1] == 0) { 302544871b1bSChris Mason wret = fixup_low_keys(trans, root, 302644871b1bSChris Mason path, &disk_key, 1); 302744871b1bSChris Mason if (wret) 302844871b1bSChris Mason ret = wret; 302944871b1bSChris Mason } 303044871b1bSChris Mason btrfs_mark_buffer_dirty(right); 303144871b1bSChris Mason return ret; 303244871b1bSChris Mason } else if ((extend || !data_size) && slot == 0) { 303344871b1bSChris Mason mid = 1; 303444871b1bSChris Mason } else { 303544871b1bSChris Mason mid = slot; 303644871b1bSChris Mason if (mid != nritems && 303744871b1bSChris Mason leaf_space_used(l, mid, nritems - mid) + 303844871b1bSChris Mason data_size > BTRFS_LEAF_DATA_SIZE(root)) { 303944871b1bSChris Mason double_split = 1; 304044871b1bSChris Mason } 304144871b1bSChris Mason } 304244871b1bSChris Mason } 304344871b1bSChris Mason } 304444871b1bSChris Mason 304544871b1bSChris Mason ret = copy_for_split(trans, root, path, l, right, slot, mid, nritems); 304644871b1bSChris Mason BUG_ON(ret); 304744871b1bSChris Mason 3048cc0c5538SChris Mason if (double_split) { 3049cc0c5538SChris Mason BUG_ON(num_doubles != 0); 3050cc0c5538SChris Mason num_doubles++; 3051cc0c5538SChris Mason goto again; 30523326d1b0SChris Mason } 305344871b1bSChris Mason 3054be0e5c09SChris Mason return ret; 3055be0e5c09SChris Mason } 3056be0e5c09SChris Mason 3057d352ac68SChris Mason /* 3058459931ecSChris Mason * This function splits a single item into two items, 3059459931ecSChris Mason * giving 'new_key' to the new item and splitting the 3060459931ecSChris Mason * old one at split_offset (from the start of the item). 3061459931ecSChris Mason * 3062459931ecSChris Mason * The path may be released by this operation. After 3063459931ecSChris Mason * the split, the path is pointing to the old item. The 3064459931ecSChris Mason * new item is going to be in the same node as the old one. 3065459931ecSChris Mason * 3066459931ecSChris Mason * Note, the item being split must be smaller enough to live alone on 3067459931ecSChris Mason * a tree block with room for one extra struct btrfs_item 3068459931ecSChris Mason * 3069459931ecSChris Mason * This allows us to split the item in place, keeping a lock on the 3070459931ecSChris Mason * leaf the entire time. 3071459931ecSChris Mason */ 3072459931ecSChris Mason int btrfs_split_item(struct btrfs_trans_handle *trans, 3073459931ecSChris Mason struct btrfs_root *root, 3074459931ecSChris Mason struct btrfs_path *path, 3075459931ecSChris Mason struct btrfs_key *new_key, 3076459931ecSChris Mason unsigned long split_offset) 3077459931ecSChris Mason { 3078459931ecSChris Mason u32 item_size; 3079459931ecSChris Mason struct extent_buffer *leaf; 3080459931ecSChris Mason struct btrfs_key orig_key; 3081459931ecSChris Mason struct btrfs_item *item; 3082459931ecSChris Mason struct btrfs_item *new_item; 3083459931ecSChris Mason int ret = 0; 3084459931ecSChris Mason int slot; 3085459931ecSChris Mason u32 nritems; 3086459931ecSChris Mason u32 orig_offset; 3087459931ecSChris Mason struct btrfs_disk_key disk_key; 3088459931ecSChris Mason char *buf; 3089459931ecSChris Mason 3090459931ecSChris Mason leaf = path->nodes[0]; 3091459931ecSChris Mason btrfs_item_key_to_cpu(leaf, &orig_key, path->slots[0]); 3092459931ecSChris Mason if (btrfs_leaf_free_space(root, leaf) >= sizeof(struct btrfs_item)) 3093459931ecSChris Mason goto split; 3094459931ecSChris Mason 3095459931ecSChris Mason item_size = btrfs_item_size_nr(leaf, path->slots[0]); 3096459931ecSChris Mason btrfs_release_path(root, path); 3097459931ecSChris Mason 3098459931ecSChris Mason path->search_for_split = 1; 3099459931ecSChris Mason path->keep_locks = 1; 3100459931ecSChris Mason 3101459931ecSChris Mason ret = btrfs_search_slot(trans, root, &orig_key, path, 0, 1); 3102459931ecSChris Mason path->search_for_split = 0; 3103459931ecSChris Mason 3104459931ecSChris Mason /* if our item isn't there or got smaller, return now */ 3105459931ecSChris Mason if (ret != 0 || item_size != btrfs_item_size_nr(path->nodes[0], 3106459931ecSChris Mason path->slots[0])) { 3107459931ecSChris Mason path->keep_locks = 0; 3108459931ecSChris Mason return -EAGAIN; 3109459931ecSChris Mason } 3110459931ecSChris Mason 3111b9473439SChris Mason btrfs_set_path_blocking(path); 311287b29b20SYan Zheng ret = split_leaf(trans, root, &orig_key, path, 311387b29b20SYan Zheng sizeof(struct btrfs_item), 1); 3114459931ecSChris Mason path->keep_locks = 0; 3115459931ecSChris Mason BUG_ON(ret); 3116459931ecSChris Mason 3117b9473439SChris Mason btrfs_unlock_up_safe(path, 1); 3118b9473439SChris Mason leaf = path->nodes[0]; 3119b9473439SChris Mason BUG_ON(btrfs_leaf_free_space(root, leaf) < sizeof(struct btrfs_item)); 3120b9473439SChris Mason 3121b9473439SChris Mason split: 3122b4ce94deSChris Mason /* 3123b4ce94deSChris Mason * make sure any changes to the path from split_leaf leave it 3124b4ce94deSChris Mason * in a blocking state 3125b4ce94deSChris Mason */ 3126b4ce94deSChris Mason btrfs_set_path_blocking(path); 3127b4ce94deSChris Mason 3128459931ecSChris Mason item = btrfs_item_nr(leaf, path->slots[0]); 3129459931ecSChris Mason orig_offset = btrfs_item_offset(leaf, item); 3130459931ecSChris Mason item_size = btrfs_item_size(leaf, item); 3131459931ecSChris Mason 3132459931ecSChris Mason buf = kmalloc(item_size, GFP_NOFS); 3133459931ecSChris Mason read_extent_buffer(leaf, buf, btrfs_item_ptr_offset(leaf, 3134459931ecSChris Mason path->slots[0]), item_size); 3135459931ecSChris Mason slot = path->slots[0] + 1; 3136459931ecSChris Mason leaf = path->nodes[0]; 3137459931ecSChris Mason 3138459931ecSChris Mason nritems = btrfs_header_nritems(leaf); 3139459931ecSChris Mason 3140459931ecSChris Mason if (slot != nritems) { 3141459931ecSChris Mason /* shift the items */ 3142459931ecSChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + 1), 3143459931ecSChris Mason btrfs_item_nr_offset(slot), 3144459931ecSChris Mason (nritems - slot) * sizeof(struct btrfs_item)); 3145459931ecSChris Mason 3146459931ecSChris Mason } 3147459931ecSChris Mason 3148459931ecSChris Mason btrfs_cpu_key_to_disk(&disk_key, new_key); 3149459931ecSChris Mason btrfs_set_item_key(leaf, &disk_key, slot); 3150459931ecSChris Mason 3151459931ecSChris Mason new_item = btrfs_item_nr(leaf, slot); 3152459931ecSChris Mason 3153459931ecSChris Mason btrfs_set_item_offset(leaf, new_item, orig_offset); 3154459931ecSChris Mason btrfs_set_item_size(leaf, new_item, item_size - split_offset); 3155459931ecSChris Mason 3156459931ecSChris Mason btrfs_set_item_offset(leaf, item, 3157459931ecSChris Mason orig_offset + item_size - split_offset); 3158459931ecSChris Mason btrfs_set_item_size(leaf, item, split_offset); 3159459931ecSChris Mason 3160459931ecSChris Mason btrfs_set_header_nritems(leaf, nritems + 1); 3161459931ecSChris Mason 3162459931ecSChris Mason /* write the data for the start of the original item */ 3163459931ecSChris Mason write_extent_buffer(leaf, buf, 3164459931ecSChris Mason btrfs_item_ptr_offset(leaf, path->slots[0]), 3165459931ecSChris Mason split_offset); 3166459931ecSChris Mason 3167459931ecSChris Mason /* write the data for the new item */ 3168459931ecSChris Mason write_extent_buffer(leaf, buf + split_offset, 3169459931ecSChris Mason btrfs_item_ptr_offset(leaf, slot), 3170459931ecSChris Mason item_size - split_offset); 3171459931ecSChris Mason btrfs_mark_buffer_dirty(leaf); 3172459931ecSChris Mason 3173459931ecSChris Mason ret = 0; 3174459931ecSChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 3175459931ecSChris Mason btrfs_print_leaf(root, leaf); 3176459931ecSChris Mason BUG(); 3177459931ecSChris Mason } 3178459931ecSChris Mason kfree(buf); 3179459931ecSChris Mason return ret; 3180459931ecSChris Mason } 3181459931ecSChris Mason 3182459931ecSChris Mason /* 3183d352ac68SChris Mason * make the item pointed to by the path smaller. new_size indicates 3184d352ac68SChris Mason * how small to make it, and from_end tells us if we just chop bytes 3185d352ac68SChris Mason * off the end of the item or if we shift the item to chop bytes off 3186d352ac68SChris Mason * the front. 3187d352ac68SChris Mason */ 3188b18c6685SChris Mason int btrfs_truncate_item(struct btrfs_trans_handle *trans, 3189b18c6685SChris Mason struct btrfs_root *root, 3190b18c6685SChris Mason struct btrfs_path *path, 3191179e29e4SChris Mason u32 new_size, int from_end) 3192b18c6685SChris Mason { 3193b18c6685SChris Mason int ret = 0; 3194b18c6685SChris Mason int slot; 3195b18c6685SChris Mason int slot_orig; 31965f39d397SChris Mason struct extent_buffer *leaf; 31975f39d397SChris Mason struct btrfs_item *item; 3198b18c6685SChris Mason u32 nritems; 3199b18c6685SChris Mason unsigned int data_end; 3200b18c6685SChris Mason unsigned int old_data_start; 3201b18c6685SChris Mason unsigned int old_size; 3202b18c6685SChris Mason unsigned int size_diff; 3203b18c6685SChris Mason int i; 3204b18c6685SChris Mason 3205b18c6685SChris Mason slot_orig = path->slots[0]; 32065f39d397SChris Mason leaf = path->nodes[0]; 3207179e29e4SChris Mason slot = path->slots[0]; 3208179e29e4SChris Mason 3209179e29e4SChris Mason old_size = btrfs_item_size_nr(leaf, slot); 3210179e29e4SChris Mason if (old_size == new_size) 3211179e29e4SChris Mason return 0; 3212b18c6685SChris Mason 32135f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3214b18c6685SChris Mason data_end = leaf_data_end(root, leaf); 3215b18c6685SChris Mason 32165f39d397SChris Mason old_data_start = btrfs_item_offset_nr(leaf, slot); 3217179e29e4SChris Mason 3218b18c6685SChris Mason size_diff = old_size - new_size; 3219b18c6685SChris Mason 3220b18c6685SChris Mason BUG_ON(slot < 0); 3221b18c6685SChris Mason BUG_ON(slot >= nritems); 3222b18c6685SChris Mason 3223b18c6685SChris Mason /* 3224b18c6685SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 3225b18c6685SChris Mason */ 3226b18c6685SChris Mason /* first correct the data pointers */ 3227b18c6685SChris Mason for (i = slot; i < nritems; i++) { 32285f39d397SChris Mason u32 ioff; 32295f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3230db94535dSChris Mason 3231db94535dSChris Mason if (!leaf->map_token) { 3232db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3233db94535dSChris Mason sizeof(struct btrfs_item), 3234db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3235db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3236db94535dSChris Mason KM_USER1); 3237db94535dSChris Mason } 3238db94535dSChris Mason 32395f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 32405f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff + size_diff); 3241b18c6685SChris Mason } 3242db94535dSChris Mason 3243db94535dSChris Mason if (leaf->map_token) { 3244db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3245db94535dSChris Mason leaf->map_token = NULL; 3246db94535dSChris Mason } 3247db94535dSChris Mason 3248b18c6685SChris Mason /* shift the data */ 3249179e29e4SChris Mason if (from_end) { 32505f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3251b18c6685SChris Mason data_end + size_diff, btrfs_leaf_data(leaf) + 3252b18c6685SChris Mason data_end, old_data_start + new_size - data_end); 3253179e29e4SChris Mason } else { 3254179e29e4SChris Mason struct btrfs_disk_key disk_key; 3255179e29e4SChris Mason u64 offset; 3256179e29e4SChris Mason 3257179e29e4SChris Mason btrfs_item_key(leaf, &disk_key, slot); 3258179e29e4SChris Mason 3259179e29e4SChris Mason if (btrfs_disk_key_type(&disk_key) == BTRFS_EXTENT_DATA_KEY) { 3260179e29e4SChris Mason unsigned long ptr; 3261179e29e4SChris Mason struct btrfs_file_extent_item *fi; 3262179e29e4SChris Mason 3263179e29e4SChris Mason fi = btrfs_item_ptr(leaf, slot, 3264179e29e4SChris Mason struct btrfs_file_extent_item); 3265179e29e4SChris Mason fi = (struct btrfs_file_extent_item *)( 3266179e29e4SChris Mason (unsigned long)fi - size_diff); 3267179e29e4SChris Mason 3268179e29e4SChris Mason if (btrfs_file_extent_type(leaf, fi) == 3269179e29e4SChris Mason BTRFS_FILE_EXTENT_INLINE) { 3270179e29e4SChris Mason ptr = btrfs_item_ptr_offset(leaf, slot); 3271179e29e4SChris Mason memmove_extent_buffer(leaf, ptr, 3272179e29e4SChris Mason (unsigned long)fi, 3273179e29e4SChris Mason offsetof(struct btrfs_file_extent_item, 3274179e29e4SChris Mason disk_bytenr)); 3275179e29e4SChris Mason } 3276179e29e4SChris Mason } 3277179e29e4SChris Mason 3278179e29e4SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3279179e29e4SChris Mason data_end + size_diff, btrfs_leaf_data(leaf) + 3280179e29e4SChris Mason data_end, old_data_start - data_end); 3281179e29e4SChris Mason 3282179e29e4SChris Mason offset = btrfs_disk_key_offset(&disk_key); 3283179e29e4SChris Mason btrfs_set_disk_key_offset(&disk_key, offset + size_diff); 3284179e29e4SChris Mason btrfs_set_item_key(leaf, &disk_key, slot); 3285179e29e4SChris Mason if (slot == 0) 3286179e29e4SChris Mason fixup_low_keys(trans, root, path, &disk_key, 1); 3287179e29e4SChris Mason } 32885f39d397SChris Mason 32895f39d397SChris Mason item = btrfs_item_nr(leaf, slot); 32905f39d397SChris Mason btrfs_set_item_size(leaf, item, new_size); 32915f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 3292b18c6685SChris Mason 3293b18c6685SChris Mason ret = 0; 32945f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 32955f39d397SChris Mason btrfs_print_leaf(root, leaf); 3296b18c6685SChris Mason BUG(); 32975f39d397SChris Mason } 3298b18c6685SChris Mason return ret; 3299b18c6685SChris Mason } 3300b18c6685SChris Mason 3301d352ac68SChris Mason /* 3302d352ac68SChris Mason * make the item pointed to by the path bigger, data_size is the new size. 3303d352ac68SChris Mason */ 33045f39d397SChris Mason int btrfs_extend_item(struct btrfs_trans_handle *trans, 33055f39d397SChris Mason struct btrfs_root *root, struct btrfs_path *path, 33065f39d397SChris Mason u32 data_size) 33076567e837SChris Mason { 33086567e837SChris Mason int ret = 0; 33096567e837SChris Mason int slot; 33106567e837SChris Mason int slot_orig; 33115f39d397SChris Mason struct extent_buffer *leaf; 33125f39d397SChris Mason struct btrfs_item *item; 33136567e837SChris Mason u32 nritems; 33146567e837SChris Mason unsigned int data_end; 33156567e837SChris Mason unsigned int old_data; 33166567e837SChris Mason unsigned int old_size; 33176567e837SChris Mason int i; 33186567e837SChris Mason 33196567e837SChris Mason slot_orig = path->slots[0]; 33205f39d397SChris Mason leaf = path->nodes[0]; 33216567e837SChris Mason 33225f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 33236567e837SChris Mason data_end = leaf_data_end(root, leaf); 33246567e837SChris Mason 33255f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < data_size) { 33265f39d397SChris Mason btrfs_print_leaf(root, leaf); 33276567e837SChris Mason BUG(); 33285f39d397SChris Mason } 33296567e837SChris Mason slot = path->slots[0]; 33305f39d397SChris Mason old_data = btrfs_item_end_nr(leaf, slot); 33316567e837SChris Mason 33326567e837SChris Mason BUG_ON(slot < 0); 33333326d1b0SChris Mason if (slot >= nritems) { 33343326d1b0SChris Mason btrfs_print_leaf(root, leaf); 3335d397712bSChris Mason printk(KERN_CRIT "slot %d too large, nritems %d\n", 3336d397712bSChris Mason slot, nritems); 33373326d1b0SChris Mason BUG_ON(1); 33383326d1b0SChris Mason } 33396567e837SChris Mason 33406567e837SChris Mason /* 33416567e837SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 33426567e837SChris Mason */ 33436567e837SChris Mason /* first correct the data pointers */ 33446567e837SChris Mason for (i = slot; i < nritems; i++) { 33455f39d397SChris Mason u32 ioff; 33465f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3347db94535dSChris Mason 3348db94535dSChris Mason if (!leaf->map_token) { 3349db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3350db94535dSChris Mason sizeof(struct btrfs_item), 3351db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3352db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3353db94535dSChris Mason KM_USER1); 3354db94535dSChris Mason } 33555f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 33565f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff - data_size); 33576567e837SChris Mason } 33585f39d397SChris Mason 3359db94535dSChris Mason if (leaf->map_token) { 3360db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3361db94535dSChris Mason leaf->map_token = NULL; 3362db94535dSChris Mason } 3363db94535dSChris Mason 33646567e837SChris Mason /* shift the data */ 33655f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 33666567e837SChris Mason data_end - data_size, btrfs_leaf_data(leaf) + 33676567e837SChris Mason data_end, old_data - data_end); 33685f39d397SChris Mason 33696567e837SChris Mason data_end = old_data; 33705f39d397SChris Mason old_size = btrfs_item_size_nr(leaf, slot); 33715f39d397SChris Mason item = btrfs_item_nr(leaf, slot); 33725f39d397SChris Mason btrfs_set_item_size(leaf, item, old_size + data_size); 33735f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 33746567e837SChris Mason 33756567e837SChris Mason ret = 0; 33765f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 33775f39d397SChris Mason btrfs_print_leaf(root, leaf); 33786567e837SChris Mason BUG(); 33795f39d397SChris Mason } 33806567e837SChris Mason return ret; 33816567e837SChris Mason } 33826567e837SChris Mason 338374123bd7SChris Mason /* 3384d352ac68SChris Mason * Given a key and some data, insert items into the tree. 338574123bd7SChris Mason * This does all the path init required, making room in the tree if needed. 3386f3465ca4SJosef Bacik * Returns the number of keys that were inserted. 3387f3465ca4SJosef Bacik */ 3388f3465ca4SJosef Bacik int btrfs_insert_some_items(struct btrfs_trans_handle *trans, 3389f3465ca4SJosef Bacik struct btrfs_root *root, 3390f3465ca4SJosef Bacik struct btrfs_path *path, 3391f3465ca4SJosef Bacik struct btrfs_key *cpu_key, u32 *data_size, 3392f3465ca4SJosef Bacik int nr) 3393f3465ca4SJosef Bacik { 3394f3465ca4SJosef Bacik struct extent_buffer *leaf; 3395f3465ca4SJosef Bacik struct btrfs_item *item; 3396f3465ca4SJosef Bacik int ret = 0; 3397f3465ca4SJosef Bacik int slot; 3398f3465ca4SJosef Bacik int i; 3399f3465ca4SJosef Bacik u32 nritems; 3400f3465ca4SJosef Bacik u32 total_data = 0; 3401f3465ca4SJosef Bacik u32 total_size = 0; 3402f3465ca4SJosef Bacik unsigned int data_end; 3403f3465ca4SJosef Bacik struct btrfs_disk_key disk_key; 3404f3465ca4SJosef Bacik struct btrfs_key found_key; 3405f3465ca4SJosef Bacik 340687b29b20SYan Zheng for (i = 0; i < nr; i++) { 340787b29b20SYan Zheng if (total_size + data_size[i] + sizeof(struct btrfs_item) > 340887b29b20SYan Zheng BTRFS_LEAF_DATA_SIZE(root)) { 340987b29b20SYan Zheng break; 341087b29b20SYan Zheng nr = i; 341187b29b20SYan Zheng } 3412f3465ca4SJosef Bacik total_data += data_size[i]; 341387b29b20SYan Zheng total_size += data_size[i] + sizeof(struct btrfs_item); 341487b29b20SYan Zheng } 341587b29b20SYan Zheng BUG_ON(nr == 0); 3416f3465ca4SJosef Bacik 3417f3465ca4SJosef Bacik ret = btrfs_search_slot(trans, root, cpu_key, path, total_size, 1); 3418f3465ca4SJosef Bacik if (ret == 0) 3419f3465ca4SJosef Bacik return -EEXIST; 3420f3465ca4SJosef Bacik if (ret < 0) 3421f3465ca4SJosef Bacik goto out; 3422f3465ca4SJosef Bacik 3423f3465ca4SJosef Bacik leaf = path->nodes[0]; 3424f3465ca4SJosef Bacik 3425f3465ca4SJosef Bacik nritems = btrfs_header_nritems(leaf); 3426f3465ca4SJosef Bacik data_end = leaf_data_end(root, leaf); 3427f3465ca4SJosef Bacik 3428f3465ca4SJosef Bacik if (btrfs_leaf_free_space(root, leaf) < total_size) { 3429f3465ca4SJosef Bacik for (i = nr; i >= 0; i--) { 3430f3465ca4SJosef Bacik total_data -= data_size[i]; 3431f3465ca4SJosef Bacik total_size -= data_size[i] + sizeof(struct btrfs_item); 3432f3465ca4SJosef Bacik if (total_size < btrfs_leaf_free_space(root, leaf)) 3433f3465ca4SJosef Bacik break; 3434f3465ca4SJosef Bacik } 3435f3465ca4SJosef Bacik nr = i; 3436f3465ca4SJosef Bacik } 3437f3465ca4SJosef Bacik 3438f3465ca4SJosef Bacik slot = path->slots[0]; 3439f3465ca4SJosef Bacik BUG_ON(slot < 0); 3440f3465ca4SJosef Bacik 3441f3465ca4SJosef Bacik if (slot != nritems) { 3442f3465ca4SJosef Bacik unsigned int old_data = btrfs_item_end_nr(leaf, slot); 3443f3465ca4SJosef Bacik 3444f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, slot); 3445f3465ca4SJosef Bacik btrfs_item_key_to_cpu(leaf, &found_key, slot); 3446f3465ca4SJosef Bacik 3447f3465ca4SJosef Bacik /* figure out how many keys we can insert in here */ 3448f3465ca4SJosef Bacik total_data = data_size[0]; 3449f3465ca4SJosef Bacik for (i = 1; i < nr; i++) { 3450f3465ca4SJosef Bacik if (comp_cpu_keys(&found_key, cpu_key + i) <= 0) 3451f3465ca4SJosef Bacik break; 3452f3465ca4SJosef Bacik total_data += data_size[i]; 3453f3465ca4SJosef Bacik } 3454f3465ca4SJosef Bacik nr = i; 3455f3465ca4SJosef Bacik 3456f3465ca4SJosef Bacik if (old_data < data_end) { 3457f3465ca4SJosef Bacik btrfs_print_leaf(root, leaf); 3458d397712bSChris Mason printk(KERN_CRIT "slot %d old_data %d data_end %d\n", 3459f3465ca4SJosef Bacik slot, old_data, data_end); 3460f3465ca4SJosef Bacik BUG_ON(1); 3461f3465ca4SJosef Bacik } 3462f3465ca4SJosef Bacik /* 3463f3465ca4SJosef Bacik * item0..itemN ... dataN.offset..dataN.size .. data0.size 3464f3465ca4SJosef Bacik */ 3465f3465ca4SJosef Bacik /* first correct the data pointers */ 3466f3465ca4SJosef Bacik WARN_ON(leaf->map_token); 3467f3465ca4SJosef Bacik for (i = slot; i < nritems; i++) { 3468f3465ca4SJosef Bacik u32 ioff; 3469f3465ca4SJosef Bacik 3470f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, i); 3471f3465ca4SJosef Bacik if (!leaf->map_token) { 3472f3465ca4SJosef Bacik map_extent_buffer(leaf, (unsigned long)item, 3473f3465ca4SJosef Bacik sizeof(struct btrfs_item), 3474f3465ca4SJosef Bacik &leaf->map_token, &leaf->kaddr, 3475f3465ca4SJosef Bacik &leaf->map_start, &leaf->map_len, 3476f3465ca4SJosef Bacik KM_USER1); 3477f3465ca4SJosef Bacik } 3478f3465ca4SJosef Bacik 3479f3465ca4SJosef Bacik ioff = btrfs_item_offset(leaf, item); 3480f3465ca4SJosef Bacik btrfs_set_item_offset(leaf, item, ioff - total_data); 3481f3465ca4SJosef Bacik } 3482f3465ca4SJosef Bacik if (leaf->map_token) { 3483f3465ca4SJosef Bacik unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3484f3465ca4SJosef Bacik leaf->map_token = NULL; 3485f3465ca4SJosef Bacik } 3486f3465ca4SJosef Bacik 3487f3465ca4SJosef Bacik /* shift the items */ 3488f3465ca4SJosef Bacik memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + nr), 3489f3465ca4SJosef Bacik btrfs_item_nr_offset(slot), 3490f3465ca4SJosef Bacik (nritems - slot) * sizeof(struct btrfs_item)); 3491f3465ca4SJosef Bacik 3492f3465ca4SJosef Bacik /* shift the data */ 3493f3465ca4SJosef Bacik memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3494f3465ca4SJosef Bacik data_end - total_data, btrfs_leaf_data(leaf) + 3495f3465ca4SJosef Bacik data_end, old_data - data_end); 3496f3465ca4SJosef Bacik data_end = old_data; 3497f3465ca4SJosef Bacik } else { 3498f3465ca4SJosef Bacik /* 3499f3465ca4SJosef Bacik * this sucks but it has to be done, if we are inserting at 3500f3465ca4SJosef Bacik * the end of the leaf only insert 1 of the items, since we 3501f3465ca4SJosef Bacik * have no way of knowing whats on the next leaf and we'd have 3502f3465ca4SJosef Bacik * to drop our current locks to figure it out 3503f3465ca4SJosef Bacik */ 3504f3465ca4SJosef Bacik nr = 1; 3505f3465ca4SJosef Bacik } 3506f3465ca4SJosef Bacik 3507f3465ca4SJosef Bacik /* setup the item for the new data */ 3508f3465ca4SJosef Bacik for (i = 0; i < nr; i++) { 3509f3465ca4SJosef Bacik btrfs_cpu_key_to_disk(&disk_key, cpu_key + i); 3510f3465ca4SJosef Bacik btrfs_set_item_key(leaf, &disk_key, slot + i); 3511f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, slot + i); 3512f3465ca4SJosef Bacik btrfs_set_item_offset(leaf, item, data_end - data_size[i]); 3513f3465ca4SJosef Bacik data_end -= data_size[i]; 3514f3465ca4SJosef Bacik btrfs_set_item_size(leaf, item, data_size[i]); 3515f3465ca4SJosef Bacik } 3516f3465ca4SJosef Bacik btrfs_set_header_nritems(leaf, nritems + nr); 3517f3465ca4SJosef Bacik btrfs_mark_buffer_dirty(leaf); 3518f3465ca4SJosef Bacik 3519f3465ca4SJosef Bacik ret = 0; 3520f3465ca4SJosef Bacik if (slot == 0) { 3521f3465ca4SJosef Bacik btrfs_cpu_key_to_disk(&disk_key, cpu_key); 3522f3465ca4SJosef Bacik ret = fixup_low_keys(trans, root, path, &disk_key, 1); 3523f3465ca4SJosef Bacik } 3524f3465ca4SJosef Bacik 3525f3465ca4SJosef Bacik if (btrfs_leaf_free_space(root, leaf) < 0) { 3526f3465ca4SJosef Bacik btrfs_print_leaf(root, leaf); 3527f3465ca4SJosef Bacik BUG(); 3528f3465ca4SJosef Bacik } 3529f3465ca4SJosef Bacik out: 3530f3465ca4SJosef Bacik if (!ret) 3531f3465ca4SJosef Bacik ret = nr; 3532f3465ca4SJosef Bacik return ret; 3533f3465ca4SJosef Bacik } 3534f3465ca4SJosef Bacik 3535f3465ca4SJosef Bacik /* 353644871b1bSChris Mason * this is a helper for btrfs_insert_empty_items, the main goal here is 353744871b1bSChris Mason * to save stack depth by doing the bulk of the work in a function 353844871b1bSChris Mason * that doesn't call btrfs_search_slot 353974123bd7SChris Mason */ 354044871b1bSChris Mason static noinline_for_stack int 354144871b1bSChris Mason setup_items_for_insert(struct btrfs_trans_handle *trans, 354244871b1bSChris Mason struct btrfs_root *root, struct btrfs_path *path, 35439c58309dSChris Mason struct btrfs_key *cpu_key, u32 *data_size, 354444871b1bSChris Mason u32 total_data, u32 total_size, int nr) 3545be0e5c09SChris Mason { 35465f39d397SChris Mason struct btrfs_item *item; 35479c58309dSChris Mason int i; 35487518a238SChris Mason u32 nritems; 3549be0e5c09SChris Mason unsigned int data_end; 3550e2fa7227SChris Mason struct btrfs_disk_key disk_key; 355144871b1bSChris Mason int ret; 355244871b1bSChris Mason struct extent_buffer *leaf; 355344871b1bSChris Mason int slot; 3554e2fa7227SChris Mason 35555f39d397SChris Mason leaf = path->nodes[0]; 355644871b1bSChris Mason slot = path->slots[0]; 355774123bd7SChris Mason 35585f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3559123abc88SChris Mason data_end = leaf_data_end(root, leaf); 3560eb60ceacSChris Mason 3561f25956ccSChris Mason if (btrfs_leaf_free_space(root, leaf) < total_size) { 35623326d1b0SChris Mason btrfs_print_leaf(root, leaf); 3563d397712bSChris Mason printk(KERN_CRIT "not enough freespace need %u have %d\n", 35649c58309dSChris Mason total_size, btrfs_leaf_free_space(root, leaf)); 3565be0e5c09SChris Mason BUG(); 3566d4dbff95SChris Mason } 35675f39d397SChris Mason 3568be0e5c09SChris Mason if (slot != nritems) { 35695f39d397SChris Mason unsigned int old_data = btrfs_item_end_nr(leaf, slot); 3570be0e5c09SChris Mason 35715f39d397SChris Mason if (old_data < data_end) { 35725f39d397SChris Mason btrfs_print_leaf(root, leaf); 3573d397712bSChris Mason printk(KERN_CRIT "slot %d old_data %d data_end %d\n", 35745f39d397SChris Mason slot, old_data, data_end); 35755f39d397SChris Mason BUG_ON(1); 35765f39d397SChris Mason } 3577be0e5c09SChris Mason /* 3578be0e5c09SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 3579be0e5c09SChris Mason */ 3580be0e5c09SChris Mason /* first correct the data pointers */ 3581db94535dSChris Mason WARN_ON(leaf->map_token); 35820783fcfcSChris Mason for (i = slot; i < nritems; i++) { 35835f39d397SChris Mason u32 ioff; 3584db94535dSChris Mason 35855f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3586db94535dSChris Mason if (!leaf->map_token) { 3587db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3588db94535dSChris Mason sizeof(struct btrfs_item), 3589db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3590db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3591db94535dSChris Mason KM_USER1); 3592db94535dSChris Mason } 3593db94535dSChris Mason 35945f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 35959c58309dSChris Mason btrfs_set_item_offset(leaf, item, ioff - total_data); 35960783fcfcSChris Mason } 3597db94535dSChris Mason if (leaf->map_token) { 3598db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3599db94535dSChris Mason leaf->map_token = NULL; 3600db94535dSChris Mason } 3601be0e5c09SChris Mason 3602be0e5c09SChris Mason /* shift the items */ 36039c58309dSChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + nr), 36045f39d397SChris Mason btrfs_item_nr_offset(slot), 36050783fcfcSChris Mason (nritems - slot) * sizeof(struct btrfs_item)); 3606be0e5c09SChris Mason 3607be0e5c09SChris Mason /* shift the data */ 36085f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 36099c58309dSChris Mason data_end - total_data, btrfs_leaf_data(leaf) + 3610be0e5c09SChris Mason data_end, old_data - data_end); 3611be0e5c09SChris Mason data_end = old_data; 3612be0e5c09SChris Mason } 36135f39d397SChris Mason 361462e2749eSChris Mason /* setup the item for the new data */ 36159c58309dSChris Mason for (i = 0; i < nr; i++) { 36169c58309dSChris Mason btrfs_cpu_key_to_disk(&disk_key, cpu_key + i); 36179c58309dSChris Mason btrfs_set_item_key(leaf, &disk_key, slot + i); 36189c58309dSChris Mason item = btrfs_item_nr(leaf, slot + i); 36199c58309dSChris Mason btrfs_set_item_offset(leaf, item, data_end - data_size[i]); 36209c58309dSChris Mason data_end -= data_size[i]; 36219c58309dSChris Mason btrfs_set_item_size(leaf, item, data_size[i]); 36229c58309dSChris Mason } 362344871b1bSChris Mason 36249c58309dSChris Mason btrfs_set_header_nritems(leaf, nritems + nr); 3625aa5d6bedSChris Mason 3626aa5d6bedSChris Mason ret = 0; 36275a01a2e3SChris Mason if (slot == 0) { 362844871b1bSChris Mason struct btrfs_disk_key disk_key; 36295a01a2e3SChris Mason btrfs_cpu_key_to_disk(&disk_key, cpu_key); 3630e089f05cSChris Mason ret = fixup_low_keys(trans, root, path, &disk_key, 1); 36315a01a2e3SChris Mason } 3632b9473439SChris Mason btrfs_unlock_up_safe(path, 1); 3633b9473439SChris Mason btrfs_mark_buffer_dirty(leaf); 3634aa5d6bedSChris Mason 36355f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 36365f39d397SChris Mason btrfs_print_leaf(root, leaf); 3637be0e5c09SChris Mason BUG(); 36385f39d397SChris Mason } 363944871b1bSChris Mason return ret; 364044871b1bSChris Mason } 364144871b1bSChris Mason 364244871b1bSChris Mason /* 364344871b1bSChris Mason * Given a key and some data, insert items into the tree. 364444871b1bSChris Mason * This does all the path init required, making room in the tree if needed. 364544871b1bSChris Mason */ 364644871b1bSChris Mason int btrfs_insert_empty_items(struct btrfs_trans_handle *trans, 364744871b1bSChris Mason struct btrfs_root *root, 364844871b1bSChris Mason struct btrfs_path *path, 364944871b1bSChris Mason struct btrfs_key *cpu_key, u32 *data_size, 365044871b1bSChris Mason int nr) 365144871b1bSChris Mason { 365244871b1bSChris Mason struct extent_buffer *leaf; 365344871b1bSChris Mason int ret = 0; 365444871b1bSChris Mason int slot; 365544871b1bSChris Mason int i; 365644871b1bSChris Mason u32 total_size = 0; 365744871b1bSChris Mason u32 total_data = 0; 365844871b1bSChris Mason 365944871b1bSChris Mason for (i = 0; i < nr; i++) 366044871b1bSChris Mason total_data += data_size[i]; 366144871b1bSChris Mason 366244871b1bSChris Mason total_size = total_data + (nr * sizeof(struct btrfs_item)); 366344871b1bSChris Mason ret = btrfs_search_slot(trans, root, cpu_key, path, total_size, 1); 366444871b1bSChris Mason if (ret == 0) 366544871b1bSChris Mason return -EEXIST; 366644871b1bSChris Mason if (ret < 0) 366744871b1bSChris Mason goto out; 366844871b1bSChris Mason 366944871b1bSChris Mason leaf = path->nodes[0]; 367044871b1bSChris Mason slot = path->slots[0]; 367144871b1bSChris Mason BUG_ON(slot < 0); 367244871b1bSChris Mason 367344871b1bSChris Mason ret = setup_items_for_insert(trans, root, path, cpu_key, data_size, 367444871b1bSChris Mason total_data, total_size, nr); 367544871b1bSChris Mason 3676ed2ff2cbSChris Mason out: 367762e2749eSChris Mason return ret; 367862e2749eSChris Mason } 367962e2749eSChris Mason 368062e2749eSChris Mason /* 368162e2749eSChris Mason * Given a key and some data, insert an item into the tree. 368262e2749eSChris Mason * This does all the path init required, making room in the tree if needed. 368362e2749eSChris Mason */ 3684e089f05cSChris Mason int btrfs_insert_item(struct btrfs_trans_handle *trans, struct btrfs_root 3685e089f05cSChris Mason *root, struct btrfs_key *cpu_key, void *data, u32 3686e089f05cSChris Mason data_size) 368762e2749eSChris Mason { 368862e2749eSChris Mason int ret = 0; 36892c90e5d6SChris Mason struct btrfs_path *path; 36905f39d397SChris Mason struct extent_buffer *leaf; 36915f39d397SChris Mason unsigned long ptr; 369262e2749eSChris Mason 36932c90e5d6SChris Mason path = btrfs_alloc_path(); 36942c90e5d6SChris Mason BUG_ON(!path); 36952c90e5d6SChris Mason ret = btrfs_insert_empty_item(trans, root, path, cpu_key, data_size); 369662e2749eSChris Mason if (!ret) { 36975f39d397SChris Mason leaf = path->nodes[0]; 36985f39d397SChris Mason ptr = btrfs_item_ptr_offset(leaf, path->slots[0]); 36995f39d397SChris Mason write_extent_buffer(leaf, data, ptr, data_size); 37005f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 370162e2749eSChris Mason } 37022c90e5d6SChris Mason btrfs_free_path(path); 3703aa5d6bedSChris Mason return ret; 3704be0e5c09SChris Mason } 3705be0e5c09SChris Mason 370674123bd7SChris Mason /* 37075de08d7dSChris Mason * delete the pointer from a given node. 370874123bd7SChris Mason * 3709d352ac68SChris Mason * the tree should have been previously balanced so the deletion does not 3710d352ac68SChris Mason * empty a node. 371174123bd7SChris Mason */ 3712e089f05cSChris Mason static int del_ptr(struct btrfs_trans_handle *trans, struct btrfs_root *root, 3713e089f05cSChris Mason struct btrfs_path *path, int level, int slot) 3714be0e5c09SChris Mason { 37155f39d397SChris Mason struct extent_buffer *parent = path->nodes[level]; 37167518a238SChris Mason u32 nritems; 3717aa5d6bedSChris Mason int ret = 0; 3718bb803951SChris Mason int wret; 3719be0e5c09SChris Mason 37205f39d397SChris Mason nritems = btrfs_header_nritems(parent); 3721be0e5c09SChris Mason if (slot != nritems - 1) { 37225f39d397SChris Mason memmove_extent_buffer(parent, 37235f39d397SChris Mason btrfs_node_key_ptr_offset(slot), 37245f39d397SChris Mason btrfs_node_key_ptr_offset(slot + 1), 3725d6025579SChris Mason sizeof(struct btrfs_key_ptr) * 3726d6025579SChris Mason (nritems - slot - 1)); 3727be0e5c09SChris Mason } 37287518a238SChris Mason nritems--; 37295f39d397SChris Mason btrfs_set_header_nritems(parent, nritems); 37307518a238SChris Mason if (nritems == 0 && parent == root->node) { 37315f39d397SChris Mason BUG_ON(btrfs_header_level(root->node) != 1); 3732eb60ceacSChris Mason /* just turn the root into a leaf and break */ 37335f39d397SChris Mason btrfs_set_header_level(root->node, 0); 3734bb803951SChris Mason } else if (slot == 0) { 37355f39d397SChris Mason struct btrfs_disk_key disk_key; 37365f39d397SChris Mason 37375f39d397SChris Mason btrfs_node_key(parent, &disk_key, 0); 37385f39d397SChris Mason wret = fixup_low_keys(trans, root, path, &disk_key, level + 1); 37390f70abe2SChris Mason if (wret) 37400f70abe2SChris Mason ret = wret; 3741be0e5c09SChris Mason } 3742d6025579SChris Mason btrfs_mark_buffer_dirty(parent); 3743aa5d6bedSChris Mason return ret; 3744be0e5c09SChris Mason } 3745be0e5c09SChris Mason 374674123bd7SChris Mason /* 3747323ac95bSChris Mason * a helper function to delete the leaf pointed to by path->slots[1] and 3748323ac95bSChris Mason * path->nodes[1]. bytenr is the node block pointer, but since the callers 3749323ac95bSChris Mason * already know it, it is faster to have them pass it down than to 3750323ac95bSChris Mason * read it out of the node again. 3751323ac95bSChris Mason * 3752323ac95bSChris Mason * This deletes the pointer in path->nodes[1] and frees the leaf 3753323ac95bSChris Mason * block extent. zero is returned if it all worked out, < 0 otherwise. 3754323ac95bSChris Mason * 3755323ac95bSChris Mason * The path must have already been setup for deleting the leaf, including 3756323ac95bSChris Mason * all the proper balancing. path->nodes[1] must be locked. 3757323ac95bSChris Mason */ 3758323ac95bSChris Mason noinline int btrfs_del_leaf(struct btrfs_trans_handle *trans, 3759323ac95bSChris Mason struct btrfs_root *root, 3760323ac95bSChris Mason struct btrfs_path *path, u64 bytenr) 3761323ac95bSChris Mason { 3762323ac95bSChris Mason int ret; 3763323ac95bSChris Mason u64 root_gen = btrfs_header_generation(path->nodes[1]); 37644d081c41SChris Mason u64 parent_start = path->nodes[1]->start; 37654d081c41SChris Mason u64 parent_owner = btrfs_header_owner(path->nodes[1]); 3766323ac95bSChris Mason 3767323ac95bSChris Mason ret = del_ptr(trans, root, path, 1, path->slots[1]); 3768323ac95bSChris Mason if (ret) 3769323ac95bSChris Mason return ret; 3770323ac95bSChris Mason 37714d081c41SChris Mason /* 37724d081c41SChris Mason * btrfs_free_extent is expensive, we want to make sure we 37734d081c41SChris Mason * aren't holding any locks when we call it 37744d081c41SChris Mason */ 37754d081c41SChris Mason btrfs_unlock_up_safe(path, 0); 37764d081c41SChris Mason 3777323ac95bSChris Mason ret = btrfs_free_extent(trans, root, bytenr, 3778323ac95bSChris Mason btrfs_level_size(root, 0), 37794d081c41SChris Mason parent_start, parent_owner, 37803bb1a1bcSYan Zheng root_gen, 0, 1); 3781323ac95bSChris Mason return ret; 3782323ac95bSChris Mason } 3783323ac95bSChris Mason /* 378474123bd7SChris Mason * delete the item at the leaf level in path. If that empties 378574123bd7SChris Mason * the leaf, remove it from the tree 378674123bd7SChris Mason */ 378785e21bacSChris Mason int btrfs_del_items(struct btrfs_trans_handle *trans, struct btrfs_root *root, 378885e21bacSChris Mason struct btrfs_path *path, int slot, int nr) 3789be0e5c09SChris Mason { 37905f39d397SChris Mason struct extent_buffer *leaf; 37915f39d397SChris Mason struct btrfs_item *item; 379285e21bacSChris Mason int last_off; 379385e21bacSChris Mason int dsize = 0; 3794aa5d6bedSChris Mason int ret = 0; 3795aa5d6bedSChris Mason int wret; 379685e21bacSChris Mason int i; 37977518a238SChris Mason u32 nritems; 3798be0e5c09SChris Mason 37995f39d397SChris Mason leaf = path->nodes[0]; 380085e21bacSChris Mason last_off = btrfs_item_offset_nr(leaf, slot + nr - 1); 380185e21bacSChris Mason 380285e21bacSChris Mason for (i = 0; i < nr; i++) 380385e21bacSChris Mason dsize += btrfs_item_size_nr(leaf, slot + i); 380485e21bacSChris Mason 38055f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3806be0e5c09SChris Mason 380785e21bacSChris Mason if (slot + nr != nritems) { 3808123abc88SChris Mason int data_end = leaf_data_end(root, leaf); 38095f39d397SChris Mason 38105f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3811d6025579SChris Mason data_end + dsize, 3812123abc88SChris Mason btrfs_leaf_data(leaf) + data_end, 381385e21bacSChris Mason last_off - data_end); 38145f39d397SChris Mason 381585e21bacSChris Mason for (i = slot + nr; i < nritems; i++) { 38165f39d397SChris Mason u32 ioff; 3817db94535dSChris Mason 38185f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3819db94535dSChris Mason if (!leaf->map_token) { 3820db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3821db94535dSChris Mason sizeof(struct btrfs_item), 3822db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3823db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3824db94535dSChris Mason KM_USER1); 3825db94535dSChris Mason } 38265f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 38275f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff + dsize); 38280783fcfcSChris Mason } 3829db94535dSChris Mason 3830db94535dSChris Mason if (leaf->map_token) { 3831db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3832db94535dSChris Mason leaf->map_token = NULL; 3833db94535dSChris Mason } 3834db94535dSChris Mason 38355f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot), 383685e21bacSChris Mason btrfs_item_nr_offset(slot + nr), 38370783fcfcSChris Mason sizeof(struct btrfs_item) * 383885e21bacSChris Mason (nritems - slot - nr)); 3839be0e5c09SChris Mason } 384085e21bacSChris Mason btrfs_set_header_nritems(leaf, nritems - nr); 384185e21bacSChris Mason nritems -= nr; 38425f39d397SChris Mason 384374123bd7SChris Mason /* delete the leaf if we've emptied it */ 38447518a238SChris Mason if (nritems == 0) { 38455f39d397SChris Mason if (leaf == root->node) { 38465f39d397SChris Mason btrfs_set_header_level(leaf, 0); 38479a8dd150SChris Mason } else { 3848323ac95bSChris Mason ret = btrfs_del_leaf(trans, root, path, leaf->start); 3849323ac95bSChris Mason BUG_ON(ret); 38509a8dd150SChris Mason } 3851be0e5c09SChris Mason } else { 38527518a238SChris Mason int used = leaf_space_used(leaf, 0, nritems); 3853aa5d6bedSChris Mason if (slot == 0) { 38545f39d397SChris Mason struct btrfs_disk_key disk_key; 38555f39d397SChris Mason 38565f39d397SChris Mason btrfs_item_key(leaf, &disk_key, 0); 3857e089f05cSChris Mason wret = fixup_low_keys(trans, root, path, 38585f39d397SChris Mason &disk_key, 1); 3859aa5d6bedSChris Mason if (wret) 3860aa5d6bedSChris Mason ret = wret; 3861aa5d6bedSChris Mason } 3862aa5d6bedSChris Mason 386374123bd7SChris Mason /* delete the leaf if it is mostly empty */ 3864a4b6e07dSChris Mason if (used < BTRFS_LEAF_DATA_SIZE(root) / 4 && 3865a4b6e07dSChris Mason !trans->transaction->delayed_refs.flushing) { 3866be0e5c09SChris Mason /* push_leaf_left fixes the path. 3867be0e5c09SChris Mason * make sure the path still points to our leaf 3868be0e5c09SChris Mason * for possible call to del_ptr below 3869be0e5c09SChris Mason */ 38704920c9acSChris Mason slot = path->slots[1]; 38715f39d397SChris Mason extent_buffer_get(leaf); 38725f39d397SChris Mason 3873b9473439SChris Mason btrfs_set_path_blocking(path); 387485e21bacSChris Mason wret = push_leaf_left(trans, root, path, 1, 1); 387554aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 3876aa5d6bedSChris Mason ret = wret; 38775f39d397SChris Mason 38785f39d397SChris Mason if (path->nodes[0] == leaf && 38795f39d397SChris Mason btrfs_header_nritems(leaf)) { 388085e21bacSChris Mason wret = push_leaf_right(trans, root, path, 1, 1); 388154aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 3882aa5d6bedSChris Mason ret = wret; 3883aa5d6bedSChris Mason } 38845f39d397SChris Mason 38855f39d397SChris Mason if (btrfs_header_nritems(leaf) == 0) { 3886323ac95bSChris Mason path->slots[1] = slot; 3887d397712bSChris Mason ret = btrfs_del_leaf(trans, root, path, 3888d397712bSChris Mason leaf->start); 3889323ac95bSChris Mason BUG_ON(ret); 38905f39d397SChris Mason free_extent_buffer(leaf); 38915de08d7dSChris Mason } else { 3892925baeddSChris Mason /* if we're still in the path, make sure 3893925baeddSChris Mason * we're dirty. Otherwise, one of the 3894925baeddSChris Mason * push_leaf functions must have already 3895925baeddSChris Mason * dirtied this buffer 3896925baeddSChris Mason */ 3897925baeddSChris Mason if (path->nodes[0] == leaf) 38985f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 38995f39d397SChris Mason free_extent_buffer(leaf); 3900be0e5c09SChris Mason } 3901d5719762SChris Mason } else { 39025f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 3903be0e5c09SChris Mason } 39049a8dd150SChris Mason } 3905aa5d6bedSChris Mason return ret; 39069a8dd150SChris Mason } 39079a8dd150SChris Mason 390897571fd0SChris Mason /* 3909925baeddSChris Mason * search the tree again to find a leaf with lesser keys 39107bb86316SChris Mason * returns 0 if it found something or 1 if there are no lesser leaves. 39117bb86316SChris Mason * returns < 0 on io errors. 3912d352ac68SChris Mason * 3913d352ac68SChris Mason * This may release the path, and so you may lose any locks held at the 3914d352ac68SChris Mason * time you call it. 39157bb86316SChris Mason */ 39167bb86316SChris Mason int btrfs_prev_leaf(struct btrfs_root *root, struct btrfs_path *path) 39177bb86316SChris Mason { 3918925baeddSChris Mason struct btrfs_key key; 3919925baeddSChris Mason struct btrfs_disk_key found_key; 3920925baeddSChris Mason int ret; 39217bb86316SChris Mason 3922925baeddSChris Mason btrfs_item_key_to_cpu(path->nodes[0], &key, 0); 3923925baeddSChris Mason 3924925baeddSChris Mason if (key.offset > 0) 3925925baeddSChris Mason key.offset--; 3926925baeddSChris Mason else if (key.type > 0) 3927925baeddSChris Mason key.type--; 3928925baeddSChris Mason else if (key.objectid > 0) 3929925baeddSChris Mason key.objectid--; 3930925baeddSChris Mason else 39317bb86316SChris Mason return 1; 39327bb86316SChris Mason 3933925baeddSChris Mason btrfs_release_path(root, path); 3934925baeddSChris Mason ret = btrfs_search_slot(NULL, root, &key, path, 0, 0); 3935925baeddSChris Mason if (ret < 0) 3936925baeddSChris Mason return ret; 3937925baeddSChris Mason btrfs_item_key(path->nodes[0], &found_key, 0); 3938925baeddSChris Mason ret = comp_keys(&found_key, &key); 3939925baeddSChris Mason if (ret < 0) 39407bb86316SChris Mason return 0; 3941925baeddSChris Mason return 1; 39427bb86316SChris Mason } 39437bb86316SChris Mason 39443f157a2fSChris Mason /* 39453f157a2fSChris Mason * A helper function to walk down the tree starting at min_key, and looking 39463f157a2fSChris Mason * for nodes or leaves that are either in cache or have a minimum 3947d352ac68SChris Mason * transaction id. This is used by the btree defrag code, and tree logging 39483f157a2fSChris Mason * 39493f157a2fSChris Mason * This does not cow, but it does stuff the starting key it finds back 39503f157a2fSChris Mason * into min_key, so you can call btrfs_search_slot with cow=1 on the 39513f157a2fSChris Mason * key and get a writable path. 39523f157a2fSChris Mason * 39533f157a2fSChris Mason * This does lock as it descends, and path->keep_locks should be set 39543f157a2fSChris Mason * to 1 by the caller. 39553f157a2fSChris Mason * 39563f157a2fSChris Mason * This honors path->lowest_level to prevent descent past a given level 39573f157a2fSChris Mason * of the tree. 39583f157a2fSChris Mason * 3959d352ac68SChris Mason * min_trans indicates the oldest transaction that you are interested 3960d352ac68SChris Mason * in walking through. Any nodes or leaves older than min_trans are 3961d352ac68SChris Mason * skipped over (without reading them). 3962d352ac68SChris Mason * 39633f157a2fSChris Mason * returns zero if something useful was found, < 0 on error and 1 if there 39643f157a2fSChris Mason * was nothing in the tree that matched the search criteria. 39653f157a2fSChris Mason */ 39663f157a2fSChris Mason int btrfs_search_forward(struct btrfs_root *root, struct btrfs_key *min_key, 3967e02119d5SChris Mason struct btrfs_key *max_key, 39683f157a2fSChris Mason struct btrfs_path *path, int cache_only, 39693f157a2fSChris Mason u64 min_trans) 39703f157a2fSChris Mason { 39713f157a2fSChris Mason struct extent_buffer *cur; 39723f157a2fSChris Mason struct btrfs_key found_key; 39733f157a2fSChris Mason int slot; 39749652480bSYan int sret; 39753f157a2fSChris Mason u32 nritems; 39763f157a2fSChris Mason int level; 39773f157a2fSChris Mason int ret = 1; 39783f157a2fSChris Mason 3979934d375bSChris Mason WARN_ON(!path->keep_locks); 39803f157a2fSChris Mason again: 39813f157a2fSChris Mason cur = btrfs_lock_root_node(root); 39823f157a2fSChris Mason level = btrfs_header_level(cur); 3983e02119d5SChris Mason WARN_ON(path->nodes[level]); 39843f157a2fSChris Mason path->nodes[level] = cur; 39853f157a2fSChris Mason path->locks[level] = 1; 39863f157a2fSChris Mason 39873f157a2fSChris Mason if (btrfs_header_generation(cur) < min_trans) { 39883f157a2fSChris Mason ret = 1; 39893f157a2fSChris Mason goto out; 39903f157a2fSChris Mason } 39913f157a2fSChris Mason while (1) { 39923f157a2fSChris Mason nritems = btrfs_header_nritems(cur); 39933f157a2fSChris Mason level = btrfs_header_level(cur); 39949652480bSYan sret = bin_search(cur, min_key, level, &slot); 39953f157a2fSChris Mason 3996323ac95bSChris Mason /* at the lowest level, we're done, setup the path and exit */ 3997323ac95bSChris Mason if (level == path->lowest_level) { 3998e02119d5SChris Mason if (slot >= nritems) 3999e02119d5SChris Mason goto find_next_key; 40003f157a2fSChris Mason ret = 0; 40013f157a2fSChris Mason path->slots[level] = slot; 40023f157a2fSChris Mason btrfs_item_key_to_cpu(cur, &found_key, slot); 40033f157a2fSChris Mason goto out; 40043f157a2fSChris Mason } 40059652480bSYan if (sret && slot > 0) 40069652480bSYan slot--; 40073f157a2fSChris Mason /* 40083f157a2fSChris Mason * check this node pointer against the cache_only and 40093f157a2fSChris Mason * min_trans parameters. If it isn't in cache or is too 40103f157a2fSChris Mason * old, skip to the next one. 40113f157a2fSChris Mason */ 40123f157a2fSChris Mason while (slot < nritems) { 40133f157a2fSChris Mason u64 blockptr; 40143f157a2fSChris Mason u64 gen; 40153f157a2fSChris Mason struct extent_buffer *tmp; 4016e02119d5SChris Mason struct btrfs_disk_key disk_key; 4017e02119d5SChris Mason 40183f157a2fSChris Mason blockptr = btrfs_node_blockptr(cur, slot); 40193f157a2fSChris Mason gen = btrfs_node_ptr_generation(cur, slot); 40203f157a2fSChris Mason if (gen < min_trans) { 40213f157a2fSChris Mason slot++; 40223f157a2fSChris Mason continue; 40233f157a2fSChris Mason } 40243f157a2fSChris Mason if (!cache_only) 40253f157a2fSChris Mason break; 40263f157a2fSChris Mason 4027e02119d5SChris Mason if (max_key) { 4028e02119d5SChris Mason btrfs_node_key(cur, &disk_key, slot); 4029e02119d5SChris Mason if (comp_keys(&disk_key, max_key) >= 0) { 4030e02119d5SChris Mason ret = 1; 4031e02119d5SChris Mason goto out; 4032e02119d5SChris Mason } 4033e02119d5SChris Mason } 4034e02119d5SChris Mason 40353f157a2fSChris Mason tmp = btrfs_find_tree_block(root, blockptr, 40363f157a2fSChris Mason btrfs_level_size(root, level - 1)); 40373f157a2fSChris Mason 40383f157a2fSChris Mason if (tmp && btrfs_buffer_uptodate(tmp, gen)) { 40393f157a2fSChris Mason free_extent_buffer(tmp); 40403f157a2fSChris Mason break; 40413f157a2fSChris Mason } 40423f157a2fSChris Mason if (tmp) 40433f157a2fSChris Mason free_extent_buffer(tmp); 40443f157a2fSChris Mason slot++; 40453f157a2fSChris Mason } 4046e02119d5SChris Mason find_next_key: 40473f157a2fSChris Mason /* 40483f157a2fSChris Mason * we didn't find a candidate key in this node, walk forward 40493f157a2fSChris Mason * and find another one 40503f157a2fSChris Mason */ 40513f157a2fSChris Mason if (slot >= nritems) { 4052e02119d5SChris Mason path->slots[level] = slot; 4053b4ce94deSChris Mason btrfs_set_path_blocking(path); 4054e02119d5SChris Mason sret = btrfs_find_next_key(root, path, min_key, level, 40553f157a2fSChris Mason cache_only, min_trans); 4056e02119d5SChris Mason if (sret == 0) { 40573f157a2fSChris Mason btrfs_release_path(root, path); 40583f157a2fSChris Mason goto again; 40593f157a2fSChris Mason } else { 40603f157a2fSChris Mason goto out; 40613f157a2fSChris Mason } 40623f157a2fSChris Mason } 40633f157a2fSChris Mason /* save our key for returning back */ 40643f157a2fSChris Mason btrfs_node_key_to_cpu(cur, &found_key, slot); 40653f157a2fSChris Mason path->slots[level] = slot; 40663f157a2fSChris Mason if (level == path->lowest_level) { 40673f157a2fSChris Mason ret = 0; 40683f157a2fSChris Mason unlock_up(path, level, 1); 40693f157a2fSChris Mason goto out; 40703f157a2fSChris Mason } 4071b4ce94deSChris Mason btrfs_set_path_blocking(path); 40723f157a2fSChris Mason cur = read_node_slot(root, cur, slot); 40733f157a2fSChris Mason 40743f157a2fSChris Mason btrfs_tree_lock(cur); 4075b4ce94deSChris Mason 40763f157a2fSChris Mason path->locks[level - 1] = 1; 40773f157a2fSChris Mason path->nodes[level - 1] = cur; 40783f157a2fSChris Mason unlock_up(path, level, 1); 40794008c04aSChris Mason btrfs_clear_path_blocking(path, NULL); 40803f157a2fSChris Mason } 40813f157a2fSChris Mason out: 40823f157a2fSChris Mason if (ret == 0) 40833f157a2fSChris Mason memcpy(min_key, &found_key, sizeof(found_key)); 4084b4ce94deSChris Mason btrfs_set_path_blocking(path); 40853f157a2fSChris Mason return ret; 40863f157a2fSChris Mason } 40873f157a2fSChris Mason 40883f157a2fSChris Mason /* 40893f157a2fSChris Mason * this is similar to btrfs_next_leaf, but does not try to preserve 40903f157a2fSChris Mason * and fixup the path. It looks for and returns the next key in the 40913f157a2fSChris Mason * tree based on the current path and the cache_only and min_trans 40923f157a2fSChris Mason * parameters. 40933f157a2fSChris Mason * 40943f157a2fSChris Mason * 0 is returned if another key is found, < 0 if there are any errors 40953f157a2fSChris Mason * and 1 is returned if there are no higher keys in the tree 40963f157a2fSChris Mason * 40973f157a2fSChris Mason * path->keep_locks should be set to 1 on the search made before 40983f157a2fSChris Mason * calling this function. 40993f157a2fSChris Mason */ 4100e7a84565SChris Mason int btrfs_find_next_key(struct btrfs_root *root, struct btrfs_path *path, 41013f157a2fSChris Mason struct btrfs_key *key, int lowest_level, 41023f157a2fSChris Mason int cache_only, u64 min_trans) 4103e7a84565SChris Mason { 4104e7a84565SChris Mason int level = lowest_level; 4105e7a84565SChris Mason int slot; 4106e7a84565SChris Mason struct extent_buffer *c; 4107e7a84565SChris Mason 4108934d375bSChris Mason WARN_ON(!path->keep_locks); 4109e7a84565SChris Mason while (level < BTRFS_MAX_LEVEL) { 4110e7a84565SChris Mason if (!path->nodes[level]) 4111e7a84565SChris Mason return 1; 4112e7a84565SChris Mason 4113e7a84565SChris Mason slot = path->slots[level] + 1; 4114e7a84565SChris Mason c = path->nodes[level]; 41153f157a2fSChris Mason next: 4116e7a84565SChris Mason if (slot >= btrfs_header_nritems(c)) { 4117e7a84565SChris Mason level++; 4118d397712bSChris Mason if (level == BTRFS_MAX_LEVEL) 4119e7a84565SChris Mason return 1; 4120e7a84565SChris Mason continue; 4121e7a84565SChris Mason } 4122e7a84565SChris Mason if (level == 0) 4123e7a84565SChris Mason btrfs_item_key_to_cpu(c, key, slot); 41243f157a2fSChris Mason else { 41253f157a2fSChris Mason u64 blockptr = btrfs_node_blockptr(c, slot); 41263f157a2fSChris Mason u64 gen = btrfs_node_ptr_generation(c, slot); 41273f157a2fSChris Mason 41283f157a2fSChris Mason if (cache_only) { 41293f157a2fSChris Mason struct extent_buffer *cur; 41303f157a2fSChris Mason cur = btrfs_find_tree_block(root, blockptr, 41313f157a2fSChris Mason btrfs_level_size(root, level - 1)); 41323f157a2fSChris Mason if (!cur || !btrfs_buffer_uptodate(cur, gen)) { 41333f157a2fSChris Mason slot++; 41343f157a2fSChris Mason if (cur) 41353f157a2fSChris Mason free_extent_buffer(cur); 41363f157a2fSChris Mason goto next; 41373f157a2fSChris Mason } 41383f157a2fSChris Mason free_extent_buffer(cur); 41393f157a2fSChris Mason } 41403f157a2fSChris Mason if (gen < min_trans) { 41413f157a2fSChris Mason slot++; 41423f157a2fSChris Mason goto next; 41433f157a2fSChris Mason } 4144e7a84565SChris Mason btrfs_node_key_to_cpu(c, key, slot); 41453f157a2fSChris Mason } 4146e7a84565SChris Mason return 0; 4147e7a84565SChris Mason } 4148e7a84565SChris Mason return 1; 4149e7a84565SChris Mason } 4150e7a84565SChris Mason 41517bb86316SChris Mason /* 4152925baeddSChris Mason * search the tree again to find a leaf with greater keys 41530f70abe2SChris Mason * returns 0 if it found something or 1 if there are no greater leaves. 41540f70abe2SChris Mason * returns < 0 on io errors. 415597571fd0SChris Mason */ 4156234b63a0SChris Mason int btrfs_next_leaf(struct btrfs_root *root, struct btrfs_path *path) 4157d97e63b6SChris Mason { 4158d97e63b6SChris Mason int slot; 41598e73f275SChris Mason int level; 41605f39d397SChris Mason struct extent_buffer *c; 41618e73f275SChris Mason struct extent_buffer *next; 4162925baeddSChris Mason struct btrfs_key key; 4163925baeddSChris Mason u32 nritems; 4164925baeddSChris Mason int ret; 41658e73f275SChris Mason int old_spinning = path->leave_spinning; 41668e73f275SChris Mason int force_blocking = 0; 4167925baeddSChris Mason 4168925baeddSChris Mason nritems = btrfs_header_nritems(path->nodes[0]); 4169d397712bSChris Mason if (nritems == 0) 4170925baeddSChris Mason return 1; 4171925baeddSChris Mason 41728e73f275SChris Mason /* 41738e73f275SChris Mason * we take the blocks in an order that upsets lockdep. Using 41748e73f275SChris Mason * blocking mode is the only way around it. 41758e73f275SChris Mason */ 41768e73f275SChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 41778e73f275SChris Mason force_blocking = 1; 41788e73f275SChris Mason #endif 4179925baeddSChris Mason 41808e73f275SChris Mason btrfs_item_key_to_cpu(path->nodes[0], &key, nritems - 1); 41818e73f275SChris Mason again: 41828e73f275SChris Mason level = 1; 41838e73f275SChris Mason next = NULL; 4184925baeddSChris Mason btrfs_release_path(root, path); 41858e73f275SChris Mason 4186a2135011SChris Mason path->keep_locks = 1; 41878e73f275SChris Mason 41888e73f275SChris Mason if (!force_blocking) 41898e73f275SChris Mason path->leave_spinning = 1; 41908e73f275SChris Mason 4191925baeddSChris Mason ret = btrfs_search_slot(NULL, root, &key, path, 0, 0); 4192925baeddSChris Mason path->keep_locks = 0; 4193925baeddSChris Mason 4194925baeddSChris Mason if (ret < 0) 4195925baeddSChris Mason return ret; 4196925baeddSChris Mason 4197a2135011SChris Mason nritems = btrfs_header_nritems(path->nodes[0]); 4198168fd7d2SChris Mason /* 4199168fd7d2SChris Mason * by releasing the path above we dropped all our locks. A balance 4200168fd7d2SChris Mason * could have added more items next to the key that used to be 4201168fd7d2SChris Mason * at the very end of the block. So, check again here and 4202168fd7d2SChris Mason * advance the path if there are now more items available. 4203168fd7d2SChris Mason */ 4204a2135011SChris Mason if (nritems > 0 && path->slots[0] < nritems - 1) { 4205168fd7d2SChris Mason path->slots[0]++; 42068e73f275SChris Mason ret = 0; 4207925baeddSChris Mason goto done; 4208925baeddSChris Mason } 4209d97e63b6SChris Mason 4210234b63a0SChris Mason while (level < BTRFS_MAX_LEVEL) { 42118e73f275SChris Mason if (!path->nodes[level]) { 42128e73f275SChris Mason ret = 1; 42138e73f275SChris Mason goto done; 42148e73f275SChris Mason } 42155f39d397SChris Mason 4216d97e63b6SChris Mason slot = path->slots[level] + 1; 4217d97e63b6SChris Mason c = path->nodes[level]; 42185f39d397SChris Mason if (slot >= btrfs_header_nritems(c)) { 4219d97e63b6SChris Mason level++; 42208e73f275SChris Mason if (level == BTRFS_MAX_LEVEL) { 42218e73f275SChris Mason ret = 1; 42228e73f275SChris Mason goto done; 42238e73f275SChris Mason } 4224d97e63b6SChris Mason continue; 4225d97e63b6SChris Mason } 42265f39d397SChris Mason 4227925baeddSChris Mason if (next) { 4228925baeddSChris Mason btrfs_tree_unlock(next); 42295f39d397SChris Mason free_extent_buffer(next); 4230925baeddSChris Mason } 42315f39d397SChris Mason 42328e73f275SChris Mason next = c; 42338e73f275SChris Mason ret = read_block_for_search(NULL, root, path, &next, level, 42348e73f275SChris Mason slot, &key); 42358e73f275SChris Mason if (ret == -EAGAIN) 42368e73f275SChris Mason goto again; 42375f39d397SChris Mason 4238*76a05b35SChris Mason if (ret < 0) { 4239*76a05b35SChris Mason btrfs_release_path(root, path); 4240*76a05b35SChris Mason goto done; 4241*76a05b35SChris Mason } 4242*76a05b35SChris Mason 42435cd57b2cSChris Mason if (!path->skip_locking) { 42448e73f275SChris Mason ret = btrfs_try_spin_lock(next); 42458e73f275SChris Mason if (!ret) { 42468e73f275SChris Mason btrfs_set_path_blocking(path); 4247925baeddSChris Mason btrfs_tree_lock(next); 42488e73f275SChris Mason if (!force_blocking) 42498e73f275SChris Mason btrfs_clear_path_blocking(path, next); 42508e73f275SChris Mason } 42518e73f275SChris Mason if (force_blocking) 4252b4ce94deSChris Mason btrfs_set_lock_blocking(next); 42535cd57b2cSChris Mason } 4254d97e63b6SChris Mason break; 4255d97e63b6SChris Mason } 4256d97e63b6SChris Mason path->slots[level] = slot; 4257d97e63b6SChris Mason while (1) { 4258d97e63b6SChris Mason level--; 4259d97e63b6SChris Mason c = path->nodes[level]; 4260925baeddSChris Mason if (path->locks[level]) 4261925baeddSChris Mason btrfs_tree_unlock(c); 42628e73f275SChris Mason 42635f39d397SChris Mason free_extent_buffer(c); 4264d97e63b6SChris Mason path->nodes[level] = next; 4265d97e63b6SChris Mason path->slots[level] = 0; 4266a74a4b97SChris Mason if (!path->skip_locking) 4267925baeddSChris Mason path->locks[level] = 1; 42688e73f275SChris Mason 4269d97e63b6SChris Mason if (!level) 4270d97e63b6SChris Mason break; 4271b4ce94deSChris Mason 42728e73f275SChris Mason ret = read_block_for_search(NULL, root, path, &next, level, 42738e73f275SChris Mason 0, &key); 42748e73f275SChris Mason if (ret == -EAGAIN) 42758e73f275SChris Mason goto again; 42768e73f275SChris Mason 4277*76a05b35SChris Mason if (ret < 0) { 4278*76a05b35SChris Mason btrfs_release_path(root, path); 4279*76a05b35SChris Mason goto done; 4280*76a05b35SChris Mason } 4281*76a05b35SChris Mason 42825cd57b2cSChris Mason if (!path->skip_locking) { 4283b9447ef8SChris Mason btrfs_assert_tree_locked(path->nodes[level]); 42848e73f275SChris Mason ret = btrfs_try_spin_lock(next); 42858e73f275SChris Mason if (!ret) { 42868e73f275SChris Mason btrfs_set_path_blocking(path); 4287925baeddSChris Mason btrfs_tree_lock(next); 42888e73f275SChris Mason if (!force_blocking) 42898e73f275SChris Mason btrfs_clear_path_blocking(path, next); 42908e73f275SChris Mason } 42918e73f275SChris Mason if (force_blocking) 4292b4ce94deSChris Mason btrfs_set_lock_blocking(next); 4293d97e63b6SChris Mason } 42945cd57b2cSChris Mason } 42958e73f275SChris Mason ret = 0; 4296925baeddSChris Mason done: 4297925baeddSChris Mason unlock_up(path, 0, 1); 42988e73f275SChris Mason path->leave_spinning = old_spinning; 42998e73f275SChris Mason if (!old_spinning) 43008e73f275SChris Mason btrfs_set_path_blocking(path); 43018e73f275SChris Mason 43028e73f275SChris Mason return ret; 4303d97e63b6SChris Mason } 43040b86a832SChris Mason 43053f157a2fSChris Mason /* 43063f157a2fSChris Mason * this uses btrfs_prev_leaf to walk backwards in the tree, and keeps 43073f157a2fSChris Mason * searching until it gets past min_objectid or finds an item of 'type' 43083f157a2fSChris Mason * 43093f157a2fSChris Mason * returns 0 if something is found, 1 if nothing was found and < 0 on error 43103f157a2fSChris Mason */ 43110b86a832SChris Mason int btrfs_previous_item(struct btrfs_root *root, 43120b86a832SChris Mason struct btrfs_path *path, u64 min_objectid, 43130b86a832SChris Mason int type) 43140b86a832SChris Mason { 43150b86a832SChris Mason struct btrfs_key found_key; 43160b86a832SChris Mason struct extent_buffer *leaf; 4317e02119d5SChris Mason u32 nritems; 43180b86a832SChris Mason int ret; 43190b86a832SChris Mason 43200b86a832SChris Mason while (1) { 43210b86a832SChris Mason if (path->slots[0] == 0) { 4322b4ce94deSChris Mason btrfs_set_path_blocking(path); 43230b86a832SChris Mason ret = btrfs_prev_leaf(root, path); 43240b86a832SChris Mason if (ret != 0) 43250b86a832SChris Mason return ret; 43260b86a832SChris Mason } else { 43270b86a832SChris Mason path->slots[0]--; 43280b86a832SChris Mason } 43290b86a832SChris Mason leaf = path->nodes[0]; 4330e02119d5SChris Mason nritems = btrfs_header_nritems(leaf); 4331e02119d5SChris Mason if (nritems == 0) 4332e02119d5SChris Mason return 1; 4333e02119d5SChris Mason if (path->slots[0] == nritems) 4334e02119d5SChris Mason path->slots[0]--; 4335e02119d5SChris Mason 43360b86a832SChris Mason btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]); 43370b86a832SChris Mason if (found_key.type == type) 43380b86a832SChris Mason return 0; 4339e02119d5SChris Mason if (found_key.objectid < min_objectid) 4340e02119d5SChris Mason break; 4341e02119d5SChris Mason if (found_key.objectid == min_objectid && 4342e02119d5SChris Mason found_key.type < type) 4343e02119d5SChris Mason break; 43440b86a832SChris Mason } 43450b86a832SChris Mason return 1; 43460b86a832SChris Mason } 4347