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