| /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,
|