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

12

/freebsd-11-stable/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.c461 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 Dsocketvar.h107 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 Dtcp_output.c326 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 Dsctputil.h284 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 Dtcp_usrreq.c954 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 Dtcp_input.c1854 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 Duipc_socket.c396 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 Dsys_socket.c186 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 Dkern_sendfile.c571 (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 Duipc_sockbuf.c219 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 Duipc_usrreq.c401 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 Dicl_soft.c881 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 Dctl_ha.c239 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 Dnetgraph.c124 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc);
H A Dinet.c181 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 Dunix.c321 so->so_snd.sb_cc, (long)unp->unp_vnode,
/freebsd-11-stable/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c261 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 Dfastpath.c266 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 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-11-stable/sys/netgraph/
H A Dng_ksocket.c614 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 Dt4_cpl_io.c329 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 Dclnt_bck.c308 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 Dng_btsocket_sco.c906 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 Dng_btsocket_l2cap.c1205 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);

Completed in 207 milliseconds

12