1 // SPDX-License-Identifier: GPL-2.0
2 /*
3 * Copyright (c) 2000-2005 Silicon Graphics, Inc.
4 * Copyright (c) 2013 Red Hat, Inc.
5 * All Rights Reserved.
6 */
7 #include "xfs.h"
8 #include "xfs_fs.h"
9 #include "xfs_shared.h"
10 #include "xfs_format.h"
11 #include "xfs_log_format.h"
12 #include "xfs_trans_resv.h"
13 #include "xfs_bit.h"
14 #include "xfs_mount.h"
15 #include "xfs_inode.h"
16 #include "xfs_dir2.h"
17 #include "xfs_dir2_priv.h"
18 #include "xfs_trans.h"
19 #include "xfs_bmap.h"
20 #include "xfs_attr_leaf.h"
21 #include "xfs_error.h"
22 #include "xfs_trace.h"
23 #include "xfs_buf_item.h"
24 #include "xfs_log.h"
25
26 /*
27 * xfs_da_btree.c
28 *
29 * Routines to implement directories as Btrees of hashed names.
30 */
31
32 /*========================================================================
33 * Function prototypes for the kernel.
34 *========================================================================*/
35
36 /*
37 * Routines used for growing the Btree.
38 */
39 STATIC int xfs_da3_root_split(xfs_da_state_t *state,
40 xfs_da_state_blk_t *existing_root,
41 xfs_da_state_blk_t *new_child);
42 STATIC int xfs_da3_node_split(xfs_da_state_t *state,
43 xfs_da_state_blk_t *existing_blk,
44 xfs_da_state_blk_t *split_blk,
45 xfs_da_state_blk_t *blk_to_add,
46 int treelevel,
47 int *result);
48 STATIC void xfs_da3_node_rebalance(xfs_da_state_t *state,
49 xfs_da_state_blk_t *node_blk_1,
50 xfs_da_state_blk_t *node_blk_2);
51 STATIC void xfs_da3_node_add(xfs_da_state_t *state,
52 xfs_da_state_blk_t *old_node_blk,
53 xfs_da_state_blk_t *new_node_blk);
54
55 /*
56 * Routines used for shrinking the Btree.
57 */
58 STATIC int xfs_da3_root_join(xfs_da_state_t *state,
59 xfs_da_state_blk_t *root_blk);
60 STATIC int xfs_da3_node_toosmall(xfs_da_state_t *state, int *retval);
61 STATIC void xfs_da3_node_remove(xfs_da_state_t *state,
62 xfs_da_state_blk_t *drop_blk);
63 STATIC void xfs_da3_node_unbalance(xfs_da_state_t *state,
64 xfs_da_state_blk_t *src_node_blk,
65 xfs_da_state_blk_t *dst_node_blk);
66
67 /*
68 * Utility routines.
69 */
70 STATIC int xfs_da3_blk_unlink(xfs_da_state_t *state,
71 xfs_da_state_blk_t *drop_blk,
72 xfs_da_state_blk_t *save_blk);
73
74
75 struct kmem_cache *xfs_da_state_cache; /* anchor for dir/attr state */
76
77 /*
78 * Allocate a dir-state structure.
79 * We don't put them on the stack since they're large.
80 */
81 struct xfs_da_state *
xfs_da_state_alloc(struct xfs_da_args * args)82 xfs_da_state_alloc(
83 struct xfs_da_args *args)
84 {
85 struct xfs_da_state *state;
86
87 state = kmem_cache_zalloc(xfs_da_state_cache, GFP_NOFS | __GFP_NOFAIL);
88 state->args = args;
89 state->mp = args->dp->i_mount;
90 return state;
91 }
92
93 /*
94 * Kill the altpath contents of a da-state structure.
95 */
96 STATIC void
xfs_da_state_kill_altpath(xfs_da_state_t * state)97 xfs_da_state_kill_altpath(xfs_da_state_t *state)
98 {
99 int i;
100
101 for (i = 0; i < state->altpath.active; i++)
102 state->altpath.blk[i].bp = NULL;
103 state->altpath.active = 0;
104 }
105
106 /*
107 * Free a da-state structure.
108 */
109 void
xfs_da_state_free(xfs_da_state_t * state)110 xfs_da_state_free(xfs_da_state_t *state)
111 {
112 xfs_da_state_kill_altpath(state);
113 #ifdef DEBUG
114 memset((char *)state, 0, sizeof(*state));
115 #endif /* DEBUG */
116 kmem_cache_free(xfs_da_state_cache, state);
117 }
118
xfs_dabuf_nfsb(struct xfs_mount * mp,int whichfork)119 static inline int xfs_dabuf_nfsb(struct xfs_mount *mp, int whichfork)
120 {
121 if (whichfork == XFS_DATA_FORK)
122 return mp->m_dir_geo->fsbcount;
123 return mp->m_attr_geo->fsbcount;
124 }
125
126 void
xfs_da3_node_hdr_from_disk(struct xfs_mount * mp,struct xfs_da3_icnode_hdr * to,struct xfs_da_intnode * from)127 xfs_da3_node_hdr_from_disk(
128 struct xfs_mount *mp,
129 struct xfs_da3_icnode_hdr *to,
130 struct xfs_da_intnode *from)
131 {
132 if (xfs_has_crc(mp)) {
133 struct xfs_da3_intnode *from3 = (struct xfs_da3_intnode *)from;
134
135 to->forw = be32_to_cpu(from3->hdr.info.hdr.forw);
136 to->back = be32_to_cpu(from3->hdr.info.hdr.back);
137 to->magic = be16_to_cpu(from3->hdr.info.hdr.magic);
138 to->count = be16_to_cpu(from3->hdr.__count);
139 to->level = be16_to_cpu(from3->hdr.__level);
140 to->btree = from3->__btree;
141 ASSERT(to->magic == XFS_DA3_NODE_MAGIC);
142 } else {
143 to->forw = be32_to_cpu(from->hdr.info.forw);
144 to->back = be32_to_cpu(from->hdr.info.back);
145 to->magic = be16_to_cpu(from->hdr.info.magic);
146 to->count = be16_to_cpu(from->hdr.__count);
147 to->level = be16_to_cpu(from->hdr.__level);
148 to->btree = from->__btree;
149 ASSERT(to->magic == XFS_DA_NODE_MAGIC);
150 }
151 }
152
153 void
xfs_da3_node_hdr_to_disk(struct xfs_mount * mp,struct xfs_da_intnode * to,struct xfs_da3_icnode_hdr * from)154 xfs_da3_node_hdr_to_disk(
155 struct xfs_mount *mp,
156 struct xfs_da_intnode *to,
157 struct xfs_da3_icnode_hdr *from)
158 {
159 if (xfs_has_crc(mp)) {
160 struct xfs_da3_intnode *to3 = (struct xfs_da3_intnode *)to;
161
162 ASSERT(from->magic == XFS_DA3_NODE_MAGIC);
163 to3->hdr.info.hdr.forw = cpu_to_be32(from->forw);
164 to3->hdr.info.hdr.back = cpu_to_be32(from->back);
165 to3->hdr.info.hdr.magic = cpu_to_be16(from->magic);
166 to3->hdr.__count = cpu_to_be16(from->count);
167 to3->hdr.__level = cpu_to_be16(from->level);
168 } else {
169 ASSERT(from->magic == XFS_DA_NODE_MAGIC);
170 to->hdr.info.forw = cpu_to_be32(from->forw);
171 to->hdr.info.back = cpu_to_be32(from->back);
172 to->hdr.info.magic = cpu_to_be16(from->magic);
173 to->hdr.__count = cpu_to_be16(from->count);
174 to->hdr.__level = cpu_to_be16(from->level);
175 }
176 }
177
178 /*
179 * Verify an xfs_da3_blkinfo structure. Note that the da3 fields are only
180 * accessible on v5 filesystems. This header format is common across da node,
181 * attr leaf and dir leaf blocks.
182 */
183 xfs_failaddr_t
xfs_da3_blkinfo_verify(struct xfs_buf * bp,struct xfs_da3_blkinfo * hdr3)184 xfs_da3_blkinfo_verify(
185 struct xfs_buf *bp,
186 struct xfs_da3_blkinfo *hdr3)
187 {
188 struct xfs_mount *mp = bp->b_mount;
189 struct xfs_da_blkinfo *hdr = &hdr3->hdr;
190
191 if (!xfs_verify_magic16(bp, hdr->magic))
192 return __this_address;
193
194 if (xfs_has_crc(mp)) {
195 if (!uuid_equal(&hdr3->uuid, &mp->m_sb.sb_meta_uuid))
196 return __this_address;
197 if (be64_to_cpu(hdr3->blkno) != xfs_buf_daddr(bp))
198 return __this_address;
199 if (!xfs_log_check_lsn(mp, be64_to_cpu(hdr3->lsn)))
200 return __this_address;
201 }
202
203 return NULL;
204 }
205
206 static xfs_failaddr_t
xfs_da3_node_verify(struct xfs_buf * bp)207 xfs_da3_node_verify(
208 struct xfs_buf *bp)
209 {
210 struct xfs_mount *mp = bp->b_mount;
211 struct xfs_da_intnode *hdr = bp->b_addr;
212 struct xfs_da3_icnode_hdr ichdr;
213 xfs_failaddr_t fa;
214
215 xfs_da3_node_hdr_from_disk(mp, &ichdr, hdr);
216
217 fa = xfs_da3_blkinfo_verify(bp, bp->b_addr);
218 if (fa)
219 return fa;
220
221 if (ichdr.level == 0)
222 return __this_address;
223 if (ichdr.level > XFS_DA_NODE_MAXDEPTH)
224 return __this_address;
225 if (ichdr.count == 0)
226 return __this_address;
227
228 /*
229 * we don't know if the node is for and attribute or directory tree,
230 * so only fail if the count is outside both bounds
231 */
232 if (ichdr.count > mp->m_dir_geo->node_ents &&
233 ichdr.count > mp->m_attr_geo->node_ents)
234 return __this_address;
235
236 /* XXX: hash order check? */
237
238 return NULL;
239 }
240
241 static void
xfs_da3_node_write_verify(struct xfs_buf * bp)242 xfs_da3_node_write_verify(
243 struct xfs_buf *bp)
244 {
245 struct xfs_mount *mp = bp->b_mount;
246 struct xfs_buf_log_item *bip = bp->b_log_item;
247 struct xfs_da3_node_hdr *hdr3 = bp->b_addr;
248 xfs_failaddr_t fa;
249
250 fa = xfs_da3_node_verify(bp);
251 if (fa) {
252 xfs_verifier_error(bp, -EFSCORRUPTED, fa);
253 return;
254 }
255
256 if (!xfs_has_crc(mp))
257 return;
258
259 if (bip)
260 hdr3->info.lsn = cpu_to_be64(bip->bli_item.li_lsn);
261
262 xfs_buf_update_cksum(bp, XFS_DA3_NODE_CRC_OFF);
263 }
264
265 /*
266 * leaf/node format detection on trees is sketchy, so a node read can be done on
267 * leaf level blocks when detection identifies the tree as a node format tree
268 * incorrectly. In this case, we need to swap the verifier to match the correct
269 * format of the block being read.
270 */
271 static void
xfs_da3_node_read_verify(struct xfs_buf * bp)272 xfs_da3_node_read_verify(
273 struct xfs_buf *bp)
274 {
275 struct xfs_da_blkinfo *info = bp->b_addr;
276 xfs_failaddr_t fa;
277
278 switch (be16_to_cpu(info->magic)) {
279 case XFS_DA3_NODE_MAGIC:
280 if (!xfs_buf_verify_cksum(bp, XFS_DA3_NODE_CRC_OFF)) {
281 xfs_verifier_error(bp, -EFSBADCRC,
282 __this_address);
283 break;
284 }
285 fallthrough;
286 case XFS_DA_NODE_MAGIC:
287 fa = xfs_da3_node_verify(bp);
288 if (fa)
289 xfs_verifier_error(bp, -EFSCORRUPTED, fa);
290 return;
291 case XFS_ATTR_LEAF_MAGIC:
292 case XFS_ATTR3_LEAF_MAGIC:
293 bp->b_ops = &xfs_attr3_leaf_buf_ops;
294 bp->b_ops->verify_read(bp);
295 return;
296 case XFS_DIR2_LEAFN_MAGIC:
297 case XFS_DIR3_LEAFN_MAGIC:
298 bp->b_ops = &xfs_dir3_leafn_buf_ops;
299 bp->b_ops->verify_read(bp);
300 return;
301 default:
302 xfs_verifier_error(bp, -EFSCORRUPTED, __this_address);
303 break;
304 }
305 }
306
307 /* Verify the structure of a da3 block. */
308 static xfs_failaddr_t
xfs_da3_node_verify_struct(struct xfs_buf * bp)309 xfs_da3_node_verify_struct(
310 struct xfs_buf *bp)
311 {
312 struct xfs_da_blkinfo *info = bp->b_addr;
313
314 switch (be16_to_cpu(info->magic)) {
315 case XFS_DA3_NODE_MAGIC:
316 case XFS_DA_NODE_MAGIC:
317 return xfs_da3_node_verify(bp);
318 case XFS_ATTR_LEAF_MAGIC:
319 case XFS_ATTR3_LEAF_MAGIC:
320 bp->b_ops = &xfs_attr3_leaf_buf_ops;
321 return bp->b_ops->verify_struct(bp);
322 case XFS_DIR2_LEAFN_MAGIC:
323 case XFS_DIR3_LEAFN_MAGIC:
324 bp->b_ops = &xfs_dir3_leafn_buf_ops;
325 return bp->b_ops->verify_struct(bp);
326 default:
327 return __this_address;
328 }
329 }
330
331 const struct xfs_buf_ops xfs_da3_node_buf_ops = {
332 .name = "xfs_da3_node",
333 .magic16 = { cpu_to_be16(XFS_DA_NODE_MAGIC),
334 cpu_to_be16(XFS_DA3_NODE_MAGIC) },
335 .verify_read = xfs_da3_node_read_verify,
336 .verify_write = xfs_da3_node_write_verify,
337 .verify_struct = xfs_da3_node_verify_struct,
338 };
339
340 static int
xfs_da3_node_set_type(struct xfs_trans * tp,struct xfs_buf * bp)341 xfs_da3_node_set_type(
342 struct xfs_trans *tp,
343 struct xfs_buf *bp)
344 {
345 struct xfs_da_blkinfo *info = bp->b_addr;
346
347 switch (be16_to_cpu(info->magic)) {
348 case XFS_DA_NODE_MAGIC:
349 case XFS_DA3_NODE_MAGIC:
350 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_DA_NODE_BUF);
351 return 0;
352 case XFS_ATTR_LEAF_MAGIC:
353 case XFS_ATTR3_LEAF_MAGIC:
354 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_ATTR_LEAF_BUF);
355 return 0;
356 case XFS_DIR2_LEAFN_MAGIC:
357 case XFS_DIR3_LEAFN_MAGIC:
358 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_DIR_LEAFN_BUF);
359 return 0;
360 default:
361 XFS_CORRUPTION_ERROR(__func__, XFS_ERRLEVEL_LOW, tp->t_mountp,
362 info, sizeof(*info));
363 xfs_trans_brelse(tp, bp);
364 return -EFSCORRUPTED;
365 }
366 }
367
368 int
xfs_da3_node_read(struct xfs_trans * tp,struct xfs_inode * dp,xfs_dablk_t bno,struct xfs_buf ** bpp,int whichfork)369 xfs_da3_node_read(
370 struct xfs_trans *tp,
371 struct xfs_inode *dp,
372 xfs_dablk_t bno,
373 struct xfs_buf **bpp,
374 int whichfork)
375 {
376 int error;
377
378 error = xfs_da_read_buf(tp, dp, bno, 0, bpp, whichfork,
379 &xfs_da3_node_buf_ops);
380 if (error || !*bpp || !tp)
381 return error;
382 return xfs_da3_node_set_type(tp, *bpp);
383 }
384
385 int
xfs_da3_node_read_mapped(struct xfs_trans * tp,struct xfs_inode * dp,xfs_daddr_t mappedbno,struct xfs_buf ** bpp,int whichfork)386 xfs_da3_node_read_mapped(
387 struct xfs_trans *tp,
388 struct xfs_inode *dp,
389 xfs_daddr_t mappedbno,
390 struct xfs_buf **bpp,
391 int whichfork)
392 {
393 struct xfs_mount *mp = dp->i_mount;
394 int error;
395
396 error = xfs_trans_read_buf(mp, tp, mp->m_ddev_targp, mappedbno,
397 XFS_FSB_TO_BB(mp, xfs_dabuf_nfsb(mp, whichfork)), 0,
398 bpp, &xfs_da3_node_buf_ops);
399 if (error || !*bpp)
400 return error;
401
402 if (whichfork == XFS_ATTR_FORK)
403 xfs_buf_set_ref(*bpp, XFS_ATTR_BTREE_REF);
404 else
405 xfs_buf_set_ref(*bpp, XFS_DIR_BTREE_REF);
406
407 if (!tp)
408 return 0;
409 return xfs_da3_node_set_type(tp, *bpp);
410 }
411
412 /*========================================================================
413 * Routines used for growing the Btree.
414 *========================================================================*/
415
416 /*
417 * Create the initial contents of an intermediate node.
418 */
419 int
xfs_da3_node_create(struct xfs_da_args * args,xfs_dablk_t blkno,int level,struct xfs_buf ** bpp,int whichfork)420 xfs_da3_node_create(
421 struct xfs_da_args *args,
422 xfs_dablk_t blkno,
423 int level,
424 struct xfs_buf **bpp,
425 int whichfork)
426 {
427 struct xfs_da_intnode *node;
428 struct xfs_trans *tp = args->trans;
429 struct xfs_mount *mp = tp->t_mountp;
430 struct xfs_da3_icnode_hdr ichdr = {0};
431 struct xfs_buf *bp;
432 int error;
433 struct xfs_inode *dp = args->dp;
434
435 trace_xfs_da_node_create(args);
436 ASSERT(level <= XFS_DA_NODE_MAXDEPTH);
437
438 error = xfs_da_get_buf(tp, dp, blkno, &bp, whichfork);
439 if (error)
440 return error;
441 bp->b_ops = &xfs_da3_node_buf_ops;
442 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_DA_NODE_BUF);
443 node = bp->b_addr;
444
445 if (xfs_has_crc(mp)) {
446 struct xfs_da3_node_hdr *hdr3 = bp->b_addr;
447
448 memset(hdr3, 0, sizeof(struct xfs_da3_node_hdr));
449 ichdr.magic = XFS_DA3_NODE_MAGIC;
450 hdr3->info.blkno = cpu_to_be64(xfs_buf_daddr(bp));
451 hdr3->info.owner = cpu_to_be64(args->dp->i_ino);
452 uuid_copy(&hdr3->info.uuid, &mp->m_sb.sb_meta_uuid);
453 } else {
454 ichdr.magic = XFS_DA_NODE_MAGIC;
455 }
456 ichdr.level = level;
457
458 xfs_da3_node_hdr_to_disk(dp->i_mount, node, &ichdr);
459 xfs_trans_log_buf(tp, bp,
460 XFS_DA_LOGRANGE(node, &node->hdr, args->geo->node_hdr_size));
461
462 *bpp = bp;
463 return 0;
464 }
465
466 /*
467 * Split a leaf node, rebalance, then possibly split
468 * intermediate nodes, rebalance, etc.
469 */
470 int /* error */
xfs_da3_split(struct xfs_da_state * state)471 xfs_da3_split(
472 struct xfs_da_state *state)
473 {
474 struct xfs_da_state_blk *oldblk;
475 struct xfs_da_state_blk *newblk;
476 struct xfs_da_state_blk *addblk;
477 struct xfs_da_intnode *node;
478 int max;
479 int action = 0;
480 int error;
481 int i;
482
483 trace_xfs_da_split(state->args);
484
485 /*
486 * Walk back up the tree splitting/inserting/adjusting as necessary.
487 * If we need to insert and there isn't room, split the node, then
488 * decide which fragment to insert the new block from below into.
489 * Note that we may split the root this way, but we need more fixup.
490 */
491 max = state->path.active - 1;
492 ASSERT((max >= 0) && (max < XFS_DA_NODE_MAXDEPTH));
493 ASSERT(state->path.blk[max].magic == XFS_ATTR_LEAF_MAGIC ||
494 state->path.blk[max].magic == XFS_DIR2_LEAFN_MAGIC);
495
496 addblk = &state->path.blk[max]; /* initial dummy value */
497 for (i = max; (i >= 0) && addblk; state->path.active--, i--) {
498 oldblk = &state->path.blk[i];
499 newblk = &state->altpath.blk[i];
500
501 /*
502 * If a leaf node then
503 * Allocate a new leaf node, then rebalance across them.
504 * else if an intermediate node then
505 * We split on the last layer, must we split the node?
506 */
507 switch (oldblk->magic) {
508 case XFS_ATTR_LEAF_MAGIC:
509 error = xfs_attr3_leaf_split(state, oldblk, newblk);
510 if ((error != 0) && (error != -ENOSPC)) {
511 return error; /* GROT: attr is inconsistent */
512 }
513 if (!error) {
514 addblk = newblk;
515 break;
516 }
517 /*
518 * Entry wouldn't fit, split the leaf again. The new
519 * extrablk will be consumed by xfs_da3_node_split if
520 * the node is split.
521 */
522 state->extravalid = 1;
523 if (state->inleaf) {
524 state->extraafter = 0; /* before newblk */
525 trace_xfs_attr_leaf_split_before(state->args);
526 error = xfs_attr3_leaf_split(state, oldblk,
527 &state->extrablk);
528 } else {
529 state->extraafter = 1; /* after newblk */
530 trace_xfs_attr_leaf_split_after(state->args);
531 error = xfs_attr3_leaf_split(state, newblk,
532 &state->extrablk);
533 }
534 if (error)
535 return error; /* GROT: attr inconsistent */
536 addblk = newblk;
537 break;
538 case XFS_DIR2_LEAFN_MAGIC:
539 error = xfs_dir2_leafn_split(state, oldblk, newblk);
540 if (error)
541 return error;
542 addblk = newblk;
543 break;
544 case XFS_DA_NODE_MAGIC:
545 error = xfs_da3_node_split(state, oldblk, newblk, addblk,
546 max - i, &action);
547 addblk->bp = NULL;
548 if (error)
549 return error; /* GROT: dir is inconsistent */
550 /*
551 * Record the newly split block for the next time thru?
552 */
553 if (action)
554 addblk = newblk;
555 else
556 addblk = NULL;
557 break;
558 }
559
560 /*
561 * Update the btree to show the new hashval for this child.
562 */
563 xfs_da3_fixhashpath(state, &state->path);
564 }
565 if (!addblk)
566 return 0;
567
568 /*
569 * xfs_da3_node_split() should have consumed any extra blocks we added
570 * during a double leaf split in the attr fork. This is guaranteed as
571 * we can't be here if the attr fork only has a single leaf block.
572 */
573 ASSERT(state->extravalid == 0 ||
574 state->path.blk[max].magic == XFS_DIR2_LEAFN_MAGIC);
575
576 /*
577 * Split the root node.
578 */
579 ASSERT(state->path.active == 0);
580 oldblk = &state->path.blk[0];
581 error = xfs_da3_root_split(state, oldblk, addblk);
582 if (error)
583 goto out;
584
585 /*
586 * Update pointers to the node which used to be block 0 and just got
587 * bumped because of the addition of a new root node. Note that the
588 * original block 0 could be at any position in the list of blocks in
589 * the tree.
590 *
591 * Note: the magic numbers and sibling pointers are in the same physical
592 * place for both v2 and v3 headers (by design). Hence it doesn't matter
593 * which version of the xfs_da_intnode structure we use here as the
594 * result will be the same using either structure.
595 */
596 node = oldblk->bp->b_addr;
597 if (node->hdr.info.forw) {
598 if (be32_to_cpu(node->hdr.info.forw) != addblk->blkno) {
599 xfs_buf_mark_corrupt(oldblk->bp);
600 error = -EFSCORRUPTED;
601 goto out;
602 }
603 node = addblk->bp->b_addr;
604 node->hdr.info.back = cpu_to_be32(oldblk->blkno);
605 xfs_trans_log_buf(state->args->trans, addblk->bp,
606 XFS_DA_LOGRANGE(node, &node->hdr.info,
607 sizeof(node->hdr.info)));
608 }
609 node = oldblk->bp->b_addr;
610 if (node->hdr.info.back) {
611 if (be32_to_cpu(node->hdr.info.back) != addblk->blkno) {
612 xfs_buf_mark_corrupt(oldblk->bp);
613 error = -EFSCORRUPTED;
614 goto out;
615 }
616 node = addblk->bp->b_addr;
617 node->hdr.info.forw = cpu_to_be32(oldblk->blkno);
618 xfs_trans_log_buf(state->args->trans, addblk->bp,
619 XFS_DA_LOGRANGE(node, &node->hdr.info,
620 sizeof(node->hdr.info)));
621 }
622 out:
623 addblk->bp = NULL;
624 return error;
625 }
626
627 /*
628 * Split the root. We have to create a new root and point to the two
629 * parts (the split old root) that we just created. Copy block zero to
630 * the EOF, extending the inode in process.
631 */
632 STATIC int /* error */
xfs_da3_root_split(struct xfs_da_state * state,struct xfs_da_state_blk * blk1,struct xfs_da_state_blk * blk2)633 xfs_da3_root_split(
634 struct xfs_da_state *state,
635 struct xfs_da_state_blk *blk1,
636 struct xfs_da_state_blk *blk2)
637 {
638 struct xfs_da_intnode *node;
639 struct xfs_da_intnode *oldroot;
640 struct xfs_da_node_entry *btree;
641 struct xfs_da3_icnode_hdr nodehdr;
642 struct xfs_da_args *args;
643 struct xfs_buf *bp;
644 struct xfs_inode *dp;
645 struct xfs_trans *tp;
646 struct xfs_dir2_leaf *leaf;
647 xfs_dablk_t blkno;
648 int level;
649 int error;
650 int size;
651
652 trace_xfs_da_root_split(state->args);
653
654 /*
655 * Copy the existing (incorrect) block from the root node position
656 * to a free space somewhere.
657 */
658 args = state->args;
659 error = xfs_da_grow_inode(args, &blkno);
660 if (error)
661 return error;
662
663 dp = args->dp;
664 tp = args->trans;
665 error = xfs_da_get_buf(tp, dp, blkno, &bp, args->whichfork);
666 if (error)
667 return error;
668 node = bp->b_addr;
669 oldroot = blk1->bp->b_addr;
670 if (oldroot->hdr.info.magic == cpu_to_be16(XFS_DA_NODE_MAGIC) ||
671 oldroot->hdr.info.magic == cpu_to_be16(XFS_DA3_NODE_MAGIC)) {
672 struct xfs_da3_icnode_hdr icnodehdr;
673
674 xfs_da3_node_hdr_from_disk(dp->i_mount, &icnodehdr, oldroot);
675 btree = icnodehdr.btree;
676 size = (int)((char *)&btree[icnodehdr.count] - (char *)oldroot);
677 level = icnodehdr.level;
678
679 /*
680 * we are about to copy oldroot to bp, so set up the type
681 * of bp while we know exactly what it will be.
682 */
683 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_DA_NODE_BUF);
684 } else {
685 struct xfs_dir3_icleaf_hdr leafhdr;
686
687 leaf = (xfs_dir2_leaf_t *)oldroot;
688 xfs_dir2_leaf_hdr_from_disk(dp->i_mount, &leafhdr, leaf);
689
690 ASSERT(leafhdr.magic == XFS_DIR2_LEAFN_MAGIC ||
691 leafhdr.magic == XFS_DIR3_LEAFN_MAGIC);
692 size = (int)((char *)&leafhdr.ents[leafhdr.count] -
693 (char *)leaf);
694 level = 0;
695
696 /*
697 * we are about to copy oldroot to bp, so set up the type
698 * of bp while we know exactly what it will be.
699 */
700 xfs_trans_buf_set_type(tp, bp, XFS_BLFT_DIR_LEAFN_BUF);
701 }
702
703 /*
704 * we can copy most of the information in the node from one block to
705 * another, but for CRC enabled headers we have to make sure that the
706 * block specific identifiers are kept intact. We update the buffer
707 * directly for this.
708 */
709 memcpy(node, oldroot, size);
710 if (oldroot->hdr.info.magic == cpu_to_be16(XFS_DA3_NODE_MAGIC) ||
711 oldroot->hdr.info.magic == cpu_to_be16(XFS_DIR3_LEAFN_MAGIC)) {
712 struct xfs_da3_intnode *node3 = (struct xfs_da3_intnode *)node;
713
714 node3->hdr.info.blkno = cpu_to_be64(xfs_buf_daddr(bp));
715 }
716 xfs_trans_log_buf(tp, bp, 0, size - 1);
717
718 bp->b_ops = blk1->bp->b_ops;
719 xfs_trans_buf_copy_type(bp, blk1->bp);
720 blk1->bp = bp;
721 blk1->blkno = blkno;
722
723 /*
724 * Set up the new root node.
725 */
726 error = xfs_da3_node_create(args,
727 (args->whichfork == XFS_DATA_FORK) ? args->geo->leafblk : 0,
728 level + 1, &bp, args->whichfork);
729 if (error)
730 return error;
731
732 node = bp->b_addr;
733 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
734 btree = nodehdr.btree;
735 btree[0].hashval = cpu_to_be32(blk1->hashval);
736 btree[0].before = cpu_to_be32(blk1->blkno);
737 btree[1].hashval = cpu_to_be32(blk2->hashval);
738 btree[1].before = cpu_to_be32(blk2->blkno);
739 nodehdr.count = 2;
740 xfs_da3_node_hdr_to_disk(dp->i_mount, node, &nodehdr);
741
742 #ifdef DEBUG
743 if (oldroot->hdr.info.magic == cpu_to_be16(XFS_DIR2_LEAFN_MAGIC) ||
744 oldroot->hdr.info.magic == cpu_to_be16(XFS_DIR3_LEAFN_MAGIC)) {
745 ASSERT(blk1->blkno >= args->geo->leafblk &&
746 blk1->blkno < args->geo->freeblk);
747 ASSERT(blk2->blkno >= args->geo->leafblk &&
748 blk2->blkno < args->geo->freeblk);
749 }
750 #endif
751
752 /* Header is already logged by xfs_da_node_create */
753 xfs_trans_log_buf(tp, bp,
754 XFS_DA_LOGRANGE(node, btree, sizeof(xfs_da_node_entry_t) * 2));
755
756 return 0;
757 }
758
759 /*
760 * Split the node, rebalance, then add the new entry.
761 */
762 STATIC int /* error */
xfs_da3_node_split(struct xfs_da_state * state,struct xfs_da_state_blk * oldblk,struct xfs_da_state_blk * newblk,struct xfs_da_state_blk * addblk,int treelevel,int * result)763 xfs_da3_node_split(
764 struct xfs_da_state *state,
765 struct xfs_da_state_blk *oldblk,
766 struct xfs_da_state_blk *newblk,
767 struct xfs_da_state_blk *addblk,
768 int treelevel,
769 int *result)
770 {
771 struct xfs_da_intnode *node;
772 struct xfs_da3_icnode_hdr nodehdr;
773 xfs_dablk_t blkno;
774 int newcount;
775 int error;
776 int useextra;
777 struct xfs_inode *dp = state->args->dp;
778
779 trace_xfs_da_node_split(state->args);
780
781 node = oldblk->bp->b_addr;
782 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
783
784 /*
785 * With V2 dirs the extra block is data or freespace.
786 */
787 useextra = state->extravalid && state->args->whichfork == XFS_ATTR_FORK;
788 newcount = 1 + useextra;
789 /*
790 * Do we have to split the node?
791 */
792 if (nodehdr.count + newcount > state->args->geo->node_ents) {
793 /*
794 * Allocate a new node, add to the doubly linked chain of
795 * nodes, then move some of our excess entries into it.
796 */
797 error = xfs_da_grow_inode(state->args, &blkno);
798 if (error)
799 return error; /* GROT: dir is inconsistent */
800
801 error = xfs_da3_node_create(state->args, blkno, treelevel,
802 &newblk->bp, state->args->whichfork);
803 if (error)
804 return error; /* GROT: dir is inconsistent */
805 newblk->blkno = blkno;
806 newblk->magic = XFS_DA_NODE_MAGIC;
807 xfs_da3_node_rebalance(state, oldblk, newblk);
808 error = xfs_da3_blk_link(state, oldblk, newblk);
809 if (error)
810 return error;
811 *result = 1;
812 } else {
813 *result = 0;
814 }
815
816 /*
817 * Insert the new entry(s) into the correct block
818 * (updating last hashval in the process).
819 *
820 * xfs_da3_node_add() inserts BEFORE the given index,
821 * and as a result of using node_lookup_int() we always
822 * point to a valid entry (not after one), but a split
823 * operation always results in a new block whose hashvals
824 * FOLLOW the current block.
825 *
826 * If we had double-split op below us, then add the extra block too.
827 */
828 node = oldblk->bp->b_addr;
829 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
830 if (oldblk->index <= nodehdr.count) {
831 oldblk->index++;
832 xfs_da3_node_add(state, oldblk, addblk);
833 if (useextra) {
834 if (state->extraafter)
835 oldblk->index++;
836 xfs_da3_node_add(state, oldblk, &state->extrablk);
837 state->extravalid = 0;
838 }
839 } else {
840 newblk->index++;
841 xfs_da3_node_add(state, newblk, addblk);
842 if (useextra) {
843 if (state->extraafter)
844 newblk->index++;
845 xfs_da3_node_add(state, newblk, &state->extrablk);
846 state->extravalid = 0;
847 }
848 }
849
850 return 0;
851 }
852
853 /*
854 * Balance the btree elements between two intermediate nodes,
855 * usually one full and one empty.
856 *
857 * NOTE: if blk2 is empty, then it will get the upper half of blk1.
858 */
859 STATIC void
xfs_da3_node_rebalance(struct xfs_da_state * state,struct xfs_da_state_blk * blk1,struct xfs_da_state_blk * blk2)860 xfs_da3_node_rebalance(
861 struct xfs_da_state *state,
862 struct xfs_da_state_blk *blk1,
863 struct xfs_da_state_blk *blk2)
864 {
865 struct xfs_da_intnode *node1;
866 struct xfs_da_intnode *node2;
867 struct xfs_da_node_entry *btree1;
868 struct xfs_da_node_entry *btree2;
869 struct xfs_da_node_entry *btree_s;
870 struct xfs_da_node_entry *btree_d;
871 struct xfs_da3_icnode_hdr nodehdr1;
872 struct xfs_da3_icnode_hdr nodehdr2;
873 struct xfs_trans *tp;
874 int count;
875 int tmp;
876 int swap = 0;
877 struct xfs_inode *dp = state->args->dp;
878
879 trace_xfs_da_node_rebalance(state->args);
880
881 node1 = blk1->bp->b_addr;
882 node2 = blk2->bp->b_addr;
883 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr1, node1);
884 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr2, node2);
885 btree1 = nodehdr1.btree;
886 btree2 = nodehdr2.btree;
887
888 /*
889 * Figure out how many entries need to move, and in which direction.
890 * Swap the nodes around if that makes it simpler.
891 */
892 if (nodehdr1.count > 0 && nodehdr2.count > 0 &&
893 ((be32_to_cpu(btree2[0].hashval) < be32_to_cpu(btree1[0].hashval)) ||
894 (be32_to_cpu(btree2[nodehdr2.count - 1].hashval) <
895 be32_to_cpu(btree1[nodehdr1.count - 1].hashval)))) {
896 swap(node1, node2);
897 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr1, node1);
898 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr2, node2);
899 btree1 = nodehdr1.btree;
900 btree2 = nodehdr2.btree;
901 swap = 1;
902 }
903
904 count = (nodehdr1.count - nodehdr2.count) / 2;
905 if (count == 0)
906 return;
907 tp = state->args->trans;
908 /*
909 * Two cases: high-to-low and low-to-high.
910 */
911 if (count > 0) {
912 /*
913 * Move elements in node2 up to make a hole.
914 */
915 tmp = nodehdr2.count;
916 if (tmp > 0) {
917 tmp *= (uint)sizeof(xfs_da_node_entry_t);
918 btree_s = &btree2[0];
919 btree_d = &btree2[count];
920 memmove(btree_d, btree_s, tmp);
921 }
922
923 /*
924 * Move the req'd B-tree elements from high in node1 to
925 * low in node2.
926 */
927 nodehdr2.count += count;
928 tmp = count * (uint)sizeof(xfs_da_node_entry_t);
929 btree_s = &btree1[nodehdr1.count - count];
930 btree_d = &btree2[0];
931 memcpy(btree_d, btree_s, tmp);
932 nodehdr1.count -= count;
933 } else {
934 /*
935 * Move the req'd B-tree elements from low in node2 to
936 * high in node1.
937 */
938 count = -count;
939 tmp = count * (uint)sizeof(xfs_da_node_entry_t);
940 btree_s = &btree2[0];
941 btree_d = &btree1[nodehdr1.count];
942 memcpy(btree_d, btree_s, tmp);
943 nodehdr1.count += count;
944
945 xfs_trans_log_buf(tp, blk1->bp,
946 XFS_DA_LOGRANGE(node1, btree_d, tmp));
947
948 /*
949 * Move elements in node2 down to fill the hole.
950 */
951 tmp = nodehdr2.count - count;
952 tmp *= (uint)sizeof(xfs_da_node_entry_t);
953 btree_s = &btree2[count];
954 btree_d = &btree2[0];
955 memmove(btree_d, btree_s, tmp);
956 nodehdr2.count -= count;
957 }
958
959 /*
960 * Log header of node 1 and all current bits of node 2.
961 */
962 xfs_da3_node_hdr_to_disk(dp->i_mount, node1, &nodehdr1);
963 xfs_trans_log_buf(tp, blk1->bp,
964 XFS_DA_LOGRANGE(node1, &node1->hdr,
965 state->args->geo->node_hdr_size));
966
967 xfs_da3_node_hdr_to_disk(dp->i_mount, node2, &nodehdr2);
968 xfs_trans_log_buf(tp, blk2->bp,
969 XFS_DA_LOGRANGE(node2, &node2->hdr,
970 state->args->geo->node_hdr_size +
971 (sizeof(btree2[0]) * nodehdr2.count)));
972
973 /*
974 * Record the last hashval from each block for upward propagation.
975 * (note: don't use the swapped node pointers)
976 */
977 if (swap) {
978 node1 = blk1->bp->b_addr;
979 node2 = blk2->bp->b_addr;
980 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr1, node1);
981 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr2, node2);
982 btree1 = nodehdr1.btree;
983 btree2 = nodehdr2.btree;
984 }
985 blk1->hashval = be32_to_cpu(btree1[nodehdr1.count - 1].hashval);
986 blk2->hashval = be32_to_cpu(btree2[nodehdr2.count - 1].hashval);
987
988 /*
989 * Adjust the expected index for insertion.
990 */
991 if (blk1->index >= nodehdr1.count) {
992 blk2->index = blk1->index - nodehdr1.count;
993 blk1->index = nodehdr1.count + 1; /* make it invalid */
994 }
995 }
996
997 /*
998 * Add a new entry to an intermediate node.
999 */
1000 STATIC void
xfs_da3_node_add(struct xfs_da_state * state,struct xfs_da_state_blk * oldblk,struct xfs_da_state_blk * newblk)1001 xfs_da3_node_add(
1002 struct xfs_da_state *state,
1003 struct xfs_da_state_blk *oldblk,
1004 struct xfs_da_state_blk *newblk)
1005 {
1006 struct xfs_da_intnode *node;
1007 struct xfs_da3_icnode_hdr nodehdr;
1008 struct xfs_da_node_entry *btree;
1009 int tmp;
1010 struct xfs_inode *dp = state->args->dp;
1011
1012 trace_xfs_da_node_add(state->args);
1013
1014 node = oldblk->bp->b_addr;
1015 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
1016 btree = nodehdr.btree;
1017
1018 ASSERT(oldblk->index >= 0 && oldblk->index <= nodehdr.count);
1019 ASSERT(newblk->blkno != 0);
1020 if (state->args->whichfork == XFS_DATA_FORK)
1021 ASSERT(newblk->blkno >= state->args->geo->leafblk &&
1022 newblk->blkno < state->args->geo->freeblk);
1023
1024 /*
1025 * We may need to make some room before we insert the new node.
1026 */
1027 tmp = 0;
1028 if (oldblk->index < nodehdr.count) {
1029 tmp = (nodehdr.count - oldblk->index) * (uint)sizeof(*btree);
1030 memmove(&btree[oldblk->index + 1], &btree[oldblk->index], tmp);
1031 }
1032 btree[oldblk->index].hashval = cpu_to_be32(newblk->hashval);
1033 btree[oldblk->index].before = cpu_to_be32(newblk->blkno);
1034 xfs_trans_log_buf(state->args->trans, oldblk->bp,
1035 XFS_DA_LOGRANGE(node, &btree[oldblk->index],
1036 tmp + sizeof(*btree)));
1037
1038 nodehdr.count += 1;
1039 xfs_da3_node_hdr_to_disk(dp->i_mount, node, &nodehdr);
1040 xfs_trans_log_buf(state->args->trans, oldblk->bp,
1041 XFS_DA_LOGRANGE(node, &node->hdr,
1042 state->args->geo->node_hdr_size));
1043
1044 /*
1045 * Copy the last hash value from the oldblk to propagate upwards.
1046 */
1047 oldblk->hashval = be32_to_cpu(btree[nodehdr.count - 1].hashval);
1048 }
1049
1050 /*========================================================================
1051 * Routines used for shrinking the Btree.
1052 *========================================================================*/
1053
1054 /*
1055 * Deallocate an empty leaf node, remove it from its parent,
1056 * possibly deallocating that block, etc...
1057 */
1058 int
xfs_da3_join(struct xfs_da_state * state)1059 xfs_da3_join(
1060 struct xfs_da_state *state)
1061 {
1062 struct xfs_da_state_blk *drop_blk;
1063 struct xfs_da_state_blk *save_blk;
1064 int action = 0;
1065 int error;
1066
1067 trace_xfs_da_join(state->args);
1068
1069 drop_blk = &state->path.blk[ state->path.active-1 ];
1070 save_blk = &state->altpath.blk[ state->path.active-1 ];
1071 ASSERT(state->path.blk[0].magic == XFS_DA_NODE_MAGIC);
1072 ASSERT(drop_blk->magic == XFS_ATTR_LEAF_MAGIC ||
1073 drop_blk->magic == XFS_DIR2_LEAFN_MAGIC);
1074
1075 /*
1076 * Walk back up the tree joining/deallocating as necessary.
1077 * When we stop dropping blocks, break out.
1078 */
1079 for ( ; state->path.active >= 2; drop_blk--, save_blk--,
1080 state->path.active--) {
1081 /*
1082 * See if we can combine the block with a neighbor.
1083 * (action == 0) => no options, just leave
1084 * (action == 1) => coalesce, then unlink
1085 * (action == 2) => block empty, unlink it
1086 */
1087 switch (drop_blk->magic) {
1088 case XFS_ATTR_LEAF_MAGIC:
1089 error = xfs_attr3_leaf_toosmall(state, &action);
1090 if (error)
1091 return error;
1092 if (action == 0)
1093 return 0;
1094 xfs_attr3_leaf_unbalance(state, drop_blk, save_blk);
1095 break;
1096 case XFS_DIR2_LEAFN_MAGIC:
1097 error = xfs_dir2_leafn_toosmall(state, &action);
1098 if (error)
1099 return error;
1100 if (action == 0)
1101 return 0;
1102 xfs_dir2_leafn_unbalance(state, drop_blk, save_blk);
1103 break;
1104 case XFS_DA_NODE_MAGIC:
1105 /*
1106 * Remove the offending node, fixup hashvals,
1107 * check for a toosmall neighbor.
1108 */
1109 xfs_da3_node_remove(state, drop_blk);
1110 xfs_da3_fixhashpath(state, &state->path);
1111 error = xfs_da3_node_toosmall(state, &action);
1112 if (error)
1113 return error;
1114 if (action == 0)
1115 return 0;
1116 xfs_da3_node_unbalance(state, drop_blk, save_blk);
1117 break;
1118 }
1119 xfs_da3_fixhashpath(state, &state->altpath);
1120 error = xfs_da3_blk_unlink(state, drop_blk, save_blk);
1121 xfs_da_state_kill_altpath(state);
1122 if (error)
1123 return error;
1124 error = xfs_da_shrink_inode(state->args, drop_blk->blkno,
1125 drop_blk->bp);
1126 drop_blk->bp = NULL;
1127 if (error)
1128 return error;
1129 }
1130 /*
1131 * We joined all the way to the top. If it turns out that
1132 * we only have one entry in the root, make the child block
1133 * the new root.
1134 */
1135 xfs_da3_node_remove(state, drop_blk);
1136 xfs_da3_fixhashpath(state, &state->path);
1137 error = xfs_da3_root_join(state, &state->path.blk[0]);
1138 return error;
1139 }
1140
1141 #ifdef DEBUG
1142 static void
xfs_da_blkinfo_onlychild_validate(struct xfs_da_blkinfo * blkinfo,__u16 level)1143 xfs_da_blkinfo_onlychild_validate(struct xfs_da_blkinfo *blkinfo, __u16 level)
1144 {
1145 __be16 magic = blkinfo->magic;
1146
1147 if (level == 1) {
1148 ASSERT(magic == cpu_to_be16(XFS_DIR2_LEAFN_MAGIC) ||
1149 magic == cpu_to_be16(XFS_DIR3_LEAFN_MAGIC) ||
1150 magic == cpu_to_be16(XFS_ATTR_LEAF_MAGIC) ||
1151 magic == cpu_to_be16(XFS_ATTR3_LEAF_MAGIC));
1152 } else {
1153 ASSERT(magic == cpu_to_be16(XFS_DA_NODE_MAGIC) ||
1154 magic == cpu_to_be16(XFS_DA3_NODE_MAGIC));
1155 }
1156 ASSERT(!blkinfo->forw);
1157 ASSERT(!blkinfo->back);
1158 }
1159 #else /* !DEBUG */
1160 #define xfs_da_blkinfo_onlychild_validate(blkinfo, level)
1161 #endif /* !DEBUG */
1162
1163 /*
1164 * We have only one entry in the root. Copy the only remaining child of
1165 * the old root to block 0 as the new root node.
1166 */
1167 STATIC int
xfs_da3_root_join(struct xfs_da_state * state,struct xfs_da_state_blk * root_blk)1168 xfs_da3_root_join(
1169 struct xfs_da_state *state,
1170 struct xfs_da_state_blk *root_blk)
1171 {
1172 struct xfs_da_intnode *oldroot;
1173 struct xfs_da_args *args;
1174 xfs_dablk_t child;
1175 struct xfs_buf *bp;
1176 struct xfs_da3_icnode_hdr oldroothdr;
1177 int error;
1178 struct xfs_inode *dp = state->args->dp;
1179
1180 trace_xfs_da_root_join(state->args);
1181
1182 ASSERT(root_blk->magic == XFS_DA_NODE_MAGIC);
1183
1184 args = state->args;
1185 oldroot = root_blk->bp->b_addr;
1186 xfs_da3_node_hdr_from_disk(dp->i_mount, &oldroothdr, oldroot);
1187 ASSERT(oldroothdr.forw == 0);
1188 ASSERT(oldroothdr.back == 0);
1189
1190 /*
1191 * If the root has more than one child, then don't do anything.
1192 */
1193 if (oldroothdr.count > 1)
1194 return 0;
1195
1196 /*
1197 * Read in the (only) child block, then copy those bytes into
1198 * the root block's buffer and free the original child block.
1199 */
1200 child = be32_to_cpu(oldroothdr.btree[0].before);
1201 ASSERT(child != 0);
1202 error = xfs_da3_node_read(args->trans, dp, child, &bp, args->whichfork);
1203 if (error)
1204 return error;
1205 xfs_da_blkinfo_onlychild_validate(bp->b_addr, oldroothdr.level);
1206
1207 /*
1208 * This could be copying a leaf back into the root block in the case of
1209 * there only being a single leaf block left in the tree. Hence we have
1210 * to update the b_ops pointer as well to match the buffer type change
1211 * that could occur. For dir3 blocks we also need to update the block
1212 * number in the buffer header.
1213 */
1214 memcpy(root_blk->bp->b_addr, bp->b_addr, args->geo->blksize);
1215 root_blk->bp->b_ops = bp->b_ops;
1216 xfs_trans_buf_copy_type(root_blk->bp, bp);
1217 if (oldroothdr.magic == XFS_DA3_NODE_MAGIC) {
1218 struct xfs_da3_blkinfo *da3 = root_blk->bp->b_addr;
1219 da3->blkno = cpu_to_be64(xfs_buf_daddr(root_blk->bp));
1220 }
1221 xfs_trans_log_buf(args->trans, root_blk->bp, 0,
1222 args->geo->blksize - 1);
1223 error = xfs_da_shrink_inode(args, child, bp);
1224 return error;
1225 }
1226
1227 /*
1228 * Check a node block and its neighbors to see if the block should be
1229 * collapsed into one or the other neighbor. Always keep the block
1230 * with the smaller block number.
1231 * If the current block is over 50% full, don't try to join it, return 0.
1232 * If the block is empty, fill in the state structure and return 2.
1233 * If it can be collapsed, fill in the state structure and return 1.
1234 * If nothing can be done, return 0.
1235 */
1236 STATIC int
xfs_da3_node_toosmall(struct xfs_da_state * state,int * action)1237 xfs_da3_node_toosmall(
1238 struct xfs_da_state *state,
1239 int *action)
1240 {
1241 struct xfs_da_intnode *node;
1242 struct xfs_da_state_blk *blk;
1243 struct xfs_da_blkinfo *info;
1244 xfs_dablk_t blkno;
1245 struct xfs_buf *bp;
1246 struct xfs_da3_icnode_hdr nodehdr;
1247 int count;
1248 int forward;
1249 int error;
1250 int retval;
1251 int i;
1252 struct xfs_inode *dp = state->args->dp;
1253
1254 trace_xfs_da_node_toosmall(state->args);
1255
1256 /*
1257 * Check for the degenerate case of the block being over 50% full.
1258 * If so, it's not worth even looking to see if we might be able
1259 * to coalesce with a sibling.
1260 */
1261 blk = &state->path.blk[ state->path.active-1 ];
1262 info = blk->bp->b_addr;
1263 node = (xfs_da_intnode_t *)info;
1264 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
1265 if (nodehdr.count > (state->args->geo->node_ents >> 1)) {
1266 *action = 0; /* blk over 50%, don't try to join */
1267 return 0; /* blk over 50%, don't try to join */
1268 }
1269
1270 /*
1271 * Check for the degenerate case of the block being empty.
1272 * If the block is empty, we'll simply delete it, no need to
1273 * coalesce it with a sibling block. We choose (arbitrarily)
1274 * to merge with the forward block unless it is NULL.
1275 */
1276 if (nodehdr.count == 0) {
1277 /*
1278 * Make altpath point to the block we want to keep and
1279 * path point to the block we want to drop (this one).
1280 */
1281 forward = (info->forw != 0);
1282 memcpy(&state->altpath, &state->path, sizeof(state->path));
1283 error = xfs_da3_path_shift(state, &state->altpath, forward,
1284 0, &retval);
1285 if (error)
1286 return error;
1287 if (retval) {
1288 *action = 0;
1289 } else {
1290 *action = 2;
1291 }
1292 return 0;
1293 }
1294
1295 /*
1296 * Examine each sibling block to see if we can coalesce with
1297 * at least 25% free space to spare. We need to figure out
1298 * whether to merge with the forward or the backward block.
1299 * We prefer coalescing with the lower numbered sibling so as
1300 * to shrink a directory over time.
1301 */
1302 count = state->args->geo->node_ents;
1303 count -= state->args->geo->node_ents >> 2;
1304 count -= nodehdr.count;
1305
1306 /* start with smaller blk num */
1307 forward = nodehdr.forw < nodehdr.back;
1308 for (i = 0; i < 2; forward = !forward, i++) {
1309 struct xfs_da3_icnode_hdr thdr;
1310 if (forward)
1311 blkno = nodehdr.forw;
1312 else
1313 blkno = nodehdr.back;
1314 if (blkno == 0)
1315 continue;
1316 error = xfs_da3_node_read(state->args->trans, dp, blkno, &bp,
1317 state->args->whichfork);
1318 if (error)
1319 return error;
1320
1321 node = bp->b_addr;
1322 xfs_da3_node_hdr_from_disk(dp->i_mount, &thdr, node);
1323 xfs_trans_brelse(state->args->trans, bp);
1324
1325 if (count - thdr.count >= 0)
1326 break; /* fits with at least 25% to spare */
1327 }
1328 if (i >= 2) {
1329 *action = 0;
1330 return 0;
1331 }
1332
1333 /*
1334 * Make altpath point to the block we want to keep (the lower
1335 * numbered block) and path point to the block we want to drop.
1336 */
1337 memcpy(&state->altpath, &state->path, sizeof(state->path));
1338 if (blkno < blk->blkno) {
1339 error = xfs_da3_path_shift(state, &state->altpath, forward,
1340 0, &retval);
1341 } else {
1342 error = xfs_da3_path_shift(state, &state->path, forward,
1343 0, &retval);
1344 }
1345 if (error)
1346 return error;
1347 if (retval) {
1348 *action = 0;
1349 return 0;
1350 }
1351 *action = 1;
1352 return 0;
1353 }
1354
1355 /*
1356 * Pick up the last hashvalue from an intermediate node.
1357 */
1358 STATIC uint
xfs_da3_node_lasthash(struct xfs_inode * dp,struct xfs_buf * bp,int * count)1359 xfs_da3_node_lasthash(
1360 struct xfs_inode *dp,
1361 struct xfs_buf *bp,
1362 int *count)
1363 {
1364 struct xfs_da3_icnode_hdr nodehdr;
1365
1366 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, bp->b_addr);
1367 if (count)
1368 *count = nodehdr.count;
1369 if (!nodehdr.count)
1370 return 0;
1371 return be32_to_cpu(nodehdr.btree[nodehdr.count - 1].hashval);
1372 }
1373
1374 /*
1375 * Walk back up the tree adjusting hash values as necessary,
1376 * when we stop making changes, return.
1377 */
1378 void
xfs_da3_fixhashpath(struct xfs_da_state * state,struct xfs_da_state_path * path)1379 xfs_da3_fixhashpath(
1380 struct xfs_da_state *state,
1381 struct xfs_da_state_path *path)
1382 {
1383 struct xfs_da_state_blk *blk;
1384 struct xfs_da_intnode *node;
1385 struct xfs_da_node_entry *btree;
1386 xfs_dahash_t lasthash=0;
1387 int level;
1388 int count;
1389 struct xfs_inode *dp = state->args->dp;
1390
1391 trace_xfs_da_fixhashpath(state->args);
1392
1393 level = path->active-1;
1394 blk = &path->blk[ level ];
1395 switch (blk->magic) {
1396 case XFS_ATTR_LEAF_MAGIC:
1397 lasthash = xfs_attr_leaf_lasthash(blk->bp, &count);
1398 if (count == 0)
1399 return;
1400 break;
1401 case XFS_DIR2_LEAFN_MAGIC:
1402 lasthash = xfs_dir2_leaf_lasthash(dp, blk->bp, &count);
1403 if (count == 0)
1404 return;
1405 break;
1406 case XFS_DA_NODE_MAGIC:
1407 lasthash = xfs_da3_node_lasthash(dp, blk->bp, &count);
1408 if (count == 0)
1409 return;
1410 break;
1411 }
1412 for (blk--, level--; level >= 0; blk--, level--) {
1413 struct xfs_da3_icnode_hdr nodehdr;
1414
1415 node = blk->bp->b_addr;
1416 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
1417 btree = nodehdr.btree;
1418 if (be32_to_cpu(btree[blk->index].hashval) == lasthash)
1419 break;
1420 blk->hashval = lasthash;
1421 btree[blk->index].hashval = cpu_to_be32(lasthash);
1422 xfs_trans_log_buf(state->args->trans, blk->bp,
1423 XFS_DA_LOGRANGE(node, &btree[blk->index],
1424 sizeof(*btree)));
1425
1426 lasthash = be32_to_cpu(btree[nodehdr.count - 1].hashval);
1427 }
1428 }
1429
1430 /*
1431 * Remove an entry from an intermediate node.
1432 */
1433 STATIC void
xfs_da3_node_remove(struct xfs_da_state * state,struct xfs_da_state_blk * drop_blk)1434 xfs_da3_node_remove(
1435 struct xfs_da_state *state,
1436 struct xfs_da_state_blk *drop_blk)
1437 {
1438 struct xfs_da_intnode *node;
1439 struct xfs_da3_icnode_hdr nodehdr;
1440 struct xfs_da_node_entry *btree;
1441 int index;
1442 int tmp;
1443 struct xfs_inode *dp = state->args->dp;
1444
1445 trace_xfs_da_node_remove(state->args);
1446
1447 node = drop_blk->bp->b_addr;
1448 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
1449 ASSERT(drop_blk->index < nodehdr.count);
1450 ASSERT(drop_blk->index >= 0);
1451
1452 /*
1453 * Copy over the offending entry, or just zero it out.
1454 */
1455 index = drop_blk->index;
1456 btree = nodehdr.btree;
1457 if (index < nodehdr.count - 1) {
1458 tmp = nodehdr.count - index - 1;
1459 tmp *= (uint)sizeof(xfs_da_node_entry_t);
1460 memmove(&btree[index], &btree[index + 1], tmp);
1461 xfs_trans_log_buf(state->args->trans, drop_blk->bp,
1462 XFS_DA_LOGRANGE(node, &btree[index], tmp));
1463 index = nodehdr.count - 1;
1464 }
1465 memset(&btree[index], 0, sizeof(xfs_da_node_entry_t));
1466 xfs_trans_log_buf(state->args->trans, drop_blk->bp,
1467 XFS_DA_LOGRANGE(node, &btree[index], sizeof(btree[index])));
1468 nodehdr.count -= 1;
1469 xfs_da3_node_hdr_to_disk(dp->i_mount, node, &nodehdr);
1470 xfs_trans_log_buf(state->args->trans, drop_blk->bp,
1471 XFS_DA_LOGRANGE(node, &node->hdr, state->args->geo->node_hdr_size));
1472
1473 /*
1474 * Copy the last hash value from the block to propagate upwards.
1475 */
1476 drop_blk->hashval = be32_to_cpu(btree[index - 1].hashval);
1477 }
1478
1479 /*
1480 * Unbalance the elements between two intermediate nodes,
1481 * move all Btree elements from one node into another.
1482 */
1483 STATIC void
xfs_da3_node_unbalance(struct xfs_da_state * state,struct xfs_da_state_blk * drop_blk,struct xfs_da_state_blk * save_blk)1484 xfs_da3_node_unbalance(
1485 struct xfs_da_state *state,
1486 struct xfs_da_state_blk *drop_blk,
1487 struct xfs_da_state_blk *save_blk)
1488 {
1489 struct xfs_da_intnode *drop_node;
1490 struct xfs_da_intnode *save_node;
1491 struct xfs_da_node_entry *drop_btree;
1492 struct xfs_da_node_entry *save_btree;
1493 struct xfs_da3_icnode_hdr drop_hdr;
1494 struct xfs_da3_icnode_hdr save_hdr;
1495 struct xfs_trans *tp;
1496 int sindex;
1497 int tmp;
1498 struct xfs_inode *dp = state->args->dp;
1499
1500 trace_xfs_da_node_unbalance(state->args);
1501
1502 drop_node = drop_blk->bp->b_addr;
1503 save_node = save_blk->bp->b_addr;
1504 xfs_da3_node_hdr_from_disk(dp->i_mount, &drop_hdr, drop_node);
1505 xfs_da3_node_hdr_from_disk(dp->i_mount, &save_hdr, save_node);
1506 drop_btree = drop_hdr.btree;
1507 save_btree = save_hdr.btree;
1508 tp = state->args->trans;
1509
1510 /*
1511 * If the dying block has lower hashvals, then move all the
1512 * elements in the remaining block up to make a hole.
1513 */
1514 if ((be32_to_cpu(drop_btree[0].hashval) <
1515 be32_to_cpu(save_btree[0].hashval)) ||
1516 (be32_to_cpu(drop_btree[drop_hdr.count - 1].hashval) <
1517 be32_to_cpu(save_btree[save_hdr.count - 1].hashval))) {
1518 /* XXX: check this - is memmove dst correct? */
1519 tmp = save_hdr.count * sizeof(xfs_da_node_entry_t);
1520 memmove(&save_btree[drop_hdr.count], &save_btree[0], tmp);
1521
1522 sindex = 0;
1523 xfs_trans_log_buf(tp, save_blk->bp,
1524 XFS_DA_LOGRANGE(save_node, &save_btree[0],
1525 (save_hdr.count + drop_hdr.count) *
1526 sizeof(xfs_da_node_entry_t)));
1527 } else {
1528 sindex = save_hdr.count;
1529 xfs_trans_log_buf(tp, save_blk->bp,
1530 XFS_DA_LOGRANGE(save_node, &save_btree[sindex],
1531 drop_hdr.count * sizeof(xfs_da_node_entry_t)));
1532 }
1533
1534 /*
1535 * Move all the B-tree elements from drop_blk to save_blk.
1536 */
1537 tmp = drop_hdr.count * (uint)sizeof(xfs_da_node_entry_t);
1538 memcpy(&save_btree[sindex], &drop_btree[0], tmp);
1539 save_hdr.count += drop_hdr.count;
1540
1541 xfs_da3_node_hdr_to_disk(dp->i_mount, save_node, &save_hdr);
1542 xfs_trans_log_buf(tp, save_blk->bp,
1543 XFS_DA_LOGRANGE(save_node, &save_node->hdr,
1544 state->args->geo->node_hdr_size));
1545
1546 /*
1547 * Save the last hashval in the remaining block for upward propagation.
1548 */
1549 save_blk->hashval = be32_to_cpu(save_btree[save_hdr.count - 1].hashval);
1550 }
1551
1552 /*========================================================================
1553 * Routines used for finding things in the Btree.
1554 *========================================================================*/
1555
1556 /*
1557 * Walk down the Btree looking for a particular filename, filling
1558 * in the state structure as we go.
1559 *
1560 * We will set the state structure to point to each of the elements
1561 * in each of the nodes where either the hashval is or should be.
1562 *
1563 * We support duplicate hashval's so for each entry in the current
1564 * node that could contain the desired hashval, descend. This is a
1565 * pruned depth-first tree search.
1566 */
1567 int /* error */
xfs_da3_node_lookup_int(struct xfs_da_state * state,int * result)1568 xfs_da3_node_lookup_int(
1569 struct xfs_da_state *state,
1570 int *result)
1571 {
1572 struct xfs_da_state_blk *blk;
1573 struct xfs_da_blkinfo *curr;
1574 struct xfs_da_intnode *node;
1575 struct xfs_da_node_entry *btree;
1576 struct xfs_da3_icnode_hdr nodehdr;
1577 struct xfs_da_args *args;
1578 xfs_dablk_t blkno;
1579 xfs_dahash_t hashval;
1580 xfs_dahash_t btreehashval;
1581 int probe;
1582 int span;
1583 int max;
1584 int error;
1585 int retval;
1586 unsigned int expected_level = 0;
1587 uint16_t magic;
1588 struct xfs_inode *dp = state->args->dp;
1589
1590 args = state->args;
1591
1592 /*
1593 * Descend thru the B-tree searching each level for the right
1594 * node to use, until the right hashval is found.
1595 */
1596 blkno = args->geo->leafblk;
1597 for (blk = &state->path.blk[0], state->path.active = 1;
1598 state->path.active <= XFS_DA_NODE_MAXDEPTH;
1599 blk++, state->path.active++) {
1600 /*
1601 * Read the next node down in the tree.
1602 */
1603 blk->blkno = blkno;
1604 error = xfs_da3_node_read(args->trans, args->dp, blkno,
1605 &blk->bp, args->whichfork);
1606 if (error) {
1607 blk->blkno = 0;
1608 state->path.active--;
1609 return error;
1610 }
1611 curr = blk->bp->b_addr;
1612 magic = be16_to_cpu(curr->magic);
1613
1614 if (magic == XFS_ATTR_LEAF_MAGIC ||
1615 magic == XFS_ATTR3_LEAF_MAGIC) {
1616 blk->magic = XFS_ATTR_LEAF_MAGIC;
1617 blk->hashval = xfs_attr_leaf_lasthash(blk->bp, NULL);
1618 break;
1619 }
1620
1621 if (magic == XFS_DIR2_LEAFN_MAGIC ||
1622 magic == XFS_DIR3_LEAFN_MAGIC) {
1623 blk->magic = XFS_DIR2_LEAFN_MAGIC;
1624 blk->hashval = xfs_dir2_leaf_lasthash(args->dp,
1625 blk->bp, NULL);
1626 break;
1627 }
1628
1629 if (magic != XFS_DA_NODE_MAGIC && magic != XFS_DA3_NODE_MAGIC) {
1630 xfs_buf_mark_corrupt(blk->bp);
1631 return -EFSCORRUPTED;
1632 }
1633
1634 blk->magic = XFS_DA_NODE_MAGIC;
1635
1636 /*
1637 * Search an intermediate node for a match.
1638 */
1639 node = blk->bp->b_addr;
1640 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr, node);
1641 btree = nodehdr.btree;
1642
1643 /* Tree taller than we can handle; bail out! */
1644 if (nodehdr.level >= XFS_DA_NODE_MAXDEPTH) {
1645 xfs_buf_mark_corrupt(blk->bp);
1646 return -EFSCORRUPTED;
1647 }
1648
1649 /* Check the level from the root. */
1650 if (blkno == args->geo->leafblk)
1651 expected_level = nodehdr.level - 1;
1652 else if (expected_level != nodehdr.level) {
1653 xfs_buf_mark_corrupt(blk->bp);
1654 return -EFSCORRUPTED;
1655 } else
1656 expected_level--;
1657
1658 max = nodehdr.count;
1659 blk->hashval = be32_to_cpu(btree[max - 1].hashval);
1660
1661 /*
1662 * Binary search. (note: small blocks will skip loop)
1663 */
1664 probe = span = max / 2;
1665 hashval = args->hashval;
1666 while (span > 4) {
1667 span /= 2;
1668 btreehashval = be32_to_cpu(btree[probe].hashval);
1669 if (btreehashval < hashval)
1670 probe += span;
1671 else if (btreehashval > hashval)
1672 probe -= span;
1673 else
1674 break;
1675 }
1676 ASSERT((probe >= 0) && (probe < max));
1677 ASSERT((span <= 4) ||
1678 (be32_to_cpu(btree[probe].hashval) == hashval));
1679
1680 /*
1681 * Since we may have duplicate hashval's, find the first
1682 * matching hashval in the node.
1683 */
1684 while (probe > 0 &&
1685 be32_to_cpu(btree[probe].hashval) >= hashval) {
1686 probe--;
1687 }
1688 while (probe < max &&
1689 be32_to_cpu(btree[probe].hashval) < hashval) {
1690 probe++;
1691 }
1692
1693 /*
1694 * Pick the right block to descend on.
1695 */
1696 if (probe == max) {
1697 blk->index = max - 1;
1698 blkno = be32_to_cpu(btree[max - 1].before);
1699 } else {
1700 blk->index = probe;
1701 blkno = be32_to_cpu(btree[probe].before);
1702 }
1703
1704 /* We can't point back to the root. */
1705 if (XFS_IS_CORRUPT(dp->i_mount, blkno == args->geo->leafblk))
1706 return -EFSCORRUPTED;
1707 }
1708
1709 if (XFS_IS_CORRUPT(dp->i_mount, expected_level != 0))
1710 return -EFSCORRUPTED;
1711
1712 /*
1713 * A leaf block that ends in the hashval that we are interested in
1714 * (final hashval == search hashval) means that the next block may
1715 * contain more entries with the same hashval, shift upward to the
1716 * next leaf and keep searching.
1717 */
1718 for (;;) {
1719 if (blk->magic == XFS_DIR2_LEAFN_MAGIC) {
1720 retval = xfs_dir2_leafn_lookup_int(blk->bp, args,
1721 &blk->index, state);
1722 } else if (blk->magic == XFS_ATTR_LEAF_MAGIC) {
1723 retval = xfs_attr3_leaf_lookup_int(blk->bp, args);
1724 blk->index = args->index;
1725 args->blkno = blk->blkno;
1726 } else {
1727 ASSERT(0);
1728 return -EFSCORRUPTED;
1729 }
1730 if (((retval == -ENOENT) || (retval == -ENOATTR)) &&
1731 (blk->hashval == args->hashval)) {
1732 error = xfs_da3_path_shift(state, &state->path, 1, 1,
1733 &retval);
1734 if (error)
1735 return error;
1736 if (retval == 0) {
1737 continue;
1738 } else if (blk->magic == XFS_ATTR_LEAF_MAGIC) {
1739 /* path_shift() gives ENOENT */
1740 retval = -ENOATTR;
1741 }
1742 }
1743 break;
1744 }
1745 *result = retval;
1746 return 0;
1747 }
1748
1749 /*========================================================================
1750 * Utility routines.
1751 *========================================================================*/
1752
1753 /*
1754 * Compare two intermediate nodes for "order".
1755 */
1756 STATIC int
xfs_da3_node_order(struct xfs_inode * dp,struct xfs_buf * node1_bp,struct xfs_buf * node2_bp)1757 xfs_da3_node_order(
1758 struct xfs_inode *dp,
1759 struct xfs_buf *node1_bp,
1760 struct xfs_buf *node2_bp)
1761 {
1762 struct xfs_da_intnode *node1;
1763 struct xfs_da_intnode *node2;
1764 struct xfs_da_node_entry *btree1;
1765 struct xfs_da_node_entry *btree2;
1766 struct xfs_da3_icnode_hdr node1hdr;
1767 struct xfs_da3_icnode_hdr node2hdr;
1768
1769 node1 = node1_bp->b_addr;
1770 node2 = node2_bp->b_addr;
1771 xfs_da3_node_hdr_from_disk(dp->i_mount, &node1hdr, node1);
1772 xfs_da3_node_hdr_from_disk(dp->i_mount, &node2hdr, node2);
1773 btree1 = node1hdr.btree;
1774 btree2 = node2hdr.btree;
1775
1776 if (node1hdr.count > 0 && node2hdr.count > 0 &&
1777 ((be32_to_cpu(btree2[0].hashval) < be32_to_cpu(btree1[0].hashval)) ||
1778 (be32_to_cpu(btree2[node2hdr.count - 1].hashval) <
1779 be32_to_cpu(btree1[node1hdr.count - 1].hashval)))) {
1780 return 1;
1781 }
1782 return 0;
1783 }
1784
1785 /*
1786 * Link a new block into a doubly linked list of blocks (of whatever type).
1787 */
1788 int /* error */
xfs_da3_blk_link(struct xfs_da_state * state,struct xfs_da_state_blk * old_blk,struct xfs_da_state_blk * new_blk)1789 xfs_da3_blk_link(
1790 struct xfs_da_state *state,
1791 struct xfs_da_state_blk *old_blk,
1792 struct xfs_da_state_blk *new_blk)
1793 {
1794 struct xfs_da_blkinfo *old_info;
1795 struct xfs_da_blkinfo *new_info;
1796 struct xfs_da_blkinfo *tmp_info;
1797 struct xfs_da_args *args;
1798 struct xfs_buf *bp;
1799 int before = 0;
1800 int error;
1801 struct xfs_inode *dp = state->args->dp;
1802
1803 /*
1804 * Set up environment.
1805 */
1806 args = state->args;
1807 ASSERT(args != NULL);
1808 old_info = old_blk->bp->b_addr;
1809 new_info = new_blk->bp->b_addr;
1810 ASSERT(old_blk->magic == XFS_DA_NODE_MAGIC ||
1811 old_blk->magic == XFS_DIR2_LEAFN_MAGIC ||
1812 old_blk->magic == XFS_ATTR_LEAF_MAGIC);
1813
1814 switch (old_blk->magic) {
1815 case XFS_ATTR_LEAF_MAGIC:
1816 before = xfs_attr_leaf_order(old_blk->bp, new_blk->bp);
1817 break;
1818 case XFS_DIR2_LEAFN_MAGIC:
1819 before = xfs_dir2_leafn_order(dp, old_blk->bp, new_blk->bp);
1820 break;
1821 case XFS_DA_NODE_MAGIC:
1822 before = xfs_da3_node_order(dp, old_blk->bp, new_blk->bp);
1823 break;
1824 }
1825
1826 /*
1827 * Link blocks in appropriate order.
1828 */
1829 if (before) {
1830 /*
1831 * Link new block in before existing block.
1832 */
1833 trace_xfs_da_link_before(args);
1834 new_info->forw = cpu_to_be32(old_blk->blkno);
1835 new_info->back = old_info->back;
1836 if (old_info->back) {
1837 error = xfs_da3_node_read(args->trans, dp,
1838 be32_to_cpu(old_info->back),
1839 &bp, args->whichfork);
1840 if (error)
1841 return error;
1842 ASSERT(bp != NULL);
1843 tmp_info = bp->b_addr;
1844 ASSERT(tmp_info->magic == old_info->magic);
1845 ASSERT(be32_to_cpu(tmp_info->forw) == old_blk->blkno);
1846 tmp_info->forw = cpu_to_be32(new_blk->blkno);
1847 xfs_trans_log_buf(args->trans, bp, 0, sizeof(*tmp_info)-1);
1848 }
1849 old_info->back = cpu_to_be32(new_blk->blkno);
1850 } else {
1851 /*
1852 * Link new block in after existing block.
1853 */
1854 trace_xfs_da_link_after(args);
1855 new_info->forw = old_info->forw;
1856 new_info->back = cpu_to_be32(old_blk->blkno);
1857 if (old_info->forw) {
1858 error = xfs_da3_node_read(args->trans, dp,
1859 be32_to_cpu(old_info->forw),
1860 &bp, args->whichfork);
1861 if (error)
1862 return error;
1863 ASSERT(bp != NULL);
1864 tmp_info = bp->b_addr;
1865 ASSERT(tmp_info->magic == old_info->magic);
1866 ASSERT(be32_to_cpu(tmp_info->back) == old_blk->blkno);
1867 tmp_info->back = cpu_to_be32(new_blk->blkno);
1868 xfs_trans_log_buf(args->trans, bp, 0, sizeof(*tmp_info)-1);
1869 }
1870 old_info->forw = cpu_to_be32(new_blk->blkno);
1871 }
1872
1873 xfs_trans_log_buf(args->trans, old_blk->bp, 0, sizeof(*tmp_info) - 1);
1874 xfs_trans_log_buf(args->trans, new_blk->bp, 0, sizeof(*tmp_info) - 1);
1875 return 0;
1876 }
1877
1878 /*
1879 * Unlink a block from a doubly linked list of blocks.
1880 */
1881 STATIC int /* error */
xfs_da3_blk_unlink(struct xfs_da_state * state,struct xfs_da_state_blk * drop_blk,struct xfs_da_state_blk * save_blk)1882 xfs_da3_blk_unlink(
1883 struct xfs_da_state *state,
1884 struct xfs_da_state_blk *drop_blk,
1885 struct xfs_da_state_blk *save_blk)
1886 {
1887 struct xfs_da_blkinfo *drop_info;
1888 struct xfs_da_blkinfo *save_info;
1889 struct xfs_da_blkinfo *tmp_info;
1890 struct xfs_da_args *args;
1891 struct xfs_buf *bp;
1892 int error;
1893
1894 /*
1895 * Set up environment.
1896 */
1897 args = state->args;
1898 ASSERT(args != NULL);
1899 save_info = save_blk->bp->b_addr;
1900 drop_info = drop_blk->bp->b_addr;
1901 ASSERT(save_blk->magic == XFS_DA_NODE_MAGIC ||
1902 save_blk->magic == XFS_DIR2_LEAFN_MAGIC ||
1903 save_blk->magic == XFS_ATTR_LEAF_MAGIC);
1904 ASSERT(save_blk->magic == drop_blk->magic);
1905 ASSERT((be32_to_cpu(save_info->forw) == drop_blk->blkno) ||
1906 (be32_to_cpu(save_info->back) == drop_blk->blkno));
1907 ASSERT((be32_to_cpu(drop_info->forw) == save_blk->blkno) ||
1908 (be32_to_cpu(drop_info->back) == save_blk->blkno));
1909
1910 /*
1911 * Unlink the leaf block from the doubly linked chain of leaves.
1912 */
1913 if (be32_to_cpu(save_info->back) == drop_blk->blkno) {
1914 trace_xfs_da_unlink_back(args);
1915 save_info->back = drop_info->back;
1916 if (drop_info->back) {
1917 error = xfs_da3_node_read(args->trans, args->dp,
1918 be32_to_cpu(drop_info->back),
1919 &bp, args->whichfork);
1920 if (error)
1921 return error;
1922 ASSERT(bp != NULL);
1923 tmp_info = bp->b_addr;
1924 ASSERT(tmp_info->magic == save_info->magic);
1925 ASSERT(be32_to_cpu(tmp_info->forw) == drop_blk->blkno);
1926 tmp_info->forw = cpu_to_be32(save_blk->blkno);
1927 xfs_trans_log_buf(args->trans, bp, 0,
1928 sizeof(*tmp_info) - 1);
1929 }
1930 } else {
1931 trace_xfs_da_unlink_forward(args);
1932 save_info->forw = drop_info->forw;
1933 if (drop_info->forw) {
1934 error = xfs_da3_node_read(args->trans, args->dp,
1935 be32_to_cpu(drop_info->forw),
1936 &bp, args->whichfork);
1937 if (error)
1938 return error;
1939 ASSERT(bp != NULL);
1940 tmp_info = bp->b_addr;
1941 ASSERT(tmp_info->magic == save_info->magic);
1942 ASSERT(be32_to_cpu(tmp_info->back) == drop_blk->blkno);
1943 tmp_info->back = cpu_to_be32(save_blk->blkno);
1944 xfs_trans_log_buf(args->trans, bp, 0,
1945 sizeof(*tmp_info) - 1);
1946 }
1947 }
1948
1949 xfs_trans_log_buf(args->trans, save_blk->bp, 0, sizeof(*save_info) - 1);
1950 return 0;
1951 }
1952
1953 /*
1954 * Move a path "forward" or "!forward" one block at the current level.
1955 *
1956 * This routine will adjust a "path" to point to the next block
1957 * "forward" (higher hashvalues) or "!forward" (lower hashvals) in the
1958 * Btree, including updating pointers to the intermediate nodes between
1959 * the new bottom and the root.
1960 */
1961 int /* error */
xfs_da3_path_shift(struct xfs_da_state * state,struct xfs_da_state_path * path,int forward,int release,int * result)1962 xfs_da3_path_shift(
1963 struct xfs_da_state *state,
1964 struct xfs_da_state_path *path,
1965 int forward,
1966 int release,
1967 int *result)
1968 {
1969 struct xfs_da_state_blk *blk;
1970 struct xfs_da_blkinfo *info;
1971 struct xfs_da_args *args;
1972 struct xfs_da_node_entry *btree;
1973 struct xfs_da3_icnode_hdr nodehdr;
1974 struct xfs_buf *bp;
1975 xfs_dablk_t blkno = 0;
1976 int level;
1977 int error;
1978 struct xfs_inode *dp = state->args->dp;
1979
1980 trace_xfs_da_path_shift(state->args);
1981
1982 /*
1983 * Roll up the Btree looking for the first block where our
1984 * current index is not at the edge of the block. Note that
1985 * we skip the bottom layer because we want the sibling block.
1986 */
1987 args = state->args;
1988 ASSERT(args != NULL);
1989 ASSERT(path != NULL);
1990 ASSERT((path->active > 0) && (path->active < XFS_DA_NODE_MAXDEPTH));
1991 level = (path->active-1) - 1; /* skip bottom layer in path */
1992 for (; level >= 0; level--) {
1993 blk = &path->blk[level];
1994 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr,
1995 blk->bp->b_addr);
1996
1997 if (forward && (blk->index < nodehdr.count - 1)) {
1998 blk->index++;
1999 blkno = be32_to_cpu(nodehdr.btree[blk->index].before);
2000 break;
2001 } else if (!forward && (blk->index > 0)) {
2002 blk->index--;
2003 blkno = be32_to_cpu(nodehdr.btree[blk->index].before);
2004 break;
2005 }
2006 }
2007 if (level < 0) {
2008 *result = -ENOENT; /* we're out of our tree */
2009 ASSERT(args->op_flags & XFS_DA_OP_OKNOENT);
2010 return 0;
2011 }
2012
2013 /*
2014 * Roll down the edge of the subtree until we reach the
2015 * same depth we were at originally.
2016 */
2017 for (blk++, level++; level < path->active; blk++, level++) {
2018 /*
2019 * Read the next child block into a local buffer.
2020 */
2021 error = xfs_da3_node_read(args->trans, dp, blkno, &bp,
2022 args->whichfork);
2023 if (error)
2024 return error;
2025
2026 /*
2027 * Release the old block (if it's dirty, the trans doesn't
2028 * actually let go) and swap the local buffer into the path
2029 * structure. This ensures failure of the above read doesn't set
2030 * a NULL buffer in an active slot in the path.
2031 */
2032 if (release)
2033 xfs_trans_brelse(args->trans, blk->bp);
2034 blk->blkno = blkno;
2035 blk->bp = bp;
2036
2037 info = blk->bp->b_addr;
2038 ASSERT(info->magic == cpu_to_be16(XFS_DA_NODE_MAGIC) ||
2039 info->magic == cpu_to_be16(XFS_DA3_NODE_MAGIC) ||
2040 info->magic == cpu_to_be16(XFS_DIR2_LEAFN_MAGIC) ||
2041 info->magic == cpu_to_be16(XFS_DIR3_LEAFN_MAGIC) ||
2042 info->magic == cpu_to_be16(XFS_ATTR_LEAF_MAGIC) ||
2043 info->magic == cpu_to_be16(XFS_ATTR3_LEAF_MAGIC));
2044
2045
2046 /*
2047 * Note: we flatten the magic number to a single type so we
2048 * don't have to compare against crc/non-crc types elsewhere.
2049 */
2050 switch (be16_to_cpu(info->magic)) {
2051 case XFS_DA_NODE_MAGIC:
2052 case XFS_DA3_NODE_MAGIC:
2053 blk->magic = XFS_DA_NODE_MAGIC;
2054 xfs_da3_node_hdr_from_disk(dp->i_mount, &nodehdr,
2055 bp->b_addr);
2056 btree = nodehdr.btree;
2057 blk->hashval = be32_to_cpu(btree[nodehdr.count - 1].hashval);
2058 if (forward)
2059 blk->index = 0;
2060 else
2061 blk->index = nodehdr.count - 1;
2062 blkno = be32_to_cpu(btree[blk->index].before);
2063 break;
2064 case XFS_ATTR_LEAF_MAGIC:
2065 case XFS_ATTR3_LEAF_MAGIC:
2066 blk->magic = XFS_ATTR_LEAF_MAGIC;
2067 ASSERT(level == path->active-1);
2068 blk->index = 0;
2069 blk->hashval = xfs_attr_leaf_lasthash(blk->bp, NULL);
2070 break;
2071 case XFS_DIR2_LEAFN_MAGIC:
2072 case XFS_DIR3_LEAFN_MAGIC:
2073 blk->magic = XFS_DIR2_LEAFN_MAGIC;
2074 ASSERT(level == path->active-1);
2075 blk->index = 0;
2076 blk->hashval = xfs_dir2_leaf_lasthash(args->dp,
2077 blk->bp, NULL);
2078 break;
2079 default:
2080 ASSERT(0);
2081 break;
2082 }
2083 }
2084 *result = 0;
2085 return 0;
2086 }
2087
2088
2089 /*========================================================================
2090 * Utility routines.
2091 *========================================================================*/
2092
2093 /*
2094 * Implement a simple hash on a character string.
2095 * Rotate the hash value by 7 bits, then XOR each character in.
2096 * This is implemented with some source-level loop unrolling.
2097 */
2098 xfs_dahash_t
xfs_da_hashname(const uint8_t * name,int namelen)2099 xfs_da_hashname(const uint8_t *name, int namelen)
2100 {
2101 xfs_dahash_t hash;
2102
2103 /*
2104 * Do four characters at a time as long as we can.
2105 */
2106 for (hash = 0; namelen >= 4; namelen -= 4, name += 4)
2107 hash = (name[0] << 21) ^ (name[1] << 14) ^ (name[2] << 7) ^
2108 (name[3] << 0) ^ rol32(hash, 7 * 4);
2109
2110 /*
2111 * Now do the rest of the characters.
2112 */
2113 switch (namelen) {
2114 case 3:
2115 return (name[0] << 14) ^ (name[1] << 7) ^ (name[2] << 0) ^
2116 rol32(hash, 7 * 3);
2117 case 2:
2118 return (name[0] << 7) ^ (name[1] << 0) ^ rol32(hash, 7 * 2);
2119 case 1:
2120 return (name[0] << 0) ^ rol32(hash, 7 * 1);
2121 default: /* case 0: */
2122 return hash;
2123 }
2124 }
2125
2126 enum xfs_dacmp
xfs_da_compname(struct xfs_da_args * args,const unsigned char * name,int len)2127 xfs_da_compname(
2128 struct xfs_da_args *args,
2129 const unsigned char *name,
2130 int len)
2131 {
2132 return (args->namelen == len && memcmp(args->name, name, len) == 0) ?
2133 XFS_CMP_EXACT : XFS_CMP_DIFFERENT;
2134 }
2135
2136 int
xfs_da_grow_inode_int(struct xfs_da_args * args,xfs_fileoff_t * bno,int count)2137 xfs_da_grow_inode_int(
2138 struct xfs_da_args *args,
2139 xfs_fileoff_t *bno,
2140 int count)
2141 {
2142 struct xfs_trans *tp = args->trans;
2143 struct xfs_inode *dp = args->dp;
2144 int w = args->whichfork;
2145 xfs_rfsblock_t nblks = dp->i_nblocks;
2146 struct xfs_bmbt_irec map, *mapp;
2147 int nmap, error, got, i, mapi;
2148
2149 /*
2150 * Find a spot in the file space to put the new block.
2151 */
2152 error = xfs_bmap_first_unused(tp, dp, count, bno, w);
2153 if (error)
2154 return error;
2155
2156 /*
2157 * Try mapping it in one filesystem block.
2158 */
2159 nmap = 1;
2160 error = xfs_bmapi_write(tp, dp, *bno, count,
2161 xfs_bmapi_aflag(w)|XFS_BMAPI_METADATA|XFS_BMAPI_CONTIG,
2162 args->total, &map, &nmap);
2163 if (error)
2164 return error;
2165
2166 ASSERT(nmap <= 1);
2167 if (nmap == 1) {
2168 mapp = ↦
2169 mapi = 1;
2170 } else if (nmap == 0 && count > 1) {
2171 xfs_fileoff_t b;
2172 int c;
2173
2174 /*
2175 * If we didn't get it and the block might work if fragmented,
2176 * try without the CONTIG flag. Loop until we get it all.
2177 */
2178 mapp = kmem_alloc(sizeof(*mapp) * count, 0);
2179 for (b = *bno, mapi = 0; b < *bno + count; ) {
2180 nmap = min(XFS_BMAP_MAX_NMAP, count);
2181 c = (int)(*bno + count - b);
2182 error = xfs_bmapi_write(tp, dp, b, c,
2183 xfs_bmapi_aflag(w)|XFS_BMAPI_METADATA,
2184 args->total, &mapp[mapi], &nmap);
2185 if (error)
2186 goto out_free_map;
2187 if (nmap < 1)
2188 break;
2189 mapi += nmap;
2190 b = mapp[mapi - 1].br_startoff +
2191 mapp[mapi - 1].br_blockcount;
2192 }
2193 } else {
2194 mapi = 0;
2195 mapp = NULL;
2196 }
2197
2198 /*
2199 * Count the blocks we got, make sure it matches the total.
2200 */
2201 for (i = 0, got = 0; i < mapi; i++)
2202 got += mapp[i].br_blockcount;
2203 if (got != count || mapp[0].br_startoff != *bno ||
2204 mapp[mapi - 1].br_startoff + mapp[mapi - 1].br_blockcount !=
2205 *bno + count) {
2206 error = -ENOSPC;
2207 goto out_free_map;
2208 }
2209
2210 /* account for newly allocated blocks in reserved blocks total */
2211 args->total -= dp->i_nblocks - nblks;
2212
2213 out_free_map:
2214 if (mapp != &map)
2215 kmem_free(mapp);
2216 return error;
2217 }
2218
2219 /*
2220 * Add a block to the btree ahead of the file.
2221 * Return the new block number to the caller.
2222 */
2223 int
xfs_da_grow_inode(struct xfs_da_args * args,xfs_dablk_t * new_blkno)2224 xfs_da_grow_inode(
2225 struct xfs_da_args *args,
2226 xfs_dablk_t *new_blkno)
2227 {
2228 xfs_fileoff_t bno;
2229 int error;
2230
2231 trace_xfs_da_grow_inode(args);
2232
2233 bno = args->geo->leafblk;
2234 error = xfs_da_grow_inode_int(args, &bno, args->geo->fsbcount);
2235 if (!error)
2236 *new_blkno = (xfs_dablk_t)bno;
2237 return error;
2238 }
2239
2240 /*
2241 * Ick. We need to always be able to remove a btree block, even
2242 * if there's no space reservation because the filesystem is full.
2243 * This is called if xfs_bunmapi on a btree block fails due to ENOSPC.
2244 * It swaps the target block with the last block in the file. The
2245 * last block in the file can always be removed since it can't cause
2246 * a bmap btree split to do that.
2247 */
2248 STATIC int
xfs_da3_swap_lastblock(struct xfs_da_args * args,xfs_dablk_t * dead_blknop,struct xfs_buf ** dead_bufp)2249 xfs_da3_swap_lastblock(
2250 struct xfs_da_args *args,
2251 xfs_dablk_t *dead_blknop,
2252 struct xfs_buf **dead_bufp)
2253 {
2254 struct xfs_da_blkinfo *dead_info;
2255 struct xfs_da_blkinfo *sib_info;
2256 struct xfs_da_intnode *par_node;
2257 struct xfs_da_intnode *dead_node;
2258 struct xfs_dir2_leaf *dead_leaf2;
2259 struct xfs_da_node_entry *btree;
2260 struct xfs_da3_icnode_hdr par_hdr;
2261 struct xfs_inode *dp;
2262 struct xfs_trans *tp;
2263 struct xfs_mount *mp;
2264 struct xfs_buf *dead_buf;
2265 struct xfs_buf *last_buf;
2266 struct xfs_buf *sib_buf;
2267 struct xfs_buf *par_buf;
2268 xfs_dahash_t dead_hash;
2269 xfs_fileoff_t lastoff;
2270 xfs_dablk_t dead_blkno;
2271 xfs_dablk_t last_blkno;
2272 xfs_dablk_t sib_blkno;
2273 xfs_dablk_t par_blkno;
2274 int error;
2275 int w;
2276 int entno;
2277 int level;
2278 int dead_level;
2279
2280 trace_xfs_da_swap_lastblock(args);
2281
2282 dead_buf = *dead_bufp;
2283 dead_blkno = *dead_blknop;
2284 tp = args->trans;
2285 dp = args->dp;
2286 w = args->whichfork;
2287 ASSERT(w == XFS_DATA_FORK);
2288 mp = dp->i_mount;
2289 lastoff = args->geo->freeblk;
2290 error = xfs_bmap_last_before(tp, dp, &lastoff, w);
2291 if (error)
2292 return error;
2293 if (XFS_IS_CORRUPT(mp, lastoff == 0))
2294 return -EFSCORRUPTED;
2295 /*
2296 * Read the last block in the btree space.
2297 */
2298 last_blkno = (xfs_dablk_t)lastoff - args->geo->fsbcount;
2299 error = xfs_da3_node_read(tp, dp, last_blkno, &last_buf, w);
2300 if (error)
2301 return error;
2302 /*
2303 * Copy the last block into the dead buffer and log it.
2304 */
2305 memcpy(dead_buf->b_addr, last_buf->b_addr, args->geo->blksize);
2306 xfs_trans_log_buf(tp, dead_buf, 0, args->geo->blksize - 1);
2307 dead_info = dead_buf->b_addr;
2308 /*
2309 * Get values from the moved block.
2310 */
2311 if (dead_info->magic == cpu_to_be16(XFS_DIR2_LEAFN_MAGIC) ||
2312 dead_info->magic == cpu_to_be16(XFS_DIR3_LEAFN_MAGIC)) {
2313 struct xfs_dir3_icleaf_hdr leafhdr;
2314 struct xfs_dir2_leaf_entry *ents;
2315
2316 dead_leaf2 = (xfs_dir2_leaf_t *)dead_info;
2317 xfs_dir2_leaf_hdr_from_disk(dp->i_mount, &leafhdr,
2318 dead_leaf2);
2319 ents = leafhdr.ents;
2320 dead_level = 0;
2321 dead_hash = be32_to_cpu(ents[leafhdr.count - 1].hashval);
2322 } else {
2323 struct xfs_da3_icnode_hdr deadhdr;
2324
2325 dead_node = (xfs_da_intnode_t *)dead_info;
2326 xfs_da3_node_hdr_from_disk(dp->i_mount, &deadhdr, dead_node);
2327 btree = deadhdr.btree;
2328 dead_level = deadhdr.level;
2329 dead_hash = be32_to_cpu(btree[deadhdr.count - 1].hashval);
2330 }
2331 sib_buf = par_buf = NULL;
2332 /*
2333 * If the moved block has a left sibling, fix up the pointers.
2334 */
2335 if ((sib_blkno = be32_to_cpu(dead_info->back))) {
2336 error = xfs_da3_node_read(tp, dp, sib_blkno, &sib_buf, w);
2337 if (error)
2338 goto done;
2339 sib_info = sib_buf->b_addr;
2340 if (XFS_IS_CORRUPT(mp,
2341 be32_to_cpu(sib_info->forw) != last_blkno ||
2342 sib_info->magic != dead_info->magic)) {
2343 error = -EFSCORRUPTED;
2344 goto done;
2345 }
2346 sib_info->forw = cpu_to_be32(dead_blkno);
2347 xfs_trans_log_buf(tp, sib_buf,
2348 XFS_DA_LOGRANGE(sib_info, &sib_info->forw,
2349 sizeof(sib_info->forw)));
2350 sib_buf = NULL;
2351 }
2352 /*
2353 * If the moved block has a right sibling, fix up the pointers.
2354 */
2355 if ((sib_blkno = be32_to_cpu(dead_info->forw))) {
2356 error = xfs_da3_node_read(tp, dp, sib_blkno, &sib_buf, w);
2357 if (error)
2358 goto done;
2359 sib_info = sib_buf->b_addr;
2360 if (XFS_IS_CORRUPT(mp,
2361 be32_to_cpu(sib_info->back) != last_blkno ||
2362 sib_info->magic != dead_info->magic)) {
2363 error = -EFSCORRUPTED;
2364 goto done;
2365 }
2366 sib_info->back = cpu_to_be32(dead_blkno);
2367 xfs_trans_log_buf(tp, sib_buf,
2368 XFS_DA_LOGRANGE(sib_info, &sib_info->back,
2369 sizeof(sib_info->back)));
2370 sib_buf = NULL;
2371 }
2372 par_blkno = args->geo->leafblk;
2373 level = -1;
2374 /*
2375 * Walk down the tree looking for the parent of the moved block.
2376 */
2377 for (;;) {
2378 error = xfs_da3_node_read(tp, dp, par_blkno, &par_buf, w);
2379 if (error)
2380 goto done;
2381 par_node = par_buf->b_addr;
2382 xfs_da3_node_hdr_from_disk(dp->i_mount, &par_hdr, par_node);
2383 if (XFS_IS_CORRUPT(mp,
2384 level >= 0 && level != par_hdr.level + 1)) {
2385 error = -EFSCORRUPTED;
2386 goto done;
2387 }
2388 level = par_hdr.level;
2389 btree = par_hdr.btree;
2390 for (entno = 0;
2391 entno < par_hdr.count &&
2392 be32_to_cpu(btree[entno].hashval) < dead_hash;
2393 entno++)
2394 continue;
2395 if (XFS_IS_CORRUPT(mp, entno == par_hdr.count)) {
2396 error = -EFSCORRUPTED;
2397 goto done;
2398 }
2399 par_blkno = be32_to_cpu(btree[entno].before);
2400 if (level == dead_level + 1)
2401 break;
2402 xfs_trans_brelse(tp, par_buf);
2403 par_buf = NULL;
2404 }
2405 /*
2406 * We're in the right parent block.
2407 * Look for the right entry.
2408 */
2409 for (;;) {
2410 for (;
2411 entno < par_hdr.count &&
2412 be32_to_cpu(btree[entno].before) != last_blkno;
2413 entno++)
2414 continue;
2415 if (entno < par_hdr.count)
2416 break;
2417 par_blkno = par_hdr.forw;
2418 xfs_trans_brelse(tp, par_buf);
2419 par_buf = NULL;
2420 if (XFS_IS_CORRUPT(mp, par_blkno == 0)) {
2421 error = -EFSCORRUPTED;
2422 goto done;
2423 }
2424 error = xfs_da3_node_read(tp, dp, par_blkno, &par_buf, w);
2425 if (error)
2426 goto done;
2427 par_node = par_buf->b_addr;
2428 xfs_da3_node_hdr_from_disk(dp->i_mount, &par_hdr, par_node);
2429 if (XFS_IS_CORRUPT(mp, par_hdr.level != level)) {
2430 error = -EFSCORRUPTED;
2431 goto done;
2432 }
2433 btree = par_hdr.btree;
2434 entno = 0;
2435 }
2436 /*
2437 * Update the parent entry pointing to the moved block.
2438 */
2439 btree[entno].before = cpu_to_be32(dead_blkno);
2440 xfs_trans_log_buf(tp, par_buf,
2441 XFS_DA_LOGRANGE(par_node, &btree[entno].before,
2442 sizeof(btree[entno].before)));
2443 *dead_blknop = last_blkno;
2444 *dead_bufp = last_buf;
2445 return 0;
2446 done:
2447 if (par_buf)
2448 xfs_trans_brelse(tp, par_buf);
2449 if (sib_buf)
2450 xfs_trans_brelse(tp, sib_buf);
2451 xfs_trans_brelse(tp, last_buf);
2452 return error;
2453 }
2454
2455 /*
2456 * Remove a btree block from a directory or attribute.
2457 */
2458 int
xfs_da_shrink_inode(struct xfs_da_args * args,xfs_dablk_t dead_blkno,struct xfs_buf * dead_buf)2459 xfs_da_shrink_inode(
2460 struct xfs_da_args *args,
2461 xfs_dablk_t dead_blkno,
2462 struct xfs_buf *dead_buf)
2463 {
2464 struct xfs_inode *dp;
2465 int done, error, w, count;
2466 struct xfs_trans *tp;
2467
2468 trace_xfs_da_shrink_inode(args);
2469
2470 dp = args->dp;
2471 w = args->whichfork;
2472 tp = args->trans;
2473 count = args->geo->fsbcount;
2474 for (;;) {
2475 /*
2476 * Remove extents. If we get ENOSPC for a dir we have to move
2477 * the last block to the place we want to kill.
2478 */
2479 error = xfs_bunmapi(tp, dp, dead_blkno, count,
2480 xfs_bmapi_aflag(w), 0, &done);
2481 if (error == -ENOSPC) {
2482 if (w != XFS_DATA_FORK)
2483 break;
2484 error = xfs_da3_swap_lastblock(args, &dead_blkno,
2485 &dead_buf);
2486 if (error)
2487 break;
2488 } else {
2489 break;
2490 }
2491 }
2492 xfs_trans_binval(tp, dead_buf);
2493 return error;
2494 }
2495
2496 static int
xfs_dabuf_map(struct xfs_inode * dp,xfs_dablk_t bno,unsigned int flags,int whichfork,struct xfs_buf_map ** mapp,int * nmaps)2497 xfs_dabuf_map(
2498 struct xfs_inode *dp,
2499 xfs_dablk_t bno,
2500 unsigned int flags,
2501 int whichfork,
2502 struct xfs_buf_map **mapp,
2503 int *nmaps)
2504 {
2505 struct xfs_mount *mp = dp->i_mount;
2506 int nfsb = xfs_dabuf_nfsb(mp, whichfork);
2507 struct xfs_bmbt_irec irec, *irecs = &irec;
2508 struct xfs_buf_map *map = *mapp;
2509 xfs_fileoff_t off = bno;
2510 int error = 0, nirecs, i;
2511
2512 if (nfsb > 1)
2513 irecs = kmem_zalloc(sizeof(irec) * nfsb, KM_NOFS);
2514
2515 nirecs = nfsb;
2516 error = xfs_bmapi_read(dp, bno, nfsb, irecs, &nirecs,
2517 xfs_bmapi_aflag(whichfork));
2518 if (error)
2519 goto out_free_irecs;
2520
2521 /*
2522 * Use the caller provided map for the single map case, else allocate a
2523 * larger one that needs to be free by the caller.
2524 */
2525 if (nirecs > 1) {
2526 map = kmem_zalloc(nirecs * sizeof(struct xfs_buf_map), KM_NOFS);
2527 if (!map) {
2528 error = -ENOMEM;
2529 goto out_free_irecs;
2530 }
2531 *mapp = map;
2532 }
2533
2534 for (i = 0; i < nirecs; i++) {
2535 if (irecs[i].br_startblock == HOLESTARTBLOCK ||
2536 irecs[i].br_startblock == DELAYSTARTBLOCK)
2537 goto invalid_mapping;
2538 if (off != irecs[i].br_startoff)
2539 goto invalid_mapping;
2540
2541 map[i].bm_bn = XFS_FSB_TO_DADDR(mp, irecs[i].br_startblock);
2542 map[i].bm_len = XFS_FSB_TO_BB(mp, irecs[i].br_blockcount);
2543 off += irecs[i].br_blockcount;
2544 }
2545
2546 if (off != bno + nfsb)
2547 goto invalid_mapping;
2548
2549 *nmaps = nirecs;
2550 out_free_irecs:
2551 if (irecs != &irec)
2552 kmem_free(irecs);
2553 return error;
2554
2555 invalid_mapping:
2556 /* Caller ok with no mapping. */
2557 if (XFS_IS_CORRUPT(mp, !(flags & XFS_DABUF_MAP_HOLE_OK))) {
2558 error = -EFSCORRUPTED;
2559 if (xfs_error_level >= XFS_ERRLEVEL_LOW) {
2560 xfs_alert(mp, "%s: bno %u inode %llu",
2561 __func__, bno, dp->i_ino);
2562
2563 for (i = 0; i < nirecs; i++) {
2564 xfs_alert(mp,
2565 "[%02d] br_startoff %lld br_startblock %lld br_blockcount %lld br_state %d",
2566 i, irecs[i].br_startoff,
2567 irecs[i].br_startblock,
2568 irecs[i].br_blockcount,
2569 irecs[i].br_state);
2570 }
2571 }
2572 } else {
2573 *nmaps = 0;
2574 }
2575 goto out_free_irecs;
2576 }
2577
2578 /*
2579 * Get a buffer for the dir/attr block.
2580 */
2581 int
xfs_da_get_buf(struct xfs_trans * tp,struct xfs_inode * dp,xfs_dablk_t bno,struct xfs_buf ** bpp,int whichfork)2582 xfs_da_get_buf(
2583 struct xfs_trans *tp,
2584 struct xfs_inode *dp,
2585 xfs_dablk_t bno,
2586 struct xfs_buf **bpp,
2587 int whichfork)
2588 {
2589 struct xfs_mount *mp = dp->i_mount;
2590 struct xfs_buf *bp;
2591 struct xfs_buf_map map, *mapp = ↦
2592 int nmap = 1;
2593 int error;
2594
2595 *bpp = NULL;
2596 error = xfs_dabuf_map(dp, bno, 0, whichfork, &mapp, &nmap);
2597 if (error || nmap == 0)
2598 goto out_free;
2599
2600 error = xfs_trans_get_buf_map(tp, mp->m_ddev_targp, mapp, nmap, 0, &bp);
2601 if (error)
2602 goto out_free;
2603
2604 *bpp = bp;
2605
2606 out_free:
2607 if (mapp != &map)
2608 kmem_free(mapp);
2609
2610 return error;
2611 }
2612
2613 /*
2614 * Get a buffer for the dir/attr block, fill in the contents.
2615 */
2616 int
xfs_da_read_buf(struct xfs_trans * tp,struct xfs_inode * dp,xfs_dablk_t bno,unsigned int flags,struct xfs_buf ** bpp,int whichfork,const struct xfs_buf_ops * ops)2617 xfs_da_read_buf(
2618 struct xfs_trans *tp,
2619 struct xfs_inode *dp,
2620 xfs_dablk_t bno,
2621 unsigned int flags,
2622 struct xfs_buf **bpp,
2623 int whichfork,
2624 const struct xfs_buf_ops *ops)
2625 {
2626 struct xfs_mount *mp = dp->i_mount;
2627 struct xfs_buf *bp;
2628 struct xfs_buf_map map, *mapp = ↦
2629 int nmap = 1;
2630 int error;
2631
2632 *bpp = NULL;
2633 error = xfs_dabuf_map(dp, bno, flags, whichfork, &mapp, &nmap);
2634 if (error || !nmap)
2635 goto out_free;
2636
2637 error = xfs_trans_read_buf_map(mp, tp, mp->m_ddev_targp, mapp, nmap, 0,
2638 &bp, ops);
2639 if (error)
2640 goto out_free;
2641
2642 if (whichfork == XFS_ATTR_FORK)
2643 xfs_buf_set_ref(bp, XFS_ATTR_BTREE_REF);
2644 else
2645 xfs_buf_set_ref(bp, XFS_DIR_BTREE_REF);
2646 *bpp = bp;
2647 out_free:
2648 if (mapp != &map)
2649 kmem_free(mapp);
2650
2651 return error;
2652 }
2653
2654 /*
2655 * Readahead the dir/attr block.
2656 */
2657 int
xfs_da_reada_buf(struct xfs_inode * dp,xfs_dablk_t bno,unsigned int flags,int whichfork,const struct xfs_buf_ops * ops)2658 xfs_da_reada_buf(
2659 struct xfs_inode *dp,
2660 xfs_dablk_t bno,
2661 unsigned int flags,
2662 int whichfork,
2663 const struct xfs_buf_ops *ops)
2664 {
2665 struct xfs_buf_map map;
2666 struct xfs_buf_map *mapp;
2667 int nmap;
2668 int error;
2669
2670 mapp = ↦
2671 nmap = 1;
2672 error = xfs_dabuf_map(dp, bno, flags, whichfork, &mapp, &nmap);
2673 if (error || !nmap)
2674 goto out_free;
2675
2676 xfs_buf_readahead_map(dp->i_mount->m_ddev_targp, mapp, nmap, ops);
2677
2678 out_free:
2679 if (mapp != &map)
2680 kmem_free(mapp);
2681
2682 return error;
2683 }
2684