Commit 1d36ed84 authored by Jim Harris's avatar Jim Harris Committed by Konrad Sztyber
Browse files

nvmf/rdma: add nvmf_rdma_poll_group_insert_need_buffer_req() helper



We will be adding some additional logic in an upcoming patch for
inserting these requests into the pending_buf_queue. So break this
out into a helper function first, and then that future patch will
just modify this helper function.

Signed-off-by: default avatarJim Harris <jim.harris@samsung.com>
Change-Id: Iff6802b10fba5be27a875a9d92c26e857770e12d
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/25293


Community-CI: Community CI Samsung <spdk.community.ci.samsung@gmail.com>
Community-CI: Mellanox Build Bot
Community-CI: Broadcom CI <spdk-ci.pdl@broadcom.com>
Reviewed-by: default avatarKonrad Sztyber <konrad.sztyber@intel.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@nvidia.com>
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarChangpeng Liu <changpeliu@tencent.com>
parent ed43989a
Loading
Loading
Loading
Loading
+8 −1
Original line number Diff line number Diff line
@@ -2047,6 +2047,13 @@ nvmf_rdma_check_fused_ordering(struct spdk_nvmf_rdma_transport *rtransport,
	}
}

static void
nvmf_rdma_poll_group_insert_need_buffer_req(struct spdk_nvmf_rdma_poll_group *rgroup,
		struct spdk_nvmf_rdma_request *rdma_req)
{
	STAILQ_INSERT_TAIL(&rgroup->group.pending_buf_queue, &rdma_req->req, buf_link);
}

bool
nvmf_rdma_request_process(struct spdk_nvmf_rdma_transport *rtransport,
			  struct spdk_nvmf_rdma_request *rdma_req)
@@ -2154,7 +2161,7 @@ nvmf_rdma_request_process(struct spdk_nvmf_rdma_transport *rtransport,
			}

			rdma_req->state = RDMA_REQUEST_STATE_NEED_BUFFER;
			STAILQ_INSERT_TAIL(&rgroup->group.pending_buf_queue, &rdma_req->req, buf_link);
			nvmf_rdma_poll_group_insert_need_buffer_req(rgroup, rdma_req);
			break;
		case RDMA_REQUEST_STATE_NEED_BUFFER:
			spdk_trace_record(TRACE_RDMA_REQUEST_STATE_NEED_BUFFER, 0, 0,