Lines Matching defs:rx_buffers

96 	struct nvmf_tcp_command_buffer_list rx_buffers;
100 	 * two locations, all protected by the rx_buffers.lock.  If a
103 	 * placed on the rx_buffers list.  When a request is allocated
421 	tcp_purge_command_buffer(&qp->rx_buffers, rsp->rccqe.cid, 0);
510 	mtx_assert(&qp->rx_buffers.lock, MA_OWNED);
513 	TAILQ_FOREACH(cb, &qp->rx_buffers.head, link) {
520 		TAILQ_REMOVE(&qp->rx_buffers.head, cb, link);
533 	mtx_assert(&qp->rx_buffers.lock, MA_OWNED);
583  * NB: This drops the rx_buffers.lock mutex.
591 	mtx_assert(&qp->rx_buffers.lock, MA_OWNED);
603 		mtx_unlock(&qp->rx_buffers.lock);
607 		mtx_unlock(&qp->rx_buffers.lock);
667 	mtx_lock(&qp->rx_buffers.lock);
670 		mtx_unlock(&qp->rx_buffers.lock);
691 		mtx_unlock(&qp->rx_buffers.lock);
703 		mtx_unlock(&qp->rx_buffers.lock);
712 		mtx_unlock(&qp->rx_buffers.lock);
722 		mtx_unlock(&qp->rx_buffers.lock);
736 		mtx_unlock(&qp->rx_buffers.lock);
755 	mtx_lock(&qp->rx_buffers.lock);
756 	cb = tcp_find_command_buffer(&qp->rx_buffers, c2h->cccid, 0);
758 		mtx_unlock(&qp->rx_buffers.lock);
774 		tcp_remove_command_buffer(&qp->rx_buffers, cb);
775 		mtx_unlock(&qp->rx_buffers.lock);
783 		mtx_unlock(&qp->rx_buffers.lock);
795 		mtx_unlock(&qp->rx_buffers.lock);
804 		mtx_unlock(&qp->rx_buffers.lock);
814 		mtx_unlock(&qp->rx_buffers.lock);
825 		tcp_remove_command_buffer(&qp->rx_buffers, cb);
828 	mtx_unlock(&qp->rx_buffers.lock);
1247 			mtx_lock(&qp->rx_buffers.lock);
1248 			tcp_add_command_buffer(&qp->rx_buffers, cb);
1249 			mtx_unlock(&qp->rx_buffers.lock);
1484 	TAILQ_INIT(&qp->rx_buffers.head);
1486 	mtx_init(&qp->rx_buffers.lock, "nvmf/tcp rx buffers", NULL, MTX_DEF);
1576 	mtx_lock(&qp->rx_buffers.lock);
1577 	TAILQ_FOREACH_SAFE(cb, &qp->rx_buffers.head, link, ncb) {
1578 		tcp_remove_command_buffer(&qp->rx_buffers, cb);
1579 		mtx_unlock(&qp->rx_buffers.lock);
1586 		mtx_lock(&qp->rx_buffers.lock);
1588 	mtx_destroy(&qp->rx_buffers.lock);
1721 	mtx_lock(&qp->rx_buffers.lock);
1726 		TAILQ_INSERT_TAIL(&qp->rx_buffers.head, cb, link);
1727 		mtx_unlock(&qp->rx_buffers.lock);
1732 	mtx_unlock(&qp->rx_buffers.lock);