Lines Matching refs:jd
32 int gfs2_replay_read_block(struct gfs2_jdesc *jd, unsigned int blk, in gfs2_replay_read_block() argument
35 struct gfs2_inode *ip = GFS2_I(jd->jd_inode); in gfs2_replay_read_block()
55 int gfs2_revoke_add(struct gfs2_jdesc *jd, u64 blkno, unsigned int where) in gfs2_revoke_add() argument
57 struct list_head *head = &jd->jd_revoke_list; in gfs2_revoke_add()
84 int gfs2_revoke_check(struct gfs2_jdesc *jd, u64 blkno, unsigned int where) in gfs2_revoke_check() argument
90 list_for_each_entry(rr, &jd->jd_revoke_list, rr_list) { in gfs2_revoke_check()
100 wrap = (rr->rr_where < jd->jd_replay_tail); in gfs2_revoke_check()
101 a = (jd->jd_replay_tail < where); in gfs2_revoke_check()
108 void gfs2_revoke_clean(struct gfs2_jdesc *jd) in gfs2_revoke_clean() argument
110 struct list_head *head = &jd->jd_revoke_list; in gfs2_revoke_clean()
167 static int get_log_header(struct gfs2_jdesc *jd, unsigned int blk, in get_log_header() argument
170 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in get_log_header()
174 error = gfs2_replay_read_block(jd, blk, &bh); in get_log_header()
198 static int foreach_descriptor(struct gfs2_jdesc *jd, u32 start, in foreach_descriptor() argument
201 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in foreach_descriptor()
212 error = gfs2_replay_read_block(jd, start, &bh); in foreach_descriptor()
224 error = get_log_header(jd, start, &lh); in foreach_descriptor()
226 gfs2_replay_incr_blk(jd, &start); in foreach_descriptor()
231 gfs2_consist_inode(GFS2_I(jd->jd_inode)); in foreach_descriptor()
241 error = lops_scan_elements(jd, start, ld, ptr, pass); in foreach_descriptor()
248 gfs2_replay_incr_blk(jd, &start); in foreach_descriptor()
264 static void clean_journal(struct gfs2_jdesc *jd, in clean_journal() argument
267 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in clean_journal()
270 gfs2_replay_incr_blk(jd, &lblock); in clean_journal()
271 gfs2_write_log_header(sdp, jd, head->lh_sequence + 1, 0, lblock, in clean_journal()
274 if (jd->jd_jid == sdp->sd_lockstruct.ls_jid) { in clean_journal()
309 static int update_statfs_inode(struct gfs2_jdesc *jd, in update_statfs_inode() argument
313 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in update_statfs_inode()
337 "[%+lld,%+lld,%+lld]\n", jd->jd_jid, sc.sc_total, in update_statfs_inode()
344 if (jd->jd_jid == sdp->sd_lockstruct.ls_jid) { in update_statfs_inode()
378 static void recover_local_statfs(struct gfs2_jdesc *jd, in recover_local_statfs() argument
382 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in recover_local_statfs()
390 error = update_statfs_inode(jd, head, sdp->sd_statfs_inode); in recover_local_statfs()
397 error = update_statfs_inode(jd, NULL, in recover_local_statfs()
398 find_local_statfs_inode(sdp, jd->jd_jid)); in recover_local_statfs()
405 struct gfs2_jdesc *jd = container_of(work, struct gfs2_jdesc, jd_work); in gfs2_recover_func() local
406 struct gfs2_inode *ip = GFS2_I(jd->jd_inode); in gfs2_recover_func()
407 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in gfs2_recover_func()
418 jd->jd_jid); in gfs2_recover_func()
424 if (jd->jd_jid != sdp->sd_lockstruct.ls_jid) { in gfs2_recover_func()
426 jd->jd_jid); in gfs2_recover_func()
430 error = gfs2_glock_nq_num(sdp, jd->jd_jid, &gfs2_journal_glops, in gfs2_recover_func()
439 fs_info(sdp, "jid=%u: Busy\n", jd->jd_jid); in gfs2_recover_func()
452 fs_info(sdp, "jid=%u, already locked for use\n", jd->jd_jid); in gfs2_recover_func()
456 fs_info(sdp, "jid=%u: Looking at journal...\n", jd->jd_jid); in gfs2_recover_func()
458 error = gfs2_jdesc_check(jd); in gfs2_recover_func()
462 error = gfs2_find_jhead(jd, &head, true); in gfs2_recover_func()
466 fs_info(sdp, "jid=%u: Journal head lookup took %lldms\n", jd->jd_jid, in gfs2_recover_func()
471 jd->jd_jid); in gfs2_recover_func()
499 "device\n", jd->jd_jid); in gfs2_recover_func()
506 jd->jd_jid, head.lh_tail, head.lh_blkno); in gfs2_recover_func()
513 lops_before_scan(jd, &head, pass); in gfs2_recover_func()
514 error = foreach_descriptor(jd, head.lh_tail, in gfs2_recover_func()
516 lops_after_scan(jd, error, pass); in gfs2_recover_func()
523 recover_local_statfs(jd, &head); in gfs2_recover_func()
524 clean_journal(jd, &head); in gfs2_recover_func()
531 jd->jd_jid, ktime_ms_delta(t_rep, t_start), in gfs2_recover_func()
538 gfs2_recovery_done(sdp, jd->jd_jid, LM_RD_SUCCESS); in gfs2_recover_func()
545 fs_info(sdp, "jid=%u: Done\n", jd->jd_jid); in gfs2_recover_func()
557 fs_info(sdp, "jid=%u: %s\n", jd->jd_jid, (error) ? "Failed" : "Done"); in gfs2_recover_func()
559 jd->jd_recover_error = error; in gfs2_recover_func()
560 gfs2_recovery_done(sdp, jd->jd_jid, LM_RD_GAVEUP); in gfs2_recover_func()
562 clear_bit(JDF_RECOVERY, &jd->jd_flags); in gfs2_recover_func()
564 wake_up_bit(&jd->jd_flags, JDF_RECOVERY); in gfs2_recover_func()
567 int gfs2_recover_journal(struct gfs2_jdesc *jd, bool wait) in gfs2_recover_journal() argument
571 if (test_and_set_bit(JDF_RECOVERY, &jd->jd_flags)) in gfs2_recover_journal()
575 rv = queue_work(gfs_recovery_wq, &jd->jd_work); in gfs2_recover_journal()
579 wait_on_bit(&jd->jd_flags, JDF_RECOVERY, in gfs2_recover_journal()
582 return wait ? jd->jd_recover_error : 0; in gfs2_recover_journal()