| version 1.116.4.1, 2006/03/08 00:53:41 |
version 1.116.4.2, 2006/04/19 05:14:00 |
| Line 155 static int sokvawaiters; |
|
| Line 155 static int sokvawaiters; |
|
| #define SOCK_LOAN_THRESH 4096 |
#define SOCK_LOAN_THRESH 4096 |
| #define SOCK_LOAN_CHUNK 65536 |
#define SOCK_LOAN_CHUNK 65536 |
| |
|
| static size_t sodopendfree(struct socket *); |
static size_t sodopendfree(void); |
| static size_t sodopendfreel(struct socket *); |
static size_t sodopendfreel(void); |
| |
|
| static vsize_t |
static vsize_t |
| sokvareserve(struct socket *so, vsize_t len) |
sokvareserve(struct socket *so, vsize_t len) |
| Line 173 sokvareserve(struct socket *so, vsize_t |
|
| Line 173 sokvareserve(struct socket *so, vsize_t |
|
| * try to do pendfree. |
* try to do pendfree. |
| */ |
*/ |
| |
|
| freed = sodopendfreel(so); |
freed = sodopendfreel(); |
| |
|
| /* |
/* |
| * if some kva was freed, try again. |
* if some kva was freed, try again. |
| Line 292 sodoloanfree(struct vm_page **pgs, caddr |
|
| Line 292 sodoloanfree(struct vm_page **pgs, caddr |
|
| } |
} |
| |
|
| static size_t |
static size_t |
| sodopendfree(struct socket *so) |
sodopendfree() |
| { |
{ |
| int s; |
int s; |
| size_t rv; |
size_t rv; |
| |
|
| s = splvm(); |
s = splvm(); |
| simple_lock(&so_pendfree_slock); |
simple_lock(&so_pendfree_slock); |
| rv = sodopendfreel(so); |
rv = sodopendfreel(); |
| simple_unlock(&so_pendfree_slock); |
simple_unlock(&so_pendfree_slock); |
| splx(s); |
splx(s); |
| |
|
| Line 315 sodopendfree(struct socket *so) |
|
| Line 315 sodopendfree(struct socket *so) |
|
| */ |
*/ |
| |
|
| static size_t |
static size_t |
| sodopendfreel(struct socket *so) |
sodopendfreel() |
| { |
{ |
| size_t rv = 0; |
size_t rv = 0; |
| |
|
| Line 705 sodisconnect(struct socket *so) |
|
| Line 705 sodisconnect(struct socket *so) |
|
| (struct lwp *)0); |
(struct lwp *)0); |
| bad: |
bad: |
| splx(s); |
splx(s); |
| sodopendfree(so); |
sodopendfree(); |
| return (error); |
return (error); |
| } |
} |
| |
|
| Line 737 sosend(struct socket *so, struct mbuf *a |
|
| Line 737 sosend(struct socket *so, struct mbuf *a |
|
| int error, s, dontroute, atomic; |
int error, s, dontroute, atomic; |
| |
|
| p = l->l_proc; |
p = l->l_proc; |
| sodopendfree(so); |
sodopendfree(); |
| |
|
| clen = 0; |
clen = 0; |
| atomic = sosendallatonce(so) || top; |
atomic = sosendallatonce(so) || top; |
| Line 955 soreceive(struct socket *so, struct mbuf |
|
| Line 955 soreceive(struct socket *so, struct mbuf |
|
| flags = 0; |
flags = 0; |
| |
|
| if ((flags & MSG_DONTWAIT) == 0) |
if ((flags & MSG_DONTWAIT) == 0) |
| sodopendfree(so); |
sodopendfree(); |
| |
|
| if (flags & MSG_OOB) { |
if (flags & MSG_OOB) { |
| m = m_get(M_WAIT, MT_DATA); |
m = m_get(M_WAIT, MT_DATA); |