491 		STAILQ_INIT(&so->so_rcv.uxdg_mb);  in uipc_attach()
493 		TAILQ_INIT(&so->so_rcv.uxdg_conns);  in uipc_attach()
521 		STAILQ_INIT(&so->so_rcv.uxst_mbq);  in uipc_attach()
877 		MPASS(SOLISTENING(so) || (STAILQ_EMPTY(&so->so_rcv.uxst_mbq) &&  in uipc_detach()
878 		    so->so_rcv.uxst_peer == NULL));  in uipc_detach()
885 		MPASS(so->so_rcv.uxdg_peeked == NULL);  in uipc_detach()
886 		MPASS(STAILQ_EMPTY(&so->so_rcv.uxdg_mb));  in uipc_detach()
887 		MPASS(TAILQ_EMPTY(&so->so_rcv.uxdg_conns));  in uipc_detach()
939 			    &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY);  in uipc_listen()
1171 	sb = &so2->so_rcv;  in uipc_sosend_stream_or_seqpacket()
1319 	struct sockbuf *sb = &so->so_rcv;  in uipc_wakeup_writer()
1348 	so->so_rcv.sb_state |= SBS_CANTRCVMORE;  in uipc_cantrcvmore()
1351 	if (so->so_rcv.uxst_peer != NULL)  in uipc_cantrcvmore()
1361 	struct sockbuf *sb = &so->so_rcv;  in uipc_soreceive_stream_or_seqpacket()
1686 			if (sbavail(&so->so_rcv) >= so->so_rcv.sb_lowat ||  in uipc_sopoll_stream_or_seqpacket()
1689 			if (so->so_rcv.sb_state & SBS_CANTRCVMORE)  in uipc_sopoll_stream_or_seqpacket()
1694 				so->so_rcv.sb_flags |= SB_SEL;  in uipc_sopoll_stream_or_seqpacket()
1699 			struct socket *so2 = so->so_rcv.uxst_peer;  in uipc_sopoll_stream_or_seqpacket()
1702 				struct sockbuf *sb = &so2->so_rcv;  in uipc_sopoll_stream_or_seqpacket()
1711 					so2->so_rcv.uxst_flags |= UXST_PEER_SEL;  in uipc_sopoll_stream_or_seqpacket()
1738 		if (so->so_rcv.uxst_peer != NULL)  in uipc_wrknl_lock()
1739 			SOCK_RECVBUF_LOCK(so->so_rcv.uxst_peer);  in uipc_wrknl_lock()
1752 		if (so->so_rcv.uxst_peer != NULL)  in uipc_wrknl_unlock()
1753 			SOCK_RECVBUF_UNLOCK(so->so_rcv.uxst_peer);  in uipc_wrknl_unlock()
1775 		if (what == LA_LOCKED && so->so_rcv.uxst_peer != NULL)  in uipc_wrknl_assert_lock()
1776 			SOCK_RECVBUF_LOCK_ASSERT(so->so_rcv.uxst_peer);  in uipc_wrknl_assert_lock()
1810 	kn->kn_data = uipc_stream_sbspace(&so2->so_rcv);  in uipc_filt_sowrite()
1812 	if (so2->so_rcv.sb_state & SBS_CANTRCVMORE) {  in uipc_filt_sowrite()
1820 		return (kn->kn_data >= so2->so_rcv.sb_lowat);  in uipc_filt_sowrite()
1834 	kn->kn_data = uipc_stream_sbspace(&so2->so_rcv);  in uipc_filt_soempty()
1876 		struct socket *so2 = so->so_rcv.uxst_peer;  in uipc_kqfilter_stream_or_seqpacket()
2094 	sb = (addr == NULL) ? &so->so_snd : &so2->so_rcv;  in uipc_sosend_dgram()
2098 			TAILQ_INSERT_HEAD(&so2->so_rcv.uxdg_conns, &so->so_snd,  in uipc_sosend_dgram()
2104 		so2->so_rcv.sb_acc += cc + ctl;  in uipc_sosend_dgram()
2105 		so2->so_rcv.sb_ccc += cc + ctl;  in uipc_sosend_dgram()
2106 		so2->so_rcv.sb_ctl += ctl;  in uipc_sosend_dgram()
2107 		so2->so_rcv.sb_mbcnt += mbcnt;  in uipc_sosend_dgram()
2153 	so->so_rcv.uxdg_peeked = m;  in uipc_peek_dgram()
2154 	so->so_rcv.uxdg_cc += m->m_pkthdr.len;  in uipc_peek_dgram()
2155 	so->so_rcv.uxdg_ctl += m->m_pkthdr.ctllen;  in uipc_peek_dgram()
2156 	so->so_rcv.uxdg_mbcnt += m->m_pkthdr.memlen;  in uipc_peek_dgram()
2241 	while ((m = so->so_rcv.uxdg_peeked) == NULL &&  in uipc_soreceive_dgram()
2242 	    (sb = TAILQ_FIRST(&so->so_rcv.uxdg_conns)) == NULL &&  in uipc_soreceive_dgram()
2243 	    (m = STAILQ_FIRST(&so->so_rcv.uxdg_mb)) == NULL) {  in uipc_soreceive_dgram()
2252 		if (so->so_rcv.sb_state & SBS_CANTRCVMORE ||  in uipc_soreceive_dgram()
2272 		sb = &so->so_rcv;  in uipc_soreceive_dgram()
2276 		MPASS(m == so->so_rcv.uxdg_peeked);  in uipc_soreceive_dgram()
2285 	if (__predict_true(m != so->so_rcv.uxdg_peeked)) {  in uipc_soreceive_dgram()
2287 		if (STAILQ_EMPTY(&sb->uxdg_mb) && sb != &so->so_rcv)  in uipc_soreceive_dgram()
2288 			TAILQ_REMOVE(&so->so_rcv.uxdg_conns, sb, uxdg_clist);  in uipc_soreceive_dgram()
2290 		so->so_rcv.uxdg_peeked = NULL;  in uipc_soreceive_dgram()
2299 	so->so_rcv.sb_acc -= m->m_pkthdr.len;  in uipc_soreceive_dgram()
2300 	so->so_rcv.sb_ccc -= m->m_pkthdr.len;  in uipc_soreceive_dgram()
2301 	so->so_rcv.sb_ctl -= m->m_pkthdr.ctllen;  in uipc_soreceive_dgram()
2302 	so->so_rcv.sb_mbcnt -= m->m_pkthdr.memlen;  in uipc_soreceive_dgram()
2393 	sb = &so2->so_rcv;  in uipc_sendfile_wait()
2457 	sb = &so2->so_rcv;  in uipc_sendfile()
2540 	sb = &so->so_rcv;  in uipc_ready_scan()
2568 		sb = &so2->so_rcv;  in uipc_ready()
3056 	sb = &so2->so_rcv;  in unp_soisconnected()
3061 		sb = &so->so_rcv;  in unp_soisconnected()
3135 	so->so_rcv.uxst_peer = NULL;  in unp_soisdisconnected()
3167 			TAILQ_REMOVE(&so2->so_rcv.uxdg_conns, &so->so_snd,  in unp_disconnect()
3169 			if (__predict_true((so2->so_rcv.sb_state &  in unp_disconnect()
3171 			    STAILQ_EMPTY(&so2->so_rcv.uxdg_mb)) {  in unp_disconnect()
3172 				STAILQ_CONCAT(&so2->so_rcv.uxdg_mb,  in unp_disconnect()
3174 				so2->so_rcv.uxdg_cc += so->so_snd.uxdg_cc;  in unp_disconnect()
3175 				so2->so_rcv.uxdg_ctl += so->so_snd.uxdg_ctl;  in unp_disconnect()
3176 				so2->so_rcv.uxdg_mbcnt += so->so_snd.uxdg_mbcnt;  in unp_disconnect()
3180 				so2->so_rcv.sb_acc -= so->so_snd.uxdg_cc;  in unp_disconnect()
3181 				so2->so_rcv.sb_ccc -= so->so_snd.uxdg_cc;  in unp_disconnect()
3182 				so2->so_rcv.sb_ctl -= so->so_snd.uxdg_ctl;  in unp_disconnect()
3183 				so2->so_rcv.sb_mbcnt -= so->so_snd.uxdg_mbcnt;  in unp_disconnect()
4029 		unp_scan(STAILQ_FIRST(&so->so_rcv.uxdg_mb), op);  in unp_scan_socket()
4030 		unp_scan(so->so_rcv.uxdg_peeked, op);  in unp_scan_socket()
4031 		TAILQ_FOREACH(sb, &so->so_rcv.uxdg_conns, uxdg_clist)  in unp_scan_socket()
4036 		unp_scan(STAILQ_FIRST(&so->so_rcv.uxst_mbq), op);  in unp_scan_socket()
4232 		while ((sb = TAILQ_FIRST(&so->so_rcv.uxdg_conns)) != NULL) {  in unp_dispose()
4233 			STAILQ_CONCAT(&so->so_rcv.uxdg_mb, &sb->uxdg_mb);  in unp_dispose()
4234 			TAILQ_REMOVE(&so->so_rcv.uxdg_conns, sb, uxdg_clist);  in unp_dispose()
4238 		sb = &so->so_rcv;  in unp_dispose()
4249 		sb = &so->so_rcv;  in unp_dispose()