/freebsd-10.0-release/sys/kern/ |
H A D | sys_socket.c | 151 SOCKBUF_LOCK(&so->so_snd); 152 so->so_snd.sb_flags |= SB_ASYNC; 153 SOCKBUF_UNLOCK(&so->so_snd); 161 SOCKBUF_LOCK(&so->so_snd); 162 so->so_snd.sb_flags &= ~SB_ASYNC; 163 SOCKBUF_UNLOCK(&so->so_snd); 174 *(int *)data = so->so_snd.sb_cc; 178 if ((so->so_snd.sb_hiwat < so->so_snd.sb_cc) || 179 (so->so_snd [all...] |
H A D | uipc_socket.c | 336 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd"); 338 sx_init(&so->so_snd.sb_sx, "so_snd_sx"); 378 if (so->so_snd.sb_hiwat) 380 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); 390 sx_destroy(&so->so_snd.sb_sx); 392 SOCKBUF_LOCK_DESTROY(&so->so_snd); 451 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd)); 528 knlist_init_mtx(&so->so_snd [all...] |
H A D | uipc_sockbuf.c | 84 SOCKBUF_LOCK_ASSERT(&so->so_snd); 86 so->so_snd.sb_state |= SBS_CANTSENDMORE; 88 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); 95 SOCKBUF_LOCK(&so->so_snd); 97 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); 245 SOCKBUF_LOCK(&so->so_snd); 247 if (sbreserve_locked(&so->so_snd, sndcc, so, td) == 0) 253 if (so->so_snd.sb_lowat == 0) 254 so->so_snd.sb_lowat = MCLBYTES; 255 if (so->so_snd [all...] |
H A D | uipc_syscalls.c | 2266 (void)sblock(&so->so_snd, SBL_WAIT | SBL_NOINTR); 2310 SOCKBUF_LOCK(&so->so_snd); 2311 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) 2312 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; 2314 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 2316 SOCKBUF_UNLOCK(&so->so_snd); 2321 SOCKBUF_UNLOCK(&so->so_snd); 2324 space = sbspace(&so->so_snd); [all...] |
H A D | uipc_usrreq.c | 401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 808 * transaction on the remote so_snd. 821 SOCKBUF_LOCK(&so2->so_snd); 822 so2->so_snd.sb_mbmax += unp->unp_mbcnt - mbcnt; 823 newhiwat = so2->so_snd.sb_hiwat + unp->unp_cc - sbcc; 824 (void)chgsbsize(so2->so_cred->cr_uidinfo, &so2->so_snd.sb_hiwat, 928 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { 998 SOCKBUF_LOCK(&so->so_snd); 999 if ((int)so->so_snd.sb_hiwat >= (int)(sbcc - unp2->unp_cc)) 1000 newhiwat = so->so_snd [all...] |
/freebsd-10.0-release/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 | 453 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 459 so->so_snd.sb_flags |= SB_AUTOSIZE; 966 SOCKBUF_LOCK(&so->so_snd); 967 sdp_append(ssk, &so->so_snd, m, cnt); 968 SOCKBUF_UNLOCK(&so->so_snd); 992 SOCKBUF_LOCK(&so->so_snd); 993 if (sbspace(&so->so_snd) < -512) { 994 SOCKBUF_UNLOCK(&so->so_snd); 1008 sdp_append(ssk, &so->so_snd, m, cnt); 1009 SOCKBUF_UNLOCK(&so->so_snd); [all...] |
/freebsd-10.0-release/sys/sys/ |
H A D | socketvar.h | 65 * (d) locked by SOCKBUF_LOCK(&so->so_snd). 107 struct sockbuf so_rcv, so_snd; member in struct:socket 179 struct xsockbuf so_rcv, so_snd; member in struct:xsocket 215 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \ 218 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \ 266 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \ 267 if (sb_notify(&(so)->so_snd)) \ 268 sowakeup((so), &(so)->so_snd); \ 270 SOCKBUF_UNLOCK(&(so)->so_snd); \ [all...] |
/freebsd-10.0-release/sys/netinet/ |
H A D | sctputil.h | 285 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \ 286 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \ 288 stcb->sctp_socket->so_snd.sb_cc = 0; \ 306 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \ 307 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \ 309 stcb->sctp_socket->so_snd.sb_cc = 0; \ 321 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
|
H A D | tcp_output.c | 301 SOCKBUF_LOCK(&so->so_snd); 326 if (off < so->so_snd.sb_cc) 337 * offset will be > 0 even if so_snd.sb_cc is 0, resulting in 352 len = ((long)ulmin(so->so_snd.sb_cc, sendwin) - off); 361 len = ((long)ulmin(so->so_snd.sb_cc, tp->snd_wnd) 462 if (V_tcp_do_autosndbuf && so->so_snd.sb_flags & SB_AUTOSIZE) { 463 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && 464 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && 465 so->so_snd [all...] |
H A D | tcp_input.c | 1713 sbdrop(&so->so_snd, acked); 1757 if (so->so_snd.sb_cc) 2583 SOCKBUF_LOCK(&so->so_snd); 2584 avail = so->so_snd.sb_cc - 2586 SOCKBUF_UNLOCK(&so->so_snd); 2718 SOCKBUF_LOCK(&so->so_snd); 2719 if (acked > so->so_snd.sb_cc) { 2720 tp->snd_wnd -= so->so_snd.sb_cc; 2721 mfree = sbcut_locked(&so->so_snd, 2722 (int)so->so_snd [all...] |
H A D | tcp_usrreq.c | 837 sbappendstream(&so->so_snd, m); 880 SOCKBUF_LOCK(&so->so_snd); 881 if (sbspace(&so->so_snd) < -512) { 882 SOCKBUF_UNLOCK(&so->so_snd); 895 sbappendstream_locked(&so->so_snd, m); 896 SOCKBUF_UNLOCK(&so->so_snd); 919 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; 1610 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 1616 so->so_snd.sb_flags |= SB_AUTOSIZE;
|
/freebsd-10.0-release/usr.bin/bluetooth/btsockstat/ |
H A D | btsockstat.c | 259 so.so_snd.sb_cc, 307 so.so_snd.sb_cc, 365 so.so_snd.sb_cc, 471 so.so_snd.sb_cc,
|
/freebsd-10.0-release/sys/dev/iscsi/ |
H A D | icl.c | 835 SOCKBUF_LOCK(&so->so_snd); 836 available = sbspace(&so->so_snd); 837 SOCKBUF_UNLOCK(&so->so_snd); 851 SOCKBUF_LOCK(&so->so_snd); 852 so->so_snd.sb_lowat = size; 853 SOCKBUF_UNLOCK(&so->so_snd); 1076 SOCKBUF_LOCK(&ic->ic_socket->so_snd); 1078 SOCKBUF_UNLOCK(&ic->ic_socket->so_snd);
|
/freebsd-10.0-release/usr.bin/netstat/ |
H A D | inet.c | 177 sbtoxsockbuf(&so->so_snd, &xso->so_snd); 479 printf("%6u %6u ", so->so_rcv.sb_cc, so->so_snd.sb_cc); 537 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, 538 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, 539 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, 540 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, 541 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, 542 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax);
|
H A D | netgraph.c | 165 name, sockb.so_rcv.sb_cc, sockb.so_snd.sb_cc);
|
H A D | atalk.c | 250 sockb.so_snd.sb_cc);
|
H A D | unix.c | 290 so->so_snd.sb_cc, (long)unp->unp_vnode, (long)unp->unp_conn,
|
/freebsd-10.0-release/sys/netipx/ |
H A D | spx_reass.c | 252 SOCKBUF_LOCK(&so->so_snd); 253 while ((m = so->so_snd.sb_mb) != NULL) { 255 sbdroprecord_locked(&so->so_snd);
|
H A D | spx_usrreq.c | 440 struct sockbuf *sb = &so->so_snd; 671 if (so->so_snd.sb_cc && cb->s_timer[SPXT_REXMT] == 0 && 1085 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 1117 sb = &so->so_snd; 1423 if (sbspace(&so->so_snd) < -512) { 1513 struct sockbuf *sb = &(ipxp->ipxp_socket->so_snd);
|
/freebsd-10.0-release/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-10.0-release/sys/netgraph/bluetooth/socket/ |
H A D | ng_btsocket_sco.c | 906 sbdroprecord(&pcb->so->so_snd); 909 if (pcb->so->so_snd.sb_cc > 0) 1222 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 1714 sbappendrecord(&pcb->so->so_snd, m); 1722 sbdroprecord(&pcb->so->so_snd); /* XXX */ 1747 pcb->so->so_snd.sb_cc > 0) { 1749 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); 1964 sbdroprecord(&pcb->so->so_snd);
|
H A D | ng_btsocket_l2cap.c | 1131 sbdroprecord(&pcb->so->so_snd); 1132 if (pcb->so->so_snd.sb_cc > 0) { 1136 sbdroprecord(&pcb->so->so_snd); /* XXX */ 1931 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 2481 sbappendrecord(&pcb->so->so_snd, m); 2489 sbdroprecord(&pcb->so->so_snd); /* XXX */ 2513 if (pcb->so->so_snd.sb_cc == 0) 2516 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); 2715 sbdroprecord(&pcb->so->so_snd);
|
/freebsd-10.0-release/sys/netgraph/ |
H A D | ng_ksocket.c | 622 SOCKBUF_LOCK(&priv->so->so_snd); 624 SOCKBUF_UNLOCK(&priv->so->so_snd); 956 SOCKBUF_LOCK(&priv->so->so_snd); 958 SOCKBUF_UNLOCK(&priv->so->so_snd); 1279 SOCKBUF_LOCK(&so->so_snd); 1281 SOCKBUF_UNLOCK(&so->so_snd);
|
/freebsd-10.0-release/sys/dev/cxgbe/tom/ |
H A D | t4_cpl_io.c | 193 sbflush(&so->so_snd); 291 SOCKBUF_LOCK(&so->so_snd); 292 if (so->so_snd.sb_flags & SB_AUTOSIZE && V_tcp_do_autosndbuf) 295 bufsize = sbspace(&so->so_snd); 296 SOCKBUF_UNLOCK(&so->so_snd); 519 * The socket's so_snd buffer consists of a stream of data starting with sb_mb 540 struct sockbuf *sb = &so->so_snd; 1413 struct sockbuf *sb = &so->so_snd;
|