gfs2: Rename gfs2_withdrawn to gfs2_withdrawing_or_withdrawn
authorAndreas Gruenbacher <agruenba@redhat.com>
Wed, 20 Dec 2023 16:16:29 +0000 (17:16 +0100)
committerAndreas Gruenbacher <agruenba@redhat.com>
Wed, 20 Dec 2023 20:29:40 +0000 (21:29 +0100)
This function checks whether the filesystem has been been marked to be
withdrawn eventually or has been withdrawn already.  Rename this
function to avoid confusing code like checking for gfs2_withdrawing()
when gfs2_withdrawn() has already returned true.

Signed-off-by: Andreas Gruenbacher <agruenba@redhat.com>
15 files changed:
fs/gfs2/aops.c
fs/gfs2/file.c
fs/gfs2/glock.c
fs/gfs2/glops.c
fs/gfs2/lock_dlm.c
fs/gfs2/log.c
fs/gfs2/meta_io.c
fs/gfs2/ops_fstype.c
fs/gfs2/quota.c
fs/gfs2/recovery.c
fs/gfs2/super.c
fs/gfs2/sys.c
fs/gfs2/trans.c
fs/gfs2/util.c
fs/gfs2/util.h

index 4482a5a9bdc909a72bdb556c6090214dbd077ae8..d551b9c94935d62d3d554707e95b54157c708177 100644 (file)
@@ -462,7 +462,7 @@ static int gfs2_read_folio(struct file *file, struct folio *folio)
                error = mpage_read_folio(folio, gfs2_block_map);
        }
 
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return -EIO;
 
        return error;
index 03902e780935289cfe3e059c17f1f5027c5b1261..992ca4effb505ec2936a403ea31fac4391cba76e 100644 (file)
@@ -1442,7 +1442,7 @@ static int gfs2_lock(struct file *file, int cmd, struct file_lock *fl)
 
        if (!(fl->fl_flags & FL_POSIX))
                return -ENOLCK;
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                if (fl->fl_type == F_UNLCK)
                        locks_lock_file_wait(file, fl);
                return -EIO;
index b71dd7c8f65ecfe08573b9e2413afd37aee3a21a..45f5c88d2622bdeeb6aa8fd0d554f906aa8d54cc 100644 (file)
@@ -156,7 +156,7 @@ static bool glock_blocked_by_withdraw(struct gfs2_glock *gl)
 {
        struct gfs2_sbd *sdp = gl->gl_name.ln_sbd;
 
-       if (!gfs2_withdrawn(sdp))
+       if (!gfs2_withdrawing_or_withdrawn(sdp))
                return false;
        if (gl->gl_ops->go_flags & GLOF_NONDISK)
                return false;
@@ -278,7 +278,7 @@ static void __gfs2_glock_put(struct gfs2_glock *gl)
        GLOCK_BUG_ON(gl, !list_empty(&gl->gl_holders));
        if (mapping) {
                truncate_inode_pages_final(mapping);
-               if (!gfs2_withdrawn(sdp))
+               if (!gfs2_withdrawing_or_withdrawn(sdp))
                        GLOCK_BUG_ON(gl, !mapping_empty(mapping));
        }
        trace_gfs2_glock_put(gl);
@@ -774,7 +774,7 @@ skip_inval:
         * gfs2_gl_hash_clear calls clear_glock) and recovery is complete
         * then it's okay to tell dlm to unlock it.
         */
