/freebsd-11-stable/sys/netinet/ |
H A D | accf_http.c | 165 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && 166 !sbfull(&so->so_rcv)) { 171 m = so->so_rcv.sb_mb; 172 cc = sbavail(&so->so_rcv) - 1; 215 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) 218 m = so->so_rcv.sb_mb; 219 cc = sbavail(&so->so_rcv); 221 for (m = so->so_rcv.sb_mb; m; m = n) { 297 if ((so->so_rcv [all...] |
H A D | sctputil.c | 377 sctp_clog.x.lock.sock_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); 378 sctp_clog.x.lock.sockrcvbuf_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); 2851 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, 3001 &stcb->sctp_socket->so_rcv, 1, 3118 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { 3137 &stcb->sctp_socket->so_rcv, 1, 3221 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { 3240 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked); 3289 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, SCTP_SO_NOT_LOCKED); 3344 sb = &stcb->sctp_socket->so_rcv; [all...] |
H A D | accf_dns.c | 75 struct sockbuf *sb = &so->so_rcv;
|
H A D | tcp_reass.c | 232 &tp->t_inpcb->inp_socket->so_rcv, 586 sb = &tp->t_inpcb->inp_socket->so_rcv; 944 * XXXLAS: Using sbspace(so->so_rcv) instead of so->so_rcv.sb_hiwat 955 SOCKBUF_LOCK(&so->so_rcv); 956 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 959 sbappendstream_locked(&so->so_rcv, m, 0); 988 if (tp->t_segqlen >= min((so->so_rcv.sb_hiwat / tp->t_maxseg) + 1, 1057 SOCKBUF_LOCK(&so->so_rcv); 1063 if (so->so_rcv [all...] |
H A D | tcp_input.c | 1531 if (V_tcp_do_autorcvbuf && (so->so_rcv.sb_flags & SB_AUTOSIZE) && 1535 if (tp->rfbuf_cnt > (so->so_rcv.sb_hiwat / 8 * 7) && 1536 so->so_rcv.sb_hiwat < V_tcp_autorcvbuf_max) { 1537 newsize = min(so->so_rcv.sb_hiwat + 1903 tlen <= sbspace(&so->so_rcv)) { 1942 SOCKBUF_LOCK(&so->so_rcv); 1943 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 1951 if (!sbreserve_locked(&so->so_rcv, 1953 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; 1955 sbappendstream_locked(&so->so_rcv, [all...] |
/freebsd-11-stable/sys/sys/ |
H A D | socketvar.h | 66 * (c) locked by SOCKBUF_LOCK(&so->so_rcv). 107 struct sockbuf so_rcv, so_snd; member in struct:socket 153 #define SOCK_MTX(_so) SOCKBUF_MTX(&(_so)->so_rcv) 154 #define SOCK_LOCK(_so) SOCKBUF_LOCK(&(_so)->so_rcv) 155 #define SOCK_OWNED(_so) SOCKBUF_OWNED(&(_so)->so_rcv) 156 #define SOCK_UNLOCK(_so) SOCKBUF_UNLOCK(&(_so)->so_rcv) 157 #define SOCK_LOCK_ASSERT(_so) SOCKBUF_LOCK_ASSERT(&(_so)->so_rcv) 185 struct xsockbuf so_rcv, so_snd; member in struct:xsocket 214 (sbavail(&(so)->so_rcv) >= (so)->so_rcv [all...] |
/freebsd-11-stable/sys/kern/ |
H A D | uipc_socket.c | 397 SOCKBUF_LOCK_INIT(&so->so_rcv, "so_rcv"); 399 sx_init(&so->so_rcv.sb_sx, "so_rcv_sx"); 401 TAILQ_INIT(&so->so_rcv.sb_aiojobq); 403 TASK_INIT(&so->so_rcv.sb_aiotask, 0, soaio_rcv, so); 447 if (so->so_rcv.sb_hiwat) 449 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY); 464 sx_destroy(&so->so_rcv.sb_sx); 466 SOCKBUF_LOCK_DESTROY(&so->so_rcv); 523 knlist_init_mtx(&so->so_rcv [all...] |
H A D | sys_socket.c | 175 * SOCKBUF_LOCK(&so->so_rcv) even though they are the same 183 SOCKBUF_LOCK(&so->so_rcv); 184 so->so_rcv.sb_flags |= SB_ASYNC; 185 SOCKBUF_UNLOCK(&so->so_rcv); 193 SOCKBUF_LOCK(&so->so_rcv); 194 so->so_rcv.sb_flags &= ~SB_ASYNC; 195 SOCKBUF_UNLOCK(&so->so_rcv); 204 *(int *)data = sbavail(&so->so_rcv); 239 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; 300 sb = &so->so_rcv; [all...] |
H A D | uipc_sockbuf.c | 239 SOCKBUF_LOCK_ASSERT(&so->so_rcv); 241 so->so_rcv.sb_state |= SBS_CANTRCVMORE; 243 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED); 250 SOCKBUF_LOCK(&so->so_rcv); 252 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED); 328 KASSERT(sb == &so->so_rcv, 381 SOCKBUF_LOCK(&so->so_rcv); 384 if (sbreserve_locked(&so->so_rcv, rcvcc, so, td) == 0) 386 if (so->so_rcv.sb_lowat == 0) 387 so->so_rcv [all...] |
H A D | uipc_usrreq.c | 401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 821 * so_rcv to avoid holding the so_rcv lock over the entire 824 SOCKBUF_LOCK(&so->so_rcv); 825 mbcnt = so->so_rcv.sb_mbcnt; 826 sbcc = sbavail(&so->so_rcv); 827 SOCKBUF_UNLOCK(&so->so_rcv); 915 SOCKBUF_LOCK(&so2->so_rcv); 916 if (sbappendaddr_locked(&so2->so_rcv, from, m, 922 SOCKBUF_UNLOCK(&so2->so_rcv); [all...] |
/freebsd-11-stable/sys/rpc/ |
H A D | svc_dg.c | 138 SOCKBUF_LOCK(&so->so_rcv); 140 SOCKBUF_UNLOCK(&so->so_rcv); 198 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); 201 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); 207 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); 209 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); 274 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); 276 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
|
H A D | svc_vc.c | 186 SOCKBUF_LOCK(&so->so_rcv); 189 SOCKBUF_UNLOCK(&so->so_rcv); 267 SOCKBUF_LOCK(&so->so_rcv); 270 SOCKBUF_UNLOCK(&so->so_rcv); 362 KNOTE_UNLOCKED(&head->so_rcv.sb_sel.si_note, 0); 404 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); 409 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); 456 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); 461 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); 603 so->so_rcv [all...] |
H A D | clnt_dg.c | 277 sb = &so->so_rcv; 278 SOCKBUF_LOCK(&so->so_rcv); 282 SOCKBUF_UNLOCK(&so->so_rcv); 295 SOCKBUF_UNLOCK(&so->so_rcv); 297 SOCKBUF_LOCK(&so->so_rcv); 311 SOCKBUF_UNLOCK(&so->so_rcv); 358 cs = cu->cu_socket->so_rcv.sb_upcallarg; 822 cs = cu->cu_socket->so_rcv.sb_upcallarg; 955 cs = cu->cu_socket->so_rcv.sb_upcallarg; 1002 cs = cu->cu_socket->so_rcv [all...] |
H A D | clnt_vc.c | 266 SOCKBUF_LOCK(&ct->ct_socket->so_rcv); 268 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv); 768 SOCKBUF_LOCK(&ct->ct_socket->so_rcv); 771 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv); 875 if (sbavail(&so->so_rcv) >= sizeof(uint32_t) 876 || (so->so_rcv.sb_state & SBS_CANTRCVMORE) 883 SOCKBUF_UNLOCK(&so->so_rcv); 888 SOCKBUF_LOCK(&so->so_rcv); 928 if (sbavail(&so->so_rcv) >= ct->ct_record_resid 929 || (so->so_rcv [all...] |
/freebsd-11-stable/sys/cam/ctl/ |
H A D | ctl_ha.c | 231 SOCKBUF_LOCK(&so->so_rcv); 235 msleep(&softc->ha_receiving, SOCKBUF_MTX(&so->so_rcv), 238 SOCKBUF_UNLOCK(&so->so_rcv); 259 SOCKBUF_LOCK(&softc->ha_lso->so_rcv); 260 if (softc->ha_lso->so_rcv.sb_upcall != NULL) 262 SOCKBUF_UNLOCK(&softc->ha_lso->so_rcv); 284 SOCKBUF_LOCK(&so->so_rcv); 285 while (sbavail(&so->so_rcv) < next || softc->ha_disconnect) { 288 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { 291 so->so_rcv [all...] |
/freebsd-11-stable/sys/dev/cxgb/ulp/tom/ |
H A D | cxgb_cpl_io.c | 592 struct sockbuf *so_rcv = &so->so_rcv; local 598 SOCKBUF_LOCK(so_rcv); 599 KASSERT(toep->tp_enqueued >= sbused(so_rcv), 600 ("%s: sbused(so_rcv) > enqueued", __func__)); 601 toep->tp_rx_credits += toep->tp_enqueued - sbused(so_rcv); 602 toep->tp_enqueued = sbused(so_rcv); 603 SOCKBUF_UNLOCK(so_rcv); 738 SOCKBUF_LOCK_ASSERT(&so->so_rcv); 740 wnd = sbspace(&so->so_rcv); 1117 struct sockbuf *so_rcv; local [all...] |
/freebsd-11-stable/sys/dev/iscsi/ |
H A D | icl_soft.c | 782 SOCKBUF_LOCK(&so->so_rcv); 783 available = sbavail(&so->so_rcv); 785 so->so_rcv.sb_lowat = ic->ic_receive_len; 786 cv_wait(&ic->ic_receive_cv, &so->so_rcv.sb_mtx); 788 so->so_rcv.sb_lowat = so->so_rcv.sb_hiwat + 1; 789 SOCKBUF_UNLOCK(&so->so_rcv); 1239 ic->ic_socket->so_rcv.sb_flags |= SB_AUTOSIZE; 1264 SOCKBUF_LOCK(&ic->ic_socket->so_rcv); 1266 SOCKBUF_UNLOCK(&ic->ic_socket->so_rcv); [all...] |
/freebsd-11-stable/sys/net/ |
H A D | raw_usrreq.c | 100 if (sbappendaddr(&last->so_rcv, src, 111 if (sbappendaddr(&last->so_rcv, src,
|
/freebsd-11-stable/sys/netinet6/ |
H A D | send.c | 290 SOCKBUF_LOCK(&V_send_so->so_rcv); 291 if (sbappendaddr_locked(&V_send_so->so_rcv, 293 SOCKBUF_UNLOCK(&V_send_so->so_rcv);
|
/freebsd-11-stable/sys/netsmb/ |
H A D | smb_trantcp.c | 155 SOCKBUF_LOCK(&so->so_rcv); 157 SOCKBUF_UNLOCK(&so->so_rcv); 158 so->so_rcv.sb_timeo = (5 * SBT_1S); 165 SOCKBUF_LOCK(&so->so_rcv); 166 so->so_rcv.sb_flags &= ~SB_NOINTR; 167 SOCKBUF_UNLOCK(&so->so_rcv); 354 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) {
|
/freebsd-11-stable/sys/netinet/tcp_stacks/ |
H A D | fastpath.c | 399 SOCKBUF_LOCK(&so->so_rcv); 400 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 408 if (!sbreserve_locked(&so->so_rcv, 410 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; 412 sbappendstream_locked(&so->so_rcv, m, 0); 466 win = sbspace(&so->so_rcv); 1311 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { 1388 SOCKBUF_LOCK(&so->so_rcv); 1389 if (th->th_urp + sbavail(&so->so_rcv) > sb_max) { 1392 SOCKBUF_UNLOCK(&so->so_rcv); /* XX [all...] |
/freebsd-11-stable/sys/netnatm/ |
H A D | natm.c | 129 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 450 if (sbspace(&so->so_rcv) > m->m_pkthdr.len) { 455 sbappendrecord(&so->so_rcv, m);
|
/freebsd-11-stable/usr.bin/netstat/ |
H A D | netgraph.c | 124 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc);
|
/freebsd-11-stable/usr.bin/bluetooth/btsockstat/ |
H A D | btsockstat.c | 260 so.so_rcv.sb_ccc, 308 so.so_rcv.sb_ccc, 366 so.so_rcv.sb_ccc, 472 so.so_rcv.sb_ccc,
|
/freebsd-11-stable/sys/netgraph/ |
H A D | ng_ksocket.c | 611 SOCKBUF_LOCK(&priv->so->so_rcv); 613 SOCKBUF_UNLOCK(&priv->so->so_rcv); 945 SOCKBUF_LOCK(&priv->so->so_rcv); 947 SOCKBUF_UNLOCK(&priv->so->so_rcv); 1163 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && 1190 if (head->so_rcv.sb_state & SBS_CANTRCVMORE) 1230 /* XXX KNOTE_UNLOCKED(&head->so_rcv.sb_sel.si_note, 0); */ 1274 SOCKBUF_LOCK(&so->so_rcv); 1276 SOCKBUF_UNLOCK(&so->so_rcv);
|