/darwin-on-arm/xnu/bsd/kern/ |
H A D | sys_socket.c | 218 so->so_rcv.sb_flags |= SB_ASYNC; 222 so->so_rcv.sb_flags &= ~SB_ASYNC; 228 bcopy(&so->so_rcv.sb_cc, data, sizeof (u_int32_t)); 285 if (cloned_so->so_rcv.sb_hiwat > 0) { 286 if (sbreserve(&so->so_rcv, 287 cloned_so->so_rcv.sb_hiwat) == 0) { 297 so->so_rcv.sb_lowat = 298 (cloned_so->so_rcv.sb_lowat > so->so_rcv.sb_hiwat) ? 299 so->so_rcv [all...] |
H A D | uipc_socket.c | 584 so->so_rcv.sb_flags |= SB_RECV; /* XXX */ 585 so->so_rcv.sb_so = so->so_snd.sb_so = so; 836 selthreadclear(&so->so_rcv.sb_sel); 837 so->so_rcv.sb_flags &= ~SB_UPCALL; 856 selthreadclear(&so->so_rcv.sb_sel); 857 so->so_rcv.sb_flags &= ~SB_UPCALL; 877 so->so_rcv.sb_flags &= ~SB_UPCALL; 901 so->so_rcv.sb_flags &= ~SB_UPCALL; 1908 so->so_rcv.sb_cc, so->so_rcv [all...] |
H A D | uipc_socket2.c | 329 so->so_rcv.sb_flags |= SB_RECV; /* XXX */ 330 so->so_rcv.sb_so = so->so_snd.sb_so = so; 343 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { 347 so->so_rcv.sb_flags |= (head->so_rcv.sb_flags & SB_USRSIZE); 655 if (sbreserve(&so->so_rcv, rcvcc) == 0) 658 so->so_rcv.sb_idealsize = rcvcc; 660 if (so->so_rcv.sb_lowat == 0) 661 so->so_rcv.sb_lowat = 1; 1691 * How much space is there in a socket buffer (so->so_snd or so->so_rcv) [all...] |
H A D | kpi_socket.c | 161 new_so->so_rcv.sb_flags |= SB_UPCALL; 360 sock->so_rcv.sb_flags |= SB_NOINTR; // This isn't safe 364 sock->so_rcv.sb_flags &= ~SB_NOINTR; // This isn't safe 943 (*new_so)->so_rcv.sb_flags |= SB_UPCALL; 1143 (so->so_rcv.sb_flags & so->so_snd.sb_flags & SB_UNIX) != SB_UNIX) { 1168 sock->so_rcv.sb_flags |= SB_UPCALL; 1173 sock->so_rcv.sb_flags &= ~SB_UPCALL;
|
H A D | uipc_usrreq.c | 362 #define rcv (&so->so_rcv) 474 if (sbappendaddr(&so2->so_rcv, from, m, control, &error)) { 493 #define rcv (&so2->so_rcv) 612 blksize += so2->so_rcv.sb_cc; 774 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 826 so->so_rcv.sb_flags |= SB_UNIX; 2081 if (so->so_rcv.sb_flags & SB_LOCK) { 2092 (void) sbwait(&so->so_rcv); 2108 unp_scan(so->so_rcv.sb_mb, unp_mark);
|
H A D | kern_control.c | 489 if (sbspace(&so->so_rcv) < m->m_pkthdr.len) { 495 if (sbappend(&so->so_rcv, m) && (flags & CTL_DATA_NOWAKEUP) == 0) 520 if (sbspace(&so->so_rcv) < (int)len) { 546 if (sbappend(&so->so_rcv, m) && (flags & CTL_DATA_NOWAKEUP) == 0) 568 avail = sbspace(&so->so_rcv);
|
H A D | kpi_socketfilter.c | 1335 if (sbappendaddr(&so->so_rcv, (struct sockaddr*)(uintptr_t)from, data, 1342 if (sbappendcontrol(&so->so_rcv, data, control, NULL)) 1352 if (sbappendrecord(&so->so_rcv, (struct mbuf*)data)) 1357 if (sbappend(&so->so_rcv, data))
|
H A D | socket_info.c | 92 fill_sockbuf_info(&so->so_rcv, &si->soi_rcv);
|
/darwin-on-arm/xnu/bsd/netat/ |
H A D | aurp_aurpd.c | 137 sblock(&so->so_rcv, M_WAIT); 182 so->so_rcv.sb_flags |=(SB_SEL|SB_NOINTR); 187 sbunlock(&so->so_rcv, 0); 337 sblock(&so->so_rcv, M_WAIT); 342 sbunlock(&so->so_rcv, 0);
|
H A D | adsp_Control.c | 102 if (((sp->gref)->so)->so_rcv.sb_mb) 103 for (p = ((sp->gref)->so)->so_rcv.sb_mb; p; p = p->m_nextpkt)
|
/darwin-on-arm/xnu/bsd/net/ |
H A D | raw_usrreq.c | 147 if (sbappendaddr(&last->so_rcv, src, 159 if (sbappendaddr(&last->so_rcv, src,
|
H A D | ntstat.c | 1044 desc->rcvbufsize = so->so_rcv.sb_hiwat; 1045 desc->rcvbufused = so->so_rcv.sb_cc; 1230 desc->rcvbufsize = so->so_rcv.sb_hiwat; 1231 desc->rcvbufused = so->so_rcv.sb_cc;
|
/darwin-on-arm/xnu/bsd/netinet6/ |
H A D | udp6_usrreq.c | 192 if (sbappendaddr(&last->in6p_socket->so_rcv, 552 if (sbappendaddr(&in6p->in6p_socket->so_rcv, 711 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
|
H A D | raw_ip6.c | 218 if (sbappendaddr(&last->in6p_socket->so_rcv, 257 if (sbappendaddr(&last->in6p_socket->so_rcv,
|
/darwin-on-arm/xnu/bsd/sys/ |
H A D | socketvar.h | 184 } so_rcv, so_snd; member in struct:socket 374 struct xsockbuf so_rcv; member in struct:xsocket 398 struct xsockbuf so_rcv; member in struct:xsocket64 590 panic("corrupt so_rcv: sb_mb %p sb_cc %d\n", \
|
/darwin-on-arm/xnu/bsd/miscfs/fifofs/ |
H A D | fifo_vnops.c | 325 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; 563 *count = sbspace(&rsock->so_rcv);
|
/darwin-on-arm/xnu/bsd/netinet/ |
H A D | tcp_usrreq.c | 627 tcp_sbrcv_trim(tp, &so->so_rcv); 1686 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 1691 if ((so->so_rcv.sb_flags & SB_USRSIZE) == 0) 1692 so->so_rcv.sb_flags |= SB_AUTOSIZE; 1745 sbflush(&so->so_rcv);
|
H A D | in_dhcp.c | 353 sowakeup(so, &so->so_rcv); 485 error = sbwait(&context->so->so_rcv); 681 error = sbwait(&context->so->so_rcv);
|
H A D | tcp_input.c | 693 if (sbappendstream(&so->so_rcv, q->tqe_m)) 1027 struct sockbuf *sbrcv = &so->so_rcv; 2423 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); 2430 if (sbappendstream(&so->so_rcv, m)) 3629 if (th->th_urp + so->so_rcv.sb_cc > sb_max) { 3650 so->so_oobmark = so->so_rcv.sb_cc + 3754 tcp_sbrcv_grow(tp, &so->so_rcv, &to, tlen); 3756 if (sbappendstream(&so->so_rcv, m)) 4527 if (bufsize < so->so_rcv.sb_hiwat) 4529 bufsize = so->so_rcv [all...] |
H A D | raw_ip.c | 267 if (sbappendaddr(&last->inp_socket->so_rcv, 322 if (sbappendaddr(&last->inp_socket->so_rcv,
|
H A D | in_pcb.c | 1053 if (so->so_rcv.sb_cc || so->so_snd.sb_cc) { 1056 so, so->so_rcv.sb_cc, so->so_snd.sb_cc); 1058 sbrelease(&so->so_rcv);
|
H A D | tcp_output.c | 905 if (4 * adv >= (int32_t) so->so_rcv.sb_hiwat) 1141 if (tp->rfbuf_ts == 0 && (so->so_rcv.sb_flags & SB_AUTOSIZE)) 1526 if (recwin < (int32_t)(so->so_rcv.sb_hiwat / 4) && recwin < (int)tp->t_maxseg)
|
H A D | in_pcblist.c | 344 sbtoxsockbuf_n(inp->inp_socket ? &inp->inp_socket->so_rcv : NULL, xsbrcv);
|
H A D | ip_divert.c | 291 if (sbappendaddr(&sa->so_rcv, (struct sockaddr *)&divsrc,
|
/darwin-on-arm/xnu/bsd/netkey/ |
H A D | keysock.c | 194 if (!sbappendaddr(&rp->rcb_socket->so_rcv, (struct sockaddr *)&key_src,
|