-       if (unlikely(sdp->sd_log_error) && !gfs2_withdrawn(sdp))
+       if (unlikely(sdp->sd_log_error) && !gfs2_withdrawing_or_withdrawn(sdp))
                gfs2_withdraw_delayed(sdp);
        if (glock_blocked_by_withdraw(gl) &&
            (target != LM_ST_UNLOCKED ||
@@ -811,7 +811,7 @@ skip_inval:
                        gfs2_glock_queue_work(gl, 0);
                } else if (ret) {
                        fs_err(sdp, "lm_lock ret %d\n", ret);
-                       GLOCK_BUG_ON(gl, !gfs2_withdrawn(sdp));
+                       GLOCK_BUG_ON(gl, !gfs2_withdrawing_or_withdrawn(sdp));
                }
        } else { /* lock_nolock */
                finish_xmote(gl, target);
index 15d0e653fd2bbeefab50ec10e5baa52d8b08aa14..45653cbc8a87d15170aa4c52b954043bc858b2d5 100644 (file)
@@ -174,7 +174,7 @@ static int gfs2_rgrp_metasync(struct gfs2_glock *gl)
 
        filemap_fdatawrite_range(metamapping, start, end);
        error = filemap_fdatawait_range(metamapping, start, end);
-       WARN_ON_ONCE(error && !gfs2_withdrawn(sdp));
+       WARN_ON_ONCE(error && !gfs2_withdrawing_or_withdrawn(sdp));
        mapping_set_error(metamapping, error);
        if (error)
                gfs2_io_error(sdp);
index 59ab18c798890f9c8af9fdd98938354e7473ee47..d1ac5d0679ea6a4ac989e2eb192d5503ab6df9f5 100644 (file)
@@ -1122,7 +1122,7 @@ static void gdlm_recover_prep(void *arg)
        struct gfs2_sbd *sdp = arg;
        struct lm_lockstruct *ls = &sdp->sd_lockstruct;
 
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_err(sdp, "recover_prep ignored due to withdraw.\n");
                return;
        }
@@ -1148,7 +1148,7 @@ static void gdlm_recover_slot(void *arg, struct dlm_slot *slot)
        struct lm_lockstruct *ls = &sdp->sd_lockstruct;
        int jid = slot->slot - 1;
 
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_err(sdp, "recover_slot jid %d ignored due to withdraw.\n",
                       jid);
                return;
@@ -1177,7 +1177,7 @@ static void gdlm_recover_done(void *arg, struct dlm_slot *slots, int num_slots,
        struct gfs2_sbd *sdp = arg;
        struct lm_lockstruct *ls = &sdp->sd_lockstruct;
 
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_err(sdp, "recover_done ignored due to withdraw.\n");
                return;
        }
@@ -1208,7 +1208,7 @@ static void gdlm_recovery_result(struct gfs2_sbd *sdp, unsigned int jid,
 {
        struct lm_lockstruct *ls = &sdp->sd_lockstruct;
 
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_err(sdp, "recovery_result jid %d ignored due to withdraw.\n",
                       jid);
                return;
index 61cd52a579d9b29a89e931a516e8920d693c6203..8691839104b7682adf8e98ddc3f30ee3a45fe5c8 100644 (file)
@@ -126,7 +126,7 @@ __acquires(&sdp->sd_ail_lock)
                        }
                }
 
-               if (gfs2_withdrawn(sdp)) {
+               if (gfs2_withdrawing_or_withdrawn(sdp)) {
                        gfs2_remove_from_ail(bd);
                        continue;
                }
@@ -842,7 +842,7 @@ void gfs2_write_log_header(struct gfs2_sbd *sdp, struct gfs2_jdesc *jd,
        struct super_block *sb = sdp->sd_vfs;
        u64 dblock;
 
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return;
 
        page = mempool_alloc(gfs2_page_pool, GFP_NOIO);
@@ -1048,7 +1048,8 @@ repeat:
         * Do this check while holding the log_flush_lock to prevent new
         * buffers from being added to the ail via gfs2_pin()
         */
-       if (gfs2_withdrawn(sdp) || !test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags))
+       if (gfs2_withdrawing_or_withdrawn(sdp) ||
+           !test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags))
                goto out;
 
        /* Log might have been flushed while we waited for the flush lock */
