Home
last modified time | relevance | path

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

12

/xnu-10063.141.1/bsd/netinet/
H A Dtcp_output.c355 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1055 if (off < so->so_snd.sb_cc) { in tcp_output()
1083 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1102 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1266 (so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) { in tcp_output()
1267 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
1268 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1269 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1270 if (sbreserve(&so->so_snd, in tcp_output()
1271 min(so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in tcp_output()
[all …]
H A Dtcp_cc.c82 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_cc_resize_sndbuf()
96 sb = &tp->t_inpcb->inp_socket->so_snd; in tcp_bad_rexmt_fix_sndbuf()
276 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Dmptcp.c468 struct sockbuf *, &mp_so->so_snd, in mptcp_input()
602 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 if ((mp_tp->mpt_sndwnd / 4 * 5) >= mp_so->so_snd.sb_hiwat && in mptcp_output()
722 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
723 if (sbreserve(&mp_so->so_snd, in mptcp_output()
724 min(mp_so->so_snd.sb_hiwat + tcp_autosndbuf_inc, in mptcp_output()
726 mp_so->so_snd.sb_idealsize = mp_so->so_snd.sb_hiwat; in mptcp_output()
841 (mptetoso(mpte)->so_snd.sb_cc || mpte->mpte_reinjectq); in mptcp_subflow_is_slow()
H A Din_pcblist.c421 &inp->inp_socket->so_snd : NULL, xsbsnd); in get_pcblist_n()
676 (activeonly && so->so_snd.sb_cc == 0)) { in inpcb_get_if_ports_used()
963 so->so_snd.sb_flags &= ~SB_LIMITED; in inp_limit_companion_link()
964 u_int32_t new_size = MAX(MIN(limit, so->so_snd.sb_lowat), so->so_snd.sb_cc); in inp_limit_companion_link()
965 sbreserve(&so->so_snd, new_size); in inp_limit_companion_link()
966 so->so_snd.sb_flags |= SB_LIMITED; in inp_limit_companion_link()
989 !(so->so_snd.sb_flags & SB_LIMITED)) { in inp_recover_companion_link()
993 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.c196 so->so_snd.sb_flags |= SB_SENDHEAD; in tcp_usr_attach()
197 so->so_snd.sb_sendhead = NULL; in tcp_usr_attach()
198 so->so_snd.sb_sendoff = 0; in tcp_usr_attach()
1021 cfil_sock_data_pending(&so->so_snd)) { in tcp_usr_shutdown()
1201 mpkl_seq = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1239 (so->so_snd.sb_flags & SB_NOCOMPRESS)); in tcp_usr_send()
1242 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1276 if (sbspace(&so->so_snd) == 0) { in tcp_usr_send()
1291 sbappendstream(&so->so_snd, m); in tcp_usr_send()
1304 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
[all …]
H A Dmptcp_subr.c654 if (mptetoso(mpte)->so_snd.sb_cc != 0 && tp->t_rxtshift >= mptcp_fail_thresh * 2) { in mptcp_handover_use_cellular()
667 if (mptetoso(mpte)->so_snd.sb_cc != 0) { in mptcp_handover_use_cellular()
773 mptetoso(mpte)->so_snd.sb_cc, in mptcp_check_subflows_and_add()
976 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_pure_handover_subflows_remove()
1029 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, w… in mptcp_handover_subflows_remove()
1524 (*so)->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1750 struct sockbuf *, &so->so_snd, in mptcp_subflow_soclose()
2333 struct sockbuf *, &so->so_rcv, struct sockbuf *, &so->so_snd); in mptcp_subflow_soreceive()
2976 struct mbuf *so_m = so->so_snd.sb_mb; in mptcp_search_seq_in_sub()
3055 sb_mb = mp_so->so_snd.sb_mb; in mptcp_subflow_output()
[all …]
H A Dmptcp_usrreq.c182 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
189 if (mp_so->so_snd.sb_preconn_hiwat == 0) { in mptcp_attach()
196 if ((mp_so->so_snd.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
197 mp_so->so_snd.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
205 mp_so->so_snd.sb_flags |= SB_NOCOMPRESS; in mptcp_attach()
1085 VERIFY(mp_so->so_snd.sb_flags & SB_NOCOMPRESS); in mptcp_usr_send()
1086 sbappendstream(&mp_so->so_snd, m); in mptcp_usr_send()
1098 error = sbwait(&mp_so->so_snd); in mptcp_usr_send()
1290 space = sbspace(&mp_so->so_snd); in mptcp_usr_sosend()
1345 sbunlock(&mp_so->so_snd, FALSE); /* will unlock socket */ in mptcp_usr_sosend()
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 Dflow_divert.c746 sbflush(&fd_cb->so->so_snd); in flow_divert_update_closed_state()
1555 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1737 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1738 buffer = fd_cb->so->so_snd.sb_mb; in flow_divert_send_buffered_data()
1776 sbdrop(&fd_cb->so->so_snd, (int)sent); in flow_divert_send_buffered_data()
1827 (void) sbdroprecord(&(fd_cb->so->so_snd)); in flow_divert_send_buffered_data()
1851 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1903 if (sbspace(&fd_cb->so->so_snd) > 0) { in flow_divert_send_app_data()
1904 if (!sbappendstream(&fd_cb->so->so_snd, pkt_data)) { in flow_divert_send_app_data()
1906 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
[all …]
H A Dmptcp_var.h212 int cwnd = (int)(MIN(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc)); in mptcp_subflow_cwnd_space()
214 return MIN(cwnd, sbspace(&so->so_snd)); in mptcp_subflow_cwnd_space()
H A Dmptcp_opt.c1115 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1116 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1120 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1125 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
1127 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
H A Dtcp_input.c1521 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3117 sbdrop(&so->so_snd, acked); in tcp_input()
3118 tcp_sbsnd_trim(&so->so_snd); in tcp_input()
3174 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
4587 if (so->so_snd.sb_cc) { in tcp_input()
5008 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5203 if (acked > so->so_snd.sb_cc) { in tcp_input()
5204 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
5205 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
5208 sbdrop(&so->so_snd, acked); in tcp_input()
[all …]
H A Dtcp_subr.c1601 dosavessthresh = (i < so->so_snd.sb_hiwat / 2); in tcp_close()
2925 if (so->so_snd.sb_hiwat < mss) { in tcp_mtudisc()
2926 mss = so->so_snd.sb_hiwat; in tcp_mtudisc()
3647 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
4298 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
4308 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
4326 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
4438 if ((so->so_snd.sb_flags & SB_SNDBYTE_CNT) && in inp_get_sndbytes_allunsent()
4439 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
4445 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
/xnu-10063.141.1/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.c403 so->so_rcv.sb_so = so->so_snd.sb_so = so; in sonewconn_internal()
413 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn_internal()
418 so->so_snd.sb_flags |= (head->so_snd.sb_flags & SB_USRSIZE); in sonewconn_internal()
759 if (sbreserve(&so->so_snd, sndcc) == 0) { in soreserve()
762 so->so_snd.sb_idealsize = sndcc; in soreserve()
774 if (so->so_snd.sb_lowat == 0) { in soreserve()
775 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
777 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) { in soreserve()
778 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
782 so->so_snd.sb_flags &= ~SB_SEL; in soreserve()
[all …]
H A Duipc_socket.c754 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1180 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1183 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1218 selthreadclear(&so->so_snd.sb_sel); in sofreelastref()
1221 so->so_snd.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1237 so->so_snd.sb_flags &= ~(SB_UPCALL | SB_SNDBYTE_CNT); in sofreelastref()
1265 so->so_snd.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
2003 if ((so->so_snd.sb_flags & SB_LOCK) != 0 && in sosendcheck()
2014 error = sblock(&so->so_snd, SBLOCKWAIT(flags)); in sosendcheck()
2045 so->so_snd.sb_cfil_thread == current_thread() && in sosendcheck()
[all …]
H A Dkpi_socket.c409 sock->so_snd.sb_flags |= SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
412 sock->so_snd.sb_flags &= ~SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
1345 (so->so_rcv.sb_flags & so->so_snd.sb_flags & SB_UNIX) != SB_UNIX) { in socket_defunct()
1375 sock->so_snd.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1377 sock->so_snd.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1379 sock->so_snd.sb_upcall = wcallback; in sock_setupcalls_locked()
1380 sock->so_snd.sb_upcallarg = wcontext; in sock_setupcalls_locked()
1382 sock->so_snd.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1383 sock->so_snd.sb_upcall = NULL; in sock_setupcalls_locked()
1384 sock->so_snd.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c436 #define snd (&so2->so_snd) in uipc_rcvd()
451 if (sb_notify(&so2->so_snd)) { in uipc_rcvd()
452 sowakeup(so2, &so2->so_snd, so); in uipc_rcvd()
582 #define snd (&so->so_snd) in uipc_send()
718 blksize = so->so_snd.sb_hiwat; in uipc_sense()
959 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
972 so->so_snd.sb_lowat = 1; in unp_attach()
1015 so->so_snd.sb_flags |= SB_UNIX; in unp_attach()
2144 &unp->unp_socket->so_snd : NULL, xsbsnd);
H A Duipc_syscalls.c649 so->so_snd.sb_flags |= SB_ASYNC; in accept_nocancel()
653 so->so_snd.sb_flags &= ~SB_ASYNC; in accept_nocancel()
1813 if (uio_resid(auio) > so->so_snd.sb_hiwat) { in sendit_x()
3863 error = sblock(&so->so_snd, SBL_WAIT); in sendfile()
3886 xfsize = sbspace(&so->so_snd); in sendfile()
4034 if (sbspace(&so->so_snd) < (long)so->so_snd.sb_lowat) { in sendfile()
4042 error = sbwait(&so->so_snd); in sendfile()
4085 sbunlock(&so->so_snd, FALSE); /* will unlock socket */ in sendfile()
4118 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.c1145 .tv_sec = so->so_snd.sb_timeo.tv_sec, in vsock_connect()
1146 .tv_nsec = so->so_snd.sb_timeo.tv_usec * 1000, in vsock_connect()
1309 error = sbwait(&so->so_snd); in vsock_send()
/xnu-10063.141.1/tools/lldbmacros/
H A Dnet.py579 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
648 snd_cc += int(so.so_snd.sb_cc)
649 total_snd_cc[0] += int(so.so_snd.sb_cc)
1566 …out_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_c…
1614 snd_cc[0] += so.so_snd.sb_cc
1615 mpkt = so.so_snd.sb_mb
1893 snd_cc = so.so_snd.sb_cc
1921 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
/xnu-10063.141.1/bsd/sys/
H A Dsocketvar.h192 } so_rcv, so_snd; member
460 struct xsockbuf so_snd; member
483 struct xsockbuf so_snd; member
/xnu-10063.141.1/bsd/net/
H A Dcontent_filter.c1541 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_acquire_sockbuf()
1597 struct sockbuf *sb = outgoing ? &so->so_snd : &so->so_rcv; in cfil_release_sockbuf()
2899 int32_t pending_snd = cfil_sock_data_pending(&so->so_snd); in cfil_sock_is_dead()
2938 int32_t pending_snd = cfil_sock_data_pending(&so->so_snd); in cfil_sock_tcp_add_time_wait()
4476 if (cfil_sock_data_pending(&so->so_snd) == 0) { in cfil_service_inject_queue()
5243 if ((so->so_snd.sb_flags & SB_LOCK) == 0) { in cfil_sock_data_out()
5247 if (so->so_snd.sb_cfil_thread != NULL) { in cfil_sock_data_out()
5249 so->so_snd.sb_cfil_thread); in cfil_sock_data_out()
5397 if (cfil_sock_data_pending(&so->so_snd) != 0) { in cfil_sock_shutdown()
5674 so->so_snd.sb_cfil_thread != current_thread()) { in cfil_sock_data_space()
[all …]

12