src/sys/kern/uipc_socket.c - diff

Return to uipc_socket.c CVS log

Up to [cvs.NetBSD.org] / src / sys / kern

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/kern/uipc_socket.c between version 1.99 and 1.107

version 1.99, 2004/04/22 01:01:40

version 1.107, 2004/09/03 18:14:09

Line 94 __KERNEL_RCSID(0, "$NetBSD$");

#include <uvm/uvm.h>

struct pool socket_pool;

POOL_INIT(socket_pool, sizeof(struct socket), 0, 0, 0, "sockpl", NULL);

MALLOC_DEFINE(M_SOOPTS, "soopts", "socket options");

MALLOC_DEFINE(M_SONAME, "soname", "socket name");

Line 116 struct evcnt sosend_kvalimit = EVCNT_INI

#define SOSEND_COUNTER_INCR(ev) (ev)->ev_count++

EVCNT_ATTACH_STATIC(sosend_loan_big);

EVCNT_ATTACH_STATIC(sosend_copy_big);

EVCNT_ATTACH_STATIC(sosend_copy_small);

EVCNT_ATTACH_STATIC(sosend_kvalimit);

#else

#define SOSEND_COUNTER_INCR(ev) /* nothing */

Line 130 soinit(void)

Line 134 soinit(void)

if (sb_max_set(sb_max))

panic("bad initial sb_max value: %lu\n", sb_max);

pool_init(&socket_pool, sizeof(struct socket), 0, 0, 0,

"sockpl", NULL);

#ifdef SOSEND_COUNTERS

evcnt_attach_static(&sosend_loan_big);

evcnt_attach_static(&sosend_copy_big);

evcnt_attach_static(&sosend_copy_small);

evcnt_attach_static(&sosend_kvalimit);

#endif /* SOSEND_COUNTERS */

}

#ifdef SOSEND_NO_LOAN

