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> 205a0e3ad6STejun Heo #include <linux/slab.h> 21eb60ceacSChris Mason #include "ctree.h" 22eb60ceacSChris Mason #include "disk-io.h" 237f5c1516SChris Mason #include "transaction.h" 245f39d397SChris Mason #include "print-tree.h" 25925baeddSChris Mason #include "locking.h" 269a8dd150SChris Mason 27e089f05cSChris Mason static int split_node(struct btrfs_trans_handle *trans, struct btrfs_root 28e089f05cSChris Mason *root, struct btrfs_path *path, int level); 29e089f05cSChris Mason static int split_leaf(struct btrfs_trans_handle *trans, struct btrfs_root 30d4dbff95SChris Mason *root, struct btrfs_key *ins_key, 31cc0c5538SChris Mason struct btrfs_path *path, int data_size, int extend); 325f39d397SChris Mason static int push_node_left(struct btrfs_trans_handle *trans, 335f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *dst, 34971a1f66SChris Mason struct extent_buffer *src, int empty); 355f39d397SChris Mason static int balance_node_right(struct btrfs_trans_handle *trans, 365f39d397SChris Mason struct btrfs_root *root, 375f39d397SChris Mason struct extent_buffer *dst_buf, 385f39d397SChris Mason struct extent_buffer *src_buf); 39e089f05cSChris Mason static int del_ptr(struct btrfs_trans_handle *trans, struct btrfs_root *root, 40e089f05cSChris Mason struct btrfs_path *path, int level, int slot); 41ad48fd75SYan, Zheng static int setup_items_for_insert(struct btrfs_trans_handle *trans, 42ad48fd75SYan, Zheng struct btrfs_root *root, struct btrfs_path *path, 43ad48fd75SYan, Zheng struct btrfs_key *cpu_key, u32 *data_size, 44ad48fd75SYan, Zheng u32 total_data, u32 total_size, int nr); 45ad48fd75SYan, Zheng 46d97e63b6SChris Mason 472c90e5d6SChris Mason struct btrfs_path *btrfs_alloc_path(void) 482c90e5d6SChris Mason { 49df24a2b9SChris Mason struct btrfs_path *path; 50e00f7308SJeff Mahoney path = kmem_cache_zalloc(btrfs_path_cachep, GFP_NOFS); 51e00f7308SJeff Mahoney if (path) 522cc58cf2SChris Mason path->reada = 1; 53df24a2b9SChris Mason return path; 542c90e5d6SChris Mason } 552c90e5d6SChris Mason 56b4ce94deSChris Mason /* 57b4ce94deSChris Mason * set all locked nodes in the path to blocking locks. This should 58b4ce94deSChris Mason * be done before scheduling 59b4ce94deSChris Mason */ 60b4ce94deSChris Mason noinline void btrfs_set_path_blocking(struct btrfs_path *p) 61b4ce94deSChris Mason { 62b4ce94deSChris Mason int i; 63b4ce94deSChris Mason for (i = 0; i < BTRFS_MAX_LEVEL; i++) { 64b4ce94deSChris Mason if (p->nodes[i] && p->locks[i]) 65b4ce94deSChris Mason btrfs_set_lock_blocking(p->nodes[i]); 66b4ce94deSChris Mason } 67b4ce94deSChris Mason } 68b4ce94deSChris Mason 69b4ce94deSChris Mason /* 70b4ce94deSChris Mason * reset all the locked nodes in the patch to spinning locks. 714008c04aSChris Mason * 724008c04aSChris Mason * held is used to keep lockdep happy, when lockdep is enabled 734008c04aSChris Mason * we set held to a blocking lock before we go around and 744008c04aSChris Mason * retake all the spinlocks in the path. You can safely use NULL 754008c04aSChris Mason * for held 76b4ce94deSChris Mason */ 774008c04aSChris Mason noinline void btrfs_clear_path_blocking(struct btrfs_path *p, 784008c04aSChris Mason struct extent_buffer *held) 79b4ce94deSChris Mason { 80b4ce94deSChris Mason int i; 814008c04aSChris Mason 824008c04aSChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 834008c04aSChris Mason /* lockdep really cares that we take all of these spinlocks 844008c04aSChris Mason * in the right order. If any of the locks in the path are not 854008c04aSChris Mason * currently blocking, it is going to complain. So, make really 864008c04aSChris Mason * really sure by forcing the path to blocking before we clear 874008c04aSChris Mason * the path blocking. 884008c04aSChris Mason */ 894008c04aSChris Mason if (held) 904008c04aSChris Mason btrfs_set_lock_blocking(held); 914008c04aSChris Mason btrfs_set_path_blocking(p); 924008c04aSChris Mason #endif 934008c04aSChris Mason 944008c04aSChris Mason for (i = BTRFS_MAX_LEVEL - 1; i >= 0; i--) { 95b4ce94deSChris Mason if (p->nodes[i] && p->locks[i]) 96b4ce94deSChris Mason btrfs_clear_lock_blocking(p->nodes[i]); 97b4ce94deSChris Mason } 984008c04aSChris Mason 994008c04aSChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 1004008c04aSChris Mason if (held) 1014008c04aSChris Mason btrfs_clear_lock_blocking(held); 1024008c04aSChris Mason #endif 103b4ce94deSChris Mason } 104b4ce94deSChris Mason 105d352ac68SChris Mason /* this also releases the path */ 1062c90e5d6SChris Mason void btrfs_free_path(struct btrfs_path *p) 1072c90e5d6SChris Mason { 108df24a2b9SChris Mason btrfs_release_path(NULL, p); 1092c90e5d6SChris Mason kmem_cache_free(btrfs_path_cachep, p); 1102c90e5d6SChris Mason } 1112c90e5d6SChris Mason 112d352ac68SChris Mason /* 113d352ac68SChris Mason * path release drops references on the extent buffers in the path 114d352ac68SChris Mason * and it drops any locks held by this path 115d352ac68SChris Mason * 116d352ac68SChris Mason * It is safe to call this on paths that no locks or extent buffers held. 117d352ac68SChris Mason */ 118d397712bSChris Mason noinline void btrfs_release_path(struct btrfs_root *root, struct btrfs_path *p) 119eb60ceacSChris Mason { 120eb60ceacSChris Mason int i; 121a2135011SChris Mason 122234b63a0SChris Mason for (i = 0; i < BTRFS_MAX_LEVEL; i++) { 1233f157a2fSChris Mason p->slots[i] = 0; 124eb60ceacSChris Mason if (!p->nodes[i]) 125925baeddSChris Mason continue; 126925baeddSChris Mason if (p->locks[i]) { 127925baeddSChris Mason btrfs_tree_unlock(p->nodes[i]); 128925baeddSChris Mason p->locks[i] = 0; 129925baeddSChris Mason } 1305f39d397SChris Mason free_extent_buffer(p->nodes[i]); 1313f157a2fSChris Mason p->nodes[i] = NULL; 132eb60ceacSChris Mason } 133eb60ceacSChris Mason } 134eb60ceacSChris Mason 135d352ac68SChris Mason /* 136d352ac68SChris Mason * safely gets a reference on the root node of a tree. A lock 137d352ac68SChris Mason * is not taken, so a concurrent writer may put a different node 138d352ac68SChris Mason * at the root of the tree. See btrfs_lock_root_node for the 139d352ac68SChris Mason * looping required. 140d352ac68SChris Mason * 141d352ac68SChris Mason * The extent buffer returned by this has a reference taken, so 142d352ac68SChris Mason * it won't disappear. It may stop being the root of the tree 143d352ac68SChris Mason * at any time because there are no locks held. 144d352ac68SChris Mason */ 145925baeddSChris Mason struct extent_buffer *btrfs_root_node(struct btrfs_root *root) 146925baeddSChris Mason { 147925baeddSChris Mason struct extent_buffer *eb; 148925baeddSChris Mason spin_lock(&root->node_lock); 149925baeddSChris Mason eb = root->node; 150925baeddSChris Mason extent_buffer_get(eb); 151925baeddSChris Mason spin_unlock(&root->node_lock); 152925baeddSChris Mason return eb; 153925baeddSChris Mason } 154925baeddSChris Mason 155d352ac68SChris Mason /* loop around taking references on and locking the root node of the 156d352ac68SChris Mason * tree until you end up with a lock on the root. A locked buffer 157d352ac68SChris Mason * is returned, with a reference held. 158d352ac68SChris Mason */ 159925baeddSChris Mason struct extent_buffer *btrfs_lock_root_node(struct btrfs_root *root) 160925baeddSChris Mason { 161925baeddSChris Mason struct extent_buffer *eb; 162925baeddSChris Mason 163925baeddSChris Mason while (1) { 164925baeddSChris Mason eb = btrfs_root_node(root); 165925baeddSChris Mason btrfs_tree_lock(eb); 166925baeddSChris Mason 167925baeddSChris Mason spin_lock(&root->node_lock); 168925baeddSChris Mason if (eb == root->node) { 169925baeddSChris Mason spin_unlock(&root->node_lock); 170925baeddSChris Mason break; 171925baeddSChris Mason } 172925baeddSChris Mason spin_unlock(&root->node_lock); 173925baeddSChris Mason 174925baeddSChris Mason btrfs_tree_unlock(eb); 175925baeddSChris Mason free_extent_buffer(eb); 176925baeddSChris Mason } 177925baeddSChris Mason return eb; 178925baeddSChris Mason } 179925baeddSChris Mason 180d352ac68SChris Mason /* cowonly root (everything not a reference counted cow subvolume), just get 181d352ac68SChris Mason * put onto a simple dirty list. transaction.c walks this to make sure they 182d352ac68SChris Mason * get properly updated on disk. 183d352ac68SChris Mason */ 1840b86a832SChris Mason static void add_root_to_dirty_list(struct btrfs_root *root) 1850b86a832SChris Mason { 1860b86a832SChris Mason if (root->track_dirty && list_empty(&root->dirty_list)) { 1870b86a832SChris Mason list_add(&root->dirty_list, 1880b86a832SChris Mason &root->fs_info->dirty_cowonly_roots); 1890b86a832SChris Mason } 1900b86a832SChris Mason } 1910b86a832SChris Mason 192d352ac68SChris Mason /* 193d352ac68SChris Mason * used by snapshot creation to make a copy of a root for a tree with 194d352ac68SChris Mason * a given objectid. The buffer with the new root node is returned in 195d352ac68SChris Mason * cow_ret, and this func returns zero on success or a negative error code. 196d352ac68SChris Mason */ 197be20aa9dSChris Mason int btrfs_copy_root(struct btrfs_trans_handle *trans, 198be20aa9dSChris Mason struct btrfs_root *root, 199be20aa9dSChris Mason struct extent_buffer *buf, 200be20aa9dSChris Mason struct extent_buffer **cow_ret, u64 new_root_objectid) 201be20aa9dSChris Mason { 202be20aa9dSChris Mason struct extent_buffer *cow; 203be20aa9dSChris Mason int ret = 0; 204be20aa9dSChris Mason int level; 2055d4f98a2SYan Zheng struct btrfs_disk_key disk_key; 206be20aa9dSChris Mason 207be20aa9dSChris Mason WARN_ON(root->ref_cows && trans->transid != 208be20aa9dSChris Mason root->fs_info->running_transaction->transid); 209be20aa9dSChris Mason WARN_ON(root->ref_cows && trans->transid != root->last_trans); 210be20aa9dSChris Mason 211be20aa9dSChris Mason level = btrfs_header_level(buf); 2125d4f98a2SYan Zheng if (level == 0) 2135d4f98a2SYan Zheng btrfs_item_key(buf, &disk_key, 0); 2145d4f98a2SYan Zheng else 2155d4f98a2SYan Zheng btrfs_node_key(buf, &disk_key, 0); 21631840ae1SZheng Yan 2175d4f98a2SYan Zheng cow = btrfs_alloc_free_block(trans, root, buf->len, 0, 2185d4f98a2SYan Zheng new_root_objectid, &disk_key, level, 2195d4f98a2SYan Zheng buf->start, 0); 2205d4f98a2SYan Zheng if (IS_ERR(cow)) 221be20aa9dSChris Mason return PTR_ERR(cow); 222be20aa9dSChris Mason 223be20aa9dSChris Mason copy_extent_buffer(cow, buf, 0, 0, cow->len); 224be20aa9dSChris Mason btrfs_set_header_bytenr(cow, cow->start); 225be20aa9dSChris Mason btrfs_set_header_generation(cow, trans->transid); 2265d4f98a2SYan Zheng btrfs_set_header_backref_rev(cow, BTRFS_MIXED_BACKREF_REV); 2275d4f98a2SYan Zheng btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN | 2285d4f98a2SYan Zheng BTRFS_HEADER_FLAG_RELOC); 2295d4f98a2SYan Zheng if (new_root_objectid == BTRFS_TREE_RELOC_OBJECTID) 2305d4f98a2SYan Zheng btrfs_set_header_flag(cow, BTRFS_HEADER_FLAG_RELOC); 2315d4f98a2SYan Zheng else 232be20aa9dSChris Mason btrfs_set_header_owner(cow, new_root_objectid); 233be20aa9dSChris Mason 2342b82032cSYan Zheng write_extent_buffer(cow, root->fs_info->fsid, 2352b82032cSYan Zheng (unsigned long)btrfs_header_fsid(cow), 2362b82032cSYan Zheng BTRFS_FSID_SIZE); 2372b82032cSYan Zheng 238be20aa9dSChris Mason WARN_ON(btrfs_header_generation(buf) > trans->transid); 2395d4f98a2SYan Zheng if (new_root_objectid == BTRFS_TREE_RELOC_OBJECTID) 2405d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 1); 2415d4f98a2SYan Zheng else 2425d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 0); 2434aec2b52SChris Mason 244be20aa9dSChris Mason if (ret) 245be20aa9dSChris Mason return ret; 246be20aa9dSChris Mason 247be20aa9dSChris Mason btrfs_mark_buffer_dirty(cow); 248be20aa9dSChris Mason *cow_ret = cow; 249be20aa9dSChris Mason return 0; 250be20aa9dSChris Mason } 251be20aa9dSChris Mason 252d352ac68SChris Mason /* 2535d4f98a2SYan Zheng * check if the tree block can be shared by multiple trees 2545d4f98a2SYan Zheng */ 2555d4f98a2SYan Zheng int btrfs_block_can_be_shared(struct btrfs_root *root, 2565d4f98a2SYan Zheng struct extent_buffer *buf) 2575d4f98a2SYan Zheng { 2585d4f98a2SYan Zheng /* 2595d4f98a2SYan Zheng * Tree blocks not in refernece counted trees and tree roots 2605d4f98a2SYan Zheng * are never shared. If a block was allocated after the last 2615d4f98a2SYan Zheng * snapshot and the block was not allocated by tree relocation, 2625d4f98a2SYan Zheng * we know the block is not shared. 2635d4f98a2SYan Zheng */ 2645d4f98a2SYan Zheng if (root->ref_cows && 2655d4f98a2SYan Zheng buf != root->node && buf != root->commit_root && 2665d4f98a2SYan Zheng (btrfs_header_generation(buf) <= 2675d4f98a2SYan Zheng btrfs_root_last_snapshot(&root->root_item) || 2685d4f98a2SYan Zheng btrfs_header_flag(buf, BTRFS_HEADER_FLAG_RELOC))) 2695d4f98a2SYan Zheng return 1; 2705d4f98a2SYan Zheng #ifdef BTRFS_COMPAT_EXTENT_TREE_V0 2715d4f98a2SYan Zheng if (root->ref_cows && 2725d4f98a2SYan Zheng btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV) 2735d4f98a2SYan Zheng return 1; 2745d4f98a2SYan Zheng #endif 2755d4f98a2SYan Zheng return 0; 2765d4f98a2SYan Zheng } 2775d4f98a2SYan Zheng 2785d4f98a2SYan Zheng static noinline int update_ref_for_cow(struct btrfs_trans_handle *trans, 2795d4f98a2SYan Zheng struct btrfs_root *root, 2805d4f98a2SYan Zheng struct extent_buffer *buf, 281f0486c68SYan, Zheng struct extent_buffer *cow, 282f0486c68SYan, Zheng int *last_ref) 2835d4f98a2SYan Zheng { 2845d4f98a2SYan Zheng u64 refs; 2855d4f98a2SYan Zheng u64 owner; 2865d4f98a2SYan Zheng u64 flags; 2875d4f98a2SYan Zheng u64 new_flags = 0; 2885d4f98a2SYan Zheng int ret; 2895d4f98a2SYan Zheng 2905d4f98a2SYan Zheng /* 2915d4f98a2SYan Zheng * Backrefs update rules: 2925d4f98a2SYan Zheng * 2935d4f98a2SYan Zheng * Always use full backrefs for extent pointers in tree block 2945d4f98a2SYan Zheng * allocated by tree relocation. 2955d4f98a2SYan Zheng * 2965d4f98a2SYan Zheng * If a shared tree block is no longer referenced by its owner 2975d4f98a2SYan Zheng * tree (btrfs_header_owner(buf) == root->root_key.objectid), 2985d4f98a2SYan Zheng * use full backrefs for extent pointers in tree block. 2995d4f98a2SYan Zheng * 3005d4f98a2SYan Zheng * If a tree block is been relocating 3015d4f98a2SYan Zheng * (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID), 3025d4f98a2SYan Zheng * use full backrefs for extent pointers in tree block. 3035d4f98a2SYan Zheng * The reason for this is some operations (such as drop tree) 3045d4f98a2SYan Zheng * are only allowed for blocks use full backrefs. 3055d4f98a2SYan Zheng */ 3065d4f98a2SYan Zheng 3075d4f98a2SYan Zheng if (btrfs_block_can_be_shared(root, buf)) { 3085d4f98a2SYan Zheng ret = btrfs_lookup_extent_info(trans, root, buf->start, 3095d4f98a2SYan Zheng buf->len, &refs, &flags); 3105d4f98a2SYan Zheng BUG_ON(ret); 3115d4f98a2SYan Zheng BUG_ON(refs == 0); 3125d4f98a2SYan Zheng } else { 3135d4f98a2SYan Zheng refs = 1; 3145d4f98a2SYan Zheng if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID || 3155d4f98a2SYan Zheng btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV) 3165d4f98a2SYan Zheng flags = BTRFS_BLOCK_FLAG_FULL_BACKREF; 3175d4f98a2SYan Zheng else 3185d4f98a2SYan Zheng flags = 0; 3195d4f98a2SYan Zheng } 3205d4f98a2SYan Zheng 3215d4f98a2SYan Zheng owner = btrfs_header_owner(buf); 3225d4f98a2SYan Zheng BUG_ON(owner == BTRFS_TREE_RELOC_OBJECTID && 3235d4f98a2SYan Zheng !(flags & BTRFS_BLOCK_FLAG_FULL_BACKREF)); 3245d4f98a2SYan Zheng 3255d4f98a2SYan Zheng if (refs > 1) { 3265d4f98a2SYan Zheng if ((owner == root->root_key.objectid || 3275d4f98a2SYan Zheng root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) && 3285d4f98a2SYan Zheng !(flags & BTRFS_BLOCK_FLAG_FULL_BACKREF)) { 3295d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, buf, 1); 3305d4f98a2SYan Zheng BUG_ON(ret); 3315d4f98a2SYan Zheng 3325d4f98a2SYan Zheng if (root->root_key.objectid == 3335d4f98a2SYan Zheng BTRFS_TREE_RELOC_OBJECTID) { 3345d4f98a2SYan Zheng ret = btrfs_dec_ref(trans, root, buf, 0); 3355d4f98a2SYan Zheng BUG_ON(ret); 3365d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 1); 3375d4f98a2SYan Zheng BUG_ON(ret); 3385d4f98a2SYan Zheng } 3395d4f98a2SYan Zheng new_flags |= BTRFS_BLOCK_FLAG_FULL_BACKREF; 3405d4f98a2SYan Zheng } else { 3415d4f98a2SYan Zheng 3425d4f98a2SYan Zheng if (root->root_key.objectid == 3435d4f98a2SYan Zheng BTRFS_TREE_RELOC_OBJECTID) 3445d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 1); 3455d4f98a2SYan Zheng else 3465d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 0); 3475d4f98a2SYan Zheng BUG_ON(ret); 3485d4f98a2SYan Zheng } 3495d4f98a2SYan Zheng if (new_flags != 0) { 3505d4f98a2SYan Zheng ret = btrfs_set_disk_extent_flags(trans, root, 3515d4f98a2SYan Zheng buf->start, 3525d4f98a2SYan Zheng buf->len, 3535d4f98a2SYan Zheng new_flags, 0); 3545d4f98a2SYan Zheng BUG_ON(ret); 3555d4f98a2SYan Zheng } 3565d4f98a2SYan Zheng } else { 3575d4f98a2SYan Zheng if (flags & BTRFS_BLOCK_FLAG_FULL_BACKREF) { 3585d4f98a2SYan Zheng if (root->root_key.objectid == 3595d4f98a2SYan Zheng BTRFS_TREE_RELOC_OBJECTID) 3605d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 1); 3615d4f98a2SYan Zheng else 3625d4f98a2SYan Zheng ret = btrfs_inc_ref(trans, root, cow, 0); 3635d4f98a2SYan Zheng BUG_ON(ret); 3645d4f98a2SYan Zheng ret = btrfs_dec_ref(trans, root, buf, 1); 3655d4f98a2SYan Zheng BUG_ON(ret); 3665d4f98a2SYan Zheng } 3675d4f98a2SYan Zheng clean_tree_block(trans, root, buf); 368f0486c68SYan, Zheng *last_ref = 1; 3695d4f98a2SYan Zheng } 3705d4f98a2SYan Zheng return 0; 3715d4f98a2SYan Zheng } 3725d4f98a2SYan Zheng 3735d4f98a2SYan Zheng /* 374d397712bSChris Mason * does the dirty work in cow of a single block. The parent block (if 375d397712bSChris Mason * supplied) is updated to point to the new cow copy. The new buffer is marked 376d397712bSChris Mason * dirty and returned locked. If you modify the block it needs to be marked 377d397712bSChris Mason * dirty again. 378d352ac68SChris Mason * 379d352ac68SChris Mason * search_start -- an allocation hint for the new block 380d352ac68SChris Mason * 381d397712bSChris Mason * empty_size -- a hint that you plan on doing more cow. This is the size in 382d397712bSChris Mason * bytes the allocator should try to find free next to the block it returns. 383d397712bSChris Mason * This is just a hint and may be ignored by the allocator. 384d352ac68SChris Mason */ 385d397712bSChris Mason static noinline int __btrfs_cow_block(struct btrfs_trans_handle *trans, 3865f39d397SChris Mason struct btrfs_root *root, 3875f39d397SChris Mason struct extent_buffer *buf, 3885f39d397SChris Mason struct extent_buffer *parent, int parent_slot, 3895f39d397SChris Mason struct extent_buffer **cow_ret, 3909fa8cfe7SChris Mason u64 search_start, u64 empty_size) 3916702ed49SChris Mason { 3925d4f98a2SYan Zheng struct btrfs_disk_key disk_key; 3935f39d397SChris Mason struct extent_buffer *cow; 3947bb86316SChris Mason int level; 395f0486c68SYan, Zheng int last_ref = 0; 396925baeddSChris Mason int unlock_orig = 0; 3975d4f98a2SYan Zheng u64 parent_start; 3986702ed49SChris Mason 399925baeddSChris Mason if (*cow_ret == buf) 400925baeddSChris Mason unlock_orig = 1; 401925baeddSChris Mason 402b9447ef8SChris Mason btrfs_assert_tree_locked(buf); 403925baeddSChris Mason 4047bb86316SChris Mason WARN_ON(root->ref_cows && trans->transid != 4057bb86316SChris Mason root->fs_info->running_transaction->transid); 4066702ed49SChris Mason WARN_ON(root->ref_cows && trans->transid != root->last_trans); 4075f39d397SChris Mason 4087bb86316SChris Mason level = btrfs_header_level(buf); 40931840ae1SZheng Yan 4105d4f98a2SYan Zheng if (level == 0) 4115d4f98a2SYan Zheng btrfs_item_key(buf, &disk_key, 0); 4125d4f98a2SYan Zheng else 4135d4f98a2SYan Zheng btrfs_node_key(buf, &disk_key, 0); 4145d4f98a2SYan Zheng 4155d4f98a2SYan Zheng if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) { 4165d4f98a2SYan Zheng if (parent) 4175d4f98a2SYan Zheng parent_start = parent->start; 4185d4f98a2SYan Zheng else 4195d4f98a2SYan Zheng parent_start = 0; 4205d4f98a2SYan Zheng } else 4215d4f98a2SYan Zheng parent_start = 0; 4225d4f98a2SYan Zheng 4235d4f98a2SYan Zheng cow = btrfs_alloc_free_block(trans, root, buf->len, parent_start, 4245d4f98a2SYan Zheng root->root_key.objectid, &disk_key, 4255d4f98a2SYan Zheng level, search_start, empty_size); 4266702ed49SChris Mason if (IS_ERR(cow)) 4276702ed49SChris Mason return PTR_ERR(cow); 4286702ed49SChris Mason 429b4ce94deSChris Mason /* cow is set to blocking by btrfs_init_new_buffer */ 430b4ce94deSChris Mason 4315f39d397SChris Mason copy_extent_buffer(cow, buf, 0, 0, cow->len); 432db94535dSChris Mason btrfs_set_header_bytenr(cow, cow->start); 4335f39d397SChris Mason btrfs_set_header_generation(cow, trans->transid); 4345d4f98a2SYan Zheng btrfs_set_header_backref_rev(cow, BTRFS_MIXED_BACKREF_REV); 4355d4f98a2SYan Zheng btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN | 4365d4f98a2SYan Zheng BTRFS_HEADER_FLAG_RELOC); 4375d4f98a2SYan Zheng if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) 4385d4f98a2SYan Zheng btrfs_set_header_flag(cow, BTRFS_HEADER_FLAG_RELOC); 4395d4f98a2SYan Zheng else 4405f39d397SChris Mason btrfs_set_header_owner(cow, root->root_key.objectid); 4416702ed49SChris Mason 4422b82032cSYan Zheng write_extent_buffer(cow, root->fs_info->fsid, 4432b82032cSYan Zheng (unsigned long)btrfs_header_fsid(cow), 4442b82032cSYan Zheng BTRFS_FSID_SIZE); 4452b82032cSYan Zheng 446f0486c68SYan, Zheng update_ref_for_cow(trans, root, buf, cow, &last_ref); 4471a40e23bSZheng Yan 4483fd0a558SYan, Zheng if (root->ref_cows) 4493fd0a558SYan, Zheng btrfs_reloc_cow_block(trans, root, buf, cow); 4503fd0a558SYan, Zheng 4516702ed49SChris Mason if (buf == root->node) { 452925baeddSChris Mason WARN_ON(parent && parent != buf); 4535d4f98a2SYan Zheng if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID || 4545d4f98a2SYan Zheng btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV) 4555d4f98a2SYan Zheng parent_start = buf->start; 4565d4f98a2SYan Zheng else 4575d4f98a2SYan Zheng parent_start = 0; 458925baeddSChris Mason 459925baeddSChris Mason spin_lock(&root->node_lock); 4606702ed49SChris Mason root->node = cow; 4615f39d397SChris Mason extent_buffer_get(cow); 462925baeddSChris Mason spin_unlock(&root->node_lock); 463925baeddSChris Mason 464f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, buf, parent_start, 465f0486c68SYan, Zheng last_ref); 4665f39d397SChris Mason free_extent_buffer(buf); 4670b86a832SChris Mason add_root_to_dirty_list(root); 4686702ed49SChris Mason } else { 4695d4f98a2SYan Zheng if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) 4705d4f98a2SYan Zheng parent_start = parent->start; 4715d4f98a2SYan Zheng else 4725d4f98a2SYan Zheng parent_start = 0; 4735d4f98a2SYan Zheng 4745d4f98a2SYan Zheng WARN_ON(trans->transid != btrfs_header_generation(parent)); 4755f39d397SChris Mason btrfs_set_node_blockptr(parent, parent_slot, 476db94535dSChris Mason cow->start); 47774493f7aSChris Mason btrfs_set_node_ptr_generation(parent, parent_slot, 47874493f7aSChris Mason trans->transid); 4796702ed49SChris Mason btrfs_mark_buffer_dirty(parent); 480f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, buf, parent_start, 481f0486c68SYan, Zheng last_ref); 4826702ed49SChris Mason } 483925baeddSChris Mason if (unlock_orig) 484925baeddSChris Mason btrfs_tree_unlock(buf); 4855f39d397SChris Mason free_extent_buffer(buf); 4866702ed49SChris Mason btrfs_mark_buffer_dirty(cow); 4876702ed49SChris Mason *cow_ret = cow; 4886702ed49SChris Mason return 0; 4896702ed49SChris Mason } 4906702ed49SChris Mason 4915d4f98a2SYan Zheng static inline int should_cow_block(struct btrfs_trans_handle *trans, 4925d4f98a2SYan Zheng struct btrfs_root *root, 4935d4f98a2SYan Zheng struct extent_buffer *buf) 4945d4f98a2SYan Zheng { 4955d4f98a2SYan Zheng if (btrfs_header_generation(buf) == trans->transid && 4965d4f98a2SYan Zheng !btrfs_header_flag(buf, BTRFS_HEADER_FLAG_WRITTEN) && 4975d4f98a2SYan Zheng !(root->root_key.objectid != BTRFS_TREE_RELOC_OBJECTID && 4985d4f98a2SYan Zheng btrfs_header_flag(buf, BTRFS_HEADER_FLAG_RELOC))) 4995d4f98a2SYan Zheng return 0; 5005d4f98a2SYan Zheng return 1; 5015d4f98a2SYan Zheng } 5025d4f98a2SYan Zheng 503d352ac68SChris Mason /* 504d352ac68SChris Mason * cows a single block, see __btrfs_cow_block for the real work. 505d352ac68SChris Mason * This version of it has extra checks so that a block isn't cow'd more than 506d352ac68SChris Mason * once per transaction, as long as it hasn't been written yet 507d352ac68SChris Mason */ 508d397712bSChris Mason noinline int btrfs_cow_block(struct btrfs_trans_handle *trans, 5095f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *buf, 5105f39d397SChris Mason struct extent_buffer *parent, int parent_slot, 5119fa8cfe7SChris Mason struct extent_buffer **cow_ret) 51202217ed2SChris Mason { 5136702ed49SChris Mason u64 search_start; 514f510cfecSChris Mason int ret; 515dc17ff8fSChris Mason 516ccd467d6SChris Mason if (trans->transaction != root->fs_info->running_transaction) { 517d397712bSChris Mason printk(KERN_CRIT "trans %llu running %llu\n", 518d397712bSChris Mason (unsigned long long)trans->transid, 519d397712bSChris Mason (unsigned long long) 520ccd467d6SChris Mason root->fs_info->running_transaction->transid); 521ccd467d6SChris Mason WARN_ON(1); 522ccd467d6SChris Mason } 523ccd467d6SChris Mason if (trans->transid != root->fs_info->generation) { 524d397712bSChris Mason printk(KERN_CRIT "trans %llu running %llu\n", 525d397712bSChris Mason (unsigned long long)trans->transid, 526d397712bSChris Mason (unsigned long long)root->fs_info->generation); 527ccd467d6SChris Mason WARN_ON(1); 528ccd467d6SChris Mason } 529dc17ff8fSChris Mason 5305d4f98a2SYan Zheng if (!should_cow_block(trans, root, buf)) { 53102217ed2SChris Mason *cow_ret = buf; 53202217ed2SChris Mason return 0; 53302217ed2SChris Mason } 534c487685dSChris Mason 5350b86a832SChris Mason search_start = buf->start & ~((u64)(1024 * 1024 * 1024) - 1); 536b4ce94deSChris Mason 537b4ce94deSChris Mason if (parent) 538b4ce94deSChris Mason btrfs_set_lock_blocking(parent); 539b4ce94deSChris Mason btrfs_set_lock_blocking(buf); 540b4ce94deSChris Mason 541f510cfecSChris Mason ret = __btrfs_cow_block(trans, root, buf, parent, 5429fa8cfe7SChris Mason parent_slot, cow_ret, search_start, 0); 543f510cfecSChris Mason return ret; 5442c90e5d6SChris Mason } 5456702ed49SChris Mason 546d352ac68SChris Mason /* 547d352ac68SChris Mason * helper function for defrag to decide if two blocks pointed to by a 548d352ac68SChris Mason * node are actually close by 549d352ac68SChris Mason */ 5506b80053dSChris Mason static int close_blocks(u64 blocknr, u64 other, u32 blocksize) 5516702ed49SChris Mason { 5526b80053dSChris Mason if (blocknr < other && other - (blocknr + blocksize) < 32768) 5536702ed49SChris Mason return 1; 5546b80053dSChris Mason if (blocknr > other && blocknr - (other + blocksize) < 32768) 5556702ed49SChris Mason return 1; 55602217ed2SChris Mason return 0; 55702217ed2SChris Mason } 55802217ed2SChris Mason 559081e9573SChris Mason /* 560081e9573SChris Mason * compare two keys in a memcmp fashion 561081e9573SChris Mason */ 562081e9573SChris Mason static int comp_keys(struct btrfs_disk_key *disk, struct btrfs_key *k2) 563081e9573SChris Mason { 564081e9573SChris Mason struct btrfs_key k1; 565081e9573SChris Mason 566081e9573SChris Mason btrfs_disk_key_to_cpu(&k1, disk); 567081e9573SChris Mason 56820736abaSDiego Calleja return btrfs_comp_cpu_keys(&k1, k2); 569081e9573SChris Mason } 570081e9573SChris Mason 571f3465ca4SJosef Bacik /* 572f3465ca4SJosef Bacik * same as comp_keys only with two btrfs_key's 573f3465ca4SJosef Bacik */ 5745d4f98a2SYan Zheng int btrfs_comp_cpu_keys(struct btrfs_key *k1, struct btrfs_key *k2) 575f3465ca4SJosef Bacik { 576f3465ca4SJosef Bacik if (k1->objectid > k2->objectid) 577f3465ca4SJosef Bacik return 1; 578f3465ca4SJosef Bacik if (k1->objectid < k2->objectid) 579f3465ca4SJosef Bacik return -1; 580f3465ca4SJosef Bacik if (k1->type > k2->type) 581f3465ca4SJosef Bacik return 1; 582f3465ca4SJosef Bacik if (k1->type < k2->type) 583f3465ca4SJosef Bacik return -1; 584f3465ca4SJosef Bacik if (k1->offset > k2->offset) 585f3465ca4SJosef Bacik return 1; 586f3465ca4SJosef Bacik if (k1->offset < k2->offset) 587f3465ca4SJosef Bacik return -1; 588f3465ca4SJosef Bacik return 0; 589f3465ca4SJosef Bacik } 590081e9573SChris Mason 591d352ac68SChris Mason /* 592d352ac68SChris Mason * this is used by the defrag code to go through all the 593d352ac68SChris Mason * leaves pointed to by a node and reallocate them so that 594d352ac68SChris Mason * disk order is close to key order 595d352ac68SChris Mason */ 5966702ed49SChris Mason int btrfs_realloc_node(struct btrfs_trans_handle *trans, 5975f39d397SChris Mason struct btrfs_root *root, struct extent_buffer *parent, 598a6b6e75eSChris Mason int start_slot, int cache_only, u64 *last_ret, 599a6b6e75eSChris Mason struct btrfs_key *progress) 6006702ed49SChris Mason { 6016b80053dSChris Mason struct extent_buffer *cur; 6026702ed49SChris Mason u64 blocknr; 603ca7a79adSChris Mason u64 gen; 604e9d0b13bSChris Mason u64 search_start = *last_ret; 605e9d0b13bSChris Mason u64 last_block = 0; 6066702ed49SChris Mason u64 other; 6076702ed49SChris Mason u32 parent_nritems; 6086702ed49SChris Mason int end_slot; 6096702ed49SChris Mason int i; 6106702ed49SChris Mason int err = 0; 611f2183bdeSChris Mason int parent_level; 6126b80053dSChris Mason int uptodate; 6136b80053dSChris Mason u32 blocksize; 614081e9573SChris Mason int progress_passed = 0; 615081e9573SChris Mason struct btrfs_disk_key disk_key; 6166702ed49SChris Mason 6175708b959SChris Mason parent_level = btrfs_header_level(parent); 6185708b959SChris Mason if (cache_only && parent_level != 1) 6195708b959SChris Mason return 0; 6205708b959SChris Mason 621d397712bSChris Mason if (trans->transaction != root->fs_info->running_transaction) 6226702ed49SChris Mason WARN_ON(1); 623d397712bSChris Mason if (trans->transid != root->fs_info->generation) 6246702ed49SChris Mason WARN_ON(1); 62586479a04SChris Mason 6266b80053dSChris Mason parent_nritems = btrfs_header_nritems(parent); 6276b80053dSChris Mason blocksize = btrfs_level_size(root, parent_level - 1); 6286702ed49SChris Mason end_slot = parent_nritems; 6296702ed49SChris Mason 6306702ed49SChris Mason if (parent_nritems == 1) 6316702ed49SChris Mason return 0; 6326702ed49SChris Mason 633b4ce94deSChris Mason btrfs_set_lock_blocking(parent); 634b4ce94deSChris Mason 6356702ed49SChris Mason for (i = start_slot; i < end_slot; i++) { 6366702ed49SChris Mason int close = 1; 637a6b6e75eSChris Mason 6385708b959SChris Mason if (!parent->map_token) { 6395708b959SChris Mason map_extent_buffer(parent, 6405708b959SChris Mason btrfs_node_key_ptr_offset(i), 6415708b959SChris Mason sizeof(struct btrfs_key_ptr), 6425708b959SChris Mason &parent->map_token, &parent->kaddr, 6435708b959SChris Mason &parent->map_start, &parent->map_len, 6445708b959SChris Mason KM_USER1); 6455708b959SChris Mason } 646081e9573SChris Mason btrfs_node_key(parent, &disk_key, i); 647081e9573SChris Mason if (!progress_passed && comp_keys(&disk_key, progress) < 0) 648081e9573SChris Mason continue; 649081e9573SChris Mason 650081e9573SChris Mason progress_passed = 1; 6516b80053dSChris Mason blocknr = btrfs_node_blockptr(parent, i); 652ca7a79adSChris Mason gen = btrfs_node_ptr_generation(parent, i); 653e9d0b13bSChris Mason if (last_block == 0) 654e9d0b13bSChris Mason last_block = blocknr; 6555708b959SChris Mason 6566702ed49SChris Mason if (i > 0) { 6576b80053dSChris Mason other = btrfs_node_blockptr(parent, i - 1); 6586b80053dSChris Mason close = close_blocks(blocknr, other, blocksize); 6596702ed49SChris Mason } 6600ef3e66bSChris Mason if (!close && i < end_slot - 2) { 6616b80053dSChris Mason other = btrfs_node_blockptr(parent, i + 1); 6626b80053dSChris Mason close = close_blocks(blocknr, other, blocksize); 6636702ed49SChris Mason } 664e9d0b13bSChris Mason if (close) { 665e9d0b13bSChris Mason last_block = blocknr; 6666702ed49SChris Mason continue; 667e9d0b13bSChris Mason } 6685708b959SChris Mason if (parent->map_token) { 6695708b959SChris Mason unmap_extent_buffer(parent, parent->map_token, 6705708b959SChris Mason KM_USER1); 6715708b959SChris Mason parent->map_token = NULL; 6725708b959SChris Mason } 6736702ed49SChris Mason 6746b80053dSChris Mason cur = btrfs_find_tree_block(root, blocknr, blocksize); 6756b80053dSChris Mason if (cur) 6761259ab75SChris Mason uptodate = btrfs_buffer_uptodate(cur, gen); 6776b80053dSChris Mason else 6786b80053dSChris Mason uptodate = 0; 6795708b959SChris Mason if (!cur || !uptodate) { 6806702ed49SChris Mason if (cache_only) { 6816b80053dSChris Mason free_extent_buffer(cur); 6826702ed49SChris Mason continue; 6836702ed49SChris Mason } 6846b80053dSChris Mason if (!cur) { 6856b80053dSChris Mason cur = read_tree_block(root, blocknr, 686ca7a79adSChris Mason blocksize, gen); 6876b80053dSChris Mason } else if (!uptodate) { 688ca7a79adSChris Mason btrfs_read_buffer(cur, gen); 6896702ed49SChris Mason } 690f2183bdeSChris Mason } 691e9d0b13bSChris Mason if (search_start == 0) 6926b80053dSChris Mason search_start = last_block; 693e9d0b13bSChris Mason 694e7a84565SChris Mason btrfs_tree_lock(cur); 695b4ce94deSChris Mason btrfs_set_lock_blocking(cur); 6966b80053dSChris Mason err = __btrfs_cow_block(trans, root, cur, parent, i, 697e7a84565SChris Mason &cur, search_start, 6986b80053dSChris Mason min(16 * blocksize, 6999fa8cfe7SChris Mason (end_slot - i) * blocksize)); 700252c38f0SYan if (err) { 701e7a84565SChris Mason btrfs_tree_unlock(cur); 7026b80053dSChris Mason free_extent_buffer(cur); 7036702ed49SChris Mason break; 704252c38f0SYan } 705e7a84565SChris Mason search_start = cur->start; 706e7a84565SChris Mason last_block = cur->start; 707f2183bdeSChris Mason *last_ret = search_start; 708e7a84565SChris Mason btrfs_tree_unlock(cur); 709e7a84565SChris Mason free_extent_buffer(cur); 7106702ed49SChris Mason } 7115708b959SChris Mason if (parent->map_token) { 7125708b959SChris Mason unmap_extent_buffer(parent, parent->map_token, 7135708b959SChris Mason KM_USER1); 7145708b959SChris Mason parent->map_token = NULL; 7155708b959SChris Mason } 7166702ed49SChris Mason return err; 7176702ed49SChris Mason } 7186702ed49SChris Mason 71974123bd7SChris Mason /* 72074123bd7SChris Mason * The leaf data grows from end-to-front in the node. 72174123bd7SChris Mason * this returns the address of the start of the last item, 72274123bd7SChris Mason * which is the stop of the leaf data stack 72374123bd7SChris Mason */ 724123abc88SChris Mason static inline unsigned int leaf_data_end(struct btrfs_root *root, 7255f39d397SChris Mason struct extent_buffer *leaf) 726be0e5c09SChris Mason { 7275f39d397SChris Mason u32 nr = btrfs_header_nritems(leaf); 728be0e5c09SChris Mason if (nr == 0) 729123abc88SChris Mason return BTRFS_LEAF_DATA_SIZE(root); 7305f39d397SChris Mason return btrfs_item_offset_nr(leaf, nr - 1); 731be0e5c09SChris Mason } 732be0e5c09SChris Mason 733d352ac68SChris Mason /* 734d352ac68SChris Mason * extra debugging checks to make sure all the items in a key are 735d352ac68SChris Mason * well formed and in the proper order 736d352ac68SChris Mason */ 737123abc88SChris Mason static int check_node(struct btrfs_root *root, struct btrfs_path *path, 738123abc88SChris Mason int level) 739aa5d6bedSChris Mason { 7405f39d397SChris Mason struct extent_buffer *parent = NULL; 7415f39d397SChris Mason struct extent_buffer *node = path->nodes[level]; 7425f39d397SChris Mason struct btrfs_disk_key parent_key; 7435f39d397SChris Mason struct btrfs_disk_key node_key; 744aa5d6bedSChris Mason int parent_slot; 7458d7be552SChris Mason int slot; 7468d7be552SChris Mason struct btrfs_key cpukey; 7475f39d397SChris Mason u32 nritems = btrfs_header_nritems(node); 748aa5d6bedSChris Mason 749aa5d6bedSChris Mason if (path->nodes[level + 1]) 7505f39d397SChris Mason parent = path->nodes[level + 1]; 751a1f39630SAneesh 7528d7be552SChris Mason slot = path->slots[level]; 7537518a238SChris Mason BUG_ON(nritems == 0); 7547518a238SChris Mason if (parent) { 755a1f39630SAneesh parent_slot = path->slots[level + 1]; 7565f39d397SChris Mason btrfs_node_key(parent, &parent_key, parent_slot); 7575f39d397SChris Mason btrfs_node_key(node, &node_key, 0); 7585f39d397SChris Mason BUG_ON(memcmp(&parent_key, &node_key, 759e2fa7227SChris Mason sizeof(struct btrfs_disk_key))); 7601d4f8a0cSChris Mason BUG_ON(btrfs_node_blockptr(parent, parent_slot) != 761db94535dSChris Mason btrfs_header_bytenr(node)); 762aa5d6bedSChris Mason } 763123abc88SChris Mason BUG_ON(nritems > BTRFS_NODEPTRS_PER_BLOCK(root)); 7648d7be552SChris Mason if (slot != 0) { 7655f39d397SChris Mason btrfs_node_key_to_cpu(node, &cpukey, slot - 1); 7665f39d397SChris Mason btrfs_node_key(node, &node_key, slot); 7675f39d397SChris Mason BUG_ON(comp_keys(&node_key, &cpukey) <= 0); 7688d7be552SChris Mason } 7698d7be552SChris Mason if (slot < nritems - 1) { 7705f39d397SChris Mason btrfs_node_key_to_cpu(node, &cpukey, slot + 1); 7715f39d397SChris Mason btrfs_node_key(node, &node_key, slot); 7725f39d397SChris Mason BUG_ON(comp_keys(&node_key, &cpukey) >= 0); 773aa5d6bedSChris Mason } 774aa5d6bedSChris Mason return 0; 775aa5d6bedSChris Mason } 776aa5d6bedSChris Mason 777d352ac68SChris Mason /* 778d352ac68SChris Mason * extra checking to make sure all the items in a leaf are 779d352ac68SChris Mason * well formed and in the proper order 780d352ac68SChris Mason */ 781123abc88SChris Mason static int check_leaf(struct btrfs_root *root, struct btrfs_path *path, 782123abc88SChris Mason int level) 783aa5d6bedSChris Mason { 7845f39d397SChris Mason struct extent_buffer *leaf = path->nodes[level]; 7855f39d397SChris Mason struct extent_buffer *parent = NULL; 786aa5d6bedSChris Mason int parent_slot; 7878d7be552SChris Mason struct btrfs_key cpukey; 7885f39d397SChris Mason struct btrfs_disk_key parent_key; 7895f39d397SChris Mason struct btrfs_disk_key leaf_key; 7905f39d397SChris Mason int slot = path->slots[0]; 7918d7be552SChris Mason 7925f39d397SChris Mason u32 nritems = btrfs_header_nritems(leaf); 793aa5d6bedSChris Mason 794aa5d6bedSChris Mason if (path->nodes[level + 1]) 7955f39d397SChris Mason parent = path->nodes[level + 1]; 7967518a238SChris Mason 7977518a238SChris Mason if (nritems == 0) 7987518a238SChris Mason return 0; 7997518a238SChris Mason 8007518a238SChris Mason if (parent) { 801a1f39630SAneesh parent_slot = path->slots[level + 1]; 8025f39d397SChris Mason btrfs_node_key(parent, &parent_key, parent_slot); 8035f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, 0); 8046702ed49SChris Mason 8055f39d397SChris Mason BUG_ON(memcmp(&parent_key, &leaf_key, 806e2fa7227SChris Mason sizeof(struct btrfs_disk_key))); 8071d4f8a0cSChris Mason BUG_ON(btrfs_node_blockptr(parent, parent_slot) != 808db94535dSChris Mason btrfs_header_bytenr(leaf)); 809aa5d6bedSChris Mason } 8105f39d397SChris Mason if (slot != 0 && slot < nritems - 1) { 8115f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, slot); 8125f39d397SChris Mason btrfs_item_key_to_cpu(leaf, &cpukey, slot - 1); 8135f39d397SChris Mason if (comp_keys(&leaf_key, &cpukey) <= 0) { 8145f39d397SChris Mason btrfs_print_leaf(root, leaf); 815d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad key\n", slot); 8165f39d397SChris Mason BUG_ON(1); 8175f39d397SChris Mason } 8185f39d397SChris Mason if (btrfs_item_offset_nr(leaf, slot - 1) != 8195f39d397SChris Mason btrfs_item_end_nr(leaf, slot)) { 8205f39d397SChris Mason btrfs_print_leaf(root, leaf); 821d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad\n", slot); 8225f39d397SChris Mason BUG_ON(1); 8235f39d397SChris Mason } 824aa5d6bedSChris Mason } 8258d7be552SChris Mason if (slot < nritems - 1) { 8265f39d397SChris Mason btrfs_item_key(leaf, &leaf_key, slot); 8275f39d397SChris Mason btrfs_item_key_to_cpu(leaf, &cpukey, slot + 1); 8285f39d397SChris Mason BUG_ON(comp_keys(&leaf_key, &cpukey) >= 0); 8295f39d397SChris Mason if (btrfs_item_offset_nr(leaf, slot) != 8305f39d397SChris Mason btrfs_item_end_nr(leaf, slot + 1)) { 8315f39d397SChris Mason btrfs_print_leaf(root, leaf); 832d397712bSChris Mason printk(KERN_CRIT "slot %d offset bad\n", slot); 8335f39d397SChris Mason BUG_ON(1); 834aa5d6bedSChris Mason } 8355f39d397SChris Mason } 8365f39d397SChris Mason BUG_ON(btrfs_item_offset_nr(leaf, 0) + 8375f39d397SChris Mason btrfs_item_size_nr(leaf, 0) != BTRFS_LEAF_DATA_SIZE(root)); 838aa5d6bedSChris Mason return 0; 839aa5d6bedSChris Mason } 840aa5d6bedSChris Mason 841d397712bSChris Mason static noinline int check_block(struct btrfs_root *root, 84298ed5174SChris Mason struct btrfs_path *path, int level) 843aa5d6bedSChris Mason { 84485d824c4SChris Mason return 0; 845aa5d6bedSChris Mason if (level == 0) 846123abc88SChris Mason return check_leaf(root, path, level); 847123abc88SChris Mason return check_node(root, path, level); 848aa5d6bedSChris Mason } 849aa5d6bedSChris Mason 85074123bd7SChris Mason /* 8515f39d397SChris Mason * search for key in the extent_buffer. The items start at offset p, 8525f39d397SChris Mason * and they are item_size apart. There are 'max' items in p. 8535f39d397SChris Mason * 85474123bd7SChris Mason * the slot in the array is returned via slot, and it points to 85574123bd7SChris Mason * the place where you would insert key if it is not found in 85674123bd7SChris Mason * the array. 85774123bd7SChris Mason * 85874123bd7SChris Mason * slot may point to max if the key is bigger than all of the keys 85974123bd7SChris Mason */ 860e02119d5SChris Mason static noinline int generic_bin_search(struct extent_buffer *eb, 861e02119d5SChris Mason unsigned long p, 8625f39d397SChris Mason int item_size, struct btrfs_key *key, 863be0e5c09SChris Mason int max, int *slot) 864be0e5c09SChris Mason { 865be0e5c09SChris Mason int low = 0; 866be0e5c09SChris Mason int high = max; 867be0e5c09SChris Mason int mid; 868be0e5c09SChris Mason int ret; 869479965d6SChris Mason struct btrfs_disk_key *tmp = NULL; 8705f39d397SChris Mason struct btrfs_disk_key unaligned; 8715f39d397SChris Mason unsigned long offset; 8725f39d397SChris Mason char *map_token = NULL; 8735f39d397SChris Mason char *kaddr = NULL; 8745f39d397SChris Mason unsigned long map_start = 0; 8755f39d397SChris Mason unsigned long map_len = 0; 876479965d6SChris Mason int err; 877be0e5c09SChris Mason 878be0e5c09SChris Mason while (low < high) { 879be0e5c09SChris Mason mid = (low + high) / 2; 8805f39d397SChris Mason offset = p + mid * item_size; 8815f39d397SChris Mason 8825f39d397SChris Mason if (!map_token || offset < map_start || 8835f39d397SChris Mason (offset + sizeof(struct btrfs_disk_key)) > 8845f39d397SChris Mason map_start + map_len) { 885479965d6SChris Mason if (map_token) { 8865f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 887479965d6SChris Mason map_token = NULL; 888479965d6SChris Mason } 889934d375bSChris Mason 890934d375bSChris Mason err = map_private_extent_buffer(eb, offset, 891479965d6SChris Mason sizeof(struct btrfs_disk_key), 892479965d6SChris Mason &map_token, &kaddr, 8935f39d397SChris Mason &map_start, &map_len, KM_USER0); 8945f39d397SChris Mason 895479965d6SChris Mason if (!err) { 896479965d6SChris Mason tmp = (struct btrfs_disk_key *)(kaddr + offset - 897479965d6SChris Mason map_start); 898479965d6SChris Mason } else { 8995f39d397SChris Mason read_extent_buffer(eb, &unaligned, 9005f39d397SChris Mason offset, sizeof(unaligned)); 9015f39d397SChris Mason tmp = &unaligned; 902479965d6SChris Mason } 903479965d6SChris Mason 9045f39d397SChris Mason } else { 9055f39d397SChris Mason tmp = (struct btrfs_disk_key *)(kaddr + offset - 9065f39d397SChris Mason map_start); 9075f39d397SChris Mason } 908be0e5c09SChris Mason ret = comp_keys(tmp, key); 909be0e5c09SChris Mason 910be0e5c09SChris Mason if (ret < 0) 911be0e5c09SChris Mason low = mid + 1; 912be0e5c09SChris Mason else if (ret > 0) 913be0e5c09SChris Mason high = mid; 914be0e5c09SChris Mason else { 915be0e5c09SChris Mason *slot = mid; 916479965d6SChris Mason if (map_token) 9175f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 918be0e5c09SChris Mason return 0; 919be0e5c09SChris Mason } 920be0e5c09SChris Mason } 921be0e5c09SChris Mason *slot = low; 9225f39d397SChris Mason if (map_token) 9235f39d397SChris Mason unmap_extent_buffer(eb, map_token, KM_USER0); 924be0e5c09SChris Mason return 1; 925be0e5c09SChris Mason } 926be0e5c09SChris Mason 92797571fd0SChris Mason /* 92897571fd0SChris Mason * simple bin_search frontend that does the right thing for 92997571fd0SChris Mason * leaves vs nodes 93097571fd0SChris Mason */ 9315f39d397SChris Mason static int bin_search(struct extent_buffer *eb, struct btrfs_key *key, 9325f39d397SChris Mason int level, int *slot) 933be0e5c09SChris Mason { 9345f39d397SChris Mason if (level == 0) { 9355f39d397SChris Mason return generic_bin_search(eb, 9365f39d397SChris Mason offsetof(struct btrfs_leaf, items), 9370783fcfcSChris Mason sizeof(struct btrfs_item), 9385f39d397SChris Mason key, btrfs_header_nritems(eb), 9397518a238SChris Mason slot); 940be0e5c09SChris Mason } else { 9415f39d397SChris Mason return generic_bin_search(eb, 9425f39d397SChris Mason offsetof(struct btrfs_node, ptrs), 943123abc88SChris Mason sizeof(struct btrfs_key_ptr), 9445f39d397SChris Mason key, btrfs_header_nritems(eb), 9457518a238SChris Mason slot); 946be0e5c09SChris Mason } 947be0e5c09SChris Mason return -1; 948be0e5c09SChris Mason } 949be0e5c09SChris Mason 9505d4f98a2SYan Zheng int btrfs_bin_search(struct extent_buffer *eb, struct btrfs_key *key, 9515d4f98a2SYan Zheng int level, int *slot) 9525d4f98a2SYan Zheng { 9535d4f98a2SYan Zheng return bin_search(eb, key, level, slot); 9545d4f98a2SYan Zheng } 9555d4f98a2SYan Zheng 956f0486c68SYan, Zheng static void root_add_used(struct btrfs_root *root, u32 size) 957f0486c68SYan, Zheng { 958f0486c68SYan, Zheng spin_lock(&root->accounting_lock); 959f0486c68SYan, Zheng btrfs_set_root_used(&root->root_item, 960f0486c68SYan, Zheng btrfs_root_used(&root->root_item) + size); 961f0486c68SYan, Zheng spin_unlock(&root->accounting_lock); 962f0486c68SYan, Zheng } 963f0486c68SYan, Zheng 964f0486c68SYan, Zheng static void root_sub_used(struct btrfs_root *root, u32 size) 965f0486c68SYan, Zheng { 966f0486c68SYan, Zheng spin_lock(&root->accounting_lock); 967f0486c68SYan, Zheng btrfs_set_root_used(&root->root_item, 968f0486c68SYan, Zheng btrfs_root_used(&root->root_item) - size); 969f0486c68SYan, Zheng spin_unlock(&root->accounting_lock); 970f0486c68SYan, Zheng } 971f0486c68SYan, Zheng 972d352ac68SChris Mason /* given a node and slot number, this reads the blocks it points to. The 973d352ac68SChris Mason * extent buffer is returned with a reference taken (but unlocked). 974d352ac68SChris Mason * NULL is returned on error. 975d352ac68SChris Mason */ 976e02119d5SChris Mason static noinline struct extent_buffer *read_node_slot(struct btrfs_root *root, 9775f39d397SChris Mason struct extent_buffer *parent, int slot) 978bb803951SChris Mason { 979ca7a79adSChris Mason int level = btrfs_header_level(parent); 980bb803951SChris Mason if (slot < 0) 981bb803951SChris Mason return NULL; 9825f39d397SChris Mason if (slot >= btrfs_header_nritems(parent)) 983bb803951SChris Mason return NULL; 984ca7a79adSChris Mason 985ca7a79adSChris Mason BUG_ON(level == 0); 986ca7a79adSChris Mason 987db94535dSChris Mason return read_tree_block(root, btrfs_node_blockptr(parent, slot), 988ca7a79adSChris Mason btrfs_level_size(root, level - 1), 989ca7a79adSChris Mason btrfs_node_ptr_generation(parent, slot)); 990bb803951SChris Mason } 991bb803951SChris Mason 992d352ac68SChris Mason /* 993d352ac68SChris Mason * node level balancing, used to make sure nodes are in proper order for 994d352ac68SChris Mason * item deletion. We balance from the top down, so we have to make sure 995d352ac68SChris Mason * that a deletion won't leave an node completely empty later on. 996d352ac68SChris Mason */ 997e02119d5SChris Mason static noinline int balance_level(struct btrfs_trans_handle *trans, 99898ed5174SChris Mason struct btrfs_root *root, 99998ed5174SChris Mason struct btrfs_path *path, int level) 1000bb803951SChris Mason { 10015f39d397SChris Mason struct extent_buffer *right = NULL; 10025f39d397SChris Mason struct extent_buffer *mid; 10035f39d397SChris Mason struct extent_buffer *left = NULL; 10045f39d397SChris Mason struct extent_buffer *parent = NULL; 1005bb803951SChris Mason int ret = 0; 1006bb803951SChris Mason int wret; 1007bb803951SChris Mason int pslot; 1008bb803951SChris Mason int orig_slot = path->slots[level]; 100979f95c82SChris Mason u64 orig_ptr; 1010bb803951SChris Mason 1011bb803951SChris Mason if (level == 0) 1012bb803951SChris Mason return 0; 1013bb803951SChris Mason 10145f39d397SChris Mason mid = path->nodes[level]; 1015b4ce94deSChris Mason 1016925baeddSChris Mason WARN_ON(!path->locks[level]); 10177bb86316SChris Mason WARN_ON(btrfs_header_generation(mid) != trans->transid); 10187bb86316SChris Mason 10191d4f8a0cSChris Mason orig_ptr = btrfs_node_blockptr(mid, orig_slot); 102079f95c82SChris Mason 1021234b63a0SChris Mason if (level < BTRFS_MAX_LEVEL - 1) 10225f39d397SChris Mason parent = path->nodes[level + 1]; 1023bb803951SChris Mason pslot = path->slots[level + 1]; 1024bb803951SChris Mason 102540689478SChris Mason /* 102640689478SChris Mason * deal with the case where there is only one pointer in the root 102740689478SChris Mason * by promoting the node below to a root 102840689478SChris Mason */ 10295f39d397SChris Mason if (!parent) { 10305f39d397SChris Mason struct extent_buffer *child; 1031bb803951SChris Mason 10325f39d397SChris Mason if (btrfs_header_nritems(mid) != 1) 1033bb803951SChris Mason return 0; 1034bb803951SChris Mason 1035bb803951SChris Mason /* promote the child to a root */ 10365f39d397SChris Mason child = read_node_slot(root, mid, 0); 10377951f3ceSJeff Mahoney BUG_ON(!child); 1038925baeddSChris Mason btrfs_tree_lock(child); 1039b4ce94deSChris Mason btrfs_set_lock_blocking(child); 10409fa8cfe7SChris Mason ret = btrfs_cow_block(trans, root, child, mid, 0, &child); 1041f0486c68SYan, Zheng if (ret) { 1042f0486c68SYan, Zheng btrfs_tree_unlock(child); 1043f0486c68SYan, Zheng free_extent_buffer(child); 1044f0486c68SYan, Zheng goto enospc; 1045f0486c68SYan, Zheng } 10462f375ab9SYan 1047925baeddSChris Mason spin_lock(&root->node_lock); 1048bb803951SChris Mason root->node = child; 1049925baeddSChris Mason spin_unlock(&root->node_lock); 1050925baeddSChris Mason 10510b86a832SChris Mason add_root_to_dirty_list(root); 1052925baeddSChris Mason btrfs_tree_unlock(child); 1053b4ce94deSChris Mason 1054925baeddSChris Mason path->locks[level] = 0; 1055bb803951SChris Mason path->nodes[level] = NULL; 10565f39d397SChris Mason clean_tree_block(trans, root, mid); 1057925baeddSChris Mason btrfs_tree_unlock(mid); 1058bb803951SChris Mason /* once for the path */ 10595f39d397SChris Mason free_extent_buffer(mid); 1060f0486c68SYan, Zheng 1061f0486c68SYan, Zheng root_sub_used(root, mid->len); 1062f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, mid, 0, 1); 1063bb803951SChris Mason /* once for the root ptr */ 10645f39d397SChris Mason free_extent_buffer(mid); 1065f0486c68SYan, Zheng return 0; 1066bb803951SChris Mason } 10675f39d397SChris Mason if (btrfs_header_nritems(mid) > 1068123abc88SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) / 4) 1069bb803951SChris Mason return 0; 1070bb803951SChris Mason 1071*559af821SAndi Kleen btrfs_header_nritems(mid); 107254aa1f4dSChris Mason 10735f39d397SChris Mason left = read_node_slot(root, parent, pslot - 1); 10745f39d397SChris Mason if (left) { 1075925baeddSChris Mason btrfs_tree_lock(left); 1076b4ce94deSChris Mason btrfs_set_lock_blocking(left); 10775f39d397SChris Mason wret = btrfs_cow_block(trans, root, left, 10789fa8cfe7SChris Mason parent, pslot - 1, &left); 107954aa1f4dSChris Mason if (wret) { 108054aa1f4dSChris Mason ret = wret; 108154aa1f4dSChris Mason goto enospc; 108254aa1f4dSChris Mason } 10832cc58cf2SChris Mason } 10845f39d397SChris Mason right = read_node_slot(root, parent, pslot + 1); 10855f39d397SChris Mason if (right) { 1086925baeddSChris Mason btrfs_tree_lock(right); 1087b4ce94deSChris Mason btrfs_set_lock_blocking(right); 10885f39d397SChris Mason wret = btrfs_cow_block(trans, root, right, 10899fa8cfe7SChris Mason parent, pslot + 1, &right); 10902cc58cf2SChris Mason if (wret) { 10912cc58cf2SChris Mason ret = wret; 10922cc58cf2SChris Mason goto enospc; 10932cc58cf2SChris Mason } 10942cc58cf2SChris Mason } 10952cc58cf2SChris Mason 10962cc58cf2SChris Mason /* first, try to make some room in the middle buffer */ 10975f39d397SChris Mason if (left) { 10985f39d397SChris Mason orig_slot += btrfs_header_nritems(left); 1099bce4eae9SChris Mason wret = push_node_left(trans, root, left, mid, 1); 110079f95c82SChris Mason if (wret < 0) 110179f95c82SChris Mason ret = wret; 1102*559af821SAndi Kleen btrfs_header_nritems(mid); 1103bb803951SChris Mason } 110479f95c82SChris Mason 110579f95c82SChris Mason /* 110679f95c82SChris Mason * then try to empty the right most buffer into the middle 110779f95c82SChris Mason */ 11085f39d397SChris Mason if (right) { 1109971a1f66SChris Mason wret = push_node_left(trans, root, mid, right, 1); 111054aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 111179f95c82SChris Mason ret = wret; 11125f39d397SChris Mason if (btrfs_header_nritems(right) == 0) { 11135f39d397SChris Mason clean_tree_block(trans, root, right); 1114925baeddSChris Mason btrfs_tree_unlock(right); 1115e089f05cSChris Mason wret = del_ptr(trans, root, path, level + 1, pslot + 1116e089f05cSChris Mason 1); 1117bb803951SChris Mason if (wret) 1118bb803951SChris Mason ret = wret; 1119f0486c68SYan, Zheng root_sub_used(root, right->len); 1120f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, right, 0, 1); 1121f0486c68SYan, Zheng free_extent_buffer(right); 1122f0486c68SYan, Zheng right = NULL; 1123bb803951SChris Mason } else { 11245f39d397SChris Mason struct btrfs_disk_key right_key; 11255f39d397SChris Mason btrfs_node_key(right, &right_key, 0); 11265f39d397SChris Mason btrfs_set_node_key(parent, &right_key, pslot + 1); 11275f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 1128bb803951SChris Mason } 1129bb803951SChris Mason } 11305f39d397SChris Mason if (btrfs_header_nritems(mid) == 1) { 113179f95c82SChris Mason /* 113279f95c82SChris Mason * we're not allowed to leave a node with one item in the 113379f95c82SChris Mason * tree during a delete. A deletion from lower in the tree 113479f95c82SChris Mason * could try to delete the only pointer in this node. 113579f95c82SChris Mason * So, pull some keys from the left. 113679f95c82SChris Mason * There has to be a left pointer at this point because 113779f95c82SChris Mason * otherwise we would have pulled some pointers from the 113879f95c82SChris Mason * right 113979f95c82SChris Mason */ 11405f39d397SChris Mason BUG_ON(!left); 11415f39d397SChris Mason wret = balance_node_right(trans, root, mid, left); 114254aa1f4dSChris Mason if (wret < 0) { 114379f95c82SChris Mason ret = wret; 114454aa1f4dSChris Mason goto enospc; 114554aa1f4dSChris Mason } 1146bce4eae9SChris Mason if (wret == 1) { 1147bce4eae9SChris Mason wret = push_node_left(trans, root, left, mid, 1); 1148bce4eae9SChris Mason if (wret < 0) 1149bce4eae9SChris Mason ret = wret; 1150bce4eae9SChris Mason } 115179f95c82SChris Mason BUG_ON(wret == 1); 115279f95c82SChris Mason } 11535f39d397SChris Mason if (btrfs_header_nritems(mid) == 0) { 11545f39d397SChris Mason clean_tree_block(trans, root, mid); 1155925baeddSChris Mason btrfs_tree_unlock(mid); 1156e089f05cSChris Mason wret = del_ptr(trans, root, path, level + 1, pslot); 1157bb803951SChris Mason if (wret) 1158bb803951SChris Mason ret = wret; 1159f0486c68SYan, Zheng root_sub_used(root, mid->len); 1160f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, mid, 0, 1); 1161f0486c68SYan, Zheng free_extent_buffer(mid); 1162f0486c68SYan, Zheng mid = NULL; 116379f95c82SChris Mason } else { 116479f95c82SChris Mason /* update the parent key to reflect our changes */ 11655f39d397SChris Mason struct btrfs_disk_key mid_key; 11665f39d397SChris Mason btrfs_node_key(mid, &mid_key, 0); 11675f39d397SChris Mason btrfs_set_node_key(parent, &mid_key, pslot); 11685f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 116979f95c82SChris Mason } 1170bb803951SChris Mason 117179f95c82SChris Mason /* update the path */ 11725f39d397SChris Mason if (left) { 11735f39d397SChris Mason if (btrfs_header_nritems(left) > orig_slot) { 11745f39d397SChris Mason extent_buffer_get(left); 1175925baeddSChris Mason /* left was locked after cow */ 11765f39d397SChris Mason path->nodes[level] = left; 1177bb803951SChris Mason path->slots[level + 1] -= 1; 1178bb803951SChris Mason path->slots[level] = orig_slot; 1179925baeddSChris Mason if (mid) { 1180925baeddSChris Mason btrfs_tree_unlock(mid); 11815f39d397SChris Mason free_extent_buffer(mid); 1182925baeddSChris Mason } 1183bb803951SChris Mason } else { 11845f39d397SChris Mason orig_slot -= btrfs_header_nritems(left); 1185bb803951SChris Mason path->slots[level] = orig_slot; 1186bb803951SChris Mason } 1187bb803951SChris Mason } 118879f95c82SChris Mason /* double check we haven't messed things up */ 1189123abc88SChris Mason check_block(root, path, level); 1190e20d96d6SChris Mason if (orig_ptr != 11915f39d397SChris Mason btrfs_node_blockptr(path->nodes[level], path->slots[level])) 119279f95c82SChris Mason BUG(); 119354aa1f4dSChris Mason enospc: 1194925baeddSChris Mason if (right) { 1195925baeddSChris Mason btrfs_tree_unlock(right); 11965f39d397SChris Mason free_extent_buffer(right); 1197925baeddSChris Mason } 1198925baeddSChris Mason if (left) { 1199925baeddSChris Mason if (path->nodes[level] != left) 1200925baeddSChris Mason btrfs_tree_unlock(left); 12015f39d397SChris Mason free_extent_buffer(left); 1202925baeddSChris Mason } 1203bb803951SChris Mason return ret; 1204bb803951SChris Mason } 1205bb803951SChris Mason 1206d352ac68SChris Mason /* Node balancing for insertion. Here we only split or push nodes around 1207d352ac68SChris Mason * when they are completely full. This is also done top down, so we 1208d352ac68SChris Mason * have to be pessimistic. 1209d352ac68SChris Mason */ 1210d397712bSChris Mason static noinline int push_nodes_for_insert(struct btrfs_trans_handle *trans, 1211e66f709bSChris Mason struct btrfs_root *root, 1212e66f709bSChris Mason struct btrfs_path *path, int level) 1213e66f709bSChris Mason { 12145f39d397SChris Mason struct extent_buffer *right = NULL; 12155f39d397SChris Mason struct extent_buffer *mid; 12165f39d397SChris Mason struct extent_buffer *left = NULL; 12175f39d397SChris Mason struct extent_buffer *parent = NULL; 1218e66f709bSChris Mason int ret = 0; 1219e66f709bSChris Mason int wret; 1220e66f709bSChris Mason int pslot; 1221e66f709bSChris Mason int orig_slot = path->slots[level]; 1222e66f709bSChris Mason 1223e66f709bSChris Mason if (level == 0) 1224e66f709bSChris Mason return 1; 1225e66f709bSChris Mason 12265f39d397SChris Mason mid = path->nodes[level]; 12277bb86316SChris Mason WARN_ON(btrfs_header_generation(mid) != trans->transid); 1228e66f709bSChris Mason 1229e66f709bSChris Mason if (level < BTRFS_MAX_LEVEL - 1) 12305f39d397SChris Mason parent = path->nodes[level + 1]; 1231e66f709bSChris Mason pslot = path->slots[level + 1]; 1232e66f709bSChris Mason 12335f39d397SChris Mason if (!parent) 1234e66f709bSChris Mason return 1; 1235e66f709bSChris Mason 12365f39d397SChris Mason left = read_node_slot(root, parent, pslot - 1); 1237e66f709bSChris Mason 1238e66f709bSChris Mason /* first, try to make some room in the middle buffer */ 12395f39d397SChris Mason if (left) { 1240e66f709bSChris Mason u32 left_nr; 1241925baeddSChris Mason 1242925baeddSChris Mason btrfs_tree_lock(left); 1243b4ce94deSChris Mason btrfs_set_lock_blocking(left); 1244b4ce94deSChris Mason 12455f39d397SChris Mason left_nr = btrfs_header_nritems(left); 124633ade1f8SChris Mason if (left_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) { 124733ade1f8SChris Mason wret = 1; 124833ade1f8SChris Mason } else { 12495f39d397SChris Mason ret = btrfs_cow_block(trans, root, left, parent, 12509fa8cfe7SChris Mason pslot - 1, &left); 125154aa1f4dSChris Mason if (ret) 125254aa1f4dSChris Mason wret = 1; 125354aa1f4dSChris Mason else { 125454aa1f4dSChris Mason wret = push_node_left(trans, root, 1255971a1f66SChris Mason left, mid, 0); 125654aa1f4dSChris Mason } 125733ade1f8SChris Mason } 1258e66f709bSChris Mason if (wret < 0) 1259e66f709bSChris Mason ret = wret; 1260e66f709bSChris Mason if (wret == 0) { 12615f39d397SChris Mason struct btrfs_disk_key disk_key; 1262e66f709bSChris Mason orig_slot += left_nr; 12635f39d397SChris Mason btrfs_node_key(mid, &disk_key, 0); 12645f39d397SChris Mason btrfs_set_node_key(parent, &disk_key, pslot); 12655f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 12665f39d397SChris Mason if (btrfs_header_nritems(left) > orig_slot) { 12675f39d397SChris Mason path->nodes[level] = left; 1268e66f709bSChris Mason path->slots[level + 1] -= 1; 1269e66f709bSChris Mason path->slots[level] = orig_slot; 1270925baeddSChris Mason btrfs_tree_unlock(mid); 12715f39d397SChris Mason free_extent_buffer(mid); 1272e66f709bSChris Mason } else { 1273e66f709bSChris Mason orig_slot -= 12745f39d397SChris Mason btrfs_header_nritems(left); 1275e66f709bSChris Mason path->slots[level] = orig_slot; 1276925baeddSChris Mason btrfs_tree_unlock(left); 12775f39d397SChris Mason free_extent_buffer(left); 1278e66f709bSChris Mason } 1279e66f709bSChris Mason return 0; 1280e66f709bSChris Mason } 1281925baeddSChris Mason btrfs_tree_unlock(left); 12825f39d397SChris Mason free_extent_buffer(left); 1283e66f709bSChris Mason } 12845f39d397SChris Mason right = read_node_slot(root, parent, pslot + 1); 1285e66f709bSChris Mason 1286e66f709bSChris Mason /* 1287e66f709bSChris Mason * then try to empty the right most buffer into the middle 1288e66f709bSChris Mason */ 12895f39d397SChris Mason if (right) { 129033ade1f8SChris Mason u32 right_nr; 1291b4ce94deSChris Mason 1292925baeddSChris Mason btrfs_tree_lock(right); 1293b4ce94deSChris Mason btrfs_set_lock_blocking(right); 1294b4ce94deSChris Mason 12955f39d397SChris Mason right_nr = btrfs_header_nritems(right); 129633ade1f8SChris Mason if (right_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) { 129733ade1f8SChris Mason wret = 1; 129833ade1f8SChris Mason } else { 12995f39d397SChris Mason ret = btrfs_cow_block(trans, root, right, 13005f39d397SChris Mason parent, pslot + 1, 13019fa8cfe7SChris Mason &right); 130254aa1f4dSChris Mason if (ret) 130354aa1f4dSChris Mason wret = 1; 130454aa1f4dSChris Mason else { 130533ade1f8SChris Mason wret = balance_node_right(trans, root, 13065f39d397SChris Mason right, mid); 130733ade1f8SChris Mason } 130854aa1f4dSChris Mason } 1309e66f709bSChris Mason if (wret < 0) 1310e66f709bSChris Mason ret = wret; 1311e66f709bSChris Mason if (wret == 0) { 13125f39d397SChris Mason struct btrfs_disk_key disk_key; 13135f39d397SChris Mason 13145f39d397SChris Mason btrfs_node_key(right, &disk_key, 0); 13155f39d397SChris Mason btrfs_set_node_key(parent, &disk_key, pslot + 1); 13165f39d397SChris Mason btrfs_mark_buffer_dirty(parent); 13175f39d397SChris Mason 13185f39d397SChris Mason if (btrfs_header_nritems(mid) <= orig_slot) { 13195f39d397SChris Mason path->nodes[level] = right; 1320e66f709bSChris Mason path->slots[level + 1] += 1; 1321e66f709bSChris Mason path->slots[level] = orig_slot - 13225f39d397SChris Mason btrfs_header_nritems(mid); 1323925baeddSChris Mason btrfs_tree_unlock(mid); 13245f39d397SChris Mason free_extent_buffer(mid); 1325e66f709bSChris Mason } else { 1326925baeddSChris Mason btrfs_tree_unlock(right); 13275f39d397SChris Mason free_extent_buffer(right); 1328e66f709bSChris Mason } 1329e66f709bSChris Mason return 0; 1330e66f709bSChris Mason } 1331925baeddSChris Mason btrfs_tree_unlock(right); 13325f39d397SChris Mason free_extent_buffer(right); 1333e66f709bSChris Mason } 1334e66f709bSChris Mason return 1; 1335e66f709bSChris Mason } 1336e66f709bSChris Mason 133774123bd7SChris Mason /* 1338d352ac68SChris Mason * readahead one full node of leaves, finding things that are close 1339d352ac68SChris Mason * to the block in 'slot', and triggering ra on them. 13403c69faecSChris Mason */ 1341c8c42864SChris Mason static void reada_for_search(struct btrfs_root *root, 1342e02119d5SChris Mason struct btrfs_path *path, 134301f46658SChris Mason int level, int slot, u64 objectid) 13443c69faecSChris Mason { 13455f39d397SChris Mason struct extent_buffer *node; 134601f46658SChris Mason struct btrfs_disk_key disk_key; 13473c69faecSChris Mason u32 nritems; 13483c69faecSChris Mason u64 search; 1349a7175319SChris Mason u64 target; 13506b80053dSChris Mason u64 nread = 0; 13513c69faecSChris Mason int direction = path->reada; 13525f39d397SChris Mason struct extent_buffer *eb; 13536b80053dSChris Mason u32 nr; 13546b80053dSChris Mason u32 blocksize; 13556b80053dSChris Mason u32 nscan = 0; 1356db94535dSChris Mason 1357a6b6e75eSChris Mason if (level != 1) 13583c69faecSChris Mason return; 13593c69faecSChris Mason 13606702ed49SChris Mason if (!path->nodes[level]) 13616702ed49SChris Mason return; 13626702ed49SChris Mason 13635f39d397SChris Mason node = path->nodes[level]; 1364925baeddSChris Mason 13653c69faecSChris Mason search = btrfs_node_blockptr(node, slot); 13666b80053dSChris Mason blocksize = btrfs_level_size(root, level - 1); 13676b80053dSChris Mason eb = btrfs_find_tree_block(root, search, blocksize); 13685f39d397SChris Mason if (eb) { 13695f39d397SChris Mason free_extent_buffer(eb); 13703c69faecSChris Mason return; 13713c69faecSChris Mason } 13723c69faecSChris Mason 1373a7175319SChris Mason target = search; 13746b80053dSChris Mason 13755f39d397SChris Mason nritems = btrfs_header_nritems(node); 13766b80053dSChris Mason nr = slot; 13773c69faecSChris Mason while (1) { 13786b80053dSChris Mason if (direction < 0) { 13796b80053dSChris Mason if (nr == 0) 13803c69faecSChris Mason break; 13816b80053dSChris Mason nr--; 13826b80053dSChris Mason } else if (direction > 0) { 13836b80053dSChris Mason nr++; 13846b80053dSChris Mason if (nr >= nritems) 13856b80053dSChris Mason break; 13863c69faecSChris Mason } 138701f46658SChris Mason if (path->reada < 0 && objectid) { 138801f46658SChris Mason btrfs_node_key(node, &disk_key, nr); 138901f46658SChris Mason if (btrfs_disk_key_objectid(&disk_key) != objectid) 139001f46658SChris Mason break; 139101f46658SChris Mason } 13926b80053dSChris Mason search = btrfs_node_blockptr(node, nr); 1393a7175319SChris Mason if ((search <= target && target - search <= 65536) || 1394a7175319SChris Mason (search > target && search - target <= 65536)) { 1395ca7a79adSChris Mason readahead_tree_block(root, search, blocksize, 1396ca7a79adSChris Mason btrfs_node_ptr_generation(node, nr)); 13976b80053dSChris Mason nread += blocksize; 13983c69faecSChris Mason } 13996b80053dSChris Mason nscan++; 1400a7175319SChris Mason if ((nread > 65536 || nscan > 32)) 14016b80053dSChris Mason break; 14023c69faecSChris Mason } 14033c69faecSChris Mason } 1404925baeddSChris Mason 1405d352ac68SChris Mason /* 1406b4ce94deSChris Mason * returns -EAGAIN if it had to drop the path, or zero if everything was in 1407b4ce94deSChris Mason * cache 1408b4ce94deSChris Mason */ 1409b4ce94deSChris Mason static noinline int reada_for_balance(struct btrfs_root *root, 1410b4ce94deSChris Mason struct btrfs_path *path, int level) 1411b4ce94deSChris Mason { 1412b4ce94deSChris Mason int slot; 1413b4ce94deSChris Mason int nritems; 1414b4ce94deSChris Mason struct extent_buffer *parent; 1415b4ce94deSChris Mason struct extent_buffer *eb; 1416b4ce94deSChris Mason u64 gen; 1417b4ce94deSChris Mason u64 block1 = 0; 1418b4ce94deSChris Mason u64 block2 = 0; 1419b4ce94deSChris Mason int ret = 0; 1420b4ce94deSChris Mason int blocksize; 1421b4ce94deSChris Mason 14228c594ea8SChris Mason parent = path->nodes[level + 1]; 1423b4ce94deSChris Mason if (!parent) 1424b4ce94deSChris Mason return 0; 1425b4ce94deSChris Mason 1426b4ce94deSChris Mason nritems = btrfs_header_nritems(parent); 14278c594ea8SChris Mason slot = path->slots[level + 1]; 1428b4ce94deSChris Mason blocksize = btrfs_level_size(root, level); 1429b4ce94deSChris Mason 1430b4ce94deSChris Mason if (slot > 0) { 1431b4ce94deSChris Mason block1 = btrfs_node_blockptr(parent, slot - 1); 1432b4ce94deSChris Mason gen = btrfs_node_ptr_generation(parent, slot - 1); 1433b4ce94deSChris Mason eb = btrfs_find_tree_block(root, block1, blocksize); 1434b4ce94deSChris Mason if (eb && btrfs_buffer_uptodate(eb, gen)) 1435b4ce94deSChris Mason block1 = 0; 1436b4ce94deSChris Mason free_extent_buffer(eb); 1437b4ce94deSChris Mason } 14388c594ea8SChris Mason if (slot + 1 < nritems) { 1439b4ce94deSChris Mason block2 = btrfs_node_blockptr(parent, slot + 1); 1440b4ce94deSChris Mason gen = btrfs_node_ptr_generation(parent, slot + 1); 1441b4ce94deSChris Mason eb = btrfs_find_tree_block(root, block2, blocksize); 1442b4ce94deSChris Mason if (eb && btrfs_buffer_uptodate(eb, gen)) 1443b4ce94deSChris Mason block2 = 0; 1444b4ce94deSChris Mason free_extent_buffer(eb); 1445b4ce94deSChris Mason } 1446b4ce94deSChris Mason if (block1 || block2) { 1447b4ce94deSChris Mason ret = -EAGAIN; 14488c594ea8SChris Mason 14498c594ea8SChris Mason /* release the whole path */ 1450b4ce94deSChris Mason btrfs_release_path(root, path); 14518c594ea8SChris Mason 14528c594ea8SChris Mason /* read the blocks */ 1453b4ce94deSChris Mason if (block1) 1454b4ce94deSChris Mason readahead_tree_block(root, block1, blocksize, 0); 1455b4ce94deSChris Mason if (block2) 1456b4ce94deSChris Mason readahead_tree_block(root, block2, blocksize, 0); 1457b4ce94deSChris Mason 1458b4ce94deSChris Mason if (block1) { 1459b4ce94deSChris Mason eb = read_tree_block(root, block1, blocksize, 0); 1460b4ce94deSChris Mason free_extent_buffer(eb); 1461b4ce94deSChris Mason } 14628c594ea8SChris Mason if (block2) { 1463b4ce94deSChris Mason eb = read_tree_block(root, block2, blocksize, 0); 1464b4ce94deSChris Mason free_extent_buffer(eb); 1465b4ce94deSChris Mason } 1466b4ce94deSChris Mason } 1467b4ce94deSChris Mason return ret; 1468b4ce94deSChris Mason } 1469b4ce94deSChris Mason 1470b4ce94deSChris Mason 1471b4ce94deSChris Mason /* 1472d397712bSChris Mason * when we walk down the tree, it is usually safe to unlock the higher layers 1473d397712bSChris Mason * in the tree. The exceptions are when our path goes through slot 0, because 1474d397712bSChris Mason * operations on the tree might require changing key pointers higher up in the 1475d397712bSChris Mason * tree. 1476d352ac68SChris Mason * 1477d397712bSChris Mason * callers might also have set path->keep_locks, which tells this code to keep 1478d397712bSChris Mason * the lock if the path points to the last slot in the block. This is part of 1479d397712bSChris Mason * walking through the tree, and selecting the next slot in the higher block. 1480d352ac68SChris Mason * 1481d397712bSChris Mason * lowest_unlock sets the lowest level in the tree we're allowed to unlock. so 1482d397712bSChris Mason * if lowest_unlock is 1, level 0 won't be unlocked 1483d352ac68SChris Mason */ 1484e02119d5SChris Mason static noinline void unlock_up(struct btrfs_path *path, int level, 1485e02119d5SChris Mason int lowest_unlock) 1486925baeddSChris Mason { 1487925baeddSChris Mason int i; 1488925baeddSChris Mason int skip_level = level; 1489051e1b9fSChris Mason int no_skips = 0; 1490925baeddSChris Mason struct extent_buffer *t; 1491925baeddSChris Mason 1492925baeddSChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1493925baeddSChris Mason if (!path->nodes[i]) 1494925baeddSChris Mason break; 1495925baeddSChris Mason if (!path->locks[i]) 1496925baeddSChris Mason break; 1497051e1b9fSChris Mason if (!no_skips && path->slots[i] == 0) { 1498925baeddSChris Mason skip_level = i + 1; 1499925baeddSChris Mason continue; 1500925baeddSChris Mason } 1501051e1b9fSChris Mason if (!no_skips && path->keep_locks) { 1502925baeddSChris Mason u32 nritems; 1503925baeddSChris Mason t = path->nodes[i]; 1504925baeddSChris Mason nritems = btrfs_header_nritems(t); 1505051e1b9fSChris Mason if (nritems < 1 || path->slots[i] >= nritems - 1) { 1506925baeddSChris Mason skip_level = i + 1; 1507925baeddSChris Mason continue; 1508925baeddSChris Mason } 1509925baeddSChris Mason } 1510051e1b9fSChris Mason if (skip_level < i && i >= lowest_unlock) 1511051e1b9fSChris Mason no_skips = 1; 1512051e1b9fSChris Mason 1513925baeddSChris Mason t = path->nodes[i]; 1514925baeddSChris Mason if (i >= lowest_unlock && i > skip_level && path->locks[i]) { 1515925baeddSChris Mason btrfs_tree_unlock(t); 1516925baeddSChris Mason path->locks[i] = 0; 1517925baeddSChris Mason } 1518925baeddSChris Mason } 1519925baeddSChris Mason } 1520925baeddSChris Mason 15213c69faecSChris Mason /* 1522b4ce94deSChris Mason * This releases any locks held in the path starting at level and 1523b4ce94deSChris Mason * going all the way up to the root. 1524b4ce94deSChris Mason * 1525b4ce94deSChris Mason * btrfs_search_slot will keep the lock held on higher nodes in a few 1526b4ce94deSChris Mason * corner cases, such as COW of the block at slot zero in the node. This 1527b4ce94deSChris Mason * ignores those rules, and it should only be called when there are no 1528b4ce94deSChris Mason * more updates to be done higher up in the tree. 1529b4ce94deSChris Mason */ 1530b4ce94deSChris Mason noinline void btrfs_unlock_up_safe(struct btrfs_path *path, int level) 1531b4ce94deSChris Mason { 1532b4ce94deSChris Mason int i; 1533b4ce94deSChris Mason 15345d4f98a2SYan Zheng if (path->keep_locks) 1535b4ce94deSChris Mason return; 1536b4ce94deSChris Mason 1537b4ce94deSChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1538b4ce94deSChris Mason if (!path->nodes[i]) 153912f4daccSChris Mason continue; 1540b4ce94deSChris Mason if (!path->locks[i]) 154112f4daccSChris Mason continue; 1542b4ce94deSChris Mason btrfs_tree_unlock(path->nodes[i]); 1543b4ce94deSChris Mason path->locks[i] = 0; 1544b4ce94deSChris Mason } 1545b4ce94deSChris Mason } 1546b4ce94deSChris Mason 1547b4ce94deSChris Mason /* 1548c8c42864SChris Mason * helper function for btrfs_search_slot. The goal is to find a block 1549c8c42864SChris Mason * in cache without setting the path to blocking. If we find the block 1550c8c42864SChris Mason * we return zero and the path is unchanged. 1551c8c42864SChris Mason * 1552c8c42864SChris Mason * If we can't find the block, we set the path blocking and do some 1553c8c42864SChris Mason * reada. -EAGAIN is returned and the search must be repeated. 1554c8c42864SChris Mason */ 1555c8c42864SChris Mason static int 1556c8c42864SChris Mason read_block_for_search(struct btrfs_trans_handle *trans, 1557c8c42864SChris Mason struct btrfs_root *root, struct btrfs_path *p, 1558c8c42864SChris Mason struct extent_buffer **eb_ret, int level, int slot, 1559c8c42864SChris Mason struct btrfs_key *key) 1560c8c42864SChris Mason { 1561c8c42864SChris Mason u64 blocknr; 1562c8c42864SChris Mason u64 gen; 1563c8c42864SChris Mason u32 blocksize; 1564c8c42864SChris Mason struct extent_buffer *b = *eb_ret; 1565c8c42864SChris Mason struct extent_buffer *tmp; 156676a05b35SChris Mason int ret; 1567c8c42864SChris Mason 1568c8c42864SChris Mason blocknr = btrfs_node_blockptr(b, slot); 1569c8c42864SChris Mason gen = btrfs_node_ptr_generation(b, slot); 1570c8c42864SChris Mason blocksize = btrfs_level_size(root, level - 1); 1571c8c42864SChris Mason 1572c8c42864SChris Mason tmp = btrfs_find_tree_block(root, blocknr, blocksize); 1573cb44921aSChris Mason if (tmp) { 1574cb44921aSChris Mason if (btrfs_buffer_uptodate(tmp, 0)) { 1575cb44921aSChris Mason if (btrfs_buffer_uptodate(tmp, gen)) { 157676a05b35SChris Mason /* 1577cb44921aSChris Mason * we found an up to date block without 1578cb44921aSChris Mason * sleeping, return 157976a05b35SChris Mason * right away 158076a05b35SChris Mason */ 1581c8c42864SChris Mason *eb_ret = tmp; 1582c8c42864SChris Mason return 0; 1583c8c42864SChris Mason } 1584cb44921aSChris Mason /* the pages were up to date, but we failed 1585cb44921aSChris Mason * the generation number check. Do a full 1586cb44921aSChris Mason * read for the generation number that is correct. 1587cb44921aSChris Mason * We must do this without dropping locks so 1588cb44921aSChris Mason * we can trust our generation number 1589cb44921aSChris Mason */ 1590cb44921aSChris Mason free_extent_buffer(tmp); 1591cb44921aSChris Mason tmp = read_tree_block(root, blocknr, blocksize, gen); 1592cb44921aSChris Mason if (tmp && btrfs_buffer_uptodate(tmp, gen)) { 1593cb44921aSChris Mason *eb_ret = tmp; 1594cb44921aSChris Mason return 0; 1595cb44921aSChris Mason } 1596cb44921aSChris Mason free_extent_buffer(tmp); 1597cb44921aSChris Mason btrfs_release_path(NULL, p); 1598cb44921aSChris Mason return -EIO; 1599cb44921aSChris Mason } 1600cb44921aSChris Mason } 1601c8c42864SChris Mason 1602c8c42864SChris Mason /* 1603c8c42864SChris Mason * reduce lock contention at high levels 1604c8c42864SChris Mason * of the btree by dropping locks before 160576a05b35SChris Mason * we read. Don't release the lock on the current 160676a05b35SChris Mason * level because we need to walk this node to figure 160776a05b35SChris Mason * out which blocks to read. 1608c8c42864SChris Mason */ 16098c594ea8SChris Mason btrfs_unlock_up_safe(p, level + 1); 16108c594ea8SChris Mason btrfs_set_path_blocking(p); 16118c594ea8SChris Mason 1612c8c42864SChris Mason free_extent_buffer(tmp); 1613c8c42864SChris Mason if (p->reada) 1614c8c42864SChris Mason reada_for_search(root, p, level, slot, key->objectid); 1615c8c42864SChris Mason 16168c594ea8SChris Mason btrfs_release_path(NULL, p); 161776a05b35SChris Mason 161876a05b35SChris Mason ret = -EAGAIN; 16195bdd3536SYan, Zheng tmp = read_tree_block(root, blocknr, blocksize, 0); 162076a05b35SChris Mason if (tmp) { 162176a05b35SChris Mason /* 162276a05b35SChris Mason * If the read above didn't mark this buffer up to date, 162376a05b35SChris Mason * it will never end up being up to date. Set ret to EIO now 162476a05b35SChris Mason * and give up so that our caller doesn't loop forever 162576a05b35SChris Mason * on our EAGAINs. 162676a05b35SChris Mason */ 162776a05b35SChris Mason if (!btrfs_buffer_uptodate(tmp, 0)) 162876a05b35SChris Mason ret = -EIO; 1629c8c42864SChris Mason free_extent_buffer(tmp); 163076a05b35SChris Mason } 163176a05b35SChris Mason return ret; 1632c8c42864SChris Mason } 1633c8c42864SChris Mason 1634c8c42864SChris Mason /* 1635c8c42864SChris Mason * helper function for btrfs_search_slot. This does all of the checks 1636c8c42864SChris Mason * for node-level blocks and does any balancing required based on 1637c8c42864SChris Mason * the ins_len. 1638c8c42864SChris Mason * 1639c8c42864SChris Mason * If no extra work was required, zero is returned. If we had to 1640c8c42864SChris Mason * drop the path, -EAGAIN is returned and btrfs_search_slot must 1641c8c42864SChris Mason * start over 1642c8c42864SChris Mason */ 1643c8c42864SChris Mason static int 1644c8c42864SChris Mason setup_nodes_for_search(struct btrfs_trans_handle *trans, 1645c8c42864SChris Mason struct btrfs_root *root, struct btrfs_path *p, 1646c8c42864SChris Mason struct extent_buffer *b, int level, int ins_len) 1647c8c42864SChris Mason { 1648c8c42864SChris Mason int ret; 1649c8c42864SChris Mason if ((p->search_for_split || ins_len > 0) && btrfs_header_nritems(b) >= 1650c8c42864SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) - 3) { 1651c8c42864SChris Mason int sret; 1652c8c42864SChris Mason 1653c8c42864SChris Mason sret = reada_for_balance(root, p, level); 1654c8c42864SChris Mason if (sret) 1655c8c42864SChris Mason goto again; 1656c8c42864SChris Mason 1657c8c42864SChris Mason btrfs_set_path_blocking(p); 1658c8c42864SChris Mason sret = split_node(trans, root, p, level); 1659c8c42864SChris Mason btrfs_clear_path_blocking(p, NULL); 1660c8c42864SChris Mason 1661c8c42864SChris Mason BUG_ON(sret > 0); 1662c8c42864SChris Mason if (sret) { 1663c8c42864SChris Mason ret = sret; 1664c8c42864SChris Mason goto done; 1665c8c42864SChris Mason } 1666c8c42864SChris Mason b = p->nodes[level]; 1667c8c42864SChris Mason } else if (ins_len < 0 && btrfs_header_nritems(b) < 1668cfbb9308SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) / 2) { 1669c8c42864SChris Mason int sret; 1670c8c42864SChris Mason 1671c8c42864SChris Mason sret = reada_for_balance(root, p, level); 1672c8c42864SChris Mason if (sret) 1673c8c42864SChris Mason goto again; 1674c8c42864SChris Mason 1675c8c42864SChris Mason btrfs_set_path_blocking(p); 1676c8c42864SChris Mason sret = balance_level(trans, root, p, level); 1677c8c42864SChris Mason btrfs_clear_path_blocking(p, NULL); 1678c8c42864SChris Mason 1679c8c42864SChris Mason if (sret) { 1680c8c42864SChris Mason ret = sret; 1681c8c42864SChris Mason goto done; 1682c8c42864SChris Mason } 1683c8c42864SChris Mason b = p->nodes[level]; 1684c8c42864SChris Mason if (!b) { 1685c8c42864SChris Mason btrfs_release_path(NULL, p); 1686c8c42864SChris Mason goto again; 1687c8c42864SChris Mason } 1688c8c42864SChris Mason BUG_ON(btrfs_header_nritems(b) == 1); 1689c8c42864SChris Mason } 1690c8c42864SChris Mason return 0; 1691c8c42864SChris Mason 1692c8c42864SChris Mason again: 1693c8c42864SChris Mason ret = -EAGAIN; 1694c8c42864SChris Mason done: 1695c8c42864SChris Mason return ret; 1696c8c42864SChris Mason } 1697c8c42864SChris Mason 1698c8c42864SChris Mason /* 169974123bd7SChris Mason * look for key in the tree. path is filled in with nodes along the way 170074123bd7SChris Mason * if key is found, we return zero and you can find the item in the leaf 170174123bd7SChris Mason * level of the path (level 0) 170274123bd7SChris Mason * 170374123bd7SChris Mason * If the key isn't found, the path points to the slot where it should 1704aa5d6bedSChris Mason * be inserted, and 1 is returned. If there are other errors during the 1705aa5d6bedSChris Mason * search a negative error number is returned. 170697571fd0SChris Mason * 170797571fd0SChris Mason * if ins_len > 0, nodes and leaves will be split as we walk down the 170897571fd0SChris Mason * tree. if ins_len < 0, nodes will be merged as we walk down the tree (if 170997571fd0SChris Mason * possible) 171074123bd7SChris Mason */ 1711e089f05cSChris Mason int btrfs_search_slot(struct btrfs_trans_handle *trans, struct btrfs_root 1712e089f05cSChris Mason *root, struct btrfs_key *key, struct btrfs_path *p, int 1713e089f05cSChris Mason ins_len, int cow) 1714be0e5c09SChris Mason { 17155f39d397SChris Mason struct extent_buffer *b; 1716be0e5c09SChris Mason int slot; 1717be0e5c09SChris Mason int ret; 171833c66f43SYan Zheng int err; 1719be0e5c09SChris Mason int level; 1720925baeddSChris Mason int lowest_unlock = 1; 17219f3a7427SChris Mason u8 lowest_level = 0; 17229f3a7427SChris Mason 17236702ed49SChris Mason lowest_level = p->lowest_level; 1724323ac95bSChris Mason WARN_ON(lowest_level && ins_len > 0); 172522b0ebdaSChris Mason WARN_ON(p->nodes[0] != NULL); 172625179201SJosef Bacik 1727925baeddSChris Mason if (ins_len < 0) 1728925baeddSChris Mason lowest_unlock = 2; 172965b51a00SChris Mason 1730bb803951SChris Mason again: 17315d4f98a2SYan Zheng if (p->search_commit_root) { 17325d4f98a2SYan Zheng b = root->commit_root; 17335d4f98a2SYan Zheng extent_buffer_get(b); 17345d4f98a2SYan Zheng if (!p->skip_locking) 17355d4f98a2SYan Zheng btrfs_tree_lock(b); 17365d4f98a2SYan Zheng } else { 17375cd57b2cSChris Mason if (p->skip_locking) 17385cd57b2cSChris Mason b = btrfs_root_node(root); 17395cd57b2cSChris Mason else 1740925baeddSChris Mason b = btrfs_lock_root_node(root); 17415d4f98a2SYan Zheng } 1742925baeddSChris Mason 1743eb60ceacSChris Mason while (b) { 17445f39d397SChris Mason level = btrfs_header_level(b); 174565b51a00SChris Mason 174665b51a00SChris Mason /* 174765b51a00SChris Mason * setup the path here so we can release it under lock 174865b51a00SChris Mason * contention with the cow code 174965b51a00SChris Mason */ 175065b51a00SChris Mason p->nodes[level] = b; 175165b51a00SChris Mason if (!p->skip_locking) 175265b51a00SChris Mason p->locks[level] = 1; 175365b51a00SChris Mason 175402217ed2SChris Mason if (cow) { 1755c8c42864SChris Mason /* 1756c8c42864SChris Mason * if we don't really need to cow this block 1757c8c42864SChris Mason * then we don't want to set the path blocking, 1758c8c42864SChris Mason * so we test it here 1759c8c42864SChris Mason */ 17605d4f98a2SYan Zheng if (!should_cow_block(trans, root, b)) 176165b51a00SChris Mason goto cow_done; 17625d4f98a2SYan Zheng 1763b4ce94deSChris Mason btrfs_set_path_blocking(p); 1764b4ce94deSChris Mason 176533c66f43SYan Zheng err = btrfs_cow_block(trans, root, b, 1766e20d96d6SChris Mason p->nodes[level + 1], 17679fa8cfe7SChris Mason p->slots[level + 1], &b); 176833c66f43SYan Zheng if (err) { 176933c66f43SYan Zheng ret = err; 177065b51a00SChris Mason goto done; 177154aa1f4dSChris Mason } 177202217ed2SChris Mason } 177365b51a00SChris Mason cow_done: 177402217ed2SChris Mason BUG_ON(!cow && ins_len); 17755f39d397SChris Mason if (level != btrfs_header_level(b)) 17762c90e5d6SChris Mason WARN_ON(1); 17775f39d397SChris Mason level = btrfs_header_level(b); 177865b51a00SChris Mason 1779eb60ceacSChris Mason p->nodes[level] = b; 17805cd57b2cSChris Mason if (!p->skip_locking) 1781925baeddSChris Mason p->locks[level] = 1; 178265b51a00SChris Mason 17834008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 1784b4ce94deSChris Mason 1785b4ce94deSChris Mason /* 1786b4ce94deSChris Mason * we have a lock on b and as long as we aren't changing 1787b4ce94deSChris Mason * the tree, there is no way to for the items in b to change. 1788b4ce94deSChris Mason * It is safe to drop the lock on our parent before we 1789b4ce94deSChris Mason * go through the expensive btree search on b. 1790b4ce94deSChris Mason * 1791b4ce94deSChris Mason * If cow is true, then we might be changing slot zero, 1792b4ce94deSChris Mason * which may require changing the parent. So, we can't 1793b4ce94deSChris Mason * drop the lock until after we know which slot we're 1794b4ce94deSChris Mason * operating on. 1795b4ce94deSChris Mason */ 1796b4ce94deSChris Mason if (!cow) 1797b4ce94deSChris Mason btrfs_unlock_up_safe(p, level + 1); 1798b4ce94deSChris Mason 1799123abc88SChris Mason ret = check_block(root, p, level); 180065b51a00SChris Mason if (ret) { 180165b51a00SChris Mason ret = -1; 180265b51a00SChris Mason goto done; 180365b51a00SChris Mason } 1804925baeddSChris Mason 18055f39d397SChris Mason ret = bin_search(b, key, level, &slot); 1806b4ce94deSChris Mason 18075f39d397SChris Mason if (level != 0) { 180833c66f43SYan Zheng int dec = 0; 180933c66f43SYan Zheng if (ret && slot > 0) { 181033c66f43SYan Zheng dec = 1; 1811be0e5c09SChris Mason slot -= 1; 181233c66f43SYan Zheng } 1813be0e5c09SChris Mason p->slots[level] = slot; 181433c66f43SYan Zheng err = setup_nodes_for_search(trans, root, p, b, level, 1815c8c42864SChris Mason ins_len); 181633c66f43SYan Zheng if (err == -EAGAIN) 1817b4ce94deSChris Mason goto again; 181833c66f43SYan Zheng if (err) { 181933c66f43SYan Zheng ret = err; 182065b51a00SChris Mason goto done; 182133c66f43SYan Zheng } 18225c680ed6SChris Mason b = p->nodes[level]; 18235c680ed6SChris Mason slot = p->slots[level]; 1824b4ce94deSChris Mason 1825f9efa9c7SChris Mason unlock_up(p, level, lowest_unlock); 1826f9efa9c7SChris Mason 1827925baeddSChris Mason if (level == lowest_level) { 182833c66f43SYan Zheng if (dec) 182933c66f43SYan Zheng p->slots[level]++; 18305b21f2edSZheng Yan goto done; 1831925baeddSChris Mason } 1832ca7a79adSChris Mason 183333c66f43SYan Zheng err = read_block_for_search(trans, root, p, 1834c8c42864SChris Mason &b, level, slot, key); 183533c66f43SYan Zheng if (err == -EAGAIN) 1836051e1b9fSChris Mason goto again; 183733c66f43SYan Zheng if (err) { 183833c66f43SYan Zheng ret = err; 183976a05b35SChris Mason goto done; 184033c66f43SYan Zheng } 184176a05b35SChris Mason 1842b4ce94deSChris Mason if (!p->skip_locking) { 18434008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 184433c66f43SYan Zheng err = btrfs_try_spin_lock(b); 1845b4ce94deSChris Mason 184633c66f43SYan Zheng if (!err) { 1847b4ce94deSChris Mason btrfs_set_path_blocking(p); 1848925baeddSChris Mason btrfs_tree_lock(b); 18494008c04aSChris Mason btrfs_clear_path_blocking(p, b); 1850b4ce94deSChris Mason } 1851b4ce94deSChris Mason } 1852be0e5c09SChris Mason } else { 1853be0e5c09SChris Mason p->slots[level] = slot; 185487b29b20SYan Zheng if (ins_len > 0 && 185587b29b20SYan Zheng btrfs_leaf_free_space(root, b) < ins_len) { 1856b4ce94deSChris Mason btrfs_set_path_blocking(p); 185733c66f43SYan Zheng err = split_leaf(trans, root, key, 1858cc0c5538SChris Mason p, ins_len, ret == 0); 18594008c04aSChris Mason btrfs_clear_path_blocking(p, NULL); 1860b4ce94deSChris Mason 186133c66f43SYan Zheng BUG_ON(err > 0); 186233c66f43SYan Zheng if (err) { 186333c66f43SYan Zheng ret = err; 186465b51a00SChris Mason goto done; 186565b51a00SChris Mason } 18665c680ed6SChris Mason } 1867459931ecSChris Mason if (!p->search_for_split) 1868925baeddSChris Mason unlock_up(p, level, lowest_unlock); 186965b51a00SChris Mason goto done; 187065b51a00SChris Mason } 187165b51a00SChris Mason } 187265b51a00SChris Mason ret = 1; 187365b51a00SChris Mason done: 1874b4ce94deSChris Mason /* 1875b4ce94deSChris Mason * we don't really know what they plan on doing with the path 1876b4ce94deSChris Mason * from here on, so for now just mark it as blocking 1877b4ce94deSChris Mason */ 1878b9473439SChris Mason if (!p->leave_spinning) 1879b4ce94deSChris Mason btrfs_set_path_blocking(p); 188076a05b35SChris Mason if (ret < 0) 188176a05b35SChris Mason btrfs_release_path(root, p); 1882be0e5c09SChris Mason return ret; 1883be0e5c09SChris Mason } 1884be0e5c09SChris Mason 188574123bd7SChris Mason /* 188674123bd7SChris Mason * adjust the pointers going up the tree, starting at level 188774123bd7SChris Mason * making sure the right key of each node is points to 'key'. 188874123bd7SChris Mason * This is used after shifting pointers to the left, so it stops 188974123bd7SChris Mason * fixing up pointers when a given leaf/node is not in slot 0 of the 189074123bd7SChris Mason * higher levels 1891aa5d6bedSChris Mason * 1892aa5d6bedSChris Mason * If this fails to write a tree block, it returns -1, but continues 1893aa5d6bedSChris Mason * fixing up the blocks in ram so the tree is consistent. 189474123bd7SChris Mason */ 18955f39d397SChris Mason static int fixup_low_keys(struct btrfs_trans_handle *trans, 18965f39d397SChris Mason struct btrfs_root *root, struct btrfs_path *path, 18975f39d397SChris Mason struct btrfs_disk_key *key, int level) 1898be0e5c09SChris Mason { 1899be0e5c09SChris Mason int i; 1900aa5d6bedSChris Mason int ret = 0; 19015f39d397SChris Mason struct extent_buffer *t; 19025f39d397SChris Mason 1903234b63a0SChris Mason for (i = level; i < BTRFS_MAX_LEVEL; i++) { 1904be0e5c09SChris Mason int tslot = path->slots[i]; 1905eb60ceacSChris Mason if (!path->nodes[i]) 1906be0e5c09SChris Mason break; 19075f39d397SChris Mason t = path->nodes[i]; 19085f39d397SChris Mason btrfs_set_node_key(t, key, tslot); 1909d6025579SChris Mason btrfs_mark_buffer_dirty(path->nodes[i]); 1910be0e5c09SChris Mason if (tslot != 0) 1911be0e5c09SChris Mason break; 1912be0e5c09SChris Mason } 1913aa5d6bedSChris Mason return ret; 1914be0e5c09SChris Mason } 1915be0e5c09SChris Mason 191674123bd7SChris Mason /* 191731840ae1SZheng Yan * update item key. 191831840ae1SZheng Yan * 191931840ae1SZheng Yan * This function isn't completely safe. It's the caller's responsibility 192031840ae1SZheng Yan * that the new key won't break the order 192131840ae1SZheng Yan */ 192231840ae1SZheng Yan int btrfs_set_item_key_safe(struct btrfs_trans_handle *trans, 192331840ae1SZheng Yan struct btrfs_root *root, struct btrfs_path *path, 192431840ae1SZheng Yan struct btrfs_key *new_key) 192531840ae1SZheng Yan { 192631840ae1SZheng Yan struct btrfs_disk_key disk_key; 192731840ae1SZheng Yan struct extent_buffer *eb; 192831840ae1SZheng Yan int slot; 192931840ae1SZheng Yan 193031840ae1SZheng Yan eb = path->nodes[0]; 193131840ae1SZheng Yan slot = path->slots[0]; 193231840ae1SZheng Yan if (slot > 0) { 193331840ae1SZheng Yan btrfs_item_key(eb, &disk_key, slot - 1); 193431840ae1SZheng Yan if (comp_keys(&disk_key, new_key) >= 0) 193531840ae1SZheng Yan return -1; 193631840ae1SZheng Yan } 193731840ae1SZheng Yan if (slot < btrfs_header_nritems(eb) - 1) { 193831840ae1SZheng Yan btrfs_item_key(eb, &disk_key, slot + 1); 193931840ae1SZheng Yan if (comp_keys(&disk_key, new_key) <= 0) 194031840ae1SZheng Yan return -1; 194131840ae1SZheng Yan } 194231840ae1SZheng Yan 194331840ae1SZheng Yan btrfs_cpu_key_to_disk(&disk_key, new_key); 194431840ae1SZheng Yan btrfs_set_item_key(eb, &disk_key, slot); 194531840ae1SZheng Yan btrfs_mark_buffer_dirty(eb); 194631840ae1SZheng Yan if (slot == 0) 194731840ae1SZheng Yan fixup_low_keys(trans, root, path, &disk_key, 1); 194831840ae1SZheng Yan return 0; 194931840ae1SZheng Yan } 195031840ae1SZheng Yan 195131840ae1SZheng Yan /* 195274123bd7SChris Mason * try to push data from one node into the next node left in the 195379f95c82SChris Mason * tree. 1954aa5d6bedSChris Mason * 1955aa5d6bedSChris Mason * returns 0 if some ptrs were pushed left, < 0 if there was some horrible 1956aa5d6bedSChris Mason * error, and > 0 if there was no room in the left hand block. 195774123bd7SChris Mason */ 195898ed5174SChris Mason static int push_node_left(struct btrfs_trans_handle *trans, 195998ed5174SChris Mason struct btrfs_root *root, struct extent_buffer *dst, 1960971a1f66SChris Mason struct extent_buffer *src, int empty) 1961be0e5c09SChris Mason { 1962be0e5c09SChris Mason int push_items = 0; 1963bb803951SChris Mason int src_nritems; 1964bb803951SChris Mason int dst_nritems; 1965aa5d6bedSChris Mason int ret = 0; 1966be0e5c09SChris Mason 19675f39d397SChris Mason src_nritems = btrfs_header_nritems(src); 19685f39d397SChris Mason dst_nritems = btrfs_header_nritems(dst); 1969123abc88SChris Mason push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems; 19707bb86316SChris Mason WARN_ON(btrfs_header_generation(src) != trans->transid); 19717bb86316SChris Mason WARN_ON(btrfs_header_generation(dst) != trans->transid); 197254aa1f4dSChris Mason 1973bce4eae9SChris Mason if (!empty && src_nritems <= 8) 1974971a1f66SChris Mason return 1; 1975971a1f66SChris Mason 1976d397712bSChris Mason if (push_items <= 0) 1977be0e5c09SChris Mason return 1; 1978be0e5c09SChris Mason 1979bce4eae9SChris Mason if (empty) { 1980971a1f66SChris Mason push_items = min(src_nritems, push_items); 1981bce4eae9SChris Mason if (push_items < src_nritems) { 1982bce4eae9SChris Mason /* leave at least 8 pointers in the node if 1983bce4eae9SChris Mason * we aren't going to empty it 1984bce4eae9SChris Mason */ 1985bce4eae9SChris Mason if (src_nritems - push_items < 8) { 1986bce4eae9SChris Mason if (push_items <= 8) 1987bce4eae9SChris Mason return 1; 1988bce4eae9SChris Mason push_items -= 8; 1989bce4eae9SChris Mason } 1990bce4eae9SChris Mason } 1991bce4eae9SChris Mason } else 1992bce4eae9SChris Mason push_items = min(src_nritems - 8, push_items); 199379f95c82SChris Mason 19945f39d397SChris Mason copy_extent_buffer(dst, src, 19955f39d397SChris Mason btrfs_node_key_ptr_offset(dst_nritems), 19965f39d397SChris Mason btrfs_node_key_ptr_offset(0), 1997123abc88SChris Mason push_items * sizeof(struct btrfs_key_ptr)); 19985f39d397SChris Mason 1999bb803951SChris Mason if (push_items < src_nritems) { 20005f39d397SChris Mason memmove_extent_buffer(src, btrfs_node_key_ptr_offset(0), 20015f39d397SChris Mason btrfs_node_key_ptr_offset(push_items), 2002e2fa7227SChris Mason (src_nritems - push_items) * 2003123abc88SChris Mason sizeof(struct btrfs_key_ptr)); 2004bb803951SChris Mason } 20055f39d397SChris Mason btrfs_set_header_nritems(src, src_nritems - push_items); 20065f39d397SChris Mason btrfs_set_header_nritems(dst, dst_nritems + push_items); 20075f39d397SChris Mason btrfs_mark_buffer_dirty(src); 20085f39d397SChris Mason btrfs_mark_buffer_dirty(dst); 200931840ae1SZheng Yan 2010bb803951SChris Mason return ret; 2011be0e5c09SChris Mason } 2012be0e5c09SChris Mason 201397571fd0SChris Mason /* 201479f95c82SChris Mason * try to push data from one node into the next node right in the 201579f95c82SChris Mason * tree. 201679f95c82SChris Mason * 201779f95c82SChris Mason * returns 0 if some ptrs were pushed, < 0 if there was some horrible 201879f95c82SChris Mason * error, and > 0 if there was no room in the right hand block. 201979f95c82SChris Mason * 202079f95c82SChris Mason * this will only push up to 1/2 the contents of the left node over 202179f95c82SChris Mason */ 20225f39d397SChris Mason static int balance_node_right(struct btrfs_trans_handle *trans, 20235f39d397SChris Mason struct btrfs_root *root, 20245f39d397SChris Mason struct extent_buffer *dst, 20255f39d397SChris Mason struct extent_buffer *src) 202679f95c82SChris Mason { 202779f95c82SChris Mason int push_items = 0; 202879f95c82SChris Mason int max_push; 202979f95c82SChris Mason int src_nritems; 203079f95c82SChris Mason int dst_nritems; 203179f95c82SChris Mason int ret = 0; 203279f95c82SChris Mason 20337bb86316SChris Mason WARN_ON(btrfs_header_generation(src) != trans->transid); 20347bb86316SChris Mason WARN_ON(btrfs_header_generation(dst) != trans->transid); 20357bb86316SChris Mason 20365f39d397SChris Mason src_nritems = btrfs_header_nritems(src); 20375f39d397SChris Mason dst_nritems = btrfs_header_nritems(dst); 2038123abc88SChris Mason push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems; 2039d397712bSChris Mason if (push_items <= 0) 204079f95c82SChris Mason return 1; 2041bce4eae9SChris Mason 2042d397712bSChris Mason if (src_nritems < 4) 2043bce4eae9SChris Mason return 1; 204479f95c82SChris Mason 204579f95c82SChris Mason max_push = src_nritems / 2 + 1; 204679f95c82SChris Mason /* don't try to empty the node */ 2047d397712bSChris Mason if (max_push >= src_nritems) 204879f95c82SChris Mason return 1; 2049252c38f0SYan 205079f95c82SChris Mason if (max_push < push_items) 205179f95c82SChris Mason push_items = max_push; 205279f95c82SChris Mason 20535f39d397SChris Mason memmove_extent_buffer(dst, btrfs_node_key_ptr_offset(push_items), 20545f39d397SChris Mason btrfs_node_key_ptr_offset(0), 20555f39d397SChris Mason (dst_nritems) * 20565f39d397SChris Mason sizeof(struct btrfs_key_ptr)); 2057d6025579SChris Mason 20585f39d397SChris Mason copy_extent_buffer(dst, src, 20595f39d397SChris Mason btrfs_node_key_ptr_offset(0), 20605f39d397SChris Mason btrfs_node_key_ptr_offset(src_nritems - push_items), 2061123abc88SChris Mason push_items * sizeof(struct btrfs_key_ptr)); 206279f95c82SChris Mason 20635f39d397SChris Mason btrfs_set_header_nritems(src, src_nritems - push_items); 20645f39d397SChris Mason btrfs_set_header_nritems(dst, dst_nritems + push_items); 206579f95c82SChris Mason 20665f39d397SChris Mason btrfs_mark_buffer_dirty(src); 20675f39d397SChris Mason btrfs_mark_buffer_dirty(dst); 206831840ae1SZheng Yan 206979f95c82SChris Mason return ret; 207079f95c82SChris Mason } 207179f95c82SChris Mason 207279f95c82SChris Mason /* 207397571fd0SChris Mason * helper function to insert a new root level in the tree. 207497571fd0SChris Mason * A new node is allocated, and a single item is inserted to 207597571fd0SChris Mason * point to the existing root 2076aa5d6bedSChris Mason * 2077aa5d6bedSChris Mason * returns zero on success or < 0 on failure. 207897571fd0SChris Mason */ 2079d397712bSChris Mason static noinline int insert_new_root(struct btrfs_trans_handle *trans, 20805f39d397SChris Mason struct btrfs_root *root, 20815f39d397SChris Mason struct btrfs_path *path, int level) 208274123bd7SChris Mason { 20837bb86316SChris Mason u64 lower_gen; 20845f39d397SChris Mason struct extent_buffer *lower; 20855f39d397SChris Mason struct extent_buffer *c; 2086925baeddSChris Mason struct extent_buffer *old; 20875f39d397SChris Mason struct btrfs_disk_key lower_key; 20885c680ed6SChris Mason 20895c680ed6SChris Mason BUG_ON(path->nodes[level]); 20905c680ed6SChris Mason BUG_ON(path->nodes[level-1] != root->node); 20915c680ed6SChris Mason 20927bb86316SChris Mason lower = path->nodes[level-1]; 20937bb86316SChris Mason if (level == 1) 20947bb86316SChris Mason btrfs_item_key(lower, &lower_key, 0); 20957bb86316SChris Mason else 20967bb86316SChris Mason btrfs_node_key(lower, &lower_key, 0); 20977bb86316SChris Mason 209831840ae1SZheng Yan c = btrfs_alloc_free_block(trans, root, root->nodesize, 0, 20995d4f98a2SYan Zheng root->root_key.objectid, &lower_key, 2100ad3d81baSChristoph Hellwig level, root->node->start, 0); 21015f39d397SChris Mason if (IS_ERR(c)) 21025f39d397SChris Mason return PTR_ERR(c); 2103925baeddSChris Mason 2104f0486c68SYan, Zheng root_add_used(root, root->nodesize); 2105f0486c68SYan, Zheng 21065d4f98a2SYan Zheng memset_extent_buffer(c, 0, 0, sizeof(struct btrfs_header)); 21075f39d397SChris Mason btrfs_set_header_nritems(c, 1); 21085f39d397SChris Mason btrfs_set_header_level(c, level); 2109db94535dSChris Mason btrfs_set_header_bytenr(c, c->start); 21105f39d397SChris Mason btrfs_set_header_generation(c, trans->transid); 21115d4f98a2SYan Zheng btrfs_set_header_backref_rev(c, BTRFS_MIXED_BACKREF_REV); 21125f39d397SChris Mason btrfs_set_header_owner(c, root->root_key.objectid); 2113d5719762SChris Mason 21145f39d397SChris Mason write_extent_buffer(c, root->fs_info->fsid, 21155f39d397SChris Mason (unsigned long)btrfs_header_fsid(c), 21165f39d397SChris Mason BTRFS_FSID_SIZE); 2117e17cade2SChris Mason 2118e17cade2SChris Mason write_extent_buffer(c, root->fs_info->chunk_tree_uuid, 2119e17cade2SChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(c), 2120e17cade2SChris Mason BTRFS_UUID_SIZE); 2121e17cade2SChris Mason 21225f39d397SChris Mason btrfs_set_node_key(c, &lower_key, 0); 2123db94535dSChris Mason btrfs_set_node_blockptr(c, 0, lower->start); 21247bb86316SChris Mason lower_gen = btrfs_header_generation(lower); 212531840ae1SZheng Yan WARN_ON(lower_gen != trans->transid); 21267bb86316SChris Mason 21277bb86316SChris Mason btrfs_set_node_ptr_generation(c, 0, lower_gen); 21285f39d397SChris Mason 21295f39d397SChris Mason btrfs_mark_buffer_dirty(c); 2130d5719762SChris Mason 2131925baeddSChris Mason spin_lock(&root->node_lock); 2132925baeddSChris Mason old = root->node; 21335f39d397SChris Mason root->node = c; 2134925baeddSChris Mason spin_unlock(&root->node_lock); 2135925baeddSChris Mason 2136925baeddSChris Mason /* the super has an extra ref to root->node */ 2137925baeddSChris Mason free_extent_buffer(old); 2138925baeddSChris Mason 21390b86a832SChris Mason add_root_to_dirty_list(root); 21405f39d397SChris Mason extent_buffer_get(c); 21415f39d397SChris Mason path->nodes[level] = c; 2142925baeddSChris Mason path->locks[level] = 1; 214374123bd7SChris Mason path->slots[level] = 0; 214474123bd7SChris Mason return 0; 214574123bd7SChris Mason } 21465c680ed6SChris Mason 21475c680ed6SChris Mason /* 21485c680ed6SChris Mason * worker function to insert a single pointer in a node. 21495c680ed6SChris Mason * the node should have enough room for the pointer already 215097571fd0SChris Mason * 21515c680ed6SChris Mason * slot and level indicate where you want the key to go, and 21525c680ed6SChris Mason * blocknr is the block the key points to. 2153aa5d6bedSChris Mason * 2154aa5d6bedSChris Mason * returns zero on success and < 0 on any error 21555c680ed6SChris Mason */ 2156e089f05cSChris Mason static int insert_ptr(struct btrfs_trans_handle *trans, struct btrfs_root 2157e089f05cSChris Mason *root, struct btrfs_path *path, struct btrfs_disk_key 2158db94535dSChris Mason *key, u64 bytenr, int slot, int level) 21595c680ed6SChris Mason { 21605f39d397SChris Mason struct extent_buffer *lower; 21615c680ed6SChris Mason int nritems; 21625c680ed6SChris Mason 21635c680ed6SChris Mason BUG_ON(!path->nodes[level]); 2164f0486c68SYan, Zheng btrfs_assert_tree_locked(path->nodes[level]); 21655f39d397SChris Mason lower = path->nodes[level]; 21665f39d397SChris Mason nritems = btrfs_header_nritems(lower); 2167c293498bSStoyan Gaydarov BUG_ON(slot > nritems); 2168123abc88SChris Mason if (nritems == BTRFS_NODEPTRS_PER_BLOCK(root)) 216974123bd7SChris Mason BUG(); 217074123bd7SChris Mason if (slot != nritems) { 21715f39d397SChris Mason memmove_extent_buffer(lower, 21725f39d397SChris Mason btrfs_node_key_ptr_offset(slot + 1), 21735f39d397SChris Mason btrfs_node_key_ptr_offset(slot), 2174123abc88SChris Mason (nritems - slot) * sizeof(struct btrfs_key_ptr)); 217574123bd7SChris Mason } 21765f39d397SChris Mason btrfs_set_node_key(lower, key, slot); 2177db94535dSChris Mason btrfs_set_node_blockptr(lower, slot, bytenr); 217874493f7aSChris Mason WARN_ON(trans->transid == 0); 217974493f7aSChris Mason btrfs_set_node_ptr_generation(lower, slot, trans->transid); 21805f39d397SChris Mason btrfs_set_header_nritems(lower, nritems + 1); 21815f39d397SChris Mason btrfs_mark_buffer_dirty(lower); 218274123bd7SChris Mason return 0; 218374123bd7SChris Mason } 218474123bd7SChris Mason 218597571fd0SChris Mason /* 218697571fd0SChris Mason * split the node at the specified level in path in two. 218797571fd0SChris Mason * The path is corrected to point to the appropriate node after the split 218897571fd0SChris Mason * 218997571fd0SChris Mason * Before splitting this tries to make some room in the node by pushing 219097571fd0SChris Mason * left and right, if either one works, it returns right away. 2191aa5d6bedSChris Mason * 2192aa5d6bedSChris Mason * returns 0 on success and < 0 on failure 219397571fd0SChris Mason */ 2194e02119d5SChris Mason static noinline int split_node(struct btrfs_trans_handle *trans, 2195e02119d5SChris Mason struct btrfs_root *root, 2196e02119d5SChris Mason struct btrfs_path *path, int level) 2197be0e5c09SChris Mason { 21985f39d397SChris Mason struct extent_buffer *c; 21995f39d397SChris Mason struct extent_buffer *split; 22005f39d397SChris Mason struct btrfs_disk_key disk_key; 2201be0e5c09SChris Mason int mid; 22025c680ed6SChris Mason int ret; 2203aa5d6bedSChris Mason int wret; 22047518a238SChris Mason u32 c_nritems; 2205be0e5c09SChris Mason 22065f39d397SChris Mason c = path->nodes[level]; 22077bb86316SChris Mason WARN_ON(btrfs_header_generation(c) != trans->transid); 22085f39d397SChris Mason if (c == root->node) { 22095c680ed6SChris Mason /* trying to split the root, lets make a new one */ 2210e089f05cSChris Mason ret = insert_new_root(trans, root, path, level + 1); 22115c680ed6SChris Mason if (ret) 22125c680ed6SChris Mason return ret; 2213b3612421SChris Mason } else { 2214e66f709bSChris Mason ret = push_nodes_for_insert(trans, root, path, level); 22155f39d397SChris Mason c = path->nodes[level]; 22165f39d397SChris Mason if (!ret && btrfs_header_nritems(c) < 2217c448acf0SChris Mason BTRFS_NODEPTRS_PER_BLOCK(root) - 3) 2218e66f709bSChris Mason return 0; 221954aa1f4dSChris Mason if (ret < 0) 222054aa1f4dSChris Mason return ret; 22215c680ed6SChris Mason } 2222e66f709bSChris Mason 22235f39d397SChris Mason c_nritems = btrfs_header_nritems(c); 22245d4f98a2SYan Zheng mid = (c_nritems + 1) / 2; 22255d4f98a2SYan Zheng btrfs_node_key(c, &disk_key, mid); 22267bb86316SChris Mason 22275d4f98a2SYan Zheng split = btrfs_alloc_free_block(trans, root, root->nodesize, 0, 22287bb86316SChris Mason root->root_key.objectid, 22295d4f98a2SYan Zheng &disk_key, level, c->start, 0); 22305f39d397SChris Mason if (IS_ERR(split)) 22315f39d397SChris Mason return PTR_ERR(split); 223254aa1f4dSChris Mason 2233f0486c68SYan, Zheng root_add_used(root, root->nodesize); 2234f0486c68SYan, Zheng 22355d4f98a2SYan Zheng memset_extent_buffer(split, 0, 0, sizeof(struct btrfs_header)); 22365f39d397SChris Mason btrfs_set_header_level(split, btrfs_header_level(c)); 2237db94535dSChris Mason btrfs_set_header_bytenr(split, split->start); 22385f39d397SChris Mason btrfs_set_header_generation(split, trans->transid); 22395d4f98a2SYan Zheng btrfs_set_header_backref_rev(split, BTRFS_MIXED_BACKREF_REV); 22405f39d397SChris Mason btrfs_set_header_owner(split, root->root_key.objectid); 22415f39d397SChris Mason write_extent_buffer(split, root->fs_info->fsid, 22425f39d397SChris Mason (unsigned long)btrfs_header_fsid(split), 22435f39d397SChris Mason BTRFS_FSID_SIZE); 2244e17cade2SChris Mason write_extent_buffer(split, root->fs_info->chunk_tree_uuid, 2245e17cade2SChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(split), 2246e17cade2SChris Mason BTRFS_UUID_SIZE); 22475f39d397SChris Mason 22485f39d397SChris Mason 22495f39d397SChris Mason copy_extent_buffer(split, c, 22505f39d397SChris Mason btrfs_node_key_ptr_offset(0), 22515f39d397SChris Mason btrfs_node_key_ptr_offset(mid), 2252123abc88SChris Mason (c_nritems - mid) * sizeof(struct btrfs_key_ptr)); 22535f39d397SChris Mason btrfs_set_header_nritems(split, c_nritems - mid); 22545f39d397SChris Mason btrfs_set_header_nritems(c, mid); 2255aa5d6bedSChris Mason ret = 0; 2256aa5d6bedSChris Mason 22575f39d397SChris Mason btrfs_mark_buffer_dirty(c); 22585f39d397SChris Mason btrfs_mark_buffer_dirty(split); 22595f39d397SChris Mason 2260db94535dSChris Mason wret = insert_ptr(trans, root, path, &disk_key, split->start, 22615f39d397SChris Mason path->slots[level + 1] + 1, 2262123abc88SChris Mason level + 1); 2263aa5d6bedSChris Mason if (wret) 2264aa5d6bedSChris Mason ret = wret; 2265aa5d6bedSChris Mason 22665de08d7dSChris Mason if (path->slots[level] >= mid) { 22675c680ed6SChris Mason path->slots[level] -= mid; 2268925baeddSChris Mason btrfs_tree_unlock(c); 22695f39d397SChris Mason free_extent_buffer(c); 22705f39d397SChris Mason path->nodes[level] = split; 22715c680ed6SChris Mason path->slots[level + 1] += 1; 2272eb60ceacSChris Mason } else { 2273925baeddSChris Mason btrfs_tree_unlock(split); 22745f39d397SChris Mason free_extent_buffer(split); 2275be0e5c09SChris Mason } 2276aa5d6bedSChris Mason return ret; 2277be0e5c09SChris Mason } 2278be0e5c09SChris Mason 227974123bd7SChris Mason /* 228074123bd7SChris Mason * how many bytes are required to store the items in a leaf. start 228174123bd7SChris Mason * and nr indicate which items in the leaf to check. This totals up the 228274123bd7SChris Mason * space used both by the item structs and the item data 228374123bd7SChris Mason */ 22845f39d397SChris Mason static int leaf_space_used(struct extent_buffer *l, int start, int nr) 2285be0e5c09SChris Mason { 2286be0e5c09SChris Mason int data_len; 22875f39d397SChris Mason int nritems = btrfs_header_nritems(l); 2288d4dbff95SChris Mason int end = min(nritems, start + nr) - 1; 2289be0e5c09SChris Mason 2290be0e5c09SChris Mason if (!nr) 2291be0e5c09SChris Mason return 0; 22925f39d397SChris Mason data_len = btrfs_item_end_nr(l, start); 22935f39d397SChris Mason data_len = data_len - btrfs_item_offset_nr(l, end); 22940783fcfcSChris Mason data_len += sizeof(struct btrfs_item) * nr; 2295d4dbff95SChris Mason WARN_ON(data_len < 0); 2296be0e5c09SChris Mason return data_len; 2297be0e5c09SChris Mason } 2298be0e5c09SChris Mason 229974123bd7SChris Mason /* 2300d4dbff95SChris Mason * The space between the end of the leaf items and 2301d4dbff95SChris Mason * the start of the leaf data. IOW, how much room 2302d4dbff95SChris Mason * the leaf has left for both items and data 2303d4dbff95SChris Mason */ 2304d397712bSChris Mason noinline int btrfs_leaf_free_space(struct btrfs_root *root, 2305e02119d5SChris Mason struct extent_buffer *leaf) 2306d4dbff95SChris Mason { 23075f39d397SChris Mason int nritems = btrfs_header_nritems(leaf); 23085f39d397SChris Mason int ret; 23095f39d397SChris Mason ret = BTRFS_LEAF_DATA_SIZE(root) - leaf_space_used(leaf, 0, nritems); 23105f39d397SChris Mason if (ret < 0) { 2311d397712bSChris Mason printk(KERN_CRIT "leaf free space ret %d, leaf data size %lu, " 2312d397712bSChris Mason "used %d nritems %d\n", 2313ae2f5411SJens Axboe ret, (unsigned long) BTRFS_LEAF_DATA_SIZE(root), 23145f39d397SChris Mason leaf_space_used(leaf, 0, nritems), nritems); 23155f39d397SChris Mason } 23165f39d397SChris Mason return ret; 2317d4dbff95SChris Mason } 2318d4dbff95SChris Mason 231999d8f83cSChris Mason /* 232099d8f83cSChris Mason * min slot controls the lowest index we're willing to push to the 232199d8f83cSChris Mason * right. We'll push up to and including min_slot, but no lower 232299d8f83cSChris Mason */ 232344871b1bSChris Mason static noinline int __push_leaf_right(struct btrfs_trans_handle *trans, 232444871b1bSChris Mason struct btrfs_root *root, 232544871b1bSChris Mason struct btrfs_path *path, 232644871b1bSChris Mason int data_size, int empty, 232744871b1bSChris Mason struct extent_buffer *right, 232899d8f83cSChris Mason int free_space, u32 left_nritems, 232999d8f83cSChris Mason u32 min_slot) 233000ec4c51SChris Mason { 23315f39d397SChris Mason struct extent_buffer *left = path->nodes[0]; 233244871b1bSChris Mason struct extent_buffer *upper = path->nodes[1]; 23335f39d397SChris Mason struct btrfs_disk_key disk_key; 233400ec4c51SChris Mason int slot; 233534a38218SChris Mason u32 i; 233600ec4c51SChris Mason int push_space = 0; 233700ec4c51SChris Mason int push_items = 0; 23380783fcfcSChris Mason struct btrfs_item *item; 233934a38218SChris Mason u32 nr; 23407518a238SChris Mason u32 right_nritems; 23415f39d397SChris Mason u32 data_end; 2342db94535dSChris Mason u32 this_item_size; 234300ec4c51SChris Mason 234434a38218SChris Mason if (empty) 234534a38218SChris Mason nr = 0; 234634a38218SChris Mason else 234799d8f83cSChris Mason nr = max_t(u32, 1, min_slot); 234834a38218SChris Mason 234931840ae1SZheng Yan if (path->slots[0] >= left_nritems) 235087b29b20SYan Zheng push_space += data_size; 235131840ae1SZheng Yan 235244871b1bSChris Mason slot = path->slots[1]; 235334a38218SChris Mason i = left_nritems - 1; 235434a38218SChris Mason while (i >= nr) { 23555f39d397SChris Mason item = btrfs_item_nr(left, i); 2356db94535dSChris Mason 235731840ae1SZheng Yan if (!empty && push_items > 0) { 235831840ae1SZheng Yan if (path->slots[0] > i) 235931840ae1SZheng Yan break; 236031840ae1SZheng Yan if (path->slots[0] == i) { 236131840ae1SZheng Yan int space = btrfs_leaf_free_space(root, left); 236231840ae1SZheng Yan if (space + push_space * 2 > free_space) 236331840ae1SZheng Yan break; 236431840ae1SZheng Yan } 236531840ae1SZheng Yan } 236631840ae1SZheng Yan 236700ec4c51SChris Mason if (path->slots[0] == i) 236887b29b20SYan Zheng push_space += data_size; 2369db94535dSChris Mason 2370db94535dSChris Mason if (!left->map_token) { 2371db94535dSChris Mason map_extent_buffer(left, (unsigned long)item, 2372db94535dSChris Mason sizeof(struct btrfs_item), 2373db94535dSChris Mason &left->map_token, &left->kaddr, 2374db94535dSChris Mason &left->map_start, &left->map_len, 2375db94535dSChris Mason KM_USER1); 2376db94535dSChris Mason } 2377db94535dSChris Mason 2378db94535dSChris Mason this_item_size = btrfs_item_size(left, item); 2379db94535dSChris Mason if (this_item_size + sizeof(*item) + push_space > free_space) 238000ec4c51SChris Mason break; 238131840ae1SZheng Yan 238200ec4c51SChris Mason push_items++; 2383db94535dSChris Mason push_space += this_item_size + sizeof(*item); 238434a38218SChris Mason if (i == 0) 238534a38218SChris Mason break; 238634a38218SChris Mason i--; 2387db94535dSChris Mason } 2388db94535dSChris Mason if (left->map_token) { 2389db94535dSChris Mason unmap_extent_buffer(left, left->map_token, KM_USER1); 2390db94535dSChris Mason left->map_token = NULL; 239100ec4c51SChris Mason } 23925f39d397SChris Mason 2393925baeddSChris Mason if (push_items == 0) 2394925baeddSChris Mason goto out_unlock; 23955f39d397SChris Mason 239634a38218SChris Mason if (!empty && push_items == left_nritems) 2397a429e513SChris Mason WARN_ON(1); 23985f39d397SChris Mason 239900ec4c51SChris Mason /* push left to right */ 24005f39d397SChris Mason right_nritems = btrfs_header_nritems(right); 240134a38218SChris Mason 24025f39d397SChris Mason push_space = btrfs_item_end_nr(left, left_nritems - push_items); 2403123abc88SChris Mason push_space -= leaf_data_end(root, left); 24045f39d397SChris Mason 240500ec4c51SChris Mason /* make room in the right data area */ 24065f39d397SChris Mason data_end = leaf_data_end(root, right); 24075f39d397SChris Mason memmove_extent_buffer(right, 24085f39d397SChris Mason btrfs_leaf_data(right) + data_end - push_space, 24095f39d397SChris Mason btrfs_leaf_data(right) + data_end, 24105f39d397SChris Mason BTRFS_LEAF_DATA_SIZE(root) - data_end); 24115f39d397SChris Mason 241200ec4c51SChris Mason /* copy from the left data area */ 24135f39d397SChris Mason copy_extent_buffer(right, left, btrfs_leaf_data(right) + 2414d6025579SChris Mason BTRFS_LEAF_DATA_SIZE(root) - push_space, 2415d6025579SChris Mason btrfs_leaf_data(left) + leaf_data_end(root, left), 2416d6025579SChris Mason push_space); 24175f39d397SChris Mason 24185f39d397SChris Mason memmove_extent_buffer(right, btrfs_item_nr_offset(push_items), 24195f39d397SChris Mason btrfs_item_nr_offset(0), 24200783fcfcSChris Mason right_nritems * sizeof(struct btrfs_item)); 24215f39d397SChris Mason 242200ec4c51SChris Mason /* copy the items from left to right */ 24235f39d397SChris Mason copy_extent_buffer(right, left, btrfs_item_nr_offset(0), 24245f39d397SChris Mason btrfs_item_nr_offset(left_nritems - push_items), 24250783fcfcSChris Mason push_items * sizeof(struct btrfs_item)); 242600ec4c51SChris Mason 242700ec4c51SChris Mason /* update the item pointers */ 24287518a238SChris Mason right_nritems += push_items; 24295f39d397SChris Mason btrfs_set_header_nritems(right, right_nritems); 2430123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root); 24317518a238SChris Mason for (i = 0; i < right_nritems; i++) { 24325f39d397SChris Mason item = btrfs_item_nr(right, i); 2433db94535dSChris Mason if (!right->map_token) { 2434db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2435db94535dSChris Mason sizeof(struct btrfs_item), 2436db94535dSChris Mason &right->map_token, &right->kaddr, 2437db94535dSChris Mason &right->map_start, &right->map_len, 2438db94535dSChris Mason KM_USER1); 2439db94535dSChris Mason } 2440db94535dSChris Mason push_space -= btrfs_item_size(right, item); 2441db94535dSChris Mason btrfs_set_item_offset(right, item, push_space); 2442db94535dSChris Mason } 2443db94535dSChris Mason 2444db94535dSChris Mason if (right->map_token) { 2445db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2446db94535dSChris Mason right->map_token = NULL; 244700ec4c51SChris Mason } 24487518a238SChris Mason left_nritems -= push_items; 24495f39d397SChris Mason btrfs_set_header_nritems(left, left_nritems); 245000ec4c51SChris Mason 245134a38218SChris Mason if (left_nritems) 24525f39d397SChris Mason btrfs_mark_buffer_dirty(left); 2453f0486c68SYan, Zheng else 2454f0486c68SYan, Zheng clean_tree_block(trans, root, left); 2455f0486c68SYan, Zheng 24565f39d397SChris Mason btrfs_mark_buffer_dirty(right); 2457a429e513SChris Mason 24585f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 24595f39d397SChris Mason btrfs_set_node_key(upper, &disk_key, slot + 1); 2460d6025579SChris Mason btrfs_mark_buffer_dirty(upper); 246102217ed2SChris Mason 246200ec4c51SChris Mason /* then fixup the leaf pointer in the path */ 24637518a238SChris Mason if (path->slots[0] >= left_nritems) { 24647518a238SChris Mason path->slots[0] -= left_nritems; 2465925baeddSChris Mason if (btrfs_header_nritems(path->nodes[0]) == 0) 2466925baeddSChris Mason clean_tree_block(trans, root, path->nodes[0]); 2467925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 24685f39d397SChris Mason free_extent_buffer(path->nodes[0]); 24695f39d397SChris Mason path->nodes[0] = right; 247000ec4c51SChris Mason path->slots[1] += 1; 247100ec4c51SChris Mason } else { 2472925baeddSChris Mason btrfs_tree_unlock(right); 24735f39d397SChris Mason free_extent_buffer(right); 247400ec4c51SChris Mason } 247500ec4c51SChris Mason return 0; 2476925baeddSChris Mason 2477925baeddSChris Mason out_unlock: 2478925baeddSChris Mason btrfs_tree_unlock(right); 2479925baeddSChris Mason free_extent_buffer(right); 2480925baeddSChris Mason return 1; 248100ec4c51SChris Mason } 2482925baeddSChris Mason 248300ec4c51SChris Mason /* 248444871b1bSChris Mason * push some data in the path leaf to the right, trying to free up at 248574123bd7SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 248644871b1bSChris Mason * 248744871b1bSChris Mason * returns 1 if the push failed because the other node didn't have enough 248844871b1bSChris Mason * room, 0 if everything worked out and < 0 if there were major errors. 248999d8f83cSChris Mason * 249099d8f83cSChris Mason * this will push starting from min_slot to the end of the leaf. It won't 249199d8f83cSChris Mason * push any slot lower than min_slot 249274123bd7SChris Mason */ 249344871b1bSChris Mason static int push_leaf_right(struct btrfs_trans_handle *trans, struct btrfs_root 249499d8f83cSChris Mason *root, struct btrfs_path *path, 249599d8f83cSChris Mason int min_data_size, int data_size, 249699d8f83cSChris Mason int empty, u32 min_slot) 2497be0e5c09SChris Mason { 249844871b1bSChris Mason struct extent_buffer *left = path->nodes[0]; 249944871b1bSChris Mason struct extent_buffer *right; 250044871b1bSChris Mason struct extent_buffer *upper; 250144871b1bSChris Mason int slot; 250244871b1bSChris Mason int free_space; 250344871b1bSChris Mason u32 left_nritems; 250444871b1bSChris Mason int ret; 250544871b1bSChris Mason 250644871b1bSChris Mason if (!path->nodes[1]) 250744871b1bSChris Mason return 1; 250844871b1bSChris Mason 250944871b1bSChris Mason slot = path->slots[1]; 251044871b1bSChris Mason upper = path->nodes[1]; 251144871b1bSChris Mason if (slot >= btrfs_header_nritems(upper) - 1) 251244871b1bSChris Mason return 1; 251344871b1bSChris Mason 251444871b1bSChris Mason btrfs_assert_tree_locked(path->nodes[1]); 251544871b1bSChris Mason 251644871b1bSChris Mason right = read_node_slot(root, upper, slot + 1); 251744871b1bSChris Mason btrfs_tree_lock(right); 251844871b1bSChris Mason btrfs_set_lock_blocking(right); 251944871b1bSChris Mason 252044871b1bSChris Mason free_space = btrfs_leaf_free_space(root, right); 252144871b1bSChris Mason if (free_space < data_size) 252244871b1bSChris Mason goto out_unlock; 252344871b1bSChris Mason 252444871b1bSChris Mason /* cow and double check */ 252544871b1bSChris Mason ret = btrfs_cow_block(trans, root, right, upper, 252644871b1bSChris Mason slot + 1, &right); 252744871b1bSChris Mason if (ret) 252844871b1bSChris Mason goto out_unlock; 252944871b1bSChris Mason 253044871b1bSChris Mason free_space = btrfs_leaf_free_space(root, right); 253144871b1bSChris Mason if (free_space < data_size) 253244871b1bSChris Mason goto out_unlock; 253344871b1bSChris Mason 253444871b1bSChris Mason left_nritems = btrfs_header_nritems(left); 253544871b1bSChris Mason if (left_nritems == 0) 253644871b1bSChris Mason goto out_unlock; 253744871b1bSChris Mason 253899d8f83cSChris Mason return __push_leaf_right(trans, root, path, min_data_size, empty, 253999d8f83cSChris Mason right, free_space, left_nritems, min_slot); 254044871b1bSChris Mason out_unlock: 254144871b1bSChris Mason btrfs_tree_unlock(right); 254244871b1bSChris Mason free_extent_buffer(right); 254344871b1bSChris Mason return 1; 254444871b1bSChris Mason } 254544871b1bSChris Mason 254644871b1bSChris Mason /* 254744871b1bSChris Mason * push some data in the path leaf to the left, trying to free up at 254844871b1bSChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 254999d8f83cSChris Mason * 255099d8f83cSChris Mason * max_slot can put a limit on how far into the leaf we'll push items. The 255199d8f83cSChris Mason * item at 'max_slot' won't be touched. Use (u32)-1 to make us do all the 255299d8f83cSChris Mason * items 255344871b1bSChris Mason */ 255444871b1bSChris Mason static noinline int __push_leaf_left(struct btrfs_trans_handle *trans, 255544871b1bSChris Mason struct btrfs_root *root, 255644871b1bSChris Mason struct btrfs_path *path, int data_size, 255744871b1bSChris Mason int empty, struct extent_buffer *left, 255899d8f83cSChris Mason int free_space, u32 right_nritems, 255999d8f83cSChris Mason u32 max_slot) 256044871b1bSChris Mason { 25615f39d397SChris Mason struct btrfs_disk_key disk_key; 25625f39d397SChris Mason struct extent_buffer *right = path->nodes[0]; 2563be0e5c09SChris Mason int i; 2564be0e5c09SChris Mason int push_space = 0; 2565be0e5c09SChris Mason int push_items = 0; 25660783fcfcSChris Mason struct btrfs_item *item; 25677518a238SChris Mason u32 old_left_nritems; 256834a38218SChris Mason u32 nr; 2569aa5d6bedSChris Mason int ret = 0; 2570aa5d6bedSChris Mason int wret; 2571db94535dSChris Mason u32 this_item_size; 2572db94535dSChris Mason u32 old_left_item_size; 2573be0e5c09SChris Mason 257434a38218SChris Mason if (empty) 257599d8f83cSChris Mason nr = min(right_nritems, max_slot); 257634a38218SChris Mason else 257799d8f83cSChris Mason nr = min(right_nritems - 1, max_slot); 257834a38218SChris Mason 257934a38218SChris Mason for (i = 0; i < nr; i++) { 25805f39d397SChris Mason item = btrfs_item_nr(right, i); 2581db94535dSChris Mason if (!right->map_token) { 2582db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2583db94535dSChris Mason sizeof(struct btrfs_item), 2584db94535dSChris Mason &right->map_token, &right->kaddr, 2585db94535dSChris Mason &right->map_start, &right->map_len, 2586db94535dSChris Mason KM_USER1); 2587db94535dSChris Mason } 2588db94535dSChris Mason 258931840ae1SZheng Yan if (!empty && push_items > 0) { 259031840ae1SZheng Yan if (path->slots[0] < i) 259131840ae1SZheng Yan break; 259231840ae1SZheng Yan if (path->slots[0] == i) { 259331840ae1SZheng Yan int space = btrfs_leaf_free_space(root, right); 259431840ae1SZheng Yan if (space + push_space * 2 > free_space) 259531840ae1SZheng Yan break; 259631840ae1SZheng Yan } 259731840ae1SZheng Yan } 259831840ae1SZheng Yan 2599be0e5c09SChris Mason if (path->slots[0] == i) 260087b29b20SYan Zheng push_space += data_size; 2601db94535dSChris Mason 2602db94535dSChris Mason this_item_size = btrfs_item_size(right, item); 2603db94535dSChris Mason if (this_item_size + sizeof(*item) + push_space > free_space) 2604be0e5c09SChris Mason break; 2605db94535dSChris Mason 2606be0e5c09SChris Mason push_items++; 2607db94535dSChris Mason push_space += this_item_size + sizeof(*item); 2608be0e5c09SChris Mason } 2609db94535dSChris Mason 2610db94535dSChris Mason if (right->map_token) { 2611db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2612db94535dSChris Mason right->map_token = NULL; 2613db94535dSChris Mason } 2614db94535dSChris Mason 2615be0e5c09SChris Mason if (push_items == 0) { 2616925baeddSChris Mason ret = 1; 2617925baeddSChris Mason goto out; 2618be0e5c09SChris Mason } 261934a38218SChris Mason if (!empty && push_items == btrfs_header_nritems(right)) 2620a429e513SChris Mason WARN_ON(1); 26215f39d397SChris Mason 2622be0e5c09SChris Mason /* push data from right to left */ 26235f39d397SChris Mason copy_extent_buffer(left, right, 26245f39d397SChris Mason btrfs_item_nr_offset(btrfs_header_nritems(left)), 26255f39d397SChris Mason btrfs_item_nr_offset(0), 26265f39d397SChris Mason push_items * sizeof(struct btrfs_item)); 26275f39d397SChris Mason 2628123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root) - 26295f39d397SChris Mason btrfs_item_offset_nr(right, push_items - 1); 26305f39d397SChris Mason 26315f39d397SChris Mason copy_extent_buffer(left, right, btrfs_leaf_data(left) + 2632d6025579SChris Mason leaf_data_end(root, left) - push_space, 2633123abc88SChris Mason btrfs_leaf_data(right) + 26345f39d397SChris Mason btrfs_item_offset_nr(right, push_items - 1), 2635be0e5c09SChris Mason push_space); 26365f39d397SChris Mason old_left_nritems = btrfs_header_nritems(left); 263787b29b20SYan Zheng BUG_ON(old_left_nritems <= 0); 2638eb60ceacSChris Mason 2639db94535dSChris Mason old_left_item_size = btrfs_item_offset_nr(left, old_left_nritems - 1); 2640be0e5c09SChris Mason for (i = old_left_nritems; i < old_left_nritems + push_items; i++) { 26415f39d397SChris Mason u32 ioff; 2642db94535dSChris Mason 26435f39d397SChris Mason item = btrfs_item_nr(left, i); 2644db94535dSChris Mason if (!left->map_token) { 2645db94535dSChris Mason map_extent_buffer(left, (unsigned long)item, 2646db94535dSChris Mason sizeof(struct btrfs_item), 2647db94535dSChris Mason &left->map_token, &left->kaddr, 2648db94535dSChris Mason &left->map_start, &left->map_len, 2649db94535dSChris Mason KM_USER1); 2650db94535dSChris Mason } 2651db94535dSChris Mason 26525f39d397SChris Mason ioff = btrfs_item_offset(left, item); 26535f39d397SChris Mason btrfs_set_item_offset(left, item, 2654db94535dSChris Mason ioff - (BTRFS_LEAF_DATA_SIZE(root) - old_left_item_size)); 2655be0e5c09SChris Mason } 26565f39d397SChris Mason btrfs_set_header_nritems(left, old_left_nritems + push_items); 2657db94535dSChris Mason if (left->map_token) { 2658db94535dSChris Mason unmap_extent_buffer(left, left->map_token, KM_USER1); 2659db94535dSChris Mason left->map_token = NULL; 2660db94535dSChris Mason } 2661be0e5c09SChris Mason 2662be0e5c09SChris Mason /* fixup right node */ 266334a38218SChris Mason if (push_items > right_nritems) { 2664d397712bSChris Mason printk(KERN_CRIT "push items %d nr %u\n", push_items, 2665d397712bSChris Mason right_nritems); 266634a38218SChris Mason WARN_ON(1); 266734a38218SChris Mason } 266834a38218SChris Mason 266934a38218SChris Mason if (push_items < right_nritems) { 26705f39d397SChris Mason push_space = btrfs_item_offset_nr(right, push_items - 1) - 2671123abc88SChris Mason leaf_data_end(root, right); 26725f39d397SChris Mason memmove_extent_buffer(right, btrfs_leaf_data(right) + 2673d6025579SChris Mason BTRFS_LEAF_DATA_SIZE(root) - push_space, 2674d6025579SChris Mason btrfs_leaf_data(right) + 2675123abc88SChris Mason leaf_data_end(root, right), push_space); 26765f39d397SChris Mason 26775f39d397SChris Mason memmove_extent_buffer(right, btrfs_item_nr_offset(0), 26785f39d397SChris Mason btrfs_item_nr_offset(push_items), 26795f39d397SChris Mason (btrfs_header_nritems(right) - push_items) * 26800783fcfcSChris Mason sizeof(struct btrfs_item)); 268134a38218SChris Mason } 2682eef1c494SYan right_nritems -= push_items; 2683eef1c494SYan btrfs_set_header_nritems(right, right_nritems); 2684123abc88SChris Mason push_space = BTRFS_LEAF_DATA_SIZE(root); 26855f39d397SChris Mason for (i = 0; i < right_nritems; i++) { 26865f39d397SChris Mason item = btrfs_item_nr(right, i); 2687db94535dSChris Mason 2688db94535dSChris Mason if (!right->map_token) { 2689db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2690db94535dSChris Mason sizeof(struct btrfs_item), 2691db94535dSChris Mason &right->map_token, &right->kaddr, 2692db94535dSChris Mason &right->map_start, &right->map_len, 2693db94535dSChris Mason KM_USER1); 2694db94535dSChris Mason } 2695db94535dSChris Mason 2696db94535dSChris Mason push_space = push_space - btrfs_item_size(right, item); 2697db94535dSChris Mason btrfs_set_item_offset(right, item, push_space); 2698db94535dSChris Mason } 2699db94535dSChris Mason if (right->map_token) { 2700db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2701db94535dSChris Mason right->map_token = NULL; 2702be0e5c09SChris Mason } 2703eb60ceacSChris Mason 27045f39d397SChris Mason btrfs_mark_buffer_dirty(left); 270534a38218SChris Mason if (right_nritems) 27065f39d397SChris Mason btrfs_mark_buffer_dirty(right); 2707f0486c68SYan, Zheng else 2708f0486c68SYan, Zheng clean_tree_block(trans, root, right); 2709098f59c2SChris Mason 27105f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 27115f39d397SChris Mason wret = fixup_low_keys(trans, root, path, &disk_key, 1); 2712aa5d6bedSChris Mason if (wret) 2713aa5d6bedSChris Mason ret = wret; 2714be0e5c09SChris Mason 2715be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 2716be0e5c09SChris Mason if (path->slots[0] < push_items) { 2717be0e5c09SChris Mason path->slots[0] += old_left_nritems; 2718925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 27195f39d397SChris Mason free_extent_buffer(path->nodes[0]); 27205f39d397SChris Mason path->nodes[0] = left; 2721be0e5c09SChris Mason path->slots[1] -= 1; 2722be0e5c09SChris Mason } else { 2723925baeddSChris Mason btrfs_tree_unlock(left); 27245f39d397SChris Mason free_extent_buffer(left); 2725be0e5c09SChris Mason path->slots[0] -= push_items; 2726be0e5c09SChris Mason } 2727eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 2728aa5d6bedSChris Mason return ret; 2729925baeddSChris Mason out: 2730925baeddSChris Mason btrfs_tree_unlock(left); 2731925baeddSChris Mason free_extent_buffer(left); 2732925baeddSChris Mason return ret; 2733be0e5c09SChris Mason } 2734be0e5c09SChris Mason 273574123bd7SChris Mason /* 273644871b1bSChris Mason * push some data in the path leaf to the left, trying to free up at 273744871b1bSChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 273899d8f83cSChris Mason * 273999d8f83cSChris Mason * max_slot can put a limit on how far into the leaf we'll push items. The 274099d8f83cSChris Mason * item at 'max_slot' won't be touched. Use (u32)-1 to make us push all the 274199d8f83cSChris Mason * items 274244871b1bSChris Mason */ 274344871b1bSChris Mason static int push_leaf_left(struct btrfs_trans_handle *trans, struct btrfs_root 274499d8f83cSChris Mason *root, struct btrfs_path *path, int min_data_size, 274599d8f83cSChris Mason int data_size, int empty, u32 max_slot) 274644871b1bSChris Mason { 274744871b1bSChris Mason struct extent_buffer *right = path->nodes[0]; 274844871b1bSChris Mason struct extent_buffer *left; 274944871b1bSChris Mason int slot; 275044871b1bSChris Mason int free_space; 275144871b1bSChris Mason u32 right_nritems; 275244871b1bSChris Mason int ret = 0; 275344871b1bSChris Mason 275444871b1bSChris Mason slot = path->slots[1]; 275544871b1bSChris Mason if (slot == 0) 275644871b1bSChris Mason return 1; 275744871b1bSChris Mason if (!path->nodes[1]) 275844871b1bSChris Mason return 1; 275944871b1bSChris Mason 276044871b1bSChris Mason right_nritems = btrfs_header_nritems(right); 276144871b1bSChris Mason if (right_nritems == 0) 276244871b1bSChris Mason return 1; 276344871b1bSChris Mason 276444871b1bSChris Mason btrfs_assert_tree_locked(path->nodes[1]); 276544871b1bSChris Mason 276644871b1bSChris Mason left = read_node_slot(root, path->nodes[1], slot - 1); 276744871b1bSChris Mason btrfs_tree_lock(left); 276844871b1bSChris Mason btrfs_set_lock_blocking(left); 276944871b1bSChris Mason 277044871b1bSChris Mason free_space = btrfs_leaf_free_space(root, left); 277144871b1bSChris Mason if (free_space < data_size) { 277244871b1bSChris Mason ret = 1; 277344871b1bSChris Mason goto out; 277444871b1bSChris Mason } 277544871b1bSChris Mason 277644871b1bSChris Mason /* cow and double check */ 277744871b1bSChris Mason ret = btrfs_cow_block(trans, root, left, 277844871b1bSChris Mason path->nodes[1], slot - 1, &left); 277944871b1bSChris Mason if (ret) { 278044871b1bSChris Mason /* we hit -ENOSPC, but it isn't fatal here */ 278144871b1bSChris Mason ret = 1; 278244871b1bSChris Mason goto out; 278344871b1bSChris Mason } 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 279199d8f83cSChris Mason return __push_leaf_left(trans, root, path, min_data_size, 279299d8f83cSChris Mason empty, left, free_space, right_nritems, 279399d8f83cSChris Mason max_slot); 279444871b1bSChris Mason out: 279544871b1bSChris Mason btrfs_tree_unlock(left); 279644871b1bSChris Mason free_extent_buffer(left); 279744871b1bSChris Mason return ret; 279844871b1bSChris Mason } 279944871b1bSChris Mason 280044871b1bSChris Mason /* 280174123bd7SChris Mason * split the path's leaf in two, making sure there is at least data_size 280274123bd7SChris Mason * available for the resulting leaf level of the path. 2803aa5d6bedSChris Mason * 2804aa5d6bedSChris Mason * returns 0 if all went well and < 0 on failure. 280574123bd7SChris Mason */ 280644871b1bSChris Mason static noinline int copy_for_split(struct btrfs_trans_handle *trans, 2807e02119d5SChris Mason struct btrfs_root *root, 280844871b1bSChris Mason struct btrfs_path *path, 280944871b1bSChris Mason struct extent_buffer *l, 281044871b1bSChris Mason struct extent_buffer *right, 281144871b1bSChris Mason int slot, int mid, int nritems) 2812be0e5c09SChris Mason { 2813be0e5c09SChris Mason int data_copy_size; 2814be0e5c09SChris Mason int rt_data_off; 2815be0e5c09SChris Mason int i; 2816d4dbff95SChris Mason int ret = 0; 2817aa5d6bedSChris Mason int wret; 2818d4dbff95SChris Mason struct btrfs_disk_key disk_key; 2819be0e5c09SChris Mason 28205f39d397SChris Mason nritems = nritems - mid; 28215f39d397SChris Mason btrfs_set_header_nritems(right, nritems); 28225f39d397SChris Mason data_copy_size = btrfs_item_end_nr(l, mid) - leaf_data_end(root, l); 28235f39d397SChris Mason 28245f39d397SChris Mason copy_extent_buffer(right, l, btrfs_item_nr_offset(0), 28255f39d397SChris Mason btrfs_item_nr_offset(mid), 28265f39d397SChris Mason nritems * sizeof(struct btrfs_item)); 28275f39d397SChris Mason 28285f39d397SChris Mason copy_extent_buffer(right, l, 2829d6025579SChris Mason btrfs_leaf_data(right) + BTRFS_LEAF_DATA_SIZE(root) - 2830123abc88SChris Mason data_copy_size, btrfs_leaf_data(l) + 2831123abc88SChris Mason leaf_data_end(root, l), data_copy_size); 283274123bd7SChris Mason 28335f39d397SChris Mason rt_data_off = BTRFS_LEAF_DATA_SIZE(root) - 28345f39d397SChris Mason btrfs_item_end_nr(l, mid); 28355f39d397SChris Mason 28365f39d397SChris Mason for (i = 0; i < nritems; i++) { 28375f39d397SChris Mason struct btrfs_item *item = btrfs_item_nr(right, i); 2838db94535dSChris Mason u32 ioff; 2839db94535dSChris Mason 2840db94535dSChris Mason if (!right->map_token) { 2841db94535dSChris Mason map_extent_buffer(right, (unsigned long)item, 2842db94535dSChris Mason sizeof(struct btrfs_item), 2843db94535dSChris Mason &right->map_token, &right->kaddr, 2844db94535dSChris Mason &right->map_start, &right->map_len, 2845db94535dSChris Mason KM_USER1); 2846db94535dSChris Mason } 2847db94535dSChris Mason 2848db94535dSChris Mason ioff = btrfs_item_offset(right, item); 28495f39d397SChris Mason btrfs_set_item_offset(right, item, ioff + rt_data_off); 28500783fcfcSChris Mason } 285174123bd7SChris Mason 2852db94535dSChris Mason if (right->map_token) { 2853db94535dSChris Mason unmap_extent_buffer(right, right->map_token, KM_USER1); 2854db94535dSChris Mason right->map_token = NULL; 2855db94535dSChris Mason } 2856db94535dSChris Mason 28575f39d397SChris Mason btrfs_set_header_nritems(l, mid); 2858aa5d6bedSChris Mason ret = 0; 28595f39d397SChris Mason btrfs_item_key(right, &disk_key, 0); 2860db94535dSChris Mason wret = insert_ptr(trans, root, path, &disk_key, right->start, 2861db94535dSChris Mason path->slots[1] + 1, 1); 2862aa5d6bedSChris Mason if (wret) 2863aa5d6bedSChris Mason ret = wret; 28645f39d397SChris Mason 28655f39d397SChris Mason btrfs_mark_buffer_dirty(right); 28665f39d397SChris Mason btrfs_mark_buffer_dirty(l); 2867eb60ceacSChris Mason BUG_ON(path->slots[0] != slot); 28685f39d397SChris Mason 2869be0e5c09SChris Mason if (mid <= slot) { 2870925baeddSChris Mason btrfs_tree_unlock(path->nodes[0]); 28715f39d397SChris Mason free_extent_buffer(path->nodes[0]); 28725f39d397SChris Mason path->nodes[0] = right; 2873be0e5c09SChris Mason path->slots[0] -= mid; 2874be0e5c09SChris Mason path->slots[1] += 1; 2875925baeddSChris Mason } else { 2876925baeddSChris Mason btrfs_tree_unlock(right); 28775f39d397SChris Mason free_extent_buffer(right); 2878925baeddSChris Mason } 28795f39d397SChris Mason 2880eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 2881d4dbff95SChris Mason 288244871b1bSChris Mason return ret; 288344871b1bSChris Mason } 288444871b1bSChris Mason 288544871b1bSChris Mason /* 288699d8f83cSChris Mason * double splits happen when we need to insert a big item in the middle 288799d8f83cSChris Mason * of a leaf. A double split can leave us with 3 mostly empty leaves: 288899d8f83cSChris Mason * leaf: [ slots 0 - N] [ our target ] [ N + 1 - total in leaf ] 288999d8f83cSChris Mason * A B C 289099d8f83cSChris Mason * 289199d8f83cSChris Mason * We avoid this by trying to push the items on either side of our target 289299d8f83cSChris Mason * into the adjacent leaves. If all goes well we can avoid the double split 289399d8f83cSChris Mason * completely. 289499d8f83cSChris Mason */ 289599d8f83cSChris Mason static noinline int push_for_double_split(struct btrfs_trans_handle *trans, 289699d8f83cSChris Mason struct btrfs_root *root, 289799d8f83cSChris Mason struct btrfs_path *path, 289899d8f83cSChris Mason int data_size) 289999d8f83cSChris Mason { 290099d8f83cSChris Mason int ret; 290199d8f83cSChris Mason int progress = 0; 290299d8f83cSChris Mason int slot; 290399d8f83cSChris Mason u32 nritems; 290499d8f83cSChris Mason 290599d8f83cSChris Mason slot = path->slots[0]; 290699d8f83cSChris Mason 290799d8f83cSChris Mason /* 290899d8f83cSChris Mason * try to push all the items after our slot into the 290999d8f83cSChris Mason * right leaf 291099d8f83cSChris Mason */ 291199d8f83cSChris Mason ret = push_leaf_right(trans, root, path, 1, data_size, 0, slot); 291299d8f83cSChris Mason if (ret < 0) 291399d8f83cSChris Mason return ret; 291499d8f83cSChris Mason 291599d8f83cSChris Mason if (ret == 0) 291699d8f83cSChris Mason progress++; 291799d8f83cSChris Mason 291899d8f83cSChris Mason nritems = btrfs_header_nritems(path->nodes[0]); 291999d8f83cSChris Mason /* 292099d8f83cSChris Mason * our goal is to get our slot at the start or end of a leaf. If 292199d8f83cSChris Mason * we've done so we're done 292299d8f83cSChris Mason */ 292399d8f83cSChris Mason if (path->slots[0] == 0 || path->slots[0] == nritems) 292499d8f83cSChris Mason return 0; 292599d8f83cSChris Mason 292699d8f83cSChris Mason if (btrfs_leaf_free_space(root, path->nodes[0]) >= data_size) 292799d8f83cSChris Mason return 0; 292899d8f83cSChris Mason 292999d8f83cSChris Mason /* try to push all the items before our slot into the next leaf */ 293099d8f83cSChris Mason slot = path->slots[0]; 293199d8f83cSChris Mason ret = push_leaf_left(trans, root, path, 1, data_size, 0, slot); 293299d8f83cSChris Mason if (ret < 0) 293399d8f83cSChris Mason return ret; 293499d8f83cSChris Mason 293599d8f83cSChris Mason if (ret == 0) 293699d8f83cSChris Mason progress++; 293799d8f83cSChris Mason 293899d8f83cSChris Mason if (progress) 293999d8f83cSChris Mason return 0; 294099d8f83cSChris Mason return 1; 294199d8f83cSChris Mason } 294299d8f83cSChris Mason 294399d8f83cSChris Mason /* 294444871b1bSChris Mason * split the path's leaf in two, making sure there is at least data_size 294544871b1bSChris Mason * available for the resulting leaf level of the path. 294644871b1bSChris Mason * 294744871b1bSChris Mason * returns 0 if all went well and < 0 on failure. 294844871b1bSChris Mason */ 294944871b1bSChris Mason static noinline int split_leaf(struct btrfs_trans_handle *trans, 295044871b1bSChris Mason struct btrfs_root *root, 295144871b1bSChris Mason struct btrfs_key *ins_key, 295244871b1bSChris Mason struct btrfs_path *path, int data_size, 295344871b1bSChris Mason int extend) 295444871b1bSChris Mason { 29555d4f98a2SYan Zheng struct btrfs_disk_key disk_key; 295644871b1bSChris Mason struct extent_buffer *l; 295744871b1bSChris Mason u32 nritems; 295844871b1bSChris Mason int mid; 295944871b1bSChris Mason int slot; 296044871b1bSChris Mason struct extent_buffer *right; 296144871b1bSChris Mason int ret = 0; 296244871b1bSChris Mason int wret; 29635d4f98a2SYan Zheng int split; 296444871b1bSChris Mason int num_doubles = 0; 296599d8f83cSChris Mason int tried_avoid_double = 0; 296644871b1bSChris Mason 2967a5719521SYan, Zheng l = path->nodes[0]; 2968a5719521SYan, Zheng slot = path->slots[0]; 2969a5719521SYan, Zheng if (extend && data_size + btrfs_item_size_nr(l, slot) + 2970a5719521SYan, Zheng sizeof(struct btrfs_item) > BTRFS_LEAF_DATA_SIZE(root)) 2971a5719521SYan, Zheng return -EOVERFLOW; 2972a5719521SYan, Zheng 297344871b1bSChris Mason /* first try to make some room by pushing left and right */ 297499d8f83cSChris Mason if (data_size) { 297599d8f83cSChris Mason wret = push_leaf_right(trans, root, path, data_size, 297699d8f83cSChris Mason data_size, 0, 0); 297744871b1bSChris Mason if (wret < 0) 297844871b1bSChris Mason return wret; 297944871b1bSChris Mason if (wret) { 298099d8f83cSChris Mason wret = push_leaf_left(trans, root, path, data_size, 298199d8f83cSChris Mason data_size, 0, (u32)-1); 298244871b1bSChris Mason if (wret < 0) 298344871b1bSChris Mason return wret; 298444871b1bSChris Mason } 298544871b1bSChris Mason l = path->nodes[0]; 298644871b1bSChris Mason 298744871b1bSChris Mason /* did the pushes work? */ 298844871b1bSChris Mason if (btrfs_leaf_free_space(root, l) >= data_size) 298944871b1bSChris Mason return 0; 299044871b1bSChris Mason } 299144871b1bSChris Mason 299244871b1bSChris Mason if (!path->nodes[1]) { 299344871b1bSChris Mason ret = insert_new_root(trans, root, path, 1); 299444871b1bSChris Mason if (ret) 299544871b1bSChris Mason return ret; 299644871b1bSChris Mason } 299744871b1bSChris Mason again: 29985d4f98a2SYan Zheng split = 1; 299944871b1bSChris Mason l = path->nodes[0]; 300044871b1bSChris Mason slot = path->slots[0]; 300144871b1bSChris Mason nritems = btrfs_header_nritems(l); 300244871b1bSChris Mason mid = (nritems + 1) / 2; 300344871b1bSChris Mason 30045d4f98a2SYan Zheng if (mid <= slot) { 30055d4f98a2SYan Zheng if (nritems == 1 || 30065d4f98a2SYan Zheng leaf_space_used(l, mid, nritems - mid) + data_size > 30075d4f98a2SYan Zheng BTRFS_LEAF_DATA_SIZE(root)) { 30085d4f98a2SYan Zheng if (slot >= nritems) { 30095d4f98a2SYan Zheng split = 0; 30105d4f98a2SYan Zheng } else { 30115d4f98a2SYan Zheng mid = slot; 30125d4f98a2SYan Zheng if (mid != nritems && 30135d4f98a2SYan Zheng leaf_space_used(l, mid, nritems - mid) + 30145d4f98a2SYan Zheng data_size > BTRFS_LEAF_DATA_SIZE(root)) { 301599d8f83cSChris Mason if (data_size && !tried_avoid_double) 301699d8f83cSChris Mason goto push_for_double; 30175d4f98a2SYan Zheng split = 2; 30185d4f98a2SYan Zheng } 30195d4f98a2SYan Zheng } 30205d4f98a2SYan Zheng } 30215d4f98a2SYan Zheng } else { 30225d4f98a2SYan Zheng if (leaf_space_used(l, 0, mid) + data_size > 30235d4f98a2SYan Zheng BTRFS_LEAF_DATA_SIZE(root)) { 30245d4f98a2SYan Zheng if (!extend && data_size && slot == 0) { 30255d4f98a2SYan Zheng split = 0; 30265d4f98a2SYan Zheng } else if ((extend || !data_size) && slot == 0) { 30275d4f98a2SYan Zheng mid = 1; 30285d4f98a2SYan Zheng } else { 30295d4f98a2SYan Zheng mid = slot; 30305d4f98a2SYan Zheng if (mid != nritems && 30315d4f98a2SYan Zheng leaf_space_used(l, mid, nritems - mid) + 30325d4f98a2SYan Zheng data_size > BTRFS_LEAF_DATA_SIZE(root)) { 303399d8f83cSChris Mason if (data_size && !tried_avoid_double) 303499d8f83cSChris Mason goto push_for_double; 30355d4f98a2SYan Zheng split = 2 ; 30365d4f98a2SYan Zheng } 30375d4f98a2SYan Zheng } 30385d4f98a2SYan Zheng } 30395d4f98a2SYan Zheng } 30405d4f98a2SYan Zheng 30415d4f98a2SYan Zheng if (split == 0) 30425d4f98a2SYan Zheng btrfs_cpu_key_to_disk(&disk_key, ins_key); 30435d4f98a2SYan Zheng else 30445d4f98a2SYan Zheng btrfs_item_key(l, &disk_key, mid); 30455d4f98a2SYan Zheng 30465d4f98a2SYan Zheng right = btrfs_alloc_free_block(trans, root, root->leafsize, 0, 304744871b1bSChris Mason root->root_key.objectid, 30485d4f98a2SYan Zheng &disk_key, 0, l->start, 0); 3049f0486c68SYan, Zheng if (IS_ERR(right)) 305044871b1bSChris Mason return PTR_ERR(right); 3051f0486c68SYan, Zheng 3052f0486c68SYan, Zheng root_add_used(root, root->leafsize); 305344871b1bSChris Mason 305444871b1bSChris Mason memset_extent_buffer(right, 0, 0, sizeof(struct btrfs_header)); 305544871b1bSChris Mason btrfs_set_header_bytenr(right, right->start); 305644871b1bSChris Mason btrfs_set_header_generation(right, trans->transid); 30575d4f98a2SYan Zheng btrfs_set_header_backref_rev(right, BTRFS_MIXED_BACKREF_REV); 305844871b1bSChris Mason btrfs_set_header_owner(right, root->root_key.objectid); 305944871b1bSChris Mason btrfs_set_header_level(right, 0); 306044871b1bSChris Mason write_extent_buffer(right, root->fs_info->fsid, 306144871b1bSChris Mason (unsigned long)btrfs_header_fsid(right), 306244871b1bSChris Mason BTRFS_FSID_SIZE); 306344871b1bSChris Mason 306444871b1bSChris Mason write_extent_buffer(right, root->fs_info->chunk_tree_uuid, 306544871b1bSChris Mason (unsigned long)btrfs_header_chunk_tree_uuid(right), 306644871b1bSChris Mason BTRFS_UUID_SIZE); 306744871b1bSChris Mason 30685d4f98a2SYan Zheng if (split == 0) { 306944871b1bSChris Mason if (mid <= slot) { 307044871b1bSChris Mason btrfs_set_header_nritems(right, 0); 307144871b1bSChris Mason wret = insert_ptr(trans, root, path, 307244871b1bSChris Mason &disk_key, right->start, 307344871b1bSChris Mason path->slots[1] + 1, 1); 307444871b1bSChris Mason if (wret) 307544871b1bSChris Mason ret = wret; 307644871b1bSChris Mason 307744871b1bSChris Mason btrfs_tree_unlock(path->nodes[0]); 307844871b1bSChris Mason free_extent_buffer(path->nodes[0]); 307944871b1bSChris Mason path->nodes[0] = right; 308044871b1bSChris Mason path->slots[0] = 0; 308144871b1bSChris Mason path->slots[1] += 1; 308244871b1bSChris Mason } else { 308344871b1bSChris Mason btrfs_set_header_nritems(right, 0); 308444871b1bSChris Mason wret = insert_ptr(trans, root, path, 308544871b1bSChris Mason &disk_key, 308644871b1bSChris Mason right->start, 308744871b1bSChris Mason path->slots[1], 1); 308844871b1bSChris Mason if (wret) 308944871b1bSChris Mason ret = wret; 309044871b1bSChris Mason btrfs_tree_unlock(path->nodes[0]); 309144871b1bSChris Mason free_extent_buffer(path->nodes[0]); 309244871b1bSChris Mason path->nodes[0] = right; 309344871b1bSChris Mason path->slots[0] = 0; 309444871b1bSChris Mason if (path->slots[1] == 0) { 309544871b1bSChris Mason wret = fixup_low_keys(trans, root, 309644871b1bSChris Mason path, &disk_key, 1); 309744871b1bSChris Mason if (wret) 309844871b1bSChris Mason ret = wret; 309944871b1bSChris Mason } 31005d4f98a2SYan Zheng } 310144871b1bSChris Mason btrfs_mark_buffer_dirty(right); 310244871b1bSChris Mason return ret; 310344871b1bSChris Mason } 310444871b1bSChris Mason 310544871b1bSChris Mason ret = copy_for_split(trans, root, path, l, right, slot, mid, nritems); 310644871b1bSChris Mason BUG_ON(ret); 310744871b1bSChris Mason 31085d4f98a2SYan Zheng if (split == 2) { 3109cc0c5538SChris Mason BUG_ON(num_doubles != 0); 3110cc0c5538SChris Mason num_doubles++; 3111cc0c5538SChris Mason goto again; 31123326d1b0SChris Mason } 311344871b1bSChris Mason 3114be0e5c09SChris Mason return ret; 311599d8f83cSChris Mason 311699d8f83cSChris Mason push_for_double: 311799d8f83cSChris Mason push_for_double_split(trans, root, path, data_size); 311899d8f83cSChris Mason tried_avoid_double = 1; 311999d8f83cSChris Mason if (btrfs_leaf_free_space(root, path->nodes[0]) >= data_size) 312099d8f83cSChris Mason return 0; 312199d8f83cSChris Mason goto again; 3122be0e5c09SChris Mason } 3123be0e5c09SChris Mason 3124ad48fd75SYan, Zheng static noinline int setup_leaf_for_split(struct btrfs_trans_handle *trans, 3125ad48fd75SYan, Zheng struct btrfs_root *root, 3126ad48fd75SYan, Zheng struct btrfs_path *path, int ins_len) 3127ad48fd75SYan, Zheng { 3128ad48fd75SYan, Zheng struct btrfs_key key; 3129ad48fd75SYan, Zheng struct extent_buffer *leaf; 3130ad48fd75SYan, Zheng struct btrfs_file_extent_item *fi; 3131ad48fd75SYan, Zheng u64 extent_len = 0; 3132ad48fd75SYan, Zheng u32 item_size; 3133ad48fd75SYan, Zheng int ret; 3134ad48fd75SYan, Zheng 3135ad48fd75SYan, Zheng leaf = path->nodes[0]; 3136ad48fd75SYan, Zheng btrfs_item_key_to_cpu(leaf, &key, path->slots[0]); 3137ad48fd75SYan, Zheng 3138ad48fd75SYan, Zheng BUG_ON(key.type != BTRFS_EXTENT_DATA_KEY && 3139ad48fd75SYan, Zheng key.type != BTRFS_EXTENT_CSUM_KEY); 3140ad48fd75SYan, Zheng 3141ad48fd75SYan, Zheng if (btrfs_leaf_free_space(root, leaf) >= ins_len) 3142ad48fd75SYan, Zheng return 0; 3143ad48fd75SYan, Zheng 3144ad48fd75SYan, Zheng item_size = btrfs_item_size_nr(leaf, path->slots[0]); 3145ad48fd75SYan, Zheng if (key.type == BTRFS_EXTENT_DATA_KEY) { 3146ad48fd75SYan, Zheng fi = btrfs_item_ptr(leaf, path->slots[0], 3147ad48fd75SYan, Zheng struct btrfs_file_extent_item); 3148ad48fd75SYan, Zheng extent_len = btrfs_file_extent_num_bytes(leaf, fi); 3149ad48fd75SYan, Zheng } 3150ad48fd75SYan, Zheng btrfs_release_path(root, path); 3151ad48fd75SYan, Zheng 3152ad48fd75SYan, Zheng path->keep_locks = 1; 3153ad48fd75SYan, Zheng path->search_for_split = 1; 3154ad48fd75SYan, Zheng ret = btrfs_search_slot(trans, root, &key, path, 0, 1); 3155ad48fd75SYan, Zheng path->search_for_split = 0; 3156ad48fd75SYan, Zheng if (ret < 0) 3157ad48fd75SYan, Zheng goto err; 3158ad48fd75SYan, Zheng 3159ad48fd75SYan, Zheng ret = -EAGAIN; 3160ad48fd75SYan, Zheng leaf = path->nodes[0]; 3161ad48fd75SYan, Zheng /* if our item isn't there or got smaller, return now */ 3162ad48fd75SYan, Zheng if (ret > 0 || item_size != btrfs_item_size_nr(leaf, path->slots[0])) 3163ad48fd75SYan, Zheng goto err; 3164ad48fd75SYan, Zheng 3165109f6aefSChris Mason /* the leaf has changed, it now has room. return now */ 3166109f6aefSChris Mason if (btrfs_leaf_free_space(root, path->nodes[0]) >= ins_len) 3167109f6aefSChris Mason goto err; 3168109f6aefSChris Mason 3169ad48fd75SYan, Zheng if (key.type == BTRFS_EXTENT_DATA_KEY) { 3170ad48fd75SYan, Zheng fi = btrfs_item_ptr(leaf, path->slots[0], 3171ad48fd75SYan, Zheng struct btrfs_file_extent_item); 3172ad48fd75SYan, Zheng if (extent_len != btrfs_file_extent_num_bytes(leaf, fi)) 3173ad48fd75SYan, Zheng goto err; 3174ad48fd75SYan, Zheng } 3175ad48fd75SYan, Zheng 3176ad48fd75SYan, Zheng btrfs_set_path_blocking(path); 3177ad48fd75SYan, Zheng ret = split_leaf(trans, root, &key, path, ins_len, 1); 3178f0486c68SYan, Zheng if (ret) 3179f0486c68SYan, Zheng goto err; 3180ad48fd75SYan, Zheng 3181ad48fd75SYan, Zheng path->keep_locks = 0; 3182ad48fd75SYan, Zheng btrfs_unlock_up_safe(path, 1); 3183ad48fd75SYan, Zheng return 0; 3184ad48fd75SYan, Zheng err: 3185ad48fd75SYan, Zheng path->keep_locks = 0; 3186ad48fd75SYan, Zheng return ret; 3187ad48fd75SYan, Zheng } 3188ad48fd75SYan, Zheng 3189ad48fd75SYan, Zheng static noinline int split_item(struct btrfs_trans_handle *trans, 3190459931ecSChris Mason struct btrfs_root *root, 3191459931ecSChris Mason struct btrfs_path *path, 3192459931ecSChris Mason struct btrfs_key *new_key, 3193459931ecSChris Mason unsigned long split_offset) 3194459931ecSChris Mason { 3195459931ecSChris Mason struct extent_buffer *leaf; 3196459931ecSChris Mason struct btrfs_item *item; 3197459931ecSChris Mason struct btrfs_item *new_item; 3198459931ecSChris Mason int slot; 3199ad48fd75SYan, Zheng char *buf; 3200459931ecSChris Mason u32 nritems; 3201ad48fd75SYan, Zheng u32 item_size; 3202459931ecSChris Mason u32 orig_offset; 3203459931ecSChris Mason struct btrfs_disk_key disk_key; 3204459931ecSChris Mason 3205459931ecSChris Mason leaf = path->nodes[0]; 3206b9473439SChris Mason BUG_ON(btrfs_leaf_free_space(root, leaf) < sizeof(struct btrfs_item)); 3207b9473439SChris Mason 3208b4ce94deSChris Mason btrfs_set_path_blocking(path); 3209b4ce94deSChris Mason 3210459931ecSChris Mason item = btrfs_item_nr(leaf, path->slots[0]); 3211459931ecSChris Mason orig_offset = btrfs_item_offset(leaf, item); 3212459931ecSChris Mason item_size = btrfs_item_size(leaf, item); 3213459931ecSChris Mason 3214459931ecSChris Mason buf = kmalloc(item_size, GFP_NOFS); 3215ad48fd75SYan, Zheng if (!buf) 3216ad48fd75SYan, Zheng return -ENOMEM; 3217ad48fd75SYan, Zheng 3218459931ecSChris Mason read_extent_buffer(leaf, buf, btrfs_item_ptr_offset(leaf, 3219459931ecSChris Mason path->slots[0]), item_size); 3220ad48fd75SYan, Zheng 3221459931ecSChris Mason slot = path->slots[0] + 1; 3222459931ecSChris Mason nritems = btrfs_header_nritems(leaf); 3223459931ecSChris Mason if (slot != nritems) { 3224459931ecSChris Mason /* shift the items */ 3225459931ecSChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + 1), 3226459931ecSChris Mason btrfs_item_nr_offset(slot), 3227459931ecSChris Mason (nritems - slot) * sizeof(struct btrfs_item)); 3228459931ecSChris Mason } 3229459931ecSChris Mason 3230459931ecSChris Mason btrfs_cpu_key_to_disk(&disk_key, new_key); 3231459931ecSChris Mason btrfs_set_item_key(leaf, &disk_key, slot); 3232459931ecSChris Mason 3233459931ecSChris Mason new_item = btrfs_item_nr(leaf, slot); 3234459931ecSChris Mason 3235459931ecSChris Mason btrfs_set_item_offset(leaf, new_item, orig_offset); 3236459931ecSChris Mason btrfs_set_item_size(leaf, new_item, item_size - split_offset); 3237459931ecSChris Mason 3238459931ecSChris Mason btrfs_set_item_offset(leaf, item, 3239459931ecSChris Mason orig_offset + item_size - split_offset); 3240459931ecSChris Mason btrfs_set_item_size(leaf, item, split_offset); 3241459931ecSChris Mason 3242459931ecSChris Mason btrfs_set_header_nritems(leaf, nritems + 1); 3243459931ecSChris Mason 3244459931ecSChris Mason /* write the data for the start of the original item */ 3245459931ecSChris Mason write_extent_buffer(leaf, buf, 3246459931ecSChris Mason btrfs_item_ptr_offset(leaf, path->slots[0]), 3247459931ecSChris Mason split_offset); 3248459931ecSChris Mason 3249459931ecSChris Mason /* write the data for the new item */ 3250459931ecSChris Mason write_extent_buffer(leaf, buf + split_offset, 3251459931ecSChris Mason btrfs_item_ptr_offset(leaf, slot), 3252459931ecSChris Mason item_size - split_offset); 3253459931ecSChris Mason btrfs_mark_buffer_dirty(leaf); 3254459931ecSChris Mason 3255ad48fd75SYan, Zheng BUG_ON(btrfs_leaf_free_space(root, leaf) < 0); 3256459931ecSChris Mason kfree(buf); 3257ad48fd75SYan, Zheng return 0; 3258ad48fd75SYan, Zheng } 3259ad48fd75SYan, Zheng 3260ad48fd75SYan, Zheng /* 3261ad48fd75SYan, Zheng * This function splits a single item into two items, 3262ad48fd75SYan, Zheng * giving 'new_key' to the new item and splitting the 3263ad48fd75SYan, Zheng * old one at split_offset (from the start of the item). 3264ad48fd75SYan, Zheng * 3265ad48fd75SYan, Zheng * The path may be released by this operation. After 3266ad48fd75SYan, Zheng * the split, the path is pointing to the old item. The 3267ad48fd75SYan, Zheng * new item is going to be in the same node as the old one. 3268ad48fd75SYan, Zheng * 3269ad48fd75SYan, Zheng * Note, the item being split must be smaller enough to live alone on 3270ad48fd75SYan, Zheng * a tree block with room for one extra struct btrfs_item 3271ad48fd75SYan, Zheng * 3272ad48fd75SYan, Zheng * This allows us to split the item in place, keeping a lock on the 3273ad48fd75SYan, Zheng * leaf the entire time. 3274ad48fd75SYan, Zheng */ 3275ad48fd75SYan, Zheng int btrfs_split_item(struct btrfs_trans_handle *trans, 3276ad48fd75SYan, Zheng struct btrfs_root *root, 3277ad48fd75SYan, Zheng struct btrfs_path *path, 3278ad48fd75SYan, Zheng struct btrfs_key *new_key, 3279ad48fd75SYan, Zheng unsigned long split_offset) 3280ad48fd75SYan, Zheng { 3281ad48fd75SYan, Zheng int ret; 3282ad48fd75SYan, Zheng ret = setup_leaf_for_split(trans, root, path, 3283ad48fd75SYan, Zheng sizeof(struct btrfs_item)); 3284ad48fd75SYan, Zheng if (ret) 3285459931ecSChris Mason return ret; 3286ad48fd75SYan, Zheng 3287ad48fd75SYan, Zheng ret = split_item(trans, root, path, new_key, split_offset); 3288ad48fd75SYan, Zheng return ret; 3289ad48fd75SYan, Zheng } 3290ad48fd75SYan, Zheng 3291ad48fd75SYan, Zheng /* 3292ad48fd75SYan, Zheng * This function duplicate a item, giving 'new_key' to the new item. 3293ad48fd75SYan, Zheng * It guarantees both items live in the same tree leaf and the new item 3294ad48fd75SYan, Zheng * is contiguous with the original item. 3295ad48fd75SYan, Zheng * 3296ad48fd75SYan, Zheng * This allows us to split file extent in place, keeping a lock on the 3297ad48fd75SYan, Zheng * leaf the entire time. 3298ad48fd75SYan, Zheng */ 3299ad48fd75SYan, Zheng int btrfs_duplicate_item(struct btrfs_trans_handle *trans, 3300ad48fd75SYan, Zheng struct btrfs_root *root, 3301ad48fd75SYan, Zheng struct btrfs_path *path, 3302ad48fd75SYan, Zheng struct btrfs_key *new_key) 3303ad48fd75SYan, Zheng { 3304ad48fd75SYan, Zheng struct extent_buffer *leaf; 3305ad48fd75SYan, Zheng int ret; 3306ad48fd75SYan, Zheng u32 item_size; 3307ad48fd75SYan, Zheng 3308ad48fd75SYan, Zheng leaf = path->nodes[0]; 3309ad48fd75SYan, Zheng item_size = btrfs_item_size_nr(leaf, path->slots[0]); 3310ad48fd75SYan, Zheng ret = setup_leaf_for_split(trans, root, path, 3311ad48fd75SYan, Zheng item_size + sizeof(struct btrfs_item)); 3312ad48fd75SYan, Zheng if (ret) 3313ad48fd75SYan, Zheng return ret; 3314ad48fd75SYan, Zheng 3315ad48fd75SYan, Zheng path->slots[0]++; 3316ad48fd75SYan, Zheng ret = setup_items_for_insert(trans, root, path, new_key, &item_size, 3317ad48fd75SYan, Zheng item_size, item_size + 3318ad48fd75SYan, Zheng sizeof(struct btrfs_item), 1); 3319ad48fd75SYan, Zheng BUG_ON(ret); 3320ad48fd75SYan, Zheng 3321ad48fd75SYan, Zheng leaf = path->nodes[0]; 3322ad48fd75SYan, Zheng memcpy_extent_buffer(leaf, 3323ad48fd75SYan, Zheng btrfs_item_ptr_offset(leaf, path->slots[0]), 3324ad48fd75SYan, Zheng btrfs_item_ptr_offset(leaf, path->slots[0] - 1), 3325ad48fd75SYan, Zheng item_size); 3326ad48fd75SYan, Zheng return 0; 3327459931ecSChris Mason } 3328459931ecSChris Mason 3329459931ecSChris Mason /* 3330d352ac68SChris Mason * make the item pointed to by the path smaller. new_size indicates 3331d352ac68SChris Mason * how small to make it, and from_end tells us if we just chop bytes 3332d352ac68SChris Mason * off the end of the item or if we shift the item to chop bytes off 3333d352ac68SChris Mason * the front. 3334d352ac68SChris Mason */ 3335b18c6685SChris Mason int btrfs_truncate_item(struct btrfs_trans_handle *trans, 3336b18c6685SChris Mason struct btrfs_root *root, 3337b18c6685SChris Mason struct btrfs_path *path, 3338179e29e4SChris Mason u32 new_size, int from_end) 3339b18c6685SChris Mason { 3340b18c6685SChris Mason int ret = 0; 3341b18c6685SChris Mason int slot; 33425f39d397SChris Mason struct extent_buffer *leaf; 33435f39d397SChris Mason struct btrfs_item *item; 3344b18c6685SChris Mason u32 nritems; 3345b18c6685SChris Mason unsigned int data_end; 3346b18c6685SChris Mason unsigned int old_data_start; 3347b18c6685SChris Mason unsigned int old_size; 3348b18c6685SChris Mason unsigned int size_diff; 3349b18c6685SChris Mason int i; 3350b18c6685SChris Mason 33515f39d397SChris Mason leaf = path->nodes[0]; 3352179e29e4SChris Mason slot = path->slots[0]; 3353179e29e4SChris Mason 3354179e29e4SChris Mason old_size = btrfs_item_size_nr(leaf, slot); 3355179e29e4SChris Mason if (old_size == new_size) 3356179e29e4SChris Mason return 0; 3357b18c6685SChris Mason 33585f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3359b18c6685SChris Mason data_end = leaf_data_end(root, leaf); 3360b18c6685SChris Mason 33615f39d397SChris Mason old_data_start = btrfs_item_offset_nr(leaf, slot); 3362179e29e4SChris Mason 3363b18c6685SChris Mason size_diff = old_size - new_size; 3364b18c6685SChris Mason 3365b18c6685SChris Mason BUG_ON(slot < 0); 3366b18c6685SChris Mason BUG_ON(slot >= nritems); 3367b18c6685SChris Mason 3368b18c6685SChris Mason /* 3369b18c6685SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 3370b18c6685SChris Mason */ 3371b18c6685SChris Mason /* first correct the data pointers */ 3372b18c6685SChris Mason for (i = slot; i < nritems; i++) { 33735f39d397SChris Mason u32 ioff; 33745f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3375db94535dSChris Mason 3376db94535dSChris Mason if (!leaf->map_token) { 3377db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3378db94535dSChris Mason sizeof(struct btrfs_item), 3379db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3380db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3381db94535dSChris Mason KM_USER1); 3382db94535dSChris Mason } 3383db94535dSChris Mason 33845f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 33855f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff + size_diff); 3386b18c6685SChris Mason } 3387db94535dSChris Mason 3388db94535dSChris Mason if (leaf->map_token) { 3389db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3390db94535dSChris Mason leaf->map_token = NULL; 3391db94535dSChris Mason } 3392db94535dSChris Mason 3393b18c6685SChris Mason /* shift the data */ 3394179e29e4SChris Mason if (from_end) { 33955f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3396b18c6685SChris Mason data_end + size_diff, btrfs_leaf_data(leaf) + 3397b18c6685SChris Mason data_end, old_data_start + new_size - data_end); 3398179e29e4SChris Mason } else { 3399179e29e4SChris Mason struct btrfs_disk_key disk_key; 3400179e29e4SChris Mason u64 offset; 3401179e29e4SChris Mason 3402179e29e4SChris Mason btrfs_item_key(leaf, &disk_key, slot); 3403179e29e4SChris Mason 3404179e29e4SChris Mason if (btrfs_disk_key_type(&disk_key) == BTRFS_EXTENT_DATA_KEY) { 3405179e29e4SChris Mason unsigned long ptr; 3406179e29e4SChris Mason struct btrfs_file_extent_item *fi; 3407179e29e4SChris Mason 3408179e29e4SChris Mason fi = btrfs_item_ptr(leaf, slot, 3409179e29e4SChris Mason struct btrfs_file_extent_item); 3410179e29e4SChris Mason fi = (struct btrfs_file_extent_item *)( 3411179e29e4SChris Mason (unsigned long)fi - size_diff); 3412179e29e4SChris Mason 3413179e29e4SChris Mason if (btrfs_file_extent_type(leaf, fi) == 3414179e29e4SChris Mason BTRFS_FILE_EXTENT_INLINE) { 3415179e29e4SChris Mason ptr = btrfs_item_ptr_offset(leaf, slot); 3416179e29e4SChris Mason memmove_extent_buffer(leaf, ptr, 3417179e29e4SChris Mason (unsigned long)fi, 3418179e29e4SChris Mason offsetof(struct btrfs_file_extent_item, 3419179e29e4SChris Mason disk_bytenr)); 3420179e29e4SChris Mason } 3421179e29e4SChris Mason } 3422179e29e4SChris Mason 3423179e29e4SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3424179e29e4SChris Mason data_end + size_diff, btrfs_leaf_data(leaf) + 3425179e29e4SChris Mason data_end, old_data_start - data_end); 3426179e29e4SChris Mason 3427179e29e4SChris Mason offset = btrfs_disk_key_offset(&disk_key); 3428179e29e4SChris Mason btrfs_set_disk_key_offset(&disk_key, offset + size_diff); 3429179e29e4SChris Mason btrfs_set_item_key(leaf, &disk_key, slot); 3430179e29e4SChris Mason if (slot == 0) 3431179e29e4SChris Mason fixup_low_keys(trans, root, path, &disk_key, 1); 3432179e29e4SChris Mason } 34335f39d397SChris Mason 34345f39d397SChris Mason item = btrfs_item_nr(leaf, slot); 34355f39d397SChris Mason btrfs_set_item_size(leaf, item, new_size); 34365f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 3437b18c6685SChris Mason 3438b18c6685SChris Mason ret = 0; 34395f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 34405f39d397SChris Mason btrfs_print_leaf(root, leaf); 3441b18c6685SChris Mason BUG(); 34425f39d397SChris Mason } 3443b18c6685SChris Mason return ret; 3444b18c6685SChris Mason } 3445b18c6685SChris Mason 3446d352ac68SChris Mason /* 3447d352ac68SChris Mason * make the item pointed to by the path bigger, data_size is the new size. 3448d352ac68SChris Mason */ 34495f39d397SChris Mason int btrfs_extend_item(struct btrfs_trans_handle *trans, 34505f39d397SChris Mason struct btrfs_root *root, struct btrfs_path *path, 34515f39d397SChris Mason u32 data_size) 34526567e837SChris Mason { 34536567e837SChris Mason int ret = 0; 34546567e837SChris Mason int slot; 34555f39d397SChris Mason struct extent_buffer *leaf; 34565f39d397SChris Mason struct btrfs_item *item; 34576567e837SChris Mason u32 nritems; 34586567e837SChris Mason unsigned int data_end; 34596567e837SChris Mason unsigned int old_data; 34606567e837SChris Mason unsigned int old_size; 34616567e837SChris Mason int i; 34626567e837SChris Mason 34635f39d397SChris Mason leaf = path->nodes[0]; 34646567e837SChris Mason 34655f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 34666567e837SChris Mason data_end = leaf_data_end(root, leaf); 34676567e837SChris Mason 34685f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < data_size) { 34695f39d397SChris Mason btrfs_print_leaf(root, leaf); 34706567e837SChris Mason BUG(); 34715f39d397SChris Mason } 34726567e837SChris Mason slot = path->slots[0]; 34735f39d397SChris Mason old_data = btrfs_item_end_nr(leaf, slot); 34746567e837SChris Mason 34756567e837SChris Mason BUG_ON(slot < 0); 34763326d1b0SChris Mason if (slot >= nritems) { 34773326d1b0SChris Mason btrfs_print_leaf(root, leaf); 3478d397712bSChris Mason printk(KERN_CRIT "slot %d too large, nritems %d\n", 3479d397712bSChris Mason slot, nritems); 34803326d1b0SChris Mason BUG_ON(1); 34813326d1b0SChris Mason } 34826567e837SChris Mason 34836567e837SChris Mason /* 34846567e837SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 34856567e837SChris Mason */ 34866567e837SChris Mason /* first correct the data pointers */ 34876567e837SChris Mason for (i = slot; i < nritems; i++) { 34885f39d397SChris Mason u32 ioff; 34895f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3490db94535dSChris Mason 3491db94535dSChris Mason if (!leaf->map_token) { 3492db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3493db94535dSChris Mason sizeof(struct btrfs_item), 3494db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3495db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3496db94535dSChris Mason KM_USER1); 3497db94535dSChris Mason } 34985f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 34995f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff - data_size); 35006567e837SChris Mason } 35015f39d397SChris Mason 3502db94535dSChris Mason if (leaf->map_token) { 3503db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3504db94535dSChris Mason leaf->map_token = NULL; 3505db94535dSChris Mason } 3506db94535dSChris Mason 35076567e837SChris Mason /* shift the data */ 35085f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 35096567e837SChris Mason data_end - data_size, btrfs_leaf_data(leaf) + 35106567e837SChris Mason data_end, old_data - data_end); 35115f39d397SChris Mason 35126567e837SChris Mason data_end = old_data; 35135f39d397SChris Mason old_size = btrfs_item_size_nr(leaf, slot); 35145f39d397SChris Mason item = btrfs_item_nr(leaf, slot); 35155f39d397SChris Mason btrfs_set_item_size(leaf, item, old_size + data_size); 35165f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 35176567e837SChris Mason 35186567e837SChris Mason ret = 0; 35195f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 35205f39d397SChris Mason btrfs_print_leaf(root, leaf); 35216567e837SChris Mason BUG(); 35225f39d397SChris Mason } 35236567e837SChris Mason return ret; 35246567e837SChris Mason } 35256567e837SChris Mason 352674123bd7SChris Mason /* 3527d352ac68SChris Mason * Given a key and some data, insert items into the tree. 352874123bd7SChris Mason * This does all the path init required, making room in the tree if needed. 3529f3465ca4SJosef Bacik * Returns the number of keys that were inserted. 3530f3465ca4SJosef Bacik */ 3531f3465ca4SJosef Bacik int btrfs_insert_some_items(struct btrfs_trans_handle *trans, 3532f3465ca4SJosef Bacik struct btrfs_root *root, 3533f3465ca4SJosef Bacik struct btrfs_path *path, 3534f3465ca4SJosef Bacik struct btrfs_key *cpu_key, u32 *data_size, 3535f3465ca4SJosef Bacik int nr) 3536f3465ca4SJosef Bacik { 3537f3465ca4SJosef Bacik struct extent_buffer *leaf; 3538f3465ca4SJosef Bacik struct btrfs_item *item; 3539f3465ca4SJosef Bacik int ret = 0; 3540f3465ca4SJosef Bacik int slot; 3541f3465ca4SJosef Bacik int i; 3542f3465ca4SJosef Bacik u32 nritems; 3543f3465ca4SJosef Bacik u32 total_data = 0; 3544f3465ca4SJosef Bacik u32 total_size = 0; 3545f3465ca4SJosef Bacik unsigned int data_end; 3546f3465ca4SJosef Bacik struct btrfs_disk_key disk_key; 3547f3465ca4SJosef Bacik struct btrfs_key found_key; 3548f3465ca4SJosef Bacik 354987b29b20SYan Zheng for (i = 0; i < nr; i++) { 355087b29b20SYan Zheng if (total_size + data_size[i] + sizeof(struct btrfs_item) > 355187b29b20SYan Zheng BTRFS_LEAF_DATA_SIZE(root)) { 355287b29b20SYan Zheng break; 355387b29b20SYan Zheng nr = i; 355487b29b20SYan Zheng } 3555f3465ca4SJosef Bacik total_data += data_size[i]; 355687b29b20SYan Zheng total_size += data_size[i] + sizeof(struct btrfs_item); 355787b29b20SYan Zheng } 355887b29b20SYan Zheng BUG_ON(nr == 0); 3559f3465ca4SJosef Bacik 3560f3465ca4SJosef Bacik ret = btrfs_search_slot(trans, root, cpu_key, path, total_size, 1); 3561f3465ca4SJosef Bacik if (ret == 0) 3562f3465ca4SJosef Bacik return -EEXIST; 3563f3465ca4SJosef Bacik if (ret < 0) 3564f3465ca4SJosef Bacik goto out; 3565f3465ca4SJosef Bacik 3566f3465ca4SJosef Bacik leaf = path->nodes[0]; 3567f3465ca4SJosef Bacik 3568f3465ca4SJosef Bacik nritems = btrfs_header_nritems(leaf); 3569f3465ca4SJosef Bacik data_end = leaf_data_end(root, leaf); 3570f3465ca4SJosef Bacik 3571f3465ca4SJosef Bacik if (btrfs_leaf_free_space(root, leaf) < total_size) { 3572f3465ca4SJosef Bacik for (i = nr; i >= 0; i--) { 3573f3465ca4SJosef Bacik total_data -= data_size[i]; 3574f3465ca4SJosef Bacik total_size -= data_size[i] + sizeof(struct btrfs_item); 3575f3465ca4SJosef Bacik if (total_size < btrfs_leaf_free_space(root, leaf)) 3576f3465ca4SJosef Bacik break; 3577f3465ca4SJosef Bacik } 3578f3465ca4SJosef Bacik nr = i; 3579f3465ca4SJosef Bacik } 3580f3465ca4SJosef Bacik 3581f3465ca4SJosef Bacik slot = path->slots[0]; 3582f3465ca4SJosef Bacik BUG_ON(slot < 0); 3583f3465ca4SJosef Bacik 3584f3465ca4SJosef Bacik if (slot != nritems) { 3585f3465ca4SJosef Bacik unsigned int old_data = btrfs_item_end_nr(leaf, slot); 3586f3465ca4SJosef Bacik 3587f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, slot); 3588f3465ca4SJosef Bacik btrfs_item_key_to_cpu(leaf, &found_key, slot); 3589f3465ca4SJosef Bacik 3590f3465ca4SJosef Bacik /* figure out how many keys we can insert in here */ 3591f3465ca4SJosef Bacik total_data = data_size[0]; 3592f3465ca4SJosef Bacik for (i = 1; i < nr; i++) { 35935d4f98a2SYan Zheng if (btrfs_comp_cpu_keys(&found_key, cpu_key + i) <= 0) 3594f3465ca4SJosef Bacik break; 3595f3465ca4SJosef Bacik total_data += data_size[i]; 3596f3465ca4SJosef Bacik } 3597f3465ca4SJosef Bacik nr = i; 3598f3465ca4SJosef Bacik 3599f3465ca4SJosef Bacik if (old_data < data_end) { 3600f3465ca4SJosef Bacik btrfs_print_leaf(root, leaf); 3601d397712bSChris Mason printk(KERN_CRIT "slot %d old_data %d data_end %d\n", 3602f3465ca4SJosef Bacik slot, old_data, data_end); 3603f3465ca4SJosef Bacik BUG_ON(1); 3604f3465ca4SJosef Bacik } 3605f3465ca4SJosef Bacik /* 3606f3465ca4SJosef Bacik * item0..itemN ... dataN.offset..dataN.size .. data0.size 3607f3465ca4SJosef Bacik */ 3608f3465ca4SJosef Bacik /* first correct the data pointers */ 3609f3465ca4SJosef Bacik WARN_ON(leaf->map_token); 3610f3465ca4SJosef Bacik for (i = slot; i < nritems; i++) { 3611f3465ca4SJosef Bacik u32 ioff; 3612f3465ca4SJosef Bacik 3613f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, i); 3614f3465ca4SJosef Bacik if (!leaf->map_token) { 3615f3465ca4SJosef Bacik map_extent_buffer(leaf, (unsigned long)item, 3616f3465ca4SJosef Bacik sizeof(struct btrfs_item), 3617f3465ca4SJosef Bacik &leaf->map_token, &leaf->kaddr, 3618f3465ca4SJosef Bacik &leaf->map_start, &leaf->map_len, 3619f3465ca4SJosef Bacik KM_USER1); 3620f3465ca4SJosef Bacik } 3621f3465ca4SJosef Bacik 3622f3465ca4SJosef Bacik ioff = btrfs_item_offset(leaf, item); 3623f3465ca4SJosef Bacik btrfs_set_item_offset(leaf, item, ioff - total_data); 3624f3465ca4SJosef Bacik } 3625f3465ca4SJosef Bacik if (leaf->map_token) { 3626f3465ca4SJosef Bacik unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3627f3465ca4SJosef Bacik leaf->map_token = NULL; 3628f3465ca4SJosef Bacik } 3629f3465ca4SJosef Bacik 3630f3465ca4SJosef Bacik /* shift the items */ 3631f3465ca4SJosef Bacik memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + nr), 3632f3465ca4SJosef Bacik btrfs_item_nr_offset(slot), 3633f3465ca4SJosef Bacik (nritems - slot) * sizeof(struct btrfs_item)); 3634f3465ca4SJosef Bacik 3635f3465ca4SJosef Bacik /* shift the data */ 3636f3465ca4SJosef Bacik memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3637f3465ca4SJosef Bacik data_end - total_data, btrfs_leaf_data(leaf) + 3638f3465ca4SJosef Bacik data_end, old_data - data_end); 3639f3465ca4SJosef Bacik data_end = old_data; 3640f3465ca4SJosef Bacik } else { 3641f3465ca4SJosef Bacik /* 3642f3465ca4SJosef Bacik * this sucks but it has to be done, if we are inserting at 3643f3465ca4SJosef Bacik * the end of the leaf only insert 1 of the items, since we 3644f3465ca4SJosef Bacik * have no way of knowing whats on the next leaf and we'd have 3645f3465ca4SJosef Bacik * to drop our current locks to figure it out 3646f3465ca4SJosef Bacik */ 3647f3465ca4SJosef Bacik nr = 1; 3648f3465ca4SJosef Bacik } 3649f3465ca4SJosef Bacik 3650f3465ca4SJosef Bacik /* setup the item for the new data */ 3651f3465ca4SJosef Bacik for (i = 0; i < nr; i++) { 3652f3465ca4SJosef Bacik btrfs_cpu_key_to_disk(&disk_key, cpu_key + i); 3653f3465ca4SJosef Bacik btrfs_set_item_key(leaf, &disk_key, slot + i); 3654f3465ca4SJosef Bacik item = btrfs_item_nr(leaf, slot + i); 3655f3465ca4SJosef Bacik btrfs_set_item_offset(leaf, item, data_end - data_size[i]); 3656f3465ca4SJosef Bacik data_end -= data_size[i]; 3657f3465ca4SJosef Bacik btrfs_set_item_size(leaf, item, data_size[i]); 3658f3465ca4SJosef Bacik } 3659f3465ca4SJosef Bacik btrfs_set_header_nritems(leaf, nritems + nr); 3660f3465ca4SJosef Bacik btrfs_mark_buffer_dirty(leaf); 3661f3465ca4SJosef Bacik 3662f3465ca4SJosef Bacik ret = 0; 3663f3465ca4SJosef Bacik if (slot == 0) { 3664f3465ca4SJosef Bacik btrfs_cpu_key_to_disk(&disk_key, cpu_key); 3665f3465ca4SJosef Bacik ret = fixup_low_keys(trans, root, path, &disk_key, 1); 3666f3465ca4SJosef Bacik } 3667f3465ca4SJosef Bacik 3668f3465ca4SJosef Bacik if (btrfs_leaf_free_space(root, leaf) < 0) { 3669f3465ca4SJosef Bacik btrfs_print_leaf(root, leaf); 3670f3465ca4SJosef Bacik BUG(); 3671f3465ca4SJosef Bacik } 3672f3465ca4SJosef Bacik out: 3673f3465ca4SJosef Bacik if (!ret) 3674f3465ca4SJosef Bacik ret = nr; 3675f3465ca4SJosef Bacik return ret; 3676f3465ca4SJosef Bacik } 3677f3465ca4SJosef Bacik 3678f3465ca4SJosef Bacik /* 367944871b1bSChris Mason * this is a helper for btrfs_insert_empty_items, the main goal here is 368044871b1bSChris Mason * to save stack depth by doing the bulk of the work in a function 368144871b1bSChris Mason * that doesn't call btrfs_search_slot 368274123bd7SChris Mason */ 368344871b1bSChris Mason static noinline_for_stack int 368444871b1bSChris Mason setup_items_for_insert(struct btrfs_trans_handle *trans, 368544871b1bSChris Mason struct btrfs_root *root, struct btrfs_path *path, 36869c58309dSChris Mason struct btrfs_key *cpu_key, u32 *data_size, 368744871b1bSChris Mason u32 total_data, u32 total_size, int nr) 3688be0e5c09SChris Mason { 36895f39d397SChris Mason struct btrfs_item *item; 36909c58309dSChris Mason int i; 36917518a238SChris Mason u32 nritems; 3692be0e5c09SChris Mason unsigned int data_end; 3693e2fa7227SChris Mason struct btrfs_disk_key disk_key; 369444871b1bSChris Mason int ret; 369544871b1bSChris Mason struct extent_buffer *leaf; 369644871b1bSChris Mason int slot; 3697e2fa7227SChris Mason 36985f39d397SChris Mason leaf = path->nodes[0]; 369944871b1bSChris Mason slot = path->slots[0]; 370074123bd7SChris Mason 37015f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3702123abc88SChris Mason data_end = leaf_data_end(root, leaf); 3703eb60ceacSChris Mason 3704f25956ccSChris Mason if (btrfs_leaf_free_space(root, leaf) < total_size) { 37053326d1b0SChris Mason btrfs_print_leaf(root, leaf); 3706d397712bSChris Mason printk(KERN_CRIT "not enough freespace need %u have %d\n", 37079c58309dSChris Mason total_size, btrfs_leaf_free_space(root, leaf)); 3708be0e5c09SChris Mason BUG(); 3709d4dbff95SChris Mason } 37105f39d397SChris Mason 3711be0e5c09SChris Mason if (slot != nritems) { 37125f39d397SChris Mason unsigned int old_data = btrfs_item_end_nr(leaf, slot); 3713be0e5c09SChris Mason 37145f39d397SChris Mason if (old_data < data_end) { 37155f39d397SChris Mason btrfs_print_leaf(root, leaf); 3716d397712bSChris Mason printk(KERN_CRIT "slot %d old_data %d data_end %d\n", 37175f39d397SChris Mason slot, old_data, data_end); 37185f39d397SChris Mason BUG_ON(1); 37195f39d397SChris Mason } 3720be0e5c09SChris Mason /* 3721be0e5c09SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 3722be0e5c09SChris Mason */ 3723be0e5c09SChris Mason /* first correct the data pointers */ 3724db94535dSChris Mason WARN_ON(leaf->map_token); 37250783fcfcSChris Mason for (i = slot; i < nritems; i++) { 37265f39d397SChris Mason u32 ioff; 3727db94535dSChris Mason 37285f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3729db94535dSChris Mason if (!leaf->map_token) { 3730db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3731db94535dSChris Mason sizeof(struct btrfs_item), 3732db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3733db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3734db94535dSChris Mason KM_USER1); 3735db94535dSChris Mason } 3736db94535dSChris Mason 37375f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 37389c58309dSChris Mason btrfs_set_item_offset(leaf, item, ioff - total_data); 37390783fcfcSChris Mason } 3740db94535dSChris Mason if (leaf->map_token) { 3741db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3742db94535dSChris Mason leaf->map_token = NULL; 3743db94535dSChris Mason } 3744be0e5c09SChris Mason 3745be0e5c09SChris Mason /* shift the items */ 37469c58309dSChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + nr), 37475f39d397SChris Mason btrfs_item_nr_offset(slot), 37480783fcfcSChris Mason (nritems - slot) * sizeof(struct btrfs_item)); 3749be0e5c09SChris Mason 3750be0e5c09SChris Mason /* shift the data */ 37515f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 37529c58309dSChris Mason data_end - total_data, btrfs_leaf_data(leaf) + 3753be0e5c09SChris Mason data_end, old_data - data_end); 3754be0e5c09SChris Mason data_end = old_data; 3755be0e5c09SChris Mason } 37565f39d397SChris Mason 375762e2749eSChris Mason /* setup the item for the new data */ 37589c58309dSChris Mason for (i = 0; i < nr; i++) { 37599c58309dSChris Mason btrfs_cpu_key_to_disk(&disk_key, cpu_key + i); 37609c58309dSChris Mason btrfs_set_item_key(leaf, &disk_key, slot + i); 37619c58309dSChris Mason item = btrfs_item_nr(leaf, slot + i); 37629c58309dSChris Mason btrfs_set_item_offset(leaf, item, data_end - data_size[i]); 37639c58309dSChris Mason data_end -= data_size[i]; 37649c58309dSChris Mason btrfs_set_item_size(leaf, item, data_size[i]); 37659c58309dSChris Mason } 376644871b1bSChris Mason 37679c58309dSChris Mason btrfs_set_header_nritems(leaf, nritems + nr); 3768aa5d6bedSChris Mason 3769aa5d6bedSChris Mason ret = 0; 37705a01a2e3SChris Mason if (slot == 0) { 377144871b1bSChris Mason struct btrfs_disk_key disk_key; 37725a01a2e3SChris Mason btrfs_cpu_key_to_disk(&disk_key, cpu_key); 3773e089f05cSChris Mason ret = fixup_low_keys(trans, root, path, &disk_key, 1); 37745a01a2e3SChris Mason } 3775b9473439SChris Mason btrfs_unlock_up_safe(path, 1); 3776b9473439SChris Mason btrfs_mark_buffer_dirty(leaf); 3777aa5d6bedSChris Mason 37785f39d397SChris Mason if (btrfs_leaf_free_space(root, leaf) < 0) { 37795f39d397SChris Mason btrfs_print_leaf(root, leaf); 3780be0e5c09SChris Mason BUG(); 37815f39d397SChris Mason } 378244871b1bSChris Mason return ret; 378344871b1bSChris Mason } 378444871b1bSChris Mason 378544871b1bSChris Mason /* 378644871b1bSChris Mason * Given a key and some data, insert items into the tree. 378744871b1bSChris Mason * This does all the path init required, making room in the tree if needed. 378844871b1bSChris Mason */ 378944871b1bSChris Mason int btrfs_insert_empty_items(struct btrfs_trans_handle *trans, 379044871b1bSChris Mason struct btrfs_root *root, 379144871b1bSChris Mason struct btrfs_path *path, 379244871b1bSChris Mason struct btrfs_key *cpu_key, u32 *data_size, 379344871b1bSChris Mason int nr) 379444871b1bSChris Mason { 379544871b1bSChris Mason int ret = 0; 379644871b1bSChris Mason int slot; 379744871b1bSChris Mason int i; 379844871b1bSChris Mason u32 total_size = 0; 379944871b1bSChris Mason u32 total_data = 0; 380044871b1bSChris Mason 380144871b1bSChris Mason for (i = 0; i < nr; i++) 380244871b1bSChris Mason total_data += data_size[i]; 380344871b1bSChris Mason 380444871b1bSChris Mason total_size = total_data + (nr * sizeof(struct btrfs_item)); 380544871b1bSChris Mason ret = btrfs_search_slot(trans, root, cpu_key, path, total_size, 1); 380644871b1bSChris Mason if (ret == 0) 380744871b1bSChris Mason return -EEXIST; 380844871b1bSChris Mason if (ret < 0) 380944871b1bSChris Mason goto out; 381044871b1bSChris Mason 381144871b1bSChris Mason slot = path->slots[0]; 381244871b1bSChris Mason BUG_ON(slot < 0); 381344871b1bSChris Mason 381444871b1bSChris Mason ret = setup_items_for_insert(trans, root, path, cpu_key, data_size, 381544871b1bSChris Mason total_data, total_size, nr); 381644871b1bSChris Mason 3817ed2ff2cbSChris Mason out: 381862e2749eSChris Mason return ret; 381962e2749eSChris Mason } 382062e2749eSChris Mason 382162e2749eSChris Mason /* 382262e2749eSChris Mason * Given a key and some data, insert an item into the tree. 382362e2749eSChris Mason * This does all the path init required, making room in the tree if needed. 382462e2749eSChris Mason */ 3825e089f05cSChris Mason int btrfs_insert_item(struct btrfs_trans_handle *trans, struct btrfs_root 3826e089f05cSChris Mason *root, struct btrfs_key *cpu_key, void *data, u32 3827e089f05cSChris Mason data_size) 382862e2749eSChris Mason { 382962e2749eSChris Mason int ret = 0; 38302c90e5d6SChris Mason struct btrfs_path *path; 38315f39d397SChris Mason struct extent_buffer *leaf; 38325f39d397SChris Mason unsigned long ptr; 383362e2749eSChris Mason 38342c90e5d6SChris Mason path = btrfs_alloc_path(); 38352c90e5d6SChris Mason BUG_ON(!path); 38362c90e5d6SChris Mason ret = btrfs_insert_empty_item(trans, root, path, cpu_key, data_size); 383762e2749eSChris Mason if (!ret) { 38385f39d397SChris Mason leaf = path->nodes[0]; 38395f39d397SChris Mason ptr = btrfs_item_ptr_offset(leaf, path->slots[0]); 38405f39d397SChris Mason write_extent_buffer(leaf, data, ptr, data_size); 38415f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 384262e2749eSChris Mason } 38432c90e5d6SChris Mason btrfs_free_path(path); 3844aa5d6bedSChris Mason return ret; 3845be0e5c09SChris Mason } 3846be0e5c09SChris Mason 384774123bd7SChris Mason /* 38485de08d7dSChris Mason * delete the pointer from a given node. 384974123bd7SChris Mason * 3850d352ac68SChris Mason * the tree should have been previously balanced so the deletion does not 3851d352ac68SChris Mason * empty a node. 385274123bd7SChris Mason */ 3853e089f05cSChris Mason static int del_ptr(struct btrfs_trans_handle *trans, struct btrfs_root *root, 3854e089f05cSChris Mason struct btrfs_path *path, int level, int slot) 3855be0e5c09SChris Mason { 38565f39d397SChris Mason struct extent_buffer *parent = path->nodes[level]; 38577518a238SChris Mason u32 nritems; 3858aa5d6bedSChris Mason int ret = 0; 3859bb803951SChris Mason int wret; 3860be0e5c09SChris Mason 38615f39d397SChris Mason nritems = btrfs_header_nritems(parent); 3862be0e5c09SChris Mason if (slot != nritems - 1) { 38635f39d397SChris Mason memmove_extent_buffer(parent, 38645f39d397SChris Mason btrfs_node_key_ptr_offset(slot), 38655f39d397SChris Mason btrfs_node_key_ptr_offset(slot + 1), 3866d6025579SChris Mason sizeof(struct btrfs_key_ptr) * 3867d6025579SChris Mason (nritems - slot - 1)); 3868be0e5c09SChris Mason } 38697518a238SChris Mason nritems--; 38705f39d397SChris Mason btrfs_set_header_nritems(parent, nritems); 38717518a238SChris Mason if (nritems == 0 && parent == root->node) { 38725f39d397SChris Mason BUG_ON(btrfs_header_level(root->node) != 1); 3873eb60ceacSChris Mason /* just turn the root into a leaf and break */ 38745f39d397SChris Mason btrfs_set_header_level(root->node, 0); 3875bb803951SChris Mason } else if (slot == 0) { 38765f39d397SChris Mason struct btrfs_disk_key disk_key; 38775f39d397SChris Mason 38785f39d397SChris Mason btrfs_node_key(parent, &disk_key, 0); 38795f39d397SChris Mason wret = fixup_low_keys(trans, root, path, &disk_key, level + 1); 38800f70abe2SChris Mason if (wret) 38810f70abe2SChris Mason ret = wret; 3882be0e5c09SChris Mason } 3883d6025579SChris Mason btrfs_mark_buffer_dirty(parent); 3884aa5d6bedSChris Mason return ret; 3885be0e5c09SChris Mason } 3886be0e5c09SChris Mason 388774123bd7SChris Mason /* 3888323ac95bSChris Mason * a helper function to delete the leaf pointed to by path->slots[1] and 38895d4f98a2SYan Zheng * path->nodes[1]. 3890323ac95bSChris Mason * 3891323ac95bSChris Mason * This deletes the pointer in path->nodes[1] and frees the leaf 3892323ac95bSChris Mason * block extent. zero is returned if it all worked out, < 0 otherwise. 3893323ac95bSChris Mason * 3894323ac95bSChris Mason * The path must have already been setup for deleting the leaf, including 3895323ac95bSChris Mason * all the proper balancing. path->nodes[1] must be locked. 3896323ac95bSChris Mason */ 38975d4f98a2SYan Zheng static noinline int btrfs_del_leaf(struct btrfs_trans_handle *trans, 3898323ac95bSChris Mason struct btrfs_root *root, 38995d4f98a2SYan Zheng struct btrfs_path *path, 39005d4f98a2SYan Zheng struct extent_buffer *leaf) 3901323ac95bSChris Mason { 3902323ac95bSChris Mason int ret; 3903323ac95bSChris Mason 39045d4f98a2SYan Zheng WARN_ON(btrfs_header_generation(leaf) != trans->transid); 3905323ac95bSChris Mason ret = del_ptr(trans, root, path, 1, path->slots[1]); 3906323ac95bSChris Mason if (ret) 3907323ac95bSChris Mason return ret; 3908323ac95bSChris Mason 39094d081c41SChris Mason /* 39104d081c41SChris Mason * btrfs_free_extent is expensive, we want to make sure we 39114d081c41SChris Mason * aren't holding any locks when we call it 39124d081c41SChris Mason */ 39134d081c41SChris Mason btrfs_unlock_up_safe(path, 0); 39144d081c41SChris Mason 3915f0486c68SYan, Zheng root_sub_used(root, leaf->len); 3916f0486c68SYan, Zheng 3917f0486c68SYan, Zheng btrfs_free_tree_block(trans, root, leaf, 0, 1); 3918f0486c68SYan, Zheng return 0; 3919323ac95bSChris Mason } 3920323ac95bSChris Mason /* 392174123bd7SChris Mason * delete the item at the leaf level in path. If that empties 392274123bd7SChris Mason * the leaf, remove it from the tree 392374123bd7SChris Mason */ 392485e21bacSChris Mason int btrfs_del_items(struct btrfs_trans_handle *trans, struct btrfs_root *root, 392585e21bacSChris Mason struct btrfs_path *path, int slot, int nr) 3926be0e5c09SChris Mason { 39275f39d397SChris Mason struct extent_buffer *leaf; 39285f39d397SChris Mason struct btrfs_item *item; 392985e21bacSChris Mason int last_off; 393085e21bacSChris Mason int dsize = 0; 3931aa5d6bedSChris Mason int ret = 0; 3932aa5d6bedSChris Mason int wret; 393385e21bacSChris Mason int i; 39347518a238SChris Mason u32 nritems; 3935be0e5c09SChris Mason 39365f39d397SChris Mason leaf = path->nodes[0]; 393785e21bacSChris Mason last_off = btrfs_item_offset_nr(leaf, slot + nr - 1); 393885e21bacSChris Mason 393985e21bacSChris Mason for (i = 0; i < nr; i++) 394085e21bacSChris Mason dsize += btrfs_item_size_nr(leaf, slot + i); 394185e21bacSChris Mason 39425f39d397SChris Mason nritems = btrfs_header_nritems(leaf); 3943be0e5c09SChris Mason 394485e21bacSChris Mason if (slot + nr != nritems) { 3945123abc88SChris Mason int data_end = leaf_data_end(root, leaf); 39465f39d397SChris Mason 39475f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) + 3948d6025579SChris Mason data_end + dsize, 3949123abc88SChris Mason btrfs_leaf_data(leaf) + data_end, 395085e21bacSChris Mason last_off - data_end); 39515f39d397SChris Mason 395285e21bacSChris Mason for (i = slot + nr; i < nritems; i++) { 39535f39d397SChris Mason u32 ioff; 3954db94535dSChris Mason 39555f39d397SChris Mason item = btrfs_item_nr(leaf, i); 3956db94535dSChris Mason if (!leaf->map_token) { 3957db94535dSChris Mason map_extent_buffer(leaf, (unsigned long)item, 3958db94535dSChris Mason sizeof(struct btrfs_item), 3959db94535dSChris Mason &leaf->map_token, &leaf->kaddr, 3960db94535dSChris Mason &leaf->map_start, &leaf->map_len, 3961db94535dSChris Mason KM_USER1); 3962db94535dSChris Mason } 39635f39d397SChris Mason ioff = btrfs_item_offset(leaf, item); 39645f39d397SChris Mason btrfs_set_item_offset(leaf, item, ioff + dsize); 39650783fcfcSChris Mason } 3966db94535dSChris Mason 3967db94535dSChris Mason if (leaf->map_token) { 3968db94535dSChris Mason unmap_extent_buffer(leaf, leaf->map_token, KM_USER1); 3969db94535dSChris Mason leaf->map_token = NULL; 3970db94535dSChris Mason } 3971db94535dSChris Mason 39725f39d397SChris Mason memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot), 397385e21bacSChris Mason btrfs_item_nr_offset(slot + nr), 39740783fcfcSChris Mason sizeof(struct btrfs_item) * 397585e21bacSChris Mason (nritems - slot - nr)); 3976be0e5c09SChris Mason } 397785e21bacSChris Mason btrfs_set_header_nritems(leaf, nritems - nr); 397885e21bacSChris Mason nritems -= nr; 39795f39d397SChris Mason 398074123bd7SChris Mason /* delete the leaf if we've emptied it */ 39817518a238SChris Mason if (nritems == 0) { 39825f39d397SChris Mason if (leaf == root->node) { 39835f39d397SChris Mason btrfs_set_header_level(leaf, 0); 39849a8dd150SChris Mason } else { 3985f0486c68SYan, Zheng btrfs_set_path_blocking(path); 3986f0486c68SYan, Zheng clean_tree_block(trans, root, leaf); 39875d4f98a2SYan Zheng ret = btrfs_del_leaf(trans, root, path, leaf); 3988323ac95bSChris Mason BUG_ON(ret); 39899a8dd150SChris Mason } 3990be0e5c09SChris Mason } else { 39917518a238SChris Mason int used = leaf_space_used(leaf, 0, nritems); 3992aa5d6bedSChris Mason if (slot == 0) { 39935f39d397SChris Mason struct btrfs_disk_key disk_key; 39945f39d397SChris Mason 39955f39d397SChris Mason btrfs_item_key(leaf, &disk_key, 0); 3996e089f05cSChris Mason wret = fixup_low_keys(trans, root, path, 39975f39d397SChris Mason &disk_key, 1); 3998aa5d6bedSChris Mason if (wret) 3999aa5d6bedSChris Mason ret = wret; 4000aa5d6bedSChris Mason } 4001aa5d6bedSChris Mason 400274123bd7SChris Mason /* delete the leaf if it is mostly empty */ 4003d717aa1dSYan Zheng if (used < BTRFS_LEAF_DATA_SIZE(root) / 3) { 4004be0e5c09SChris Mason /* push_leaf_left fixes the path. 4005be0e5c09SChris Mason * make sure the path still points to our leaf 4006be0e5c09SChris Mason * for possible call to del_ptr below 4007be0e5c09SChris Mason */ 40084920c9acSChris Mason slot = path->slots[1]; 40095f39d397SChris Mason extent_buffer_get(leaf); 40105f39d397SChris Mason 4011b9473439SChris Mason btrfs_set_path_blocking(path); 401299d8f83cSChris Mason wret = push_leaf_left(trans, root, path, 1, 1, 401399d8f83cSChris Mason 1, (u32)-1); 401454aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 4015aa5d6bedSChris Mason ret = wret; 40165f39d397SChris Mason 40175f39d397SChris Mason if (path->nodes[0] == leaf && 40185f39d397SChris Mason btrfs_header_nritems(leaf)) { 401999d8f83cSChris Mason wret = push_leaf_right(trans, root, path, 1, 402099d8f83cSChris Mason 1, 1, 0); 402154aa1f4dSChris Mason if (wret < 0 && wret != -ENOSPC) 4022aa5d6bedSChris Mason ret = wret; 4023aa5d6bedSChris Mason } 40245f39d397SChris Mason 40255f39d397SChris Mason if (btrfs_header_nritems(leaf) == 0) { 4026323ac95bSChris Mason path->slots[1] = slot; 40275d4f98a2SYan Zheng ret = btrfs_del_leaf(trans, root, path, leaf); 4028323ac95bSChris Mason BUG_ON(ret); 40295f39d397SChris Mason free_extent_buffer(leaf); 40305de08d7dSChris Mason } else { 4031925baeddSChris Mason /* if we're still in the path, make sure 4032925baeddSChris Mason * we're dirty. Otherwise, one of the 4033925baeddSChris Mason * push_leaf functions must have already 4034925baeddSChris Mason * dirtied this buffer 4035925baeddSChris Mason */ 4036925baeddSChris Mason if (path->nodes[0] == leaf) 40375f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 40385f39d397SChris Mason free_extent_buffer(leaf); 4039be0e5c09SChris Mason } 4040d5719762SChris Mason } else { 40415f39d397SChris Mason btrfs_mark_buffer_dirty(leaf); 4042be0e5c09SChris Mason } 40439a8dd150SChris Mason } 4044aa5d6bedSChris Mason return ret; 40459a8dd150SChris Mason } 40469a8dd150SChris Mason 404797571fd0SChris Mason /* 4048925baeddSChris Mason * search the tree again to find a leaf with lesser keys 40497bb86316SChris Mason * returns 0 if it found something or 1 if there are no lesser leaves. 40507bb86316SChris Mason * returns < 0 on io errors. 4051d352ac68SChris Mason * 4052d352ac68SChris Mason * This may release the path, and so you may lose any locks held at the 4053d352ac68SChris Mason * time you call it. 40547bb86316SChris Mason */ 40557bb86316SChris Mason int btrfs_prev_leaf(struct btrfs_root *root, struct btrfs_path *path) 40567bb86316SChris Mason { 4057925baeddSChris Mason struct btrfs_key key; 4058925baeddSChris Mason struct btrfs_disk_key found_key; 4059925baeddSChris Mason int ret; 40607bb86316SChris Mason 4061925baeddSChris Mason btrfs_item_key_to_cpu(path->nodes[0], &key, 0); 4062925baeddSChris Mason 4063925baeddSChris Mason if (key.offset > 0) 4064925baeddSChris Mason key.offset--; 4065925baeddSChris Mason else if (key.type > 0) 4066925baeddSChris Mason key.type--; 4067925baeddSChris Mason else if (key.objectid > 0) 4068925baeddSChris Mason key.objectid--; 4069925baeddSChris Mason else 40707bb86316SChris Mason return 1; 40717bb86316SChris Mason 4072925baeddSChris Mason btrfs_release_path(root, path); 4073925baeddSChris Mason ret = btrfs_search_slot(NULL, root, &key, path, 0, 0); 4074925baeddSChris Mason if (ret < 0) 4075925baeddSChris Mason return ret; 4076925baeddSChris Mason btrfs_item_key(path->nodes[0], &found_key, 0); 4077925baeddSChris Mason ret = comp_keys(&found_key, &key); 4078925baeddSChris Mason if (ret < 0) 40797bb86316SChris Mason return 0; 4080925baeddSChris Mason return 1; 40817bb86316SChris Mason } 40827bb86316SChris Mason 40833f157a2fSChris Mason /* 40843f157a2fSChris Mason * A helper function to walk down the tree starting at min_key, and looking 40853f157a2fSChris Mason * for nodes or leaves that are either in cache or have a minimum 4086d352ac68SChris Mason * transaction id. This is used by the btree defrag code, and tree logging 40873f157a2fSChris Mason * 40883f157a2fSChris Mason * This does not cow, but it does stuff the starting key it finds back 40893f157a2fSChris Mason * into min_key, so you can call btrfs_search_slot with cow=1 on the 40903f157a2fSChris Mason * key and get a writable path. 40913f157a2fSChris Mason * 40923f157a2fSChris Mason * This does lock as it descends, and path->keep_locks should be set 40933f157a2fSChris Mason * to 1 by the caller. 40943f157a2fSChris Mason * 40953f157a2fSChris Mason * This honors path->lowest_level to prevent descent past a given level 40963f157a2fSChris Mason * of the tree. 40973f157a2fSChris Mason * 4098d352ac68SChris Mason * min_trans indicates the oldest transaction that you are interested 4099d352ac68SChris Mason * in walking through. Any nodes or leaves older than min_trans are 4100d352ac68SChris Mason * skipped over (without reading them). 4101d352ac68SChris Mason * 41023f157a2fSChris Mason * returns zero if something useful was found, < 0 on error and 1 if there 41033f157a2fSChris Mason * was nothing in the tree that matched the search criteria. 41043f157a2fSChris Mason */ 41053f157a2fSChris Mason int btrfs_search_forward(struct btrfs_root *root, struct btrfs_key *min_key, 4106e02119d5SChris Mason struct btrfs_key *max_key, 41073f157a2fSChris Mason struct btrfs_path *path, int cache_only, 41083f157a2fSChris Mason u64 min_trans) 41093f157a2fSChris Mason { 41103f157a2fSChris Mason struct extent_buffer *cur; 41113f157a2fSChris Mason struct btrfs_key found_key; 41123f157a2fSChris Mason int slot; 41139652480bSYan int sret; 41143f157a2fSChris Mason u32 nritems; 41153f157a2fSChris Mason int level; 41163f157a2fSChris Mason int ret = 1; 41173f157a2fSChris Mason 4118934d375bSChris Mason WARN_ON(!path->keep_locks); 41193f157a2fSChris Mason again: 41203f157a2fSChris Mason cur = btrfs_lock_root_node(root); 41213f157a2fSChris Mason level = btrfs_header_level(cur); 4122e02119d5SChris Mason WARN_ON(path->nodes[level]); 41233f157a2fSChris Mason path->nodes[level] = cur; 41243f157a2fSChris Mason path->locks[level] = 1; 41253f157a2fSChris Mason 41263f157a2fSChris Mason if (btrfs_header_generation(cur) < min_trans) { 41273f157a2fSChris Mason ret = 1; 41283f157a2fSChris Mason goto out; 41293f157a2fSChris Mason } 41303f157a2fSChris Mason while (1) { 41313f157a2fSChris Mason nritems = btrfs_header_nritems(cur); 41323f157a2fSChris Mason level = btrfs_header_level(cur); 41339652480bSYan sret = bin_search(cur, min_key, level, &slot); 41343f157a2fSChris Mason 4135323ac95bSChris Mason /* at the lowest level, we're done, setup the path and exit */ 4136323ac95bSChris Mason if (level == path->lowest_level) { 4137e02119d5SChris Mason if (slot >= nritems) 4138e02119d5SChris Mason goto find_next_key; 41393f157a2fSChris Mason ret = 0; 41403f157a2fSChris Mason path->slots[level] = slot; 41413f157a2fSChris Mason btrfs_item_key_to_cpu(cur, &found_key, slot); 41423f157a2fSChris Mason goto out; 41433f157a2fSChris Mason } 41449652480bSYan if (sret && slot > 0) 41459652480bSYan slot--; 41463f157a2fSChris Mason /* 41473f157a2fSChris Mason * check this node pointer against the cache_only and 41483f157a2fSChris Mason * min_trans parameters. If it isn't in cache or is too 41493f157a2fSChris Mason * old, skip to the next one. 41503f157a2fSChris Mason */ 41513f157a2fSChris Mason while (slot < nritems) { 41523f157a2fSChris Mason u64 blockptr; 41533f157a2fSChris Mason u64 gen; 41543f157a2fSChris Mason struct extent_buffer *tmp; 4155e02119d5SChris Mason struct btrfs_disk_key disk_key; 4156e02119d5SChris Mason 41573f157a2fSChris Mason blockptr = btrfs_node_blockptr(cur, slot); 41583f157a2fSChris Mason gen = btrfs_node_ptr_generation(cur, slot); 41593f157a2fSChris Mason if (gen < min_trans) { 41603f157a2fSChris Mason slot++; 41613f157a2fSChris Mason continue; 41623f157a2fSChris Mason } 41633f157a2fSChris Mason if (!cache_only) 41643f157a2fSChris Mason break; 41653f157a2fSChris Mason 4166e02119d5SChris Mason if (max_key) { 4167e02119d5SChris Mason btrfs_node_key(cur, &disk_key, slot); 4168e02119d5SChris Mason if (comp_keys(&disk_key, max_key) >= 0) { 4169e02119d5SChris Mason ret = 1; 4170e02119d5SChris Mason goto out; 4171e02119d5SChris Mason } 4172e02119d5SChris Mason } 4173e02119d5SChris Mason 41743f157a2fSChris Mason tmp = btrfs_find_tree_block(root, blockptr, 41753f157a2fSChris Mason btrfs_level_size(root, level - 1)); 41763f157a2fSChris Mason 41773f157a2fSChris Mason if (tmp && btrfs_buffer_uptodate(tmp, gen)) { 41783f157a2fSChris Mason free_extent_buffer(tmp); 41793f157a2fSChris Mason break; 41803f157a2fSChris Mason } 41813f157a2fSChris Mason if (tmp) 41823f157a2fSChris Mason free_extent_buffer(tmp); 41833f157a2fSChris Mason slot++; 41843f157a2fSChris Mason } 4185e02119d5SChris Mason find_next_key: 41863f157a2fSChris Mason /* 41873f157a2fSChris Mason * we didn't find a candidate key in this node, walk forward 41883f157a2fSChris Mason * and find another one 41893f157a2fSChris Mason */ 41903f157a2fSChris Mason if (slot >= nritems) { 4191e02119d5SChris Mason path->slots[level] = slot; 4192b4ce94deSChris Mason btrfs_set_path_blocking(path); 4193e02119d5SChris Mason sret = btrfs_find_next_key(root, path, min_key, level, 41943f157a2fSChris Mason cache_only, min_trans); 4195e02119d5SChris Mason if (sret == 0) { 41963f157a2fSChris Mason btrfs_release_path(root, path); 41973f157a2fSChris Mason goto again; 41983f157a2fSChris Mason } else { 41993f157a2fSChris Mason goto out; 42003f157a2fSChris Mason } 42013f157a2fSChris Mason } 42023f157a2fSChris Mason /* save our key for returning back */ 42033f157a2fSChris Mason btrfs_node_key_to_cpu(cur, &found_key, slot); 42043f157a2fSChris Mason path->slots[level] = slot; 42053f157a2fSChris Mason if (level == path->lowest_level) { 42063f157a2fSChris Mason ret = 0; 42073f157a2fSChris Mason unlock_up(path, level, 1); 42083f157a2fSChris Mason goto out; 42093f157a2fSChris Mason } 4210b4ce94deSChris Mason btrfs_set_path_blocking(path); 42113f157a2fSChris Mason cur = read_node_slot(root, cur, slot); 42123f157a2fSChris Mason 42133f157a2fSChris Mason btrfs_tree_lock(cur); 4214b4ce94deSChris Mason 42153f157a2fSChris Mason path->locks[level - 1] = 1; 42163f157a2fSChris Mason path->nodes[level - 1] = cur; 42173f157a2fSChris Mason unlock_up(path, level, 1); 42184008c04aSChris Mason btrfs_clear_path_blocking(path, NULL); 42193f157a2fSChris Mason } 42203f157a2fSChris Mason out: 42213f157a2fSChris Mason if (ret == 0) 42223f157a2fSChris Mason memcpy(min_key, &found_key, sizeof(found_key)); 4223b4ce94deSChris Mason btrfs_set_path_blocking(path); 42243f157a2fSChris Mason return ret; 42253f157a2fSChris Mason } 42263f157a2fSChris Mason 42273f157a2fSChris Mason /* 42283f157a2fSChris Mason * this is similar to btrfs_next_leaf, but does not try to preserve 42293f157a2fSChris Mason * and fixup the path. It looks for and returns the next key in the 42303f157a2fSChris Mason * tree based on the current path and the cache_only and min_trans 42313f157a2fSChris Mason * parameters. 42323f157a2fSChris Mason * 42333f157a2fSChris Mason * 0 is returned if another key is found, < 0 if there are any errors 42343f157a2fSChris Mason * and 1 is returned if there are no higher keys in the tree 42353f157a2fSChris Mason * 42363f157a2fSChris Mason * path->keep_locks should be set to 1 on the search made before 42373f157a2fSChris Mason * calling this function. 42383f157a2fSChris Mason */ 4239e7a84565SChris Mason int btrfs_find_next_key(struct btrfs_root *root, struct btrfs_path *path, 424033c66f43SYan Zheng struct btrfs_key *key, int level, 42413f157a2fSChris Mason int cache_only, u64 min_trans) 4242e7a84565SChris Mason { 4243e7a84565SChris Mason int slot; 4244e7a84565SChris Mason struct extent_buffer *c; 4245e7a84565SChris Mason 4246934d375bSChris Mason WARN_ON(!path->keep_locks); 4247e7a84565SChris Mason while (level < BTRFS_MAX_LEVEL) { 4248e7a84565SChris Mason if (!path->nodes[level]) 4249e7a84565SChris Mason return 1; 4250e7a84565SChris Mason 4251e7a84565SChris Mason slot = path->slots[level] + 1; 4252e7a84565SChris Mason c = path->nodes[level]; 42533f157a2fSChris Mason next: 4254e7a84565SChris Mason if (slot >= btrfs_header_nritems(c)) { 425533c66f43SYan Zheng int ret; 425633c66f43SYan Zheng int orig_lowest; 425733c66f43SYan Zheng struct btrfs_key cur_key; 425833c66f43SYan Zheng if (level + 1 >= BTRFS_MAX_LEVEL || 425933c66f43SYan Zheng !path->nodes[level + 1]) 4260e7a84565SChris Mason return 1; 426133c66f43SYan Zheng 426233c66f43SYan Zheng if (path->locks[level + 1]) { 426333c66f43SYan Zheng level++; 4264e7a84565SChris Mason continue; 4265e7a84565SChris Mason } 426633c66f43SYan Zheng 426733c66f43SYan Zheng slot = btrfs_header_nritems(c) - 1; 426833c66f43SYan Zheng if (level == 0) 426933c66f43SYan Zheng btrfs_item_key_to_cpu(c, &cur_key, slot); 427033c66f43SYan Zheng else 427133c66f43SYan Zheng btrfs_node_key_to_cpu(c, &cur_key, slot); 427233c66f43SYan Zheng 427333c66f43SYan Zheng orig_lowest = path->lowest_level; 427433c66f43SYan Zheng btrfs_release_path(root, path); 427533c66f43SYan Zheng path->lowest_level = level; 427633c66f43SYan Zheng ret = btrfs_search_slot(NULL, root, &cur_key, path, 427733c66f43SYan Zheng 0, 0); 427833c66f43SYan Zheng path->lowest_level = orig_lowest; 427933c66f43SYan Zheng if (ret < 0) 428033c66f43SYan Zheng return ret; 428133c66f43SYan Zheng 428233c66f43SYan Zheng c = path->nodes[level]; 428333c66f43SYan Zheng slot = path->slots[level]; 428433c66f43SYan Zheng if (ret == 0) 428533c66f43SYan Zheng slot++; 428633c66f43SYan Zheng goto next; 428733c66f43SYan Zheng } 428833c66f43SYan Zheng 4289e7a84565SChris Mason if (level == 0) 4290e7a84565SChris Mason btrfs_item_key_to_cpu(c, key, slot); 42913f157a2fSChris Mason else { 42923f157a2fSChris Mason u64 blockptr = btrfs_node_blockptr(c, slot); 42933f157a2fSChris Mason u64 gen = btrfs_node_ptr_generation(c, slot); 42943f157a2fSChris Mason 42953f157a2fSChris Mason if (cache_only) { 42963f157a2fSChris Mason struct extent_buffer *cur; 42973f157a2fSChris Mason cur = btrfs_find_tree_block(root, blockptr, 42983f157a2fSChris Mason btrfs_level_size(root, level - 1)); 42993f157a2fSChris Mason if (!cur || !btrfs_buffer_uptodate(cur, gen)) { 43003f157a2fSChris Mason slot++; 43013f157a2fSChris Mason if (cur) 43023f157a2fSChris Mason free_extent_buffer(cur); 43033f157a2fSChris Mason goto next; 43043f157a2fSChris Mason } 43053f157a2fSChris Mason free_extent_buffer(cur); 43063f157a2fSChris Mason } 43073f157a2fSChris Mason if (gen < min_trans) { 43083f157a2fSChris Mason slot++; 43093f157a2fSChris Mason goto next; 43103f157a2fSChris Mason } 4311e7a84565SChris Mason btrfs_node_key_to_cpu(c, key, slot); 43123f157a2fSChris Mason } 4313e7a84565SChris Mason return 0; 4314e7a84565SChris Mason } 4315e7a84565SChris Mason return 1; 4316e7a84565SChris Mason } 4317e7a84565SChris Mason 43187bb86316SChris Mason /* 4319925baeddSChris Mason * search the tree again to find a leaf with greater keys 43200f70abe2SChris Mason * returns 0 if it found something or 1 if there are no greater leaves. 43210f70abe2SChris Mason * returns < 0 on io errors. 432297571fd0SChris Mason */ 4323234b63a0SChris Mason int btrfs_next_leaf(struct btrfs_root *root, struct btrfs_path *path) 4324d97e63b6SChris Mason { 4325d97e63b6SChris Mason int slot; 43268e73f275SChris Mason int level; 43275f39d397SChris Mason struct extent_buffer *c; 43288e73f275SChris Mason struct extent_buffer *next; 4329925baeddSChris Mason struct btrfs_key key; 4330925baeddSChris Mason u32 nritems; 4331925baeddSChris Mason int ret; 43328e73f275SChris Mason int old_spinning = path->leave_spinning; 43338e73f275SChris Mason int force_blocking = 0; 4334925baeddSChris Mason 4335925baeddSChris Mason nritems = btrfs_header_nritems(path->nodes[0]); 4336d397712bSChris Mason if (nritems == 0) 4337925baeddSChris Mason return 1; 4338925baeddSChris Mason 43398e73f275SChris Mason /* 43408e73f275SChris Mason * we take the blocks in an order that upsets lockdep. Using 43418e73f275SChris Mason * blocking mode is the only way around it. 43428e73f275SChris Mason */ 43438e73f275SChris Mason #ifdef CONFIG_DEBUG_LOCK_ALLOC 43448e73f275SChris Mason force_blocking = 1; 43458e73f275SChris Mason #endif 4346925baeddSChris Mason 43478e73f275SChris Mason btrfs_item_key_to_cpu(path->nodes[0], &key, nritems - 1); 43488e73f275SChris Mason again: 43498e73f275SChris Mason level = 1; 43508e73f275SChris Mason next = NULL; 4351925baeddSChris Mason btrfs_release_path(root, path); 43528e73f275SChris Mason 4353a2135011SChris Mason path->keep_locks = 1; 43548e73f275SChris Mason 43558e73f275SChris Mason if (!force_blocking) 43568e73f275SChris Mason path->leave_spinning = 1; 43578e73f275SChris Mason 4358925baeddSChris Mason ret = btrfs_search_slot(NULL, root, &key, path, 0, 0); 4359925baeddSChris Mason path->keep_locks = 0; 4360925baeddSChris Mason 4361925baeddSChris Mason if (ret < 0) 4362925baeddSChris Mason return ret; 4363925baeddSChris Mason 4364a2135011SChris Mason nritems = btrfs_header_nritems(path->nodes[0]); 4365168fd7d2SChris Mason /* 4366168fd7d2SChris Mason * by releasing the path above we dropped all our locks. A balance 4367168fd7d2SChris Mason * could have added more items next to the key that used to be 4368168fd7d2SChris Mason * at the very end of the block. So, check again here and 4369168fd7d2SChris Mason * advance the path if there are now more items available. 4370168fd7d2SChris Mason */ 4371a2135011SChris Mason if (nritems > 0 && path->slots[0] < nritems - 1) { 4372e457afecSYan Zheng if (ret == 0) 4373168fd7d2SChris Mason path->slots[0]++; 43748e73f275SChris Mason ret = 0; 4375925baeddSChris Mason goto done; 4376925baeddSChris Mason } 4377d97e63b6SChris Mason 4378234b63a0SChris Mason while (level < BTRFS_MAX_LEVEL) { 43798e73f275SChris Mason if (!path->nodes[level]) { 43808e73f275SChris Mason ret = 1; 43818e73f275SChris Mason goto done; 43828e73f275SChris Mason } 43835f39d397SChris Mason 4384d97e63b6SChris Mason slot = path->slots[level] + 1; 4385d97e63b6SChris Mason c = path->nodes[level]; 43865f39d397SChris Mason if (slot >= btrfs_header_nritems(c)) { 4387d97e63b6SChris Mason level++; 43888e73f275SChris Mason if (level == BTRFS_MAX_LEVEL) { 43898e73f275SChris Mason ret = 1; 43908e73f275SChris Mason goto done; 43918e73f275SChris Mason } 4392d97e63b6SChris Mason continue; 4393d97e63b6SChris Mason } 43945f39d397SChris Mason 4395925baeddSChris Mason if (next) { 4396925baeddSChris Mason btrfs_tree_unlock(next); 43975f39d397SChris Mason free_extent_buffer(next); 4398925baeddSChris Mason } 43995f39d397SChris Mason 44008e73f275SChris Mason next = c; 44018e73f275SChris Mason ret = read_block_for_search(NULL, root, path, &next, level, 44028e73f275SChris Mason slot, &key); 44038e73f275SChris Mason if (ret == -EAGAIN) 44048e73f275SChris Mason goto again; 44055f39d397SChris Mason 440676a05b35SChris Mason if (ret < 0) { 440776a05b35SChris Mason btrfs_release_path(root, path); 440876a05b35SChris Mason goto done; 440976a05b35SChris Mason } 441076a05b35SChris Mason 44115cd57b2cSChris Mason if (!path->skip_locking) { 44128e73f275SChris Mason ret = btrfs_try_spin_lock(next); 44138e73f275SChris Mason if (!ret) { 44148e73f275SChris Mason btrfs_set_path_blocking(path); 4415925baeddSChris Mason btrfs_tree_lock(next); 44168e73f275SChris Mason if (!force_blocking) 44178e73f275SChris Mason btrfs_clear_path_blocking(path, next); 44188e73f275SChris Mason } 44198e73f275SChris Mason if (force_blocking) 4420b4ce94deSChris Mason btrfs_set_lock_blocking(next); 44215cd57b2cSChris Mason } 4422d97e63b6SChris Mason break; 4423d97e63b6SChris Mason } 4424d97e63b6SChris Mason path->slots[level] = slot; 4425d97e63b6SChris Mason while (1) { 4426d97e63b6SChris Mason level--; 4427d97e63b6SChris Mason c = path->nodes[level]; 4428925baeddSChris Mason if (path->locks[level]) 4429925baeddSChris Mason btrfs_tree_unlock(c); 44308e73f275SChris Mason 44315f39d397SChris Mason free_extent_buffer(c); 4432d97e63b6SChris Mason path->nodes[level] = next; 4433d97e63b6SChris Mason path->slots[level] = 0; 4434a74a4b97SChris Mason if (!path->skip_locking) 4435925baeddSChris Mason path->locks[level] = 1; 44368e73f275SChris Mason 4437d97e63b6SChris Mason if (!level) 4438d97e63b6SChris Mason break; 4439b4ce94deSChris Mason 44408e73f275SChris Mason ret = read_block_for_search(NULL, root, path, &next, level, 44418e73f275SChris Mason 0, &key); 44428e73f275SChris Mason if (ret == -EAGAIN) 44438e73f275SChris Mason goto again; 44448e73f275SChris Mason 444576a05b35SChris Mason if (ret < 0) { 444676a05b35SChris Mason btrfs_release_path(root, path); 444776a05b35SChris Mason goto done; 444876a05b35SChris Mason } 444976a05b35SChris Mason 44505cd57b2cSChris Mason if (!path->skip_locking) { 4451b9447ef8SChris Mason btrfs_assert_tree_locked(path->nodes[level]); 44528e73f275SChris Mason ret = btrfs_try_spin_lock(next); 44538e73f275SChris Mason if (!ret) { 44548e73f275SChris Mason btrfs_set_path_blocking(path); 4455925baeddSChris Mason btrfs_tree_lock(next); 44568e73f275SChris Mason if (!force_blocking) 44578e73f275SChris Mason btrfs_clear_path_blocking(path, next); 44588e73f275SChris Mason } 44598e73f275SChris Mason if (force_blocking) 4460b4ce94deSChris Mason btrfs_set_lock_blocking(next); 4461d97e63b6SChris Mason } 44625cd57b2cSChris Mason } 44638e73f275SChris Mason ret = 0; 4464925baeddSChris Mason done: 4465925baeddSChris Mason unlock_up(path, 0, 1); 44668e73f275SChris Mason path->leave_spinning = old_spinning; 44678e73f275SChris Mason if (!old_spinning) 44688e73f275SChris Mason btrfs_set_path_blocking(path); 44698e73f275SChris Mason 44708e73f275SChris Mason return ret; 4471d97e63b6SChris Mason } 44720b86a832SChris Mason 44733f157a2fSChris Mason /* 44743f157a2fSChris Mason * this uses btrfs_prev_leaf to walk backwards in the tree, and keeps 44753f157a2fSChris Mason * searching until it gets past min_objectid or finds an item of 'type' 44763f157a2fSChris Mason * 44773f157a2fSChris Mason * returns 0 if something is found, 1 if nothing was found and < 0 on error 44783f157a2fSChris Mason */ 44790b86a832SChris Mason int btrfs_previous_item(struct btrfs_root *root, 44800b86a832SChris Mason struct btrfs_path *path, u64 min_objectid, 44810b86a832SChris Mason int type) 44820b86a832SChris Mason { 44830b86a832SChris Mason struct btrfs_key found_key; 44840b86a832SChris Mason struct extent_buffer *leaf; 4485e02119d5SChris Mason u32 nritems; 44860b86a832SChris Mason int ret; 44870b86a832SChris Mason 44880b86a832SChris Mason while (1) { 44890b86a832SChris Mason if (path->slots[0] == 0) { 4490b4ce94deSChris Mason btrfs_set_path_blocking(path); 44910b86a832SChris Mason ret = btrfs_prev_leaf(root, path); 44920b86a832SChris Mason if (ret != 0) 44930b86a832SChris Mason return ret; 44940b86a832SChris Mason } else { 44950b86a832SChris Mason path->slots[0]--; 44960b86a832SChris Mason } 44970b86a832SChris Mason leaf = path->nodes[0]; 4498e02119d5SChris Mason nritems = btrfs_header_nritems(leaf); 4499e02119d5SChris Mason if (nritems == 0) 4500e02119d5SChris Mason return 1; 4501e02119d5SChris Mason if (path->slots[0] == nritems) 4502e02119d5SChris Mason path->slots[0]--; 4503e02119d5SChris Mason 45040b86a832SChris Mason btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]); 4505e02119d5SChris Mason if (found_key.objectid < min_objectid) 4506e02119d5SChris Mason break; 45070a4eefbbSYan Zheng if (found_key.type == type) 45080a4eefbbSYan Zheng return 0; 4509e02119d5SChris Mason if (found_key.objectid == min_objectid && 4510e02119d5SChris Mason found_key.type < type) 4511e02119d5SChris Mason break; 45120b86a832SChris Mason } 45130b86a832SChris Mason return 1; 45140b86a832SChris Mason } 4515