Home
last modified time | relevance | path

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

12

/xnu-12377.41.6/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.c592 so->so_rcv.sb_flags |= SB_RECV; in socreate_internal()
593 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1015 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1016 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1053 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1054 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1070 so->so_rcv.sb_flags &= ~SB_UPCALL; in sofreelastref()
1098 so->so_rcv.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
2846 sbfree(&so->so_rcv, m); in soreceive_addr()
2850 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()
416 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn_internal()
420 so->so_rcv.sb_flags |= (head->so_rcv.sb_flags & SB_USRSIZE); in sonewconn_internal()
768 if (sbreserve(&so->so_rcv, rcvcc) == 0) { in soreserve()
771 so->so_rcv.sb_idealsize = rcvcc; in soreserve()
774 if (so->so_rcv.sb_lowat == 0) { in soreserve()
775 so->so_rcv.sb_lowat = 1; in soreserve()
797 so->so_rcv.sb_preconn_hiwat = pre_cc; in soreserve_preconnect()
1595 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.c348 const uint32_t buf_alloc = pcb->so->so_rcv.sb_hiwat; in vsock_pcb_send_message()
472 if (pcb->so->so_rcv.sb_hiwat != pcb->last_buf_alloc || pcb->fwd_cnt != pcb->last_fwd_cnt) { in vsock_pcb_credit_update_if_needed()
557 error = !sbappendstream(&pcb->so->so_rcv, m); in vsock_put_message_connected()
/xnu-12377.41.6/bsd/netinet/
H A Dtcp_cc.c189 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_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 Dmptcp.c285 qlimit = MIN(MAX(100, mp_so->so_rcv.sb_hiwat >> 10), in mptcp_reass()
428 count = mp_so->so_rcv.sb_cc; in mptcp_input()
477 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
480 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
611 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
615 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
628 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_syncookie.c347 win = ((so->so_rcv.sb_flags & SB_USRSIZE) != 0) ? in syncookie_respond()
348 so->so_rcv.sb_hiwat : tcp_autorcvbuf_max; in syncookie_respond()
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()
3087 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach()
3105 if ((so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in tcp_attach()
3106 so->so_rcv.sb_flags |= SB_AUTOSIZE; in tcp_attach()
3152 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
3163 sbflush(&so->so_rcv); in tcp_disconnect()
H A Dtcp_output.c1720 if (recwin < (int32_t)(so->so_rcv.sb_hiwat / 4) && in tcp_output()
1728 if (recwin < (int32_t)(mp_so->so_rcv.sb_hiwat / 4) && in tcp_output()
1900 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat && in tcp_output()
1916 if (so->so_rcv.sb_cc == 0 && in tcp_output()
1923 if (4 * adv >= (int32_t) so->so_rcv.sb_hiwat) { in tcp_output()
3911 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()
931 sbflush(&mp_so->so_rcv); in mptcp_disconnect()
H A Dtcp_input.c596 qlimit = min(max(100, so->so_rcv.sb_hiwat >> 10), in tcp_reass()
1216 struct sockbuf *sbrcv = &so->so_rcv; in tcp_sbrcv_tstmp_check()
3904 (mem == MEMACCT_SOFTLIMIT && so->so_rcv.sb_cc > 0)) { in tcp_input()
3953 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5882 if (th->th_urp + so->so_rcv.sb_cc > sb_max) { in tcp_input()
5903 so->so_oobmark = so->so_rcv.sb_cc + in tcp_input()
5980 (mem == MEMACCT_SOFTLIMIT && so->so_rcv.sb_cc > 0)) { in tcp_input()
6034 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
6084 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
7262 if (bufsize < so->so_rcv.sb_hiwat) in tcp_mss()
[all …]
/xnu-12377.41.6/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-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=" +…
641 rcv_cc += int(so.so_rcv.sb_cc)
642 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1510 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1572 rcv_cc[0] += so.so_rcv.sb_cc
1573 mpkt = so.so_rcv.sb_mb
1817 ….evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so_rcv.sb_…
1851 rcv_cc = so.so_rcv.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/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-12377.41.6/bsd/sys/
H A Dsocketvar.h192 } so_rcv, so_snd; member
457 struct xsockbuf so_rcv; member
480 struct xsockbuf so_rcv; member
/xnu-12377.41.6/bsd/netinet6/
H A Dudp6_usrreq.c230 if (sbappendaddr(&last->in6p_socket->so_rcv, in udp6_append()
664 if (sbappendaddr(&in6p->in6p_socket->so_rcv, in udp6_input()
824 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in udp6_attach()
H A Draw_ip6.c235 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
276 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
/xnu-12377.41.6/bsd/netkey/
H A Dkeysock.c229 if (!sbappendaddr(&rp->rcb_socket->so_rcv, SA(&key_src), in key_sendup0()

12