Lines Matching refs:rx_buffers

96 	struct nvmf_tcp_command_buffer_list rx_buffers;  member
421 tcp_purge_command_buffer(&qp->rx_buffers, rsp->rccqe.cid, 0); in nvmf_tcp_save_response_capsule()
510 mtx_assert(&qp->rx_buffers.lock, MA_OWNED); in nvmf_tcp_next_r2t()
513 TAILQ_FOREACH(cb, &qp->rx_buffers.head, link) { in nvmf_tcp_next_r2t()
520 TAILQ_REMOVE(&qp->rx_buffers.head, cb, link); in nvmf_tcp_next_r2t()
533 mtx_assert(&qp->rx_buffers.lock, MA_OWNED); in nvmf_tcp_allocate_ttag()
591 mtx_assert(&qp->rx_buffers.lock, MA_OWNED); in nvmf_tcp_send_next_r2t()
603 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_send_next_r2t()
607 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_send_next_r2t()
667 mtx_lock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
670 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
691 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
703 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
712 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
722 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
736 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_h2c_data()
755 mtx_lock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
756 cb = tcp_find_command_buffer(&qp->rx_buffers, c2h->cccid, 0); in nvmf_tcp_handle_c2h_data()
758 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
774 tcp_remove_command_buffer(&qp->rx_buffers, cb); in nvmf_tcp_handle_c2h_data()
775 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
783 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
795 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
804 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
814 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
825 tcp_remove_command_buffer(&qp->rx_buffers, cb); in nvmf_tcp_handle_c2h_data()
828 mtx_unlock(&qp->rx_buffers.lock); in nvmf_tcp_handle_c2h_data()
1247 mtx_lock(&qp->rx_buffers.lock); in tcp_command_pdu()
1248 tcp_add_command_buffer(&qp->rx_buffers, cb); in tcp_command_pdu()
1249 mtx_unlock(&qp->rx_buffers.lock); in tcp_command_pdu()
1484 TAILQ_INIT(&qp->rx_buffers.head); in tcp_allocate_qpair()
1486 mtx_init(&qp->rx_buffers.lock, "nvmf/tcp rx buffers", NULL, MTX_DEF); in tcp_allocate_qpair()
1576 mtx_lock(&qp->rx_buffers.lock); in tcp_free_qpair()
1577 TAILQ_FOREACH_SAFE(cb, &qp->rx_buffers.head, link, ncb) { in tcp_free_qpair()
1578 tcp_remove_command_buffer(&qp->rx_buffers, cb); in tcp_free_qpair()
1579 mtx_unlock(&qp->rx_buffers.lock); in tcp_free_qpair()
1586 mtx_lock(&qp->rx_buffers.lock); in tcp_free_qpair()
1588 mtx_destroy(&qp->rx_buffers.lock); in tcp_free_qpair()
1721 mtx_lock(&qp->rx_buffers.lock); in tcp_receive_r2t_data()
1726 TAILQ_INSERT_TAIL(&qp->rx_buffers.head, cb, link); in tcp_receive_r2t_data()
1727 mtx_unlock(&qp->rx_buffers.lock); in tcp_receive_r2t_data()
1732 mtx_unlock(&qp->rx_buffers.lock); in tcp_receive_r2t_data()