17 #include "dat.h"
24  * struct nilfs_dat_info - on-memory private data of DAT file
26  * @palloc_cache: persistent object allocator cache of DAT file
27  * @shadow: shadow map of DAT file
35 static inline struct nilfs_dat_info *NILFS_DAT_I(struct inode *dat)  in NILFS_DAT_I()  argument
37 	return (struct nilfs_dat_info *)NILFS_MDT(dat);  in NILFS_DAT_I()
40 static int nilfs_dat_prepare_entry(struct inode *dat,  in nilfs_dat_prepare_entry()  argument
45 	ret = nilfs_palloc_get_entry_block(dat, req->pr_entry_nr,  in nilfs_dat_prepare_entry()
48 		nilfs_err(dat->i_sb,  in nilfs_dat_prepare_entry()
49 			  "DAT doesn't have a block to manage vblocknr = %llu",  in nilfs_dat_prepare_entry()
60 static void nilfs_dat_commit_entry(struct inode *dat,  in nilfs_dat_commit_entry()  argument
64 	nilfs_mdt_mark_dirty(dat);  in nilfs_dat_commit_entry()
68 static void nilfs_dat_abort_entry(struct inode *dat,  in nilfs_dat_abort_entry()  argument
74 int nilfs_dat_prepare_alloc(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_prepare_alloc()  argument
78 	ret = nilfs_palloc_prepare_alloc_entry(dat, req, true);  in nilfs_dat_prepare_alloc()
82 	ret = nilfs_dat_prepare_entry(dat, req, 1);  in nilfs_dat_prepare_alloc()
84 		nilfs_palloc_abort_alloc_entry(dat, req);  in nilfs_dat_prepare_alloc()
89 void nilfs_dat_commit_alloc(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_commit_alloc()  argument
95 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_commit_alloc()
102 	nilfs_palloc_commit_alloc_entry(dat, req);  in nilfs_dat_commit_alloc()
103 	nilfs_dat_commit_entry(dat, req);  in nilfs_dat_commit_alloc()
106 void nilfs_dat_abort_alloc(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_abort_alloc()  argument
108 	nilfs_dat_abort_entry(dat, req);  in nilfs_dat_abort_alloc()
109 	nilfs_palloc_abort_alloc_entry(dat, req);  in nilfs_dat_abort_alloc()
112 static void nilfs_dat_commit_free(struct inode *dat,  in nilfs_dat_commit_free()  argument
119 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_commit_free()
126 	nilfs_dat_commit_entry(dat, req);  in nilfs_dat_commit_free()
129 		nilfs_error(dat->i_sb,  in nilfs_dat_commit_free()
134 	nilfs_palloc_commit_free_entry(dat, req);  in nilfs_dat_commit_free()
137 int nilfs_dat_prepare_start(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_prepare_start()  argument
139 	return nilfs_dat_prepare_entry(dat, req, 0);  in nilfs_dat_prepare_start()
142 void nilfs_dat_commit_start(struct inode *dat, struct nilfs_palloc_req *req,  in nilfs_dat_commit_start()  argument
149 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_commit_start()
151 	entry->de_start = cpu_to_le64(nilfs_mdt_cno(dat));  in nilfs_dat_commit_start()
155 	nilfs_dat_commit_entry(dat, req);  in nilfs_dat_commit_start()
158 int nilfs_dat_prepare_end(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_prepare_end()  argument
166 	ret = nilfs_dat_prepare_entry(dat, req, 0);  in nilfs_dat_prepare_end()
171 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_prepare_end()
178 		ret = nilfs_palloc_prepare_free_entry(dat, req);  in nilfs_dat_prepare_end()
180 			nilfs_dat_abort_entry(dat, req);  in nilfs_dat_prepare_end()
184 	if (unlikely(start > nilfs_mdt_cno(dat))) {  in nilfs_dat_prepare_end()
185 		nilfs_err(dat->i_sb,  in nilfs_dat_prepare_end()
189 			  (unsigned long long)nilfs_mdt_cno(dat));  in nilfs_dat_prepare_end()
190 		nilfs_dat_abort_entry(dat, req);  in nilfs_dat_prepare_end()
197 void nilfs_dat_commit_end(struct inode *dat, struct nilfs_palloc_req *req,  in nilfs_dat_commit_end()  argument
206 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_commit_end()
210 		end = nilfs_mdt_cno(dat);  in nilfs_dat_commit_end()
218 		nilfs_dat_commit_free(dat, req);  in nilfs_dat_commit_end()
220 		nilfs_dat_commit_entry(dat, req);  in nilfs_dat_commit_end()
223 void nilfs_dat_abort_end(struct inode *dat, struct nilfs_palloc_req *req)  in nilfs_dat_abort_end()  argument
231 	entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr,  in nilfs_dat_abort_end()
237 	if (start == nilfs_mdt_cno(dat) && blocknr == 0)  in nilfs_dat_abort_end()
238 		nilfs_palloc_abort_free_entry(dat, req);  in nilfs_dat_abort_end()
239 	nilfs_dat_abort_entry(dat, req);  in nilfs_dat_abort_end()
242 int nilfs_dat_prepare_update(struct inode *dat,  in nilfs_dat_prepare_update()  argument
248 	ret = nilfs_dat_prepare_end(dat, oldreq);  in nilfs_dat_prepare_update()
250 		ret = nilfs_dat_prepare_alloc(dat, newreq);  in nilfs_dat_prepare_update()
252 			nilfs_dat_abort_end(dat, oldreq);  in nilfs_dat_prepare_update()
257 void nilfs_dat_commit_update(struct inode *dat,  in nilfs_dat_commit_update()  argument
261 	nilfs_dat_commit_end(dat, oldreq, dead);  in nilfs_dat_commit_update()
262 	nilfs_dat_commit_alloc(dat, newreq);  in nilfs_dat_commit_update()
265 void nilfs_dat_abort_update(struct inode *dat,  in nilfs_dat_abort_update()  argument
269 	nilfs_dat_abort_end(dat, oldreq);  in nilfs_dat_abort_update()
270 	nilfs_dat_abort_alloc(dat, newreq);  in nilfs_dat_abort_update()
274  * nilfs_dat_mark_dirty - mark the DAT block buffer containing the specified
276  * @dat:      DAT file inode
280  * * %-EINVAL	- Invalid DAT entry (internal code).
284 int nilfs_dat_mark_dirty(struct inode *dat, __u64 vblocknr)  in nilfs_dat_mark_dirty()  argument
290 	ret = nilfs_dat_prepare_entry(dat, &req, 0);  in nilfs_dat_mark_dirty()
292 		nilfs_dat_commit_entry(dat, &req);  in nilfs_dat_mark_dirty()
298  * @dat: DAT file inode
314 int nilfs_dat_freev(struct inode *dat, __u64 *vblocknrs, size_t nitems)  in nilfs_dat_freev()  argument
316 	return nilfs_palloc_freev(dat, vblocknrs, nitems);  in nilfs_dat_freev()
321  * @dat: DAT file inode
335 int nilfs_dat_move(struct inode *dat, __u64 vblocknr, sector_t blocknr)  in nilfs_dat_move()  argument
342 	ret = nilfs_palloc_get_entry_block(dat, vblocknr, 0, &entry_bh);  in nilfs_dat_move()
355 		ret = nilfs_mdt_freeze_buffer(dat, entry_bh);  in nilfs_dat_move()
363 	entry = nilfs_palloc_block_get_entry(dat, vblocknr, entry_bh, kaddr);  in nilfs_dat_move()
365 		nilfs_crit(dat->i_sb,  in nilfs_dat_move()
379 	nilfs_mdt_mark_dirty(dat);  in nilfs_dat_move()
388  * @dat: DAT file inode
405 int nilfs_dat_translate(struct inode *dat, __u64 vblocknr, sector_t *blocknrp)  in nilfs_dat_translate()  argument
413 	ret = nilfs_palloc_get_entry_block(dat, vblocknr, 0, &entry_bh);  in nilfs_dat_translate()
418 		bh = nilfs_mdt_get_frozen_buffer(dat, entry_bh);  in nilfs_dat_translate()
427 	entry = nilfs_palloc_block_get_entry(dat, vblocknr, entry_bh, kaddr);  in nilfs_dat_translate()
441 ssize_t nilfs_dat_get_vinfo(struct inode *dat, void *buf, unsigned int visz,  in nilfs_dat_get_vinfo()  argument
449 	unsigned long entries_per_block = NILFS_MDT(dat)->mi_entries_per_block;  in nilfs_dat_get_vinfo()
453 		ret = nilfs_palloc_get_entry_block(dat, vinfo->vi_vblocknr,  in nilfs_dat_get_vinfo()
468 				dat, vinfo->vi_vblocknr, entry_bh, kaddr);  in nilfs_dat_get_vinfo()
481  * nilfs_dat_read - read or get dat inode
483  * @entry_size: size of a dat entry
484  * @raw_inode: on-disk dat inode
491 	struct inode *dat;  in nilfs_dat_read()  local
496 		nilfs_err(sb, "too large DAT entry size: %zu bytes",  in nilfs_dat_read()
500 		nilfs_err(sb, "too small DAT entry size: %zu bytes",  in nilfs_dat_read()
505 	dat = nilfs_iget_locked(sb, NULL, NILFS_DAT_INO);  in nilfs_dat_read()
506 	if (unlikely(!dat))  in nilfs_dat_read()
508 	if (!(dat->i_state & I_NEW))  in nilfs_dat_read()
511 	err = nilfs_mdt_init(dat, NILFS_MDT_GFP, sizeof(*di));  in nilfs_dat_read()
515 	err = nilfs_palloc_init_blockgroup(dat, entry_size);  in nilfs_dat_read()
519 	di = NILFS_DAT_I(dat);  in nilfs_dat_read()
521 	nilfs_palloc_setup_cache(dat, &di->palloc_cache);  in nilfs_dat_read()
522 	err = nilfs_mdt_setup_shadow_map(dat, &di->shadow);  in nilfs_dat_read()
526 	err = nilfs_read_inode_common(dat, raw_inode);  in nilfs_dat_read()
530 	unlock_new_inode(dat);  in nilfs_dat_read()
532 	*inodep = dat;  in nilfs_dat_read()
535 	iget_failed(dat);  in nilfs_dat_read()