bsd/kern/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.sb_lowat, so->so_rcv.sb_hiwat);
1933 		struct sockbuf *sb = &so->so_rcv;
2032 	error = sblock(&so->so_rcv, SBLOCKWAIT(flags));
2040 	m = so->so_rcv.sb_mb;
2053 	    so->so_rcv.sb_cc < uio_resid(uio)) &&
2054 	    (so->so_rcv.sb_cc < so->so_rcv.sb_lowat ||
2055 	    ((flags & MSG_WAITALL) && uio_resid(uio) <= so->so_rcv.sb_hiwat)) &&
2064 		SB_MB_CHECK(&so->so_rcv);
2082 				m = so->so_rcv.sb_mb;
2097 		SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 1");
2098 		SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 1");
2099 		sbunlock(&so->so_rcv, 1);
2105 		error = sbwait(&so->so_rcv);
2123 	SBLASTRECORDCHK(&so->so_rcv, "soreceive 1");
2124 	SBLASTMBUFCHK(&so->so_rcv, "soreceive 1");
2146 				sbfree(&so->so_rcv, m);
2150 			so->so_rcv.sb_mb = nextrecord;
2151 			SB_EMPTY_FIXUP(&so->so_rcv);
2152 			SBLASTRECORDCHK(&so->so_rcv, "soreceive 1a");
2153 			SBLASTMBUFCHK(&so->so_rcv, "soreceive 1a");
2172 				sbunlock(&so->so_rcv, 1);
2190 				sballoc(&so->so_rcv, m);
2191 			sballoc(&so->so_rcv, m);
2192 			if (so->so_rcv.sb_mb == NULL) {
2193 				so->so_rcv.sb_lastrecord = m0;
2194 				so->so_rcv.sb_mbtail = m;
2197 			nextrecord = m->m_nextpkt = so->so_rcv.sb_mb;
2198 			so->so_rcv.sb_mb = m;
2199 			SBLASTRECORDCHK(&so->so_rcv, "soreceive 1b");
2200 			SBLASTMBUFCHK(&so->so_rcv, "soreceive 1b");
2215 			sbfree(&so->so_rcv, m);
2216 			if (m->m_next == 0 && so->so_rcv.sb_cc != 0)
2219 			MFREE(m, so->so_rcv.sb_mb);
2220 			m = so->so_rcv.sb_mb;
2224 				so->so_rcv.sb_mb = nextrecord;
2225 				SB_EMPTY_FIXUP(&so->so_rcv);
2239 		struct sockbuf *sb_rcv = &so->so_rcv;
2295 		SBLASTRECORDCHK(&so->so_rcv, "soreceive ctl");
2296 		SBLASTMBUFCHK(&so->so_rcv, "soreceive ctl");
2359 			if (m != so->so_rcv.sb_mb || m->m_nextpkt != nextrecord)
2364 				so->so_rcv.sb_lastrecord = m;
2371 			SB_EMPTY_FIXUP(&so->so_rcv);
2374 	SBLASTRECORDCHK(&so->so_rcv, "soreceive 2");
2375 	SBLASTMBUFCHK(&so->so_rcv, "soreceive 2");
2418 			SBLASTRECORDCHK(&so->so_rcv, "soreceive uiomove");
2419 			SBLASTMBUFCHK(&so->so_rcv, "soreceive uiomove");
2452 					if (m != so->so_rcv.sb_mb) {
2475 				sbfree(&so->so_rcv, m);
2481 					so->so_rcv.sb_mb = m = m->m_next;
2489 					so->so_rcv.sb_mb = m = m->m_next;
2495 						so->so_rcv.sb_lastrecord = m;
2497 					so->so_rcv.sb_mb = nextrecord;
2498 					SB_EMPTY_FIXUP(&so->so_rcv);
2500 				SBLASTRECORDCHK(&so->so_rcv, "soreceive 3");
2501 				SBLASTMBUFCHK(&so->so_rcv, "soreceive 3");
2528 				so->so_rcv.sb_cc -= len;
2580 			SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 2");
2581 			SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 2");
2583 			if (so->so_rcv.sb_mb == NULL && sbwait(&so->so_rcv)) {
2606 			    (delayed_copy_len > (so->so_rcv.sb_hiwat / 2))) {
2613 			m = so->so_rcv.sb_mb;
2617 			SB_MB_CHECK(&so->so_rcv);
2634 				(void) sbdroprecord(&so->so_rcv);
2648 	if ((so->so_options & SO_WANTMORE) && so->so_rcv.sb_cc > 0)
2653 			so->so_rcv.sb_mb = nextrecord;
2659 			if (so->so_rcv.sb_mb == NULL) {
2660 				so->so_rcv.sb_mbtail = NULL;
2661 				so->so_rcv.sb_lastrecord = NULL;
2663 				so->so_rcv.sb_lastrecord = nextrecord;
2665 			SB_MB_CHECK(&so->so_rcv);
2667 		SBLASTRECORDCHK(&so->so_rcv, "soreceive 4");
2668 		SBLASTMBUFCHK(&so->so_rcv, "soreceive 4");
2688 		sbunlock(&so->so_rcv, 1);
2706 	sbunlock(&so->so_rcv, 0);	/* will unlock socket */
2710 	    so->so_rcv.sb_cc, 0, error);
2825 	register struct sockbuf *sb = &so->so_rcv;
3083 					&so->so_snd : &so->so_rcv;
3104 				so->so_rcv.sb_lowat =
3105 				    (optval > so->so_rcv.sb_hiwat) ?
3106 				    so->so_rcv.sb_hiwat : optval;
3122 				so->so_rcv.sb_timeo = tv;
3524 				m1 = so->so_rcv.sb_mb;
3533 				optval = so->so_rcv.sb_cc - so->so_rcv.sb_ctl;
3551 			optval = so->so_rcv.sb_hiwat;
3559 			optval = so->so_rcv.sb_lowat;
3565 			    so->so_snd.sb_timeo : so->so_rcv.sb_timeo);
3820 	selwakeup(&so->so_rcv.sb_sel);
3849 			so->so_rcv.sb_flags |= SB_SEL;
3850 			selrecord(p, &so->so_rcv.sb_sel, wql);
3886 		skl = &so->so_rcv.sb_sel.si_note;
3904 			so->so_rcv.sb_flags |= SB_KNOTE;
3927 	if (so->so_rcv.sb_flags & SB_KNOTE)
3928 		if (KNOTE_DETACH(&so->so_rcv.sb_sel.si_note, kn))
3929 			so->so_rcv.sb_flags &= ~SB_KNOTE;
3961 	kn->kn_data = so->so_rcv.sb_cc - so->so_rcv.sb_ctl;
4002 	int64_t	lowwat = so->so_rcv.sb_lowat;
4005 		if (kn->kn_sdata > so->so_rcv.sb_hiwat)
4006 			lowwat = so->so_rcv.sb_hiwat;
4336 		if (!(so->so_snd.sb_flags & so->so_rcv.sb_flags & SB_DROP))
4359 	so->so_rcv.sb_flags |= SB_DROP;
4381 	rcv = &so->so_rcv;