Home
last modified time | relevance | path

Searched refs:so_rcv (Results 1 – 25 of 40) sorted by relevance

12

/xnu-11417.140.69/bsd/kern/
H A Dsys_socket.c217 so->so_rcv.sb_flags |= SB_ASYNC; in soioctl()
221 so->so_rcv.sb_flags &= ~SB_ASYNC; in soioctl()
227 bcopy(&so->so_rcv.sb_cc, data, sizeof(u_int32_t)); in soioctl()
312 so->so_rcv.sb_flags |= SB_SEL; in soo_select()
315 so->so_rcv.sb_flags &= ~SB_SEL; in soo_select()
318 selrecord(procp, &so->so_rcv.sb_sel, wql); in soo_select()
332 so->so_rcv.sb_flags |= SB_SEL; in soo_select()
335 so->so_rcv.sb_flags &= ~SB_SEL; in soo_select()
338 selrecord(procp, &so->so_rcv.sb_sel, wql); in soo_select()
375 so->so_rcv.sb_cc != 0) { in soo_stat()
[all …]
H A Duipc_socket.c752 so->so_rcv.sb_flags |= SB_RECV; in socreate_internal()
753 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1175 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1176 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1213 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1214 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1230 so->so_rcv.sb_flags &= ~SB_UPCALL; in sofreelastref()
1258 so->so_rcv.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
2992 sbfree(&so->so_rcv, m); in soreceive_addr()
2996 so->so_rcv.sb_mb = nextrecord; in soreceive_addr()
[all …]
H A Dkern_control.c317 so->so_rcv.sb_flags |= SB_KCTL; in ctl_attach()
741 struct sockbuf *__single sb = &so->so_rcv; in ctl_sbrcv_trim()
921 struct sockbuf *__single sb = &so->so_rcv; in ctl_rcvbspace()
1011 if (sbappend_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf()
1023 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf()
1112 if (sbappendrecord_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf_list()
1136 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list()
1223 if (sbappend(&so->so_rcv, m) != 0) { in ctl_enqueuedata()
1237 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata()
1264 m1 = so->so_rcv.sb_mb; in ctl_getenqueuepacketcount()
[all …]
H A Duipc_socket2.c403 so->so_rcv.sb_flags |= SB_RECV; /* XXX */ in sonewconn_internal()
404 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()
418 so->so_rcv.sb_flags |= (head->so_rcv.sb_flags & SB_USRSIZE); in sonewconn_internal()
766 if (sbreserve(&so->so_rcv, rcvcc) == 0) { in soreserve()
769 so->so_rcv.sb_idealsize = rcvcc; in soreserve()
772 if (so->so_rcv.sb_lowat == 0) { in soreserve()
773 so->so_rcv.sb_lowat = 1; in soreserve()
795 so->so_rcv.sb_preconn_hiwat = pre_cc; in soreserve_preconnect()
1632 return sbappendmptcpstream_rcv(&so->so_rcv, m); in sbappendstream_rcvdemux()
[all …]
H A Dkpi_socket.c406 sock->so_rcv.sb_flags |= SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
409 sock->so_rcv.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()
1361 sock->so_rcv.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1363 sock->so_rcv.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1365 sock->so_rcv.sb_upcall = rcallback; in sock_setupcalls_locked()
1366 sock->so_rcv.sb_upcallarg = rcontext; in sock_setupcalls_locked()
1368 sock->so_rcv.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1369 sock->so_rcv.sb_upcall = NULL; in sock_setupcalls_locked()
1370 sock->so_rcv.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c433 #define rcv (&so->so_rcv) in uipc_rcvd()
573 if (sbappendaddr(&so2->so_rcv, from, m, control, &error)) { in uipc_send()
575 if (sb_notify(&so2->so_rcv)) { in uipc_send()
576 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
596 #define rcv (&so2->so_rcv) in uipc_send()
677 if (sb_notify(&so2->so_rcv)) { in uipc_send()
678 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
739 blksize += so2->so_rcv.sb_cc; in uipc_sense()
989 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
1044 so->so_rcv.sb_flags |= SB_UNIX; in unp_attach()
[all …]
H A Dkpi_socketfilter.c1614 if (sbappendaddr(&so->so_rcv, in sock_inject_data_in()
1622 if (sbappendcontrol(&so->so_rcv, data, control, NULL)) { in sock_inject_data_in()
1633 if (sbappendrecord(&so->so_rcv, (struct mbuf *)data)) { in sock_inject_data_in()
1639 if (sbappend(&so->so_rcv, data)) { in sock_inject_data_in()
H A Dsocket_info.c99 fill_sockbuf_info(&so->so_rcv, &si->soi_rcv); in fill_common_sockinfo()
H A Dvsock_domain.c315 uint32_t buf_alloc = pcb->so->so_rcv.sb_hiwat; in vsock_pcb_send_message()
506 error = !sbappendstream(&pcb->so->so_rcv, m); in vsock_put_message_connected()
/xnu-11417.140.69/bsd/netinet/
H A Dmptcp_subr.c1529 (*so)->so_rcv.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1763 struct sockbuf *, &so->so_rcv, in mptcp_subflow_soclose()
1964 sballoc(&so->so_rcv, new); in mptcp_adj_rmap()
1966 so->so_rcv.sb_cc -= new->m_len; in mptcp_adj_rmap()
1968 if (so->so_rcv.sb_mbtail == m) { in mptcp_adj_rmap()
1969 so->so_rcv.sb_mbtail = new; in mptcp_adj_rmap()
2067 struct sockbuf *sb = &so->so_rcv; in mptcp_subflow_soreceive()
2106 error = sblock(&so->so_rcv, 0); in mptcp_subflow_soreceive()
2111 m = so->so_rcv.sb_mb; in mptcp_subflow_soreceive()
2120 SB_MB_CHECK(&so->so_rcv); in mptcp_subflow_soreceive()
[all …]
H A Dtcp_cc.c198 tp->t_inpcb->inp_socket->so_rcv.sb_cc > tp->t_inpcb->inp_socket->so_rcv.sb_lowat && in tcp_cc_delay_ack()
H A Dmptcp.c285 qlimit = MIN(MAX(100, mp_so->so_rcv.sb_hiwat >> 10), in mptcp_reass()
421 count = mp_so->so_rcv.sb_cc; in mptcp_input()
470 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
473 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
604 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
608 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
621 count = mp_so->so_rcv.sb_cc; in mptcp_input()
H A Dmp_pcb.c276 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
281 sbrelease(&mp_so->so_rcv); in mptcp_pcbdispose()
H A Dtcp_usrreq.c1049 tcp_sbrcv_trim(tp, &so->so_rcv); in tcp_usr_rcvd()
1065 cfil_sock_buf_update(&so->so_rcv); in tcp_usr_rcvd()
3090 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach()
3108 if ((so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in tcp_attach()
3109 so->so_rcv.sb_flags |= SB_AUTOSIZE; in tcp_attach()
3155 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
3166 sbflush(&so->so_rcv); in tcp_disconnect()
H A Dtcp_output.c1484 if (recwin < (int32_t)(so->so_rcv.sb_hiwat / 4) && in tcp_output()
1492 if (recwin < (int32_t)(mp_so->so_rcv.sb_hiwat / 4) && in tcp_output()
1688 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat && in tcp_output()
1704 if (so->so_rcv.sb_cc == 0 && in tcp_output()
1711 if (4 * adv >= (int32_t) so->so_rcv.sb_hiwat) { in tcp_output()
3807 struct sockbuf *__single sbrcv = &tp->t_inpcb->inp_socket->so_rcv; in tcp_recv_throttle()
H A Dmptcp_usrreq.c183 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
194 if ((mp_so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
195 mp_so->so_rcv.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
929 sbflush(&mp_so->so_rcv); in mptcp_disconnect()
H A Dtcp_input.c610 qlimit = min(max(100, so->so_rcv.sb_hiwat >> 10), in tcp_reass()
1217 struct sockbuf *sbrcv = &so->so_rcv; in tcp_sbrcv_tstmp_check()
3419 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5697 if (th->th_urp + so->so_rcv.sb_cc > sb_max) { in tcp_input()
5718 so->so_oobmark = so->so_rcv.sb_cc + in tcp_input()
5838 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5889 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
7065 if (bufsize < so->so_rcv.sb_hiwat) in tcp_mss()
7067 bufsize = so->so_rcv.sb_hiwat; in tcp_mss()
7070 (void)sbreserve(&so->so_rcv, bufsize); in tcp_mss()
H A Dflow_divert.c1469 rbuff_space = fd_cb->so->so_rcv.sb_hiwat; in flow_divert_send_connect_result()
2805 if (sbspace(&so->so_rcv) == 0) { in flow_divert_handle_data()
2856 appended = (sbappendstream(&so->so_rcv, data) != 0); in flow_divert_handle_data()
2877 appended = sbappendaddr(&so->so_rcv, append_sa, data, mctl, &append_error); in flow_divert_handle_data()
3416 sbflush(&so->so_rcv); in flow_divert_detach()
3446 sbflush(&so->so_rcv); in flow_divert_close()
3512 space = sbspace(&so->so_rcv); in flow_divert_rcvd()
/xnu-11417.140.69/bsd/net/
H A Draw_usrreq.c132 if (sbappendaddr(&last->so_rcv, src, in raw_input()
144 if (sbappendaddr(&last->so_rcv, src, in raw_input()
/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=" +…
688 rcv_cc += int(so.so_rcv.sb_cc)
689 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1557 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1608 rcv_cc[0] += so.so_rcv.sb_cc
1609 mpkt = so.so_rcv.sb_mb
1853 ….evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so_rcv.sb_…
1887 rcv_cc = so.so_rcv.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/miscfs/fifofs/
H A Dfifo_vnops.c344 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; in fifo_read()
612 *count = sbspace(&rsock->so_rcv); in fifo_freespace()
/xnu-11417.140.69/bsd/sys/
H A Dsocketvar.h198 } so_rcv, so_snd; member
466 struct xsockbuf so_rcv; member
489 struct xsockbuf so_rcv; member
/xnu-11417.140.69/bsd/netinet6/
H A Dudp6_usrreq.c232 if (sbappendaddr(&last->in6p_socket->so_rcv, in udp6_append()
659 if (sbappendaddr(&in6p->in6p_socket->so_rcv, in udp6_input()
819 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in udp6_attach()
H A Draw_ip6.c233 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
273 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
/xnu-11417.140.69/bsd/netkey/
H A Dkeysock.c229 if (!sbappendaddr(&rp->rcb_socket->so_rcv, SA(&key_src), in key_sendup0()

12