Lines Matching defs:so_rcv
592 struct sockbuf *so_rcv = &so->so_rcv;
598 SOCKBUF_LOCK(so_rcv);
599 KASSERT(toep->tp_enqueued >= so_rcv->sb_cc,
600 ("%s: so_rcv->sb_cc > enqueued", __func__));
601 toep->tp_rx_credits += toep->tp_enqueued - so_rcv->sb_cc;
602 toep->tp_enqueued = so_rcv->sb_cc;
603 SOCKBUF_UNLOCK(so_rcv);
738 SOCKBUF_LOCK_ASSERT(&so->so_rcv);
740 wnd = sbspace(&so->so_rcv);
780 SOCKBUF_LOCK(&so->so_rcv);
782 SOCKBUF_UNLOCK(&so->so_rcv);
990 SOCKBUF_LOCK(&so->so_rcv);
993 SOCKBUF_UNLOCK(&so->so_rcv);
1117 struct sockbuf *so_rcv;
1165 so_rcv = &so->so_rcv;
1166 SOCKBUF_LOCK(so_rcv);
1168 if (__predict_false(so_rcv->sb_state & SBS_CANTRCVMORE)) {
1171 SOCKBUF_UNLOCK(so_rcv);
1186 if (so_rcv->sb_flags & SB_AUTOSIZE &&
1188 so_rcv->sb_hiwat < V_tcp_autorcvbuf_max &&
1189 (m->m_pkthdr.len > (sbspace(so_rcv) / 8 * 7) || tp->rcv_wnd < 32768)) {
1190 unsigned int hiwat = so_rcv->sb_hiwat;
1194 if (!sbreserve_locked(so_rcv, newsize, so, NULL))
1195 so_rcv->sb_flags &= ~SB_AUTOSIZE;
1201 sbappendstream_locked(so_rcv, m);
1203 SOCKBUF_UNLOCK_ASSERT(so_rcv);
1318 if (so->so_rcv.sb_state & SBS_CANTRCVMORE)
1599 SOCKBUF_LOCK(&so->so_rcv);
1601 SOCKBUF_UNLOCK(&so->so_rcv);