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" 7be0e5c09SChris Mason 8be0e5c09SChris Mason static inline void init_path(struct ctree_path *p) 9be0e5c09SChris Mason { 10be0e5c09SChris Mason memset(p, 0, sizeof(*p)); 11be0e5c09SChris Mason } 12be0e5c09SChris Mason 13eb60ceacSChris Mason static void release_path(struct ctree_root *root, struct ctree_path *p) 14eb60ceacSChris Mason { 15eb60ceacSChris Mason int i; 16eb60ceacSChris Mason for (i = 0; i < MAX_LEVEL; i++) { 17eb60ceacSChris Mason if (!p->nodes[i]) 18eb60ceacSChris Mason break; 19eb60ceacSChris Mason tree_block_release(root, p->nodes[i]); 20eb60ceacSChris Mason } 21eb60ceacSChris Mason } 22eb60ceacSChris Mason 23be0e5c09SChris Mason static inline unsigned int leaf_data_end(struct leaf *leaf) 24be0e5c09SChris Mason { 25be0e5c09SChris Mason unsigned int nr = leaf->header.nritems; 26be0e5c09SChris Mason if (nr == 0) 27be0e5c09SChris Mason return ARRAY_SIZE(leaf->data); 28be0e5c09SChris Mason return leaf->items[nr-1].offset; 29be0e5c09SChris Mason } 30be0e5c09SChris Mason 31be0e5c09SChris Mason static inline int leaf_free_space(struct leaf *leaf) 32be0e5c09SChris Mason { 33be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 34be0e5c09SChris Mason int nritems = leaf->header.nritems; 35be0e5c09SChris Mason char *items_end = (char *)(leaf->items + nritems + 1); 36be0e5c09SChris Mason return (char *)(leaf->data + data_end) - (char *)items_end; 37be0e5c09SChris Mason } 38be0e5c09SChris Mason 39be0e5c09SChris Mason int comp_keys(struct key *k1, struct key *k2) 40be0e5c09SChris Mason { 41be0e5c09SChris Mason if (k1->objectid > k2->objectid) 42be0e5c09SChris Mason return 1; 43be0e5c09SChris Mason if (k1->objectid < k2->objectid) 44be0e5c09SChris Mason return -1; 45be0e5c09SChris Mason if (k1->flags > k2->flags) 46be0e5c09SChris Mason return 1; 47be0e5c09SChris Mason if (k1->flags < k2->flags) 48be0e5c09SChris Mason return -1; 49be0e5c09SChris Mason if (k1->offset > k2->offset) 50be0e5c09SChris Mason return 1; 51be0e5c09SChris Mason if (k1->offset < k2->offset) 52be0e5c09SChris Mason return -1; 53be0e5c09SChris Mason return 0; 54be0e5c09SChris Mason } 55be0e5c09SChris Mason int generic_bin_search(char *p, int item_size, struct key *key, 56be0e5c09SChris Mason int max, int *slot) 57be0e5c09SChris Mason { 58be0e5c09SChris Mason int low = 0; 59be0e5c09SChris Mason int high = max; 60be0e5c09SChris Mason int mid; 61be0e5c09SChris Mason int ret; 62be0e5c09SChris Mason struct key *tmp; 63be0e5c09SChris Mason 64be0e5c09SChris Mason while(low < high) { 65be0e5c09SChris Mason mid = (low + high) / 2; 66be0e5c09SChris Mason tmp = (struct key *)(p + mid * item_size); 67be0e5c09SChris Mason ret = comp_keys(tmp, key); 68be0e5c09SChris Mason 69be0e5c09SChris Mason if (ret < 0) 70be0e5c09SChris Mason low = mid + 1; 71be0e5c09SChris Mason else if (ret > 0) 72be0e5c09SChris Mason high = mid; 73be0e5c09SChris Mason else { 74be0e5c09SChris Mason *slot = mid; 75be0e5c09SChris Mason return 0; 76be0e5c09SChris Mason } 77be0e5c09SChris Mason } 78be0e5c09SChris Mason *slot = low; 79be0e5c09SChris Mason return 1; 80be0e5c09SChris Mason } 81be0e5c09SChris Mason 82be0e5c09SChris Mason int bin_search(struct node *c, struct key *key, int *slot) 83be0e5c09SChris Mason { 84be0e5c09SChris Mason if (is_leaf(c->header.flags)) { 85be0e5c09SChris Mason struct leaf *l = (struct leaf *)c; 86be0e5c09SChris Mason return generic_bin_search((void *)l->items, sizeof(struct item), 87be0e5c09SChris Mason key, c->header.nritems, slot); 88be0e5c09SChris Mason } else { 89be0e5c09SChris Mason return generic_bin_search((void *)c->keys, sizeof(struct key), 90be0e5c09SChris Mason key, c->header.nritems, slot); 91be0e5c09SChris Mason } 92be0e5c09SChris Mason return -1; 93be0e5c09SChris Mason } 94be0e5c09SChris Mason 95be0e5c09SChris Mason int search_slot(struct ctree_root *root, struct key *key, struct ctree_path *p) 96be0e5c09SChris Mason { 97eb60ceacSChris Mason struct tree_buffer *b = root->node; 98eb60ceacSChris Mason struct node *c; 99eb60ceacSChris Mason 100be0e5c09SChris Mason int slot; 101be0e5c09SChris Mason int ret; 102be0e5c09SChris Mason int level; 103eb60ceacSChris Mason b->count++; 104eb60ceacSChris Mason while (b) { 105eb60ceacSChris Mason c = &b->node; 106be0e5c09SChris Mason level = node_level(c->header.flags); 107eb60ceacSChris Mason p->nodes[level] = b; 108be0e5c09SChris Mason ret = bin_search(c, key, &slot); 109be0e5c09SChris Mason if (!is_leaf(c->header.flags)) { 110be0e5c09SChris Mason if (ret && slot > 0) 111be0e5c09SChris Mason slot -= 1; 112be0e5c09SChris Mason p->slots[level] = slot; 113eb60ceacSChris Mason b = read_tree_block(root, c->blockptrs[slot]); 114be0e5c09SChris Mason continue; 115be0e5c09SChris Mason } else { 116be0e5c09SChris Mason p->slots[level] = slot; 117be0e5c09SChris Mason return ret; 118be0e5c09SChris Mason } 119be0e5c09SChris Mason } 120be0e5c09SChris Mason return -1; 121be0e5c09SChris Mason } 122be0e5c09SChris Mason 123eb60ceacSChris Mason static void fixup_low_keys(struct ctree_root *root, 124eb60ceacSChris Mason struct ctree_path *path, struct key *key, 125be0e5c09SChris Mason int level) 126be0e5c09SChris Mason { 127be0e5c09SChris Mason int i; 128be0e5c09SChris Mason /* adjust the pointers going up the tree */ 129be0e5c09SChris Mason for (i = level; i < MAX_LEVEL; i++) { 130eb60ceacSChris Mason struct node *t; 131be0e5c09SChris Mason int tslot = path->slots[i]; 132eb60ceacSChris Mason if (!path->nodes[i]) 133be0e5c09SChris Mason break; 134eb60ceacSChris Mason t = &path->nodes[i]->node; 135be0e5c09SChris Mason memcpy(t->keys + tslot, key, sizeof(*key)); 136eb60ceacSChris Mason write_tree_block(root, path->nodes[i]); 137be0e5c09SChris Mason if (tslot != 0) 138be0e5c09SChris Mason break; 139be0e5c09SChris Mason } 140be0e5c09SChris Mason } 141be0e5c09SChris Mason 142be0e5c09SChris Mason int __insert_ptr(struct ctree_root *root, 143be0e5c09SChris Mason struct ctree_path *path, struct key *key, 144be0e5c09SChris Mason u64 blocknr, int slot, int level) 145be0e5c09SChris Mason { 146be0e5c09SChris Mason struct node *c; 147be0e5c09SChris Mason struct node *lower; 148be0e5c09SChris Mason struct key *lower_key; 149be0e5c09SChris Mason int nritems; 150be0e5c09SChris Mason /* need a new root */ 151be0e5c09SChris Mason if (!path->nodes[level]) { 152eb60ceacSChris Mason struct tree_buffer *t; 153eb60ceacSChris Mason t = alloc_free_block(root); 154eb60ceacSChris Mason c = &t->node; 155be0e5c09SChris Mason memset(c, 0, sizeof(c)); 156be0e5c09SChris Mason c->header.nritems = 2; 157be0e5c09SChris Mason c->header.flags = node_level(level); 158eb60ceacSChris Mason c->header.blocknr = t->blocknr; 159eb60ceacSChris Mason lower = &path->nodes[level-1]->node; 160be0e5c09SChris Mason if (is_leaf(lower->header.flags)) 161be0e5c09SChris Mason lower_key = &((struct leaf *)lower)->items[0].key; 162be0e5c09SChris Mason else 163be0e5c09SChris Mason lower_key = lower->keys; 164be0e5c09SChris Mason memcpy(c->keys, lower_key, sizeof(struct key)); 165be0e5c09SChris Mason memcpy(c->keys + 1, key, sizeof(struct key)); 166eb60ceacSChris Mason c->blockptrs[0] = path->nodes[level-1]->blocknr; 167be0e5c09SChris Mason c->blockptrs[1] = blocknr; 168eb60ceacSChris Mason /* the path has an extra ref to root->node */ 169eb60ceacSChris Mason tree_block_release(root, root->node); 170eb60ceacSChris Mason root->node = t; 171eb60ceacSChris Mason t->count++; 172eb60ceacSChris Mason write_tree_block(root, t); 173eb60ceacSChris Mason path->nodes[level] = t; 174be0e5c09SChris Mason path->slots[level] = 0; 175be0e5c09SChris Mason if (c->keys[1].objectid == 0) 176be0e5c09SChris Mason BUG(); 177be0e5c09SChris Mason return 0; 178be0e5c09SChris Mason } 179eb60ceacSChris Mason lower = &path->nodes[level]->node; 180be0e5c09SChris Mason nritems = lower->header.nritems; 181be0e5c09SChris Mason if (slot > nritems) 182be0e5c09SChris Mason BUG(); 183be0e5c09SChris Mason if (nritems == NODEPTRS_PER_BLOCK) 184be0e5c09SChris Mason BUG(); 185be0e5c09SChris Mason if (slot != nritems) { 186be0e5c09SChris Mason memmove(lower->keys + slot + 1, lower->keys + slot, 187be0e5c09SChris Mason (nritems - slot) * sizeof(struct key)); 188be0e5c09SChris Mason memmove(lower->blockptrs + slot + 1, lower->blockptrs + slot, 189be0e5c09SChris Mason (nritems - slot) * sizeof(u64)); 190be0e5c09SChris Mason } 191be0e5c09SChris Mason memcpy(lower->keys + slot, key, sizeof(struct key)); 192be0e5c09SChris Mason lower->blockptrs[slot] = blocknr; 193be0e5c09SChris Mason lower->header.nritems++; 194be0e5c09SChris Mason if (lower->keys[1].objectid == 0) 195be0e5c09SChris Mason BUG(); 196eb60ceacSChris Mason write_tree_block(root, path->nodes[level]); 197be0e5c09SChris Mason return 0; 198be0e5c09SChris Mason } 199be0e5c09SChris Mason 200be0e5c09SChris Mason int push_node_left(struct ctree_root *root, struct ctree_path *path, int level) 201be0e5c09SChris Mason { 202be0e5c09SChris Mason int slot; 203be0e5c09SChris Mason struct node *left; 204be0e5c09SChris Mason struct node *right; 205be0e5c09SChris Mason int push_items = 0; 206be0e5c09SChris Mason int left_nritems; 207be0e5c09SChris Mason int right_nritems; 208eb60ceacSChris Mason struct tree_buffer *t; 209eb60ceacSChris Mason struct tree_buffer *right_buf; 210be0e5c09SChris Mason 211be0e5c09SChris Mason if (level == MAX_LEVEL - 1 || path->nodes[level + 1] == 0) 212be0e5c09SChris Mason return 1; 213be0e5c09SChris Mason slot = path->slots[level + 1]; 214be0e5c09SChris Mason if (slot == 0) 215be0e5c09SChris Mason return 1; 216be0e5c09SChris Mason 217eb60ceacSChris Mason t = read_tree_block(root, 218eb60ceacSChris Mason path->nodes[level + 1]->node.blockptrs[slot - 1]); 219eb60ceacSChris Mason left = &t->node; 220eb60ceacSChris Mason right_buf = path->nodes[level]; 221eb60ceacSChris Mason right = &right_buf->node; 222be0e5c09SChris Mason left_nritems = left->header.nritems; 223be0e5c09SChris Mason right_nritems = right->header.nritems; 224be0e5c09SChris Mason push_items = NODEPTRS_PER_BLOCK - (left_nritems + 1); 225eb60ceacSChris Mason if (push_items <= 0) { 226eb60ceacSChris Mason tree_block_release(root, t); 227be0e5c09SChris Mason return 1; 228eb60ceacSChris Mason } 229be0e5c09SChris Mason 230be0e5c09SChris Mason if (right_nritems < push_items) 231be0e5c09SChris Mason push_items = right_nritems; 232be0e5c09SChris Mason memcpy(left->keys + left_nritems, right->keys, 233be0e5c09SChris Mason push_items * sizeof(struct key)); 234be0e5c09SChris Mason memcpy(left->blockptrs + left_nritems, right->blockptrs, 235be0e5c09SChris Mason push_items * sizeof(u64)); 236be0e5c09SChris Mason memmove(right->keys, right->keys + push_items, 237be0e5c09SChris Mason (right_nritems - push_items) * sizeof(struct key)); 238be0e5c09SChris Mason memmove(right->blockptrs, right->blockptrs + push_items, 239be0e5c09SChris Mason (right_nritems - push_items) * sizeof(u64)); 240be0e5c09SChris Mason right->header.nritems -= push_items; 241be0e5c09SChris Mason left->header.nritems += push_items; 242be0e5c09SChris Mason 243be0e5c09SChris Mason /* adjust the pointers going up the tree */ 244eb60ceacSChris Mason fixup_low_keys(root, path, right->keys, level + 1); 245eb60ceacSChris Mason 246eb60ceacSChris Mason write_tree_block(root, t); 247eb60ceacSChris Mason write_tree_block(root, right_buf); 248be0e5c09SChris Mason 249be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 250be0e5c09SChris Mason if (path->slots[level] < push_items) { 251be0e5c09SChris Mason path->slots[level] += left_nritems; 252eb60ceacSChris Mason tree_block_release(root, path->nodes[level]); 253eb60ceacSChris Mason path->nodes[level] = t; 254be0e5c09SChris Mason path->slots[level + 1] -= 1; 255be0e5c09SChris Mason } else { 256be0e5c09SChris Mason path->slots[level] -= push_items; 257eb60ceacSChris Mason tree_block_release(root, t); 258be0e5c09SChris Mason } 259be0e5c09SChris Mason return 0; 260be0e5c09SChris Mason } 261be0e5c09SChris Mason 262be0e5c09SChris Mason int push_node_right(struct ctree_root *root, struct ctree_path *path, int level) 263be0e5c09SChris Mason { 264be0e5c09SChris Mason int slot; 265eb60ceacSChris Mason struct tree_buffer *t; 266eb60ceacSChris Mason struct tree_buffer *src_buffer; 267be0e5c09SChris Mason struct node *dst; 268be0e5c09SChris Mason struct node *src; 269be0e5c09SChris Mason int push_items = 0; 270be0e5c09SChris Mason int dst_nritems; 271be0e5c09SChris Mason int src_nritems; 272be0e5c09SChris Mason 273be0e5c09SChris Mason if (level == MAX_LEVEL - 1 || path->nodes[level + 1] == 0) 274be0e5c09SChris Mason return 1; 275be0e5c09SChris Mason slot = path->slots[level + 1]; 276be0e5c09SChris Mason if (slot == NODEPTRS_PER_BLOCK - 1) 277be0e5c09SChris Mason return 1; 278be0e5c09SChris Mason 279eb60ceacSChris Mason if (slot >= path->nodes[level + 1]->node.header.nritems -1) 280be0e5c09SChris Mason return 1; 281be0e5c09SChris Mason 282eb60ceacSChris Mason t = read_tree_block(root, 283eb60ceacSChris Mason path->nodes[level + 1]->node.blockptrs[slot + 1]); 284eb60ceacSChris Mason dst = &t->node; 285eb60ceacSChris Mason src_buffer = path->nodes[level]; 286eb60ceacSChris Mason src = &src_buffer->node; 287be0e5c09SChris Mason dst_nritems = dst->header.nritems; 288be0e5c09SChris Mason src_nritems = src->header.nritems; 289be0e5c09SChris Mason push_items = NODEPTRS_PER_BLOCK - (dst_nritems + 1); 290eb60ceacSChris Mason if (push_items <= 0) { 291eb60ceacSChris Mason tree_block_release(root, t); 292be0e5c09SChris Mason return 1; 293eb60ceacSChris Mason } 294be0e5c09SChris Mason 295be0e5c09SChris Mason if (src_nritems < push_items) 296be0e5c09SChris Mason push_items = src_nritems; 297be0e5c09SChris Mason memmove(dst->keys + push_items, dst->keys, 298be0e5c09SChris Mason dst_nritems * sizeof(struct key)); 299be0e5c09SChris Mason memcpy(dst->keys, src->keys + src_nritems - push_items, 300be0e5c09SChris Mason push_items * sizeof(struct key)); 301be0e5c09SChris Mason 302be0e5c09SChris Mason memmove(dst->blockptrs + push_items, dst->blockptrs, 303be0e5c09SChris Mason dst_nritems * sizeof(u64)); 304be0e5c09SChris Mason memcpy(dst->blockptrs, src->blockptrs + src_nritems - push_items, 305be0e5c09SChris Mason push_items * sizeof(u64)); 306be0e5c09SChris Mason 307be0e5c09SChris Mason src->header.nritems -= push_items; 308be0e5c09SChris Mason dst->header.nritems += push_items; 309be0e5c09SChris Mason 310be0e5c09SChris Mason /* adjust the pointers going up the tree */ 311eb60ceacSChris Mason memcpy(path->nodes[level + 1]->node.keys + path->slots[level + 1] + 1, 312be0e5c09SChris Mason dst->keys, sizeof(struct key)); 313eb60ceacSChris Mason 314eb60ceacSChris Mason write_tree_block(root, path->nodes[level + 1]); 315eb60ceacSChris Mason write_tree_block(root, t); 316eb60ceacSChris Mason write_tree_block(root, src_buffer); 317eb60ceacSChris Mason 318be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 319be0e5c09SChris Mason if (path->slots[level] >= src->header.nritems) { 320be0e5c09SChris Mason path->slots[level] -= src->header.nritems; 321eb60ceacSChris Mason tree_block_release(root, path->nodes[level]); 322eb60ceacSChris Mason path->nodes[level] = t; 323be0e5c09SChris Mason path->slots[level + 1] += 1; 324eb60ceacSChris Mason } else { 325eb60ceacSChris Mason tree_block_release(root, t); 326be0e5c09SChris Mason } 327be0e5c09SChris Mason return 0; 328be0e5c09SChris Mason } 329be0e5c09SChris Mason 330be0e5c09SChris Mason int insert_ptr(struct ctree_root *root, 331be0e5c09SChris Mason struct ctree_path *path, struct key *key, 332be0e5c09SChris Mason u64 blocknr, int level) 333be0e5c09SChris Mason { 334eb60ceacSChris Mason struct tree_buffer *t = path->nodes[level]; 335eb60ceacSChris Mason struct node *c = &path->nodes[level]->node; 336be0e5c09SChris Mason struct node *b; 337eb60ceacSChris Mason struct tree_buffer *b_buffer; 338eb60ceacSChris Mason struct tree_buffer *bal[MAX_LEVEL]; 339be0e5c09SChris Mason int bal_level = level; 340be0e5c09SChris Mason int mid; 341be0e5c09SChris Mason int bal_start = -1; 342be0e5c09SChris Mason 343be0e5c09SChris Mason memset(bal, 0, ARRAY_SIZE(bal)); 344eb60ceacSChris Mason while(t && t->node.header.nritems == NODEPTRS_PER_BLOCK) { 345eb60ceacSChris Mason c = &t->node; 346be0e5c09SChris Mason if (push_node_left(root, path, 347be0e5c09SChris Mason node_level(c->header.flags)) == 0) 348be0e5c09SChris Mason break; 349be0e5c09SChris Mason if (push_node_right(root, path, 350be0e5c09SChris Mason node_level(c->header.flags)) == 0) 351be0e5c09SChris Mason break; 352be0e5c09SChris Mason bal_start = bal_level; 353be0e5c09SChris Mason if (bal_level == MAX_LEVEL - 1) 354be0e5c09SChris Mason BUG(); 355eb60ceacSChris Mason b_buffer = alloc_free_block(root); 356eb60ceacSChris Mason b = &b_buffer->node; 357be0e5c09SChris Mason b->header.flags = c->header.flags; 358eb60ceacSChris Mason b->header.blocknr = b_buffer->blocknr; 359be0e5c09SChris Mason mid = (c->header.nritems + 1) / 2; 360be0e5c09SChris Mason memcpy(b->keys, c->keys + mid, 361be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(struct key)); 362be0e5c09SChris Mason memcpy(b->blockptrs, c->blockptrs + mid, 363be0e5c09SChris Mason (c->header.nritems - mid) * sizeof(u64)); 364be0e5c09SChris Mason b->header.nritems = c->header.nritems - mid; 365be0e5c09SChris Mason c->header.nritems = mid; 366eb60ceacSChris Mason 367eb60ceacSChris Mason write_tree_block(root, t); 368eb60ceacSChris Mason write_tree_block(root, b_buffer); 369eb60ceacSChris Mason 370eb60ceacSChris Mason bal[bal_level] = b_buffer; 371be0e5c09SChris Mason if (bal_level == MAX_LEVEL - 1) 372be0e5c09SChris Mason break; 373be0e5c09SChris Mason bal_level += 1; 374eb60ceacSChris Mason t = path->nodes[bal_level]; 375be0e5c09SChris Mason } 376be0e5c09SChris Mason while(bal_start > 0) { 377eb60ceacSChris Mason b_buffer = bal[bal_start]; 378eb60ceacSChris Mason c = &path->nodes[bal_start]->node; 379eb60ceacSChris Mason __insert_ptr(root, path, b_buffer->node.keys, b_buffer->blocknr, 380be0e5c09SChris Mason path->slots[bal_start + 1] + 1, bal_start + 1); 381be0e5c09SChris Mason if (path->slots[bal_start] >= c->header.nritems) { 382be0e5c09SChris Mason path->slots[bal_start] -= c->header.nritems; 383eb60ceacSChris Mason tree_block_release(root, path->nodes[bal_start]); 384eb60ceacSChris Mason path->nodes[bal_start] = b_buffer; 385be0e5c09SChris Mason path->slots[bal_start + 1] += 1; 386eb60ceacSChris Mason } else { 387eb60ceacSChris Mason tree_block_release(root, b_buffer); 388be0e5c09SChris Mason } 389be0e5c09SChris Mason bal_start--; 390be0e5c09SChris Mason if (!bal[bal_start]) 391be0e5c09SChris Mason break; 392be0e5c09SChris Mason } 393be0e5c09SChris Mason return __insert_ptr(root, path, key, blocknr, path->slots[level] + 1, 394be0e5c09SChris Mason level); 395be0e5c09SChris Mason } 396be0e5c09SChris Mason 397be0e5c09SChris Mason int leaf_space_used(struct leaf *l, int start, int nr) 398be0e5c09SChris Mason { 399be0e5c09SChris Mason int data_len; 400be0e5c09SChris Mason int end = start + nr - 1; 401be0e5c09SChris Mason 402be0e5c09SChris Mason if (!nr) 403be0e5c09SChris Mason return 0; 404be0e5c09SChris Mason data_len = l->items[start].offset + l->items[start].size; 405be0e5c09SChris Mason data_len = data_len - l->items[end].offset; 406be0e5c09SChris Mason data_len += sizeof(struct item) * nr; 407be0e5c09SChris Mason return data_len; 408be0e5c09SChris Mason } 409be0e5c09SChris Mason 410be0e5c09SChris Mason int push_leaf_left(struct ctree_root *root, struct ctree_path *path, 411be0e5c09SChris Mason int data_size) 412be0e5c09SChris Mason { 413eb60ceacSChris Mason struct tree_buffer *right_buf = path->nodes[0]; 414eb60ceacSChris Mason struct leaf *right = &right_buf->leaf; 415eb60ceacSChris Mason struct tree_buffer *t; 416be0e5c09SChris Mason struct leaf *left; 417be0e5c09SChris Mason int slot; 418be0e5c09SChris Mason int i; 419be0e5c09SChris Mason int free_space; 420be0e5c09SChris Mason int push_space = 0; 421be0e5c09SChris Mason int push_items = 0; 422be0e5c09SChris Mason struct item *item; 423be0e5c09SChris Mason int old_left_nritems; 424be0e5c09SChris Mason 425be0e5c09SChris Mason slot = path->slots[1]; 426be0e5c09SChris Mason if (slot == 0) { 427be0e5c09SChris Mason return 1; 428be0e5c09SChris Mason } 429be0e5c09SChris Mason if (!path->nodes[1]) { 430be0e5c09SChris Mason return 1; 431be0e5c09SChris Mason } 432eb60ceacSChris Mason t = read_tree_block(root, path->nodes[1]->node.blockptrs[slot - 1]); 433eb60ceacSChris Mason left = &t->leaf; 434be0e5c09SChris Mason free_space = leaf_free_space(left); 435be0e5c09SChris Mason if (free_space < data_size + sizeof(struct item)) { 436eb60ceacSChris Mason tree_block_release(root, t); 437be0e5c09SChris Mason return 1; 438be0e5c09SChris Mason } 439be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 440be0e5c09SChris Mason item = right->items + i; 441be0e5c09SChris Mason if (path->slots[0] == i) 442be0e5c09SChris Mason push_space += data_size + sizeof(*item); 443be0e5c09SChris Mason if (item->size + sizeof(*item) + push_space > free_space) 444be0e5c09SChris Mason break; 445be0e5c09SChris Mason push_items++; 446be0e5c09SChris Mason push_space += item->size + sizeof(*item); 447be0e5c09SChris Mason } 448be0e5c09SChris Mason if (push_items == 0) { 449eb60ceacSChris Mason tree_block_release(root, t); 450be0e5c09SChris Mason return 1; 451be0e5c09SChris Mason } 452be0e5c09SChris Mason /* push data from right to left */ 453be0e5c09SChris Mason memcpy(left->items + left->header.nritems, 454be0e5c09SChris Mason right->items, push_items * sizeof(struct item)); 455be0e5c09SChris Mason push_space = LEAF_DATA_SIZE - right->items[push_items -1].offset; 456be0e5c09SChris Mason memcpy(left->data + leaf_data_end(left) - push_space, 457be0e5c09SChris Mason right->data + right->items[push_items - 1].offset, 458be0e5c09SChris Mason push_space); 459be0e5c09SChris Mason old_left_nritems = left->header.nritems; 460eb60ceacSChris Mason BUG_ON(old_left_nritems < 0); 461eb60ceacSChris Mason 462be0e5c09SChris Mason for(i = old_left_nritems; i < old_left_nritems + push_items; i++) { 463be0e5c09SChris Mason left->items[i].offset -= LEAF_DATA_SIZE - 464be0e5c09SChris Mason left->items[old_left_nritems -1].offset; 465be0e5c09SChris Mason } 466be0e5c09SChris Mason left->header.nritems += push_items; 467be0e5c09SChris Mason 468be0e5c09SChris Mason /* fixup right node */ 469be0e5c09SChris Mason push_space = right->items[push_items-1].offset - leaf_data_end(right); 470be0e5c09SChris Mason memmove(right->data + LEAF_DATA_SIZE - push_space, right->data + 471be0e5c09SChris Mason leaf_data_end(right), push_space); 472be0e5c09SChris Mason memmove(right->items, right->items + push_items, 473be0e5c09SChris Mason (right->header.nritems - push_items) * sizeof(struct item)); 474be0e5c09SChris Mason right->header.nritems -= push_items; 475be0e5c09SChris Mason push_space = LEAF_DATA_SIZE; 476eb60ceacSChris Mason 477be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 478be0e5c09SChris Mason right->items[i].offset = push_space - right->items[i].size; 479be0e5c09SChris Mason push_space = right->items[i].offset; 480be0e5c09SChris Mason } 481eb60ceacSChris Mason 482eb60ceacSChris Mason write_tree_block(root, t); 483eb60ceacSChris Mason write_tree_block(root, right_buf); 484eb60ceacSChris Mason 485eb60ceacSChris Mason fixup_low_keys(root, path, &right->items[0].key, 1); 486be0e5c09SChris Mason 487be0e5c09SChris Mason /* then fixup the leaf pointer in the path */ 488be0e5c09SChris Mason if (path->slots[0] < push_items) { 489be0e5c09SChris Mason path->slots[0] += old_left_nritems; 490eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 491eb60ceacSChris Mason path->nodes[0] = t; 492be0e5c09SChris Mason path->slots[1] -= 1; 493be0e5c09SChris Mason } else { 494eb60ceacSChris Mason tree_block_release(root, t); 495be0e5c09SChris Mason path->slots[0] -= push_items; 496be0e5c09SChris Mason } 497eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 498be0e5c09SChris Mason return 0; 499be0e5c09SChris Mason } 500be0e5c09SChris Mason 501be0e5c09SChris Mason int split_leaf(struct ctree_root *root, struct ctree_path *path, int data_size) 502be0e5c09SChris Mason { 503eb60ceacSChris Mason struct tree_buffer *l_buf = path->nodes[0]; 504eb60ceacSChris Mason struct leaf *l = &l_buf->leaf; 505eb60ceacSChris Mason int nritems; 506eb60ceacSChris Mason int mid; 507eb60ceacSChris Mason int slot; 508be0e5c09SChris Mason struct leaf *right; 509eb60ceacSChris Mason struct tree_buffer *right_buffer; 510be0e5c09SChris Mason int space_needed = data_size + sizeof(struct item); 511be0e5c09SChris Mason int data_copy_size; 512be0e5c09SChris Mason int rt_data_off; 513be0e5c09SChris Mason int i; 514be0e5c09SChris Mason int ret; 515be0e5c09SChris Mason 516be0e5c09SChris Mason if (push_leaf_left(root, path, data_size) == 0) { 517eb60ceacSChris Mason l_buf = path->nodes[0]; 518eb60ceacSChris Mason l = &l_buf->leaf; 519eb60ceacSChris Mason if (leaf_free_space(l) >= sizeof(struct item) + data_size) 520be0e5c09SChris Mason return 0; 521be0e5c09SChris Mason } 522eb60ceacSChris Mason slot = path->slots[0]; 523eb60ceacSChris Mason nritems = l->header.nritems; 524eb60ceacSChris Mason mid = (nritems + 1)/ 2; 525eb60ceacSChris Mason 526eb60ceacSChris Mason right_buffer = alloc_free_block(root); 527eb60ceacSChris Mason BUG_ON(!right_buffer); 528eb60ceacSChris Mason BUG_ON(mid == nritems); 529eb60ceacSChris Mason right = &right_buffer->leaf; 530be0e5c09SChris Mason memset(right, 0, sizeof(*right)); 531be0e5c09SChris Mason if (mid <= slot) { 532be0e5c09SChris Mason if (leaf_space_used(l, mid, nritems - mid) + space_needed > 533be0e5c09SChris Mason LEAF_DATA_SIZE) 534be0e5c09SChris Mason BUG(); 535be0e5c09SChris Mason } else { 536be0e5c09SChris Mason if (leaf_space_used(l, 0, mid + 1) + space_needed > 537be0e5c09SChris Mason LEAF_DATA_SIZE) 538be0e5c09SChris Mason BUG(); 539be0e5c09SChris Mason } 540be0e5c09SChris Mason right->header.nritems = nritems - mid; 541eb60ceacSChris Mason right->header.blocknr = right_buffer->blocknr; 542eb60ceacSChris Mason right->header.flags = node_level(0); 543be0e5c09SChris Mason data_copy_size = l->items[mid].offset + l->items[mid].size - 544be0e5c09SChris Mason leaf_data_end(l); 545be0e5c09SChris Mason memcpy(right->items, l->items + mid, 546be0e5c09SChris Mason (nritems - mid) * sizeof(struct item)); 547be0e5c09SChris Mason memcpy(right->data + LEAF_DATA_SIZE - data_copy_size, 548be0e5c09SChris Mason l->data + leaf_data_end(l), data_copy_size); 549be0e5c09SChris Mason rt_data_off = LEAF_DATA_SIZE - 550be0e5c09SChris Mason (l->items[mid].offset + l->items[mid].size); 551be0e5c09SChris Mason for (i = 0; i < right->header.nritems; i++) { 552be0e5c09SChris Mason right->items[i].offset += rt_data_off; 553be0e5c09SChris Mason } 554be0e5c09SChris Mason l->header.nritems = mid; 555be0e5c09SChris Mason ret = insert_ptr(root, path, &right->items[0].key, 556eb60ceacSChris Mason right_buffer->blocknr, 1); 557eb60ceacSChris Mason 558eb60ceacSChris Mason write_tree_block(root, right_buffer); 559eb60ceacSChris Mason write_tree_block(root, l_buf); 560eb60ceacSChris Mason 561eb60ceacSChris Mason BUG_ON(path->slots[0] != slot); 562be0e5c09SChris Mason if (mid <= slot) { 563eb60ceacSChris Mason tree_block_release(root, path->nodes[0]); 564eb60ceacSChris Mason path->nodes[0] = right_buffer; 565be0e5c09SChris Mason path->slots[0] -= mid; 566be0e5c09SChris Mason path->slots[1] += 1; 567eb60ceacSChris Mason } else 568eb60ceacSChris Mason tree_block_release(root, right_buffer); 569eb60ceacSChris Mason BUG_ON(path->slots[0] < 0); 570be0e5c09SChris Mason return ret; 571be0e5c09SChris Mason } 572be0e5c09SChris Mason 573be0e5c09SChris Mason int insert_item(struct ctree_root *root, struct key *key, 574be0e5c09SChris Mason void *data, int data_size) 575be0e5c09SChris Mason { 576be0e5c09SChris Mason int ret; 577be0e5c09SChris Mason int slot; 578eb60ceacSChris Mason int slot_orig; 579be0e5c09SChris Mason struct leaf *leaf; 580eb60ceacSChris Mason struct tree_buffer *leaf_buf; 581be0e5c09SChris Mason unsigned int nritems; 582be0e5c09SChris Mason unsigned int data_end; 583be0e5c09SChris Mason struct ctree_path path; 584be0e5c09SChris Mason 585eb60ceacSChris Mason if (!root->node) { 586eb60ceacSChris Mason struct tree_buffer *t; 587eb60ceacSChris Mason t = alloc_free_block(root); 588eb60ceacSChris Mason BUG_ON(!t); 589eb60ceacSChris Mason t->node.header.nritems = 0; 590eb60ceacSChris Mason t->node.header.flags = node_level(0); 591eb60ceacSChris Mason t->node.header.blocknr = t->blocknr; 592eb60ceacSChris Mason root->node = t; 593eb60ceacSChris Mason write_tree_block(root, t); 594eb60ceacSChris Mason } 595be0e5c09SChris Mason init_path(&path); 596be0e5c09SChris Mason ret = search_slot(root, key, &path); 597eb60ceacSChris Mason if (ret == 0) { 598eb60ceacSChris Mason release_path(root, &path); 599be0e5c09SChris Mason return -EEXIST; 600eb60ceacSChris Mason } 601be0e5c09SChris Mason 602eb60ceacSChris Mason slot_orig = path.slots[0]; 603eb60ceacSChris Mason leaf_buf = path.nodes[0]; 604eb60ceacSChris Mason leaf = &leaf_buf->leaf; 605eb60ceacSChris Mason if (leaf_free_space(leaf) < sizeof(struct item) + data_size) { 606be0e5c09SChris Mason split_leaf(root, &path, data_size); 607eb60ceacSChris Mason leaf_buf = path.nodes[0]; 608eb60ceacSChris Mason leaf = &path.nodes[0]->leaf; 609eb60ceacSChris Mason } 610be0e5c09SChris Mason nritems = leaf->header.nritems; 611be0e5c09SChris Mason data_end = leaf_data_end(leaf); 612eb60ceacSChris Mason 613be0e5c09SChris Mason if (leaf_free_space(leaf) < sizeof(struct item) + data_size) 614be0e5c09SChris Mason BUG(); 615be0e5c09SChris Mason 616be0e5c09SChris Mason slot = path.slots[0]; 617eb60ceacSChris Mason BUG_ON(slot < 0); 618be0e5c09SChris Mason if (slot == 0) 619eb60ceacSChris Mason fixup_low_keys(root, &path, key, 1); 620be0e5c09SChris Mason if (slot != nritems) { 621be0e5c09SChris Mason int i; 622be0e5c09SChris Mason unsigned int old_data = leaf->items[slot].offset + 623be0e5c09SChris Mason leaf->items[slot].size; 624be0e5c09SChris Mason 625be0e5c09SChris Mason /* 626be0e5c09SChris Mason * item0..itemN ... dataN.offset..dataN.size .. data0.size 627be0e5c09SChris Mason */ 628be0e5c09SChris Mason /* first correct the data pointers */ 629be0e5c09SChris Mason for (i = slot; i < nritems; i++) 630be0e5c09SChris Mason leaf->items[i].offset -= data_size; 631be0e5c09SChris Mason 632be0e5c09SChris Mason /* shift the items */ 633be0e5c09SChris Mason memmove(leaf->items + slot + 1, leaf->items + slot, 634be0e5c09SChris Mason (nritems - slot) * sizeof(struct item)); 635be0e5c09SChris Mason 636be0e5c09SChris Mason /* shift the data */ 637be0e5c09SChris Mason memmove(leaf->data + data_end - data_size, leaf->data + 638be0e5c09SChris Mason data_end, old_data - data_end); 639be0e5c09SChris Mason data_end = old_data; 640be0e5c09SChris Mason } 641be0e5c09SChris Mason memcpy(&leaf->items[slot].key, key, sizeof(struct key)); 642be0e5c09SChris Mason leaf->items[slot].offset = data_end - data_size; 643be0e5c09SChris Mason leaf->items[slot].size = data_size; 644be0e5c09SChris Mason memcpy(leaf->data + data_end - data_size, data, data_size); 645be0e5c09SChris Mason leaf->header.nritems += 1; 646eb60ceacSChris Mason write_tree_block(root, leaf_buf); 647be0e5c09SChris Mason if (leaf_free_space(leaf) < 0) 648be0e5c09SChris Mason BUG(); 649eb60ceacSChris Mason release_path(root, &path); 650be0e5c09SChris Mason return 0; 651be0e5c09SChris Mason } 652be0e5c09SChris Mason 653be0e5c09SChris Mason int del_ptr(struct ctree_root *root, struct ctree_path *path, int level) 654be0e5c09SChris Mason { 655be0e5c09SChris Mason int slot; 656eb60ceacSChris Mason struct tree_buffer *t; 657be0e5c09SChris Mason struct node *node; 658be0e5c09SChris Mason int nritems; 659be0e5c09SChris Mason 660be0e5c09SChris Mason while(1) { 661eb60ceacSChris Mason t = path->nodes[level]; 662eb60ceacSChris Mason if (!t) 663be0e5c09SChris Mason break; 664eb60ceacSChris Mason node = &t->node; 665be0e5c09SChris Mason slot = path->slots[level]; 666be0e5c09SChris Mason nritems = node->header.nritems; 667be0e5c09SChris Mason 668be0e5c09SChris Mason if (slot != nritems -1) { 669be0e5c09SChris Mason memmove(node->keys + slot, node->keys + slot + 1, 670be0e5c09SChris Mason sizeof(struct key) * (nritems - slot - 1)); 671be0e5c09SChris Mason memmove(node->blockptrs + slot, 672be0e5c09SChris Mason node->blockptrs + slot + 1, 673be0e5c09SChris Mason sizeof(u64) * (nritems - slot - 1)); 674be0e5c09SChris Mason } 675be0e5c09SChris Mason node->header.nritems--; 676eb60ceacSChris Mason write_tree_block(root, t); 677be0e5c09SChris Mason if (node->header.nritems != 0) { 678be0e5c09SChris Mason int tslot; 679be0e5c09SChris Mason if (slot == 0) 680eb60ceacSChris Mason fixup_low_keys(root, path, node->keys, 681eb60ceacSChris Mason level + 1); 682be0e5c09SChris Mason tslot = path->slots[level+1]; 683eb60ceacSChris Mason t->count++; 684be0e5c09SChris Mason push_node_left(root, path, level); 685be0e5c09SChris Mason if (node->header.nritems) { 686be0e5c09SChris Mason push_node_right(root, path, level); 687be0e5c09SChris Mason } 688eb60ceacSChris Mason if (node->header.nritems) { 689eb60ceacSChris Mason tree_block_release(root, t); 690be0e5c09SChris Mason break; 691eb60ceacSChris Mason } 692eb60ceacSChris Mason tree_block_release(root, t); 6934920c9acSChris Mason path->slots[level+1] = tslot; 694be0e5c09SChris Mason } 695eb60ceacSChris Mason if (t == root->node) { 696eb60ceacSChris Mason /* just turn the root into a leaf and break */ 697eb60ceacSChris Mason root->node->node.header.flags = node_level(0); 698eb60ceacSChris Mason write_tree_block(root, t); 699be0e5c09SChris Mason break; 700be0e5c09SChris Mason } 701be0e5c09SChris Mason level++; 702be0e5c09SChris Mason if (!path->nodes[level]) 703be0e5c09SChris Mason BUG(); 704be0e5c09SChris Mason } 705be0e5c09SChris Mason return 0; 706be0e5c09SChris Mason } 707be0e5c09SChris Mason 7084920c9acSChris Mason int del_item(struct ctree_root *root, struct ctree_path *path) 709be0e5c09SChris Mason { 710be0e5c09SChris Mason int slot; 711be0e5c09SChris Mason struct leaf *leaf; 712eb60ceacSChris Mason struct tree_buffer *leaf_buf; 713be0e5c09SChris Mason int doff; 714be0e5c09SChris Mason int dsize; 715be0e5c09SChris Mason 716eb60ceacSChris Mason leaf_buf = path->nodes[0]; 717eb60ceacSChris Mason leaf = &leaf_buf->leaf; 7184920c9acSChris Mason slot = path->slots[0]; 719be0e5c09SChris Mason doff = leaf->items[slot].offset; 720be0e5c09SChris Mason dsize = leaf->items[slot].size; 721be0e5c09SChris Mason 722be0e5c09SChris Mason if (slot != leaf->header.nritems - 1) { 723be0e5c09SChris Mason int i; 724be0e5c09SChris Mason int data_end = leaf_data_end(leaf); 725be0e5c09SChris Mason memmove(leaf->data + data_end + dsize, 726be0e5c09SChris Mason leaf->data + data_end, 727be0e5c09SChris Mason doff - data_end); 728be0e5c09SChris Mason for (i = slot + 1; i < leaf->header.nritems; i++) 729be0e5c09SChris Mason leaf->items[i].offset += dsize; 730be0e5c09SChris Mason memmove(leaf->items + slot, leaf->items + slot + 1, 731be0e5c09SChris Mason sizeof(struct item) * 732be0e5c09SChris Mason (leaf->header.nritems - slot - 1)); 733be0e5c09SChris Mason } 734be0e5c09SChris Mason leaf->header.nritems -= 1; 735be0e5c09SChris Mason if (leaf->header.nritems == 0) { 736eb60ceacSChris Mason if (leaf_buf == root->node) { 737eb60ceacSChris Mason leaf->header.flags = node_level(0); 738eb60ceacSChris Mason write_tree_block(root, leaf_buf); 739eb60ceacSChris Mason } else 7404920c9acSChris Mason del_ptr(root, path, 1); 741be0e5c09SChris Mason } else { 742be0e5c09SChris Mason if (slot == 0) 743eb60ceacSChris Mason fixup_low_keys(root, path, &leaf->items[0].key, 1); 744eb60ceacSChris Mason write_tree_block(root, leaf_buf); 745be0e5c09SChris Mason if (leaf_space_used(leaf, 0, leaf->header.nritems) < 746be0e5c09SChris Mason LEAF_DATA_SIZE / 4) { 747be0e5c09SChris Mason /* push_leaf_left fixes the path. 748be0e5c09SChris Mason * make sure the path still points to our leaf 749be0e5c09SChris Mason * for possible call to del_ptr below 750be0e5c09SChris Mason */ 7514920c9acSChris Mason slot = path->slots[1]; 752eb60ceacSChris Mason leaf_buf->count++; 7534920c9acSChris Mason push_leaf_left(root, path, 1); 754be0e5c09SChris Mason if (leaf->header.nritems == 0) { 7554920c9acSChris Mason path->slots[1] = slot; 7564920c9acSChris Mason del_ptr(root, path, 1); 757be0e5c09SChris Mason } 758eb60ceacSChris Mason tree_block_release(root, leaf_buf); 759be0e5c09SChris Mason } 760be0e5c09SChris Mason } 761be0e5c09SChris Mason return 0; 762be0e5c09SChris Mason } 763be0e5c09SChris Mason 764be0e5c09SChris Mason void print_leaf(struct leaf *l) 765be0e5c09SChris Mason { 766be0e5c09SChris Mason int i; 767be0e5c09SChris Mason int nr = l->header.nritems; 768be0e5c09SChris Mason struct item *item; 769eb60ceacSChris Mason printf("leaf %lu total ptrs %d free space %d\n", l->header.blocknr, nr, 770be0e5c09SChris Mason leaf_free_space(l)); 771be0e5c09SChris Mason fflush(stdout); 772be0e5c09SChris Mason for (i = 0 ; i < nr ; i++) { 773be0e5c09SChris Mason item = l->items + i; 774be0e5c09SChris Mason printf("\titem %d key (%lu %u %lu) itemoff %d itemsize %d\n", 775be0e5c09SChris Mason i, 776be0e5c09SChris Mason item->key.objectid, item->key.flags, item->key.offset, 777be0e5c09SChris Mason item->offset, item->size); 778be0e5c09SChris Mason fflush(stdout); 779be0e5c09SChris Mason printf("\t\titem data %.*s\n", item->size, l->data+item->offset); 780be0e5c09SChris Mason fflush(stdout); 781be0e5c09SChris Mason } 782be0e5c09SChris Mason } 783eb60ceacSChris Mason void print_tree(struct ctree_root *root, struct tree_buffer *t) 784be0e5c09SChris Mason { 785be0e5c09SChris Mason int i; 786be0e5c09SChris Mason int nr; 787eb60ceacSChris Mason struct node *c; 788be0e5c09SChris Mason 789eb60ceacSChris Mason if (!t) 790be0e5c09SChris Mason return; 791eb60ceacSChris Mason c = &t->node; 792be0e5c09SChris Mason nr = c->header.nritems; 793eb60ceacSChris Mason if (c->header.blocknr != t->blocknr) 794eb60ceacSChris Mason BUG(); 795be0e5c09SChris Mason if (is_leaf(c->header.flags)) { 796be0e5c09SChris Mason print_leaf((struct leaf *)c); 797be0e5c09SChris Mason return; 798be0e5c09SChris Mason } 799eb60ceacSChris Mason printf("node %lu level %d total ptrs %d free spc %lu\n", t->blocknr, 800be0e5c09SChris Mason node_level(c->header.flags), c->header.nritems, 801be0e5c09SChris Mason NODEPTRS_PER_BLOCK - c->header.nritems); 802be0e5c09SChris Mason fflush(stdout); 803be0e5c09SChris Mason for (i = 0; i < nr; i++) { 804eb60ceacSChris Mason printf("\tkey %d (%lu %u %lu) block %lu\n", 805be0e5c09SChris Mason i, 806be0e5c09SChris Mason c->keys[i].objectid, c->keys[i].flags, c->keys[i].offset, 807be0e5c09SChris Mason c->blockptrs[i]); 808be0e5c09SChris Mason fflush(stdout); 809be0e5c09SChris Mason } 810be0e5c09SChris Mason for (i = 0; i < nr; i++) { 811eb60ceacSChris Mason struct tree_buffer *next_buf = read_tree_block(root, 812eb60ceacSChris Mason c->blockptrs[i]); 813eb60ceacSChris Mason struct node *next = &next_buf->node; 814be0e5c09SChris Mason if (is_leaf(next->header.flags) && 815be0e5c09SChris Mason node_level(c->header.flags) != 1) 816be0e5c09SChris Mason BUG(); 817be0e5c09SChris Mason if (node_level(next->header.flags) != 818be0e5c09SChris Mason node_level(c->header.flags) - 1) 819be0e5c09SChris Mason BUG(); 820eb60ceacSChris Mason print_tree(root, next_buf); 821eb60ceacSChris Mason tree_block_release(root, next_buf); 822be0e5c09SChris Mason } 823be0e5c09SChris Mason 824be0e5c09SChris Mason } 825be0e5c09SChris Mason 826be0e5c09SChris Mason /* for testing only */ 827be0e5c09SChris Mason int next_key(int i, int max_key) { 828be0e5c09SChris Mason return rand() % max_key; 829be0e5c09SChris Mason // return i; 830be0e5c09SChris Mason } 831be0e5c09SChris Mason 832be0e5c09SChris Mason int main() { 833eb60ceacSChris Mason struct ctree_root *root; 834be0e5c09SChris Mason struct key ins; 8354920c9acSChris Mason struct key last = { (u64)-1, 0, 0}; 836be0e5c09SChris Mason char *buf; 837be0e5c09SChris Mason int i; 838be0e5c09SChris Mason int num; 839be0e5c09SChris Mason int ret; 840eb60ceacSChris Mason int run_size = 1000000; 841be0e5c09SChris Mason int max_key = 100000000; 842be0e5c09SChris Mason int tree_size = 0; 843be0e5c09SChris Mason struct ctree_path path; 844be0e5c09SChris Mason 845eb60ceacSChris Mason radix_tree_init(); 846eb60ceacSChris Mason 847eb60ceacSChris Mason 848eb60ceacSChris Mason root = open_ctree("dbfile"); 849be0e5c09SChris Mason 850be0e5c09SChris Mason srand(55); 851be0e5c09SChris Mason for (i = 0; i < run_size; i++) { 852be0e5c09SChris Mason buf = malloc(64); 853be0e5c09SChris Mason num = next_key(i, max_key); 854be0e5c09SChris Mason // num = i; 855be0e5c09SChris Mason sprintf(buf, "string-%d", num); 856be0e5c09SChris Mason // printf("insert %d\n", num); 857be0e5c09SChris Mason ins.objectid = num; 858be0e5c09SChris Mason ins.offset = 0; 859be0e5c09SChris Mason ins.flags = 0; 860eb60ceacSChris Mason ret = insert_item(root, &ins, buf, strlen(buf)); 861be0e5c09SChris Mason if (!ret) 862be0e5c09SChris Mason tree_size++; 863be0e5c09SChris Mason } 864eb60ceacSChris Mason close_ctree(root); 865eb60ceacSChris Mason root = open_ctree("dbfile"); 866eb60ceacSChris Mason printf("starting search\n"); 867be0e5c09SChris Mason srand(55); 868be0e5c09SChris Mason for (i = 0; i < run_size; i++) { 869be0e5c09SChris Mason num = next_key(i, max_key); 870be0e5c09SChris Mason ins.objectid = num; 871be0e5c09SChris Mason init_path(&path); 872eb60ceacSChris Mason ret = search_slot(root, &ins, &path); 873be0e5c09SChris Mason if (ret) { 874eb60ceacSChris Mason print_tree(root, root->node); 875be0e5c09SChris Mason printf("unable to find %d\n", num); 876be0e5c09SChris Mason exit(1); 877be0e5c09SChris Mason } 878eb60ceacSChris Mason release_path(root, &path); 879be0e5c09SChris Mason } 880eb60ceacSChris Mason close_ctree(root); 881eb60ceacSChris Mason root = open_ctree("dbfile"); 882eb60ceacSChris Mason printf("node %p level %d total ptrs %d free spc %lu\n", root->node, 883eb60ceacSChris Mason node_level(root->node->node.header.flags), 884eb60ceacSChris Mason root->node->node.header.nritems, 885eb60ceacSChris Mason NODEPTRS_PER_BLOCK - root->node->node.header.nritems); 886eb60ceacSChris Mason printf("all searches good, deleting some items\n"); 887be0e5c09SChris Mason i = 0; 888be0e5c09SChris Mason srand(55); 8894920c9acSChris Mason for (i = 0 ; i < run_size/4; i++) { 890be0e5c09SChris Mason num = next_key(i, max_key); 891be0e5c09SChris Mason ins.objectid = num; 8924920c9acSChris Mason init_path(&path); 893eb60ceacSChris Mason ret = search_slot(root, &ins, &path); 8944920c9acSChris Mason if (ret) 8954920c9acSChris Mason continue; 896eb60ceacSChris Mason ret = del_item(root, &path); 8974920c9acSChris Mason if (ret != 0) 8984920c9acSChris Mason BUG(); 899eb60ceacSChris Mason release_path(root, &path); 9004920c9acSChris Mason tree_size--; 9014920c9acSChris Mason } 9024920c9acSChris Mason srand(128); 9034920c9acSChris Mason for (i = 0; i < run_size; i++) { 9044920c9acSChris Mason buf = malloc(64); 9054920c9acSChris Mason num = next_key(i, max_key); 9064920c9acSChris Mason sprintf(buf, "string-%d", num); 9074920c9acSChris Mason ins.objectid = num; 908eb60ceacSChris Mason ret = insert_item(root, &ins, buf, strlen(buf)); 9094920c9acSChris Mason if (!ret) 9104920c9acSChris Mason tree_size++; 9114920c9acSChris Mason } 912eb60ceacSChris Mason close_ctree(root); 913eb60ceacSChris Mason root = open_ctree("dbfile"); 914eb60ceacSChris Mason printf("starting search2\n"); 915eb60ceacSChris Mason srand(128); 916eb60ceacSChris Mason for (i = 0; i < run_size; i++) { 917eb60ceacSChris Mason num = next_key(i, max_key); 918eb60ceacSChris Mason ins.objectid = num; 919eb60ceacSChris Mason init_path(&path); 920eb60ceacSChris Mason ret = search_slot(root, &ins, &path); 921eb60ceacSChris Mason if (ret) { 922eb60ceacSChris Mason print_tree(root, root->node); 923eb60ceacSChris Mason printf("unable to find %d\n", num); 924eb60ceacSChris Mason exit(1); 925eb60ceacSChris Mason } 926eb60ceacSChris Mason release_path(root, &path); 927eb60ceacSChris Mason } 928eb60ceacSChris Mason printf("starting big long delete run\n"); 929eb60ceacSChris Mason while(root->node && root->node->node.header.nritems > 0) { 9304920c9acSChris Mason struct leaf *leaf; 9314920c9acSChris Mason int slot; 9324920c9acSChris Mason ins.objectid = (u64)-1; 9334920c9acSChris Mason init_path(&path); 934eb60ceacSChris Mason ret = search_slot(root, &ins, &path); 9354920c9acSChris Mason if (ret == 0) 9364920c9acSChris Mason BUG(); 9374920c9acSChris Mason 938eb60ceacSChris Mason leaf = &path.nodes[0]->leaf; 9394920c9acSChris Mason slot = path.slots[0]; 9404920c9acSChris Mason if (slot != leaf->header.nritems) 9414920c9acSChris Mason BUG(); 9424920c9acSChris Mason while(path.slots[0] > 0) { 9434920c9acSChris Mason path.slots[0] -= 1; 9444920c9acSChris Mason slot = path.slots[0]; 945eb60ceacSChris Mason leaf = &path.nodes[0]->leaf; 9464920c9acSChris Mason 9474920c9acSChris Mason if (comp_keys(&last, &leaf->items[slot].key) <= 0) 9484920c9acSChris Mason BUG(); 9494920c9acSChris Mason memcpy(&last, &leaf->items[slot].key, sizeof(last)); 950eb60ceacSChris Mason ret = del_item(root, &path); 951eb60ceacSChris Mason if (ret != 0) { 952eb60ceacSChris Mason printf("del_item returned %d\n", ret); 9534920c9acSChris Mason BUG(); 954eb60ceacSChris Mason } 9554920c9acSChris Mason tree_size--; 9564920c9acSChris Mason } 957eb60ceacSChris Mason release_path(root, &path); 958be0e5c09SChris Mason } 959eb60ceacSChris Mason close_ctree(root); 9604920c9acSChris Mason printf("tree size is now %d\n", tree_size); 961be0e5c09SChris Mason return 0; 962be0e5c09SChris Mason } 963