Lines Matching full:dat
3 * dat.c - NILFS disk address translation.
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); 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
165 ret = nilfs_dat_prepare_entry(dat, req, 0); in nilfs_dat_prepare_end()
170 entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr, in nilfs_dat_prepare_end()
176 ret = nilfs_palloc_prepare_free_entry(dat, req); in nilfs_dat_prepare_end()
178 nilfs_dat_abort_entry(dat, req); in nilfs_dat_prepare_end()
186 void nilfs_dat_commit_end(struct inode *dat, struct nilfs_palloc_req *req, in nilfs_dat_commit_end() argument
195 entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr, in nilfs_dat_commit_end()
199 end = nilfs_mdt_cno(dat); in nilfs_dat_commit_end()
207 nilfs_dat_commit_free(dat, req); in nilfs_dat_commit_end()
209 nilfs_dat_commit_entry(dat, req); in nilfs_dat_commit_end()
212 void nilfs_dat_abort_end(struct inode *dat, struct nilfs_palloc_req *req) in nilfs_dat_abort_end() argument
220 entry = nilfs_palloc_block_get_entry(dat, req->pr_entry_nr, in nilfs_dat_abort_end()
226 if (start == nilfs_mdt_cno(dat) && blocknr == 0) in nilfs_dat_abort_end()
227 nilfs_palloc_abort_free_entry(dat, req); in nilfs_dat_abort_end()
228 nilfs_dat_abort_entry(dat, req); in nilfs_dat_abort_end()
231 int nilfs_dat_prepare_update(struct inode *dat, in nilfs_dat_prepare_update() argument
237 ret = nilfs_dat_prepare_end(dat, oldreq); in nilfs_dat_prepare_update()
239 ret = nilfs_dat_prepare_alloc(dat, newreq); in nilfs_dat_prepare_update()
241 nilfs_dat_abort_end(dat, oldreq); in nilfs_dat_prepare_update()
246 void nilfs_dat_commit_update(struct inode *dat, in nilfs_dat_commit_update() argument
250 nilfs_dat_commit_end(dat, oldreq, dead); in nilfs_dat_commit_update()
251 nilfs_dat_commit_alloc(dat, newreq); in nilfs_dat_commit_update()
254 void nilfs_dat_abort_update(struct inode *dat, in nilfs_dat_abort_update() argument
258 nilfs_dat_abort_end(dat, oldreq); in nilfs_dat_abort_update()
259 nilfs_dat_abort_alloc(dat, newreq); in nilfs_dat_abort_update()
264 * @dat: DAT file inode
276 int nilfs_dat_mark_dirty(struct inode *dat, __u64 vblocknr) in nilfs_dat_mark_dirty() argument
282 ret = nilfs_dat_prepare_entry(dat, &req, 0); in nilfs_dat_mark_dirty()
284 nilfs_dat_commit_entry(dat, &req); in nilfs_dat_mark_dirty()
290 * @dat: DAT file inode
306 int nilfs_dat_freev(struct inode *dat, __u64 *vblocknrs, size_t nitems) in nilfs_dat_freev() argument
308 return nilfs_palloc_freev(dat, vblocknrs, nitems); in nilfs_dat_freev()
313 * @dat: DAT file inode
327 int nilfs_dat_move(struct inode *dat, __u64 vblocknr, sector_t blocknr) in nilfs_dat_move() argument
334 ret = nilfs_palloc_get_entry_block(dat, vblocknr, 0, &entry_bh); in nilfs_dat_move()
347 ret = nilfs_mdt_freeze_buffer(dat, entry_bh); in nilfs_dat_move()
355 entry = nilfs_palloc_block_get_entry(dat, vblocknr, entry_bh, kaddr); in nilfs_dat_move()
357 nilfs_crit(dat->i_sb, in nilfs_dat_move()
371 nilfs_mdt_mark_dirty(dat); in nilfs_dat_move()
380 * @dat: DAT file inode
397 int nilfs_dat_translate(struct inode *dat, __u64 vblocknr, sector_t *blocknrp) in nilfs_dat_translate() argument
405 ret = nilfs_palloc_get_entry_block(dat, vblocknr, 0, &entry_bh); in nilfs_dat_translate()
410 bh = nilfs_mdt_get_frozen_buffer(dat, entry_bh); in nilfs_dat_translate()
419 entry = nilfs_palloc_block_get_entry(dat, vblocknr, entry_bh, kaddr); in nilfs_dat_translate()
433 ssize_t nilfs_dat_get_vinfo(struct inode *dat, void *buf, unsigned int visz, in nilfs_dat_get_vinfo() argument
441 unsigned long entries_per_block = NILFS_MDT(dat)->mi_entries_per_block; in nilfs_dat_get_vinfo()
445 ret = nilfs_palloc_get_entry_block(dat, vinfo->vi_vblocknr, in nilfs_dat_get_vinfo()
460 dat, vinfo->vi_vblocknr, entry_bh, kaddr); in nilfs_dat_get_vinfo()
473 * nilfs_dat_read - read or get dat inode
475 * @entry_size: size of a dat entry
476 * @raw_inode: on-disk dat inode
483 struct inode *dat; in nilfs_dat_read() local
488 nilfs_err(sb, "too large DAT entry size: %zu bytes", in nilfs_dat_read()
492 nilfs_err(sb, "too small DAT entry size: %zu bytes", in nilfs_dat_read()
497 dat = nilfs_iget_locked(sb, NULL, NILFS_DAT_INO); in nilfs_dat_read()
498 if (unlikely(!dat)) in nilfs_dat_read()
500 if (!(dat->i_state & I_NEW)) in nilfs_dat_read()
503 err = nilfs_mdt_init(dat, NILFS_MDT_GFP, sizeof(*di)); in nilfs_dat_read()
507 err = nilfs_palloc_init_blockgroup(dat, entry_size); in nilfs_dat_read()
511 di = NILFS_DAT_I(dat); in nilfs_dat_read()
513 nilfs_palloc_setup_cache(dat, &di->palloc_cache); in nilfs_dat_read()
514 err = nilfs_mdt_setup_shadow_map(dat, &di->shadow); in nilfs_dat_read()
518 err = nilfs_read_inode_common(dat, raw_inode); in nilfs_dat_read()
522 unlock_new_inode(dat); in nilfs_dat_read()
524 *inodep = dat; in nilfs_dat_read()
527 iget_failed(dat); in nilfs_dat_read()