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

nvme/rdma: use spdk_malloc() for DMA data buffers

Browse Source 
These allocations need to be from memory registered with the SPDK env
library to allow future work on automatic ibverbs memory registration.

Change-Id: I6ec6999ecd6d6bf6ba4ab159630f7d01f3d46154
Signed-off-by: Daniel Verkamp <daniel.verkamp@intel.com>
This commit is contained in:
Daniel Verkamp 2017-03-02 13:11:09 -07:00
parent 7f448daaa3
commit 6a03451228
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/nvme/nvme_rdma.c
View File

@ -351,7 +351,7 @@ nvme_rdma_free_reqs(struct nvme_rdma_qpair *rqpair)
} }
if (rdma_req->bb) { if (rdma_req->bb) {
free(rdma_req->bb); spdk_free(rdma_req->bb);
} }
} }
@ -405,7 +405,7 @@ nvme_rdma_alloc_reqs(struct nvme_rdma_qpair *rqpair)
rdma_req->send_sgl.length = sizeof(*cmd); rdma_req->send_sgl.length = sizeof(*cmd);
rdma_req->send_sgl.lkey = rqpair->cmd_mr->lkey; rdma_req->send_sgl.lkey = rqpair->cmd_mr->lkey;
rdma_req->bb = calloc(1, NVME_RDMA_RW_BUFFER_SIZE); rdma_req->bb = spdk_zmalloc(NVME_RDMA_RW_BUFFER_SIZE, 64, NULL);
if (!rdma_req->bb) { if (!rdma_req->bb) {
SPDK_ERRLOG("Unable to register allocate read/write buffer\n"); SPDK_ERRLOG("Unable to register allocate read/write buffer\n");
goto fail; goto fail;
@ -692,7 +692,8 @@ nvme_rdma_qpair_fabric_connect(struct nvme_rdma_qpair *rqpair)
} }
rctrlr = nvme_rdma_ctrlr(ctrlr); rctrlr = nvme_rdma_ctrlr(ctrlr);
nvmf_data = calloc(1, sizeof(*nvmf_data));
nvmf_data = spdk_zmalloc(sizeof(*nvmf_data), 0, NULL);
if (!nvmf_data) { if (!nvmf_data) {
SPDK_ERRLOG("nvmf_data allocation error\n"); SPDK_ERRLOG("nvmf_data allocation error\n");
rc = -1; rc = -1;
@ -741,7 +742,7 @@ nvme_rdma_qpair_fabric_connect(struct nvme_rdma_qpair *rqpair)
rsp = (struct spdk_nvmf_fabric_connect_rsp *)&status.cpl; rsp = (struct spdk_nvmf_fabric_connect_rsp *)&status.cpl;
rctrlr->cntlid = rsp->status_code_specific.success.cntlid; rctrlr->cntlid = rsp->status_code_specific.success.cntlid;
ret: ret:
free(nvmf_data); spdk_free(nvmf_data);
return rc; return rc;
} }