/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_bcopy.c | 158 if (sk->so_snd.sb_sndptr) 173 if (sk->so_snd.sb_sndptr) { 198 sdp_tx_ring_slots_left(ssk) && sk->so_snd.sb_sndptr && 199 sdp_nagle_off(ssk, sk->so_snd.sb_sndptr)) { 204 sdp_tx_ring_slots_left(ssk) && (mb = sk->so_snd.sb_sndptr) && 208 SOCKBUF_LOCK(&sk->so_snd); 209 sk->so_snd.sb_sndptr = mb->m_nextpkt; 210 sk->so_snd.sb_mb = mb->m_nextpkt; 212 SB_EMPTY_FIXUP(&sk->so_snd); 214 sbfree(&sk->so_snd, [all...] |
H A D | sdp_main.c | 461 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 467 so->so_snd.sb_flags |= SB_AUTOSIZE; 975 SOCKBUF_LOCK(&so->so_snd); 976 sdp_append(ssk, &so->so_snd, m, cnt); 977 SOCKBUF_UNLOCK(&so->so_snd); 1001 SOCKBUF_LOCK(&so->so_snd); 1002 if (sbspace(&so->so_snd) < -512) { 1003 SOCKBUF_UNLOCK(&so->so_snd); 1017 sdp_append(ssk, &so->so_snd, m, cnt); 1018 SOCKBUF_UNLOCK(&so->so_snd); [all...] |
/freebsd-11-stable/sys/sys/ |
H A D | socketvar.h | 107 struct sockbuf so_rcv, so_snd; member in struct:socket 185 struct xsockbuf so_rcv, so_snd; member in struct:xsocket 221 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \ 224 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \ 272 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \ 273 if (sb_notify(&(so)->so_snd)) \ 274 sowakeup((so), &(so)->so_snd); \ 276 SOCKBUF_UNLOCK(&(so)->so_snd); \ 280 SOCKBUF_LOCK(&(so)->so_snd); \ [all...] |
/freebsd-11-stable/sys/netinet/ |
H A D | tcp_output.c | 326 SOCKBUF_LOCK(&so->so_snd); 351 if (off < sbused(&so->so_snd)) 362 * offset will be > 0 even if so_snd.sb_cc is 0, resulting in 377 len = ((long)ulmin(sbavail(&so->so_snd), sendwin) - 387 len = ((long)ulmin(sbavail(&so->so_snd), tp->snd_wnd) - 468 (off < (int) sbavail(&so->so_snd))) { 517 if (V_tcp_do_autosndbuf && so->so_snd.sb_flags & SB_AUTOSIZE) { 518 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && 519 sbused(&so->so_snd) >= (so->so_snd [all...] |
H A D | sctputil.h | 284 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \ 285 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \ 287 stcb->sctp_socket->so_snd.sb_cc = 0; \ 305 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \ 306 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \ 308 stcb->sctp_socket->so_snd.sb_cc = 0; \ 320 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
|
H A D | tcp_usrreq.c | 954 sbappendstream(&so->so_snd, m, flags); 997 SOCKBUF_LOCK(&so->so_snd); 998 if (sbspace(&so->so_snd) < -512) { 999 SOCKBUF_UNLOCK(&so->so_snd); 1012 sbappendstream_locked(&so->so_snd, m, flags); 1013 SOCKBUF_UNLOCK(&so->so_snd); 1035 tp->snd_up = tp->snd_una + sbavail(&so->so_snd); 1070 SOCKBUF_LOCK(&so->so_snd); 1071 error = sbready(&so->so_snd, m, count); 1072 SOCKBUF_UNLOCK(&so->so_snd); [all...] |
H A D | tcp_input.c | 1854 sbdrop(&so->so_snd, acked); 1898 if (sbavail(&so->so_snd)) 2714 SOCKBUF_LOCK(&so->so_snd); 2715 avail = sbavail(&so->so_snd) - 2717 SOCKBUF_UNLOCK(&so->so_snd); 2862 SOCKBUF_LOCK(&so->so_snd); 2863 if (acked > sbavail(&so->so_snd)) { 2864 if (tp->snd_wnd >= sbavail(&so->so_snd)) 2865 tp->snd_wnd -= sbavail(&so->so_snd); 2868 mfree = sbcut_locked(&so->so_snd, [all...] |
/freebsd-11-stable/sys/kern/ |
H A D | uipc_socket.c | 396 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd"); 398 sx_init(&so->so_snd.sb_sx, "so_snd_sx"); 400 TAILQ_INIT(&so->so_snd.sb_aiojobq); 402 TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so); 450 if (so->so_snd.sb_hiwat) 452 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); 463 sx_destroy(&so->so_snd.sb_sx); 465 SOCKBUF_LOCK_DESTROY(&so->so_snd); 524 knlist_init_mtx(&so->so_snd [all...] |
H A D | sys_socket.c | 186 SOCKBUF_LOCK(&so->so_snd); 187 so->so_snd.sb_flags |= SB_ASYNC; 188 SOCKBUF_UNLOCK(&so->so_snd); 196 SOCKBUF_LOCK(&so->so_snd); 197 so->so_snd.sb_flags &= ~SB_ASYNC; 198 SOCKBUF_UNLOCK(&so->so_snd); 209 *(int *)data = sbavail(&so->so_snd); 214 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || 215 (so->so_snd [all...] |
H A D | kern_sendfile.c | 571 (void)sblock(&so->so_snd, SBL_WAIT | SBL_NOINTR); 607 SOCKBUF_LOCK(&so->so_snd); 608 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) 609 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; 611 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 613 SOCKBUF_UNLOCK(&so->so_snd); 618 SOCKBUF_UNLOCK(&so->so_snd); 621 space = sbspace(&so->so_snd); [all...] |
H A D | uipc_sockbuf.c | 219 SOCKBUF_LOCK_ASSERT(&so->so_snd); 221 so->so_snd.sb_state |= SBS_CANTSENDMORE; 223 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); 230 SOCKBUF_LOCK(&so->so_snd); 232 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); 380 SOCKBUF_LOCK(&so->so_snd); 382 if (sbreserve_locked(&so->so_snd, sndcc, so, td) == 0) 388 if (so->so_snd.sb_lowat == 0) 389 so->so_snd.sb_lowat = MCLBYTES; 390 if (so->so_snd [all...] |
H A D | uipc_usrreq.c | 401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 822 * transaction on the remote so_snd. 844 SOCKBUF_LOCK(&so2->so_snd); 845 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) 846 so2->so_snd.sb_flags &= ~SB_STOP; 950 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 1029 SOCKBUF_LOCK(&so->so_snd); 1030 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd [all...] |
/freebsd-11-stable/sys/dev/iscsi/ |
H A D | icl_soft.c | 881 SOCKBUF_LOCK(&so->so_snd); 888 available = sbspace(&so->so_snd); 894 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; 895 SOCKBUF_UNLOCK(&so->so_snd); 908 SOCKBUF_LOCK(&so->so_snd); 909 available = sbspace(&so->so_snd); 916 so->so_snd.sb_lowat = max(size, 917 so->so_snd.sb_hiwat / 8); 918 SOCKBUF_UNLOCK(&so->so_snd); [all...] |
/freebsd-11-stable/sys/cam/ctl/ |
H A D | ctl_ha.c | 239 SOCKBUF_LOCK(&so->so_snd); 241 SOCKBUF_UNLOCK(&so->so_snd); 342 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; 346 SOCKBUF_LOCK(&so->so_snd); 347 if (sbspace(&so->so_snd) < softc->ha_sending->m_pkthdr.len) { 348 so->so_snd.sb_lowat = softc->ha_sending->m_pkthdr.len; 349 SOCKBUF_UNLOCK(&so->so_snd); 352 SOCKBUF_UNLOCK(&so->so_snd); 379 SOCKBUF_LOCK(&so->so_snd); [all...] |
/freebsd-11-stable/usr.bin/netstat/ |
H A D | netgraph.c | 124 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc);
|
H A D | inet.c | 181 sbtoxsockbuf(&so->so_snd, &xso->so_snd); 508 so->so_rcv.sb_cc, so->so_snd.sb_cc); 588 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, 589 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, 590 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, 591 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, 592 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, 593 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax);
|
H A D | unix.c | 321 so->so_snd.sb_cc, (long)unp->unp_vnode,
|
/freebsd-11-stable/usr.bin/bluetooth/btsockstat/ |
H A D | btsockstat.c | 261 so.so_snd.sb_ccc, 309 so.so_snd.sb_ccc, 367 so.so_snd.sb_ccc, 473 so.so_snd.sb_ccc,
|
/freebsd-11-stable/sys/netinet/tcp_stacks/ |
H A D | fastpath.c | 266 sbdrop(&so->so_snd, acked); 317 if (sbavail(&so->so_snd)) 1124 SOCKBUF_LOCK(&so->so_snd); 1125 avail = sbavail(&so->so_snd) - 1127 SOCKBUF_UNLOCK(&so->so_snd); 1259 SOCKBUF_LOCK(&so->so_snd); 1260 if (acked > sbavail(&so->so_snd)) { 1261 tp->snd_wnd -= sbavail(&so->so_snd); 1262 mfree = sbcut_locked(&so->so_snd, 1263 (int)sbavail(&so->so_snd)); [all...] |
/freebsd-11-stable/sys/netsmb/ |
H A D | smb_trantcp.c | 159 so->so_snd.sb_timeo = (5 * SBT_1S); 168 SOCKBUF_LOCK(&so->so_snd); 169 so->so_snd.sb_flags &= ~SB_NOINTR; 170 SOCKBUF_UNLOCK(&so->so_snd);
|
/freebsd-11-stable/sys/netgraph/ |
H A D | ng_ksocket.c | 614 SOCKBUF_LOCK(&priv->so->so_snd); 616 SOCKBUF_UNLOCK(&priv->so->so_snd); 948 SOCKBUF_LOCK(&priv->so->so_snd); 950 SOCKBUF_UNLOCK(&priv->so->so_snd); 1277 SOCKBUF_LOCK(&so->so_snd); 1279 SOCKBUF_UNLOCK(&so->so_snd);
|
/freebsd-11-stable/sys/dev/cxgbe/tom/ |
H A D | t4_cpl_io.c | 329 sbflush(&so->so_snd); 426 SOCKBUF_LOCK(&so->so_snd); 427 if (so->so_snd.sb_flags & SB_AUTOSIZE && V_tcp_do_autosndbuf) 430 bufsize = sbspace(&so->so_snd); 431 SOCKBUF_UNLOCK(&so->so_snd); 700 * The socket's so_snd buffer consists of a stream of data starting with sb_mb 721 struct sockbuf *sb = &so->so_snd; 1800 struct sockbuf *sb = &so->so_snd; 1810 * changed to ISCSI is still in so_snd. 1811 * Incoming credits should account for so_snd [all...] |
/freebsd-11-stable/sys/rpc/ |
H A D | clnt_bck.c | 308 SOCKBUF_LOCK(&xprt->xp_socket->so_snd); 309 sbwait(&xprt->xp_socket->so_snd); 310 SOCKBUF_UNLOCK(&xprt->xp_socket->so_snd);
|
/freebsd-11-stable/sys/netgraph/bluetooth/socket/ |
H A D | ng_btsocket_sco.c | 906 sbdroprecord(&pcb->so->so_snd); 909 if (sbavail(&pcb->so->so_snd) > 0) 1226 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 1718 sbappendrecord(&pcb->so->so_snd, m); 1726 sbdroprecord(&pcb->so->so_snd); /* XXX */ 1751 sbavail(&pcb->so->so_snd) > 0) { 1753 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); 1968 sbdroprecord(&pcb->so->so_snd);
|
H A D | ng_btsocket_l2cap.c | 1205 sbdroprecord(&pcb->so->so_snd); 1206 if (sbavail(&pcb->so->so_snd) > 0) { 1210 sbdroprecord(&pcb->so->so_snd); /* XXX */ 2025 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 2630 sbappendrecord(&pcb->so->so_snd, m); 2638 sbdroprecord(&pcb->so->so_snd); /* XXX */ 2662 if (sbavail(&pcb->so->so_snd) == 0) 2665 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); 2870 sbdroprecord(&pcb->so->so_snd);
|