Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files. =================================================================== RCS file: /ftp/cvs/cvsroot/src/sys/kern/uipc_socket.c,v retrieving revision 1.50 retrieving revision 1.50.4.5 diff -u -p -r1.50 -r1.50.4.5 --- src/sys/kern/uipc_socket.c 2000/03/30 09:27:14 1.50 +++ src/sys/kern/uipc_socket.c 2002/09/18 16:04:53 1.50.4.5 @@ -1,4 +1,4 @@ -/* $NetBSD: uipc_socket.c,v 1.50 2000/03/30 09:27:14 augustss Exp $ */ +/* $NetBSD: uipc_socket.c,v 1.50.4.5 2002/09/18 16:04:53 itojun Exp $ */ /* * Copyright (c) 1982, 1986, 1988, 1990, 1993 @@ -126,11 +126,11 @@ socreate(dom, aso, type, proto) } int -sobind(so, nam) +sobind(so, nam, p) struct socket *so; struct mbuf *nam; + struct proc *p; { - struct proc *p = curproc; /* XXX */ int s = splsoftnet(); int error; @@ -262,7 +262,7 @@ soaccept(so, nam) struct mbuf *nam; { int s = splsoftnet(); - int error; + int error = 0; if ((so->so_state & SS_NOFDREF) == 0) panic("soaccept: !NOFDREF"); @@ -271,7 +271,8 @@ soaccept(so, nam) error = (*so->so_proto->pr_usrreq)(so, PRU_ACCEPT, (struct mbuf *)0, nam, (struct mbuf *)0, (struct proc *)0); else - error = 0; + error = ECONNABORTED; + splx(s); return (error); } @@ -568,6 +569,7 @@ soreceive(so, paddr, uio, mp0, controlp, struct mbuf *nextrecord; int moff, type = 0; int orig_resid = uio->uio_resid; + int mbuf_removed = 0; mp = mp0; if (paddr) @@ -682,6 +684,7 @@ dontblock: m = m->m_next; } else { sbfree(&so->so_rcv, m); + mbuf_removed = 1; if (paddr) { *paddr = m; so->so_rcv.sb_mb = m->m_next; @@ -700,6 +703,7 @@ dontblock: m = m->m_next; } else { sbfree(&so->so_rcv, m); + mbuf_removed = 1; if (controlp) { if (pr->pr_domain->dom_externalize && mtod(m, struct cmsghdr *)->cmsg_type == @@ -756,6 +760,24 @@ dontblock: splx(s); error = uiomove(mtod(m, caddr_t) + moff, (int)len, uio); s = splsoftnet(); + if (error) { + /* + * If any part of the record has been removed + * (such as the MT_SONAME mbuf, which will + * happen when PR_ADDR, and thus also + * PR_ATOMIC, is set), then drop the entire + * record to maintain the atomicity of the + * receive operation. + * + * This avoids a later panic("receive 1a") + * when compiled with DIAGNOSTIC. + */ + if (m && mbuf_removed + && (pr->pr_flags & PR_ATOMIC)) + (void) sbdroprecord(&so->so_rcv); + + goto release; + } } else uio->uio_resid -= len; if (len == m->m_len - moff) {