From: Christoph Hellwig <hch@infradead.org>
To: Sergei Shtepa <sergei.shtepa@veeam.com>
Cc: snitzer@redhat.com, agk@redhat.com, hare@suse.de,
song@kernel.org, axboe@kernel.dk, dm-devel@redhat.com,
linux-block@vger.kernel.org, linux-kernel@vger.kernel.org,
linux-raid@vger.kernel.org, linux-api@vger.kernel.org,
pavel.tide@veeam.com
Subject: Re: [PATCH v6 2/4] block: add blk_interposer
Date: Tue, 9 Mar 2021 17:27:17 +0000 [thread overview]
Message-ID: <20210309172717.GB201344@infradead.org> (raw)
In-Reply-To: <1614774618-22410-3-git-send-email-sergei.shtepa@veeam.com>
> +static blk_qc_t __submit_bio_interposed(struct bio *bio)
> +{
> + struct bio_list bio_list[2] = { };
> + blk_qc_t ret = BLK_QC_T_NONE;
> +
> + current->bio_list = bio_list;
> + if (likely(bio_queue_enter(bio) == 0)) {
> + struct block_device *bdev = bio->bi_bdev;
> +
> + if (likely(bdev_has_interposer(bdev))) {
> + bio_set_flag(bio, BIO_INTERPOSED);
> + bdev->bd_interposer->ip_submit_bio(bio);
> + } else {
> + /* interposer was removed */
> + bio_list_add(¤t->bio_list[0], bio);
> + }
> +
> + blk_queue_exit(bdev->bd_disk->queue);
> + }
> + current->bio_list = NULL;
> +
> + /* Resubmit remaining bios */
> + while ((bio = bio_list_pop(&bio_list[0])))
> + ret = submit_bio_noacct(bio);
> +
> + return ret;
> +}
> +
> /**
> * submit_bio_noacct - re-submit a bio to the block device layer for I/O
> * @bio: The bio describing the location in memory and on the device.
> @@ -1043,6 +1071,14 @@ blk_qc_t submit_bio_noacct(struct bio *bio)
> return BLK_QC_T_NONE;
> }
>
> + /*
> + * Checking the BIO_INTERPOSED flag is necessary so that the bio
> + * created by the bdev_interposer do not get to it for processing.
> + */
> + if (bdev_has_interposer(bio->bi_bdev) &&
> + !bio_flagged(bio, BIO_INTERPOSED))
> + return __submit_bio_interposed(bio);
> +
> if (!bio->bi_bdev->bd_disk->fops->submit_bio)
> return __submit_bio_noacct_mq(bio);
> return __submit_bio_noacct(bio);
> diff --git a/block/genhd.c b/block/genhd.c
> index fcc530164b5a..1ae8516643c8 100644
> --- a/block/genhd.c
> +++ b/block/genhd.c
> @@ -30,6 +30,11 @@
> static struct kobject *block_depr;
>
> DECLARE_RWSEM(bdev_lookup_sem);
> +/*
> + * Prevents different block-layer interposers from attaching or detaching
> + * to the block device at the same time.
> + */
> +DEFINE_MUTEX(bdev_interposer_attach_lock);
This one can and should be marked static.
> +int bdev_interposer_attach(struct block_device *bdev, struct bdev_interposer *interposer,
Please avoid the overly long line.
> + int ret = 0;
> +
> + if (WARN_ON(!interposer))
WARN_ON_ONCE?
> + return -EINVAL;
> +
> + if (!blk_mq_is_queue_frozen(bdev->bd_disk->queue))
> + return -EPERM;
This probly should be a WARN_ON_ONCE() as well.
> +
> + mutex_lock(&bdev_interposer_attach_lock);
> + if (bdev_has_interposer(bdev)) {
> + if (bdev->bd_interposer->ip_submit_bio == ip_submit_bio)
> + ret = -EALREADY;
> + else
> + ret = -EBUSY;
> + goto out;
> + }
Do we really need the two different error codes here?
> +
> + interposer->ip_submit_bio = ip_submit_bio;
I'd rather let the caller initialize the field instead of passing the
submit function separately.
> +void bdev_interposer_detach(struct bdev_interposer *interposer,
> + const ip_submit_bio_t ip_submit_bio)
> +{
> + /* Check if it is really our interposer. */
> + if (WARN_ON(bdev->bd_interposer->ip_submit_bio != ip_submit_bio))
> + goto out;
I don't really see any need to pass ip_submit_bio just for this check.
> + struct bdev_interposer * bd_interposer;
The * goes just before the member name.
> +/*
> + * block layer interposers structure and functions
> + */
> +typedef void (*ip_submit_bio_t) (struct bio *bio);
> +
> +struct bdev_interposer {
> + ip_submit_bio_t ip_submit_bio;
> + struct block_device *bdev;
Do we need the ip_ prefix here? Also we probably don't really the
the typedef for the function pointer.
> +#define bdev_has_interposer(bd) ((bd)->bd_interposer != NULL)
And inline function would be nice here.
next prev parent reply other threads:[~2021-03-09 17:28 UTC|newest]
Thread overview: 13+ messages / expand[flat|nested] mbox.gz Atom feed top
2021-03-03 12:30 [PATCH v6 0/4] block-layer interposer Sergei Shtepa
2021-03-03 12:30 ` [PATCH v6 1/4] block: add blk_mq_is_queue_frozen() Sergei Shtepa
2021-03-09 17:19 ` Christoph Hellwig
2021-03-03 12:30 ` [PATCH v6 2/4] block: add blk_interposer Sergei Shtepa
2021-03-09 17:27 ` Christoph Hellwig [this message]
2021-03-10 4:53 ` Sergei Shtepa
2021-03-10 10:04 ` Christoph Hellwig
2021-03-03 12:30 ` [PATCH v6 3/4] dm: introduce dm-interposer Sergei Shtepa
2021-03-03 12:30 ` [PATCH v6 4/4] dm: add DM_INTERPOSED_FLAG Sergei Shtepa
2021-03-09 17:35 ` Christoph Hellwig
2021-03-10 5:28 ` Sergei Shtepa
2021-03-10 12:34 ` Christoph Hellwig
2021-03-11 10:54 ` Sergei Shtepa
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20210309172717.GB201344@infradead.org \
--to=hch@infradead.org \
--cc=agk@redhat.com \
--cc=axboe@kernel.dk \
--cc=dm-devel@redhat.com \
--cc=hare@suse.de \
--cc=linux-api@vger.kernel.org \
--cc=linux-block@vger.kernel.org \
--cc=linux-kernel@vger.kernel.org \
--cc=linux-raid@vger.kernel.org \
--cc=pavel.tide@veeam.com \
--cc=sergei.shtepa@veeam.com \
--cc=snitzer@redhat.com \
--cc=song@kernel.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).