Lines Matching refs:so_rcv
1092 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1100 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1104 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1106 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_tcp_receive()
1109 avail = sbavail(&so->so_rcv); in nvmf_tcp_receive()
1110 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0) { in nvmf_tcp_receive()
1115 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1119 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_tcp_receive()
1122 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1173 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1200 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1201 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0) { in nvmf_tcp_receive()
1203 SOCKBUF_MTX(&so->so_rcv), 30 * hz); in nvmf_tcp_receive()
1207 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1212 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1214 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1495 SOCKBUF_LOCK(&so->so_rcv); in tcp_allocate_qpair()
1497 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_allocate_qpair()
1545 SOCKBUF_LOCK(&so->so_rcv); in tcp_free_qpair()
1549 mtx_sleep(qp->rx_thread, SOCKBUF_MTX(&so->so_rcv), 0, in tcp_free_qpair()
1553 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_free_qpair()