diff --git a/lib/nvmf/ctrlr.c b/lib/nvmf/ctrlr.c index b01d5614f..b8aa3215d 100644 --- a/lib/nvmf/ctrlr.c +++ b/lib/nvmf/ctrlr.c @@ -4170,10 +4170,8 @@ spdk_nvmf_request_exec(struct spdk_nvmf_request *req) struct spdk_nvmf_transport *transport = qpair->transport; enum spdk_nvmf_request_exec_status status; - if (!spdk_nvmf_request_using_zcopy(req)) { - if (!nvmf_check_subsystem_active(req)) { - return; - } + if (!nvmf_check_subsystem_active(req)) { + return; } if (SPDK_DEBUGLOG_FLAG_ENABLED("nvmf")) { diff --git a/test/unit/lib/nvmf/ctrlr.c/ctrlr_ut.c b/test/unit/lib/nvmf/ctrlr.c/ctrlr_ut.c index 4518522b3..9350f5031 100644 --- a/test/unit/lib/nvmf/ctrlr.c/ctrlr_ut.c +++ b/test/unit/lib/nvmf/ctrlr.c/ctrlr_ut.c @@ -2579,13 +2579,7 @@ test_zcopy_read(void) CU_ASSERT(req.zcopy_bdev_io == zcopy_start_bdev_io_read); CU_ASSERT(qpair.outstanding.tqh_first == &req); CU_ASSERT(ns_info.io_outstanding == 1); - - /* Execute the request */ - spdk_nvmf_request_exec(&req); CU_ASSERT(nvme_status_success(&rsp.nvme_cpl.status)); - CU_ASSERT(req.zcopy_bdev_io == zcopy_start_bdev_io_read); - CU_ASSERT(qpair.outstanding.tqh_first == &req); - CU_ASSERT(ns_info.io_outstanding == 1); /* Perform the zcopy end */ spdk_nvmf_request_zcopy_end(&req, false); @@ -2593,6 +2587,7 @@ test_zcopy_read(void) CU_ASSERT(req.zcopy_phase == NVMF_ZCOPY_PHASE_COMPLETE); CU_ASSERT(qpair.outstanding.tqh_first == NULL); CU_ASSERT(ns_info.io_outstanding == 0); + CU_ASSERT(nvme_status_success(&rsp.nvme_cpl.status)); } static void @@ -2670,13 +2665,7 @@ test_zcopy_write(void) CU_ASSERT(req.zcopy_bdev_io == zcopy_start_bdev_io_write); CU_ASSERT(qpair.outstanding.tqh_first == &req); CU_ASSERT(ns_info.io_outstanding == 1); - - /* Execute the request */ - spdk_nvmf_request_exec(&req); CU_ASSERT(nvme_status_success(&rsp.nvme_cpl.status)); - CU_ASSERT(req.zcopy_bdev_io == zcopy_start_bdev_io_write); - CU_ASSERT(qpair.outstanding.tqh_first == &req); - CU_ASSERT(ns_info.io_outstanding == 1); /* Perform the zcopy end */ spdk_nvmf_request_zcopy_end(&req, true); @@ -2684,6 +2673,7 @@ test_zcopy_write(void) CU_ASSERT(req.zcopy_phase == NVMF_ZCOPY_PHASE_COMPLETE); CU_ASSERT(qpair.outstanding.tqh_first == NULL); CU_ASSERT(ns_info.io_outstanding == 0); + CU_ASSERT(nvme_status_success(&rsp.nvme_cpl.status)); } static void