Commit dafc6984 authored by Kalwas, Jacek's avatar Kalwas, Jacek Committed by Tomasz Zawadzki
Browse files

bdev: use utility fn meant to incr outstanding io 



Change-Id: I5035bf6c880b28c966f94d2caa8c558db749e138
Signed-off-by: default avatarKalwas, Jacek <jacek.kalwas@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/19816


Community-CI: Mellanox Build Bot
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarKonrad Sztyber <konrad.sztyber@intel.com>
Reviewed-by: default avatarChangpeng Liu <changpeng.liu@intel.com>
parent 0005b3ed

lib/bdev/bdev.c

+3 −8
Original line number Diff line number Diff line
@@ -2608,11 +2608,8 @@ _bdev_io_complete_in_submit(struct spdk_bdev_channel *bdev_ch, 
			    struct spdk_bdev_io *bdev_io,

			    enum spdk_bdev_io_status status)

{

	struct spdk_bdev_shared_resource *shared_resource = bdev_ch->shared_resource;



	bdev_io->internal.in_submit_request = true;

	bdev_ch->io_outstanding++;

	shared_resource->io_outstanding++;

	bdev_io_increment_outstanding(bdev_ch, bdev_ch->shared_resource);

	spdk_bdev_io_complete(bdev_io, status);

	bdev_io->internal.in_submit_request = false;

}
@@ -2646,8 +2643,7 @@ bdev_io_do_submit(struct spdk_bdev_channel *bdev_ch, struct spdk_bdev_io *bdev_i 
	}



	if (spdk_likely(TAILQ_EMPTY(&shared_resource->nomem_io))) {

		bdev_ch->io_outstanding++;

		shared_resource->io_outstanding++;

		bdev_io_increment_outstanding(bdev_ch, shared_resource);

		bdev_io->internal.in_submit_request = true;

		bdev_submit_request(bdev, ch, bdev_io);

		bdev_io->internal.in_submit_request = false;
@@ -4070,8 +4066,7 @@ bdev_abort_all_queued_io(bdev_io_tailq_t *queue, struct spdk_bdev_channel *ch) 
			 *  that spdk_bdev_io_complete() will do.

			 */

			if (bdev_io->type != SPDK_BDEV_IO_TYPE_RESET) {

				ch->io_outstanding++;

				ch->shared_resource->io_outstanding++;

				bdev_io_increment_outstanding(ch, ch->shared_resource);

			}

			spdk_bdev_io_complete(bdev_io, SPDK_BDEV_IO_STATUS_ABORTED);

		}