Commit c2ce2f85 authored by Shuhei Matsumoto's avatar Shuhei Matsumoto Committed by Tomasz Zawadzki
Browse files

lib/bdev: Rename bdev_abort_buf_io by bdev_abort_all_buf_io 



Current bdev_abort_buf_io() aborts all queued I/Os due to buffer
pool capacity, and we want to use the name for the new function
which aborts only the specified I/O if queued. So rename
bdev_abort_buf_io() by bdev_abort_all_buf_io() in this patch.

Signed-off-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Change-Id: I50a4ef1f5c4d2f8db9a0781413520345a7f13e59
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/2395


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Community-CI: Broadcom CI
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarMichael Haeuptle <michaelhaeuptle@gmail.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@mellanox.com>
parent 0d31e2ba

lib/bdev/bdev.c

+5 −5
Original line number Diff line number Diff line
@@ -2613,7 +2613,7 @@ bdev_channel_create(void *io_device, void *ctx_buf) 
 *  linked using the spdk_bdev_io internal.buf_link TAILQ_ENTRY.

 */

static void

bdev_abort_buf_io(bdev_io_stailq_t *queue, struct spdk_bdev_channel *ch)

bdev_abort_all_buf_io(bdev_io_stailq_t *queue, struct spdk_bdev_channel *ch)

{

	bdev_io_stailq_t tmp;

	struct spdk_bdev_io *bdev_io;
@@ -2780,8 +2780,8 @@ bdev_channel_destroy(void *io_device, void *ctx_buf) 


	bdev_abort_all_queued_io(&ch->queued_resets, ch);

	bdev_abort_all_queued_io(&shared_resource->nomem_io, ch);

	bdev_abort_buf_io(&mgmt_ch->need_buf_small, ch);

	bdev_abort_buf_io(&mgmt_ch->need_buf_large, ch);

	bdev_abort_all_buf_io(&mgmt_ch->need_buf_small, ch);

	bdev_abort_all_buf_io(&mgmt_ch->need_buf_large, ch);



	if (ch->histogram) {

		spdk_histogram_data_free(ch->histogram);
@@ -4208,8 +4208,8 @@ bdev_reset_freeze_channel(struct spdk_io_channel_iter *i) 
	}



	bdev_abort_all_queued_io(&shared_resource->nomem_io, channel);

	bdev_abort_buf_io(&mgmt_channel->need_buf_small, channel);

	bdev_abort_buf_io(&mgmt_channel->need_buf_large, channel);

	bdev_abort_all_buf_io(&mgmt_channel->need_buf_small, channel);

	bdev_abort_all_buf_io(&mgmt_channel->need_buf_large, channel);

	bdev_abort_all_queued_io(&tmp_queued, channel);



	spdk_for_each_channel_continue(i, 0);