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

12

/freebsd-9.3-release/sys/kern/
H A Dsys_socket.c150 SOCKBUF_LOCK(&so->so_snd);
151 so->so_snd.sb_flags |= SB_ASYNC;
152 SOCKBUF_UNLOCK(&so->so_snd);
160 SOCKBUF_LOCK(&so->so_snd);
161 so->so_snd.sb_flags &= ~SB_ASYNC;
162 SOCKBUF_UNLOCK(&so->so_snd);
173 *(int *)data = so->so_snd.sb_cc;
177 if ((so->so_snd.sb_hiwat < so->so_snd.sb_cc) ||
178 (so->so_snd
[all...]
H A Duipc_socket.c342 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd");
344 sx_init(&so->so_snd.sb_sx, "so_snd_sx");
384 if (so->so_snd.sb_hiwat)
386 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY);
396 sx_destroy(&so->so_snd.sb_sx);
398 SOCKBUF_LOCK_DESTROY(&so->so_snd);
448 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd));
537 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.c2006 (void)sblock(&so->so_snd, SBL_WAIT | SBL_NOINTR);
2050 SOCKBUF_LOCK(&so->so_snd);
2051 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2)
2052 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2;
2054 if (so->so_snd.sb_state & SBS_CANTSENDMORE) {
2056 SOCKBUF_UNLOCK(&so->so_snd);
2061 SOCKBUF_UNLOCK(&so->so_snd);
2064 space = sbspace(&so->so_snd);
[all...]
H A Duipc_usrreq.c396 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
792 * transaction on the remote so_snd.
805 SOCKBUF_LOCK(&so2->so_snd);
806 so2->so_snd.sb_mbmax += unp->unp_mbcnt - mbcnt;
807 newhiwat = so2->so_snd.sb_hiwat + unp->unp_cc - sbcc;
808 (void)chgsbsize(so2->so_cred->cr_uidinfo, &so2->so_snd.sb_hiwat,
913 if (so->so_snd.sb_state & SBS_CANTSENDMORE) {
989 SOCKBUF_LOCK(&so->so_snd);
990 if ((int)so->so_snd.sb_hiwat >= (int)(sbcc - unp2->unp_cc))
991 newhiwat = so->so_snd
[all...]
/freebsd-9.3-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-9.3-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-9.3-release/sys/netinet/
H A Dtcp_output.c298 SOCKBUF_LOCK(&so->so_snd);
323 if (off < so->so_snd.sb_cc)
334 * offset will be > 0 even if so_snd.sb_cc is 0, resulting in
349 len = ((long)ulmin(so->so_snd.sb_cc, sendwin) - off);
358 len = ((long)ulmin(so->so_snd.sb_cc, tp->snd_wnd)
419 (off < (int) so->so_snd.sb_cc)) {
466 if (V_tcp_do_autosndbuf && so->so_snd.sb_flags & SB_AUTOSIZE) {
467 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat &&
468 so->so_snd.sb_cc >= (so->so_snd
[all...]
H A Dsctputil.h287 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \
288 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \
290 stcb->sctp_socket->so_snd.sb_cc = 0; \
308 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \
309 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \
311 stcb->sctp_socket->so_snd.sb_cc = 0; \
323 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
H A Dtcp_input.c1697 sbdrop(&so->so_snd, acked);
1741 if (so->so_snd.sb_cc)
2561 SOCKBUF_LOCK(&so->so_snd);
2562 avail = so->so_snd.sb_cc -
2564 SOCKBUF_UNLOCK(&so->so_snd);
2696 SOCKBUF_LOCK(&so->so_snd);
2697 if (acked > so->so_snd.sb_cc) {
2698 tp->snd_wnd -= so->so_snd.sb_cc;
2699 sbdrop_locked(&so->so_snd, (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;
1611 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
1617 so->so_snd.sb_flags |= SB_AUTOSIZE;
/freebsd-9.3-release/sys/fs/fifofs/
H A Dfifo_vnops.c222 wso->so_snd.sb_lowat = PIPE_BUF;
240 SOCKBUF_LOCK(&fip->fi_writesock->so_snd);
241 fip->fi_writesock->so_snd.sb_state &= ~SBS_CANTSENDMORE;
242 SOCKBUF_UNLOCK(&fip->fi_writesock->so_snd);
353 SOCKBUF_LOCK(&so->so_snd);
354 knlist_remove(&so->so_snd.sb_sel.si_note, kn, 1);
355 if (knlist_empty(&so->so_snd.sb_sel.si_note))
356 so->so_snd.sb_flags &= ~SB_KNOTE;
357 SOCKBUF_UNLOCK(&so->so_snd);
365 SOCKBUF_LOCK_ASSERT(&so->so_snd);
[all...]
/freebsd-9.3-release/sys/fs/portalfs/
H A Dportal_vnops.c324 SOCKBUF_LOCK(&so->so_snd);
325 so->so_snd.sb_timeo = 0;
326 so->so_snd.sb_flags |= SB_NOINTR;
327 SOCKBUF_UNLOCK(&so->so_snd);
/freebsd-9.3-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-9.3-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.c166 name, sockb.so_rcv.sb_cc, sockb.so_snd.sb_cc);
H A Datalk.c250 sockb.so_snd.sb_cc);
H A Dunix.c289 so->so_snd.sb_cc, (long)unp->unp_vnode, (long)unp->unp_conn,
/freebsd-9.3-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);
/freebsd-9.3-release/sys/netsmb/
H A Dsmb_trantcp.c159 so->so_snd.sb_timeo = (5 * hz);
168 SOCKBUF_LOCK(&so->so_snd);
169 so->so_snd.sb_flags &= ~SB_NOINTR;
170 SOCKBUF_UNLOCK(&so->so_snd);
/freebsd-9.3-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_DONTWAIT);
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_DONTWAIT);
2715 sbdroprecord(&pcb->so->so_snd);
/freebsd-9.3-release/sys/netgraph/
H A Dng_ksocket.c620 SOCKBUF_LOCK(&priv->so->so_snd);
622 SOCKBUF_UNLOCK(&priv->so->so_snd);
954 SOCKBUF_LOCK(&priv->so->so_snd);
956 SOCKBUF_UNLOCK(&priv->so->so_snd);
1272 SOCKBUF_LOCK(&so->so_snd);
1274 SOCKBUF_UNLOCK(&so->so_snd);
/freebsd-9.3-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;
1410 struct sockbuf *sb = &so->so_snd;

Completed in 191 milliseconds

12