Home
last modified time | relevance | path

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

12

/xnu-12377.41.6/bsd/netinet/
H A Dtcp_output.c332 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1363 if (off < so->so_snd.sb_cc) { in tcp_output()
1392 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1403 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1575 (so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) { in tcp_output()
1576 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
1577 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1578 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1579 if (sbreserve(&so->so_snd, in tcp_output()
1580 min(so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in tcp_output()
[all …]
H A Dtcp_cc.c84 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_cc_resize_sndbuf()
98 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_bad_rexmt_fix_sndbuf()
251 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Dmptcp.c478 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
612 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
730 if ((mp_so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) { in mptcp_output()
731 if ((mp_tp->mpt_sndwnd / 4 * 5) >= mp_so->so_snd.sb_hiwat && in mptcp_output()
732 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
733 if (sbreserve(&mp_so->so_snd, in mptcp_output()
734 min(mp_so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in mptcp_output()
736 mp_so->so_snd.sb_idealsize = mp_so->so_snd.sb_hiwat; in mptcp_output()
851 (mptetoso(mpte)->so_snd.sb_cc || mpte->mpte_reinjectq); in mptcp_subflow_is_slow()
H A Din_pcblist.c424 &inp->inp_socket->so_snd : NULL, xsbsnd); in get_pcblist_n()
679 (activeonly && so->so_snd.sb_cc == 0)) { in inpcb_get_if_ports_used()
967 so->so_snd.sb_flags &= ~SB_LIMITED; in inp_limit_companion_link()
968 u_int32_t new_size = MAX(MIN(limit, so->so_snd.sb_lowat), so->so_snd.sb_cc); in inp_limit_companion_link()
969 sbreserve(&so->so_snd, new_size); in inp_limit_companion_link()
970 so->so_snd.sb_flags |= SB_LIMITED; in inp_limit_companion_link()
993 !(so->so_snd.sb_flags & SB_LIMITED)) { in inp_recover_companion_link()
997 so->so_snd.sb_flags &= ~SB_LIMITED; in inp_recover_companion_link()
H A Dtcp_ccdbg.c119 dbg_state.ccd_sndcc = inp->inp_socket->so_snd.sb_cc; in tcp_ccdbg_trace()
120 dbg_state.ccd_sndhiwat = inp->inp_socket->so_snd.sb_hiwat; in tcp_ccdbg_trace()
H A Dtcp_usrreq.c174 so->so_snd.sb_flags |= SB_SENDHEAD; in tcp_usr_attach()
175 so->so_snd.sb_sendhead = NULL; in tcp_usr_attach()
176 so->so_snd.sb_sendoff = 0; in tcp_usr_attach()
1024 cfil_sock_data_pending(&so->so_snd)) { in tcp_usr_shutdown()
1200 mpkl_seq = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1238 (so->so_snd.sb_flags & SB_NOCOMPRESS)); in tcp_usr_send()
1241 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1275 if (sbspace(&so->so_snd) == 0) { in tcp_usr_send()
1290 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1303 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
[all …]
H A Dmptcp_subr.c660 if (mptetoso(mpte)->so_snd.sb_cc != 0 && tp->t_rxtshift >= mptcp_fail_thresh * 2) { in mptcp_handover_use_cellular()
673 if (mptetoso(mpte)->so_snd.sb_cc != 0) { in mptcp_handover_use_cellular()
779 mptetoso(mpte)->so_snd.sb_cc, in mptcp_check_subflows_and_add()
982 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_pure_handover_subflows_remove()
1035 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_handover_subflows_remove()
1530 (*so)->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1764 struct sockbuf *, &so->so_snd, in mptcp_subflow_soclose()
2358 struct sockbuf *, &so->so_rcv, struct sockbuf *, &so->so_snd); in mptcp_subflow_soreceive()
3006 struct mbuf *so_m = so->so_snd.sb_mb; in mptcp_search_seq_in_sub()
3085 sb_mb = mp_so->so_snd.sb_mb; in mptcp_subflow_output()
[all …]
H A Dmptcp_usrreq.c183 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
190 if (mp_so->so_snd.sb_preconn_hiwat == 0) { in mptcp_attach()
197 if ((mp_so->so_snd.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
198 mp_so->so_snd.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
206 mp_so->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_attach()
1089 VERIFY(mp_so->so_snd.sb_flags & SB_NOCOMPRESS); in mptcp_usr_send()
1090 sbappendstream(&mp_so->so_snd, m); in mptcp_usr_send()
1102 error = sbwait(&mp_so->so_snd); in mptcp_usr_send()
1294 space = sbspace(&mp_so->so_snd); in mptcp_usr_sosend()
1352 sbunlock(&mp_so->so_snd, FALSE); /* will unlock socket */ in mptcp_usr_sosend()
H A Dflow_divert.c748 sbflush(&fd_cb->so->so_snd); in flow_divert_update_closed_state()
1563 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1741 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1742 buffer = fd_cb->so->so_snd.sb_mb; in flow_divert_send_buffered_data()
1780 sbdrop(&fd_cb->so->so_snd, (int)sent); in flow_divert_send_buffered_data()
1831 (void) sbdroprecord(&(fd_cb->so->so_snd)); in flow_divert_send_buffered_data()
1855 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1906 if (sbspace(&fd_cb->so->so_snd) > 0) { in flow_divert_send_app_data()
1907 if (!sbappendstream(&fd_cb->so->so_snd, pkt_data)) { in flow_divert_send_app_data()
1909 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
[all …]
H A Dmp_pcb.c276 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
282 sbrelease(&mp_so->so_snd); in mptcp_pcbdispose()
H A Dmptcp_var.h214 int cwnd = (int)(MIN(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc)); in mptcp_subflow_cwnd_space()
216 return MIN(cwnd, sbspace(&so->so_snd)); in mptcp_subflow_cwnd_space()
H A Dmptcp_opt.c1098 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1099 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1103 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1108 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
1110 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
H A Dtcp_input.c1439 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3826 sbdrop(&so->so_snd, acked); in tcp_input()
3827 tcp_sbsnd_trim(&so->so_snd); in tcp_input()
3884 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
5000 if (so->so_snd.sb_cc) { in tcp_input()
5446 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5695 if (acked > so->so_snd.sb_cc) { in tcp_input()
5696 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
5697 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
5700 sbdrop(&so->so_snd, acked); in tcp_input()
[all …]
H A Dtcp_subr.c1892 dosavessthresh = (i < so->so_snd.sb_hiwat / 2); in tcp_close()
3206 if (so->so_snd.sb_hiwat < mss) { in tcp_mtudisc()
3207 mss = so->so_snd.sb_hiwat; in tcp_mtudisc()
3905 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
5274 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
5284 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
5302 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
5414 if ((so->so_snd.sb_flags & SB_SNDBYTE_CNT) && in inp_get_sndbytes_allunsent()
5415 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
5421 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
/xnu-12377.41.6/bsd/kern/
H A Dsys_socket.c218 so->so_snd.sb_flags |= SB_ASYNC; in soioctl()
222 so->so_snd.sb_flags &= ~SB_ASYNC; in soioctl()
322 so->so_snd.sb_flags |= SB_SEL; in soo_select()
325 so->so_snd.sb_flags &= ~SB_SEL; in soo_select()
328 selrecord(procp, &so->so_snd.sb_sel, wql); in soo_select()
H A Duipc_socket2.c404 so->so_rcv.sb_so = so->so_snd.sb_so = so; in sonewconn_internal()
416 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn_internal()
421 so->so_snd.sb_flags |= (head->so_snd.sb_flags & SB_USRSIZE); in sonewconn_internal()
762 if (sbreserve(&so->so_snd, sndcc) == 0) { in soreserve()
765 so->so_snd.sb_idealsize = sndcc; in soreserve()
777 if (so->so_snd.sb_lowat == 0) { in soreserve()
778 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
780 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) { in soreserve()
781 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
785 so->so_snd.sb_flags &= ~SB_SEL; in soreserve()
[all …]
H A Duipc_socket.c593 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1014 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1017 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1052 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1055 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1071 so->so_snd.sb_flags &= ~(SB_UPCALL | SB_SNDBYTE_CNT); in sofreelastref()
1099 so->so_snd.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
1864 if ((so->so_snd.sb_flags & SB_LOCK) != 0 && in sosendcheck()
1875 error = sblock(&so->so_snd, SBLOCKWAIT(flags)); in sosendcheck()
1906 so->so_snd.sb_cfil_thread == current_thread() && in sosendcheck()
[all …]
H A Dkpi_socket.c407 sock->so_snd.sb_flags |= SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
410 sock->so_snd.sb_flags &= ~SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
1344 (so->so_rcv.sb_flags & so->so_snd.sb_flags & SB_UNIX) != SB_UNIX) { in socket_defunct()
1374 sock->so_snd.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1376 sock->so_snd.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1378 sock->so_snd.sb_upcall = wcallback; in sock_setupcalls_locked()
1379 sock->so_snd.sb_upcallarg = wcontext; in sock_setupcalls_locked()
1381 sock->so_snd.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1382 sock->so_snd.sb_upcall = NULL; in sock_setupcalls_locked()
1383 sock->so_snd.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c434 #define snd (&so2->so_snd) in uipc_rcvd()
445 if (sb_notify(&so2->so_snd)) { in uipc_rcvd()
446 sowakeup(so2, &so2->so_snd, so); in uipc_rcvd()
469 if (sb_notify(&so2->so_snd)) { in uipc_rcvd()
470 sowakeup(so2, &so2->so_snd, so); in uipc_rcvd()
597 #define snd (&so->so_snd) in uipc_send()
736 blksize = so->so_snd.sb_hiwat; in uipc_sense()
989 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
1002 so->so_snd.sb_lowat = 1; in unp_attach()
1045 so->so_snd.sb_flags |= SB_UNIX; in unp_attach()
[all …]
H A Duipc_syscalls.c656 so->so_snd.sb_flags |= SB_ASYNC; in accept_nocancel()
660 so->so_snd.sb_flags &= ~SB_ASYNC; in accept_nocancel()
1819 if (uio_resid(auio) > so->so_snd.sb_hiwat) { in sendit_x()
3868 error = sblock(&so->so_snd, SBL_WAIT); in sendfile()
3891 xfsize = sbspace(&so->so_snd); in sendfile()
4038 if (sbspace(&so->so_snd) < (long)so->so_snd.sb_lowat) { in sendfile()
4046 error = sbwait(&so->so_snd); in sendfile()
4092 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
4125 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
H A Dsocket_info.c98 fill_sockbuf_info(&so->so_snd, &si->soi_snd); in fill_common_sockinfo()
H A Dvsock_domain.c1246 .tv_sec = so->so_snd.sb_timeo.tv_sec, in vsock_connect()
1247 .tv_nsec = so->so_snd.sb_timeo.tv_usec * 1000, in vsock_connect()
1401 error = sbwait(&so->so_snd); in vsock_send()
/xnu-12377.41.6/tools/lldbmacros/
H A Dnet.py570 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
639 snd_cc += int(so.so_snd.sb_cc)
640 total_snd_cc[0] += int(so.so_snd.sb_cc)
1510 …out_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_c…
1569 snd_cc[0] += so.so_snd.sb_cc
1570 mpkt = so.so_snd.sb_mb
1850 snd_cc = so.so_snd.sb_cc
1878 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
/xnu-12377.41.6/bsd/sys/
H A Dsocketvar.h192 } so_rcv, so_snd; member
458 struct xsockbuf so_snd; member
481 struct xsockbuf so_snd; member
/xnu-12377.41.6/bsd/net/
H A Dcontent_filter.c1546 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_acquire_sockbuf()
1602 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_release_sockbuf()
2909 int32_t pending_snd = cfil_sock_data_pending(&so->so_snd); in cfil_sock_is_dead()
2951 int32_t pending_snd = cfil_sock_data_pending(&so->so_snd); in cfil_sock_tcp_add_time_wait()
4545 if (cfil_sock_data_pending(&so->so_snd) == 0) { in cfil_service_inject_queue()
5319 if ((so->so_snd.sb_flags & SB_LOCK) == 0) { in cfil_sock_data_out()
5323 if (so->so_snd.sb_cfil_thread != NULL) { in cfil_sock_data_out()
5325 so->so_snd.sb_cfil_thread); in cfil_sock_data_out()
5473 if (cfil_sock_data_pending(&so->so_snd) != 0) { in cfil_sock_shutdown()
5750 so->so_snd.sb_cfil_thread != current_thread()) { in cfil_sock_data_space()
[all …]

12