Cross Reference: /src/sys/dev/kttcp.c

Lines Matching refs:so_rcv
252 			SBLASTRECORDCHK(&so->so_rcv,
254 			SBLASTMBUFCHK(&so->so_rcv,
389 	if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0)
391 	m = so->so_rcv.sb_mb;
404 	    so->so_rcv.sb_cc < resid) &&
405 	    (so->so_rcv.sb_cc < so->so_rcv.sb_lowat ||
406 	    ((flags & MSG_WAITALL) && resid <= so->so_rcv.sb_hiwat)) &&
409 		if (m == NULL && so->so_rcv.sb_cc)
428 				m = so->so_rcv.sb_mb;
443 		sbunlock(&so->so_rcv);
444 		error = sbwait(&so->so_rcv);
461 	KASSERT(m == so->so_rcv.sb_mb);
462 	SBLASTRECORDCHK(&so->so_rcv, "kttcp_soreceive 1");
463 	SBLASTMBUFCHK(&so->so_rcv, "kttcp_soreceive 1");
474 			sbfree(&so->so_rcv, m);
475 			m = so->so_rcv.sb_mb = m_free(m);
482 			sbfree(&so->so_rcv, m);
483 			m = so->so_rcv.sb_mb = m_free(m);
502 				KASSERT(so->so_rcv.sb_mb == m);
503 				so->so_rcv.sb_lastrecord = m;
511 			KASSERT(so->so_rcv.sb_mb == m);
512 			so->so_rcv.sb_mb = nextrecord;
513 			SB_EMPTY_FIXUP(&so->so_rcv);
516 	SBLASTRECORDCHK(&so->so_rcv, "kttcp_soreceive 2");
517 	SBLASTMBUFCHK(&so->so_rcv, "kttcp_soreceive 2");
554 				sbfree(&so->so_rcv, m);
558 					so->so_rcv.sb_mb = m = m->m_next;
561 					m = so->so_rcv.sb_mb = m_free(m);
565 				 * so->so_rcv.sb_mb != NULL.
567 				KASSERT(so->so_rcv.sb_mb == m);
571 						so->so_rcv.sb_lastrecord = m;
573 					so->so_rcv.sb_mb = nextrecord;
574 					SB_EMPTY_FIXUP(&so->so_rcv);
576 				SBLASTRECORDCHK(&so->so_rcv,
578 				SBLASTMBUFCHK(&so->so_rcv,
592 				so->so_rcv.sb_cc -= len;
625 			if ((flags & MSG_PEEK) && sbspace(&so->so_rcv) <= 0)
635 			SBLASTRECORDCHK(&so->so_rcv,
637 			SBLASTMBUFCHK(&so->so_rcv,
639 			error = sbwait(&so->so_rcv);
641 				sbunlock(&so->so_rcv);
645 			if ((m = so->so_rcv.sb_mb) != NULL)
653 			(void) sbdroprecord(&so->so_rcv);
662 			so->so_rcv.sb_mb = nextrecord;
663 			if (so->so_rcv.sb_mb == NULL) {
664 				so->so_rcv.sb_mbtail = NULL;
665 				so->so_rcv.sb_lastrecord = NULL;
667 				so->so_rcv.sb_lastrecord = nextrecord;
669 		SBLASTRECORDCHK(&so->so_rcv, "kttcp_soreceive 4");
670 		SBLASTMBUFCHK(&so->so_rcv, "kttcp_soreceive 4");
677 		sbunlock(&so->so_rcv);
684 	sbunlock(&so->so_rcv);
OpenGrok