@@ -1097,13 +1098,13 @@ repeat:
                        goto out_withdraw;
 
        gfs2_ordered_write(sdp);
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                goto out_withdraw;
        lops_before_commit(sdp, tr);
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                goto out_withdraw;
        gfs2_log_submit_bio(&sdp->sd_jdesc->jd_log_bio, REQ_OP_WRITE);
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                goto out_withdraw;
 
        if (sdp->sd_log_head != sdp->sd_log_flush_head) {
@@ -1111,7 +1112,7 @@ repeat:
        } else if (sdp->sd_log_tail != sdp->sd_log_flush_tail && !sdp->sd_log_idle) {
                log_write_header(sdp, flags);
        }
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                goto out_withdraw;
        lops_after_commit(sdp, tr);
 
@@ -1129,7 +1130,7 @@ repeat:
        if (!(flags & GFS2_LOG_HEAD_FLUSH_NORMAL)) {
                if (!sdp->sd_log_idle) {
                        empty_ail1_list(sdp);
-                       if (gfs2_withdrawn(sdp))
+                       if (gfs2_withdrawing_or_withdrawn(sdp))
                                goto out_withdraw;
                        log_write_header(sdp, flags);
                }
@@ -1299,7 +1300,7 @@ int gfs2_logd(void *data)
        unsigned long t = 1;
 
        while (!kthread_should_stop()) {
-               if (gfs2_withdrawn(sdp))
+               if (gfs2_withdrawing_or_withdrawn(sdp))
                        break;
 
                /* Check for errors writing to the journal */
@@ -1338,7 +1339,7 @@ int gfs2_logd(void *data)
                                gfs2_ail_flush_reqd(sdp) ||
                                gfs2_jrnl_flush_reqd(sdp) ||
                                sdp->sd_log_error ||
-                               gfs2_withdrawn(sdp) ||
+                               gfs2_withdrawing_or_withdrawn(sdp) ||
                                kthread_should_stop(),
                                t);
        }
