]> git.kernelconcepts.de Git - karo-tx-linux.git/blob - fs/xfs/libxfs/xfs_bmap_btree.c
xfs: remove bmap block allocation retries
[karo-tx-linux.git] / fs / xfs / libxfs / xfs_bmap_btree.c
1 /*
2  * Copyright (c) 2000-2003,2005 Silicon Graphics, Inc.
3  * All Rights Reserved.
4  *
5  * This program is free software; you can redistribute it and/or
6  * modify it under the terms of the GNU General Public License as
7  * published by the Free Software Foundation.
8  *
9  * This program is distributed in the hope that it would be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write the Free Software Foundation,
16  * Inc.,  51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17  */
18 #include "xfs.h"
19 #include "xfs_fs.h"
20 #include "xfs_shared.h"
21 #include "xfs_format.h"
22 #include "xfs_log_format.h"
23 #include "xfs_trans_resv.h"
24 #include "xfs_bit.h"
25 #include "xfs_mount.h"
26 #include "xfs_defer.h"
27 #include "xfs_inode.h"
28 #include "xfs_trans.h"
29 #include "xfs_inode_item.h"
30 #include "xfs_alloc.h"
31 #include "xfs_btree.h"
32 #include "xfs_bmap_btree.h"
33 #include "xfs_bmap.h"
34 #include "xfs_error.h"
35 #include "xfs_quota.h"
36 #include "xfs_trace.h"
37 #include "xfs_cksum.h"
38 #include "xfs_rmap.h"
39
40 /*
41  * Determine the extent state.
42  */
43 /* ARGSUSED */
44 STATIC xfs_exntst_t
45 xfs_extent_state(
46         xfs_filblks_t           blks,
47         int                     extent_flag)
48 {
49         if (extent_flag) {
50                 ASSERT(blks != 0);      /* saved for DMIG */
51                 return XFS_EXT_UNWRITTEN;
52         }
53         return XFS_EXT_NORM;
54 }
55
56 /*
57  * Convert on-disk form of btree root to in-memory form.
58  */
59 void
60 xfs_bmdr_to_bmbt(
61         struct xfs_inode        *ip,
62         xfs_bmdr_block_t        *dblock,
63         int                     dblocklen,
64         struct xfs_btree_block  *rblock,
65         int                     rblocklen)
66 {
67         struct xfs_mount        *mp = ip->i_mount;
68         int                     dmxr;
69         xfs_bmbt_key_t          *fkp;
70         __be64                  *fpp;
71         xfs_bmbt_key_t          *tkp;
72         __be64                  *tpp;
73
74         xfs_btree_init_block_int(mp, rblock, XFS_BUF_DADDR_NULL,
75                                  XFS_BTNUM_BMAP, 0, 0, ip->i_ino,
76                                  XFS_BTREE_LONG_PTRS);
77         rblock->bb_level = dblock->bb_level;
78         ASSERT(be16_to_cpu(rblock->bb_level) > 0);
79         rblock->bb_numrecs = dblock->bb_numrecs;
80         dmxr = xfs_bmdr_maxrecs(dblocklen, 0);
81         fkp = XFS_BMDR_KEY_ADDR(dblock, 1);
82         tkp = XFS_BMBT_KEY_ADDR(mp, rblock, 1);
83         fpp = XFS_BMDR_PTR_ADDR(dblock, 1, dmxr);
84         tpp = XFS_BMAP_BROOT_PTR_ADDR(mp, rblock, 1, rblocklen);
85         dmxr = be16_to_cpu(dblock->bb_numrecs);
86         memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
87         memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
88 }
89
90 /*
91  * Convert a compressed bmap extent record to an uncompressed form.
92  * This code must be in sync with the routines xfs_bmbt_get_startoff,
93  * xfs_bmbt_get_startblock, xfs_bmbt_get_blockcount and xfs_bmbt_get_state.
94  */
95 STATIC void
96 __xfs_bmbt_get_all(
97                 __uint64_t l0,
98                 __uint64_t l1,
99                 xfs_bmbt_irec_t *s)
100 {
101         int     ext_flag;
102         xfs_exntst_t st;
103
104         ext_flag = (int)(l0 >> (64 - BMBT_EXNTFLAG_BITLEN));
105         s->br_startoff = ((xfs_fileoff_t)l0 &
106                            xfs_mask64lo(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
107         s->br_startblock = (((xfs_fsblock_t)l0 & xfs_mask64lo(9)) << 43) |
108                            (((xfs_fsblock_t)l1) >> 21);
109         s->br_blockcount = (xfs_filblks_t)(l1 & xfs_mask64lo(21));
110         /* This is xfs_extent_state() in-line */
111         if (ext_flag) {
112                 ASSERT(s->br_blockcount != 0);  /* saved for DMIG */
113                 st = XFS_EXT_UNWRITTEN;
114         } else
115                 st = XFS_EXT_NORM;
116         s->br_state = st;
117 }
118
119 void
120 xfs_bmbt_get_all(
121         xfs_bmbt_rec_host_t *r,
122         xfs_bmbt_irec_t *s)
123 {
124         __xfs_bmbt_get_all(r->l0, r->l1, s);
125 }
126
127 /*
128  * Extract the blockcount field from an in memory bmap extent record.
129  */
130 xfs_filblks_t
131 xfs_bmbt_get_blockcount(
132         xfs_bmbt_rec_host_t     *r)
133 {
134         return (xfs_filblks_t)(r->l1 & xfs_mask64lo(21));
135 }
136
137 /*
138  * Extract the startblock field from an in memory bmap extent record.
139  */
140 xfs_fsblock_t
141 xfs_bmbt_get_startblock(
142         xfs_bmbt_rec_host_t     *r)
143 {
144         return (((xfs_fsblock_t)r->l0 & xfs_mask64lo(9)) << 43) |
145                (((xfs_fsblock_t)r->l1) >> 21);
146 }
147
148 /*
149  * Extract the startoff field from an in memory bmap extent record.
150  */
151 xfs_fileoff_t
152 xfs_bmbt_get_startoff(
153         xfs_bmbt_rec_host_t     *r)
154 {
155         return ((xfs_fileoff_t)r->l0 &
156                  xfs_mask64lo(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
157 }
158
159 xfs_exntst_t
160 xfs_bmbt_get_state(
161         xfs_bmbt_rec_host_t     *r)
162 {
163         int     ext_flag;
164
165         ext_flag = (int)((r->l0) >> (64 - BMBT_EXNTFLAG_BITLEN));
166         return xfs_extent_state(xfs_bmbt_get_blockcount(r),
167                                 ext_flag);
168 }
169
170 /*
171  * Extract the blockcount field from an on disk bmap extent record.
172  */
173 xfs_filblks_t
174 xfs_bmbt_disk_get_blockcount(
175         xfs_bmbt_rec_t  *r)
176 {
177         return (xfs_filblks_t)(be64_to_cpu(r->l1) & xfs_mask64lo(21));
178 }
179
180 /*
181  * Extract the startoff field from a disk format bmap extent record.
182  */
183 xfs_fileoff_t
184 xfs_bmbt_disk_get_startoff(
185         xfs_bmbt_rec_t  *r)
186 {
187         return ((xfs_fileoff_t)be64_to_cpu(r->l0) &
188                  xfs_mask64lo(64 - BMBT_EXNTFLAG_BITLEN)) >> 9;
189 }
190
191
192 /*
193  * Set all the fields in a bmap extent record from the arguments.
194  */
195 void
196 xfs_bmbt_set_allf(
197         xfs_bmbt_rec_host_t     *r,
198         xfs_fileoff_t           startoff,
199         xfs_fsblock_t           startblock,
200         xfs_filblks_t           blockcount,
201         xfs_exntst_t            state)
202 {
203         int             extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
204
205         ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
206         ASSERT((startoff & xfs_mask64hi(64-BMBT_STARTOFF_BITLEN)) == 0);
207         ASSERT((blockcount & xfs_mask64hi(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
208
209         ASSERT((startblock & xfs_mask64hi(64-BMBT_STARTBLOCK_BITLEN)) == 0);
210
211         r->l0 = ((xfs_bmbt_rec_base_t)extent_flag << 63) |
212                 ((xfs_bmbt_rec_base_t)startoff << 9) |
213                 ((xfs_bmbt_rec_base_t)startblock >> 43);
214         r->l1 = ((xfs_bmbt_rec_base_t)startblock << 21) |
215                 ((xfs_bmbt_rec_base_t)blockcount &
216                 (xfs_bmbt_rec_base_t)xfs_mask64lo(21));
217 }
218
219 /*
220  * Set all the fields in a bmap extent record from the uncompressed form.
221  */
222 void
223 xfs_bmbt_set_all(
224         xfs_bmbt_rec_host_t *r,
225         xfs_bmbt_irec_t *s)
226 {
227         xfs_bmbt_set_allf(r, s->br_startoff, s->br_startblock,
228                              s->br_blockcount, s->br_state);
229 }
230
231
232 /*
233  * Set all the fields in a disk format bmap extent record from the arguments.
234  */
235 void
236 xfs_bmbt_disk_set_allf(
237         xfs_bmbt_rec_t          *r,
238         xfs_fileoff_t           startoff,
239         xfs_fsblock_t           startblock,
240         xfs_filblks_t           blockcount,
241         xfs_exntst_t            state)
242 {
243         int                     extent_flag = (state == XFS_EXT_NORM) ? 0 : 1;
244
245         ASSERT(state == XFS_EXT_NORM || state == XFS_EXT_UNWRITTEN);
246         ASSERT((startoff & xfs_mask64hi(64-BMBT_STARTOFF_BITLEN)) == 0);
247         ASSERT((blockcount & xfs_mask64hi(64-BMBT_BLOCKCOUNT_BITLEN)) == 0);
248         ASSERT((startblock & xfs_mask64hi(64-BMBT_STARTBLOCK_BITLEN)) == 0);
249
250         r->l0 = cpu_to_be64(
251                 ((xfs_bmbt_rec_base_t)extent_flag << 63) |
252                  ((xfs_bmbt_rec_base_t)startoff << 9) |
253                  ((xfs_bmbt_rec_base_t)startblock >> 43));
254         r->l1 = cpu_to_be64(
255                 ((xfs_bmbt_rec_base_t)startblock << 21) |
256                  ((xfs_bmbt_rec_base_t)blockcount &
257                   (xfs_bmbt_rec_base_t)xfs_mask64lo(21)));
258 }
259
260 /*
261  * Set all the fields in a bmap extent record from the uncompressed form.
262  */
263 STATIC void
264 xfs_bmbt_disk_set_all(
265         xfs_bmbt_rec_t  *r,
266         xfs_bmbt_irec_t *s)
267 {
268         xfs_bmbt_disk_set_allf(r, s->br_startoff, s->br_startblock,
269                                   s->br_blockcount, s->br_state);
270 }
271
272 /*
273  * Set the blockcount field in a bmap extent record.
274  */
275 void
276 xfs_bmbt_set_blockcount(
277         xfs_bmbt_rec_host_t *r,
278         xfs_filblks_t   v)
279 {
280         ASSERT((v & xfs_mask64hi(43)) == 0);
281         r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)xfs_mask64hi(43)) |
282                   (xfs_bmbt_rec_base_t)(v & xfs_mask64lo(21));
283 }
284
285 /*
286  * Set the startblock field in a bmap extent record.
287  */
288 void
289 xfs_bmbt_set_startblock(
290         xfs_bmbt_rec_host_t *r,
291         xfs_fsblock_t   v)
292 {
293         ASSERT((v & xfs_mask64hi(12)) == 0);
294         r->l0 = (r->l0 & (xfs_bmbt_rec_base_t)xfs_mask64hi(55)) |
295                   (xfs_bmbt_rec_base_t)(v >> 43);
296         r->l1 = (r->l1 & (xfs_bmbt_rec_base_t)xfs_mask64lo(21)) |
297                   (xfs_bmbt_rec_base_t)(v << 21);
298 }
299
300 /*
301  * Set the startoff field in a bmap extent record.
302  */
303 void
304 xfs_bmbt_set_startoff(
305         xfs_bmbt_rec_host_t *r,
306         xfs_fileoff_t   v)
307 {
308         ASSERT((v & xfs_mask64hi(9)) == 0);
309         r->l0 = (r->l0 & (xfs_bmbt_rec_base_t) xfs_mask64hi(1)) |
310                 ((xfs_bmbt_rec_base_t)v << 9) |
311                   (r->l0 & (xfs_bmbt_rec_base_t)xfs_mask64lo(9));
312 }
313
314 /*
315  * Set the extent state field in a bmap extent record.
316  */
317 void
318 xfs_bmbt_set_state(
319         xfs_bmbt_rec_host_t *r,
320         xfs_exntst_t    v)
321 {
322         ASSERT(v == XFS_EXT_NORM || v == XFS_EXT_UNWRITTEN);
323         if (v == XFS_EXT_NORM)
324                 r->l0 &= xfs_mask64lo(64 - BMBT_EXNTFLAG_BITLEN);
325         else
326                 r->l0 |= xfs_mask64hi(BMBT_EXNTFLAG_BITLEN);
327 }
328
329 /*
330  * Convert in-memory form of btree root to on-disk form.
331  */
332 void
333 xfs_bmbt_to_bmdr(
334         struct xfs_mount        *mp,
335         struct xfs_btree_block  *rblock,
336         int                     rblocklen,
337         xfs_bmdr_block_t        *dblock,
338         int                     dblocklen)
339 {
340         int                     dmxr;
341         xfs_bmbt_key_t          *fkp;
342         __be64                  *fpp;
343         xfs_bmbt_key_t          *tkp;
344         __be64                  *tpp;
345
346         if (xfs_sb_version_hascrc(&mp->m_sb)) {
347                 ASSERT(rblock->bb_magic == cpu_to_be32(XFS_BMAP_CRC_MAGIC));
348                 ASSERT(uuid_equal(&rblock->bb_u.l.bb_uuid,
349                        &mp->m_sb.sb_meta_uuid));
350                 ASSERT(rblock->bb_u.l.bb_blkno ==
351                        cpu_to_be64(XFS_BUF_DADDR_NULL));
352         } else
353                 ASSERT(rblock->bb_magic == cpu_to_be32(XFS_BMAP_MAGIC));
354         ASSERT(rblock->bb_u.l.bb_leftsib == cpu_to_be64(NULLFSBLOCK));
355         ASSERT(rblock->bb_u.l.bb_rightsib == cpu_to_be64(NULLFSBLOCK));
356         ASSERT(rblock->bb_level != 0);
357         dblock->bb_level = rblock->bb_level;
358         dblock->bb_numrecs = rblock->bb_numrecs;
359         dmxr = xfs_bmdr_maxrecs(dblocklen, 0);
360         fkp = XFS_BMBT_KEY_ADDR(mp, rblock, 1);
361         tkp = XFS_BMDR_KEY_ADDR(dblock, 1);
362         fpp = XFS_BMAP_BROOT_PTR_ADDR(mp, rblock, 1, rblocklen);
363         tpp = XFS_BMDR_PTR_ADDR(dblock, 1, dmxr);
364         dmxr = be16_to_cpu(dblock->bb_numrecs);
365         memcpy(tkp, fkp, sizeof(*fkp) * dmxr);
366         memcpy(tpp, fpp, sizeof(*fpp) * dmxr);
367 }
368
369 /*
370  * Check extent records, which have just been read, for
371  * any bit in the extent flag field. ASSERT on debug
372  * kernels, as this condition should not occur.
373  * Return an error condition (1) if any flags found,
374  * otherwise return 0.
375  */
376
377 int
378 xfs_check_nostate_extents(
379         xfs_ifork_t             *ifp,
380         xfs_extnum_t            idx,
381         xfs_extnum_t            num)
382 {
383         for (; num > 0; num--, idx++) {
384                 xfs_bmbt_rec_host_t *ep = xfs_iext_get_ext(ifp, idx);
385                 if ((ep->l0 >>
386                      (64 - BMBT_EXNTFLAG_BITLEN)) != 0) {
387                         ASSERT(0);
388                         return 1;
389                 }
390         }
391         return 0;
392 }
393
394
395 STATIC struct xfs_btree_cur *
396 xfs_bmbt_dup_cursor(
397         struct xfs_btree_cur    *cur)
398 {
399         struct xfs_btree_cur    *new;
400
401         new = xfs_bmbt_init_cursor(cur->bc_mp, cur->bc_tp,
402                         cur->bc_private.b.ip, cur->bc_private.b.whichfork);
403
404         /*
405          * Copy the firstblock, dfops, and flags values,
406          * since init cursor doesn't get them.
407          */
408         new->bc_private.b.firstblock = cur->bc_private.b.firstblock;
409         new->bc_private.b.dfops = cur->bc_private.b.dfops;
410         new->bc_private.b.flags = cur->bc_private.b.flags;
411
412         return new;
413 }
414
415 STATIC void
416 xfs_bmbt_update_cursor(
417         struct xfs_btree_cur    *src,
418         struct xfs_btree_cur    *dst)
419 {
420         ASSERT((dst->bc_private.b.firstblock != NULLFSBLOCK) ||
421                (dst->bc_private.b.ip->i_d.di_flags & XFS_DIFLAG_REALTIME));
422         ASSERT(dst->bc_private.b.dfops == src->bc_private.b.dfops);
423
424         dst->bc_private.b.allocated += src->bc_private.b.allocated;
425         dst->bc_private.b.firstblock = src->bc_private.b.firstblock;
426
427         src->bc_private.b.allocated = 0;
428 }
429
430 STATIC int
431 xfs_bmbt_alloc_block(
432         struct xfs_btree_cur    *cur,
433         union xfs_btree_ptr     *start,
434         union xfs_btree_ptr     *new,
435         int                     *stat)
436 {
437         xfs_alloc_arg_t         args;           /* block allocation args */
438         int                     error;          /* error return value */
439
440         memset(&args, 0, sizeof(args));
441         args.tp = cur->bc_tp;
442         args.mp = cur->bc_mp;
443         args.fsbno = cur->bc_private.b.firstblock;
444         args.firstblock = args.fsbno;
445         xfs_rmap_ino_bmbt_owner(&args.oinfo, cur->bc_private.b.ip->i_ino,
446                         cur->bc_private.b.whichfork);
447
448         if (args.fsbno == NULLFSBLOCK) {
449                 args.fsbno = be64_to_cpu(start->l);
450                 args.type = XFS_ALLOCTYPE_START_BNO;
451                 /*
452                  * Make sure there is sufficient room left in the AG to
453                  * complete a full tree split for an extent insert.  If
454                  * we are converting the middle part of an extent then
455                  * we may need space for two tree splits.
456                  *
457                  * We are relying on the caller to make the correct block
458                  * reservation for this operation to succeed.  If the
459                  * reservation amount is insufficient then we may fail a
460                  * block allocation here and corrupt the filesystem.
461                  */
462                 args.minleft = args.tp->t_blk_res;
463         } else if (cur->bc_private.b.dfops->dop_low) {
464                 args.type = XFS_ALLOCTYPE_START_BNO;
465         } else {
466                 args.type = XFS_ALLOCTYPE_NEAR_BNO;
467         }
468
469         args.minlen = args.maxlen = args.prod = 1;
470         args.wasdel = cur->bc_private.b.flags & XFS_BTCUR_BPRV_WASDEL;
471         if (!args.wasdel && args.tp->t_blk_res == 0) {
472                 error = -ENOSPC;
473                 goto error0;
474         }
475         error = xfs_alloc_vextent(&args);
476         if (error)
477                 goto error0;
478
479         if (args.fsbno == NULLFSBLOCK && args.minleft) {
480                 /*
481                  * Could not find an AG with enough free space to satisfy
482                  * a full btree split.  Try again and if
483                  * successful activate the lowspace algorithm.
484                  */
485                 args.fsbno = 0;
486                 args.type = XFS_ALLOCTYPE_FIRST_AG;
487                 error = xfs_alloc_vextent(&args);
488                 if (error)
489                         goto error0;
490                 cur->bc_private.b.dfops->dop_low = true;
491         }
492         if (WARN_ON_ONCE(args.fsbno == NULLFSBLOCK)) {
493                 XFS_BTREE_TRACE_CURSOR(cur, XBT_EXIT);
494                 *stat = 0;
495                 return 0;
496         }
497         ASSERT(args.len == 1);
498         cur->bc_private.b.firstblock = args.fsbno;
499         cur->bc_private.b.allocated++;
500         cur->bc_private.b.ip->i_d.di_nblocks++;
501         xfs_trans_log_inode(args.tp, cur->bc_private.b.ip, XFS_ILOG_CORE);
502         xfs_trans_mod_dquot_byino(args.tp, cur->bc_private.b.ip,
503                         XFS_TRANS_DQ_BCOUNT, 1L);
504
505         new->l = cpu_to_be64(args.fsbno);
506
507         XFS_BTREE_TRACE_CURSOR(cur, XBT_EXIT);
508         *stat = 1;
509         return 0;
510
511  error0:
512         XFS_BTREE_TRACE_CURSOR(cur, XBT_ERROR);
513         return error;
514 }
515
516 STATIC int
517 xfs_bmbt_free_block(
518         struct xfs_btree_cur    *cur,
519         struct xfs_buf          *bp)
520 {
521         struct xfs_mount        *mp = cur->bc_mp;
522         struct xfs_inode        *ip = cur->bc_private.b.ip;
523         struct xfs_trans        *tp = cur->bc_tp;
524         xfs_fsblock_t           fsbno = XFS_DADDR_TO_FSB(mp, XFS_BUF_ADDR(bp));
525         struct xfs_owner_info   oinfo;
526
527         xfs_rmap_ino_bmbt_owner(&oinfo, ip->i_ino, cur->bc_private.b.whichfork);
528         xfs_bmap_add_free(mp, cur->bc_private.b.dfops, fsbno, 1, &oinfo);
529         ip->i_d.di_nblocks--;
530
531         xfs_trans_log_inode(tp, ip, XFS_ILOG_CORE);
532         xfs_trans_mod_dquot_byino(tp, ip, XFS_TRANS_DQ_BCOUNT, -1L);
533         return 0;
534 }
535
536 STATIC int
537 xfs_bmbt_get_minrecs(
538         struct xfs_btree_cur    *cur,
539         int                     level)
540 {
541         if (level == cur->bc_nlevels - 1) {
542                 struct xfs_ifork        *ifp;
543
544                 ifp = XFS_IFORK_PTR(cur->bc_private.b.ip,
545                                     cur->bc_private.b.whichfork);
546
547                 return xfs_bmbt_maxrecs(cur->bc_mp,
548                                         ifp->if_broot_bytes, level == 0) / 2;
549         }
550
551         return cur->bc_mp->m_bmap_dmnr[level != 0];
552 }
553
554 int
555 xfs_bmbt_get_maxrecs(
556         struct xfs_btree_cur    *cur,
557         int                     level)
558 {
559         if (level == cur->bc_nlevels - 1) {
560                 struct xfs_ifork        *ifp;
561
562                 ifp = XFS_IFORK_PTR(cur->bc_private.b.ip,
563                                     cur->bc_private.b.whichfork);
564
565                 return xfs_bmbt_maxrecs(cur->bc_mp,
566                                         ifp->if_broot_bytes, level == 0);
567         }
568
569         return cur->bc_mp->m_bmap_dmxr[level != 0];
570
571 }
572
573 /*
574  * Get the maximum records we could store in the on-disk format.
575  *
576  * For non-root nodes this is equivalent to xfs_bmbt_get_maxrecs, but
577  * for the root node this checks the available space in the dinode fork
578  * so that we can resize the in-memory buffer to match it.  After a
579  * resize to the maximum size this function returns the same value
580  * as xfs_bmbt_get_maxrecs for the root node, too.
581  */
582 STATIC int
583 xfs_bmbt_get_dmaxrecs(
584         struct xfs_btree_cur    *cur,
585         int                     level)
586 {
587         if (level != cur->bc_nlevels - 1)
588                 return cur->bc_mp->m_bmap_dmxr[level != 0];
589         return xfs_bmdr_maxrecs(cur->bc_private.b.forksize, level == 0);
590 }
591
592 STATIC void
593 xfs_bmbt_init_key_from_rec(
594         union xfs_btree_key     *key,
595         union xfs_btree_rec     *rec)
596 {
597         key->bmbt.br_startoff =
598                 cpu_to_be64(xfs_bmbt_disk_get_startoff(&rec->bmbt));
599 }
600
601 STATIC void
602 xfs_bmbt_init_rec_from_cur(
603         struct xfs_btree_cur    *cur,
604         union xfs_btree_rec     *rec)
605 {
606         xfs_bmbt_disk_set_all(&rec->bmbt, &cur->bc_rec.b);
607 }
608
609 STATIC void
610 xfs_bmbt_init_ptr_from_cur(
611         struct xfs_btree_cur    *cur,
612         union xfs_btree_ptr     *ptr)
613 {
614         ptr->l = 0;
615 }
616
617 STATIC __int64_t
618 xfs_bmbt_key_diff(
619         struct xfs_btree_cur    *cur,
620         union xfs_btree_key     *key)
621 {
622         return (__int64_t)be64_to_cpu(key->bmbt.br_startoff) -
623                                       cur->bc_rec.b.br_startoff;
624 }
625
626 static bool
627 xfs_bmbt_verify(
628         struct xfs_buf          *bp)
629 {
630         struct xfs_mount        *mp = bp->b_target->bt_mount;
631         struct xfs_btree_block  *block = XFS_BUF_TO_BLOCK(bp);
632         unsigned int            level;
633
634         switch (block->bb_magic) {
635         case cpu_to_be32(XFS_BMAP_CRC_MAGIC):
636                 if (!xfs_sb_version_hascrc(&mp->m_sb))
637                         return false;
638                 if (!uuid_equal(&block->bb_u.l.bb_uuid, &mp->m_sb.sb_meta_uuid))
639                         return false;
640                 if (be64_to_cpu(block->bb_u.l.bb_blkno) != bp->b_bn)
641                         return false;
642                 /*
643                  * XXX: need a better way of verifying the owner here. Right now
644                  * just make sure there has been one set.
645                  */
646                 if (be64_to_cpu(block->bb_u.l.bb_owner) == 0)
647                         return false;
648                 /* fall through */
649         case cpu_to_be32(XFS_BMAP_MAGIC):
650                 break;
651         default:
652                 return false;
653         }
654
655         /*
656          * numrecs and level verification.
657          *
658          * We don't know what fork we belong to, so just verify that the level
659          * is less than the maximum of the two. Later checks will be more
660          * precise.
661          */
662         level = be16_to_cpu(block->bb_level);
663         if (level > max(mp->m_bm_maxlevels[0], mp->m_bm_maxlevels[1]))
664                 return false;
665         if (be16_to_cpu(block->bb_numrecs) > mp->m_bmap_dmxr[level != 0])
666                 return false;
667
668         /* sibling pointer verification */
669         if (!block->bb_u.l.bb_leftsib ||
670             (block->bb_u.l.bb_leftsib != cpu_to_be64(NULLFSBLOCK) &&
671              !XFS_FSB_SANITY_CHECK(mp, be64_to_cpu(block->bb_u.l.bb_leftsib))))
672                 return false;
673         if (!block->bb_u.l.bb_rightsib ||
674             (block->bb_u.l.bb_rightsib != cpu_to_be64(NULLFSBLOCK) &&
675              !XFS_FSB_SANITY_CHECK(mp, be64_to_cpu(block->bb_u.l.bb_rightsib))))
676                 return false;
677
678         return true;
679 }
680
681 static void
682 xfs_bmbt_read_verify(
683         struct xfs_buf  *bp)
684 {
685         if (!xfs_btree_lblock_verify_crc(bp))
686                 xfs_buf_ioerror(bp, -EFSBADCRC);
687         else if (!xfs_bmbt_verify(bp))
688                 xfs_buf_ioerror(bp, -EFSCORRUPTED);
689
690         if (bp->b_error) {
691                 trace_xfs_btree_corrupt(bp, _RET_IP_);
692                 xfs_verifier_error(bp);
693         }
694 }
695
696 static void
697 xfs_bmbt_write_verify(
698         struct xfs_buf  *bp)
699 {
700         if (!xfs_bmbt_verify(bp)) {
701                 trace_xfs_btree_corrupt(bp, _RET_IP_);
702                 xfs_buf_ioerror(bp, -EFSCORRUPTED);
703                 xfs_verifier_error(bp);
704                 return;
705         }
706         xfs_btree_lblock_calc_crc(bp);
707 }
708
709 const struct xfs_buf_ops xfs_bmbt_buf_ops = {
710         .name = "xfs_bmbt",
711         .verify_read = xfs_bmbt_read_verify,
712         .verify_write = xfs_bmbt_write_verify,
713 };
714
715
716 #if defined(DEBUG) || defined(XFS_WARN)
717 STATIC int
718 xfs_bmbt_keys_inorder(
719         struct xfs_btree_cur    *cur,
720         union xfs_btree_key     *k1,
721         union xfs_btree_key     *k2)
722 {
723         return be64_to_cpu(k1->bmbt.br_startoff) <
724                 be64_to_cpu(k2->bmbt.br_startoff);
725 }
726
727 STATIC int
728 xfs_bmbt_recs_inorder(
729         struct xfs_btree_cur    *cur,
730         union xfs_btree_rec     *r1,
731         union xfs_btree_rec     *r2)
732 {
733         return xfs_bmbt_disk_get_startoff(&r1->bmbt) +
734                 xfs_bmbt_disk_get_blockcount(&r1->bmbt) <=
735                 xfs_bmbt_disk_get_startoff(&r2->bmbt);
736 }
737 #endif  /* DEBUG */
738
739 static const struct xfs_btree_ops xfs_bmbt_ops = {
740         .rec_len                = sizeof(xfs_bmbt_rec_t),
741         .key_len                = sizeof(xfs_bmbt_key_t),
742
743         .dup_cursor             = xfs_bmbt_dup_cursor,
744         .update_cursor          = xfs_bmbt_update_cursor,
745         .alloc_block            = xfs_bmbt_alloc_block,
746         .free_block             = xfs_bmbt_free_block,
747         .get_maxrecs            = xfs_bmbt_get_maxrecs,
748         .get_minrecs            = xfs_bmbt_get_minrecs,
749         .get_dmaxrecs           = xfs_bmbt_get_dmaxrecs,
750         .init_key_from_rec      = xfs_bmbt_init_key_from_rec,
751         .init_rec_from_cur      = xfs_bmbt_init_rec_from_cur,
752         .init_ptr_from_cur      = xfs_bmbt_init_ptr_from_cur,
753         .key_diff               = xfs_bmbt_key_diff,
754         .buf_ops                = &xfs_bmbt_buf_ops,
755 #if defined(DEBUG) || defined(XFS_WARN)
756         .keys_inorder           = xfs_bmbt_keys_inorder,
757         .recs_inorder           = xfs_bmbt_recs_inorder,
758 #endif
759 };
760
761 /*
762  * Allocate a new bmap btree cursor.
763  */
764 struct xfs_btree_cur *                          /* new bmap btree cursor */
765 xfs_bmbt_init_cursor(
766         struct xfs_mount        *mp,            /* file system mount point */
767         struct xfs_trans        *tp,            /* transaction pointer */
768         struct xfs_inode        *ip,            /* inode owning the btree */
769         int                     whichfork)      /* data or attr fork */
770 {
771         struct xfs_ifork        *ifp = XFS_IFORK_PTR(ip, whichfork);
772         struct xfs_btree_cur    *cur;
773         ASSERT(whichfork != XFS_COW_FORK);
774
775         cur = kmem_zone_zalloc(xfs_btree_cur_zone, KM_NOFS);
776
777         cur->bc_tp = tp;
778         cur->bc_mp = mp;
779         cur->bc_nlevels = be16_to_cpu(ifp->if_broot->bb_level) + 1;
780         cur->bc_btnum = XFS_BTNUM_BMAP;
781         cur->bc_blocklog = mp->m_sb.sb_blocklog;
782         cur->bc_statoff = XFS_STATS_CALC_INDEX(xs_bmbt_2);
783
784         cur->bc_ops = &xfs_bmbt_ops;
785         cur->bc_flags = XFS_BTREE_LONG_PTRS | XFS_BTREE_ROOT_IN_INODE;
786         if (xfs_sb_version_hascrc(&mp->m_sb))
787                 cur->bc_flags |= XFS_BTREE_CRC_BLOCKS;
788
789         cur->bc_private.b.forksize = XFS_IFORK_SIZE(ip, whichfork);
790         cur->bc_private.b.ip = ip;
791         cur->bc_private.b.firstblock = NULLFSBLOCK;
792         cur->bc_private.b.dfops = NULL;
793         cur->bc_private.b.allocated = 0;
794         cur->bc_private.b.flags = 0;
795         cur->bc_private.b.whichfork = whichfork;
796
797         return cur;
798 }
799
800 /*
801  * Calculate number of records in a bmap btree block.
802  */
803 int
804 xfs_bmbt_maxrecs(
805         struct xfs_mount        *mp,
806         int                     blocklen,
807         int                     leaf)
808 {
809         blocklen -= XFS_BMBT_BLOCK_LEN(mp);
810
811         if (leaf)
812                 return blocklen / sizeof(xfs_bmbt_rec_t);
813         return blocklen / (sizeof(xfs_bmbt_key_t) + sizeof(xfs_bmbt_ptr_t));
814 }
815
816 /*
817  * Calculate number of records in a bmap btree inode root.
818  */
819 int
820 xfs_bmdr_maxrecs(
821         int                     blocklen,
822         int                     leaf)
823 {
824         blocklen -= sizeof(xfs_bmdr_block_t);
825
826         if (leaf)
827                 return blocklen / sizeof(xfs_bmdr_rec_t);
828         return blocklen / (sizeof(xfs_bmdr_key_t) + sizeof(xfs_bmdr_ptr_t));
829 }
830
831 /*
832  * Change the owner of a btree format fork fo the inode passed in. Change it to
833  * the owner of that is passed in so that we can change owners before or after
834  * we switch forks between inodes. The operation that the caller is doing will
835  * determine whether is needs to change owner before or after the switch.
836  *
837  * For demand paged transactional modification, the fork switch should be done
838  * after reading in all the blocks, modifying them and pinning them in the
839  * transaction. For modification when the buffers are already pinned in memory,
840  * the fork switch can be done before changing the owner as we won't need to
841  * validate the owner until the btree buffers are unpinned and writes can occur
842  * again.
843  *
844  * For recovery based ownership change, there is no transactional context and
845  * so a buffer list must be supplied so that we can record the buffers that we
846  * modified for the caller to issue IO on.
847  */
848 int
849 xfs_bmbt_change_owner(
850         struct xfs_trans        *tp,
851         struct xfs_inode        *ip,
852         int                     whichfork,
853         xfs_ino_t               new_owner,
854         struct list_head        *buffer_list)
855 {
856         struct xfs_btree_cur    *cur;
857         int                     error;
858
859         ASSERT(tp || buffer_list);
860         ASSERT(!(tp && buffer_list));
861         if (whichfork == XFS_DATA_FORK)
862                 ASSERT(ip->i_d.di_format == XFS_DINODE_FMT_BTREE);
863         else
864                 ASSERT(ip->i_d.di_aformat == XFS_DINODE_FMT_BTREE);
865
866         cur = xfs_bmbt_init_cursor(ip->i_mount, tp, ip, whichfork);
867         if (!cur)
868                 return -ENOMEM;
869
870         error = xfs_btree_change_owner(cur, new_owner, buffer_list);
871         xfs_btree_del_cursor(cur, error ? XFS_BTREE_ERROR : XFS_BTREE_NOERROR);
872         return error;
873 }