xref: /openbmc/linux/fs/btrfs/ctree.c (revision 79f95c82dca7665f32bafd68b7cdf4a01fab0840)
1be0e5c09SChris Mason #include <stdio.h>
2be0e5c09SChris Mason #include <stdlib.h>
3be0e5c09SChris Mason #include "kerncompat.h"
4eb60ceacSChris Mason #include "radix-tree.h"
5eb60ceacSChris Mason #include "ctree.h"
6eb60ceacSChris Mason #include "disk-io.h"
75de08d7dSChris Mason #include "print-tree.h"
89a8dd150SChris Mason 
9aa5d6bedSChris Mason static int split_node(struct ctree_root *root, struct ctree_path *path,
10aa5d6bedSChris Mason 		      int level);
11aa5d6bedSChris Mason static int split_leaf(struct ctree_root *root, struct ctree_path *path,
12aa5d6bedSChris Mason 		      int data_size);
13bb803951SChris Mason static int push_node_left(struct ctree_root *root, struct tree_buffer *dst,
14bb803951SChris Mason 			  struct tree_buffer *src);
1579f95c82SChris Mason static int balance_node_right(struct ctree_root *root,
1679f95c82SChris Mason 			      struct tree_buffer *dst_buf,
1779f95c82SChris Mason 			      struct tree_buffer *src_buf);
18bb803951SChris Mason static int del_ptr(struct ctree_root *root, struct ctree_path *path, int level,
19bb803951SChris Mason 		   int slot);
20d97e63b6SChris Mason 
215de08d7dSChris Mason inline void init_path(struct ctree_path *p)
22be0e5c09SChris Mason {
23be0e5c09SChris Mason 	memset(p, 0, sizeof(*p));
24be0e5c09SChris Mason }
25be0e5c09SChris Mason 
265de08d7dSChris Mason void release_path(struct ctree_root *root, struct ctree_path *p)
27eb60ceacSChris Mason {
28eb60ceacSChris Mason 	int i;
29eb60ceacSChris Mason 	for (i = 0; i < MAX_LEVEL; i++) {
30eb60ceacSChris Mason 		if (!p->nodes[i])
31eb60ceacSChris Mason 			break;
32eb60ceacSChris Mason 		tree_block_release(root, p->nodes[i]);
33eb60ceacSChris Mason 	}
34aa5d6bedSChris Mason 	memset(p, 0, sizeof(*p));
35eb60ceacSChris Mason }
36eb60ceacSChris Mason 
3774123bd7SChris Mason /*
3874123bd7SChris Mason  * The leaf data grows from end-to-front in the node.
3974123bd7SChris Mason  * this returns the address of the start of the last item,
4074123bd7SChris Mason  * which is the stop of the leaf data stack
4174123bd7SChris Mason  */
42be0e5c09SChris Mason static inline unsigned int leaf_data_end(struct leaf *leaf)
43be0e5c09SChris Mason {
44be0e5c09SChris Mason 	unsigned int nr = leaf->header.nritems;
45be0e5c09SChris Mason 	if (nr == 0)
46d97e63b6SChris Mason 		return sizeof(leaf->data);
47be0e5c09SChris Mason 	return leaf->items[nr-1].offset;
48be0e5c09SChris Mason }
49be0e5c09SChris Mason 
5074123bd7SChris Mason /*
5174123bd7SChris Mason  * The space between the end of the leaf items and
5274123bd7SChris Mason  * the start of the leaf data.  IOW, how much room
5374123bd7SChris Mason  * the leaf has left for both items and data
5474123bd7SChris Mason  */
555de08d7dSChris Mason int leaf_free_space(struct leaf *leaf)
56be0e5c09SChris Mason {
57be0e5c09SChris Mason 	int data_end = leaf_data_end(leaf);
58be0e5c09SChris Mason 	int nritems = leaf->header.nritems;
59be0e5c09SChris Mason 	char *items_end = (char *)(leaf->items + nritems + 1);
60be0e5c09SChris Mason 	return (char *)(leaf->data + data_end) - (char *)items_end;
61be0e5c09SChris Mason }
62be0e5c09SChris Mason 
6374123bd7SChris Mason /*
6474123bd7SChris Mason  * compare two keys in a memcmp fashion
6574123bd7SChris Mason  */
66be0e5c09SChris Mason int comp_keys(struct key *k1, struct key *k2)
67be0e5c09SChris Mason {
68be0e5c09SChris Mason 	if (k1->objectid > k2->objectid)
69be0e5c09SChris Mason 		return 1;
70be0e5c09SChris Mason 	if (k1->objectid < k2->objectid)
71be0e5c09SChris Mason 		return -1;
72be0e5c09SChris Mason 	if (k1->flags > k2->flags)
73be0e5c09SChris Mason 		return 1;
74be0e5c09SChris Mason 	if (k1->flags < k2->flags)
75be0e5c09SChris Mason 		return -1;
76be0e5c09SChris Mason 	if (k1->offset > k2->offset)
77be0e5c09SChris Mason 		return 1;
78be0e5c09SChris Mason 	if (k1->offset < k2->offset)
79be0e5c09SChris Mason 		return -1;
80be0e5c09SChris Mason 	return 0;
81be0e5c09SChris Mason }
8274123bd7SChris Mason 
83aa5d6bedSChris Mason int check_node(struct ctree_path *path, int level)
84aa5d6bedSChris Mason {
85aa5d6bedSChris Mason 	int i;
86aa5d6bedSChris Mason 	struct node *parent = NULL;
87aa5d6bedSChris Mason 	struct node *node = &path->nodes[level]->node;
88aa5d6bedSChris Mason 	int parent_slot;
89aa5d6bedSChris Mason 
90aa5d6bedSChris Mason 	if (path->nodes[level + 1])
91aa5d6bedSChris Mason 		parent = &path->nodes[level + 1]->node;
92aa5d6bedSChris Mason 	parent_slot = path->slots[level + 1];
93aa5d6bedSChris Mason 	if (parent && node->header.nritems > 0) {
94aa5d6bedSChris Mason 		struct key *parent_key;
95aa5d6bedSChris Mason 		parent_key = &parent->keys[parent_slot];
96aa5d6bedSChris Mason 		BUG_ON(memcmp(parent_key, node->keys, sizeof(struct key)));
97aa5d6bedSChris Mason 		BUG_ON(parent->blockptrs[parent_slot] != node->header.blocknr);
98aa5d6bedSChris Mason 	}
99aa5d6bedSChris Mason 	BUG_ON(node->header.nritems > NODEPTRS_PER_BLOCK);
100aa5d6bedSChris Mason 	for (i = 0; i < node->header.nritems - 2; i++) {
101aa5d6bedSChris Mason 		BUG_ON(comp_keys(&node->keys[i], &node->keys[i+1]) >= 0);
102aa5d6bedSChris Mason 	}
103aa5d6bedSChris Mason 	return 0;
104aa5d6bedSChris Mason }
105aa5d6bedSChris Mason 
106aa5d6bedSChris Mason int check_leaf(struct ctree_path *path, int level)
107aa5d6bedSChris Mason {
108aa5d6bedSChris Mason 	int i;
109aa5d6bedSChris Mason 	struct leaf *leaf = &path->nodes[level]->leaf;
110aa5d6bedSChris Mason 	struct node *parent = NULL;
111aa5d6bedSChris Mason 	int parent_slot;
112aa5d6bedSChris Mason 
113aa5d6bedSChris Mason 	if (path->nodes[level + 1])
114aa5d6bedSChris Mason 		parent = &path->nodes[level + 1]->node;
115aa5d6bedSChris Mason 	parent_slot = path->slots[level + 1];
116aa5d6bedSChris Mason 	if (parent && leaf->header.nritems > 0) {
117aa5d6bedSChris Mason 		struct key *parent_key;
118aa5d6bedSChris Mason 		parent_key = &parent->keys[parent_slot];
119aa5d6bedSChris Mason 		BUG_ON(memcmp(parent_key, &leaf->items[0].key,
120aa5d6bedSChris Mason 		       sizeof(struct key)));
121aa5d6bedSChris Mason 		BUG_ON(parent->blockptrs[parent_slot] != leaf->header.blocknr);
122aa5d6bedSChris Mason 	}
123aa5d6bedSChris Mason 	for (i = 0; i < leaf->header.nritems - 2; i++) {
124aa5d6bedSChris Mason 		BUG_ON(comp_keys(&leaf->items[i].key,
125aa5d6bedSChris Mason 		                 &leaf->items[i+1].key) >= 0);
126aa5d6bedSChris Mason 		BUG_ON(leaf->items[i].offset != leaf->items[i + 1].offset +
127aa5d6bedSChris Mason 		    leaf->items[i + 1].size);
128aa5d6bedSChris Mason 		if (i == 0) {
129aa5d6bedSChris Mason 			BUG_ON(leaf->items[i].offset + leaf->items[i].size !=
130aa5d6bedSChris Mason 				LEAF_DATA_SIZE);
131aa5d6bedSChris Mason 		}
132aa5d6bedSChris Mason 	}
133aa5d6bedSChris Mason 	BUG_ON(leaf_free_space(leaf) < 0);
134aa5d6bedSChris Mason 	return 0;
135aa5d6bedSChris Mason }
136aa5d6bedSChris Mason 
137aa5d6bedSChris Mason int check_block(struct ctree_path *path, int level)
138aa5d6bedSChris Mason {
139aa5d6bedSChris Mason 	if (level == 0)
140aa5d6bedSChris Mason 		return check_leaf(path, level);
141aa5d6bedSChris Mason 	return check_node(path, level);
142aa5d6bedSChris Mason }
143aa5d6bedSChris Mason 
14474123bd7SChris Mason /*
14574123bd7SChris Mason  * search for key in the array p.  items p are item_size apart
14674123bd7SChris Mason  * and there are 'max' items in p
14774123bd7SChris Mason  * the slot in the array is returned via slot, and it points to
14874123bd7SChris Mason  * the place where you would insert key if it is not found in
14974123bd7SChris Mason  * the array.
15074123bd7SChris Mason  *
15174123bd7SChris Mason  * slot may point to max if the key is bigger than all of the keys
15274123bd7SChris Mason  */
153be0e5c09SChris Mason int generic_bin_search(char *p, int item_size, struct key *key,
154be0e5c09SChris Mason 		       int max, int *slot)
155be0e5c09SChris Mason {
156be0e5c09SChris Mason 	int low = 0;
157be0e5c09SChris Mason 	int high = max;
158be0e5c09SChris Mason 	int mid;
159be0e5c09SChris Mason 	int ret;
160be0e5c09SChris Mason 	struct key *tmp;
161be0e5c09SChris Mason 
162be0e5c09SChris Mason 	while(low < high) {
163be0e5c09SChris Mason 		mid = (low + high) / 2;
164be0e5c09SChris Mason 		tmp = (struct key *)(p + mid * item_size);
165be0e5c09SChris Mason 		ret = comp_keys(tmp, key);
166be0e5c09SChris Mason 
167be0e5c09SChris Mason 		if (ret < 0)
168be0e5c09SChris Mason 			low = mid + 1;
169be0e5c09SChris Mason 		else if (ret > 0)
170be0e5c09SChris Mason 			high = mid;
171be0e5c09SChris Mason 		else {
172be0e5c09SChris Mason 			*slot = mid;
173be0e5c09SChris Mason 			return 0;
174be0e5c09SChris Mason 		}
175be0e5c09SChris Mason 	}
176be0e5c09SChris Mason 	*slot = low;
177be0e5c09SChris Mason 	return 1;
178be0e5c09SChris Mason }
179be0e5c09SChris Mason 
18097571fd0SChris Mason /*
18197571fd0SChris Mason  * simple bin_search frontend that does the right thing for
18297571fd0SChris Mason  * leaves vs nodes
18397571fd0SChris Mason  */
184be0e5c09SChris Mason int bin_search(struct node *c, struct key *key, int *slot)
185be0e5c09SChris Mason {
186be0e5c09SChris Mason 	if (is_leaf(c->header.flags)) {
187be0e5c09SChris Mason 		struct leaf *l = (struct leaf *)c;
188be0e5c09SChris Mason 		return generic_bin_search((void *)l->items, sizeof(struct item),
189be0e5c09SChris Mason 					  key, c->header.nritems, slot);
190be0e5c09SChris Mason 	} else {
191be0e5c09SChris Mason 		return generic_bin_search((void *)c->keys, sizeof(struct key),
192be0e5c09SChris Mason 					  key, c->header.nritems, slot);
193be0e5c09SChris Mason 	}
194be0e5c09SChris Mason 	return -1;
195be0e5c09SChris Mason }
196be0e5c09SChris Mason 
197bb803951SChris Mason struct tree_buffer *read_node_slot(struct ctree_root *root,
198bb803951SChris Mason 				   struct tree_buffer *parent_buf,
199bb803951SChris Mason 				   int slot)
200bb803951SChris Mason {
201bb803951SChris Mason 	struct node *node = &parent_buf->node;
202bb803951SChris Mason 	if (slot < 0)
203bb803951SChris Mason 		return NULL;
204bb803951SChris Mason 	if (slot >= node->header.nritems)
205bb803951SChris Mason 		return NULL;
206bb803951SChris Mason 	return read_tree_block(root, node->blockptrs[slot]);
207bb803951SChris Mason }
208bb803951SChris Mason 
209bb803951SChris Mason static int balance_level(struct ctree_root *root, struct ctree_path *path,
210bb803951SChris Mason 			int level)
211bb803951SChris Mason {
212bb803951SChris Mason 	struct tree_buffer *right_buf;
213bb803951SChris Mason 	struct tree_buffer *mid_buf;
214bb803951SChris Mason 	struct tree_buffer *left_buf;
215bb803951SChris Mason 	struct tree_buffer *parent_buf = NULL;
216bb803951SChris Mason 	struct node *right = NULL;
217bb803951SChris Mason 	struct node *mid;
218bb803951SChris Mason 	struct node *left = NULL;
219bb803951SChris Mason 	struct node *parent = NULL;
220bb803951SChris Mason 	int ret = 0;
221bb803951SChris Mason 	int wret;
222bb803951SChris Mason 	int pslot;
223bb803951SChris Mason 	int orig_slot = path->slots[level];
22479f95c82SChris Mason 	u64 orig_ptr;
225bb803951SChris Mason 
226bb803951SChris Mason 	if (level == 0)
227bb803951SChris Mason 		return 0;
228bb803951SChris Mason 
229bb803951SChris Mason 	mid_buf = path->nodes[level];
230bb803951SChris Mason 	mid = &mid_buf->node;
23179f95c82SChris Mason 	orig_ptr = mid->blockptrs[orig_slot];
23279f95c82SChris Mason 
233bb803951SChris Mason 	if (level < MAX_LEVEL - 1)
234bb803951SChris Mason 		parent_buf = path->nodes[level + 1];
235bb803951SChris Mason 	pslot = path->slots[level + 1];
236bb803951SChris Mason 
237bb803951SChris Mason 	if (!parent_buf) {
238bb803951SChris Mason 		struct tree_buffer *child;
239bb803951SChris Mason 		u64 blocknr = mid_buf->blocknr;
240bb803951SChris Mason 
241bb803951SChris Mason 		if (mid->header.nritems != 1)
242bb803951SChris Mason 			return 0;
243bb803951SChris Mason 
244bb803951SChris Mason 		/* promote the child to a root */
245bb803951SChris Mason 		child = read_node_slot(root, mid_buf, 0);
246bb803951SChris Mason 		BUG_ON(!child);
247bb803951SChris Mason 		root->node = child;
248bb803951SChris Mason 		path->nodes[level] = NULL;
249bb803951SChris Mason 		/* once for the path */
250bb803951SChris Mason 		tree_block_release(root, mid_buf);
251bb803951SChris Mason 		/* once for the root ptr */
252bb803951SChris Mason 		tree_block_release(root, mid_buf);
253bb803951SChris Mason 		return free_extent(root, blocknr, 1);
254bb803951SChris Mason 	}
255bb803951SChris Mason 	parent = &parent_buf->node;
256bb803951SChris Mason 
257bb803951SChris Mason 	if (mid->header.nritems > NODEPTRS_PER_BLOCK / 4)
258bb803951SChris Mason 		return 0;
259bb803951SChris Mason 
260bb803951SChris Mason 	left_buf = read_node_slot(root, parent_buf, pslot - 1);
261bb803951SChris Mason 	right_buf = read_node_slot(root, parent_buf, pslot + 1);
26279f95c82SChris Mason 
26379f95c82SChris Mason 	/* first, try to make some room in the middle buffer */
264bb803951SChris Mason 	if (left_buf) {
265bb803951SChris Mason 		left = &left_buf->node;
266bb803951SChris Mason 		orig_slot += left->header.nritems;
26779f95c82SChris Mason 		wret = push_node_left(root, left_buf, mid_buf);
26879f95c82SChris Mason 		if (wret < 0)
26979f95c82SChris Mason 			ret = wret;
270bb803951SChris Mason 	}
27179f95c82SChris Mason 
27279f95c82SChris Mason 	/*
27379f95c82SChris Mason 	 * then try to empty the right most buffer into the middle
27479f95c82SChris Mason 	 */
275bb803951SChris Mason 	if (right_buf) {
27679f95c82SChris Mason 		right = &right_buf->node;
27779f95c82SChris Mason 		wret = push_node_left(root, mid_buf, right_buf);
27879f95c82SChris Mason 		if (wret < 0)
27979f95c82SChris Mason 			ret = wret;
280bb803951SChris Mason 		if (right->header.nritems == 0) {
281bb803951SChris Mason 			u64 blocknr = right_buf->blocknr;
282bb803951SChris Mason 			tree_block_release(root, right_buf);
283bb803951SChris Mason 			right_buf = NULL;
284bb803951SChris Mason 			right = NULL;
285bb803951SChris Mason 			wret = del_ptr(root, path, level + 1, pslot + 1);
286bb803951SChris Mason 			if (wret)
287bb803951SChris Mason 				ret = wret;
288bb803951SChris Mason 			wret = free_extent(root, blocknr, 1);
289bb803951SChris Mason 			if (wret)
290bb803951SChris Mason 				ret = wret;
291bb803951SChris Mason 		} else {
292bb803951SChris Mason 			memcpy(parent->keys + pslot + 1, right->keys,
293bb803951SChris Mason 				sizeof(struct key));
29479f95c82SChris Mason 			wret = write_tree_block(root, parent_buf);
29579f95c82SChris Mason 			if (wret)
29679f95c82SChris Mason 				ret = wret;
297bb803951SChris Mason 		}
298bb803951SChris Mason 	}
29979f95c82SChris Mason 	if (mid->header.nritems == 1) {
30079f95c82SChris Mason 		/*
30179f95c82SChris Mason 		 * we're not allowed to leave a node with one item in the
30279f95c82SChris Mason 		 * tree during a delete.  A deletion from lower in the tree
30379f95c82SChris Mason 		 * could try to delete the only pointer in this node.
30479f95c82SChris Mason 		 * So, pull some keys from the left.
30579f95c82SChris Mason 		 * There has to be a left pointer at this point because
30679f95c82SChris Mason 		 * otherwise we would have pulled some pointers from the
30779f95c82SChris Mason 		 * right
30879f95c82SChris Mason 		 */
30979f95c82SChris Mason 		BUG_ON(!left_buf);
31079f95c82SChris Mason 		wret = balance_node_right(root, mid_buf, left_buf);
31179f95c82SChris Mason 		if (wret < 0)
31279f95c82SChris Mason 			ret = wret;
31379f95c82SChris Mason 		BUG_ON(wret == 1);
31479f95c82SChris Mason 	}
315bb803951SChris Mason 	if (mid->header.nritems == 0) {
31679f95c82SChris Mason 		/* we've managed to empty the middle node, drop it */
317bb803951SChris Mason 		u64 blocknr = mid_buf->blocknr;
318bb803951SChris Mason 		tree_block_release(root, mid_buf);
319bb803951SChris Mason 		mid_buf = NULL;
320bb803951SChris Mason 		mid = NULL;
321bb803951SChris Mason 		wret = del_ptr(root, path, level + 1, pslot);
322bb803951SChris Mason 		if (wret)
323bb803951SChris Mason 			ret = wret;
324bb803951SChris Mason 		wret = free_extent(root, blocknr, 1);
325bb803951SChris Mason 		if (wret)
326bb803951SChris Mason 			ret = wret;
32779f95c82SChris Mason 	} else {
32879f95c82SChris Mason 		/* update the parent key to reflect our changes */
329bb803951SChris Mason 		memcpy(parent->keys + pslot, mid->keys, sizeof(struct key));
33079f95c82SChris Mason 		wret = write_tree_block(root, parent_buf);
33179f95c82SChris Mason 		if (wret)
33279f95c82SChris Mason 			ret = wret;
33379f95c82SChris Mason 	}
334bb803951SChris Mason 
33579f95c82SChris Mason 	/* update the path */
336bb803951SChris Mason 	if (left_buf) {
33779f95c82SChris Mason 		if (left->header.nritems > orig_slot) {
338bb803951SChris Mason 			left_buf->count++; // released below
339bb803951SChris Mason 			path->nodes[level] = left_buf;
340bb803951SChris Mason 			path->slots[level + 1] -= 1;
341bb803951SChris Mason 			path->slots[level] = orig_slot;
342bb803951SChris Mason 			if (mid_buf)
343bb803951SChris Mason 				tree_block_release(root, mid_buf);
344bb803951SChris Mason 		} else {
345bb803951SChris Mason 			orig_slot -= left->header.nritems;
346bb803951SChris Mason 			path->slots[level] = orig_slot;
347bb803951SChris Mason 		}
348bb803951SChris Mason 	}
34979f95c82SChris Mason 	/* double check we haven't messed things up */
35079f95c82SChris Mason 	check_block(path, level);
35179f95c82SChris Mason 	if (orig_ptr != path->nodes[level]->node.blockptrs[path->slots[level]])
35279f95c82SChris Mason 		BUG();
353bb803951SChris Mason 
354bb803951SChris Mason 	if (right_buf)
355bb803951SChris Mason 		tree_block_release(root, right_buf);
356bb803951SChris Mason 	if (left_buf)
357bb803951SChris Mason 		tree_block_release(root, left_buf);
358bb803951SChris Mason 	return ret;
359bb803951SChris Mason }
360bb803951SChris Mason 
36174123bd7SChris Mason /*
36274123bd7SChris Mason  * look for key in the tree.  path is filled in with nodes along the way
36374123bd7SChris Mason  * if key is found, we return zero and you can find the item in the leaf
36474123bd7SChris Mason  * level of the path (level 0)
36574123bd7SChris Mason  *
36674123bd7SChris Mason  * If the key isn't found, the path points to the slot where it should
367aa5d6bedSChris Mason  * be inserted, and 1 is returned.  If there are other errors during the
368aa5d6bedSChris Mason  * search a negative error number is returned.
36997571fd0SChris Mason  *
37097571fd0SChris Mason  * if ins_len > 0, nodes and leaves will be split as we walk down the
37197571fd0SChris Mason  * tree.  if ins_len < 0, nodes will be merged as we walk down the tree (if
37297571fd0SChris Mason  * possible)
37374123bd7SChris Mason  */
3745de08d7dSChris Mason int search_slot(struct ctree_root *root, struct key *key,
3755de08d7dSChris Mason 		struct ctree_path *p, int ins_len)
376be0e5c09SChris Mason {
377bb803951SChris Mason 	struct tree_buffer *b;
378eb60ceacSChris Mason 	struct node *c;
379be0e5c09SChris Mason 	int slot;
380be0e5c09SChris Mason 	int ret;
381be0e5c09SChris Mason 	int level;
3825c680ed6SChris Mason 
383bb803951SChris Mason again:
384bb803951SChris Mason 	b = root->node;
385eb60ceacSChris Mason 	b->count++;
386eb60ceacSChris Mason 	while (b) {
387eb60ceacSChris Mason 		c = &b->node;
388be0e5c09SChris Mason 		level = node_level(c->header.flags);
389eb60ceacSChris Mason 		p->nodes[level] = b;
390aa5d6bedSChris Mason 		ret = check_block(p, level);
391aa5d6bedSChris Mason 		if (ret)
392aa5d6bedSChris Mason 			return -1;
393be0e5c09SChris Mason 		ret = bin_search(c, key, &slot);
394be0e5c09SChris Mason 		if (!is_leaf(c->header.flags)) {
395be0e5c09SChris Mason 			if (ret && slot > 0)
396be0e5c09SChris Mason 				slot -= 1;
397be0e5c09SChris Mason 			p->slots[level] = slot;
3985de08d7dSChris Mason 			if (ins_len > 0 &&
3995de08d7dSChris Mason 			    c->header.nritems == NODEPTRS_PER_BLOCK) {
4005c680ed6SChris Mason 				int sret = split_node(root, p, level);
4015c680ed6SChris Mason 				BUG_ON(sret > 0);
4025c680ed6SChris Mason 				if (sret)
4035c680ed6SChris Mason 					return sret;
4045c680ed6SChris Mason 				b = p->nodes[level];
4055c680ed6SChris Mason 				c = &b->node;
4065c680ed6SChris Mason 				slot = p->slots[level];
407bb803951SChris Mason 			} else if (ins_len < 0) {
408bb803951SChris Mason 				int sret = balance_level(root, p, level);
409bb803951SChris Mason 				if (sret)
410bb803951SChris Mason 					return sret;
411bb803951SChris Mason 				b = p->nodes[level];
412bb803951SChris Mason 				if (!b)
413bb803951SChris Mason 					goto again;
414bb803951SChris Mason 				c = &b->node;
415bb803951SChris Mason 				slot = p->slots[level];
41679f95c82SChris Mason 				BUG_ON(c->header.nritems == 1);
4175c680ed6SChris Mason 			}
418eb60ceacSChris Mason 			b = read_tree_block(root, c->blockptrs[slot]);
419be0e5c09SChris Mason 		} else {
4205c680ed6SChris Mason 			struct leaf *l = (struct leaf *)c;
421be0e5c09SChris Mason 			p->slots[level] = slot;
4225de08d7dSChris Mason 			if (ins_len > 0 && leaf_free_space(l) <
4235de08d7dSChris Mason 			    sizeof(struct item) + ins_len) {
4245c680ed6SChris Mason 				int sret = split_leaf(root, p, ins_len);
4255c680ed6SChris Mason 				BUG_ON(sret > 0);
4265c680ed6SChris Mason 				if (sret)
4275c680ed6SChris Mason 					return sret;
4285c680ed6SChris Mason 			}
429bb803951SChris Mason 			BUG_ON(root->node->count == 1);
430be0e5c09SChris Mason 			return ret;
431be0e5c09SChris Mason 		}
432be0e5c09SChris Mason 	}
433bb803951SChris Mason 	BUG_ON(root->node->count == 1);
434aa5d6bedSChris Mason 	return 1;
435be0e5c09SChris Mason }
436be0e5c09SChris Mason 
43774123bd7SChris Mason /*
43874123bd7SChris Mason  * adjust the pointers going up the tree, starting at level
43974123bd7SChris Mason  * making sure the right key of each node is points to 'key'.
44074123bd7SChris Mason  * This is used after shifting pointers to the left, so it stops
44174123bd7SChris Mason  * fixing up pointers when a given leaf/node is not in slot 0 of the
44274123bd7SChris Mason  * higher levels
443aa5d6bedSChris Mason  *
444aa5d6bedSChris Mason  * If this fails to write a tree block, it returns -1, but continues
445aa5d6bedSChris Mason  * fixing up the blocks in ram so the tree is consistent.
44674123bd7SChris Mason  */
447aa5d6bedSChris Mason static int fixup_low_keys(struct ctree_root *root,
448eb60ceacSChris Mason 			   struct ctree_path *path, struct key *key,
449be0e5c09SChris Mason 			   int level)
450be0e5c09SChris Mason {
451be0e5c09SChris Mason 	int i;
452aa5d6bedSChris Mason 	int ret = 0;
453aa5d6bedSChris Mason 	int wret;
454be0e5c09SChris Mason 	for (i = level; i < MAX_LEVEL; i++) {
455eb60ceacSChris Mason 		struct node *t;
456be0e5c09SChris Mason 		int tslot = path->slots[i];
457eb60ceacSChris Mason 		if (!path->nodes[i])
458be0e5c09SChris Mason 			break;
459eb60ceacSChris Mason 		t = &path->nodes[i]->node;
460be0e5c09SChris Mason 		memcpy(t->keys + tslot, key, sizeof(*key));
461aa5d6bedSChris Mason 		wret = write_tree_block(root, path->nodes[i]);
462aa5d6bedSChris Mason 		if (wret)
463aa5d6bedSChris Mason 			ret = wret;
464be0e5c09SChris Mason 		if (tslot != 0)
465be0e5c09SChris Mason 			break;
466be0e5c09SChris Mason 	}
467aa5d6bedSChris Mason 	return ret;
468be0e5c09SChris Mason }
469be0e5c09SChris Mason 
47074123bd7SChris Mason /*
47174123bd7SChris Mason  * try to push data from one node into the next node left in the
47279f95c82SChris Mason  * tree.
473aa5d6bedSChris Mason  *
474aa5d6bedSChris Mason  * returns 0 if some ptrs were pushed left, < 0 if there was some horrible
475aa5d6bedSChris Mason  * error, and > 0 if there was no room in the left hand block.
47674123bd7SChris Mason  */
477bb803951SChris Mason static int push_node_left(struct ctree_root *root, struct tree_buffer *dst_buf,
478bb803951SChris Mason 			  struct tree_buffer *src_buf)
479be0e5c09SChris Mason {
480bb803951SChris Mason 	struct node *src = &src_buf->node;
481bb803951SChris Mason 	struct node *dst = &dst_buf->node;
482be0e5c09SChris Mason 	int push_items = 0;
483bb803951SChris Mason 	int src_nritems;
484bb803951SChris Mason 	int dst_nritems;
485aa5d6bedSChris Mason 	int ret = 0;
486aa5d6bedSChris Mason 	int wret;
487be0e5c09SChris Mason 
488be0e5c09SChris Mason 	src_nritems = src->header.nritems;
489bb803951SChris Mason 	dst_nritems = dst->header.nritems;
490bb803951SChris Mason 	push_items = NODEPTRS_PER_BLOCK - dst_nritems;
491eb60ceacSChris Mason 	if (push_items <= 0) {
492be0e5c09SChris Mason 		return 1;
493eb60ceacSChris Mason 	}
494be0e5c09SChris Mason 
495be0e5c09SChris Mason 	if (src_nritems < push_items)
496be0e5c09SChris Mason 		push_items = src_nritems;
49779f95c82SChris Mason 
498bb803951SChris Mason 	memcpy(dst->keys + dst_nritems, src->keys,
499be0e5c09SChris Mason 		push_items * sizeof(struct key));
500bb803951SChris Mason 	memcpy(dst->blockptrs + dst_nritems, src->blockptrs,
501be0e5c09SChris Mason 		push_items * sizeof(u64));
502bb803951SChris Mason 	if (push_items < src_nritems) {
503bb803951SChris Mason 		memmove(src->keys, src->keys + push_items,
504bb803951SChris Mason 			(src_nritems - push_items) * sizeof(struct key));
505bb803951SChris Mason 		memmove(src->blockptrs, src->blockptrs + push_items,
506bb803951SChris Mason 			(src_nritems - push_items) * sizeof(u64));
507bb803951SChris Mason 	}
508be0e5c09SChris Mason 	src->header.nritems -= push_items;
509be0e5c09SChris Mason 	dst->header.nritems += push_items;
510be0e5c09SChris Mason 
511bb803951SChris Mason 	wret = write_tree_block(root, src_buf);
512bb803951SChris Mason 	if (wret < 0)
513bb803951SChris Mason 		ret = wret;
514eb60ceacSChris Mason 
515bb803951SChris Mason 	wret = write_tree_block(root, dst_buf);
516bb803951SChris Mason 	if (wret < 0)
517bb803951SChris Mason 		ret = wret;
518bb803951SChris Mason 	return ret;
519be0e5c09SChris Mason }
520be0e5c09SChris Mason 
52197571fd0SChris Mason /*
52279f95c82SChris Mason  * try to push data from one node into the next node right in the
52379f95c82SChris Mason  * tree.
52479f95c82SChris Mason  *
52579f95c82SChris Mason  * returns 0 if some ptrs were pushed, < 0 if there was some horrible
52679f95c82SChris Mason  * error, and > 0 if there was no room in the right hand block.
52779f95c82SChris Mason  *
52879f95c82SChris Mason  * this will  only push up to 1/2 the contents of the left node over
52979f95c82SChris Mason  */
53079f95c82SChris Mason static int balance_node_right(struct ctree_root *root,
53179f95c82SChris Mason 			      struct tree_buffer *dst_buf,
53279f95c82SChris Mason 			      struct tree_buffer *src_buf)
53379f95c82SChris Mason {
53479f95c82SChris Mason 	struct node *src = &src_buf->node;
53579f95c82SChris Mason 	struct node *dst = &dst_buf->node;
53679f95c82SChris Mason 	int push_items = 0;
53779f95c82SChris Mason 	int max_push;
53879f95c82SChris Mason 	int src_nritems;
53979f95c82SChris Mason 	int dst_nritems;
54079f95c82SChris Mason 	int ret = 0;
54179f95c82SChris Mason 	int wret;
54279f95c82SChris Mason 
54379f95c82SChris Mason 	src_nritems = src->header.nritems;
54479f95c82SChris Mason 	dst_nritems = dst->header.nritems;
54579f95c82SChris Mason 	push_items = NODEPTRS_PER_BLOCK - dst_nritems;
54679f95c82SChris Mason 	if (push_items <= 0) {
54779f95c82SChris Mason 		return 1;
54879f95c82SChris Mason 	}
54979f95c82SChris Mason 
55079f95c82SChris Mason 	max_push = src_nritems / 2 + 1;
55179f95c82SChris Mason 	/* don't try to empty the node */
55279f95c82SChris Mason 	if (max_push > src_nritems)
55379f95c82SChris Mason 		return 1;
55479f95c82SChris Mason 	if (max_push < push_items)
55579f95c82SChris Mason 		push_items = max_push;
55679f95c82SChris Mason 
55779f95c82SChris Mason 	memmove(dst->keys + push_items, dst->keys,
55879f95c82SChris Mason 		dst_nritems * sizeof(struct key));
55979f95c82SChris Mason 	memmove(dst->blockptrs + push_items, dst->blockptrs,
56079f95c82SChris Mason 		dst_nritems * sizeof(u64));
56179f95c82SChris Mason 	memcpy(dst->keys, src->keys + src_nritems - push_items,
56279f95c82SChris Mason 		push_items * sizeof(struct key));
56379f95c82SChris Mason 	memcpy(dst->blockptrs, src->blockptrs + src_nritems - push_items,
56479f95c82SChris Mason 		push_items * sizeof(u64));
56579f95c82SChris Mason 
56679f95c82SChris Mason 	src->header.nritems -= push_items;
56779f95c82SChris Mason 	dst->header.nritems += push_items;
56879f95c82SChris Mason 
56979f95c82SChris Mason 	wret = write_tree_block(root, src_buf);
57079f95c82SChris Mason 	if (wret < 0)
57179f95c82SChris Mason 		ret = wret;
57279f95c82SChris Mason 
57379f95c82SChris Mason 	wret = write_tree_block(root, dst_buf);
57479f95c82SChris Mason 	if (wret < 0)
57579f95c82SChris Mason 		ret = wret;
57679f95c82SChris Mason 	return ret;
57779f95c82SChris Mason }
57879f95c82SChris Mason 
57979f95c82SChris Mason /*
58097571fd0SChris Mason  * helper function to insert a new root level in the tree.
58197571fd0SChris Mason  * A new node is allocated, and a single item is inserted to
58297571fd0SChris Mason  * point to the existing root
583aa5d6bedSChris Mason  *
584aa5d6bedSChris Mason  * returns zero on success or < 0 on failure.
58597571fd0SChris Mason  */
5865de08d7dSChris Mason static int insert_new_root(struct ctree_root *root,
5875de08d7dSChris Mason 			   struct ctree_path *path, int level)
58874123bd7SChris Mason {
58974123bd7SChris Mason 	struct tree_buffer *t;
5905c680ed6SChris Mason 	struct node *lower;
5915c680ed6SChris Mason 	struct node *c;
5925c680ed6SChris Mason 	struct key *lower_key;
5935c680ed6SChris Mason 
5945c680ed6SChris Mason 	BUG_ON(path->nodes[level]);
5955c680ed6SChris Mason 	BUG_ON(path->nodes[level-1] != root->node);
5965c680ed6SChris Mason 
59774123bd7SChris Mason 	t = alloc_free_block(root);
59874123bd7SChris Mason 	c = &t->node;
59974123bd7SChris Mason 	memset(c, 0, sizeof(c));
6005c680ed6SChris Mason 	c->header.nritems = 1;
60174123bd7SChris Mason 	c->header.flags = node_level(level);
60274123bd7SChris Mason 	c->header.blocknr = t->blocknr;
603cfaa7295SChris Mason 	c->header.parentid = root->node->node.header.parentid;
60474123bd7SChris Mason 	lower = &path->nodes[level-1]->node;
60574123bd7SChris Mason 	if (is_leaf(lower->header.flags))
60674123bd7SChris Mason 		lower_key = &((struct leaf *)lower)->items[0].key;
60774123bd7SChris Mason 	else
60874123bd7SChris Mason 		lower_key = lower->keys;
60974123bd7SChris Mason 	memcpy(c->keys, lower_key, sizeof(struct key));
61074123bd7SChris Mason 	c->blockptrs[0] = path->nodes[level-1]->blocknr;
611cfaa7295SChris Mason 	/* the super has an extra ref to root->node */
61274123bd7SChris Mason 	tree_block_release(root, root->node);
61374123bd7SChris Mason 	root->node = t;
61474123bd7SChris Mason 	t->count++;
61574123bd7SChris Mason 	write_tree_block(root, t);
61674123bd7SChris Mason 	path->nodes[level] = t;
61774123bd7SChris Mason 	path->slots[level] = 0;
61874123bd7SChris Mason 	return 0;
61974123bd7SChris Mason }
6205c680ed6SChris Mason 
6215c680ed6SChris Mason /*
6225c680ed6SChris Mason  * worker function to insert a single pointer in a node.
6235c680ed6SChris Mason  * the node should have enough room for the pointer already
62497571fd0SChris Mason  *
6255c680ed6SChris Mason  * slot and level indicate where you want the key to go, and
6265c680ed6SChris Mason  * blocknr is the block the key points to.
627aa5d6bedSChris Mason  *
628aa5d6bedSChris Mason  * returns zero on success and < 0 on any error
6295c680ed6SChris Mason  */
630aa5d6bedSChris Mason static int insert_ptr(struct ctree_root *root,
6315c680ed6SChris Mason 		struct ctree_path *path, struct key *key,
6325c680ed6SChris Mason 		u64 blocknr, int slot, int level)
6335c680ed6SChris Mason {
6345c680ed6SChris Mason 	struct node *lower;
6355c680ed6SChris Mason 	int nritems;
6365c680ed6SChris Mason 
6375c680ed6SChris Mason 	BUG_ON(!path->nodes[level]);
63874123bd7SChris Mason 	lower = &path->nodes[level]->node;
63974123bd7SChris Mason 	nritems = lower->header.nritems;
64074123bd7SChris Mason 	if (slot > nritems)
64174123bd7SChris Mason 		BUG();
64274123bd7SChris Mason 	if (nritems == NODEPTRS_PER_BLOCK)
64374123bd7SChris Mason 		BUG();
64474123bd7SChris Mason 	if (slot != nritems) {
64574123bd7SChris Mason 		memmove(lower->keys + slot + 1, lower->keys + slot,
64674123bd7SChris Mason 			(nritems - slot) * sizeof(struct key));
64774123bd7SChris Mason 		memmove(lower->blockptrs + slot + 1, lower->blockptrs + slot,
64874123bd7SChris Mason 			(nritems - slot) * sizeof(u64));
64974123bd7SChris Mason 	}
65074123bd7SChris Mason 	memcpy(lower->keys + slot, key, sizeof(struct key));
65174123bd7SChris Mason 	lower->blockptrs[slot] = blocknr;
65274123bd7SChris Mason 	lower->header.nritems++;
65374123bd7SChris Mason 	if (lower->keys[1].objectid == 0)
65474123bd7SChris Mason 			BUG();
65574123bd7SChris Mason 	write_tree_block(root, path->nodes[level]);
65674123bd7SChris Mason 	return 0;
65774123bd7SChris Mason }
65874123bd7SChris Mason 
65997571fd0SChris Mason /*
66097571fd0SChris Mason  * split the node at the specified level in path in two.
66197571fd0SChris Mason  * The path is corrected to point to the appropriate node after the split
66297571fd0SChris Mason  *
66397571fd0SChris Mason  * Before splitting this tries to make some room in the node by pushing
66497571fd0SChris Mason  * left and right, if either one works, it returns right away.
665aa5d6bedSChris Mason  *
666aa5d6bedSChris Mason  * returns 0 on success and < 0 on failure
66797571fd0SChris Mason  */
668aa5d6bedSChris Mason static int split_node(struct ctree_root *root, struct ctree_path *path,
669aa5d6bedSChris Mason 		      int level)
670be0e5c09SChris Mason {
6715c680ed6SChris Mason 	struct tree_buffer *t;
6725c680ed6SChris Mason 	struct node *c;
6735c680ed6SChris Mason 	struct tree_buffer *split_buffer;
6745c680ed6SChris Mason 	struct node *split;
675be0e5c09SChris Mason 	int mid;
6765c680ed6SChris Mason 	int ret;
677aa5d6bedSChris Mason 	int wret;
678be0e5c09SChris Mason 
6795c680ed6SChris Mason 	t = path->nodes[level];
680eb60ceacSChris Mason 	c = &t->node;
6815c680ed6SChris Mason 	if (t == root->node) {
6825c680ed6SChris Mason 		/* trying to split the root, lets make a new one */
6835c680ed6SChris Mason 		ret = insert_new_root(root, path, level + 1);
6845c680ed6SChris Mason 		if (ret)
6855c680ed6SChris Mason 			return ret;
6865c680ed6SChris Mason 	}
6875c680ed6SChris Mason 	split_buffer = alloc_free_block(root);
6885c680ed6SChris Mason 	split = &split_buffer->node;
6895c680ed6SChris Mason 	split->header.flags = c->header.flags;
6905c680ed6SChris Mason 	split->header.blocknr = split_buffer->blocknr;
6915c680ed6SChris Mason 	split->header.parentid = root->node->node.header.parentid;
692be0e5c09SChris Mason 	mid = (c->header.nritems + 1) / 2;
6935c680ed6SChris Mason 	memcpy(split->keys, c->keys + mid,
694be0e5c09SChris Mason 		(c->header.nritems - mid) * sizeof(struct key));
6955c680ed6SChris Mason 	memcpy(split->blockptrs, c->blockptrs + mid,
696be0e5c09SChris Mason 		(c->header.nritems - mid) * sizeof(u64));
6975c680ed6SChris Mason 	split->header.nritems = c->header.nritems - mid;
698be0e5c09SChris Mason 	c->header.nritems = mid;
699aa5d6bedSChris Mason 	ret = 0;
700aa5d6bedSChris Mason 
701aa5d6bedSChris Mason 	wret = write_tree_block(root, t);
702aa5d6bedSChris Mason 	if (wret)
703aa5d6bedSChris Mason 		ret = wret;
704aa5d6bedSChris Mason 	wret = write_tree_block(root, split_buffer);
705aa5d6bedSChris Mason 	if (wret)
706aa5d6bedSChris Mason 		ret = wret;
707aa5d6bedSChris Mason 	wret = insert_ptr(root, path, split->keys, split_buffer->blocknr,
7085c680ed6SChris Mason 			  path->slots[level + 1] + 1, level + 1);
709aa5d6bedSChris Mason 	if (wret)
710aa5d6bedSChris Mason 		ret = wret;
711aa5d6bedSChris Mason 
7125de08d7dSChris Mason 	if (path->slots[level] >= mid) {
7135c680ed6SChris Mason 		path->slots[level] -= mid;
7145c680ed6SChris Mason 		tree_block_release(root, t);
7155c680ed6SChris Mason 		path->nodes[level] = split_buffer;
7165c680ed6SChris Mason 		path->slots[level + 1] += 1;
717eb60ceacSChris Mason 	} else {
7185c680ed6SChris Mason 		tree_block_release(root, split_buffer);
719be0e5c09SChris Mason 	}
720aa5d6bedSChris Mason 	return ret;
721be0e5c09SChris Mason }
722be0e5c09SChris Mason 
72374123bd7SChris Mason /*
72474123bd7SChris Mason  * how many bytes are required to store the items in a leaf.  start
72574123bd7SChris Mason  * and nr indicate which items in the leaf to check.  This totals up the
72674123bd7SChris Mason  * space used both by the item structs and the item data
72774123bd7SChris Mason  */
728aa5d6bedSChris Mason static int leaf_space_used(struct leaf *l, int start, int nr)
729be0e5c09SChris Mason {
730be0e5c09SChris Mason 	int data_len;
731be0e5c09SChris Mason 	int end = start + nr - 1;
732be0e5c09SChris Mason 
733be0e5c09SChris Mason 	if (!nr)
734be0e5c09SChris Mason 		return 0;
735be0e5c09SChris Mason 	data_len = l->items[start].offset + l->items[start].size;
736be0e5c09SChris Mason 	data_len = data_len - l->items[end].offset;
737be0e5c09SChris Mason 	data_len += sizeof(struct item) * nr;
738be0e5c09SChris Mason 	return data_len;
739be0e5c09SChris Mason }
740be0e5c09SChris Mason 
74174123bd7SChris Mason /*
74200ec4c51SChris Mason  * push some data in the path leaf to the right, trying to free up at
74300ec4c51SChris Mason  * least data_size bytes.  returns zero if the push worked, nonzero otherwise
744aa5d6bedSChris Mason  *
745aa5d6bedSChris Mason  * returns 1 if the push failed because the other node didn't have enough
746aa5d6bedSChris Mason  * room, 0 if everything worked out and < 0 if there were major errors.
74700ec4c51SChris Mason  */
748aa5d6bedSChris Mason static int push_leaf_right(struct ctree_root *root, struct ctree_path *path,
74900ec4c51SChris Mason 			   int data_size)
75000ec4c51SChris Mason {
75100ec4c51SChris Mason 	struct tree_buffer *left_buf = path->nodes[0];
75200ec4c51SChris Mason 	struct leaf *left = &left_buf->leaf;
75300ec4c51SChris Mason 	struct leaf *right;
75400ec4c51SChris Mason 	struct tree_buffer *right_buf;
75500ec4c51SChris Mason 	struct tree_buffer *upper;
75600ec4c51SChris Mason 	int slot;
75700ec4c51SChris Mason 	int i;
75800ec4c51SChris Mason 	int free_space;
75900ec4c51SChris Mason 	int push_space = 0;
76000ec4c51SChris Mason 	int push_items = 0;
76100ec4c51SChris Mason 	struct item *item;
76200ec4c51SChris Mason 
76300ec4c51SChris Mason 	slot = path->slots[1];
76400ec4c51SChris Mason 	if (!path->nodes[1]) {
76500ec4c51SChris Mason 		return 1;
76600ec4c51SChris Mason 	}
76700ec4c51SChris Mason 	upper = path->nodes[1];
76800ec4c51SChris Mason 	if (slot >= upper->node.header.nritems - 1) {
76900ec4c51SChris Mason 		return 1;
77000ec4c51SChris Mason 	}
77100ec4c51SChris Mason 	right_buf = read_tree_block(root, upper->node.blockptrs[slot + 1]);
77200ec4c51SChris Mason 	right = &right_buf->leaf;
77300ec4c51SChris Mason 	free_space = leaf_free_space(right);
77400ec4c51SChris Mason 	if (free_space < data_size + sizeof(struct item)) {
77500ec4c51SChris Mason 		tree_block_release(root, right_buf);
77600ec4c51SChris Mason 		return 1;
77700ec4c51SChris Mason 	}
77800ec4c51SChris Mason 	for (i = left->header.nritems - 1; i >= 0; i--) {
77900ec4c51SChris Mason 		item = left->items + i;
78000ec4c51SChris Mason 		if (path->slots[0] == i)
78100ec4c51SChris Mason 			push_space += data_size + sizeof(*item);
78200ec4c51SChris Mason 		if (item->size + sizeof(*item) + push_space > free_space)
78300ec4c51SChris Mason 			break;
78400ec4c51SChris Mason 		push_items++;
78500ec4c51SChris Mason 		push_space += item->size + sizeof(*item);
78600ec4c51SChris Mason 	}
78700ec4c51SChris Mason 	if (push_items == 0) {
78800ec4c51SChris Mason 		tree_block_release(root, right_buf);
78900ec4c51SChris Mason 		return 1;
79000ec4c51SChris Mason 	}
79100ec4c51SChris Mason 	/* push left to right */
79200ec4c51SChris Mason 	push_space = left->items[left->header.nritems - push_items].offset +
79300ec4c51SChris Mason 		     left->items[left->header.nritems - push_items].size;
79400ec4c51SChris Mason 	push_space -= leaf_data_end(left);
79500ec4c51SChris Mason 	/* make room in the right data area */
79600ec4c51SChris Mason 	memmove(right->data + leaf_data_end(right) - push_space,
79700ec4c51SChris Mason 		right->data + leaf_data_end(right),
79800ec4c51SChris Mason 		LEAF_DATA_SIZE - leaf_data_end(right));
79900ec4c51SChris Mason 	/* copy from the left data area */
80000ec4c51SChris Mason 	memcpy(right->data + LEAF_DATA_SIZE - push_space,
80100ec4c51SChris Mason 		left->data + leaf_data_end(left),
80200ec4c51SChris Mason 		push_space);
80300ec4c51SChris Mason 	memmove(right->items + push_items, right->items,
80400ec4c51SChris Mason 		right->header.nritems * sizeof(struct item));
80500ec4c51SChris Mason 	/* copy the items from left to right */
80600ec4c51SChris Mason 	memcpy(right->items, left->items + left->header.nritems - push_items,
80700ec4c51SChris Mason 		push_items * sizeof(struct item));
80800ec4c51SChris Mason 
80900ec4c51SChris Mason 	/* update the item pointers */
81000ec4c51SChris Mason 	right->header.nritems += push_items;
81100ec4c51SChris Mason 	push_space = LEAF_DATA_SIZE;
81200ec4c51SChris Mason 	for (i = 0; i < right->header.nritems; i++) {
81300ec4c51SChris Mason 		right->items[i].offset = push_space - right->items[i].size;
81400ec4c51SChris Mason 		push_space = right->items[i].offset;
81500ec4c51SChris Mason 	}
81600ec4c51SChris Mason 	left->header.nritems -= push_items;
81700ec4c51SChris Mason 
81800ec4c51SChris Mason 	write_tree_block(root, left_buf);
81900ec4c51SChris Mason 	write_tree_block(root, right_buf);
82000ec4c51SChris Mason 	memcpy(upper->node.keys + slot + 1,
82100ec4c51SChris Mason 		&right->items[0].key, sizeof(struct key));
82200ec4c51SChris Mason 	write_tree_block(root, upper);
82300ec4c51SChris Mason 	/* then fixup the leaf pointer in the path */
82400ec4c51SChris Mason 	if (path->slots[0] >= left->header.nritems) {
82500ec4c51SChris Mason 		path->slots[0] -= left->header.nritems;
82600ec4c51SChris Mason 		tree_block_release(root, path->nodes[0]);
82700ec4c51SChris Mason 		path->nodes[0] = right_buf;
82800ec4c51SChris Mason 		path->slots[1] += 1;
82900ec4c51SChris Mason 	} else {
83000ec4c51SChris Mason 		tree_block_release(root, right_buf);
83100ec4c51SChris Mason 	}
83200ec4c51SChris Mason 	return 0;
83300ec4c51SChris Mason }
83400ec4c51SChris Mason /*
83574123bd7SChris Mason  * push some data in the path leaf to the left, trying to free up at
83674123bd7SChris Mason  * least data_size bytes.  returns zero if the push worked, nonzero otherwise
83774123bd7SChris Mason  */
838aa5d6bedSChris Mason static int push_leaf_left(struct ctree_root *root, struct ctree_path *path,
839be0e5c09SChris Mason 			  int data_size)
840be0e5c09SChris Mason {
841eb60ceacSChris Mason 	struct tree_buffer *right_buf = path->nodes[0];
842eb60ceacSChris Mason 	struct leaf *right = &right_buf->leaf;
843eb60ceacSChris Mason 	struct tree_buffer *t;
844be0e5c09SChris Mason 	struct leaf *left;
845be0e5c09SChris Mason 	int slot;
846be0e5c09SChris Mason 	int i;
847be0e5c09SChris Mason 	int free_space;
848be0e5c09SChris Mason 	int push_space = 0;
849be0e5c09SChris Mason 	int push_items = 0;
850be0e5c09SChris Mason 	struct item *item;
851be0e5c09SChris Mason 	int old_left_nritems;
852aa5d6bedSChris Mason 	int ret = 0;
853aa5d6bedSChris Mason 	int wret;
854be0e5c09SChris Mason 
855be0e5c09SChris Mason 	slot = path->slots[1];
856be0e5c09SChris Mason 	if (slot == 0) {
857be0e5c09SChris Mason 		return 1;
858be0e5c09SChris Mason 	}
859be0e5c09SChris Mason 	if (!path->nodes[1]) {
860be0e5c09SChris Mason 		return 1;
861be0e5c09SChris Mason 	}
862eb60ceacSChris Mason 	t = read_tree_block(root, path->nodes[1]->node.blockptrs[slot - 1]);
863eb60ceacSChris Mason 	left = &t->leaf;
864be0e5c09SChris Mason 	free_space = leaf_free_space(left);
865be0e5c09SChris Mason 	if (free_space < data_size + sizeof(struct item)) {
866eb60ceacSChris Mason 		tree_block_release(root, t);
867be0e5c09SChris Mason 		return 1;
868be0e5c09SChris Mason 	}
869be0e5c09SChris Mason 	for (i = 0; i < right->header.nritems; i++) {
870be0e5c09SChris Mason 		item = right->items + i;
871be0e5c09SChris Mason 		if (path->slots[0] == i)
872be0e5c09SChris Mason 			push_space += data_size + sizeof(*item);
873be0e5c09SChris Mason 		if (item->size + sizeof(*item) + push_space > free_space)
874be0e5c09SChris Mason 			break;
875be0e5c09SChris Mason 		push_items++;
876be0e5c09SChris Mason 		push_space += item->size + sizeof(*item);
877be0e5c09SChris Mason 	}
878be0e5c09SChris Mason 	if (push_items == 0) {
879eb60ceacSChris Mason 		tree_block_release(root, t);
880be0e5c09SChris Mason 		return 1;
881be0e5c09SChris Mason 	}
882be0e5c09SChris Mason 	/* push data from right to left */
883be0e5c09SChris Mason 	memcpy(left->items + left->header.nritems,
884be0e5c09SChris Mason 		right->items, push_items * sizeof(struct item));
885be0e5c09SChris Mason 	push_space = LEAF_DATA_SIZE - right->items[push_items -1].offset;
886be0e5c09SChris Mason 	memcpy(left->data + leaf_data_end(left) - push_space,
887be0e5c09SChris Mason 		right->data + right->items[push_items - 1].offset,
888be0e5c09SChris Mason 		push_space);
889be0e5c09SChris Mason 	old_left_nritems = left->header.nritems;
890eb60ceacSChris Mason 	BUG_ON(old_left_nritems < 0);
891eb60ceacSChris Mason 
892be0e5c09SChris Mason 	for(i = old_left_nritems; i < old_left_nritems + push_items; i++) {
893be0e5c09SChris Mason 		left->items[i].offset -= LEAF_DATA_SIZE -
894be0e5c09SChris Mason 			left->items[old_left_nritems -1].offset;
895be0e5c09SChris Mason 	}
896be0e5c09SChris Mason 	left->header.nritems += push_items;
897be0e5c09SChris Mason 
898be0e5c09SChris Mason 	/* fixup right node */
899be0e5c09SChris Mason 	push_space = right->items[push_items-1].offset - leaf_data_end(right);
900be0e5c09SChris Mason 	memmove(right->data + LEAF_DATA_SIZE - push_space, right->data +
901be0e5c09SChris Mason 		leaf_data_end(right), push_space);
902be0e5c09SChris Mason 	memmove(right->items, right->items + push_items,
903be0e5c09SChris Mason 		(right->header.nritems - push_items) * sizeof(struct item));
904be0e5c09SChris Mason 	right->header.nritems -= push_items;
905be0e5c09SChris Mason 	push_space = LEAF_DATA_SIZE;
906eb60ceacSChris Mason 
907be0e5c09SChris Mason 	for (i = 0; i < right->header.nritems; i++) {
908be0e5c09SChris Mason 		right->items[i].offset = push_space - right->items[i].size;
909be0e5c09SChris Mason 		push_space = right->items[i].offset;
910be0e5c09SChris Mason 	}
911eb60ceacSChris Mason 
912aa5d6bedSChris Mason 	wret = write_tree_block(root, t);
913aa5d6bedSChris Mason 	if (wret)
914aa5d6bedSChris Mason 		ret = wret;
915aa5d6bedSChris Mason 	wret = write_tree_block(root, right_buf);
916aa5d6bedSChris Mason 	if (wret)
917aa5d6bedSChris Mason 		ret = wret;
918eb60ceacSChris Mason 
919aa5d6bedSChris Mason 	wret = fixup_low_keys(root, path, &right->items[0].key, 1);
920aa5d6bedSChris Mason 	if (wret)
921aa5d6bedSChris Mason 		ret = wret;
922be0e5c09SChris Mason 
923be0e5c09SChris Mason 	/* then fixup the leaf pointer in the path */
924be0e5c09SChris Mason 	if (path->slots[0] < push_items) {
925be0e5c09SChris Mason 		path->slots[0] += old_left_nritems;
926eb60ceacSChris Mason 		tree_block_release(root, path->nodes[0]);
927eb60ceacSChris Mason 		path->nodes[0] = t;
928be0e5c09SChris Mason 		path->slots[1] -= 1;
929be0e5c09SChris Mason 	} else {
930eb60ceacSChris Mason 		tree_block_release(root, t);
931be0e5c09SChris Mason 		path->slots[0] -= push_items;
932be0e5c09SChris Mason 	}
933eb60ceacSChris Mason 	BUG_ON(path->slots[0] < 0);
934aa5d6bedSChris Mason 	return ret;
935be0e5c09SChris Mason }
936be0e5c09SChris Mason 
93774123bd7SChris Mason /*
93874123bd7SChris Mason  * split the path's leaf in two, making sure there is at least data_size
93974123bd7SChris Mason  * available for the resulting leaf level of the path.
940aa5d6bedSChris Mason  *
941aa5d6bedSChris Mason  * returns 0 if all went well and < 0 on failure.
94274123bd7SChris Mason  */
943aa5d6bedSChris Mason static int split_leaf(struct ctree_root *root, struct ctree_path *path,
944aa5d6bedSChris Mason 		      int data_size)
945be0e5c09SChris Mason {
946aa5d6bedSChris Mason 	struct tree_buffer *l_buf;
947aa5d6bedSChris Mason 	struct leaf *l;
948eb60ceacSChris Mason 	int nritems;
949eb60ceacSChris Mason 	int mid;
950eb60ceacSChris Mason 	int slot;
951be0e5c09SChris Mason 	struct leaf *right;
952eb60ceacSChris Mason 	struct tree_buffer *right_buffer;
953be0e5c09SChris Mason 	int space_needed = data_size + sizeof(struct item);
954be0e5c09SChris Mason 	int data_copy_size;
955be0e5c09SChris Mason 	int rt_data_off;
956be0e5c09SChris Mason 	int i;
957be0e5c09SChris Mason 	int ret;
958aa5d6bedSChris Mason 	int wret;
959be0e5c09SChris Mason 
960aa5d6bedSChris Mason 	wret = push_leaf_left(root, path, data_size);
961aa5d6bedSChris Mason 	if (wret < 0)
962aa5d6bedSChris Mason 		return wret;
963aa5d6bedSChris Mason 	if (wret) {
964aa5d6bedSChris Mason 		wret = push_leaf_right(root, path, data_size);
965aa5d6bedSChris Mason 		if (wret < 0)
966aa5d6bedSChris Mason 			return wret;
967aa5d6bedSChris Mason 	}
968eb60ceacSChris Mason 	l_buf = path->nodes[0];
969eb60ceacSChris Mason 	l = &l_buf->leaf;
970aa5d6bedSChris Mason 
971aa5d6bedSChris Mason 	/* did the pushes work? */
972eb60ceacSChris Mason 	if (leaf_free_space(l) >= sizeof(struct item) + data_size)
973be0e5c09SChris Mason 		return 0;
974aa5d6bedSChris Mason 
9755c680ed6SChris Mason 	if (!path->nodes[1]) {
9765c680ed6SChris Mason 		ret = insert_new_root(root, path, 1);
9775c680ed6SChris Mason 		if (ret)
9785c680ed6SChris Mason 			return ret;
9795c680ed6SChris Mason 	}
980eb60ceacSChris Mason 	slot = path->slots[0];
981eb60ceacSChris Mason 	nritems = l->header.nritems;
982eb60ceacSChris Mason 	mid = (nritems + 1)/ 2;
983eb60ceacSChris Mason 
984eb60ceacSChris Mason 	right_buffer = alloc_free_block(root);
985eb60ceacSChris Mason 	BUG_ON(!right_buffer);
986eb60ceacSChris Mason 	BUG_ON(mid == nritems);
987eb60ceacSChris Mason 	right = &right_buffer->leaf;
988be0e5c09SChris Mason 	memset(right, 0, sizeof(*right));
989be0e5c09SChris Mason 	if (mid <= slot) {
99097571fd0SChris Mason 		/* FIXME, just alloc a new leaf here */
991be0e5c09SChris Mason 		if (leaf_space_used(l, mid, nritems - mid) + space_needed >
992be0e5c09SChris Mason 			LEAF_DATA_SIZE)
993be0e5c09SChris Mason 			BUG();
994be0e5c09SChris Mason 	} else {
99597571fd0SChris Mason 		/* FIXME, just alloc a new leaf here */
996be0e5c09SChris Mason 		if (leaf_space_used(l, 0, mid + 1) + space_needed >
997be0e5c09SChris Mason 			LEAF_DATA_SIZE)
998be0e5c09SChris Mason 			BUG();
999be0e5c09SChris Mason 	}
1000be0e5c09SChris Mason 	right->header.nritems = nritems - mid;
1001eb60ceacSChris Mason 	right->header.blocknr = right_buffer->blocknr;
1002eb60ceacSChris Mason 	right->header.flags = node_level(0);
1003cfaa7295SChris Mason 	right->header.parentid = root->node->node.header.parentid;
1004be0e5c09SChris Mason 	data_copy_size = l->items[mid].offset + l->items[mid].size -
1005be0e5c09SChris Mason 			 leaf_data_end(l);
1006be0e5c09SChris Mason 	memcpy(right->items, l->items + mid,
1007be0e5c09SChris Mason 	       (nritems - mid) * sizeof(struct item));
1008be0e5c09SChris Mason 	memcpy(right->data + LEAF_DATA_SIZE - data_copy_size,
1009be0e5c09SChris Mason 	       l->data + leaf_data_end(l), data_copy_size);
1010be0e5c09SChris Mason 	rt_data_off = LEAF_DATA_SIZE -
1011be0e5c09SChris Mason 		     (l->items[mid].offset + l->items[mid].size);
101274123bd7SChris Mason 
101374123bd7SChris Mason 	for (i = 0; i < right->header.nritems; i++)
1014be0e5c09SChris Mason 		right->items[i].offset += rt_data_off;
101574123bd7SChris Mason 
1016be0e5c09SChris Mason 	l->header.nritems = mid;
1017aa5d6bedSChris Mason 	ret = 0;
1018aa5d6bedSChris Mason 	wret = insert_ptr(root, path, &right->items[0].key,
10195c680ed6SChris Mason 			  right_buffer->blocknr, path->slots[1] + 1, 1);
1020aa5d6bedSChris Mason 	if (wret)
1021aa5d6bedSChris Mason 		ret = wret;
1022aa5d6bedSChris Mason 	wret = write_tree_block(root, right_buffer);
1023aa5d6bedSChris Mason 	if (wret)
1024aa5d6bedSChris Mason 		ret = wret;
1025aa5d6bedSChris Mason 	wret = write_tree_block(root, l_buf);
1026aa5d6bedSChris Mason 	if (wret)
1027aa5d6bedSChris Mason 		ret = wret;
1028eb60ceacSChris Mason 
1029eb60ceacSChris Mason 	BUG_ON(path->slots[0] != slot);
1030be0e5c09SChris Mason 	if (mid <= slot) {
1031eb60ceacSChris Mason 		tree_block_release(root, path->nodes[0]);
1032eb60ceacSChris Mason 		path->nodes[0] = right_buffer;
1033be0e5c09SChris Mason 		path->slots[0] -= mid;
1034be0e5c09SChris Mason 		path->slots[1] += 1;
1035eb60ceacSChris Mason 	} else
1036eb60ceacSChris Mason 		tree_block_release(root, right_buffer);
1037eb60ceacSChris Mason 	BUG_ON(path->slots[0] < 0);
1038be0e5c09SChris Mason 	return ret;
1039be0e5c09SChris Mason }
1040be0e5c09SChris Mason 
104174123bd7SChris Mason /*
104274123bd7SChris Mason  * Given a key and some data, insert an item into the tree.
104374123bd7SChris Mason  * This does all the path init required, making room in the tree if needed.
104474123bd7SChris Mason  */
1045be0e5c09SChris Mason int insert_item(struct ctree_root *root, struct key *key,
1046be0e5c09SChris Mason 			  void *data, int data_size)
1047be0e5c09SChris Mason {
1048aa5d6bedSChris Mason 	int ret = 0;
1049aa5d6bedSChris Mason 	int wret;
1050be0e5c09SChris Mason 	int slot;
1051eb60ceacSChris Mason 	int slot_orig;
1052be0e5c09SChris Mason 	struct leaf *leaf;
1053eb60ceacSChris Mason 	struct tree_buffer *leaf_buf;
1054be0e5c09SChris Mason 	unsigned int nritems;
1055be0e5c09SChris Mason 	unsigned int data_end;
1056be0e5c09SChris Mason 	struct ctree_path path;
1057be0e5c09SChris Mason 
105874123bd7SChris Mason 	/* create a root if there isn't one */
10595c680ed6SChris Mason 	if (!root->node)
1060cfaa7295SChris Mason 		BUG();
1061be0e5c09SChris Mason 	init_path(&path);
10625c680ed6SChris Mason 	ret = search_slot(root, key, &path, data_size);
1063eb60ceacSChris Mason 	if (ret == 0) {
1064eb60ceacSChris Mason 		release_path(root, &path);
1065be0e5c09SChris Mason 		return -EEXIST;
1066eb60ceacSChris Mason 	}
1067aa5d6bedSChris Mason 	if (ret < 0) {
1068aa5d6bedSChris Mason 		release_path(root, &path);
1069aa5d6bedSChris Mason 		return ret;
1070aa5d6bedSChris Mason 	}
1071be0e5c09SChris Mason 
1072eb60ceacSChris Mason 	slot_orig = path.slots[0];
1073eb60ceacSChris Mason 	leaf_buf = path.nodes[0];
1074eb60ceacSChris Mason 	leaf = &leaf_buf->leaf;
107574123bd7SChris Mason 
1076be0e5c09SChris Mason 	nritems = leaf->header.nritems;
1077be0e5c09SChris Mason 	data_end = leaf_data_end(leaf);
1078eb60ceacSChris Mason 
1079be0e5c09SChris Mason 	if (leaf_free_space(leaf) <  sizeof(struct item) + data_size)
1080be0e5c09SChris Mason 		BUG();
1081be0e5c09SChris Mason 
1082be0e5c09SChris Mason 	slot = path.slots[0];
1083eb60ceacSChris Mason 	BUG_ON(slot < 0);
1084be0e5c09SChris Mason 	if (slot != nritems) {
1085be0e5c09SChris Mason 		int i;
1086be0e5c09SChris Mason 		unsigned int old_data = leaf->items[slot].offset +
1087be0e5c09SChris Mason 					leaf->items[slot].size;
1088be0e5c09SChris Mason 
1089be0e5c09SChris Mason 		/*
1090be0e5c09SChris Mason 		 * item0..itemN ... dataN.offset..dataN.size .. data0.size
1091be0e5c09SChris Mason 		 */
1092be0e5c09SChris Mason 		/* first correct the data pointers */
1093be0e5c09SChris Mason 		for (i = slot; i < nritems; i++)
1094be0e5c09SChris Mason 			leaf->items[i].offset -= data_size;
1095be0e5c09SChris Mason 
1096be0e5c09SChris Mason 		/* shift the items */
1097be0e5c09SChris Mason 		memmove(leaf->items + slot + 1, leaf->items + slot,
1098be0e5c09SChris Mason 		        (nritems - slot) * sizeof(struct item));
1099be0e5c09SChris Mason 
1100be0e5c09SChris Mason 		/* shift the data */
1101be0e5c09SChris Mason 		memmove(leaf->data + data_end - data_size, leaf->data +
1102be0e5c09SChris Mason 		        data_end, old_data - data_end);
1103be0e5c09SChris Mason 		data_end = old_data;
1104be0e5c09SChris Mason 	}
110574123bd7SChris Mason 	/* copy the new data in */
1106be0e5c09SChris Mason 	memcpy(&leaf->items[slot].key, key, sizeof(struct key));
1107be0e5c09SChris Mason 	leaf->items[slot].offset = data_end - data_size;
1108be0e5c09SChris Mason 	leaf->items[slot].size = data_size;
1109be0e5c09SChris Mason 	memcpy(leaf->data + data_end - data_size, data, data_size);
1110be0e5c09SChris Mason 	leaf->header.nritems += 1;
1111aa5d6bedSChris Mason 
1112aa5d6bedSChris Mason 	ret = 0;
11138e19f2cdSChris Mason 	if (slot == 0)
1114aa5d6bedSChris Mason 		ret = fixup_low_keys(root, &path, key, 1);
1115aa5d6bedSChris Mason 
1116aa5d6bedSChris Mason 	wret = write_tree_block(root, leaf_buf);
1117aa5d6bedSChris Mason 	if (wret)
1118aa5d6bedSChris Mason 		ret = wret;
1119aa5d6bedSChris Mason 
1120be0e5c09SChris Mason 	if (leaf_free_space(leaf) < 0)
1121be0e5c09SChris Mason 		BUG();
1122bb803951SChris Mason 	check_leaf(&path, 0);
1123eb60ceacSChris Mason 	release_path(root, &path);
1124aa5d6bedSChris Mason 	return ret;
1125be0e5c09SChris Mason }
1126be0e5c09SChris Mason 
112774123bd7SChris Mason /*
11285de08d7dSChris Mason  * delete the pointer from a given node.
112974123bd7SChris Mason  *
113074123bd7SChris Mason  * If the delete empties a node, the node is removed from the tree,
113174123bd7SChris Mason  * continuing all the way the root if required.  The root is converted into
113274123bd7SChris Mason  * a leaf if all the nodes are emptied.
113374123bd7SChris Mason  */
1134bb803951SChris Mason static int del_ptr(struct ctree_root *root, struct ctree_path *path, int level,
1135bb803951SChris Mason 		   int slot)
1136be0e5c09SChris Mason {
1137be0e5c09SChris Mason 	struct node *node;
1138bb803951SChris Mason 	struct tree_buffer *parent = path->nodes[level];
1139be0e5c09SChris Mason 	int nritems;
1140aa5d6bedSChris Mason 	int ret = 0;
1141bb803951SChris Mason 	int wret;
1142be0e5c09SChris Mason 
1143bb803951SChris Mason 	node = &parent->node;
1144be0e5c09SChris Mason 	nritems = node->header.nritems;
1145be0e5c09SChris Mason 
1146be0e5c09SChris Mason 	if (slot != nritems -1) {
1147be0e5c09SChris Mason 		memmove(node->keys + slot, node->keys + slot + 1,
1148be0e5c09SChris Mason 			sizeof(struct key) * (nritems - slot - 1));
1149be0e5c09SChris Mason 		memmove(node->blockptrs + slot,
1150be0e5c09SChris Mason 			node->blockptrs + slot + 1,
1151be0e5c09SChris Mason 			sizeof(u64) * (nritems - slot - 1));
1152be0e5c09SChris Mason 	}
1153be0e5c09SChris Mason 	node->header.nritems--;
1154bb803951SChris Mason 	if (node->header.nritems == 0 && parent == root->node) {
1155bb803951SChris Mason 		BUG_ON(node_level(root->node->node.header.flags) != 1);
1156eb60ceacSChris Mason 		/* just turn the root into a leaf and break */
1157eb60ceacSChris Mason 		root->node->node.header.flags = node_level(0);
1158bb803951SChris Mason 	} else if (slot == 0) {
1159bb803951SChris Mason 		wret = fixup_low_keys(root, path, node->keys, level + 1);
11600f70abe2SChris Mason 		if (wret)
11610f70abe2SChris Mason 			ret = wret;
1162be0e5c09SChris Mason 	}
1163bb803951SChris Mason 	wret = write_tree_block(root, parent);
1164bb803951SChris Mason 	if (wret)
1165bb803951SChris Mason 		ret = wret;
1166aa5d6bedSChris Mason 	return ret;
1167be0e5c09SChris Mason }
1168be0e5c09SChris Mason 
116974123bd7SChris Mason /*
117074123bd7SChris Mason  * delete the item at the leaf level in path.  If that empties
117174123bd7SChris Mason  * the leaf, remove it from the tree
117274123bd7SChris Mason  */
11734920c9acSChris Mason int del_item(struct ctree_root *root, struct ctree_path *path)
1174be0e5c09SChris Mason {
1175be0e5c09SChris Mason 	int slot;
1176be0e5c09SChris Mason 	struct leaf *leaf;
1177eb60ceacSChris Mason 	struct tree_buffer *leaf_buf;
1178be0e5c09SChris Mason 	int doff;
1179be0e5c09SChris Mason 	int dsize;
1180aa5d6bedSChris Mason 	int ret = 0;
1181aa5d6bedSChris Mason 	int wret;
1182be0e5c09SChris Mason 
1183eb60ceacSChris Mason 	leaf_buf = path->nodes[0];
1184eb60ceacSChris Mason 	leaf = &leaf_buf->leaf;
11854920c9acSChris Mason 	slot = path->slots[0];
1186be0e5c09SChris Mason 	doff = leaf->items[slot].offset;
1187be0e5c09SChris Mason 	dsize = leaf->items[slot].size;
1188be0e5c09SChris Mason 
1189be0e5c09SChris Mason 	if (slot != leaf->header.nritems - 1) {
1190be0e5c09SChris Mason 		int i;
1191be0e5c09SChris Mason 		int data_end = leaf_data_end(leaf);
1192be0e5c09SChris Mason 		memmove(leaf->data + data_end + dsize,
1193be0e5c09SChris Mason 			leaf->data + data_end,
1194be0e5c09SChris Mason 			doff - data_end);
1195be0e5c09SChris Mason 		for (i = slot + 1; i < leaf->header.nritems; i++)
1196be0e5c09SChris Mason 			leaf->items[i].offset += dsize;
1197be0e5c09SChris Mason 		memmove(leaf->items + slot, leaf->items + slot + 1,
1198be0e5c09SChris Mason 			sizeof(struct item) *
1199be0e5c09SChris Mason 			(leaf->header.nritems - slot - 1));
1200be0e5c09SChris Mason 	}
1201be0e5c09SChris Mason 	leaf->header.nritems -= 1;
120274123bd7SChris Mason 	/* delete the leaf if we've emptied it */
1203be0e5c09SChris Mason 	if (leaf->header.nritems == 0) {
1204eb60ceacSChris Mason 		if (leaf_buf == root->node) {
1205eb60ceacSChris Mason 			leaf->header.flags = node_level(0);
1206eb60ceacSChris Mason 			write_tree_block(root, leaf_buf);
12079a8dd150SChris Mason 		} else {
1208bb803951SChris Mason 			wret = del_ptr(root, path, 1, path->slots[1]);
1209aa5d6bedSChris Mason 			if (wret)
1210aa5d6bedSChris Mason 				ret = wret;
12110f70abe2SChris Mason 			wret = free_extent(root, leaf_buf->blocknr, 1);
12120f70abe2SChris Mason 			if (wret)
12130f70abe2SChris Mason 				ret = wret;
12149a8dd150SChris Mason 		}
1215be0e5c09SChris Mason 	} else {
12165de08d7dSChris Mason 		int used = leaf_space_used(leaf, 0, leaf->header.nritems);
1217aa5d6bedSChris Mason 		if (slot == 0) {
1218aa5d6bedSChris Mason 			wret = fixup_low_keys(root, path,
1219aa5d6bedSChris Mason 						   &leaf->items[0].key, 1);
1220aa5d6bedSChris Mason 			if (wret)
1221aa5d6bedSChris Mason 				ret = wret;
1222aa5d6bedSChris Mason 		}
1223aa5d6bedSChris Mason 		wret = write_tree_block(root, leaf_buf);
1224aa5d6bedSChris Mason 		if (wret)
1225aa5d6bedSChris Mason 			ret = wret;
1226aa5d6bedSChris Mason 
122774123bd7SChris Mason 		/* delete the leaf if it is mostly empty */
12285de08d7dSChris Mason 		if (used < LEAF_DATA_SIZE / 3) {
1229be0e5c09SChris Mason 			/* push_leaf_left fixes the path.
1230be0e5c09SChris Mason 			 * make sure the path still points to our leaf
1231be0e5c09SChris Mason 			 * for possible call to del_ptr below
1232be0e5c09SChris Mason 			 */
12334920c9acSChris Mason 			slot = path->slots[1];
1234eb60ceacSChris Mason 			leaf_buf->count++;
1235aa5d6bedSChris Mason 			wret = push_leaf_left(root, path, 1);
1236aa5d6bedSChris Mason 			if (wret < 0)
1237aa5d6bedSChris Mason 				ret = wret;
1238aa5d6bedSChris Mason 			if (leaf->header.nritems) {
1239aa5d6bedSChris Mason 				wret = push_leaf_right(root, path, 1);
1240aa5d6bedSChris Mason 				if (wret < 0)
1241aa5d6bedSChris Mason 					ret = wret;
1242aa5d6bedSChris Mason 			}
1243be0e5c09SChris Mason 			if (leaf->header.nritems == 0) {
12445de08d7dSChris Mason 				u64 blocknr = leaf_buf->blocknr;
1245bb803951SChris Mason 				wret = del_ptr(root, path, 1, slot);
1246aa5d6bedSChris Mason 				if (wret)
1247aa5d6bedSChris Mason 					ret = wret;
12485de08d7dSChris Mason 				tree_block_release(root, leaf_buf);
12490f70abe2SChris Mason 				wret = free_extent(root, blocknr, 1);
12500f70abe2SChris Mason 				if (wret)
12510f70abe2SChris Mason 					ret = wret;
12525de08d7dSChris Mason 			} else {
1253eb60ceacSChris Mason 				tree_block_release(root, leaf_buf);
1254be0e5c09SChris Mason 			}
1255be0e5c09SChris Mason 		}
12569a8dd150SChris Mason 	}
1257aa5d6bedSChris Mason 	return ret;
12589a8dd150SChris Mason }
12599a8dd150SChris Mason 
126097571fd0SChris Mason /*
126197571fd0SChris Mason  * walk up the tree as far as required to find the next leaf.
12620f70abe2SChris Mason  * returns 0 if it found something or 1 if there are no greater leaves.
12630f70abe2SChris Mason  * returns < 0 on io errors.
126497571fd0SChris Mason  */
1265d97e63b6SChris Mason int next_leaf(struct ctree_root *root, struct ctree_path *path)
1266d97e63b6SChris Mason {
1267d97e63b6SChris Mason 	int slot;
1268d97e63b6SChris Mason 	int level = 1;
1269d97e63b6SChris Mason 	u64 blocknr;
1270d97e63b6SChris Mason 	struct tree_buffer *c;
1271cfaa7295SChris Mason 	struct tree_buffer *next = NULL;
1272d97e63b6SChris Mason 
1273d97e63b6SChris Mason 	while(level < MAX_LEVEL) {
1274d97e63b6SChris Mason 		if (!path->nodes[level])
12750f70abe2SChris Mason 			return 1;
1276d97e63b6SChris Mason 		slot = path->slots[level] + 1;
1277d97e63b6SChris Mason 		c = path->nodes[level];
1278d97e63b6SChris Mason 		if (slot >= c->node.header.nritems) {
1279d97e63b6SChris Mason 			level++;
1280d97e63b6SChris Mason 			continue;
1281d97e63b6SChris Mason 		}
1282d97e63b6SChris Mason 		blocknr = c->node.blockptrs[slot];
1283cfaa7295SChris Mason 		if (next)
1284cfaa7295SChris Mason 			tree_block_release(root, next);
1285d97e63b6SChris Mason 		next = read_tree_block(root, blocknr);
1286d97e63b6SChris Mason 		break;
1287d97e63b6SChris Mason 	}
1288d97e63b6SChris Mason 	path->slots[level] = slot;
1289d97e63b6SChris Mason 	while(1) {
1290d97e63b6SChris Mason 		level--;
1291d97e63b6SChris Mason 		c = path->nodes[level];
1292d97e63b6SChris Mason 		tree_block_release(root, c);
1293d97e63b6SChris Mason 		path->nodes[level] = next;
1294d97e63b6SChris Mason 		path->slots[level] = 0;
1295d97e63b6SChris Mason 		if (!level)
1296d97e63b6SChris Mason 			break;
1297d97e63b6SChris Mason 		next = read_tree_block(root, next->node.blockptrs[0]);
1298d97e63b6SChris Mason 	}
1299d97e63b6SChris Mason 	return 0;
1300d97e63b6SChris Mason }
1301d97e63b6SChris Mason 
1302