+ struct filedesc *fdp = p->p_fd;
+ struct socket *so;
+ struct file *fp;
+ int fd, error;
+
+ if (error = falloc(p, &fp, &fd))
+ return (error);
+ fp->f_flag = FREAD|FWRITE;
+ fp->f_type = DTYPE_SOCKET;
+ fp->f_ops = &socketops;
+ if (error = socreate(uap->domain, &so, uap->type, uap->protocol)) {
+ fdp->fd_ofiles[fd] = 0;
+ ffree(fp);
+ } else {
+ fp->f_data = (caddr_t)so;
+ *retval = fd;
+ }
+ return (error);
+}
+
+/* ARGSUSED */
+bind(p, uap, retval)
+ struct proc *p;
+ register struct args {
+ int s;
+ caddr_t name;
+ int namelen;
+ } *uap;
+ int *retval;
+{
+ struct file *fp;
+ struct mbuf *nam;
+ int error;
+
+ if (error = getsock(p->p_fd, uap->s, &fp))
+ return (error);
+ if (error = sockargs(&nam, uap->name, uap->namelen, MT_SONAME))
+ return (error);
+ error = sobind((struct socket *)fp->f_data, nam);
+ m_freem(nam);
+ return (error);
+}
+
+/* ARGSUSED */
+listen(p, uap, retval)
+ struct proc *p;
+ register struct args {
+ int s;
+ int backlog;
+ } *uap;
+ int *retval;
+{
+ struct file *fp;
+ int error;
+
+ if (error = getsock(p->p_fd, uap->s, &fp))
+ return (error);
+ return (solisten((struct socket *)fp->f_data, uap->backlog));
+}
+
+#ifdef COMPAT_43
+accept(p, uap, retval)
+ struct proc *p;
+ struct args {
+ int s;
+ caddr_t name;
+ int *anamelen;
+ int compat_43;
+ } *uap;
+ int *retval;
+{
+
+ uap->compat_43 = 0;
+ return (accept1(p, uap, retval));
+}
+
+oaccept(p, uap, retval)
+ struct proc *p;
+ struct args {
+ int s;
+ caddr_t name;
+ int *anamelen;
+ int compat_43;
+ } *uap;
+ int *retval;
+{
+
+ uap->compat_43 = 1;
+ return (accept1(p, uap, retval));
+}
+#else /* COMPAT_43 */
+
+#define accept1 accept
+#endif
+
+accept1(p, uap, retval)
+ struct proc *p;
+ register struct args {
+ int s;
+ caddr_t name;
+ int *anamelen;
+#ifdef COMPAT_43
+ int compat_43;
+#endif
+ } *uap;
+ int *retval;
+{
+ struct file *fp;
+ struct mbuf *nam;
+ int namelen, error, s;
+ register struct socket *so;
+
+ if (uap->name && (error = copyin((caddr_t)uap->anamelen,
+ (caddr_t)&namelen, sizeof (namelen))))
+ return (error);
+ if (error = getsock(p->p_fd, uap->s, &fp))
+ return (error);
+ s = splnet();
+ so = (struct socket *)fp->f_data;
+ if ((so->so_options & SO_ACCEPTCONN) == 0) {
+ splx(s);
+ return (EINVAL);
+ }
+ if ((so->so_state & SS_NBIO) && so->so_qlen == 0) {
+ splx(s);
+ return (EWOULDBLOCK);
+ }
+ while (so->so_qlen == 0 && so->so_error == 0) {
+ if (so->so_state & SS_CANTRCVMORE) {
+ so->so_error = ECONNABORTED;
+ break;
+ }
+ if (error = tsleep((caddr_t)&so->so_timeo, PSOCK | PCATCH,
+ netcon, 0)) {
+ splx(s);
+ return (error);
+ }
+ }
+ if (so->so_error) {
+ error = so->so_error;
+ so->so_error = 0;
+ splx(s);
+ return (error);
+ }
+ if (error = falloc(p, &fp, retval)) {
+ splx(s);
+ return (error);
+ }
+ { struct socket *aso = so->so_q;
+ if (soqremque(aso, 1) == 0)
+ panic("accept");
+ so = aso;
+ }
+ fp->f_type = DTYPE_SOCKET;
+ fp->f_flag = FREAD|FWRITE;
+ fp->f_ops = &socketops;
+ fp->f_data = (caddr_t)so;
+ nam = m_get(M_WAIT, MT_SONAME);
+ (void) soaccept(so, nam);
+ if (uap->name) {
+#ifdef COMPAT_43
+ if (uap->compat_43)
+ mtod(nam, struct osockaddr *)->sa_family =
+ mtod(nam, struct sockaddr *)->sa_family;
+#endif
+ if (namelen > nam->m_len)
+ namelen = nam->m_len;
+ /* SHOULD COPY OUT A CHAIN HERE */
+ if ((error = copyout(mtod(nam, caddr_t), (caddr_t)uap->name,
+ (u_int)namelen)) == 0)
+ error = copyout((caddr_t)&namelen,
+ (caddr_t)uap->anamelen, sizeof (*uap->anamelen));
+ }
+ m_freem(nam);
+ splx(s);
+ return (error);
+}
+
+/* ARGSUSED */
+connect(p, uap, retval)
+ struct proc *p;
+ register struct args {
+ int s;
+ caddr_t name;
+ int namelen;
+ } *uap;
+ int *retval;
+{
+ struct file *fp;
+ register struct socket *so;
+ struct mbuf *nam;
+ int error, s;
+
+ if (error = getsock(p->p_fd, uap->s, &fp))
+ return (error);
+ so = (struct socket *)fp->f_data;
+ if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING))
+ return (EALREADY);
+ if (error = sockargs(&nam, uap->name, uap->namelen, MT_SONAME))
+ return (error);
+ error = soconnect(so, nam);
+ if (error)
+ goto bad;
+ if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING)) {
+ m_freem(nam);
+ return (EINPROGRESS);
+ }
+ s = splnet();
+ while ((so->so_state & SS_ISCONNECTING) && so->so_error == 0)
+ if (error = tsleep((caddr_t)&so->so_timeo, PSOCK | PCATCH,
+ netcon, 0))
+ break;
+ if (error == 0) {
+ error = so->so_error;
+ so->so_error = 0;
+ }
+ splx(s);
+bad:
+ so->so_state &= ~SS_ISCONNECTING;
+ m_freem(nam);
+ if (error == ERESTART)
+ error = EINTR;
+ return (error);
+}
+
+socketpair(p, uap, retval)
+ struct proc *p;
+ register struct args {
+ int domain;
+ int type;
+ int protocol;
+ int *rsv;
+ } *uap;
+ int retval[];
+{
+ register struct filedesc *fdp = p->p_fd;
+ struct file *fp1, *fp2;
+ struct socket *so1, *so2;
+ int fd, error, sv[2];
+
+ if (error = socreate(uap->domain, &so1, uap->type, uap->protocol))
+ return (error);
+ if (error = socreate(uap->domain, &so2, uap->type, uap->protocol))
+ goto free1;
+ if (error = falloc(p, &fp1, &fd))