Lines Matching full:sdp
37 * @sdp: The superblock
42 void gfs2_pin(struct gfs2_sbd *sdp, struct buffer_head *bh) in gfs2_pin() argument
50 gfs2_assert_withdraw(sdp, 0); in gfs2_pin()
52 gfs2_io_error_bh_wd(sdp, bh); in gfs2_pin()
57 spin_lock(&sdp->sd_ail_lock); in gfs2_pin()
60 spin_unlock(&sdp->sd_ail_lock); in gfs2_pin()
62 atomic_inc(&sdp->sd_log_pinned); in gfs2_pin()
74 struct gfs2_sbd *sdp = gl->gl_name.ln_sbd; in maybe_release_space() local
81 if (sdp->sd_args.ar_discard) in maybe_release_space()
82 gfs2_rgrp_send_discards(sdp, rgd->rd_data0, bd->bd_bh, bi, 1, NULL); in maybe_release_space()
92 * @sdp: the filesystem the buffer belongs to
99 static void gfs2_unpin(struct gfs2_sbd *sdp, struct buffer_head *bh, in gfs2_unpin() argument
114 spin_lock(&sdp->sd_ail_lock); in gfs2_unpin()
125 spin_unlock(&sdp->sd_ail_lock); in gfs2_unpin()
130 atomic_dec(&sdp->sd_log_pinned); in gfs2_unpin()
133 void gfs2_log_incr_head(struct gfs2_sbd *sdp) in gfs2_log_incr_head() argument
135 BUG_ON((sdp->sd_log_flush_head == sdp->sd_log_tail) && in gfs2_log_incr_head()
136 (sdp->sd_log_flush_head != sdp->sd_log_head)); in gfs2_log_incr_head()
138 if (++sdp->sd_log_flush_head == sdp->sd_jdesc->jd_blocks) in gfs2_log_incr_head()
139 sdp->sd_log_flush_head = 0; in gfs2_log_incr_head()
156 * @sdp: The superblock
166 static void gfs2_end_log_write_bh(struct gfs2_sbd *sdp, in gfs2_end_log_write_bh() argument
201 struct gfs2_sbd *sdp = bio->bi_private; in gfs2_end_log_write() local
207 if (!cmpxchg(&sdp->sd_log_error, 0, (int)bio->bi_status)) in gfs2_end_log_write()
208 fs_err(sdp, "Error %d writing to journal, jid=%u\n", in gfs2_end_log_write()
209 bio->bi_status, sdp->sd_jdesc->jd_jid); in gfs2_end_log_write()
210 gfs2_withdraw_delayed(sdp); in gfs2_end_log_write()
212 clear_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags); in gfs2_end_log_write()
213 wake_up(&sdp->sd_logd_waitq); in gfs2_end_log_write()
219 gfs2_end_log_write_bh(sdp, bvec, bio->bi_status); in gfs2_end_log_write()
225 if (atomic_dec_and_test(&sdp->sd_log_in_flight)) in gfs2_end_log_write()
226 wake_up(&sdp->sd_log_flush_wait); in gfs2_end_log_write()
242 struct gfs2_sbd *sdp = bio->bi_private; in gfs2_log_submit_bio() local
243 atomic_inc(&sdp->sd_log_in_flight); in gfs2_log_submit_bio()
252 * @sdp: The super block
261 static struct bio *gfs2_log_alloc_bio(struct gfs2_sbd *sdp, u64 blkno, in gfs2_log_alloc_bio() argument
264 struct super_block *sb = sdp->sd_vfs; in gfs2_log_alloc_bio()
267 bio->bi_iter.bi_sector = blkno << sdp->sd_fsb2bb_shift; in gfs2_log_alloc_bio()
270 bio->bi_private = sdp; in gfs2_log_alloc_bio()
277 * @sdp: The super block
292 static struct bio *gfs2_log_get_bio(struct gfs2_sbd *sdp, u64 blkno, in gfs2_log_get_bio() argument
302 nblk >>= sdp->sd_fsb2bb_shift; in gfs2_log_get_bio()
308 *biop = gfs2_log_alloc_bio(sdp, blkno, end_io); in gfs2_log_get_bio()
314 * @sdp: the filesystem
325 void gfs2_log_write(struct gfs2_sbd *sdp, struct page *page, in gfs2_log_write() argument
331 bio = gfs2_log_get_bio(sdp, blkno, &sdp->sd_log_bio, REQ_OP_WRITE, in gfs2_log_write()
335 bio = gfs2_log_get_bio(sdp, blkno, &sdp->sd_log_bio, in gfs2_log_write()
344 * @sdp: The super block
352 static void gfs2_log_write_bh(struct gfs2_sbd *sdp, struct buffer_head *bh) in gfs2_log_write_bh() argument
356 dblock = gfs2_log_bmap(sdp->sd_jdesc, sdp->sd_log_flush_head); in gfs2_log_write_bh()
357 gfs2_log_incr_head(sdp); in gfs2_log_write_bh()
358 gfs2_log_write(sdp, bh->b_page, bh->b_size, bh_offset(bh), dblock); in gfs2_log_write_bh()
363 * @sdp: The superblock
372 void gfs2_log_write_page(struct gfs2_sbd *sdp, struct page *page) in gfs2_log_write_page() argument
374 struct super_block *sb = sdp->sd_vfs; in gfs2_log_write_page()
377 dblock = gfs2_log_bmap(sdp->sd_jdesc, sdp->sd_log_flush_head); in gfs2_log_write_page()
378 gfs2_log_incr_head(sdp); in gfs2_log_write_page()
379 gfs2_log_write(sdp, page, sb->s_blocksize, 0, dblock); in gfs2_log_write_page()
422 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in gfs2_jhead_pg_srch() local
428 for (offset = 0; offset < PAGE_SIZE; offset += sdp->sd_sb.sb_bsize) { in gfs2_jhead_pg_srch()
429 if (!__get_log_header(sdp, kaddr + offset, 0, &lh)) { in gfs2_jhead_pg_srch()
507 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in gfs2_find_jhead() local
510 unsigned int bsize = sdp->sd_sb.sb_bsize, off; in gfs2_find_jhead()
511 unsigned int bsize_shift = sdp->sd_sb.sb_bsize_shift; in gfs2_find_jhead()
523 gfs2_map_journal_extents(sdp, jd); in gfs2_find_jhead()
542 sector_t sector = dblock << sdp->sd_fsb2bb_shift; in gfs2_find_jhead()
563 bio = gfs2_log_alloc_bio(sdp, dblock, gfs2_end_log_read); in gfs2_find_jhead()
601 static struct page *gfs2_get_log_desc(struct gfs2_sbd *sdp, u32 ld_type, in gfs2_get_log_desc() argument
645 static void gfs2_before_commit(struct gfs2_sbd *sdp, unsigned int limit, in gfs2_before_commit() argument
656 gfs2_log_lock(sdp); in gfs2_before_commit()
663 gfs2_log_unlock(sdp); in gfs2_before_commit()
664 page = gfs2_get_log_desc(sdp, in gfs2_before_commit()
668 gfs2_log_lock(sdp); in gfs2_before_commit()
682 gfs2_log_unlock(sdp); in gfs2_before_commit()
683 gfs2_log_write_page(sdp, page); in gfs2_before_commit()
684 gfs2_log_lock(sdp); in gfs2_before_commit()
689 gfs2_log_unlock(sdp); in gfs2_before_commit()
704 gfs2_log_write_page(sdp, page); in gfs2_before_commit()
706 gfs2_log_write_bh(sdp, bd2->bd_bh); in gfs2_before_commit()
708 gfs2_log_lock(sdp); in gfs2_before_commit()
716 gfs2_log_unlock(sdp); in gfs2_before_commit()
719 static void buf_lo_before_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in buf_lo_before_commit() argument
721 unsigned int limit = buf_limit(sdp); /* 503 for 4k blocks */ in buf_lo_before_commit()
726 gfs2_before_commit(sdp, limit, nbuf, &tr->tr_buf, 0); in buf_lo_before_commit()
729 static void buf_lo_after_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in buf_lo_after_commit() argument
741 gfs2_unpin(sdp, bd->bd_bh, tr); in buf_lo_after_commit()
760 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in buf_lo_scan_elements() local
787 if (gfs2_meta_check(sdp, bh_ip)) in buf_lo_scan_elements()
796 rgd = gfs2_blk2rgrpd(sdp, blkno, false); in buf_lo_scan_elements()
799 fs_info(sdp, "Replaying 0x%llx but we " in buf_lo_scan_elements()
802 fs_info(sdp, "busy:%d, pinned:%d\n", in buf_lo_scan_elements()
825 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in buf_lo_after_scan() local
836 fs_info(sdp, "jid=%u: Replayed %u of %u blocks\n", in buf_lo_after_scan()
840 static void revoke_lo_before_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in revoke_lo_before_commit() argument
844 struct list_head *head = &sdp->sd_log_revokes; in revoke_lo_before_commit()
849 gfs2_write_revokes(sdp); in revoke_lo_before_commit()
850 if (!sdp->sd_log_num_revoke) in revoke_lo_before_commit()
853 length = gfs2_struct2blk(sdp, sdp->sd_log_num_revoke); in revoke_lo_before_commit()
854 page = gfs2_get_log_desc(sdp, GFS2_LOG_DESC_REVOKE, length, sdp->sd_log_num_revoke); in revoke_lo_before_commit()
858 sdp->sd_log_num_revoke--; in revoke_lo_before_commit()
860 if (offset + sizeof(u64) > sdp->sd_sb.sb_bsize) { in revoke_lo_before_commit()
862 gfs2_log_write_page(sdp, page); in revoke_lo_before_commit()
875 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_revoke); in revoke_lo_before_commit()
877 gfs2_log_write_page(sdp, page); in revoke_lo_before_commit()
880 static void revoke_lo_after_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in revoke_lo_after_commit() argument
882 struct list_head *head = &sdp->sd_log_revokes; in revoke_lo_after_commit()
909 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in revoke_lo_scan_elements() local
929 gfs2_metatype_check(sdp, bh, GFS2_METATYPE_LB); in revoke_lo_scan_elements()
931 while (offset + sizeof(u64) <= sdp->sd_sb.sb_bsize) { in revoke_lo_scan_elements()
957 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in revoke_lo_after_scan() local
966 fs_info(sdp, "jid=%u: Found %u revoke tags\n", in revoke_lo_after_scan()
977 static void databuf_lo_before_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in databuf_lo_before_commit() argument
979 unsigned int limit = databuf_limit(sdp); in databuf_lo_before_commit()
984 gfs2_before_commit(sdp, limit, nbuf, &tr->tr_databuf, 1); in databuf_lo_before_commit()
1040 struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode); in databuf_lo_after_scan() local
1052 fs_info(sdp, "jid=%u: Replayed %u of %u data blocks\n", in databuf_lo_after_scan()
1056 static void databuf_lo_after_commit(struct gfs2_sbd *sdp, struct gfs2_trans *tr) in databuf_lo_after_commit() argument
1068 gfs2_unpin(sdp, bd->bd_bh, tr); in databuf_lo_after_commit()