1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18#include "xfs.h"
19#include "xfs_fs.h"
20#include "xfs_types.h"
21#include "xfs_bit.h"
22#include "xfs_log.h"
23#include "xfs_inum.h"
24#include "xfs_trans.h"
25#include "xfs_sb.h"
26#include "xfs_ag.h"
27#include "xfs_dir2.h"
28#include "xfs_dmapi.h"
29#include "xfs_mount.h"
30#include "xfs_bmap_btree.h"
31#include "xfs_alloc_btree.h"
32#include "xfs_ialloc_btree.h"
33#include "xfs_dir2_sf.h"
34#include "xfs_attr_sf.h"
35#include "xfs_dinode.h"
36#include "xfs_inode.h"
37#include "xfs_btree.h"
38#include "xfs_ialloc.h"
39#include "xfs_alloc.h"
40#include "xfs_bmap.h"
41#include "xfs_rtalloc.h"
42#include "xfs_fsops.h"
43#include "xfs_error.h"
44#include "xfs_rw.h"
45#include "xfs_inode_item.h"
46#include "xfs_trans_space.h"
47
48
49
50
51
52
53
54STATIC int xfs_rtallocate_range(xfs_mount_t *, xfs_trans_t *, xfs_rtblock_t,
55 xfs_extlen_t, xfs_buf_t **, xfs_fsblock_t *);
56STATIC int xfs_rtany_summary(xfs_mount_t *, xfs_trans_t *, int, int,
57 xfs_rtblock_t, xfs_buf_t **, xfs_fsblock_t *, int *);
58STATIC int xfs_rtcheck_range(xfs_mount_t *, xfs_trans_t *, xfs_rtblock_t,
59 xfs_extlen_t, int, xfs_rtblock_t *, int *);
60STATIC int xfs_rtfind_back(xfs_mount_t *, xfs_trans_t *, xfs_rtblock_t,
61 xfs_rtblock_t, xfs_rtblock_t *);
62STATIC int xfs_rtfind_forw(xfs_mount_t *, xfs_trans_t *, xfs_rtblock_t,
63 xfs_rtblock_t, xfs_rtblock_t *);
64STATIC int xfs_rtget_summary( xfs_mount_t *, xfs_trans_t *, int,
65 xfs_rtblock_t, xfs_buf_t **, xfs_fsblock_t *, xfs_suminfo_t *);
66STATIC int xfs_rtmodify_range(xfs_mount_t *, xfs_trans_t *, xfs_rtblock_t,
67 xfs_extlen_t, int);
68STATIC int xfs_rtmodify_summary(xfs_mount_t *, xfs_trans_t *, int,
69 xfs_rtblock_t, int, xfs_buf_t **, xfs_fsblock_t *);
70
71
72
73
74
75
76
77
78STATIC int
79xfs_lowbit32(
80 __uint32_t v)
81{
82 if (v)
83 return ffs(v) - 1;
84 return -1;
85}
86
87
88
89
90STATIC int
91xfs_growfs_rt_alloc(
92 xfs_mount_t *mp,
93 xfs_extlen_t oblocks,
94 xfs_extlen_t nblocks,
95 xfs_ino_t ino)
96{
97 xfs_fileoff_t bno;
98 xfs_buf_t *bp;
99 int cancelflags;
100 int committed;
101 xfs_daddr_t d;
102 int error;
103 xfs_fsblock_t firstblock;
104 xfs_bmap_free_t flist;
105 xfs_fsblock_t fsbno;
106 xfs_inode_t *ip;
107 xfs_bmbt_irec_t map;
108 int nmap;
109 int resblks;
110 xfs_trans_t *tp;
111
112
113
114
115 while (oblocks < nblocks) {
116 tp = xfs_trans_alloc(mp, XFS_TRANS_GROWFSRT_ALLOC);
117 resblks = XFS_GROWFSRT_SPACE_RES(mp, nblocks - oblocks);
118 cancelflags = 0;
119
120
121
122 if ((error = xfs_trans_reserve(tp, resblks,
123 XFS_GROWRTALLOC_LOG_RES(mp), 0,
124 XFS_TRANS_PERM_LOG_RES,
125 XFS_DEFAULT_PERM_LOG_COUNT)))
126 goto error_exit;
127 cancelflags = XFS_TRANS_RELEASE_LOG_RES;
128
129
130
131 if ((error = xfs_trans_iget(mp, tp, ino, 0,
132 XFS_ILOCK_EXCL, &ip)))
133 goto error_exit;
134 XFS_BMAP_INIT(&flist, &firstblock);
135
136
137
138 nmap = 1;
139 cancelflags |= XFS_TRANS_ABORT;
140 error = xfs_bmapi(tp, ip, oblocks, nblocks - oblocks,
141 XFS_BMAPI_WRITE | XFS_BMAPI_METADATA, &firstblock,
142 resblks, &map, &nmap, &flist, NULL);
143 if (!error && nmap < 1)
144 error = XFS_ERROR(ENOSPC);
145 if (error)
146 goto error_exit;
147
148
149
150 error = xfs_bmap_finish(&tp, &flist, firstblock, &committed);
151 if (error)
152 goto error_exit;
153 xfs_trans_commit(tp, XFS_TRANS_RELEASE_LOG_RES, NULL);
154
155
156
157
158 cancelflags = 0;
159 for (bno = map.br_startoff, fsbno = map.br_startblock;
160 bno < map.br_startoff + map.br_blockcount;
161 bno++, fsbno++) {
162 tp = xfs_trans_alloc(mp, XFS_TRANS_GROWFSRT_ZERO);
163
164
165
166 if ((error = xfs_trans_reserve(tp, 0,
167 XFS_GROWRTZERO_LOG_RES(mp), 0, 0, 0)))
168 goto error_exit;
169
170
171
172 if ((error = xfs_trans_iget(mp, tp, ino, 0,
173 XFS_ILOCK_EXCL, &ip)))
174 goto error_exit;
175
176
177
178 d = XFS_FSB_TO_DADDR(mp, fsbno);
179 bp = xfs_trans_get_buf(tp, mp->m_ddev_targp, d,
180 mp->m_bsize, 0);
181 if (bp == NULL) {
182 error = XFS_ERROR(EIO);
183 goto error_exit;
184 }
185 memset(XFS_BUF_PTR(bp), 0, mp->m_sb.sb_blocksize);
186 xfs_trans_log_buf(tp, bp, 0, mp->m_sb.sb_blocksize - 1);
187
188
189
190 xfs_trans_commit(tp, 0, NULL);
191 }
192
193
194
195 oblocks = map.br_startoff + map.br_blockcount;
196 }
197 return 0;
198error_exit:
199 xfs_trans_cancel(tp, cancelflags);
200 return error;
201}
202
203
204
205
206
207
208
209STATIC int
210xfs_rtallocate_extent_block(
211 xfs_mount_t *mp,
212 xfs_trans_t *tp,
213 xfs_rtblock_t bbno,
214 xfs_extlen_t minlen,
215 xfs_extlen_t maxlen,
216 xfs_extlen_t *len,
217 xfs_rtblock_t *nextp,
218 xfs_buf_t **rbpp,
219 xfs_fsblock_t *rsb,
220 xfs_extlen_t prod,
221 xfs_rtblock_t *rtblock)
222{
223 xfs_rtblock_t besti;
224 xfs_rtblock_t bestlen;
225 xfs_rtblock_t end;
226 int error;
227 xfs_rtblock_t i;
228 xfs_rtblock_t next;
229 int stat;
230
231
232
233
234
235 for (i = XFS_BLOCKTOBIT(mp, bbno), besti = -1, bestlen = 0,
236 end = XFS_BLOCKTOBIT(mp, bbno + 1) - 1;
237 i <= end;
238 i++) {
239
240
241
242
243 error = xfs_rtcheck_range(mp, tp, i, maxlen, 1, &next, &stat);
244 if (error) {
245 return error;
246 }
247 if (stat) {
248
249
250
251 error = xfs_rtallocate_range(mp, tp, i, maxlen, rbpp,
252 rsb);
253 if (error) {
254 return error;
255 }
256 *len = maxlen;
257 *rtblock = i;
258 return 0;
259 }
260
261
262
263
264
265
266 if (minlen < maxlen) {
267 xfs_rtblock_t thislen;
268
269 thislen = next - i;
270 if (thislen >= minlen && thislen > bestlen) {
271 besti = i;
272 bestlen = thislen;
273 }
274 }
275
276
277
278 if (next < end) {
279 error = xfs_rtfind_forw(mp, tp, next, end, &i);
280 if (error) {
281 return error;
282 }
283 } else
284 break;
285 }
286
287
288
289 if (minlen < maxlen && besti != -1) {
290 xfs_extlen_t p;
291
292
293
294
295 if (prod > 1 && (p = do_mod(bestlen, prod)))
296 bestlen -= p;
297
298
299
300 error = xfs_rtallocate_range(mp, tp, besti, bestlen, rbpp, rsb);
301 if (error) {
302 return error;
303 }
304 *len = bestlen;
305 *rtblock = besti;
306 return 0;
307 }
308
309
310
311 *nextp = next;
312 *rtblock = NULLRTBLOCK;
313 return 0;
314}
315
316
317
318
319
320
321
322STATIC int
323xfs_rtallocate_extent_exact(
324 xfs_mount_t *mp,
325 xfs_trans_t *tp,
326 xfs_rtblock_t bno,
327 xfs_extlen_t minlen,
328 xfs_extlen_t maxlen,
329 xfs_extlen_t *len,
330 xfs_buf_t **rbpp,
331 xfs_fsblock_t *rsb,
332 xfs_extlen_t prod,
333 xfs_rtblock_t *rtblock)
334{
335 int error;
336 xfs_extlen_t i;
337 int isfree;
338 xfs_rtblock_t next;
339
340 ASSERT(minlen % prod == 0 && maxlen % prod == 0);
341
342
343
344 error = xfs_rtcheck_range(mp, tp, bno, maxlen, 1, &next, &isfree);
345 if (error) {
346 return error;
347 }
348 if (isfree) {
349
350
351
352 error = xfs_rtallocate_range(mp, tp, bno, maxlen, rbpp, rsb);
353 if (error) {
354 return error;
355 }
356 *len = maxlen;
357 *rtblock = bno;
358 return 0;
359 }
360
361
362
363 maxlen = next - bno;
364 if (maxlen < minlen) {
365
366
367
368 *rtblock = NULLRTBLOCK;
369 return 0;
370 }
371
372
373
374 if (prod > 1 && (i = maxlen % prod)) {
375 maxlen -= i;
376 if (maxlen < minlen) {
377
378
379
380 *rtblock = NULLRTBLOCK;
381 return 0;
382 }
383 }
384
385
386
387 error = xfs_rtallocate_range(mp, tp, bno, maxlen, rbpp, rsb);
388 if (error) {
389 return error;
390 }
391 *len = maxlen;
392 *rtblock = bno;
393 return 0;
394}
395
396
397
398
399
400
401STATIC int
402xfs_rtallocate_extent_near(
403 xfs_mount_t *mp,
404 xfs_trans_t *tp,
405 xfs_rtblock_t bno,
406 xfs_extlen_t minlen,
407 xfs_extlen_t maxlen,
408 xfs_extlen_t *len,
409 xfs_buf_t **rbpp,
410 xfs_fsblock_t *rsb,
411 xfs_extlen_t prod,
412 xfs_rtblock_t *rtblock)
413{
414 int any;
415 xfs_rtblock_t bbno;
416 int error;
417 int i;
418 int j;
419 int log2len;
420 xfs_rtblock_t n;
421 xfs_rtblock_t r;
422
423 ASSERT(minlen % prod == 0 && maxlen % prod == 0);
424
425
426
427
428 if (bno >= mp->m_sb.sb_rextents)
429 bno = mp->m_sb.sb_rextents - 1;
430
431
432
433 error = xfs_rtallocate_extent_exact(mp, tp, bno, minlen, maxlen, len,
434 rbpp, rsb, prod, &r);
435 if (error) {
436 return error;
437 }
438
439
440
441 if (r != NULLRTBLOCK) {
442 *rtblock = r;
443 return 0;
444 }
445 bbno = XFS_BITTOBLOCK(mp, bno);
446 i = 0;
447 log2len = xfs_highbit32(minlen);
448
449
450
451 for (;;) {
452
453
454
455
456 error = xfs_rtany_summary(mp, tp, log2len, mp->m_rsumlevels - 1,
457 bbno + i, rbpp, rsb, &any);
458 if (error) {
459 return error;
460 }
461
462
463
464
465 if (any) {
466
467
468
469 if (i >= 0) {
470
471
472
473
474 error = xfs_rtallocate_extent_block(mp, tp,
475 bbno + i, minlen, maxlen, len, &n, rbpp,
476 rsb, prod, &r);
477 if (error) {
478 return error;
479 }
480
481
482
483 if (r != NULLRTBLOCK) {
484 *rtblock = r;
485 return 0;
486 }
487 }
488
489
490
491 else {
492
493
494
495
496
497
498 for (j = -1; j > i; j--) {
499
500
501
502
503 error = xfs_rtany_summary(mp, tp,
504 log2len, mp->m_rsumlevels - 1,
505 bbno + j, rbpp, rsb, &any);
506 if (error) {
507 return error;
508 }
509
510
511
512
513
514
515
516
517 if (any)
518 continue;
519 error = xfs_rtallocate_extent_block(mp,
520 tp, bbno + j, minlen, maxlen,
521 len, &n, rbpp, rsb, prod, &r);
522 if (error) {
523 return error;
524 }
525
526
527
528 if (r != NULLRTBLOCK) {
529 *rtblock = r;
530 return 0;
531 }
532 }
533
534
535
536
537
538
539
540
541 error = xfs_rtallocate_extent_block(mp, tp,
542 bbno + i, minlen, maxlen, len, &n, rbpp,
543 rsb, prod, &r);
544 if (error) {
545 return error;
546 }
547
548
549
550 if (r != NULLRTBLOCK) {
551 *rtblock = r;
552 return 0;
553 }
554 }
555 }
556
557
558
559
560 if (i > 0 && (int)bbno - i >= 0)
561 i = -i;
562
563
564
565
566 else if (i > 0 && (int)bbno + i < mp->m_sb.sb_rbmblocks - 1)
567 i++;
568
569
570
571
572 else if (i <= 0 && (int)bbno - i < mp->m_sb.sb_rbmblocks - 1)
573 i = 1 - i;
574
575
576
577
578 else if (i <= 0 && (int)bbno + i > 0)
579 i--;
580
581
582
583 else
584 break;
585 }
586 *rtblock = NULLRTBLOCK;
587 return 0;
588}
589
590
591
592
593
594
595STATIC int
596xfs_rtallocate_extent_size(
597 xfs_mount_t *mp,
598 xfs_trans_t *tp,
599 xfs_extlen_t minlen,
600 xfs_extlen_t maxlen,
601 xfs_extlen_t *len,
602 xfs_buf_t **rbpp,
603 xfs_fsblock_t *rsb,
604 xfs_extlen_t prod,
605 xfs_rtblock_t *rtblock)
606{
607 int error;
608 int i;
609 int l;
610 xfs_rtblock_t n;
611 xfs_rtblock_t r;
612 xfs_suminfo_t sum;
613
614 ASSERT(minlen % prod == 0 && maxlen % prod == 0);
615
616
617
618
619
620
621
622 for (l = xfs_highbit32(maxlen); l < mp->m_rsumlevels; l++) {
623
624
625
626 for (i = 0; i < mp->m_sb.sb_rbmblocks; i++) {
627
628
629
630 error = xfs_rtget_summary(mp, tp, l, i, rbpp, rsb,
631 &sum);
632 if (error) {
633 return error;
634 }
635
636
637
638 if (!sum)
639 continue;
640
641
642
643 error = xfs_rtallocate_extent_block(mp, tp, i, maxlen,
644 maxlen, len, &n, rbpp, rsb, prod, &r);
645 if (error) {
646 return error;
647 }
648
649
650
651 if (r != NULLRTBLOCK) {
652 *rtblock = r;
653 return 0;
654 }
655
656
657
658
659
660 if (XFS_BITTOBLOCK(mp, n) > i + 1)
661 i = XFS_BITTOBLOCK(mp, n) - 1;
662 }
663 }
664
665
666
667
668 if (minlen > --maxlen) {
669 *rtblock = NULLRTBLOCK;
670 return 0;
671 }
672
673
674
675
676
677 for (l = xfs_highbit32(maxlen); l >= xfs_highbit32(minlen); l--) {
678
679
680
681
682 for (i = 0; i < mp->m_sb.sb_rbmblocks; i++) {
683
684
685
686 error = xfs_rtget_summary(mp, tp, l, i, rbpp, rsb,
687 &sum);
688 if (error) {
689 return error;
690 }
691
692
693
694 if (!sum)
695 continue;
696
697
698
699
700
701 error = xfs_rtallocate_extent_block(mp, tp, i,
702 XFS_RTMAX(minlen, 1 << l),
703 XFS_RTMIN(maxlen, (1 << (l + 1)) - 1),
704 len, &n, rbpp, rsb, prod, &r);
705 if (error) {
706 return error;
707 }
708
709
710
711 if (r != NULLRTBLOCK) {
712 *rtblock = r;
713 return 0;
714 }
715
716
717
718
719
720 if (XFS_BITTOBLOCK(mp, n) > i + 1)
721 i = XFS_BITTOBLOCK(mp, n) - 1;
722 }
723 }
724
725
726
727 *rtblock = NULLRTBLOCK;
728 return 0;
729}
730
731
732
733
734
735STATIC int
736xfs_rtallocate_range(
737 xfs_mount_t *mp,
738 xfs_trans_t *tp,
739 xfs_rtblock_t start,
740 xfs_extlen_t len,
741 xfs_buf_t **rbpp,
742 xfs_fsblock_t *rsb)
743{
744 xfs_rtblock_t end;
745 int error;
746 xfs_rtblock_t postblock;
747 xfs_rtblock_t preblock;
748
749 end = start + len - 1;
750
751
752
753
754
755 error = xfs_rtfind_back(mp, tp, start, 0, &preblock);
756 if (error) {
757 return error;
758 }
759
760
761
762 error = xfs_rtfind_forw(mp, tp, end, mp->m_sb.sb_rextents - 1,
763 &postblock);
764 if (error) {
765 return error;
766 }
767
768
769
770
771 error = xfs_rtmodify_summary(mp, tp,
772 XFS_RTBLOCKLOG(postblock + 1 - preblock),
773 XFS_BITTOBLOCK(mp, preblock), -1, rbpp, rsb);
774 if (error) {
775 return error;
776 }
777
778
779
780
781 if (preblock < start) {
782 error = xfs_rtmodify_summary(mp, tp,
783 XFS_RTBLOCKLOG(start - preblock),
784 XFS_BITTOBLOCK(mp, preblock), 1, rbpp, rsb);
785 if (error) {
786 return error;
787 }
788 }
789
790
791
792
793 if (postblock > end) {
794 error = xfs_rtmodify_summary(mp, tp,
795 XFS_RTBLOCKLOG(postblock - end),
796 XFS_BITTOBLOCK(mp, end + 1), 1, rbpp, rsb);
797 if (error) {
798 return error;
799 }
800 }
801
802
803
804 error = xfs_rtmodify_range(mp, tp, start, len, 0);
805 return error;
806}
807
808
809
810
811
812STATIC int
813xfs_rtany_summary(
814 xfs_mount_t *mp,
815 xfs_trans_t *tp,
816 int low,
817 int high,
818 xfs_rtblock_t bbno,
819 xfs_buf_t **rbpp,
820 xfs_fsblock_t *rsb,
821 int *stat)
822{
823 int error;
824 int log;
825 xfs_suminfo_t sum;
826
827
828
829
830 for (log = low; log <= high; log++) {
831
832
833
834 error = xfs_rtget_summary(mp, tp, log, bbno, rbpp, rsb, &sum);
835 if (error) {
836 return error;
837 }
838
839
840
841 if (sum) {
842 *stat = 1;
843 return 0;
844 }
845 }
846
847
848
849 *stat = 0;
850 return 0;
851}
852
853
854
855
856
857STATIC int
858xfs_rtbuf_get(
859 xfs_mount_t *mp,
860 xfs_trans_t *tp,
861 xfs_rtblock_t block,
862 int issum,
863 xfs_buf_t **bpp)
864{
865 xfs_buf_t *bp;
866 xfs_daddr_t d;
867 int error;
868 xfs_fsblock_t fsb;
869 xfs_inode_t *ip;
870
871 ip = issum ? mp->m_rsumip : mp->m_rbmip;
872
873
874
875
876 error = xfs_bmapi_single(tp, ip, XFS_DATA_FORK, &fsb, block);
877 if (error) {
878 return error;
879 }
880 ASSERT(fsb != NULLFSBLOCK);
881
882
883
884 d = XFS_FSB_TO_DADDR(mp, fsb);
885
886
887
888 error = xfs_trans_read_buf(mp, tp, mp->m_ddev_targp, d,
889 mp->m_bsize, 0, &bp);
890 if (error) {
891 return error;
892 }
893 ASSERT(bp && !XFS_BUF_GETERROR(bp));
894 *bpp = bp;
895 return 0;
896}
897
898#ifdef DEBUG
899
900
901
902STATIC int
903xfs_rtcheck_alloc_range(
904 xfs_mount_t *mp,
905 xfs_trans_t *tp,
906 xfs_rtblock_t bno,
907 xfs_extlen_t len,
908 int *stat)
909{
910 xfs_rtblock_t new;
911
912 return xfs_rtcheck_range(mp, tp, bno, len, 0, &new, stat);
913}
914#endif
915
916#ifdef DEBUG
917
918
919
920STATIC int
921xfs_rtcheck_bit(
922 xfs_mount_t *mp,
923 xfs_trans_t *tp,
924 xfs_rtblock_t start,
925 int val)
926{
927 int bit;
928 xfs_rtblock_t block;
929 xfs_buf_t *bp;
930 xfs_rtword_t *bufp;
931
932 int error;
933 xfs_rtword_t wdiff;
934 int word;
935 xfs_rtword_t wval;
936
937 block = XFS_BITTOBLOCK(mp, start);
938 error = xfs_rtbuf_get(mp, tp, block, 0, &bp);
939 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
940 word = XFS_BITTOWORD(mp, start);
941 bit = (int)(start & (XFS_NBWORD - 1));
942 wval = bufp[word];
943 xfs_trans_brelse(tp, bp);
944 wdiff = (wval ^ -val) & ((xfs_rtword_t)1 << bit);
945 return !wdiff;
946}
947#endif
948
949#if 0
950
951
952
953STATIC int
954xfs_rtcheck_free_range(
955 xfs_mount_t *mp,
956 xfs_trans_t *tp,
957 xfs_rtblock_t bno,
958 xfs_extlen_t len,
959 int *stat)
960{
961 xfs_rtblock_t new;
962
963 return xfs_rtcheck_range(mp, tp, bno, len, 1, &new, stat);
964}
965#endif
966
967
968
969
970
971STATIC int
972xfs_rtcheck_range(
973 xfs_mount_t *mp,
974 xfs_trans_t *tp,
975 xfs_rtblock_t start,
976 xfs_extlen_t len,
977 int val,
978 xfs_rtblock_t *new,
979 int *stat)
980{
981 xfs_rtword_t *b;
982 int bit;
983 xfs_rtblock_t block;
984 xfs_buf_t *bp;
985 xfs_rtword_t *bufp;
986 int error;
987 xfs_rtblock_t i;
988 xfs_rtblock_t lastbit;
989 xfs_rtword_t mask;
990 xfs_rtword_t wdiff;
991 int word;
992
993
994
995
996 block = XFS_BITTOBLOCK(mp, start);
997
998
999
1000 error = xfs_rtbuf_get(mp, tp, block, 0, &bp);
1001 if (error) {
1002 return error;
1003 }
1004 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1005
1006
1007
1008 word = XFS_BITTOWORD(mp, start);
1009 b = &bufp[word];
1010 bit = (int)(start & (XFS_NBWORD - 1));
1011
1012
1013
1014 val = -val;
1015
1016
1017
1018
1019 if (bit) {
1020
1021
1022
1023 lastbit = XFS_RTMIN(bit + len, XFS_NBWORD);
1024
1025
1026
1027 mask = (((xfs_rtword_t)1 << (lastbit - bit)) - 1) << bit;
1028
1029
1030
1031 if ((wdiff = (*b ^ val) & mask)) {
1032
1033
1034
1035 xfs_trans_brelse(tp, bp);
1036 i = XFS_RTLOBIT(wdiff) - bit;
1037 *new = start + i;
1038 *stat = 0;
1039 return 0;
1040 }
1041 i = lastbit - bit;
1042
1043
1044
1045
1046 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1047
1048
1049
1050 xfs_trans_brelse(tp, bp);
1051 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1052 if (error) {
1053 return error;
1054 }
1055 b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1056 word = 0;
1057 } else {
1058
1059
1060
1061 b++;
1062 }
1063 } else {
1064
1065
1066
1067 i = 0;
1068 }
1069
1070
1071
1072
1073 while (len - i >= XFS_NBWORD) {
1074
1075
1076
1077 if ((wdiff = *b ^ val)) {
1078
1079
1080
1081 xfs_trans_brelse(tp, bp);
1082 i += XFS_RTLOBIT(wdiff);
1083 *new = start + i;
1084 *stat = 0;
1085 return 0;
1086 }
1087 i += XFS_NBWORD;
1088
1089
1090
1091
1092 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1093
1094
1095
1096 xfs_trans_brelse(tp, bp);
1097 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1098 if (error) {
1099 return error;
1100 }
1101 b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1102 word = 0;
1103 } else {
1104
1105
1106
1107 b++;
1108 }
1109 }
1110
1111
1112
1113
1114 if ((lastbit = len - i)) {
1115
1116
1117
1118 mask = ((xfs_rtword_t)1 << lastbit) - 1;
1119
1120
1121
1122 if ((wdiff = (*b ^ val) & mask)) {
1123
1124
1125
1126 xfs_trans_brelse(tp, bp);
1127 i += XFS_RTLOBIT(wdiff);
1128 *new = start + i;
1129 *stat = 0;
1130 return 0;
1131 } else
1132 i = len;
1133 }
1134
1135
1136
1137 xfs_trans_brelse(tp, bp);
1138 *new = start + i;
1139 *stat = 1;
1140 return 0;
1141}
1142
1143
1144
1145
1146
1147STATIC int
1148xfs_rtcopy_summary(
1149 xfs_mount_t *omp,
1150 xfs_mount_t *nmp,
1151 xfs_trans_t *tp)
1152{
1153 xfs_rtblock_t bbno;
1154 xfs_buf_t *bp;
1155 int error;
1156 int log;
1157 xfs_suminfo_t sum;
1158 xfs_fsblock_t sumbno;
1159
1160 bp = NULL;
1161 for (log = omp->m_rsumlevels - 1; log >= 0; log--) {
1162 for (bbno = omp->m_sb.sb_rbmblocks - 1;
1163 (xfs_srtblock_t)bbno >= 0;
1164 bbno--) {
1165 error = xfs_rtget_summary(omp, tp, log, bbno, &bp,
1166 &sumbno, &sum);
1167 if (error)
1168 return error;
1169 if (sum == 0)
1170 continue;
1171 error = xfs_rtmodify_summary(omp, tp, log, bbno, -sum,
1172 &bp, &sumbno);
1173 if (error)
1174 return error;
1175 error = xfs_rtmodify_summary(nmp, tp, log, bbno, sum,
1176 &bp, &sumbno);
1177 if (error)
1178 return error;
1179 ASSERT(sum > 0);
1180 }
1181 }
1182 return 0;
1183}
1184
1185
1186
1187
1188
1189STATIC int
1190xfs_rtfind_back(
1191 xfs_mount_t *mp,
1192 xfs_trans_t *tp,
1193 xfs_rtblock_t start,
1194 xfs_rtblock_t limit,
1195 xfs_rtblock_t *rtblock)
1196{
1197 xfs_rtword_t *b;
1198 int bit;
1199 xfs_rtblock_t block;
1200 xfs_buf_t *bp;
1201 xfs_rtword_t *bufp;
1202 int error;
1203 xfs_rtblock_t firstbit;
1204 xfs_rtblock_t i;
1205 xfs_rtblock_t len;
1206 xfs_rtword_t mask;
1207 xfs_rtword_t want;
1208 xfs_rtword_t wdiff;
1209 int word;
1210
1211
1212
1213
1214 block = XFS_BITTOBLOCK(mp, start);
1215 error = xfs_rtbuf_get(mp, tp, block, 0, &bp);
1216 if (error) {
1217 return error;
1218 }
1219 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1220
1221
1222
1223 word = XFS_BITTOWORD(mp, start);
1224 b = &bufp[word];
1225 bit = (int)(start & (XFS_NBWORD - 1));
1226 len = start - limit + 1;
1227
1228
1229
1230
1231 want = (*b & ((xfs_rtword_t)1 << bit)) ? -1 : 0;
1232
1233
1234
1235
1236 if (bit < XFS_NBWORD - 1) {
1237
1238
1239
1240
1241 firstbit = XFS_RTMAX((xfs_srtblock_t)(bit - len + 1), 0);
1242 mask = (((xfs_rtword_t)1 << (bit - firstbit + 1)) - 1) <<
1243 firstbit;
1244
1245
1246
1247
1248 if ((wdiff = (*b ^ want) & mask)) {
1249
1250
1251
1252 xfs_trans_brelse(tp, bp);
1253 i = bit - XFS_RTHIBIT(wdiff);
1254 *rtblock = start - i + 1;
1255 return 0;
1256 }
1257 i = bit - firstbit + 1;
1258
1259
1260
1261
1262 if (--word == -1 && i < len) {
1263
1264
1265
1266 xfs_trans_brelse(tp, bp);
1267 error = xfs_rtbuf_get(mp, tp, --block, 0, &bp);
1268 if (error) {
1269 return error;
1270 }
1271 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1272 word = XFS_BLOCKWMASK(mp);
1273 b = &bufp[word];
1274 } else {
1275
1276
1277
1278 b--;
1279 }
1280 } else {
1281
1282
1283
1284 i = 0;
1285 }
1286
1287
1288
1289
1290 while (len - i >= XFS_NBWORD) {
1291
1292
1293
1294 if ((wdiff = *b ^ want)) {
1295
1296
1297
1298 xfs_trans_brelse(tp, bp);
1299 i += XFS_NBWORD - 1 - XFS_RTHIBIT(wdiff);
1300 *rtblock = start - i + 1;
1301 return 0;
1302 }
1303 i += XFS_NBWORD;
1304
1305
1306
1307
1308 if (--word == -1 && i < len) {
1309
1310
1311
1312 xfs_trans_brelse(tp, bp);
1313 error = xfs_rtbuf_get(mp, tp, --block, 0, &bp);
1314 if (error) {
1315 return error;
1316 }
1317 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1318 word = XFS_BLOCKWMASK(mp);
1319 b = &bufp[word];
1320 } else {
1321
1322
1323
1324 b--;
1325 }
1326 }
1327
1328
1329
1330
1331 if (len - i) {
1332
1333
1334
1335
1336 firstbit = XFS_NBWORD - (len - i);
1337 mask = (((xfs_rtword_t)1 << (len - i)) - 1) << firstbit;
1338
1339
1340
1341 if ((wdiff = (*b ^ want) & mask)) {
1342
1343
1344
1345 xfs_trans_brelse(tp, bp);
1346 i += XFS_NBWORD - 1 - XFS_RTHIBIT(wdiff);
1347 *rtblock = start - i + 1;
1348 return 0;
1349 } else
1350 i = len;
1351 }
1352
1353
1354
1355 xfs_trans_brelse(tp, bp);
1356 *rtblock = start - i + 1;
1357 return 0;
1358}
1359
1360
1361
1362
1363
1364STATIC int
1365xfs_rtfind_forw(
1366 xfs_mount_t *mp,
1367 xfs_trans_t *tp,
1368 xfs_rtblock_t start,
1369 xfs_rtblock_t limit,
1370 xfs_rtblock_t *rtblock)
1371{
1372 xfs_rtword_t *b;
1373 int bit;
1374 xfs_rtblock_t block;
1375 xfs_buf_t *bp;
1376 xfs_rtword_t *bufp;
1377 int error;
1378 xfs_rtblock_t i;
1379 xfs_rtblock_t lastbit;
1380 xfs_rtblock_t len;
1381 xfs_rtword_t mask;
1382 xfs_rtword_t want;
1383 xfs_rtword_t wdiff;
1384 int word;
1385
1386
1387
1388
1389 block = XFS_BITTOBLOCK(mp, start);
1390 error = xfs_rtbuf_get(mp, tp, block, 0, &bp);
1391 if (error) {
1392 return error;
1393 }
1394 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1395
1396
1397
1398 word = XFS_BITTOWORD(mp, start);
1399 b = &bufp[word];
1400 bit = (int)(start & (XFS_NBWORD - 1));
1401 len = limit - start + 1;
1402
1403
1404
1405
1406 want = (*b & ((xfs_rtword_t)1 << bit)) ? -1 : 0;
1407
1408
1409
1410
1411 if (bit) {
1412
1413
1414
1415
1416 lastbit = XFS_RTMIN(bit + len, XFS_NBWORD);
1417 mask = (((xfs_rtword_t)1 << (lastbit - bit)) - 1) << bit;
1418
1419
1420
1421
1422 if ((wdiff = (*b ^ want) & mask)) {
1423
1424
1425
1426 xfs_trans_brelse(tp, bp);
1427 i = XFS_RTLOBIT(wdiff) - bit;
1428 *rtblock = start + i - 1;
1429 return 0;
1430 }
1431 i = lastbit - bit;
1432
1433
1434
1435
1436 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1437
1438
1439
1440 xfs_trans_brelse(tp, bp);
1441 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1442 if (error) {
1443 return error;
1444 }
1445 b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1446 word = 0;
1447 } else {
1448
1449
1450
1451 b++;
1452 }
1453 } else {
1454
1455
1456
1457 i = 0;
1458 }
1459
1460
1461
1462
1463 while (len - i >= XFS_NBWORD) {
1464
1465
1466
1467 if ((wdiff = *b ^ want)) {
1468
1469
1470
1471 xfs_trans_brelse(tp, bp);
1472 i += XFS_RTLOBIT(wdiff);
1473 *rtblock = start + i - 1;
1474 return 0;
1475 }
1476 i += XFS_NBWORD;
1477
1478
1479
1480
1481 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1482
1483
1484
1485 xfs_trans_brelse(tp, bp);
1486 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1487 if (error) {
1488 return error;
1489 }
1490 b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1491 word = 0;
1492 } else {
1493
1494
1495
1496 b++;
1497 }
1498 }
1499
1500
1501
1502
1503 if ((lastbit = len - i)) {
1504
1505
1506
1507 mask = ((xfs_rtword_t)1 << lastbit) - 1;
1508
1509
1510
1511 if ((wdiff = (*b ^ want) & mask)) {
1512
1513
1514
1515 xfs_trans_brelse(tp, bp);
1516 i += XFS_RTLOBIT(wdiff);
1517 *rtblock = start + i - 1;
1518 return 0;
1519 } else
1520 i = len;
1521 }
1522
1523
1524
1525 xfs_trans_brelse(tp, bp);
1526 *rtblock = start + i - 1;
1527 return 0;
1528}
1529
1530
1531
1532
1533
1534STATIC int
1535xfs_rtfree_range(
1536 xfs_mount_t *mp,
1537 xfs_trans_t *tp,
1538 xfs_rtblock_t start,
1539 xfs_extlen_t len,
1540 xfs_buf_t **rbpp,
1541 xfs_fsblock_t *rsb)
1542{
1543 xfs_rtblock_t end;
1544 int error;
1545 xfs_rtblock_t postblock;
1546 xfs_rtblock_t preblock;
1547
1548 end = start + len - 1;
1549
1550
1551
1552 error = xfs_rtmodify_range(mp, tp, start, len, 1);
1553 if (error) {
1554 return error;
1555 }
1556
1557
1558
1559
1560
1561 error = xfs_rtfind_back(mp, tp, start, 0, &preblock);
1562 if (error) {
1563 return error;
1564 }
1565
1566
1567
1568 error = xfs_rtfind_forw(mp, tp, end, mp->m_sb.sb_rextents - 1,
1569 &postblock);
1570
1571
1572
1573
1574 if (preblock < start) {
1575 error = xfs_rtmodify_summary(mp, tp,
1576 XFS_RTBLOCKLOG(start - preblock),
1577 XFS_BITTOBLOCK(mp, preblock), -1, rbpp, rsb);
1578 if (error) {
1579 return error;
1580 }
1581 }
1582
1583
1584
1585
1586 if (postblock > end) {
1587 error = xfs_rtmodify_summary(mp, tp,
1588 XFS_RTBLOCKLOG(postblock - end),
1589 XFS_BITTOBLOCK(mp, end + 1), -1, rbpp, rsb);
1590 if (error) {
1591 return error;
1592 }
1593 }
1594
1595
1596
1597
1598 error = xfs_rtmodify_summary(mp, tp,
1599 XFS_RTBLOCKLOG(postblock + 1 - preblock),
1600 XFS_BITTOBLOCK(mp, preblock), 1, rbpp, rsb);
1601 return error;
1602}
1603
1604
1605
1606
1607
1608
1609
1610STATIC int
1611xfs_rtget_summary(
1612 xfs_mount_t *mp,
1613 xfs_trans_t *tp,
1614 int log,
1615 xfs_rtblock_t bbno,
1616 xfs_buf_t **rbpp,
1617 xfs_fsblock_t *rsb,
1618 xfs_suminfo_t *sum)
1619{
1620 xfs_buf_t *bp;
1621 int error;
1622 xfs_fsblock_t sb;
1623 int so;
1624 xfs_suminfo_t *sp;
1625
1626
1627
1628
1629 so = XFS_SUMOFFS(mp, log, bbno);
1630
1631
1632
1633 sb = XFS_SUMOFFSTOBLOCK(mp, so);
1634
1635
1636
1637 if (rbpp && *rbpp && *rsb == sb)
1638 bp = *rbpp;
1639
1640
1641
1642 else {
1643
1644
1645
1646 if (rbpp && *rbpp)
1647 xfs_trans_brelse(tp, *rbpp);
1648 error = xfs_rtbuf_get(mp, tp, sb, 1, &bp);
1649 if (error) {
1650 return error;
1651 }
1652
1653
1654
1655 if (rbpp) {
1656 *rbpp = bp;
1657 *rsb = sb;
1658 }
1659 }
1660
1661
1662
1663 sp = XFS_SUMPTR(mp, bp, so);
1664 *sum = *sp;
1665
1666
1667
1668 if (!rbpp)
1669 xfs_trans_brelse(tp, bp);
1670 return 0;
1671}
1672
1673
1674
1675
1676
1677STATIC int
1678xfs_rtmodify_range(
1679 xfs_mount_t *mp,
1680 xfs_trans_t *tp,
1681 xfs_rtblock_t start,
1682 xfs_extlen_t len,
1683 int val)
1684{
1685 xfs_rtword_t *b;
1686 int bit;
1687 xfs_rtblock_t block;
1688 xfs_buf_t *bp;
1689 xfs_rtword_t *bufp;
1690 int error;
1691 xfs_rtword_t *first;
1692 int i;
1693 int lastbit;
1694 xfs_rtword_t mask;
1695 int word;
1696
1697
1698
1699
1700 block = XFS_BITTOBLOCK(mp, start);
1701
1702
1703
1704 error = xfs_rtbuf_get(mp, tp, block, 0, &bp);
1705 if (error) {
1706 return error;
1707 }
1708 bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1709
1710
1711
1712 word = XFS_BITTOWORD(mp, start);
1713 first = b = &bufp[word];
1714 bit = (int)(start & (XFS_NBWORD - 1));
1715
1716
1717
1718 val = -val;
1719
1720
1721
1722
1723 if (bit) {
1724
1725
1726
1727 lastbit = XFS_RTMIN(bit + len, XFS_NBWORD);
1728 mask = (((xfs_rtword_t)1 << (lastbit - bit)) - 1) << bit;
1729
1730
1731
1732 if (val)
1733 *b |= mask;
1734 else
1735 *b &= ~mask;
1736 i = lastbit - bit;
1737
1738
1739
1740
1741 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1742
1743
1744
1745
1746 xfs_trans_log_buf(tp, bp,
1747 (uint)((char *)first - (char *)bufp),
1748 (uint)((char *)b - (char *)bufp));
1749 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1750 if (error) {
1751 return error;
1752 }
1753 first = b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1754 word = 0;
1755 } else {
1756
1757
1758
1759 b++;
1760 }
1761 } else {
1762
1763
1764
1765 i = 0;
1766 }
1767
1768
1769
1770
1771 while (len - i >= XFS_NBWORD) {
1772
1773
1774
1775 *b = val;
1776 i += XFS_NBWORD;
1777
1778
1779
1780
1781 if (++word == XFS_BLOCKWSIZE(mp) && i < len) {
1782
1783
1784
1785
1786 xfs_trans_log_buf(tp, bp,
1787 (uint)((char *)first - (char *)bufp),
1788 (uint)((char *)b - (char *)bufp));
1789 error = xfs_rtbuf_get(mp, tp, ++block, 0, &bp);
1790 if (error) {
1791 return error;
1792 }
1793 first = b = bufp = (xfs_rtword_t *)XFS_BUF_PTR(bp);
1794 word = 0;
1795 } else {
1796
1797
1798
1799 b++;
1800 }
1801 }
1802
1803
1804
1805
1806 if ((lastbit = len - i)) {
1807
1808
1809
1810 bit = 0;
1811 mask = ((xfs_rtword_t)1 << lastbit) - 1;
1812
1813
1814
1815 if (val)
1816 *b |= mask;
1817 else
1818 *b &= ~mask;
1819 b++;
1820 }
1821
1822
1823
1824 if (b > first)
1825 xfs_trans_log_buf(tp, bp, (uint)((char *)first - (char *)bufp),
1826 (uint)((char *)b - (char *)bufp - 1));
1827 return 0;
1828}
1829
1830
1831
1832
1833
1834
1835
1836STATIC int
1837xfs_rtmodify_summary(
1838 xfs_mount_t *mp,
1839 xfs_trans_t *tp,
1840 int log,
1841 xfs_rtblock_t bbno,
1842 int delta,
1843 xfs_buf_t **rbpp,
1844 xfs_fsblock_t *rsb)
1845{
1846 xfs_buf_t *bp;
1847 int error;
1848 xfs_fsblock_t sb;
1849 int so;
1850 xfs_suminfo_t *sp;
1851
1852
1853
1854
1855 so = XFS_SUMOFFS(mp, log, bbno);
1856
1857
1858
1859 sb = XFS_SUMOFFSTOBLOCK(mp, so);
1860
1861
1862
1863 if (rbpp && *rbpp && *rsb == sb)
1864 bp = *rbpp;
1865
1866
1867
1868 else {
1869
1870
1871
1872 if (rbpp && *rbpp)
1873 xfs_trans_brelse(tp, *rbpp);
1874 error = xfs_rtbuf_get(mp, tp, sb, 1, &bp);
1875 if (error) {
1876 return error;
1877 }
1878
1879
1880
1881 if (rbpp) {
1882 *rbpp = bp;
1883 *rsb = sb;
1884 }
1885 }
1886
1887
1888
1889 sp = XFS_SUMPTR(mp, bp, so);
1890 *sp += delta;
1891 xfs_trans_log_buf(tp, bp, (uint)((char *)sp - (char *)XFS_BUF_PTR(bp)),
1892 (uint)((char *)sp - (char *)XFS_BUF_PTR(bp) + sizeof(*sp) - 1));
1893 return 0;
1894}
1895
1896
1897
1898
1899
1900
1901
1902
1903int
1904xfs_growfs_rt(
1905 xfs_mount_t *mp,
1906 xfs_growfs_rt_t *in)
1907{
1908 xfs_rtblock_t bmbno;
1909 xfs_buf_t *bp;
1910 int cancelflags;
1911 int error;
1912 xfs_inode_t *ip;
1913 xfs_mount_t *nmp;
1914 xfs_drfsbno_t nrblocks;
1915 xfs_extlen_t nrbmblocks;
1916 xfs_drtbno_t nrextents;
1917 uint8_t nrextslog;
1918 xfs_extlen_t nrsumblocks;
1919 uint nrsumlevels;
1920 uint nrsumsize;
1921 xfs_sb_t *nsbp;
1922 xfs_extlen_t rbmblocks;
1923 xfs_extlen_t rsumblocks;
1924 xfs_sb_t *sbp;
1925 xfs_fsblock_t sumbno;
1926 xfs_trans_t *tp;
1927
1928 sbp = &mp->m_sb;
1929
1930
1931
1932 if (mp->m_rtdev_targp == NULL || mp->m_rbmip == NULL ||
1933 (nrblocks = in->newblocks) <= sbp->sb_rblocks ||
1934 (sbp->sb_rblocks && (in->extsize != sbp->sb_rextsize)))
1935 return XFS_ERROR(EINVAL);
1936
1937
1938
1939 error = xfs_read_buf(mp, mp->m_rtdev_targp,
1940 XFS_FSB_TO_BB(mp, in->newblocks - 1),
1941 XFS_FSB_TO_BB(mp, 1), 0, &bp);
1942 if (error)
1943 return error;
1944 ASSERT(bp);
1945 xfs_buf_relse(bp);
1946
1947
1948
1949 nrextents = nrblocks;
1950 do_div(nrextents, in->extsize);
1951 nrbmblocks = howmany_64(nrextents, NBBY * sbp->sb_blocksize);
1952 nrextslog = xfs_highbit32(nrextents);
1953 nrsumlevels = nrextslog + 1;
1954 nrsumsize = (uint)sizeof(xfs_suminfo_t) * nrsumlevels * nrbmblocks;
1955 nrsumblocks = XFS_B_TO_FSB(mp, nrsumsize);
1956 nrsumsize = XFS_FSB_TO_B(mp, nrsumblocks);
1957
1958
1959
1960
1961
1962 if (nrsumblocks > (mp->m_sb.sb_logblocks >> 1))
1963 return XFS_ERROR(EINVAL);
1964
1965
1966
1967
1968 rbmblocks = XFS_B_TO_FSB(mp, mp->m_rbmip->i_d.di_size);
1969 rsumblocks = XFS_B_TO_FSB(mp, mp->m_rsumip->i_d.di_size);
1970
1971
1972
1973 if ((error = xfs_growfs_rt_alloc(mp, rbmblocks, nrbmblocks,
1974 mp->m_sb.sb_rbmino)))
1975 return error;
1976 if ((error = xfs_growfs_rt_alloc(mp, rsumblocks, nrsumblocks,
1977 mp->m_sb.sb_rsumino)))
1978 return error;
1979
1980
1981
1982 nmp = kmem_alloc(sizeof(*nmp), KM_SLEEP);
1983
1984
1985
1986
1987
1988
1989 for (bmbno = sbp->sb_rbmblocks -
1990 ((sbp->sb_rextents & ((1 << mp->m_blkbit_log) - 1)) != 0);
1991 bmbno < nrbmblocks;
1992 bmbno++) {
1993 *nmp = *mp;
1994 nsbp = &nmp->m_sb;
1995
1996
1997
1998 nsbp->sb_rextsize = in->extsize;
1999 nsbp->sb_rbmblocks = bmbno + 1;
2000 nsbp->sb_rblocks =
2001 XFS_RTMIN(nrblocks,
2002 nsbp->sb_rbmblocks * NBBY *
2003 nsbp->sb_blocksize * nsbp->sb_rextsize);
2004 nsbp->sb_rextents = nsbp->sb_rblocks;
2005 do_div(nsbp->sb_rextents, nsbp->sb_rextsize);
2006 nsbp->sb_rextslog = xfs_highbit32(nsbp->sb_rextents);
2007 nrsumlevels = nmp->m_rsumlevels = nsbp->sb_rextslog + 1;
2008 nrsumsize =
2009 (uint)sizeof(xfs_suminfo_t) * nrsumlevels *
2010 nsbp->sb_rbmblocks;
2011 nrsumblocks = XFS_B_TO_FSB(mp, nrsumsize);
2012 nmp->m_rsumsize = nrsumsize = XFS_FSB_TO_B(mp, nrsumblocks);
2013
2014
2015
2016 tp = xfs_trans_alloc(mp, XFS_TRANS_GROWFSRT_FREE);
2017 cancelflags = 0;
2018 if ((error = xfs_trans_reserve(tp, 0,
2019 XFS_GROWRTFREE_LOG_RES(nmp), 0, 0, 0)))
2020 break;
2021
2022
2023
2024 if ((error = xfs_trans_iget(mp, tp, mp->m_sb.sb_rbmino, 0,
2025 XFS_ILOCK_EXCL, &ip)))
2026 break;
2027 ASSERT(ip == mp->m_rbmip);
2028
2029
2030
2031 mp->m_rbmip->i_d.di_size =
2032 nsbp->sb_rbmblocks * nsbp->sb_blocksize;
2033 xfs_trans_log_inode(tp, mp->m_rbmip, XFS_ILOG_CORE);
2034 cancelflags |= XFS_TRANS_ABORT;
2035
2036
2037
2038 if ((error = xfs_trans_iget(mp, tp, mp->m_sb.sb_rsumino, 0,
2039 XFS_ILOCK_EXCL, &ip)))
2040 break;
2041 ASSERT(ip == mp->m_rsumip);
2042
2043
2044
2045 mp->m_rsumip->i_d.di_size = nmp->m_rsumsize;
2046 xfs_trans_log_inode(tp, mp->m_rsumip, XFS_ILOG_CORE);
2047
2048
2049
2050
2051 if (sbp->sb_rbmblocks != nsbp->sb_rbmblocks ||
2052 mp->m_rsumlevels != nmp->m_rsumlevels) {
2053 error = xfs_rtcopy_summary(mp, nmp, tp);
2054 if (error)
2055 break;
2056 }
2057
2058
2059
2060 if (nsbp->sb_rextsize != sbp->sb_rextsize)
2061 xfs_trans_mod_sb(tp, XFS_TRANS_SB_REXTSIZE,
2062 nsbp->sb_rextsize - sbp->sb_rextsize);
2063 if (nsbp->sb_rbmblocks != sbp->sb_rbmblocks)
2064 xfs_trans_mod_sb(tp, XFS_TRANS_SB_RBMBLOCKS,
2065 nsbp->sb_rbmblocks - sbp->sb_rbmblocks);
2066 if (nsbp->sb_rblocks != sbp->sb_rblocks)
2067 xfs_trans_mod_sb(tp, XFS_TRANS_SB_RBLOCKS,
2068 nsbp->sb_rblocks - sbp->sb_rblocks);
2069 if (nsbp->sb_rextents != sbp->sb_rextents)
2070 xfs_trans_mod_sb(tp, XFS_TRANS_SB_REXTENTS,
2071 nsbp->sb_rextents - sbp->sb_rextents);
2072 if (nsbp->sb_rextslog != sbp->sb_rextslog)
2073 xfs_trans_mod_sb(tp, XFS_TRANS_SB_REXTSLOG,
2074 nsbp->sb_rextslog - sbp->sb_rextslog);
2075
2076
2077
2078 bp = NULL;
2079 error = xfs_rtfree_range(nmp, tp, sbp->sb_rextents,
2080 nsbp->sb_rextents - sbp->sb_rextents, &bp, &sumbno);
2081 if (error)
2082 break;
2083
2084
2085
2086 xfs_trans_mod_sb(tp, XFS_TRANS_SB_FREXTENTS,
2087 nsbp->sb_rextents - sbp->sb_rextents);
2088
2089
2090
2091 mp->m_rsumlevels = nrsumlevels;
2092 mp->m_rsumsize = nrsumsize;
2093
2094
2095
2096 xfs_trans_commit(tp, 0, NULL);
2097 }
2098
2099 if (error)
2100 xfs_trans_cancel(tp, cancelflags);
2101
2102
2103
2104
2105 kmem_free(nmp, sizeof(*nmp));
2106
2107 return error;
2108}
2109
2110
2111
2112
2113
2114
2115int
2116xfs_rtallocate_extent(
2117 xfs_trans_t *tp,
2118 xfs_rtblock_t bno,
2119 xfs_extlen_t minlen,
2120 xfs_extlen_t maxlen,
2121 xfs_extlen_t *len,
2122 xfs_alloctype_t type,
2123 int wasdel,
2124 xfs_extlen_t prod,
2125 xfs_rtblock_t *rtblock)
2126{
2127 int error;
2128 xfs_inode_t *ip;
2129 xfs_mount_t *mp;
2130 xfs_rtblock_t r;
2131 xfs_fsblock_t sb;
2132 xfs_buf_t *sumbp;
2133
2134 ASSERT(minlen > 0 && minlen <= maxlen);
2135 mp = tp->t_mountp;
2136
2137
2138
2139 if (prod > 1) {
2140 xfs_extlen_t i;
2141
2142 if ((i = maxlen % prod))
2143 maxlen -= i;
2144 if ((i = minlen % prod))
2145 minlen += prod - i;
2146 if (maxlen < minlen) {
2147 *rtblock = NULLRTBLOCK;
2148 return 0;
2149 }
2150 }
2151
2152
2153
2154 if ((error = xfs_trans_iget(mp, tp, mp->m_sb.sb_rbmino, 0,
2155 XFS_ILOCK_EXCL, &ip)))
2156 return error;
2157 sumbp = NULL;
2158
2159
2160
2161 switch (type) {
2162 case XFS_ALLOCTYPE_ANY_AG:
2163 error = xfs_rtallocate_extent_size(mp, tp, minlen, maxlen, len,
2164 &sumbp, &sb, prod, &r);
2165 break;
2166 case XFS_ALLOCTYPE_NEAR_BNO:
2167 error = xfs_rtallocate_extent_near(mp, tp, bno, minlen, maxlen,
2168 len, &sumbp, &sb, prod, &r);
2169 break;
2170 case XFS_ALLOCTYPE_THIS_BNO:
2171 error = xfs_rtallocate_extent_exact(mp, tp, bno, minlen, maxlen,
2172 len, &sumbp, &sb, prod, &r);
2173 break;
2174 default:
2175 ASSERT(0);
2176 }
2177 if (error) {
2178 return error;
2179 }
2180
2181
2182
2183 if (r != NULLRTBLOCK) {
2184 long slen = (long)*len;
2185
2186 ASSERT(*len >= minlen && *len <= maxlen);
2187 if (wasdel)
2188 xfs_trans_mod_sb(tp, XFS_TRANS_SB_RES_FREXTENTS, -slen);
2189 else
2190 xfs_trans_mod_sb(tp, XFS_TRANS_SB_FREXTENTS, -slen);
2191 }
2192 *rtblock = r;
2193 return 0;
2194}
2195
2196
2197
2198
2199
2200int
2201xfs_rtfree_extent(
2202 xfs_trans_t *tp,
2203 xfs_rtblock_t bno,
2204 xfs_extlen_t len)
2205{
2206 int error;
2207 xfs_inode_t *ip;
2208 xfs_mount_t *mp;
2209 xfs_fsblock_t sb;
2210 xfs_buf_t *sumbp;
2211
2212 mp = tp->t_mountp;
2213
2214
2215
2216 if ((error = xfs_trans_iget(mp, tp, mp->m_sb.sb_rbmino, 0,
2217 XFS_ILOCK_EXCL, &ip)))
2218 return error;
2219#if defined(__KERNEL__) && defined(DEBUG)
2220
2221
2222
2223 {
2224 int stat;
2225
2226 error = xfs_rtcheck_alloc_range(mp, tp, bno, len, &stat);
2227 if (error) {
2228 return error;
2229 }
2230 ASSERT(stat);
2231 }
2232#endif
2233 sumbp = NULL;
2234
2235
2236
2237 error = xfs_rtfree_range(mp, tp, bno, len, &sumbp, &sb);
2238 if (error) {
2239 return error;
2240 }
2241
2242
2243
2244 xfs_trans_mod_sb(tp, XFS_TRANS_SB_FREXTENTS, (long)len);
2245
2246
2247
2248
2249 if (tp->t_frextents_delta + mp->m_sb.sb_frextents ==
2250 mp->m_sb.sb_rextents) {
2251 if (!(ip->i_d.di_flags & XFS_DIFLAG_NEWRTBM))
2252 ip->i_d.di_flags |= XFS_DIFLAG_NEWRTBM;
2253 *(__uint64_t *)&ip->i_d.di_atime = 0;
2254 xfs_trans_log_inode(tp, ip, XFS_ILOG_CORE);
2255 }
2256 return 0;
2257}
2258
2259
2260
2261
2262int
2263xfs_rtmount_init(
2264 xfs_mount_t *mp)
2265{
2266 xfs_buf_t *bp;
2267 xfs_daddr_t d;
2268 int error;
2269 xfs_sb_t *sbp;
2270
2271 sbp = &mp->m_sb;
2272 if (sbp->sb_rblocks == 0)
2273 return 0;
2274 if (mp->m_rtdev_targp == NULL) {
2275 cmn_err(CE_WARN,
2276 "XFS: This filesystem has a realtime volume, use rtdev=device option");
2277 return XFS_ERROR(ENODEV);
2278 }
2279 mp->m_rsumlevels = sbp->sb_rextslog + 1;
2280 mp->m_rsumsize =
2281 (uint)sizeof(xfs_suminfo_t) * mp->m_rsumlevels *
2282 sbp->sb_rbmblocks;
2283 mp->m_rsumsize = roundup(mp->m_rsumsize, sbp->sb_blocksize);
2284 mp->m_rbmip = mp->m_rsumip = NULL;
2285
2286
2287
2288 d = (xfs_daddr_t)XFS_FSB_TO_BB(mp, mp->m_sb.sb_rblocks);
2289 if (XFS_BB_TO_FSB(mp, d) != mp->m_sb.sb_rblocks) {
2290 cmn_err(CE_WARN, "XFS: realtime mount -- %llu != %llu",
2291 (unsigned long long) XFS_BB_TO_FSB(mp, d),
2292 (unsigned long long) mp->m_sb.sb_rblocks);
2293 return XFS_ERROR(E2BIG);
2294 }
2295 error = xfs_read_buf(mp, mp->m_rtdev_targp,
2296 d - XFS_FSB_TO_BB(mp, 1),
2297 XFS_FSB_TO_BB(mp, 1), 0, &bp);
2298 if (error) {
2299 cmn_err(CE_WARN,
2300 "XFS: realtime mount -- xfs_read_buf failed, returned %d", error);
2301 if (error == ENOSPC)
2302 return XFS_ERROR(E2BIG);
2303 return error;
2304 }
2305 xfs_buf_relse(bp);
2306 return 0;
2307}
2308
2309
2310
2311
2312
2313int
2314xfs_rtmount_inodes(
2315 xfs_mount_t *mp)
2316{
2317 int error;
2318 xfs_sb_t *sbp;
2319
2320 sbp = &mp->m_sb;
2321 if (sbp->sb_rbmino == NULLFSINO)
2322 return 0;
2323 error = xfs_iget(mp, NULL, sbp->sb_rbmino, 0, 0, &mp->m_rbmip, 0);
2324 if (error)
2325 return error;
2326 ASSERT(mp->m_rbmip != NULL);
2327 ASSERT(sbp->sb_rsumino != NULLFSINO);
2328 error = xfs_iget(mp, NULL, sbp->sb_rsumino, 0, 0, &mp->m_rsumip, 0);
2329 if (error) {
2330 VN_RELE(XFS_ITOV(mp->m_rbmip));
2331 return error;
2332 }
2333 ASSERT(mp->m_rsumip != NULL);
2334 return 0;
2335}
2336
2337
2338
2339
2340
2341
2342
2343
2344int
2345xfs_rtpick_extent(
2346 xfs_mount_t *mp,
2347 xfs_trans_t *tp,
2348 xfs_extlen_t len,
2349 xfs_rtblock_t *pick)
2350{
2351 xfs_rtblock_t b;
2352 int error;
2353 xfs_inode_t *ip;
2354 int log2;
2355 __uint64_t resid;
2356 __uint64_t seq;
2357 __uint64_t *seqp;
2358
2359 if ((error = xfs_trans_iget(mp, tp, mp->m_sb.sb_rbmino, 0,
2360 XFS_ILOCK_EXCL, &ip)))
2361 return error;
2362 ASSERT(ip == mp->m_rbmip);
2363 seqp = (__uint64_t *)&ip->i_d.di_atime;
2364 if (!(ip->i_d.di_flags & XFS_DIFLAG_NEWRTBM)) {
2365 ip->i_d.di_flags |= XFS_DIFLAG_NEWRTBM;
2366 *seqp = 0;
2367 }
2368 seq = *seqp;
2369 if ((log2 = xfs_highbit64(seq)) == -1)
2370 b = 0;
2371 else {
2372 resid = seq - (1ULL << log2);
2373 b = (mp->m_sb.sb_rextents * ((resid << 1) + 1ULL)) >>
2374 (log2 + 1);
2375 if (b >= mp->m_sb.sb_rextents)
2376 b = do_mod(b, mp->m_sb.sb_rextents);
2377 if (b + len > mp->m_sb.sb_rextents)
2378 b = mp->m_sb.sb_rextents - len;
2379 }
2380 *seqp = seq + 1;
2381 xfs_trans_log_inode(tp, ip, XFS_ILOG_CORE);
2382 *pick = b;
2383 return 0;
2384}
2385
2386#ifdef DEBUG
2387
2388
2389
2390void
2391xfs_rtprint_range(
2392 xfs_mount_t *mp,
2393 xfs_trans_t *tp,
2394 xfs_rtblock_t start,
2395 xfs_extlen_t len)
2396{
2397 xfs_extlen_t i;
2398
2399 cmn_err(CE_DEBUG, "%Ld: ", (long long)start);
2400 for (i = 0; i < len; i++)
2401 cmn_err(CE_DEBUG, "%d", xfs_rtcheck_bit(mp, tp, start + i, 1));
2402 cmn_err(CE_DEBUG, "\n");
2403}
2404
2405
2406
2407
2408void
2409xfs_rtprint_summary(
2410 xfs_mount_t *mp,
2411 xfs_trans_t *tp)
2412{
2413 xfs_suminfo_t c;
2414 xfs_rtblock_t i;
2415 int l;
2416 int p;
2417 xfs_fsblock_t sb;
2418 xfs_buf_t *sumbp;
2419
2420 sumbp = NULL;
2421 for (l = 0; l < mp->m_rsumlevels; l++) {
2422 for (p = 0, i = 0; i < mp->m_sb.sb_rbmblocks; i++) {
2423 (void)xfs_rtget_summary(mp, tp, l, i, &sumbp, &sb, &c);
2424 if (c) {
2425 if (!p) {
2426 cmn_err(CE_DEBUG, "%Ld-%Ld:", 1LL << l,
2427 XFS_RTMIN((1LL << l) +
2428 ((1LL << l) - 1LL),
2429 mp->m_sb.sb_rextents));
2430 p = 1;
2431 }
2432 cmn_err(CE_DEBUG, " %Ld:%d", (long long)i, c);
2433 }
2434 }
2435 if (p)
2436 cmn_err(CE_DEBUG, "\n");
2437 }
2438 if (sumbp)
2439 xfs_trans_brelse(tp, sumbp);
2440}
2441#endif
2442