index 299ae67ae85ef3073b55ca8c881888453af21e11..f814054c8cd08ab388e4cf1ffc249093366063d7 100644 (file)
@@ -252,7 +252,8 @@ int gfs2_meta_read(struct gfs2_glock *gl, u64 blkno, int flags,
        struct buffer_head *bh, *bhs[2];
        int num = 0;
 
-       if (gfs2_withdrawn(sdp) && !gfs2_withdraw_in_prog(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp) &&
+           !gfs2_withdraw_in_prog(sdp)) {
                *bhp = NULL;
                return -EIO;
        }
@@ -310,7 +311,8 @@ int gfs2_meta_read(struct gfs2_glock *gl, u64 blkno, int flags,
 
 int gfs2_meta_wait(struct gfs2_sbd *sdp, struct buffer_head *bh)
 {
-       if (gfs2_withdrawn(sdp) && !gfs2_withdraw_in_prog(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp) &&
+           !gfs2_withdraw_in_prog(sdp))
                return -EIO;
 
        wait_on_buffer(bh);
@@ -321,7 +323,8 @@ int gfs2_meta_wait(struct gfs2_sbd *sdp, struct buffer_head *bh)
                        gfs2_io_error_bh_wd(sdp, bh);
                return -EIO;
        }
-       if (gfs2_withdrawn(sdp) && !gfs2_withdraw_in_prog(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp) &&
+           !gfs2_withdraw_in_prog(sdp))
                return -EIO;
 
        return 0;
index c6ec08909c6993be6e127dcda4beea53614ebd27..9c6f1a8fb5fb8ef7f7fa95288904f07734d31fd2 100644 (file)
@@ -1073,7 +1073,7 @@ hostdata_error:
 void gfs2_lm_unmount(struct gfs2_sbd *sdp)
 {
        const struct lm_lockops *lm = sdp->sd_lockstruct.ls_ops;
-       if (!gfs2_withdrawn(sdp) && lm->lm_unmount)
+       if (!gfs2_withdrawing_or_withdrawn(sdp) && lm->lm_unmount)
                lm->lm_unmount(sdp);
 }
 
index f139ce8cf5ce2615ac29bd551b3ab35d6ff31404..9ade69f8d3384288c962527e4f0225d6358f983b 100644 (file)
@@ -128,7 +128,7 @@ static void gfs2_qd_dispose(struct gfs2_quota_data *qd)
        hlist_bl_del_rcu(&qd->qd_hlist);
        spin_unlock_bucket(qd->qd_hash);
 
-       if (!gfs2_withdrawn(sdp)) {
+       if (!gfs2_withdrawing_or_withdrawn(sdp)) {
                gfs2_assert_warn(sdp, !qd->qd_change);
                gfs2_assert_warn(sdp, !qd->qd_slot_ref);
                gfs2_assert_warn(sdp, !qd->qd_bh_count);
@@ -1540,7 +1540,7 @@ static void quotad_error(struct gfs2_sbd *sdp, const char *msg, int error)
 {
        if (error == 0 || error == -EROFS)
                return;
-       if (!gfs2_withdrawn(sdp)) {
+       if (!gfs2_withdrawing_or_withdrawn(sdp)) {
                if (!cmpxchg(&sdp->sd_log_error, 0, error))
                        fs_err(sdp, "gfs2_quotad: %s error %d\n", msg, error);
                wake_up(&sdp->sd_logd_waitq);
@@ -1584,7 +1584,7 @@ int gfs2_quotad(void *data)
        unsigned long t = 0;
 
        while (!kthread_should_stop()) {
-               if (gfs2_withdrawn(sdp))
+               if (gfs2_withdrawing_or_withdrawn(sdp))
                        break;
 
                /* Update the master statfs file */
@@ -1608,7 +1608,7 @@ int gfs2_quotad(void *data)
 
                t = wait_event_interruptible_timeout(sdp->sd_quota_wait,
                                sdp->sd_statfs_force_sync ||
-                               gfs2_withdrawn(sdp) ||
+                               gfs2_withdrawing_or_withdrawn(sdp) ||
                                kthread_should_stop(),
                                t);
 
index 5aae02669a4090ae62af37412c5ccd67c328c38d..f4fe7039f725b0e267b534ddf6ab4b563f41b4bb 100644 (file)
@@ -411,7 +411,7 @@ void gfs2_recover_func(struct work_struct *work)
        int error = 0;
        int jlocked = 0;
 
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_err(sdp, "jid=%u: Recovery not attempted due to withdraw.\n",
                       jd->jd_jid);
                goto fail;
index 85c77dd327ec43282dfa4461021fb8b5f20f3242..cf3431486fd4867ef4345a0f1920624de3a1ff6b 100644 (file)
@@ -134,7 +134,7 @@ int gfs2_make_fs_rw(struct gfs2_sbd *sdp)
        int error;
 
        j_gl->gl_ops->go_inval(j_gl, DIO_METADATA);
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return -EIO;
 
        error = gfs2_find_jhead(sdp->sd_jdesc, &head, false);
@@ -153,7 +153,7 @@ int gfs2_make_fs_rw(struct gfs2_sbd *sdp)
        gfs2_log_pointers_init(sdp, head.lh_blkno);
 
        error = gfs2_quota_init(sdp);
-       if (!error && gfs2_withdrawn(sdp))
+       if (!error && gfs2_withdrawing_or_withdrawn(sdp))
                error = -EIO;
        if (!error)
                set_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags);
@@ -499,7 +499,7 @@ static void gfs2_dirty_inode(struct inode *inode, int flags)
                return;
        }
 
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return;
        if (!gfs2_glock_is_locked_by_me(ip->i_gl)) {
                ret = gfs2_glock_nq_init(ip->i_gl, LM_ST_EXCLUSIVE, 0, &gh);
@@ -605,7 +605,7 @@ restart:
        if (!sb_rdonly(sb))
                gfs2_make_fs_ro(sdp);
        else {
-               if (gfs2_withdrawn(sdp))
+               if (gfs2_withdrawing_or_withdrawn(sdp))
                        gfs2_destroy_threads(sdp);
 
                gfs2_quota_cleanup(sdp);
@@ -685,7 +685,7 @@ static int gfs2_freeze_locally(struct gfs2_sbd *sdp)
        if (test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
                gfs2_log_flush(sdp, NULL, GFS2_LOG_HEAD_FLUSH_FREEZE |
                               GFS2_LFC_FREEZE_GO_SYNC);
-               if (gfs2_withdrawn(sdp)) {
+               if (gfs2_withdrawing_or_withdrawn(sdp)) {
                        error = thaw_super(sb, FREEZE_HOLDER_USERSPACE);
                        if (error)
                                return error;
index 60a0206890c54ceaebf793b18760f0afd58437bb..250f340cb44d61cb6d625236ff8d5e71fadecb17 100644 (file)
@@ -193,7 +193,7 @@ static ssize_t freeze_store(struct gfs2_sbd *sdp, const char *buf, size_t len)
 
 static ssize_t withdraw_show(struct gfs2_sbd *sdp, char *buf)
 {
-       unsigned int b = gfs2_withdrawn(sdp);
+       unsigned int b = gfs2_withdrawing_or_withdrawn(sdp);
        return snprintf(buf, PAGE_SIZE, "%u\n", b);
 }
 
index 1487fbb62d842a208792be7efd2450e48556e94c..192213c7359af12e1079674f243bc236f1cb7252 100644 (file)
@@ -268,7 +268,7 @@ void gfs2_trans_add_meta(struct gfs2_glock *gl, struct buffer_head *bh)
                       (unsigned long long)bd->bd_bh->b_blocknr);
                BUG();
        }
-       if (gfs2_withdrawn(sdp)) {
+       if (gfs2_withdrawing_or_withdrawn(sdp)) {
                fs_info(sdp, "GFS2:adding buf while withdrawn! 0x%llx\n",
                        (unsigned long long)bd->bd_bh->b_blocknr);
                goto out_unlock;
index da29fafb62728addbface4973f50049ef42febc4..f52141ce948533607c9a2af2914df2279331269b 100644 (file)
@@ -372,7 +372,7 @@ void gfs2_assert_withdraw_i(struct gfs2_sbd *sdp, char *assertion,
                            const char *function, char *file, unsigned int line,
                            bool delayed)
 {
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return;
 
        fs_err(sdp,
@@ -548,7 +548,7 @@ void gfs2_io_error_bh_i(struct gfs2_sbd *sdp, struct buffer_head *bh,
                        const char *function, char *file, unsigned int line,
                        bool withdraw)
 {
-       if (gfs2_withdrawn(sdp))
+       if (gfs2_withdrawing_or_withdrawn(sdp))
                return;
 
        fs_err(sdp, "fatal: I/O error\n"
index 76acf0b3981496b5e9f15763e41fd13df7feb9b4..ba071998461fd462b3a57c991d87858a09377500 100644 (file)
@@ -198,10 +198,11 @@ static inline void gfs2_withdraw_delayed(struct gfs2_sbd *sdp)
 }
 
 /**
- * gfs2_withdrawn - test whether the file system is withdrawing or withdrawn
+ * gfs2_withdrawing_or_withdrawn - test whether the file system is withdrawing
+ *                                 or withdrawn
  * @sdp: the superblock
  */
-static inline bool gfs2_withdrawn(struct gfs2_sbd *sdp)
+static inline bool gfs2_withdrawing_or_withdrawn(struct gfs2_sbd *sdp)
 {
        return unlikely(test_bit(SDF_WITHDRAWN, &sdp->sd_flags) ||
                        test_bit(SDF_WITHDRAWING, &sdp->sd_flags));