1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /* -*- mode: c; c-basic-offset: 8; -*-
3 * vim: noexpandtab sw=8 ts=8 sts=0:
7 * Creates, reads, walks and deletes directory-nodes
9 * Copyright (C) 2002, 2004 Oracle. All rights reserved.
11 * Portions of this code from linux/fs/ext3/dir.c
13 * Copyright (C) 1992, 1993, 1994, 1995
14 * Remy Card (card@masi.ibp.fr)
15 * Laboratoire MASI - Institut Blaise pascal
16 * Universite Pierre et Marie Curie (Paris VI)
20 * linux/fs/minix/dir.c
22 * Copyright (C) 1991, 1992 Linus Torvalds
26 #include <linux/types.h>
27 #include <linux/slab.h>
28 #include <linux/highmem.h>
29 #include <linux/quotaops.h>
30 #include <linux/sort.h>
31 #include <linux/iversion.h>
33 #include <cluster/masklog.h>
38 #include "blockcheck.h"
41 #include "extent_map.h"
50 #include "ocfs2_trace.h"
52 #include "buffer_head_io.h"
54 #define NAMEI_RA_CHUNKS 2
55 #define NAMEI_RA_BLOCKS 4
56 #define NAMEI_RA_SIZE (NAMEI_RA_CHUNKS * NAMEI_RA_BLOCKS)
58 static int ocfs2_do_extend_dir(struct super_block
*sb
,
61 struct buffer_head
*parent_fe_bh
,
62 struct ocfs2_alloc_context
*data_ac
,
63 struct ocfs2_alloc_context
*meta_ac
,
64 struct buffer_head
**new_bh
);
65 static int ocfs2_dir_indexed(struct inode
*inode
);
68 * These are distinct checks because future versions of the file system will
69 * want to have a trailing dirent structure independent of indexing.
71 static int ocfs2_supports_dir_trailer(struct inode
*dir
)
73 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
75 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
78 return ocfs2_meta_ecc(osb
) || ocfs2_dir_indexed(dir
);
82 * "new' here refers to the point at which we're creating a new
83 * directory via "mkdir()", but also when we're expanding an inline
84 * directory. In either case, we don't yet have the indexing bit set
85 * on the directory, so the standard checks will fail in when metaecc
86 * is turned off. Only directory-initialization type functions should
87 * use this then. Everything else wants ocfs2_supports_dir_trailer()
89 static int ocfs2_new_dir_wants_trailer(struct inode
*dir
)
91 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
93 return ocfs2_meta_ecc(osb
) ||
94 ocfs2_supports_indexed_dirs(osb
);
97 static inline unsigned int ocfs2_dir_trailer_blk_off(struct super_block
*sb
)
99 return sb
->s_blocksize
- sizeof(struct ocfs2_dir_block_trailer
);
102 #define ocfs2_trailer_from_bh(_bh, _sb) ((struct ocfs2_dir_block_trailer *) ((_bh)->b_data + ocfs2_dir_trailer_blk_off((_sb))))
104 /* XXX ocfs2_block_dqtrailer() is similar but not quite - can we make
105 * them more consistent? */
106 struct ocfs2_dir_block_trailer
*ocfs2_dir_trailer_from_size(int blocksize
,
111 p
+= blocksize
- sizeof(struct ocfs2_dir_block_trailer
);
112 return (struct ocfs2_dir_block_trailer
*)p
;
116 * XXX: This is executed once on every dirent. We should consider optimizing
119 static int ocfs2_skip_dir_trailer(struct inode
*dir
,
120 struct ocfs2_dir_entry
*de
,
121 unsigned long offset
,
122 unsigned long blklen
)
124 unsigned long toff
= blklen
- sizeof(struct ocfs2_dir_block_trailer
);
126 if (!ocfs2_supports_dir_trailer(dir
))
135 static void ocfs2_init_dir_trailer(struct inode
*inode
,
136 struct buffer_head
*bh
, u16 rec_len
)
138 struct ocfs2_dir_block_trailer
*trailer
;
140 trailer
= ocfs2_trailer_from_bh(bh
, inode
->i_sb
);
141 strcpy(trailer
->db_signature
, OCFS2_DIR_TRAILER_SIGNATURE
);
142 trailer
->db_compat_rec_len
=
143 cpu_to_le16(sizeof(struct ocfs2_dir_block_trailer
));
144 trailer
->db_parent_dinode
= cpu_to_le64(OCFS2_I(inode
)->ip_blkno
);
145 trailer
->db_blkno
= cpu_to_le64(bh
->b_blocknr
);
146 trailer
->db_free_rec_len
= cpu_to_le16(rec_len
);
149 * Link an unindexed block with a dir trailer structure into the index free
150 * list. This function will modify dirdata_bh, but assumes you've already
151 * passed it to the journal.
153 static int ocfs2_dx_dir_link_trailer(struct inode
*dir
, handle_t
*handle
,
154 struct buffer_head
*dx_root_bh
,
155 struct buffer_head
*dirdata_bh
)
158 struct ocfs2_dx_root_block
*dx_root
;
159 struct ocfs2_dir_block_trailer
*trailer
;
161 ret
= ocfs2_journal_access_dr(handle
, INODE_CACHE(dir
), dx_root_bh
,
162 OCFS2_JOURNAL_ACCESS_WRITE
);
167 trailer
= ocfs2_trailer_from_bh(dirdata_bh
, dir
->i_sb
);
168 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
170 trailer
->db_free_next
= dx_root
->dr_free_blk
;
171 dx_root
->dr_free_blk
= cpu_to_le64(dirdata_bh
->b_blocknr
);
173 ocfs2_journal_dirty(handle
, dx_root_bh
);
179 static int ocfs2_free_list_at_root(struct ocfs2_dir_lookup_result
*res
)
181 return res
->dl_prev_leaf_bh
== NULL
;
184 void ocfs2_free_dir_lookup_result(struct ocfs2_dir_lookup_result
*res
)
186 brelse(res
->dl_dx_root_bh
);
187 brelse(res
->dl_leaf_bh
);
188 brelse(res
->dl_dx_leaf_bh
);
189 brelse(res
->dl_prev_leaf_bh
);
192 static int ocfs2_dir_indexed(struct inode
*inode
)
194 if (OCFS2_I(inode
)->ip_dyn_features
& OCFS2_INDEXED_DIR_FL
)
199 static inline int ocfs2_dx_root_inline(struct ocfs2_dx_root_block
*dx_root
)
201 return dx_root
->dr_flags
& OCFS2_DX_FLAG_INLINE
;
205 * Hashing code adapted from ext3
207 #define DELTA 0x9E3779B9
209 static void TEA_transform(__u32 buf
[4], __u32
const in
[])
212 __u32 b0
= buf
[0], b1
= buf
[1];
213 __u32 a
= in
[0], b
= in
[1], c
= in
[2], d
= in
[3];
218 b0
+= ((b1
<< 4)+a
) ^ (b1
+sum
) ^ ((b1
>> 5)+b
);
219 b1
+= ((b0
<< 4)+c
) ^ (b0
+sum
) ^ ((b0
>> 5)+d
);
226 static void str2hashbuf(const char *msg
, int len
, __u32
*buf
, int num
)
231 pad
= (__u32
)len
| ((__u32
)len
<< 8);
237 for (i
= 0; i
< len
; i
++) {
240 val
= msg
[i
] + (val
<< 8);
253 static void ocfs2_dx_dir_name_hash(struct inode
*dir
, const char *name
, int len
,
254 struct ocfs2_dx_hinfo
*hinfo
)
256 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
261 * XXX: Is this really necessary, if the index is never looked
262 * at by readdir? Is a hash value of '0' a bad idea?
264 if ((len
== 1 && !strncmp(".", name
, 1)) ||
265 (len
== 2 && !strncmp("..", name
, 2))) {
270 #ifdef OCFS2_DEBUG_DX_DIRS
272 * This makes it very easy to debug indexing problems. We
273 * should never allow this to be selected without hand editing
276 buf
[0] = buf
[1] = len
;
280 memcpy(buf
, osb
->osb_dx_seed
, sizeof(buf
));
284 str2hashbuf(p
, len
, in
, 4);
285 TEA_transform(buf
, in
);
291 hinfo
->major_hash
= buf
[0];
292 hinfo
->minor_hash
= buf
[1];
296 * bh passed here can be an inode block or a dir data block, depending
297 * on the inode inline data flag.
299 static int ocfs2_check_dir_entry(struct inode
* dir
,
300 struct ocfs2_dir_entry
* de
,
301 struct buffer_head
* bh
,
302 unsigned long offset
)
304 const char *error_msg
= NULL
;
305 const int rlen
= le16_to_cpu(de
->rec_len
);
307 if (unlikely(rlen
< OCFS2_DIR_REC_LEN(1)))
308 error_msg
= "rec_len is smaller than minimal";
309 else if (unlikely(rlen
% 4 != 0))
310 error_msg
= "rec_len % 4 != 0";
311 else if (unlikely(rlen
< OCFS2_DIR_REC_LEN(de
->name_len
)))
312 error_msg
= "rec_len is too small for name_len";
314 ((char *) de
- bh
->b_data
) + rlen
> dir
->i_sb
->s_blocksize
))
315 error_msg
= "directory entry across blocks";
317 if (unlikely(error_msg
!= NULL
))
318 mlog(ML_ERROR
, "bad entry in directory #%llu: %s - "
319 "offset=%lu, inode=%llu, rec_len=%d, name_len=%d\n",
320 (unsigned long long)OCFS2_I(dir
)->ip_blkno
, error_msg
,
321 offset
, (unsigned long long)le64_to_cpu(de
->inode
), rlen
,
324 return error_msg
== NULL
? 1 : 0;
327 static inline int ocfs2_match(int len
,
328 const char * const name
,
329 struct ocfs2_dir_entry
*de
)
331 if (len
!= de
->name_len
)
335 return !memcmp(name
, de
->name
, len
);
339 * Returns 0 if not found, -1 on failure, and 1 on success
341 static inline int ocfs2_search_dirblock(struct buffer_head
*bh
,
343 const char *name
, int namelen
,
344 unsigned long offset
,
347 struct ocfs2_dir_entry
**res_dir
)
349 struct ocfs2_dir_entry
*de
;
350 char *dlimit
, *de_buf
;
355 dlimit
= de_buf
+ bytes
;
357 while (de_buf
< dlimit
) {
358 /* this code is executed quadratically often */
359 /* do minimal checking `by hand' */
361 de
= (struct ocfs2_dir_entry
*) de_buf
;
363 if (de_buf
+ namelen
<= dlimit
&&
364 ocfs2_match(namelen
, name
, de
)) {
365 /* found a match - just to be sure, do a full check */
366 if (!ocfs2_check_dir_entry(dir
, de
, bh
, offset
)) {
375 /* prevent looping on a bad block */
376 de_len
= le16_to_cpu(de
->rec_len
);
387 trace_ocfs2_search_dirblock(ret
);
391 static struct buffer_head
*ocfs2_find_entry_id(const char *name
,
394 struct ocfs2_dir_entry
**res_dir
)
397 struct buffer_head
*di_bh
= NULL
;
398 struct ocfs2_dinode
*di
;
399 struct ocfs2_inline_data
*data
;
401 ret
= ocfs2_read_inode_block(dir
, &di_bh
);
407 di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
408 data
= &di
->id2
.i_data
;
410 found
= ocfs2_search_dirblock(di_bh
, dir
, name
, namelen
, 0,
411 data
->id_data
, i_size_read(dir
), res_dir
);
420 static int ocfs2_validate_dir_block(struct super_block
*sb
,
421 struct buffer_head
*bh
)
424 struct ocfs2_dir_block_trailer
*trailer
=
425 ocfs2_trailer_from_bh(bh
, sb
);
429 * We don't validate dirents here, that's handled
430 * in-place when the code walks them.
432 trace_ocfs2_validate_dir_block((unsigned long long)bh
->b_blocknr
);
434 BUG_ON(!buffer_uptodate(bh
));
437 * If the ecc fails, we return the error but otherwise
438 * leave the filesystem running. We know any error is
439 * local to this block.
441 * Note that we are safe to call this even if the directory
442 * doesn't have a trailer. Filesystems without metaecc will do
443 * nothing, and filesystems with it will have one.
445 rc
= ocfs2_validate_meta_ecc(sb
, bh
->b_data
, &trailer
->db_check
);
447 mlog(ML_ERROR
, "Checksum failed for dinode %llu\n",
448 (unsigned long long)bh
->b_blocknr
);
454 * Validate a directory trailer.
456 * We check the trailer here rather than in ocfs2_validate_dir_block()
457 * because that function doesn't have the inode to test.
459 static int ocfs2_check_dir_trailer(struct inode
*dir
, struct buffer_head
*bh
)
462 struct ocfs2_dir_block_trailer
*trailer
;
464 trailer
= ocfs2_trailer_from_bh(bh
, dir
->i_sb
);
465 if (!OCFS2_IS_VALID_DIR_TRAILER(trailer
)) {
466 rc
= ocfs2_error(dir
->i_sb
,
467 "Invalid dirblock #%llu: signature = %.*s\n",
468 (unsigned long long)bh
->b_blocknr
, 7,
469 trailer
->db_signature
);
472 if (le64_to_cpu(trailer
->db_blkno
) != bh
->b_blocknr
) {
473 rc
= ocfs2_error(dir
->i_sb
,
474 "Directory block #%llu has an invalid db_blkno of %llu\n",
475 (unsigned long long)bh
->b_blocknr
,
476 (unsigned long long)le64_to_cpu(trailer
->db_blkno
));
479 if (le64_to_cpu(trailer
->db_parent_dinode
) !=
480 OCFS2_I(dir
)->ip_blkno
) {
481 rc
= ocfs2_error(dir
->i_sb
,
482 "Directory block #%llu on dinode #%llu has an invalid parent_dinode of %llu\n",
483 (unsigned long long)bh
->b_blocknr
,
484 (unsigned long long)OCFS2_I(dir
)->ip_blkno
,
485 (unsigned long long)le64_to_cpu(trailer
->db_blkno
));
493 * This function forces all errors to -EIO for consistency with its
494 * predecessor, ocfs2_bread(). We haven't audited what returning the
495 * real error codes would do to callers. We log the real codes with
496 * mlog_errno() before we squash them.
498 static int ocfs2_read_dir_block(struct inode
*inode
, u64 v_block
,
499 struct buffer_head
**bh
, int flags
)
502 struct buffer_head
*tmp
= *bh
;
504 rc
= ocfs2_read_virt_blocks(inode
, v_block
, 1, &tmp
, flags
,
505 ocfs2_validate_dir_block
);
511 if (!(flags
& OCFS2_BH_READAHEAD
) &&
512 ocfs2_supports_dir_trailer(inode
)) {
513 rc
= ocfs2_check_dir_trailer(inode
, tmp
);
522 /* If ocfs2_read_virt_blocks() got us a new bh, pass it up. */
527 return rc
? -EIO
: 0;
531 * Read the block at 'phys' which belongs to this directory
532 * inode. This function does no virtual->physical block translation -
533 * what's passed in is assumed to be a valid directory block.
535 static int ocfs2_read_dir_block_direct(struct inode
*dir
, u64 phys
,
536 struct buffer_head
**bh
)
539 struct buffer_head
*tmp
= *bh
;
541 ret
= ocfs2_read_block(INODE_CACHE(dir
), phys
, &tmp
,
542 ocfs2_validate_dir_block
);
548 if (ocfs2_supports_dir_trailer(dir
)) {
549 ret
= ocfs2_check_dir_trailer(dir
, tmp
);
564 static int ocfs2_validate_dx_root(struct super_block
*sb
,
565 struct buffer_head
*bh
)
568 struct ocfs2_dx_root_block
*dx_root
;
570 BUG_ON(!buffer_uptodate(bh
));
572 dx_root
= (struct ocfs2_dx_root_block
*) bh
->b_data
;
574 ret
= ocfs2_validate_meta_ecc(sb
, bh
->b_data
, &dx_root
->dr_check
);
577 "Checksum failed for dir index root block %llu\n",
578 (unsigned long long)bh
->b_blocknr
);
582 if (!OCFS2_IS_VALID_DX_ROOT(dx_root
)) {
583 ret
= ocfs2_error(sb
,
584 "Dir Index Root # %llu has bad signature %.*s\n",
585 (unsigned long long)le64_to_cpu(dx_root
->dr_blkno
),
586 7, dx_root
->dr_signature
);
592 static int ocfs2_read_dx_root(struct inode
*dir
, struct ocfs2_dinode
*di
,
593 struct buffer_head
**dx_root_bh
)
596 u64 blkno
= le64_to_cpu(di
->i_dx_root
);
597 struct buffer_head
*tmp
= *dx_root_bh
;
599 ret
= ocfs2_read_block(INODE_CACHE(dir
), blkno
, &tmp
,
600 ocfs2_validate_dx_root
);
602 /* If ocfs2_read_block() got us a new bh, pass it up. */
603 if (!ret
&& !*dx_root_bh
)
609 static int ocfs2_validate_dx_leaf(struct super_block
*sb
,
610 struct buffer_head
*bh
)
613 struct ocfs2_dx_leaf
*dx_leaf
= (struct ocfs2_dx_leaf
*)bh
->b_data
;
615 BUG_ON(!buffer_uptodate(bh
));
617 ret
= ocfs2_validate_meta_ecc(sb
, bh
->b_data
, &dx_leaf
->dl_check
);
620 "Checksum failed for dir index leaf block %llu\n",
621 (unsigned long long)bh
->b_blocknr
);
625 if (!OCFS2_IS_VALID_DX_LEAF(dx_leaf
)) {
626 ret
= ocfs2_error(sb
, "Dir Index Leaf has bad signature %.*s\n",
627 7, dx_leaf
->dl_signature
);
633 static int ocfs2_read_dx_leaf(struct inode
*dir
, u64 blkno
,
634 struct buffer_head
**dx_leaf_bh
)
637 struct buffer_head
*tmp
= *dx_leaf_bh
;
639 ret
= ocfs2_read_block(INODE_CACHE(dir
), blkno
, &tmp
,
640 ocfs2_validate_dx_leaf
);
642 /* If ocfs2_read_block() got us a new bh, pass it up. */
643 if (!ret
&& !*dx_leaf_bh
)
650 * Read a series of dx_leaf blocks. This expects all buffer_head
651 * pointers to be NULL on function entry.
653 static int ocfs2_read_dx_leaves(struct inode
*dir
, u64 start
, int num
,
654 struct buffer_head
**dx_leaf_bhs
)
658 ret
= ocfs2_read_blocks(INODE_CACHE(dir
), start
, num
, dx_leaf_bhs
, 0,
659 ocfs2_validate_dx_leaf
);
666 static struct buffer_head
*ocfs2_find_entry_el(const char *name
, int namelen
,
668 struct ocfs2_dir_entry
**res_dir
)
670 struct super_block
*sb
;
671 struct buffer_head
*bh_use
[NAMEI_RA_SIZE
];
672 struct buffer_head
*bh
, *ret
= NULL
;
673 unsigned long start
, block
, b
;
674 int ra_max
= 0; /* Number of bh's in the readahead
676 int ra_ptr
= 0; /* Current index into readahead
683 nblocks
= i_size_read(dir
) >> sb
->s_blocksize_bits
;
684 start
= OCFS2_I(dir
)->ip_dir_start_lookup
;
685 if (start
>= nblocks
)
692 * We deal with the read-ahead logic here.
694 if (ra_ptr
>= ra_max
) {
695 /* Refill the readahead buffer */
698 for (ra_max
= 0; ra_max
< NAMEI_RA_SIZE
; ra_max
++) {
700 * Terminate if we reach the end of the
701 * directory and must wrap, or if our
702 * search has finished at this block.
704 if (b
>= nblocks
|| (num
&& block
== start
)) {
705 bh_use
[ra_max
] = NULL
;
711 err
= ocfs2_read_dir_block(dir
, b
++, &bh
,
716 if ((bh
= bh_use
[ra_ptr
++]) == NULL
)
718 if (ocfs2_read_dir_block(dir
, block
, &bh
, 0)) {
719 /* read error, skip block & hope for the best.
720 * ocfs2_read_dir_block() has released the bh. */
721 mlog(ML_ERROR
, "reading directory %llu, "
723 (unsigned long long)OCFS2_I(dir
)->ip_blkno
,
727 i
= ocfs2_search_dirblock(bh
, dir
, name
, namelen
,
728 block
<< sb
->s_blocksize_bits
,
729 bh
->b_data
, sb
->s_blocksize
,
732 OCFS2_I(dir
)->ip_dir_start_lookup
= block
;
734 goto cleanup_and_exit
;
738 goto cleanup_and_exit
;
741 if (++block
>= nblocks
)
743 } while (block
!= start
);
746 * If the directory has grown while we were searching, then
747 * search the last part of the directory before giving up.
750 nblocks
= i_size_read(dir
) >> sb
->s_blocksize_bits
;
751 if (block
< nblocks
) {
757 /* Clean up the read-ahead blocks */
758 for (; ra_ptr
< ra_max
; ra_ptr
++)
759 brelse(bh_use
[ra_ptr
]);
761 trace_ocfs2_find_entry_el(ret
);
765 static int ocfs2_dx_dir_lookup_rec(struct inode
*inode
,
766 struct ocfs2_extent_list
*el
,
770 unsigned int *ret_clen
)
772 int ret
= 0, i
, found
;
773 struct buffer_head
*eb_bh
= NULL
;
774 struct ocfs2_extent_block
*eb
;
775 struct ocfs2_extent_rec
*rec
= NULL
;
777 if (el
->l_tree_depth
) {
778 ret
= ocfs2_find_leaf(INODE_CACHE(inode
), el
, major_hash
,
785 eb
= (struct ocfs2_extent_block
*) eb_bh
->b_data
;
788 if (el
->l_tree_depth
) {
789 ret
= ocfs2_error(inode
->i_sb
,
790 "Inode %lu has non zero tree depth in btree tree block %llu\n",
792 (unsigned long long)eb_bh
->b_blocknr
);
798 for (i
= le16_to_cpu(el
->l_next_free_rec
) - 1; i
>= 0; i
--) {
799 rec
= &el
->l_recs
[i
];
801 if (le32_to_cpu(rec
->e_cpos
) <= major_hash
) {
808 ret
= ocfs2_error(inode
->i_sb
,
809 "Inode %lu has bad extent record (%u, %u, 0) in btree\n",
811 le32_to_cpu(rec
->e_cpos
),
812 ocfs2_rec_clusters(el
, rec
));
817 *ret_phys_blkno
= le64_to_cpu(rec
->e_blkno
);
819 *ret_cpos
= le32_to_cpu(rec
->e_cpos
);
821 *ret_clen
= le16_to_cpu(rec
->e_leaf_clusters
);
829 * Returns the block index, from the start of the cluster which this
832 static inline unsigned int __ocfs2_dx_dir_hash_idx(struct ocfs2_super
*osb
,
835 return minor_hash
& osb
->osb_dx_mask
;
838 static inline unsigned int ocfs2_dx_dir_hash_idx(struct ocfs2_super
*osb
,
839 struct ocfs2_dx_hinfo
*hinfo
)
841 return __ocfs2_dx_dir_hash_idx(osb
, hinfo
->minor_hash
);
844 static int ocfs2_dx_dir_lookup(struct inode
*inode
,
845 struct ocfs2_extent_list
*el
,
846 struct ocfs2_dx_hinfo
*hinfo
,
851 unsigned int cend
, uninitialized_var(clen
);
852 u32
uninitialized_var(cpos
);
853 u64
uninitialized_var(blkno
);
854 u32 name_hash
= hinfo
->major_hash
;
856 ret
= ocfs2_dx_dir_lookup_rec(inode
, el
, name_hash
, &cpos
, &blkno
,
864 if (name_hash
>= cend
) {
865 /* We want the last cluster */
866 blkno
+= ocfs2_clusters_to_blocks(inode
->i_sb
, clen
- 1);
869 blkno
+= ocfs2_clusters_to_blocks(inode
->i_sb
,
875 * We now have the cluster which should hold our entry. To
876 * find the exact block from the start of the cluster to
877 * search, we take the lower bits of the hash.
879 blkno
+= ocfs2_dx_dir_hash_idx(OCFS2_SB(inode
->i_sb
), hinfo
);
882 *ret_phys_blkno
= blkno
;
891 static int ocfs2_dx_dir_search(const char *name
, int namelen
,
893 struct ocfs2_dx_root_block
*dx_root
,
894 struct ocfs2_dir_lookup_result
*res
)
897 u64
uninitialized_var(phys
);
898 struct buffer_head
*dx_leaf_bh
= NULL
;
899 struct ocfs2_dx_leaf
*dx_leaf
;
900 struct ocfs2_dx_entry
*dx_entry
= NULL
;
901 struct buffer_head
*dir_ent_bh
= NULL
;
902 struct ocfs2_dir_entry
*dir_ent
= NULL
;
903 struct ocfs2_dx_hinfo
*hinfo
= &res
->dl_hinfo
;
904 struct ocfs2_extent_list
*dr_el
;
905 struct ocfs2_dx_entry_list
*entry_list
;
907 ocfs2_dx_dir_name_hash(dir
, name
, namelen
, &res
->dl_hinfo
);
909 if (ocfs2_dx_root_inline(dx_root
)) {
910 entry_list
= &dx_root
->dr_entries
;
914 dr_el
= &dx_root
->dr_list
;
916 ret
= ocfs2_dx_dir_lookup(dir
, dr_el
, hinfo
, NULL
, &phys
);
922 trace_ocfs2_dx_dir_search((unsigned long long)OCFS2_I(dir
)->ip_blkno
,
923 namelen
, name
, hinfo
->major_hash
,
924 hinfo
->minor_hash
, (unsigned long long)phys
);
926 ret
= ocfs2_read_dx_leaf(dir
, phys
, &dx_leaf_bh
);
932 dx_leaf
= (struct ocfs2_dx_leaf
*) dx_leaf_bh
->b_data
;
934 trace_ocfs2_dx_dir_search_leaf_info(
935 le16_to_cpu(dx_leaf
->dl_list
.de_num_used
),
936 le16_to_cpu(dx_leaf
->dl_list
.de_count
));
938 entry_list
= &dx_leaf
->dl_list
;
942 * Empty leaf is legal, so no need to check for that.
945 for (i
= 0; i
< le16_to_cpu(entry_list
->de_num_used
); i
++) {
946 dx_entry
= &entry_list
->de_entries
[i
];
948 if (hinfo
->major_hash
!= le32_to_cpu(dx_entry
->dx_major_hash
)
949 || hinfo
->minor_hash
!= le32_to_cpu(dx_entry
->dx_minor_hash
))
953 * Search unindexed leaf block now. We're not
954 * guaranteed to find anything.
956 ret
= ocfs2_read_dir_block_direct(dir
,
957 le64_to_cpu(dx_entry
->dx_dirent_blk
),
965 * XXX: We should check the unindexed block here,
969 found
= ocfs2_search_dirblock(dir_ent_bh
, dir
, name
, namelen
,
970 0, dir_ent_bh
->b_data
,
971 dir
->i_sb
->s_blocksize
, &dir_ent
);
976 /* This means we found a bad directory entry. */
991 res
->dl_leaf_bh
= dir_ent_bh
;
992 res
->dl_entry
= dir_ent
;
993 res
->dl_dx_leaf_bh
= dx_leaf_bh
;
994 res
->dl_dx_entry
= dx_entry
;
1005 static int ocfs2_find_entry_dx(const char *name
, int namelen
,
1007 struct ocfs2_dir_lookup_result
*lookup
)
1010 struct buffer_head
*di_bh
= NULL
;
1011 struct ocfs2_dinode
*di
;
1012 struct buffer_head
*dx_root_bh
= NULL
;
1013 struct ocfs2_dx_root_block
*dx_root
;
1015 ret
= ocfs2_read_inode_block(dir
, &di_bh
);
1021 di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
1023 ret
= ocfs2_read_dx_root(dir
, di
, &dx_root_bh
);
1028 dx_root
= (struct ocfs2_dx_root_block
*) dx_root_bh
->b_data
;
1030 ret
= ocfs2_dx_dir_search(name
, namelen
, dir
, dx_root
, lookup
);
1037 lookup
->dl_dx_root_bh
= dx_root_bh
;
1046 * Try to find an entry of the provided name within 'dir'.
1048 * If nothing was found, -ENOENT is returned. Otherwise, zero is
1049 * returned and the struct 'res' will contain information useful to
1050 * other directory manipulation functions.
1052 * Caller can NOT assume anything about the contents of the
1053 * buffer_heads - they are passed back only so that it can be passed
1054 * into any one of the manipulation functions (add entry, delete
1055 * entry, etc). As an example, bh in the extent directory case is a
1056 * data block, in the inline-data case it actually points to an inode,
1057 * in the indexed directory case, multiple buffers are involved.
1059 int ocfs2_find_entry(const char *name
, int namelen
,
1060 struct inode
*dir
, struct ocfs2_dir_lookup_result
*lookup
)
1062 struct buffer_head
*bh
;
1063 struct ocfs2_dir_entry
*res_dir
= NULL
;
1065 if (ocfs2_dir_indexed(dir
))
1066 return ocfs2_find_entry_dx(name
, namelen
, dir
, lookup
);
1069 * The unindexed dir code only uses part of the lookup
1070 * structure, so there's no reason to push it down further
1073 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
1074 bh
= ocfs2_find_entry_id(name
, namelen
, dir
, &res_dir
);
1076 bh
= ocfs2_find_entry_el(name
, namelen
, dir
, &res_dir
);
1081 lookup
->dl_leaf_bh
= bh
;
1082 lookup
->dl_entry
= res_dir
;
1087 * Update inode number and type of a previously found directory entry.
1089 int ocfs2_update_entry(struct inode
*dir
, handle_t
*handle
,
1090 struct ocfs2_dir_lookup_result
*res
,
1091 struct inode
*new_entry_inode
)
1094 ocfs2_journal_access_func access
= ocfs2_journal_access_db
;
1095 struct ocfs2_dir_entry
*de
= res
->dl_entry
;
1096 struct buffer_head
*de_bh
= res
->dl_leaf_bh
;
1099 * The same code works fine for both inline-data and extent
1100 * based directories, so no need to split this up. The only
1101 * difference is the journal_access function.
1104 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
1105 access
= ocfs2_journal_access_di
;
1107 ret
= access(handle
, INODE_CACHE(dir
), de_bh
,
1108 OCFS2_JOURNAL_ACCESS_WRITE
);
1114 de
->inode
= cpu_to_le64(OCFS2_I(new_entry_inode
)->ip_blkno
);
1115 ocfs2_set_de_type(de
, new_entry_inode
->i_mode
);
1117 ocfs2_journal_dirty(handle
, de_bh
);
1124 * __ocfs2_delete_entry deletes a directory entry by merging it with the
1127 static int __ocfs2_delete_entry(handle_t
*handle
, struct inode
*dir
,
1128 struct ocfs2_dir_entry
*de_del
,
1129 struct buffer_head
*bh
, char *first_de
,
1132 struct ocfs2_dir_entry
*de
, *pde
;
1133 int i
, status
= -ENOENT
;
1134 ocfs2_journal_access_func access
= ocfs2_journal_access_db
;
1136 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
1137 access
= ocfs2_journal_access_di
;
1141 de
= (struct ocfs2_dir_entry
*) first_de
;
1143 if (!ocfs2_check_dir_entry(dir
, de
, bh
, i
)) {
1149 status
= access(handle
, INODE_CACHE(dir
), bh
,
1150 OCFS2_JOURNAL_ACCESS_WRITE
);
1157 le16_add_cpu(&pde
->rec_len
,
1158 le16_to_cpu(de
->rec_len
));
1160 inode_inc_iversion(dir
);
1161 ocfs2_journal_dirty(handle
, bh
);
1164 i
+= le16_to_cpu(de
->rec_len
);
1166 de
= (struct ocfs2_dir_entry
*)((char *)de
+ le16_to_cpu(de
->rec_len
));
1172 static unsigned int ocfs2_figure_dirent_hole(struct ocfs2_dir_entry
*de
)
1176 if (le64_to_cpu(de
->inode
) == 0)
1177 hole
= le16_to_cpu(de
->rec_len
);
1179 hole
= le16_to_cpu(de
->rec_len
) -
1180 OCFS2_DIR_REC_LEN(de
->name_len
);
1185 static int ocfs2_find_max_rec_len(struct super_block
*sb
,
1186 struct buffer_head
*dirblock_bh
)
1188 int size
, this_hole
, largest_hole
= 0;
1189 char *trailer
, *de_buf
, *limit
, *start
= dirblock_bh
->b_data
;
1190 struct ocfs2_dir_entry
*de
;
1192 trailer
= (char *)ocfs2_trailer_from_bh(dirblock_bh
, sb
);
1193 size
= ocfs2_dir_trailer_blk_off(sb
);
1194 limit
= start
+ size
;
1196 de
= (struct ocfs2_dir_entry
*)de_buf
;
1198 if (de_buf
!= trailer
) {
1199 this_hole
= ocfs2_figure_dirent_hole(de
);
1200 if (this_hole
> largest_hole
)
1201 largest_hole
= this_hole
;
1204 de_buf
+= le16_to_cpu(de
->rec_len
);
1205 de
= (struct ocfs2_dir_entry
*)de_buf
;
1206 } while (de_buf
< limit
);
1208 if (largest_hole
>= OCFS2_DIR_MIN_REC_LEN
)
1209 return largest_hole
;
1213 static void ocfs2_dx_list_remove_entry(struct ocfs2_dx_entry_list
*entry_list
,
1216 int num_used
= le16_to_cpu(entry_list
->de_num_used
);
1218 if (num_used
== 1 || index
== (num_used
- 1))
1221 memmove(&entry_list
->de_entries
[index
],
1222 &entry_list
->de_entries
[index
+ 1],
1223 (num_used
- index
- 1)*sizeof(struct ocfs2_dx_entry
));
1226 memset(&entry_list
->de_entries
[num_used
], 0,
1227 sizeof(struct ocfs2_dx_entry
));
1228 entry_list
->de_num_used
= cpu_to_le16(num_used
);
1231 static int ocfs2_delete_entry_dx(handle_t
*handle
, struct inode
*dir
,
1232 struct ocfs2_dir_lookup_result
*lookup
)
1234 int ret
, index
, max_rec_len
, add_to_free_list
= 0;
1235 struct buffer_head
*dx_root_bh
= lookup
->dl_dx_root_bh
;
1236 struct buffer_head
*leaf_bh
= lookup
->dl_leaf_bh
;
1237 struct ocfs2_dx_leaf
*dx_leaf
;
1238 struct ocfs2_dx_entry
*dx_entry
= lookup
->dl_dx_entry
;
1239 struct ocfs2_dir_block_trailer
*trailer
;
1240 struct ocfs2_dx_root_block
*dx_root
;
1241 struct ocfs2_dx_entry_list
*entry_list
;
1244 * This function gets a bit messy because we might have to
1245 * modify the root block, regardless of whether the indexed
1246 * entries are stored inline.
1250 * *Only* set 'entry_list' here, based on where we're looking
1251 * for the indexed entries. Later, we might still want to
1252 * journal both blocks, based on free list state.
1254 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
1255 if (ocfs2_dx_root_inline(dx_root
)) {
1256 entry_list
= &dx_root
->dr_entries
;
1258 dx_leaf
= (struct ocfs2_dx_leaf
*) lookup
->dl_dx_leaf_bh
->b_data
;
1259 entry_list
= &dx_leaf
->dl_list
;
1262 /* Neither of these are a disk corruption - that should have
1263 * been caught by lookup, before we got here. */
1264 BUG_ON(le16_to_cpu(entry_list
->de_count
) <= 0);
1265 BUG_ON(le16_to_cpu(entry_list
->de_num_used
) <= 0);
1267 index
= (char *)dx_entry
- (char *)entry_list
->de_entries
;
1268 index
/= sizeof(*dx_entry
);
1270 if (index
>= le16_to_cpu(entry_list
->de_num_used
)) {
1271 mlog(ML_ERROR
, "Dir %llu: Bad dx_entry ptr idx %d, (%p, %p)\n",
1272 (unsigned long long)OCFS2_I(dir
)->ip_blkno
, index
,
1273 entry_list
, dx_entry
);
1278 * We know that removal of this dirent will leave enough room
1279 * for a new one, so add this block to the free list if it
1280 * isn't already there.
1282 trailer
= ocfs2_trailer_from_bh(leaf_bh
, dir
->i_sb
);
1283 if (trailer
->db_free_rec_len
== 0)
1284 add_to_free_list
= 1;
1287 * Add the block holding our index into the journal before
1288 * removing the unindexed entry. If we get an error return
1289 * from __ocfs2_delete_entry(), then it hasn't removed the
1290 * entry yet. Likewise, successful return means we *must*
1291 * remove the indexed entry.
1293 * We're also careful to journal the root tree block here as
1294 * the entry count needs to be updated. Also, we might be
1295 * adding to the start of the free list.
1297 ret
= ocfs2_journal_access_dr(handle
, INODE_CACHE(dir
), dx_root_bh
,
1298 OCFS2_JOURNAL_ACCESS_WRITE
);
1304 if (!ocfs2_dx_root_inline(dx_root
)) {
1305 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
),
1306 lookup
->dl_dx_leaf_bh
,
1307 OCFS2_JOURNAL_ACCESS_WRITE
);
1314 trace_ocfs2_delete_entry_dx((unsigned long long)OCFS2_I(dir
)->ip_blkno
,
1317 ret
= __ocfs2_delete_entry(handle
, dir
, lookup
->dl_entry
,
1318 leaf_bh
, leaf_bh
->b_data
, leaf_bh
->b_size
);
1324 max_rec_len
= ocfs2_find_max_rec_len(dir
->i_sb
, leaf_bh
);
1325 trailer
->db_free_rec_len
= cpu_to_le16(max_rec_len
);
1326 if (add_to_free_list
) {
1327 trailer
->db_free_next
= dx_root
->dr_free_blk
;
1328 dx_root
->dr_free_blk
= cpu_to_le64(leaf_bh
->b_blocknr
);
1329 ocfs2_journal_dirty(handle
, dx_root_bh
);
1332 /* leaf_bh was journal_accessed for us in __ocfs2_delete_entry */
1333 ocfs2_journal_dirty(handle
, leaf_bh
);
1335 le32_add_cpu(&dx_root
->dr_num_entries
, -1);
1336 ocfs2_journal_dirty(handle
, dx_root_bh
);
1338 ocfs2_dx_list_remove_entry(entry_list
, index
);
1340 if (!ocfs2_dx_root_inline(dx_root
))
1341 ocfs2_journal_dirty(handle
, lookup
->dl_dx_leaf_bh
);
1347 static inline int ocfs2_delete_entry_id(handle_t
*handle
,
1349 struct ocfs2_dir_entry
*de_del
,
1350 struct buffer_head
*bh
)
1353 struct buffer_head
*di_bh
= NULL
;
1354 struct ocfs2_dinode
*di
;
1355 struct ocfs2_inline_data
*data
;
1357 ret
= ocfs2_read_inode_block(dir
, &di_bh
);
1363 di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
1364 data
= &di
->id2
.i_data
;
1366 ret
= __ocfs2_delete_entry(handle
, dir
, de_del
, bh
, data
->id_data
,
1374 static inline int ocfs2_delete_entry_el(handle_t
*handle
,
1376 struct ocfs2_dir_entry
*de_del
,
1377 struct buffer_head
*bh
)
1379 return __ocfs2_delete_entry(handle
, dir
, de_del
, bh
, bh
->b_data
,
1384 * Delete a directory entry. Hide the details of directory
1385 * implementation from the caller.
1387 int ocfs2_delete_entry(handle_t
*handle
,
1389 struct ocfs2_dir_lookup_result
*res
)
1391 if (ocfs2_dir_indexed(dir
))
1392 return ocfs2_delete_entry_dx(handle
, dir
, res
);
1394 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
1395 return ocfs2_delete_entry_id(handle
, dir
, res
->dl_entry
,
1398 return ocfs2_delete_entry_el(handle
, dir
, res
->dl_entry
,
1403 * Check whether 'de' has enough room to hold an entry of
1404 * 'new_rec_len' bytes.
1406 static inline int ocfs2_dirent_would_fit(struct ocfs2_dir_entry
*de
,
1407 unsigned int new_rec_len
)
1409 unsigned int de_really_used
;
1411 /* Check whether this is an empty record with enough space */
1412 if (le64_to_cpu(de
->inode
) == 0 &&
1413 le16_to_cpu(de
->rec_len
) >= new_rec_len
)
1417 * Record might have free space at the end which we can
1420 de_really_used
= OCFS2_DIR_REC_LEN(de
->name_len
);
1421 if (le16_to_cpu(de
->rec_len
) >= (de_really_used
+ new_rec_len
))
1427 static void ocfs2_dx_dir_leaf_insert_tail(struct ocfs2_dx_leaf
*dx_leaf
,
1428 struct ocfs2_dx_entry
*dx_new_entry
)
1432 i
= le16_to_cpu(dx_leaf
->dl_list
.de_num_used
);
1433 dx_leaf
->dl_list
.de_entries
[i
] = *dx_new_entry
;
1435 le16_add_cpu(&dx_leaf
->dl_list
.de_num_used
, 1);
1438 static void ocfs2_dx_entry_list_insert(struct ocfs2_dx_entry_list
*entry_list
,
1439 struct ocfs2_dx_hinfo
*hinfo
,
1443 struct ocfs2_dx_entry
*dx_entry
;
1445 i
= le16_to_cpu(entry_list
->de_num_used
);
1446 dx_entry
= &entry_list
->de_entries
[i
];
1448 memset(dx_entry
, 0, sizeof(*dx_entry
));
1449 dx_entry
->dx_major_hash
= cpu_to_le32(hinfo
->major_hash
);
1450 dx_entry
->dx_minor_hash
= cpu_to_le32(hinfo
->minor_hash
);
1451 dx_entry
->dx_dirent_blk
= cpu_to_le64(dirent_blk
);
1453 le16_add_cpu(&entry_list
->de_num_used
, 1);
1456 static int __ocfs2_dx_dir_leaf_insert(struct inode
*dir
, handle_t
*handle
,
1457 struct ocfs2_dx_hinfo
*hinfo
,
1459 struct buffer_head
*dx_leaf_bh
)
1462 struct ocfs2_dx_leaf
*dx_leaf
;
1464 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
), dx_leaf_bh
,
1465 OCFS2_JOURNAL_ACCESS_WRITE
);
1471 dx_leaf
= (struct ocfs2_dx_leaf
*)dx_leaf_bh
->b_data
;
1472 ocfs2_dx_entry_list_insert(&dx_leaf
->dl_list
, hinfo
, dirent_blk
);
1473 ocfs2_journal_dirty(handle
, dx_leaf_bh
);
1479 static void ocfs2_dx_inline_root_insert(struct inode
*dir
, handle_t
*handle
,
1480 struct ocfs2_dx_hinfo
*hinfo
,
1482 struct ocfs2_dx_root_block
*dx_root
)
1484 ocfs2_dx_entry_list_insert(&dx_root
->dr_entries
, hinfo
, dirent_blk
);
1487 static int ocfs2_dx_dir_insert(struct inode
*dir
, handle_t
*handle
,
1488 struct ocfs2_dir_lookup_result
*lookup
)
1491 struct ocfs2_dx_root_block
*dx_root
;
1492 struct buffer_head
*dx_root_bh
= lookup
->dl_dx_root_bh
;
1494 ret
= ocfs2_journal_access_dr(handle
, INODE_CACHE(dir
), dx_root_bh
,
1495 OCFS2_JOURNAL_ACCESS_WRITE
);
1501 dx_root
= (struct ocfs2_dx_root_block
*)lookup
->dl_dx_root_bh
->b_data
;
1502 if (ocfs2_dx_root_inline(dx_root
)) {
1503 ocfs2_dx_inline_root_insert(dir
, handle
,
1505 lookup
->dl_leaf_bh
->b_blocknr
,
1508 ret
= __ocfs2_dx_dir_leaf_insert(dir
, handle
, &lookup
->dl_hinfo
,
1509 lookup
->dl_leaf_bh
->b_blocknr
,
1510 lookup
->dl_dx_leaf_bh
);
1515 le32_add_cpu(&dx_root
->dr_num_entries
, 1);
1516 ocfs2_journal_dirty(handle
, dx_root_bh
);
1522 static void ocfs2_remove_block_from_free_list(struct inode
*dir
,
1524 struct ocfs2_dir_lookup_result
*lookup
)
1526 struct ocfs2_dir_block_trailer
*trailer
, *prev
;
1527 struct ocfs2_dx_root_block
*dx_root
;
1528 struct buffer_head
*bh
;
1530 trailer
= ocfs2_trailer_from_bh(lookup
->dl_leaf_bh
, dir
->i_sb
);
1532 if (ocfs2_free_list_at_root(lookup
)) {
1533 bh
= lookup
->dl_dx_root_bh
;
1534 dx_root
= (struct ocfs2_dx_root_block
*)bh
->b_data
;
1535 dx_root
->dr_free_blk
= trailer
->db_free_next
;
1537 bh
= lookup
->dl_prev_leaf_bh
;
1538 prev
= ocfs2_trailer_from_bh(bh
, dir
->i_sb
);
1539 prev
->db_free_next
= trailer
->db_free_next
;
1542 trailer
->db_free_rec_len
= cpu_to_le16(0);
1543 trailer
->db_free_next
= cpu_to_le64(0);
1545 ocfs2_journal_dirty(handle
, bh
);
1546 ocfs2_journal_dirty(handle
, lookup
->dl_leaf_bh
);
1550 * This expects that a journal write has been reserved on
1551 * lookup->dl_prev_leaf_bh or lookup->dl_dx_root_bh
1553 static void ocfs2_recalc_free_list(struct inode
*dir
, handle_t
*handle
,
1554 struct ocfs2_dir_lookup_result
*lookup
)
1557 struct ocfs2_dir_block_trailer
*trailer
;
1559 /* Walk dl_leaf_bh to figure out what the new free rec_len is. */
1560 max_rec_len
= ocfs2_find_max_rec_len(dir
->i_sb
, lookup
->dl_leaf_bh
);
1563 * There's still room in this block, so no need to remove it
1564 * from the free list. In this case, we just want to update
1565 * the rec len accounting.
1567 trailer
= ocfs2_trailer_from_bh(lookup
->dl_leaf_bh
, dir
->i_sb
);
1568 trailer
->db_free_rec_len
= cpu_to_le16(max_rec_len
);
1569 ocfs2_journal_dirty(handle
, lookup
->dl_leaf_bh
);
1571 ocfs2_remove_block_from_free_list(dir
, handle
, lookup
);
1575 /* we don't always have a dentry for what we want to add, so people
1576 * like orphan dir can call this instead.
1578 * The lookup context must have been filled from
1579 * ocfs2_prepare_dir_for_insert.
1581 int __ocfs2_add_entry(handle_t
*handle
,
1583 const char *name
, int namelen
,
1584 struct inode
*inode
, u64 blkno
,
1585 struct buffer_head
*parent_fe_bh
,
1586 struct ocfs2_dir_lookup_result
*lookup
)
1588 unsigned long offset
;
1589 unsigned short rec_len
;
1590 struct ocfs2_dir_entry
*de
, *de1
;
1591 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)parent_fe_bh
->b_data
;
1592 struct super_block
*sb
= dir
->i_sb
;
1594 unsigned int size
= sb
->s_blocksize
;
1595 struct buffer_head
*insert_bh
= lookup
->dl_leaf_bh
;
1596 char *data_start
= insert_bh
->b_data
;
1601 if (ocfs2_dir_indexed(dir
)) {
1602 struct buffer_head
*bh
;
1605 * An indexed dir may require that we update the free space
1606 * list. Reserve a write to the previous node in the list so
1607 * that we don't fail later.
1609 * XXX: This can be either a dx_root_block, or an unindexed
1610 * directory tree leaf block.
1612 if (ocfs2_free_list_at_root(lookup
)) {
1613 bh
= lookup
->dl_dx_root_bh
;
1614 retval
= ocfs2_journal_access_dr(handle
,
1615 INODE_CACHE(dir
), bh
,
1616 OCFS2_JOURNAL_ACCESS_WRITE
);
1618 bh
= lookup
->dl_prev_leaf_bh
;
1619 retval
= ocfs2_journal_access_db(handle
,
1620 INODE_CACHE(dir
), bh
,
1621 OCFS2_JOURNAL_ACCESS_WRITE
);
1627 } else if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
) {
1628 data_start
= di
->id2
.i_data
.id_data
;
1629 size
= i_size_read(dir
);
1631 BUG_ON(insert_bh
!= parent_fe_bh
);
1634 rec_len
= OCFS2_DIR_REC_LEN(namelen
);
1636 de
= (struct ocfs2_dir_entry
*) data_start
;
1638 BUG_ON((char *)de
>= (size
+ data_start
));
1640 /* These checks should've already been passed by the
1641 * prepare function, but I guess we can leave them
1643 if (!ocfs2_check_dir_entry(dir
, de
, insert_bh
, offset
)) {
1647 if (ocfs2_match(namelen
, name
, de
)) {
1652 /* We're guaranteed that we should have space, so we
1653 * can't possibly have hit the trailer...right? */
1654 mlog_bug_on_msg(ocfs2_skip_dir_trailer(dir
, de
, offset
, size
),
1655 "Hit dir trailer trying to insert %.*s "
1656 "(namelen %d) into directory %llu. "
1657 "offset is %lu, trailer offset is %d\n",
1658 namelen
, name
, namelen
,
1659 (unsigned long long)parent_fe_bh
->b_blocknr
,
1660 offset
, ocfs2_dir_trailer_blk_off(dir
->i_sb
));
1662 if (ocfs2_dirent_would_fit(de
, rec_len
)) {
1663 dir
->i_mtime
= dir
->i_ctime
= current_time(dir
);
1664 retval
= ocfs2_mark_inode_dirty(handle
, dir
, parent_fe_bh
);
1670 if (insert_bh
== parent_fe_bh
)
1671 retval
= ocfs2_journal_access_di(handle
,
1674 OCFS2_JOURNAL_ACCESS_WRITE
);
1676 retval
= ocfs2_journal_access_db(handle
,
1679 OCFS2_JOURNAL_ACCESS_WRITE
);
1681 if (!retval
&& ocfs2_dir_indexed(dir
))
1682 retval
= ocfs2_dx_dir_insert(dir
,
1692 /* By now the buffer is marked for journaling */
1693 offset
+= le16_to_cpu(de
->rec_len
);
1694 if (le64_to_cpu(de
->inode
)) {
1695 de1
= (struct ocfs2_dir_entry
*)((char *) de
+
1696 OCFS2_DIR_REC_LEN(de
->name_len
));
1698 cpu_to_le16(le16_to_cpu(de
->rec_len
) -
1699 OCFS2_DIR_REC_LEN(de
->name_len
));
1700 de
->rec_len
= cpu_to_le16(OCFS2_DIR_REC_LEN(de
->name_len
));
1703 de
->file_type
= FT_UNKNOWN
;
1705 de
->inode
= cpu_to_le64(blkno
);
1706 ocfs2_set_de_type(de
, inode
->i_mode
);
1709 de
->name_len
= namelen
;
1710 memcpy(de
->name
, name
, namelen
);
1712 if (ocfs2_dir_indexed(dir
))
1713 ocfs2_recalc_free_list(dir
, handle
, lookup
);
1715 inode_inc_iversion(dir
);
1716 ocfs2_journal_dirty(handle
, insert_bh
);
1721 offset
+= le16_to_cpu(de
->rec_len
);
1722 de
= (struct ocfs2_dir_entry
*) ((char *) de
+ le16_to_cpu(de
->rec_len
));
1725 /* when you think about it, the assert above should prevent us
1726 * from ever getting here. */
1735 static int ocfs2_dir_foreach_blk_id(struct inode
*inode
,
1737 struct dir_context
*ctx
)
1740 unsigned long offset
= ctx
->pos
;
1741 struct buffer_head
*di_bh
= NULL
;
1742 struct ocfs2_dinode
*di
;
1743 struct ocfs2_inline_data
*data
;
1744 struct ocfs2_dir_entry
*de
;
1746 ret
= ocfs2_read_inode_block(inode
, &di_bh
);
1748 mlog(ML_ERROR
, "Unable to read inode block for dir %llu\n",
1749 (unsigned long long)OCFS2_I(inode
)->ip_blkno
);
1753 di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
1754 data
= &di
->id2
.i_data
;
1756 while (ctx
->pos
< i_size_read(inode
)) {
1757 /* If the dir block has changed since the last call to
1758 * readdir(2), then we might be pointing to an invalid
1759 * dirent right now. Scan from the start of the block
1761 if (!inode_eq_iversion(inode
, *f_version
)) {
1762 for (i
= 0; i
< i_size_read(inode
) && i
< offset
; ) {
1763 de
= (struct ocfs2_dir_entry
*)
1764 (data
->id_data
+ i
);
1765 /* It's too expensive to do a full
1766 * dirent test each time round this
1767 * loop, but we do have to test at
1768 * least that it is non-zero. A
1769 * failure will be detected in the
1770 * dirent test below. */
1771 if (le16_to_cpu(de
->rec_len
) <
1772 OCFS2_DIR_REC_LEN(1))
1774 i
+= le16_to_cpu(de
->rec_len
);
1776 ctx
->pos
= offset
= i
;
1777 *f_version
= inode_query_iversion(inode
);
1780 de
= (struct ocfs2_dir_entry
*) (data
->id_data
+ ctx
->pos
);
1781 if (!ocfs2_check_dir_entry(inode
, de
, di_bh
, ctx
->pos
)) {
1782 /* On error, skip the f_pos to the end. */
1783 ctx
->pos
= i_size_read(inode
);
1786 offset
+= le16_to_cpu(de
->rec_len
);
1787 if (le64_to_cpu(de
->inode
)) {
1788 if (!dir_emit(ctx
, de
->name
, de
->name_len
,
1789 le64_to_cpu(de
->inode
),
1790 fs_ftype_to_dtype(de
->file_type
)))
1793 ctx
->pos
+= le16_to_cpu(de
->rec_len
);
1801 * NOTE: This function can be called against unindexed directories,
1804 static int ocfs2_dir_foreach_blk_el(struct inode
*inode
,
1806 struct dir_context
*ctx
,
1809 unsigned long offset
, blk
, last_ra_blk
= 0;
1811 struct buffer_head
* bh
, * tmp
;
1812 struct ocfs2_dir_entry
* de
;
1813 struct super_block
* sb
= inode
->i_sb
;
1814 unsigned int ra_sectors
= 16;
1819 offset
= ctx
->pos
& (sb
->s_blocksize
- 1);
1821 while (ctx
->pos
< i_size_read(inode
)) {
1822 blk
= ctx
->pos
>> sb
->s_blocksize_bits
;
1823 if (ocfs2_read_dir_block(inode
, blk
, &bh
, 0)) {
1824 /* Skip the corrupt dirblock and keep trying */
1825 ctx
->pos
+= sb
->s_blocksize
- offset
;
1829 /* The idea here is to begin with 8k read-ahead and to stay
1830 * 4k ahead of our current position.
1832 * TODO: Use the pagecache for this. We just need to
1833 * make sure it's cluster-safe... */
1835 || (((last_ra_blk
- blk
) << 9) <= (ra_sectors
/ 2))) {
1836 for (i
= ra_sectors
>> (sb
->s_blocksize_bits
- 9);
1839 if (!ocfs2_read_dir_block(inode
, ++blk
, &tmp
,
1840 OCFS2_BH_READAHEAD
))
1847 /* If the dir block has changed since the last call to
1848 * readdir(2), then we might be pointing to an invalid
1849 * dirent right now. Scan from the start of the block
1851 if (!inode_eq_iversion(inode
, *f_version
)) {
1852 for (i
= 0; i
< sb
->s_blocksize
&& i
< offset
; ) {
1853 de
= (struct ocfs2_dir_entry
*) (bh
->b_data
+ i
);
1854 /* It's too expensive to do a full
1855 * dirent test each time round this
1856 * loop, but we do have to test at
1857 * least that it is non-zero. A
1858 * failure will be detected in the
1859 * dirent test below. */
1860 if (le16_to_cpu(de
->rec_len
) <
1861 OCFS2_DIR_REC_LEN(1))
1863 i
+= le16_to_cpu(de
->rec_len
);
1866 ctx
->pos
= (ctx
->pos
& ~(sb
->s_blocksize
- 1))
1868 *f_version
= inode_query_iversion(inode
);
1871 while (ctx
->pos
< i_size_read(inode
)
1872 && offset
< sb
->s_blocksize
) {
1873 de
= (struct ocfs2_dir_entry
*) (bh
->b_data
+ offset
);
1874 if (!ocfs2_check_dir_entry(inode
, de
, bh
, offset
)) {
1875 /* On error, skip the f_pos to the
1877 ctx
->pos
= (ctx
->pos
| (sb
->s_blocksize
- 1)) + 1;
1880 if (le64_to_cpu(de
->inode
)) {
1881 if (!dir_emit(ctx
, de
->name
,
1883 le64_to_cpu(de
->inode
),
1884 fs_ftype_to_dtype(de
->file_type
))) {
1890 offset
+= le16_to_cpu(de
->rec_len
);
1891 ctx
->pos
+= le16_to_cpu(de
->rec_len
);
1896 if (!persist
&& stored
)
1902 static int ocfs2_dir_foreach_blk(struct inode
*inode
, u64
*f_version
,
1903 struct dir_context
*ctx
,
1906 if (OCFS2_I(inode
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
1907 return ocfs2_dir_foreach_blk_id(inode
, f_version
, ctx
);
1908 return ocfs2_dir_foreach_blk_el(inode
, f_version
, ctx
, persist
);
1912 * This is intended to be called from inside other kernel functions,
1913 * so we fake some arguments.
1915 int ocfs2_dir_foreach(struct inode
*inode
, struct dir_context
*ctx
)
1917 u64 version
= inode_query_iversion(inode
);
1918 ocfs2_dir_foreach_blk(inode
, &version
, ctx
, true);
1926 int ocfs2_readdir(struct file
*file
, struct dir_context
*ctx
)
1929 struct inode
*inode
= file_inode(file
);
1932 trace_ocfs2_readdir((unsigned long long)OCFS2_I(inode
)->ip_blkno
);
1934 error
= ocfs2_inode_lock_atime(inode
, file
->f_path
.mnt
, &lock_level
, 1);
1935 if (lock_level
&& error
>= 0) {
1936 /* We release EX lock which used to update atime
1937 * and get PR lock again to reduce contention
1938 * on commonly accessed directories. */
1939 ocfs2_inode_unlock(inode
, 1);
1941 error
= ocfs2_inode_lock(inode
, NULL
, 0);
1944 if (error
!= -ENOENT
)
1946 /* we haven't got any yet, so propagate the error. */
1950 error
= ocfs2_dir_foreach_blk(inode
, &file
->f_version
, ctx
, false);
1952 ocfs2_inode_unlock(inode
, lock_level
);
1962 * NOTE: this should always be called with parent dir i_mutex taken.
1964 int ocfs2_find_files_on_disk(const char *name
,
1967 struct inode
*inode
,
1968 struct ocfs2_dir_lookup_result
*lookup
)
1970 int status
= -ENOENT
;
1972 trace_ocfs2_find_files_on_disk(namelen
, name
, blkno
,
1973 (unsigned long long)OCFS2_I(inode
)->ip_blkno
);
1975 status
= ocfs2_find_entry(name
, namelen
, inode
, lookup
);
1979 *blkno
= le64_to_cpu(lookup
->dl_entry
->inode
);
1988 * Convenience function for callers which just want the block number
1989 * mapped to a name and don't require the full dirent info, etc.
1991 int ocfs2_lookup_ino_from_name(struct inode
*dir
, const char *name
,
1992 int namelen
, u64
*blkno
)
1995 struct ocfs2_dir_lookup_result lookup
= { NULL
, };
1997 ret
= ocfs2_find_files_on_disk(name
, namelen
, blkno
, dir
, &lookup
);
1998 ocfs2_free_dir_lookup_result(&lookup
);
2003 /* Check for a name within a directory.
2005 * Return 0 if the name does not exist
2006 * Return -EEXIST if the directory contains the name
2008 * Callers should have i_mutex + a cluster lock on dir
2010 int ocfs2_check_dir_for_entry(struct inode
*dir
,
2015 struct ocfs2_dir_lookup_result lookup
= { NULL
, };
2017 trace_ocfs2_check_dir_for_entry(
2018 (unsigned long long)OCFS2_I(dir
)->ip_blkno
, namelen
, name
);
2020 if (ocfs2_find_entry(name
, namelen
, dir
, &lookup
) == 0) {
2025 ocfs2_free_dir_lookup_result(&lookup
);
2030 struct ocfs2_empty_dir_priv
{
2031 struct dir_context ctx
;
2033 unsigned seen_dot_dot
;
2034 unsigned seen_other
;
2037 static int ocfs2_empty_dir_filldir(struct dir_context
*ctx
, const char *name
,
2038 int name_len
, loff_t pos
, u64 ino
,
2041 struct ocfs2_empty_dir_priv
*p
=
2042 container_of(ctx
, struct ocfs2_empty_dir_priv
, ctx
);
2045 * Check the positions of "." and ".." records to be sure
2046 * they're in the correct place.
2048 * Indexed directories don't need to proceed past the first
2049 * two entries, so we end the scan after seeing '..'. Despite
2050 * that, we allow the scan to proceed In the event that we
2051 * have a corrupted indexed directory (no dot or dot dot
2052 * entries). This allows us to double check for existing
2053 * entries which might not have been found in the index.
2055 if (name_len
== 1 && !strncmp(".", name
, 1) && pos
== 0) {
2060 if (name_len
== 2 && !strncmp("..", name
, 2) &&
2061 pos
== OCFS2_DIR_REC_LEN(1)) {
2062 p
->seen_dot_dot
= 1;
2064 if (p
->dx_dir
&& p
->seen_dot
)
2074 static int ocfs2_empty_dir_dx(struct inode
*inode
,
2075 struct ocfs2_empty_dir_priv
*priv
)
2078 struct buffer_head
*di_bh
= NULL
;
2079 struct buffer_head
*dx_root_bh
= NULL
;
2080 struct ocfs2_dinode
*di
;
2081 struct ocfs2_dx_root_block
*dx_root
;
2085 ret
= ocfs2_read_inode_block(inode
, &di_bh
);
2090 di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
2092 ret
= ocfs2_read_dx_root(inode
, di
, &dx_root_bh
);
2097 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
2099 if (le32_to_cpu(dx_root
->dr_num_entries
) != 2)
2100 priv
->seen_other
= 1;
2109 * routine to check that the specified directory is empty (for rmdir)
2111 * Returns 1 if dir is empty, zero otherwise.
2113 * XXX: This is a performance problem for unindexed directories.
2115 int ocfs2_empty_dir(struct inode
*inode
)
2118 struct ocfs2_empty_dir_priv priv
= {
2119 .ctx
.actor
= ocfs2_empty_dir_filldir
,
2122 if (ocfs2_dir_indexed(inode
)) {
2123 ret
= ocfs2_empty_dir_dx(inode
, &priv
);
2127 * We still run ocfs2_dir_foreach to get the checks
2132 ret
= ocfs2_dir_foreach(inode
, &priv
.ctx
);
2136 if (!priv
.seen_dot
|| !priv
.seen_dot_dot
) {
2137 mlog(ML_ERROR
, "bad directory (dir #%llu) - no `.' or `..'\n",
2138 (unsigned long long)OCFS2_I(inode
)->ip_blkno
);
2140 * XXX: Is it really safe to allow an unlink to continue?
2145 return !priv
.seen_other
;
2149 * Fills "." and ".." dirents in a new directory block. Returns dirent for
2150 * "..", which might be used during creation of a directory with a trailing
2151 * header. It is otherwise safe to ignore the return code.
2153 static struct ocfs2_dir_entry
*ocfs2_fill_initial_dirents(struct inode
*inode
,
2154 struct inode
*parent
,
2158 struct ocfs2_dir_entry
*de
= (struct ocfs2_dir_entry
*)start
;
2160 de
->inode
= cpu_to_le64(OCFS2_I(inode
)->ip_blkno
);
2163 cpu_to_le16(OCFS2_DIR_REC_LEN(de
->name_len
));
2164 strcpy(de
->name
, ".");
2165 ocfs2_set_de_type(de
, S_IFDIR
);
2167 de
= (struct ocfs2_dir_entry
*) ((char *)de
+ le16_to_cpu(de
->rec_len
));
2168 de
->inode
= cpu_to_le64(OCFS2_I(parent
)->ip_blkno
);
2169 de
->rec_len
= cpu_to_le16(size
- OCFS2_DIR_REC_LEN(1));
2171 strcpy(de
->name
, "..");
2172 ocfs2_set_de_type(de
, S_IFDIR
);
2178 * This works together with code in ocfs2_mknod_locked() which sets
2179 * the inline-data flag and initializes the inline-data section.
2181 static int ocfs2_fill_new_dir_id(struct ocfs2_super
*osb
,
2183 struct inode
*parent
,
2184 struct inode
*inode
,
2185 struct buffer_head
*di_bh
)
2188 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
2189 struct ocfs2_inline_data
*data
= &di
->id2
.i_data
;
2190 unsigned int size
= le16_to_cpu(data
->id_count
);
2192 ret
= ocfs2_journal_access_di(handle
, INODE_CACHE(inode
), di_bh
,
2193 OCFS2_JOURNAL_ACCESS_WRITE
);
2199 ocfs2_fill_initial_dirents(inode
, parent
, data
->id_data
, size
);
2200 ocfs2_journal_dirty(handle
, di_bh
);
2202 i_size_write(inode
, size
);
2203 set_nlink(inode
, 2);
2204 inode
->i_blocks
= ocfs2_inode_sector_count(inode
);
2206 ret
= ocfs2_mark_inode_dirty(handle
, inode
, di_bh
);
2214 static int ocfs2_fill_new_dir_el(struct ocfs2_super
*osb
,
2216 struct inode
*parent
,
2217 struct inode
*inode
,
2218 struct buffer_head
*fe_bh
,
2219 struct ocfs2_alloc_context
*data_ac
,
2220 struct buffer_head
**ret_new_bh
)
2223 unsigned int size
= osb
->sb
->s_blocksize
;
2224 struct buffer_head
*new_bh
= NULL
;
2225 struct ocfs2_dir_entry
*de
;
2227 if (ocfs2_new_dir_wants_trailer(inode
))
2228 size
= ocfs2_dir_trailer_blk_off(parent
->i_sb
);
2230 status
= ocfs2_do_extend_dir(osb
->sb
, handle
, inode
, fe_bh
,
2231 data_ac
, NULL
, &new_bh
);
2237 ocfs2_set_new_buffer_uptodate(INODE_CACHE(inode
), new_bh
);
2239 status
= ocfs2_journal_access_db(handle
, INODE_CACHE(inode
), new_bh
,
2240 OCFS2_JOURNAL_ACCESS_CREATE
);
2245 memset(new_bh
->b_data
, 0, osb
->sb
->s_blocksize
);
2247 de
= ocfs2_fill_initial_dirents(inode
, parent
, new_bh
->b_data
, size
);
2248 if (ocfs2_new_dir_wants_trailer(inode
)) {
2249 int size
= le16_to_cpu(de
->rec_len
);
2252 * Figure out the size of the hole left over after
2253 * insertion of '.' and '..'. The trailer wants this
2256 size
-= OCFS2_DIR_REC_LEN(2);
2257 size
-= sizeof(struct ocfs2_dir_block_trailer
);
2259 ocfs2_init_dir_trailer(inode
, new_bh
, size
);
2262 ocfs2_journal_dirty(handle
, new_bh
);
2264 i_size_write(inode
, inode
->i_sb
->s_blocksize
);
2265 set_nlink(inode
, 2);
2266 inode
->i_blocks
= ocfs2_inode_sector_count(inode
);
2267 status
= ocfs2_mark_inode_dirty(handle
, inode
, fe_bh
);
2275 *ret_new_bh
= new_bh
;
2284 static int ocfs2_dx_dir_attach_index(struct ocfs2_super
*osb
,
2285 handle_t
*handle
, struct inode
*dir
,
2286 struct buffer_head
*di_bh
,
2287 struct buffer_head
*dirdata_bh
,
2288 struct ocfs2_alloc_context
*meta_ac
,
2289 int dx_inline
, u32 num_entries
,
2290 struct buffer_head
**ret_dx_root_bh
)
2293 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*) di_bh
->b_data
;
2294 u16 dr_suballoc_bit
;
2295 u64 suballoc_loc
, dr_blkno
;
2296 unsigned int num_bits
;
2297 struct buffer_head
*dx_root_bh
= NULL
;
2298 struct ocfs2_dx_root_block
*dx_root
;
2299 struct ocfs2_dir_block_trailer
*trailer
=
2300 ocfs2_trailer_from_bh(dirdata_bh
, dir
->i_sb
);
2302 ret
= ocfs2_claim_metadata(handle
, meta_ac
, 1, &suballoc_loc
,
2303 &dr_suballoc_bit
, &num_bits
, &dr_blkno
);
2309 trace_ocfs2_dx_dir_attach_index(
2310 (unsigned long long)OCFS2_I(dir
)->ip_blkno
,
2311 (unsigned long long)dr_blkno
);
2313 dx_root_bh
= sb_getblk(osb
->sb
, dr_blkno
);
2314 if (dx_root_bh
== NULL
) {
2318 ocfs2_set_new_buffer_uptodate(INODE_CACHE(dir
), dx_root_bh
);
2320 ret
= ocfs2_journal_access_dr(handle
, INODE_CACHE(dir
), dx_root_bh
,
2321 OCFS2_JOURNAL_ACCESS_CREATE
);
2327 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
2328 memset(dx_root
, 0, osb
->sb
->s_blocksize
);
2329 strcpy(dx_root
->dr_signature
, OCFS2_DX_ROOT_SIGNATURE
);
2330 dx_root
->dr_suballoc_slot
= cpu_to_le16(meta_ac
->ac_alloc_slot
);
2331 dx_root
->dr_suballoc_loc
= cpu_to_le64(suballoc_loc
);
2332 dx_root
->dr_suballoc_bit
= cpu_to_le16(dr_suballoc_bit
);
2333 dx_root
->dr_fs_generation
= cpu_to_le32(osb
->fs_generation
);
2334 dx_root
->dr_blkno
= cpu_to_le64(dr_blkno
);
2335 dx_root
->dr_dir_blkno
= cpu_to_le64(OCFS2_I(dir
)->ip_blkno
);
2336 dx_root
->dr_num_entries
= cpu_to_le32(num_entries
);
2337 if (le16_to_cpu(trailer
->db_free_rec_len
))
2338 dx_root
->dr_free_blk
= cpu_to_le64(dirdata_bh
->b_blocknr
);
2340 dx_root
->dr_free_blk
= cpu_to_le64(0);
2343 dx_root
->dr_flags
|= OCFS2_DX_FLAG_INLINE
;
2344 dx_root
->dr_entries
.de_count
=
2345 cpu_to_le16(ocfs2_dx_entries_per_root(osb
->sb
));
2347 dx_root
->dr_list
.l_count
=
2348 cpu_to_le16(ocfs2_extent_recs_per_dx_root(osb
->sb
));
2350 ocfs2_journal_dirty(handle
, dx_root_bh
);
2352 ret
= ocfs2_journal_access_di(handle
, INODE_CACHE(dir
), di_bh
,
2353 OCFS2_JOURNAL_ACCESS_CREATE
);
2359 di
->i_dx_root
= cpu_to_le64(dr_blkno
);
2361 spin_lock(&OCFS2_I(dir
)->ip_lock
);
2362 OCFS2_I(dir
)->ip_dyn_features
|= OCFS2_INDEXED_DIR_FL
;
2363 di
->i_dyn_features
= cpu_to_le16(OCFS2_I(dir
)->ip_dyn_features
);
2364 spin_unlock(&OCFS2_I(dir
)->ip_lock
);
2366 ocfs2_journal_dirty(handle
, di_bh
);
2368 *ret_dx_root_bh
= dx_root_bh
;
2376 static int ocfs2_dx_dir_format_cluster(struct ocfs2_super
*osb
,
2377 handle_t
*handle
, struct inode
*dir
,
2378 struct buffer_head
**dx_leaves
,
2379 int num_dx_leaves
, u64 start_blk
)
2382 struct ocfs2_dx_leaf
*dx_leaf
;
2383 struct buffer_head
*bh
;
2385 for (i
= 0; i
< num_dx_leaves
; i
++) {
2386 bh
= sb_getblk(osb
->sb
, start_blk
+ i
);
2393 ocfs2_set_new_buffer_uptodate(INODE_CACHE(dir
), bh
);
2395 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
), bh
,
2396 OCFS2_JOURNAL_ACCESS_CREATE
);
2402 dx_leaf
= (struct ocfs2_dx_leaf
*) bh
->b_data
;
2404 memset(dx_leaf
, 0, osb
->sb
->s_blocksize
);
2405 strcpy(dx_leaf
->dl_signature
, OCFS2_DX_LEAF_SIGNATURE
);
2406 dx_leaf
->dl_fs_generation
= cpu_to_le32(osb
->fs_generation
);
2407 dx_leaf
->dl_blkno
= cpu_to_le64(bh
->b_blocknr
);
2408 dx_leaf
->dl_list
.de_count
=
2409 cpu_to_le16(ocfs2_dx_entries_per_leaf(osb
->sb
));
2411 trace_ocfs2_dx_dir_format_cluster(
2412 (unsigned long long)OCFS2_I(dir
)->ip_blkno
,
2413 (unsigned long long)bh
->b_blocknr
,
2414 le16_to_cpu(dx_leaf
->dl_list
.de_count
));
2416 ocfs2_journal_dirty(handle
, bh
);
2425 * Allocates and formats a new cluster for use in an indexed dir
2426 * leaf. This version will not do the extent insert, so that it can be
2427 * used by operations which need careful ordering.
2429 static int __ocfs2_dx_dir_new_cluster(struct inode
*dir
,
2430 u32 cpos
, handle_t
*handle
,
2431 struct ocfs2_alloc_context
*data_ac
,
2432 struct buffer_head
**dx_leaves
,
2433 int num_dx_leaves
, u64
*ret_phys_blkno
)
2438 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
2441 * XXX: For create, this should claim cluster for the index
2442 * *before* the unindexed insert so that we have a better
2443 * chance of contiguousness as the directory grows in number
2446 ret
= __ocfs2_claim_clusters(handle
, data_ac
, 1, 1, &phys
, &num
);
2453 * Format the new cluster first. That way, we're inserting
2456 phys_blkno
= ocfs2_clusters_to_blocks(osb
->sb
, phys
);
2457 ret
= ocfs2_dx_dir_format_cluster(osb
, handle
, dir
, dx_leaves
,
2458 num_dx_leaves
, phys_blkno
);
2464 *ret_phys_blkno
= phys_blkno
;
2469 static int ocfs2_dx_dir_new_cluster(struct inode
*dir
,
2470 struct ocfs2_extent_tree
*et
,
2471 u32 cpos
, handle_t
*handle
,
2472 struct ocfs2_alloc_context
*data_ac
,
2473 struct ocfs2_alloc_context
*meta_ac
,
2474 struct buffer_head
**dx_leaves
,
2480 ret
= __ocfs2_dx_dir_new_cluster(dir
, cpos
, handle
, data_ac
, dx_leaves
,
2481 num_dx_leaves
, &phys_blkno
);
2487 ret
= ocfs2_insert_extent(handle
, et
, cpos
, phys_blkno
, 1, 0,
2495 static struct buffer_head
**ocfs2_dx_dir_kmalloc_leaves(struct super_block
*sb
,
2496 int *ret_num_leaves
)
2498 int num_dx_leaves
= ocfs2_clusters_to_blocks(sb
, 1);
2499 struct buffer_head
**dx_leaves
;
2501 dx_leaves
= kcalloc(num_dx_leaves
, sizeof(struct buffer_head
*),
2503 if (dx_leaves
&& ret_num_leaves
)
2504 *ret_num_leaves
= num_dx_leaves
;
2509 static int ocfs2_fill_new_dir_dx(struct ocfs2_super
*osb
,
2511 struct inode
*parent
,
2512 struct inode
*inode
,
2513 struct buffer_head
*di_bh
,
2514 struct ocfs2_alloc_context
*data_ac
,
2515 struct ocfs2_alloc_context
*meta_ac
)
2518 struct buffer_head
*leaf_bh
= NULL
;
2519 struct buffer_head
*dx_root_bh
= NULL
;
2520 struct ocfs2_dx_hinfo hinfo
;
2521 struct ocfs2_dx_root_block
*dx_root
;
2522 struct ocfs2_dx_entry_list
*entry_list
;
2525 * Our strategy is to create the directory as though it were
2526 * unindexed, then add the index block. This works with very
2527 * little complication since the state of a new directory is a
2528 * very well known quantity.
2530 * Essentially, we have two dirents ("." and ".."), in the 1st
2531 * block which need indexing. These are easily inserted into
2535 ret
= ocfs2_fill_new_dir_el(osb
, handle
, parent
, inode
, di_bh
,
2542 ret
= ocfs2_dx_dir_attach_index(osb
, handle
, inode
, di_bh
, leaf_bh
,
2543 meta_ac
, 1, 2, &dx_root_bh
);
2548 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
2549 entry_list
= &dx_root
->dr_entries
;
2551 /* Buffer has been journaled for us by ocfs2_dx_dir_attach_index */
2552 ocfs2_dx_dir_name_hash(inode
, ".", 1, &hinfo
);
2553 ocfs2_dx_entry_list_insert(entry_list
, &hinfo
, leaf_bh
->b_blocknr
);
2555 ocfs2_dx_dir_name_hash(inode
, "..", 2, &hinfo
);
2556 ocfs2_dx_entry_list_insert(entry_list
, &hinfo
, leaf_bh
->b_blocknr
);
2564 int ocfs2_fill_new_dir(struct ocfs2_super
*osb
,
2566 struct inode
*parent
,
2567 struct inode
*inode
,
2568 struct buffer_head
*fe_bh
,
2569 struct ocfs2_alloc_context
*data_ac
,
2570 struct ocfs2_alloc_context
*meta_ac
)
2573 BUG_ON(!ocfs2_supports_inline_data(osb
) && data_ac
== NULL
);
2575 if (OCFS2_I(inode
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
)
2576 return ocfs2_fill_new_dir_id(osb
, handle
, parent
, inode
, fe_bh
);
2578 if (ocfs2_supports_indexed_dirs(osb
))
2579 return ocfs2_fill_new_dir_dx(osb
, handle
, parent
, inode
, fe_bh
,
2582 return ocfs2_fill_new_dir_el(osb
, handle
, parent
, inode
, fe_bh
,
2586 static int ocfs2_dx_dir_index_block(struct inode
*dir
,
2588 struct buffer_head
**dx_leaves
,
2590 u32
*num_dx_entries
,
2591 struct buffer_head
*dirent_bh
)
2593 int ret
= 0, namelen
, i
;
2594 char *de_buf
, *limit
;
2595 struct ocfs2_dir_entry
*de
;
2596 struct buffer_head
*dx_leaf_bh
;
2597 struct ocfs2_dx_hinfo hinfo
;
2598 u64 dirent_blk
= dirent_bh
->b_blocknr
;
2600 de_buf
= dirent_bh
->b_data
;
2601 limit
= de_buf
+ dir
->i_sb
->s_blocksize
;
2603 while (de_buf
< limit
) {
2604 de
= (struct ocfs2_dir_entry
*)de_buf
;
2606 namelen
= de
->name_len
;
2607 if (!namelen
|| !de
->inode
)
2610 ocfs2_dx_dir_name_hash(dir
, de
->name
, namelen
, &hinfo
);
2612 i
= ocfs2_dx_dir_hash_idx(OCFS2_SB(dir
->i_sb
), &hinfo
);
2613 dx_leaf_bh
= dx_leaves
[i
];
2615 ret
= __ocfs2_dx_dir_leaf_insert(dir
, handle
, &hinfo
,
2616 dirent_blk
, dx_leaf_bh
);
2622 *num_dx_entries
= *num_dx_entries
+ 1;
2625 de_buf
+= le16_to_cpu(de
->rec_len
);
2633 * XXX: This expects dx_root_bh to already be part of the transaction.
2635 static void ocfs2_dx_dir_index_root_block(struct inode
*dir
,
2636 struct buffer_head
*dx_root_bh
,
2637 struct buffer_head
*dirent_bh
)
2639 char *de_buf
, *limit
;
2640 struct ocfs2_dx_root_block
*dx_root
;
2641 struct ocfs2_dir_entry
*de
;
2642 struct ocfs2_dx_hinfo hinfo
;
2643 u64 dirent_blk
= dirent_bh
->b_blocknr
;
2645 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
2647 de_buf
= dirent_bh
->b_data
;
2648 limit
= de_buf
+ dir
->i_sb
->s_blocksize
;
2650 while (de_buf
< limit
) {
2651 de
= (struct ocfs2_dir_entry
*)de_buf
;
2653 if (!de
->name_len
|| !de
->inode
)
2656 ocfs2_dx_dir_name_hash(dir
, de
->name
, de
->name_len
, &hinfo
);
2658 trace_ocfs2_dx_dir_index_root_block(
2659 (unsigned long long)dir
->i_ino
,
2660 hinfo
.major_hash
, hinfo
.minor_hash
,
2661 de
->name_len
, de
->name
,
2662 le16_to_cpu(dx_root
->dr_entries
.de_num_used
));
2664 ocfs2_dx_entry_list_insert(&dx_root
->dr_entries
, &hinfo
,
2667 le32_add_cpu(&dx_root
->dr_num_entries
, 1);
2669 de_buf
+= le16_to_cpu(de
->rec_len
);
2674 * Count the number of inline directory entries in di_bh and compare
2675 * them against the number of entries we can hold in an inline dx root
2678 static int ocfs2_new_dx_should_be_inline(struct inode
*dir
,
2679 struct buffer_head
*di_bh
)
2681 int dirent_count
= 0;
2682 char *de_buf
, *limit
;
2683 struct ocfs2_dir_entry
*de
;
2684 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
2686 de_buf
= di
->id2
.i_data
.id_data
;
2687 limit
= de_buf
+ i_size_read(dir
);
2689 while (de_buf
< limit
) {
2690 de
= (struct ocfs2_dir_entry
*)de_buf
;
2692 if (de
->name_len
&& de
->inode
)
2695 de_buf
+= le16_to_cpu(de
->rec_len
);
2698 /* We are careful to leave room for one extra record. */
2699 return dirent_count
< ocfs2_dx_entries_per_root(dir
->i_sb
);
2703 * Expand rec_len of the rightmost dirent in a directory block so that it
2704 * contains the end of our valid space for dirents. We do this during
2705 * expansion from an inline directory to one with extents. The first dir block
2706 * in that case is taken from the inline data portion of the inode block.
2708 * This will also return the largest amount of contiguous space for a dirent
2709 * in the block. That value is *not* necessarily the last dirent, even after
2710 * expansion. The directory indexing code wants this value for free space
2711 * accounting. We do this here since we're already walking the entire dir
2714 * We add the dir trailer if this filesystem wants it.
2716 static unsigned int ocfs2_expand_last_dirent(char *start
, unsigned int old_size
,
2719 struct super_block
*sb
= dir
->i_sb
;
2720 struct ocfs2_dir_entry
*de
;
2721 struct ocfs2_dir_entry
*prev_de
;
2722 char *de_buf
, *limit
;
2723 unsigned int new_size
= sb
->s_blocksize
;
2724 unsigned int bytes
, this_hole
;
2725 unsigned int largest_hole
= 0;
2727 if (ocfs2_new_dir_wants_trailer(dir
))
2728 new_size
= ocfs2_dir_trailer_blk_off(sb
);
2730 bytes
= new_size
- old_size
;
2732 limit
= start
+ old_size
;
2734 de
= (struct ocfs2_dir_entry
*)de_buf
;
2736 this_hole
= ocfs2_figure_dirent_hole(de
);
2737 if (this_hole
> largest_hole
)
2738 largest_hole
= this_hole
;
2741 de_buf
+= le16_to_cpu(de
->rec_len
);
2742 de
= (struct ocfs2_dir_entry
*)de_buf
;
2743 } while (de_buf
< limit
);
2745 le16_add_cpu(&prev_de
->rec_len
, bytes
);
2747 /* We need to double check this after modification of the final
2749 this_hole
= ocfs2_figure_dirent_hole(prev_de
);
2750 if (this_hole
> largest_hole
)
2751 largest_hole
= this_hole
;
2753 if (largest_hole
>= OCFS2_DIR_MIN_REC_LEN
)
2754 return largest_hole
;
2759 * We allocate enough clusters to fulfill "blocks_wanted", but set
2760 * i_size to exactly one block. Ocfs2_extend_dir() will handle the
2761 * rest automatically for us.
2763 * *first_block_bh is a pointer to the 1st data block allocated to the
2766 static int ocfs2_expand_inline_dir(struct inode
*dir
, struct buffer_head
*di_bh
,
2767 unsigned int blocks_wanted
,
2768 struct ocfs2_dir_lookup_result
*lookup
,
2769 struct buffer_head
**first_block_bh
)
2771 u32 alloc
, dx_alloc
, bit_off
, len
, num_dx_entries
= 0;
2772 struct super_block
*sb
= dir
->i_sb
;
2773 int ret
, i
, num_dx_leaves
= 0, dx_inline
= 0,
2774 credits
= ocfs2_inline_to_extents_credits(sb
);
2775 u64 dx_insert_blkno
, blkno
,
2776 bytes
= blocks_wanted
<< sb
->s_blocksize_bits
;
2777 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
2778 struct ocfs2_inode_info
*oi
= OCFS2_I(dir
);
2779 struct ocfs2_alloc_context
*data_ac
= NULL
;
2780 struct ocfs2_alloc_context
*meta_ac
= NULL
;
2781 struct buffer_head
*dirdata_bh
= NULL
;
2782 struct buffer_head
*dx_root_bh
= NULL
;
2783 struct buffer_head
**dx_leaves
= NULL
;
2784 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
2786 struct ocfs2_extent_tree et
;
2787 struct ocfs2_extent_tree dx_et
;
2788 int did_quota
= 0, bytes_allocated
= 0;
2790 ocfs2_init_dinode_extent_tree(&et
, INODE_CACHE(dir
), di_bh
);
2792 alloc
= ocfs2_clusters_for_bytes(sb
, bytes
);
2795 down_write(&oi
->ip_alloc_sem
);
2797 if (ocfs2_supports_indexed_dirs(osb
)) {
2798 credits
+= ocfs2_add_dir_index_credits(sb
);
2800 dx_inline
= ocfs2_new_dx_should_be_inline(dir
, di_bh
);
2802 /* Add one more cluster for an index leaf */
2804 dx_leaves
= ocfs2_dx_dir_kmalloc_leaves(sb
,
2813 /* This gets us the dx_root */
2814 ret
= ocfs2_reserve_new_metadata_blocks(osb
, 1, &meta_ac
);
2822 * We should never need more than 2 clusters for the unindexed
2823 * tree - maximum dirent size is far less than one block. In
2824 * fact, the only time we'd need more than one cluster is if
2825 * blocksize == clustersize and the dirent won't fit in the
2826 * extra space that the expansion to a single block gives. As
2827 * of today, that only happens on 4k/4k file systems.
2831 ret
= ocfs2_reserve_clusters(osb
, alloc
+ dx_alloc
, &data_ac
);
2838 * Prepare for worst case allocation scenario of two separate
2839 * extents in the unindexed tree.
2842 credits
+= OCFS2_SUBALLOC_ALLOC
;
2844 handle
= ocfs2_start_trans(osb
, credits
);
2845 if (IS_ERR(handle
)) {
2846 ret
= PTR_ERR(handle
);
2851 ret
= dquot_alloc_space_nodirty(dir
,
2852 ocfs2_clusters_to_bytes(osb
->sb
, alloc
+ dx_alloc
));
2857 if (ocfs2_supports_indexed_dirs(osb
) && !dx_inline
) {
2859 * Allocate our index cluster first, to maximize the
2860 * possibility that unindexed leaves grow
2863 ret
= __ocfs2_dx_dir_new_cluster(dir
, 0, handle
, data_ac
,
2864 dx_leaves
, num_dx_leaves
,
2870 bytes_allocated
+= ocfs2_clusters_to_bytes(dir
->i_sb
, 1);
2874 * Try to claim as many clusters as the bitmap can give though
2875 * if we only get one now, that's enough to continue. The rest
2876 * will be claimed after the conversion to extents.
2878 if (ocfs2_dir_resv_allowed(osb
))
2879 data_ac
->ac_resv
= &oi
->ip_la_data_resv
;
2880 ret
= ocfs2_claim_clusters(handle
, data_ac
, 1, &bit_off
, &len
);
2885 bytes_allocated
+= ocfs2_clusters_to_bytes(dir
->i_sb
, 1);
2888 * Operations are carefully ordered so that we set up the new
2889 * data block first. The conversion from inline data to
2892 blkno
= ocfs2_clusters_to_blocks(dir
->i_sb
, bit_off
);
2893 dirdata_bh
= sb_getblk(sb
, blkno
);
2900 ocfs2_set_new_buffer_uptodate(INODE_CACHE(dir
), dirdata_bh
);
2902 ret
= ocfs2_journal_access_db(handle
, INODE_CACHE(dir
), dirdata_bh
,
2903 OCFS2_JOURNAL_ACCESS_CREATE
);
2909 memcpy(dirdata_bh
->b_data
, di
->id2
.i_data
.id_data
, i_size_read(dir
));
2910 memset(dirdata_bh
->b_data
+ i_size_read(dir
), 0,
2911 sb
->s_blocksize
- i_size_read(dir
));
2912 i
= ocfs2_expand_last_dirent(dirdata_bh
->b_data
, i_size_read(dir
), dir
);
2913 if (ocfs2_new_dir_wants_trailer(dir
)) {
2915 * Prepare the dir trailer up front. It will otherwise look
2916 * like a valid dirent. Even if inserting the index fails
2917 * (unlikely), then all we'll have done is given first dir
2918 * block a small amount of fragmentation.
2920 ocfs2_init_dir_trailer(dir
, dirdata_bh
, i
);
2923 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
2924 ocfs2_journal_dirty(handle
, dirdata_bh
);
2926 if (ocfs2_supports_indexed_dirs(osb
) && !dx_inline
) {
2928 * Dx dirs with an external cluster need to do this up
2929 * front. Inline dx root's get handled later, after
2930 * we've allocated our root block. We get passed back
2931 * a total number of items so that dr_num_entries can
2932 * be correctly set once the dx_root has been
2935 ret
= ocfs2_dx_dir_index_block(dir
, handle
, dx_leaves
,
2936 num_dx_leaves
, &num_dx_entries
,
2945 * Set extent, i_size, etc on the directory. After this, the
2946 * inode should contain the same exact dirents as before and
2947 * be fully accessible from system calls.
2949 * We let the later dirent insert modify c/mtime - to the user
2950 * the data hasn't changed.
2952 ret
= ocfs2_journal_access_di(handle
, INODE_CACHE(dir
), di_bh
,
2953 OCFS2_JOURNAL_ACCESS_CREATE
);
2959 spin_lock(&oi
->ip_lock
);
2960 oi
->ip_dyn_features
&= ~OCFS2_INLINE_DATA_FL
;
2961 di
->i_dyn_features
= cpu_to_le16(oi
->ip_dyn_features
);
2962 spin_unlock(&oi
->ip_lock
);
2964 ocfs2_dinode_new_extent_list(dir
, di
);
2966 i_size_write(dir
, sb
->s_blocksize
);
2967 dir
->i_mtime
= dir
->i_ctime
= current_time(dir
);
2969 di
->i_size
= cpu_to_le64(sb
->s_blocksize
);
2970 di
->i_ctime
= di
->i_mtime
= cpu_to_le64(dir
->i_ctime
.tv_sec
);
2971 di
->i_ctime_nsec
= di
->i_mtime_nsec
= cpu_to_le32(dir
->i_ctime
.tv_nsec
);
2972 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
2975 * This should never fail as our extent list is empty and all
2976 * related blocks have been journaled already.
2978 ret
= ocfs2_insert_extent(handle
, &et
, 0, blkno
, len
,
2986 * Set i_blocks after the extent insert for the most up to
2987 * date ip_clusters value.
2989 dir
->i_blocks
= ocfs2_inode_sector_count(dir
);
2991 ocfs2_journal_dirty(handle
, di_bh
);
2993 if (ocfs2_supports_indexed_dirs(osb
)) {
2994 ret
= ocfs2_dx_dir_attach_index(osb
, handle
, dir
, di_bh
,
2995 dirdata_bh
, meta_ac
, dx_inline
,
2996 num_dx_entries
, &dx_root_bh
);
3003 ocfs2_dx_dir_index_root_block(dir
, dx_root_bh
,
3006 ocfs2_init_dx_root_extent_tree(&dx_et
,
3009 ret
= ocfs2_insert_extent(handle
, &dx_et
, 0,
3010 dx_insert_blkno
, 1, 0, NULL
);
3017 * We asked for two clusters, but only got one in the 1st
3018 * pass. Claim the 2nd cluster as a separate extent.
3021 ret
= ocfs2_claim_clusters(handle
, data_ac
, 1, &bit_off
,
3027 blkno
= ocfs2_clusters_to_blocks(dir
->i_sb
, bit_off
);
3029 ret
= ocfs2_insert_extent(handle
, &et
, 1,
3030 blkno
, len
, 0, NULL
);
3035 bytes_allocated
+= ocfs2_clusters_to_bytes(dir
->i_sb
, 1);
3038 *first_block_bh
= dirdata_bh
;
3040 if (ocfs2_supports_indexed_dirs(osb
)) {
3045 * We need to return the correct block within the
3046 * cluster which should hold our entry.
3048 off
= ocfs2_dx_dir_hash_idx(osb
,
3050 get_bh(dx_leaves
[off
]);
3051 lookup
->dl_dx_leaf_bh
= dx_leaves
[off
];
3053 lookup
->dl_dx_root_bh
= dx_root_bh
;
3058 if (ret
< 0 && did_quota
)
3059 dquot_free_space_nodirty(dir
, bytes_allocated
);
3061 ocfs2_commit_trans(osb
, handle
);
3064 up_write(&oi
->ip_alloc_sem
);
3066 ocfs2_free_alloc_context(data_ac
);
3068 ocfs2_free_alloc_context(meta_ac
);
3071 for (i
= 0; i
< num_dx_leaves
; i
++)
3072 brelse(dx_leaves
[i
]);
3082 /* returns a bh of the 1st new block in the allocation. */
3083 static int ocfs2_do_extend_dir(struct super_block
*sb
,
3086 struct buffer_head
*parent_fe_bh
,
3087 struct ocfs2_alloc_context
*data_ac
,
3088 struct ocfs2_alloc_context
*meta_ac
,
3089 struct buffer_head
**new_bh
)
3092 int extend
, did_quota
= 0;
3093 u64 p_blkno
, v_blkno
;
3095 spin_lock(&OCFS2_I(dir
)->ip_lock
);
3096 extend
= (i_size_read(dir
) == ocfs2_clusters_to_bytes(sb
, OCFS2_I(dir
)->ip_clusters
));
3097 spin_unlock(&OCFS2_I(dir
)->ip_lock
);
3100 u32 offset
= OCFS2_I(dir
)->ip_clusters
;
3102 status
= dquot_alloc_space_nodirty(dir
,
3103 ocfs2_clusters_to_bytes(sb
, 1));
3108 status
= ocfs2_add_inode_data(OCFS2_SB(sb
), dir
, &offset
,
3109 1, 0, parent_fe_bh
, handle
,
3110 data_ac
, meta_ac
, NULL
);
3111 BUG_ON(status
== -EAGAIN
);
3118 v_blkno
= ocfs2_blocks_for_bytes(sb
, i_size_read(dir
));
3119 status
= ocfs2_extent_map_get_blocks(dir
, v_blkno
, &p_blkno
, NULL
, NULL
);
3125 *new_bh
= sb_getblk(sb
, p_blkno
);
3133 if (did_quota
&& status
< 0)
3134 dquot_free_space_nodirty(dir
, ocfs2_clusters_to_bytes(sb
, 1));
3139 * Assumes you already have a cluster lock on the directory.
3141 * 'blocks_wanted' is only used if we have an inline directory which
3142 * is to be turned into an extent based one. The size of the dirent to
3143 * insert might be larger than the space gained by growing to just one
3144 * block, so we may have to grow the inode by two blocks in that case.
3146 * If the directory is already indexed, dx_root_bh must be provided.
3148 static int ocfs2_extend_dir(struct ocfs2_super
*osb
,
3150 struct buffer_head
*parent_fe_bh
,
3151 unsigned int blocks_wanted
,
3152 struct ocfs2_dir_lookup_result
*lookup
,
3153 struct buffer_head
**new_de_bh
)
3156 int credits
, num_free_extents
, drop_alloc_sem
= 0;
3158 struct ocfs2_dinode
*fe
= (struct ocfs2_dinode
*) parent_fe_bh
->b_data
;
3159 struct ocfs2_extent_list
*el
= &fe
->id2
.i_list
;
3160 struct ocfs2_alloc_context
*data_ac
= NULL
;
3161 struct ocfs2_alloc_context
*meta_ac
= NULL
;
3162 handle_t
*handle
= NULL
;
3163 struct buffer_head
*new_bh
= NULL
;
3164 struct ocfs2_dir_entry
* de
;
3165 struct super_block
*sb
= osb
->sb
;
3166 struct ocfs2_extent_tree et
;
3167 struct buffer_head
*dx_root_bh
= lookup
->dl_dx_root_bh
;
3169 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
) {
3171 * This would be a code error as an inline directory should
3172 * never have an index root.
3176 status
= ocfs2_expand_inline_dir(dir
, parent_fe_bh
,
3177 blocks_wanted
, lookup
,
3184 /* Expansion from inline to an indexed directory will
3185 * have given us this. */
3186 dx_root_bh
= lookup
->dl_dx_root_bh
;
3188 if (blocks_wanted
== 1) {
3190 * If the new dirent will fit inside the space
3191 * created by pushing out to one block, then
3192 * we can complete the operation
3193 * here. Otherwise we have to expand i_size
3194 * and format the 2nd block below.
3196 BUG_ON(new_bh
== NULL
);
3201 * Get rid of 'new_bh' - we want to format the 2nd
3202 * data block and return that instead.
3207 down_write(&OCFS2_I(dir
)->ip_alloc_sem
);
3209 dir_i_size
= i_size_read(dir
);
3210 credits
= OCFS2_SIMPLE_DIR_EXTEND_CREDITS
;
3214 down_write(&OCFS2_I(dir
)->ip_alloc_sem
);
3216 dir_i_size
= i_size_read(dir
);
3217 trace_ocfs2_extend_dir((unsigned long long)OCFS2_I(dir
)->ip_blkno
,
3220 /* dir->i_size is always block aligned. */
3221 spin_lock(&OCFS2_I(dir
)->ip_lock
);
3222 if (dir_i_size
== ocfs2_clusters_to_bytes(sb
, OCFS2_I(dir
)->ip_clusters
)) {
3223 spin_unlock(&OCFS2_I(dir
)->ip_lock
);
3224 ocfs2_init_dinode_extent_tree(&et
, INODE_CACHE(dir
),
3226 num_free_extents
= ocfs2_num_free_extents(&et
);
3227 if (num_free_extents
< 0) {
3228 status
= num_free_extents
;
3233 if (!num_free_extents
) {
3234 status
= ocfs2_reserve_new_metadata(osb
, el
, &meta_ac
);
3236 if (status
!= -ENOSPC
)
3242 status
= ocfs2_reserve_clusters(osb
, 1, &data_ac
);
3244 if (status
!= -ENOSPC
)
3249 if (ocfs2_dir_resv_allowed(osb
))
3250 data_ac
->ac_resv
= &OCFS2_I(dir
)->ip_la_data_resv
;
3252 credits
= ocfs2_calc_extend_credits(sb
, el
);
3254 spin_unlock(&OCFS2_I(dir
)->ip_lock
);
3255 credits
= OCFS2_SIMPLE_DIR_EXTEND_CREDITS
;
3259 if (ocfs2_dir_indexed(dir
))
3260 credits
++; /* For attaching the new dirent block to the
3263 handle
= ocfs2_start_trans(osb
, credits
);
3264 if (IS_ERR(handle
)) {
3265 status
= PTR_ERR(handle
);
3271 status
= ocfs2_do_extend_dir(osb
->sb
, handle
, dir
, parent_fe_bh
,
3272 data_ac
, meta_ac
, &new_bh
);
3278 ocfs2_set_new_buffer_uptodate(INODE_CACHE(dir
), new_bh
);
3280 status
= ocfs2_journal_access_db(handle
, INODE_CACHE(dir
), new_bh
,
3281 OCFS2_JOURNAL_ACCESS_CREATE
);
3286 memset(new_bh
->b_data
, 0, sb
->s_blocksize
);
3288 de
= (struct ocfs2_dir_entry
*) new_bh
->b_data
;
3290 if (ocfs2_supports_dir_trailer(dir
)) {
3291 de
->rec_len
= cpu_to_le16(ocfs2_dir_trailer_blk_off(sb
));
3293 ocfs2_init_dir_trailer(dir
, new_bh
, le16_to_cpu(de
->rec_len
));
3295 if (ocfs2_dir_indexed(dir
)) {
3296 status
= ocfs2_dx_dir_link_trailer(dir
, handle
,
3297 dx_root_bh
, new_bh
);
3304 de
->rec_len
= cpu_to_le16(sb
->s_blocksize
);
3306 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
3307 ocfs2_journal_dirty(handle
, new_bh
);
3309 dir_i_size
+= dir
->i_sb
->s_blocksize
;
3310 i_size_write(dir
, dir_i_size
);
3311 dir
->i_blocks
= ocfs2_inode_sector_count(dir
);
3312 status
= ocfs2_mark_inode_dirty(handle
, dir
, parent_fe_bh
);
3319 *new_de_bh
= new_bh
;
3323 ocfs2_commit_trans(osb
, handle
);
3325 up_write(&OCFS2_I(dir
)->ip_alloc_sem
);
3328 ocfs2_free_alloc_context(data_ac
);
3330 ocfs2_free_alloc_context(meta_ac
);
3337 static int ocfs2_find_dir_space_id(struct inode
*dir
, struct buffer_head
*di_bh
,
3338 const char *name
, int namelen
,
3339 struct buffer_head
**ret_de_bh
,
3340 unsigned int *blocks_wanted
)
3343 struct super_block
*sb
= dir
->i_sb
;
3344 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
3345 struct ocfs2_dir_entry
*de
, *last_de
= NULL
;
3346 char *de_buf
, *limit
;
3347 unsigned long offset
= 0;
3348 unsigned int rec_len
, new_rec_len
, free_space
= dir
->i_sb
->s_blocksize
;
3351 * This calculates how many free bytes we'd have in block zero, should
3352 * this function force expansion to an extent tree.
3354 if (ocfs2_new_dir_wants_trailer(dir
))
3355 free_space
= ocfs2_dir_trailer_blk_off(sb
) - i_size_read(dir
);
3357 free_space
= dir
->i_sb
->s_blocksize
- i_size_read(dir
);
3359 de_buf
= di
->id2
.i_data
.id_data
;
3360 limit
= de_buf
+ i_size_read(dir
);
3361 rec_len
= OCFS2_DIR_REC_LEN(namelen
);
3363 while (de_buf
< limit
) {
3364 de
= (struct ocfs2_dir_entry
*)de_buf
;
3366 if (!ocfs2_check_dir_entry(dir
, de
, di_bh
, offset
)) {
3370 if (ocfs2_match(namelen
, name
, de
)) {
3375 * No need to check for a trailing dirent record here as
3376 * they're not used for inline dirs.
3379 if (ocfs2_dirent_would_fit(de
, rec_len
)) {
3380 /* Ok, we found a spot. Return this bh and let
3381 * the caller actually fill it in. */
3389 de_buf
+= le16_to_cpu(de
->rec_len
);
3390 offset
+= le16_to_cpu(de
->rec_len
);
3394 * We're going to require expansion of the directory - figure
3395 * out how many blocks we'll need so that a place for the
3396 * dirent can be found.
3399 new_rec_len
= le16_to_cpu(last_de
->rec_len
) + free_space
;
3400 if (new_rec_len
< (rec_len
+ OCFS2_DIR_REC_LEN(last_de
->name_len
)))
3408 static int ocfs2_find_dir_space_el(struct inode
*dir
, const char *name
,
3409 int namelen
, struct buffer_head
**ret_de_bh
)
3411 unsigned long offset
;
3412 struct buffer_head
*bh
= NULL
;
3413 unsigned short rec_len
;
3414 struct ocfs2_dir_entry
*de
;
3415 struct super_block
*sb
= dir
->i_sb
;
3417 int blocksize
= dir
->i_sb
->s_blocksize
;
3419 status
= ocfs2_read_dir_block(dir
, 0, &bh
, 0);
3423 rec_len
= OCFS2_DIR_REC_LEN(namelen
);
3425 de
= (struct ocfs2_dir_entry
*) bh
->b_data
;
3427 if ((char *)de
>= sb
->s_blocksize
+ bh
->b_data
) {
3431 if (i_size_read(dir
) <= offset
) {
3433 * Caller will have to expand this
3439 status
= ocfs2_read_dir_block(dir
,
3440 offset
>> sb
->s_blocksize_bits
,
3445 /* move to next block */
3446 de
= (struct ocfs2_dir_entry
*) bh
->b_data
;
3448 if (!ocfs2_check_dir_entry(dir
, de
, bh
, offset
)) {
3452 if (ocfs2_match(namelen
, name
, de
)) {
3457 if (ocfs2_skip_dir_trailer(dir
, de
, offset
% blocksize
,
3461 if (ocfs2_dirent_would_fit(de
, rec_len
)) {
3462 /* Ok, we found a spot. Return this bh and let
3463 * the caller actually fill it in. */
3470 offset
+= le16_to_cpu(de
->rec_len
);
3471 de
= (struct ocfs2_dir_entry
*)((char *) de
+ le16_to_cpu(de
->rec_len
));
3482 static int dx_leaf_sort_cmp(const void *a
, const void *b
)
3484 const struct ocfs2_dx_entry
*entry1
= a
;
3485 const struct ocfs2_dx_entry
*entry2
= b
;
3486 u32 major_hash1
= le32_to_cpu(entry1
->dx_major_hash
);
3487 u32 major_hash2
= le32_to_cpu(entry2
->dx_major_hash
);
3488 u32 minor_hash1
= le32_to_cpu(entry1
->dx_minor_hash
);
3489 u32 minor_hash2
= le32_to_cpu(entry2
->dx_minor_hash
);
3491 if (major_hash1
> major_hash2
)
3493 if (major_hash1
< major_hash2
)
3497 * It is not strictly necessary to sort by minor
3499 if (minor_hash1
> minor_hash2
)
3501 if (minor_hash1
< minor_hash2
)
3506 static void dx_leaf_sort_swap(void *a
, void *b
, int size
)
3508 struct ocfs2_dx_entry
*entry1
= a
;
3509 struct ocfs2_dx_entry
*entry2
= b
;
3511 BUG_ON(size
!= sizeof(*entry1
));
3513 swap(*entry1
, *entry2
);
3516 static int ocfs2_dx_leaf_same_major(struct ocfs2_dx_leaf
*dx_leaf
)
3518 struct ocfs2_dx_entry_list
*dl_list
= &dx_leaf
->dl_list
;
3519 int i
, num
= le16_to_cpu(dl_list
->de_num_used
);
3521 for (i
= 0; i
< (num
- 1); i
++) {
3522 if (le32_to_cpu(dl_list
->de_entries
[i
].dx_major_hash
) !=
3523 le32_to_cpu(dl_list
->de_entries
[i
+ 1].dx_major_hash
))
3531 * Find the optimal value to split this leaf on. This expects the leaf
3532 * entries to be in sorted order.
3534 * leaf_cpos is the cpos of the leaf we're splitting. insert_hash is
3535 * the hash we want to insert.
3537 * This function is only concerned with the major hash - that which
3538 * determines which cluster an item belongs to.
3540 static int ocfs2_dx_dir_find_leaf_split(struct ocfs2_dx_leaf
*dx_leaf
,
3541 u32 leaf_cpos
, u32 insert_hash
,
3544 struct ocfs2_dx_entry_list
*dl_list
= &dx_leaf
->dl_list
;
3545 int i
, num_used
= le16_to_cpu(dl_list
->de_num_used
);
3549 * There's a couple rare, but nasty corner cases we have to
3550 * check for here. All of them involve a leaf where all value
3551 * have the same hash, which is what we look for first.
3553 * Most of the time, all of the above is false, and we simply
3554 * pick the median value for a split.
3556 allsame
= ocfs2_dx_leaf_same_major(dx_leaf
);
3558 u32 val
= le32_to_cpu(dl_list
->de_entries
[0].dx_major_hash
);
3560 if (val
== insert_hash
) {
3562 * No matter where we would choose to split,
3563 * the new entry would want to occupy the same
3564 * block as these. Since there's no space left
3565 * in their existing block, we know there
3566 * won't be space after the split.
3571 if (val
== leaf_cpos
) {
3573 * Because val is the same as leaf_cpos (which
3574 * is the smallest value this leaf can have),
3575 * yet is not equal to insert_hash, then we
3576 * know that insert_hash *must* be larger than
3577 * val (and leaf_cpos). At least cpos+1 in value.
3579 * We also know then, that there cannot be an
3580 * adjacent extent (otherwise we'd be looking
3581 * at it). Choosing this value gives us a
3582 * chance to get some contiguousness.
3584 *split_hash
= leaf_cpos
+ 1;
3588 if (val
> insert_hash
) {
3590 * val can not be the same as insert hash, and
3591 * also must be larger than leaf_cpos. Also,
3592 * we know that there can't be a leaf between
3593 * cpos and val, otherwise the entries with
3594 * hash 'val' would be there.
3600 *split_hash
= insert_hash
;
3605 * Since the records are sorted and the checks above
3606 * guaranteed that not all records in this block are the same,
3607 * we simple travel forward, from the median, and pick the 1st
3608 * record whose value is larger than leaf_cpos.
3610 for (i
= (num_used
/ 2); i
< num_used
; i
++)
3611 if (le32_to_cpu(dl_list
->de_entries
[i
].dx_major_hash
) >
3615 BUG_ON(i
== num_used
); /* Should be impossible */
3616 *split_hash
= le32_to_cpu(dl_list
->de_entries
[i
].dx_major_hash
);
3621 * Transfer all entries in orig_dx_leaves whose major hash is equal to or
3622 * larger than split_hash into new_dx_leaves. We use a temporary
3623 * buffer (tmp_dx_leaf) to make the changes to the original leaf blocks.
3625 * Since the block offset inside a leaf (cluster) is a constant mask
3626 * of minor_hash, we can optimize - an item at block offset X within
3627 * the original cluster, will be at offset X within the new cluster.
3629 static void ocfs2_dx_dir_transfer_leaf(struct inode
*dir
, u32 split_hash
,
3631 struct ocfs2_dx_leaf
*tmp_dx_leaf
,
3632 struct buffer_head
**orig_dx_leaves
,
3633 struct buffer_head
**new_dx_leaves
,
3638 struct ocfs2_dx_leaf
*orig_dx_leaf
, *new_dx_leaf
;
3639 struct ocfs2_dx_entry_list
*orig_list
, *tmp_list
;
3640 struct ocfs2_dx_entry
*dx_entry
;
3642 tmp_list
= &tmp_dx_leaf
->dl_list
;
3644 for (i
= 0; i
< num_dx_leaves
; i
++) {
3645 orig_dx_leaf
= (struct ocfs2_dx_leaf
*) orig_dx_leaves
[i
]->b_data
;
3646 orig_list
= &orig_dx_leaf
->dl_list
;
3647 new_dx_leaf
= (struct ocfs2_dx_leaf
*) new_dx_leaves
[i
]->b_data
;
3649 num_used
= le16_to_cpu(orig_list
->de_num_used
);
3651 memcpy(tmp_dx_leaf
, orig_dx_leaf
, dir
->i_sb
->s_blocksize
);
3652 tmp_list
->de_num_used
= cpu_to_le16(0);
3653 memset(&tmp_list
->de_entries
, 0, sizeof(*dx_entry
)*num_used
);
3655 for (j
= 0; j
< num_used
; j
++) {
3656 dx_entry
= &orig_list
->de_entries
[j
];
3657 major_hash
= le32_to_cpu(dx_entry
->dx_major_hash
);
3658 if (major_hash
>= split_hash
)
3659 ocfs2_dx_dir_leaf_insert_tail(new_dx_leaf
,
3662 ocfs2_dx_dir_leaf_insert_tail(tmp_dx_leaf
,
3665 memcpy(orig_dx_leaf
, tmp_dx_leaf
, dir
->i_sb
->s_blocksize
);
3667 ocfs2_journal_dirty(handle
, orig_dx_leaves
[i
]);
3668 ocfs2_journal_dirty(handle
, new_dx_leaves
[i
]);
3672 static int ocfs2_dx_dir_rebalance_credits(struct ocfs2_super
*osb
,
3673 struct ocfs2_dx_root_block
*dx_root
)
3675 int credits
= ocfs2_clusters_to_blocks(osb
->sb
, 3);
3677 credits
+= ocfs2_calc_extend_credits(osb
->sb
, &dx_root
->dr_list
);
3678 credits
+= ocfs2_quota_trans_credits(osb
->sb
);
3683 * Find the median value in dx_leaf_bh and allocate a new leaf to move
3684 * half our entries into.
3686 static int ocfs2_dx_dir_rebalance(struct ocfs2_super
*osb
, struct inode
*dir
,
3687 struct buffer_head
*dx_root_bh
,
3688 struct buffer_head
*dx_leaf_bh
,
3689 struct ocfs2_dx_hinfo
*hinfo
, u32 leaf_cpos
,
3692 struct ocfs2_dx_leaf
*dx_leaf
= (struct ocfs2_dx_leaf
*)dx_leaf_bh
->b_data
;
3693 int credits
, ret
, i
, num_used
, did_quota
= 0;
3694 u32 cpos
, split_hash
, insert_hash
= hinfo
->major_hash
;
3695 u64 orig_leaves_start
;
3697 struct buffer_head
**orig_dx_leaves
= NULL
;
3698 struct buffer_head
**new_dx_leaves
= NULL
;
3699 struct ocfs2_alloc_context
*data_ac
= NULL
, *meta_ac
= NULL
;
3700 struct ocfs2_extent_tree et
;
3701 handle_t
*handle
= NULL
;
3702 struct ocfs2_dx_root_block
*dx_root
;
3703 struct ocfs2_dx_leaf
*tmp_dx_leaf
= NULL
;
3705 trace_ocfs2_dx_dir_rebalance((unsigned long long)OCFS2_I(dir
)->ip_blkno
,
3706 (unsigned long long)leaf_blkno
,
3709 ocfs2_init_dx_root_extent_tree(&et
, INODE_CACHE(dir
), dx_root_bh
);
3711 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
3713 * XXX: This is a rather large limit. We should use a more
3716 if (le32_to_cpu(dx_root
->dr_clusters
) == UINT_MAX
)
3719 num_used
= le16_to_cpu(dx_leaf
->dl_list
.de_num_used
);
3720 if (num_used
< le16_to_cpu(dx_leaf
->dl_list
.de_count
)) {
3721 mlog(ML_ERROR
, "DX Dir: %llu, Asked to rebalance empty leaf: "
3722 "%llu, %d\n", (unsigned long long)OCFS2_I(dir
)->ip_blkno
,
3723 (unsigned long long)leaf_blkno
, num_used
);
3728 orig_dx_leaves
= ocfs2_dx_dir_kmalloc_leaves(osb
->sb
, &num_dx_leaves
);
3729 if (!orig_dx_leaves
) {
3735 new_dx_leaves
= ocfs2_dx_dir_kmalloc_leaves(osb
->sb
, NULL
);
3736 if (!new_dx_leaves
) {
3742 ret
= ocfs2_lock_allocators(dir
, &et
, 1, 0, &data_ac
, &meta_ac
);
3749 credits
= ocfs2_dx_dir_rebalance_credits(osb
, dx_root
);
3750 handle
= ocfs2_start_trans(osb
, credits
);
3751 if (IS_ERR(handle
)) {
3752 ret
= PTR_ERR(handle
);
3758 ret
= dquot_alloc_space_nodirty(dir
,
3759 ocfs2_clusters_to_bytes(dir
->i_sb
, 1));
3764 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
), dx_leaf_bh
,
3765 OCFS2_JOURNAL_ACCESS_WRITE
);
3772 * This block is changing anyway, so we can sort it in place.
3774 sort(dx_leaf
->dl_list
.de_entries
, num_used
,
3775 sizeof(struct ocfs2_dx_entry
), dx_leaf_sort_cmp
,
3778 ocfs2_journal_dirty(handle
, dx_leaf_bh
);
3780 ret
= ocfs2_dx_dir_find_leaf_split(dx_leaf
, leaf_cpos
, insert_hash
,
3787 trace_ocfs2_dx_dir_rebalance_split(leaf_cpos
, split_hash
, insert_hash
);
3790 * We have to carefully order operations here. There are items
3791 * which want to be in the new cluster before insert, but in
3792 * order to put those items in the new cluster, we alter the
3793 * old cluster. A failure to insert gets nasty.
3795 * So, start by reserving writes to the old
3796 * cluster. ocfs2_dx_dir_new_cluster will reserve writes on
3797 * the new cluster for us, before inserting it. The insert
3798 * won't happen if there's an error before that. Once the
3799 * insert is done then, we can transfer from one leaf into the
3800 * other without fear of hitting any error.
3804 * The leaf transfer wants some scratch space so that we don't
3805 * wind up doing a bunch of expensive memmove().
3807 tmp_dx_leaf
= kmalloc(osb
->sb
->s_blocksize
, GFP_NOFS
);
3814 orig_leaves_start
= ocfs2_block_to_cluster_start(dir
->i_sb
, leaf_blkno
);
3815 ret
= ocfs2_read_dx_leaves(dir
, orig_leaves_start
, num_dx_leaves
,
3823 ret
= ocfs2_dx_dir_new_cluster(dir
, &et
, cpos
, handle
,
3824 data_ac
, meta_ac
, new_dx_leaves
,
3831 for (i
= 0; i
< num_dx_leaves
; i
++) {
3832 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
),
3834 OCFS2_JOURNAL_ACCESS_WRITE
);
3840 ret
= ocfs2_journal_access_dl(handle
, INODE_CACHE(dir
),
3842 OCFS2_JOURNAL_ACCESS_WRITE
);
3849 ocfs2_dx_dir_transfer_leaf(dir
, split_hash
, handle
, tmp_dx_leaf
,
3850 orig_dx_leaves
, new_dx_leaves
, num_dx_leaves
);
3853 if (ret
< 0 && did_quota
)
3854 dquot_free_space_nodirty(dir
,
3855 ocfs2_clusters_to_bytes(dir
->i_sb
, 1));
3857 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
3858 ocfs2_commit_trans(osb
, handle
);
3861 if (orig_dx_leaves
|| new_dx_leaves
) {
3862 for (i
= 0; i
< num_dx_leaves
; i
++) {
3864 brelse(orig_dx_leaves
[i
]);
3866 brelse(new_dx_leaves
[i
]);
3868 kfree(orig_dx_leaves
);
3869 kfree(new_dx_leaves
);
3873 ocfs2_free_alloc_context(meta_ac
);
3875 ocfs2_free_alloc_context(data_ac
);
3881 static int ocfs2_find_dir_space_dx(struct ocfs2_super
*osb
, struct inode
*dir
,
3882 struct buffer_head
*di_bh
,
3883 struct buffer_head
*dx_root_bh
,
3884 const char *name
, int namelen
,
3885 struct ocfs2_dir_lookup_result
*lookup
)
3887 int ret
, rebalanced
= 0;
3888 struct ocfs2_dx_root_block
*dx_root
;
3889 struct buffer_head
*dx_leaf_bh
= NULL
;
3890 struct ocfs2_dx_leaf
*dx_leaf
;
3894 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
3897 ret
= ocfs2_dx_dir_lookup(dir
, &dx_root
->dr_list
, &lookup
->dl_hinfo
,
3898 &leaf_cpos
, &blkno
);
3904 ret
= ocfs2_read_dx_leaf(dir
, blkno
, &dx_leaf_bh
);
3910 dx_leaf
= (struct ocfs2_dx_leaf
*)dx_leaf_bh
->b_data
;
3912 if (le16_to_cpu(dx_leaf
->dl_list
.de_num_used
) >=
3913 le16_to_cpu(dx_leaf
->dl_list
.de_count
)) {
3916 * Rebalancing should have provided us with
3917 * space in an appropriate leaf.
3919 * XXX: Is this an abnormal condition then?
3920 * Should we print a message here?
3926 ret
= ocfs2_dx_dir_rebalance(osb
, dir
, dx_root_bh
, dx_leaf_bh
,
3927 &lookup
->dl_hinfo
, leaf_cpos
,
3936 * Restart the lookup. The rebalance might have
3937 * changed which block our item fits into. Mark our
3938 * progress, so we only execute this once.
3943 goto restart_search
;
3946 lookup
->dl_dx_leaf_bh
= dx_leaf_bh
;
3954 static int ocfs2_search_dx_free_list(struct inode
*dir
,
3955 struct buffer_head
*dx_root_bh
,
3957 struct ocfs2_dir_lookup_result
*lookup
)
3960 struct buffer_head
*leaf_bh
= NULL
, *prev_leaf_bh
= NULL
;
3961 struct ocfs2_dir_block_trailer
*db
;
3963 int rec_len
= OCFS2_DIR_REC_LEN(namelen
);
3964 struct ocfs2_dx_root_block
*dx_root
;
3966 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
3967 next_block
= le64_to_cpu(dx_root
->dr_free_blk
);
3969 while (next_block
) {
3970 brelse(prev_leaf_bh
);
3971 prev_leaf_bh
= leaf_bh
;
3974 ret
= ocfs2_read_dir_block_direct(dir
, next_block
, &leaf_bh
);
3980 db
= ocfs2_trailer_from_bh(leaf_bh
, dir
->i_sb
);
3981 if (rec_len
<= le16_to_cpu(db
->db_free_rec_len
)) {
3982 lookup
->dl_leaf_bh
= leaf_bh
;
3983 lookup
->dl_prev_leaf_bh
= prev_leaf_bh
;
3985 prev_leaf_bh
= NULL
;
3989 next_block
= le64_to_cpu(db
->db_free_next
);
3998 brelse(prev_leaf_bh
);
4002 static int ocfs2_expand_inline_dx_root(struct inode
*dir
,
4003 struct buffer_head
*dx_root_bh
)
4005 int ret
, num_dx_leaves
, i
, j
, did_quota
= 0;
4006 struct buffer_head
**dx_leaves
= NULL
;
4007 struct ocfs2_extent_tree et
;
4009 struct ocfs2_alloc_context
*data_ac
= NULL
;
4010 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
4011 handle_t
*handle
= NULL
;
4012 struct ocfs2_dx_root_block
*dx_root
;
4013 struct ocfs2_dx_entry_list
*entry_list
;
4014 struct ocfs2_dx_entry
*dx_entry
;
4015 struct ocfs2_dx_leaf
*target_leaf
;
4017 ret
= ocfs2_reserve_clusters(osb
, 1, &data_ac
);
4023 dx_leaves
= ocfs2_dx_dir_kmalloc_leaves(osb
->sb
, &num_dx_leaves
);
4030 handle
= ocfs2_start_trans(osb
, ocfs2_calc_dxi_expand_credits(osb
->sb
));
4031 if (IS_ERR(handle
)) {
4032 ret
= PTR_ERR(handle
);
4037 ret
= dquot_alloc_space_nodirty(dir
,
4038 ocfs2_clusters_to_bytes(osb
->sb
, 1));
4044 * We do this up front, before the allocation, so that a
4045 * failure to add the dx_root_bh to the journal won't result
4046 * us losing clusters.
4048 ret
= ocfs2_journal_access_dr(handle
, INODE_CACHE(dir
), dx_root_bh
,
4049 OCFS2_JOURNAL_ACCESS_WRITE
);
4055 ret
= __ocfs2_dx_dir_new_cluster(dir
, 0, handle
, data_ac
, dx_leaves
,
4056 num_dx_leaves
, &insert_blkno
);
4063 * Transfer the entries from our dx_root into the appropriate
4066 dx_root
= (struct ocfs2_dx_root_block
*) dx_root_bh
->b_data
;
4067 entry_list
= &dx_root
->dr_entries
;
4069 for (i
= 0; i
< le16_to_cpu(entry_list
->de_num_used
); i
++) {
4070 dx_entry
= &entry_list
->de_entries
[i
];
4072 j
= __ocfs2_dx_dir_hash_idx(osb
,
4073 le32_to_cpu(dx_entry
->dx_minor_hash
));
4074 target_leaf
= (struct ocfs2_dx_leaf
*)dx_leaves
[j
]->b_data
;
4076 ocfs2_dx_dir_leaf_insert_tail(target_leaf
, dx_entry
);
4078 /* Each leaf has been passed to the journal already
4079 * via __ocfs2_dx_dir_new_cluster() */
4082 dx_root
->dr_flags
&= ~OCFS2_DX_FLAG_INLINE
;
4083 memset(&dx_root
->dr_list
, 0, osb
->sb
->s_blocksize
-
4084 offsetof(struct ocfs2_dx_root_block
, dr_list
));
4085 dx_root
->dr_list
.l_count
=
4086 cpu_to_le16(ocfs2_extent_recs_per_dx_root(osb
->sb
));
4088 /* This should never fail considering we start with an empty
4090 ocfs2_init_dx_root_extent_tree(&et
, INODE_CACHE(dir
), dx_root_bh
);
4091 ret
= ocfs2_insert_extent(handle
, &et
, 0, insert_blkno
, 1, 0, NULL
);
4096 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
4097 ocfs2_journal_dirty(handle
, dx_root_bh
);
4100 if (ret
< 0 && did_quota
)
4101 dquot_free_space_nodirty(dir
,
4102 ocfs2_clusters_to_bytes(dir
->i_sb
, 1));
4104 ocfs2_commit_trans(osb
, handle
);
4108 ocfs2_free_alloc_context(data_ac
);
4111 for (i
= 0; i
< num_dx_leaves
; i
++)
4112 brelse(dx_leaves
[i
]);
4118 static int ocfs2_inline_dx_has_space(struct buffer_head
*dx_root_bh
)
4120 struct ocfs2_dx_root_block
*dx_root
;
4121 struct ocfs2_dx_entry_list
*entry_list
;
4123 dx_root
= (struct ocfs2_dx_root_block
*) dx_root_bh
->b_data
;
4124 entry_list
= &dx_root
->dr_entries
;
4126 if (le16_to_cpu(entry_list
->de_num_used
) >=
4127 le16_to_cpu(entry_list
->de_count
))
4133 static int ocfs2_prepare_dx_dir_for_insert(struct inode
*dir
,
4134 struct buffer_head
*di_bh
,
4137 struct ocfs2_dir_lookup_result
*lookup
)
4139 int ret
, free_dx_root
= 1;
4140 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
4141 struct buffer_head
*dx_root_bh
= NULL
;
4142 struct buffer_head
*leaf_bh
= NULL
;
4143 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
4144 struct ocfs2_dx_root_block
*dx_root
;
4146 ret
= ocfs2_read_dx_root(dir
, di
, &dx_root_bh
);
4152 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
4153 if (le32_to_cpu(dx_root
->dr_num_entries
) == OCFS2_DX_ENTRIES_MAX
) {
4159 if (ocfs2_dx_root_inline(dx_root
)) {
4160 ret
= ocfs2_inline_dx_has_space(dx_root_bh
);
4166 * We ran out of room in the root block. Expand it to
4167 * an extent, then allow ocfs2_find_dir_space_dx to do
4170 ret
= ocfs2_expand_inline_dx_root(dir
, dx_root_bh
);
4178 * Insert preparation for an indexed directory is split into two
4179 * steps. The call to find_dir_space_dx reserves room in the index for
4180 * an additional item. If we run out of space there, it's a real error
4181 * we can't continue on.
4183 ret
= ocfs2_find_dir_space_dx(osb
, dir
, di_bh
, dx_root_bh
, name
,
4192 * Next, we need to find space in the unindexed tree. This call
4193 * searches using the free space linked list. If the unindexed tree
4194 * lacks sufficient space, we'll expand it below. The expansion code
4195 * is smart enough to add any new blocks to the free space list.
4197 ret
= ocfs2_search_dx_free_list(dir
, dx_root_bh
, namelen
, lookup
);
4198 if (ret
&& ret
!= -ENOSPC
) {
4203 /* Do this up here - ocfs2_extend_dir might need the dx_root */
4204 lookup
->dl_dx_root_bh
= dx_root_bh
;
4207 if (ret
== -ENOSPC
) {
4208 ret
= ocfs2_extend_dir(osb
, dir
, di_bh
, 1, lookup
, &leaf_bh
);
4216 * We make the assumption here that new leaf blocks are added
4217 * to the front of our free list.
4219 lookup
->dl_prev_leaf_bh
= NULL
;
4220 lookup
->dl_leaf_bh
= leaf_bh
;
4230 * Get a directory ready for insert. Any directory allocation required
4231 * happens here. Success returns zero, and enough context in the dir
4232 * lookup result that ocfs2_add_entry() will be able complete the task
4233 * with minimal performance impact.
4235 int ocfs2_prepare_dir_for_insert(struct ocfs2_super
*osb
,
4237 struct buffer_head
*parent_fe_bh
,
4240 struct ocfs2_dir_lookup_result
*lookup
)
4243 unsigned int blocks_wanted
= 1;
4244 struct buffer_head
*bh
= NULL
;
4246 trace_ocfs2_prepare_dir_for_insert(
4247 (unsigned long long)OCFS2_I(dir
)->ip_blkno
, namelen
);
4256 * Do this up front to reduce confusion.
4258 * The directory might start inline, then be turned into an
4259 * indexed one, in which case we'd need to hash deep inside
4260 * ocfs2_find_dir_space_id(). Since
4261 * ocfs2_prepare_dx_dir_for_insert() also needs this hash
4262 * done, there seems no point in spreading out the calls. We
4263 * can optimize away the case where the file system doesn't
4266 if (ocfs2_supports_indexed_dirs(osb
))
4267 ocfs2_dx_dir_name_hash(dir
, name
, namelen
, &lookup
->dl_hinfo
);
4269 if (ocfs2_dir_indexed(dir
)) {
4270 ret
= ocfs2_prepare_dx_dir_for_insert(dir
, parent_fe_bh
,
4271 name
, namelen
, lookup
);
4277 if (OCFS2_I(dir
)->ip_dyn_features
& OCFS2_INLINE_DATA_FL
) {
4278 ret
= ocfs2_find_dir_space_id(dir
, parent_fe_bh
, name
,
4279 namelen
, &bh
, &blocks_wanted
);
4281 ret
= ocfs2_find_dir_space_el(dir
, name
, namelen
, &bh
);
4283 if (ret
&& ret
!= -ENOSPC
) {
4288 if (ret
== -ENOSPC
) {
4290 * We have to expand the directory to add this name.
4294 ret
= ocfs2_extend_dir(osb
, dir
, parent_fe_bh
, blocks_wanted
,
4305 lookup
->dl_leaf_bh
= bh
;
4312 static int ocfs2_dx_dir_remove_index(struct inode
*dir
,
4313 struct buffer_head
*di_bh
,
4314 struct buffer_head
*dx_root_bh
)
4317 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
4318 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
4319 struct ocfs2_dx_root_block
*dx_root
;
4320 struct inode
*dx_alloc_inode
= NULL
;
4321 struct buffer_head
*dx_alloc_bh
= NULL
;
4327 dx_root
= (struct ocfs2_dx_root_block
*) dx_root_bh
->b_data
;
4329 dx_alloc_inode
= ocfs2_get_system_file_inode(osb
,
4330 EXTENT_ALLOC_SYSTEM_INODE
,
4331 le16_to_cpu(dx_root
->dr_suballoc_slot
));
4332 if (!dx_alloc_inode
) {
4337 inode_lock(dx_alloc_inode
);
4339 ret
= ocfs2_inode_lock(dx_alloc_inode
, &dx_alloc_bh
, 1);
4345 handle
= ocfs2_start_trans(osb
, OCFS2_DX_ROOT_REMOVE_CREDITS
);
4346 if (IS_ERR(handle
)) {
4347 ret
= PTR_ERR(handle
);
4352 ret
= ocfs2_journal_access_di(handle
, INODE_CACHE(dir
), di_bh
,
4353 OCFS2_JOURNAL_ACCESS_WRITE
);
4359 spin_lock(&OCFS2_I(dir
)->ip_lock
);
4360 OCFS2_I(dir
)->ip_dyn_features
&= ~OCFS2_INDEXED_DIR_FL
;
4361 di
->i_dyn_features
= cpu_to_le16(OCFS2_I(dir
)->ip_dyn_features
);
4362 spin_unlock(&OCFS2_I(dir
)->ip_lock
);
4363 di
->i_dx_root
= cpu_to_le64(0ULL);
4364 ocfs2_update_inode_fsync_trans(handle
, dir
, 1);
4366 ocfs2_journal_dirty(handle
, di_bh
);
4368 blk
= le64_to_cpu(dx_root
->dr_blkno
);
4369 bit
= le16_to_cpu(dx_root
->dr_suballoc_bit
);
4370 if (dx_root
->dr_suballoc_loc
)
4371 bg_blkno
= le64_to_cpu(dx_root
->dr_suballoc_loc
);
4373 bg_blkno
= ocfs2_which_suballoc_group(blk
, bit
);
4374 ret
= ocfs2_free_suballoc_bits(handle
, dx_alloc_inode
, dx_alloc_bh
,
4380 ocfs2_commit_trans(osb
, handle
);
4383 ocfs2_inode_unlock(dx_alloc_inode
, 1);
4386 inode_unlock(dx_alloc_inode
);
4387 brelse(dx_alloc_bh
);
4389 iput(dx_alloc_inode
);
4393 int ocfs2_dx_dir_truncate(struct inode
*dir
, struct buffer_head
*di_bh
)
4396 unsigned int uninitialized_var(clen
);
4397 u32 major_hash
= UINT_MAX
, p_cpos
, uninitialized_var(cpos
);
4398 u64
uninitialized_var(blkno
);
4399 struct ocfs2_super
*osb
= OCFS2_SB(dir
->i_sb
);
4400 struct buffer_head
*dx_root_bh
= NULL
;
4401 struct ocfs2_dx_root_block
*dx_root
;
4402 struct ocfs2_dinode
*di
= (struct ocfs2_dinode
*)di_bh
->b_data
;
4403 struct ocfs2_cached_dealloc_ctxt dealloc
;
4404 struct ocfs2_extent_tree et
;
4406 ocfs2_init_dealloc_ctxt(&dealloc
);
4408 if (!ocfs2_dir_indexed(dir
))
4411 ret
= ocfs2_read_dx_root(dir
, di
, &dx_root_bh
);
4416 dx_root
= (struct ocfs2_dx_root_block
*)dx_root_bh
->b_data
;
4418 if (ocfs2_dx_root_inline(dx_root
))
4421 ocfs2_init_dx_root_extent_tree(&et
, INODE_CACHE(dir
), dx_root_bh
);
4423 /* XXX: What if dr_clusters is too large? */
4424 while (le32_to_cpu(dx_root
->dr_clusters
)) {
4425 ret
= ocfs2_dx_dir_lookup_rec(dir
, &dx_root
->dr_list
,
4426 major_hash
, &cpos
, &blkno
, &clen
);
4432 p_cpos
= ocfs2_blocks_to_clusters(dir
->i_sb
, blkno
);
4434 ret
= ocfs2_remove_btree_range(dir
, &et
, cpos
, p_cpos
, clen
, 0,
4435 &dealloc
, 0, false);
4444 major_hash
= cpos
- 1;
4448 ret
= ocfs2_dx_dir_remove_index(dir
, di_bh
, dx_root_bh
);
4454 ocfs2_remove_from_cache(INODE_CACHE(dir
), dx_root_bh
);
4456 ocfs2_schedule_truncate_log_flush(osb
, 1);
4457 ocfs2_run_deallocs(osb
, &dealloc
);