Lines Matching refs:tx_buffers
95 struct nvmf_tcp_command_buffer_list tx_buffers; member
422 tcp_purge_command_buffer(&qp->tx_buffers, rsp->rccqe.cid, 0); in nvmf_tcp_save_response_capsule()
950 mtx_lock(&qp->tx_buffers.lock); in nvmf_tcp_handle_r2t()
951 cb = tcp_find_command_buffer(&qp->tx_buffers, r2t->cccid, 0); in nvmf_tcp_handle_r2t()
953 mtx_unlock(&qp->tx_buffers.lock); in nvmf_tcp_handle_r2t()
964 mtx_unlock(&qp->tx_buffers.lock); in nvmf_tcp_handle_r2t()
978 mtx_unlock(&qp->tx_buffers.lock); in nvmf_tcp_handle_r2t()
988 tcp_remove_command_buffer(&qp->tx_buffers, cb); in nvmf_tcp_handle_r2t()
991 mtx_unlock(&qp->tx_buffers.lock); in nvmf_tcp_handle_r2t()
1243 mtx_lock(&qp->tx_buffers.lock); in tcp_command_pdu()
1244 tcp_add_command_buffer(&qp->tx_buffers, cb); in tcp_command_pdu()
1245 mtx_unlock(&qp->tx_buffers.lock); in tcp_command_pdu()
1485 TAILQ_INIT(&qp->tx_buffers.head); in tcp_allocate_qpair()
1487 mtx_init(&qp->tx_buffers.lock, "nvmf/tcp tx buffers", NULL, MTX_DEF); in tcp_allocate_qpair()
1590 mtx_lock(&qp->tx_buffers.lock); in tcp_free_qpair()
1591 TAILQ_FOREACH_SAFE(cb, &qp->tx_buffers.head, link, ncb) { in tcp_free_qpair()
1592 tcp_remove_command_buffer(&qp->tx_buffers, cb); in tcp_free_qpair()
1593 mtx_unlock(&qp->tx_buffers.lock); in tcp_free_qpair()
1596 mtx_lock(&qp->tx_buffers.lock); in tcp_free_qpair()
1598 mtx_destroy(&qp->tx_buffers.lock); in tcp_free_qpair()