version 1.69, 2002/07/03 19:06:48 |
version 1.71, 2002/08/21 05:13:37 |
|
|
#endif /* SOSEND_COUNTERS */ |
#endif /* SOSEND_COUNTERS */ |
} |
} |
|
|
#ifdef SOSEND_LOAN |
#ifdef SOSEND_NO_LOAN |
int use_sosend_loan = 1; |
|
#else |
|
int use_sosend_loan = 0; |
int use_sosend_loan = 0; |
|
#else |
|
int use_sosend_loan = 1; |
#endif |
#endif |
|
|
struct mbuf *so_pendfree; |
struct mbuf *so_pendfree; |
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. |
*/ |
*/ |