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 95c680ed6SChris Mason int split_node(struct ctree_root *root, struct ctree_path *path, int level); 105c680ed6SChris Mason int split_leaf(struct ctree_root *root, struct ctree_path *path, int data_size); 115de08d7dSChris Mason int push_node_left(struct ctree_root *root, struct ctree_path *path, int level); 125de08d7dSChris Mason int push_node_right(struct ctree_root *root, 135de08d7dSChris Mason struct ctree_path *path, int level); 145de08d7dSChris Mason int del_ptr(struct ctree_root *root, struct ctree_path *path, int level); 15d97e63b6SChris Mason 165de08d7dSChris Mason inline void init_path(struct ctree_path *p) 17be0e5c09SChris Mason { 18be0e5c09SChris Mason memset(p, 0, sizeof(*p)); 19be0e5c09SChris Mason } 20be0e5c09SChris Mason 215de08d7dSChris Mason void release_path(struct ctree_root *root, struct ctree_path *p) 22eb60ceacSChris Mason { 23eb60ceacSChris Mason int i; 24eb60ceacSChris Mason for (i = 0; i < MAX_LEVEL; i++) { 25eb60ceacSChris Mason if (!p->nodes[i]) 26eb60ceacSChris Mason break; 27eb60ceacSChris Mason tree_block_release(root, p->nodes[i]); 28eb60ceacSChris Mason } 29eb60ceacSChris Mason } 30eb60ceacSChris Mason 3174123bd7SChris Mason /* 3274123bd7SChris Mason * The leaf data grows from end-to-front in the node. 3374123bd7SChris Mason * this returns the address of the start of the last item, 3474123bd7SChris Mason * which is the stop of the leaf data stack 3574123bd7SChris Mason */ 36be0e5c09SChris Mason static inline unsigned int leaf_data_end(struct leaf *leaf) 37be0e5c09SChris Mason { 38be0e5c09SChris Mason unsigned int nr = leaf->header.nritems; 39be0e5c09SChris Mason if (nr == 0) 40d97e63b6SChris Mason return sizeof(leaf->data); 41be0e5c09SChris Mason return leaf->items[nr-1].offset; 42be0e5c09SChris Mason } 43be0e5c09SChris Mason 4474123bd7SChris Mason /* 4574123bd7SChris Mason * The space between the end of the leaf items and 4674123bd7SChris Mason * the start of the leaf data. IOW, how much room 4774123bd7SChris Mason * the leaf has left for both items and data 4874123bd7SChris Mason */ 495de08d7dSChris Mason int leaf_free_space(struct leaf *leaf) 50be0e5c09SChris Mason { 51be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 52be0e5c09SChris Mason int nritems = leaf->header.nritems; 53be0e5c09SChris Mason char *items_end = (char *)(leaf->items + nritems + 1); 54be0e5c09SChris Mason return (char *)(leaf->data + data_end) - (char *)items_end; 55be0e5c09SChris Mason } 56be0e5c09SChris Mason 5774123bd7SChris Mason /* 5874123bd7SChris Mason * compare two keys in a memcmp fashion 5974123bd7SChris Mason */ 60be0e5c09SChris Mason int comp_keys(struct key *k1, struct key *k2) 61be0e5c09SChris Mason { 62be0e5c09SChris Mason if (k1->objectid > k2->objectid) 63be0e5c09SChris Mason return 1; 64be0e5c09SChris Mason if (k1->objectid < k2->objectid) 65be0e5c09SChris Mason return -1; 66be0e5c09SChris Mason if (k1->flags > k2->flags) 67be0e5c09SChris Mason return 1; 68be0e5c09SChris Mason if (k1->flags < k2->flags) 69be0e5c09SChris Mason return -1; 70be0e5c09SChris Mason if (k1->offset > k2->offset) 71be0e5c09SChris Mason return 1; 72be0e5c09SChris Mason if (k1->offset < k2->offset) 73be0e5c09SChris Mason return -1; 74be0e5c09SChris Mason return 0; 75be0e5c09SChris Mason } 7674123bd7SChris Mason 7774123bd7SChris Mason /* 7874123bd7SChris Mason * search for key in the array p. items p are item_size apart 7974123bd7SChris Mason * and there are 'max' items in p 8074123bd7SChris Mason * the slot in the array is returned via slot, and it points to 8174123bd7SChris Mason * the place where you would insert key if it is not found in 8274123bd7SChris Mason * the array. 8374123bd7SChris Mason * 8474123bd7SChris Mason * slot may point to max if the key is bigger than all of the keys 8574123bd7SChris Mason */ 86be0e5c09SChris Mason int generic_bin_search(char *p, int item_size, struct key *key, 87be0e5c09SChris Mason int max, int *slot) 88be0e5c09SChris Mason { 89be0e5c09SChris Mason int low = 0; 90be0e5c09SChris Mason int high = max; 91be0e5c09SChris Mason int mid; 92be0e5c09SChris Mason int ret; 93be0e5c09SChris Mason struct key *tmp; 94be0e5c09SChris Mason 95be0e5c09SChris Mason while(low < high) { 96be0e5c09SChris Mason mid = (low + high) / 2; 97be0e5c09SChris Mason tmp = (struct key *)(p + mid * item_size); 98be0e5c09SChris Mason ret = comp_keys(tmp, key); 99be0e5c09SChris Mason 100be0e5c09SChris Mason if (ret < 0) 101be0e5c09SChris Mason low = mid + 1; 102be0e5c09SChris Mason else if (ret > 0) 103be0e5c09SChris Mason high = mid; 104be0e5c09SChris Mason else { 105be0e5c09SChris Mason *slot = mid; 106be0e5c09SChris Mason return 0; 107be0e5c09SChris Mason } 108be0e5c09SChris Mason } 109be0e5c09SChris Mason *slot = low; 110be0e5c09SChris Mason return 1; 111be0e5c09SChris Mason } 112be0e5c09SChris Mason 113be0e5c09SChris Mason int bin_search(struct node *c, struct key *key, int *slot) 114be0e5c09SChris Mason { 115be0e5c09SChris Mason if (is_leaf(c->header.flags)) { 116be0e5c09SChris Mason struct leaf *l = (struct leaf *)c; 117be0e5c09SChris Mason return generic_bin_search((void *)l->items, sizeof(struct item), 118be0e5c09SChris Mason key, c->header.nritems, slot); 119be0e5c09SChris Mason } else { 120be0e5c09SChris Mason return generic_bin_search((void *)c->keys, sizeof(struct key), 121be0e5c09SChris Mason key, c->header.nritems, slot); 122be0e5c09SChris Mason } 123be0e5c09SChris Mason return -1; 124be0e5c09SChris Mason } 125be0e5c09SChris Mason 12674123bd7SChris Mason /* 12774123bd7SChris Mason * look for key in the tree. path is filled in with nodes along the way 12874123bd7SChris Mason * if key is found, we return zero and you can find the item in the leaf 12974123bd7SChris Mason * level of the path (level 0) 13074123bd7SChris Mason * 13174123bd7SChris Mason * If the key isn't found, the path points to the slot where it should 13274123bd7SChris Mason * be inserted. 13374123bd7SChris Mason */ 1345de08d7dSChris Mason int search_slot(struct ctree_root *root, struct key *key, 1355de08d7dSChris Mason struct ctree_path *p, int ins_len) 136be0e5c09SChris Mason { 137eb60ceacSChris Mason struct tree_buffer *b = root->node; 138eb60ceacSChris Mason struct node *c; 139be0e5c09SChris Mason int slot; 140be0e5c09SChris Mason int ret; 141be0e5c09SChris Mason int level; 1425c680ed6SChris Mason 143eb60ceacSChris Mason b->count++; 144eb60ceacSChris Mason while (b) { 145eb60ceacSChris Mason c = &b->node; 146be0e5c09SChris Mason level = node_level(c->header.flags); 147eb60ceacSChris Mason p->nodes[level] = b; 148be0e5c09SChris Mason ret = bin_search(c, key, &slot); 149be0e5c09SChris Mason if (!is_leaf(c->header.flags)) { 150be0e5c09SChris Mason if (ret && slot > 0) 151be0e5c09SChris Mason slot -= 1; 152be0e5c09SChris Mason p->slots[level] = slot; 1535de08d7dSChris Mason if (ins_len > 0 && 1545de08d7dSChris Mason c->header.nritems == NODEPTRS_PER_BLOCK) { 1555c680ed6SChris Mason int sret = split_node(root, p, level); 1565c680ed6SChris Mason BUG_ON(sret > 0); 1575c680ed6SChris Mason if (sret) 1585c680ed6SChris Mason return sret; 1595c680ed6SChris Mason b = p->nodes[level]; 1605c680ed6SChris Mason c = &b->node; 1615c680ed6SChris Mason slot = p->slots[level]; 1625de08d7dSChris Mason } else if (ins_len < 0 && 1635de08d7dSChris Mason c->header.nritems <= NODEPTRS_PER_BLOCK/4) { 1645de08d7dSChris Mason u64 blocknr = b->blocknr; 1655de08d7dSChris Mason slot = p->slots[level +1]; 1665de08d7dSChris Mason b->count++; 1675de08d7dSChris Mason if (push_node_left(root, p, level)) 1685de08d7dSChris Mason push_node_right(root, p, level); 1695de08d7dSChris Mason if (c->header.nritems == 0 && 1705de08d7dSChris Mason level < MAX_LEVEL - 1 && 1715de08d7dSChris Mason p->nodes[level + 1]) { 1725de08d7dSChris Mason int tslot = p->slots[level + 1]; 1735de08d7dSChris Mason 1745de08d7dSChris Mason p->slots[level + 1] = slot; 1755de08d7dSChris Mason del_ptr(root, p, level + 1); 1765de08d7dSChris Mason p->slots[level + 1] = tslot; 1775de08d7dSChris Mason tree_block_release(root, b); 1785de08d7dSChris Mason free_extent(root, blocknr, 1); 1795de08d7dSChris Mason } else { 1805de08d7dSChris Mason tree_block_release(root, b); 1815de08d7dSChris Mason } 1825de08d7dSChris Mason b = p->nodes[level]; 1835de08d7dSChris Mason c = &b->node; 1845de08d7dSChris Mason slot = p->slots[level]; 1855c680ed6SChris Mason } 186eb60ceacSChris Mason b = read_tree_block(root, c->blockptrs[slot]); 187be0e5c09SChris Mason continue; 188be0e5c09SChris Mason } else { 1895c680ed6SChris Mason struct leaf *l = (struct leaf *)c; 190be0e5c09SChris Mason p->slots[level] = slot; 1915de08d7dSChris Mason if (ins_len > 0 && leaf_free_space(l) < 1925de08d7dSChris Mason sizeof(struct item) + ins_len) { 1935c680ed6SChris Mason int sret = split_leaf(root, p, ins_len); 1945c680ed6SChris Mason BUG_ON(sret > 0); 1955c680ed6SChris Mason if (sret) 1965c680ed6SChris Mason return sret; 1975c680ed6SChris Mason } 198be0e5c09SChris Mason return ret; 199be0e5c09SChris Mason } 200be0e5c09SChris Mason } 201be0e5c09SChris Mason return -1; 202be0e5c09SChris Mason } 203be0e5c09SChris Mason 20474123bd7SChris Mason /* 20574123bd7SChris Mason * adjust the pointers going up the tree, starting at level 20674123bd7SChris Mason * making sure the right key of each node is points to 'key'. 20774123bd7SChris Mason * This is used after shifting pointers to the left, so it stops 20874123bd7SChris Mason * fixing up pointers when a given leaf/node is not in slot 0 of the 20974123bd7SChris Mason * higher levels 21074123bd7SChris Mason */ 211eb60ceacSChris Mason static void fixup_low_keys(struct ctree_root *root, 212eb60ceacSChris Mason struct ctree_path *path, struct key *key, 213be0e5c09SChris Mason int level) 214be0e5c09SChris Mason { 215be0e5c09SChris Mason int i; 216be0e5c09SChris Mason for (i = level; i < MAX_LEVEL; i++) { 217eb60ceacSChris Mason struct node *t; 218be0e5c09SChris Mason int tslot = path->slots[i]; 219eb60ceacSChris Mason if (!path->nodes[i]) 220be0e5c09SChris Mason break; 221eb60ceacSChris Mason t = &path->nodes[i]->node; 222be0e5c09SChris Mason memcpy(t->keys + tslot, key, sizeof(*key)); 223eb60ceacSChris Mason write_tree_block(root, path->nodes[i]); 224be0e5c09SChris Mason if (tslot != 0) 225be0e5c09SChris Mason break; 226be0e5c09SChris Mason } 227be0e5c09SChris Mason } 228be0e5c09SChris Mason 22974123bd7SChris Mason /* 23074123bd7SChris Mason * try to push data from one node into the next node left in the 23174123bd7SChris Mason * tree. The src node is found at specified level in the path. 23274123bd7SChris Mason * If some bytes were pushed, return 0, otherwise return 1. 23374123bd7SChris Mason * 23474123bd7SChris Mason * Lower nodes/leaves in the path are not touched, higher nodes may 23574123bd7SChris Mason * be modified to reflect the push. 23674123bd7SChris Mason * 23774123bd7SChris Mason * The path is altered to reflect the push. 23874123bd7SChris Mason */ 239be0e5c09SChris Mason int push_node_left(struct ctree_root *root, struct ctree_path *path, int level) 240be0e5c09SChris Mason { 241be0e5c09SChris Mason int slot; 242be0e5c09SChris Mason struct node *left; 243be0e5c09SChris Mason struct node *right; 244be0e5c09SChris Mason int push_items = 0; 245be0e5c09SChris Mason int left_nritems; 246be0e5c09SChris Mason int right_nritems; 247eb60ceacSChris Mason struct tree_buffer *t; 248eb60ceacSChris Mason struct tree_buffer *right_buf; 249be0e5c09SChris Mason 250be0e5c09SChris Mason if (level == MAX_LEVEL - 1 || path->nodes[level + 1] == 0) 251be0e5c09SChris Mason return 1; 252be0e5c09SChris Mason slot = path->slots[level + 1]; 253be0e5c09SChris Mason if (slot == 0) 254be0e5c09SChris Mason return 1; 255be0e5c09SChris Mason 256eb60ceacSChris Mason t = read_tree_block(root, 257eb60ceacSChris Mason path->nodes[level + 1]->node.blockptrs[slot - 1]); 258eb60ceacSChris Mason left = &t->node; 259eb60ceacSChris Mason right_buf = path->nodes[level]; 260eb60ceacSChris Mason right = &right_buf->node; 261be0e5c09SChris Mason left_nritems = left->header.nritems; 262be0e5c09SChris Mason right_nritems = right->header.nritems; 263be0e5c09SChris Mason push_items = NODEPTRS_PER_BLOCK - (left_nritems + 1); 264eb60ceacSChris Mason if (push_items <= 0) { 265eb60ceacSChris Mason tree_block_release(root, t); 266be0e5c09SChris Mason return 1; 267eb60ceacSChris Mason } 268be0e5c09SChris Mason 269be0e5c09SChris Mason if (right_nritems < push_items) 270be0e5c09SChris Mason push_items = right_nritems; 271be0e5c09SChris Mason memcpy(left->keys + left_nritems, right->keys, 272be0e5c09SChris Mason push_items * sizeof(struct key)); 273be0e5c09SChris Mason memcpy(left->blockptrs + left_nritems, right->blockptrs, 274be0e5c09SChris Mason push_items * sizeof(u64)); 275be0e5c09SChris Mason memmove(right->keys, right->keys + push_items, 276be0e5c09SChris Mason (right_nritems - push_items) * sizeof(struct key)); 277be0e5c09SChris Mason memmove(right->blockptrs, right->blockptrs + push_items, 278be0e5c09SChris Mason (right_nritems - push_items) * sizeof(u64)); 279be0e5c09SChris Mason right->header.nritems -= push_items; 280be0e5c09SChris Mason left->header.nritems += push_items; 281be0e5c09SChris Mason 282be0e5c09SChris Mason /* adjust the pointers going up the tree */ 283eb60ceacSChris Mason fixup_low_keys(root, path, right->keys, level + 1); 284eb60ceacSChris Mason 285eb60ceacSChris Mason write_tree_block(root, t); 286eb60ceacSChris Mason write_tree_block(root, right_buf); 287be0e5c09SChris Mason 288be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 289be0e5c09SChris Mason if (path->slots[level] < push_items) { 290be0e5c09SChris Mason path->slots[level] += left_nritems; 291eb60ceacSChris Mason tree_block_release(root, path->nodes[level]); 292eb60ceacSChris Mason path->nodes[level] = t; 293be0e5c09SChris Mason path->slots[level + 1] -= 1; 294be0e5c09SChris Mason } else { 295be0e5c09SChris Mason path->slots[level] -= push_items; 296eb60ceacSChris Mason tree_block_release(root, t); 297be0e5c09SChris Mason } 298be0e5c09SChris Mason return 0; 299be0e5c09SChris Mason } 300be0e5c09SChris Mason 30174123bd7SChris Mason /* 30274123bd7SChris Mason * try to push data from one node into the next node right in the 30374123bd7SChris Mason * tree. The src node is found at specified level in the path. 30474123bd7SChris Mason * If some bytes were pushed, return 0, otherwise return 1. 30574123bd7SChris Mason * 30674123bd7SChris Mason * Lower nodes/leaves in the path are not touched, higher nodes may 30774123bd7SChris Mason * be modified to reflect the push. 30874123bd7SChris Mason * 30974123bd7SChris Mason * The path is altered to reflect the push. 31074123bd7SChris Mason */ 311be0e5c09SChris Mason int push_node_right(struct ctree_root *root, struct ctree_path *path, int level) 312be0e5c09SChris Mason { 313be0e5c09SChris Mason int slot; 314eb60ceacSChris Mason struct tree_buffer *t; 315eb60ceacSChris Mason struct tree_buffer *src_buffer; 316be0e5c09SChris Mason struct node *dst; 317be0e5c09SChris Mason struct node *src; 318be0e5c09SChris Mason int push_items = 0; 319be0e5c09SChris Mason int dst_nritems; 320be0e5c09SChris Mason int src_nritems; 321be0e5c09SChris Mason 32274123bd7SChris Mason /* can't push from the root */ 323be0e5c09SChris Mason if (level == MAX_LEVEL - 1 || path->nodes[level + 1] == 0) 324be0e5c09SChris Mason return 1; 32574123bd7SChris Mason 32674123bd7SChris Mason /* only try to push inside the node higher up */ 327be0e5c09SChris Mason slot = path->slots[level + 1]; 328be0e5c09SChris Mason if (slot == NODEPTRS_PER_BLOCK - 1) 329be0e5c09SChris Mason return 1; 330be0e5c09SChris Mason 331eb60ceacSChris Mason if (slot >= path->nodes[level + 1]->node.header.nritems -1) 332be0e5c09SChris Mason return 1; 333be0e5c09SChris Mason 334eb60ceacSChris Mason t = read_tree_block(root, 335eb60ceacSChris Mason path->nodes[level + 1]->node.blockptrs[slot + 1]); 336eb60ceacSChris Mason dst = &t->node; 337eb60ceacSChris Mason src_buffer = path->nodes[level]; 338eb60ceacSChris Mason src = &src_buffer->node; 339be0e5c09SChris Mason dst_nritems = dst->header.nritems; 340be0e5c09SChris Mason src_nritems = src->header.nritems; 341be0e5c09SChris Mason push_items = NODEPTRS_PER_BLOCK - (dst_nritems + 1); 342eb60ceacSChris Mason if (push_items <= 0) { 343eb60ceacSChris Mason tree_block_release(root, t); 344be0e5c09SChris Mason return 1; 345eb60ceacSChris Mason } 346be0e5c09SChris Mason 347be0e5c09SChris Mason if (src_nritems < push_items) 348be0e5c09SChris Mason push_items = src_nritems; 349be0e5c09SChris Mason memmove(dst->keys + push_items, dst->keys, 350be0e5c09SChris Mason dst_nritems * sizeof(struct key)); 351be0e5c09SChris Mason memcpy(dst->keys, src->keys + src_nritems - push_items, 352be0e5c09SChris Mason push_items * sizeof(struct key)); 353be0e5c09SChris Mason 354be0e5c09SChris Mason memmove(dst->blockptrs + push_items, dst->blockptrs, 355be0e5c09SChris Mason dst_nritems * sizeof(u64)); 356be0e5c09SChris Mason memcpy(dst->blockptrs, src->blockptrs + src_nritems - push_items, 357be0e5c09SChris Mason push_items * sizeof(u64)); 358be0e5c09SChris Mason 359be0e5c09SChris Mason src->header.nritems -= push_items; 360be0e5c09SChris Mason dst->header.nritems += push_items; 361be0e5c09SChris Mason 362be0e5c09SChris Mason /* adjust the pointers going up the tree */ 363eb60ceacSChris Mason memcpy(path->nodes[level + 1]->node.keys + path->slots[level + 1] + 1, 364be0e5c09SChris Mason dst->keys, sizeof(struct key)); 365eb60ceacSChris Mason 366eb60ceacSChris Mason write_tree_block(root, path->nodes[level + 1]); 367eb60ceacSChris Mason write_tree_block(root, t); 368eb60ceacSChris Mason write_tree_block(root, src_buffer); 369eb60ceacSChris Mason 37074123bd7SChris Mason /* then fixup the pointers in the path */ 371be0e5c09SChris Mason if (path->slots[level] >= src->header.nritems) { 372be0e5c09SChris Mason path->slots[level] -= src->header.nritems; 373eb60ceacSChris Mason tree_block_release(root, path->nodes[level]); 374eb60ceacSChris Mason path->nodes[level] = t; 375be0e5c09SChris Mason path->slots[level + 1] += 1; 376eb60ceacSChris Mason } else { 377eb60ceacSChris Mason tree_block_release(root, t); 378be0e5c09SChris Mason } 379be0e5c09SChris Mason return 0; 380be0e5c09SChris Mason } 381be0e5c09SChris Mason 3825de08d7dSChris Mason static int insert_new_root(struct ctree_root *root, 3835de08d7dSChris Mason struct ctree_path *path, int level) 38474123bd7SChris Mason { 38574123bd7SChris Mason struct tree_buffer *t; 3865c680ed6SChris Mason struct node *lower; 3875c680ed6SChris Mason struct node *c; 3885c680ed6SChris Mason struct key *lower_key; 3895c680ed6SChris Mason 3905c680ed6SChris Mason BUG_ON(path->nodes[level]); 3915c680ed6SChris Mason BUG_ON(path->nodes[level-1] != root->node); 3925c680ed6SChris Mason 39374123bd7SChris Mason t = alloc_free_block(root); 39474123bd7SChris Mason c = &t->node; 39574123bd7SChris Mason memset(c, 0, sizeof(c)); 3965c680ed6SChris Mason c->header.nritems = 1; 39774123bd7SChris Mason c->header.flags = node_level(level); 39874123bd7SChris Mason c->header.blocknr = t->blocknr; 399cfaa7295SChris Mason c->header.parentid = root->node->node.header.parentid; 40074123bd7SChris Mason lower = &path->nodes[level-1]->node; 40174123bd7SChris Mason if (is_leaf(lower->header.flags)) 40274123bd7SChris Mason lower_key = &((struct leaf *)lower)->items[0].key; 40374123bd7SChris Mason else 40474123bd7SChris Mason lower_key = lower->keys; 40574123bd7SChris Mason memcpy(c->keys, lower_key, sizeof(struct key)); 40674123bd7SChris Mason c->blockptrs[0] = path->nodes[level-1]->blocknr; 407cfaa7295SChris Mason /* the super has an extra ref to root->node */ 40874123bd7SChris Mason tree_block_release(root, root->node); 40974123bd7SChris Mason root->node = t; 41074123bd7SChris Mason t->count++; 41174123bd7SChris Mason write_tree_block(root, t); 41274123bd7SChris Mason path->nodes[level] = t; 41374123bd7SChris Mason path->slots[level] = 0; 41474123bd7SChris Mason return 0; 41574123bd7SChris Mason } 4165c680ed6SChris Mason 4175c680ed6SChris Mason /* 4185c680ed6SChris Mason * worker function to insert a single pointer in a node. 4195c680ed6SChris Mason * the node should have enough room for the pointer already 4205c680ed6SChris Mason * slot and level indicate where you want the key to go, and 4215c680ed6SChris Mason * blocknr is the block the key points to. 4225c680ed6SChris Mason */ 4235c680ed6SChris Mason int insert_ptr(struct ctree_root *root, 4245c680ed6SChris Mason struct ctree_path *path, struct key *key, 4255c680ed6SChris Mason u64 blocknr, int slot, int level) 4265c680ed6SChris Mason { 4275c680ed6SChris Mason struct node *lower; 4285c680ed6SChris Mason int nritems; 4295c680ed6SChris Mason 4305c680ed6SChris Mason BUG_ON(!path->nodes[level]); 43174123bd7SChris Mason lower = &path->nodes[level]->node; 43274123bd7SChris Mason nritems = lower->header.nritems; 43374123bd7SChris Mason if (slot > nritems) 43474123bd7SChris Mason BUG(); 43574123bd7SChris Mason if (nritems == NODEPTRS_PER_BLOCK) 43674123bd7SChris Mason BUG(); 43774123bd7SChris Mason if (slot != nritems) { 43874123bd7SChris Mason memmove(lower->keys + slot + 1, lower->keys + slot, 43974123bd7SChris Mason (nritems - slot) * sizeof(struct key)); 44074123bd7SChris Mason memmove(lower->blockptrs + slot + 1, lower->blockptrs + slot, 44174123bd7SChris Mason (nritems - slot) * sizeof(u64)); 44274123bd7SChris Mason } 44374123bd7SChris Mason memcpy(lower->keys + slot, key, sizeof(struct key)); 44474123bd7SChris Mason lower->blockptrs[slot] = blocknr; 44574123bd7SChris Mason lower->header.nritems++; 44674123bd7SChris Mason if (lower->keys[1].objectid == 0) 44774123bd7SChris Mason BUG(); 44874123bd7SChris Mason write_tree_block(root, path->nodes[level]); 44974123bd7SChris Mason return 0; 45074123bd7SChris Mason } 45174123bd7SChris Mason 4525c680ed6SChris Mason int split_node(struct ctree_root *root, struct ctree_path *path, int level) 453be0e5c09SChris Mason { 4545c680ed6SChris Mason struct tree_buffer *t; 4555c680ed6SChris Mason struct node *c; 4565c680ed6SChris Mason struct tree_buffer *split_buffer; 4575c680ed6SChris Mason struct node *split; 458be0e5c09SChris Mason int mid; 4595c680ed6SChris Mason int ret; 460be0e5c09SChris Mason 4615c680ed6SChris Mason ret = push_node_left(root, path, level); 4625c680ed6SChris Mason if (!ret) 4635c680ed6SChris Mason return 0; 4645c680ed6SChris Mason ret = push_node_right(root, path, level); 4655c680ed6SChris Mason if (!ret) 4665c680ed6SChris Mason return 0; 4675c680ed6SChris Mason t = path->nodes[level]; 468eb60ceacSChris Mason c = &t->node; 4695c680ed6SChris Mason if (t == root->node) { 4705c680ed6SChris Mason /* trying to split the root, lets make a new one */ 4715c680ed6SChris Mason ret = insert_new_root(root, path, level + 1); 4725c680ed6SChris Mason if (ret) 4735c680ed6SChris Mason return ret; 4745c680ed6SChris Mason } 4755c680ed6SChris Mason split_buffer = alloc_free_block(root); 4765c680ed6SChris Mason split = &split_buffer->node; 4775c680ed6SChris Mason split->header.flags = c->header.flags; 4785c680ed6SChris Mason split->header.blocknr = split_buffer->blocknr; 4795c680ed6SChris Mason split->header.parentid = root->node->node.header.parentid; 480be0e5c09SChris Mason mid = (c->header.nritems + 1) / 2; 4815c680ed6SChris Mason memcpy(split->keys, c->keys + mid, 482be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(struct key)); 4835c680ed6SChris Mason memcpy(split->blockptrs, c->blockptrs + mid, 484be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(u64)); 4855c680ed6SChris Mason split->header.nritems = c->header.nritems - mid; 486be0e5c09SChris Mason c->header.nritems = mid; 487eb60ceacSChris Mason write_tree_block(root, t); 4885c680ed6SChris Mason write_tree_block(root, split_buffer); 4895c680ed6SChris Mason insert_ptr(root, path, split->keys, split_buffer->blocknr, 4905c680ed6SChris Mason path->slots[level + 1] + 1, level + 1); 4915de08d7dSChris Mason if (path->slots[level] >= mid) { 4925c680ed6SChris Mason path->slots[level] -= mid; 4935c680ed6SChris Mason tree_block_release(root, t); 4945c680ed6SChris Mason path->nodes[level] = split_buffer; 4955c680ed6SChris Mason path->slots[level + 1] += 1; 496eb60ceacSChris Mason } else { 4975c680ed6SChris Mason tree_block_release(root, split_buffer); 498be0e5c09SChris Mason } 4995c680ed6SChris Mason return 0; 500be0e5c09SChris Mason } 501be0e5c09SChris Mason 50274123bd7SChris Mason /* 50374123bd7SChris Mason * how many bytes are required to store the items in a leaf. start 50474123bd7SChris Mason * and nr indicate which items in the leaf to check. This totals up the 50574123bd7SChris Mason * space used both by the item structs and the item data 50674123bd7SChris Mason */ 507be0e5c09SChris Mason int leaf_space_used(struct leaf *l, int start, int nr) 508be0e5c09SChris Mason { 509be0e5c09SChris Mason int data_len; 510be0e5c09SChris Mason int end = start + nr - 1; 511be0e5c09SChris Mason 512be0e5c09SChris Mason if (!nr) 513be0e5c09SChris Mason return 0; 514be0e5c09SChris Mason data_len = l->items[start].offset + l->items[start].size; 515be0e5c09SChris Mason data_len = data_len - l->items[end].offset; 516be0e5c09SChris Mason data_len += sizeof(struct item) * nr; 517be0e5c09SChris Mason return data_len; 518be0e5c09SChris Mason } 519be0e5c09SChris Mason 52074123bd7SChris Mason /* 52100ec4c51SChris Mason * push some data in the path leaf to the right, trying to free up at 52200ec4c51SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 52300ec4c51SChris Mason */ 52400ec4c51SChris Mason int push_leaf_right(struct ctree_root *root, struct ctree_path *path, 52500ec4c51SChris Mason int data_size) 52600ec4c51SChris Mason { 52700ec4c51SChris Mason struct tree_buffer *left_buf = path->nodes[0]; 52800ec4c51SChris Mason struct leaf *left = &left_buf->leaf; 52900ec4c51SChris Mason struct leaf *right; 53000ec4c51SChris Mason struct tree_buffer *right_buf; 53100ec4c51SChris Mason struct tree_buffer *upper; 53200ec4c51SChris Mason int slot; 53300ec4c51SChris Mason int i; 53400ec4c51SChris Mason int free_space; 53500ec4c51SChris Mason int push_space = 0; 53600ec4c51SChris Mason int push_items = 0; 53700ec4c51SChris Mason struct item *item; 53800ec4c51SChris Mason 53900ec4c51SChris Mason slot = path->slots[1]; 54000ec4c51SChris Mason if (!path->nodes[1]) { 54100ec4c51SChris Mason return 1; 54200ec4c51SChris Mason } 54300ec4c51SChris Mason upper = path->nodes[1]; 54400ec4c51SChris Mason if (slot >= upper->node.header.nritems - 1) { 54500ec4c51SChris Mason return 1; 54600ec4c51SChris Mason } 54700ec4c51SChris Mason right_buf = read_tree_block(root, upper->node.blockptrs[slot + 1]); 54800ec4c51SChris Mason right = &right_buf->leaf; 54900ec4c51SChris Mason free_space = leaf_free_space(right); 55000ec4c51SChris Mason if (free_space < data_size + sizeof(struct item)) { 55100ec4c51SChris Mason tree_block_release(root, right_buf); 55200ec4c51SChris Mason return 1; 55300ec4c51SChris Mason } 55400ec4c51SChris Mason for (i = left->header.nritems - 1; i >= 0; i--) { 55500ec4c51SChris Mason item = left->items + i; 55600ec4c51SChris Mason if (path->slots[0] == i) 55700ec4c51SChris Mason push_space += data_size + sizeof(*item); 55800ec4c51SChris Mason if (item->size + sizeof(*item) + push_space > free_space) 55900ec4c51SChris Mason break; 56000ec4c51SChris Mason push_items++; 56100ec4c51SChris Mason push_space += item->size + sizeof(*item); 56200ec4c51SChris Mason } 56300ec4c51SChris Mason if (push_items == 0) { 56400ec4c51SChris Mason tree_block_release(root, right_buf); 56500ec4c51SChris Mason return 1; 56600ec4c51SChris Mason } 56700ec4c51SChris Mason /* push left to right */ 56800ec4c51SChris Mason push_space = left->items[left->header.nritems - push_items].offset + 56900ec4c51SChris Mason left->items[left->header.nritems - push_items].size; 57000ec4c51SChris Mason push_space -= leaf_data_end(left); 57100ec4c51SChris Mason /* make room in the right data area */ 57200ec4c51SChris Mason memmove(right->data + leaf_data_end(right) - push_space, 57300ec4c51SChris Mason right->data + leaf_data_end(right), 57400ec4c51SChris Mason LEAF_DATA_SIZE - leaf_data_end(right)); 57500ec4c51SChris Mason /* copy from the left data area */ 57600ec4c51SChris Mason memcpy(right->data + LEAF_DATA_SIZE - push_space, 57700ec4c51SChris Mason left->data + leaf_data_end(left), 57800ec4c51SChris Mason push_space); 57900ec4c51SChris Mason memmove(right->items + push_items, right->items, 58000ec4c51SChris Mason right->header.nritems * sizeof(struct item)); 58100ec4c51SChris Mason /* copy the items from left to right */ 58200ec4c51SChris Mason memcpy(right->items, left->items + left->header.nritems - push_items, 58300ec4c51SChris Mason push_items * sizeof(struct item)); 58400ec4c51SChris Mason 58500ec4c51SChris Mason /* update the item pointers */ 58600ec4c51SChris Mason right->header.nritems += push_items; 58700ec4c51SChris Mason push_space = LEAF_DATA_SIZE; 58800ec4c51SChris Mason for (i = 0; i < right->header.nritems; i++) { 58900ec4c51SChris Mason right->items[i].offset = push_space - right->items[i].size; 59000ec4c51SChris Mason push_space = right->items[i].offset; 59100ec4c51SChris Mason } 59200ec4c51SChris Mason left->header.nritems -= push_items; 59300ec4c51SChris Mason 59400ec4c51SChris Mason write_tree_block(root, left_buf); 59500ec4c51SChris Mason write_tree_block(root, right_buf); 59600ec4c51SChris Mason memcpy(upper->node.keys + slot + 1, 59700ec4c51SChris Mason &right->items[0].key, sizeof(struct key)); 59800ec4c51SChris Mason write_tree_block(root, upper); 59900ec4c51SChris Mason /* then fixup the leaf pointer in the path */ 60000ec4c51SChris Mason // FIXME use nritems in here somehow 60100ec4c51SChris Mason if (path->slots[0] >= left->header.nritems) { 60200ec4c51SChris Mason path->slots[0] -= left->header.nritems; 60300ec4c51SChris Mason tree_block_release(root, path->nodes[0]); 60400ec4c51SChris Mason path->nodes[0] = right_buf; 60500ec4c51SChris Mason path->slots[1] += 1; 60600ec4c51SChris Mason } else { 60700ec4c51SChris Mason tree_block_release(root, right_buf); 60800ec4c51SChris Mason } 60900ec4c51SChris Mason return 0; 61000ec4c51SChris Mason } 61100ec4c51SChris Mason /* 61274123bd7SChris Mason * push some data in the path leaf to the left, trying to free up at 61374123bd7SChris Mason * least data_size bytes. returns zero if the push worked, nonzero otherwise 61474123bd7SChris Mason */ 615be0e5c09SChris Mason int push_leaf_left(struct ctree_root *root, struct ctree_path *path, 616be0e5c09SChris Mason int data_size) 617be0e5c09SChris Mason { 618eb60ceacSChris Mason struct tree_buffer *right_buf = path->nodes[0]; 619eb60ceacSChris Mason struct leaf *right = &right_buf->leaf; 620eb60ceacSChris Mason struct tree_buffer *t; 621be0e5c09SChris Mason struct leaf *left; 622be0e5c09SChris Mason int slot; 623be0e5c09SChris Mason int i; 624be0e5c09SChris Mason int free_space; 625be0e5c09SChris Mason int push_space = 0; 626be0e5c09SChris Mason int push_items = 0; 627be0e5c09SChris Mason struct item *item; 628be0e5c09SChris Mason int old_left_nritems; 629be0e5c09SChris Mason 630be0e5c09SChris Mason slot = path->slots[1]; 631be0e5c09SChris Mason if (slot == 0) { 632be0e5c09SChris Mason return 1; 633be0e5c09SChris Mason } 634be0e5c09SChris Mason if (!path->nodes[1]) { 635be0e5c09SChris Mason return 1; 636be0e5c09SChris Mason } 637eb60ceacSChris Mason t = read_tree_block(root, path->nodes[1]->node.blockptrs[slot - 1]); 638eb60ceacSChris Mason left = &t->leaf; 639be0e5c09SChris Mason free_space = leaf_free_space(left); 640be0e5c09SChris Mason if (free_space < data_size + sizeof(struct item)) { 641eb60ceacSChris Mason tree_block_release(root, t); 642be0e5c09SChris Mason return 1; 643be0e5c09SChris Mason } 644be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 645be0e5c09SChris Mason item = right->items + i; 646be0e5c09SChris Mason if (path->slots[0] == i) 647be0e5c09SChris Mason push_space += data_size + sizeof(*item); 648be0e5c09SChris Mason if (item->size + sizeof(*item) + push_space > free_space) 649be0e5c09SChris Mason break; 650be0e5c09SChris Mason push_items++; 651be0e5c09SChris Mason push_space += item->size + sizeof(*item); 652be0e5c09SChris Mason } 653be0e5c09SChris Mason if (push_items == 0) { 654eb60ceacSChris Mason tree_block_release(root, t); 655be0e5c09SChris Mason return 1; 656be0e5c09SChris Mason } 657be0e5c09SChris Mason /* push data from right to left */ 658be0e5c09SChris Mason memcpy(left->items + left->header.nritems, 659be0e5c09SChris Mason right->items, push_items * sizeof(struct item)); 660be0e5c09SChris Mason push_space = LEAF_DATA_SIZE - right->items[push_items -1].offset; 661be0e5c09SChris Mason memcpy(left->data + leaf_data_end(left) - push_space, 662be0e5c09SChris Mason right->data + right->items[push_items - 1].offset, 663be0e5c09SChris Mason push_space); 664be0e5c09SChris Mason old_left_nritems = left->header.nritems; 665eb60ceacSChris Mason BUG_ON(old_left_nritems < 0); 666eb60ceacSChris Mason 667be0e5c09SChris Mason for(i = old_left_nritems; i < old_left_nritems + push_items; i++) { 668be0e5c09SChris Mason left->items[i].offset -= LEAF_DATA_SIZE - 669be0e5c09SChris Mason left->items[old_left_nritems -1].offset; 670be0e5c09SChris Mason } 671be0e5c09SChris Mason left->header.nritems += push_items; 672be0e5c09SChris Mason 673be0e5c09SChris Mason /* fixup right node */ 674be0e5c09SChris Mason push_space = right->items[push_items-1].offset - leaf_data_end(right); 675be0e5c09SChris Mason memmove(right->data + LEAF_DATA_SIZE - push_space, right->data + 676be0e5c09SChris Mason leaf_data_end(right), push_space); 677be0e5c09SChris Mason memmove(right->items, right->items + push_items, 678be0e5c09SChris Mason (right->header.nritems - push_items) * sizeof(struct item)); 679be0e5c09SChris Mason right->header.nritems -= push_items; 680be0e5c09SChris Mason push_space = LEAF_DATA_SIZE; 681eb60ceacSChris Mason 682be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 683be0e5c09SChris Mason right->items[i].offset = push_space - right->items[i].size; 684be0e5c09SChris Mason push_space = right->items[i].offset; 685be0e5c09SChris Mason } 686eb60ceacSChris Mason 687eb60ceacSChris Mason write_tree_block(root, t); 688eb60ceacSChris Mason write_tree_block(root, right_buf); 689eb60ceacSChris Mason 690eb60ceacSChris Mason fixup_low_keys(root, path, &right->items[0].key, 1); 691be0e5c09SChris Mason 692be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 693be0e5c09SChris Mason if (path->slots[0] < push_items) { 694be0e5c09SChris Mason path->slots[0] += old_left_nritems; 695eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 696eb60ceacSChris Mason path->nodes[0] = t; 697be0e5c09SChris Mason path->slots[1] -= 1; 698be0e5c09SChris Mason } else { 699eb60ceacSChris Mason tree_block_release(root, t); 700be0e5c09SChris Mason path->slots[0] -= push_items; 701be0e5c09SChris Mason } 702eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 703be0e5c09SChris Mason return 0; 704be0e5c09SChris Mason } 705be0e5c09SChris Mason 70674123bd7SChris Mason /* 70774123bd7SChris Mason * split the path's leaf in two, making sure there is at least data_size 70874123bd7SChris Mason * available for the resulting leaf level of the path. 70974123bd7SChris Mason */ 710be0e5c09SChris Mason int split_leaf(struct ctree_root *root, struct ctree_path *path, int data_size) 711be0e5c09SChris Mason { 712eb60ceacSChris Mason struct tree_buffer *l_buf = path->nodes[0]; 713eb60ceacSChris Mason struct leaf *l = &l_buf->leaf; 714eb60ceacSChris Mason int nritems; 715eb60ceacSChris Mason int mid; 716eb60ceacSChris Mason int slot; 717be0e5c09SChris Mason struct leaf *right; 718eb60ceacSChris Mason struct tree_buffer *right_buffer; 719be0e5c09SChris Mason int space_needed = data_size + sizeof(struct item); 720be0e5c09SChris Mason int data_copy_size; 721be0e5c09SChris Mason int rt_data_off; 722be0e5c09SChris Mason int i; 723be0e5c09SChris Mason int ret; 724be0e5c09SChris Mason 72500ec4c51SChris Mason if (push_leaf_left(root, path, data_size) == 0 || 72600ec4c51SChris Mason push_leaf_right(root, path, data_size) == 0) { 727eb60ceacSChris Mason l_buf = path->nodes[0]; 728eb60ceacSChris Mason l = &l_buf->leaf; 729eb60ceacSChris Mason if (leaf_free_space(l) >= sizeof(struct item) + data_size) 730be0e5c09SChris Mason return 0; 731be0e5c09SChris Mason } 7325c680ed6SChris Mason if (!path->nodes[1]) { 7335c680ed6SChris Mason ret = insert_new_root(root, path, 1); 7345c680ed6SChris Mason if (ret) 7355c680ed6SChris Mason return ret; 7365c680ed6SChris Mason } 737eb60ceacSChris Mason slot = path->slots[0]; 738eb60ceacSChris Mason nritems = l->header.nritems; 739eb60ceacSChris Mason mid = (nritems + 1)/ 2; 740eb60ceacSChris Mason 741eb60ceacSChris Mason right_buffer = alloc_free_block(root); 742eb60ceacSChris Mason BUG_ON(!right_buffer); 743eb60ceacSChris Mason BUG_ON(mid == nritems); 744eb60ceacSChris Mason right = &right_buffer->leaf; 745be0e5c09SChris Mason memset(right, 0, sizeof(*right)); 746be0e5c09SChris Mason if (mid <= slot) { 747be0e5c09SChris Mason if (leaf_space_used(l, mid, nritems - mid) + space_needed > 748be0e5c09SChris Mason LEAF_DATA_SIZE) 749be0e5c09SChris Mason BUG(); 750be0e5c09SChris Mason } else { 751be0e5c09SChris Mason if (leaf_space_used(l, 0, mid + 1) + space_needed > 752be0e5c09SChris Mason LEAF_DATA_SIZE) 753be0e5c09SChris Mason BUG(); 754be0e5c09SChris Mason } 755be0e5c09SChris Mason right->header.nritems = nritems - mid; 756eb60ceacSChris Mason right->header.blocknr = right_buffer->blocknr; 757eb60ceacSChris Mason right->header.flags = node_level(0); 758cfaa7295SChris Mason right->header.parentid = root->node->node.header.parentid; 759be0e5c09SChris Mason data_copy_size = l->items[mid].offset + l->items[mid].size - 760be0e5c09SChris Mason leaf_data_end(l); 761be0e5c09SChris Mason memcpy(right->items, l->items + mid, 762be0e5c09SChris Mason (nritems - mid) * sizeof(struct item)); 763be0e5c09SChris Mason memcpy(right->data + LEAF_DATA_SIZE - data_copy_size, 764be0e5c09SChris Mason l->data + leaf_data_end(l), data_copy_size); 765be0e5c09SChris Mason rt_data_off = LEAF_DATA_SIZE - 766be0e5c09SChris Mason (l->items[mid].offset + l->items[mid].size); 76774123bd7SChris Mason 76874123bd7SChris Mason for (i = 0; i < right->header.nritems; i++) 769be0e5c09SChris Mason right->items[i].offset += rt_data_off; 77074123bd7SChris Mason 771be0e5c09SChris Mason l->header.nritems = mid; 772be0e5c09SChris Mason ret = insert_ptr(root, path, &right->items[0].key, 7735c680ed6SChris Mason right_buffer->blocknr, path->slots[1] + 1, 1); 774eb60ceacSChris Mason write_tree_block(root, right_buffer); 775eb60ceacSChris Mason write_tree_block(root, l_buf); 776eb60ceacSChris Mason 777eb60ceacSChris Mason BUG_ON(path->slots[0] != slot); 778be0e5c09SChris Mason if (mid <= slot) { 779eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 780eb60ceacSChris Mason path->nodes[0] = right_buffer; 781be0e5c09SChris Mason path->slots[0] -= mid; 782be0e5c09SChris Mason path->slots[1] += 1; 783eb60ceacSChris Mason } else 784eb60ceacSChris Mason tree_block_release(root, right_buffer); 785eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 786be0e5c09SChris Mason return ret; 787be0e5c09SChris Mason } 788be0e5c09SChris Mason 78974123bd7SChris Mason /* 79074123bd7SChris Mason * Given a key and some data, insert an item into the tree. 79174123bd7SChris Mason * This does all the path init required, making room in the tree if needed. 79274123bd7SChris Mason */ 793be0e5c09SChris Mason int insert_item(struct ctree_root *root, struct key *key, 794be0e5c09SChris Mason void *data, int data_size) 795be0e5c09SChris Mason { 796be0e5c09SChris Mason int ret; 797be0e5c09SChris Mason int slot; 798eb60ceacSChris Mason int slot_orig; 799be0e5c09SChris Mason struct leaf *leaf; 800eb60ceacSChris Mason struct tree_buffer *leaf_buf; 801be0e5c09SChris Mason unsigned int nritems; 802be0e5c09SChris Mason unsigned int data_end; 803be0e5c09SChris Mason struct ctree_path path; 804be0e5c09SChris Mason 80574123bd7SChris Mason /* create a root if there isn't one */ 8065c680ed6SChris Mason if (!root->node) 807cfaa7295SChris Mason BUG(); 808be0e5c09SChris Mason init_path(&path); 8095c680ed6SChris Mason ret = search_slot(root, key, &path, data_size); 810eb60ceacSChris Mason if (ret == 0) { 811eb60ceacSChris Mason release_path(root, &path); 812be0e5c09SChris Mason return -EEXIST; 813eb60ceacSChris Mason } 814be0e5c09SChris Mason 815eb60ceacSChris Mason slot_orig = path.slots[0]; 816eb60ceacSChris Mason leaf_buf = path.nodes[0]; 817eb60ceacSChris Mason leaf = &leaf_buf->leaf; 81874123bd7SChris Mason 819be0e5c09SChris Mason nritems = leaf->header.nritems; 820be0e5c09SChris Mason data_end = leaf_data_end(leaf); 821eb60ceacSChris Mason 822be0e5c09SChris Mason if (leaf_free_space(leaf) < sizeof(struct item) + data_size) 823be0e5c09SChris Mason BUG(); 824be0e5c09SChris Mason 825be0e5c09SChris Mason slot = path.slots[0]; 826eb60ceacSChris Mason BUG_ON(slot < 0); 827be0e5c09SChris Mason if (slot == 0) 828eb60ceacSChris Mason fixup_low_keys(root, &path, key, 1); 829be0e5c09SChris Mason if (slot != nritems) { 830be0e5c09SChris Mason int i; 831be0e5c09SChris Mason unsigned int old_data = leaf->items[slot].offset + 832be0e5c09SChris Mason leaf->items[slot].size; 833be0e5c09SChris Mason 834be0e5c09SChris Mason /* 835be0e5c09SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 836be0e5c09SChris Mason */ 837be0e5c09SChris Mason /* first correct the data pointers */ 838be0e5c09SChris Mason for (i = slot; i < nritems; i++) 839be0e5c09SChris Mason leaf->items[i].offset -= data_size; 840be0e5c09SChris Mason 841be0e5c09SChris Mason /* shift the items */ 842be0e5c09SChris Mason memmove(leaf->items + slot + 1, leaf->items + slot, 843be0e5c09SChris Mason (nritems - slot) * sizeof(struct item)); 844be0e5c09SChris Mason 845be0e5c09SChris Mason /* shift the data */ 846be0e5c09SChris Mason memmove(leaf->data + data_end - data_size, leaf->data + 847be0e5c09SChris Mason data_end, old_data - data_end); 848be0e5c09SChris Mason data_end = old_data; 849be0e5c09SChris Mason } 85074123bd7SChris Mason /* copy the new data in */ 851be0e5c09SChris Mason memcpy(&leaf->items[slot].key, key, sizeof(struct key)); 852be0e5c09SChris Mason leaf->items[slot].offset = data_end - data_size; 853be0e5c09SChris Mason leaf->items[slot].size = data_size; 854be0e5c09SChris Mason memcpy(leaf->data + data_end - data_size, data, data_size); 855be0e5c09SChris Mason leaf->header.nritems += 1; 856eb60ceacSChris Mason write_tree_block(root, leaf_buf); 857be0e5c09SChris Mason if (leaf_free_space(leaf) < 0) 858be0e5c09SChris Mason BUG(); 859eb60ceacSChris Mason release_path(root, &path); 860be0e5c09SChris Mason return 0; 861be0e5c09SChris Mason } 862be0e5c09SChris Mason 86374123bd7SChris Mason /* 8645de08d7dSChris Mason * delete the pointer from a given node. 86574123bd7SChris Mason * 86674123bd7SChris Mason * If the delete empties a node, the node is removed from the tree, 86774123bd7SChris Mason * continuing all the way the root if required. The root is converted into 86874123bd7SChris Mason * a leaf if all the nodes are emptied. 86974123bd7SChris Mason */ 870be0e5c09SChris Mason int del_ptr(struct ctree_root *root, struct ctree_path *path, int level) 871be0e5c09SChris Mason { 872be0e5c09SChris Mason int slot; 873eb60ceacSChris Mason struct tree_buffer *t; 874be0e5c09SChris Mason struct node *node; 875be0e5c09SChris Mason int nritems; 8769a8dd150SChris Mason u64 blocknr; 877be0e5c09SChris Mason 878be0e5c09SChris Mason while(1) { 879eb60ceacSChris Mason t = path->nodes[level]; 880eb60ceacSChris Mason if (!t) 881be0e5c09SChris Mason break; 882eb60ceacSChris Mason node = &t->node; 883be0e5c09SChris Mason slot = path->slots[level]; 884be0e5c09SChris Mason nritems = node->header.nritems; 885be0e5c09SChris Mason 886be0e5c09SChris Mason if (slot != nritems -1) { 887be0e5c09SChris Mason memmove(node->keys + slot, node->keys + slot + 1, 888be0e5c09SChris Mason sizeof(struct key) * (nritems - slot - 1)); 889be0e5c09SChris Mason memmove(node->blockptrs + slot, 890be0e5c09SChris Mason node->blockptrs + slot + 1, 891be0e5c09SChris Mason sizeof(u64) * (nritems - slot - 1)); 892be0e5c09SChris Mason } 893be0e5c09SChris Mason node->header.nritems--; 894eb60ceacSChris Mason write_tree_block(root, t); 8959a8dd150SChris Mason blocknr = t->blocknr; 896be0e5c09SChris Mason if (node->header.nritems != 0) { 897be0e5c09SChris Mason if (slot == 0) 898eb60ceacSChris Mason fixup_low_keys(root, path, node->keys, 899eb60ceacSChris Mason level + 1); 900be0e5c09SChris Mason break; 901eb60ceacSChris Mason } 902eb60ceacSChris Mason if (t == root->node) { 903eb60ceacSChris Mason /* just turn the root into a leaf and break */ 904eb60ceacSChris Mason root->node->node.header.flags = node_level(0); 905eb60ceacSChris Mason write_tree_block(root, t); 906be0e5c09SChris Mason break; 907be0e5c09SChris Mason } 908be0e5c09SChris Mason level++; 9099a8dd150SChris Mason free_extent(root, blocknr, 1); 910be0e5c09SChris Mason if (!path->nodes[level]) 911be0e5c09SChris Mason BUG(); 912be0e5c09SChris Mason } 913be0e5c09SChris Mason return 0; 914be0e5c09SChris Mason } 915be0e5c09SChris Mason 91674123bd7SChris Mason /* 91774123bd7SChris Mason * delete the item at the leaf level in path. If that empties 91874123bd7SChris Mason * the leaf, remove it from the tree 91974123bd7SChris Mason */ 9204920c9acSChris Mason int del_item(struct ctree_root *root, struct ctree_path *path) 921be0e5c09SChris Mason { 922be0e5c09SChris Mason int slot; 923be0e5c09SChris Mason struct leaf *leaf; 924eb60ceacSChris Mason struct tree_buffer *leaf_buf; 925be0e5c09SChris Mason int doff; 926be0e5c09SChris Mason int dsize; 927be0e5c09SChris Mason 928eb60ceacSChris Mason leaf_buf = path->nodes[0]; 929eb60ceacSChris Mason leaf = &leaf_buf->leaf; 9304920c9acSChris Mason slot = path->slots[0]; 931be0e5c09SChris Mason doff = leaf->items[slot].offset; 932be0e5c09SChris Mason dsize = leaf->items[slot].size; 933be0e5c09SChris Mason 934be0e5c09SChris Mason if (slot != leaf->header.nritems - 1) { 935be0e5c09SChris Mason int i; 936be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 937be0e5c09SChris Mason memmove(leaf->data + data_end + dsize, 938be0e5c09SChris Mason leaf->data + data_end, 939be0e5c09SChris Mason doff - data_end); 940be0e5c09SChris Mason for (i = slot + 1; i < leaf->header.nritems; i++) 941be0e5c09SChris Mason leaf->items[i].offset += dsize; 942be0e5c09SChris Mason memmove(leaf->items + slot, leaf->items + slot + 1, 943be0e5c09SChris Mason sizeof(struct item) * 944be0e5c09SChris Mason (leaf->header.nritems - slot - 1)); 945be0e5c09SChris Mason } 946be0e5c09SChris Mason leaf->header.nritems -= 1; 94774123bd7SChris Mason /* delete the leaf if we've emptied it */ 948be0e5c09SChris Mason if (leaf->header.nritems == 0) { 949eb60ceacSChris Mason if (leaf_buf == root->node) { 950eb60ceacSChris Mason leaf->header.flags = node_level(0); 951eb60ceacSChris Mason write_tree_block(root, leaf_buf); 9529a8dd150SChris Mason } else { 9534920c9acSChris Mason del_ptr(root, path, 1); 9549a8dd150SChris Mason free_extent(root, leaf_buf->blocknr, 1); 9559a8dd150SChris Mason } 956be0e5c09SChris Mason } else { 9575de08d7dSChris Mason int used = leaf_space_used(leaf, 0, leaf->header.nritems); 958be0e5c09SChris Mason if (slot == 0) 959eb60ceacSChris Mason fixup_low_keys(root, path, &leaf->items[0].key, 1); 960eb60ceacSChris Mason write_tree_block(root, leaf_buf); 96174123bd7SChris Mason /* delete the leaf if it is mostly empty */ 9625de08d7dSChris Mason if (used < LEAF_DATA_SIZE / 3) { 963be0e5c09SChris Mason /* push_leaf_left fixes the path. 964be0e5c09SChris Mason * make sure the path still points to our leaf 965be0e5c09SChris Mason * for possible call to del_ptr below 966be0e5c09SChris Mason */ 9674920c9acSChris Mason slot = path->slots[1]; 968eb60ceacSChris Mason leaf_buf->count++; 9694920c9acSChris Mason push_leaf_left(root, path, 1); 97000ec4c51SChris Mason if (leaf->header.nritems) 97100ec4c51SChris Mason push_leaf_right(root, path, 1); 972be0e5c09SChris Mason if (leaf->header.nritems == 0) { 9735de08d7dSChris Mason u64 blocknr = leaf_buf->blocknr; 9744920c9acSChris Mason path->slots[1] = slot; 9754920c9acSChris Mason del_ptr(root, path, 1); 9765de08d7dSChris Mason tree_block_release(root, leaf_buf); 9775de08d7dSChris Mason free_extent(root, blocknr, 1); 9785de08d7dSChris Mason } else { 979eb60ceacSChris Mason tree_block_release(root, leaf_buf); 980be0e5c09SChris Mason } 981be0e5c09SChris Mason } 9829a8dd150SChris Mason } 9839a8dd150SChris Mason return 0; 9849a8dd150SChris Mason } 9859a8dd150SChris Mason 986d97e63b6SChris Mason int next_leaf(struct ctree_root *root, struct ctree_path *path) 987d97e63b6SChris Mason { 988d97e63b6SChris Mason int slot; 989d97e63b6SChris Mason int level = 1; 990d97e63b6SChris Mason u64 blocknr; 991d97e63b6SChris Mason struct tree_buffer *c; 992cfaa7295SChris Mason struct tree_buffer *next = NULL; 993d97e63b6SChris Mason 994d97e63b6SChris Mason while(level < MAX_LEVEL) { 995d97e63b6SChris Mason if (!path->nodes[level]) 996d97e63b6SChris Mason return -1; 997d97e63b6SChris Mason slot = path->slots[level] + 1; 998d97e63b6SChris Mason c = path->nodes[level]; 999d97e63b6SChris Mason if (slot >= c->node.header.nritems) { 1000d97e63b6SChris Mason level++; 1001d97e63b6SChris Mason continue; 1002d97e63b6SChris Mason } 1003d97e63b6SChris Mason blocknr = c->node.blockptrs[slot]; 1004cfaa7295SChris Mason if (next) 1005cfaa7295SChris Mason tree_block_release(root, next); 1006d97e63b6SChris Mason next = read_tree_block(root, blocknr); 1007d97e63b6SChris Mason break; 1008d97e63b6SChris Mason } 1009d97e63b6SChris Mason path->slots[level] = slot; 1010d97e63b6SChris Mason while(1) { 1011d97e63b6SChris Mason level--; 1012d97e63b6SChris Mason c = path->nodes[level]; 1013d97e63b6SChris Mason tree_block_release(root, c); 1014d97e63b6SChris Mason path->nodes[level] = next; 1015d97e63b6SChris Mason path->slots[level] = 0; 1016d97e63b6SChris Mason if (!level) 1017d97e63b6SChris Mason break; 1018d97e63b6SChris Mason next = read_tree_block(root, next->node.blockptrs[0]); 1019d97e63b6SChris Mason } 1020d97e63b6SChris Mason return 0; 1021d97e63b6SChris Mason } 1022d97e63b6SChris Mason 1023be0e5c09SChris Mason /* for testing only */ 1024be0e5c09SChris Mason int next_key(int i, int max_key) { 10255de08d7dSChris Mason return rand() % max_key; 10265de08d7dSChris Mason //return i; 1027be0e5c09SChris Mason } 1028be0e5c09SChris Mason 1029be0e5c09SChris Mason int main() { 1030eb60ceacSChris Mason struct ctree_root *root; 1031be0e5c09SChris Mason struct key ins; 10324920c9acSChris Mason struct key last = { (u64)-1, 0, 0}; 1033be0e5c09SChris Mason char *buf; 1034be0e5c09SChris Mason int i; 1035be0e5c09SChris Mason int num; 1036be0e5c09SChris Mason int ret; 10375de08d7dSChris Mason int run_size = 20000000; 1038be0e5c09SChris Mason int max_key = 100000000; 1039be0e5c09SChris Mason int tree_size = 0; 1040be0e5c09SChris Mason struct ctree_path path; 1041cfaa7295SChris Mason struct ctree_super_block super; 1042be0e5c09SChris Mason 1043eb60ceacSChris Mason radix_tree_init(); 1044eb60ceacSChris Mason 1045eb60ceacSChris Mason 1046cfaa7295SChris Mason root = open_ctree("dbfile", &super); 1047be0e5c09SChris Mason 1048be0e5c09SChris Mason srand(55); 1049be0e5c09SChris Mason for (i = 0; i < run_size; i++) { 1050be0e5c09SChris Mason buf = malloc(64); 1051be0e5c09SChris Mason num = next_key(i, max_key); 1052be0e5c09SChris Mason // num = i; 1053be0e5c09SChris Mason sprintf(buf, "string-%d", num); 10545de08d7dSChris Mason if (i % 10000 == 0) 105500ec4c51SChris Mason fprintf(stderr, "insert %d:%d\n", num, i); 1056be0e5c09SChris Mason ins.objectid = num; 1057be0e5c09SChris Mason ins.offset = 0; 1058be0e5c09SChris Mason ins.flags = 0; 1059eb60ceacSChris Mason ret = insert_item(root, &ins, buf, strlen(buf)); 1060be0e5c09SChris Mason if (!ret) 1061be0e5c09SChris Mason tree_size++; 10625de08d7dSChris Mason free(buf); 1063be0e5c09SChris Mason } 1064cfaa7295SChris Mason write_ctree_super(root, &super); 1065eb60ceacSChris Mason close_ctree(root); 1066cfaa7295SChris Mason 1067cfaa7295SChris Mason root = open_ctree("dbfile", &super); 1068eb60ceacSChris Mason printf("starting search\n"); 1069be0e5c09SChris Mason srand(55); 1070be0e5c09SChris Mason for (i = 0; i < run_size; i++) { 1071be0e5c09SChris Mason num = next_key(i, max_key); 1072be0e5c09SChris Mason ins.objectid = num; 1073be0e5c09SChris Mason init_path(&path); 10745de08d7dSChris Mason if (i % 10000 == 0) 107500ec4c51SChris Mason fprintf(stderr, "search %d:%d\n", num, i); 10765c680ed6SChris Mason ret = search_slot(root, &ins, &path, 0); 1077be0e5c09SChris Mason if (ret) { 1078eb60ceacSChris Mason print_tree(root, root->node); 1079be0e5c09SChris Mason printf("unable to find %d\n", num); 1080be0e5c09SChris Mason exit(1); 1081be0e5c09SChris Mason } 1082eb60ceacSChris Mason release_path(root, &path); 1083be0e5c09SChris Mason } 1084cfaa7295SChris Mason write_ctree_super(root, &super); 1085eb60ceacSChris Mason close_ctree(root); 1086cfaa7295SChris Mason root = open_ctree("dbfile", &super); 1087eb60ceacSChris Mason printf("node %p level %d total ptrs %d free spc %lu\n", root->node, 1088eb60ceacSChris Mason node_level(root->node->node.header.flags), 1089eb60ceacSChris Mason root->node->node.header.nritems, 1090eb60ceacSChris Mason NODEPTRS_PER_BLOCK - root->node->node.header.nritems); 1091eb60ceacSChris Mason printf("all searches good, deleting some items\n"); 1092be0e5c09SChris Mason i = 0; 1093be0e5c09SChris Mason srand(55); 10944920c9acSChris Mason for (i = 0 ; i < run_size/4; i++) { 1095be0e5c09SChris Mason num = next_key(i, max_key); 1096be0e5c09SChris Mason ins.objectid = num; 10974920c9acSChris Mason init_path(&path); 10985de08d7dSChris Mason ret = search_slot(root, &ins, &path, -1); 10995de08d7dSChris Mason if (!ret) { 11005de08d7dSChris Mason if (i % 10000 == 0) 110100ec4c51SChris Mason fprintf(stderr, "del %d:%d\n", num, i); 1102eb60ceacSChris Mason ret = del_item(root, &path); 11034920c9acSChris Mason if (ret != 0) 11044920c9acSChris Mason BUG(); 11054920c9acSChris Mason tree_size--; 11064920c9acSChris Mason } 11075de08d7dSChris Mason release_path(root, &path); 11085de08d7dSChris Mason } 11095de08d7dSChris Mason write_ctree_super(root, &super); 11105de08d7dSChris Mason close_ctree(root); 11115de08d7dSChris Mason root = open_ctree("dbfile", &super); 11124920c9acSChris Mason srand(128); 11134920c9acSChris Mason for (i = 0; i < run_size; i++) { 11144920c9acSChris Mason buf = malloc(64); 11154920c9acSChris Mason num = next_key(i, max_key); 11164920c9acSChris Mason sprintf(buf, "string-%d", num); 11174920c9acSChris Mason ins.objectid = num; 11185de08d7dSChris Mason if (i % 10000 == 0) 111900ec4c51SChris Mason fprintf(stderr, "insert %d:%d\n", num, i); 1120eb60ceacSChris Mason ret = insert_item(root, &ins, buf, strlen(buf)); 11214920c9acSChris Mason if (!ret) 11224920c9acSChris Mason tree_size++; 11235de08d7dSChris Mason free(buf); 11244920c9acSChris Mason } 1125cfaa7295SChris Mason write_ctree_super(root, &super); 1126eb60ceacSChris Mason close_ctree(root); 1127cfaa7295SChris Mason root = open_ctree("dbfile", &super); 1128eb60ceacSChris Mason srand(128); 11299a8dd150SChris Mason printf("starting search2\n"); 1130eb60ceacSChris Mason for (i = 0; i < run_size; i++) { 1131eb60ceacSChris Mason num = next_key(i, max_key); 1132eb60ceacSChris Mason ins.objectid = num; 1133eb60ceacSChris Mason init_path(&path); 11345de08d7dSChris Mason if (i % 10000 == 0) 113500ec4c51SChris Mason fprintf(stderr, "search %d:%d\n", num, i); 11365c680ed6SChris Mason ret = search_slot(root, &ins, &path, 0); 1137eb60ceacSChris Mason if (ret) { 1138eb60ceacSChris Mason print_tree(root, root->node); 1139eb60ceacSChris Mason printf("unable to find %d\n", num); 1140eb60ceacSChris Mason exit(1); 1141eb60ceacSChris Mason } 1142eb60ceacSChris Mason release_path(root, &path); 1143eb60ceacSChris Mason } 1144eb60ceacSChris Mason printf("starting big long delete run\n"); 1145eb60ceacSChris Mason while(root->node && root->node->node.header.nritems > 0) { 11464920c9acSChris Mason struct leaf *leaf; 11474920c9acSChris Mason int slot; 11484920c9acSChris Mason ins.objectid = (u64)-1; 11494920c9acSChris Mason init_path(&path); 11505de08d7dSChris Mason ret = search_slot(root, &ins, &path, -1); 11514920c9acSChris Mason if (ret == 0) 11524920c9acSChris Mason BUG(); 11534920c9acSChris Mason 1154eb60ceacSChris Mason leaf = &path.nodes[0]->leaf; 11554920c9acSChris Mason slot = path.slots[0]; 11564920c9acSChris Mason if (slot != leaf->header.nritems) 11574920c9acSChris Mason BUG(); 11584920c9acSChris Mason while(path.slots[0] > 0) { 11594920c9acSChris Mason path.slots[0] -= 1; 11604920c9acSChris Mason slot = path.slots[0]; 1161eb60ceacSChris Mason leaf = &path.nodes[0]->leaf; 11624920c9acSChris Mason 11634920c9acSChris Mason if (comp_keys(&last, &leaf->items[slot].key) <= 0) 11644920c9acSChris Mason BUG(); 11654920c9acSChris Mason memcpy(&last, &leaf->items[slot].key, sizeof(last)); 11665de08d7dSChris Mason if (tree_size % 10000 == 0) 11675de08d7dSChris Mason printf("big del %d:%d\n", tree_size, i); 1168eb60ceacSChris Mason ret = del_item(root, &path); 1169eb60ceacSChris Mason if (ret != 0) { 1170eb60ceacSChris Mason printf("del_item returned %d\n", ret); 11714920c9acSChris Mason BUG(); 1172eb60ceacSChris Mason } 11734920c9acSChris Mason tree_size--; 11744920c9acSChris Mason } 1175eb60ceacSChris Mason release_path(root, &path); 1176be0e5c09SChris Mason } 11774920c9acSChris Mason printf("tree size is now %d\n", tree_size); 11789a8dd150SChris Mason printf("map tree\n"); 117900ec4c51SChris Mason print_tree(root->extent_root, root->extent_root->node); 11805de08d7dSChris Mason write_ctree_super(root, &super); 11815de08d7dSChris Mason close_ctree(root); 1182be0e5c09SChris Mason return 0; 1183be0e5c09SChris Mason } 1184