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

nvmf: pass nvmf_request to nvmf_io_cmd_continue()

Browse Source 
Change-Id: Ib73510376c3af558b88d5c29a131df931a1a9eda
Signed-off-by: Daniel Verkamp <daniel.verkamp@intel.com>
This commit is contained in:
Daniel Verkamp 2016-06-21 09:35:09 -07:00 committed by Benjamin Walker
parent 0b672d8e63
commit 855e11e990
1 changed files with 2 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/nvmf/conn.c
View File

@ -399,22 +399,10 @@ spdk_nvmf_send_response(struct spdk_nvmf_conn *conn, struct nvmf_request *req)
} }
static int static int
nvmf_io_cmd_continue(struct spdk_nvmf_conn *conn, struct nvme_qp_tx_desc *tx_desc) nvmf_io_cmd_continue(struct spdk_nvmf_conn *conn, struct nvmf_request *req)
{ {
struct nvme_qp_rx_desc *rx_desc;
struct nvmf_request *req;
int ret; int ret;
rx_desc = tx_desc->rx_desc;
if (rx_desc == NULL) {
SPDK_ERRLOG(" rx_desc does not exist!\n");
return -1;
}
req = &tx_desc->req_state;
req->fabric_rx_ctx = rx_desc;
/* send to NVMf library for backend NVMe processing */ /* send to NVMf library for backend NVMe processing */
ret = nvmf_process_io_cmd(req); ret = nvmf_process_io_cmd(req);
if (ret) { if (ret) {
@ -1112,7 +1100,7 @@ static int nvmf_cq_event_handler(struct spdk_nvmf_conn *conn)
req = &tx_desc->req_state; req = &tx_desc->req_state;
if (req->pending == NVMF_PENDING_WRITE) { if (req->pending == NVMF_PENDING_WRITE) {
req->pending = NVMF_PENDING_NONE; req->pending = NVMF_PENDING_NONE;
rc = nvmf_io_cmd_continue(conn, tx_desc); rc = nvmf_io_cmd_continue(conn, req);
if (rc) { if (rc) {
SPDK_ERRLOG("error from io cmd continue\n"); SPDK_ERRLOG("error from io cmd continue\n");
goto handler_error; goto handler_error;