Home
last modified time | relevance | path

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

12

/xnu-10063.141.1/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.c753 so->so_rcv.sb_flags |= SB_RECV; in socreate_internal()
754 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1181 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1182 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1219 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1220 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1236 so->so_rcv.sb_flags &= ~SB_UPCALL; in sofreelastref()
1264 so->so_rcv.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
2960 sbfree(&so->so_rcv, m); in soreceive_addr()
2964 so->so_rcv.sb_mb = nextrecord; in soreceive_addr()
[all …]
H A Dkern_control.c309 so->so_rcv.sb_flags |= SB_KCTL; in ctl_attach()
728 struct sockbuf *sb = &so->so_rcv; in ctl_sbrcv_trim()
903 struct sockbuf *sb = &so->so_rcv; in ctl_rcvbspace()
993 if (sbappend_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf()
1005 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf()
1094 if (sbappendrecord_nodrop(&so->so_rcv, m) != 0) { in ctl_enqueuembuf_list()
1118 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list()
1206 if (sbappend(&so->so_rcv, m) != 0) { in ctl_enqueuedata()
1220 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata()
1247 m1 = so->so_rcv.sb_mb; in ctl_getenqueuepacketcount()
[all …]
H A Duipc_socket2.c402 so->so_rcv.sb_flags |= SB_RECV; /* XXX */ in sonewconn_internal()
403 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()
417 so->so_rcv.sb_flags |= (head->so_rcv.sb_flags & SB_USRSIZE); in sonewconn_internal()
765 if (sbreserve(&so->so_rcv, rcvcc) == 0) { in soreserve()
768 so->so_rcv.sb_idealsize = rcvcc; in soreserve()
771 if (so->so_rcv.sb_lowat == 0) { in soreserve()
772 so->so_rcv.sb_lowat = 1; in soreserve()
794 so->so_rcv.sb_preconn_hiwat = pre_cc; in soreserve_preconnect()
1581 return sbappendmptcpstream_rcv(&so->so_rcv, m); in sbappendstream_rcvdemux()
[all …]
H A Dkpi_socket.c408 sock->so_rcv.sb_flags |= SB_NOINTR; /* This isn't safe */ in sock_nointerrupt()
411 sock->so_rcv.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()
1362 sock->so_rcv.sb_flags |= SB_UPCALL; in sock_setupcalls_locked()
1364 sock->so_rcv.sb_flags |= SB_UPCALL_LOCK; in sock_setupcalls_locked()
1366 sock->so_rcv.sb_upcall = rcallback; in sock_setupcalls_locked()
1367 sock->so_rcv.sb_upcallarg = rcontext; in sock_setupcalls_locked()
1369 sock->so_rcv.sb_flags &= ~(SB_UPCALL | SB_UPCALL_LOCK); in sock_setupcalls_locked()
1370 sock->so_rcv.sb_upcall = NULL; in sock_setupcalls_locked()
1371 sock->so_rcv.sb_upcallarg = NULL; in sock_setupcalls_locked()
H A Duipc_usrreq.c435 #define rcv (&so->so_rcv) in uipc_rcvd()
556 if (sbappendaddr(&so2->so_rcv, from, m, control, &error)) { in uipc_send()
558 if (sb_notify(&so2->so_rcv)) { in uipc_send()
559 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
581 #define rcv (&so2->so_rcv) in uipc_send()
658 if (sb_notify(&so2->so_rcv)) { in uipc_send()
659 sowakeup(so2, &so2->so_rcv, so); in uipc_send()
721 blksize += so2->so_rcv.sb_cc; in uipc_sense()
959 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach()
1014 so->so_rcv.sb_flags |= SB_UNIX; in unp_attach()
[all …]
H A Dkpi_socketfilter.c1606 if (sbappendaddr(&so->so_rcv, in sock_inject_data_in()
1614 if (sbappendcontrol(&so->so_rcv, data, control, NULL)) { in sock_inject_data_in()
1625 if (sbappendrecord(&so->so_rcv, (struct mbuf *)data)) { in sock_inject_data_in()
1631 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.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-10063.141.1/bsd/netinet/
H A Dtcp_cc.c200 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.c1523 (*so)->so_rcv.sb_flags |= SB_NOCOMPRESS; in mptcp_subflow_socreate()
1749 struct sockbuf *, &so->so_rcv, in mptcp_subflow_soclose()
1950 sballoc(&so->so_rcv, new); in mptcp_adj_rmap()
1952 so->so_rcv.sb_cc -= new->m_len; in mptcp_adj_rmap()
1954 if (so->so_rcv.sb_mbtail == m) { in mptcp_adj_rmap()
1955 so->so_rcv.sb_mbtail = new; in mptcp_adj_rmap()
2053 struct sockbuf *sb = &so->so_rcv; in mptcp_subflow_soreceive()
2092 error = sblock(&so->so_rcv, 0); in mptcp_subflow_soreceive()
2097 m = so->so_rcv.sb_mb; in mptcp_subflow_soreceive()
2106 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()
418 count = mp_so->so_rcv.sb_cc; in mptcp_input()
467 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
470 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
601 struct sockbuf *, &mp_so->so_rcv, in mptcp_input()
605 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
618 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_output.c1405 if (recwin < (int32_t)(so->so_rcv.sb_hiwat / 4) && in tcp_output()
1413 if (recwin < (int32_t)(mp_so->so_rcv.sb_hiwat / 4) && in tcp_output()
1593 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat && in tcp_output()
1609 if (so->so_rcv.sb_cc == 0 && in tcp_output()
1616 if (4 * adv >= (int32_t) so->so_rcv.sb_hiwat) { in tcp_output()
3615 struct sockbuf *sbrcv = &tp->t_inpcb->inp_socket->so_rcv; in tcp_recv_throttle()
H A Dtcp_usrreq.c1046 tcp_sbrcv_trim(tp, &so->so_rcv); in tcp_usr_rcvd()
1062 cfil_sock_buf_update(&so->so_rcv); in tcp_usr_rcvd()
3071 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach()
3089 if ((so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in tcp_attach()
3090 so->so_rcv.sb_flags |= SB_AUTOSIZE; in tcp_attach()
3136 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
3147 sbflush(&so->so_rcv); in tcp_disconnect()
H A Dmptcp_usrreq.c182 if (mp_so->so_snd.sb_hiwat == 0 || mp_so->so_rcv.sb_hiwat == 0) { in mptcp_attach()
193 if ((mp_so->so_rcv.sb_flags & SB_USRSIZE) == 0) { in mptcp_attach()
194 mp_so->so_rcv.sb_flags |= SB_AUTOSIZE; in mptcp_attach()
927 sbflush(&mp_so->so_rcv); in mptcp_disconnect()
H A Dtcp_input.c616 qlimit = min(max(100, so->so_rcv.sb_hiwat >> 10), in tcp_reass()
1219 struct sockbuf *sbrcv = &so->so_rcv; in tcp_sbrcv_tstmp_check()
3235 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5371 if (th->th_urp + so->so_rcv.sb_cc > sb_max) { in tcp_input()
5392 so->so_oobmark = so->so_rcv.sb_cc + in tcp_input()
5511 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
5562 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); in tcp_input()
6720 if (bufsize < so->so_rcv.sb_hiwat) in tcp_mss()
6722 bufsize = so->so_rcv.sb_hiwat; in tcp_mss()
6725 (void)sbreserve(&so->so_rcv, bufsize); in tcp_mss()
H A Dflow_divert.c1458 rbuff_space = fd_cb->so->so_rcv.sb_hiwat; in flow_divert_send_connect_result()
2819 if (sbspace(&fd_cb->so->so_rcv) == 0) { in flow_divert_handle_data()
2870 appended = (sbappendstream(&fd_cb->so->so_rcv, data) != 0); in flow_divert_handle_data()
2891 appended = sbappendaddr(&fd_cb->so->so_rcv, append_sa, data, mctl, &append_error); in flow_divert_handle_data()
3459 sbflush(&so->so_rcv); in flow_divert_close()
3512 space = sbspace(&so->so_rcv); in flow_divert_rcvd()
/xnu-10063.141.1/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-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=" +…
650 rcv_cc += int(so.so_rcv.sb_cc)
651 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1566 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1617 rcv_cc[0] += so.so_rcv.sb_cc
1618 mpkt = so.so_rcv.sb_mb
1860 ….evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so_rcv.sb_…
1894 rcv_cc = so.so_rcv.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/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-10063.141.1/bsd/sys/
H A Dsocketvar.h192 } so_rcv, so_snd; member
459 struct xsockbuf so_rcv; member
482 struct xsockbuf so_rcv; member
/xnu-10063.141.1/bsd/netinet6/
H A Dudp6_usrreq.c232 if (sbappendaddr(&last->in6p_socket->so_rcv, in udp6_append()
643 if (sbappendaddr(&in6p->in6p_socket->so_rcv, in udp6_input()
802 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in udp6_attach()
H A Draw_ip6.c232 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
272 if (sbappendaddr(&last->in6p_socket->so_rcv, in rip6_input()
/xnu-10063.141.1/bsd/netkey/
H A Dkeysock.c228 if (!sbappendaddr(&rp->rcb_socket->so_rcv, (struct sockaddr *)&key_src, in key_sendup0()

12