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