Searched refs:so_snd (Results 1 - 25 of 49) sorted by relevance

12

/freebsd-10.0-release/sys/kern/
H A Dsys_socket.c151 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 Duipc_socket.c336 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 Duipc_sockbuf.c84 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 Duipc_syscalls.c2266 (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 Duipc_usrreq.c401 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 Dsdp_bcopy.c158 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 Dsdp_main.c453 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 Dsocketvar.h65 * (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 Dsctputil.h285 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 Dtcp_output.c301 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 Dtcp_input.c1713 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 Dtcp_usrreq.c837 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 Dbtsockstat.c259 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 Dicl.c835 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 Dinet.c177 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 Dnetgraph.c165 name, sockb.so_rcv.sb_cc, sockb.so_snd.sb_cc);
H A Datalk.c250 sockb.so_snd.sb_cc);
H A Dunix.c290 so->so_snd.sb_cc, (long)unp->unp_vnode, (long)unp->unp_conn,
/freebsd-10.0-release/sys/netipx/
H A Dspx_reass.c252 SOCKBUF_LOCK(&so->so_snd);
253 while ((m = so->so_snd.sb_mb) != NULL) {
255 sbdroprecord_locked(&so->so_snd);
H A Dspx_usrreq.c440 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 Dsmb_trantcp.c159 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 Dng_btsocket_sco.c906 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 Dng_btsocket_l2cap.c1131 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 Dng_ksocket.c622 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 Dt4_cpl_io.c193 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;

Completed in 196 milliseconds

12