]> git.ipfire.org Git - thirdparty/kernel/linux.git/commitdiff
bcachefs: Rename BCH_WRITE flags fer consistency with other x-macros enums
authorKent Overstreet <kent.overstreet@linux.dev>
Sun, 19 Jan 2025 18:18:50 +0000 (13:18 -0500)
committerKent Overstreet <kent.overstreet@linux.dev>
Sat, 15 Mar 2025 01:02:11 +0000 (21:02 -0400)
The uppercase/lowercase style is nice for making the namespace explicit.

Signed-off-by: Kent Overstreet <kent.overstreet@linux.dev>
fs/bcachefs/alloc_foreground.c
fs/bcachefs/data_update.c
fs/bcachefs/fs-io-buffered.c
fs/bcachefs/fs-io-direct.c
fs/bcachefs/io_read.c
fs/bcachefs/io_write.c
fs/bcachefs/io_write.h
fs/bcachefs/io_write_types.h
fs/bcachefs/rebalance.c

index 5a781fb4c794b96238d25b8e87a780a2af265eb3..1a539e7bedc8ca58132c538f6cd909e09a0c6b25 100644 (file)
@@ -728,7 +728,7 @@ int bch2_bucket_alloc_set_trans(struct btree_trans *trans,
 
                struct bch_dev_usage usage;
                struct open_bucket *ob = bch2_bucket_alloc_trans(trans, ca, watermark, data_type,
-                                                    cl, flags & BCH_WRITE_ALLOC_NOWAIT, &usage);
+                                                    cl, flags & BCH_WRITE_alloc_nowait, &usage);
                if (!IS_ERR(ob))
                        bch2_dev_stripe_increment_inlined(ca, stripe, &usage);
                bch2_dev_put(ca);
@@ -1336,7 +1336,7 @@ retry:
        if (wp->data_type != BCH_DATA_user)
                have_cache = true;
 