Line 412 sosend_loan(struct socket *so, struct ui

Line 407 sosend_loan(struct socket *so, struct ui

/* XXX KDASSERT */

KASSERT(npgs <= M_EXT_MAXPAGES);

KASSERT(uio->uio_procp != NULL);

lva = sokvaalloc(len, so);

if (lva == 0)

Line 455 sosend_loan(struct socket *so, struct ui

Line 451 sosend_loan(struct socket *so, struct ui

/*ARGSUSED*/

int

socreate(int dom, struct socket **aso, int type, int proto)

socreate(int dom, struct socket **aso, int type, int proto, struct proc *p)

{

struct proc *p;

const struct protosw *prp;

struct socket *so;

int error, s;

p = curproc; /* XXX */

if (proto)

prp = pffindproto(dom, proto, type);

else

Line 655 soaccept(struct socket *so, struct mbuf

Line 649 soaccept(struct socket *so, struct mbuf

}

int

soconnect(struct socket *so, struct mbuf *nam)

soconnect(struct socket *so, struct mbuf *nam, struct proc *p)

{

struct proc *p;

int s, error;

p = curproc; /* XXX */

if (so->so_options & SO_ACCEPTCONN)

return (EOPNOTSUPP);

s = splsoftnet();

Line 737 sodisconnect(struct socket *so)

Line 729 sodisconnect(struct socket *so)

int

sosend(struct socket *so, struct mbuf *addr, struct uio *uio, struct mbuf *top,

struct mbuf *control, int flags)

struct mbuf *control, int flags, struct proc *p)

{

struct proc *p;

struct mbuf **mp, *m;

long space, len, resid, clen, mlen;

int error, s, dontroute, atomic;

sodopendfree(so);

p = curproc; /* XXX */

clen = 0;

atomic = sosendallatonce(so) || top;

if (uio)

Line 767 sosend(struct socket *so, struct mbuf *a

Line 757 sosend(struct socket *so, struct mbuf *a

dontroute =

(flags & MSG_DONTROUTE) && (so->so_options & SO_DONTROUTE) == 0 &&

(so->so_proto->pr_flags & PR_ATOMIC);

p->p_stats->p_ru.ru_msgsnd++;

if (p)

p->p_stats->p_ru.ru_msgsnd++;

if (control)

clen = control->m_len;

#define snderr(errno) { error = errno; splx(s); goto release; }

Line 940 int

Line 931 int

soreceive(struct socket *so, struct mbuf **paddr, struct uio *uio,

struct mbuf **mp0, struct mbuf **controlp, int *flagsp)

{

struct proc * p;

struct mbuf *m, **mp;

int flags, len, error, s, offset, moff, type, orig_resid;

const struct protosw *pr;

Line 950 soreceive(struct socket *so, struct mbuf

Line 942 soreceive(struct socket *so, struct mbuf

mp = mp0;

type = 0;

orig_resid = uio->uio_resid;

p = uio->uio_procp;

if (paddr)

*paddr = 0;

if (controlp)

Line 965 soreceive(struct socket *so, struct mbuf

Line 959 soreceive(struct socket *so, struct mbuf

if (flags & MSG_OOB) {

m = m_get(M_WAIT, MT_DATA);

error = (*pr->pr_usrreq)(so, PRU_RCVOOB, m,

(struct mbuf *)(long)(flags & MSG_PEEK), (struct mbuf *)0,

(struct mbuf *)(long)(flags & MSG_PEEK),

(struct proc *)0);

(struct mbuf *)0, p);

if (error)

goto bad;

do {

Line 983 soreceive(struct socket *so, struct mbuf

Line 977 soreceive(struct socket *so, struct mbuf

*mp = (struct mbuf *)0;

if (so->so_state & SS_ISCONFIRMING && uio->uio_resid)

(*pr->pr_usrreq)(so, PRU_RCVD, (struct mbuf *)0,

(struct mbuf *)0, (struct mbuf *)0, (struct proc *)0);

(struct mbuf *)0, (struct mbuf *)0, p);

restart:

if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0)

Line 1056 soreceive(struct socket *so, struct mbuf

Line 1050 soreceive(struct socket *so, struct mbuf

* While we process the initial mbufs containing address and control

* info, we save a copy of m->m_nextpkt into nextrecord.

#ifdef notyet /* XXXX */

if (p)

if (uio->uio_procp)

p->p_stats->p_ru.ru_msgrcv++;

uio->uio_procp->p_stats->p_ru.ru_msgrcv++;

#endif

KASSERT(m == so->so_rcv.sb_mb);

SBLASTRECORDCHK(&so->so_rcv, "soreceive 1");

SBLASTMBUFCHK(&so->so_rcv, "soreceive 1");

Line 1097 soreceive(struct socket *so, struct mbuf

Line 1089 soreceive(struct socket *so, struct mbuf

sbfree(&so->so_rcv, m);

mbuf_removed = 1;

if (controlp) {

if (pr->pr_domain->dom_externalize &&

struct domain *dom = pr->pr_domain;

if (dom->dom_externalize && p &&

mtod(m, struct cmsghdr *)->cmsg_type ==

SCM_RIGHTS)

error = (*pr->pr_domain->dom_externalize)(m);

error = (*dom->dom_externalize)(m, p);

*controlp = m;

so->so_rcv.sb_mb = m->m_next;

m->m_next = 0;

m = so->so_rcv.sb_mb;

} else {

* Dispose of any SCM_RIGHTS message that went

* through the read path rather than recv.

if (pr->pr_domain->dom_dispose &&

mtod(m, struct cmsghdr *)->cmsg_type == SCM_RIGHTS)

(*pr->pr_domain->dom_dispose)(m);

MFREE(m, so->so_rcv.sb_mb);

m = so->so_rcv.sb_mb;

}

Line 1286 soreceive(struct socket *so, struct mbuf

(*pr->pr_usrreq)(so, PRU_RCVD,

(struct mbuf *)0,

(struct mbuf *)(long)flags,

(struct mbuf *)0,

(struct mbuf *)0, p);

(struct proc *)0);

SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 2");

SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 2");

error = sbwait(&so->so_rcv);

Line 1324 soreceive(struct socket *so, struct mbuf

Line 1323 soreceive(struct socket *so, struct mbuf

SBLASTMBUFCHK(&so->so_rcv, "soreceive 4");

if (pr->pr_flags & PR_WANTRCVD && so->so_pcb)

(*pr->pr_usrreq)(so, PRU_RCVD, (struct mbuf *)0,

(struct mbuf *)(long)flags, (struct mbuf *)0,

(struct mbuf *)(long)flags, (struct mbuf *)0, p);

(struct proc *)0);

}

if (orig_resid == uio->uio_resid && orig_resid &&

(flags & MSG_EOR) == 0 && (so->so_state & SS_CANTRCVMORE) == 0) {

Line 1485 sosetopt(struct socket *so, int level, i

Line 1483 sosetopt(struct socket *so, int level, i

case SO_RCVTIMEO:

{

struct timeval *tv;

short val;

int val;

if (m == NULL || m->m_len < sizeof(*tv)) {

error = EINVAL;

goto bad;

}

tv = mtod(m, struct timeval *);

if (tv->tv_sec > (SHRT_MAX - tv->tv_usec / tick) / hz) {

if (tv->tv_sec > (INT_MAX - tv->tv_usec / tick) / hz) {

error = EDOM;

goto bad;

}

Line 1602 sogetopt(struct socket *so, int level, i

Line 1600 sogetopt(struct socket *so, int level, i

break;

}

case SO_OVERFLOWED:

*mtod(m, int *) = so->so_rcv.sb_overflowed;

break;

default:

(void)m_free(m);

return (ENOPROTOOPT);

Line 1780 SYSCTL_SETUP(sysctl_kern_somaxkva_setup,

Line 1782 SYSCTL_SETUP(sysctl_kern_somaxkva_setup,

sysctl_createv(clog, 0, NULL, NULL,

CTLFLAG_PERMANENT|CTLFLAG_READWRITE,

CTLTYPE_INT, "somaxkva", NULL,

CTLTYPE_INT, "somaxkva",

SYSCTL_DESCR("Maximum amount of kernel memory to be "

"used for socket buffers"),

sysctl_kern_somaxkva, 0, NULL, 0,

CTL_KERN, KERN_SOMAXKVA, CTL_EOL);

}

CVSweb <webmaster@jp.NetBSD.org>