1be0e5c09SChris Mason #include <stdio.h> 2be0e5c09SChris Mason #include <stdlib.h> 3be0e5c09SChris Mason #include "kerncompat.h" 4eb60ceacSChris Mason #include "radix-tree.h" 5eb60ceacSChris Mason #include "ctree.h" 6eb60ceacSChris Mason #include "disk-io.h" 75de08d7dSChris Mason #include "print-tree.h" 89a8dd150SChris Mason 9aa5d6bedSChris Mason static int split_node(struct ctree_root *root, struct ctree_path *path, 10aa5d6bedSChris Mason int level); 11aa5d6bedSChris Mason static int split_leaf(struct ctree_root *root, struct ctree_path *path, 12aa5d6bedSChris Mason int data_size); 13bb803951SChris Mason static int push_node_left(struct ctree_root *root, struct tree_buffer *dst, 14bb803951SChris Mason struct tree_buffer *src); 1579f95c82SChris Mason static int balance_node_right(struct ctree_root *root, 1679f95c82SChris Mason struct tree_buffer *dst_buf, 1779f95c82SChris Mason struct tree_buffer *src_buf); 18bb803951SChris Mason static int del_ptr(struct ctree_root *root, struct ctree_path *path, int level, 19bb803951SChris Mason int slot); 20d97e63b6SChris Mason 215de08d7dSChris Mason inline void init_path(struct ctree_path *p) 22be0e5c09SChris Mason { 23be0e5c09SChris Mason memset(p, 0, sizeof(*p)); 24be0e5c09SChris Mason } 25be0e5c09SChris Mason 265de08d7dSChris Mason void release_path(struct ctree_root *root, struct ctree_path *p) 27eb60ceacSChris Mason { 28eb60ceacSChris Mason int i; 29eb60ceacSChris Mason for (i = 0; i < MAX_LEVEL; i++) { 30eb60ceacSChris Mason if (!p->nodes[i]) 31eb60ceacSChris Mason break; 32eb60ceacSChris Mason tree_block_release(root, p->nodes[i]); 33eb60ceacSChris Mason } 34aa5d6bedSChris Mason memset(p, 0, sizeof(*p)); 35eb60ceacSChris Mason } 36eb60ceacSChris Mason 3702217ed2SChris Mason int btrfs_cow_block(struct ctree_root *root, 3802217ed2SChris Mason struct tree_buffer *buf, 3902217ed2SChris Mason struct tree_buffer *parent, 4002217ed2SChris Mason int parent_slot, 4102217ed2SChris Mason struct tree_buffer **cow_ret) 4202217ed2SChris Mason { 4302217ed2SChris Mason struct tree_buffer *cow; 4402217ed2SChris Mason 4502217ed2SChris Mason if (!list_empty(&buf->dirty)) { 4602217ed2SChris Mason *cow_ret = buf; 4702217ed2SChris Mason return 0; 4802217ed2SChris Mason } 4902217ed2SChris Mason cow = alloc_free_block(root); 5002217ed2SChris Mason memcpy(&cow->node, &buf->node, sizeof(buf->node)); 5102217ed2SChris Mason cow->node.header.blocknr = cow->blocknr; 5202217ed2SChris Mason *cow_ret = cow; 5302217ed2SChris Mason if (buf == root->node) { 5402217ed2SChris Mason root->node = cow; 5502217ed2SChris Mason cow->count++; 5602217ed2SChris Mason tree_block_release(root, buf); 5702217ed2SChris Mason } else { 5802217ed2SChris Mason parent->node.blockptrs[parent_slot] = cow->blocknr; 5902217ed2SChris Mason BUG_ON(list_empty(&parent->dirty)); 6002217ed2SChris Mason } 6102217ed2SChris Mason if (0 && root != root->extent_root && !is_leaf(cow->node.header.flags)) { 6202217ed2SChris Mason btrfs_inc_ref(root, cow); 6302217ed2SChris Mason } 6402217ed2SChris Mason tree_block_release(root, buf); 6502217ed2SChris Mason return 0; 6602217ed2SChris Mason } 6702217ed2SChris Mason 6874123bd7SChris Mason /* 6974123bd7SChris Mason * The leaf data grows from end-to-front in the node. 7074123bd7SChris Mason * this returns the address of the start of the last item, 7174123bd7SChris Mason * which is the stop of the leaf data stack 7274123bd7SChris Mason */ 73be0e5c09SChris Mason static inline unsigned int leaf_data_end(struct leaf *leaf) 74be0e5c09SChris Mason { 75be0e5c09SChris Mason unsigned int nr = leaf->header.nritems; 76be0e5c09SChris Mason if (nr == 0) 77d97e63b6SChris Mason return sizeof(leaf->data); 78be0e5c09SChris Mason return leaf->items[nr-1].offset; 79be0e5c09SChris Mason } 80be0e5c09SChris Mason 8174123bd7SChris Mason /* 8274123bd7SChris Mason * The space between the end of the leaf items and 8374123bd7SChris Mason * the start of the leaf data. IOW, how much room 8474123bd7SChris Mason * the leaf has left for both items and data 8574123bd7SChris Mason */ 865de08d7dSChris Mason int leaf_free_space(struct leaf *leaf) 87be0e5c09SChris Mason { 88be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 89be0e5c09SChris Mason int nritems = leaf->header.nritems; 90be0e5c09SChris Mason char *items_end = (char *)(leaf->items + nritems + 1); 91be0e5c09SChris Mason return (char *)(leaf->data + data_end) - (char *)items_end; 92be0e5c09SChris Mason } 93be0e5c09SChris Mason 9474123bd7SChris Mason /* 9574123bd7SChris Mason * compare two keys in a memcmp fashion 9674123bd7SChris Mason */ 97be0e5c09SChris Mason int comp_keys(struct key *k1, struct key *k2) 98be0e5c09SChris Mason { 99be0e5c09SChris Mason if (k1->objectid > k2->objectid) 100be0e5c09SChris Mason return 1; 101be0e5c09SChris Mason if (k1->objectid < k2->objectid) 102be0e5c09SChris Mason return -1; 103be0e5c09SChris Mason if (k1->flags > k2->flags) 104be0e5c09SChris Mason return 1; 105be0e5c09SChris Mason if (k1->flags < k2->flags) 106be0e5c09SChris Mason return -1; 107be0e5c09SChris Mason if (k1->offset > k2->offset) 108be0e5c09SChris Mason return 1; 109be0e5c09SChris Mason if (k1->offset < k2->offset) 110be0e5c09SChris Mason return -1; 111be0e5c09SChris Mason return 0; 112be0e5c09SChris Mason } 11374123bd7SChris Mason 114aa5d6bedSChris Mason int check_node(struct ctree_path *path, int level) 115aa5d6bedSChris Mason { 116aa5d6bedSChris Mason int i; 117aa5d6bedSChris Mason struct node *parent = NULL; 118aa5d6bedSChris Mason struct node *node = &path->nodes[level]->node; 119aa5d6bedSChris Mason int parent_slot; 120aa5d6bedSChris Mason 121aa5d6bedSChris Mason if (path->nodes[level + 1]) 122aa5d6bedSChris Mason parent = &path->nodes[level + 1]->node; 123aa5d6bedSChris Mason parent_slot = path->slots[level + 1]; 124aa5d6bedSChris Mason if (parent && node->header.nritems > 0) { 125aa5d6bedSChris Mason struct key *parent_key; 126aa5d6bedSChris Mason parent_key = &parent->keys[parent_slot]; 127aa5d6bedSChris Mason BUG_ON(memcmp(parent_key, node->keys, sizeof(struct key))); 128aa5d6bedSChris Mason BUG_ON(parent->blockptrs[parent_slot] != node->header.blocknr); 129aa5d6bedSChris Mason } 130aa5d6bedSChris Mason BUG_ON(node->header.nritems > NODEPTRS_PER_BLOCK); 131aa5d6bedSChris Mason for (i = 0; i < node->header.nritems - 2; i++) { 132aa5d6bedSChris Mason BUG_ON(comp_keys(&node->keys[i], &node->keys[i+1]) >= 0); 133aa5d6bedSChris Mason } 134aa5d6bedSChris Mason return 0; 135aa5d6bedSChris Mason } 136aa5d6bedSChris Mason 137aa5d6bedSChris Mason int check_leaf(struct ctree_path *path, int level) 138aa5d6bedSChris Mason { 139aa5d6bedSChris Mason int i; 140aa5d6bedSChris Mason struct leaf *leaf = &path->nodes[level]->leaf; 141aa5d6bedSChris Mason struct node *parent = NULL; 142aa5d6bedSChris Mason int parent_slot; 143aa5d6bedSChris Mason 144aa5d6bedSChris Mason if (path->nodes[level + 1]) 145aa5d6bedSChris Mason parent = &path->nodes[level + 1]->node; 146aa5d6bedSChris Mason parent_slot = path->slots[level + 1]; 147aa5d6bedSChris Mason if (parent && leaf->header.nritems > 0) { 148aa5d6bedSChris Mason struct key *parent_key; 149aa5d6bedSChris Mason parent_key = &parent->keys[parent_slot]; 150aa5d6bedSChris Mason BUG_ON(memcmp(parent_key, &leaf->items[0].key, 151aa5d6bedSChris Mason sizeof(struct key))); 152aa5d6bedSChris Mason BUG_ON(parent->blockptrs[parent_slot] != leaf->header.blocknr); 153aa5d6bedSChris Mason } 154aa5d6bedSChris Mason for (i = 0; i < leaf->header.nritems - 2; i++) { 155aa5d6bedSChris Mason BUG_ON(comp_keys(&leaf->items[i].key, 156aa5d6bedSChris Mason &leaf->items[i+1].key) >= 0); 157aa5d6bedSChris Mason BUG_ON(leaf->items[i].offset != leaf->items[i + 1].offset + 158aa5d6bedSChris Mason leaf->items[i + 1].size); 159aa5d6bedSChris Mason if (i == 0) { 160aa5d6bedSChris Mason BUG_ON(leaf->items[i].offset + leaf->items[i].size != 161aa5d6bedSChris Mason LEAF_DATA_SIZE); 162aa5d6bedSChris Mason } 163aa5d6bedSChris Mason } 164aa5d6bedSChris Mason BUG_ON(leaf_free_space(leaf) < 0); 165aa5d6bedSChris Mason return 0; 166aa5d6bedSChris Mason } 167aa5d6bedSChris Mason 168aa5d6bedSChris Mason int check_block(struct ctree_path *path, int level) 169aa5d6bedSChris Mason { 170aa5d6bedSChris Mason if (level == 0) 171aa5d6bedSChris Mason return check_leaf(path, level); 172aa5d6bedSChris Mason return check_node(path, level); 173aa5d6bedSChris Mason } 174aa5d6bedSChris Mason 17574123bd7SChris Mason /* 17674123bd7SChris Mason * search for key in the array p. items p are item_size apart 17774123bd7SChris Mason * and there are 'max' items in p 17874123bd7SChris Mason * the slot in the array is returned via slot, and it points to 17974123bd7SChris Mason * the place where you would insert key if it is not found in 18074123bd7SChris Mason * the array. 18174123bd7SChris Mason * 18274123bd7SChris Mason * slot may point to max if the key is bigger than all of the keys 18374123bd7SChris Mason */ 184be0e5c09SChris Mason int generic_bin_search(char *p, int item_size, struct key *key, 185be0e5c09SChris Mason int max, int *slot) 186be0e5c09SChris Mason { 187be0e5c09SChris Mason int low = 0; 188be0e5c09SChris Mason int high = max; 189be0e5c09SChris Mason int mid; 190be0e5c09SChris Mason int ret; 191be0e5c09SChris Mason struct key *tmp; 192be0e5c09SChris Mason 193be0e5c09SChris Mason while(low < high) { 194be0e5c09SChris Mason mid = (low + high) / 2; 195be0e5c09SChris Mason tmp = (struct key *)(p + mid * item_size); 196be0e5c09SChris Mason ret = comp_keys(tmp, key); 197be0e5c09SChris Mason 198be0e5c09SChris Mason if (ret < 0) 199be0e5c09SChris Mason low = mid + 1; 200be0e5c09SChris Mason else if (ret > 0) 201be0e5c09SChris Mason high = mid; 202be0e5c09SChris Mason else { 203be0e5c09SChris Mason *slot = mid; 204be0e5c09SChris Mason return 0; 205be0e5c09SChris Mason } 206be0e5c09SChris Mason } 207be0e5c09SChris Mason *slot = low; 208be0e5c09SChris Mason return 1; 209be0e5c09SChris Mason } 210be0e5c09SChris Mason 21197571fd0SChris Mason /* 21297571fd0SChris Mason * simple bin_search frontend that does the right thing for 21397571fd0SChris Mason * leaves vs nodes 21497571fd0SChris Mason */ 215be0e5c09SChris Mason int bin_search(struct node *c, struct key *key, int *slot) 216be0e5c09SChris Mason { 217be0e5c09SChris Mason if (is_leaf(c->header.flags)) { 218be0e5c09SChris Mason struct leaf *l = (struct leaf *)c; 219be0e5c09SChris Mason return generic_bin_search((void *)l->items, sizeof(struct item), 220be0e5c09SChris Mason key, c->header.nritems, slot); 221be0e5c09SChris Mason } else { 222be0e5c09SChris Mason return generic_bin_search((void *)c->keys, sizeof(struct key), 223be0e5c09SChris Mason key, c->header.nritems, slot); 224be0e5c09SChris Mason } 225be0e5c09SChris Mason return -1; 226be0e5c09SChris Mason } 227be0e5c09SChris Mason 228bb803951SChris Mason struct tree_buffer *read_node_slot(struct ctree_root *root, 229bb803951SChris Mason struct tree_buffer *parent_buf, 230bb803951SChris Mason int slot) 231bb803951SChris Mason { 232bb803951SChris Mason struct node *node = &parent_buf->node; 233bb803951SChris Mason if (slot < 0) 234bb803951SChris Mason return NULL; 235bb803951SChris Mason if (slot >= node->header.nritems) 236bb803951SChris Mason return NULL; 237bb803951SChris Mason return read_tree_block(root, node->blockptrs[slot]); 238bb803951SChris Mason } 239bb803951SChris Mason 240bb803951SChris Mason static int balance_level(struct ctree_root *root, struct ctree_path *path, 241bb803951SChris Mason int level) 242bb803951SChris Mason { 243bb803951SChris Mason struct tree_buffer *right_buf; 244bb803951SChris Mason struct tree_buffer *mid_buf; 245bb803951SChris Mason struct tree_buffer *left_buf; 246bb803951SChris Mason struct tree_buffer *parent_buf = NULL; 247bb803951SChris Mason struct node *right = NULL; 248bb803951SChris Mason struct node *mid; 249bb803951SChris Mason struct node *left = NULL; 250bb803951SChris Mason struct node *parent = NULL; 251bb803951SChris Mason int ret = 0; 252bb803951SChris Mason int wret; 253bb803951SChris Mason int pslot; 254bb803951SChris Mason int orig_slot = path->slots[level]; 25579f95c82SChris Mason u64 orig_ptr; 256bb803951SChris Mason 257bb803951SChris Mason if (level == 0) 258bb803951SChris Mason return 0; 259bb803951SChris Mason 260bb803951SChris Mason mid_buf = path->nodes[level]; 261bb803951SChris Mason mid = &mid_buf->node; 26279f95c82SChris Mason orig_ptr = mid->blockptrs[orig_slot]; 26379f95c82SChris Mason 264bb803951SChris Mason if (level < MAX_LEVEL - 1) 265bb803951SChris Mason parent_buf = path->nodes[level + 1]; 266bb803951SChris Mason pslot = path->slots[level + 1]; 267bb803951SChris Mason 268bb803951SChris Mason if (!parent_buf) { 269bb803951SChris Mason struct tree_buffer *child; 270bb803951SChris Mason u64 blocknr = mid_buf->blocknr; 271bb803951SChris Mason 272bb803951SChris Mason if (mid->header.nritems != 1) 273bb803951SChris Mason return 0; 274bb803951SChris Mason 275bb803951SChris Mason /* promote the child to a root */ 276bb803951SChris Mason child = read_node_slot(root, mid_buf, 0); 277bb803951SChris Mason BUG_ON(!child); 278bb803951SChris Mason root->node = child; 279bb803951SChris Mason path->nodes[level] = NULL; 280bb803951SChris Mason /* once for the path */ 281bb803951SChris Mason tree_block_release(root, mid_buf); 282bb803951SChris Mason /* once for the root ptr */ 283bb803951SChris Mason tree_block_release(root, mid_buf); 284ed2ff2cbSChris Mason clean_tree_block(root, mid_buf); 285bb803951SChris Mason return free_extent(root, blocknr, 1); 286bb803951SChris Mason } 287bb803951SChris Mason parent = &parent_buf->node; 288bb803951SChris Mason 289bb803951SChris Mason if (mid->header.nritems > NODEPTRS_PER_BLOCK / 4) 290bb803951SChris Mason return 0; 291bb803951SChris Mason 292bb803951SChris Mason left_buf = read_node_slot(root, parent_buf, pslot - 1); 293bb803951SChris Mason right_buf = read_node_slot(root, parent_buf, pslot + 1); 29479f95c82SChris Mason 29579f95c82SChris Mason /* first, try to make some room in the middle buffer */ 296bb803951SChris Mason if (left_buf) { 29702217ed2SChris Mason btrfs_cow_block(root, left_buf, parent_buf, 29802217ed2SChris Mason pslot - 1, &left_buf); 299bb803951SChris Mason left = &left_buf->node; 300bb803951SChris Mason orig_slot += left->header.nritems; 30179f95c82SChris Mason wret = push_node_left(root, left_buf, mid_buf); 30279f95c82SChris Mason if (wret < 0) 30379f95c82SChris Mason ret = wret; 304bb803951SChris Mason } 30579f95c82SChris Mason 30679f95c82SChris Mason /* 30779f95c82SChris Mason * then try to empty the right most buffer into the middle 30879f95c82SChris Mason */ 309bb803951SChris Mason if (right_buf) { 31002217ed2SChris Mason btrfs_cow_block(root, right_buf, parent_buf, 31102217ed2SChris Mason pslot + 1, &right_buf); 31279f95c82SChris Mason right = &right_buf->node; 31379f95c82SChris Mason wret = push_node_left(root, mid_buf, right_buf); 31479f95c82SChris Mason if (wret < 0) 31579f95c82SChris Mason ret = wret; 316bb803951SChris Mason if (right->header.nritems == 0) { 317bb803951SChris Mason u64 blocknr = right_buf->blocknr; 318bb803951SChris Mason tree_block_release(root, right_buf); 319ed2ff2cbSChris Mason clean_tree_block(root, right_buf); 320bb803951SChris Mason right_buf = NULL; 321bb803951SChris Mason right = NULL; 322bb803951SChris Mason wret = del_ptr(root, path, level + 1, pslot + 1); 323bb803951SChris Mason if (wret) 324bb803951SChris Mason ret = wret; 325bb803951SChris Mason wret = free_extent(root, blocknr, 1); 326bb803951SChris Mason if (wret) 327bb803951SChris Mason ret = wret; 328bb803951SChris Mason } else { 329bb803951SChris Mason memcpy(parent->keys + pslot + 1, right->keys, 330bb803951SChris Mason sizeof(struct key)); 33102217ed2SChris Mason BUG_ON(list_empty(&parent_buf->dirty)); 332bb803951SChris Mason } 333bb803951SChris Mason } 33479f95c82SChris Mason if (mid->header.nritems == 1) { 33579f95c82SChris Mason /* 33679f95c82SChris Mason * we're not allowed to leave a node with one item in the 33779f95c82SChris Mason * tree during a delete. A deletion from lower in the tree 33879f95c82SChris Mason * could try to delete the only pointer in this node. 33979f95c82SChris Mason * So, pull some keys from the left. 34079f95c82SChris Mason * There has to be a left pointer at this point because 34179f95c82SChris Mason * otherwise we would have pulled some pointers from the 34279f95c82SChris Mason * right 34379f95c82SChris Mason */ 34479f95c82SChris Mason BUG_ON(!left_buf); 34579f95c82SChris Mason wret = balance_node_right(root, mid_buf, left_buf); 34679f95c82SChris Mason if (wret < 0) 34779f95c82SChris Mason ret = wret; 34879f95c82SChris Mason BUG_ON(wret == 1); 34979f95c82SChris Mason } 350bb803951SChris Mason if (mid->header.nritems == 0) { 35179f95c82SChris Mason /* we've managed to empty the middle node, drop it */ 352bb803951SChris Mason u64 blocknr = mid_buf->blocknr; 353bb803951SChris Mason tree_block_release(root, mid_buf); 354ed2ff2cbSChris Mason clean_tree_block(root, mid_buf); 355bb803951SChris Mason mid_buf = NULL; 356bb803951SChris Mason mid = NULL; 357bb803951SChris Mason wret = del_ptr(root, path, level + 1, pslot); 358bb803951SChris Mason if (wret) 359bb803951SChris Mason ret = wret; 360bb803951SChris Mason wret = free_extent(root, blocknr, 1); 361bb803951SChris Mason if (wret) 362bb803951SChris Mason ret = wret; 36379f95c82SChris Mason } else { 36479f95c82SChris Mason /* update the parent key to reflect our changes */ 365bb803951SChris Mason memcpy(parent->keys + pslot, mid->keys, sizeof(struct key)); 36602217ed2SChris Mason BUG_ON(list_empty(&parent_buf->dirty)); 36779f95c82SChris Mason } 368bb803951SChris Mason 36979f95c82SChris Mason /* update the path */ 370bb803951SChris Mason if (left_buf) { 37179f95c82SChris Mason if (left->header.nritems > orig_slot) { 372bb803951SChris Mason left_buf->count++; // released below 373bb803951SChris Mason path->nodes[level] = left_buf; 374bb803951SChris Mason path->slots[level + 1] -= 1; 375bb803951SChris Mason path->slots[level] = orig_slot; 376bb803951SChris Mason if (mid_buf) 377bb803951SChris Mason tree_block_release(root, mid_buf); 378bb803951SChris Mason } else { 379bb803951SChris Mason orig_slot -= left->header.nritems; 380bb803951SChris Mason path->slots[level] = orig_slot; 381bb803951SChris Mason } 382bb803951SChris Mason } 38379f95c82SChris Mason /* double check we haven't messed things up */ 38479f95c82SChris Mason check_block(path, level); 38579f95c82SChris Mason if (orig_ptr != path->nodes[level]->node.blockptrs[path->slots[level]]) 38679f95c82SChris Mason BUG(); 387bb803951SChris Mason 388bb803951SChris Mason if (right_buf) 389bb803951SChris Mason tree_block_release(root, right_buf); 390bb803951SChris Mason if (left_buf) 391bb803951SChris Mason tree_block_release(root, left_buf); 392bb803951SChris Mason return ret; 393bb803951SChris Mason } 394bb803951SChris Mason 39574123bd7SChris Mason /* 39674123bd7SChris Mason * look for key in the tree. path is filled in with nodes along the way 39774123bd7SChris Mason * if key is found, we return zero and you can find the item in the leaf 39874123bd7SChris Mason * level of the path (level 0) 39974123bd7SChris Mason * 40074123bd7SChris Mason * If the key isn't found, the path points to the slot where it should 401aa5d6bedSChris Mason * be inserted, and 1 is returned. If there are other errors during the 402aa5d6bedSChris Mason * search a negative error number is returned. 40397571fd0SChris Mason * 40497571fd0SChris Mason * if ins_len > 0, nodes and leaves will be split as we walk down the 40597571fd0SChris Mason * tree. if ins_len < 0, nodes will be merged as we walk down the tree (if 40697571fd0SChris Mason * possible) 40774123bd7SChris Mason */ 4085de08d7dSChris Mason int search_slot(struct ctree_root *root, struct key *key, 40902217ed2SChris Mason struct ctree_path *p, int ins_len, int cow) 410be0e5c09SChris Mason { 411bb803951SChris Mason struct tree_buffer *b; 41202217ed2SChris Mason struct tree_buffer *cow_buf; 413eb60ceacSChris Mason struct node *c; 414be0e5c09SChris Mason int slot; 415be0e5c09SChris Mason int ret; 416be0e5c09SChris Mason int level; 4175c680ed6SChris Mason 418bb803951SChris Mason again: 419bb803951SChris Mason b = root->node; 420eb60ceacSChris Mason b->count++; 421eb60ceacSChris Mason while (b) { 42202217ed2SChris Mason level = node_level(b->node.header.flags); 42302217ed2SChris Mason if (cow) { 42402217ed2SChris Mason int wret; 42502217ed2SChris Mason wret = btrfs_cow_block(root, b, p->nodes[level + 1], 42602217ed2SChris Mason p->slots[level + 1], &cow_buf); 42702217ed2SChris Mason b = cow_buf; 42802217ed2SChris Mason } 42902217ed2SChris Mason BUG_ON(!cow && ins_len); 430eb60ceacSChris Mason c = &b->node; 431eb60ceacSChris Mason p->nodes[level] = b; 432aa5d6bedSChris Mason ret = check_block(p, level); 433aa5d6bedSChris Mason if (ret) 434aa5d6bedSChris Mason return -1; 435be0e5c09SChris Mason ret = bin_search(c, key, &slot); 436be0e5c09SChris Mason if (!is_leaf(c->header.flags)) { 437be0e5c09SChris Mason if (ret && slot > 0) 438be0e5c09SChris Mason slot -= 1; 439be0e5c09SChris Mason p->slots[level] = slot; 4405de08d7dSChris Mason if (ins_len > 0 && 4415de08d7dSChris Mason c->header.nritems == NODEPTRS_PER_BLOCK) { 4425c680ed6SChris Mason int sret = split_node(root, p, level); 4435c680ed6SChris Mason BUG_ON(sret > 0); 4445c680ed6SChris Mason if (sret) 4455c680ed6SChris Mason return sret; 4465c680ed6SChris Mason b = p->nodes[level]; 4475c680ed6SChris Mason c = &b->node; 4485c680ed6SChris Mason slot = p->slots[level]; 449bb803951SChris Mason } else if (ins_len < 0) { 450bb803951SChris Mason int sret = balance_level(root, p, level); 451bb803951SChris Mason if (sret) 452bb803951SChris Mason return sret; 453bb803951SChris Mason b = p->nodes[level]; 454bb803951SChris Mason if (!b) 455bb803951SChris Mason goto again; 456bb803951SChris Mason c = &b->node; 457bb803951SChris Mason slot = p->slots[level]; 45879f95c82SChris Mason BUG_ON(c->header.nritems == 1); 4595c680ed6SChris Mason } 460eb60ceacSChris Mason b = read_tree_block(root, c->blockptrs[slot]); 461be0e5c09SChris Mason } else { 4625c680ed6SChris Mason struct leaf *l = (struct leaf *)c; 463be0e5c09SChris Mason p->slots[level] = slot; 4645de08d7dSChris Mason if (ins_len > 0 && leaf_free_space(l) < 4655de08d7dSChris Mason sizeof(struct item) + ins_len) { 4665c680ed6SChris Mason int sret = split_leaf(root, p, ins_len); 4675c680ed6SChris Mason BUG_ON(sret > 0); 4685c680ed6SChris Mason if (sret) 4695c680ed6SChris Mason return sret; 4705c680ed6SChris Mason } 471bb803951SChris Mason BUG_ON(root->node->count == 1); 472be0e5c09SChris Mason return ret; 473be0e5c09SChris Mason } 474be0e5c09SChris Mason } 475bb803951SChris Mason BUG_ON(root->node->count == 1); 476aa5d6bedSChris Mason return 1; 477be0e5c09SChris Mason } 478be0e5c09SChris Mason 47974123bd7SChris Mason /* 48074123bd7SChris Mason * adjust the pointers going up the tree, starting at level 48174123bd7SChris Mason * making sure the right key of each node is points to 'key'. 48274123bd7SChris Mason * This is used after shifting pointers to the left, so it stops 48374123bd7SChris Mason * fixing up pointers when a given leaf/node is not in slot 0 of the 48474123bd7SChris Mason * higher levels 485aa5d6bedSChris Mason * 486aa5d6bedSChris Mason * If this fails to write a tree block, it returns -1, but continues 487aa5d6bedSChris Mason * fixing up the blocks in ram so the tree is consistent. 48874123bd7SChris Mason */ 489aa5d6bedSChris Mason static int fixup_low_keys(struct ctree_root *root, 490eb60ceacSChris Mason struct ctree_path *path, struct key *key, 491be0e5c09SChris Mason int level) 492be0e5c09SChris Mason { 493be0e5c09SChris Mason int i; 494aa5d6bedSChris Mason int ret = 0; 495be0e5c09SChris Mason for (i = level; i < MAX_LEVEL; i++) { 496eb60ceacSChris Mason struct node *t; 497be0e5c09SChris Mason int tslot = path->slots[i]; 498eb60ceacSChris Mason if (!path->nodes[i]) 499be0e5c09SChris Mason break; 500eb60ceacSChris Mason t = &path->nodes[i]->node; 501be0e5c09SChris Mason memcpy(t->keys + tslot, key, sizeof(*key)); 50202217ed2SChris Mason BUG_ON(list_empty(&path->nodes[i]->dirty)); 503be0e5c09SChris Mason if (tslot != 0) 504be0e5c09SChris Mason break; 505be0e5c09SChris Mason } 506aa5d6bedSChris Mason return ret; 507be0e5c09SChris Mason } 508be0e5c09SChris Mason 50974123bd7SChris Mason /* 51074123bd7SChris Mason * try to push data from one node into the next node left in the 51179f95c82SChris Mason * tree. 512aa5d6bedSChris Mason * 513aa5d6bedSChris Mason * returns 0 if some ptrs were pushed left, < 0 if there was some horrible 514aa5d6bedSChris Mason * error, and > 0 if there was no room in the left hand block. 51574123bd7SChris Mason */ 516bb803951SChris Mason static int push_node_left(struct ctree_root *root, struct tree_buffer *dst_buf, 517bb803951SChris Mason struct tree_buffer *src_buf) 518be0e5c09SChris Mason { 519bb803951SChris Mason struct node *src = &src_buf->node; 520bb803951SChris Mason struct node *dst = &dst_buf->node; 521be0e5c09SChris Mason int push_items = 0; 522bb803951SChris Mason int src_nritems; 523bb803951SChris Mason int dst_nritems; 524aa5d6bedSChris Mason int ret = 0; 525be0e5c09SChris Mason 526be0e5c09SChris Mason src_nritems = src->header.nritems; 527bb803951SChris Mason dst_nritems = dst->header.nritems; 528bb803951SChris Mason push_items = NODEPTRS_PER_BLOCK - dst_nritems; 529eb60ceacSChris Mason if (push_items <= 0) { 530be0e5c09SChris Mason return 1; 531eb60ceacSChris Mason } 532be0e5c09SChris Mason 533be0e5c09SChris Mason if (src_nritems < push_items) 534be0e5c09SChris Mason push_items = src_nritems; 53579f95c82SChris Mason 536bb803951SChris Mason memcpy(dst->keys + dst_nritems, src->keys, 537be0e5c09SChris Mason push_items * sizeof(struct key)); 538bb803951SChris Mason memcpy(dst->blockptrs + dst_nritems, src->blockptrs, 539be0e5c09SChris Mason push_items * sizeof(u64)); 540bb803951SChris Mason if (push_items < src_nritems) { 541bb803951SChris Mason memmove(src->keys, src->keys + push_items, 542bb803951SChris Mason (src_nritems - push_items) * sizeof(struct key)); 543bb803951SChris Mason memmove(src->blockptrs, src->blockptrs + push_items, 544bb803951SChris Mason (src_nritems - push_items) * sizeof(u64)); 545bb803951SChris Mason } 546be0e5c09SChris Mason src->header.nritems -= push_items; 547be0e5c09SChris Mason dst->header.nritems += push_items; 548be0e5c09SChris Mason 54902217ed2SChris Mason BUG_ON(list_empty(&src_buf->dirty)); 55002217ed2SChris Mason BUG_ON(list_empty(&dst_buf->dirty)); 551bb803951SChris Mason return ret; 552be0e5c09SChris Mason } 553be0e5c09SChris Mason 55497571fd0SChris Mason /* 55579f95c82SChris Mason * try to push data from one node into the next node right in the 55679f95c82SChris Mason * tree. 55779f95c82SChris Mason * 55879f95c82SChris Mason * returns 0 if some ptrs were pushed, < 0 if there was some horrible 55979f95c82SChris Mason * error, and > 0 if there was no room in the right hand block. 56079f95c82SChris Mason * 56179f95c82SChris Mason * this will only push up to 1/2 the contents of the left node over 56279f95c82SChris Mason */ 56379f95c82SChris Mason static int balance_node_right(struct ctree_root *root, 56479f95c82SChris Mason struct tree_buffer *dst_buf, 56579f95c82SChris Mason struct tree_buffer *src_buf) 56679f95c82SChris Mason { 56779f95c82SChris Mason struct node *src = &src_buf->node; 56879f95c82SChris Mason struct node *dst = &dst_buf->node; 56979f95c82SChris Mason int push_items = 0; 57079f95c82SChris Mason int max_push; 57179f95c82SChris Mason int src_nritems; 57279f95c82SChris Mason int dst_nritems; 57379f95c82SChris Mason int ret = 0; 57479f95c82SChris Mason 57579f95c82SChris Mason src_nritems = src->header.nritems; 57679f95c82SChris Mason dst_nritems = dst->header.nritems; 57779f95c82SChris Mason push_items = NODEPTRS_PER_BLOCK - dst_nritems; 57879f95c82SChris Mason if (push_items <= 0) { 57979f95c82SChris Mason return 1; 58079f95c82SChris Mason } 58179f95c82SChris Mason 58279f95c82SChris Mason max_push = src_nritems / 2 + 1; 58379f95c82SChris Mason /* don't try to empty the node */ 58479f95c82SChris Mason if (max_push > src_nritems) 58579f95c82SChris Mason return 1; 58679f95c82SChris Mason if (max_push < push_items) 58779f95c82SChris Mason push_items = max_push; 58879f95c82SChris Mason 58979f95c82SChris Mason memmove(dst->keys + push_items, dst->keys, 59079f95c82SChris Mason dst_nritems * sizeof(struct key)); 59179f95c82SChris Mason memmove(dst->blockptrs + push_items, dst->blockptrs, 59279f95c82SChris Mason dst_nritems * sizeof(u64)); 59379f95c82SChris Mason memcpy(dst->keys, src->keys + src_nritems - push_items, 59479f95c82SChris Mason push_items * sizeof(struct key)); 59579f95c82SChris Mason memcpy(dst->blockptrs, src->blockptrs + src_nritems - push_items, 59679f95c82SChris Mason push_items * sizeof(u64)); 59779f95c82SChris Mason 59879f95c82SChris Mason src->header.nritems -= push_items; 59979f95c82SChris Mason dst->header.nritems += push_items; 60079f95c82SChris Mason 60102217ed2SChris Mason BUG_ON(list_empty(&src_buf->dirty)); 60202217ed2SChris Mason BUG_ON(list_empty(&dst_buf->dirty)); 60379f95c82SChris Mason return ret; 60479f95c82SChris Mason } 60579f95c82SChris Mason 60679f95c82SChris Mason /* 60797571fd0SChris Mason * helper function to insert a new root level in the tree. 60897571fd0SChris Mason * A new node is allocated, and a single item is inserted to 60997571fd0SChris Mason * point to the existing root 610aa5d6bedSChris Mason * 611aa5d6bedSChris Mason * returns zero on success or < 0 on failure. 61297571fd0SChris Mason */ 6135de08d7dSChris Mason static int insert_new_root(struct ctree_root *root, 6145de08d7dSChris Mason struct ctree_path *path, int level) 61574123bd7SChris Mason { 61674123bd7SChris Mason struct tree_buffer *t; 6175c680ed6SChris Mason struct node *lower; 6185c680ed6SChris Mason struct node *c; 6195c680ed6SChris Mason struct key *lower_key; 6205c680ed6SChris Mason 6215c680ed6SChris Mason BUG_ON(path->nodes[level]); 6225c680ed6SChris Mason BUG_ON(path->nodes[level-1] != root->node); 6235c680ed6SChris Mason 62474123bd7SChris Mason t = alloc_free_block(root); 62574123bd7SChris Mason c = &t->node; 62674123bd7SChris Mason memset(c, 0, sizeof(c)); 6275c680ed6SChris Mason c->header.nritems = 1; 62874123bd7SChris Mason c->header.flags = node_level(level); 62974123bd7SChris Mason c->header.blocknr = t->blocknr; 630cfaa7295SChris Mason c->header.parentid = root->node->node.header.parentid; 63174123bd7SChris Mason lower = &path->nodes[level-1]->node; 63274123bd7SChris Mason if (is_leaf(lower->header.flags)) 63374123bd7SChris Mason lower_key = &((struct leaf *)lower)->items[0].key; 63474123bd7SChris Mason else 63574123bd7SChris Mason lower_key = lower->keys; 63674123bd7SChris Mason memcpy(c->keys, lower_key, sizeof(struct key)); 63774123bd7SChris Mason c->blockptrs[0] = path->nodes[level-1]->blocknr; 638cfaa7295SChris Mason /* the super has an extra ref to root->node */ 63974123bd7SChris Mason tree_block_release(root, root->node); 64074123bd7SChris Mason root->node = t; 64174123bd7SChris Mason t->count++; 64274123bd7SChris Mason path->nodes[level] = t; 64374123bd7SChris Mason path->slots[level] = 0; 64474123bd7SChris Mason return 0; 64574123bd7SChris Mason } 6465c680ed6SChris Mason 6475c680ed6SChris Mason /* 6485c680ed6SChris Mason * worker function to insert a single pointer in a node. 6495c680ed6SChris Mason * the node should have enough room for the pointer already 65097571fd0SChris Mason * 6515c680ed6SChris Mason * slot and level indicate where you want the key to go, and 6525c680ed6SChris Mason * blocknr is the block the key points to. 653aa5d6bedSChris Mason * 654aa5d6bedSChris Mason * returns zero on success and < 0 on any error 6555c680ed6SChris Mason */ 656aa5d6bedSChris Mason static int insert_ptr(struct ctree_root *root, 6575c680ed6SChris Mason struct ctree_path *path, struct key *key, 6585c680ed6SChris Mason u64 blocknr, int slot, int level) 6595c680ed6SChris Mason { 6605c680ed6SChris Mason struct node *lower; 6615c680ed6SChris Mason int nritems; 6625c680ed6SChris Mason 6635c680ed6SChris Mason BUG_ON(!path->nodes[level]); 66474123bd7SChris Mason lower = &path->nodes[level]->node; 66574123bd7SChris Mason nritems = lower->header.nritems; 66674123bd7SChris Mason if (slot > nritems) 66774123bd7SChris Mason BUG(); 66874123bd7SChris Mason if (nritems == NODEPTRS_PER_BLOCK) 66974123bd7SChris Mason BUG(); 67074123bd7SChris Mason if (slot != nritems) { 67174123bd7SChris Mason memmove(lower->keys + slot + 1, lower->keys + slot, 67274123bd7SChris Mason (nritems - slot) * sizeof(struct key)); 67374123bd7SChris Mason memmove(lower->blockptrs + slot + 1, lower->blockptrs + slot, 67474123bd7SChris Mason (nritems - slot) * sizeof(u64)); 67574123bd7SChris Mason } 67674123bd7SChris Mason memcpy(lower->keys + slot, key, sizeof(struct key)); 67774123bd7SChris Mason lower->blockptrs[slot] = blocknr; 67874123bd7SChris Mason lower->header.nritems++; 67974123bd7SChris Mason if (lower->keys[1].objectid == 0) 68074123bd7SChris Mason BUG(); 68102217ed2SChris Mason BUG_ON(list_empty(&path->nodes[level]->dirty)); 68274123bd7SChris Mason return 0; 68374123bd7SChris Mason } 68474123bd7SChris Mason 68597571fd0SChris Mason /* 68697571fd0SChris Mason * split the node at the specified level in path in two. 68797571fd0SChris Mason * The path is corrected to point to the appropriate node after the split 68897571fd0SChris Mason * 68997571fd0SChris Mason * Before splitting this tries to make some room in the node by pushing 69097571fd0SChris Mason * left and right, if either one works, it returns right away. 691aa5d6bedSChris Mason * 692aa5d6bedSChris Mason * returns 0 on success and < 0 on failure 69397571fd0SChris Mason */ 694aa5d6bedSChris Mason static int split_node(struct ctree_root *root, struct ctree_path *path, 695aa5d6bedSChris Mason int level) 696be0e5c09SChris Mason { 6975c680ed6SChris Mason struct tree_buffer *t; 6985c680ed6SChris Mason struct node *c; 6995c680ed6SChris Mason struct tree_buffer *split_buffer; 7005c680ed6SChris Mason struct node *split; 701be0e5c09SChris Mason int mid; 7025c680ed6SChris Mason int ret; 703aa5d6bedSChris Mason int wret; 704be0e5c09SChris Mason 7055c680ed6SChris Mason t = path->nodes[level]; 706eb60ceacSChris Mason c = &t->node; 7075c680ed6SChris Mason if (t == root->node) { 7085c680ed6SChris Mason /* trying to split the root, lets make a new one */ 7095c680ed6SChris Mason ret = insert_new_root(root, path, level + 1); 7105c680ed6SChris Mason if (ret) 7115c680ed6SChris Mason return ret; 7125c680ed6SChris Mason } 7135c680ed6SChris Mason split_buffer = alloc_free_block(root); 7145c680ed6SChris Mason split = &split_buffer->node; 7155c680ed6SChris Mason split->header.flags = c->header.flags; 7165c680ed6SChris Mason split->header.blocknr = split_buffer->blocknr; 7175c680ed6SChris Mason split->header.parentid = root->node->node.header.parentid; 718be0e5c09SChris Mason mid = (c->header.nritems + 1) / 2; 7195c680ed6SChris Mason memcpy(split->keys, c->keys + mid, 720be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(struct key)); 7215c680ed6SChris Mason memcpy(split->blockptrs, c->blockptrs + mid, 722be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(u64)); 7235c680ed6SChris Mason split->header.nritems = c->header.nritems - mid; 724be0e5c09SChris Mason c->header.nritems = mid; 725aa5d6bedSChris Mason ret = 0; 726aa5d6bedSChris Mason 72702217ed2SChris Mason BUG_ON(list_empty(&t->dirty)); 728aa5d6bedSChris Mason wret = insert_ptr(root, path, split->keys, split_buffer->blocknr, 7295c680ed6SChris Mason path->slots[level + 1] + 1, level + 1); 730aa5d6bedSChris Mason if (wret) 731aa5d6bedSChris Mason ret = wret; 732aa5d6bedSChris Mason 7335de08d7dSChris Mason if (path->slots[level] >= mid) { 7345c680ed6SChris Mason path->slots[level] -= mid; 7355c680ed6SChris Mason tree_block_release(root, t); 7365c680ed6SChris Mason path->nodes[level] = split_buffer; 7375c680ed6SChris Mason path->slots[level + 1] += 1; 738eb60ceacSChris Mason } else { 7395c680ed6SChris Mason tree_block_release(root, split_buffer); 740be0e5c09SChris Mason } 741aa5d6bedSChris Mason return ret; 742be0e5c09SChris Mason } 743be0e5c09SChris Mason 74474123bd7SChris Mason /* 74574123bd7SChris Mason * how many bytes are required to store the items in a leaf. start 74674123bd7SChris Mason * and nr indicate which items in the leaf to check. This totals up the 74774123bd7SChris Mason * space used both by the item structs and the item data 74874123bd7SChris Mason */ 749aa5d6bedSChris Mason static int leaf_space_used(struct leaf *l, int start, int nr) 750be0e5c09SChris Mason { 751be0e5c09SChris Mason int data_len; 752be0e5c09SChris Mason int end = start + nr - 1; 753be0e5c09SChris Mason 754be0e5c09SChris Mason if (!nr) 755be0e5c09SChris Mason return 0; 756be0e5c09SChris Mason data_len = l->items[start].offset + l->items[start].size; 757be0e5c09SChris Mason data_len = data_len - l->items[end].offset; 758be0e5c09SChris Mason data_len += sizeof(struct item) * nr; 759be0e5c09SChris Mason return data_len; 760be0e5c09SChris Mason } 761be0e5c09SChris Mason 76274123bd7SChris Mason /* 76300ec4c51SChris Mason * push some data in the path leaf to the right, trying to free up at 76400ec4c51SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 765aa5d6bedSChris Mason * 766aa5d6bedSChris Mason * returns 1 if the push failed because the other node didn't have enough 767aa5d6bedSChris Mason * room, 0 if everything worked out and < 0 if there were major errors. 76800ec4c51SChris Mason */ 769aa5d6bedSChris Mason static int push_leaf_right(struct ctree_root *root, struct ctree_path *path, 77000ec4c51SChris Mason int data_size) 77100ec4c51SChris Mason { 77200ec4c51SChris Mason struct tree_buffer *left_buf = path->nodes[0]; 77300ec4c51SChris Mason struct leaf *left = &left_buf->leaf; 77400ec4c51SChris Mason struct leaf *right; 77500ec4c51SChris Mason struct tree_buffer *right_buf; 77600ec4c51SChris Mason struct tree_buffer *upper; 77700ec4c51SChris Mason int slot; 77800ec4c51SChris Mason int i; 77900ec4c51SChris Mason int free_space; 78000ec4c51SChris Mason int push_space = 0; 78100ec4c51SChris Mason int push_items = 0; 78200ec4c51SChris Mason struct item *item; 78300ec4c51SChris Mason 78400ec4c51SChris Mason slot = path->slots[1]; 78500ec4c51SChris Mason if (!path->nodes[1]) { 78600ec4c51SChris Mason return 1; 78700ec4c51SChris Mason } 78800ec4c51SChris Mason upper = path->nodes[1]; 78900ec4c51SChris Mason if (slot >= upper->node.header.nritems - 1) { 79000ec4c51SChris Mason return 1; 79100ec4c51SChris Mason } 79200ec4c51SChris Mason right_buf = read_tree_block(root, upper->node.blockptrs[slot + 1]); 79300ec4c51SChris Mason right = &right_buf->leaf; 79400ec4c51SChris Mason free_space = leaf_free_space(right); 79500ec4c51SChris Mason if (free_space < data_size + sizeof(struct item)) { 79600ec4c51SChris Mason tree_block_release(root, right_buf); 79700ec4c51SChris Mason return 1; 79800ec4c51SChris Mason } 79902217ed2SChris Mason /* cow and double check */ 80002217ed2SChris Mason btrfs_cow_block(root, right_buf, upper, slot + 1, &right_buf); 80102217ed2SChris Mason right = &right_buf->leaf; 80202217ed2SChris Mason free_space = leaf_free_space(right); 80302217ed2SChris Mason if (free_space < data_size + sizeof(struct item)) { 80402217ed2SChris Mason tree_block_release(root, right_buf); 80502217ed2SChris Mason return 1; 80602217ed2SChris Mason } 80702217ed2SChris Mason 80800ec4c51SChris Mason for (i = left->header.nritems - 1; i >= 0; i--) { 80900ec4c51SChris Mason item = left->items + i; 81000ec4c51SChris Mason if (path->slots[0] == i) 81100ec4c51SChris Mason push_space += data_size + sizeof(*item); 81200ec4c51SChris Mason if (item->size + sizeof(*item) + push_space > free_space) 81300ec4c51SChris Mason break; 81400ec4c51SChris Mason push_items++; 81500ec4c51SChris Mason push_space += item->size + sizeof(*item); 81600ec4c51SChris Mason } 81700ec4c51SChris Mason if (push_items == 0) { 81800ec4c51SChris Mason tree_block_release(root, right_buf); 81900ec4c51SChris Mason return 1; 82000ec4c51SChris Mason } 82100ec4c51SChris Mason /* push left to right */ 82200ec4c51SChris Mason push_space = left->items[left->header.nritems - push_items].offset + 82300ec4c51SChris Mason left->items[left->header.nritems - push_items].size; 82400ec4c51SChris Mason push_space -= leaf_data_end(left); 82500ec4c51SChris Mason /* make room in the right data area */ 82600ec4c51SChris Mason memmove(right->data + leaf_data_end(right) - push_space, 82700ec4c51SChris Mason right->data + leaf_data_end(right), 82800ec4c51SChris Mason LEAF_DATA_SIZE - leaf_data_end(right)); 82900ec4c51SChris Mason /* copy from the left data area */ 83000ec4c51SChris Mason memcpy(right->data + LEAF_DATA_SIZE - push_space, 83100ec4c51SChris Mason left->data + leaf_data_end(left), 83200ec4c51SChris Mason push_space); 83300ec4c51SChris Mason memmove(right->items + push_items, right->items, 83400ec4c51SChris Mason right->header.nritems * sizeof(struct item)); 83500ec4c51SChris Mason /* copy the items from left to right */ 83600ec4c51SChris Mason memcpy(right->items, left->items + left->header.nritems - push_items, 83700ec4c51SChris Mason push_items * sizeof(struct item)); 83800ec4c51SChris Mason 83900ec4c51SChris Mason /* update the item pointers */ 84000ec4c51SChris Mason right->header.nritems += push_items; 84100ec4c51SChris Mason push_space = LEAF_DATA_SIZE; 84200ec4c51SChris Mason for (i = 0; i < right->header.nritems; i++) { 84300ec4c51SChris Mason right->items[i].offset = push_space - right->items[i].size; 84400ec4c51SChris Mason push_space = right->items[i].offset; 84500ec4c51SChris Mason } 84600ec4c51SChris Mason left->header.nritems -= push_items; 84700ec4c51SChris Mason 84802217ed2SChris Mason BUG_ON(list_empty(&left_buf->dirty)); 84902217ed2SChris Mason BUG_ON(list_empty(&right_buf->dirty)); 85000ec4c51SChris Mason memcpy(upper->node.keys + slot + 1, 85100ec4c51SChris Mason &right->items[0].key, sizeof(struct key)); 85202217ed2SChris Mason BUG_ON(list_empty(&upper->dirty)); 85302217ed2SChris Mason 85400ec4c51SChris Mason /* then fixup the leaf pointer in the path */ 85500ec4c51SChris Mason if (path->slots[0] >= left->header.nritems) { 85600ec4c51SChris Mason path->slots[0] -= left->header.nritems; 85700ec4c51SChris Mason tree_block_release(root, path->nodes[0]); 85800ec4c51SChris Mason path->nodes[0] = right_buf; 85900ec4c51SChris Mason path->slots[1] += 1; 86000ec4c51SChris Mason } else { 86100ec4c51SChris Mason tree_block_release(root, right_buf); 86200ec4c51SChris Mason } 86300ec4c51SChris Mason return 0; 86400ec4c51SChris Mason } 86500ec4c51SChris Mason /* 86674123bd7SChris Mason * push some data in the path leaf to the left, trying to free up at 86774123bd7SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 86874123bd7SChris Mason */ 869aa5d6bedSChris Mason static int push_leaf_left(struct ctree_root *root, struct ctree_path *path, 870be0e5c09SChris Mason int data_size) 871be0e5c09SChris Mason { 872eb60ceacSChris Mason struct tree_buffer *right_buf = path->nodes[0]; 873eb60ceacSChris Mason struct leaf *right = &right_buf->leaf; 874eb60ceacSChris Mason struct tree_buffer *t; 875be0e5c09SChris Mason struct leaf *left; 876be0e5c09SChris Mason int slot; 877be0e5c09SChris Mason int i; 878be0e5c09SChris Mason int free_space; 879be0e5c09SChris Mason int push_space = 0; 880be0e5c09SChris Mason int push_items = 0; 881be0e5c09SChris Mason struct item *item; 882be0e5c09SChris Mason int old_left_nritems; 883aa5d6bedSChris Mason int ret = 0; 884aa5d6bedSChris Mason int wret; 885be0e5c09SChris Mason 886be0e5c09SChris Mason slot = path->slots[1]; 887be0e5c09SChris Mason if (slot == 0) { 888be0e5c09SChris Mason return 1; 889be0e5c09SChris Mason } 890be0e5c09SChris Mason if (!path->nodes[1]) { 891be0e5c09SChris Mason return 1; 892be0e5c09SChris Mason } 893eb60ceacSChris Mason t = read_tree_block(root, path->nodes[1]->node.blockptrs[slot - 1]); 894eb60ceacSChris Mason left = &t->leaf; 895be0e5c09SChris Mason free_space = leaf_free_space(left); 896be0e5c09SChris Mason if (free_space < data_size + sizeof(struct item)) { 897eb60ceacSChris Mason tree_block_release(root, t); 898be0e5c09SChris Mason return 1; 899be0e5c09SChris Mason } 90002217ed2SChris Mason 90102217ed2SChris Mason /* cow and double check */ 90202217ed2SChris Mason btrfs_cow_block(root, t, path->nodes[1], slot - 1, &t); 90302217ed2SChris Mason left = &t->leaf; 90402217ed2SChris Mason free_space = leaf_free_space(left); 90502217ed2SChris Mason if (free_space < data_size + sizeof(struct item)) { 90602217ed2SChris Mason tree_block_release(root, t); 90702217ed2SChris Mason return 1; 90802217ed2SChris Mason } 90902217ed2SChris Mason 910be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 911be0e5c09SChris Mason item = right->items + i; 912be0e5c09SChris Mason if (path->slots[0] == i) 913be0e5c09SChris Mason push_space += data_size + sizeof(*item); 914be0e5c09SChris Mason if (item->size + sizeof(*item) + push_space > free_space) 915be0e5c09SChris Mason break; 916be0e5c09SChris Mason push_items++; 917be0e5c09SChris Mason push_space += item->size + sizeof(*item); 918be0e5c09SChris Mason } 919be0e5c09SChris Mason if (push_items == 0) { 920eb60ceacSChris Mason tree_block_release(root, t); 921be0e5c09SChris Mason return 1; 922be0e5c09SChris Mason } 923be0e5c09SChris Mason /* push data from right to left */ 924be0e5c09SChris Mason memcpy(left->items + left->header.nritems, 925be0e5c09SChris Mason right->items, push_items * sizeof(struct item)); 926be0e5c09SChris Mason push_space = LEAF_DATA_SIZE - right->items[push_items -1].offset; 927be0e5c09SChris Mason memcpy(left->data + leaf_data_end(left) - push_space, 928be0e5c09SChris Mason right->data + right->items[push_items - 1].offset, 929be0e5c09SChris Mason push_space); 930be0e5c09SChris Mason old_left_nritems = left->header.nritems; 931eb60ceacSChris Mason BUG_ON(old_left_nritems < 0); 932eb60ceacSChris Mason 933be0e5c09SChris Mason for(i = old_left_nritems; i < old_left_nritems + push_items; i++) { 934be0e5c09SChris Mason left->items[i].offset -= LEAF_DATA_SIZE - 935be0e5c09SChris Mason left->items[old_left_nritems -1].offset; 936be0e5c09SChris Mason } 937be0e5c09SChris Mason left->header.nritems += push_items; 938be0e5c09SChris Mason 939be0e5c09SChris Mason /* fixup right node */ 940be0e5c09SChris Mason push_space = right->items[push_items-1].offset - leaf_data_end(right); 941be0e5c09SChris Mason memmove(right->data + LEAF_DATA_SIZE - push_space, right->data + 942be0e5c09SChris Mason leaf_data_end(right), push_space); 943be0e5c09SChris Mason memmove(right->items, right->items + push_items, 944be0e5c09SChris Mason (right->header.nritems - push_items) * sizeof(struct item)); 945be0e5c09SChris Mason right->header.nritems -= push_items; 946be0e5c09SChris Mason push_space = LEAF_DATA_SIZE; 947eb60ceacSChris Mason 948be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 949be0e5c09SChris Mason right->items[i].offset = push_space - right->items[i].size; 950be0e5c09SChris Mason push_space = right->items[i].offset; 951be0e5c09SChris Mason } 952eb60ceacSChris Mason 95302217ed2SChris Mason BUG_ON(list_empty(&t->dirty)); 95402217ed2SChris Mason BUG_ON(list_empty(&right_buf->dirty)); 955eb60ceacSChris Mason 956aa5d6bedSChris Mason wret = fixup_low_keys(root, path, &right->items[0].key, 1); 957aa5d6bedSChris Mason if (wret) 958aa5d6bedSChris Mason ret = wret; 959be0e5c09SChris Mason 960be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 961be0e5c09SChris Mason if (path->slots[0] < push_items) { 962be0e5c09SChris Mason path->slots[0] += old_left_nritems; 963eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 964eb60ceacSChris Mason path->nodes[0] = t; 965be0e5c09SChris Mason path->slots[1] -= 1; 966be0e5c09SChris Mason } else { 967eb60ceacSChris Mason tree_block_release(root, t); 968be0e5c09SChris Mason path->slots[0] -= push_items; 969be0e5c09SChris Mason } 970eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 971aa5d6bedSChris Mason return ret; 972be0e5c09SChris Mason } 973be0e5c09SChris Mason 97474123bd7SChris Mason /* 97574123bd7SChris Mason * split the path's leaf in two, making sure there is at least data_size 97674123bd7SChris Mason * available for the resulting leaf level of the path. 977aa5d6bedSChris Mason * 978aa5d6bedSChris Mason * returns 0 if all went well and < 0 on failure. 97974123bd7SChris Mason */ 980aa5d6bedSChris Mason static int split_leaf(struct ctree_root *root, struct ctree_path *path, 981aa5d6bedSChris Mason int data_size) 982be0e5c09SChris Mason { 983aa5d6bedSChris Mason struct tree_buffer *l_buf; 984aa5d6bedSChris Mason struct leaf *l; 985eb60ceacSChris Mason int nritems; 986eb60ceacSChris Mason int mid; 987eb60ceacSChris Mason int slot; 988be0e5c09SChris Mason struct leaf *right; 989eb60ceacSChris Mason struct tree_buffer *right_buffer; 990be0e5c09SChris Mason int space_needed = data_size + sizeof(struct item); 991be0e5c09SChris Mason int data_copy_size; 992be0e5c09SChris Mason int rt_data_off; 993be0e5c09SChris Mason int i; 994be0e5c09SChris Mason int ret; 995aa5d6bedSChris Mason int wret; 996be0e5c09SChris Mason 997aa5d6bedSChris Mason wret = push_leaf_left(root, path, data_size); 998aa5d6bedSChris Mason if (wret < 0) 999aa5d6bedSChris Mason return wret; 1000aa5d6bedSChris Mason if (wret) { 1001aa5d6bedSChris Mason wret = push_leaf_right(root, path, data_size); 1002aa5d6bedSChris Mason if (wret < 0) 1003aa5d6bedSChris Mason return wret; 1004aa5d6bedSChris Mason } 100502217ed2SChris Mason 1006eb60ceacSChris Mason l_buf = path->nodes[0]; 1007eb60ceacSChris Mason l = &l_buf->leaf; 1008aa5d6bedSChris Mason 1009aa5d6bedSChris Mason /* did the pushes work? */ 1010eb60ceacSChris Mason if (leaf_free_space(l) >= sizeof(struct item) + data_size) 1011be0e5c09SChris Mason return 0; 1012aa5d6bedSChris Mason 10135c680ed6SChris Mason if (!path->nodes[1]) { 10145c680ed6SChris Mason ret = insert_new_root(root, path, 1); 10155c680ed6SChris Mason if (ret) 10165c680ed6SChris Mason return ret; 10175c680ed6SChris Mason } 1018eb60ceacSChris Mason slot = path->slots[0]; 1019eb60ceacSChris Mason nritems = l->header.nritems; 1020eb60ceacSChris Mason mid = (nritems + 1)/ 2; 1021eb60ceacSChris Mason 1022eb60ceacSChris Mason right_buffer = alloc_free_block(root); 1023eb60ceacSChris Mason BUG_ON(!right_buffer); 1024eb60ceacSChris Mason BUG_ON(mid == nritems); 1025eb60ceacSChris Mason right = &right_buffer->leaf; 1026be0e5c09SChris Mason memset(right, 0, sizeof(*right)); 1027be0e5c09SChris Mason if (mid <= slot) { 102897571fd0SChris Mason /* FIXME, just alloc a new leaf here */ 1029be0e5c09SChris Mason if (leaf_space_used(l, mid, nritems - mid) + space_needed > 1030be0e5c09SChris Mason LEAF_DATA_SIZE) 1031be0e5c09SChris Mason BUG(); 1032be0e5c09SChris Mason } else { 103397571fd0SChris Mason /* FIXME, just alloc a new leaf here */ 1034be0e5c09SChris Mason if (leaf_space_used(l, 0, mid + 1) + space_needed > 1035be0e5c09SChris Mason LEAF_DATA_SIZE) 1036be0e5c09SChris Mason BUG(); 1037be0e5c09SChris Mason } 1038be0e5c09SChris Mason right->header.nritems = nritems - mid; 1039eb60ceacSChris Mason right->header.blocknr = right_buffer->blocknr; 1040eb60ceacSChris Mason right->header.flags = node_level(0); 1041cfaa7295SChris Mason right->header.parentid = root->node->node.header.parentid; 1042be0e5c09SChris Mason data_copy_size = l->items[mid].offset + l->items[mid].size - 1043be0e5c09SChris Mason leaf_data_end(l); 1044be0e5c09SChris Mason memcpy(right->items, l->items + mid, 1045be0e5c09SChris Mason (nritems - mid) * sizeof(struct item)); 1046be0e5c09SChris Mason memcpy(right->data + LEAF_DATA_SIZE - data_copy_size, 1047be0e5c09SChris Mason l->data + leaf_data_end(l), data_copy_size); 1048be0e5c09SChris Mason rt_data_off = LEAF_DATA_SIZE - 1049be0e5c09SChris Mason (l->items[mid].offset + l->items[mid].size); 105074123bd7SChris Mason 105174123bd7SChris Mason for (i = 0; i < right->header.nritems; i++) 1052be0e5c09SChris Mason right->items[i].offset += rt_data_off; 105374123bd7SChris Mason 1054be0e5c09SChris Mason l->header.nritems = mid; 1055aa5d6bedSChris Mason ret = 0; 1056aa5d6bedSChris Mason wret = insert_ptr(root, path, &right->items[0].key, 10575c680ed6SChris Mason right_buffer->blocknr, path->slots[1] + 1, 1); 1058aa5d6bedSChris Mason if (wret) 1059aa5d6bedSChris Mason ret = wret; 106002217ed2SChris Mason BUG_ON(list_empty(&right_buffer->dirty)); 106102217ed2SChris Mason BUG_ON(list_empty(&l_buf->dirty)); 1062eb60ceacSChris Mason BUG_ON(path->slots[0] != slot); 1063be0e5c09SChris Mason if (mid <= slot) { 1064eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 1065eb60ceacSChris Mason path->nodes[0] = right_buffer; 1066be0e5c09SChris Mason path->slots[0] -= mid; 1067be0e5c09SChris Mason path->slots[1] += 1; 1068eb60ceacSChris Mason } else 1069eb60ceacSChris Mason tree_block_release(root, right_buffer); 1070eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 1071be0e5c09SChris Mason return ret; 1072be0e5c09SChris Mason } 1073be0e5c09SChris Mason 107474123bd7SChris Mason /* 107574123bd7SChris Mason * Given a key and some data, insert an item into the tree. 107674123bd7SChris Mason * This does all the path init required, making room in the tree if needed. 107774123bd7SChris Mason */ 1078be0e5c09SChris Mason int insert_item(struct ctree_root *root, struct key *key, 1079be0e5c09SChris Mason void *data, int data_size) 1080be0e5c09SChris Mason { 1081aa5d6bedSChris Mason int ret = 0; 1082be0e5c09SChris Mason int slot; 1083eb60ceacSChris Mason int slot_orig; 1084be0e5c09SChris Mason struct leaf *leaf; 1085eb60ceacSChris Mason struct tree_buffer *leaf_buf; 1086be0e5c09SChris Mason unsigned int nritems; 1087be0e5c09SChris Mason unsigned int data_end; 1088be0e5c09SChris Mason struct ctree_path path; 1089be0e5c09SChris Mason 109074123bd7SChris Mason /* create a root if there isn't one */ 10915c680ed6SChris Mason if (!root->node) 1092cfaa7295SChris Mason BUG(); 1093be0e5c09SChris Mason init_path(&path); 109402217ed2SChris Mason ret = search_slot(root, key, &path, data_size, 1); 1095eb60ceacSChris Mason if (ret == 0) { 1096eb60ceacSChris Mason release_path(root, &path); 1097f0930a37SChris Mason return -EEXIST; 1098aa5d6bedSChris Mason } 1099ed2ff2cbSChris Mason if (ret < 0) 1100ed2ff2cbSChris Mason goto out; 1101be0e5c09SChris Mason 1102eb60ceacSChris Mason slot_orig = path.slots[0]; 1103eb60ceacSChris Mason leaf_buf = path.nodes[0]; 1104eb60ceacSChris Mason leaf = &leaf_buf->leaf; 110574123bd7SChris Mason 1106be0e5c09SChris Mason nritems = leaf->header.nritems; 1107be0e5c09SChris Mason data_end = leaf_data_end(leaf); 1108eb60ceacSChris Mason 1109be0e5c09SChris Mason if (leaf_free_space(leaf) < sizeof(struct item) + data_size) 1110be0e5c09SChris Mason BUG(); 1111be0e5c09SChris Mason 1112be0e5c09SChris Mason slot = path.slots[0]; 1113eb60ceacSChris Mason BUG_ON(slot < 0); 1114be0e5c09SChris Mason if (slot != nritems) { 1115be0e5c09SChris Mason int i; 1116be0e5c09SChris Mason unsigned int old_data = leaf->items[slot].offset + 1117be0e5c09SChris Mason leaf->items[slot].size; 1118be0e5c09SChris Mason 1119be0e5c09SChris Mason /* 1120be0e5c09SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 1121be0e5c09SChris Mason */ 1122be0e5c09SChris Mason /* first correct the data pointers */ 1123be0e5c09SChris Mason for (i = slot; i < nritems; i++) 1124be0e5c09SChris Mason leaf->items[i].offset -= data_size; 1125be0e5c09SChris Mason 1126be0e5c09SChris Mason /* shift the items */ 1127be0e5c09SChris Mason memmove(leaf->items + slot + 1, leaf->items + slot, 1128be0e5c09SChris Mason (nritems - slot) * sizeof(struct item)); 1129be0e5c09SChris Mason 1130be0e5c09SChris Mason /* shift the data */ 1131be0e5c09SChris Mason memmove(leaf->data + data_end - data_size, leaf->data + 1132be0e5c09SChris Mason data_end, old_data - data_end); 1133be0e5c09SChris Mason data_end = old_data; 1134be0e5c09SChris Mason } 113574123bd7SChris Mason /* copy the new data in */ 1136be0e5c09SChris Mason memcpy(&leaf->items[slot].key, key, sizeof(struct key)); 1137be0e5c09SChris Mason leaf->items[slot].offset = data_end - data_size; 1138be0e5c09SChris Mason leaf->items[slot].size = data_size; 1139be0e5c09SChris Mason memcpy(leaf->data + data_end - data_size, data, data_size); 1140be0e5c09SChris Mason leaf->header.nritems += 1; 1141aa5d6bedSChris Mason 1142aa5d6bedSChris Mason ret = 0; 11438e19f2cdSChris Mason if (slot == 0) 1144aa5d6bedSChris Mason ret = fixup_low_keys(root, &path, key, 1); 1145aa5d6bedSChris Mason 114602217ed2SChris Mason BUG_ON(list_empty(&leaf_buf->dirty)); 1147be0e5c09SChris Mason if (leaf_free_space(leaf) < 0) 1148be0e5c09SChris Mason BUG(); 1149bb803951SChris Mason check_leaf(&path, 0); 1150ed2ff2cbSChris Mason out: 1151eb60ceacSChris Mason release_path(root, &path); 1152aa5d6bedSChris Mason return ret; 1153be0e5c09SChris Mason } 1154be0e5c09SChris Mason 115574123bd7SChris Mason /* 11565de08d7dSChris Mason * delete the pointer from a given node. 115774123bd7SChris Mason * 115874123bd7SChris Mason * If the delete empties a node, the node is removed from the tree, 115974123bd7SChris Mason * continuing all the way the root if required. The root is converted into 116074123bd7SChris Mason * a leaf if all the nodes are emptied. 116174123bd7SChris Mason */ 1162bb803951SChris Mason static int del_ptr(struct ctree_root *root, struct ctree_path *path, int level, 1163bb803951SChris Mason int slot) 1164be0e5c09SChris Mason { 1165be0e5c09SChris Mason struct node *node; 1166bb803951SChris Mason struct tree_buffer *parent = path->nodes[level]; 1167be0e5c09SChris Mason int nritems; 1168aa5d6bedSChris Mason int ret = 0; 1169bb803951SChris Mason int wret; 1170be0e5c09SChris Mason 1171bb803951SChris Mason node = &parent->node; 1172be0e5c09SChris Mason nritems = node->header.nritems; 1173be0e5c09SChris Mason 1174be0e5c09SChris Mason if (slot != nritems -1) { 1175be0e5c09SChris Mason memmove(node->keys + slot, node->keys + slot + 1, 1176be0e5c09SChris Mason sizeof(struct key) * (nritems - slot - 1)); 1177be0e5c09SChris Mason memmove(node->blockptrs + slot, 1178be0e5c09SChris Mason node->blockptrs + slot + 1, 1179be0e5c09SChris Mason sizeof(u64) * (nritems - slot - 1)); 1180be0e5c09SChris Mason } 1181be0e5c09SChris Mason node->header.nritems--; 1182bb803951SChris Mason if (node->header.nritems == 0 && parent == root->node) { 1183bb803951SChris Mason BUG_ON(node_level(root->node->node.header.flags) != 1); 1184eb60ceacSChris Mason /* just turn the root into a leaf and break */ 1185eb60ceacSChris Mason root->node->node.header.flags = node_level(0); 1186bb803951SChris Mason } else if (slot == 0) { 1187bb803951SChris Mason wret = fixup_low_keys(root, path, node->keys, level + 1); 11880f70abe2SChris Mason if (wret) 11890f70abe2SChris Mason ret = wret; 1190be0e5c09SChris Mason } 119102217ed2SChris Mason BUG_ON(list_empty(&parent->dirty)); 1192aa5d6bedSChris Mason return ret; 1193be0e5c09SChris Mason } 1194be0e5c09SChris Mason 119574123bd7SChris Mason /* 119674123bd7SChris Mason * delete the item at the leaf level in path. If that empties 119774123bd7SChris Mason * the leaf, remove it from the tree 119874123bd7SChris Mason */ 11994920c9acSChris Mason int del_item(struct ctree_root *root, struct ctree_path *path) 1200be0e5c09SChris Mason { 1201be0e5c09SChris Mason int slot; 1202be0e5c09SChris Mason struct leaf *leaf; 1203eb60ceacSChris Mason struct tree_buffer *leaf_buf; 1204be0e5c09SChris Mason int doff; 1205be0e5c09SChris Mason int dsize; 1206aa5d6bedSChris Mason int ret = 0; 1207aa5d6bedSChris Mason int wret; 1208be0e5c09SChris Mason 1209eb60ceacSChris Mason leaf_buf = path->nodes[0]; 1210eb60ceacSChris Mason leaf = &leaf_buf->leaf; 12114920c9acSChris Mason slot = path->slots[0]; 1212be0e5c09SChris Mason doff = leaf->items[slot].offset; 1213be0e5c09SChris Mason dsize = leaf->items[slot].size; 1214be0e5c09SChris Mason 1215be0e5c09SChris Mason if (slot != leaf->header.nritems - 1) { 1216be0e5c09SChris Mason int i; 1217be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 1218be0e5c09SChris Mason memmove(leaf->data + data_end + dsize, 1219be0e5c09SChris Mason leaf->data + data_end, 1220be0e5c09SChris Mason doff - data_end); 1221be0e5c09SChris Mason for (i = slot + 1; i < leaf->header.nritems; i++) 1222be0e5c09SChris Mason leaf->items[i].offset += dsize; 1223be0e5c09SChris Mason memmove(leaf->items + slot, leaf->items + slot + 1, 1224be0e5c09SChris Mason sizeof(struct item) * 1225be0e5c09SChris Mason (leaf->header.nritems - slot - 1)); 1226be0e5c09SChris Mason } 1227be0e5c09SChris Mason leaf->header.nritems -= 1; 122874123bd7SChris Mason /* delete the leaf if we've emptied it */ 1229be0e5c09SChris Mason if (leaf->header.nritems == 0) { 1230eb60ceacSChris Mason if (leaf_buf == root->node) { 1231eb60ceacSChris Mason leaf->header.flags = node_level(0); 123202217ed2SChris Mason BUG_ON(list_empty(&leaf_buf->dirty)); 12339a8dd150SChris Mason } else { 1234ed2ff2cbSChris Mason clean_tree_block(root, leaf_buf); 1235bb803951SChris Mason wret = del_ptr(root, path, 1, path->slots[1]); 1236aa5d6bedSChris Mason if (wret) 1237aa5d6bedSChris Mason ret = wret; 12380f70abe2SChris Mason wret = free_extent(root, leaf_buf->blocknr, 1); 12390f70abe2SChris Mason if (wret) 12400f70abe2SChris Mason ret = wret; 12419a8dd150SChris Mason } 1242be0e5c09SChris Mason } else { 12435de08d7dSChris Mason int used = leaf_space_used(leaf, 0, leaf->header.nritems); 1244aa5d6bedSChris Mason if (slot == 0) { 1245aa5d6bedSChris Mason wret = fixup_low_keys(root, path, 1246aa5d6bedSChris Mason &leaf->items[0].key, 1); 1247aa5d6bedSChris Mason if (wret) 1248aa5d6bedSChris Mason ret = wret; 1249aa5d6bedSChris Mason } 125002217ed2SChris Mason BUG_ON(list_empty(&leaf_buf->dirty)); 1251aa5d6bedSChris Mason 125274123bd7SChris Mason /* delete the leaf if it is mostly empty */ 12535de08d7dSChris Mason if (used < LEAF_DATA_SIZE / 3) { 1254be0e5c09SChris Mason /* push_leaf_left fixes the path. 1255be0e5c09SChris Mason * make sure the path still points to our leaf 1256be0e5c09SChris Mason * for possible call to del_ptr below 1257be0e5c09SChris Mason */ 12584920c9acSChris Mason slot = path->slots[1]; 1259eb60ceacSChris Mason leaf_buf->count++; 1260aa5d6bedSChris Mason wret = push_leaf_left(root, path, 1); 1261aa5d6bedSChris Mason if (wret < 0) 1262aa5d6bedSChris Mason ret = wret; 1263f0930a37SChris Mason if (path->nodes[0] == leaf_buf && 1264f0930a37SChris Mason leaf->header.nritems) { 1265aa5d6bedSChris Mason wret = push_leaf_right(root, path, 1); 1266aa5d6bedSChris Mason if (wret < 0) 1267aa5d6bedSChris Mason ret = wret; 1268aa5d6bedSChris Mason } 1269be0e5c09SChris Mason if (leaf->header.nritems == 0) { 12705de08d7dSChris Mason u64 blocknr = leaf_buf->blocknr; 1271ed2ff2cbSChris Mason clean_tree_block(root, leaf_buf); 1272bb803951SChris Mason wret = del_ptr(root, path, 1, slot); 1273aa5d6bedSChris Mason if (wret) 1274aa5d6bedSChris Mason ret = wret; 12755de08d7dSChris Mason tree_block_release(root, leaf_buf); 12760f70abe2SChris Mason wret = free_extent(root, blocknr, 1); 12770f70abe2SChris Mason if (wret) 12780f70abe2SChris Mason ret = wret; 12795de08d7dSChris Mason } else { 1280eb60ceacSChris Mason tree_block_release(root, leaf_buf); 1281be0e5c09SChris Mason } 1282be0e5c09SChris Mason } 12839a8dd150SChris Mason } 1284aa5d6bedSChris Mason return ret; 12859a8dd150SChris Mason } 12869a8dd150SChris Mason 128797571fd0SChris Mason /* 128897571fd0SChris Mason * walk up the tree as far as required to find the next leaf. 12890f70abe2SChris Mason * returns 0 if it found something or 1 if there are no greater leaves. 12900f70abe2SChris Mason * returns < 0 on io errors. 129197571fd0SChris Mason */ 1292d97e63b6SChris Mason int next_leaf(struct ctree_root *root, struct ctree_path *path) 1293d97e63b6SChris Mason { 1294d97e63b6SChris Mason int slot; 1295d97e63b6SChris Mason int level = 1; 1296d97e63b6SChris Mason u64 blocknr; 1297d97e63b6SChris Mason struct tree_buffer *c; 1298cfaa7295SChris Mason struct tree_buffer *next = NULL; 1299d97e63b6SChris Mason 1300d97e63b6SChris Mason while(level < MAX_LEVEL) { 1301d97e63b6SChris Mason if (!path->nodes[level]) 13020f70abe2SChris Mason return 1; 1303d97e63b6SChris Mason slot = path->slots[level] + 1; 1304d97e63b6SChris Mason c = path->nodes[level]; 1305d97e63b6SChris Mason if (slot >= c->node.header.nritems) { 1306d97e63b6SChris Mason level++; 1307d97e63b6SChris Mason continue; 1308d97e63b6SChris Mason } 1309d97e63b6SChris Mason blocknr = c->node.blockptrs[slot]; 1310cfaa7295SChris Mason if (next) 1311cfaa7295SChris Mason tree_block_release(root, next); 1312d97e63b6SChris Mason next = read_tree_block(root, blocknr); 1313d97e63b6SChris Mason break; 1314d97e63b6SChris Mason } 1315d97e63b6SChris Mason path->slots[level] = slot; 1316d97e63b6SChris Mason while(1) { 1317d97e63b6SChris Mason level--; 1318d97e63b6SChris Mason c = path->nodes[level]; 1319d97e63b6SChris Mason tree_block_release(root, c); 1320d97e63b6SChris Mason path->nodes[level] = next; 1321d97e63b6SChris Mason path->slots[level] = 0; 1322d97e63b6SChris Mason if (!level) 1323d97e63b6SChris Mason break; 1324d97e63b6SChris Mason next = read_tree_block(root, next->node.blockptrs[0]); 1325d97e63b6SChris Mason } 1326d97e63b6SChris Mason return 0; 1327d97e63b6SChris Mason } 1328d97e63b6SChris Mason 132902217ed2SChris Mason 1330