diff --git a/include/spdk_internal/nvme_tcp.h b/include/spdk_internal/nvme_tcp.h index 38f607dfc..c5bf874e2 100644 --- a/include/spdk_internal/nvme_tcp.h +++ b/include/spdk_internal/nvme_tcp.h @@ -107,7 +107,6 @@ struct nvme_tcp_pdu { uint8_t ch_valid_bytes; uint8_t psh_valid_bytes; uint8_t psh_len; - int ref; nvme_tcp_qpair_xfer_complete_cb cb_fn; void *cb_arg; diff --git a/lib/nvmf/tcp.c b/lib/nvmf/tcp.c index a4a1e5264..24cd6b9be 100644 --- a/lib/nvmf/tcp.c +++ b/lib/nvmf/tcp.c @@ -328,7 +328,6 @@ spdk_nvmf_tcp_pdu_get(struct spdk_nvmf_tcp_qpair *tqpair) TAILQ_REMOVE(&tqpair->free_queue, pdu, tailq); memset(pdu, 0, sizeof(*pdu)); pdu->qpair = tqpair; - pdu->ref = 1; pdu->hdr = &pdu->hdr_mem; return pdu; @@ -337,17 +336,8 @@ spdk_nvmf_tcp_pdu_get(struct spdk_nvmf_tcp_qpair *tqpair) static void spdk_nvmf_tcp_pdu_put(struct spdk_nvmf_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu) { - if (!pdu) { - return; - } - - assert(pdu->ref > 0); - - pdu->ref--; - if (pdu->ref == 0) { - tqpair->free_pdu_num++; - TAILQ_INSERT_HEAD(&tqpair->free_queue, pdu, tailq); - } + tqpair->free_pdu_num++; + TAILQ_INSERT_HEAD(&tqpair->free_queue, pdu, tailq); } static struct spdk_nvmf_tcp_req *