-/* uipc_socket.c 4.64 82/11/13 */
-
-#include "../h/param.h"
-#include "../h/systm.h"
-#include "../h/dir.h"
-#include "../h/user.h"
-#include "../h/proc.h"
-#include "../h/file.h"
-#include "../h/inode.h"
-#include "../h/buf.h"
-#include "../h/mbuf.h"
-#include "../h/protosw.h"
-#include "../h/socket.h"
-#include "../h/socketvar.h"
-#include "../h/stat.h"
-#include "../h/ioctl.h"
-#include "../h/uio.h"
-#include "../net/route.h"
+/*
+ * Copyright (c) 1982, 1986, 1988 Regents of the University of California.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by the University of California, Berkeley. The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * @(#)uipc_socket.c 7.14 (Berkeley) %G%
+ */
+
+#include "param.h"
+#include "user.h"
+#include "proc.h"
+#include "file.h"
+#include "malloc.h"
+#include "mbuf.h"
+#include "domain.h"
+#include "protosw.h"
+#include "socket.h"
+#include "socketvar.h"
/*
* Socket operation routines.
* sys_socket.c or from a system process, and
* implement the semantics of socket operations by
* switching out to the protocol specific routines.
+ *
+ * TODO:
+ * test socketpair
+ * clean up async
+ * out-of-band is a kludge
*/
-
/*ARGSUSED*/
-socreate(dom, aso, type, proto, opt)
+socreate(dom, aso, type, proto)
struct socket **aso;
- int type, proto;
- struct socketopt *opt;
+ register int type;
+ int proto;
{
register struct protosw *prp;
register struct socket *so;
- struct mbuf *m;
- int error;
+ register int error;
if (proto)
- prp = pffindproto(dom, proto);
+ prp = pffindproto(dom, proto, type);
else
prp = pffindtype(dom, type);
if (prp == 0)
return (EPROTONOSUPPORT);
if (prp->pr_type != type)
return (EPROTOTYPE);
- m = m_getclr(M_WAIT);
- if (m == 0)
- return (ENOBUFS);
- so = mtod(m, struct socket *);
- so->so_options = 0;
- so->so_state = 0;
+ MALLOC(so, struct socket *, sizeof(*so), M_SOCKET, M_WAIT);
+ bzero((caddr_t)so, sizeof(*so));
so->so_type = type;
if (u.u_uid == 0)
so->so_state = SS_PRIV;
so->so_proto = prp;
- error = (*prp->pr_usrreq)(so, PRU_ATTACH,
- (struct mbuf *)0, (struct mbuf *)0, (struct socketopt *)0);
+ error =
+ (*prp->pr_usrreq)(so, PRU_ATTACH,
+ (struct mbuf *)0, (struct mbuf *)proto, (struct mbuf *)0);
if (error) {
so->so_state |= SS_NOFDREF;
sofree(so);
return (0);
}
-sobind(so, nam, opt)
+sobind(so, nam)
struct socket *so;
struct mbuf *nam;
- struct socketopt *opt;
{
int s = splnet();
int error;
error =
(*so->so_proto->pr_usrreq)(so, PRU_BIND,
- (struct mbuf *)0, nam, opt);
+ (struct mbuf *)0, nam, (struct mbuf *)0);
splx(s);
return (error);
}
solisten(so, backlog)
- struct socket *so;
+ register struct socket *so;
int backlog;
{
- int s = splnet();
- int error;
+ int s = splnet(), error;
- error = (*so->so_proto->pr_usrreq)(so, PRU_LISTEN,
- (struct mbuf *)0, (struct mbuf *)0, (struct socketopt *)0);
+ error =
+ (*so->so_proto->pr_usrreq)(so, PRU_LISTEN,
+ (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0);
if (error) {
splx(s);
return (error);
}
if (backlog < 0)
backlog = 0;
- so->so_qlimit = backlog < 5 ? backlog : 5;
- so->so_options |= SO_NEWFDONCONN;
+ so->so_qlimit = min(backlog, SOMAXCONN);
+ splx(s);
return (0);
}
sofree(so)
- struct socket *so;
+ register struct socket *so;
{
+ if (so->so_pcb || (so->so_state & SS_NOFDREF) == 0)
+ return;
if (so->so_head) {
if (!soqremque(so, 0) && !soqremque(so, 1))
panic("sofree dq");
so->so_head = 0;
}
- if (so->so_pcb || (so->so_state & SS_NOFDREF) == 0)
- return;
sbrelease(&so->so_snd);
- sbrelease(&so->so_rcv);
- (void) m_free(dtom(so));
+ sorflush(so);
+ FREE(so, M_SOCKET);
}
/*
* Initiate disconnect if connected.
* Free socket when disconnect complete.
*/
-soclose(so, exiting)
+soclose(so)
register struct socket *so;
- int exiting;
{
int s = splnet(); /* conservative */
- int error;
+ int error = 0;
if (so->so_options & SO_ACCEPTCONN) {
while (so->so_q0 != so)
- (void) soclose(so->so_q0, 1);
+ (void) soabort(so->so_q0);
while (so->so_q != so)
- (void) soclose(so->so_q, 1);
+ (void) soabort(so->so_q);
}
if (so->so_pcb == 0)
goto discard;
- if (exiting)
- so->so_options |= SO_KEEPALIVE;
if (so->so_state & SS_ISCONNECTED) {
if ((so->so_state & SS_ISDISCONNECTING) == 0) {
- error = sodisconnect(so, (struct mbuf *)0);
- if (error) {
- if (exiting)
- goto drop;
- splx(s);
- return (error);
- }
+ error = sodisconnect(so);
+ if (error)
+ goto drop;
}
- if ((so->so_options & SO_DONTLINGER) == 0) {
+ if (so->so_options & SO_LINGER) {
if ((so->so_state & SS_ISDISCONNECTING) &&
- (so->so_state & SS_NBIO) &&
- exiting == 0)
- return (EINPROGRESS);
- /* should use tsleep here, for at most linger */
+ (so->so_state & SS_NBIO))
+ goto drop;
while (so->so_state & SS_ISCONNECTED)
sleep((caddr_t)&so->so_timeo, PZERO+1);
}
}
drop:
if (so->so_pcb) {
- error = (*so->so_proto->pr_usrreq)(so, PRU_DETACH,
- (struct mbuf *)0, (struct mbuf *)0, (struct socketopt *)0);
- if (exiting == 0 && error) {
- splx(s);
- return (error);
- }
+ int error2 =
+ (*so->so_proto->pr_usrreq)(so, PRU_DETACH,
+ (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0);
+ if (error == 0)
+ error = error2;
}
discard:
+ if (so->so_state & SS_NOFDREF)
+ panic("soclose: NOFDREF");
so->so_state |= SS_NOFDREF;
sofree(so);
splx(s);
- return (0);
+ return (error);
}
-/*ARGSUSED*/
-sostat(so, ub)
+/*
+ * Must be called at splnet...
+ */
+soabort(so)
struct socket *so;
- struct stat *ub;
{
- struct stat sb;
- bzero((caddr_t)&sb, sizeof (sb)); /* XXX */
- (void) copyout((caddr_t)&sb, (caddr_t)ub, sizeof (sb));/* XXX */
- return (0); /* XXX */
+ return (
+ (*so->so_proto->pr_usrreq)(so, PRU_ABORT,
+ (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0));
}
-soaccept(so, nam, opt)
- struct socket *so;
+soaccept(so, nam)
+ register struct socket *so;
struct mbuf *nam;
- struct socketopt *opt;
{
int s = splnet();
int error;
+ if ((so->so_state & SS_NOFDREF) == 0)
+ panic("soaccept: !NOFDREF");
+ so->so_state &= ~SS_NOFDREF;
error = (*so->so_proto->pr_usrreq)(so, PRU_ACCEPT,
- (struct mbuf *)0, nam, opt);
+ (struct mbuf *)0, nam, (struct mbuf *)0);
splx(s);
return (error);
}
-soconnect(so, nam, opt)
- struct socket *so;
+soconnect(so, nam)
+ register struct socket *so;
struct mbuf *nam;
- struct socketopt *opt;
{
- int s = splnet();
+ int s;
int error;
- if (so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING)) {
+ if (so->so_options & SO_ACCEPTCONN)
+ return (EOPNOTSUPP);
+ s = splnet();
+ /*
+ * If protocol is connection-based, can only connect once.
+ * Otherwise, if connected, try to disconnect first.
+ * This allows user to disconnect by connecting to, e.g.,
+ * a null address.
+ */
+ if (so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING) &&
+ ((so->so_proto->pr_flags & PR_CONNREQUIRED) ||
+ (error = sodisconnect(so))))
error = EISCONN;
- goto bad;
- }
- error = (*so->so_proto->pr_usrreq)(so, PRU_CONNECT,
- (struct mbuf *)0, nam, opt);
-bad:
+ else
+ error = (*so->so_proto->pr_usrreq)(so, PRU_CONNECT,
+ (struct mbuf *)0, nam, (struct mbuf *)0);
splx(s);
return (error);
}
-sodisconnect(so, nam)
- struct socket *so;
- struct mbuf *nam;
+soconnect2(so1, so2)
+ register struct socket *so1;
+ struct socket *so2;
+{
+ int s = splnet();
+ int error;
+
+ error = (*so1->so_proto->pr_usrreq)(so1, PRU_CONNECT2,
+ (struct mbuf *)0, (struct mbuf *)so2, (struct mbuf *)0);
+ splx(s);
+ return (error);
+}
+
+sodisconnect(so)
+ register struct socket *so;
{
int s = splnet();
int error;
goto bad;
}
error = (*so->so_proto->pr_usrreq)(so, PRU_DISCONNECT,
- (struct mbuf *)0, nam, (struct socketopt *)0);
+ (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0);
bad:
splx(s);
return (error);
* Lock against other senders.
* If must go all at once and not enough room now, then
* inform user that this would block and do nothing.
+ * Otherwise, if nonblocking, send as much as possible.
*/
-sosend(so, nam, uio, flags)
+sosend(so, nam, uio, flags, rights, control)
register struct socket *so;
struct mbuf *nam;
- struct uio *uio;
+ register struct uio *uio;
int flags;
+ struct mbuf *rights, *control;
{
- struct mbuf *top = 0;
- register struct mbuf *m, **mp = ⊤
- register int len;
- int error = 0, space, s;
+ struct mbuf *top = 0, **mp;
+ register struct mbuf *m;
+ register int space, len;
+ int rlen = 0, error = 0, s, dontroute, first = 1, mlen;
+ int atomic = sosendallatonce(so);
- if (sosendallatonce(so) && uio->uio_resid > so->so_snd.sb_hiwat)
+ if (atomic && uio->uio_resid > so->so_snd.sb_hiwat)
return (EMSGSIZE);
-restart:
- sblock(&so->so_snd);
+ dontroute =
+ (flags & MSG_DONTROUTE) && (so->so_options & SO_DONTROUTE) == 0 &&
+ (so->so_proto->pr_flags & PR_ATOMIC);
+ u.u_ru.ru_msgsnd++;
+ if (rights)
+ rlen = rights->m_len;
#define snderr(errno) { error = errno; splx(s); goto release; }
- u.u_ru.ru_msgsnd++;
-again:
- s = splnet();
- if (so->so_state & SS_CANTSENDMORE) {
- psignal(u.u_procp, SIGPIPE);
- snderr(EPIPE);
- }
- if (so->so_error) {
- error = so->so_error;
- so->so_error = 0; /* ??? */
- splx(s);
- goto release;
- }
- if ((so->so_state & SS_ISCONNECTED) == 0) {
- if (so->so_proto->pr_flags & PR_CONNREQUIRED)
- snderr(ENOTCONN);
- if (nam == 0)
- snderr(EDESTADDRREQ);
- }
- if (top) {
- error = (*so->so_proto->pr_usrreq)(so,
- (flags & SOF_OOB) ? PRU_SENDOOB : PRU_SEND,
- top, (caddr_t)nam, (struct socketopt *)0);
- top = 0;
- if (error) {
- splx(s);
- goto release;
- }
- mp = ⊤
- }
- if (uio->uio_resid == 0) {
- splx(s);
- goto release;
- }
- if (flags & SOF_OOB)
- space = 1024;
- else {
- space = sbspace(&so->so_snd);
- if (space <= 0 ||
- sosendallatonce(so) && space < uio->uio_resid) {
- if (so->so_state & SS_NBIO)
- snderr(EWOULDBLOCK);
- sbunlock(&so->so_snd);
- sbwait(&so->so_snd);
- splx(s);
- goto restart;
- }
- }
- splx(s);
- while (uio->uio_resid > 0 && space > 0) {
- register struct iovec *iov = uio->uio_iov;
-
- if (iov->iov_len == 0) {
- uio->uio_iov++;
- uio->uio_iovcnt--;
- if (uio->uio_iovcnt < 0)
- panic("sosend");
- continue;
+restart:
+ sblock(&so->so_snd);
+ do {
+ s = splnet();
+ if (so->so_state & SS_CANTSENDMORE)
+ snderr(EPIPE);
+ if (so->so_error)
+ snderr(so->so_error);
+ if ((so->so_state & SS_ISCONNECTED) == 0) {
+ if (so->so_proto->pr_flags & PR_CONNREQUIRED) {
+ if (!uio->uio_resid && !rights && control) {
+ snderr((*so->so_proto->pr_usrreq)(so,
+ (flags & MSG_OOB) ? PRU_SENDOOB : PRU_SEND,
+ top, (caddr_t)0, rights, control));
+ } else if (so->so_state & SS_ISCONFIRMING)
+ /* is ok */;
+ else
+ snderr(ENOTCONN);
+ } else if (nam == 0)
+ snderr(EDESTADDRREQ);
}
- MGET(m, 1);
- if (m == NULL) {
- error = ENOBUFS; /* SIGPIPE? */
- goto release;
+ if (flags & MSG_OOB)
+ space = 1024;
+ else {
+ space = sbspace(&so->so_snd);
+ if (space <= rlen ||
+ (atomic && space < uio->uio_resid + rlen) ||
+ (uio->uio_resid >= MCLBYTES && space < MCLBYTES &&
+ so->so_snd.sb_cc >= MCLBYTES &&
+ (so->so_state & SS_NBIO) == 0)) {
+ if (so->so_state & SS_NBIO) {
+ if (first)
+ error = EWOULDBLOCK;
+ splx(s);
+ goto release;
+ }
+ sbunlock(&so->so_snd);
+ sbwait(&so->so_snd);
+ splx(s);
+ goto restart;
+ }
}
- if (iov->iov_len >= CLBYTES && space >= CLBYTES) {
- register struct mbuf *p;
- MCLGET(p, 1);
- if (p == 0)
- goto nopages;
- m->m_off = (int)p - (int)m;
- len = CLBYTES;
- } else {
+ splx(s);
+ mp = ⊤
+ space -= rlen;
+ do {
+ do {
+ if (top == 0) {
+ MGETHDR(m, M_WAIT, MT_DATA);
+ mlen = MHLEN;
+ m->m_pkthdr.len = 0;
+ m->m_pkthdr.rcvif = (struct ifnet *)0;
+ } else {
+ MGET(m, M_WAIT, MT_DATA);
+ mlen = MLEN;
+ }
+ if (uio->uio_resid >= MINCLSIZE && space >= MCLBYTES) {
+ MCLGET(m, M_WAIT);
+ if ((m->m_flags & M_EXT) == 0)
+ goto nopages;
+ mlen = MCLBYTES;
+#ifdef MAPPED_MBUFS
+ len = min(MCLBYTES, uio->uio_resid);
+ if (len < mlen - max_hdr)
+ m->m_data += max_hdr;
+#else
+ len = min(MCLBYTES - max_hdr, uio->uio_resid);
+ m->m_data += max_hdr;
+#endif
+ space -= MCLBYTES;
+ } else {
nopages:
- len = MIN(MLEN, iov->iov_len);
- }
- (void) uiomove(mtod(m, caddr_t), len, UIO_WRITE, uio);
- m->m_len = len;
- *mp = m;
- mp = &m->m_next;
- if (flags & SOF_OOB)
- space -= len;
- else
- space = sbspace(&so->so_snd);
- }
- goto again;
+ len = min(min(mlen, uio->uio_resid), space);
+ space -= len;
+ /*
+ * For datagram protocols, leave room
+ * for protocol headers in first mbuf.
+ */
+ if (atomic && top == 0 && len < mlen)
+ MH_ALIGN(m, len);
+ }
+ error = uiomove(mtod(m, caddr_t), len, uio);
+ m->m_len = len;
+ *mp = m;
+ top->m_pkthdr.len += len;
+ if (error)
+ goto release;
+ mp = &m->m_next;
+ if (uio->uio_resid <= 0) {
+ if ((flags & MSG_EOR) && top)
+ top->m_flags |= M_EOR;
+ break;
+ }
+ } while (space > 0 && atomic);
+ if (dontroute)
+ so->so_options |= SO_DONTROUTE;
+ s = splnet(); /* XXX */
+ error = (*so->so_proto->pr_usrreq)(so,
+ (flags & MSG_OOB) ? PRU_SENDOOB : PRU_SEND,
+ top, (caddr_t)nam, rights, control);
+ splx(s);
+ if (dontroute)
+ so->so_options &= ~SO_DONTROUTE;
+ rights = 0;
+ rlen = 0;
+ top = 0;
+ mp = ⊤
+ first = 0;
+ if (error)
+ goto release;
+ } while (uio->uio_resid && space > 0);
+ } while (uio->uio_resid);
release:
sbunlock(&so->so_snd);
if (top)
m_freem(top);
+ if (error == EPIPE)
+ psignal(u.u_procp, SIGPIPE);
return (error);
}
-soreceive(so, aname, uio, flags)
+/*
+ * Implement receive operations on a socket.
+ * We depend on the way that records are added to the sockbuf
+ * by sbappend*. In particular, each record (mbufs linked through m_next)
+ * must begin with an address if the protocol so specifies,
+ * followed by an optional mbuf containing access rights if supported
+ * by the protocol, and then zero or more mbufs of data.
+ * In order to avoid blocking network interrupts for the entire time here,
+ * we splx() while doing the actual copy to user space.
+ * Although the sockbuf is locked, new data may still be appended,
+ * and thus we must maintain consistency of the sockbuf during that time.
+ */
+soreceive(so, aname, uio, flagsp, rightsp, controlp)
register struct socket *so;
struct mbuf **aname;
- struct uio *uio;
- int flags;
+ register struct uio *uio;
+ int *flagsp;
+ struct mbuf **rightsp, **controlp;
{
- register struct mbuf *m, *n;
- int len;
- int eor, s, error = 0, moff, tomark;
-
- if (flags & SOF_OOB) {
- m = m_get(M_WAIT);
- error = (*so->so_proto->pr_usrreq)(so, PRU_RCVOOB,
- m, (struct mbuf *)0, (struct socketopt *)0);
+ register struct mbuf *m;
+ register int flags, len, error = 0, s, offset;
+ struct protosw *pr = so->so_proto;
+ struct mbuf *nextrecord;
+ int moff;
+
+ if (rightsp)
+ *rightsp = 0;
+ if (aname)
+ *aname = 0;
+ if (controlp)
+ *controlp = 0;
+ if (flagsp)
+ flags = *flagsp &~ MSG_EOR;
+ else
+ flags = 0;
+ if (flags & MSG_OOB) {
+ m = m_get(M_WAIT, MT_DATA);
+ error = (*pr->pr_usrreq)(so, PRU_RCVOOB,
+ m, (struct mbuf *)(flags & MSG_PEEK), (struct mbuf *)0);
if (error)
- return (error);
- len = uio->uio_resid;
+ goto bad;
do {
+ len = uio->uio_resid;
if (len > m->m_len)
len = m->m_len;
- error =
- uiomove(mtod(m, caddr_t), (int)len, UIO_READ, uio);
+ error = uiomove(mtod(m, caddr_t), (int)len, uio);
m = m_free(m);
} while (uio->uio_resid && error == 0 && m);
+bad:
if (m)
m_freem(m);
return (error);
}
+ if (so->so_state & SS_ISCONFIRMING && uio->uio_resid)
+ (*pr->pr_usrreq)(so, PRU_RCVD, (struct mbuf *)0,
+ (struct mbuf *)0, (struct mbuf *)0);
restart:
sblock(&so->so_rcv);
s = splnet();
-SBCHECK(&so->so_rcv, "soreceive restart");
-#define rcverr(errno) { error = errno; splx(s); goto release; }
- if (so->so_rcv.sb_cc == 0) {
+ m = so->so_rcv.sb_mb;
+ if (m == 0) {
+ if (so->so_rcv.sb_cc)
+ panic("receive 1");
if (so->so_error) {
error = so->so_error;
so->so_error = 0;
- splx(s);
goto release;
}
- if (so->so_state & SS_CANTRCVMORE) {
- splx(s);
+ if (so->so_state & SS_CANTRCVMORE)
goto release;
- }
if ((so->so_state & SS_ISCONNECTED) == 0 &&
- (so->so_proto->pr_flags & PR_CONNREQUIRED))
- rcverr(ENOTCONN);
- if (so->so_state & SS_NBIO)
- rcverr(EWOULDBLOCK);
+ (so->so_proto->pr_flags & PR_CONNREQUIRED)) {
+ error = ENOTCONN;
+ goto release;
+ }
+ if (uio->uio_resid == 0)
+ goto release;
+ if (so->so_state & SS_NBIO) {
+ error = EWOULDBLOCK;
+ goto release;
+ }
sbunlock(&so->so_rcv);
sbwait(&so->so_rcv);
splx(s);
goto restart;
}
u.u_ru.ru_msgrcv++;
- m = so->so_rcv.sb_mb;
- if (m == 0)
- panic("receive");
-SBCHECK(&so->so_snd, "soreceive havecc");
- if (so->so_proto->pr_flags & PR_ADDR) {
- if ((flags & SOF_PREVIEW) == 0) {
- so->so_rcv.sb_cc -= m->m_len;
- so->so_rcv.sb_mbcnt -= MSIZE;
- }
- if (aname) {
- if (flags & SOF_PREVIEW)
+if (m->m_type == 0)
+panic("receive 3a");
+ nextrecord = m->m_nextpkt;
+ if (pr->pr_flags & PR_ADDR) {
+ if (m->m_type != MT_SONAME)
+ panic("receive 1a");
+ if (flags & MSG_PEEK) {
+ if (aname)
*aname = m_copy(m, 0, m->m_len);
- else
- *aname = m;
m = m->m_next;
- (*aname)->m_next = 0;
- } else
- if (flags & SOF_PREVIEW)
- m = m->m_next;
- else
- m = m_free(m);
- if (m == 0)
+ } else {
+ sbfree(&so->so_rcv, m);
+ if (aname) {
+ *aname = m;
+ so->so_rcv.sb_mb = m->m_next;
+ m->m_next = 0;
+ m = so->so_rcv.sb_mb;
+ } else {
+ MFREE(m, so->so_rcv.sb_mb);
+ m = so->so_rcv.sb_mb;
+ }
+ }
+ }
+ if (m && m->m_type == MT_RIGHTS) {
+ if ((pr->pr_flags & PR_RIGHTS) == 0)
panic("receive 2");
- if ((flags & SOF_PREVIEW) == 0)
- so->so_rcv.sb_mb = m;
-SBCHECK(&so->so_snd, "soreceive afteraddr");
+ if (flags & MSG_PEEK) {
+ if (rightsp)
+ *rightsp = m_copy(m, 0, m->m_len);
+ m = m->m_next;
+ } else {
+ sbfree(&so->so_rcv, m);
+ if (rightsp) {
+ *rightsp = m;
+ so->so_rcv.sb_mb = m->m_next;
+ m->m_next = 0;
+ m = so->so_rcv.sb_mb;
+ } else {
+ MFREE(m, so->so_rcv.sb_mb);
+ m = so->so_rcv.sb_mb;
+ }
+ }
+ }
+ if (m && m->m_type == MT_CONTROL) {
+ if (flags & MSG_PEEK) {
+ if (controlp)
+ *controlp = m_copy(m, 0, m->m_len);
+ m = m->m_next;
+ } else {
+ sbfree(&so->so_rcv, m);
+ if (controlp) {
+ *controlp = m;
+ so->so_rcv.sb_mb = m->m_next;
+ m->m_next = 0;
+ m = so->so_rcv.sb_mb;
+ } else {
+ MFREE(m, so->so_rcv.sb_mb);
+ m = so->so_rcv.sb_mb;
+ }
+ }
}
- eor = 0;
+ if (m)
+ m->m_nextpkt = nextrecord;
moff = 0;
- tomark = so->so_oobmark;
- do {
- if (uio->uio_resid <= 0)
- break;
+ offset = 0;
+ while (m && uio->uio_resid > 0 && error == 0) {
+ if (m->m_type == MT_OOBDATA)
+ flags |= MSG_OOB;
+ else if (m->m_type != MT_DATA && m->m_type != MT_HEADER)
+ panic("receive 3");
+ if (m->m_flags & M_EOR)
+ flags |= MSG_EOR;
len = uio->uio_resid;
so->so_state &= ~SS_RCVATMARK;
- if (tomark && len > tomark)
- len = tomark;
- if (moff+len > m->m_len - moff)
+ if (so->so_oobmark && len > so->so_oobmark - offset)
+ len = so->so_oobmark - offset;
+ if (len > m->m_len - moff)
len = m->m_len - moff;
splx(s);
- error =
- uiomove(mtod(m, caddr_t) + moff, (int)len, UIO_READ, uio);
+ error = uiomove(mtod(m, caddr_t) + moff, (int)len, uio);
s = splnet();
- if (len == m->m_len) {
- eor = (int)m->m_act;
- if (flags & SOF_PREVIEW)
+ if (len == m->m_len - moff) {
+ if (flags & MSG_PEEK) {
m = m->m_next;
- else {
+ moff = 0;
+ } else {
+ nextrecord = m->m_nextpkt;
sbfree(&so->so_rcv, m);
- MFREE(m, n);
- m = n;
- so->so_rcv.sb_mb = m;
+ MFREE(m, so->so_rcv.sb_mb);
+ m = so->so_rcv.sb_mb;
+ if (m)
+ m->m_nextpkt = nextrecord;
}
- moff = 0;
} else {
- if (flags & SOF_PREVIEW)
+ if (flags & MSG_PEEK)
moff += len;
else {
- m->m_off += len;
+ m->m_data += len;
m->m_len -= len;
so->so_rcv.sb_cc -= len;
}
}
- if ((flags & SOF_PREVIEW) == 0 && so->so_oobmark) {
- so->so_oobmark -= len;
- if (so->so_oobmark == 0) {
- so->so_state |= SS_RCVATMARK;
- break;
- }
+ if (so->so_oobmark) {
+ if ((flags & MSG_PEEK) == 0) {
+ so->so_oobmark -= len;
+ if (so->so_oobmark == 0) {
+ so->so_state |= SS_RCVATMARK;
+ break;
+ }
+ } else
+ offset += len;
}
- if (tomark) {
- tomark -= len;
- if (tomark == 0)
- break;
+ }
+ if (m && (flags & MSG_EOR)) {
+ flags &= ~MSG_EOR;
+ if ((flags & MSG_PEEK) == 0)
+ m->m_flags |= M_EOR;
+ }
+ if ((flags & MSG_PEEK) == 0) {
+ if (m == 0)
+ so->so_rcv.sb_mb = nextrecord;
+ else if (pr->pr_flags & PR_ATOMIC) {
+ flags |= MSG_TRUNC;
+ (void) sbdroprecord(&so->so_rcv);
}
-SBCHECK(&so->so_snd, "soreceive rcvloop");
- } while (m && error == 0 && !eor);
- if (flags & SOF_PREVIEW)
- goto release;
- if ((so->so_proto->pr_flags & PR_ATOMIC) && eor == 0)
- do {
- if (m == 0)
- panic("receive 3");
- sbfree(&so->so_rcv, m);
- eor = (int)m->m_act;
- so->so_rcv.sb_mb = m->m_next;
- MFREE(m, n);
- m = n;
-SBCHECK(&so->so_snd, "soreceive atomicloop");
- } while (eor == 0);
- if ((so->so_proto->pr_flags & PR_WANTRCVD) && so->so_pcb)
- (*so->so_proto->pr_usrreq)(so, PRU_RCVD,
- (struct mbuf *)0, (struct mbuf *)0, (struct socketopt *)0);
+ if (pr->pr_flags & PR_WANTRCVD && so->so_pcb)
+ (*pr->pr_usrreq)(so, PRU_RCVD, (struct mbuf *)0,
+ (struct mbuf *)flags, (struct mbuf *)0,
+ (struct mbuf *)0);
+ if (error == 0 && rightsp && *rightsp &&
+ pr->pr_domain->dom_externalize)
+ error = (*pr->pr_domain->dom_externalize)(*rightsp);
+ }
+ if (flagsp)
+ *flagsp |= flags;
release:
sbunlock(&so->so_rcv);
splx(s);
return (error);
}
-sohasoutofband(so)
- struct socket *so;
+soshutdown(so, how)
+ register struct socket *so;
+ register int how;
{
+ register struct protosw *pr = so->so_proto;
+
+ how++;
+ if (how & FREAD)
+ sorflush(so);
+ if (how & FWRITE)
+ return ((*pr->pr_usrreq)(so, PRU_SHUTDOWN,
+ (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0));
+ return (0);
+}
- if (so->so_pgrp == 0)
- return;
- if (so->so_pgrp > 0)
- gsignal(so->so_pgrp, SIGURG);
- else {
- struct proc *p = pfind(-so->so_pgrp);
-
- if (p)
- psignal(p, SIGURG);
- }
+sorflush(so)
+ register struct socket *so;
+{
+ register struct sockbuf *sb = &so->so_rcv;
+ register struct protosw *pr = so->so_proto;
+ register int s;
+ struct sockbuf asb;
+
+ sblock(sb);
+ s = splimp();
+ socantrcvmore(so);
+ sbunlock(sb);
+ asb = *sb;
+ bzero((caddr_t)sb, sizeof (*sb));
+ splx(s);
+ if (pr->pr_flags & PR_RIGHTS && pr->pr_domain->dom_dispose)
+ (*pr->pr_domain->dom_dispose)(asb.sb_mb);
+ sbrelease(&asb);
}
-/*ARGSUSED*/
-soioctl(so, cmd, data)
+sosetopt(so, level, optname, m0)
register struct socket *so;
- int cmd;
- register char *data;
+ int level, optname;
+ struct mbuf *m0;
{
+ int error = 0;
+ register struct mbuf *m = m0;
+
+ if (level != SOL_SOCKET) {
+ if (so->so_proto && so->so_proto->pr_ctloutput)
+ return ((*so->so_proto->pr_ctloutput)
+ (PRCO_SETOPT, so, level, optname, &m0));
+ error = ENOPROTOOPT;
+ } else {
+ switch (optname) {
+
+ case SO_LINGER:
+ if (m == NULL || m->m_len != sizeof (struct linger)) {
+ error = EINVAL;
+ goto bad;
+ }
+ so->so_linger = mtod(m, struct linger *)->l_linger;
+ /* fall thru... */
+
+ case SO_DEBUG:
+ case SO_KEEPALIVE:
+ case SO_DONTROUTE:
+ case SO_USELOOPBACK:
+ case SO_BROADCAST:
+ case SO_REUSEADDR:
+ case SO_OOBINLINE:
+ if (m == NULL || m->m_len < sizeof (int)) {
+ error = EINVAL;
+ goto bad;
+ }
+ if (*mtod(m, int *))
+ so->so_options |= optname;
+ else
+ so->so_options &= ~optname;
+ break;
+
+ case SO_SNDBUF:
+ case SO_RCVBUF:
+ case SO_SNDLOWAT:
+ case SO_RCVLOWAT:
+ case SO_SNDTIMEO:
+ case SO_RCVTIMEO:
+ if (m == NULL || m->m_len < sizeof (int)) {
+ error = EINVAL;
+ goto bad;
+ }
+ switch (optname) {
+
+ case SO_SNDBUF:
+ case SO_RCVBUF:
+ if (sbreserve(optname == SO_SNDBUF ?
+ &so->so_snd : &so->so_rcv,
+ (u_long) *mtod(m, int *)) == 0) {
+ error = ENOBUFS;
+ goto bad;
+ }
+ break;
- switch (cmd) {
-
- case FIONBIO:
- if (*(int *)data)
- so->so_state |= SS_NBIO;
- else
- so->so_state &= ~SS_NBIO;
- break;
-
- case FIOASYNC:
- if (*(int *)data)
- so->so_state |= SS_ASYNC;
- else
- so->so_state &= ~SS_ASYNC;
- break;
-
- case SIOCSKEEP:
- if (*(int *)data)
- so->so_options &= ~SO_KEEPALIVE;
- else
- so->so_options |= SO_KEEPALIVE;
- break;
-
- case SIOCGKEEP:
- *(int *)data = (so->so_options & SO_KEEPALIVE) != 0;
- break;
-
- case SIOCSLINGER:
- so->so_linger = *(int *)data;
- if (so->so_linger)
- so->so_options &= ~SO_DONTLINGER;
- else
- so->so_options |= SO_DONTLINGER;
- break;
-
- case SIOCGLINGER:
- *(int *)data = so->so_linger;
- break;
-
- case SIOCSPGRP:
- so->so_pgrp = *(int *)data;
- break;
-
- case SIOCGPGRP:
- *(int *)data = so->so_pgrp;
- break;
-
- case SIOCDONE: {
- int flags = *(int *)data;
-
- flags++;
- if (flags & FREAD) {
- int s = splimp();
- socantrcvmore(so);
- sbflush(&so->so_rcv);
- splx(s);
+ case SO_SNDLOWAT:
+ so->so_snd.sb_lowat = *mtod(m, int *);
+ break;
+ case SO_RCVLOWAT:
+ so->so_rcv.sb_lowat = *mtod(m, int *);
+ break;
+ case SO_SNDTIMEO:
+ so->so_snd.sb_timeo = *mtod(m, int *);
+ break;
+ case SO_RCVTIMEO:
+ so->so_rcv.sb_timeo = *mtod(m, int *);
+ break;
+ }
+ break;
+
+ default:
+ error = ENOPROTOOPT;
+ break;
}
- if (flags & FWRITE)
- return ((*so->so_proto->pr_usrreq)(so, PRU_SHUTDOWN,
- (struct mbuf *)0, (struct mbuf *)0,
- (struct socketopt *)0));
- break;
}
+bad:
+ if (m)
+ (void) m_free(m);
+ return (error);
+}
- case SIOCSENDOOB: {
- char oob = *(char *)data;
- struct mbuf *m = m_get(M_DONTWAIT);
+sogetopt(so, level, optname, mp)
+ register struct socket *so;
+ int level, optname;
+ struct mbuf **mp;
+{
+ register struct mbuf *m;
+
+ if (level != SOL_SOCKET) {
+ if (so->so_proto && so->so_proto->pr_ctloutput) {
+ return ((*so->so_proto->pr_ctloutput)
+ (PRCO_GETOPT, so, level, optname, mp));
+ } else
+ return (ENOPROTOOPT);
+ } else {
+ m = m_get(M_WAIT, MT_SOOPTS);
+ m->m_len = sizeof (int);
+
+ switch (optname) {
+
+ case SO_LINGER:
+ m->m_len = sizeof (struct linger);
+ mtod(m, struct linger *)->l_onoff =
+ so->so_options & SO_LINGER;
+ mtod(m, struct linger *)->l_linger = so->so_linger;
+ break;
- if (m == 0)
- return (ENOBUFS);
- m->m_len = 1;
- *mtod(m, char *) = oob;
- return ((*so->so_proto->pr_usrreq)(so, PRU_SENDOOB,
- m, (struct mbuf *)0, (struct socketopt *)0));
- }
+ case SO_USELOOPBACK:
+ case SO_DONTROUTE:
+ case SO_DEBUG:
+ case SO_KEEPALIVE:
+ case SO_REUSEADDR:
+ case SO_BROADCAST:
+ case SO_OOBINLINE:
+ *mtod(m, int *) = so->so_options & optname;
+ break;
- case SIOCRCVOOB: {
- struct mbuf *m = m_get(M_WAIT);
+ case SO_TYPE:
+ *mtod(m, int *) = so->so_type;
+ break;
- if (m == 0)
- return (ENOBUFS);
- *mtod(m, caddr_t) = 0;
- (*so->so_proto->pr_usrreq)(so, PRU_RCVOOB,
- m, (struct mbuf *)0, (struct socketopt *)0);
- *(char *)data = *mtod(m, char *);
- (void) m_free(m);
- break;
- }
+ case SO_ERROR:
+ *mtod(m, int *) = so->so_error;
+ so->so_error = 0;
+ break;
- case SIOCATMARK:
- *(int *)data = (so->so_state&SS_RCVATMARK) != 0;
- break;
+ case SO_SNDBUF:
+ *mtod(m, int *) = so->so_snd.sb_hiwat;
+ break;
- /* routing table update calls */
- case SIOCADDRT:
- case SIOCDELRT:
- if (!suser())
- return (u.u_error); /* XXX */
- return (rtrequest(cmd, (struct rtentry *)data));
+ case SO_RCVBUF:
+ *mtod(m, int *) = so->so_rcv.sb_hiwat;
+ break;
+
+ case SO_SNDLOWAT:
+ *mtod(m, int *) = so->so_snd.sb_lowat;
+ break;
- /* type/protocol specific ioctls */
- default:
- return (ENOTTY);
+ case SO_RCVLOWAT:
+ *mtod(m, int *) = so->so_rcv.sb_lowat;
+ break;
+
+ case SO_SNDTIMEO:
+ *mtod(m, int *) = so->so_snd.sb_timeo;
+ break;
+
+ case SO_RCVTIMEO:
+ *mtod(m, int *) = so->so_rcv.sb_timeo;
+ break;
+
+ default:
+ (void)m_free(m);
+ return (ENOPROTOOPT);
+ }
+ *mp = m;
+ return (0);
+ }
+}
+
+sohasoutofband(so)
+ register struct socket *so;
+{
+ struct proc *p;
+
+ if (so->so_pgid < 0)
+ gsignal(-so->so_pgid, SIGURG);
+ else if (so->so_pgid > 0 && (p = pfind(so->so_pgid)) != 0)
+ psignal(p, SIGURG);
+ if (so->so_rcv.sb_sel) {
+ selwakeup(so->so_rcv.sb_sel, so->so_rcv.sb_flags & SB_COLL);
+ so->so_rcv.sb_sel = 0;
+ so->so_rcv.sb_flags &= ~SB_COLL;
}
- return (0);
}