Commit 99389857 authored by Daniel Verkamp's avatar Daniel Verkamp
Browse files

nvme/rdma: queue request if no rdma_req available 



This matches the behavior of nvme_pcie, which queues a request if no
tracker is available.

Change-Id: Idbf6c951c89451cfea22ec6bc553ff46f988f818
Signed-off-by: default avatarDaniel Verkamp <daniel.verkamp@intel.com>
parent ee827136

lib/nvme/nvme_rdma.c

+12 −2
Original line number Diff line number Diff line
@@ -472,6 +472,7 @@ fail: 
static int

nvme_rdma_recv(struct nvme_rdma_qpair *rqpair, struct ibv_wc *wc)

{

	struct spdk_nvme_qpair *qpair = &rqpair->qpair;

	struct spdk_nvme_rdma_req *rdma_req;

	struct spdk_nvme_cpl *rsp;

	struct nvme_request *req;
@@ -496,6 +497,12 @@ nvme_rdma_recv(struct nvme_rdma_qpair *rqpair, struct ibv_wc *wc) 
		return -1;

	}



	if (!STAILQ_EMPTY(&qpair->queued_req) && !qpair->ctrlr->is_resetting) {

		req = STAILQ_FIRST(&qpair->queued_req);

		STAILQ_REMOVE_HEAD(&qpair->queued_req, stailq);

		nvme_qpair_submit_request(qpair, req);

	}



	return 0;

}
@@ -1327,8 +1334,11 @@ nvme_rdma_qpair_submit_request(struct spdk_nvme_qpair *qpair, 


	rdma_req = nvme_rdma_req_get(rqpair);

	if (!rdma_req) {

		SPDK_ERRLOG("nvme_rdma_req_get() failed\n");

		return -1;

		/*

		 * No rdma_req is available.  Queue the request to be processed later.

		 */

		STAILQ_INSERT_TAIL(&qpair->queued_req, req, stailq);

		return 0;

	}



	if (nvme_rdma_req_init(rqpair, req, rdma_req)) {