Home
last modified time | relevance | path

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

12

/xnu-8020.140.41/bsd/netinet/
H A Dtcp_output.c351 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
932 if (off < so->so_snd.sb_cc) { in tcp_output()
960 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
979 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1139 (so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE && in tcp_output()
1140 tcp_cansbgrow(&so->so_snd)) { in tcp_output()
1141 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
1142 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1143 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1144 if (sbreserve(&so->so_snd, in tcp_output()
[all …]
H A Dtcp_cc.c224 dbg_state.ccd_sndcc = inp->inp_socket->so_snd.sb_cc; in tcp_ccdbg_trace()
225 dbg_state.ccd_sndhiwat = inp->inp_socket->so_snd.sb_hiwat; in tcp_ccdbg_trace()
263 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_cc_resize_sndbuf()
277 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_bad_rexmt_fix_sndbuf()
461 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Din_pcblist.c402 &inp->inp_socket->so_snd : NULL, xsbsnd); in get_pcblist_n()
630 (activeonly && so->so_snd.sb_cc == 0)) { in inpcb_get_if_ports_used()
881 so->so_snd.sb_flags &= ~SB_LIMITED; in inp_limit_companion_link()
882 u_int32_t new_size = MAX(MIN(limit, so->so_snd.sb_lowat), so->so_snd.sb_cc); in inp_limit_companion_link()
883 sbreserve(&so->so_snd, new_size); in inp_limit_companion_link()
884 so->so_snd.sb_flags |= SB_LIMITED; in inp_limit_companion_link()
907 !(so->so_snd.sb_flags & SB_LIMITED)) { in inp_recover_companion_link()
911 so->so_snd.sb_flags &= ~SB_LIMITED; in inp_recover_companion_link()
H A Dmptcp.c466 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
600 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
720 if ((mp_so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE && in mptcp_output()
721 tcp_cansbgrow(&mp_so->so_snd)) { in mptcp_output()
722 if ((mp_tp->mpt_sndwnd / 4 * 5) >= mp_so->so_snd.sb_hiwat && in mptcp_output()
723 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
724 if (sbreserve(&mp_so->so_snd, in mptcp_output()
725 min(mp_so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in mptcp_output()
727 mp_so->so_snd.sb_idealsize = mp_so->so_snd.sb_hiwat; in mptcp_output()
842 (mptetoso(mpte)->so_snd.sb_cc || mpte->mpte_reinjectq); in mptcp_subflow_is_slow()
H A Dmptcp_subr.c843 if (mptetoso(mpte)->so_snd.sb_cc != 0 && tp->t_rxtshift >= mptcp_fail_thresh * 2) { in mptcp_handover_use_cellular()
856 if (mptetoso(mpte)->so_snd.sb_cc != 0) { in mptcp_handover_use_cellular()
962 mptetoso(mpte)->so_snd.sb_cc, in mptcp_check_subflows_and_add()
1165 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_pure_handover_subflows_remove()
1218 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_handover_subflows_remove()
1713 (*so)->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1939 struct sockbuf *, &so->so_snd, in mptcp_subflow_soclose()
2441 struct sockbuf *, &so->so_rcv, struct sockbuf *, &so->so_snd); in mptcp_subflow_soreceive()
3077 struct mbuf *so_m = so->so_snd.sb_mb; in mptcp_search_seq_in_sub()
3160 sb_mb = mp_so->so_snd.sb_mb; in mptcp_subflow_output()
[all …]
H A Dmptcp_usrreq.c186 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
193 if (mp_so->so_snd.sb_preconn_hiwat == 0) { in mptcp_attach()
200 if ((mp_so->so_snd.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
201 mp_so->so_snd.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
209 mp_so->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_attach()
1082 VERIFY(mp_so->so_snd.sb_flags & SB_NOCOMPRESS); in mptcp_usr_send()
1083 sbappendstream(&mp_so->so_snd, m); in mptcp_usr_send()
1095 error = sbwait(&mp_so->so_snd); in mptcp_usr_send()
1287 space = sbspace(&mp_so->so_snd); in mptcp_usr_sosend()
1342 sbunlock(&mp_so->so_snd, FALSE); /* will unlock socket */ in mptcp_usr_sosend()
H A Dtcp_usrreq.c945 cfil_sock_data_pending(&so->so_snd)) { in tcp_usr_shutdown()
1126 mpkl_seq = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1164 (so->so_snd.sb_flags & SB_NOCOMPRESS)); in tcp_usr_send()
1167 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1199 if (sbspace(&so->so_snd) == 0) { in tcp_usr_send()
1214 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1227 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1245 error = sbwait(&so->so_snd); in tcp_usr_send()
1718 ti->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_fill_info()
1968 tci->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_connection_fill_info()
[all …]
H A Dflow_divert.c688 sbflush(&fd_cb->so->so_snd); in flow_divert_update_closed_state()
1481 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1569 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1570 buffer = fd_cb->so->so_snd.sb_mb; in flow_divert_send_buffered_data()
1608 sbdrop(&fd_cb->so->so_snd, (int)sent); in flow_divert_send_buffered_data()
1654 (void) sbdroprecord(&(fd_cb->so->so_snd)); in flow_divert_send_buffered_data()
1678 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1723 if (sbspace(&fd_cb->so->so_snd) > 0) { in flow_divert_send_app_data()
1724 if (!sbappendstream(&fd_cb->so->so_snd, pkt_data)) { in flow_divert_send_app_data()
1726 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
[all …]
H A Dmp_pcb.c277 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
283 sbrelease(&mp_so->so_snd); in mptcp_pcbdispose()
H A Dmptcp_opt.c1136 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1137 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1141 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1146 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
1148 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
H A Dmptcp_var.h211 int cwnd = (int)(MIN(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc)); in mptcp_subflow_cwnd_space()
213 return MIN(cwnd, sbspace(&so->so_snd)); in mptcp_subflow_cwnd_space()
H A Dtcp_input.c1589 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3008 sbdrop(&so->so_snd, acked); in tcp_input()
3009 tcp_sbsnd_trim(&so->so_snd); in tcp_input()
3065 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
4276 if (so->so_snd.sb_cc) { in tcp_input()
4696 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
4877 if (acked > so->so_snd.sb_cc) { in tcp_input()
4878 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
4879 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
4882 sbdrop(&so->so_snd, acked); in tcp_input()
[all …]
H A Dtcp_subr.c1582 dosavessthresh = (i < so->so_snd.sb_hiwat / 2); in tcp_close()
2911 if (so->so_snd.sb_hiwat < mss) { in tcp_mtudisc()
2912 mss = so->so_snd.sb_hiwat; in tcp_mtudisc()
3635 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
4308 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
4318 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
4336 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
4448 if ((so->so_snd.sb_flags & SB_SNDBYTE_CNT) && in inp_get_sndbytes_allunsent()
4449 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
4455 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
H A Din_pcb.c1985 if (so->so_rcv.sb_cc > 0 || so->so_snd.sb_cc > 0) { in in_pcbdispose()
1991 sbrelease(&so->so_snd); in in_pcbdispose()
3854 so->so_snd.sb_flags |= SB_SNDBYTE_CNT; in inp_count_sndbytes()
3860 if (so->so_snd.sb_cc > 0) { in inp_count_sndbytes()
3861 inp_incr_sndbytes_total(so, so->so_snd.sb_cc); in inp_count_sndbytes()
3913 if (so == NULL || !(so->so_snd.sb_flags & SB_SNDBYTE_CNT)) { in inp_decr_sndbytes_unsent()
3934 if (so == NULL || !(so->so_snd.sb_flags & SB_SNDBYTE_CNT)) { in inp_decr_sndbytes_allunsent()
/xnu-8020.140.41/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()
326 so->so_snd.sb_flags |= SB_SEL; in soo_select()
329 so->so_snd.sb_flags &= ~SB_SEL; in soo_select()
332 selrecord(procp, &so->so_snd.sb_sel, wql); in soo_select()
H A Duipc_socket2.c401 so->so_rcv.sb_so = so->so_snd.sb_so = so; in sonewconn_internal()
411 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn_internal()
416 so->so_snd.sb_flags |= (head->so_snd.sb_flags & SB_USRSIZE); in sonewconn_internal()
771 if (sbreserve(&so->so_snd, sndcc) == 0) { in soreserve()
774 so->so_snd.sb_idealsize = sndcc; in soreserve()
786 if (so->so_snd.sb_lowat == 0) { in soreserve()
787 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
789 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) { in soreserve()
790 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
794 so->so_snd.sb_flags &= ~SB_SEL; in soreserve()
[all …]
H A Duipc_socket.c746 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1166 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1169 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1204 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1207 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1223 so->so_snd.sb_flags &= ~(SB_UPCALL | SB_SNDBYTE_CNT); in sofreelastref()
1251 so->so_snd.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
1987 if ((so->so_snd.sb_flags & SB_LOCK) != 0 && in sosendcheck()
1998 error = sblock(&so->so_snd, SBLOCKWAIT(flags)); in sosendcheck()
2029 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()
1285 (so->so_rcv.sb_flags & so->so_snd.sb_flags & SB_UNIX) != SB_UNIX) { in socket_defunct()
1315 sock->so_snd.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1317 sock->so_snd.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1319 sock->so_snd.sb_upcall = wcallback; in sock_setupcalls_locked()
1320 sock->so_snd.sb_upcallarg = wcontext; in sock_setupcalls_locked()
1322 sock->so_snd.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1323 sock->so_snd.sb_upcall = NULL; in sock_setupcalls_locked()
1324 sock->so_snd.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c401 #define snd (&so2->so_snd) in uipc_rcvd()
416 if (sb_notify(&so2->so_snd)) { in uipc_rcvd()
417 sowakeup(so2, &so2->so_snd, so); in uipc_rcvd()
544 #define snd (&so->so_snd) in uipc_send()
675 blksize = so->so_snd.sb_hiwat; in uipc_sense()
921 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
970 so->so_snd.sb_flags |= SB_UNIX; in unp_attach()
H A Duipc_syscalls.c595 so->so_snd.sb_flags |= SB_ASYNC; in accept_nocancel()
599 so->so_snd.sb_flags &= ~SB_ASYNC; in accept_nocancel()
3522 error = sblock(&so->so_snd, SBL_WAIT); in sendfile()
3544 xfsize = sbspace(&so->so_snd); in sendfile()
3693 if (sbspace(&so->so_snd) < (long)so->so_snd.sb_lowat) { in sendfile()
3701 error = sbwait(&so->so_snd); in sendfile()
3744 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
3774 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
H A Dsocket_info.c96 fill_sockbuf_info(&so->so_snd, &si->soi_snd); in fill_common_sockinfo()
H A Dvsock_domain.c1126 .tv_sec = so->so_snd.sb_timeo.tv_sec, in vsock_connect()
1127 .tv_nsec = so->so_snd.sb_timeo.tv_usec * 1000, in vsock_connect()
1290 error = sbwait(&so->so_snd); in vsock_send()
/xnu-8020.140.41/tools/lldbmacros/
H A Dnet.py582 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
651 snd_cc += int(so.so_snd.sb_cc)
652 total_snd_cc[0] += int(so.so_snd.sb_cc)
1701 …out_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_c…
1734 snd_cc[0] += so.so_snd.sb_cc
1735 mpkt = so.so_snd.sb_mb
1977 snd_cc = so.so_snd.sb_cc
2005 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
/xnu-8020.140.41/bsd/sys/
H A Dsocketvar.h187 } so_rcv, so_snd; member
446 struct xsockbuf so_snd; member
469 struct xsockbuf so_snd; member
/xnu-8020.140.41/bsd/net/
H A Dcontent_filter.c1510 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_acquire_sockbuf()
1566 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_release_sockbuf()
4201 if (cfil_sock_data_pending(&so->so_snd) == 0) { in cfil_service_inject_queue()
4953 if ((so->so_snd.sb_flags & SB_LOCK) == 0) { in cfil_sock_data_out()
4957 if (so->so_snd.sb_cfil_thread != NULL) { in cfil_sock_data_out()
4959 so->so_snd.sb_cfil_thread); in cfil_sock_data_out()
5107 if (cfil_sock_data_pending(&so->so_snd) != 0) { in cfil_sock_shutdown()
5384 so->so_snd.sb_cfil_thread != current_thread()) { in cfil_sock_data_space()
6172 (check_thread == FALSE || so->so_snd.sb_cfil_thread != current_thread())) { in cfil_sock_udp_data_pending()
6311 if (cfil_sock_data_pending(&so->so_snd) != 0) { in cfil_sock_udp_shutdown()

12