Commit 6ffe892e authored by Artur Paszkiewicz's avatar Artur Paszkiewicz Committed by Jim Harris
Browse files

bdev: refactor lba range locking functions 



To prepare for following patches adding bdev quiesce API.

Change-Id: I545c4c3852f3e27ca02f8016459e85c474e2fb4f
Signed-off-by: default avatarArtur Paszkiewicz <artur.paszkiewicz@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/18096


Community-CI: Mellanox Build Bot
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
parent cca7c14a

lib/bdev/bdev.c

+28 −10
Original line number Diff line number Diff line
@@ -9302,12 +9302,10 @@ bdev_lba_range_overlaps_tailq(struct lba_range *range, lba_range_tailq_t *tailq) 
}



static int

bdev_lock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch,

_bdev_lock_lba_range(struct spdk_bdev *bdev, struct spdk_bdev_channel *ch,

		     uint64_t offset, uint64_t length,

		     lock_range_cb cb_fn, void *cb_arg)

{

	struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(desc);

	struct spdk_bdev_channel *ch = __io_ch_to_bdev_ch(_ch);

	struct locked_lba_range_ctx *ctx;



	if (cb_arg == NULL) {
@@ -9343,6 +9341,17 @@ bdev_lock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch, 
	return 0;

}



static int

bdev_lock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch,

		    uint64_t offset, uint64_t length,

		    lock_range_cb cb_fn, void *cb_arg)

{

	struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(desc);

	struct spdk_bdev_channel *ch = __io_ch_to_bdev_ch(_ch);



	return _bdev_lock_lba_range(bdev, ch, offset, length, cb_fn, cb_arg);

}



static void

bdev_lock_lba_range_ctx_msg(void *_ctx)

{
@@ -9426,12 +9435,10 @@ bdev_unlock_lba_range_get_channel(struct spdk_bdev_channel_iter *i, struct spdk_ 
}



static int

bdev_unlock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch,

_bdev_unlock_lba_range(struct spdk_bdev *bdev, struct spdk_bdev_channel *ch,

		       uint64_t offset, uint64_t length,

		       lock_range_cb cb_fn, void *cb_arg)

{

	struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(desc);

	struct spdk_bdev_channel *ch = __io_ch_to_bdev_ch(_ch);

	struct locked_lba_range_ctx *ctx;

	struct lba_range *range;

	bool range_found = false;
@@ -9481,6 +9488,17 @@ bdev_unlock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch, 
	return 0;

}



static int

bdev_unlock_lba_range(struct spdk_bdev_desc *desc, struct spdk_io_channel *_ch,

		      uint64_t offset, uint64_t length,

		      lock_range_cb cb_fn, void *cb_arg)

{

	struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(desc);

	struct spdk_bdev_channel *ch = __io_ch_to_bdev_ch(_ch);



	return _bdev_unlock_lba_range(bdev, ch, offset, length, cb_fn, cb_arg);

}



int

spdk_bdev_get_memory_domains(struct spdk_bdev *bdev, struct spdk_memory_domain **domains,

			     int array_size)