so_rcv 90 kern/sys_socket.c so->so_rcv.sb_flags |= SB_ASYNC; so_rcv 94 kern/sys_socket.c so->so_rcv.sb_flags &= ~SB_ASYNC; so_rcv 100 kern/sys_socket.c *(int *)data = so->so_rcv.sb_datacc; so_rcv 151 kern/sys_socket.c selrecord(p, &so->so_rcv.sb_sel); so_rcv 152 kern/sys_socket.c so->so_rcv.sb_flags |= SB_SEL; so_rcv 590 kern/uipc_socket.c if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0) so_rcv 594 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 607 kern/uipc_socket.c so->so_rcv.sb_cc < uio->uio_resid) && so_rcv 608 kern/uipc_socket.c (so->so_rcv.sb_cc < so->so_rcv.sb_lowat || so_rcv 609 kern/uipc_socket.c ((flags & MSG_WAITALL) && uio->uio_resid <= so->so_rcv.sb_hiwat)) && so_rcv 612 kern/uipc_socket.c if (m == NULL && so->so_rcv.sb_cc) so_rcv 631 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 645 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 1"); so_rcv 646 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 1"); so_rcv 647 kern/uipc_socket.c sbunlock(&so->so_rcv); so_rcv 648 kern/uipc_socket.c error = sbwait(&so->so_rcv); so_rcv 662 kern/uipc_socket.c KASSERT(m == so->so_rcv.sb_mb); so_rcv 663 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 1"); so_rcv 664 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 1"); so_rcv 677 kern/uipc_socket.c sbfree(&so->so_rcv, m); so_rcv 680 kern/uipc_socket.c so->so_rcv.sb_mb = m->m_next; so_rcv 682 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 684 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb); so_rcv 685 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 695 kern/uipc_socket.c sbfree(&so->so_rcv, m); so_rcv 702 kern/uipc_socket.c so->so_rcv.sb_mb = m->m_next; so_rcv 704 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 713 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb); so_rcv 714 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 738 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m); so_rcv 739 kern/uipc_socket.c so->so_rcv.sb_lastrecord = m; so_rcv 751 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m); so_rcv 752 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord; so_rcv 753 kern/uipc_socket.c SB_EMPTY_FIXUP(&so->so_rcv); so_rcv 756 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 2"); so_rcv 757 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 2"); so_rcv 786 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive uiomove"); so_rcv 787 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive uiomove"); so_rcv 806 kern/uipc_socket.c sbfree(&so->so_rcv, m); so_rcv 810 kern/uipc_socket.c so->so_rcv.sb_mb = m = m->m_next; so_rcv 813 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb); so_rcv 814 kern/uipc_socket.c m = so->so_rcv.sb_mb; so_rcv 820 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m); so_rcv 824 kern/uipc_socket.c so->so_rcv.sb_lastrecord = m; so_rcv 826 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord; so_rcv 827 kern/uipc_socket.c SB_EMPTY_FIXUP(&so->so_rcv); so_rcv 829 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 3"); so_rcv 830 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 3"); so_rcv 840 kern/uipc_socket.c so->so_rcv.sb_cc -= len; so_rcv 841 kern/uipc_socket.c so->so_rcv.sb_datacc -= len; so_rcv 870 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 2"); so_rcv 871 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 2"); so_rcv 872 kern/uipc_socket.c error = sbwait(&so->so_rcv); so_rcv 874 kern/uipc_socket.c sbunlock(&so->so_rcv); so_rcv 878 kern/uipc_socket.c if ((m = so->so_rcv.sb_mb) != NULL) so_rcv 886 kern/uipc_socket.c (void) sbdroprecord(&so->so_rcv); so_rcv 895 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord; so_rcv 896 kern/uipc_socket.c if (so->so_rcv.sb_mb == NULL) { so_rcv 897 kern/uipc_socket.c so->so_rcv.sb_mbtail = NULL; so_rcv 898 kern/uipc_socket.c so->so_rcv.sb_lastrecord = NULL; so_rcv 900 kern/uipc_socket.c so->so_rcv.sb_lastrecord = nextrecord; so_rcv 902 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 4"); so_rcv 903 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 4"); so_rcv 910 kern/uipc_socket.c sbunlock(&so->so_rcv); so_rcv 921 kern/uipc_socket.c sbunlock(&so->so_rcv); so_rcv 948 kern/uipc_socket.c struct sockbuf *sb = &so->so_rcv; so_rcv 1039 kern/uipc_socket.c if (sbcheckreserve(cnt, so->so_rcv.sb_hiwat) || so_rcv 1040 kern/uipc_socket.c sbreserve(&so->so_rcv, cnt) == 0) { so_rcv 1051 kern/uipc_socket.c so->so_rcv.sb_lowat = (cnt > so->so_rcv.sb_hiwat) ? so_rcv 1052 kern/uipc_socket.c so->so_rcv.sb_hiwat : cnt; so_rcv 1083 kern/uipc_socket.c so->so_rcv.sb_timeo = val; so_rcv 1155 kern/uipc_socket.c *mtod(m, int *) = so->so_rcv.sb_hiwat; so_rcv 1163 kern/uipc_socket.c *mtod(m, int *) = so->so_rcv.sb_lowat; so_rcv 1170 kern/uipc_socket.c so->so_snd.sb_timeo : so->so_rcv.sb_timeo); so_rcv 1192 kern/uipc_socket.c selwakeup(&so->so_rcv.sb_sel); so_rcv 1208 kern/uipc_socket.c sb = &so->so_rcv; so_rcv 1231 kern/uipc_socket.c SLIST_REMOVE(&so->so_rcv.sb_sel.si_note, kn, knote, kn_selnext); so_rcv 1232 kern/uipc_socket.c if (SLIST_EMPTY(&so->so_rcv.sb_sel.si_note)) so_rcv 1233 kern/uipc_socket.c so->so_rcv.sb_flags &= ~SB_KNOTE; so_rcv 1243 kern/uipc_socket.c kn->kn_data = so->so_rcv.sb_cc; so_rcv 1253 kern/uipc_socket.c return (kn->kn_data >= so->so_rcv.sb_lowat); so_rcv 188 kern/uipc_socket2.c rcv_sb_hiwat = head->so_rcv.sb_hiwat; so_rcv 366 kern/uipc_socket2.c if (sbreserve(&so->so_rcv, rcvcc) == 0) so_rcv 368 kern/uipc_socket2.c if (so->so_rcv.sb_lowat == 0) so_rcv 369 kern/uipc_socket2.c so->so_rcv.sb_lowat = 1; so_rcv 222 kern/uipc_syscalls.c KNOTE(&head->so_rcv.sb_sel.si_note, 0); so_rcv 146 kern/uipc_usrreq.c #define rcv (&so->so_rcv) so_rcv 196 kern/uipc_usrreq.c if (sbappendaddr(&so2->so_rcv, from, m, control)) { so_rcv 208 kern/uipc_usrreq.c #define rcv (&so2->so_rcv) so_rcv 256 kern/uipc_usrreq.c ((struct stat *) m)->st_blksize += so2->so_rcv.sb_cc; so_rcv 337 kern/uipc_usrreq.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { so_rcv 839 kern/uipc_usrreq.c if (so->so_rcv.sb_flags & SB_LOCK) { so_rcv 850 kern/uipc_usrreq.c (void) sbwait(&so->so_rcv); so_rcv 854 kern/uipc_usrreq.c unp_scan(so->so_rcv.sb_mb, unp_mark, 0); so_rcv 514 miscfs/fifofs/fifo_vnops.c sb = &so->so_rcv; so_rcv 537 miscfs/fifofs/fifo_vnops.c SLIST_REMOVE(&so->so_rcv.sb_sel.si_note, kn, knote, kn_selnext); so_rcv 538 miscfs/fifofs/fifo_vnops.c if (SLIST_EMPTY(&so->so_rcv.sb_sel.si_note)) so_rcv 539 miscfs/fifofs/fifo_vnops.c so->so_rcv.sb_flags &= ~SB_KNOTE; so_rcv 547 miscfs/fifofs/fifo_vnops.c kn->kn_data = so->so_rcv.sb_cc; so_rcv 365 miscfs/portal/portal_vnops.c so->so_rcv.sb_timeo = 0; so_rcv 367 miscfs/portal/portal_vnops.c so->so_rcv.sb_flags |= SB_NOINTR; so_rcv 151 net/pfkey.c if (!sbappendaddr(&socket->so_rcv, &pfkey_addr, packet2, NULL)) { so_rcv 110 net/raw_usrreq.c if (sbappendaddr(&last->so_rcv, src, so_rcv 123 net/raw_usrreq.c if (sbappendaddr(&last->so_rcv, src, so_rcv 371 netatalk/ddp_input.c if ( sbappendaddr( &ddp->ddp_socket->so_rcv, (struct sockaddr *)&from, so_rcv 704 netbt/hci_socket.c if (m0 && sbappendaddr(&pcb->hp_socket->so_rcv, so_rcv 396 netbt/l2cap_socket.c if (m->m_pkthdr.len > sbspace(&so->so_rcv)) { so_rcv 405 netbt/l2cap_socket.c sbappendrecord(&so->so_rcv, m); so_rcv 143 netbt/rfcomm_socket.c err = rfcomm_rcvd(up->so_pcb, sbspace(&up->so_rcv)); so_rcv 226 netbt/rfcomm_socket.c return rfcomm_rcvd(pcb, sbspace(&up->so_rcv)); so_rcv 409 netbt/rfcomm_socket.c if (m->m_pkthdr.len > sbspace(&so->so_rcv)) { so_rcv 418 netbt/rfcomm_socket.c sbappendstream(&so->so_rcv, m); so_rcv 373 netbt/sco_socket.c while (m->m_pkthdr.len > sbspace(&so->so_rcv)) so_rcv 374 netbt/sco_socket.c sbdroprecord(&so->so_rcv); so_rcv 378 netbt/sco_socket.c sbappendrecord(&so->so_rcv, m); so_rcv 1322 netinet/ip_mroute.c if (sbappendaddr(&s->so_rcv, sintosa(src), mm, so_rcv 2364 netinet/ip_mroute.c m->m_len, sbspace(&viftable[vifi].v_rsvpd->so_rcv)); so_rcv 146 netinet/raw_ip.c if (sbappendaddr(&last->inp_socket->so_rcv, so_rcv 162 netinet/raw_ip.c if (sbappendaddr(&last->inp_socket->so_rcv, sintosa(&ripsrc), m, so_rcv 317 netinet/tcp_input.c sbappendstream(&so->so_rcv, q->tcpqe_m); so_rcv 755 netinet/tcp_input.c tcp_rscale(tp, so->so_rcv.sb_hiwat); so_rcv 1076 netinet/tcp_input.c tlen <= sbspace(&so->so_rcv)) { so_rcv 1100 netinet/tcp_input.c sbappendstream(&so->so_rcv, m); so_rcv 1123 netinet/tcp_input.c win = sbspace(&so->so_rcv); so_rcv 1979 netinet/tcp_input.c if (th->th_urp + so->so_rcv.sb_cc > sb_max) { so_rcv 2000 netinet/tcp_input.c so->so_oobmark = so->so_rcv.sb_cc + so_rcv 2057 netinet/tcp_input.c sbappendstream(&so->so_rcv, m); so_rcv 2081 netinet/tcp_input.c len = so->so_rcv.sb_hiwat - (tp->rcv_adv - tp->rcv_nxt); so_rcv 3205 netinet/tcp_input.c bufsize = so->so_rcv.sb_hiwat; so_rcv 3210 netinet/tcp_input.c (void)sbreserve(&so->so_rcv, bufsize); so_rcv 3991 netinet/tcp_input.c win = sbspace(&so->so_rcv); so_rcv 4093 netinet/tcp_input.c so->so_rcv.sb_hiwat) so_rcv 399 netinet/tcp_output.c win = sbspace(&so->so_rcv); so_rcv 447 netinet/tcp_output.c if (2 * adv >= (long) so->so_rcv.sb_hiwat) so_rcv 870 netinet/tcp_output.c if (win < (long)(so->so_rcv.sb_hiwat / 4) && win < (long)tp->t_maxseg) so_rcv 335 netinet/tcp_subr.c win = sbspace(&tp->t_inpcb->inp_socket->so_rcv); so_rcv 326 netinet/tcp_usrreq.c tcp_rscale(tp, so->so_rcv.sb_hiwat); so_rcv 669 netinet/tcp_usrreq.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { so_rcv 720 netinet/tcp_usrreq.c sbflush(&so->so_rcv); so_rcv 472 netinet/udp_usrreq.c &last->inp_socket->so_rcv, so_rcv 515 netinet/udp_usrreq.c if (sbappendaddr(&last->inp_socket->so_rcv, so_rcv 634 netinet/udp_usrreq.c if (sbappendaddr(&inp->inp_socket->so_rcv, &srcsa.sa, m, opts) == 0) { so_rcv 1933 netinet6/icmp6.c if (sbappendaddr(&last->in6p_socket->so_rcv, so_rcv 1952 netinet6/icmp6.c if (sbappendaddr(&last->in6p_socket->so_rcv, so_rcv 980 netinet6/ip6_mroute.c if (sbappendaddr(&s->so_rcv, so_rcv 208 netinet6/raw_ip6.c if (sbappendaddr(&last->in6p_socket->so_rcv, so_rcv 227 netinet6/raw_ip6.c if (sbappendaddr(&last->in6p_socket->so_rcv, so_rcv 109 netnatm/natm.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { so_rcv 388 netnatm/natm.c if (sbspace(&so->so_rcv) > m->m_pkthdr.len || so_rcv 389 netnatm/natm.c ((npcb->npcb_flags & NPCB_RAW) != 0 && so->so_rcv.sb_cc < NPCB_RAWCC) ) { so_rcv 394 netnatm/natm.c sbappendrecord(&so->so_rcv, m); so_rcv 246 nfs/nfs_socket.c so->so_rcv.sb_timeo = (5 * hz); so_rcv 282 nfs/nfs_socket.c so->so_rcv.sb_flags |= SB_NOINTR; so_rcv 249 nfs/nfs_syscalls.c so->so_rcv.sb_flags &= ~SB_NOINTR; so_rcv 250 nfs/nfs_syscalls.c so->so_rcv.sb_timeo = 0; so_rcv 95 sys/socketvar.h } so_rcv, so_snd; so_rcv 169 sys/socketvar.h ((so)->so_rcv.sb_cc >= (so)->so_rcv.sb_lowat || \ so_rcv 218 sys/socketvar.h #define sorwakeup(so) { sowakeup((so), &(so)->so_rcv); \