Commit 17d652d7 authored by Piotr Pelplinski's avatar Piotr Pelplinski Committed by Ben Walker
Browse files

bdev_aio: enable double buffering on write path 



Signed-off-by: default avatarTomasz Zawadzki <tomasz.zawadzki@intel.com>
Signed-off-by: default avatarPiotr Pelplinski <piotr.pelplinski@intel.com>
Change-Id: I621a8a3891c8f3829564940219c70c6520c6f9c7
Reviewed-on: https://review.gerrithub.io/427899


Chandler-Test-Pool: SPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
parent 807c3a2b

lib/bdev/aio/bdev_aio.c

+25 −15
Original line number Diff line number Diff line
@@ -325,6 +325,8 @@ bdev_aio_reset(struct file_disk *fdisk, struct bdev_aio_task *aio_task) 


static void bdev_aio_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io)

{

	switch (bdev_io->type) {

	case SPDK_BDEV_IO_TYPE_READ:

		bdev_aio_readv((struct file_disk *)bdev_io->bdev->ctxt,

			       ch,

			       (struct bdev_aio_task *)bdev_io->driver_ctx,
@@ -332,16 +334,7 @@ static void bdev_aio_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io 
			       bdev_io->u.bdev.iovcnt,

			       bdev_io->u.bdev.num_blocks * bdev_io->bdev->blocklen,

			       bdev_io->u.bdev.offset_blocks * bdev_io->bdev->blocklen);

}



static int _bdev_aio_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io)

{

	switch (bdev_io->type) {

	case SPDK_BDEV_IO_TYPE_READ:

		spdk_bdev_io_get_buf(bdev_io, bdev_aio_get_buf_cb,

				     bdev_io->u.bdev.num_blocks * bdev_io->bdev->blocklen);

		return 0;



		break;

	case SPDK_BDEV_IO_TYPE_WRITE:

		bdev_aio_writev((struct file_disk *)bdev_io->bdev->ctxt,

				ch,
@@ -350,6 +343,23 @@ static int _bdev_aio_submit_request(struct spdk_io_channel *ch, struct spdk_bdev 
				bdev_io->u.bdev.iovcnt,

				bdev_io->u.bdev.num_blocks * bdev_io->bdev->blocklen,

				bdev_io->u.bdev.offset_blocks * bdev_io->bdev->blocklen);

		break;

	default:

		SPDK_ERRLOG("Wrong io type\n");

		break;

	}

}



static int _bdev_aio_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io)

{

	switch (bdev_io->type) {

	/* Read and write operations must be performed on buffers aligned to

	 * bdev->required_alignment. If user specified unaligned buffers,

	 * get the aligned buffer from the pool by calling spdk_bdev_io_get_buf. */

	case SPDK_BDEV_IO_TYPE_READ:

	case SPDK_BDEV_IO_TYPE_WRITE:

		spdk_bdev_io_get_buf(bdev_io, bdev_aio_get_buf_cb,

				     bdev_io->u.bdev.num_blocks * bdev_io->bdev->blocklen);

		return 0;

	case SPDK_BDEV_IO_TYPE_FLUSH:

		bdev_aio_flush((struct file_disk *)bdev_io->bdev->ctxt,