Home
last modified time | relevance | path

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

12

/NextBSD/sys/kern/
HDsys_socket.c160 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
161 so->so_snd.sb_flags |= SB_ASYNC; in soo_ioctl()
162 SOCKBUF_UNLOCK(&so->so_snd); in soo_ioctl()
170 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
171 so->so_snd.sb_flags &= ~SB_ASYNC; in soo_ioctl()
172 SOCKBUF_UNLOCK(&so->so_snd); in soo_ioctl()
183 *(int *)data = sbavail(&so->so_snd); in soo_ioctl()
188 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl()
189 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) in soo_ioctl()
192 *(int *)data = sbspace(&so->so_snd); in soo_ioctl()
[all …]
HDuipc_socket.c389 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd"); in soalloc()
391 sx_init(&so->so_snd.sb_sx, "so_snd_sx"); in soalloc()
440 if (so->so_snd.sb_hiwat) in sodealloc()
442 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
453 sx_destroy(&so->so_snd.sb_sx); in sodealloc()
455 SOCKBUF_LOCK_DESTROY(&so->so_snd); in sodealloc()
514 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd)); in socreate()
603 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd));
605 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
618 so->so_snd.sb_lowat = head->so_snd.sb_lowat;
[all …]
HDuipc_sockbuf.c218 SOCKBUF_LOCK_ASSERT(&so->so_snd); in socantsendmore_locked()
220 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
222 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); in socantsendmore_locked()
229 SOCKBUF_LOCK(&so->so_snd); in socantsendmore()
231 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); in socantsendmore()
379 SOCKBUF_LOCK(&so->so_snd); in soreserve()
381 if (sbreserve_locked(&so->so_snd, sndcc, so, td) == 0) in soreserve()
387 if (so->so_snd.sb_lowat == 0) in soreserve()
388 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
389 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
[all …]
HDuipc_syscalls.c2423 (void)sblock(&so->so_snd, SBL_WAIT | SBL_NOINTR); in vn_sendfile()
2459 SOCKBUF_LOCK(&so->so_snd); in vn_sendfile()
2460 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in vn_sendfile()
2461 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in vn_sendfile()
2463 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in vn_sendfile()
2465 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
2470 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
2473 space = sbspace(&so->so_snd); in vn_sendfile()
2476 space < so->so_snd.sb_lowat)) { in vn_sendfile()
2478 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
[all …]
HDuipc_usrreq.c401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
833 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
834 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
835 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
939 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1018 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1019 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1020 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
1021 SOCKBUF_UNLOCK(&so->so_snd); in uipc_send()
1087 sb->st_blksize = so->so_snd.sb_hiwat; in uipc_sense()
/NextBSD/sys/ofed/drivers/infiniband/ulp/sdp/
HDsdp_bcopy.c158 if (sk->so_snd.sb_sndptr) in sdp_nagle_timeout()
173 if (sk->so_snd.sb_sndptr) { in sdp_post_sends()
198 sdp_tx_ring_slots_left(ssk) && sk->so_snd.sb_sndptr && in sdp_post_sends()
199 sdp_nagle_off(ssk, sk->so_snd.sb_sndptr)) { in sdp_post_sends()
204 sdp_tx_ring_slots_left(ssk) && (mb = sk->so_snd.sb_sndptr) && in sdp_post_sends()
208 SOCKBUF_LOCK(&sk->so_snd); in sdp_post_sends()
209 sk->so_snd.sb_sndptr = mb->m_nextpkt; in sdp_post_sends()
210 sk->so_snd.sb_mb = mb->m_nextpkt; in sdp_post_sends()
212 SB_EMPTY_FIXUP(&sk->so_snd); in sdp_post_sends()
214 sbfree(&sk->so_snd, n); in sdp_post_sends()
[all …]
HDsdp_main.c454 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in sdp_attach()
460 so->so_snd.sb_flags |= SB_AUTOSIZE; in sdp_attach()
967 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
968 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
969 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
993 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
994 if (sbspace(&so->so_snd) < -512) { in sdp_send()
995 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
1009 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
1010 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
[all …]
/NextBSD/sys/netinet/
HDtcp_output.c327 SOCKBUF_LOCK(&so->so_snd); in tcp_output()
352 if (off < sbused(&so->so_snd)) in tcp_output()
378 len = ((long)ulmin(sbavail(&so->so_snd), sendwin) - in tcp_output()
388 len = ((long)ulmin(sbavail(&so->so_snd), tp->snd_wnd) - in tcp_output()
469 (off < (int) sbavail(&so->so_snd))) { in tcp_output()
518 if (V_tcp_do_autosndbuf && so->so_snd.sb_flags & SB_AUTOSIZE) { in tcp_output()
519 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
520 sbused(&so->so_snd) >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
521 sbused(&so->so_snd) < V_tcp_autosndbuf_max && in tcp_output()
522 sendwin >= (sbused(&so->so_snd) - in tcp_output()
[all …]
HDsctputil.h292 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \
293 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \
295 stcb->sctp_socket->so_snd.sb_cc = 0; \
313 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \
314 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \
316 stcb->sctp_socket->so_snd.sb_cc = 0; \
328 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
HDtcp_usrreq.c902 sbappendstream(&so->so_snd, m, flags); in tcp_usr_send()
945 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_send()
946 if (sbspace(&so->so_snd) < -512) { in tcp_usr_send()
947 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
960 sbappendstream_locked(&so->so_snd, m, flags); in tcp_usr_send()
961 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
983 tp->snd_up = tp->snd_una + sbavail(&so->so_snd); in tcp_usr_send()
1018 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_ready()
1019 error = sbready(&so->so_snd, m, count); in tcp_usr_ready()
1020 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_ready()
[all …]
HDtcp_input.c1741 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1786 if (sbavail(&so->so_snd)) in tcp_do_segment()
2655 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2656 avail = sbavail(&so->so_snd) - in tcp_do_segment()
2658 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_segment()
2800 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2801 if (acked > sbavail(&so->so_snd)) { in tcp_do_segment()
2802 tp->snd_wnd -= sbavail(&so->so_snd); in tcp_do_segment()
2803 mfree = sbcut_locked(&so->so_snd, in tcp_do_segment()
2804 (int)sbavail(&so->so_snd)); in tcp_do_segment()
[all …]
/NextBSD/sys/sys/
HDsocketvar.h109 struct sockbuf so_rcv, so_snd; member
182 struct xsockbuf so_rcv, so_snd; member
218 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
221 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
269 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \
270 if (sb_notify(&(so)->so_snd)) \
271 sowakeup((so), &(so)->so_snd); \
273 SOCKBUF_UNLOCK(&(so)->so_snd); \
277 SOCKBUF_LOCK(&(so)->so_snd); \
/NextBSD/sys/dev/iscsi/
HDicl_soft.c887 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
894 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
900 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in icl_conn_send_pdus()
901 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
914 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
915 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
922 so->so_snd.sb_lowat = size; in icl_conn_send_pdus()
923 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
926 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
1252 ic->ic_socket->so_snd.sb_flags |= SB_AUTOSIZE; in icl_conn_start()
[all …]
/NextBSD/sys/cam/ctl/
HDctl_ha.c239 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_close()
241 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_close()
341 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in ctl_ha_send()
345 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_send()
346 if (sbspace(&so->so_snd) < softc->ha_sending->m_pkthdr.len) { in ctl_ha_send()
347 so->so_snd.sb_lowat = softc->ha_sending->m_pkthdr.len; in ctl_ha_send()
348 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
351 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
378 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_sock_setup()
379 so->so_snd.sb_lowat = sizeof(struct ha_msg_wire); in ctl_ha_sock_setup()
[all …]
/NextBSD/usr.bin/bluetooth/btsockstat/
HDbtsockstat.c259 so.so_snd.sb_ccc, in hcirawpr()
307 so.so_snd.sb_ccc, in l2caprawpr()
365 so.so_snd.sb_ccc, in l2cappr()
471 so.so_snd.sb_ccc, in rfcommpr()
/NextBSD/usr.bin/netstat/
HDinet.c179 sbtoxsockbuf(&so->so_snd, &xso->so_snd); in sotoxsocket()
511 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
576 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, in protopr()
577 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, in protopr()
578 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
579 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
580 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
581 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
HDnetgraph.c124 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc); in netgraphprotopr()
/NextBSD/sys/netinet/tcp_stacks/
HDfastpath.c277 sbdrop(&so->so_snd, acked); in tcp_do_fastack()
327 if (sbavail(&so->so_snd)) in tcp_do_fastack()
1198 SOCKBUF_LOCK(&so->so_snd); in tcp_do_slowpath()
1199 avail = sbavail(&so->so_snd) - in tcp_do_slowpath()
1201 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_slowpath()
1333 SOCKBUF_LOCK(&so->so_snd); in tcp_do_slowpath()
1334 if (acked > sbavail(&so->so_snd)) { in tcp_do_slowpath()
1335 tp->snd_wnd -= sbavail(&so->so_snd); in tcp_do_slowpath()
1336 mfree = sbcut_locked(&so->so_snd, in tcp_do_slowpath()
1337 (int)sbavail(&so->so_snd)); in tcp_do_slowpath()
[all …]
/NextBSD/sys/netgraph/
HDng_ksocket.c614 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_connect()
616 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_connect()
948 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
950 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
1277 SOCKBUF_LOCK(&so->so_snd); in ng_ksocket_finish_accept()
1279 SOCKBUF_UNLOCK(&so->so_snd); in ng_ksocket_finish_accept()
/NextBSD/sys/netsmb/
HDsmb_trantcp.c159 so->so_snd.sb_timeo = (5 * SBT_1S); in nb_connect_in()
168 SOCKBUF_LOCK(&so->so_snd); in nb_connect_in()
169 so->so_snd.sb_flags &= ~SB_NOINTR; in nb_connect_in()
170 SOCKBUF_UNLOCK(&so->so_snd); in nb_connect_in()
/NextBSD/sys/netgraph/bluetooth/socket/
HDng_btsocket_sco.c906 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_default_msg_input()
909 if (sbavail(&pcb->so->so_snd) > 0) in ng_btsocket_sco_default_msg_input()
1226 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach()
1718 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_sco_send()
1726 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_sco_send()
1751 sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_sco_send2()
1753 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_sco_send2()
1968 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_process_timeout()
HDng_btsocket_rfcomm.c408 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
975 sbappend(&pcb->so->so_snd, m, flags); in ng_btsocket_rfcomm_send()
1062 SOCKBUF_LOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1064 SOCKBUF_UNLOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1302 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1304 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1388 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1390 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
3286 length = min(pcb->mtu, sbavail(&pcb->so->so_snd)); in ng_btsocket_rfcomm_pcb_send()
3291 m = ng_btsocket_rfcomm_prepare_packet(&pcb->so->so_snd, length); in ng_btsocket_rfcomm_pcb_send()
[all …]
HDng_btsocket_l2cap.c1205 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_l2ca_write_rsp()
1206 if (sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
1210 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_process_l2ca_write_rsp()
2025 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_l2cap_attach()
2630 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_l2cap_send()
2638 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_send()
2662 if (sbavail(&pcb->so->so_snd) == 0) in ng_btsocket_l2cap_send2()
2665 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_l2cap_send2()
2870 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_timeout()
/NextBSD/sys/rpc/
HDclnt_bck.c313 SOCKBUF_LOCK(&xprt->xp_socket->so_snd); in clnt_bck_call()
314 sbwait(&xprt->xp_socket->so_snd); in clnt_bck_call()
315 SOCKBUF_UNLOCK(&xprt->xp_socket->so_snd); in clnt_bck_call()
/NextBSD/sys/dev/cxgbe/tom/
HDt4_cpl_io.c200 sbflush(&so->so_snd); in send_reset()
306 SOCKBUF_LOCK(&so->so_snd); in make_established()
307 if (so->so_snd.sb_flags & SB_AUTOSIZE && V_tcp_do_autosndbuf) in make_established()
310 bufsize = sbspace(&so->so_snd); in make_established()
311 SOCKBUF_UNLOCK(&so->so_snd); in make_established()
566 struct sockbuf *sb = &so->so_snd; in t4_push_frames()
1642 struct sockbuf *sb = &so->so_snd; in do_fw4_ack()

12