]> git.ipfire.org Git - people/ms/linux.git/blame - fs/btrfs/ctree.c
Importing "grsecurity-3.1-3.19.2-201503201903.patch"
[people/ms/linux.git] / fs / btrfs / ctree.c
CommitLineData
6cbd5570 1/*
d352ac68 2 * Copyright (C) 2007,2008 Oracle. All rights reserved.
6cbd5570
CM
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public
6 * License v2 as published by the Free Software Foundation.
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 * General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public
14 * License along with this program; if not, write to the
15 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
16 * Boston, MA 021110-1307, USA.
17 */
18
a6b6e75e 19#include <linux/sched.h>
5a0e3ad6 20#include <linux/slab.h>
bd989ba3 21#include <linux/rbtree.h>
eb60ceac
CM
22#include "ctree.h"
23#include "disk-io.h"
7f5c1516 24#include "transaction.h"
5f39d397 25#include "print-tree.h"
925baedd 26#include "locking.h"
9a8dd150 27
e089f05c
CM
28static int split_node(struct btrfs_trans_handle *trans, struct btrfs_root
29 *root, struct btrfs_path *path, int level);
30static int split_leaf(struct btrfs_trans_handle *trans, struct btrfs_root
d4dbff95 31 *root, struct btrfs_key *ins_key,
cc0c5538 32 struct btrfs_path *path, int data_size, int extend);
5f39d397
CM
33static int push_node_left(struct btrfs_trans_handle *trans,
34 struct btrfs_root *root, struct extent_buffer *dst,
971a1f66 35 struct extent_buffer *src, int empty);
5f39d397
CM
36static int balance_node_right(struct btrfs_trans_handle *trans,
37 struct btrfs_root *root,
38 struct extent_buffer *dst_buf,
39 struct extent_buffer *src_buf);
afe5fea7
TI
40static void del_ptr(struct btrfs_root *root, struct btrfs_path *path,
41 int level, int slot);
5de865ee 42static int tree_mod_log_free_eb(struct btrfs_fs_info *fs_info,
f230475e 43 struct extent_buffer *eb);
d97e63b6 44
df24a2b9 45struct btrfs_path *btrfs_alloc_path(void)
2c90e5d6 46{
df24a2b9 47 struct btrfs_path *path;
e00f7308 48 path = kmem_cache_zalloc(btrfs_path_cachep, GFP_NOFS);
df24a2b9 49 return path;
2c90e5d6
CM
50}
51
b4ce94de
CM
52/*
53 * set all locked nodes in the path to blocking locks. This should
54 * be done before scheduling
55 */
56noinline void btrfs_set_path_blocking(struct btrfs_path *p)
57{
58 int i;
59 for (i = 0; i < BTRFS_MAX_LEVEL; i++) {
bd681513
CM
60 if (!p->nodes[i] || !p->locks[i])
61 continue;
62 btrfs_set_lock_blocking_rw(p->nodes[i], p->locks[i]);
63 if (p->locks[i] == BTRFS_READ_LOCK)
64 p->locks[i] = BTRFS_READ_LOCK_BLOCKING;
65 else if (p->locks[i] == BTRFS_WRITE_LOCK)
66 p->locks[i] = BTRFS_WRITE_LOCK_BLOCKING;
b4ce94de
CM
67 }
68}
69
70/*
71 * reset all the locked nodes in the patch to spinning locks.
4008c04a
CM
72 *
73 * held is used to keep lockdep happy, when lockdep is enabled
74 * we set held to a blocking lock before we go around and
75 * retake all the spinlocks in the path. You can safely use NULL
76 * for held
b4ce94de 77 */
4008c04a 78noinline void btrfs_clear_path_blocking(struct btrfs_path *p,
bd681513 79 struct extent_buffer *held, int held_rw)
b4ce94de
CM
80{
81 int i;
4008c04a 82
bd681513
CM
83 if (held) {
84 btrfs_set_lock_blocking_rw(held, held_rw);
85 if (held_rw == BTRFS_WRITE_LOCK)
86 held_rw = BTRFS_WRITE_LOCK_BLOCKING;
87 else if (held_rw == BTRFS_READ_LOCK)
88 held_rw = BTRFS_READ_LOCK_BLOCKING;
89 }
4008c04a 90 btrfs_set_path_blocking(p);
4008c04a
CM
91
92 for (i = BTRFS_MAX_LEVEL - 1; i >= 0; i--) {
bd681513
CM
93 if (p->nodes[i] && p->locks[i]) {
94 btrfs_clear_lock_blocking_rw(p->nodes[i], p->locks[i]);
95 if (p->locks[i] == BTRFS_WRITE_LOCK_BLOCKING)
96 p->locks[i] = BTRFS_WRITE_LOCK;
97 else if (p->locks[i] == BTRFS_READ_LOCK_BLOCKING)
98 p->locks[i] = BTRFS_READ_LOCK;
99 }
b4ce94de 100 }
4008c04a 101
4008c04a 102 if (held)
bd681513 103 btrfs_clear_lock_blocking_rw(held, held_rw);
b4ce94de
CM
104}
105
d352ac68 106/* this also releases the path */
df24a2b9 107void btrfs_free_path(struct btrfs_path *p)
be0e5c09 108{
ff175d57
JJ
109 if (!p)
110 return;
b3b4aa74 111 btrfs_release_path(p);
df24a2b9 112 kmem_cache_free(btrfs_path_cachep, p);
be0e5c09
CM
113}
114
d352ac68
CM
115/*
116 * path release drops references on the extent buffers in the path
117 * and it drops any locks held by this path
118 *
119 * It is safe to call this on paths that no locks or extent buffers held.
120 */
b3b4aa74 121noinline void btrfs_release_path(struct btrfs_path *p)
eb60ceac
CM
122{
123 int i;
a2135011 124
234b63a0 125 for (i = 0; i < BTRFS_MAX_LEVEL; i++) {
3f157a2f 126 p->slots[i] = 0;
eb60ceac 127 if (!p->nodes[i])
925baedd
CM
128 continue;
129 if (p->locks[i]) {
bd681513 130 btrfs_tree_unlock_rw(p->nodes[i], p->locks[i]);
925baedd
CM
131 p->locks[i] = 0;
132 }
5f39d397 133 free_extent_buffer(p->nodes[i]);
3f157a2f 134 p->nodes[i] = NULL;
eb60ceac
CM
135 }
136}
137
d352ac68
CM
138/*
139 * safely gets a reference on the root node of a tree. A lock
140 * is not taken, so a concurrent writer may put a different node
141 * at the root of the tree. See btrfs_lock_root_node for the
142 * looping required.
143 *
144 * The extent buffer returned by this has a reference taken, so
145 * it won't disappear. It may stop being the root of the tree
146 * at any time because there are no locks held.
147 */
925baedd
CM
148struct extent_buffer *btrfs_root_node(struct btrfs_root *root)
149{
150 struct extent_buffer *eb;
240f62c8 151
3083ee2e
JB
152 while (1) {
153 rcu_read_lock();
154 eb = rcu_dereference(root->node);
155
156 /*
157 * RCU really hurts here, we could free up the root node because
158 * it was cow'ed but we may not get the new root node yet so do
159 * the inc_not_zero dance and if it doesn't work then
160 * synchronize_rcu and try again.
161 */
162 if (atomic_inc_not_zero(&eb->refs)) {
163 rcu_read_unlock();
164 break;
165 }
166 rcu_read_unlock();
167 synchronize_rcu();
168 }
925baedd
CM
169 return eb;
170}
171
d352ac68
CM
172/* loop around taking references on and locking the root node of the
173 * tree until you end up with a lock on the root. A locked buffer
174 * is returned, with a reference held.
175 */
925baedd
CM
176struct extent_buffer *btrfs_lock_root_node(struct btrfs_root *root)
177{
178 struct extent_buffer *eb;
179
d397712b 180 while (1) {
925baedd
CM
181 eb = btrfs_root_node(root);
182 btrfs_tree_lock(eb);
240f62c8 183 if (eb == root->node)
925baedd 184 break;
925baedd
CM
185 btrfs_tree_unlock(eb);
186 free_extent_buffer(eb);
187 }
188 return eb;
189}
190
bd681513
CM
191/* loop around taking references on and locking the root node of the
192 * tree until you end up with a lock on the root. A locked buffer
193 * is returned, with a reference held.
194 */
48a3b636 195static struct extent_buffer *btrfs_read_lock_root_node(struct btrfs_root *root)
bd681513
CM
196{
197 struct extent_buffer *eb;
198
199 while (1) {
200 eb = btrfs_root_node(root);
201 btrfs_tree_read_lock(eb);
202 if (eb == root->node)
203 break;
204 btrfs_tree_read_unlock(eb);
205 free_extent_buffer(eb);
206 }
207 return eb;
208}
209
d352ac68
CM
210/* cowonly root (everything not a reference counted cow subvolume), just get
211 * put onto a simple dirty list. transaction.c walks this to make sure they
212 * get properly updated on disk.
213 */
0b86a832
CM
214static void add_root_to_dirty_list(struct btrfs_root *root)
215{
e5846fc6 216 spin_lock(&root->fs_info->trans_lock);
27cdeb70
MX
217 if (test_bit(BTRFS_ROOT_TRACK_DIRTY, &root->state) &&
218 list_empty(&root->dirty_list)) {
0b86a832
CM
219 list_add(&root->dirty_list,
220 &root->fs_info->dirty_cowonly_roots);
221 }
e5846fc6 222 spin_unlock(&root->fs_info->trans_lock);
0b86a832
CM
223}
224
d352ac68
CM
225/*
226 * used by snapshot creation to make a copy of a root for a tree with
227 * a given objectid. The buffer with the new root node is returned in
228 * cow_ret, and this func returns zero on success or a negative error code.
229 */
be20aa9d
CM
230int btrfs_copy_root(struct btrfs_trans_handle *trans,
231 struct btrfs_root *root,
232 struct extent_buffer *buf,
233 struct extent_buffer **cow_ret, u64 new_root_objectid)
234{
235 struct extent_buffer *cow;
be20aa9d
CM
236 int ret = 0;
237 int level;
5d4f98a2 238 struct btrfs_disk_key disk_key;
be20aa9d 239
27cdeb70
MX
240 WARN_ON(test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
241 trans->transid != root->fs_info->running_transaction->transid);
242 WARN_ON(test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
243 trans->transid != root->last_trans);
be20aa9d
CM
244
245 level = btrfs_header_level(buf);
5d4f98a2
YZ
246 if (level == 0)
247 btrfs_item_key(buf, &disk_key, 0);
248 else
249 btrfs_node_key(buf, &disk_key, 0);
31840ae1 250
4d75f8a9
DS
251 cow = btrfs_alloc_tree_block(trans, root, 0, new_root_objectid,
252 &disk_key, level, buf->start, 0);
5d4f98a2 253 if (IS_ERR(cow))
be20aa9d
CM
254 return PTR_ERR(cow);
255
256 copy_extent_buffer(cow, buf, 0, 0, cow->len);
257 btrfs_set_header_bytenr(cow, cow->start);
258 btrfs_set_header_generation(cow, trans->transid);
5d4f98a2
YZ
259 btrfs_set_header_backref_rev(cow, BTRFS_MIXED_BACKREF_REV);
260 btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN |
261 BTRFS_HEADER_FLAG_RELOC);
262 if (new_root_objectid == BTRFS_TREE_RELOC_OBJECTID)
263 btrfs_set_header_flag(cow, BTRFS_HEADER_FLAG_RELOC);
264 else
265 btrfs_set_header_owner(cow, new_root_objectid);
be20aa9d 266
0a4e5586 267 write_extent_buffer(cow, root->fs_info->fsid, btrfs_header_fsid(),
2b82032c
YZ
268 BTRFS_FSID_SIZE);
269
be20aa9d 270 WARN_ON(btrfs_header_generation(buf) > trans->transid);
5d4f98a2 271 if (new_root_objectid == BTRFS_TREE_RELOC_OBJECTID)
e339a6b0 272 ret = btrfs_inc_ref(trans, root, cow, 1);
5d4f98a2 273 else
e339a6b0 274 ret = btrfs_inc_ref(trans, root, cow, 0);
4aec2b52 275
be20aa9d
CM
276 if (ret)
277 return ret;
278
279 btrfs_mark_buffer_dirty(cow);
280 *cow_ret = cow;
281 return 0;
282}
283
bd989ba3
JS
284enum mod_log_op {
285 MOD_LOG_KEY_REPLACE,
286 MOD_LOG_KEY_ADD,
287 MOD_LOG_KEY_REMOVE,
288 MOD_LOG_KEY_REMOVE_WHILE_FREEING,
289 MOD_LOG_KEY_REMOVE_WHILE_MOVING,
290 MOD_LOG_MOVE_KEYS,
291 MOD_LOG_ROOT_REPLACE,
292};
293
294struct tree_mod_move {
295 int dst_slot;
296 int nr_items;
297};
298
299struct tree_mod_root {
300 u64 logical;
301 u8 level;
302};
303
304struct tree_mod_elem {
305 struct rb_node node;
306 u64 index; /* shifted logical */
097b8a7c 307 u64 seq;
bd989ba3
JS
308 enum mod_log_op op;
309
310 /* this is used for MOD_LOG_KEY_* and MOD_LOG_MOVE_KEYS operations */
311 int slot;
312
313 /* this is used for MOD_LOG_KEY* and MOD_LOG_ROOT_REPLACE */
314 u64 generation;
315
316 /* those are used for op == MOD_LOG_KEY_{REPLACE,REMOVE} */
317 struct btrfs_disk_key key;
318 u64 blockptr;
319
320 /* this is used for op == MOD_LOG_MOVE_KEYS */
321 struct tree_mod_move move;
322
323 /* this is used for op == MOD_LOG_ROOT_REPLACE */
324 struct tree_mod_root old_root;
325};
326
097b8a7c 327static inline void tree_mod_log_read_lock(struct btrfs_fs_info *fs_info)
bd989ba3 328{
097b8a7c 329 read_lock(&fs_info->tree_mod_log_lock);
bd989ba3
JS
330}
331
097b8a7c
JS
332static inline void tree_mod_log_read_unlock(struct btrfs_fs_info *fs_info)
333{
334 read_unlock(&fs_info->tree_mod_log_lock);
335}
336
337static inline void tree_mod_log_write_lock(struct btrfs_fs_info *fs_info)
338{
339 write_lock(&fs_info->tree_mod_log_lock);
340}
341
342static inline void tree_mod_log_write_unlock(struct btrfs_fs_info *fs_info)
343{
344 write_unlock(&fs_info->tree_mod_log_lock);
345}
346
fc36ed7e 347/*
fcebe456 348 * Pull a new tree mod seq number for our operation.
fc36ed7e 349 */
fcebe456 350static inline u64 btrfs_inc_tree_mod_seq(struct btrfs_fs_info *fs_info)
fc36ed7e
JS
351{
352 return atomic64_inc_return(&fs_info->tree_mod_seq);
353}
354
097b8a7c
JS
355/*
356 * This adds a new blocker to the tree mod log's blocker list if the @elem
357 * passed does not already have a sequence number set. So when a caller expects
358 * to record tree modifications, it should ensure to set elem->seq to zero
359 * before calling btrfs_get_tree_mod_seq.
360 * Returns a fresh, unused tree log modification sequence number, even if no new
361 * blocker was added.
362 */
363u64 btrfs_get_tree_mod_seq(struct btrfs_fs_info *fs_info,
364 struct seq_list *elem)
bd989ba3 365{
097b8a7c 366 tree_mod_log_write_lock(fs_info);
bd989ba3 367 spin_lock(&fs_info->tree_mod_seq_lock);
097b8a7c 368 if (!elem->seq) {
fcebe456 369 elem->seq = btrfs_inc_tree_mod_seq(fs_info);
097b8a7c
JS
370 list_add_tail(&elem->list, &fs_info->tree_mod_seq_list);
371 }
bd989ba3 372 spin_unlock(&fs_info->tree_mod_seq_lock);
097b8a7c
JS
373 tree_mod_log_write_unlock(fs_info);
374
fcebe456 375 return elem->seq;
bd989ba3
JS
376}
377
378void btrfs_put_tree_mod_seq(struct btrfs_fs_info *fs_info,
379 struct seq_list *elem)
380{
381 struct rb_root *tm_root;
382 struct rb_node *node;
383 struct rb_node *next;
384 struct seq_list *cur_elem;
385 struct tree_mod_elem *tm;
386 u64 min_seq = (u64)-1;
387 u64 seq_putting = elem->seq;
388
389 if (!seq_putting)
390 return;
391
bd989ba3
JS
392 spin_lock(&fs_info->tree_mod_seq_lock);
393 list_del(&elem->list);
097b8a7c 394 elem->seq = 0;
bd989ba3
JS
395
396 list_for_each_entry(cur_elem, &fs_info->tree_mod_seq_list, list) {
097b8a7c 397 if (cur_elem->seq < min_seq) {
bd989ba3
JS
398 if (seq_putting > cur_elem->seq) {
399 /*
400 * blocker with lower sequence number exists, we
401 * cannot remove anything from the log
402 */
097b8a7c
JS
403 spin_unlock(&fs_info->tree_mod_seq_lock);
404 return;
bd989ba3
JS
405 }
406 min_seq = cur_elem->seq;
407 }
408 }
097b8a7c
JS
409 spin_unlock(&fs_info->tree_mod_seq_lock);
410
bd989ba3
JS
411 /*
412 * anything that's lower than the lowest existing (read: blocked)
413 * sequence number can be removed from the tree.
414 */
097b8a7c 415 tree_mod_log_write_lock(fs_info);
bd989ba3
JS
416 tm_root = &fs_info->tree_mod_log;
417 for (node = rb_first(tm_root); node; node = next) {
418 next = rb_next(node);
419 tm = container_of(node, struct tree_mod_elem, node);
097b8a7c 420 if (tm->seq > min_seq)
bd989ba3
JS
421 continue;
422 rb_erase(node, tm_root);
bd989ba3
JS
423 kfree(tm);
424 }
097b8a7c 425 tree_mod_log_write_unlock(fs_info);
bd989ba3
JS
426}
427
428/*
429 * key order of the log:
430 * index -> sequence
431 *
432 * the index is the shifted logical of the *new* root node for root replace
433 * operations, or the shifted logical of the affected block for all other
434 * operations.
5de865ee
FDBM
435 *
436 * Note: must be called with write lock (tree_mod_log_write_lock).
bd989ba3
JS
437 */
438static noinline int
439__tree_mod_log_insert(struct btrfs_fs_info *fs_info, struct tree_mod_elem *tm)
440{
441 struct rb_root *tm_root;
442 struct rb_node **new;
443 struct rb_node *parent = NULL;
444 struct tree_mod_elem *cur;
c8cc6341
JB
445
446 BUG_ON(!tm);
447
fcebe456 448 tm->seq = btrfs_inc_tree_mod_seq(fs_info);
bd989ba3 449
bd989ba3
JS
450 tm_root = &fs_info->tree_mod_log;
451 new = &tm_root->rb_node;
452 while (*new) {
453 cur = container_of(*new, struct tree_mod_elem, node);
454 parent = *new;
455 if (cur->index < tm->index)
456 new = &((*new)->rb_left);
457 else if (cur->index > tm->index)
458 new = &((*new)->rb_right);
097b8a7c 459 else if (cur->seq < tm->seq)
bd989ba3 460 new = &((*new)->rb_left);
097b8a7c 461 else if (cur->seq > tm->seq)
bd989ba3 462 new = &((*new)->rb_right);
5de865ee
FDBM
463 else
464 return -EEXIST;
bd989ba3
JS
465 }
466
467 rb_link_node(&tm->node, parent, new);
468 rb_insert_color(&tm->node, tm_root);
5de865ee 469 return 0;
bd989ba3
JS
470}
471
097b8a7c
JS
472/*
473 * Determines if logging can be omitted. Returns 1 if it can. Otherwise, it
474 * returns zero with the tree_mod_log_lock acquired. The caller must hold
475 * this until all tree mod log insertions are recorded in the rb tree and then
476 * call tree_mod_log_write_unlock() to release.
477 */
e9b7fd4d
JS
478static inline int tree_mod_dont_log(struct btrfs_fs_info *fs_info,
479 struct extent_buffer *eb) {
480 smp_mb();
481 if (list_empty(&(fs_info)->tree_mod_seq_list))
482 return 1;
097b8a7c
JS
483 if (eb && btrfs_header_level(eb) == 0)
484 return 1;
5de865ee
FDBM
485
486 tree_mod_log_write_lock(fs_info);
487 if (list_empty(&(fs_info)->tree_mod_seq_list)) {
488 tree_mod_log_write_unlock(fs_info);
489 return 1;
490 }
491
e9b7fd4d
JS
492 return 0;
493}
494
5de865ee
FDBM
495/* Similar to tree_mod_dont_log, but doesn't acquire any locks. */
496static inline int tree_mod_need_log(const struct btrfs_fs_info *fs_info,
497 struct extent_buffer *eb)
498{
499 smp_mb();
500 if (list_empty(&(fs_info)->tree_mod_seq_list))
501 return 0;
502 if (eb && btrfs_header_level(eb) == 0)
503 return 0;
504
505 return 1;
506}
507
508static struct tree_mod_elem *
509alloc_tree_mod_elem(struct extent_buffer *eb, int slot,
510 enum mod_log_op op, gfp_t flags)
bd989ba3 511{
097b8a7c 512 struct tree_mod_elem *tm;
bd989ba3 513
c8cc6341
JB
514 tm = kzalloc(sizeof(*tm), flags);
515 if (!tm)
5de865ee 516 return NULL;
bd989ba3
JS
517
518 tm->index = eb->start >> PAGE_CACHE_SHIFT;
519 if (op != MOD_LOG_KEY_ADD) {
520 btrfs_node_key(eb, &tm->key, slot);
521 tm->blockptr = btrfs_node_blockptr(eb, slot);
522 }
523 tm->op = op;
524 tm->slot = slot;
525 tm->generation = btrfs_node_ptr_generation(eb, slot);
5de865ee 526 RB_CLEAR_NODE(&tm->node);
bd989ba3 527
5de865ee 528 return tm;
097b8a7c
JS
529}
530
531static noinline int
c8cc6341
JB
532tree_mod_log_insert_key(struct btrfs_fs_info *fs_info,
533 struct extent_buffer *eb, int slot,
534 enum mod_log_op op, gfp_t flags)
097b8a7c 535{
5de865ee
FDBM
536 struct tree_mod_elem *tm;
537 int ret;
538
539 if (!tree_mod_need_log(fs_info, eb))
540 return 0;
541
542 tm = alloc_tree_mod_elem(eb, slot, op, flags);
543 if (!tm)
544 return -ENOMEM;
545
546 if (tree_mod_dont_log(fs_info, eb)) {
547 kfree(tm);
097b8a7c 548 return 0;
5de865ee
FDBM
549 }
550
551 ret = __tree_mod_log_insert(fs_info, tm);
552 tree_mod_log_write_unlock(fs_info);
553 if (ret)
554 kfree(tm);
097b8a7c 555
5de865ee 556 return ret;
097b8a7c
JS
557}
558
bd989ba3
JS
559static noinline int
560tree_mod_log_insert_move(struct btrfs_fs_info *fs_info,
561 struct extent_buffer *eb, int dst_slot, int src_slot,
562 int nr_items, gfp_t flags)
563{
5de865ee
FDBM
564 struct tree_mod_elem *tm = NULL;
565 struct tree_mod_elem **tm_list = NULL;
566 int ret = 0;
bd989ba3 567 int i;
5de865ee 568 int locked = 0;
bd989ba3 569
5de865ee 570 if (!tree_mod_need_log(fs_info, eb))
f395694c 571 return 0;
bd989ba3 572
5de865ee
FDBM
573 tm_list = kzalloc(nr_items * sizeof(struct tree_mod_elem *), flags);
574 if (!tm_list)
575 return -ENOMEM;
576
577 tm = kzalloc(sizeof(*tm), flags);
578 if (!tm) {
579 ret = -ENOMEM;
580 goto free_tms;
581 }
582
583 tm->index = eb->start >> PAGE_CACHE_SHIFT;
584 tm->slot = src_slot;
585 tm->move.dst_slot = dst_slot;
586 tm->move.nr_items = nr_items;
587 tm->op = MOD_LOG_MOVE_KEYS;
588
589 for (i = 0; i + dst_slot < src_slot && i < nr_items; i++) {
590 tm_list[i] = alloc_tree_mod_elem(eb, i + dst_slot,
591 MOD_LOG_KEY_REMOVE_WHILE_MOVING, flags);
592 if (!tm_list[i]) {
593 ret = -ENOMEM;
594 goto free_tms;
595 }
596 }
597
598 if (tree_mod_dont_log(fs_info, eb))
599 goto free_tms;
600 locked = 1;
601
01763a2e
JS
602 /*
603 * When we override something during the move, we log these removals.
604 * This can only happen when we move towards the beginning of the
605 * buffer, i.e. dst_slot < src_slot.
606 */
bd989ba3 607 for (i = 0; i + dst_slot < src_slot && i < nr_items; i++) {
5de865ee
FDBM
608 ret = __tree_mod_log_insert(fs_info, tm_list[i]);
609 if (ret)
610 goto free_tms;
bd989ba3
JS
611 }
612
5de865ee
FDBM
613 ret = __tree_mod_log_insert(fs_info, tm);
614 if (ret)
615 goto free_tms;
616 tree_mod_log_write_unlock(fs_info);
617 kfree(tm_list);
f395694c 618
5de865ee
FDBM
619 return 0;
620free_tms:
621 for (i = 0; i < nr_items; i++) {
622 if (tm_list[i] && !RB_EMPTY_NODE(&tm_list[i]->node))
623 rb_erase(&tm_list[i]->node, &fs_info->tree_mod_log);
624 kfree(tm_list[i]);
625 }
626 if (locked)
627 tree_mod_log_write_unlock(fs_info);
628 kfree(tm_list);
629 kfree(tm);
bd989ba3 630
5de865ee 631 return ret;
bd989ba3
JS
632}
633
5de865ee
FDBM
634static inline int
635__tree_mod_log_free_eb(struct btrfs_fs_info *fs_info,
636 struct tree_mod_elem **tm_list,
637 int nritems)
097b8a7c 638{
5de865ee 639 int i, j;
097b8a7c
JS
640 int ret;
641
097b8a7c 642 for (i = nritems - 1; i >= 0; i--) {
5de865ee
FDBM
643 ret = __tree_mod_log_insert(fs_info, tm_list[i]);
644 if (ret) {
645 for (j = nritems - 1; j > i; j--)
646 rb_erase(&tm_list[j]->node,
647 &fs_info->tree_mod_log);
648 return ret;
649 }
097b8a7c 650 }
5de865ee
FDBM
651
652 return 0;
097b8a7c
JS
653}
654
bd989ba3
JS
655static noinline int
656tree_mod_log_insert_root(struct btrfs_fs_info *fs_info,
657 struct extent_buffer *old_root,
90f8d62e
JS
658 struct extent_buffer *new_root, gfp_t flags,
659 int log_removal)
bd989ba3 660{
5de865ee
FDBM
661 struct tree_mod_elem *tm = NULL;
662 struct tree_mod_elem **tm_list = NULL;
663 int nritems = 0;
664 int ret = 0;
665 int i;
bd989ba3 666
5de865ee 667 if (!tree_mod_need_log(fs_info, NULL))
097b8a7c
JS
668 return 0;
669
5de865ee
FDBM
670 if (log_removal && btrfs_header_level(old_root) > 0) {
671 nritems = btrfs_header_nritems(old_root);
672 tm_list = kzalloc(nritems * sizeof(struct tree_mod_elem *),
673 flags);
674 if (!tm_list) {
675 ret = -ENOMEM;
676 goto free_tms;
677 }
678 for (i = 0; i < nritems; i++) {
679 tm_list[i] = alloc_tree_mod_elem(old_root, i,
680 MOD_LOG_KEY_REMOVE_WHILE_FREEING, flags);
681 if (!tm_list[i]) {
682 ret = -ENOMEM;
683 goto free_tms;
684 }
685 }
686 }
d9abbf1c 687
c8cc6341 688 tm = kzalloc(sizeof(*tm), flags);
5de865ee
FDBM
689 if (!tm) {
690 ret = -ENOMEM;
691 goto free_tms;
692 }
bd989ba3
JS
693
694 tm->index = new_root->start >> PAGE_CACHE_SHIFT;
695 tm->old_root.logical = old_root->start;
696 tm->old_root.level = btrfs_header_level(old_root);
697 tm->generation = btrfs_header_generation(old_root);
698 tm->op = MOD_LOG_ROOT_REPLACE;
699
5de865ee
FDBM
700 if (tree_mod_dont_log(fs_info, NULL))
701 goto free_tms;
702
703 if (tm_list)
704 ret = __tree_mod_log_free_eb(fs_info, tm_list, nritems);
705 if (!ret)
706 ret = __tree_mod_log_insert(fs_info, tm);
707
708 tree_mod_log_write_unlock(fs_info);
709 if (ret)
710 goto free_tms;
711 kfree(tm_list);
712
713 return ret;
714
715free_tms:
716 if (tm_list) {
717 for (i = 0; i < nritems; i++)
718 kfree(tm_list[i]);
719 kfree(tm_list);
720 }
721 kfree(tm);
722
723 return ret;
bd989ba3
JS
724}
725
726static struct tree_mod_elem *
727__tree_mod_log_search(struct btrfs_fs_info *fs_info, u64 start, u64 min_seq,
728 int smallest)
729{
730 struct rb_root *tm_root;
731 struct rb_node *node;
732 struct tree_mod_elem *cur = NULL;
733 struct tree_mod_elem *found = NULL;
734 u64 index = start >> PAGE_CACHE_SHIFT;
735
097b8a7c 736 tree_mod_log_read_lock(fs_info);
bd989ba3
JS
737 tm_root = &fs_info->tree_mod_log;
738 node = tm_root->rb_node;
739 while (node) {
740 cur = container_of(node, struct tree_mod_elem, node);
741 if (cur->index < index) {
742 node = node->rb_left;
743 } else if (cur->index > index) {
744 node = node->rb_right;
097b8a7c 745 } else if (cur->seq < min_seq) {
bd989ba3
JS
746 node = node->rb_left;
747 } else if (!smallest) {
748 /* we want the node with the highest seq */
749 if (found)
097b8a7c 750 BUG_ON(found->seq > cur->seq);
bd989ba3
JS
751 found = cur;
752 node = node->rb_left;
097b8a7c 753 } else if (cur->seq > min_seq) {
bd989ba3
JS
754 /* we want the node with the smallest seq */
755 if (found)
097b8a7c 756 BUG_ON(found->seq < cur->seq);
bd989ba3
JS
757 found = cur;
758 node = node->rb_right;
759 } else {
760 found = cur;
761 break;
762 }
763 }
097b8a7c 764 tree_mod_log_read_unlock(fs_info);
bd989ba3
JS
765
766 return found;
767}
768
769/*
770 * this returns the element from the log with the smallest time sequence
771 * value that's in the log (the oldest log item). any element with a time
772 * sequence lower than min_seq will be ignored.
773 */
774static struct tree_mod_elem *
775tree_mod_log_search_oldest(struct btrfs_fs_info *fs_info, u64 start,
776 u64 min_seq)
777{
778 return __tree_mod_log_search(fs_info, start, min_seq, 1);
779}
780
781/*
782 * this returns the element from the log with the largest time sequence
783 * value that's in the log (the most recent log item). any element with
784 * a time sequence lower than min_seq will be ignored.
785 */
786static struct tree_mod_elem *
787tree_mod_log_search(struct btrfs_fs_info *fs_info, u64 start, u64 min_seq)
788{
789 return __tree_mod_log_search(fs_info, start, min_seq, 0);
790}
791
5de865ee 792static noinline int
bd989ba3
JS
793tree_mod_log_eb_copy(struct btrfs_fs_info *fs_info, struct extent_buffer *dst,
794 struct extent_buffer *src, unsigned long dst_offset,
90f8d62e 795 unsigned long src_offset, int nr_items)
bd989ba3 796{
5de865ee
FDBM
797 int ret = 0;
798 struct tree_mod_elem **tm_list = NULL;
799 struct tree_mod_elem **tm_list_add, **tm_list_rem;
bd989ba3 800 int i;
5de865ee 801 int locked = 0;
bd989ba3 802
5de865ee
FDBM
803 if (!tree_mod_need_log(fs_info, NULL))
804 return 0;
bd989ba3 805
c8cc6341 806 if (btrfs_header_level(dst) == 0 && btrfs_header_level(src) == 0)
5de865ee
FDBM
807 return 0;
808
809 tm_list = kzalloc(nr_items * 2 * sizeof(struct tree_mod_elem *),
810 GFP_NOFS);
811 if (!tm_list)
812 return -ENOMEM;
bd989ba3 813
5de865ee
FDBM
814 tm_list_add = tm_list;
815 tm_list_rem = tm_list + nr_items;
bd989ba3 816 for (i = 0; i < nr_items; i++) {
5de865ee
FDBM
817 tm_list_rem[i] = alloc_tree_mod_elem(src, i + src_offset,
818 MOD_LOG_KEY_REMOVE, GFP_NOFS);
819 if (!tm_list_rem[i]) {
820 ret = -ENOMEM;
821 goto free_tms;
822 }
823
824 tm_list_add[i] = alloc_tree_mod_elem(dst, i + dst_offset,
825 MOD_LOG_KEY_ADD, GFP_NOFS);
826 if (!tm_list_add[i]) {
827 ret = -ENOMEM;
828 goto free_tms;
829 }
830 }
831
832 if (tree_mod_dont_log(fs_info, NULL))
833 goto free_tms;
834 locked = 1;
835
836 for (i = 0; i < nr_items; i++) {
837 ret = __tree_mod_log_insert(fs_info, tm_list_rem[i]);
838 if (ret)
839 goto free_tms;
840 ret = __tree_mod_log_insert(fs_info, tm_list_add[i]);
841 if (ret)
842 goto free_tms;
bd989ba3 843 }
5de865ee
FDBM
844
845 tree_mod_log_write_unlock(fs_info);
846 kfree(tm_list);
847
848 return 0;
849
850free_tms:
851 for (i = 0; i < nr_items * 2; i++) {
852 if (tm_list[i] && !RB_EMPTY_NODE(&tm_list[i]->node))
853 rb_erase(&tm_list[i]->node, &fs_info->tree_mod_log);
854 kfree(tm_list[i]);
855 }
856 if (locked)
857 tree_mod_log_write_unlock(fs_info);
858 kfree(tm_list);
859
860 return ret;
bd989ba3
JS
861}
862
863static inline void
864tree_mod_log_eb_move(struct btrfs_fs_info *fs_info, struct extent_buffer *dst,
865 int dst_offset, int src_offset, int nr_items)
866{
867 int ret;
868 ret = tree_mod_log_insert_move(fs_info, dst, dst_offset, src_offset,
869 nr_items, GFP_NOFS);
870 BUG_ON(ret < 0);
871}
872
097b8a7c 873static noinline void
bd989ba3 874tree_mod_log_set_node_key(struct btrfs_fs_info *fs_info,
32adf090 875 struct extent_buffer *eb, int slot, int atomic)
bd989ba3
JS
876{
877 int ret;
878
78357766 879 ret = tree_mod_log_insert_key(fs_info, eb, slot,
c8cc6341
JB
880 MOD_LOG_KEY_REPLACE,
881 atomic ? GFP_ATOMIC : GFP_NOFS);
bd989ba3
JS
882 BUG_ON(ret < 0);
883}
884
5de865ee 885static noinline int
097b8a7c 886tree_mod_log_free_eb(struct btrfs_fs_info *fs_info, struct extent_buffer *eb)
bd989ba3 887{
5de865ee
FDBM
888 struct tree_mod_elem **tm_list = NULL;
889 int nritems = 0;
890 int i;
891 int ret = 0;
892
893 if (btrfs_header_level(eb) == 0)
894 return 0;
895
896 if (!tree_mod_need_log(fs_info, NULL))
897 return 0;
898
899 nritems = btrfs_header_nritems(eb);
900 tm_list = kzalloc(nritems * sizeof(struct tree_mod_elem *),
901 GFP_NOFS);
902 if (!tm_list)
903 return -ENOMEM;
904
905 for (i = 0; i < nritems; i++) {
906 tm_list[i] = alloc_tree_mod_elem(eb, i,
907 MOD_LOG_KEY_REMOVE_WHILE_FREEING, GFP_NOFS);
908 if (!tm_list[i]) {
909 ret = -ENOMEM;
910 goto free_tms;
911 }
912 }
913
e9b7fd4d 914 if (tree_mod_dont_log(fs_info, eb))
5de865ee
FDBM
915 goto free_tms;
916
917 ret = __tree_mod_log_free_eb(fs_info, tm_list, nritems);
918 tree_mod_log_write_unlock(fs_info);
919 if (ret)
920 goto free_tms;
921 kfree(tm_list);
922
923 return 0;
924
925free_tms:
926 for (i = 0; i < nritems; i++)
927 kfree(tm_list[i]);
928 kfree(tm_list);
929
930 return ret;
bd989ba3
JS
931}
932
097b8a7c 933static noinline void
bd989ba3 934tree_mod_log_set_root_pointer(struct btrfs_root *root,
90f8d62e
JS
935 struct extent_buffer *new_root_node,
936 int log_removal)
bd989ba3
JS
937{
938 int ret;
bd989ba3 939 ret = tree_mod_log_insert_root(root->fs_info, root->node,
90f8d62e 940 new_root_node, GFP_NOFS, log_removal);
bd989ba3
JS
941 BUG_ON(ret < 0);
942}
943
5d4f98a2
YZ
944/*
945 * check if the tree block can be shared by multiple trees
946 */
947int btrfs_block_can_be_shared(struct btrfs_root *root,
948 struct extent_buffer *buf)
949{
950 /*
951 * Tree blocks not in refernece counted trees and tree roots
952 * are never shared. If a block was allocated after the last
953 * snapshot and the block was not allocated by tree relocation,
954 * we know the block is not shared.
955 */
27cdeb70 956 if (test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
5d4f98a2
YZ
957 buf != root->node && buf != root->commit_root &&
958 (btrfs_header_generation(buf) <=
959 btrfs_root_last_snapshot(&root->root_item) ||
960 btrfs_header_flag(buf, BTRFS_HEADER_FLAG_RELOC)))
961 return 1;
962#ifdef BTRFS_COMPAT_EXTENT_TREE_V0
27cdeb70 963 if (test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
5d4f98a2
YZ
964 btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV)
965 return 1;
966#endif
967 return 0;
968}
969
970static noinline int update_ref_for_cow(struct btrfs_trans_handle *trans,
971 struct btrfs_root *root,
972 struct extent_buffer *buf,
f0486c68
YZ
973 struct extent_buffer *cow,
974 int *last_ref)
5d4f98a2
YZ
975{
976 u64 refs;
977 u64 owner;
978 u64 flags;
979 u64 new_flags = 0;
980 int ret;
981
982 /*
983 * Backrefs update rules:
984 *
985 * Always use full backrefs for extent pointers in tree block
986 * allocated by tree relocation.
987 *
988 * If a shared tree block is no longer referenced by its owner
989 * tree (btrfs_header_owner(buf) == root->root_key.objectid),
990 * use full backrefs for extent pointers in tree block.
991 *
992 * If a tree block is been relocating
993 * (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID),
994 * use full backrefs for extent pointers in tree block.
995 * The reason for this is some operations (such as drop tree)
996 * are only allowed for blocks use full backrefs.
997 */
998
999 if (btrfs_block_can_be_shared(root, buf)) {
1000 ret = btrfs_lookup_extent_info(trans, root, buf->start,
3173a18f
JB
1001 btrfs_header_level(buf), 1,
1002 &refs, &flags);
be1a5564
MF
1003 if (ret)
1004 return ret;
e5df9573
MF
1005 if (refs == 0) {
1006 ret = -EROFS;
1007 btrfs_std_error(root->fs_info, ret);
1008 return ret;
1009 }
5d4f98a2
YZ
1010 } else {
1011 refs = 1;
1012 if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID ||
1013 btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV)
1014 flags = BTRFS_BLOCK_FLAG_FULL_BACKREF;
1015 else
1016 flags = 0;
1017 }
1018
1019 owner = btrfs_header_owner(buf);
1020 BUG_ON(owner == BTRFS_TREE_RELOC_OBJECTID &&
1021 !(flags & BTRFS_BLOCK_FLAG_FULL_BACKREF));
1022
1023 if (refs > 1) {
1024 if ((owner == root->root_key.objectid ||
1025 root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) &&
1026 !(flags & BTRFS_BLOCK_FLAG_FULL_BACKREF)) {
e339a6b0 1027 ret = btrfs_inc_ref(trans, root, buf, 1);
79787eaa 1028 BUG_ON(ret); /* -ENOMEM */
5d4f98a2
YZ
1029
1030 if (root->root_key.objectid ==
1031 BTRFS_TREE_RELOC_OBJECTID) {
e339a6b0 1032 ret = btrfs_dec_ref(trans, root, buf, 0);
79787eaa 1033 BUG_ON(ret); /* -ENOMEM */
e339a6b0 1034 ret = btrfs_inc_ref(trans, root, cow, 1);
79787eaa 1035 BUG_ON(ret); /* -ENOMEM */
5d4f98a2
YZ
1036 }
1037 new_flags |= BTRFS_BLOCK_FLAG_FULL_BACKREF;
1038 } else {
1039
1040 if (root->root_key.objectid ==
1041 BTRFS_TREE_RELOC_OBJECTID)
e339a6b0 1042 ret = btrfs_inc_ref(trans, root, cow, 1);
5d4f98a2 1043 else
e339a6b0 1044 ret = btrfs_inc_ref(trans, root, cow, 0);
79787eaa 1045 BUG_ON(ret); /* -ENOMEM */
5d4f98a2
YZ
1046 }
1047 if (new_flags != 0) {
b1c79e09
JB
1048 int level = btrfs_header_level(buf);
1049
5d4f98a2
YZ
1050 ret = btrfs_set_disk_extent_flags(trans, root,
1051 buf->start,
1052 buf->len,
b1c79e09 1053 new_flags, level, 0);
be1a5564
MF
1054 if (ret)
1055 return ret;
5d4f98a2
YZ
1056 }
1057 } else {
1058 if (flags & BTRFS_BLOCK_FLAG_FULL_BACKREF) {
1059 if (root->root_key.objectid ==
1060 BTRFS_TREE_RELOC_OBJECTID)
e339a6b0 1061 ret = btrfs_inc_ref(trans, root, cow, 1);
5d4f98a2 1062 else
e339a6b0 1063 ret = btrfs_inc_ref(trans, root, cow, 0);
79787eaa 1064 BUG_ON(ret); /* -ENOMEM */
e339a6b0 1065 ret = btrfs_dec_ref(trans, root, buf, 1);
79787eaa 1066 BUG_ON(ret); /* -ENOMEM */
5d4f98a2
YZ
1067 }
1068 clean_tree_block(trans, root, buf);
f0486c68 1069 *last_ref = 1;
5d4f98a2
YZ
1070 }
1071 return 0;
1072}
1073
d352ac68 1074/*
d397712b
CM
1075 * does the dirty work in cow of a single block. The parent block (if
1076 * supplied) is updated to point to the new cow copy. The new buffer is marked
1077 * dirty and returned locked. If you modify the block it needs to be marked
1078 * dirty again.
d352ac68
CM
1079 *
1080 * search_start -- an allocation hint for the new block
1081 *
d397712b
CM
1082 * empty_size -- a hint that you plan on doing more cow. This is the size in
1083 * bytes the allocator should try to find free next to the block it returns.
1084 * This is just a hint and may be ignored by the allocator.
d352ac68 1085 */
d397712b 1086static noinline int __btrfs_cow_block(struct btrfs_trans_handle *trans,
5f39d397
CM
1087 struct btrfs_root *root,
1088 struct extent_buffer *buf,
1089 struct extent_buffer *parent, int parent_slot,
1090 struct extent_buffer **cow_ret,
9fa8cfe7 1091 u64 search_start, u64 empty_size)
02217ed2 1092{
5d4f98a2 1093 struct btrfs_disk_key disk_key;
5f39d397 1094 struct extent_buffer *cow;
be1a5564 1095 int level, ret;
f0486c68 1096 int last_ref = 0;
925baedd 1097 int unlock_orig = 0;
5d4f98a2 1098 u64 parent_start;
7bb86316 1099
925baedd
CM
1100 if (*cow_ret == buf)
1101 unlock_orig = 1;
1102
b9447ef8 1103 btrfs_assert_tree_locked(buf);
925baedd 1104
27cdeb70
MX
1105 WARN_ON(test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
1106 trans->transid != root->fs_info->running_transaction->transid);
1107 WARN_ON(test_bit(BTRFS_ROOT_REF_COWS, &root->state) &&
1108 trans->transid != root->last_trans);
5f39d397 1109
7bb86316 1110 level = btrfs_header_level(buf);
31840ae1 1111
5d4f98a2
YZ
1112 if (level == 0)
1113 btrfs_item_key(buf, &disk_key, 0);
1114 else
1115 btrfs_node_key(buf, &disk_key, 0);
1116
1117 if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) {
1118 if (parent)
1119 parent_start = parent->start;
1120 else
1121 parent_start = 0;
1122 } else
1123 parent_start = 0;
1124
4d75f8a9
DS
1125 cow = btrfs_alloc_tree_block(trans, root, parent_start,
1126 root->root_key.objectid, &disk_key, level,
1127 search_start, empty_size);
54aa1f4d
CM
1128 if (IS_ERR(cow))
1129 return PTR_ERR(cow);
6702ed49 1130
b4ce94de
CM
1131 /* cow is set to blocking by btrfs_init_new_buffer */
1132
5f39d397 1133 copy_extent_buffer(cow, buf, 0, 0, cow->len);
db94535d 1134 btrfs_set_header_bytenr(cow, cow->start);
5f39d397 1135 btrfs_set_header_generation(cow, trans->transid);
5d4f98a2
YZ
1136 btrfs_set_header_backref_rev(cow, BTRFS_MIXED_BACKREF_REV);
1137 btrfs_clear_header_flag(cow, BTRFS_HEADER_FLAG_WRITTEN |
1138 BTRFS_HEADER_FLAG_RELOC);
1139 if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID)
1140 btrfs_set_header_flag(cow, BTRFS_HEADER_FLAG_RELOC);
1141 else
1142 btrfs_set_header_owner(cow, root->root_key.objectid);
6702ed49 1143
0a4e5586 1144 write_extent_buffer(cow, root->fs_info->fsid, btrfs_header_fsid(),
2b82032c
YZ
1145 BTRFS_FSID_SIZE);
1146
be1a5564 1147 ret = update_ref_for_cow(trans, root, buf, cow, &last_ref);
b68dc2a9 1148 if (ret) {
79787eaa 1149 btrfs_abort_transaction(trans, root, ret);
b68dc2a9
MF
1150 return ret;
1151 }
1a40e23b 1152
27cdeb70 1153 if (test_bit(BTRFS_ROOT_REF_COWS, &root->state)) {
83d4cfd4
JB
1154 ret = btrfs_reloc_cow_block(trans, root, buf, cow);
1155 if (ret)
1156 return ret;
1157 }
3fd0a558 1158
02217ed2 1159 if (buf == root->node) {
925baedd 1160 WARN_ON(parent && parent != buf);
5d4f98a2
YZ
1161 if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID ||
1162 btrfs_header_backref_rev(buf) < BTRFS_MIXED_BACKREF_REV)
1163 parent_start = buf->start;
1164 else
1165 parent_start = 0;
925baedd 1166
5f39d397 1167 extent_buffer_get(cow);
90f8d62e 1168 tree_mod_log_set_root_pointer(root, cow, 1);
240f62c8 1169 rcu_assign_pointer(root->node, cow);
925baedd 1170
f0486c68 1171 btrfs_free_tree_block(trans, root, buf, parent_start,
5581a51a 1172 last_ref);
5f39d397 1173 free_extent_buffer(buf);
0b86a832 1174 add_root_to_dirty_list(root);
02217ed2 1175 } else {
63d9c273
MT
1176 if (root->root_key.objectid == BTRFS_TREE_RELOC_OBJECTID) {
1177 if (parent)
1178 parent_start = parent->start;
1179 else
1180 parent_start = 0;
1181 } else
5d4f98a2
YZ
1182 parent_start = 0;
1183
1184 WARN_ON(trans->transid != btrfs_header_generation(parent));
f230475e 1185 tree_mod_log_insert_key(root->fs_info, parent, parent_slot,
c8cc6341 1186 MOD_LOG_KEY_REPLACE, GFP_NOFS);
5f39d397 1187 btrfs_set_node_blockptr(parent, parent_slot,
db94535d 1188 cow->start);
74493f7a
CM
1189 btrfs_set_node_ptr_generation(parent, parent_slot,
1190 trans->transid);
d6025579 1191 btrfs_mark_buffer_dirty(parent);
5de865ee
FDBM
1192 if (last_ref) {
1193 ret = tree_mod_log_free_eb(root->fs_info, buf);
1194 if (ret) {
1195 btrfs_abort_transaction(trans, root, ret);
1196 return ret;
1197 }
1198 }
f0486c68 1199 btrfs_free_tree_block(trans, root, buf, parent_start,
5581a51a 1200 last_ref);
02217ed2 1201 }
925baedd
CM
1202 if (unlock_orig)
1203 btrfs_tree_unlock(buf);
3083ee2e 1204 free_extent_buffer_stale(buf);
ccd467d6 1205 btrfs_mark_buffer_dirty(cow);
2c90e5d6 1206 *cow_ret = cow;
02217ed2
CM
1207 return 0;
1208}
1209
5d9e75c4
JS
1210/*
1211 * returns the logical address of the oldest predecessor of the given root.
1212 * entries older than time_seq are ignored.
1213 */
1214static struct tree_mod_elem *
1215__tree_mod_log_oldest_root(struct btrfs_fs_info *fs_info,
30b0463a 1216 struct extent_buffer *eb_root, u64 time_seq)
5d9e75c4
JS
1217{
1218 struct tree_mod_elem *tm;
1219 struct tree_mod_elem *found = NULL;
30b0463a 1220 u64 root_logical = eb_root->start;
5d9e75c4
JS
1221 int looped = 0;
1222
1223 if (!time_seq)
35a3621b 1224 return NULL;
5d9e75c4
JS
1225
1226 /*
1227 * the very last operation that's logged for a root is the replacement
1228 * operation (if it is replaced at all). this has the index of the *new*
1229 * root, making it the very first operation that's logged for this root.
1230 */
1231 while (1) {
1232 tm = tree_mod_log_search_oldest(fs_info, root_logical,
1233 time_seq);
1234 if (!looped && !tm)
35a3621b 1235 return NULL;
5d9e75c4 1236 /*
28da9fb4
JS
1237 * if there are no tree operation for the oldest root, we simply
1238 * return it. this should only happen if that (old) root is at
1239 * level 0.
5d9e75c4 1240 */
28da9fb4
JS
1241 if (!tm)
1242 break;
5d9e75c4 1243
28da9fb4
JS
1244 /*
1245 * if there's an operation that's not a root replacement, we
1246 * found the oldest version of our root. normally, we'll find a
1247 * MOD_LOG_KEY_REMOVE_WHILE_FREEING operation here.
1248 */
5d9e75c4
JS
1249 if (tm->op != MOD_LOG_ROOT_REPLACE)
1250 break;
1251
1252 found = tm;
1253 root_logical = tm->old_root.logical;
5d9e75c4
JS
1254 looped = 1;
1255 }
1256
a95236d9
JS
1257 /* if there's no old root to return, return what we found instead */
1258 if (!found)
1259 found = tm;
1260
5d9e75c4
JS
1261 return found;
1262}
1263
1264/*
1265 * tm is a pointer to the first operation to rewind within eb. then, all
1266 * previous operations will be rewinded (until we reach something older than
1267 * time_seq).
1268 */
1269static void
f1ca7e98
JB
1270__tree_mod_log_rewind(struct btrfs_fs_info *fs_info, struct extent_buffer *eb,
1271 u64 time_seq, struct tree_mod_elem *first_tm)
5d9e75c4
JS
1272{
1273 u32 n;
1274 struct rb_node *next;
1275 struct tree_mod_elem *tm = first_tm;
1276 unsigned long o_dst;
1277 unsigned long o_src;
1278 unsigned long p_size = sizeof(struct btrfs_key_ptr);
1279
1280 n = btrfs_header_nritems(eb);
f1ca7e98 1281 tree_mod_log_read_lock(fs_info);
097b8a7c 1282 while (tm && tm->seq >= time_seq) {
5d9e75c4
JS
1283 /*
1284 * all the operations are recorded with the operator used for
1285 * the modification. as we're going backwards, we do the
1286 * opposite of each operation here.
1287 */
1288 switch (tm->op) {
1289 case MOD_LOG_KEY_REMOVE_WHILE_FREEING:
1290 BUG_ON(tm->slot < n);
1c697d4a 1291 /* Fallthrough */
95c80bb1 1292 case MOD_LOG_KEY_REMOVE_WHILE_MOVING:
4c3e6969 1293 case MOD_LOG_KEY_REMOVE:
5d9e75c4
JS
1294 btrfs_set_node_key(eb, &tm->key, tm->slot);
1295 btrfs_set_node_blockptr(eb, tm->slot, tm->blockptr);
1296 btrfs_set_node_ptr_generation(eb, tm->slot,
1297 tm->generation);
4c3e6969 1298 n++;
5d9e75c4
JS
1299 break;
1300 case MOD_LOG_KEY_REPLACE:
1301 BUG_ON(tm->slot >= n);
1302 btrfs_set_node_key(eb, &tm->key, tm->slot);
1303 btrfs_set_node_blockptr(eb, tm->slot, tm->blockptr);
1304 btrfs_set_node_ptr_generation(eb, tm->slot,
1305 tm->generation);
1306 break;
1307 case MOD_LOG_KEY_ADD:
19956c7e 1308 /* if a move operation is needed it's in the log */
5d9e75c4
JS
1309 n--;
1310 break;
1311 case MOD_LOG_MOVE_KEYS:
c3193108
JS
1312 o_dst = btrfs_node_key_ptr_offset(tm->slot);
1313 o_src = btrfs_node_key_ptr_offset(tm->move.dst_slot);
1314 memmove_extent_buffer(eb, o_dst, o_src,
5d9e75c4
JS
1315 tm->move.nr_items * p_size);
1316 break;
1317 case MOD_LOG_ROOT_REPLACE:
1318 /*
1319 * this operation is special. for roots, this must be
1320 * handled explicitly before rewinding.
1321 * for non-roots, this operation may exist if the node
1322 * was a root: root A -> child B; then A gets empty and
1323 * B is promoted to the new root. in the mod log, we'll
1324 * have a root-replace operation for B, a tree block
1325 * that is no root. we simply ignore that operation.
1326 */
1327 break;
1328 }
1329 next = rb_next(&tm->node);
1330 if (!next)
1331 break;
1332 tm = container_of(next, struct tree_mod_elem, node);
1333 if (tm->index != first_tm->index)
1334 break;
1335 }
f1ca7e98 1336 tree_mod_log_read_unlock(fs_info);
5d9e75c4
JS
1337 btrfs_set_header_nritems(eb, n);
1338}
1339
47fb091f
JS
1340/*
1341 * Called with eb read locked. If the buffer cannot be rewinded, the same buffer
1342 * is returned. If rewind operations happen, a fresh buffer is returned. The
1343 * returned buffer is always read-locked. If the returned buffer is not the
1344 * input buffer, the lock on the input buffer is released and the input buffer
1345 * is freed (its refcount is decremented).
1346 */
5d9e75c4 1347static struct extent_buffer *
9ec72677
JB
1348tree_mod_log_rewind(struct btrfs_fs_info *fs_info, struct btrfs_path *path,
1349 struct extent_buffer *eb, u64 time_seq)
5d9e75c4
JS
1350{
1351 struct extent_buffer *eb_rewin;
1352 struct tree_mod_elem *tm;
1353
1354 if (!time_seq)
1355 return eb;
1356
1357 if (btrfs_header_level(eb) == 0)
1358 return eb;
1359
1360 tm = tree_mod_log_search(fs_info, eb->start, time_seq);
1361 if (!tm)
1362 return eb;
1363
9ec72677
JB
1364 btrfs_set_path_blocking(path);
1365 btrfs_set_lock_blocking_rw(eb, BTRFS_READ_LOCK);
1366
5d9e75c4
JS
1367 if (tm->op == MOD_LOG_KEY_REMOVE_WHILE_FREEING) {
1368 BUG_ON(tm->slot != 0);
1369 eb_rewin = alloc_dummy_extent_buffer(eb->start,
1370 fs_info->tree_root->nodesize);
db7f3436 1371 if (!eb_rewin) {
9ec72677 1372 btrfs_tree_read_unlock_blocking(eb);
db7f3436
JB
1373 free_extent_buffer(eb);
1374 return NULL;
1375 }
5d9e75c4
JS
1376 btrfs_set_header_bytenr(eb_rewin, eb->start);
1377 btrfs_set_header_backref_rev(eb_rewin,
1378 btrfs_header_backref_rev(eb));
1379 btrfs_set_header_owner(eb_rewin, btrfs_header_owner(eb));
c3193108 1380 btrfs_set_header_level(eb_rewin, btrfs_header_level(eb));
5d9e75c4
JS
1381 } else {
1382 eb_rewin = btrfs_clone_extent_buffer(eb);
db7f3436 1383 if (!eb_rewin) {
9ec72677 1384 btrfs_tree_read_unlock_blocking(eb);
db7f3436
JB
1385 free_extent_buffer(eb);
1386 return NULL;
1387 }
5d9e75c4
JS
1388 }
1389
9ec72677
JB
1390 btrfs_clear_path_blocking(path, NULL, BTRFS_READ_LOCK);
1391 btrfs_tree_read_unlock_blocking(eb);
5d9e75c4
JS
1392 free_extent_buffer(eb);
1393
47fb091f
JS
1394 extent_buffer_get(eb_rewin);
1395 btrfs_tree_read_lock(eb_rewin);
f1ca7e98 1396 __tree_mod_log_rewind(fs_info, eb_rewin, time_seq, tm);
57911b8b 1397 WARN_ON(btrfs_header_nritems(eb_rewin) >
2a745b14 1398 BTRFS_NODEPTRS_PER_BLOCK(fs_info->tree_root));
5d9e75c4
JS
1399
1400 return eb_rewin;
1401}
1402
8ba97a15
JS
1403/*
1404 * get_old_root() rewinds the state of @root's root node to the given @time_seq
1405 * value. If there are no changes, the current root->root_node is returned. If
1406 * anything changed in between, there's a fresh buffer allocated on which the
1407 * rewind operations are done. In any case, the returned buffer is read locked.
1408 * Returns NULL on error (with no locks held).
1409 */
5d9e75c4
JS
1410static inline struct extent_buffer *
1411get_old_root(struct btrfs_root *root, u64 time_seq)
1412{
1413 struct tree_mod_elem *tm;
30b0463a
JS
1414 struct extent_buffer *eb = NULL;
1415 struct extent_buffer *eb_root;
7bfdcf7f 1416 struct extent_buffer *old;
a95236d9 1417 struct tree_mod_root *old_root = NULL;
4325edd0 1418 u64 old_generation = 0;
a95236d9 1419 u64 logical;
5d9e75c4 1420
30b0463a
JS
1421 eb_root = btrfs_read_lock_root_node(root);
1422 tm = __tree_mod_log_oldest_root(root->fs_info, eb_root, time_seq);
5d9e75c4 1423 if (!tm)
30b0463a 1424 return eb_root;
5d9e75c4 1425
a95236d9
JS
1426 if (tm->op == MOD_LOG_ROOT_REPLACE) {
1427 old_root = &tm->old_root;
1428 old_generation = tm->generation;
1429 logical = old_root->logical;
1430 } else {
30b0463a 1431 logical = eb_root->start;
a95236d9 1432 }
5d9e75c4 1433
a95236d9 1434 tm = tree_mod_log_search(root->fs_info, logical, time_seq);
834328a8 1435 if (old_root && tm && tm->op != MOD_LOG_KEY_REMOVE_WHILE_FREEING) {
30b0463a
JS
1436 btrfs_tree_read_unlock(eb_root);
1437 free_extent_buffer(eb_root);
ce86cd59 1438 old = read_tree_block(root, logical, 0);
fae7f21c 1439 if (WARN_ON(!old || !extent_buffer_uptodate(old))) {
416bc658 1440 free_extent_buffer(old);
efe120a0
FH
1441 btrfs_warn(root->fs_info,
1442 "failed to read tree block %llu from get_old_root", logical);
834328a8 1443 } else {
7bfdcf7f
LB
1444 eb = btrfs_clone_extent_buffer(old);
1445 free_extent_buffer(old);
834328a8
JS
1446 }
1447 } else if (old_root) {
30b0463a
JS
1448 btrfs_tree_read_unlock(eb_root);
1449 free_extent_buffer(eb_root);
28da9fb4 1450 eb = alloc_dummy_extent_buffer(logical, root->nodesize);
834328a8 1451 } else {
9ec72677 1452 btrfs_set_lock_blocking_rw(eb_root, BTRFS_READ_LOCK);
30b0463a 1453 eb = btrfs_clone_extent_buffer(eb_root);
9ec72677 1454 btrfs_tree_read_unlock_blocking(eb_root);
30b0463a 1455 free_extent_buffer(eb_root);
834328a8
JS
1456 }
1457
8ba97a15
JS
1458 if (!eb)
1459 return NULL;
d6381084 1460 extent_buffer_get(eb);
8ba97a15 1461 btrfs_tree_read_lock(eb);
a95236d9 1462 if (old_root) {
5d9e75c4
JS
1463 btrfs_set_header_bytenr(eb, eb->start);
1464 btrfs_set_header_backref_rev(eb, BTRFS_MIXED_BACKREF_REV);
30b0463a 1465 btrfs_set_header_owner(eb, btrfs_header_owner(eb_root));
a95236d9
JS
1466 btrfs_set_header_level(eb, old_root->level);
1467 btrfs_set_header_generation(eb, old_generation);
5d9e75c4 1468 }
28da9fb4 1469 if (tm)
f1ca7e98 1470 __tree_mod_log_rewind(root->fs_info, eb, time_seq, tm);
28da9fb4
JS
1471 else
1472 WARN_ON(btrfs_header_level(eb) != 0);
57911b8b 1473 WARN_ON(btrfs_header_nritems(eb) > BTRFS_NODEPTRS_PER_BLOCK(root));
5d9e75c4
JS
1474
1475 return eb;
1476}
1477
5b6602e7
JS
1478int btrfs_old_root_level(struct btrfs_root *root, u64 time_seq)
1479{
1480 struct tree_mod_elem *tm;
1481 int level;
30b0463a 1482 struct extent_buffer *eb_root = btrfs_root_node(root);
5b6602e7 1483
30b0463a 1484 tm = __tree_mod_log_oldest_root(root->fs_info, eb_root, time_seq);
5b6602e7
JS
1485 if (tm && tm->op == MOD_LOG_ROOT_REPLACE) {
1486 level = tm->old_root.level;
1487 } else {
30b0463a 1488 level = btrfs_header_level(eb_root);
5b6602e7 1489 }
30b0463a 1490 free_extent_buffer(eb_root);
5b6602e7
JS
1491
1492 return level;
1493}
1494
5d4f98a2
YZ
1495static inline int should_cow_block(struct btrfs_trans_handle *trans,
1496 struct btrfs_root *root,
1497 struct extent_buffer *buf)
1498{
fccb84c9 1499 if (btrfs_test_is_dummy_root(root))
faa2dbf0 1500 return 0;
fccb84c9 1501
f1ebcc74
LB
1502 /* ensure we can see the force_cow */
1503 smp_rmb();
1504
1505 /*
1506 * We do not need to cow a block if
1507 * 1) this block is not created or changed in this transaction;
1508 * 2) this block does not belong to TREE_RELOC tree;
1509 * 3) the root is not forced COW.
1510 *
1511 * What is forced COW:
1512 * when we create snapshot during commiting the transaction,
1513 * after we've finished coping src root, we must COW the shared
1514 * block to ensure the metadata consistency.
1515 */
5d4f98a2
YZ
1516 if (btrfs_header_generation(buf) == trans->transid &&
1517 !btrfs_header_flag(buf, BTRFS_HEADER_FLAG_WRITTEN) &&
1518 !(root->root_key.objectid != BTRFS_TREE_RELOC_OBJECTID &&
f1ebcc74 1519 btrfs_header_flag(buf, BTRFS_HEADER_FLAG_RELOC)) &&
27cdeb70 1520 !test_bit(BTRFS_ROOT_FORCE_COW, &root->state))
5d4f98a2
YZ
1521 return 0;
1522 return 1;
1523}
1524
d352ac68
CM
1525/*
1526 * cows a single block, see __btrfs_cow_block for the real work.
1527 * This version of it has extra checks so that a block isn't cow'd more than
1528 * once per transaction, as long as it hasn't been written yet
1529 */
d397712b 1530noinline int btrfs_cow_block(struct btrfs_trans_handle *trans,
5f39d397
CM
1531 struct btrfs_root *root, struct extent_buffer *buf,
1532 struct extent_buffer *parent, int parent_slot,
9fa8cfe7 1533 struct extent_buffer **cow_ret)
6702ed49
CM
1534{
1535 u64 search_start;
f510cfec 1536 int ret;
dc17ff8f 1537
31b1a2bd
JL
1538 if (trans->transaction != root->fs_info->running_transaction)
1539 WARN(1, KERN_CRIT "trans %llu running %llu\n",
c1c9ff7c 1540 trans->transid,
6702ed49 1541 root->fs_info->running_transaction->transid);
31b1a2bd
JL
1542
1543 if (trans->transid != root->fs_info->generation)
1544 WARN(1, KERN_CRIT "trans %llu running %llu\n",
c1c9ff7c 1545 trans->transid, root->fs_info->generation);
dc17ff8f 1546
5d4f98a2 1547 if (!should_cow_block(trans, root, buf)) {
6702ed49
CM
1548 *cow_ret = buf;
1549 return 0;
1550 }
c487685d 1551
0b86a832 1552 search_start = buf->start & ~((u64)(1024 * 1024 * 1024) - 1);
b4ce94de
CM
1553
1554 if (parent)
1555 btrfs_set_lock_blocking(parent);
1556 btrfs_set_lock_blocking(buf);
1557
f510cfec 1558 ret = __btrfs_cow_block(trans, root, buf, parent,
9fa8cfe7 1559 parent_slot, cow_ret, search_start, 0);
1abe9b8a 1560
1561 trace_btrfs_cow_block(root, buf, *cow_ret);
1562
f510cfec 1563 return ret;
6702ed49
CM
1564}
1565
d352ac68
CM
1566/*
1567 * helper function for defrag to decide if two blocks pointed to by a
1568 * node are actually close by
1569 */
6b80053d 1570static int close_blocks(u64 blocknr, u64 other, u32 blocksize)
6702ed49 1571{
6b80053d 1572 if (blocknr < other && other - (blocknr + blocksize) < 32768)
6702ed49 1573 return 1;
6b80053d 1574 if (blocknr > other && blocknr - (other + blocksize) < 32768)
6702ed49
CM
1575 return 1;
1576 return 0;
1577}
1578
081e9573
CM
1579/*
1580 * compare two keys in a memcmp fashion
1581 */
1582static int comp_keys(struct btrfs_disk_key *disk, struct btrfs_key *k2)
1583{
1584 struct btrfs_key k1;
1585
1586 btrfs_disk_key_to_cpu(&k1, disk);
1587
20736aba 1588 return btrfs_comp_cpu_keys(&k1, k2);
081e9573
CM
1589}
1590
f3465ca4
JB
1591/*
1592 * same as comp_keys only with two btrfs_key's
1593 */
5d4f98a2 1594int btrfs_comp_cpu_keys(struct btrfs_key *k1, struct btrfs_key *k2)
f3465ca4
JB
1595{
1596 if (k1->objectid > k2->objectid)
1597 return 1;
1598 if (k1->objectid < k2->objectid)
1599 return -1;
1600 if (k1->type > k2->type)
1601 return 1;
1602 if (k1->type < k2->type)
1603 return -1;
1604 if (k1->offset > k2->offset)
1605 return 1;
1606 if (k1->offset < k2->offset)
1607 return -1;
1608 return 0;
1609}
081e9573 1610
d352ac68
CM
1611/*
1612 * this is used by the defrag code to go through all the
1613 * leaves pointed to by a node and reallocate them so that
1614 * disk order is close to key order
1615 */
6702ed49 1616int btrfs_realloc_node(struct btrfs_trans_handle *trans,
5f39d397 1617 struct btrfs_root *root, struct extent_buffer *parent,
de78b51a 1618 int start_slot, u64 *last_ret,
a6b6e75e 1619 struct btrfs_key *progress)
6702ed49 1620{
6b80053d 1621 struct extent_buffer *cur;
6702ed49 1622 u64 blocknr;
ca7a79ad 1623 u64 gen;
e9d0b13b
CM
1624 u64 search_start = *last_ret;
1625 u64 last_block = 0;
6702ed49
CM
1626 u64 other;
1627 u32 parent_nritems;
6702ed49
CM
1628 int end_slot;
1629 int i;
1630 int err = 0;
f2183bde 1631 int parent_level;
6b80053d
CM
1632 int uptodate;
1633 u32 blocksize;
081e9573
CM
1634 int progress_passed = 0;
1635 struct btrfs_disk_key disk_key;
6702ed49 1636
5708b959 1637 parent_level = btrfs_header_level(parent);
5708b959 1638
6c1500f2
JL
1639 WARN_ON(trans->transaction != root->fs_info->running_transaction);
1640 WARN_ON(trans->transid != root->fs_info->generation);
86479a04 1641
6b80053d 1642 parent_nritems = btrfs_header_nritems(parent);
707e8a07 1643 blocksize = root->nodesize;
6702ed49
CM
1644 end_slot = parent_nritems;
1645
1646 if (parent_nritems == 1)
1647 return 0;
1648
b4ce94de
CM
1649 btrfs_set_lock_blocking(parent);
1650
6702ed49
CM
1651 for (i = start_slot; i < end_slot; i++) {
1652 int close = 1;
a6b6e75e 1653
081e9573
CM
1654 btrfs_node_key(parent, &disk_key, i);
1655 if (!progress_passed && comp_keys(&disk_key, progress) < 0)
1656 continue;
1657
1658 progress_passed = 1;
6b80053d 1659 blocknr = btrfs_node_blockptr(parent, i);
ca7a79ad 1660 gen = btrfs_node_ptr_generation(parent, i);
e9d0b13b
CM
1661 if (last_block == 0)
1662 last_block = blocknr;
5708b959 1663
6702ed49 1664 if (i > 0) {
6b80053d
CM
1665 other = btrfs_node_blockptr(parent, i - 1);
1666 close = close_blocks(blocknr, other, blocksize);
6702ed49 1667 }
0ef3e66b 1668 if (!close && i < end_slot - 2) {
6b80053d
CM
1669 other = btrfs_node_blockptr(parent, i + 1);
1670 close = close_blocks(blocknr, other, blocksize);
6702ed49 1671 }
e9d0b13b
CM
1672 if (close) {
1673 last_block = blocknr;
6702ed49 1674 continue;
e9d0b13b 1675 }
6702ed49 1676
0308af44 1677 cur = btrfs_find_tree_block(root, blocknr);
6b80053d 1678 if (cur)
b9fab919 1679 uptodate = btrfs_buffer_uptodate(cur, gen, 0);
6b80053d
CM
1680 else
1681 uptodate = 0;
5708b959 1682 if (!cur || !uptodate) {
6b80053d 1683 if (!cur) {
ce86cd59 1684 cur = read_tree_block(root, blocknr, gen);
416bc658
JB
1685 if (!cur || !extent_buffer_uptodate(cur)) {
1686 free_extent_buffer(cur);
97d9a8a4 1687 return -EIO;
416bc658 1688 }
6b80053d 1689 } else if (!uptodate) {
018642a1
TI
1690 err = btrfs_read_buffer(cur, gen);
1691 if (err) {
1692 free_extent_buffer(cur);
1693 return err;
1694 }
f2183bde 1695 }
6702ed49 1696 }
e9d0b13b 1697 if (search_start == 0)
6b80053d 1698 search_start = last_block;
e9d0b13b 1699
e7a84565 1700 btrfs_tree_lock(cur);
b4ce94de 1701 btrfs_set_lock_blocking(cur);
6b80053d 1702 err = __btrfs_cow_block(trans, root, cur, parent, i,
e7a84565 1703 &cur, search_start,
6b80053d 1704 min(16 * blocksize,
9fa8cfe7 1705 (end_slot - i) * blocksize));
252c38f0 1706 if (err) {
e7a84565 1707 btrfs_tree_unlock(cur);
6b80053d 1708 free_extent_buffer(cur);
6702ed49 1709 break;
252c38f0 1710 }
e7a84565
CM
1711 search_start = cur->start;
1712 last_block = cur->start;
f2183bde 1713 *last_ret = search_start;
e7a84565
CM
1714 btrfs_tree_unlock(cur);
1715 free_extent_buffer(cur);
6702ed49
CM
1716 }
1717 return err;
1718}
1719
74123bd7
CM
1720/*
1721 * The leaf data grows from end-to-front in the node.
1722 * this returns the address of the start of the last item,
1723 * which is the stop of the leaf data stack
1724 */
123abc88 1725static inline unsigned int leaf_data_end(struct btrfs_root *root,
5f39d397 1726 struct extent_buffer *leaf)
be0e5c09 1727{
5f39d397 1728 u32 nr = btrfs_header_nritems(leaf);
be0e5c09 1729 if (nr == 0)
123abc88 1730 return BTRFS_LEAF_DATA_SIZE(root);
5f39d397 1731 return btrfs_item_offset_nr(leaf, nr - 1);
be0e5c09
CM
1732}
1733
aa5d6bed 1734
74123bd7 1735/*
5f39d397
CM
1736 * search for key in the extent_buffer. The items start at offset p,
1737 * and they are item_size apart. There are 'max' items in p.
1738 *
74123bd7
CM
1739 * the slot in the array is returned via slot, and it points to
1740 * the place where you would insert key if it is not found in
1741 * the array.
1742 *
1743 * slot may point to max if the key is bigger than all of the keys
1744 */
e02119d5
CM
1745static noinline int generic_bin_search(struct extent_buffer *eb,
1746 unsigned long p,
1747 int item_size, struct btrfs_key *key,
1748 int max, int *slot)
be0e5c09
CM
1749{
1750 int low = 0;
1751 int high = max;
1752 int mid;
1753 int ret;
479965d6 1754 struct btrfs_disk_key *tmp = NULL;
5f39d397
CM
1755 struct btrfs_disk_key unaligned;
1756 unsigned long offset;
5f39d397
CM
1757 char *kaddr = NULL;
1758 unsigned long map_start = 0;
1759 unsigned long map_len = 0;
479965d6 1760 int err;
be0e5c09 1761
d397712b 1762 while (low < high) {
be0e5c09 1763 mid = (low + high) / 2;
5f39d397
CM
1764 offset = p + mid * item_size;
1765
a6591715 1766 if (!kaddr || offset < map_start ||
5f39d397
CM
1767 (offset + sizeof(struct btrfs_disk_key)) >
1768 map_start + map_len) {
934d375b
CM
1769
1770 err = map_private_extent_buffer(eb, offset,
479965d6 1771 sizeof(struct btrfs_disk_key),
a6591715 1772 &kaddr, &map_start, &map_len);
479965d6
CM
1773
1774 if (!err) {
1775 tmp = (struct btrfs_disk_key *)(kaddr + offset -
1776 map_start);
1777 } else {
1778 read_extent_buffer(eb, &unaligned,
1779 offset, sizeof(unaligned));
1780 tmp = &unaligned;
1781 }
5f39d397 1782
5f39d397
CM
1783 } else {
1784 tmp = (struct btrfs_disk_key *)(kaddr + offset -
1785 map_start);
1786 }
be0e5c09
CM
1787 ret = comp_keys(tmp, key);
1788
1789 if (ret < 0)
1790 low = mid + 1;
1791 else if (ret > 0)
1792 high = mid;
1793 else {
1794 *slot = mid;
1795 return 0;
1796 }
1797 }
1798 *slot = low;
1799 return 1;
1800}
1801
97571fd0
CM
1802/*
1803 * simple bin_search frontend that does the right thing for
1804 * leaves vs nodes
1805 */
5f39d397
CM
1806static int bin_search(struct extent_buffer *eb, struct btrfs_key *key,
1807 int level, int *slot)
be0e5c09 1808{
f775738f 1809 if (level == 0)
5f39d397
CM
1810 return generic_bin_search(eb,
1811 offsetof(struct btrfs_leaf, items),
0783fcfc 1812 sizeof(struct btrfs_item),
5f39d397 1813 key, btrfs_header_nritems(eb),
7518a238 1814 slot);
f775738f 1815 else
5f39d397
CM
1816 return generic_bin_search(eb,
1817 offsetof(struct btrfs_node, ptrs),
123abc88 1818 sizeof(struct btrfs_key_ptr),
5f39d397 1819 key, btrfs_header_nritems(eb),
7518a238 1820 slot);
be0e5c09
CM
1821}
1822
5d4f98a2
YZ
1823int btrfs_bin_search(struct extent_buffer *eb, struct btrfs_key *key,
1824 int level, int *slot)
1825{
1826 return bin_search(eb, key, level, slot);
1827}
1828
f0486c68
YZ
1829static void root_add_used(struct btrfs_root *root, u32 size)
1830{
1831 spin_lock(&root->accounting_lock);
1832 btrfs_set_root_used(&root->root_item,
1833 btrfs_root_used(&root->root_item) + size);
1834 spin_unlock(&root->accounting_lock);
1835}
1836
1837static void root_sub_used(struct btrfs_root *root, u32 size)
1838{
1839 spin_lock(&root->accounting_lock);
1840 btrfs_set_root_used(&root->root_item,
1841 btrfs_root_used(&root->root_item) - size);
1842 spin_unlock(&root->accounting_lock);
1843}
1844
d352ac68
CM
1845/* given a node and slot number, this reads the blocks it points to. The
1846 * extent buffer is returned with a reference taken (but unlocked).
1847 * NULL is returned on error.
1848 */
e02119d5 1849static noinline struct extent_buffer *read_node_slot(struct btrfs_root *root,
5f39d397 1850 struct extent_buffer *parent, int slot)
bb803951 1851{
ca7a79ad 1852 int level = btrfs_header_level(parent);
416bc658
JB
1853 struct extent_buffer *eb;
1854
bb803951
CM
1855 if (slot < 0)
1856 return NULL;
5f39d397 1857 if (slot >= btrfs_header_nritems(parent))
bb803951 1858 return NULL;
ca7a79ad
CM
1859
1860 BUG_ON(level == 0);
1861
416bc658 1862 eb = read_tree_block(root, btrfs_node_blockptr(parent, slot),
416bc658
JB
1863 btrfs_node_ptr_generation(parent, slot));
1864 if (eb && !extent_buffer_uptodate(eb)) {
1865 free_extent_buffer(eb);
1866 eb = NULL;
1867 }
1868
1869 return eb;
bb803951
CM
1870}
1871
d352ac68
CM
1872/*
1873 * node level balancing, used to make sure nodes are in proper order for
1874 * item deletion. We balance from the top down, so we have to make sure
1875 * that a deletion won't leave an node completely empty later on.
1876 */
e02119d5 1877static noinline int balance_level(struct btrfs_trans_handle *trans,
98ed5174
CM
1878 struct btrfs_root *root,
1879 struct btrfs_path *path, int level)
bb803951 1880{
5f39d397
CM
1881 struct extent_buffer *right = NULL;
1882 struct extent_buffer *mid;
1883 struct extent_buffer *left = NULL;
1884 struct extent_buffer *parent = NULL;
bb803951
CM
1885 int ret = 0;
1886 int wret;
1887 int pslot;
bb803951 1888 int orig_slot = path->slots[level];
79f95c82 1889 u64 orig_ptr;
bb803951
CM
1890
1891 if (level == 0)
1892 return 0;
1893
5f39d397 1894 mid = path->nodes[level];
b4ce94de 1895
bd681513
CM
1896 WARN_ON(path->locks[level] != BTRFS_WRITE_LOCK &&
1897 path->locks[level] != BTRFS_WRITE_LOCK_BLOCKING);
7bb86316
CM
1898 WARN_ON(btrfs_header_generation(mid) != trans->transid);
1899
1d4f8a0c 1900 orig_ptr = btrfs_node_blockptr(mid, orig_slot);
79f95c82 1901
a05a9bb1 1902 if (level < BTRFS_MAX_LEVEL - 1) {
5f39d397 1903 parent = path->nodes[level + 1];
a05a9bb1
LZ
1904 pslot = path->slots[level + 1];
1905 }
bb803951 1906
40689478
CM
1907 /*
1908 * deal with the case where there is only one pointer in the root
1909 * by promoting the node below to a root
1910 */
5f39d397
CM
1911 if (!parent) {
1912 struct extent_buffer *child;
bb803951 1913
5f39d397 1914 if (btrfs_header_nritems(mid) != 1)
bb803951
CM
1915 return 0;
1916
1917 /* promote the child to a root */
5f39d397 1918 child = read_node_slot(root, mid, 0);
305a26af
MF
1919 if (!child) {
1920 ret = -EROFS;
1921 btrfs_std_error(root->fs_info, ret);
1922 goto enospc;
1923 }
1924
925baedd 1925 btrfs_tree_lock(child);
b4ce94de 1926 btrfs_set_lock_blocking(child);
9fa8cfe7 1927 ret = btrfs_cow_block(trans, root, child, mid, 0, &child);
f0486c68
YZ
1928 if (ret) {
1929 btrfs_tree_unlock(child);
1930 free_extent_buffer(child);
1931 goto enospc;
1932 }
2f375ab9 1933
90f8d62e 1934 tree_mod_log_set_root_pointer(root, child, 1);
240f62c8 1935 rcu_assign_pointer(root->node, child);
925baedd 1936
0b86a832 1937 add_root_to_dirty_list(root);
925baedd 1938 btrfs_tree_unlock(child);
b4ce94de 1939
925baedd 1940 path->locks[level] = 0;
bb803951 1941 path->nodes[level] = NULL;
5f39d397 1942 clean_tree_block(trans, root, mid);
925baedd 1943 btrfs_tree_unlock(mid);
bb803951 1944 /* once for the path */
5f39d397 1945 free_extent_buffer(mid);
f0486c68
YZ
1946
1947 root_sub_used(root, mid->len);
5581a51a 1948 btrfs_free_tree_block(trans, root, mid, 0, 1);
bb803951 1949 /* once for the root ptr */
3083ee2e 1950 free_extent_buffer_stale(mid);
f0486c68 1951 return 0;
bb803951 1952 }
5f39d397 1953 if (btrfs_header_nritems(mid) >
123abc88 1954 BTRFS_NODEPTRS_PER_BLOCK(root) / 4)
bb803951
CM
1955 return 0;
1956
5f39d397
CM
1957 left = read_node_slot(root, parent, pslot - 1);
1958 if (left) {
925baedd 1959 btrfs_tree_lock(left);
b4ce94de 1960 btrfs_set_lock_blocking(left);
5f39d397 1961 wret = btrfs_cow_block(trans, root, left,
9fa8cfe7 1962 parent, pslot - 1, &left);
54aa1f4d
CM
1963 if (wret) {
1964 ret = wret;
1965 goto enospc;
1966 }
2cc58cf2 1967 }
5f39d397
CM
1968 right = read_node_slot(root, parent, pslot + 1);
1969 if (right) {
925baedd 1970 btrfs_tree_lock(right);
b4ce94de 1971 btrfs_set_lock_blocking(right);
5f39d397 1972 wret = btrfs_cow_block(trans, root, right,
9fa8cfe7 1973 parent, pslot + 1, &right);
2cc58cf2
CM
1974 if (wret) {
1975 ret = wret;
1976 goto enospc;
1977 }
1978 }
1979
1980 /* first, try to make some room in the middle buffer */
5f39d397
CM
1981 if (left) {
1982 orig_slot += btrfs_header_nritems(left);
bce4eae9 1983 wret = push_node_left(trans, root, left, mid, 1);
79f95c82
CM
1984 if (wret < 0)
1985 ret = wret;
bb803951 1986 }
79f95c82
CM
1987
1988 /*
1989 * then try to empty the right most buffer into the middle
1990 */
5f39d397 1991 if (right) {
971a1f66 1992 wret = push_node_left(trans, root, mid, right, 1);
54aa1f4d 1993 if (wret < 0 && wret != -ENOSPC)
79f95c82 1994 ret = wret;
5f39d397 1995 if (btrfs_header_nritems(right) == 0) {
5f39d397 1996 clean_tree_block(trans, root, right);
925baedd 1997 btrfs_tree_unlock(right);
afe5fea7 1998 del_ptr(root, path, level + 1, pslot + 1);
f0486c68 1999 root_sub_used(root, right->len);
5581a51a 2000 btrfs_free_tree_block(trans, root, right, 0, 1);
3083ee2e 2001 free_extent_buffer_stale(right);
f0486c68 2002 right = NULL;
bb803951 2003 } else {
5f39d397
CM
2004 struct btrfs_disk_key right_key;
2005 btrfs_node_key(right, &right_key, 0);
f230475e 2006 tree_mod_log_set_node_key(root->fs_info, parent,
32adf090 2007 pslot + 1, 0);
5f39d397
CM
2008 btrfs_set_node_key(parent, &right_key, pslot + 1);
2009 btrfs_mark_buffer_dirty(parent);
bb803951
CM
2010 }
2011 }
5f39d397 2012 if (btrfs_header_nritems(mid) == 1) {
79f95c82
CM
2013 /*
2014 * we're not allowed to leave a node with one item in the
2015 * tree during a delete. A deletion from lower in the tree
2016 * could try to delete the only pointer in this node.
2017 * So, pull some keys from the left.
2018 * There has to be a left pointer at this point because
2019 * otherwise we would have pulled some pointers from the
2020 * right
2021 */
305a26af
MF
2022 if (!left) {
2023 ret = -EROFS;
2024 btrfs_std_error(root->fs_info, ret);
2025 goto enospc;
2026 }
5f39d397 2027 wret = balance_node_right(trans, root, mid, left);
54aa1f4d 2028 if (wret < 0) {
79f95c82 2029 ret = wret;
54aa1f4d
CM
2030 goto enospc;
2031 }
bce4eae9
CM
2032 if (wret == 1) {
2033 wret = push_node_left(trans, root, left, mid, 1);
2034 if (wret < 0)
2035 ret = wret;
2036 }
79f95c82
CM
2037 BUG_ON(wret == 1);
2038 }
5f39d397 2039 if (btrfs_header_nritems(mid) == 0) {
5f39d397 2040 clean_tree_block(trans, root, mid);
925baedd 2041 btrfs_tree_unlock(mid);
afe5fea7 2042 del_ptr(root, path, level + 1, pslot);
f0486c68 2043 root_sub_used(root, mid->len);
5581a51a 2044 btrfs_free_tree_block(trans, root, mid, 0, 1);
3083ee2e 2045 free_extent_buffer_stale(mid);
f0486c68 2046 mid = NULL;
79f95c82
CM
2047 } else {
2048 /* update the parent key to reflect our changes */
5f39d397
CM
2049 struct btrfs_disk_key mid_key;
2050 btrfs_node_key(mid, &mid_key, 0);
32adf090 2051 tree_mod_log_set_node_key(root->fs_info, parent,
f230475e 2052 pslot, 0);
5f39d397
CM
2053 btrfs_set_node_key(parent, &mid_key, pslot);
2054 btrfs_mark_buffer_dirty(parent);
79f95c82 2055 }
bb803951 2056
79f95c82 2057 /* update the path */
5f39d397
CM
2058 if (left) {
2059 if (btrfs_header_nritems(left) > orig_slot) {
2060 extent_buffer_get(left);
925baedd 2061 /* left was locked after cow */
5f39d397 2062 path->nodes[level] = left;
bb803951
CM
2063 path->slots[level + 1] -= 1;
2064 path->slots[level] = orig_slot;
925baedd
CM
2065 if (mid) {
2066 btrfs_tree_unlock(mid);
5f39d397 2067 free_extent_buffer(mid);
925baedd 2068 }
bb803951 2069 } else {
5f39d397 2070 orig_slot -= btrfs_header_nritems(left);
bb803951
CM
2071 path->slots[level] = orig_slot;
2072 }
2073 }
79f95c82 2074 /* double check we haven't messed things up */
e20d96d6 2075 if (orig_ptr !=
5f39d397 2076 btrfs_node_blockptr(path->nodes[level], path->slots[level]))
79f95c82 2077 BUG();
54aa1f4d 2078enospc:
925baedd
CM
2079 if (right) {
2080 btrfs_tree_unlock(right);
5f39d397 2081 free_extent_buffer(right);
925baedd
CM
2082 }
2083 if (left) {
2084 if (path->nodes[level] != left)
2085 btrfs_tree_unlock(left);
5f39d397 2086 free_extent_buffer(left);
925baedd 2087 }
bb803951
CM
2088 return ret;
2089}
2090
d352ac68
CM
2091/* Node balancing for insertion. Here we only split or push nodes around
2092 * when they are completely full. This is also done top down, so we
2093 * have to be pessimistic.
2094 */
d397712b 2095static noinline int push_nodes_for_insert(struct btrfs_trans_handle *trans,
98ed5174
CM
2096 struct btrfs_root *root,
2097 struct btrfs_path *path, int level)
e66f709b 2098{
5f39d397
CM
2099 struct extent_buffer *right = NULL;
2100 struct extent_buffer *mid;
2101 struct extent_buffer *left = NULL;
2102 struct extent_buffer *parent = NULL;
e66f709b
CM
2103 int ret = 0;
2104 int wret;
2105 int pslot;
2106 int orig_slot = path->slots[level];
e66f709b
CM
2107
2108 if (level == 0)
2109 return 1;
2110
5f39d397 2111 mid = path->nodes[level];
7bb86316 2112 WARN_ON(btrfs_header_generation(mid) != trans->transid);
e66f709b 2113
a05a9bb1 2114 if (level < BTRFS_MAX_LEVEL - 1) {
5f39d397 2115 parent = path->nodes[level + 1];
a05a9bb1
LZ
2116 pslot = path->slots[level + 1];
2117 }
e66f709b 2118
5f39d397 2119 if (!parent)
e66f709b 2120 return 1;
e66f709b 2121
5f39d397 2122 left = read_node_slot(root, parent, pslot - 1);
e66f709b
CM
2123
2124 /* first, try to make some room in the middle buffer */
5f39d397 2125 if (left) {
e66f709b 2126 u32 left_nr;
925baedd
CM
2127
2128 btrfs_tree_lock(left);
b4ce94de
CM
2129 btrfs_set_lock_blocking(left);
2130
5f39d397 2131 left_nr = btrfs_header_nritems(left);
33ade1f8
CM
2132 if (left_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) {
2133 wret = 1;
2134 } else {
5f39d397 2135 ret = btrfs_cow_block(trans, root, left, parent,
9fa8cfe7 2136 pslot - 1, &left);
54aa1f4d
CM
2137 if (ret)
2138 wret = 1;
2139 else {
54aa1f4d 2140 wret = push_node_left(trans, root,
971a1f66 2141 left, mid, 0);
54aa1f4d 2142 }
33ade1f8 2143 }
e66f709b
CM
2144 if (wret < 0)
2145 ret = wret;
2146 if (wret == 0) {
5f39d397 2147 struct btrfs_disk_key disk_key;
e66f709b 2148 orig_slot += left_nr;
5f39d397 2149 btrfs_node_key(mid, &disk_key, 0);
f230475e 2150 tree_mod_log_set_node_key(root->fs_info, parent,
32adf090 2151 pslot, 0);
5f39d397
CM
2152 btrfs_set_node_key(parent, &disk_key, pslot);
2153 btrfs_mark_buffer_dirty(parent);
2154 if (btrfs_header_nritems(left) > orig_slot) {
2155 path->nodes[level] = left;
e66f709b
CM
2156 path->slots[level + 1] -= 1;
2157 path->slots[level] = orig_slot;
925baedd 2158 btrfs_tree_unlock(mid);
5f39d397 2159 free_extent_buffer(mid);
e66f709b
CM
2160 } else {
2161 orig_slot -=
5f39d397 2162 btrfs_header_nritems(left);
e66f709b 2163 path->slots[level] = orig_slot;
925baedd 2164 btrfs_tree_unlock(left);
5f39d397 2165 free_extent_buffer(left);
e66f709b 2166 }
e66f709b
CM
2167 return 0;
2168 }
925baedd 2169 btrfs_tree_unlock(left);
5f39d397 2170 free_extent_buffer(left);
e66f709b 2171 }
925baedd 2172 right = read_node_slot(root, parent, pslot + 1);
e66f709b
CM
2173
2174 /*
2175 * then try to empty the right most buffer into the middle
2176 */
5f39d397 2177 if (right) {
33ade1f8 2178 u32 right_nr;
b4ce94de 2179
925baedd 2180 btrfs_tree_lock(right);
b4ce94de
CM
2181 btrfs_set_lock_blocking(right);
2182
5f39d397 2183 right_nr = btrfs_header_nritems(right);
33ade1f8
CM
2184 if (right_nr >= BTRFS_NODEPTRS_PER_BLOCK(root) - 1) {
2185 wret = 1;
2186 } else {
5f39d397
CM
2187 ret = btrfs_cow_block(trans, root, right,
2188 parent, pslot + 1,
9fa8cfe7 2189 &right);
54aa1f4d
CM
2190 if (ret)
2191 wret = 1;
2192 else {
54aa1f4d 2193 wret = balance_node_right(trans, root,
5f39d397 2194 right, mid);
54aa1f4d 2195 }
33ade1f8 2196 }
e66f709b
CM
2197 if (wret < 0)
2198 ret = wret;
2199 if (wret == 0) {
5f39d397
CM
2200 struct btrfs_disk_key disk_key;
2201
2202 btrfs_node_key(right, &disk_key, 0);
f230475e 2203 tree_mod_log_set_node_key(root->fs_info, parent,
32adf090 2204 pslot + 1, 0);
5f39d397
CM
2205 btrfs_set_node_key(parent, &disk_key, pslot + 1);
2206 btrfs_mark_buffer_dirty(parent);
2207
2208 if (btrfs_header_nritems(mid) <= orig_slot) {
2209 path->nodes[level] = right;
e66f709b
CM
2210 path->slots[level + 1] += 1;
2211 path->slots[level] = orig_slot -
5f39d397 2212 btrfs_header_nritems(mid);
925baedd 2213 btrfs_tree_unlock(mid);
5f39d397 2214 free_extent_buffer(mid);
e66f709b 2215 } else {
925baedd 2216 btrfs_tree_unlock(right);
5f39d397 2217 free_extent_buffer(right);
e66f709b 2218 }
e66f709b
CM
2219 return 0;
2220 }
925baedd 2221 btrfs_tree_unlock(right);
5f39d397 2222 free_extent_buffer(right);
e66f709b 2223 }
e66f709b
CM
2224 return 1;
2225}
2226
3c69faec 2227/*
d352ac68
CM
2228 * readahead one full node of leaves, finding things that are close
2229 * to the block in 'slot', and triggering ra on them.
3c69faec 2230 */
c8c42864
CM
2231static void reada_for_search(struct btrfs_root *root,
2232 struct btrfs_path *path,
2233 int level, int slot, u64 objectid)
3c69faec 2234{
5f39d397 2235 struct extent_buffer *node;
01f46658 2236 struct btrfs_disk_key disk_key;
3c69faec 2237 u32 nritems;
3c69faec 2238 u64 search;
a7175319 2239 u64 target;
6b80053d 2240 u64 nread = 0;
cb25c2ea 2241 u64 gen;
3c69faec 2242 int direction = path->reada;
5f39d397 2243 struct extent_buffer *eb;
6b80053d
CM
2244 u32 nr;
2245 u32 blocksize;
2246 u32 nscan = 0;
db94535d 2247
a6b6e75e 2248 if (level != 1)
6702ed49
CM
2249 return;
2250
2251 if (!path->nodes[level])
3c69faec
CM
2252 return;
2253
5f39d397 2254 node = path->nodes[level];
925baedd 2255
3c69faec 2256 search = btrfs_node_blockptr(node, slot);
707e8a07 2257 blocksize = root->nodesize;
0308af44 2258 eb = btrfs_find_tree_block(root, search);
5f39d397
CM
2259 if (eb) {
2260 free_extent_buffer(eb);
3c69faec
CM
2261 return;
2262 }
2263
a7175319 2264 target = search;
6b80053d 2265
5f39d397 2266 nritems = btrfs_header_nritems(node);
6b80053d 2267 nr = slot;
25b8b936 2268
d397712b 2269 while (1) {
6b80053d
CM
2270 if (direction < 0) {
2271 if (nr == 0)
2272 break;
2273 nr--;
2274 } else if (direction > 0) {
2275 nr++;
2276 if (nr >= nritems)
2277 break;
3c69faec 2278 }
01f46658
CM
2279 if (path->reada < 0 && objectid) {
2280 btrfs_node_key(node, &disk_key, nr);
2281 if (btrfs_disk_key_objectid(&disk_key) != objectid)
2282 break;
2283 }
6b80053d 2284 search = btrfs_node_blockptr(node, nr);
a7175319
CM
2285 if ((search <= target && target - search <= 65536) ||
2286 (search > target && search - target <= 65536)) {
cb25c2ea 2287 gen = btrfs_node_ptr_generation(node, nr);
58dc4ce4 2288 readahead_tree_block(root, search, blocksize);
6b80053d
CM
2289 nread += blocksize;
2290 }
2291 nscan++;
a7175319 2292 if ((nread > 65536 || nscan > 32))
6b80053d 2293 break;
3c69faec
CM
2294 }
2295}
925baedd 2296
0b08851f
JB
2297static noinline void reada_for_balance(struct btrfs_root *root,
2298 struct btrfs_path *path, int level)
b4ce94de
CM
2299{
2300 int slot;
2301 int nritems;
2302 struct extent_buffer *parent;
2303 struct extent_buffer *eb;
2304 u64 gen;
2305 u64 block1 = 0;
2306 u64 block2 = 0;
b4ce94de
CM
2307 int blocksize;
2308
8c594ea8 2309 parent = path->nodes[level + 1];
b4ce94de 2310 if (!parent)
0b08851f 2311 return;
b4ce94de
CM
2312
2313 nritems = btrfs_header_nritems(parent);
8c594ea8 2314 slot = path->slots[level + 1];
707e8a07 2315 blocksize = root->nodesize;
b4ce94de
CM
2316
2317 if (slot > 0) {
2318 block1 = btrfs_node_blockptr(parent, slot - 1);
2319 gen = btrfs_node_ptr_generation(parent, slot - 1);
0308af44 2320 eb = btrfs_find_tree_block(root, block1);
b9fab919
CM
2321 /*
2322 * if we get -eagain from btrfs_buffer_uptodate, we
2323 * don't want to return eagain here. That will loop
2324 * forever
2325 */
2326 if (eb && btrfs_buffer_uptodate(eb, gen, 1) != 0)
b4ce94de
CM
2327 block1 = 0;
2328 free_extent_buffer(eb);
2329 }
8c594ea8 2330 if (slot + 1 < nritems) {
b4ce94de
CM
2331 block2 = btrfs_node_blockptr(parent, slot + 1);
2332 gen = btrfs_node_ptr_generation(parent, slot + 1);
0308af44 2333 eb = btrfs_find_tree_block(root, block2);
b9fab919 2334 if (eb && btrfs_buffer_uptodate(eb, gen, 1) != 0)
b4ce94de
CM
2335 block2 = 0;
2336 free_extent_buffer(eb);
2337 }
8c594ea8 2338
0b08851f 2339 if (block1)
58dc4ce4 2340 readahead_tree_block(root, block1, blocksize);
0b08851f 2341 if (block2)
58dc4ce4 2342 readahead_tree_block(root, block2, blocksize);
b4ce94de
CM
2343}
2344
2345
d352ac68 2346/*
d397712b
CM
2347 * when we walk down the tree, it is usually safe to unlock the higher layers
2348 * in the tree. The exceptions are when our path goes through slot 0, because
2349 * operations on the tree might require changing key pointers higher up in the
2350 * tree.
d352ac68 2351 *
d397712b
CM
2352 * callers might also have set path->keep_locks, which tells this code to keep
2353 * the lock if the path points to the last slot in the block. This is part of
2354 * walking through the tree, and selecting the next slot in the higher block.
d352ac68 2355 *
d397712b
CM
2356 * lowest_unlock sets the lowest level in the tree we're allowed to unlock. so
2357 * if lowest_unlock is 1, level 0 won't be unlocked
d352ac68 2358 */
e02119d5 2359static noinline void unlock_up(struct btrfs_path *path, int level,
f7c79f30
CM
2360 int lowest_unlock, int min_write_lock_level,
2361 int *write_lock_level)
925baedd
CM
2362{
2363 int i;
2364 int skip_level = level;
051e1b9f 2365 int no_skips = 0;
925baedd
CM
2366 struct extent_buffer *t;
2367
2368 for (i = level; i < BTRFS_MAX_LEVEL; i++) {
2369 if (!path->nodes[i])
2370 break;
2371 if (!path->locks[i])
2372 break;
051e1b9f 2373 if (!no_skips && path->slots[i] == 0) {
925baedd
CM
2374 skip_level = i + 1;
2375 continue;
2376 }
051e1b9f 2377 if (!no_skips && path->keep_locks) {
925baedd
CM
2378 u32 nritems;
2379 t = path->nodes[i];
2380 nritems = btrfs_header_nritems(t);
051e1b9f 2381 if (nritems < 1 || path->slots[i] >= nritems - 1) {
925baedd
CM
2382 skip_level = i + 1;
2383 continue;
2384 }
2385 }
051e1b9f
CM
2386 if (skip_level < i && i >= lowest_unlock)
2387 no_skips = 1;
2388
925baedd
CM
2389 t = path->nodes[i];
2390 if (i >= lowest_unlock && i > skip_level && path->locks[i]) {
bd681513 2391 btrfs_tree_unlock_rw(t, path->locks[i]);
925baedd 2392 path->locks[i] = 0;
f7c79f30
CM
2393 if (write_lock_level &&
2394 i > min_write_lock_level &&
2395 i <= *write_lock_level) {
2396 *write_lock_level = i - 1;
2397 }
925baedd
CM
2398 }
2399 }
2400}
2401
b4ce94de
CM
2402/*
2403 * This releases any locks held in the path starting at level and
2404 * going all the way up to the root.
2405 *
2406 * btrfs_search_slot will keep the lock held on higher nodes in a few
2407 * corner cases, such as COW of the block at slot zero in the node. This
2408 * ignores those rules, and it should only be called when there are no
2409 * more updates to be done higher up in the tree.
2410 */
2411noinline void btrfs_unlock_up_safe(struct btrfs_path *path, int level)
2412{
2413 int i;
2414
09a2a8f9 2415 if (path->keep_locks)
b4ce94de
CM
2416 return;
2417
2418 for (i = level; i < BTRFS_MAX_LEVEL; i++) {
2419 if (!path->nodes[i])
12f4dacc 2420 continue;
b4ce94de 2421 if (!path->locks[i])
12f4dacc 2422 continue;
bd681513 2423 btrfs_tree_unlock_rw(path->nodes[i], path->locks[i]);
b4ce94de
CM
2424 path->locks[i] = 0;
2425 }
2426}
2427
c8c42864
CM
2428/*
2429 * helper function for btrfs_search_slot. The goal is to find a block
2430 * in cache without setting the path to blocking. If we find the block
2431 * we return zero and the path is unchanged.
2432 *
2433 * If we can't find the block, we set the path blocking and do some
2434 * reada. -EAGAIN is returned and the search must be repeated.
2435 */
2436static int
2437read_block_for_search(struct btrfs_trans_handle *trans,
2438 struct btrfs_root *root, struct btrfs_path *p,
2439 struct extent_buffer **eb_ret, int level, int slot,
5d9e75c4 2440 struct btrfs_key *key, u64 time_seq)
c8c42864
CM
2441{
2442 u64 blocknr;
2443 u64 gen;
c8c42864
CM
2444 struct extent_buffer *b = *eb_ret;
2445 struct extent_buffer *tmp;
76a05b35 2446 int ret;
c8c42864
CM
2447
2448 blocknr = btrfs_node_blockptr(b, slot);
2449 gen = btrfs_node_ptr_generation(b, slot);
c8c42864 2450
0308af44 2451 tmp = btrfs_find_tree_block(root, blocknr);
cb44921a 2452 if (tmp) {
b9fab919 2453 /* first we do an atomic uptodate check */
bdf7c00e
JB
2454 if (btrfs_buffer_uptodate(tmp, gen, 1) > 0) {
2455 *eb_ret = tmp;
2456 return 0;
2457 }
2458
2459 /* the pages were up to date, but we failed
2460 * the generation number check. Do a full
2461 * read for the generation number that is correct.
2462 * We must do this without dropping locks so
2463 * we can trust our generation number
2464 */
2465 btrfs_set_path_blocking(p);
2466
2467 /* now we're allowed to do a blocking uptodate check */
2468 ret = btrfs_read_buffer(tmp, gen);
2469 if (!ret) {
2470 *eb_ret = tmp;
2471 return 0;
cb44921a 2472 }
bdf7c00e
JB
2473 free_extent_buffer(tmp);
2474 btrfs_release_path(p);
2475 return -EIO;
c8c42864
CM
2476 }
2477
2478 /*
2479 * reduce lock contention at high levels
2480 * of the btree by dropping locks before
76a05b35
CM
2481 * we read. Don't release the lock on the current
2482 * level because we need to walk this node to figure
2483 * out which blocks to read.
c8c42864 2484 */
8c594ea8
CM
2485 btrfs_unlock_up_safe(p, level + 1);
2486 btrfs_set_path_blocking(p);
2487
cb44921a 2488 free_extent_buffer(tmp);
c8c42864
CM
2489 if (p->reada)
2490 reada_for_search(root, p, level, slot, key->objectid);
2491
b3b4aa74 2492 btrfs_release_path(p);
76a05b35
CM
2493
2494 ret = -EAGAIN;
ce86cd59 2495 tmp = read_tree_block(root, blocknr, 0);
76a05b35
CM
2496 if (tmp) {
2497 /*
2498 * If the read above didn't mark this buffer up to date,
2499 * it will never end up being up to date. Set ret to EIO now
2500 * and give up so that our caller doesn't loop forever
2501 * on our EAGAINs.
2502 */
b9fab919 2503 if (!btrfs_buffer_uptodate(tmp, 0, 0))
76a05b35 2504 ret = -EIO;
c8c42864 2505 free_extent_buffer(tmp);
76a05b35
CM
2506 }
2507 return ret;
c8c42864
CM
2508}
2509
2510/*
2511 * helper function for btrfs_search_slot. This does all of the checks
2512 * for node-level blocks and does any balancing required based on
2513 * the ins_len.
2514 *
2515 * If no extra work was required, zero is returned. If we had to
2516 * drop the path, -EAGAIN is returned and btrfs_search_slot must
2517 * start over
2518 */
2519static int
2520setup_nodes_for_search(struct btrfs_trans_handle *trans,
2521 struct btrfs_root *root, struct btrfs_path *p,
bd681513
CM
2522 struct extent_buffer *b, int level, int ins_len,
2523 int *write_lock_level)
c8c42864
CM
2524{
2525 int ret;
2526 if ((p->search_for_split || ins_len > 0) && btrfs_header_nritems(b) >=
2527 BTRFS_NODEPTRS_PER_BLOCK(root) - 3) {
2528 int sret;
2529
bd681513
CM
2530 if (*write_lock_level < level + 1) {
2531 *write_lock_level = level + 1;
2532 btrfs_release_path(p);
2533 goto again;
2534 }
2535
c8c42864 2536 btrfs_set_path_blocking(p);
0b08851f 2537 reada_for_balance(root, p, level);
c8c42864 2538 sret = split_node(trans, root, p, level);
bd681513 2539 btrfs_clear_path_blocking(p, NULL, 0);
c8c42864
CM
2540
2541 BUG_ON(sret > 0);
2542 if (sret) {
2543 ret = sret;
2544 goto done;
2545 }
2546 b = p->nodes[level];
2547 } else if (ins_len < 0 && btrfs_header_nritems(b) <
cfbb9308 2548 BTRFS_NODEPTRS_PER_BLOCK(root) / 2) {
c8c42864
CM
2549 int sret;
2550
bd681513
CM
2551 if (*write_lock_level < level + 1) {
2552 *write_lock_level = level + 1;
2553 btrfs_release_path(p);
2554 goto again;
2555 }
2556
c8c42864 2557 btrfs_set_path_blocking(p);
0b08851f 2558 reada_for_balance(root, p, level);
c8c42864 2559 sret = balance_level(trans, root, p, level);
bd681513 2560 btrfs_clear_path_blocking(p, NULL, 0);
c8c42864
CM
2561
2562 if (sret) {
2563 ret = sret;
2564 goto done;
2565 }
2566 b = p->nodes[level];
2567 if (!b) {
b3b4aa74 2568 btrfs_release_path(p);
c8c42864
CM
2569 goto again;
2570 }
2571 BUG_ON(btrfs_header_nritems(b) == 1);
2572 }
2573 return 0;
2574
2575again:
2576 ret = -EAGAIN;
2577done:
2578 return ret;
2579}
2580
d7396f07
FDBM
2581static void key_search_validate(struct extent_buffer *b,
2582 struct btrfs_key *key,
2583 int level)
2584{
2585#ifdef CONFIG_BTRFS_ASSERT
2586 struct btrfs_disk_key disk_key;
2587
2588 btrfs_cpu_key_to_disk(&disk_key, key);
2589
2590 if (level == 0)
2591 ASSERT(!memcmp_extent_buffer(b, &disk_key,
2592 offsetof(struct btrfs_leaf, items[0].key),
2593 sizeof(disk_key)));
2594 else
2595 ASSERT(!memcmp_extent_buffer(b, &disk_key,
2596 offsetof(struct btrfs_node, ptrs[0].key),
2597 sizeof(disk_key)));
2598#endif
2599}
2600
2601static int key_search(struct extent_buffer *b, struct btrfs_key *key,
2602 int level, int *prev_cmp, int *slot)
2603{
2604 if (*prev_cmp != 0) {
2605 *prev_cmp = bin_search(b, key, level, slot);
2606 return *prev_cmp;
2607 }
2608
2609 key_search_validate(b, key, level);
2610 *slot = 0;
2611
2612 return 0;
2613}
2614
46da9e76 2615int btrfs_find_item(struct btrfs_root *fs_root, struct btrfs_path *path,
e33d5c3d
KN
2616 u64 iobjectid, u64 ioff, u8 key_type,
2617 struct btrfs_key *found_key)
2618{
2619 int ret;
2620 struct btrfs_key key;
2621 struct extent_buffer *eb;
46da9e76
DS
2622
2623 ASSERT(path);
e33d5c3d
KN
2624
2625 key.type = key_type;
2626 key.objectid = iobjectid;
2627 key.offset = ioff;
2628
2629 ret = btrfs_search_slot(NULL, fs_root, &key, path, 0, 0);
46da9e76 2630 if ((ret < 0) || (found_key == NULL))
e33d5c3d
KN
2631 return ret;
2632
2633 eb = path->nodes[0];
2634 if (ret && path->slots[0] >= btrfs_header_nritems(eb)) {
2635 ret = btrfs_next_leaf(fs_root, path);
2636 if (ret)
2637 return ret;
2638 eb = path->nodes[0];
2639 }
2640
2641 btrfs_item_key_to_cpu(eb, found_key, path->slots[0]);
2642 if (found_key->type != key.type ||
2643 found_key->objectid != key.objectid)
2644 return 1;
2645
2646 return 0;
2647}
2648
74123bd7
CM
2649/*
2650 * look for key in the tree. path is filled in with nodes along the way
2651 * if key is found, we return zero and you can find the item in the leaf
2652 * level of the path (level 0)
2653 *
2654 * If the key isn't found, the path points to the slot where it should
aa5d6bed
CM
2655 * be inserted, and 1 is returned. If there are other errors during the
2656 * search a negative error number is returned.
97571fd0
CM
2657 *
2658 * if ins_len > 0, nodes and leaves will be split as we walk down the
2659 * tree. if ins_len < 0, nodes will be merged as we walk down the tree (if
2660 * possible)
74123bd7 2661 */
e089f05c
CM
2662int btrfs_search_slot(struct btrfs_trans_handle *trans, struct btrfs_root
2663 *root, struct btrfs_key *key, struct btrfs_path *p, int
2664 ins_len, int cow)
be0e5c09 2665{
5f39d397 2666 struct extent_buffer *b;
be0e5c09
CM
2667 int slot;
2668 int ret;
33c66f43 2669 int err;
be0e5c09 2670 int level;
925baedd 2671 int lowest_unlock = 1;
bd681513
CM
2672 int root_lock;
2673 /* everything at write_lock_level or lower must be write locked */
2674 int write_lock_level = 0;
9f3a7427 2675 u8 lowest_level = 0;
f7c79f30 2676 int min_write_lock_level;
d7396f07 2677 int prev_cmp;
9f3a7427 2678
6702ed49 2679 lowest_level = p->lowest_level;
323ac95b 2680 WARN_ON(lowest_level && ins_len > 0);
22b0ebda 2681 WARN_ON(p->nodes[0] != NULL);
eb653de1 2682 BUG_ON(!cow && ins_len);
25179201 2683
bd681513 2684 if (ins_len < 0) {
925baedd 2685 lowest_unlock = 2;
65b51a00 2686
bd681513
CM
2687 /* when we are removing items, we might have to go up to level
2688 * two as we update tree pointers Make sure we keep write
2689 * for those levels as well
2690 */
2691 write_lock_level = 2;
2692 } else if (ins_len > 0) {
2693 /*
2694 * for inserting items, make sure we have a write lock on
2695 * level 1 so we can update keys
2696 */
2697 write_lock_level = 1;
2698 }
2699
2700 if (!cow)
2701 write_lock_level = -1;
2702
09a2a8f9 2703 if (cow && (p->keep_locks || p->lowest_level))
bd681513
CM
2704 write_lock_level = BTRFS_MAX_LEVEL;
2705
f7c79f30
CM
2706 min_write_lock_level = write_lock_level;
2707
bb803951 2708again:
d7396f07 2709 prev_cmp = -1;
bd681513
CM
2710 /*
2711 * we try very hard to do read locks on the root
2712 */
2713 root_lock = BTRFS_READ_LOCK;
2714 level = 0;
5d4f98a2 2715 if (p->search_commit_root) {
bd681513
CM
2716 /*
2717 * the commit roots are read only
2718 * so we always do read locks
2719 */
3f8a18cc
JB
2720 if (p->need_commit_sem)
2721 down_read(&root->fs_info->commit_root_sem);
5d4f98a2
YZ
2722 b = root->commit_root;
2723 extent_buffer_get(b);
bd681513 2724 level = btrfs_header_level(b);
3f8a18cc
JB
2725 if (p->need_commit_sem)
2726 up_read(&root->fs_info->commit_root_sem);
5d4f98a2 2727 if (!p->skip_locking)
bd681513 2728 btrfs_tree_read_lock(b);
5d4f98a2 2729 } else {
bd681513 2730 if (p->skip_locking) {
5d4f98a2 2731 b = btrfs_root_node(root);
bd681513
CM
2732 level = btrfs_header_level(b);
2733 } else {
2734 /* we don't know the level of the root node
2735 * until we actually have it read locked
2736 */
2737 b = btrfs_read_lock_root_node(root);
2738 level = btrfs_header_level(b);
2739 if (level <= write_lock_level) {
2740 /* whoops, must trade for write lock */
2741 btrfs_tree_read_unlock(b);
2742 free_extent_buffer(b);
2743 b = btrfs_lock_root_node(root);
2744 root_lock = BTRFS_WRITE_LOCK;
2745
2746 /* the level might have changed, check again */
2747 level = btrfs_header_level(b);
2748 }
2749 }
5d4f98a2 2750 }
bd681513
CM
2751 p->nodes[level] = b;
2752 if (!p->skip_locking)
2753 p->locks[level] = root_lock;
925baedd 2754
eb60ceac 2755 while (b) {
5f39d397 2756 level = btrfs_header_level(b);
65b51a00
CM
2757
2758 /*
2759 * setup the path here so we can release it under lock
2760 * contention with the cow code
2761 */
02217ed2 2762 if (cow) {
c8c42864
CM
2763 /*
2764 * if we don't really need to cow this block
2765 * then we don't want to set the path blocking,
2766 * so we test it here
2767 */
5d4f98a2 2768 if (!should_cow_block(trans, root, b))
65b51a00 2769 goto cow_done;
5d4f98a2 2770
bd681513
CM
2771 /*
2772 * must have write locks on this node and the
2773 * parent
2774 */
5124e00e
JB
2775 if (level > write_lock_level ||
2776 (level + 1 > write_lock_level &&
2777 level + 1 < BTRFS_MAX_LEVEL &&
2778 p->nodes[level + 1])) {
bd681513
CM
2779 write_lock_level = level + 1;
2780 btrfs_release_path(p);
2781 goto again;
2782 }
2783
160f4089 2784 btrfs_set_path_blocking(p);
33c66f43
YZ
2785 err = btrfs_cow_block(trans, root, b,
2786 p->nodes[level + 1],
2787 p->slots[level + 1], &b);
2788 if (err) {
33c66f43 2789 ret = err;
65b51a00 2790 goto done;
54aa1f4d 2791 }
02217ed2 2792 }
65b51a00 2793cow_done:
eb60ceac 2794 p->nodes[level] = b;
bd681513 2795 btrfs_clear_path_blocking(p, NULL, 0);
b4ce94de
CM
2796
2797 /*
2798 * we have a lock on b and as long as we aren't changing
2799 * the tree, there is no way to for the items in b to change.
2800 * It is safe to drop the lock on our parent before we
2801 * go through the expensive btree search on b.
2802 *
eb653de1
FDBM
2803 * If we're inserting or deleting (ins_len != 0), then we might
2804 * be changing slot zero, which may require changing the parent.
2805 * So, we can't drop the lock until after we know which slot
2806 * we're operating on.
b4ce94de 2807 */
eb653de1
FDBM
2808 if (!ins_len && !p->keep_locks) {
2809 int u = level + 1;
2810
2811 if (u < BTRFS_MAX_LEVEL && p->locks[u]) {
2812 btrfs_tree_unlock_rw(p->nodes[u], p->locks[u]);
2813 p->locks[u] = 0;
2814 }
2815 }
b4ce94de 2816
d7396f07 2817 ret = key_search(b, key, level, &prev_cmp, &slot);
b4ce94de 2818
5f39d397 2819 if (level != 0) {
33c66f43
YZ
2820 int dec = 0;
2821 if (ret && slot > 0) {
2822 dec = 1;
be0e5c09 2823 slot -= 1;
33c66f43 2824 }
be0e5c09 2825 p->slots[level] = slot;
33c66f43 2826 err = setup_nodes_for_search(trans, root, p, b, level,
bd681513 2827 ins_len, &write_lock_level);
33c66f43 2828 if (err == -EAGAIN)
c8c42864 2829 goto again;
33c66f43
YZ
2830 if (err) {
2831 ret = err;
c8c42864 2832 goto done;
33c66f43 2833 }
c8c42864
CM
2834 b = p->nodes[level];
2835 slot = p->slots[level];
b4ce94de 2836
bd681513
CM
2837 /*
2838 * slot 0 is special, if we change the key
2839 * we have to update the parent pointer
2840 * which means we must have a write lock
2841 * on the parent
2842 */
eb653de1 2843 if (slot == 0 && ins_len &&
bd681513
CM
2844 write_lock_level < level + 1) {
2845 write_lock_level = level + 1;
2846 btrfs_release_path(p);
2847 goto again;
2848 }
2849
f7c79f30
CM
2850 unlock_up(p, level, lowest_unlock,
2851 min_write_lock_level, &write_lock_level);
f9efa9c7 2852
925baedd 2853 if (level == lowest_level) {
33c66f43
YZ
2854 if (dec)
2855 p->slots[level]++;
5b21f2ed 2856 goto done;
925baedd 2857 }
ca7a79ad 2858
33c66f43 2859 err = read_block_for_search(trans, root, p,
5d9e75c4 2860 &b, level, slot, key, 0);
33c66f43 2861 if (err == -EAGAIN)
c8c42864 2862 goto again;
33c66f43
YZ
2863 if (err) {
2864 ret = err;
76a05b35 2865 goto done;
33c66f43 2866 }
76a05b35 2867
b4ce94de 2868 if (!p->skip_locking) {
bd681513
CM
2869 level = btrfs_header_level(b);
2870 if (level <= write_lock_level) {
2871 err = btrfs_try_tree_write_lock(b);
2872 if (!err) {
2873 btrfs_set_path_blocking(p);
2874 btrfs_tree_lock(b);
2875 btrfs_clear_path_blocking(p, b,
2876 BTRFS_WRITE_LOCK);
2877 }
2878 p->locks[level] = BTRFS_WRITE_LOCK;
2879 } else {
f82c458a 2880 err = btrfs_tree_read_lock_atomic(b);
bd681513
CM
2881 if (!err) {
2882 btrfs_set_path_blocking(p);
2883 btrfs_tree_read_lock(b);
2884 btrfs_clear_path_blocking(p, b,
2885 BTRFS_READ_LOCK);
2886 }
2887 p->locks[level] = BTRFS_READ_LOCK;
b4ce94de 2888 }
bd681513 2889 p->nodes[level] = b;
b4ce94de 2890 }
be0e5c09
CM
2891 } else {
2892 p->slots[level] = slot;
87b29b20
YZ
2893 if (ins_len > 0 &&
2894 btrfs_leaf_free_space(root, b) < ins_len) {
bd681513
CM
2895 if (write_lock_level < 1) {
2896 write_lock_level = 1;
2897 btrfs_release_path(p);
2898 goto again;
2899 }
2900
b4ce94de 2901 btrfs_set_path_blocking(p);
33c66f43
YZ
2902 err = split_leaf(trans, root, key,
2903 p, ins_len, ret == 0);
bd681513 2904 btrfs_clear_path_blocking(p, NULL, 0);
b4ce94de 2905
33c66f43
YZ
2906 BUG_ON(err > 0);
2907 if (err) {
2908 ret = err;
65b51a00
CM
2909 goto done;
2910 }
5c680ed6 2911 }
459931ec 2912 if (!p->search_for_split)
f7c79f30
CM
2913 unlock_up(p, level, lowest_unlock,
2914 min_write_lock_level, &write_lock_level);
65b51a00 2915 goto done;
be0e5c09
CM
2916 }
2917 }
65b51a00
CM
2918 ret = 1;
2919done:
b4ce94de
CM
2920 /*
2921 * we don't really know what they plan on doing with the path
2922 * from here on, so for now just mark it as blocking
2923 */
b9473439
CM
2924 if (!p->leave_spinning)
2925 btrfs_set_path_blocking(p);
5f5bc6b1 2926 if (ret < 0 && !p->skip_release_on_error)
b3b4aa74 2927 btrfs_release_path(p);
65b51a00 2928 return ret;
be0e5c09
CM
2929}
2930
5d9e75c4
JS
2931/*
2932 * Like btrfs_search_slot, this looks for a key in the given tree. It uses the
2933 * current state of the tree together with the operations recorded in the tree
2934 * modification log to search for the key in a previous version of this tree, as
2935 * denoted by the time_seq parameter.
2936 *
2937 * Naturally, there is no support for insert, delete or cow operations.
2938 *
2939 * The resulting path and return value will be set up as if we called
2940 * btrfs_search_slot at that point in time with ins_len and cow both set to 0.
2941 */
2942int btrfs_search_old_slot(struct btrfs_root *root, struct btrfs_key *key,
2943 struct btrfs_path *p, u64 time_seq)
2944{
2945 struct extent_buffer *b;
2946 int slot;
2947 int ret;
2948 int err;
2949 int level;
2950 int lowest_unlock = 1;
2951 u8 lowest_level = 0;
d4b4087c 2952 int prev_cmp = -1;
5d9e75c4
JS
2953
2954 lowest_level = p->lowest_level;
2955 WARN_ON(p->nodes[0] != NULL);
2956
2957 if (p->search_commit_root) {
2958 BUG_ON(time_seq);
2959 return btrfs_search_slot(NULL, root, key, p, 0, 0);
2960 }
2961
2962again:
5d9e75c4 2963 b = get_old_root(root, time_seq);
5d9e75c4 2964 level = btrfs_header_level(b);
5d9e75c4
JS
2965 p->locks[level] = BTRFS_READ_LOCK;
2966
2967 while (b) {
2968 level = btrfs_header_level(b);
2969 p->nodes[level] = b;
2970 btrfs_clear_path_blocking(p, NULL, 0);
2971
2972 /*
2973 * we have a lock on b and as long as we aren't changing
2974 * the tree, there is no way to for the items in b to change.
2975 * It is safe to drop the lock on our parent before we
2976 * go through the expensive btree search on b.
2977 */
2978 btrfs_unlock_up_safe(p, level + 1);
2979
d4b4087c
JB
2980 /*
2981 * Since we can unwind eb's we want to do a real search every
2982 * time.
2983 */
2984 prev_cmp = -1;
d7396f07 2985 ret = key_search(b, key, level, &prev_cmp, &slot);
5d9e75c4
JS
2986
2987 if (level != 0) {
2988 int dec = 0;
2989 if (ret && slot > 0) {
2990 dec = 1;
2991 slot -= 1;
2992 }
2993 p->slots[level] = slot;
2994 unlock_up(p, level, lowest_unlock, 0, NULL);
2995
2996 if (level == lowest_level) {
2997 if (dec)
2998 p->slots[level]++;
2999 goto done;
3000 }
3001
3002 err = read_block_for_search(NULL, root, p, &b, level,
3003 slot, key, time_seq);
3004 if (err == -EAGAIN)
3005 goto again;
3006 if (err) {
3007 ret = err;
3008 goto done;
3009 }
3010
3011 level = btrfs_header_level(b);
f82c458a 3012 err = btrfs_tree_read_lock_atomic(b);
5d9e75c4
JS
3013 if (!err) {
3014 btrfs_set_path_blocking(p);
3015 btrfs_tree_read_lock(b);
3016 btrfs_clear_path_blocking(p, b,
3017 BTRFS_READ_LOCK);
3018 }
9ec72677 3019 b = tree_mod_log_rewind(root->fs_info, p, b, time_seq);
db7f3436
JB
3020 if (!b) {
3021 ret = -ENOMEM;
3022 goto done;
3023 }
5d9e75c4
JS
3024 p->locks[level] = BTRFS_READ_LOCK;
3025 p->nodes[level] = b;
5d9e75c4
JS
3026 } else {
3027 p->slots[level] = slot;
3028 unlock_up(p, level, lowest_unlock, 0, NULL);
3029 goto done;
3030 }
3031 }
3032 ret = 1;
3033done:
3034 if (!p->leave_spinning)
3035 btrfs_set_path_blocking(p);
3036 if (ret < 0)
3037 btrfs_release_path(p);
3038
3039 return ret;
3040}
3041
2f38b3e1
AJ
3042/*
3043 * helper to use instead of search slot if no exact match is needed but
3044 * instead the next or previous item should be returned.
3045 * When find_higher is true, the next higher item is returned, the next lower
3046 * otherwise.
3047 * When return_any and find_higher are both true, and no higher item is found,
3048 * return the next lower instead.
3049 * When return_any is true and find_higher is false, and no lower item is found,
3050 * return the next higher instead.
3051 * It returns 0 if any item is found, 1 if none is found (tree empty), and
3052 * < 0 on error
3053 */
3054int btrfs_search_slot_for_read(struct btrfs_root *root,
3055 struct btrfs_key *key, struct btrfs_path *p,
3056 int find_higher, int return_any)
3057{
3058 int ret;
3059 struct extent_buffer *leaf;
3060
3061again:
3062 ret = btrfs_search_slot(NULL, root, key, p, 0, 0);
3063 if (ret <= 0)
3064 return ret;
3065 /*
3066 * a return value of 1 means the path is at the position where the
3067 * item should be inserted. Normally this is the next bigger item,
3068 * but in case the previous item is the last in a leaf, path points
3069 * to the first free slot in the previous leaf, i.e. at an invalid
3070 * item.
3071 */
3072 leaf = p->nodes[0];
3073
3074 if (find_higher) {
3075 if (p->slots[0] >= btrfs_header_nritems(leaf)) {
3076 ret = btrfs_next_leaf(root, p);
3077 if (ret <= 0)
3078 return ret;
3079 if (!return_any)
3080 return 1;
3081 /*
3082 * no higher item found, return the next
3083 * lower instead
3084 */
3085 return_any = 0;
3086 find_higher = 0;
3087 btrfs_release_path(p);
3088 goto again;
3089 }
3090 } else {
e6793769
AJ
3091 if (p->slots[0] == 0) {
3092 ret = btrfs_prev_leaf(root, p);
3093 if (ret < 0)
3094 return ret;
3095 if (!ret) {
23c6bf6a
FDBM
3096 leaf = p->nodes[0];
3097 if (p->slots[0] == btrfs_header_nritems(leaf))
3098 p->slots[0]--;
e6793769 3099 return 0;
2f38b3e1 3100 }
e6793769
AJ
3101 if (!return_any)
3102 return 1;
3103 /*
3104 * no lower item found, return the next
3105 * higher instead
3106 */
3107 return_any = 0;
3108 find_higher = 1;
3109 btrfs_release_path(p);
3110 goto again;
3111 } else {
2f38b3e1
AJ
3112 --p->slots[0];
3113 }
3114 }
3115 return 0;
3116}
3117
74123bd7
CM
3118/*
3119 * adjust the pointers going up the tree, starting at level
3120 * making sure the right key of each node is points to 'key'.
3121 * This is used after shifting pointers to the left, so it stops
3122 * fixing up pointers when a given leaf/node is not in slot 0 of the
3123 * higher levels
aa5d6bed 3124 *
74123bd7 3125 */
d6a0a126 3126static void fixup_low_keys(struct btrfs_root *root, struct btrfs_path *path,
143bede5 3127 struct btrfs_disk_key *key, int level)
be0e5c09
CM
3128{
3129 int i;
5f39d397
CM
3130 struct extent_buffer *t;
3131
234b63a0 3132 for (i = level; i < BTRFS_MAX_LEVEL; i++) {
be0e5c09 3133 int tslot = path->slots[i];
eb60ceac 3134 if (!path->nodes[i])
be0e5c09 3135 break;
5f39d397 3136 t = path->nodes[i];
32adf090 3137 tree_mod_log_set_node_key(root->fs_info, t, tslot, 1);
5f39d397 3138 btrfs_set_node_key(t, key, tslot);
d6025579 3139 btrfs_mark_buffer_dirty(path->nodes[i]);
be0e5c09
CM
3140 if (tslot != 0)
3141 break;
3142 }
3143}
3144
31840ae1
ZY
3145/*
3146 * update item key.
3147 *
3148 * This function isn't completely safe. It's the caller's responsibility
3149 * that the new key won't break the order
3150 */
afe5fea7 3151void btrfs_set_item_key_safe(struct btrfs_root *root, struct btrfs_path *path,
143bede5 3152 struct btrfs_key *new_key)
31840ae1
ZY
3153{
3154 struct btrfs_disk_key disk_key;
3155 struct extent_buffer *eb;
3156 int slot;
3157
3158 eb = path->nodes[0];
3159 slot = path->slots[0];
3160 if (slot > 0) {
3161 btrfs_item_key(eb, &disk_key, slot - 1);
143bede5 3162 BUG_ON(comp_keys(&disk_key, new_key) >= 0);
31840ae1
ZY
3163 }
3164 if (slot < btrfs_header_nritems(eb) - 1) {
3165 btrfs_item_key(eb, &disk_key, slot + 1);
143bede5 3166 BUG_ON(comp_keys(&disk_key, new_key) <= 0);
31840ae1
ZY
3167 }
3168
3169 btrfs_cpu_key_to_disk(&disk_key, new_key);
3170 btrfs_set_item_key(eb, &disk_key, slot);
3171 btrfs_mark_buffer_dirty(eb);
3172 if (slot == 0)
d6a0a126 3173 fixup_low_keys(root, path, &disk_key, 1);
31840ae1
ZY
3174}
3175
74123bd7
CM
3176/*
3177 * try to push data from one node into the next node left in the
79f95c82 3178 * tree.
aa5d6bed
CM
3179 *
3180 * returns 0 if some ptrs were pushed left, < 0 if there was some horrible
3181 * error, and > 0 if there was no room in the left hand block.
74123bd7 3182 */
98ed5174
CM
3183static int push_node_left(struct btrfs_trans_handle *trans,
3184 struct btrfs_root *root, struct extent_buffer *dst,
971a1f66 3185 struct extent_buffer *src, int empty)
be0e5c09 3186{
be0e5c09 3187 int push_items = 0;
bb803951
CM
3188 int src_nritems;
3189 int dst_nritems;
aa5d6bed 3190 int ret = 0;
be0e5c09 3191
5f39d397
CM
3192 src_nritems = btrfs_header_nritems(src);
3193 dst_nritems = btrfs_header_nritems(dst);
123abc88 3194 push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems;
7bb86316
CM
3195 WARN_ON(btrfs_header_generation(src) != trans->transid);
3196 WARN_ON(btrfs_header_generation(dst) != trans->transid);
54aa1f4d 3197
bce4eae9 3198 if (!empty && src_nritems <= 8)
971a1f66
CM
3199 return 1;
3200
d397712b 3201 if (push_items <= 0)
be0e5c09
CM
3202 return 1;
3203
bce4eae9 3204 if (empty) {
971a1f66 3205 push_items = min(src_nritems, push_items);
bce4eae9
CM
3206 if (push_items < src_nritems) {
3207 /* leave at least 8 pointers in the node if
3208 * we aren't going to empty it
3209 */
3210 if (src_nritems - push_items < 8) {
3211 if (push_items <= 8)
3212 return 1;
3213 push_items -= 8;
3214 }
3215 }
3216 } else
3217 push_items = min(src_nritems - 8, push_items);
79f95c82 3218
5de865ee
FDBM
3219 ret = tree_mod_log_eb_copy(root->fs_info, dst, src, dst_nritems, 0,
3220 push_items);
3221 if (ret) {
3222 btrfs_abort_transaction(trans, root, ret);
3223 return ret;
3224 }
5f39d397
CM
3225 copy_extent_buffer(dst, src,
3226 btrfs_node_key_ptr_offset(dst_nritems),
3227 btrfs_node_key_ptr_offset(0),
d397712b 3228 push_items * sizeof(struct btrfs_key_ptr));
5f39d397 3229
bb803951 3230 if (push_items < src_nritems) {
57911b8b
JS
3231 /*
3232 * don't call tree_mod_log_eb_move here, key removal was already
3233 * fully logged by tree_mod_log_eb_copy above.
3234 */
5f39d397
CM
3235 memmove_extent_buffer(src, btrfs_node_key_ptr_offset(0),
3236 btrfs_node_key_ptr_offset(push_items),
3237 (src_nritems - push_items) *
3238 sizeof(struct btrfs_key_ptr));
3239 }
3240 btrfs_set_header_nritems(src, src_nritems - push_items);
3241 btrfs_set_header_nritems(dst, dst_nritems + push_items);
3242 btrfs_mark_buffer_dirty(src);
3243 btrfs_mark_buffer_dirty(dst);
31840ae1 3244
79f95c82
CM
3245 return ret;
3246}
3247
3248/*
3249 * try to push data from one node into the next node right in the
3250 * tree.
3251 *
3252 * returns 0 if some ptrs were pushed, < 0 if there was some horrible
3253 * error, and > 0 if there was no room in the right hand block.
3254 *
3255 * this will only push up to 1/2 the contents of the left node over
3256 */
5f39d397
CM
3257static int balance_node_right(struct btrfs_trans_handle *trans,
3258 struct btrfs_root *root,
3259 struct extent_buffer *dst,
3260 struct extent_buffer *src)
79f95c82 3261{
79f95c82
CM
3262 int push_items = 0;
3263 int max_push;
3264 int src_nritems;
3265 int dst_nritems;
3266 int ret = 0;
79f95c82 3267
7bb86316
CM
3268 WARN_ON(btrfs_header_generation(src) != trans->transid);
3269 WARN_ON(btrfs_header_generation(dst) != trans->transid);
3270
5f39d397
CM
3271 src_nritems = btrfs_header_nritems(src);
3272 dst_nritems = btrfs_header_nritems(dst);
123abc88 3273 push_items = BTRFS_NODEPTRS_PER_BLOCK(root) - dst_nritems;
d397712b 3274 if (push_items <= 0)
79f95c82 3275 return 1;
bce4eae9 3276
d397712b 3277 if (src_nritems < 4)
bce4eae9 3278 return 1;
79f95c82
CM
3279
3280 max_push = src_nritems / 2 + 1;
3281 /* don't try to empty the node */
d397712b 3282 if (max_push >= src_nritems)
79f95c82 3283 return 1;
252c38f0 3284
79f95c82
CM
3285 if (max_push < push_items)
3286 push_items = max_push;
3287
f230475e 3288 tree_mod_log_eb_move(root->fs_info, dst, push_items, 0, dst_nritems);
5f39d397
CM
3289 memmove_extent_buffer(dst, btrfs_node_key_ptr_offset(push_items),
3290 btrfs_node_key_ptr_offset(0),
3291 (dst_nritems) *
3292 sizeof(struct btrfs_key_ptr));
d6025579 3293
5de865ee
FDBM
3294 ret = tree_mod_log_eb_copy(root->fs_info, dst, src, 0,
3295 src_nritems - push_items, push_items);
3296 if (ret) {
3297 btrfs_abort_transaction(trans, root, ret);
3298 return ret;
3299 }
5f39d397
CM
3300 copy_extent_buffer(dst, src,
3301 btrfs_node_key_ptr_offset(0),
3302 btrfs_node_key_ptr_offset(src_nritems - push_items),
d397712b 3303 push_items * sizeof(struct btrfs_key_ptr));
79f95c82 3304
5f39d397
CM
3305 btrfs_set_header_nritems(src, src_nritems - push_items);
3306 btrfs_set_header_nritems(dst, dst_nritems + push_items);
79f95c82 3307
5f39d397
CM
3308 btrfs_mark_buffer_dirty(src);
3309 btrfs_mark_buffer_dirty(dst);
31840ae1 3310
aa5d6bed 3311 return ret;
be0e5c09
CM
3312}
3313
97571fd0
CM
3314/*
3315 * helper function to insert a new root level in the tree.
3316 * A new node is allocated, and a single item is inserted to
3317 * point to the existing root
aa5d6bed
CM
3318 *
3319 * returns zero on success or < 0 on failure.
97571fd0 3320 */
d397712b 3321static noinline int insert_new_root(struct btrfs_trans_handle *trans,
5f39d397 3322 struct btrfs_root *root,
fdd99c72 3323 struct btrfs_path *path, int level)
5c680ed6 3324{
7bb86316 3325 u64 lower_gen;
5f39d397
CM
3326 struct extent_buffer *lower;
3327 struct extent_buffer *c;
925baedd 3328 struct extent_buffer *old;
5f39d397 3329 struct btrfs_disk_key lower_key;
5c680ed6
CM
3330
3331 BUG_ON(path->nodes[level]);
3332 BUG_ON(path->nodes[level-1] != root->node);
3333
7bb86316
CM
3334 lower = path->nodes[level-1];
3335 if (level == 1)
3336 btrfs_item_key(lower, &lower_key, 0);
3337 else
3338 btrfs_node_key(lower, &lower_key, 0);
3339
4d75f8a9
DS
3340 c = btrfs_alloc_tree_block(trans, root, 0, root->root_key.objectid,
3341 &lower_key, level, root->node->start, 0);
5f39d397
CM
3342 if (IS_ERR(c))
3343 return PTR_ERR(c);
925baedd 3344
f0486c68
YZ
3345 root_add_used(root, root->nodesize);
3346
5d4f98a2 3347 memset_extent_buffer(c, 0, 0, sizeof(struct btrfs_header));
5f39d397
CM
3348 btrfs_set_header_nritems(c, 1);
3349 btrfs_set_header_level(c, level);
db94535d 3350 btrfs_set_header_bytenr(c, c->start);
5f39d397 3351 btrfs_set_header_generation(c, trans->transid);
5d4f98a2 3352 btrfs_set_header_backref_rev(c, BTRFS_MIXED_BACKREF_REV);
5f39d397 3353 btrfs_set_header_owner(c, root->root_key.objectid);
5f39d397 3354
0a4e5586 3355 write_extent_buffer(c, root->fs_info->fsid, btrfs_header_fsid(),
5f39d397 3356 BTRFS_FSID_SIZE);
e17cade2
CM
3357
3358 write_extent_buffer(c, root->fs_info->chunk_tree_uuid,
b308bc2f 3359 btrfs_header_chunk_tree_uuid(c), BTRFS_UUID_SIZE);
e17cade2 3360
5f39d397 3361 btrfs_set_node_key(c, &lower_key, 0);
db94535d 3362 btrfs_set_node_blockptr(c, 0, lower->start);
7bb86316 3363 lower_gen = btrfs_header_generation(lower);
31840ae1 3364 WARN_ON(lower_gen != trans->transid);
7bb86316
CM
3365
3366 btrfs_set_node_ptr_generation(c, 0, lower_gen);
d5719762 3367
5f39d397 3368 btrfs_mark_buffer_dirty(c);
d5719762 3369
925baedd 3370 old = root->node;
fdd99c72 3371 tree_mod_log_set_root_pointer(root, c, 0);
240f62c8 3372 rcu_assign_pointer(root->node, c);
925baedd
CM
3373
3374 /* the super has an extra ref to root->node */
3375 free_extent_buffer(old);
3376
0b86a832 3377 add_root_to_dirty_list(root);
5f39d397
CM
3378 extent_buffer_get(c);
3379 path->nodes[level] = c;
bd681513 3380 path->locks[level] = BTRFS_WRITE_LOCK;
5c680ed6
CM
3381 path->slots[level] = 0;
3382 return 0;
3383}
3384
74123bd7
CM
3385/*
3386 * worker function to insert a single pointer in a node.
3387 * the node should have enough room for the pointer already
97571fd0 3388 *
74123bd7
CM
3389 * slot and level indicate where you want the key to go, and
3390 * blocknr is the block the key points to.
3391 */
143bede5
JM
3392static void insert_ptr(struct btrfs_trans_handle *trans,
3393 struct btrfs_root *root, struct btrfs_path *path,
3394 struct btrfs_disk_key *key, u64 bytenr,
c3e06965 3395 int slot, int level)
74123bd7 3396{
5f39d397 3397 struct extent_buffer *lower;
74123bd7 3398 int nritems;
f3ea38da 3399 int ret;
5c680ed6
CM
3400
3401 BUG_ON(!path->nodes[level]);
f0486c68 3402 btrfs_assert_tree_locked(path->nodes[level]);
5f39d397
CM
3403 lower = path->nodes[level];
3404 nritems = btrfs_header_nritems(lower);
c293498b 3405 BUG_ON(slot > nritems);
143bede5 3406 BUG_ON(nritems == BTRFS_NODEPTRS_PER_BLOCK(root));
74123bd7 3407 if (slot != nritems) {
c3e06965 3408 if (level)
f3ea38da
JS
3409 tree_mod_log_eb_move(root->fs_info, lower, slot + 1,
3410 slot, nritems - slot);
5f39d397
CM
3411 memmove_extent_buffer(lower,
3412 btrfs_node_key_ptr_offset(slot + 1),
3413 btrfs_node_key_ptr_offset(slot),
d6025579 3414 (nritems - slot) * sizeof(struct btrfs_key_ptr));
74123bd7 3415 }
c3e06965 3416 if (level) {
f3ea38da 3417 ret = tree_mod_log_insert_key(root->fs_info, lower, slot,
c8cc6341 3418 MOD_LOG_KEY_ADD, GFP_NOFS);
f3ea38da
JS
3419 BUG_ON(ret < 0);
3420 }
5f39d397 3421 btrfs_set_node_key(lower, key, slot);
db94535d 3422 btrfs_set_node_blockptr(lower, slot, bytenr);
74493f7a
CM
3423 WARN_ON(trans->transid == 0);
3424 btrfs_set_node_ptr_generation(lower, slot, trans->transid);
5f39d397
CM
3425 btrfs_set_header_nritems(lower, nritems + 1);
3426 btrfs_mark_buffer_dirty(lower);
74123bd7
CM
3427}
3428
97571fd0
CM
3429/*
3430 * split the node at the specified level in path in two.
3431 * The path is corrected to point to the appropriate node after the split
3432 *
3433 * Before splitting this tries to make some room in the node by pushing
3434 * left and right, if either one works, it returns right away.
aa5d6bed
CM
3435 *
3436 * returns 0 on success and < 0 on failure
97571fd0 3437 */
e02119d5
CM
3438static noinline int split_node(struct btrfs_trans_handle *trans,
3439 struct btrfs_root *root,
3440 struct btrfs_path *path, int level)
be0e5c09 3441{
5f39d397
CM
3442 struct extent_buffer *c;
3443 struct extent_buffer *split;
3444 struct btrfs_disk_key disk_key;
be0e5c09 3445 int mid;
5c680ed6 3446 int ret;
7518a238 3447 u32 c_nritems;
eb60ceac 3448
5f39d397 3449 c = path->nodes[level];
7bb86316 3450 WARN_ON(btrfs_header_generation(c) != trans->transid);
5f39d397 3451 if (c == root->node) {
d9abbf1c 3452 /*
90f8d62e
JS
3453 * trying to split the root, lets make a new one
3454 *
fdd99c72 3455 * tree mod log: We don't log_removal old root in
90f8d62e
JS
3456 * insert_new_root, because that root buffer will be kept as a
3457 * normal node. We are going to log removal of half of the
3458 * elements below with tree_mod_log_eb_copy. We're holding a
3459 * tree lock on the buffer, which is why we cannot race with
3460 * other tree_mod_log users.
d9abbf1c 3461 */
fdd99c72 3462 ret = insert_new_root(trans, root, path, level + 1);
5c680ed6
CM
3463 if (ret)
3464 return ret;
b3612421 3465 } else {
e66f709b 3466 ret = push_nodes_for_insert(trans, root, path, level);
5f39d397
CM
3467 c = path->nodes[level];
3468 if (!ret && btrfs_header_nritems(c) <
c448acf0 3469 BTRFS_NODEPTRS_PER_BLOCK(root) - 3)
e66f709b 3470 return 0;
54aa1f4d
CM
3471 if (ret < 0)
3472 return ret;
be0e5c09 3473 }
e66f709b 3474
5f39d397 3475 c_nritems = btrfs_header_nritems(c);
5d4f98a2
YZ
3476 mid = (c_nritems + 1) / 2;
3477 btrfs_node_key(c, &disk_key, mid);
7bb86316 3478
4d75f8a9
DS
3479 split = btrfs_alloc_tree_block(trans, root, 0, root->root_key.objectid,
3480 &disk_key, level, c->start, 0);
5f39d397
CM
3481 if (IS_ERR(split))
3482 return PTR_ERR(split);
3483
f0486c68
YZ
3484 root_add_used(root, root->nodesize);
3485
5d4f98a2 3486 memset_extent_buffer(split, 0, 0, sizeof(struct btrfs_header));
5f39d397 3487 btrfs_set_header_level(split, btrfs_header_level(c));
db94535d 3488 btrfs_set_header_bytenr(split, split->start);
5f39d397 3489 btrfs_set_header_generation(split, trans->transid);
5d4f98a2 3490 btrfs_set_header_backref_rev(split, BTRFS_MIXED_BACKREF_REV);
5f39d397
CM
3491 btrfs_set_header_owner(split, root->root_key.objectid);
3492 write_extent_buffer(split, root->fs_info->fsid,
0a4e5586 3493 btrfs_header_fsid(), BTRFS_FSID_SIZE);
e17cade2 3494 write_extent_buffer(split, root->fs_info->chunk_tree_uuid,
b308bc2f 3495 btrfs_header_chunk_tree_uuid(split),
e17cade2 3496 BTRFS_UUID_SIZE);
54aa1f4d 3497
5de865ee
FDBM
3498 ret = tree_mod_log_eb_copy(root->fs_info, split, c, 0,
3499 mid, c_nritems - mid);
3500 if (ret) {
3501 btrfs_abort_transaction(trans, root, ret);
3502 return ret;
3503 }
5f39d397
CM
3504 copy_extent_buffer(split, c,
3505 btrfs_node_key_ptr_offset(0),
3506 btrfs_node_key_ptr_offset(mid),
3507 (c_nritems - mid) * sizeof(struct btrfs_key_ptr));
3508 btrfs_set_header_nritems(split, c_nritems - mid);
3509 btrfs_set_header_nritems(c, mid);
aa5d6bed
CM
3510 ret = 0;
3511
5f39d397
CM
3512 btrfs_mark_buffer_dirty(c);
3513 btrfs_mark_buffer_dirty(split);
3514
143bede5 3515 insert_ptr(trans, root, path, &disk_key, split->start,
c3e06965 3516 path->slots[level + 1] + 1, level + 1);
aa5d6bed 3517
5de08d7d 3518 if (path->slots[level] >= mid) {
5c680ed6 3519 path->slots[level] -= mid;
925baedd 3520 btrfs_tree_unlock(c);
5f39d397
CM
3521 free_extent_buffer(c);
3522 path->nodes[level] = split;
5c680ed6
CM
3523 path->slots[level + 1] += 1;
3524 } else {
925baedd 3525 btrfs_tree_unlock(split);
5f39d397 3526 free_extent_buffer(split);
be0e5c09 3527 }
aa5d6bed 3528 return ret;
be0e5c09
CM
3529}
3530
74123bd7
CM
3531/*
3532 * how many bytes are required to store the items in a leaf. start
3533 * and nr indicate which items in the leaf to check. This totals up the
3534 * space used both by the item structs and the item data
3535 */
5f39d397 3536static int leaf_space_used(struct extent_buffer *l, int start, int nr)
be0e5c09 3537{
41be1f3b
JB
3538 struct btrfs_item *start_item;
3539 struct btrfs_item *end_item;
3540 struct btrfs_map_token token;
be0e5c09 3541 int data_len;
5f39d397 3542 int nritems = btrfs_header_nritems(l);
d4dbff95 3543 int end = min(nritems, start + nr) - 1;
be0e5c09
CM
3544
3545 if (!nr)
3546 return 0;
41be1f3b 3547 btrfs_init_map_token(&token);
dd3cc16b
RK
3548 start_item = btrfs_item_nr(start);
3549 end_item = btrfs_item_nr(end);
41be1f3b
JB
3550 data_len = btrfs_token_item_offset(l, start_item, &token) +
3551 btrfs_token_item_size(l, start_item, &token);
3552 data_len = data_len - btrfs_token_item_offset(l, end_item, &token);
0783fcfc 3553 data_len += sizeof(struct btrfs_item) * nr;
d4dbff95 3554 WARN_ON(data_len < 0);
be0e5c09
CM
3555 return data_len;
3556}
3557
d4dbff95
CM
3558/*
3559 * The space between the end of the leaf items and
3560 * the start of the leaf data. IOW, how much room
3561 * the leaf has left for both items and data
3562 */
d397712b 3563noinline int btrfs_leaf_free_space(struct btrfs_root *root,
e02119d5 3564 struct extent_buffer *leaf)
d4dbff95 3565{
5f39d397
CM
3566 int nritems = btrfs_header_nritems(leaf);
3567 int ret;
3568 ret = BTRFS_LEAF_DATA_SIZE(root) - leaf_space_used(leaf, 0, nritems);
3569 if (ret < 0) {
efe120a0
FH
3570 btrfs_crit(root->fs_info,
3571 "leaf free space ret %d, leaf data size %lu, used %d nritems %d",
ae2f5411 3572 ret, (unsigned long) BTRFS_LEAF_DATA_SIZE(root),
5f39d397
CM
3573 leaf_space_used(leaf, 0, nritems), nritems);
3574 }
3575 return ret;
d4dbff95
CM
3576}
3577
99d8f83c
CM
3578/*
3579 * min slot controls the lowest index we're willing to push to the
3580 * right. We'll push up to and including min_slot, but no lower
3581 */
44871b1b
CM
3582static noinline int __push_leaf_right(struct btrfs_trans_handle *trans,
3583 struct btrfs_root *root,
3584 struct btrfs_path *path,
3585 int data_size, int empty,
3586 struct extent_buffer *right,
99d8f83c
CM
3587 int free_space, u32 left_nritems,
3588 u32 min_slot)
00ec4c51 3589{
5f39d397 3590 struct extent_buffer *left = path->nodes[0];
44871b1b 3591 struct extent_buffer *upper = path->nodes[1];
cfed81a0 3592 struct btrfs_map_token token;
5f39d397 3593 struct btrfs_disk_key disk_key;
00ec4c51 3594 int slot;
34a38218 3595 u32 i;
00ec4c51
CM
3596 int push_space = 0;
3597 int push_items = 0;
0783fcfc 3598 struct btrfs_item *item;
34a38218 3599 u32 nr;
7518a238 3600 u32 right_nritems;
5f39d397 3601 u32 data_end;
db94535d 3602 u32 this_item_size;
00ec4c51 3603
cfed81a0
CM
3604 btrfs_init_map_token(&token);
3605
34a38218
CM
3606 if (empty)
3607 nr = 0;
3608 else
99d8f83c 3609 nr = max_t(u32, 1, min_slot);
34a38218 3610
31840ae1 3611 if (path->slots[0] >= left_nritems)
87b29b20 3612 push_space += data_size;
31840ae1 3613
44871b1b 3614 slot = path->slots[1];
34a38218
CM
3615 i = left_nritems - 1;
3616 while (i >= nr) {
dd3cc16b 3617 item = btrfs_item_nr(i);
db94535d 3618
31840ae1
ZY
3619 if (!empty && push_items > 0) {
3620 if (path->slots[0] > i)
3621 break;
3622 if (path->slots[0] == i) {
3623 int space = btrfs_leaf_free_space(root, left);
3624 if (space + push_space * 2 > free_space)
3625 break;
3626 }
3627 }
3628
00ec4c51 3629 if (path->slots[0] == i)
87b29b20 3630 push_space += data_size;
db94535d 3631
db94535d
CM
3632 this_item_size = btrfs_item_size(left, item);
3633 if (this_item_size + sizeof(*item) + push_space > free_space)
00ec4c51 3634 break;
31840ae1 3635
00ec4c51 3636 push_items++;
db94535d 3637 push_space += this_item_size + sizeof(*item);
34a38218
CM
3638 if (i == 0)
3639 break;
3640 i--;
db94535d 3641 }
5f39d397 3642
925baedd
CM
3643 if (push_items == 0)
3644 goto out_unlock;
5f39d397 3645
6c1500f2 3646 WARN_ON(!empty && push_items == left_nritems);
5f39d397 3647
00ec4c51 3648 /* push left to right */
5f39d397 3649 right_nritems = btrfs_header_nritems(right);
34a38218 3650
5f39d397 3651 push_space = btrfs_item_end_nr(left, left_nritems - push_items);
123abc88 3652 push_space -= leaf_data_end(root, left);
5f39d397 3653
00ec4c51 3654 /* make room in the right data area */
5f39d397
CM
3655 data_end = leaf_data_end(root, right);
3656 memmove_extent_buffer(right,
3657 btrfs_leaf_data(right) + data_end - push_space,
3658 btrfs_leaf_data(right) + data_end,
3659 BTRFS_LEAF_DATA_SIZE(root) - data_end);
3660
00ec4c51 3661 /* copy from the left data area */
5f39d397 3662 copy_extent_buffer(right, left, btrfs_leaf_data(right) +
d6025579
CM
3663 BTRFS_LEAF_DATA_SIZE(root) - push_space,
3664 btrfs_leaf_data(left) + leaf_data_end(root, left),
3665 push_space);
5f39d397
CM
3666
3667 memmove_extent_buffer(right, btrfs_item_nr_offset(push_items),
3668 btrfs_item_nr_offset(0),
3669 right_nritems * sizeof(struct btrfs_item));
3670
00ec4c51 3671 /* copy the items from left to right */
5f39d397
CM
3672 copy_extent_buffer(right, left, btrfs_item_nr_offset(0),
3673 btrfs_item_nr_offset(left_nritems - push_items),
3674 push_items * sizeof(struct btrfs_item));
00ec4c51
CM
3675
3676 /* update the item pointers */
7518a238 3677 right_nritems += push_items;
5f39d397 3678 btrfs_set_header_nritems(right, right_nritems);
123abc88 3679 push_space = BTRFS_LEAF_DATA_SIZE(root);
7518a238 3680 for (i = 0; i < right_nritems; i++) {
dd3cc16b 3681 item = btrfs_item_nr(i);
cfed81a0
CM
3682 push_space -= btrfs_token_item_size(right, item, &token);
3683 btrfs_set_token_item_offset(right, item, push_space, &token);
db94535d
CM
3684 }
3685
7518a238 3686 left_nritems -= push_items;
5f39d397 3687 btrfs_set_header_nritems(left, left_nritems);
00ec4c51 3688
34a38218
CM
3689 if (left_nritems)
3690 btrfs_mark_buffer_dirty(left);
f0486c68
YZ
3691 else
3692 clean_tree_block(trans, root, left);
3693
5f39d397 3694 btrfs_mark_buffer_dirty(right);
a429e513 3695
5f39d397
CM
3696 btrfs_item_key(right, &disk_key, 0);
3697 btrfs_set_node_key(upper, &disk_key, slot + 1);
d6025579 3698 btrfs_mark_buffer_dirty(upper);
02217ed2 3699
00ec4c51 3700 /* then fixup the leaf pointer in the path */
7518a238
CM
3701 if (path->slots[0] >= left_nritems) {
3702 path->slots[0] -= left_nritems;
925baedd
CM
3703 if (btrfs_header_nritems(path->nodes[0]) == 0)
3704 clean_tree_block(trans, root, path->nodes[0]);
3705 btrfs_tree_unlock(path->nodes[0]);
5f39d397
CM
3706 free_extent_buffer(path->nodes[0]);
3707 path->nodes[0] = right;
00ec4c51
CM
3708 path->slots[1] += 1;
3709 } else {
925baedd 3710 btrfs_tree_unlock(right);
5f39d397 3711 free_extent_buffer(right);
00ec4c51
CM
3712 }
3713 return 0;
925baedd
CM
3714
3715out_unlock:
3716 btrfs_tree_unlock(right);
3717 free_extent_buffer(right);
3718 return 1;
00ec4c51 3719}
925baedd 3720
44871b1b
CM
3721/*
3722 * push some data in the path leaf to the right, trying to free up at
3723 * least data_size bytes. returns zero if the push worked, nonzero otherwise
3724 *
3725 * returns 1 if the push failed because the other node didn't have enough
3726 * room, 0 if everything worked out and < 0 if there were major errors.
99d8f83c
CM
3727 *
3728 * this will push starting from min_slot to the end of the leaf. It won't
3729 * push any slot lower than min_slot
44871b1b
CM
3730 */
3731static int push_leaf_right(struct btrfs_trans_handle *trans, struct btrfs_root
99d8f83c
CM
3732 *root, struct btrfs_path *path,
3733 int min_data_size, int data_size,
3734 int empty, u32 min_slot)
44871b1b
CM
3735{
3736 struct extent_buffer *left = path->nodes[0];
3737 struct extent_buffer *right;
3738 struct extent_buffer *upper;
3739 int slot;
3740 int free_space;
3741 u32 left_nritems;
3742 int ret;
3743
3744 if (!path->nodes[1])
3745 return 1;
3746
3747 slot = path->slots[1];
3748 upper = path->nodes[1];
3749 if (slot >= btrfs_header_nritems(upper) - 1)
3750 return 1;
3751
3752 btrfs_assert_tree_locked(path->nodes[1]);
3753
3754 right = read_node_slot(root, upper, slot + 1);
91ca338d
TI
3755 if (right == NULL)
3756 return 1;
3757
44871b1b
CM
3758 btrfs_tree_lock(right);
3759 btrfs_set_lock_blocking(right);
3760
3761 free_space = btrfs_leaf_free_space(root, right);
3762 if (free_space < data_size)
3763 goto out_unlock;
3764
3765 /* cow and double check */
3766 ret = btrfs_cow_block(trans, root, right, upper,
3767 slot + 1, &right);
3768 if (ret)
3769 goto out_unlock;
3770
3771 free_space = btrfs_leaf_free_space(root, right);
3772 if (free_space < data_size)
3773 goto out_unlock;
3774
3775 left_nritems = btrfs_header_nritems(left);
3776 if (left_nritems == 0)
3777 goto out_unlock;
3778
2ef1fed2
FDBM
3779 if (path->slots[0] == left_nritems && !empty) {
3780 /* Key greater than all keys in the leaf, right neighbor has
3781 * enough room for it and we're not emptying our leaf to delete
3782 * it, therefore use right neighbor to insert the new item and
3783 * no need to touch/dirty our left leaft. */
3784 btrfs_tree_unlock(left);
3785 free_extent_buffer(left);
3786 path->nodes[0] = right;
3787 path->slots[0] = 0;
3788 path->slots[1]++;
3789 return 0;
3790 }
3791
99d8f83c
CM
3792 return __push_leaf_right(trans, root, path, min_data_size, empty,
3793 right, free_space, left_nritems, min_slot);
44871b1b
CM
3794out_unlock:
3795 btrfs_tree_unlock(right);
3796 free_extent_buffer(right);
3797 return 1;
3798}
3799
74123bd7
CM
3800/*
3801 * push some data in the path leaf to the left, trying to free up at
3802 * least data_size bytes. returns zero if the push worked, nonzero otherwise
99d8f83c
CM
3803 *
3804 * max_slot can put a limit on how far into the leaf we'll push items. The
3805 * item at 'max_slot' won't be touched. Use (u32)-1 to make us do all the
3806 * items
74123bd7 3807 */
44871b1b
CM
3808static noinline int __push_leaf_left(struct btrfs_trans_handle *trans,
3809 struct btrfs_root *root,
3810 struct btrfs_path *path, int data_size,
3811 int empty, struct extent_buffer *left,
99d8f83c
CM
3812 int free_space, u32 right_nritems,
3813 u32 max_slot)
be0e5c09 3814{
5f39d397
CM
3815 struct btrfs_disk_key disk_key;
3816 struct extent_buffer *right = path->nodes[0];
be0e5c09 3817 int i;
be0e5c09
CM
3818 int push_space = 0;
3819 int push_items = 0;
0783fcfc 3820 struct btrfs_item *item;
7518a238 3821 u32 old_left_nritems;
34a38218 3822 u32 nr;
aa5d6bed 3823 int ret = 0;
db94535d
CM
3824 u32 this_item_size;
3825 u32 old_left_item_size;
cfed81a0
CM
3826 struct btrfs_map_token token;
3827
3828 btrfs_init_map_token(&token);
be0e5c09 3829
34a38218 3830 if (empty)
99d8f83c 3831 nr = min(right_nritems, max_slot);
34a38218 3832 else
99d8f83c 3833 nr = min(right_nritems - 1, max_slot);
34a38218
CM
3834
3835 for (i = 0; i < nr; i++) {
dd3cc16b 3836 item = btrfs_item_nr(i);
db94535d 3837
31840ae1
ZY
3838 if (!empty && push_items > 0) {
3839 if (path->slots[0] < i)
3840 break;
3841 if (path->slots[0] == i) {
3842 int space = btrfs_leaf_free_space(root, right);
3843 if (space + push_space * 2 > free_space)
3844 break;
3845 }
3846 }
3847
be0e5c09 3848 if (path->slots[0] == i)
87b29b20 3849 push_space += data_size;
db94535d
CM
3850
3851 this_item_size = btrfs_item_size(right, item);
3852 if (this_item_size + sizeof(*item) + push_space > free_space)
be0e5c09 3853 break;
db94535d 3854
be0e5c09 3855 push_items++;
db94535d
CM
3856 push_space += this_item_size + sizeof(*item);
3857 }
3858
be0e5c09 3859 if (push_items == 0) {
925baedd
CM
3860 ret = 1;
3861 goto out;
be0e5c09 3862 }
fae7f21c 3863 WARN_ON(!empty && push_items == btrfs_header_nritems(right));
5f39d397 3864
be0e5c09 3865 /* push data from right to left */
5f39d397
CM
3866 copy_extent_buffer(left, right,
3867 btrfs_item_nr_offset(btrfs_header_nritems(left)),
3868 btrfs_item_nr_offset(0),
3869 push_items * sizeof(struct btrfs_item));
3870
123abc88 3871 push_space = BTRFS_LEAF_DATA_SIZE(root) -
d397712b 3872 btrfs_item_offset_nr(right, push_items - 1);
5f39d397
CM
3873
3874 copy_extent_buffer(left, right, btrfs_leaf_data(left) +
d6025579
CM
3875 leaf_data_end(root, left) - push_space,
3876 btrfs_leaf_data(right) +
5f39d397 3877 btrfs_item_offset_nr(right, push_items - 1),
d6025579 3878 push_space);
5f39d397 3879 old_left_nritems = btrfs_header_nritems(left);
87b29b20 3880 BUG_ON(old_left_nritems <= 0);
eb60ceac 3881
db94535d 3882 old_left_item_size = btrfs_item_offset_nr(left, old_left_nritems - 1);
0783fcfc 3883 for (i = old_left_nritems; i < old_left_nritems + push_items; i++) {
5f39d397 3884 u32 ioff;
db94535d 3885
dd3cc16b 3886 item = btrfs_item_nr(i);
db94535d 3887
cfed81a0
CM
3888 ioff = btrfs_token_item_offset(left, item, &token);
3889 btrfs_set_token_item_offset(left, item,
3890 ioff - (BTRFS_LEAF_DATA_SIZE(root) - old_left_item_size),
3891 &token);
be0e5c09 3892 }
5f39d397 3893 btrfs_set_header_nritems(left, old_left_nritems + push_items);
be0e5c09
CM
3894
3895 /* fixup right node */
31b1a2bd
JL
3896 if (push_items > right_nritems)
3897 WARN(1, KERN_CRIT "push items %d nr %u\n", push_items,
d397712b 3898 right_nritems);
34a38218
CM
3899
3900 if (push_items < right_nritems) {
3901 push_space = btrfs_item_offset_nr(right, push_items - 1) -
3902 leaf_data_end(root, right);
3903 memmove_extent_buffer(right, btrfs_leaf_data(right) +
3904 BTRFS_LEAF_DATA_SIZE(root) - push_space,
3905 btrfs_leaf_data(right) +
3906 leaf_data_end(root, right), push_space);
3907
3908 memmove_extent_buffer(right, btrfs_item_nr_offset(0),
5f39d397
CM
3909 btrfs_item_nr_offset(push_items),
3910 (btrfs_header_nritems(right) - push_items) *
3911 sizeof(struct btrfs_item));
34a38218 3912 }
eef1c494
Y
3913 right_nritems -= push_items;
3914 btrfs_set_header_nritems(right, right_nritems);
123abc88 3915 push_space = BTRFS_LEAF_DATA_SIZE(root);
5f39d397 3916 for (i = 0; i < right_nritems; i++) {
dd3cc16b 3917 item = btrfs_item_nr(i);
db94535d 3918
cfed81a0
CM
3919 push_space = push_space - btrfs_token_item_size(right,
3920 item, &token);
3921 btrfs_set_token_item_offset(right, item, push_space, &token);
db94535d 3922 }
eb60ceac 3923
5f39d397 3924 btrfs_mark_buffer_dirty(left);
34a38218
CM
3925 if (right_nritems)
3926 btrfs_mark_buffer_dirty(right);
f0486c68
YZ
3927 else
3928 clean_tree_block(trans, root, right);
098f59c2 3929
5f39d397 3930 btrfs_item_key(right, &disk_key, 0);
d6a0a126 3931 fixup_low_keys(root, path, &disk_key, 1);
be0e5c09
CM
3932
3933 /* then fixup the leaf pointer in the path */
3934 if (path->slots[0] < push_items) {
3935 path->slots[0] += old_left_nritems;
925baedd 3936 btrfs_tree_unlock(path->nodes[0]);
5f39d397
CM
3937 free_extent_buffer(path->nodes[0]);
3938 path->nodes[0] = left;
be0e5c09
CM
3939 path->slots[1] -= 1;
3940 } else {
925baedd 3941 btrfs_tree_unlock(left);
5f39d397 3942 free_extent_buffer(left);
be0e5c09
CM
3943 path->slots[0] -= push_items;
3944 }
eb60ceac 3945 BUG_ON(path->slots[0] < 0);
aa5d6bed 3946 return ret;
925baedd
CM
3947out:
3948 btrfs_tree_unlock(left);
3949 free_extent_buffer(left);
3950 return ret;
be0e5c09
CM
3951}
3952
44871b1b
CM
3953/*
3954 * push some data in the path leaf to the left, trying to free up at
3955 * least data_size bytes. returns zero if the push worked, nonzero otherwise
99d8f83c
CM
3956 *
3957 * max_slot can put a limit on how far into the leaf we'll push items. The
3958 * item at 'max_slot' won't be touched. Use (u32)-1 to make us push all the
3959 * items
44871b1b
CM
3960 */
3961static int push_leaf_left(struct btrfs_trans_handle *trans, struct btrfs_root
99d8f83c
CM
3962 *root, struct btrfs_path *path, int min_data_size,
3963 int data_size, int empty, u32 max_slot)
44871b1b
CM
3964{
3965 struct extent_buffer *right = path->nodes[0];
3966 struct extent_buffer *left;
3967 int slot;
3968 int free_space;
3969 u32 right_nritems;
3970 int ret = 0;
3971
3972 slot = path->slots[1];
3973 if (slot == 0)
3974 return 1;
3975 if (!path->nodes[1])
3976 return 1;
3977
3978 right_nritems = btrfs_header_nritems(right);
3979 if (right_nritems == 0)
3980 return 1;
3981
3982 btrfs_assert_tree_locked(path->nodes[1]);
3983
3984 left = read_node_slot(root, path->nodes[1], slot - 1);
91ca338d
TI
3985 if (left == NULL)
3986 return 1;
3987
44871b1b
CM
3988 btrfs_tree_lock(left);
3989 btrfs_set_lock_blocking(left);
3990
3991 free_space = btrfs_leaf_free_space(root, left);
3992 if (free_space < data_size) {
3993 ret = 1;
3994 goto out;
3995 }
3996
3997 /* cow and double check */
3998 ret = btrfs_cow_block(trans, root, left,
3999 path->nodes[1], slot - 1, &left);
4000 if (ret) {
4001 /* we hit -ENOSPC, but it isn't fatal here */
79787eaa
JM
4002 if (ret == -ENOSPC)
4003 ret = 1;
44871b1b
CM
4004 goto out;
4005 }
4006
4007 free_space = btrfs_leaf_free_space(root, left);
4008 if (free_space < data_size) {
4009 ret = 1;
4010 goto out;
4011 }
4012
99d8f83c
CM
4013 return __push_leaf_left(trans, root, path, min_data_size,
4014 empty, left, free_space, right_nritems,
4015 max_slot);
44871b1b
CM
4016out:
4017 btrfs_tree_unlock(left);
4018 free_extent_buffer(left);
4019 return ret;
4020}
4021
4022/*
4023 * split the path's leaf in two, making sure there is at least data_size
4024 * available for the resulting leaf level of the path.
44871b1b 4025 */
143bede5
JM
4026static noinline void copy_for_split(struct btrfs_trans_handle *trans,
4027 struct btrfs_root *root,
4028 struct btrfs_path *path,
4029 struct extent_buffer *l,
4030 struct extent_buffer *right,
4031 int slot, int mid, int nritems)
44871b1b
CM
4032{
4033 int data_copy_size;
4034 int rt_data_off;
4035 int i;
44871b1b 4036 struct btrfs_disk_key disk_key;
cfed81a0
CM
4037 struct btrfs_map_token token;
4038
4039 btrfs_init_map_token(&token);
44871b1b
CM
4040
4041 nritems = nritems - mid;
4042 btrfs_set_header_nritems(right, nritems);
4043 data_copy_size = btrfs_item_end_nr(l, mid) - leaf_data_end(root, l);
4044
4045 copy_extent_buffer(right, l, btrfs_item_nr_offset(0),
4046 btrfs_item_nr_offset(mid),
4047 nritems * sizeof(struct btrfs_item));
4048
4049 copy_extent_buffer(right, l,
4050 btrfs_leaf_data(right) + BTRFS_LEAF_DATA_SIZE(root) -
4051 data_copy_size, btrfs_leaf_data(l) +
4052 leaf_data_end(root, l), data_copy_size);
4053
4054 rt_data_off = BTRFS_LEAF_DATA_SIZE(root) -
4055 btrfs_item_end_nr(l, mid);
4056
4057 for (i = 0; i < nritems; i++) {
dd3cc16b 4058 struct btrfs_item *item = btrfs_item_nr(i);
44871b1b
CM
4059 u32 ioff;
4060
cfed81a0
CM
4061 ioff = btrfs_token_item_offset(right, item, &token);
4062 btrfs_set_token_item_offset(right, item,
4063 ioff + rt_data_off, &token);
44871b1b
CM
4064 }
4065
44871b1b 4066 btrfs_set_header_nritems(l, mid);
44871b1b 4067 btrfs_item_key(right, &disk_key, 0);
143bede5 4068 insert_ptr(trans, root, path, &disk_key, right->start,
c3e06965 4069 path->slots[1] + 1, 1);
44871b1b
CM
4070
4071 btrfs_mark_buffer_dirty(right);
4072 btrfs_mark_buffer_dirty(l);
4073 BUG_ON(path->slots[0] != slot);
4074
44871b1b
CM
4075 if (mid <= slot) {
4076 btrfs_tree_unlock(path->nodes[0]);
4077 free_extent_buffer(path->nodes[0]);
4078 path->nodes[0] = right;
4079 path->slots[0] -= mid;
4080 path->slots[1] += 1;
4081 } else {
4082 btrfs_tree_unlock(right);
4083 free_extent_buffer(right);
4084 }
4085
4086 BUG_ON(path->slots[0] < 0);
44871b1b
CM
4087}
4088
99d8f83c
CM
4089/*
4090 * double splits happen when we need to insert a big item in the middle
4091 * of a leaf. A double split can leave us with 3 mostly empty leaves:
4092 * leaf: [ slots 0 - N] [ our target ] [ N + 1 - total in leaf ]
4093 * A B C
4094 *
4095 * We avoid this by trying to push the items on either side of our target
4096 * into the adjacent leaves. If all goes well we can avoid the double split
4097 * completely.
4098 */
4099static noinline int push_for_double_split(struct btrfs_trans_handle *trans,
4100 struct btrfs_root *root,
4101 struct btrfs_path *path,
4102 int data_size)
4103{
4104 int ret;
4105 int progress = 0;
4106 int slot;
4107 u32 nritems;
5a4267ca 4108 int space_needed = data_size;
99d8f83c
CM
4109
4110 slot = path->slots[0];
5a4267ca
FDBM
4111 if (slot < btrfs_header_nritems(path->nodes[0]))
4112 space_needed -= btrfs_leaf_free_space(root, path->nodes[0]);
99d8f83c
CM
4113
4114 /*
4115 * try to push all the items after our slot into the
4116 * right leaf
4117 */
5a4267ca 4118 ret = push_leaf_right(trans, root, path, 1, space_needed, 0, slot);
99d8f83c
CM
4119 if (ret < 0)
4120 return ret;
4121
4122 if (ret == 0)
4123 progress++;
4124
4125 nritems = btrfs_header_nritems(path->nodes[0]);
4126 /*
4127 * our goal is to get our slot at the start or end of a leaf. If
4128 * we've done so we're done
4129 */
4130 if (path->slots[0] == 0 || path->slots[0] == nritems)
4131 return 0;
4132
4133 if (btrfs_leaf_free_space(root, path->nodes[0]) >= data_size)
4134 return 0;
4135
4136 /* try to push all the items before our slot into the next leaf */
4137 slot = path->slots[0];
5a4267ca 4138 ret = push_leaf_left(trans, root, path, 1, space_needed, 0, slot);
99d8f83c
CM
4139 if (ret < 0)
4140 return ret;
4141
4142 if (ret == 0)
4143 progress++;
4144
4145 if (progress)
4146 return 0;
4147 return 1;
4148}
4149
74123bd7
CM
4150/*
4151 * split the path's leaf in two, making sure there is at least data_size
4152 * available for the resulting leaf level of the path.
aa5d6bed
CM
4153 *
4154 * returns 0 if all went well and < 0 on failure.
74123bd7 4155 */
e02119d5
CM
4156static noinline int split_leaf(struct btrfs_trans_handle *trans,
4157 struct btrfs_root *root,
4158 struct btrfs_key *ins_key,
4159 struct btrfs_path *path, int data_size,
4160 int extend)
be0e5c09 4161{
5d4f98a2 4162 struct btrfs_disk_key disk_key;
5f39d397 4163 struct extent_buffer *l;
7518a238 4164 u32 nritems;
eb60ceac
CM
4165 int mid;
4166 int slot;
5f39d397 4167 struct extent_buffer *right;
d4dbff95 4168 int ret = 0;
aa5d6bed 4169 int wret;
5d4f98a2 4170 int split;
cc0c5538 4171 int num_doubles = 0;
99d8f83c 4172 int tried_avoid_double = 0;
aa5d6bed 4173
a5719521
YZ
4174 l = path->nodes[0];
4175 slot = path->slots[0];
4176 if (extend && data_size + btrfs_item_size_nr(l, slot) +
4177 sizeof(struct btrfs_item) > BTRFS_LEAF_DATA_SIZE(root))
4178 return -EOVERFLOW;
4179
40689478 4180 /* first try to make some room by pushing left and right */
33157e05 4181 if (data_size && path->nodes[1]) {
5a4267ca
FDBM
4182 int space_needed = data_size;
4183
4184 if (slot < btrfs_header_nritems(l))
4185 space_needed -= btrfs_leaf_free_space(root, l);
4186
4187 wret = push_leaf_right(trans, root, path, space_needed,
4188 space_needed, 0, 0);
d397712b 4189 if (wret < 0)
eaee50e8 4190 return wret;
3685f791 4191 if (wret) {
5a4267ca
FDBM
4192 wret = push_leaf_left(trans, root, path, space_needed,
4193 space_needed, 0, (u32)-1);
3685f791
CM
4194 if (wret < 0)
4195 return wret;
4196 }
4197 l = path->nodes[0];
aa5d6bed 4198
3685f791 4199 /* did the pushes work? */
87b29b20 4200 if (btrfs_leaf_free_space(root, l) >= data_size)
3685f791 4201 return 0;
3326d1b0 4202 }
aa5d6bed 4203
5c680ed6 4204 if (!path->nodes[1]) {
fdd99c72 4205 ret = insert_new_root(trans, root, path, 1);
5c680ed6
CM
4206 if (ret)
4207 return ret;
4208 }
cc0c5538 4209again:
5d4f98a2 4210 split = 1;
cc0c5538 4211 l = path->nodes[0];
eb60ceac 4212 slot = path->slots[0];
5f39d397 4213 nritems = btrfs_header_nritems(l);
d397712b 4214 mid = (nritems + 1) / 2;
54aa1f4d 4215
5d4f98a2
YZ
4216 if (mid <= slot) {
4217 if (nritems == 1 ||
4218 leaf_space_used(l, mid, nritems - mid) + data_size >
4219 BTRFS_LEAF_DATA_SIZE(root)) {
4220 if (slot >= nritems) {
4221 split = 0;
4222 } else {
4223 mid = slot;
4224 if (mid != nritems &&
4225 leaf_space_used(l, mid, nritems - mid) +
4226 data_size > BTRFS_LEAF_DATA_SIZE(root)) {
99d8f83c
CM
4227 if (data_size && !tried_avoid_double)
4228 goto push_for_double;
5d4f98a2
YZ
4229 split = 2;
4230 }
4231 }
4232 }
4233 } else {
4234 if (leaf_space_used(l, 0, mid) + data_size >
4235 BTRFS_LEAF_DATA_SIZE(root)) {
4236 if (!extend && data_size && slot == 0) {
4237 split = 0;
4238 } else if ((extend || !data_size) && slot == 0) {
4239 mid = 1;
4240 } else {
4241 mid = slot;
4242 if (mid != nritems &&
4243 leaf_space_used(l, mid, nritems - mid) +
4244 data_size > BTRFS_LEAF_DATA_SIZE(root)) {
99d8f83c
CM
4245 if (data_size && !tried_avoid_double)
4246 goto push_for_double;
67871254 4247 split = 2;
5d4f98a2
YZ
4248 }
4249 }
4250 }
4251 }
4252
4253 if (split == 0)
4254 btrfs_cpu_key_to_disk(&disk_key, ins_key);
4255 else
4256 btrfs_item_key(l, &disk_key, mid);
4257
4d75f8a9
DS
4258 right = btrfs_alloc_tree_block(trans, root, 0, root->root_key.objectid,
4259 &disk_key, 0, l->start, 0);
f0486c68 4260 if (IS_ERR(right))
5f39d397 4261 return PTR_ERR(right);
f0486c68 4262
707e8a07 4263 root_add_used(root, root->nodesize);
5f39d397
CM
4264
4265 memset_extent_buffer(right, 0, 0, sizeof(struct btrfs_header));
db94535d 4266 btrfs_set_header_bytenr(right, right->start);
5f39d397 4267 btrfs_set_header_generation(right, trans->transid);
5d4f98a2 4268 btrfs_set_header_backref_rev(right, BTRFS_MIXED_BACKREF_REV);
5f39d397
CM
4269 btrfs_set_header_owner(right, root->root_key.objectid);
4270 btrfs_set_header_level(right, 0);
4271 write_extent_buffer(right, root->fs_info->fsid,
0a4e5586 4272 btrfs_header_fsid(), BTRFS_FSID_SIZE);
e17cade2
CM
4273
4274 write_extent_buffer(right, root->fs_info->chunk_tree_uuid,
b308bc2f 4275 btrfs_header_chunk_tree_uuid(right),
e17cade2 4276 BTRFS_UUID_SIZE);
44871b1b 4277
5d4f98a2
YZ
4278 if (split == 0) {
4279 if (mid <= slot) {
4280 btrfs_set_header_nritems(right, 0);
143bede5 4281 insert_ptr(trans, root, path, &disk_key, right->start,
c3e06965 4282 path->slots[1] + 1, 1);
5d4f98a2
YZ
4283 btrfs_tree_unlock(path->nodes[0]);
4284 free_extent_buffer(path->nodes[0]);
4285 path->nodes[0] = right;
4286 path->slots[0] = 0;
4287 path->slots[1] += 1;
4288 } else {
4289 btrfs_set_header_nritems(right, 0);
143bede5 4290 insert_ptr(trans, root, path, &disk_key, right->start,
c3e06965 4291 path->slots[1], 1);
5d4f98a2
YZ
4292 btrfs_tree_unlock(path->nodes[0]);
4293 free_extent_buffer(path->nodes[0]);
4294 path->nodes[0] = right;
4295 path->slots[0] = 0;
143bede5 4296 if (path->slots[1] == 0)
d6a0a126 4297 fixup_low_keys(root, path, &disk_key, 1);
d4dbff95 4298 }
5d4f98a2
YZ
4299 btrfs_mark_buffer_dirty(right);
4300 return ret;
d4dbff95 4301 }
74123bd7 4302
143bede5 4303 copy_for_split(trans, root, path, l, right, slot, mid, nritems);
31840ae1 4304
5d4f98a2 4305 if (split == 2) {
cc0c5538
CM
4306 BUG_ON(num_doubles != 0);
4307 num_doubles++;
4308 goto again;
a429e513 4309 }
44871b1b 4310
143bede5 4311 return 0;
99d8f83c
CM
4312
4313push_for_double:
4314 push_for_double_split(trans, root, path, data_size);
4315 tried_avoid_double = 1;
4316 if (btrfs_leaf_free_space(root, path->nodes[0]) >= data_size)
4317 return 0;
4318 goto again;
be0e5c09
CM
4319}
4320
ad48fd75
YZ
4321static noinline int setup_leaf_for_split(struct btrfs_trans_handle *trans,
4322 struct btrfs_root *root,
4323 struct btrfs_path *path, int ins_len)
459931ec 4324{
ad48fd75 4325 struct btrfs_key key;
459931ec 4326 struct extent_buffer *leaf;
ad48fd75
YZ
4327 struct btrfs_file_extent_item *fi;
4328 u64 extent_len = 0;
4329 u32 item_size;
4330 int ret;
459931ec
CM
4331
4332 leaf = path->nodes[0];
ad48fd75
YZ
4333 btrfs_item_key_to_cpu(leaf, &key, path->slots[0]);
4334
4335 BUG_ON(key.type != BTRFS_EXTENT_DATA_KEY &&
4336 key.type != BTRFS_EXTENT_CSUM_KEY);
4337
4338 if (btrfs_leaf_free_space(root, leaf) >= ins_len)
4339 return 0;
459931ec
CM
4340
4341 item_size = btrfs_item_size_nr(leaf, path->slots[0]);
ad48fd75
YZ
4342 if (key.type == BTRFS_EXTENT_DATA_KEY) {
4343 fi = btrfs_item_ptr(leaf, path->slots[0],
4344 struct btrfs_file_extent_item);
4345 extent_len = btrfs_file_extent_num_bytes(leaf, fi);
4346 }
b3b4aa74 4347 btrfs_release_path(path);
459931ec 4348
459931ec 4349 path->keep_locks = 1;
ad48fd75
YZ
4350 path->search_for_split = 1;
4351 ret = btrfs_search_slot(trans, root, &key, path, 0, 1);
459931ec 4352 path->search_for_split = 0;
ad48fd75
YZ
4353 if (ret < 0)
4354 goto err;
459931ec 4355
ad48fd75
YZ
4356 ret = -EAGAIN;
4357 leaf = path->nodes[0];
459931ec 4358 /* if our item isn't there or got smaller, return now */
ad48fd75
YZ
4359 if (ret > 0 || item_size != btrfs_item_size_nr(leaf, path->slots[0]))
4360 goto err;
4361
109f6aef
CM
4362 /* the leaf has changed, it now has room. return now */
4363 if (btrfs_leaf_free_space(root, path->nodes[0]) >= ins_len)
4364 goto err;
4365
ad48fd75
YZ
4366 if (key.type == BTRFS_EXTENT_DATA_KEY) {
4367 fi = btrfs_item_ptr(leaf, path->slots[0],
4368 struct btrfs_file_extent_item);
4369 if (extent_len != btrfs_file_extent_num_bytes(leaf, fi))
4370 goto err;
459931ec
CM
4371 }
4372
b9473439 4373 btrfs_set_path_blocking(path);
ad48fd75 4374 ret = split_leaf(trans, root, &key, path, ins_len, 1);
f0486c68
YZ
4375 if (ret)
4376 goto err;
459931ec 4377
ad48fd75 4378 path->keep_locks = 0;
b9473439 4379 btrfs_unlock_up_safe(path, 1);
ad48fd75
YZ
4380 return 0;
4381err:
4382 path->keep_locks = 0;
4383 return ret;
4384}
4385
4386static noinline int split_item(struct btrfs_trans_handle *trans,
4387 struct btrfs_root *root,
4388 struct btrfs_path *path,
4389 struct btrfs_key *new_key,
4390 unsigned long split_offset)
4391{
4392 struct extent_buffer *leaf;
4393 struct btrfs_item *item;
4394 struct btrfs_item *new_item;
4395 int slot;
4396 char *buf;
4397 u32 nritems;
4398 u32 item_size;
4399 u32 orig_offset;
4400 struct btrfs_disk_key disk_key;
4401
b9473439
CM
4402 leaf = path->nodes[0];
4403 BUG_ON(btrfs_leaf_free_space(root, leaf) < sizeof(struct btrfs_item));
4404
b4ce94de
CM
4405 btrfs_set_path_blocking(path);
4406
dd3cc16b 4407 item = btrfs_item_nr(path->slots[0]);
459931ec
CM
4408 orig_offset = btrfs_item_offset(leaf, item);
4409 item_size = btrfs_item_size(leaf, item);
4410
459931ec 4411 buf = kmalloc(item_size, GFP_NOFS);
ad48fd75
YZ
4412 if (!buf)
4413 return -ENOMEM;
4414
459931ec
CM
4415 read_extent_buffer(leaf, buf, btrfs_item_ptr_offset(leaf,
4416 path->slots[0]), item_size);
459931ec 4417
ad48fd75 4418 slot = path->slots[0] + 1;
459931ec 4419 nritems = btrfs_header_nritems(leaf);
459931ec
CM
4420 if (slot != nritems) {
4421 /* shift the items */
4422 memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + 1),
ad48fd75
YZ
4423 btrfs_item_nr_offset(slot),
4424 (nritems - slot) * sizeof(struct btrfs_item));
459931ec
CM
4425 }
4426
4427 btrfs_cpu_key_to_disk(&disk_key, new_key);
4428 btrfs_set_item_key(leaf, &disk_key, slot);
4429
dd3cc16b 4430 new_item = btrfs_item_nr(slot);
459931ec
CM
4431
4432 btrfs_set_item_offset(leaf, new_item, orig_offset);
4433 btrfs_set_item_size(leaf, new_item, item_size - split_offset);
4434
4435 btrfs_set_item_offset(leaf, item,
4436 orig_offset + item_size - split_offset);
4437 btrfs_set_item_size(leaf, item, split_offset);
4438
4439 btrfs_set_header_nritems(leaf, nritems + 1);
4440
4441 /* write the data for the start of the original item */
4442 write_extent_buffer(leaf, buf,
4443 btrfs_item_ptr_offset(leaf, path->slots[0]),
4444 split_offset);
4445
4446 /* write the data for the new item */
4447 write_extent_buffer(leaf, buf + split_offset,
4448 btrfs_item_ptr_offset(leaf, slot),
4449 item_size - split_offset);
4450 btrfs_mark_buffer_dirty(leaf);
4451
ad48fd75 4452 BUG_ON(btrfs_leaf_free_space(root, leaf) < 0);
459931ec 4453 kfree(buf);
ad48fd75
YZ
4454 return 0;
4455}
4456
4457/*
4458 * This function splits a single item into two items,
4459 * giving 'new_key' to the new item and splitting the
4460 * old one at split_offset (from the start of the item).
4461 *
4462 * The path may be released by this operation. After
4463 * the split, the path is pointing to the old item. The
4464 * new item is going to be in the same node as the old one.
4465 *
4466 * Note, the item being split must be smaller enough to live alone on
4467 * a tree block with room for one extra struct btrfs_item
4468 *
4469 * This allows us to split the item in place, keeping a lock on the
4470 * leaf the entire time.
4471 */
4472int btrfs_split_item(struct btrfs_trans_handle *trans,
4473 struct btrfs_root *root,
4474 struct btrfs_path *path,
4475 struct btrfs_key *new_key,
4476 unsigned long split_offset)
4477{
4478 int ret;
4479 ret = setup_leaf_for_split(trans, root, path,
4480 sizeof(struct btrfs_item));
4481 if (ret)
4482 return ret;
4483
4484 ret = split_item(trans, root, path, new_key, split_offset);
459931ec
CM
4485 return ret;
4486}
4487
ad48fd75
YZ
4488/*
4489 * This function duplicate a item, giving 'new_key' to the new item.
4490 * It guarantees both items live in the same tree leaf and the new item
4491 * is contiguous with the original item.
4492 *
4493 * This allows us to split file extent in place, keeping a lock on the
4494 * leaf the entire time.
4495 */
4496int btrfs_duplicate_item(struct btrfs_trans_handle *trans,
4497 struct btrfs_root *root,
4498 struct btrfs_path *path,
4499 struct btrfs_key *new_key)
4500{
4501 struct extent_buffer *leaf;
4502 int ret;
4503 u32 item_size;
4504
4505 leaf = path->nodes[0];
4506 item_size = btrfs_item_size_nr(leaf, path->slots[0]);
4507 ret = setup_leaf_for_split(trans, root, path,
4508 item_size + sizeof(struct btrfs_item));
4509 if (ret)
4510 return ret;
4511
4512 path->slots[0]++;
afe5fea7 4513 setup_items_for_insert(root, path, new_key, &item_size,
143bede5
JM
4514 item_size, item_size +
4515 sizeof(struct btrfs_item), 1);
ad48fd75
YZ
4516 leaf = path->nodes[0];
4517 memcpy_extent_buffer(leaf,
4518 btrfs_item_ptr_offset(leaf, path->slots[0]),
4519 btrfs_item_ptr_offset(leaf, path->slots[0] - 1),
4520 item_size);
4521 return 0;
4522}
4523
d352ac68
CM
4524/*
4525 * make the item pointed to by the path smaller. new_size indicates
4526 * how small to make it, and from_end tells us if we just chop bytes
4527 * off the end of the item or if we shift the item to chop bytes off
4528 * the front.
4529 */
afe5fea7 4530void btrfs_truncate_item(struct btrfs_root *root, struct btrfs_path *path,
143bede5 4531 u32 new_size, int from_end)
b18c6685 4532{
b18c6685 4533 int slot;
5f39d397
CM
4534 struct extent_buffer *leaf;
4535 struct btrfs_item *item;
b18c6685
CM
4536 u32 nritems;
4537 unsigned int data_end;
4538 unsigned int old_data_start;
4539 unsigned int old_size;
4540 unsigned int size_diff;
4541 int i;
cfed81a0
CM
4542 struct btrfs_map_token token;
4543
4544 btrfs_init_map_token(&token);
b18c6685 4545
5f39d397 4546 leaf = path->nodes[0];
179e29e4
CM
4547 slot = path->slots[0];
4548
4549 old_size = btrfs_item_size_nr(leaf, slot);
4550 if (old_size == new_size)
143bede5 4551 return;
b18c6685 4552
5f39d397 4553 nritems = btrfs_header_nritems(leaf);
b18c6685
CM
4554 data_end = leaf_data_end(root, leaf);
4555
5f39d397 4556 old_data_start = btrfs_item_offset_nr(leaf, slot);
179e29e4 4557
b18c6685
CM
4558 size_diff = old_size - new_size;
4559
4560 BUG_ON(slot < 0);
4561 BUG_ON(slot >= nritems);
4562
4563 /*
4564 * item0..itemN ... dataN.offset..dataN.size .. data0.size
4565 */
4566 /* first correct the data pointers */
4567 for (i = slot; i < nritems; i++) {
5f39d397 4568 u32 ioff;
dd3cc16b 4569 item = btrfs_item_nr(i);
db94535d 4570
cfed81a0
CM
4571 ioff = btrfs_token_item_offset(leaf, item, &token);
4572 btrfs_set_token_item_offset(leaf, item,
4573 ioff + size_diff, &token);
b18c6685 4574 }
db94535d 4575
b18c6685 4576 /* shift the data */
179e29e4
CM
4577 if (from_end) {
4578 memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) +
4579 data_end + size_diff, btrfs_leaf_data(leaf) +
4580 data_end, old_data_start + new_size - data_end);
4581 } else {
4582 struct btrfs_disk_key disk_key;
4583 u64 offset;
4584
4585 btrfs_item_key(leaf, &disk_key, slot);
4586
4587 if (btrfs_disk_key_type(&disk_key) == BTRFS_EXTENT_DATA_KEY) {
4588 unsigned long ptr;
4589 struct btrfs_file_extent_item *fi;
4590
4591 fi = btrfs_item_ptr(leaf, slot,
4592 struct btrfs_file_extent_item);
4593 fi = (struct btrfs_file_extent_item *)(
4594 (unsigned long)fi - size_diff);
4595
4596 if (btrfs_file_extent_type(leaf, fi) ==
4597 BTRFS_FILE_EXTENT_INLINE) {
4598 ptr = btrfs_item_ptr_offset(leaf, slot);
4599 memmove_extent_buffer(leaf, ptr,
d397712b 4600 (unsigned long)fi,
7ec20afb 4601 BTRFS_FILE_EXTENT_INLINE_DATA_START);
179e29e4
CM
4602 }
4603 }
4604
4605 memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) +
4606 data_end + size_diff, btrfs_leaf_data(leaf) +
4607 data_end, old_data_start - data_end);
4608
4609 offset = btrfs_disk_key_offset(&disk_key);
4610 btrfs_set_disk_key_offset(&disk_key, offset + size_diff);
4611 btrfs_set_item_key(leaf, &disk_key, slot);
4612 if (slot == 0)
d6a0a126 4613 fixup_low_keys(root, path, &disk_key, 1);
179e29e4 4614 }
5f39d397 4615
dd3cc16b 4616 item = btrfs_item_nr(slot);
5f39d397
CM
4617 btrfs_set_item_size(leaf, item, new_size);
4618 btrfs_mark_buffer_dirty(leaf);
b18c6685 4619
5f39d397
CM
4620 if (btrfs_leaf_free_space(root, leaf) < 0) {
4621 btrfs_print_leaf(root, leaf);
b18c6685 4622 BUG();
5f39d397 4623 }
b18c6685
CM
4624}
4625
d352ac68 4626/*
8f69dbd2 4627 * make the item pointed to by the path bigger, data_size is the added size.
d352ac68 4628 */
4b90c680 4629void btrfs_extend_item(struct btrfs_root *root, struct btrfs_path *path,
143bede5 4630 u32 data_size)
6567e837 4631{
6567e837 4632 int slot;
5f39d397
CM
4633 struct extent_buffer *leaf;
4634 struct btrfs_item *item;
6567e837
CM
4635 u32 nritems;
4636 unsigned int data_end;
4637 unsigned int old_data;
4638 unsigned int old_size;
4639 int i;
cfed81a0
CM
4640 struct btrfs_map_token token;
4641
4642 btrfs_init_map_token(&token);
6567e837 4643
5f39d397 4644 leaf = path->nodes[0];
6567e837 4645
5f39d397 4646 nritems = btrfs_header_nritems(leaf);
6567e837
CM
4647 data_end = leaf_data_end(root, leaf);
4648
5f39d397
CM
4649 if (btrfs_leaf_free_space(root, leaf) < data_size) {
4650 btrfs_print_leaf(root, leaf);
6567e837 4651 BUG();
5f39d397 4652 }
6567e837 4653 slot = path->slots[0];
5f39d397 4654 old_data = btrfs_item_end_nr(leaf, slot);
6567e837
CM
4655
4656 BUG_ON(slot < 0);
3326d1b0
CM
4657 if (slot >= nritems) {
4658 btrfs_print_leaf(root, leaf);
efe120a0 4659 btrfs_crit(root->fs_info, "slot %d too large, nritems %d",
d397712b 4660 slot, nritems);
3326d1b0
CM
4661 BUG_ON(1);
4662 }
6567e837
CM
4663
4664 /*
4665 * item0..itemN ... dataN.offset..dataN.size .. data0.size
4666 */
4667 /* first correct the data pointers */
4668 for (i = slot; i < nritems; i++) {
5f39d397 4669 u32 ioff;
dd3cc16b 4670 item = btrfs_item_nr(i);
db94535d 4671
cfed81a0
CM
4672 ioff = btrfs_token_item_offset(leaf, item, &token);
4673 btrfs_set_token_item_offset(leaf, item,
4674 ioff - data_size, &token);
6567e837 4675 }
5f39d397 4676
6567e837 4677 /* shift the data */
5f39d397 4678 memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) +
6567e837
CM
4679 data_end - data_size, btrfs_leaf_data(leaf) +
4680 data_end, old_data - data_end);
5f39d397 4681
6567e837 4682 data_end = old_data;
5f39d397 4683 old_size = btrfs_item_size_nr(leaf, slot);
dd3cc16b 4684 item = btrfs_item_nr(slot);
5f39d397
CM
4685 btrfs_set_item_size(leaf, item, old_size + data_size);
4686 btrfs_mark_buffer_dirty(leaf);
6567e837 4687
5f39d397
CM
4688 if (btrfs_leaf_free_space(root, leaf) < 0) {
4689 btrfs_print_leaf(root, leaf);
6567e837 4690 BUG();
5f39d397 4691 }
6567e837
CM
4692}
4693
74123bd7 4694/*
44871b1b
CM
4695 * this is a helper for btrfs_insert_empty_items, the main goal here is
4696 * to save stack depth by doing the bulk of the work in a function
4697 * that doesn't call btrfs_search_slot
74123bd7 4698 */
afe5fea7 4699void setup_items_for_insert(struct btrfs_root *root, struct btrfs_path *path,
143bede5
JM
4700 struct btrfs_key *cpu_key, u32 *data_size,
4701 u32 total_data, u32 total_size, int nr)
be0e5c09 4702{
5f39d397 4703 struct btrfs_item *item;
9c58309d 4704 int i;
7518a238 4705 u32 nritems;
be0e5c09 4706 unsigned int data_end;
e2fa7227 4707 struct btrfs_disk_key disk_key;
44871b1b
CM
4708 struct extent_buffer *leaf;
4709 int slot;
cfed81a0
CM
4710 struct btrfs_map_token token;
4711
24cdc847
FM
4712 if (path->slots[0] == 0) {
4713 btrfs_cpu_key_to_disk(&disk_key, cpu_key);
4714 fixup_low_keys(root, path, &disk_key, 1);
4715 }
4716 btrfs_unlock_up_safe(path, 1);
4717
cfed81a0 4718 btrfs_init_map_token(&token);
e2fa7227 4719
5f39d397 4720 leaf = path->nodes[0];
44871b1b 4721 slot = path->slots[0];
74123bd7 4722
5f39d397 4723 nritems = btrfs_header_nritems(leaf);
123abc88 4724 data_end = leaf_data_end(root, leaf);
eb60ceac 4725
f25956cc 4726 if (btrfs_leaf_free_space(root, leaf) < total_size) {
3326d1b0 4727 btrfs_print_leaf(root, leaf);
efe120a0 4728 btrfs_crit(root->fs_info, "not enough freespace need %u have %d",
9c58309d 4729 total_size, btrfs_leaf_free_space(root, leaf));
be0e5c09 4730 BUG();
d4dbff95 4731 }
5f39d397 4732
be0e5c09 4733 if (slot != nritems) {
5f39d397 4734 unsigned int old_data = btrfs_item_end_nr(leaf, slot);
be0e5c09 4735
5f39d397
CM
4736 if (old_data < data_end) {
4737 btrfs_print_leaf(root, leaf);
efe120a0 4738 btrfs_crit(root->fs_info, "slot %d old_data %d data_end %d",
5f39d397
CM
4739 slot, old_data, data_end);
4740 BUG_ON(1);
4741 }
be0e5c09
CM
4742 /*
4743 * item0..itemN ... dataN.offset..dataN.size .. data0.size
4744 */
4745 /* first correct the data pointers */
0783fcfc 4746 for (i = slot; i < nritems; i++) {
5f39d397 4747 u32 ioff;
db94535d 4748
dd3cc16b 4749 item = btrfs_item_nr( i);
cfed81a0
CM
4750 ioff = btrfs_token_item_offset(leaf, item, &token);
4751 btrfs_set_token_item_offset(leaf, item,
4752 ioff - total_data, &token);
0783fcfc 4753 }
be0e5c09 4754 /* shift the items */
9c58309d 4755 memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot + nr),
5f39d397 4756 btrfs_item_nr_offset(slot),
d6025579 4757 (nritems - slot) * sizeof(struct btrfs_item));
be0e5c09
CM
4758
4759 /* shift the data */
5f39d397 4760 memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) +
9c58309d 4761 data_end - total_data, btrfs_leaf_data(leaf) +
d6025579 4762 data_end, old_data - data_end);
be0e5c09
CM
4763 data_end = old_data;
4764 }
5f39d397 4765
62e2749e 4766 /* setup the item for the new data */
9c58309d
CM
4767 for (i = 0; i < nr; i++) {
4768 btrfs_cpu_key_to_disk(&disk_key, cpu_key + i);
4769 btrfs_set_item_key(leaf, &disk_key, slot + i);
dd3cc16b 4770 item = btrfs_item_nr(slot + i);
cfed81a0
CM
4771 btrfs_set_token_item_offset(leaf, item,
4772 data_end - data_size[i], &token);
9c58309d 4773 data_end -= data_size[i];
cfed81a0 4774 btrfs_set_token_item_size(leaf, item, data_size[i], &token);
9c58309d 4775 }
44871b1b 4776
9c58309d 4777 btrfs_set_header_nritems(leaf, nritems + nr);
b9473439 4778 btrfs_mark_buffer_dirty(leaf);
aa5d6bed 4779
5f39d397
CM
4780 if (btrfs_leaf_free_space(root, leaf) < 0) {
4781 btrfs_print_leaf(root, leaf);
be0e5c09 4782 BUG();
5f39d397 4783 }
44871b1b
CM
4784}
4785
4786/*
4787 * Given a key and some data, insert items into the tree.
4788 * This does all the path init required, making room in the tree if needed.
4789 */
4790int btrfs_insert_empty_items(struct btrfs_trans_handle *trans,
4791 struct btrfs_root *root,
4792 struct btrfs_path *path,
4793 struct btrfs_key *cpu_key, u32 *data_size,
4794 int nr)
4795{
44871b1b
CM
4796 int ret = 0;
4797 int slot;
4798 int i;
4799 u32 total_size = 0;
4800 u32 total_data = 0;
4801
4802 for (i = 0; i < nr; i++)
4803 total_data += data_size[i];
4804
4805 total_size = total_data + (nr * sizeof(struct btrfs_item));
4806 ret = btrfs_search_slot(trans, root, cpu_key, path, total_size, 1);
4807 if (ret == 0)
4808 return -EEXIST;
4809 if (ret < 0)
143bede5 4810 return ret;
44871b1b 4811
44871b1b
CM
4812 slot = path->slots[0];
4813 BUG_ON(slot < 0);
4814
afe5fea7 4815 setup_items_for_insert(root, path, cpu_key, data_size,
44871b1b 4816 total_data, total_size, nr);
143bede5 4817 return 0;
62e2749e
CM
4818}
4819
4820/*
4821 * Given a key and some data, insert an item into the tree.
4822 * This does all the path init required, making room in the tree if needed.
4823 */
e089f05c
CM
4824int btrfs_insert_item(struct btrfs_trans_handle *trans, struct btrfs_root
4825 *root, struct btrfs_key *cpu_key, void *data, u32
4826 data_size)
62e2749e
CM
4827{
4828 int ret = 0;
2c90e5d6 4829 struct btrfs_path *path;
5f39d397
CM
4830 struct extent_buffer *leaf;
4831 unsigned long ptr;
62e2749e 4832
2c90e5d6 4833 path = btrfs_alloc_path();
db5b493a
TI
4834 if (!path)
4835 return -ENOMEM;
2c90e5d6 4836 ret = btrfs_insert_empty_item(trans, root, path, cpu_key, data_size);
62e2749e 4837 if (!ret) {
5f39d397
CM
4838 leaf = path->nodes[0];
4839 ptr = btrfs_item_ptr_offset(leaf, path->slots[0]);
4840 write_extent_buffer(leaf, data, ptr, data_size);
4841 btrfs_mark_buffer_dirty(leaf);
62e2749e 4842 }
2c90e5d6 4843 btrfs_free_path(path);
aa5d6bed 4844 return ret;
be0e5c09
CM
4845}
4846
74123bd7 4847/*
5de08d7d 4848 * delete the pointer from a given node.
74123bd7 4849 *
d352ac68
CM
4850 * the tree should have been previously balanced so the deletion does not
4851 * empty a node.
74123bd7 4852 */
afe5fea7
TI
4853static void del_ptr(struct btrfs_root *root, struct btrfs_path *path,
4854 int level, int slot)
be0e5c09 4855{
5f39d397 4856 struct extent_buffer *parent = path->nodes[level];
7518a238 4857 u32 nritems;
f3ea38da 4858 int ret;
be0e5c09 4859
5f39d397 4860 nritems = btrfs_header_nritems(parent);
d397712b 4861 if (slot != nritems - 1) {
0e411ece 4862 if (level)
f3ea38da
JS
4863 tree_mod_log_eb_move(root->fs_info, parent, slot,
4864 slot + 1, nritems - slot - 1);
5f39d397
CM
4865 memmove_extent_buffer(parent,
4866 btrfs_node_key_ptr_offset(slot),
4867 btrfs_node_key_ptr_offset(slot + 1),
d6025579
CM
4868 sizeof(struct btrfs_key_ptr) *
4869 (nritems - slot - 1));
57ba86c0
CM
4870 } else if (level) {
4871 ret = tree_mod_log_insert_key(root->fs_info, parent, slot,
c8cc6341 4872 MOD_LOG_KEY_REMOVE, GFP_NOFS);
57ba86c0 4873 BUG_ON(ret < 0);
bb803951 4874 }
f3ea38da 4875
7518a238 4876 nritems--;
5f39d397 4877 btrfs_set_header_nritems(parent, nritems);
7518a238 4878 if (nritems == 0 && parent == root->node) {
5f39d397 4879 BUG_ON(btrfs_header_level(root->node) != 1);
bb803951 4880 /* just turn the root into a leaf and break */
5f39d397 4881 btrfs_set_header_level(root->node, 0);
bb803951 4882 } else if (slot == 0) {
5f39d397
CM
4883 struct btrfs_disk_key disk_key;
4884
4885 btrfs_node_key(parent, &disk_key, 0);
d6a0a126 4886 fixup_low_keys(root, path, &disk_key, level + 1);
be0e5c09 4887 }
d6025579 4888 btrfs_mark_buffer_dirty(parent);
be0e5c09
CM
4889}
4890
323ac95b
CM
4891/*
4892 * a helper function to delete the leaf pointed to by path->slots[1] and
5d4f98a2 4893 * path->nodes[1].
323ac95b
CM
4894 *
4895 * This deletes the pointer in path->nodes[1] and frees the leaf
4896 * block extent. zero is returned if it all worked out, < 0 otherwise.
4897 *
4898 * The path must have already been setup for deleting the leaf, including
4899 * all the proper balancing. path->nodes[1] must be locked.
4900 */
143bede5
JM
4901static noinline void btrfs_del_leaf(struct btrfs_trans_handle *trans,
4902 struct btrfs_root *root,
4903 struct btrfs_path *path,
4904 struct extent_buffer *leaf)
323ac95b 4905{
5d4f98a2 4906 WARN_ON(btrfs_header_generation(leaf) != trans->transid);
afe5fea7 4907 del_ptr(root, path, 1, path->slots[1]);
323ac95b 4908
4d081c41
CM
4909 /*
4910 * btrfs_free_extent is expensive, we want to make sure we
4911 * aren't holding any locks when we call it
4912 */
4913 btrfs_unlock_up_safe(path, 0);
4914
f0486c68
YZ
4915 root_sub_used(root, leaf->len);
4916
3083ee2e 4917 extent_buffer_get(leaf);
5581a51a 4918 btrfs_free_tree_block(trans, root, leaf, 0, 1);
3083ee2e 4919 free_extent_buffer_stale(leaf);
323ac95b 4920}
74123bd7
CM
4921/*
4922 * delete the item at the leaf level in path. If that empties
4923 * the leaf, remove it from the tree
4924 */
85e21bac
CM
4925int btrfs_del_items(struct btrfs_trans_handle *trans, struct btrfs_root *root,
4926 struct btrfs_path *path, int slot, int nr)
be0e5c09 4927{
5f39d397
CM
4928 struct extent_buffer *leaf;
4929 struct btrfs_item *item;
85e21bac
CM
4930 int last_off;
4931 int dsize = 0;
aa5d6bed
CM
4932 int ret = 0;
4933 int wret;
85e21bac 4934 int i;
7518a238 4935 u32 nritems;
cfed81a0
CM
4936 struct btrfs_map_token token;
4937
4938 btrfs_init_map_token(&token);
be0e5c09 4939
5f39d397 4940 leaf = path->nodes[0];
85e21bac
CM
4941 last_off = btrfs_item_offset_nr(leaf, slot + nr - 1);
4942
4943 for (i = 0; i < nr; i++)
4944 dsize += btrfs_item_size_nr(leaf, slot + i);
4945
5f39d397 4946 nritems = btrfs_header_nritems(leaf);
be0e5c09 4947
85e21bac 4948 if (slot + nr != nritems) {
123abc88 4949 int data_end = leaf_data_end(root, leaf);
5f39d397
CM
4950
4951 memmove_extent_buffer(leaf, btrfs_leaf_data(leaf) +
d6025579
CM
4952 data_end + dsize,
4953 btrfs_leaf_data(leaf) + data_end,
85e21bac 4954 last_off - data_end);
5f39d397 4955
85e21bac 4956 for (i = slot + nr; i < nritems; i++) {
5f39d397 4957 u32 ioff;
db94535d 4958
dd3cc16b 4959 item = btrfs_item_nr(i);
cfed81a0
CM
4960 ioff = btrfs_token_item_offset(leaf, item, &token);
4961 btrfs_set_token_item_offset(leaf, item,
4962 ioff + dsize, &token);
0783fcfc 4963 }
db94535d 4964
5f39d397 4965 memmove_extent_buffer(leaf, btrfs_item_nr_offset(slot),
85e21bac 4966 btrfs_item_nr_offset(slot + nr),
d6025579 4967 sizeof(struct btrfs_item) *
85e21bac 4968 (nritems - slot - nr));
be0e5c09 4969 }
85e21bac
CM
4970 btrfs_set_header_nritems(leaf, nritems - nr);
4971 nritems -= nr;
5f39d397 4972
74123bd7 4973 /* delete the leaf if we've emptied it */
7518a238 4974 if (nritems == 0) {
5f39d397
CM
4975 if (leaf == root->node) {
4976 btrfs_set_header_level(leaf, 0);
9a8dd150 4977 } else {
f0486c68
YZ
4978 btrfs_set_path_blocking(path);
4979 clean_tree_block(trans, root, leaf);
143bede5 4980 btrfs_del_leaf(trans, root, path, leaf);
9a8dd150 4981 }
be0e5c09 4982 } else {
7518a238 4983 int used = leaf_space_used(leaf, 0, nritems);
aa5d6bed 4984 if (slot == 0) {
5f39d397
CM
4985 struct btrfs_disk_key disk_key;
4986
4987 btrfs_item_key(leaf, &disk_key, 0);
d6a0a126 4988 fixup_low_keys(root, path, &disk_key, 1);
aa5d6bed 4989 }
aa5d6bed 4990
74123bd7 4991 /* delete the leaf if it is mostly empty */
d717aa1d 4992 if (used < BTRFS_LEAF_DATA_SIZE(root) / 3) {
be0e5c09
CM
4993 /* push_leaf_left fixes the path.
4994 * make sure the path still points to our leaf
4995 * for possible call to del_ptr below
4996 */
4920c9ac 4997 slot = path->slots[1];
5f39d397
CM
4998 extent_buffer_get(leaf);
4999
b9473439 5000 btrfs_set_path_blocking(path);
99d8f83c
CM
5001 wret = push_leaf_left(trans, root, path, 1, 1,
5002 1, (u32)-1);
54aa1f4d 5003 if (wret < 0 && wret != -ENOSPC)
aa5d6bed 5004 ret = wret;
5f39d397
CM
5005
5006 if (path->nodes[0] == leaf &&
5007 btrfs_header_nritems(leaf)) {
99d8f83c
CM
5008 wret = push_leaf_right(trans, root, path, 1,
5009 1, 1, 0);
54aa1f4d 5010 if (wret < 0 && wret != -ENOSPC)
aa5d6bed
CM
5011 ret = wret;
5012 }
5f39d397
CM
5013
5014 if (btrfs_header_nritems(leaf) == 0) {
323ac95b 5015 path->slots[1] = slot;
143bede5 5016 btrfs_del_leaf(trans, root, path, leaf);
5f39d397 5017 free_extent_buffer(leaf);
143bede5 5018 ret = 0;
5de08d7d 5019 } else {
925baedd
CM
5020 /* if we're still in the path, make sure
5021 * we're dirty. Otherwise, one of the
5022 * push_leaf functions must have already
5023 * dirtied this buffer
5024 */
5025 if (path->nodes[0] == leaf)
5026 btrfs_mark_buffer_dirty(leaf);
5f39d397 5027 free_extent_buffer(leaf);
be0e5c09 5028 }
d5719762 5029 } else {
5f39d397 5030 btrfs_mark_buffer_dirty(leaf);
be0e5c09
CM
5031 }
5032 }
aa5d6bed 5033 return ret;
be0e5c09
CM
5034}
5035
7bb86316 5036/*
925baedd 5037 * search the tree again to find a leaf with lesser keys
7bb86316
CM
5038 * returns 0 if it found something or 1 if there are no lesser leaves.
5039 * returns < 0 on io errors.
d352ac68
CM
5040 *
5041 * This may release the path, and so you may lose any locks held at the
5042 * time you call it.
7bb86316 5043 */
16e7549f 5044int btrfs_prev_leaf(struct btrfs_root *root, struct btrfs_path *path)
7bb86316 5045{
925baedd
CM
5046 struct btrfs_key key;
5047 struct btrfs_disk_key found_key;
5048 int ret;
7bb86316 5049
925baedd 5050 btrfs_item_key_to_cpu(path->nodes[0], &key, 0);
7bb86316 5051
e8b0d724 5052 if (key.offset > 0) {
925baedd 5053 key.offset--;
e8b0d724 5054 } else if (key.type > 0) {
925baedd 5055 key.type--;
e8b0d724
FDBM
5056 key.offset = (u64)-1;
5057 } else if (key.objectid > 0) {
925baedd 5058 key.objectid--;
e8b0d724
FDBM
5059 key.type = (u8)-1;
5060 key.offset = (u64)-1;
5061 } else {
925baedd 5062 return 1;
e8b0d724 5063 }
7bb86316 5064
b3b4aa74 5065 btrfs_release_path(path);
925baedd
CM
5066 ret = btrfs_search_slot(NULL, root, &key, path, 0, 0);
5067 if (ret < 0)
5068 return ret;
5069 btrfs_item_key(path->nodes[0], &found_key, 0);
5070 ret = comp_keys(&found_key, &key);
337c6f68
FM
5071 /*
5072 * We might have had an item with the previous key in the tree right
5073 * before we released our path. And after we released our path, that
5074 * item might have been pushed to the first slot (0) of the leaf we
5075 * were holding due to a tree balance. Alternatively, an item with the
5076 * previous key can exist as the only element of a leaf (big fat item).
5077 * Therefore account for these 2 cases, so that our callers (like
5078 * btrfs_previous_item) don't miss an existing item with a key matching
5079 * the previous key we computed above.
5080 */
5081 if (ret <= 0)
925baedd
CM
5082 return 0;
5083 return 1;
7bb86316
CM
5084}
5085
3f157a2f
CM
5086/*
5087 * A helper function to walk down the tree starting at min_key, and looking
de78b51a
ES
5088 * for nodes or leaves that are have a minimum transaction id.
5089 * This is used by the btree defrag code, and tree logging
3f157a2f
CM
5090 *
5091 * This does not cow, but it does stuff the starting key it finds back
5092 * into min_key, so you can call btrfs_search_slot with cow=1 on the
5093 * key and get a writable path.
5094 *
5095 * This does lock as it descends, and path->keep_locks should be set
5096 * to 1 by the caller.
5097 *
5098 * This honors path->lowest_level to prevent descent past a given level
5099 * of the tree.
5100 *
d352ac68
CM
5101 * min_trans indicates the oldest transaction that you are interested
5102 * in walking through. Any nodes or leaves older than min_trans are
5103 * skipped over (without reading them).
5104 *
3f157a2f
CM
5105 * returns zero if something useful was found, < 0 on error and 1 if there
5106 * was nothing in the tree that matched the search criteria.
5107 */
5108int btrfs_search_forward(struct btrfs_root *root, struct btrfs_key *min_key,
de78b51a 5109 struct btrfs_path *path,
3f157a2f
CM
5110 u64 min_trans)
5111{
5112 struct extent_buffer *cur;
5113 struct btrfs_key found_key;
5114 int slot;
9652480b 5115 int sret;
3f157a2f
CM
5116 u32 nritems;
5117 int level;
5118 int ret = 1;
f98de9b9 5119 int keep_locks = path->keep_locks;
3f157a2f 5120
f98de9b9 5121 path->keep_locks = 1;
3f157a2f 5122again:
bd681513 5123 cur = btrfs_read_lock_root_node(root);
3f157a2f 5124 level = btrfs_header_level(cur);
e02119d5 5125 WARN_ON(path->nodes[level]);
3f157a2f 5126 path->nodes[level] = cur;
bd681513 5127 path->locks[level] = BTRFS_READ_LOCK;
3f157a2f
CM
5128
5129 if (btrfs_header_generation(cur) < min_trans) {
5130 ret = 1;
5131 goto out;
5132 }
d397712b 5133 while (1) {
3f157a2f
CM
5134 nritems = btrfs_header_nritems(cur);
5135 level = btrfs_header_level(cur);
9652480b 5136 sret = bin_search(cur, min_key, level, &slot);
3f157a2f 5137
323ac95b
CM
5138 /* at the lowest level, we're done, setup the path and exit */
5139 if (level == path->lowest_level) {
e02119d5
CM
5140 if (slot >= nritems)
5141 goto find_next_key;
3f157a2f
CM
5142 ret = 0;
5143 path->slots[level] = slot;
5144 btrfs_item_key_to_cpu(cur, &found_key, slot);
5145 goto out;
5146 }
9652480b
Y
5147 if (sret && slot > 0)
5148 slot--;
3f157a2f 5149 /*
de78b51a
ES
5150 * check this node pointer against the min_trans parameters.
5151 * If it is too old, old, skip to the next one.
3f157a2f 5152 */
d397712b 5153 while (slot < nritems) {
3f157a2f 5154 u64 gen;
e02119d5 5155
3f157a2f
CM
5156 gen = btrfs_node_ptr_generation(cur, slot);
5157 if (gen < min_trans) {
5158 slot++;
5159 continue;
5160 }
de78b51a 5161 break;
3f157a2f 5162 }
e02119d5 5163find_next_key:
3f157a2f
CM
5164 /*
5165 * we didn't find a candidate key in this node, walk forward
5166 * and find another one
5167 */
5168 if (slot >= nritems) {
e02119d5 5169 path->slots[level] = slot;
b4ce94de 5170 btrfs_set_path_blocking(path);
e02119d5 5171 sret = btrfs_find_next_key(root, path, min_key, level,
de78b51a 5172 min_trans);
e02119d5 5173 if (sret == 0) {
b3b4aa74 5174 btrfs_release_path(path);
3f157a2f
CM
5175 goto again;
5176 } else {
5177 goto out;
5178 }
5179 }
5180 /* save our key for returning back */
5181 btrfs_node_key_to_cpu(cur, &found_key, slot);
5182 path->slots[level] = slot;
5183 if (level == path->lowest_level) {
5184 ret = 0;
3f157a2f
CM
5185 goto out;
5186 }
b4ce94de 5187 btrfs_set_path_blocking(path);
3f157a2f 5188 cur = read_node_slot(root, cur, slot);
79787eaa 5189 BUG_ON(!cur); /* -ENOMEM */
3f157a2f 5190
bd681513 5191 btrfs_tree_read_lock(cur);
b4ce94de 5192
bd681513 5193 path->locks[level - 1] = BTRFS_READ_LOCK;
3f157a2f 5194 path->nodes[level - 1] = cur;
f7c79f30 5195 unlock_up(path, level, 1, 0, NULL);
bd681513 5196 btrfs_clear_path_blocking(path, NULL, 0);
3f157a2f
CM
5197 }
5198out:
f98de9b9
FM
5199 path->keep_locks = keep_locks;
5200 if (ret == 0) {
5201 btrfs_unlock_up_safe(path, path->lowest_level + 1);
5202 btrfs_set_path_blocking(path);
3f157a2f 5203 memcpy(min_key, &found_key, sizeof(found_key));
f98de9b9 5204 }
3f157a2f
CM
5205 return ret;
5206}
5207
7069830a
AB
5208static void tree_move_down(struct btrfs_root *root,
5209 struct btrfs_path *path,
5210 int *level, int root_level)
5211{
74dd17fb 5212 BUG_ON(*level == 0);
7069830a
AB
5213 path->nodes[*level - 1] = read_node_slot(root, path->nodes[*level],
5214 path->slots[*level]);
5215 path->slots[*level - 1] = 0;
5216 (*level)--;
5217}
5218
5219static int tree_move_next_or_upnext(struct btrfs_root *root,
5220 struct btrfs_path *path,
5221 int *level, int root_level)
5222{
5223 int ret = 0;
5224 int nritems;
5225 nritems = btrfs_header_nritems(path->nodes[*level]);
5226
5227 path->slots[*level]++;
5228
74dd17fb 5229 while (path->slots[*level] >= nritems) {
7069830a
AB
5230 if (*level == root_level)
5231 return -1;
5232
5233 /* move upnext */
5234 path->slots[*level] = 0;
5235 free_extent_buffer(path->nodes[*level]);
5236 path->nodes[*level] = NULL;
5237 (*level)++;
5238 path->slots[*level]++;
5239
5240 nritems = btrfs_header_nritems(path->nodes[*level]);
5241 ret = 1;
5242 }
5243 return ret;
5244}
5245
5246/*
5247 * Returns 1 if it had to move up and next. 0 is returned if it moved only next
5248 * or down.
5249 */
5250static int tree_advance(struct btrfs_root *root,
5251 struct btrfs_path *path,
5252 int *level, int root_level,
5253 int allow_down,
5254 struct btrfs_key *key)
5255{
5256 int ret;
5257
5258 if (*level == 0 || !allow_down) {
5259 ret = tree_move_next_or_upnext(root, path, level, root_level);
5260 } else {
5261 tree_move_down(root, path, level, root_level);
5262 ret = 0;
5263 }
5264 if (ret >= 0) {
5265 if (*level == 0)
5266 btrfs_item_key_to_cpu(path->nodes[*level], key,
5267 path->slots[*level]);
5268 else
5269 btrfs_node_key_to_cpu(path->nodes[*level], key,
5270 path->slots[*level]);
5271 }
5272 return ret;
5273}
5274
5275static int tree_compare_item(struct btrfs_root *left_root,
5276 struct btrfs_path *left_path,
5277 struct btrfs_path *right_path,
5278 char *tmp_buf)
5279{
5280 int cmp;
5281 int len1, len2;
5282 unsigned long off1, off2;
5283
5284 len1 = btrfs_item_size_nr(left_path->nodes[0], left_path->slots[0]);
5285 len2 = btrfs_item_size_nr(right_path->nodes[0], right_path->slots[0]);
5286 if (len1 != len2)
5287 return 1;
5288
5289 off1 = btrfs_item_ptr_offset(left_path->nodes[0], left_path->slots[0]);
5290 off2 = btrfs_item_ptr_offset(right_path->nodes[0],
5291 right_path->slots[0]);
5292
5293 read_extent_buffer(left_path->nodes[0], tmp_buf, off1, len1);
5294
5295 cmp = memcmp_extent_buffer(right_path->nodes[0], tmp_buf, off2, len1);
5296 if (cmp)
5297 return 1;
5298 return 0;
5299}
5300
5301#define ADVANCE 1
5302#define ADVANCE_ONLY_NEXT -1
5303
5304/*
5305 * This function compares two trees and calls the provided callback for
5306 * every changed/new/deleted item it finds.
5307 * If shared tree blocks are encountered, whole subtrees are skipped, making
5308 * the compare pretty fast on snapshotted subvolumes.
5309 *
5310 * This currently works on commit roots only. As commit roots are read only,
5311 * we don't do any locking. The commit roots are protected with transactions.
5312 * Transactions are ended and rejoined when a commit is tried in between.
5313 *
5314 * This function checks for modifications done to the trees while comparing.
5315 * If it detects a change, it aborts immediately.
5316 */
5317int btrfs_compare_trees(struct btrfs_root *left_root,
5318 struct btrfs_root *right_root,
5319 btrfs_changed_cb_t changed_cb, void *ctx)
5320{
5321 int ret;
5322 int cmp;
7069830a
AB
5323 struct btrfs_path *left_path = NULL;
5324 struct btrfs_path *right_path = NULL;
5325 struct btrfs_key left_key;
5326 struct btrfs_key right_key;
5327 char *tmp_buf = NULL;
5328 int left_root_level;
5329 int right_root_level;
5330 int left_level;
5331 int right_level;
5332 int left_end_reached;
5333 int right_end_reached;
5334 int advance_left;
5335 int advance_right;
5336 u64 left_blockptr;
5337 u64 right_blockptr;
6baa4293
FM
5338 u64 left_gen;
5339 u64 right_gen;
7069830a
AB
5340
5341 left_path = btrfs_alloc_path();
5342 if (!left_path) {
5343 ret = -ENOMEM;
5344 goto out;
5345 }
5346 right_path = btrfs_alloc_path();
5347 if (!right_path) {
5348 ret = -ENOMEM;
5349 goto out;
5350 }
5351
707e8a07 5352 tmp_buf = kmalloc(left_root->nodesize, GFP_NOFS);
7069830a
AB
5353 if (!tmp_buf) {
5354 ret = -ENOMEM;
5355 goto out;
5356 }
5357
5358 left_path->search_commit_root = 1;
5359 left_path->skip_locking = 1;
5360 right_path->search_commit_root = 1;
5361 right_path->skip_locking = 1;
5362
7069830a
AB
5363 /*
5364 * Strategy: Go to the first items of both trees. Then do
5365 *
5366 * If both trees are at level 0
5367 * Compare keys of current items
5368 * If left < right treat left item as new, advance left tree
5369 * and repeat
5370 * If left > right treat right item as deleted, advance right tree
5371 * and repeat
5372 * If left == right do deep compare of items, treat as changed if
5373 * needed, advance both trees and repeat
5374 * If both trees are at the same level but not at level 0
5375 * Compare keys of current nodes/leafs
5376 * If left < right advance left tree and repeat
5377 * If left > right advance right tree and repeat
5378 * If left == right compare blockptrs of the next nodes/leafs
5379 * If they match advance both trees but stay at the same level
5380 * and repeat
5381 * If they don't match advance both trees while allowing to go
5382 * deeper and repeat
5383 * If tree levels are different
5384 * Advance the tree that needs it and repeat
5385 *
5386 * Advancing a tree means:
5387 * If we are at level 0, try to go to the next slot. If that's not
5388 * possible, go one level up and repeat. Stop when we found a level
5389 * where we could go to the next slot. We may at this point be on a
5390 * node or a leaf.
5391 *
5392 * If we are not at level 0 and not on shared tree blocks, go one
5393 * level deeper.
5394 *
5395 * If we are not at level 0 and on shared tree blocks, go one slot to
5396 * the right if possible or go up and right.
5397 */
5398
3f8a18cc 5399 down_read(&left_root->fs_info->commit_root_sem);
7069830a
AB
5400 left_level = btrfs_header_level(left_root->commit_root);
5401 left_root_level = left_level;
5402 left_path->nodes[left_level] = left_root->commit_root;
5403 extent_buffer_get(left_path->nodes[left_level]);
5404
5405 right_level = btrfs_header_level(right_root->commit_root);
5406 right_root_level = right_level;
5407 right_path->nodes[right_level] = right_root->commit_root;
5408 extent_buffer_get(right_path->nodes[right_level]);
3f8a18cc 5409 up_read(&left_root->fs_info->commit_root_sem);
7069830a
AB
5410
5411 if (left_level == 0)
5412 btrfs_item_key_to_cpu(left_path->nodes[left_level],
5413 &left_key, left_path->slots[left_level]);
5414 else
5415 btrfs_node_key_to_cpu(left_path->nodes[left_level],
5416 &left_key, left_path->slots[left_level]);
5417 if (right_level == 0)
5418 btrfs_item_key_to_cpu(right_path->nodes[right_level],
5419 &right_key, right_path->slots[right_level]);
5420 else
5421 btrfs_node_key_to_cpu(right_path->nodes[right_level],
5422 &right_key, right_path->slots[right_level]);
5423
5424 left_end_reached = right_end_reached = 0;
5425 advance_left = advance_right = 0;
5426
5427 while (1) {
7069830a
AB
5428 if (advance_left && !left_end_reached) {
5429 ret = tree_advance(left_root, left_path, &left_level,
5430 left_root_level,
5431 advance_left != ADVANCE_ONLY_NEXT,
5432 &left_key);
5433 if (ret < 0)
5434 left_end_reached = ADVANCE;
5435 advance_left = 0;
5436 }
5437 if (advance_right && !right_end_reached) {
5438 ret = tree_advance(right_root, right_path, &right_level,
5439 right_root_level,
5440 advance_right != ADVANCE_ONLY_NEXT,
5441 &right_key);
5442 if (ret < 0)
5443 right_end_reached = ADVANCE;
5444 advance_right = 0;
5445 }
5446
5447 if (left_end_reached && right_end_reached) {
5448 ret = 0;
5449 goto out;
5450 } else if (left_end_reached) {
5451 if (right_level == 0) {
5452 ret = changed_cb(left_root, right_root,
5453 left_path, right_path,
5454 &right_key,
5455 BTRFS_COMPARE_TREE_DELETED,
5456 ctx);
5457 if (ret < 0)
5458 goto out;
5459 }
5460 advance_right = ADVANCE;
5461 continue;
5462 } else if (right_end_reached) {
5463 if (left_level == 0) {
5464 ret = changed_cb(left_root, right_root,
5465 left_path, right_path,
5466 &left_key,
5467 BTRFS_COMPARE_TREE_NEW,
5468 ctx);
5469 if (ret < 0)
5470 goto out;
5471 }
5472 advance_left = ADVANCE;
5473 continue;
5474 }
5475
5476 if (left_level == 0 && right_level == 0) {
5477 cmp = btrfs_comp_cpu_keys(&left_key, &right_key);
5478 if (cmp < 0) {
5479 ret = changed_cb(left_root, right_root,
5480 left_path, right_path,
5481 &left_key,
5482 BTRFS_COMPARE_TREE_NEW,
5483 ctx);
5484 if (ret < 0)
5485 goto out;
5486 advance_left = ADVANCE;
5487 } else if (cmp > 0) {
5488 ret = changed_cb(left_root, right_root,
5489 left_path, right_path,
5490 &right_key,
5491 BTRFS_COMPARE_TREE_DELETED,
5492 ctx);
5493 if (ret < 0)
5494 goto out;
5495 advance_right = ADVANCE;
5496 } else {
b99d9a6a 5497 enum btrfs_compare_tree_result result;
ba5e8f2e 5498
74dd17fb 5499 WARN_ON(!extent_buffer_uptodate(left_path->nodes[0]));
7069830a
AB
5500 ret = tree_compare_item(left_root, left_path,
5501 right_path, tmp_buf);
ba5e8f2e 5502 if (ret)
b99d9a6a 5503 result = BTRFS_COMPARE_TREE_CHANGED;
ba5e8f2e 5504 else
b99d9a6a 5505 result = BTRFS_COMPARE_TREE_SAME;
ba5e8f2e
JB
5506 ret = changed_cb(left_root, right_root,
5507 left_path, right_path,
b99d9a6a 5508 &left_key, result, ctx);
ba5e8f2e
JB
5509 if (ret < 0)
5510 goto out;
7069830a
AB
5511 advance_left = ADVANCE;
5512 advance_right = ADVANCE;
5513 }
5514 } else if (left_level == right_level) {
5515 cmp = btrfs_comp_cpu_keys(&left_key, &right_key);
5516 if (cmp < 0) {
5517 advance_left = ADVANCE;
5518 } else if (cmp > 0) {
5519 advance_right = ADVANCE;
5520 } else {
5521 left_blockptr = btrfs_node_blockptr(
5522 left_path->nodes[left_level],
5523 left_path->slots[left_level]);
5524 right_blockptr = btrfs_node_blockptr(
5525 right_path->nodes[right_level],
5526 right_path->slots[right_level]);
6baa4293
FM
5527 left_gen = btrfs_node_ptr_generation(
5528 left_path->nodes[left_level],
5529 left_path->slots[left_level]);
5530 right_gen = btrfs_node_ptr_generation(
5531 right_path->nodes[right_level],
5532 right_path->slots[right_level]);
5533 if (left_blockptr == right_blockptr &&
5534 left_gen == right_gen) {
7069830a
AB
5535 /*
5536 * As we're on a shared block, don't
5537 * allow to go deeper.
5538 */
5539 advance_left = ADVANCE_ONLY_NEXT;
5540 advance_right = ADVANCE_ONLY_NEXT;
5541 } else {
5542 advance_left = ADVANCE;
5543 advance_right = ADVANCE;
5544 }
5545 }
5546 } else if (left_level < right_level) {
5547 advance_right = ADVANCE;
5548 } else {
5549 advance_left = ADVANCE;
5550 }
5551 }
5552
5553out:
5554 btrfs_free_path(left_path);
5555 btrfs_free_path(right_path);
5556 kfree(tmp_buf);
7069830a
AB
5557 return ret;
5558}
5559
3f157a2f
CM
5560/*
5561 * this is similar to btrfs_next_leaf, but does not try to preserve
5562 * and fixup the path. It looks for and returns the next key in the
de78b51a 5563 * tree based on the current path and the min_trans parameters.
3f157a2f
CM
5564 *
5565 * 0 is returned if another key is found, < 0 if there are any errors
5566 * and 1 is returned if there are no higher keys in the tree
5567 *
5568 * path->keep_locks should be set to 1 on the search made before
5569 * calling this function.
5570 */
e7a84565 5571int btrfs_find_next_key(struct btrfs_root *root, struct btrfs_path *path,
de78b51a 5572 struct btrfs_key *key, int level, u64 min_trans)
e7a84565 5573{
e7a84565
CM
5574 int slot;
5575 struct extent_buffer *c;
5576
934d375b 5577 WARN_ON(!path->keep_locks);
d397712b 5578 while (level < BTRFS_MAX_LEVEL) {
e7a84565
CM
5579 if (!path->nodes[level])
5580 return 1;
5581
5582 slot = path->slots[level] + 1;
5583 c = path->nodes[level];
3f157a2f 5584next:
e7a84565 5585 if (slot >= btrfs_header_nritems(c)) {
33c66f43
YZ
5586 int ret;
5587 int orig_lowest;
5588 struct btrfs_key cur_key;
5589 if (level + 1 >= BTRFS_MAX_LEVEL ||
5590 !path->nodes[level + 1])
e7a84565 5591 return 1;
33c66f43
YZ
5592
5593 if (path->locks[level + 1]) {
5594 level++;
5595 continue;
5596 }
5597
5598 slot = btrfs_header_nritems(c) - 1;
5599 if (level == 0)
5600 btrfs_item_key_to_cpu(c, &cur_key, slot);
5601 else
5602 btrfs_node_key_to_cpu(c, &cur_key, slot);
5603
5604 orig_lowest = path->lowest_level;
b3b4aa74 5605 btrfs_release_path(path);
33c66f43
YZ
5606 path->lowest_level = level;
5607 ret = btrfs_search_slot(NULL, root, &cur_key, path,
5608 0, 0);
5609 path->lowest_level = orig_lowest;
5610 if (ret < 0)
5611 return ret;
5612
5613 c = path->nodes[level];
5614 slot = path->slots[level];
5615 if (ret == 0)
5616 slot++;
5617 goto next;
e7a84565 5618 }
33c66f43 5619
e7a84565
CM
5620 if (level == 0)
5621 btrfs_item_key_to_cpu(c, key, slot);
3f157a2f 5622 else {
3f157a2f
CM
5623 u64 gen = btrfs_node_ptr_generation(c, slot);
5624
3f157a2f
CM
5625 if (gen < min_trans) {
5626 slot++;
5627 goto next;
5628 }
e7a84565 5629 btrfs_node_key_to_cpu(c, key, slot);
3f157a2f 5630 }
e7a84565
CM
5631 return 0;
5632 }
5633 return 1;
5634}
5635
97571fd0 5636/*
925baedd 5637 * search the tree again to find a leaf with greater keys
0f70abe2
CM
5638 * returns 0 if it found something or 1 if there are no greater leaves.
5639 * returns < 0 on io errors.
97571fd0 5640 */
234b63a0 5641int btrfs_next_leaf(struct btrfs_root *root, struct btrfs_path *path)
3d7806ec
JS
5642{
5643 return btrfs_next_old_leaf(root, path, 0);
5644}
5645
5646int btrfs_next_old_leaf(struct btrfs_root *root, struct btrfs_path *path,
5647 u64 time_seq)
d97e63b6
CM
5648{
5649 int slot;
8e73f275 5650 int level;
5f39d397 5651 struct extent_buffer *c;
8e73f275 5652 struct extent_buffer *next;
925baedd
CM
5653 struct btrfs_key key;
5654 u32 nritems;
5655 int ret;
8e73f275 5656 int old_spinning = path->leave_spinning;
bd681513 5657 int next_rw_lock = 0;
925baedd
CM
5658
5659 nritems = btrfs_header_nritems(path->nodes[0]);
d397712b 5660 if (nritems == 0)
925baedd 5661 return 1;
925baedd 5662
8e73f275
CM
5663 btrfs_item_key_to_cpu(path->nodes[0], &key, nritems - 1);
5664again:
5665 level = 1;
5666 next = NULL;
bd681513 5667 next_rw_lock = 0;
b3b4aa74 5668 btrfs_release_path(path);
8e73f275 5669
a2135011 5670 path->keep_locks = 1;
31533fb2 5671 path->leave_spinning = 1;
8e73f275 5672
3d7806ec
JS
5673 if (time_seq)
5674 ret = btrfs_search_old_slot(root, &key, path, time_seq);
5675 else
5676 ret = btrfs_search_slot(NULL, root, &key, path, 0, 0);
925baedd
CM
5677 path->keep_locks = 0;
5678
5679 if (ret < 0)
5680 return ret;
5681
a2135011 5682 nritems = btrfs_header_nritems(path->nodes[0]);
168fd7d2
CM
5683 /*
5684 * by releasing the path above we dropped all our locks. A balance
5685 * could have added more items next to the key that used to be
5686 * at the very end of the block. So, check again here and
5687 * advance the path if there are now more items available.
5688 */
a2135011 5689 if (nritems > 0 && path->slots[0] < nritems - 1) {
e457afec
YZ
5690 if (ret == 0)
5691 path->slots[0]++;
8e73f275 5692 ret = 0;
925baedd
CM
5693 goto done;
5694 }
0b43e04f
LB
5695 /*
5696 * So the above check misses one case:
5697 * - after releasing the path above, someone has removed the item that
5698 * used to be at the very end of the block, and balance between leafs
5699 * gets another one with bigger key.offset to replace it.
5700 *
5701 * This one should be returned as well, or we can get leaf corruption
5702 * later(esp. in __btrfs_drop_extents()).
5703 *
5704 * And a bit more explanation about this check,
5705 * with ret > 0, the key isn't found, the path points to the slot
5706 * where it should be inserted, so the path->slots[0] item must be the
5707 * bigger one.
5708 */
5709 if (nritems > 0 && ret > 0 && path->slots[0] == nritems - 1) {
5710 ret = 0;
5711 goto done;
5712 }
d97e63b6 5713
d397712b 5714 while (level < BTRFS_MAX_LEVEL) {
8e73f275
CM
5715 if (!path->nodes[level]) {
5716 ret = 1;
5717 goto done;
5718 }
5f39d397 5719
d97e63b6
CM
5720 slot = path->slots[level] + 1;
5721 c = path->nodes[level];
5f39d397 5722 if (slot >= btrfs_header_nritems(c)) {
d97e63b6 5723 level++;
8e73f275
CM
5724 if (level == BTRFS_MAX_LEVEL) {
5725 ret = 1;
5726 goto done;
5727 }
d97e63b6
CM
5728 continue;
5729 }
5f39d397 5730
925baedd 5731 if (next) {
bd681513 5732 btrfs_tree_unlock_rw(next, next_rw_lock);
5f39d397 5733 free_extent_buffer(next);
925baedd 5734 }
5f39d397 5735
8e73f275 5736 next = c;
bd681513 5737 next_rw_lock = path->locks[level];
8e73f275 5738 ret = read_block_for_search(NULL, root, path, &next, level,
5d9e75c4 5739 slot, &key, 0);
8e73f275
CM
5740 if (ret == -EAGAIN)
5741 goto again;
5f39d397 5742
76a05b35 5743 if (ret < 0) {
b3b4aa74 5744 btrfs_release_path(path);
76a05b35
CM
5745 goto done;
5746 }
5747
5cd57b2c 5748 if (!path->skip_locking) {
bd681513 5749 ret = btrfs_try_tree_read_lock(next);
d42244a0
JS
5750 if (!ret && time_seq) {
5751 /*
5752 * If we don't get the lock, we may be racing
5753 * with push_leaf_left, holding that lock while
5754 * itself waiting for the leaf we've currently
5755 * locked. To solve this situation, we give up
5756 * on our lock and cycle.
5757 */
cf538830 5758 free_extent_buffer(next);
d42244a0
JS
5759 btrfs_release_path(path);
5760 cond_resched();
5761 goto again;
5762 }
8e73f275
CM
5763 if (!ret) {
5764 btrfs_set_path_blocking(path);
bd681513 5765 btrfs_tree_read_lock(next);
31533fb2 5766 btrfs_clear_path_blocking(path, next,
bd681513 5767 BTRFS_READ_LOCK);
8e73f275 5768 }
31533fb2 5769 next_rw_lock = BTRFS_READ_LOCK;
5cd57b2c 5770 }
d97e63b6
CM
5771 break;
5772 }
5773 path->slots[level] = slot;
d397712b 5774 while (1) {
d97e63b6
CM
5775 level--;
5776 c = path->nodes[level];
925baedd 5777 if (path->locks[level])
bd681513 5778 btrfs_tree_unlock_rw(c, path->locks[level]);
8e73f275 5779
5f39d397 5780 free_extent_buffer(c);
d97e63b6
CM
5781 path->nodes[level] = next;
5782 path->slots[level] = 0;
a74a4b97 5783 if (!path->skip_locking)
bd681513 5784 path->locks[level] = next_rw_lock;
d97e63b6
CM
5785 if (!level)
5786 break;
b4ce94de 5787
8e73f275 5788 ret = read_block_for_search(NULL, root, path, &next, level,
5d9e75c4 5789 0, &key, 0);
8e73f275
CM
5790 if (ret == -EAGAIN)
5791 goto again;
5792
76a05b35 5793 if (ret < 0) {
b3b4aa74 5794 btrfs_release_path(path);
76a05b35
CM
5795 goto done;
5796 }
5797
5cd57b2c 5798 if (!path->skip_locking) {
bd681513 5799 ret = btrfs_try_tree_read_lock(next);
8e73f275
CM
5800 if (!ret) {
5801 btrfs_set_path_blocking(path);
bd681513 5802 btrfs_tree_read_lock(next);
31533fb2 5803 btrfs_clear_path_blocking(path, next,
bd681513
CM
5804 BTRFS_READ_LOCK);
5805 }
31533fb2 5806 next_rw_lock = BTRFS_READ_LOCK;
5cd57b2c 5807 }
d97e63b6 5808 }
8e73f275 5809 ret = 0;
925baedd 5810done:
f7c79f30 5811 unlock_up(path, 0, 1, 0, NULL);
8e73f275
CM
5812 path->leave_spinning = old_spinning;
5813 if (!old_spinning)
5814 btrfs_set_path_blocking(path);
5815
5816 return ret;
d97e63b6 5817}
0b86a832 5818
3f157a2f
CM
5819/*
5820 * this uses btrfs_prev_leaf to walk backwards in the tree, and keeps
5821 * searching until it gets past min_objectid or finds an item of 'type'
5822 *
5823 * returns 0 if something is found, 1 if nothing was found and < 0 on error
5824 */
0b86a832
CM
5825int btrfs_previous_item(struct btrfs_root *root,
5826 struct btrfs_path *path, u64 min_objectid,
5827 int type)
5828{
5829 struct btrfs_key found_key;
5830 struct extent_buffer *leaf;
e02119d5 5831 u32 nritems;
0b86a832
CM
5832 int ret;
5833
d397712b 5834 while (1) {
0b86a832 5835 if (path->slots[0] == 0) {
b4ce94de 5836 btrfs_set_path_blocking(path);
0b86a832
CM
5837 ret = btrfs_prev_leaf(root, path);
5838 if (ret != 0)
5839 return ret;
5840 } else {
5841 path->slots[0]--;
5842 }
5843 leaf = path->nodes[0];
e02119d5
CM
5844 nritems = btrfs_header_nritems(leaf);
5845 if (nritems == 0)
5846 return 1;
5847 if (path->slots[0] == nritems)
5848 path->slots[0]--;
5849
0b86a832 5850 btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]);
e02119d5
CM
5851 if (found_key.objectid < min_objectid)
5852 break;
0a4eefbb
YZ
5853 if (found_key.type == type)
5854 return 0;
e02119d5
CM
5855 if (found_key.objectid == min_objectid &&
5856 found_key.type < type)
5857 break;
0b86a832
CM
5858 }
5859 return 1;
5860}
ade2e0b3
WS
5861
5862/*
5863 * search in extent tree to find a previous Metadata/Data extent item with
5864 * min objecitd.
5865 *
5866 * returns 0 if something is found, 1 if nothing was found and < 0 on error
5867 */
5868int btrfs_previous_extent_item(struct btrfs_root *root,
5869 struct btrfs_path *path, u64 min_objectid)
5870{
5871 struct btrfs_key found_key;
5872 struct extent_buffer *leaf;
5873 u32 nritems;
5874 int ret;
5875
5876 while (1) {
5877 if (path->slots[0] == 0) {
5878 btrfs_set_path_blocking(path);
5879 ret = btrfs_prev_leaf(root, path);
5880 if (ret != 0)
5881 return ret;
5882 } else {
5883 path->slots[0]--;
5884 }
5885 leaf = path->nodes[0];
5886 nritems = btrfs_header_nritems(leaf);
5887 if (nritems == 0)
5888 return 1;
5889 if (path->slots[0] == nritems)
5890 path->slots[0]--;
5891
5892 btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]);
5893 if (found_key.objectid < min_objectid)
5894 break;
5895 if (found_key.type == BTRFS_EXTENT_ITEM_KEY ||
5896 found_key.type == BTRFS_METADATA_ITEM_KEY)
5897 return 0;
5898 if (found_key.objectid == min_objectid &&
5899 found_key.type < BTRFS_EXTENT_ITEM_KEY)
5900 break;
5901 }
5902 return 1;
5903}