-       if (target && !(flags & BCH_WRITE_ONLY_SPECIFIED_DEVS)) {
+       if (target && !(flags & BCH_WRITE_only_specified_devs)) {
                ret = open_bucket_add_buckets(trans, &ptrs, wp, devs_have,
                                              target, erasure_code,
                                              nr_replicas, &nr_effective,
@@ -1426,7 +1426,7 @@ err:
        if (cl && bch2_err_matches(ret, BCH_ERR_open_buckets_empty))
                ret = -BCH_ERR_bucket_alloc_blocked;
 
-       if (cl && !(flags & BCH_WRITE_ALLOC_NOWAIT) &&
+       if (cl && !(flags & BCH_WRITE_alloc_nowait) &&
            bch2_err_matches(ret, BCH_ERR_freelist_empty))
                ret = -BCH_ERR_bucket_alloc_blocked;
 
index 1cfb86823fdff915af1ebf58f396ecc1ee6b42ea..bfd8ba1626301b648a27be0825d2fafad289ee0e 100644 (file)
@@ -681,10 +681,10 @@ int bch2_data_update_init(struct btree_trans *trans,
        m->op.target    = data_opts.target;
        m->op.write_point = wp;
        m->op.nr_replicas = 0;
-       m->op.flags     |= BCH_WRITE_PAGES_STABLE|
-               BCH_WRITE_PAGES_OWNED|
-               BCH_WRITE_DATA_ENCODED|
-               BCH_WRITE_MOVE|
+       m->op.flags     |= BCH_WRITE_pages_stable|
+               BCH_WRITE_pages_owned|
+               BCH_WRITE_data_encoded|
+               BCH_WRITE_move|
                m->data_opts.write_flags;
        m->op.compression_opt   = io_opts.background_compression;
        m->op.watermark         = m->data_opts.btree_insert_flags & BCH_WATERMARK_MASK;
index b68472f1d1d9d3003046a60e96ebd04d5c3f1313..dc00edfefc911626ced641a36e880a09be043b4d 100644 (file)
@@ -430,7 +430,7 @@ static void bch2_writepage_io_done(struct bch_write_op *op)
                }
        }
 
-       if (io->op.flags & BCH_WRITE_WROTE_DATA_INLINE) {
+       if (io->op.flags & BCH_WRITE_wrote_data_inline) {
                bio_for_each_folio_all(fi, bio) {
                        struct bch_folio *s;
 
index 2089c36b5866dc4424285f384307694d28eb4711..d2f2cbaba7a8a2956642c7486c0568266427327e 100644 (file)
@@ -511,8 +511,8 @@ static __always_inline long bch2_dio_write_loop(struct dio_write *dio)
                dio->op.devs_need_flush = &inode->ei_devs_need_flush;
 
                if (sync)
-                       dio->op.flags |= BCH_WRITE_SYNC;
-               dio->op.flags |= BCH_WRITE_CHECK_ENOSPC;
+                       dio->op.flags |= BCH_WRITE_sync;
+               dio->op.flags |= BCH_WRITE_check_enospc;
 
                ret = bch2_quota_reservation_add(c, inode, &dio->quota_res,
                                                 bio_sectors(bio), true);
index 304f76fb0f4341d4bc1bc92e10885419728d3376..539b48f94523198ae9935a57af0e8e7936179055 100644 (file)
@@ -232,7 +232,7 @@ static struct promote_op *__promote_alloc(struct btree_trans *trans,
        if (!have_io_error(failed)) {
                update_opts.target = opts.promote_target;
                update_opts.extra_replicas = 1;
-               update_opts.write_flags = BCH_WRITE_ALLOC_NOWAIT|BCH_WRITE_CACHED;
+               update_opts.write_flags = BCH_WRITE_alloc_nowait|BCH_WRITE_cached;
        } else {
                update_opts.target = opts.foreground_target;
 
index a903f39caa3e8489e1c3b36ed508933128b2bc9a..076e39474610a22ee8a11e95b9b0ebef761d3716 100644 (file)
@@ -374,7 +374,7 @@ static int bch2_write_index_default(struct bch_write_op *op)
                        bch2_extent_update(trans, inum, &iter, sk.k,
                                        &op->res,
                                        op->new_i_size, &op->i_sectors_delta,
-                                       op->flags & BCH_WRITE_CHECK_ENOSPC);
+                                       op->flags & BCH_WRITE_check_enospc);
                bch2_trans_iter_exit(trans, &iter);
 
                if (bch2_err_matches(ret, BCH_ERR_transaction_restart))
@@ -403,7 +403,7 @@ static void __bch2_write_op_error(struct printbuf *out, struct bch_write_op *op,
                                 (subvol_inum) { op->subvol, op->pos.inode, },
                                 offset << 9);
        prt_printf(out, "write error%s: ",
-                  op->flags & BCH_WRITE_MOVE ? "(internal move)" : "");
+                  op->flags & BCH_WRITE_move ? "(internal move)" : "");
 }
 
 void bch2_write_op_error(struct printbuf *out, struct bch_write_op *op)
@@ -418,7 +418,7 @@ static void bch2_write_op_error_trans(struct btree_trans *trans, struct printbuf
                                       (subvol_inum) { op->subvol, op->pos.inode, },
                                       offset << 9);
        prt_printf(out, "write error%s: ",
-                  op->flags & BCH_WRITE_MOVE ? "(internal move)" : "");
+                  op->flags & BCH_WRITE_move ? "(internal move)" : "");
 }
 
 void bch2_submit_wbio_replicas(struct bch_write_bio *wbio, struct bch_fs *c,
@@ -493,7 +493,7 @@ static void bch2_write_done(struct closure *cl)
        bch2_time_stats_update(&c->times[BCH_TIME_data_write], op->start_time);
        bch2_disk_reservation_put(c, &op->res);
 
-       if (!(op->flags & BCH_WRITE_MOVE))
+       if (!(op->flags & BCH_WRITE_move))
                bch2_write_ref_put(c, BCH_WRITE_REF_write);
        bch2_keylist_free(&op->insert_keys, op->inline_keys);
 
@@ -539,7 +539,7 @@ static void __bch2_write_index(struct bch_write_op *op)
        unsigned dev;
        int ret = 0;
 
-       if (unlikely(op->flags & BCH_WRITE_IO_ERROR)) {
+       if (unlikely(op->flags & BCH_WRITE_io_error)) {
                ret = bch2_write_drop_io_error_ptrs(op);
                if (ret)
                        goto err;
@@ -548,7 +548,7 @@ static void __bch2_write_index(struct bch_write_op *op)
        if (!bch2_keylist_empty(keys)) {
                u64 sectors_start = keylist_sectors(keys);
 
-               ret = !(op->flags & BCH_WRITE_MOVE)
+               ret = !(op->flags & BCH_WRITE_move)
                        ? bch2_write_index_default(op)
                        : bch2_data_update_index_update(op);
 
@@ -580,7 +580,7 @@ out:
 err:
        keys->top = keys->keys;
        op->error = ret;
-       op->flags |= BCH_WRITE_SUBMITTED;
+       op->flags |= BCH_WRITE_submitted;
        goto out;
 }
 
@@ -623,8 +623,8 @@ static CLOSURE_CALLBACK(bch2_write_index)
        struct workqueue_struct *wq = index_update_wq(op);
        unsigned long flags;
 
-       if ((op->flags & BCH_WRITE_SUBMITTED) &&
-           (op->flags & BCH_WRITE_MOVE))
+       if ((op->flags & BCH_WRITE_submitted) &&
+           (op->flags & BCH_WRITE_move))
                bch2_bio_free_pages_pool(op->c, &op->wbio.bio);
 
        spin_lock_irqsave(&wp->writes_lock, flags);
@@ -662,11 +662,11 @@ void bch2_write_point_do_index_updates(struct work_struct *work)
                if (!op)
                        break;
 
-               op->flags |= BCH_WRITE_IN_WORKER;
+               op->flags |= BCH_WRITE_in_worker;
 
                __bch2_write_index(op);
 
-               if (!(op->flags & BCH_WRITE_SUBMITTED))
+               if (!(op->flags & BCH_WRITE_submitted))
                        __bch2_write(op);
                else
                        bch2_write_done(&op->cl);
@@ -690,7 +690,7 @@ static void bch2_write_endio(struct bio *bio)
                                    "data write error: %s",
                                    bch2_blk_status_to_str(bio->bi_status))) {
                set_bit(wbio->dev, op->failed.d);
-               op->flags |= BCH_WRITE_IO_ERROR;
+               op->flags |= BCH_WRITE_io_error;
        }
 
        if (wbio->nocow) {
@@ -737,7 +737,7 @@ static void init_append_extent(struct bch_write_op *op,
                bch2_extent_crc_append(&e->k_i, crc);
 
        bch2_alloc_sectors_append_ptrs_inlined(op->c, wp, &e->k_i, crc.compressed_size,
-                                      op->flags & BCH_WRITE_CACHED);
+                                      op->flags & BCH_WRITE_cached);
 
        bch2_keylist_push(&op->insert_keys);
 }
@@ -854,7 +854,7 @@ static enum prep_encoded_ret {
        struct bch_fs *c = op->c;
        struct bio *bio = &op->wbio.bio;
 
-       if (!(op->flags & BCH_WRITE_DATA_ENCODED))
+       if (!(op->flags & BCH_WRITE_data_encoded))
                return PREP_ENCODED_OK;
 
        BUG_ON(bio_sectors(bio) != op->crc.compressed_size);
@@ -962,9 +962,9 @@ static int bch2_write_extent(struct bch_write_op *op, struct write_point *wp,
        if (ec_buf ||
            op->compression_opt ||
            (op->csum_type &&
-            !(op->flags & BCH_WRITE_PAGES_STABLE)) ||
+            !(op->flags & BCH_WRITE_pages_stable)) ||
            (bch2_csum_type_is_encryption(op->csum_type) &&
-            !(op->flags & BCH_WRITE_PAGES_OWNED))) {
+            !(op->flags & BCH_WRITE_pages_owned))) {
                dst = bch2_write_bio_alloc(c, wp, src,
                                           &page_alloc_failed,
                                           ec_buf);
@@ -984,7 +984,7 @@ static int bch2_write_extent(struct bch_write_op *op, struct write_point *wp,
                        break;
 
                BUG_ON(op->compression_opt &&
-                      (op->flags & BCH_WRITE_DATA_ENCODED) &&
+                      (op->flags & BCH_WRITE_data_encoded) &&
                       bch2_csum_type_is_encryption(op->crc.csum_type));
                BUG_ON(op->compression_opt && !bounce);
 
@@ -1022,7 +1022,7 @@ static int bch2_write_extent(struct bch_write_op *op, struct write_point *wp,
                        }
                }
 
-               if ((op->flags & BCH_WRITE_DATA_ENCODED) &&
+               if ((op->flags & BCH_WRITE_data_encoded) &&
                    !crc_is_compressed(crc) &&
                    bch2_csum_type_is_encryption(op->crc.csum_type) ==
                    bch2_csum_type_is_encryption(op->csum_type)) {
@@ -1054,7 +1054,7 @@ static int bch2_write_extent(struct bch_write_op *op, struct write_point *wp,
                        crc.compression_type = compression_type;
                        crc.nonce = nonce;
                } else {
-                       if ((op->flags & BCH_WRITE_DATA_ENCODED) &&
+                       if ((op->flags & BCH_WRITE_data_encoded) &&
                            bch2_rechecksum_bio(c, src, version, op->crc,
                                        NULL, &op->crc,
                                        src_len >> 9,
@@ -1228,9 +1228,9 @@ static void bch2_nocow_write_convert_unwritten(struct bch_write_op *op)
 
 static void __bch2_nocow_write_done(struct bch_write_op *op)
 {
-       if (unlikely(op->flags & BCH_WRITE_IO_ERROR)) {
+       if (unlikely(op->flags & BCH_WRITE_io_error)) {
                op->error = -EIO;
-       } else if (unlikely(op->flags & BCH_WRITE_CONVERT_UNWRITTEN))
+       } else if (unlikely(op->flags & BCH_WRITE_convert_unwritten))
                bch2_nocow_write_convert_unwritten(op);
 }
 
@@ -1259,7 +1259,7 @@ static void bch2_nocow_write(struct bch_write_op *op)
        struct bucket_to_lock *stale_at;
        int stale, ret;
 
-       if (op->flags & BCH_WRITE_MOVE)
+       if (op->flags & BCH_WRITE_move)
                return;
 
        darray_init(&buckets);
@@ -1317,7 +1317,7 @@ retry:
                                                   }), GFP_KERNEL|__GFP_NOFAIL);
 
                        if (ptr->unwritten)
-                               op->flags |= BCH_WRITE_CONVERT_UNWRITTEN;
+                               op->flags |= BCH_WRITE_convert_unwritten;
                }
 
                /* Unlock before taking nocow locks, doing IO: */
@@ -1325,7 +1325,7 @@ retry:
                bch2_trans_unlock(trans);
 
                bch2_cut_front(op->pos, op->insert_keys.top);
-               if (op->flags & BCH_WRITE_CONVERT_UNWRITTEN)
+               if (op->flags & BCH_WRITE_convert_unwritten)
                        bch2_cut_back(POS(op->pos.inode, op->pos.offset + bio_sectors(bio)), op->insert_keys.top);
 
                darray_for_each(buckets, i) {
@@ -1350,7 +1350,7 @@ retry:
                        wbio_init(bio)->put_bio = true;
                        bio->bi_opf = op->wbio.bio.bi_opf;
                } else {
-                       op->flags |= BCH_WRITE_SUBMITTED;
+                       op->flags |= BCH_WRITE_submitted;
                }
 
                op->pos.offset += bio_sectors(bio);
@@ -1364,7 +1364,7 @@ retry:
                                          op->insert_keys.top, true);
 
                bch2_keylist_push(&op->insert_keys);
-               if (op->flags & BCH_WRITE_SUBMITTED)
+               if (op->flags & BCH_WRITE_submitted)
                        break;
                bch2_btree_iter_advance(&iter);
        }
@@ -1384,15 +1384,15 @@ err:
                bch_err_ratelimited(c, "%s", buf.buf);
                printbuf_exit(&buf);
                op->error = ret;
-               op->flags |= BCH_WRITE_SUBMITTED;
+               op->flags |= BCH_WRITE_submitted;
        }
 
        /* fallback to cow write path? */
-       if (!(op->flags & BCH_WRITE_SUBMITTED)) {
+       if (!(op->flags & BCH_WRITE_submitted)) {
                closure_sync(&op->cl);
                __bch2_nocow_write_done(op);
                op->insert_keys.top = op->insert_keys.keys;
-       } else if (op->flags & BCH_WRITE_SYNC) {
+       } else if (op->flags & BCH_WRITE_sync) {
                closure_sync(&op->cl);
                bch2_nocow_write_done(&op->cl.work);
        } else {
@@ -1444,7 +1444,7 @@ static void __bch2_write(struct bch_write_op *op)
 
        if (unlikely(op->opts.nocow && c->opts.nocow_enabled)) {
                bch2_nocow_write(op);
-               if (op->flags & BCH_WRITE_SUBMITTED)
+               if (op->flags & BCH_WRITE_submitted)
                        goto out_nofs_restore;
        }
 again:
@@ -1474,7 +1474,7 @@ again:
                ret = bch2_trans_run(c, lockrestart_do(trans,
                        bch2_alloc_sectors_start_trans(trans,
                                op->target,
-                               op->opts.erasure_code && !(op->flags & BCH_WRITE_CACHED),
+                               op->opts.erasure_code && !(op->flags & BCH_WRITE_cached),
                                op->write_point,
                                &op->devs_have,
                                op->nr_replicas,
@@ -1497,10 +1497,10 @@ again:
                bch2_alloc_sectors_done_inlined(c, wp);
 err:
                if (ret <= 0) {
-                       op->flags |= BCH_WRITE_SUBMITTED;
+                       op->flags |= BCH_WRITE_submitted;
 
                        if (unlikely(ret < 0)) {
-                               if (!(op->flags & BCH_WRITE_ALLOC_NOWAIT)) {
+                               if (!(op->flags & BCH_WRITE_alloc_nowait)) {
                                        struct printbuf buf = PRINTBUF;
                                        bch2_write_op_error(&buf, op);
                                        prt_printf(&buf, "%s(): %s", __func__, bch2_err_str(ret));
@@ -1532,14 +1532,14 @@ err:
         * synchronously here if we weren't able to submit all of the IO at
         * once, as that signals backpressure to the caller.
         */
-       if ((op->flags & BCH_WRITE_SYNC) ||
-           (!(op->flags & BCH_WRITE_SUBMITTED) &&
-            !(op->flags & BCH_WRITE_IN_WORKER))) {
+       if ((op->flags & BCH_WRITE_sync) ||
+           (!(op->flags & BCH_WRITE_submitted) &&
+            !(op->flags & BCH_WRITE_in_worker))) {
                bch2_wait_on_allocator(c, &op->cl);
 
                __bch2_write_index(op);
 
-               if (!(op->flags & BCH_WRITE_SUBMITTED))
+               if (!(op->flags & BCH_WRITE_submitted))
                        goto again;
                bch2_write_done(&op->cl);
        } else {
@@ -1560,8 +1560,8 @@ static void bch2_write_data_inline(struct bch_write_op *op, unsigned data_len)
 
        memset(&op->failed, 0, sizeof(op->failed));
 
-       op->flags |= BCH_WRITE_WROTE_DATA_INLINE;
-       op->flags |= BCH_WRITE_SUBMITTED;
+       op->flags |= BCH_WRITE_wrote_data_inline;
+       op->flags |= BCH_WRITE_submitted;
 
        bch2_check_set_feature(op->c, BCH_FEATURE_inline_data);
 
@@ -1624,8 +1624,8 @@ CLOSURE_CALLBACK(bch2_write)
        BUG_ON(!op->write_point.v);
        BUG_ON(bkey_eq(op->pos, POS_MAX));
 
-       if (op->flags & BCH_WRITE_ONLY_SPECIFIED_DEVS)
-               op->flags |= BCH_WRITE_ALLOC_NOWAIT;
+       if (op->flags & BCH_WRITE_only_specified_devs)
+               op->flags |= BCH_WRITE_alloc_nowait;
 
        op->nr_replicas_required = min_t(unsigned, op->nr_replicas_required, op->nr_replicas);
        op->start_time = local_clock();
@@ -1646,13 +1646,13 @@ CLOSURE_CALLBACK(bch2_write)
                goto err;
        }
 
-       if (!(op->flags & BCH_WRITE_MOVE) &&
+       if (!(op->flags & BCH_WRITE_move) &&
            !bch2_write_ref_tryget(c, BCH_WRITE_REF_write)) {
                op->error = -BCH_ERR_erofs_no_writes;
                goto err;
        }
 
-       if (!(op->flags & BCH_WRITE_MOVE))
+       if (!(op->flags & BCH_WRITE_move))
                this_cpu_add(c->counters[BCH_COUNTER_io_write], bio_sectors(bio));
        bch2_increment_clock(c, bio_sectors(bio), WRITE);
 
index b4626013abc84a0633f816955c86f17a01df3e4c..02cca52be0bdd98b381b447d664e4dafa6505944 100644 (file)
@@ -23,21 +23,20 @@ void bch2_submit_wbio_replicas(struct bch_write_bio *, struct bch_fs *,
 void bch2_write_op_error(struct printbuf *out, struct bch_write_op *op);
 
 #define BCH_WRITE_FLAGS()              \
-       x(ALLOC_NOWAIT)                 \
-       x(CACHED)                       \
-       x(DATA_ENCODED)                 \
-       x(PAGES_STABLE)                 \
-       x(PAGES_OWNED)                  \
-       x(ONLY_SPECIFIED_DEVS)          \
-       x(WROTE_DATA_INLINE)            \
-       x(FROM_INTERNAL)                \
-       x(CHECK_ENOSPC)                 \
-       x(SYNC)                         \
-       x(MOVE)                         \
-       x(IN_WORKER)                    \
-       x(SUBMITTED)                    \
-       x(IO_ERROR)                     \
-       x(CONVERT_UNWRITTEN)
+       x(alloc_nowait)                 \
+       x(cached)                       \
+       x(data_encoded)                 \
+       x(pages_stable)                 \
+       x(pages_owned)                  \
+       x(only_specified_devs)          \
+       x(wrote_data_inline)            \
+       x(check_enospc)                 \
+       x(sync)                         \
+       x(move)                         \
+       x(in_worker)                    \
+       x(submitted)                    \
+       x(io_error)                     \
+       x(convert_unwritten)
 
 enum __bch_write_flags {
 #define x(f)   __BCH_WRITE_##f,
index 6e878a6f2f0b29fde3966cdf08df821eac870ff1..3ef6df9145ef3edcbd85a80632928bd7fe1127ac 100644 (file)
@@ -64,7 +64,7 @@ struct bch_write_op {
        struct bpos             pos;
        struct bversion         version;
 
-       /* For BCH_WRITE_DATA_ENCODED: */
+       /* For BCH_WRITE_data_encoded: */
        struct bch_extent_crc_unpacked crc;
 
        struct write_point_specifier write_point;
index d0a1f5cd5c2b336c56c928afc0970276c322671f..58f6d97e506cbf1f4c7034b724f1588fa66c4cef 100644 (file)
@@ -341,7 +341,7 @@ static struct bkey_s_c next_rebalance_extent(struct btree_trans *trans,
        memset(data_opts, 0, sizeof(*data_opts));
        data_opts->rewrite_ptrs         = bch2_bkey_ptrs_need_rebalance(c, io_opts, k);
        data_opts->target               = io_opts->background_target;
-       data_opts->write_flags          |= BCH_WRITE_ONLY_SPECIFIED_DEVS;
+       data_opts->write_flags          |= BCH_WRITE_only_specified_devs;
 
        if (!data_opts->rewrite_ptrs) {
                /*
@@ -449,7 +449,7 @@ static bool rebalance_pred(struct bch_fs *c, void *arg,
 {
        data_opts->rewrite_ptrs         = bch2_bkey_ptrs_need_rebalance(c, io_opts, k);
        data_opts->target               = io_opts->background_target;
-       data_opts->write_flags          |= BCH_WRITE_ONLY_SPECIFIED_DEVS;
+       data_opts->write_flags          |= BCH_WRITE_only_specified_devs;
        return data_opts->rewrite_ptrs != 0;
 }