| version 1.69, 2002/07/03 19:06:48 |
version 1.70, 2002/07/03 21:39:41 |
| Line 995 soreceive(struct socket *so, struct mbuf |
|
| Line 995 soreceive(struct socket *so, struct mbuf |
|
| if ((flags & MSG_PEEK) == 0) { |
if ((flags & MSG_PEEK) == 0) { |
| KASSERT(so->so_rcv.sb_mb == m); |
KASSERT(so->so_rcv.sb_mb == m); |
| so->so_rcv.sb_mb = nextrecord; |
so->so_rcv.sb_mb = nextrecord; |
| SB_UPDATE_TAIL(&so->so_rcv); |
SB_EMPTY_FIXUP(&so->so_rcv); |
| } |
} |
| } |
} |
| SBLASTRECORDCHK(&so->so_rcv, "soreceive 2"); |
SBLASTRECORDCHK(&so->so_rcv, "soreceive 2"); |
| Line 1082 soreceive(struct socket *so, struct mbuf |
|
| Line 1082 soreceive(struct socket *so, struct mbuf |
|
| so->so_rcv.sb_lastrecord = m; |
so->so_rcv.sb_lastrecord = m; |
| } else { |
} else { |
| so->so_rcv.sb_mb = nextrecord; |
so->so_rcv.sb_mb = nextrecord; |
| SB_UPDATE_TAIL(&so->so_rcv); |
SB_EMPTY_FIXUP(&so->so_rcv); |
| } |
} |
| SBLASTRECORDCHK(&so->so_rcv, "soreceive 3"); |
SBLASTRECORDCHK(&so->so_rcv, "soreceive 3"); |
| SBLASTMBUFCHK(&so->so_rcv, "soreceive 3"); |
SBLASTMBUFCHK(&so->so_rcv, "soreceive 3"); |
| Line 1162 soreceive(struct socket *so, struct mbuf |
|
| Line 1162 soreceive(struct socket *so, struct mbuf |
|
| if ((flags & MSG_PEEK) == 0) { |
if ((flags & MSG_PEEK) == 0) { |
| if (m == 0) { |
if (m == 0) { |
| /* |
/* |
| * First part is an inline SB_UPDATE_TAIL(). Second |
* First part is an inline SB_EMPTY_FIXUP(). Second |
| * part makes sure sb_lastrecord is up-to-date if |
* part makes sure sb_lastrecord is up-to-date if |
| * there is still data in the socket buffer. |
* there is still data in the socket buffer. |
| */ |
*/ |