diff --git a/include/spdk_internal/nvme_tcp.h b/include/spdk_internal/nvme_tcp.h index 5240b44b5..99f12b371 100644 --- a/include/spdk_internal/nvme_tcp.h +++ b/include/spdk_internal/nvme_tcp.h @@ -125,6 +125,7 @@ struct nvme_tcp_pdu { struct spdk_dif_ctx *dif_ctx; void *req; /* data tied to a tcp request */ + void *qpair; }; enum nvme_tcp_pdu_recv_state { diff --git a/lib/nvmf/tcp.c b/lib/nvmf/tcp.c index 82a9c9be3..b842152df 100644 --- a/lib/nvmf/tcp.c +++ b/lib/nvmf/tcp.c @@ -326,6 +326,7 @@ spdk_nvmf_tcp_pdu_get(struct spdk_nvmf_tcp_qpair *tqpair) tqpair->free_pdu_num--; TAILQ_REMOVE(&tqpair->free_queue, pdu, tailq); memset(pdu, 0, sizeof(*pdu)); + pdu->qpair = tqpair; pdu->ref = 1; pdu->hdr = &pdu->hdr_mem;