d/numam-spdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

unittest/nvmf: test for nvmf_rdma_update_ibv_state

Browse Source 
test nvmf_rdma_update_ibv_state of nvmf/rdma.c

Signed-off-by: ChengqiangMeng <chengqiangx.meng@intel.com>
Change-Id: Ia9c172f799577eddd7a5949ee3d51d1a682d76f8
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/8724
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Ziye Yang <ziye.yang@intel.com>
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
Reviewed-by: Aleksey Marchuk <alexeymar@mellanox.com>
Reviewed-by: <dongx.yi@intel.com>
Community-CI: Broadcom CI <spdk-ci.pdl@broadcom.com>
This commit is contained in:
ChengqiangMeng 2021-07-09 13:10:14 +08:00 committed by Tomasz Zawadzki
parent 2f0fdf0e48
commit 2f5abdb7fd
1 changed files with 50 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
test/unit/lib/nvmf/rdma.c/rdma_ut.c
View File

@ -77,6 +77,24 @@ DEFINE_STUB_V(spdk_nvme_trid_populate_transport, (struct spdk_nvme_transport_id
DEFINE_STUB_V(spdk_nvmf_tgt_new_qpair, (struct spdk_nvmf_tgt *tgt, struct spdk_nvmf_qpair *qpair));
DEFINE_STUB(nvmf_ctrlr_abort_request, int, (struct spdk_nvmf_request *req), 0);
int ibv_query_qp(struct ibv_qp *qp, struct ibv_qp_attr *attr,
int attr_mask, struct ibv_qp_init_attr *init_attr)
{
if (qp == NULL) {
return -1;
} else {
attr->port_num = 80;
if (qp->state == IBV_QPS_ERR) {
attr->qp_state = 10;
} else {
attr->qp_state = IBV_QPS_INIT;
}
return 0;
}
}
const char *
spdk_nvme_transport_id_trtype_str(enum spdk_nvme_transport_type trtype)
{
@ -1292,6 +1310,37 @@ test_nvmf_rdma_request_free_data(void)
spdk_mempool_free(rtransport.data_wr_pool);
}
static void
test_nvmf_rdma_update_ibv_state(void)
{
struct spdk_nvmf_rdma_qpair rqpair = {};
struct spdk_rdma_qp rdma_qp = {};
struct ibv_qp qp = {};
int rc = 0;
rqpair.rdma_qp = &rdma_qp;
/* Case 1: Failed to get updated RDMA queue pair state */
rqpair.ibv_state = IBV_QPS_INIT;
rqpair.rdma_qp->qp = NULL;
rc = nvmf_rdma_update_ibv_state(&rqpair);
CU_ASSERT(rc == IBV_QPS_ERR + 1);
/* Case 2: Bad state updated */
rqpair.rdma_qp->qp = &qp;
qp.state = IBV_QPS_ERR;
rc = nvmf_rdma_update_ibv_state(&rqpair);
CU_ASSERT(rqpair.ibv_state == 10);
CU_ASSERT(rc == IBV_QPS_ERR + 1);
/* Case 3: Pass */
qp.state = IBV_QPS_INIT;
rc = nvmf_rdma_update_ibv_state(&rqpair);
CU_ASSERT(rqpair.ibv_state == IBV_QPS_INIT);
CU_ASSERT(rc == IBV_QPS_INIT);
}
int main(int argc, char **argv)
{
CU_pSuite suite = NULL;
@ -1308,6 +1357,7 @@ int main(int argc, char **argv)
CU_ADD_TEST(suite, test_spdk_nvmf_rdma_request_parse_sgl_with_md);
CU_ADD_TEST(suite, test_nvmf_rdma_opts_init);
CU_ADD_TEST(suite, test_nvmf_rdma_request_free_data);
CU_ADD_TEST(suite, test_nvmf_rdma_update_ibv_state);
CU_basic_set_mode(CU_BRM_VERBOSE);
CU_basic_run_tests();