Home
last modified time | relevance | path

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

12

/xnu-8020.140.41/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()
316 so->so_rcv.sb_flags |= SB_SEL; in soo_select()
319 so->so_rcv.sb_flags &= ~SB_SEL; in soo_select()
322 selrecord(procp, &so->so_rcv.sb_sel, wql); in soo_select()
336 so->so_rcv.sb_flags |= SB_SEL; in soo_select()
339 so->so_rcv.sb_flags &= ~SB_SEL; in soo_select()
342 selrecord(procp, &so->so_rcv.sb_sel, wql); in soo_select()
379 so->so_rcv.sb_cc != 0) { in soo_stat()
[all …]
H A Duipc_socket.c745 so->so_rcv.sb_flags |= SB_RECV; in socreate_internal()
746 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1167 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1168 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1205 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1206 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1222 so->so_rcv.sb_flags &= ~SB_UPCALL; in sofreelastref()
1250 so->so_rcv.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
3021 sbfree(&so->so_rcv, m); in soreceive_addr()
3025 so->so_rcv.sb_mb = nextrecord; in soreceive_addr()
[all …]
H A Duipc_socket2.c400 so->so_rcv.sb_flags |= SB_RECV; /* XXX */ in sonewconn_internal()
401 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()
415 so->so_rcv.sb_flags |= (head->so_rcv.sb_flags & SB_USRSIZE); in sonewconn_internal()
777 if (sbreserve(&so->so_rcv, rcvcc) == 0) { in soreserve()
780 so->so_rcv.sb_idealsize = rcvcc; in soreserve()
783 if (so->so_rcv.sb_lowat == 0) { in soreserve()
784 so->so_rcv.sb_lowat = 1; in soreserve()
806 so->so_rcv.sb_preconn_hiwat = pre_cc; in soreserve_preconnect()
1586 return sbappendmptcpstream_rcv(&so->so_rcv, m); in sbappendstream_rcvdemux()
[all …]
H A Dkern_control.c737 struct sockbuf *sb = &so->so_rcv; in ctl_sbrcv_trim()
911 struct sockbuf *sb = &so->so_rcv; in ctl_rcvbspace()
1002 if (sbappend_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf()
1014 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf()
1099 if (sbappendrecord_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf_list()
1123 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list()
1209 if (sbappend(&so->so_rcv, m) != 0) { in ctl_enqueuedata()
1223 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata()
1250 m1 = so->so_rcv.sb_mb; in ctl_getenqueuepacketcount()
1281 avail = sbspace(&so->so_rcv); in ctl_getenqueuespace()
[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()
1285 (so->so_rcv.sb_flags & so->so_snd.sb_flags & SB_UNIX) != SB_UNIX) { in socket_defunct()
1302 sock->so_rcv.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1304 sock->so_rcv.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1306 sock->so_rcv.sb_upcall = rcallback; in sock_setupcalls_locked()
1307 sock->so_rcv.sb_upcallarg = rcontext; in sock_setupcalls_locked()
1309 sock->so_rcv.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1310 sock->so_rcv.sb_upcall = NULL; in sock_setupcalls_locked()
1311 sock->so_rcv.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c400 #define rcv (&so->so_rcv) in uipc_rcvd()
520 if (sbappendaddr(&so2->so_rcv, from, m, control, &error)) { in uipc_send()
522 if (sb_notify(&so2->so_rcv)) { in uipc_send()
523 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
543 #define rcv (&so2->so_rcv) in uipc_send()
620 if (sb_notify(&so2->so_rcv)) { in uipc_send()
621 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
678 blksize += so2->so_rcv.sb_cc; in uipc_sense()
921 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
969 so->so_rcv.sb_flags |= SB_UNIX; in unp_attach()
[all …]
H A Dkpi_socketfilter.c1613 if (sbappendaddr(&so->so_rcv, in sock_inject_data_in()
1621 if (sbappendcontrol(&so->so_rcv, data, control, NULL)) { in sock_inject_data_in()
1632 if (sbappendrecord(&so->so_rcv, (struct mbuf *)data)) { in sock_inject_data_in()
1638 if (sbappend(&so->so_rcv, data)) { in sock_inject_data_in()
H A Dsocket_info.c97 fill_sockbuf_info(&so->so_rcv, &si->soi_rcv); in fill_common_sockinfo()
H A Dvsock_domain.c300 uint32_t buf_alloc = pcb->so->so_rcv.sb_hiwat; in vsock_pcb_send_message()
484 error = !sbappendstream(&pcb->so->so_rcv, m); in vsock_put_message_connected()
/xnu-8020.140.41/bsd/net/
H A Draw_usrreq.c133 if (sbappendaddr(&last->so_rcv, src, in raw_input()
145 if (sbappendaddr(&last->so_rcv, src, in raw_input()
/xnu-8020.140.41/bsd/netinet/
H A Dmptcp_subr.c1712 (*so)->so_rcv.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1938 struct sockbuf *, &so->so_rcv, in mptcp_subflow_soclose()
2084 sballoc(&so->so_rcv, new); in mptcp_adj_rmap()
2086 so->so_rcv.sb_cc -= new->m_len; in mptcp_adj_rmap()
2088 if (so->so_rcv.sb_mbtail == m) { in mptcp_adj_rmap()
2089 so->so_rcv.sb_mbtail = new; in mptcp_adj_rmap()
2171 struct sockbuf *sb = &so->so_rcv; in mptcp_subflow_soreceive()
2210 error = sblock(&so->so_rcv, 0); in mptcp_subflow_soreceive()
2215 m = so->so_rcv.sb_mb; in mptcp_subflow_soreceive()
2224 SB_MB_CHECK(&so->so_rcv); in mptcp_subflow_soreceive()
[all …]
H A Dmptcp.c284 qlimit = MIN(MAX(100, mp_so->so_rcv.sb_hiwat >> 10), in mptcp_reass()
416 count = mp_so->so_rcv.sb_cc; in mptcp_input()
465 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
468 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
599 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
603 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
616 count = mp_so->so_rcv.sb_cc; in mptcp_input()
H A Dmp_pcb.c277 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
282 sbrelease(&mp_so->so_rcv); in mptcp_pcbdispose()
H A Dtcp_cc.c379 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 Dtcp_output.c1279 if (recwin < (int32_t)(so->so_rcv.sb_hiwat / 4) && in tcp_output()
1287 if (recwin < (int32_t)(mp_so->so_rcv.sb_hiwat / 4) && in tcp_output()
1449 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat && in tcp_output()
1465 if (so->so_rcv.sb_cc == 0 && in tcp_output()
1472 if (4 * adv >= (int32_t) so->so_rcv.sb_hiwat) { in tcp_output()
3231 struct sockbuf *sbrcv = &tp->t_inpcb->inp_socket->so_rcv; in tcp_recv_throttle()
H A Dtcp_usrreq.c970 tcp_sbrcv_trim(tp, &so->so_rcv); in tcp_usr_rcvd()
986 cfil_sock_buf_update(&so->so_rcv); in tcp_usr_rcvd()
2949 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach()
2967 if ((so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in tcp_attach()
2968 so->so_rcv.sb_flags |= SB_AUTOSIZE; in tcp_attach()
3013 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0) { in tcp_disconnect()
3023 sbflush(&so->so_rcv); in tcp_disconnect()
H A Dmptcp_usrreq.c186 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
197 if ((mp_so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
198 mp_so->so_rcv.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
924 sbflush(&mp_so->so_rcv); in mptcp_disconnect()
H A Dtcp_input.c619 qlimit = min(max(100, so->so_rcv.sb_hiwat >> 10), in tcp_reass()
1274 struct sockbuf *sbrcv = &so->so_rcv; in tcp_sbrcv_tstmp_check()
3126 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5043 if (th->th_urp + so->so_rcv.sb_cc > sb_max) { in tcp_input()
5064 so->so_oobmark = so->so_rcv.sb_cc + in tcp_input()
5183 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5234 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
6363 if (bufsize < so->so_rcv.sb_hiwat) in tcp_mss()
6365 bufsize = so->so_rcv.sb_hiwat; in tcp_mss()
6371 (void)sbreserve(&so->so_rcv, bufsize); in tcp_mss()
H A Draw_ip.c269 if (sbappendaddr(&last->inp_socket->so_rcv, in rip_input()
322 if (sbappendaddr(&last->inp_socket->so_rcv, in rip_input()
/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=" +…
653 rcv_cc += int(so.so_rcv.sb_cc)
654 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1701 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1737 rcv_cc[0] += so.so_rcv.sb_cc
1738 mpkt = so.so_rcv.sb_mb
1944 ….evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so_rcv.sb_…
1978 rcv_cc = so.so_rcv.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/miscfs/fifofs/
H A Dfifo_vnops.c340 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; in fifo_read()
600 *count = sbspace(&rsock->so_rcv); in fifo_freespace()
/xnu-8020.140.41/bsd/sys/
H A Dsocketvar.h187 } so_rcv, so_snd; member
445 struct xsockbuf so_rcv; member
468 struct xsockbuf so_rcv; member
/xnu-8020.140.41/bsd/netinet6/
H A Dudp6_usrreq.c229 if (sbappendaddr(&last->in6p_socket->so_rcv, in udp6_append()
632 if (sbappendaddr(&in6p->in6p_socket->so_rcv, in udp6_input()
780 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in udp6_attach()
H A Draw_ip6.c228 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
266 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
/xnu-8020.140.41/bsd/netkey/
H A Dkeysock.c228 if (!sbappendaddr(&rp->rcb_socket->so_rcv, (struct sockaddr *)&key_src, in key_sendup0()

12