GFS2: Fix gfs2_replay_incr_blk for multiple journal sizes
authorBob Peterson <rpeterso@redhat.com>
Thu, 21 Jul 2016 18:02:44 +0000 (13:02 -0500)
committerBob Peterson <rpeterso@redhat.com>
Thu, 21 Jul 2016 18:02:44 +0000 (13:02 -0500)
Before this patch, if you used gfs2_jadd to add new journals of a
size smaller than the existing journals, replaying those new journals
would withdraw. That's because function gfs2_replay_incr_blk was
using the number of journal blocks (jd_block) from the superblock's
journal pointer. In other words, "My journal's max size" rather than
"the journal we're replaying's size." This patch changes the function
to use the size of the pertinent journal rather than always using the
journal we happen to be using.

Signed-off-by: Bob Peterson <rpeterso@redhat.com>
fs/gfs2/lops.c
fs/gfs2/recovery.c
fs/gfs2/recovery.h

index d5369a109781d990317cf634f3f8537c38a5dd7c..8e3ba20d5e9dfcf4d7d4450a3bc2c0d9a9c5db44 100644 (file)
@@ -535,9 +535,9 @@ static int buf_lo_scan_elements(struct gfs2_jdesc *jd, unsigned int start,
        if (pass != 1 || be32_to_cpu(ld->ld_type) != GFS2_LOG_DESC_METADATA)
                return 0;
 
-       gfs2_replay_incr_blk(sdp, &start);
+       gfs2_replay_incr_blk(jd, &start);
 
-       for (; blks; gfs2_replay_incr_blk(sdp, &start), blks--) {
+       for (; blks; gfs2_replay_incr_blk(jd, &start), blks--) {
                blkno = be64_to_cpu(*ptr++);
 
                jd->jd_found_blocks++;
@@ -693,7 +693,7 @@ static int revoke_lo_scan_elements(struct gfs2_jdesc *jd, unsigned int start,
 
        offset = sizeof(struct gfs2_log_descriptor);
 
-       for (; blks; gfs2_replay_incr_blk(sdp, &start), blks--) {
+       for (; blks; gfs2_replay_incr_blk(jd, &start), blks--) {
                error = gfs2_replay_read_block(jd, start, &bh);
                if (error)
                        return error;
@@ -762,7 +762,6 @@ static int databuf_lo_scan_elements(struct gfs2_jdesc *jd, unsigned int start,
                                    __be64 *ptr, int pass)
 {
        struct gfs2_inode *ip = GFS2_I(jd->jd_inode);
-       struct gfs2_sbd *sdp = GFS2_SB(jd->jd_inode);
        struct gfs2_glock *gl = ip->i_gl;
        unsigned int blks = be32_to_cpu(ld->ld_data1);
        struct buffer_head *bh_log, *bh_ip;
@@ -773,8 +772,8 @@ static int databuf_lo_scan_elements(struct gfs2_jdesc *jd, unsigned int start,
        if (pass != 1 || be32_to_cpu(ld->ld_type) != GFS2_LOG_DESC_JDATA)
                return 0;
 
-       gfs2_replay_incr_blk(sdp, &start);
-       for (; blks; gfs2_replay_incr_blk(sdp, &start), blks--) {
+       gfs2_replay_incr_blk(jd, &start);
+       for (; blks; gfs2_replay_incr_blk(jd, &start), blks--) {
                blkno = be64_to_cpu(*ptr++);
                esc = be64_to_cpu(*ptr++);
 
index 1b645773c98e2499ff111606c5d0f6290f1ea7ca..113b6095a58dd000e2d2c23e71435a1d065fbfb9 100644 (file)
@@ -338,7 +338,7 @@ static int foreach_descriptor(struct gfs2_jdesc *jd, unsigned int start,
                        struct gfs2_log_header_host lh;
                        error = get_log_header(jd, start, &lh);
                        if (!error) {
-                               gfs2_replay_incr_blk(sdp, &start);
+                               gfs2_replay_incr_blk(jd, &start);
                                brelse(bh);
                                continue;
                        }
@@ -360,7 +360,7 @@ static int foreach_descriptor(struct gfs2_jdesc *jd, unsigned int start,
                }
 
                while (length--)
-                       gfs2_replay_incr_blk(sdp, &start);
+                       gfs2_replay_incr_blk(jd, &start);
 
                brelse(bh);
        }
@@ -390,7 +390,7 @@ static int clean_journal(struct gfs2_jdesc *jd, struct gfs2_log_header_host *hea
        struct buffer_head bh_map = { .b_state = 0, .b_blocknr = 0 };
 
        lblock = head->lh_blkno;
-       gfs2_replay_incr_blk(sdp, &lblock);
+       gfs2_replay_incr_blk(jd, &lblock);
        bh_map.b_size = 1 << ip->i_inode.i_blkbits;
        error = gfs2_block_map(&ip->i_inode, lblock, &bh_map, 0);
        if (error)
index 6142836cce961484acb8139d4d86683f7b8daa15..11fdfab4bf99d800af39dcbf69d726142a9af563 100644 (file)
@@ -14,9 +14,9 @@
 
 extern struct workqueue_struct *gfs_recovery_wq;
 
-static inline void gfs2_replay_incr_blk(struct gfs2_sbd *sdp, unsigned int *blk)
+static inline void gfs2_replay_incr_blk(struct gfs2_jdesc *jd, unsigned int *blk)
 {
-       if (++*blk == sdp->sd_jdesc->jd_blocks)
+       if (++*blk == jd->jd_blocks)
                *blk = 0;
 }