Home
last modified time | relevance | path

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

12

/xnu-11417.140.69/bsd/netinet/
H A Dtcp_output.c372 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1127 if (off < so->so_snd.sb_cc) { in tcp_output()
1156 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1167 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1339 (so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) { in tcp_output()
1340 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
1341 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1342 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1343 if (sbreserve(&so->so_snd, in tcp_output()
1344 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()
275 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Dmptcp.c471 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
605 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
723 if ((mp_so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) { in mptcp_output()
724 if ((mp_tp->mpt_sndwnd / 4 * 5) >= mp_so->so_snd.sb_hiwat && in mptcp_output()
725 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
726 if (sbreserve(&mp_so->so_snd, in mptcp_output()
727 min(mp_so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in mptcp_output()
729 mp_so->so_snd.sb_idealsize = mp_so->so_snd.sb_hiwat; in mptcp_output()
844 (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()
3001 struct mbuf *so_m = so->so_snd.sb_mb; in mptcp_search_seq_in_sub()
3080 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()
1087 VERIFY(mp_so->so_snd.sb_flags & SB_NOCOMPRESS); in mptcp_usr_send()
1088 sbappendstream(&mp_so->so_snd, m); in mptcp_usr_send()
1100 error = sbwait(&mp_so->so_snd); in mptcp_usr_send()
1292 space = sbspace(&mp_so->so_snd); in mptcp_usr_sosend()
1347 sbunlock(&mp_so->so_snd, FALSE); /* will unlock socket */ in mptcp_usr_sosend()
H A Dflow_divert.c751 sbflush(&fd_cb->so->so_snd); in flow_divert_update_closed_state()
1566 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1744 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1745 buffer = fd_cb->so->so_snd.sb_mb; in flow_divert_send_buffered_data()
1783 sbdrop(&fd_cb->so->so_snd, (int)sent); in flow_divert_send_buffered_data()
1834 (void) sbdroprecord(&(fd_cb->so->so_snd)); in flow_divert_send_buffered_data()
1858 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1909 if (sbspace(&fd_cb->so->so_snd) > 0) { in flow_divert_send_app_data()
1910 if (!sbappendstream(&fd_cb->so->so_snd, pkt_data)) { in flow_divert_send_app_data()
1912 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.c1192 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1193 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1197 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1202 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
1204 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
H A Dtcp_input.c1526 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3299 sbdrop(&so->so_snd, acked); in tcp_input()
3300 tcp_sbsnd_trim(&so->so_snd); in tcp_input()
3358 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
4831 if (so->so_snd.sb_cc) { in tcp_input()
5264 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5511 if (acked > so->so_snd.sb_cc) { in tcp_input()
5512 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
5513 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
5516 sbdrop(&so->so_snd, acked); in tcp_input()
[all …]
H A Dtcp_subr.c1630 dosavessthresh = (i < so->so_snd.sb_hiwat / 2); in tcp_close()
2971 if (so->so_snd.sb_hiwat < mss) { in tcp_mtudisc()
2972 mss = so->so_snd.sb_hiwat; in tcp_mtudisc()
3767 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
5086 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
5096 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
5114 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
5226 if ((so->so_snd.sb_flags & SB_SNDBYTE_CNT) && in inp_get_sndbytes_allunsent()
5227 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
5233 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
H A Din_pcb.c2145 if (so->so_rcv.sb_cc > 0 || so->so_snd.sb_cc > 0) { in in_pcbdispose()
2151 sbrelease(&so->so_snd); in in_pcbdispose()
4221 so->so_snd.sb_flags |= SB_SNDBYTE_CNT; in inp_count_sndbytes()
4227 if (so->so_snd.sb_cc > 0) { in inp_count_sndbytes()
4228 inp_incr_sndbytes_total(so, so->so_snd.sb_cc); in inp_count_sndbytes()
4280 if (so == NULL || !(so->so_snd.sb_flags & SB_SNDBYTE_CNT)) { in inp_decr_sndbytes_unsent()
4301 if (so == NULL || !(so->so_snd.sb_flags & SB_SNDBYTE_CNT)) { in inp_decr_sndbytes_allunsent()
/xnu-11417.140.69/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()
414 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn_internal()
419 so->so_snd.sb_flags |= (head->so_snd.sb_flags & SB_USRSIZE); in sonewconn_internal()
760 if (sbreserve(&so->so_snd, sndcc) == 0) { in soreserve()
763 so->so_snd.sb_idealsize = sndcc; in soreserve()
775 if (so->so_snd.sb_lowat == 0) { in soreserve()
776 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
778 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) { in soreserve()
779 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
783 so->so_snd.sb_flags &= ~SB_SEL; in soreserve()
[all …]
H A Duipc_socket.c753 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1174 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1177 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1212 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1215 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1231 so->so_snd.sb_flags &= ~(SB_UPCALL | SB_SNDBYTE_CNT); in sofreelastref()
1259 so->so_snd.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
2023 if ((so->so_snd.sb_flags & SB_LOCK) != 0 && in sosendcheck()
2034 error = sblock(&so->so_snd, SBLOCKWAIT(flags)); in sosendcheck()
2065 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()
1823 if (uio_resid(auio) > so->so_snd.sb_hiwat) { in sendit_x()
3872 error = sblock(&so->so_snd, SBL_WAIT); in sendfile()
3895 xfsize = sbspace(&so->so_snd); in sendfile()
4043 if (sbspace(&so->so_snd) < (long)so->so_snd.sb_lowat) { in sendfile()
4051 error = sbwait(&so->so_snd); in sendfile()
4094 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
4127 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.c1151 .tv_sec = so->so_snd.sb_timeo.tv_sec, in vsock_connect()
1152 .tv_nsec = so->so_snd.sb_timeo.tv_usec * 1000, in vsock_connect()
1306 error = sbwait(&so->so_snd); in vsock_send()
/xnu-11417.140.69/tools/lldbmacros/
H A Dnet.py617 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
686 snd_cc += int(so.so_snd.sb_cc)
687 total_snd_cc[0] += int(so.so_snd.sb_cc)
1557 …out_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_c…
1605 snd_cc[0] += so.so_snd.sb_cc
1606 mpkt = so.so_snd.sb_mb
1886 snd_cc = so.so_snd.sb_cc
1914 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
/xnu-11417.140.69/bsd/sys/
H A Dsocketvar.h198 } so_rcv, so_snd; member
467 struct xsockbuf so_snd; member
490 struct xsockbuf so_snd; member

12