| version 1.116, 2006/03/01 12:38:21 |
version 1.116.2.2, 2006/05/24 10:58:42 |
| Line 91 __KERNEL_RCSID(0, "$NetBSD$"); |
|
| Line 91 __KERNEL_RCSID(0, "$NetBSD$"); |
|
| #include <sys/pool.h> |
#include <sys/pool.h> |
| #include <sys/event.h> |
#include <sys/event.h> |
| #include <sys/poll.h> |
#include <sys/poll.h> |
| |
#include <sys/kauth.h> |
| |
|
| #include <uvm/uvm.h> |
#include <uvm/uvm.h> |
| |
|
| Line 155 static int sokvawaiters; |
|
| Line 156 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 174 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 293 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 316 sodopendfree(struct socket *so) |
|
| */ |
*/ |
| |
|
| static size_t |
static size_t |
| sodopendfreel(struct socket *so) |
sodopendfreel() |
| { |
{ |
| size_t rv = 0; |
size_t rv = 0; |
| |
|
| Line 478 socreate(int dom, struct socket **aso, i |
|
| Line 479 socreate(int dom, struct socket **aso, i |
|
| so->so_mowner = &prp->pr_domain->dom_mowner; |
so->so_mowner = &prp->pr_domain->dom_mowner; |
| #endif |
#endif |
| if (l != NULL) { |
if (l != NULL) { |
| uid = l->l_proc->p_ucred->cr_uid; |
uid = kauth_cred_geteuid(l->l_proc->p_cred); |
| } else { |
} else { |
| uid = 0; |
uid = 0; |
| } |
} |
| Line 705 sodisconnect(struct socket *so) |
|
| Line 706 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 738 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 956 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); |