Home | History | Annotate | Line # | Download | only in kern
uipc_syscalls.c revision 1.36
      1  1.36     perry /*	$NetBSD: uipc_syscalls.c,v 1.36 1998/08/04 04:03:18 perry Exp $	*/
      2   1.8       cgd 
      3   1.1       cgd /*
      4   1.7   mycroft  * Copyright (c) 1982, 1986, 1989, 1990, 1993
      5   1.7   mycroft  *	The Regents of the University of California.  All rights reserved.
      6   1.1       cgd  *
      7   1.1       cgd  * Redistribution and use in source and binary forms, with or without
      8   1.1       cgd  * modification, are permitted provided that the following conditions
      9   1.1       cgd  * are met:
     10   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     11   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     12   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     14   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     15   1.1       cgd  * 3. All advertising materials mentioning features or use of this software
     16   1.1       cgd  *    must display the following acknowledgement:
     17   1.1       cgd  *	This product includes software developed by the University of
     18   1.1       cgd  *	California, Berkeley and its contributors.
     19   1.1       cgd  * 4. Neither the name of the University nor the names of its contributors
     20   1.1       cgd  *    may be used to endorse or promote products derived from this software
     21   1.1       cgd  *    without specific prior written permission.
     22   1.1       cgd  *
     23   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     24   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     25   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     26   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     27   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     28   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     29   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     30   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     31   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     32   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     33   1.1       cgd  * SUCH DAMAGE.
     34   1.1       cgd  *
     35  1.29      fvdl  *	@(#)uipc_syscalls.c	8.6 (Berkeley) 2/14/95
     36   1.1       cgd  */
     37  1.31   thorpej 
     38  1.31   thorpej #include "opt_ktrace.h"
     39   1.1       cgd 
     40   1.6   mycroft #include <sys/param.h>
     41   1.9       cgd #include <sys/systm.h>
     42   1.6   mycroft #include <sys/filedesc.h>
     43   1.6   mycroft #include <sys/proc.h>
     44   1.6   mycroft #include <sys/file.h>
     45   1.6   mycroft #include <sys/buf.h>
     46   1.6   mycroft #include <sys/malloc.h>
     47   1.6   mycroft #include <sys/mbuf.h>
     48   1.6   mycroft #include <sys/protosw.h>
     49   1.6   mycroft #include <sys/socket.h>
     50   1.6   mycroft #include <sys/socketvar.h>
     51  1.18  christos #include <sys/signalvar.h>
     52  1.18  christos #include <sys/un.h>
     53   1.1       cgd #ifdef KTRACE
     54   1.6   mycroft #include <sys/ktrace.h>
     55   1.1       cgd #endif
     56   1.1       cgd 
     57   1.9       cgd #include <sys/mount.h>
     58   1.9       cgd #include <sys/syscallargs.h>
     59   1.9       cgd 
     60   1.1       cgd /*
     61   1.1       cgd  * System call interface to the socket abstraction.
     62   1.1       cgd  */
     63   1.1       cgd extern	struct fileops socketops;
     64   1.1       cgd 
     65   1.7   mycroft int
     66  1.16   mycroft sys_socket(p, v, retval)
     67   1.1       cgd 	struct proc *p;
     68  1.15   thorpej 	void *v;
     69  1.15   thorpej 	register_t *retval;
     70  1.15   thorpej {
     71  1.16   mycroft 	register struct sys_socket_args /* {
     72   1.9       cgd 		syscallarg(int) domain;
     73   1.9       cgd 		syscallarg(int) type;
     74   1.9       cgd 		syscallarg(int) protocol;
     75  1.15   thorpej 	} */ *uap = v;
     76   1.1       cgd 	struct filedesc *fdp = p->p_fd;
     77   1.1       cgd 	struct socket *so;
     78   1.1       cgd 	struct file *fp;
     79   1.1       cgd 	int fd, error;
     80   1.1       cgd 
     81  1.18  christos 	if ((error = falloc(p, &fp, &fd)) != 0)
     82   1.1       cgd 		return (error);
     83   1.1       cgd 	fp->f_flag = FREAD|FWRITE;
     84   1.1       cgd 	fp->f_type = DTYPE_SOCKET;
     85   1.1       cgd 	fp->f_ops = &socketops;
     86  1.18  christos 	error = socreate(SCARG(uap, domain), &so, SCARG(uap, type),
     87  1.18  christos 			 SCARG(uap, protocol));
     88  1.18  christos 	if (error) {
     89   1.1       cgd 		fdp->fd_ofiles[fd] = 0;
     90   1.1       cgd 		ffree(fp);
     91   1.1       cgd 	} else {
     92   1.1       cgd 		fp->f_data = (caddr_t)so;
     93   1.1       cgd 		*retval = fd;
     94   1.1       cgd 	}
     95   1.1       cgd 	return (error);
     96   1.1       cgd }
     97   1.1       cgd 
     98   1.1       cgd /* ARGSUSED */
     99   1.7   mycroft int
    100  1.16   mycroft sys_bind(p, v, retval)
    101   1.1       cgd 	struct proc *p;
    102  1.15   thorpej 	void *v;
    103  1.15   thorpej 	register_t *retval;
    104  1.15   thorpej {
    105  1.16   mycroft 	register struct sys_bind_args /* {
    106   1.9       cgd 		syscallarg(int) s;
    107  1.23       cgd 		syscallarg(const struct sockaddr *) name;
    108   1.9       cgd 		syscallarg(int) namelen;
    109  1.15   thorpej 	} */ *uap = v;
    110   1.1       cgd 	struct file *fp;
    111   1.1       cgd 	struct mbuf *nam;
    112   1.1       cgd 	int error;
    113   1.1       cgd 
    114  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    115   1.1       cgd 		return (error);
    116  1.18  christos 	error = sockargs(&nam, SCARG(uap, name), SCARG(uap, namelen),
    117  1.23       cgd 	    MT_SONAME);
    118  1.18  christos 	if (error)
    119   1.1       cgd 		return (error);
    120   1.1       cgd 	error = sobind((struct socket *)fp->f_data, nam);
    121   1.1       cgd 	m_freem(nam);
    122   1.1       cgd 	return (error);
    123   1.1       cgd }
    124   1.1       cgd 
    125   1.1       cgd /* ARGSUSED */
    126   1.7   mycroft int
    127  1.16   mycroft sys_listen(p, v, retval)
    128   1.1       cgd 	struct proc *p;
    129  1.15   thorpej 	void *v;
    130  1.15   thorpej 	register_t *retval;
    131  1.15   thorpej {
    132  1.16   mycroft 	register struct sys_listen_args /* {
    133   1.9       cgd 		syscallarg(int) s;
    134   1.9       cgd 		syscallarg(int) backlog;
    135  1.15   thorpej 	} */ *uap = v;
    136   1.1       cgd 	struct file *fp;
    137   1.1       cgd 	int error;
    138   1.1       cgd 
    139  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    140   1.1       cgd 		return (error);
    141   1.9       cgd 	return (solisten((struct socket *)fp->f_data, SCARG(uap, backlog)));
    142   1.1       cgd }
    143   1.1       cgd 
    144   1.7   mycroft int
    145  1.16   mycroft sys_accept(p, v, retval)
    146   1.1       cgd 	struct proc *p;
    147  1.15   thorpej 	void *v;
    148  1.15   thorpej 	register_t *retval;
    149  1.15   thorpej {
    150  1.16   mycroft 	register struct sys_accept_args /* {
    151   1.9       cgd 		syscallarg(int) s;
    152  1.23       cgd 		syscallarg(struct sockaddr *) name;
    153   1.9       cgd 		syscallarg(int *) anamelen;
    154  1.15   thorpej 	} */ *uap = v;
    155   1.1       cgd 	struct file *fp;
    156   1.1       cgd 	struct mbuf *nam;
    157   1.9       cgd 	int namelen, error, s, tmpfd;
    158   1.1       cgd 	register struct socket *so;
    159   1.1       cgd 
    160   1.9       cgd 	if (SCARG(uap, name) && (error = copyin((caddr_t)SCARG(uap, anamelen),
    161  1.34     perry 	    (caddr_t)&namelen, sizeof(namelen))))
    162   1.1       cgd 		return (error);
    163  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    164   1.1       cgd 		return (error);
    165  1.14   mycroft 	s = splsoftnet();
    166   1.1       cgd 	so = (struct socket *)fp->f_data;
    167   1.1       cgd 	if ((so->so_options & SO_ACCEPTCONN) == 0) {
    168   1.1       cgd 		splx(s);
    169   1.1       cgd 		return (EINVAL);
    170   1.1       cgd 	}
    171   1.1       cgd 	if ((so->so_state & SS_NBIO) && so->so_qlen == 0) {
    172   1.1       cgd 		splx(s);
    173   1.1       cgd 		return (EWOULDBLOCK);
    174   1.1       cgd 	}
    175   1.1       cgd 	while (so->so_qlen == 0 && so->so_error == 0) {
    176   1.1       cgd 		if (so->so_state & SS_CANTRCVMORE) {
    177   1.1       cgd 			so->so_error = ECONNABORTED;
    178   1.1       cgd 			break;
    179   1.1       cgd 		}
    180  1.18  christos 		error = tsleep((caddr_t)&so->so_timeo, PSOCK | PCATCH,
    181  1.18  christos 			       netcon, 0);
    182  1.18  christos 		if (error) {
    183   1.1       cgd 			splx(s);
    184   1.1       cgd 			return (error);
    185   1.1       cgd 		}
    186   1.1       cgd 	}
    187   1.1       cgd 	if (so->so_error) {
    188   1.1       cgd 		error = so->so_error;
    189   1.1       cgd 		so->so_error = 0;
    190   1.1       cgd 		splx(s);
    191   1.1       cgd 		return (error);
    192   1.1       cgd 	}
    193  1.18  christos 	if ((error = falloc(p, &fp, &tmpfd)) != 0) {
    194   1.1       cgd 		splx(s);
    195   1.1       cgd 		return (error);
    196   1.1       cgd 	}
    197   1.9       cgd 	*retval = tmpfd;
    198  1.27   thorpej 	{ struct socket *aso = so->so_q.tqh_first;
    199   1.1       cgd 	  if (soqremque(aso, 1) == 0)
    200   1.1       cgd 		panic("accept");
    201   1.1       cgd 	  so = aso;
    202   1.1       cgd 	}
    203   1.1       cgd 	fp->f_type = DTYPE_SOCKET;
    204   1.1       cgd 	fp->f_flag = FREAD|FWRITE;
    205   1.1       cgd 	fp->f_ops = &socketops;
    206   1.1       cgd 	fp->f_data = (caddr_t)so;
    207   1.1       cgd 	nam = m_get(M_WAIT, MT_SONAME);
    208   1.1       cgd 	(void) soaccept(so, nam);
    209   1.9       cgd 	if (SCARG(uap, name)) {
    210   1.1       cgd 		if (namelen > nam->m_len)
    211   1.1       cgd 			namelen = nam->m_len;
    212   1.1       cgd 		/* SHOULD COPY OUT A CHAIN HERE */
    213   1.9       cgd 		if ((error = copyout(mtod(nam, caddr_t),
    214   1.9       cgd 		    (caddr_t)SCARG(uap, name), (u_int)namelen)) == 0)
    215   1.1       cgd 			error = copyout((caddr_t)&namelen,
    216   1.9       cgd 			    (caddr_t)SCARG(uap, anamelen),
    217  1.34     perry 			    sizeof(*SCARG(uap, anamelen)));
    218   1.1       cgd 	}
    219   1.1       cgd 	m_freem(nam);
    220   1.1       cgd 	splx(s);
    221   1.1       cgd 	return (error);
    222   1.1       cgd }
    223   1.1       cgd 
    224   1.1       cgd /* ARGSUSED */
    225   1.7   mycroft int
    226  1.16   mycroft sys_connect(p, v, retval)
    227   1.1       cgd 	struct proc *p;
    228  1.15   thorpej 	void *v;
    229  1.15   thorpej 	register_t *retval;
    230  1.15   thorpej {
    231  1.16   mycroft 	register struct sys_connect_args /* {
    232   1.9       cgd 		syscallarg(int) s;
    233  1.23       cgd 		syscallarg(const struct sockaddr *) name;
    234   1.9       cgd 		syscallarg(int) namelen;
    235  1.15   thorpej 	} */ *uap = v;
    236   1.1       cgd 	struct file *fp;
    237   1.1       cgd 	register struct socket *so;
    238   1.1       cgd 	struct mbuf *nam;
    239   1.1       cgd 	int error, s;
    240   1.1       cgd 
    241  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    242   1.1       cgd 		return (error);
    243   1.1       cgd 	so = (struct socket *)fp->f_data;
    244   1.1       cgd 	if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING))
    245   1.1       cgd 		return (EALREADY);
    246  1.18  christos 	error = sockargs(&nam, SCARG(uap, name), SCARG(uap, namelen),
    247  1.23       cgd 	    MT_SONAME);
    248  1.18  christos 	if (error)
    249   1.1       cgd 		return (error);
    250   1.1       cgd 	error = soconnect(so, nam);
    251   1.1       cgd 	if (error)
    252   1.1       cgd 		goto bad;
    253   1.1       cgd 	if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING)) {
    254   1.1       cgd 		m_freem(nam);
    255   1.1       cgd 		return (EINPROGRESS);
    256   1.1       cgd 	}
    257  1.14   mycroft 	s = splsoftnet();
    258  1.18  christos 	while ((so->so_state & SS_ISCONNECTING) && so->so_error == 0) {
    259  1.18  christos 		error = tsleep((caddr_t)&so->so_timeo, PSOCK | PCATCH,
    260  1.18  christos 			       netcon, 0);
    261  1.18  christos 		if (error)
    262   1.1       cgd 			break;
    263  1.18  christos 	}
    264   1.1       cgd 	if (error == 0) {
    265   1.1       cgd 		error = so->so_error;
    266   1.1       cgd 		so->so_error = 0;
    267   1.1       cgd 	}
    268   1.1       cgd 	splx(s);
    269   1.1       cgd bad:
    270   1.1       cgd 	so->so_state &= ~SS_ISCONNECTING;
    271   1.1       cgd 	m_freem(nam);
    272   1.1       cgd 	if (error == ERESTART)
    273   1.1       cgd 		error = EINTR;
    274   1.1       cgd 	return (error);
    275   1.1       cgd }
    276   1.1       cgd 
    277   1.7   mycroft int
    278  1.16   mycroft sys_socketpair(p, v, retval)
    279   1.1       cgd 	struct proc *p;
    280  1.15   thorpej 	void *v;
    281  1.15   thorpej 	register_t *retval;
    282  1.15   thorpej {
    283  1.16   mycroft 	register struct sys_socketpair_args /* {
    284   1.9       cgd 		syscallarg(int) domain;
    285   1.9       cgd 		syscallarg(int) type;
    286   1.9       cgd 		syscallarg(int) protocol;
    287   1.9       cgd 		syscallarg(int *) rsv;
    288  1.15   thorpej 	} */ *uap = v;
    289   1.1       cgd 	register struct filedesc *fdp = p->p_fd;
    290   1.1       cgd 	struct file *fp1, *fp2;
    291   1.1       cgd 	struct socket *so1, *so2;
    292   1.1       cgd 	int fd, error, sv[2];
    293   1.1       cgd 
    294  1.18  christos 	error = socreate(SCARG(uap, domain), &so1, SCARG(uap, type),
    295  1.18  christos 			 SCARG(uap, protocol));
    296  1.18  christos 	if (error)
    297   1.1       cgd 		return (error);
    298  1.18  christos 	error = socreate(SCARG(uap, domain), &so2, SCARG(uap, type),
    299  1.18  christos 			 SCARG(uap, protocol));
    300  1.18  christos 	if (error)
    301   1.1       cgd 		goto free1;
    302  1.18  christos 	if ((error = falloc(p, &fp1, &fd)) != 0)
    303   1.1       cgd 		goto free2;
    304   1.1       cgd 	sv[0] = fd;
    305   1.1       cgd 	fp1->f_flag = FREAD|FWRITE;
    306   1.1       cgd 	fp1->f_type = DTYPE_SOCKET;
    307   1.1       cgd 	fp1->f_ops = &socketops;
    308   1.1       cgd 	fp1->f_data = (caddr_t)so1;
    309  1.18  christos 	if ((error = falloc(p, &fp2, &fd)) != 0)
    310   1.1       cgd 		goto free3;
    311   1.1       cgd 	fp2->f_flag = FREAD|FWRITE;
    312   1.1       cgd 	fp2->f_type = DTYPE_SOCKET;
    313   1.1       cgd 	fp2->f_ops = &socketops;
    314   1.1       cgd 	fp2->f_data = (caddr_t)so2;
    315   1.1       cgd 	sv[1] = fd;
    316  1.18  christos 	if ((error = soconnect2(so1, so2)) != 0)
    317   1.1       cgd 		goto free4;
    318   1.9       cgd 	if (SCARG(uap, type) == SOCK_DGRAM) {
    319   1.1       cgd 		/*
    320   1.1       cgd 		 * Datagram socket connection is asymmetric.
    321   1.1       cgd 		 */
    322  1.18  christos 		 if ((error = soconnect2(so2, so1)) != 0)
    323   1.1       cgd 			goto free4;
    324   1.1       cgd 	}
    325   1.9       cgd 	error = copyout((caddr_t)sv, (caddr_t)SCARG(uap, rsv),
    326  1.34     perry 	    2 * sizeof(int));
    327   1.1       cgd 	return (error);
    328   1.1       cgd free4:
    329   1.1       cgd 	ffree(fp2);
    330   1.1       cgd 	fdp->fd_ofiles[sv[1]] = 0;
    331   1.1       cgd free3:
    332   1.1       cgd 	ffree(fp1);
    333   1.1       cgd 	fdp->fd_ofiles[sv[0]] = 0;
    334   1.1       cgd free2:
    335   1.1       cgd 	(void)soclose(so2);
    336   1.1       cgd free1:
    337   1.1       cgd 	(void)soclose(so1);
    338   1.1       cgd 	return (error);
    339   1.1       cgd }
    340   1.1       cgd 
    341   1.7   mycroft int
    342  1.16   mycroft sys_sendto(p, v, retval)
    343   1.1       cgd 	struct proc *p;
    344  1.15   thorpej 	void *v;
    345  1.15   thorpej 	register_t *retval;
    346  1.15   thorpej {
    347  1.16   mycroft 	register struct sys_sendto_args /* {
    348   1.9       cgd 		syscallarg(int) s;
    349  1.23       cgd 		syscallarg(const void *) buf;
    350   1.9       cgd 		syscallarg(size_t) len;
    351   1.9       cgd 		syscallarg(int) flags;
    352  1.23       cgd 		syscallarg(const struct sockaddr *) to;
    353   1.9       cgd 		syscallarg(int) tolen;
    354  1.15   thorpej 	} */ *uap = v;
    355   1.1       cgd 	struct msghdr msg;
    356   1.1       cgd 	struct iovec aiov;
    357   1.1       cgd 
    358  1.23       cgd 	msg.msg_name = (caddr_t)SCARG(uap, to);		/* XXX kills const */
    359   1.9       cgd 	msg.msg_namelen = SCARG(uap, tolen);
    360   1.1       cgd 	msg.msg_iov = &aiov;
    361   1.1       cgd 	msg.msg_iovlen = 1;
    362   1.1       cgd 	msg.msg_control = 0;
    363   1.7   mycroft #ifdef COMPAT_OLDSOCK
    364   1.1       cgd 	msg.msg_flags = 0;
    365   1.1       cgd #endif
    366  1.23       cgd 	aiov.iov_base = (char *)SCARG(uap, buf);	/* XXX kills const */
    367   1.9       cgd 	aiov.iov_len = SCARG(uap, len);
    368   1.9       cgd 	return (sendit(p, SCARG(uap, s), &msg, SCARG(uap, flags), retval));
    369   1.1       cgd }
    370   1.1       cgd 
    371   1.7   mycroft int
    372  1.16   mycroft sys_sendmsg(p, v, retval)
    373   1.1       cgd 	struct proc *p;
    374  1.15   thorpej 	void *v;
    375  1.15   thorpej 	register_t *retval;
    376  1.15   thorpej {
    377  1.16   mycroft 	register struct sys_sendmsg_args /* {
    378   1.9       cgd 		syscallarg(int) s;
    379  1.23       cgd 		syscallarg(const struct msghdr *) msg;
    380   1.9       cgd 		syscallarg(int) flags;
    381  1.15   thorpej 	} */ *uap = v;
    382   1.1       cgd 	struct msghdr msg;
    383   1.1       cgd 	struct iovec aiov[UIO_SMALLIOV], *iov;
    384   1.1       cgd 	int error;
    385   1.1       cgd 
    386  1.34     perry 	error = copyin(SCARG(uap, msg), (caddr_t)&msg, sizeof(msg));
    387  1.18  christos 	if (error)
    388   1.1       cgd 		return (error);
    389  1.35    kleink 	if ((u_int)msg.msg_iovlen > UIO_SMALLIOV) {
    390  1.35    kleink 		if ((u_int)msg.msg_iovlen > UIO_MAXIOV)
    391   1.1       cgd 			return (EMSGSIZE);
    392   1.1       cgd 		MALLOC(iov, struct iovec *,
    393   1.1       cgd 		       sizeof(struct iovec) * (u_int)msg.msg_iovlen, M_IOV,
    394   1.1       cgd 		       M_WAITOK);
    395   1.1       cgd 	} else
    396   1.1       cgd 		iov = aiov;
    397   1.1       cgd 	if (msg.msg_iovlen &&
    398   1.1       cgd 	    (error = copyin((caddr_t)msg.msg_iov, (caddr_t)iov,
    399  1.34     perry 	    (unsigned)(msg.msg_iovlen * sizeof(struct iovec)))))
    400   1.1       cgd 		goto done;
    401   1.1       cgd 	msg.msg_iov = iov;
    402   1.7   mycroft #ifdef COMPAT_OLDSOCK
    403   1.1       cgd 	msg.msg_flags = 0;
    404   1.1       cgd #endif
    405   1.9       cgd 	error = sendit(p, SCARG(uap, s), &msg, SCARG(uap, flags), retval);
    406   1.1       cgd done:
    407   1.1       cgd 	if (iov != aiov)
    408   1.1       cgd 		FREE(iov, M_IOV);
    409   1.1       cgd 	return (error);
    410   1.1       cgd }
    411   1.1       cgd 
    412   1.7   mycroft int
    413   1.1       cgd sendit(p, s, mp, flags, retsize)
    414   1.1       cgd 	register struct proc *p;
    415   1.1       cgd 	int s;
    416   1.1       cgd 	register struct msghdr *mp;
    417   1.9       cgd 	int flags;
    418   1.9       cgd 	register_t *retsize;
    419   1.1       cgd {
    420   1.1       cgd 	struct file *fp;
    421   1.1       cgd 	struct uio auio;
    422   1.1       cgd 	register struct iovec *iov;
    423   1.1       cgd 	register int i;
    424   1.1       cgd 	struct mbuf *to, *control;
    425   1.1       cgd 	int len, error;
    426  1.30      matt 	struct socket *so;
    427   1.1       cgd #ifdef KTRACE
    428   1.1       cgd 	struct iovec *ktriov = NULL;
    429   1.1       cgd #endif
    430   1.1       cgd 
    431  1.18  christos 	if ((error = getsock(p->p_fd, s, &fp)) != 0)
    432   1.1       cgd 		return (error);
    433   1.1       cgd 	auio.uio_iov = mp->msg_iov;
    434   1.1       cgd 	auio.uio_iovcnt = mp->msg_iovlen;
    435   1.1       cgd 	auio.uio_segflg = UIO_USERSPACE;
    436   1.1       cgd 	auio.uio_rw = UIO_WRITE;
    437   1.1       cgd 	auio.uio_procp = p;
    438   1.1       cgd 	auio.uio_offset = 0;			/* XXX */
    439   1.1       cgd 	auio.uio_resid = 0;
    440   1.1       cgd 	iov = mp->msg_iov;
    441   1.1       cgd 	for (i = 0; i < mp->msg_iovlen; i++, iov++) {
    442  1.18  christos #if 0
    443  1.18  christos 		/* cannot happen; iov_len is unsigned */
    444   1.1       cgd 		if (iov->iov_len < 0)
    445   1.1       cgd 			return (EINVAL);
    446  1.18  christos #endif
    447  1.33   thorpej 		/*
    448  1.33   thorpej 		 * Writes return ssize_t because -1 is returned on error.
    449  1.33   thorpej 		 * Therefore, we must restrict the length to SSIZE_MAX to
    450  1.33   thorpej 		 * avoid garbage return values.
    451  1.33   thorpej 		 */
    452  1.33   thorpej 		auio.uio_resid += iov->iov_len;
    453  1.33   thorpej 		if (iov->iov_len > SSIZE_MAX || auio.uio_resid > SSIZE_MAX)
    454   1.1       cgd 			return (EINVAL);
    455   1.1       cgd 	}
    456   1.1       cgd 	if (mp->msg_name) {
    457  1.18  christos 		error = sockargs(&to, mp->msg_name, mp->msg_namelen,
    458  1.18  christos 				 MT_SONAME);
    459  1.18  christos 		if (error)
    460   1.1       cgd 			return (error);
    461   1.1       cgd 	} else
    462   1.1       cgd 		to = 0;
    463   1.1       cgd 	if (mp->msg_control) {
    464   1.1       cgd 		if (mp->msg_controllen < sizeof(struct cmsghdr)
    465   1.7   mycroft #ifdef COMPAT_OLDSOCK
    466   1.1       cgd 		    && mp->msg_flags != MSG_COMPAT
    467   1.1       cgd #endif
    468   1.1       cgd 		) {
    469   1.1       cgd 			error = EINVAL;
    470   1.1       cgd 			goto bad;
    471   1.1       cgd 		}
    472  1.18  christos 		error = sockargs(&control, mp->msg_control,
    473  1.18  christos 				 mp->msg_controllen, MT_CONTROL);
    474  1.18  christos 		if (error)
    475   1.1       cgd 			goto bad;
    476   1.7   mycroft #ifdef COMPAT_OLDSOCK
    477   1.1       cgd 		if (mp->msg_flags == MSG_COMPAT) {
    478   1.1       cgd 			register struct cmsghdr *cm;
    479   1.1       cgd 
    480   1.1       cgd 			M_PREPEND(control, sizeof(*cm), M_WAIT);
    481   1.1       cgd 			if (control == 0) {
    482   1.1       cgd 				error = ENOBUFS;
    483   1.1       cgd 				goto bad;
    484   1.1       cgd 			} else {
    485   1.1       cgd 				cm = mtod(control, struct cmsghdr *);
    486   1.1       cgd 				cm->cmsg_len = control->m_len;
    487   1.1       cgd 				cm->cmsg_level = SOL_SOCKET;
    488   1.1       cgd 				cm->cmsg_type = SCM_RIGHTS;
    489   1.1       cgd 			}
    490   1.1       cgd 		}
    491   1.1       cgd #endif
    492   1.1       cgd 	} else
    493   1.1       cgd 		control = 0;
    494   1.1       cgd #ifdef KTRACE
    495   1.1       cgd 	if (KTRPOINT(p, KTR_GENIO)) {
    496  1.34     perry 		int iovlen = auio.uio_iovcnt * sizeof(struct iovec);
    497   1.1       cgd 
    498   1.1       cgd 		MALLOC(ktriov, struct iovec *, iovlen, M_TEMP, M_WAITOK);
    499  1.36     perry 		memcpy((caddr_t)ktriov, (caddr_t)auio.uio_iov, iovlen);
    500   1.1       cgd 	}
    501   1.1       cgd #endif
    502   1.1       cgd 	len = auio.uio_resid;
    503  1.30      matt 	so = (struct socket *)fp->f_data;
    504  1.30      matt 	error = (*so->so_send)(so, to, &auio, NULL, control, flags);
    505  1.18  christos 	if (error) {
    506   1.1       cgd 		if (auio.uio_resid != len && (error == ERESTART ||
    507   1.1       cgd 		    error == EINTR || error == EWOULDBLOCK))
    508   1.1       cgd 			error = 0;
    509   1.1       cgd 		if (error == EPIPE)
    510   1.1       cgd 			psignal(p, SIGPIPE);
    511   1.1       cgd 	}
    512   1.1       cgd 	if (error == 0)
    513   1.1       cgd 		*retsize = len - auio.uio_resid;
    514   1.1       cgd #ifdef KTRACE
    515   1.1       cgd 	if (ktriov != NULL) {
    516   1.1       cgd 		if (error == 0)
    517   1.1       cgd 			ktrgenio(p->p_tracep, s, UIO_WRITE,
    518   1.1       cgd 				ktriov, *retsize, error);
    519   1.1       cgd 		FREE(ktriov, M_TEMP);
    520   1.1       cgd 	}
    521   1.1       cgd #endif
    522   1.1       cgd bad:
    523   1.1       cgd 	if (to)
    524   1.1       cgd 		m_freem(to);
    525   1.1       cgd 	return (error);
    526   1.1       cgd }
    527   1.1       cgd 
    528   1.7   mycroft int
    529  1.16   mycroft sys_recvfrom(p, v, retval)
    530   1.1       cgd 	struct proc *p;
    531  1.15   thorpej 	void *v;
    532  1.15   thorpej 	register_t *retval;
    533  1.15   thorpej {
    534  1.16   mycroft 	register struct sys_recvfrom_args /* {
    535   1.9       cgd 		syscallarg(int) s;
    536  1.23       cgd 		syscallarg(void *) buf;
    537   1.9       cgd 		syscallarg(size_t) len;
    538   1.9       cgd 		syscallarg(int) flags;
    539  1.23       cgd 		syscallarg(struct sockaddr *) from;
    540   1.9       cgd 		syscallarg(int *) fromlenaddr;
    541  1.15   thorpej 	} */ *uap = v;
    542   1.1       cgd 	struct msghdr msg;
    543   1.1       cgd 	struct iovec aiov;
    544   1.1       cgd 	int error;
    545   1.1       cgd 
    546   1.9       cgd 	if (SCARG(uap, fromlenaddr)) {
    547  1.18  christos 		error = copyin((caddr_t)SCARG(uap, fromlenaddr),
    548  1.18  christos 			       (caddr_t)&msg.msg_namelen,
    549  1.34     perry 			       sizeof(msg.msg_namelen));
    550  1.18  christos 		if (error)
    551   1.1       cgd 			return (error);
    552   1.1       cgd 	} else
    553   1.1       cgd 		msg.msg_namelen = 0;
    554  1.23       cgd 	msg.msg_name = (caddr_t)SCARG(uap, from);
    555   1.1       cgd 	msg.msg_iov = &aiov;
    556   1.1       cgd 	msg.msg_iovlen = 1;
    557   1.9       cgd 	aiov.iov_base = SCARG(uap, buf);
    558   1.9       cgd 	aiov.iov_len = SCARG(uap, len);
    559   1.1       cgd 	msg.msg_control = 0;
    560   1.9       cgd 	msg.msg_flags = SCARG(uap, flags);
    561   1.9       cgd 	return (recvit(p, SCARG(uap, s), &msg,
    562  1.18  christos 		       (caddr_t)SCARG(uap, fromlenaddr), retval));
    563   1.1       cgd }
    564   1.1       cgd 
    565   1.7   mycroft int
    566  1.16   mycroft sys_recvmsg(p, v, retval)
    567   1.1       cgd 	struct proc *p;
    568  1.15   thorpej 	void *v;
    569  1.15   thorpej 	register_t *retval;
    570  1.15   thorpej {
    571  1.16   mycroft 	register struct sys_recvmsg_args /* {
    572   1.9       cgd 		syscallarg(int) s;
    573   1.9       cgd 		syscallarg(struct msghdr *) msg;
    574   1.9       cgd 		syscallarg(int) flags;
    575  1.15   thorpej 	} */ *uap = v;
    576   1.1       cgd 	struct msghdr msg;
    577   1.1       cgd 	struct iovec aiov[UIO_SMALLIOV], *uiov, *iov;
    578   1.1       cgd 	register int error;
    579   1.1       cgd 
    580  1.18  christos 	error = copyin((caddr_t)SCARG(uap, msg), (caddr_t)&msg,
    581  1.34     perry 		       sizeof(msg));
    582  1.18  christos 	if (error)
    583   1.1       cgd 		return (error);
    584  1.35    kleink 	if ((u_int)msg.msg_iovlen > UIO_SMALLIOV) {
    585  1.35    kleink 		if ((u_int)msg.msg_iovlen > UIO_MAXIOV)
    586   1.1       cgd 			return (EMSGSIZE);
    587   1.1       cgd 		MALLOC(iov, struct iovec *,
    588   1.1       cgd 		       sizeof(struct iovec) * (u_int)msg.msg_iovlen, M_IOV,
    589   1.1       cgd 		       M_WAITOK);
    590   1.1       cgd 	} else
    591   1.1       cgd 		iov = aiov;
    592   1.7   mycroft #ifdef COMPAT_OLDSOCK
    593   1.9       cgd 	msg.msg_flags = SCARG(uap, flags) &~ MSG_COMPAT;
    594   1.1       cgd #else
    595   1.9       cgd 	msg.msg_flags = SCARG(uap, flags);
    596   1.1       cgd #endif
    597   1.1       cgd 	uiov = msg.msg_iov;
    598   1.1       cgd 	msg.msg_iov = iov;
    599  1.18  christos 	error = copyin((caddr_t)uiov, (caddr_t)iov,
    600  1.34     perry 		       (unsigned)(msg.msg_iovlen * sizeof(struct iovec)));
    601  1.18  christos 	if (error)
    602   1.1       cgd 		goto done;
    603   1.9       cgd 	if ((error = recvit(p, SCARG(uap, s), &msg, (caddr_t)0, retval)) == 0) {
    604   1.1       cgd 		msg.msg_iov = uiov;
    605   1.9       cgd 		error = copyout((caddr_t)&msg, (caddr_t)SCARG(uap, msg),
    606   1.9       cgd 		    sizeof(msg));
    607   1.1       cgd 	}
    608   1.1       cgd done:
    609   1.1       cgd 	if (iov != aiov)
    610   1.1       cgd 		FREE(iov, M_IOV);
    611   1.1       cgd 	return (error);
    612   1.1       cgd }
    613   1.1       cgd 
    614   1.7   mycroft int
    615   1.1       cgd recvit(p, s, mp, namelenp, retsize)
    616   1.1       cgd 	register struct proc *p;
    617   1.1       cgd 	int s;
    618   1.1       cgd 	register struct msghdr *mp;
    619   1.1       cgd 	caddr_t namelenp;
    620   1.9       cgd 	register_t *retsize;
    621   1.1       cgd {
    622   1.1       cgd 	struct file *fp;
    623   1.1       cgd 	struct uio auio;
    624   1.1       cgd 	register struct iovec *iov;
    625   1.1       cgd 	register int i;
    626   1.1       cgd 	int len, error;
    627   1.1       cgd 	struct mbuf *from = 0, *control = 0;
    628  1.30      matt 	struct socket *so;
    629   1.1       cgd #ifdef KTRACE
    630   1.1       cgd 	struct iovec *ktriov = NULL;
    631   1.1       cgd #endif
    632   1.1       cgd 
    633  1.18  christos 	if ((error = getsock(p->p_fd, s, &fp)) != 0)
    634   1.1       cgd 		return (error);
    635   1.1       cgd 	auio.uio_iov = mp->msg_iov;
    636   1.1       cgd 	auio.uio_iovcnt = mp->msg_iovlen;
    637   1.1       cgd 	auio.uio_segflg = UIO_USERSPACE;
    638   1.1       cgd 	auio.uio_rw = UIO_READ;
    639   1.1       cgd 	auio.uio_procp = p;
    640   1.1       cgd 	auio.uio_offset = 0;			/* XXX */
    641   1.1       cgd 	auio.uio_resid = 0;
    642   1.1       cgd 	iov = mp->msg_iov;
    643   1.1       cgd 	for (i = 0; i < mp->msg_iovlen; i++, iov++) {
    644  1.18  christos #if 0
    645  1.18  christos 		/* cannot happen iov_len is unsigned */
    646   1.1       cgd 		if (iov->iov_len < 0)
    647   1.1       cgd 			return (EINVAL);
    648  1.18  christos #endif
    649  1.33   thorpej 		/*
    650  1.33   thorpej 		 * Reads return ssize_t because -1 is returned on error.
    651  1.33   thorpej 		 * Therefore we must restrict the length to SSIZE_MAX to
    652  1.33   thorpej 		 * avoid garbage return values.
    653  1.33   thorpej 		 */
    654  1.33   thorpej 		auio.uio_resid += iov->iov_len;
    655  1.33   thorpej 		if (iov->iov_len > SSIZE_MAX || auio.uio_resid > SSIZE_MAX)
    656   1.1       cgd 			return (EINVAL);
    657   1.1       cgd 	}
    658   1.1       cgd #ifdef KTRACE
    659   1.1       cgd 	if (KTRPOINT(p, KTR_GENIO)) {
    660  1.34     perry 		int iovlen = auio.uio_iovcnt * sizeof(struct iovec);
    661   1.1       cgd 
    662   1.1       cgd 		MALLOC(ktriov, struct iovec *, iovlen, M_TEMP, M_WAITOK);
    663  1.36     perry 		memcpy((caddr_t)ktriov, (caddr_t)auio.uio_iov, iovlen);
    664   1.1       cgd 	}
    665   1.1       cgd #endif
    666   1.1       cgd 	len = auio.uio_resid;
    667  1.30      matt 	so = (struct socket *)fp->f_data;
    668  1.30      matt 	error = (*so->so_receive)(so, &from, &auio, NULL,
    669  1.30      matt 			  mp->msg_control ? &control : NULL, &mp->msg_flags);
    670  1.18  christos 	if (error) {
    671   1.1       cgd 		if (auio.uio_resid != len && (error == ERESTART ||
    672   1.1       cgd 		    error == EINTR || error == EWOULDBLOCK))
    673   1.1       cgd 			error = 0;
    674   1.1       cgd 	}
    675   1.1       cgd #ifdef KTRACE
    676   1.1       cgd 	if (ktriov != NULL) {
    677   1.1       cgd 		if (error == 0)
    678   1.1       cgd 			ktrgenio(p->p_tracep, s, UIO_READ,
    679   1.1       cgd 				ktriov, len - auio.uio_resid, error);
    680   1.1       cgd 		FREE(ktriov, M_TEMP);
    681   1.1       cgd 	}
    682   1.1       cgd #endif
    683   1.1       cgd 	if (error)
    684   1.1       cgd 		goto out;
    685   1.1       cgd 	*retsize = len - auio.uio_resid;
    686   1.1       cgd 	if (mp->msg_name) {
    687   1.1       cgd 		len = mp->msg_namelen;
    688   1.1       cgd 		if (len <= 0 || from == 0)
    689   1.1       cgd 			len = 0;
    690   1.1       cgd 		else {
    691   1.7   mycroft #ifdef COMPAT_OLDSOCK
    692   1.1       cgd 			if (mp->msg_flags & MSG_COMPAT)
    693   1.1       cgd 				mtod(from, struct osockaddr *)->sa_family =
    694   1.1       cgd 				    mtod(from, struct sockaddr *)->sa_family;
    695   1.1       cgd #endif
    696   1.1       cgd 			if (len > from->m_len)
    697   1.1       cgd 				len = from->m_len;
    698   1.1       cgd 			/* else if len < from->m_len ??? */
    699  1.18  christos 			error = copyout(mtod(from, caddr_t),
    700  1.18  christos 					(caddr_t)mp->msg_name, (unsigned)len);
    701  1.18  christos 			if (error)
    702   1.1       cgd 				goto out;
    703   1.1       cgd 		}
    704   1.1       cgd 		mp->msg_namelen = len;
    705   1.1       cgd 		if (namelenp &&
    706  1.34     perry 		    (error = copyout((caddr_t)&len, namelenp, sizeof(int)))) {
    707   1.7   mycroft #ifdef COMPAT_OLDSOCK
    708   1.1       cgd 			if (mp->msg_flags & MSG_COMPAT)
    709   1.1       cgd 				error = 0;	/* old recvfrom didn't check */
    710   1.1       cgd 			else
    711   1.1       cgd #endif
    712   1.1       cgd 			goto out;
    713   1.1       cgd 		}
    714   1.1       cgd 	}
    715   1.1       cgd 	if (mp->msg_control) {
    716   1.7   mycroft #ifdef COMPAT_OLDSOCK
    717   1.1       cgd 		/*
    718   1.1       cgd 		 * We assume that old recvmsg calls won't receive access
    719   1.1       cgd 		 * rights and other control info, esp. as control info
    720   1.1       cgd 		 * is always optional and those options didn't exist in 4.3.
    721   1.1       cgd 		 * If we receive rights, trim the cmsghdr; anything else
    722   1.1       cgd 		 * is tossed.
    723   1.1       cgd 		 */
    724   1.1       cgd 		if (control && mp->msg_flags & MSG_COMPAT) {
    725   1.1       cgd 			if (mtod(control, struct cmsghdr *)->cmsg_level !=
    726   1.1       cgd 			    SOL_SOCKET ||
    727   1.1       cgd 			    mtod(control, struct cmsghdr *)->cmsg_type !=
    728   1.1       cgd 			    SCM_RIGHTS) {
    729   1.1       cgd 				mp->msg_controllen = 0;
    730   1.1       cgd 				goto out;
    731   1.1       cgd 			}
    732  1.34     perry 			control->m_len -= sizeof(struct cmsghdr);
    733  1.34     perry 			control->m_data += sizeof(struct cmsghdr);
    734   1.1       cgd 		}
    735   1.1       cgd #endif
    736   1.1       cgd 		len = mp->msg_controllen;
    737   1.1       cgd 		if (len <= 0 || control == 0)
    738   1.1       cgd 			len = 0;
    739   1.1       cgd 		else {
    740  1.26   thorpej 			struct mbuf *m = control;
    741  1.26   thorpej 			caddr_t p = (caddr_t)mp->msg_control;
    742  1.26   thorpej 
    743  1.28   thorpej 			do {
    744  1.26   thorpej 				i = m->m_len;
    745  1.26   thorpej 				if (len < i) {
    746  1.26   thorpej 					mp->msg_flags |= MSG_CTRUNC;
    747  1.26   thorpej 					i = len;
    748  1.26   thorpej 				}
    749  1.26   thorpej 				error = copyout(mtod(m, caddr_t), p,
    750  1.26   thorpej 				    (unsigned)i);
    751  1.28   thorpej 				if (m->m_next)
    752  1.28   thorpej 					i = ALIGN(i);
    753  1.26   thorpej 				p += i;
    754  1.26   thorpej 				len -= i;
    755  1.26   thorpej 				if (error != 0 || len <= 0)
    756  1.26   thorpej 					break;
    757  1.28   thorpej 			} while ((m = m->m_next) != NULL);
    758  1.26   thorpej 			len = p - (caddr_t)mp->msg_control;
    759   1.1       cgd 		}
    760   1.1       cgd 		mp->msg_controllen = len;
    761   1.1       cgd 	}
    762   1.1       cgd out:
    763   1.1       cgd 	if (from)
    764   1.1       cgd 		m_freem(from);
    765   1.1       cgd 	if (control)
    766   1.1       cgd 		m_freem(control);
    767   1.1       cgd 	return (error);
    768   1.1       cgd }
    769   1.1       cgd 
    770   1.1       cgd /* ARGSUSED */
    771   1.7   mycroft int
    772  1.16   mycroft sys_shutdown(p, v, retval)
    773   1.1       cgd 	struct proc *p;
    774  1.15   thorpej 	void *v;
    775  1.15   thorpej 	register_t *retval;
    776  1.15   thorpej {
    777  1.16   mycroft 	register struct sys_shutdown_args /* {
    778   1.9       cgd 		syscallarg(int) s;
    779   1.9       cgd 		syscallarg(int) how;
    780  1.15   thorpej 	} */ *uap = v;
    781   1.1       cgd 	struct file *fp;
    782   1.1       cgd 	int error;
    783   1.1       cgd 
    784  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    785   1.1       cgd 		return (error);
    786   1.9       cgd 	return (soshutdown((struct socket *)fp->f_data, SCARG(uap, how)));
    787   1.1       cgd }
    788   1.1       cgd 
    789   1.1       cgd /* ARGSUSED */
    790   1.7   mycroft int
    791  1.16   mycroft sys_setsockopt(p, v, retval)
    792   1.1       cgd 	struct proc *p;
    793  1.15   thorpej 	void *v;
    794  1.15   thorpej 	register_t *retval;
    795  1.15   thorpej {
    796  1.16   mycroft 	register struct sys_setsockopt_args /* {
    797   1.9       cgd 		syscallarg(int) s;
    798   1.9       cgd 		syscallarg(int) level;
    799   1.9       cgd 		syscallarg(int) name;
    800  1.23       cgd 		syscallarg(const void *) val;
    801   1.9       cgd 		syscallarg(int) valsize;
    802  1.15   thorpej 	} */ *uap = v;
    803   1.1       cgd 	struct file *fp;
    804   1.1       cgd 	struct mbuf *m = NULL;
    805   1.1       cgd 	int error;
    806   1.1       cgd 
    807  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    808   1.1       cgd 		return (error);
    809   1.9       cgd 	if (SCARG(uap, valsize) > MLEN)
    810   1.1       cgd 		return (EINVAL);
    811   1.9       cgd 	if (SCARG(uap, val)) {
    812   1.1       cgd 		m = m_get(M_WAIT, MT_SOOPTS);
    813  1.18  christos 		error = copyin(SCARG(uap, val), mtod(m, caddr_t),
    814  1.18  christos 			       (u_int)SCARG(uap, valsize));
    815  1.18  christos 		if (error) {
    816   1.1       cgd 			(void) m_free(m);
    817   1.1       cgd 			return (error);
    818   1.1       cgd 		}
    819   1.9       cgd 		m->m_len = SCARG(uap, valsize);
    820   1.1       cgd 	}
    821   1.9       cgd 	return (sosetopt((struct socket *)fp->f_data, SCARG(uap, level),
    822  1.18  christos 			 SCARG(uap, name), m));
    823   1.1       cgd }
    824   1.1       cgd 
    825   1.1       cgd /* ARGSUSED */
    826   1.7   mycroft int
    827  1.16   mycroft sys_getsockopt(p, v, retval)
    828   1.1       cgd 	struct proc *p;
    829  1.15   thorpej 	void *v;
    830  1.15   thorpej 	register_t *retval;
    831  1.15   thorpej {
    832  1.16   mycroft 	register struct sys_getsockopt_args /* {
    833   1.9       cgd 		syscallarg(int) s;
    834   1.9       cgd 		syscallarg(int) level;
    835   1.9       cgd 		syscallarg(int) name;
    836  1.23       cgd 		syscallarg(void *) val;
    837   1.9       cgd 		syscallarg(int *) avalsize;
    838  1.15   thorpej 	} */ *uap = v;
    839   1.1       cgd 	struct file *fp;
    840   1.1       cgd 	struct mbuf *m = NULL;
    841   1.1       cgd 	int valsize, error;
    842   1.1       cgd 
    843  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, s), &fp)) != 0)
    844   1.1       cgd 		return (error);
    845   1.9       cgd 	if (SCARG(uap, val)) {
    846  1.18  christos 		error = copyin((caddr_t)SCARG(uap, avalsize),
    847  1.34     perry 			       (caddr_t)&valsize, sizeof(valsize));
    848  1.18  christos 		if (error)
    849   1.1       cgd 			return (error);
    850   1.1       cgd 	} else
    851   1.1       cgd 		valsize = 0;
    852   1.9       cgd 	if ((error = sogetopt((struct socket *)fp->f_data, SCARG(uap, level),
    853   1.9       cgd 	    SCARG(uap, name), &m)) == 0 && SCARG(uap, val) && valsize &&
    854   1.9       cgd 	    m != NULL) {
    855   1.1       cgd 		if (valsize > m->m_len)
    856   1.1       cgd 			valsize = m->m_len;
    857   1.9       cgd 		error = copyout(mtod(m, caddr_t), SCARG(uap, val),
    858   1.9       cgd 		    (u_int)valsize);
    859   1.1       cgd 		if (error == 0)
    860   1.1       cgd 			error = copyout((caddr_t)&valsize,
    861  1.34     perry 			    (caddr_t)SCARG(uap, avalsize), sizeof(valsize));
    862   1.1       cgd 	}
    863   1.1       cgd 	if (m != NULL)
    864   1.1       cgd 		(void) m_free(m);
    865   1.1       cgd 	return (error);
    866   1.1       cgd }
    867   1.1       cgd 
    868   1.1       cgd /* ARGSUSED */
    869   1.7   mycroft int
    870  1.16   mycroft sys_pipe(p, v, retval)
    871   1.1       cgd 	struct proc *p;
    872  1.16   mycroft 	void *v;
    873   1.9       cgd 	register_t *retval;
    874   1.1       cgd {
    875   1.1       cgd 	register struct filedesc *fdp = p->p_fd;
    876   1.1       cgd 	struct file *rf, *wf;
    877   1.1       cgd 	struct socket *rso, *wso;
    878   1.1       cgd 	int fd, error;
    879   1.1       cgd 
    880  1.32     lukem 	if ((error = socreate(AF_LOCAL, &rso, SOCK_STREAM, 0)) != 0)
    881   1.1       cgd 		return (error);
    882  1.32     lukem 	if ((error = socreate(AF_LOCAL, &wso, SOCK_STREAM, 0)) != 0)
    883   1.1       cgd 		goto free1;
    884  1.18  christos 	if ((error = falloc(p, &rf, &fd)) != 0)
    885   1.1       cgd 		goto free2;
    886   1.1       cgd 	retval[0] = fd;
    887   1.1       cgd 	rf->f_flag = FREAD;
    888   1.1       cgd 	rf->f_type = DTYPE_SOCKET;
    889   1.1       cgd 	rf->f_ops = &socketops;
    890   1.1       cgd 	rf->f_data = (caddr_t)rso;
    891  1.18  christos 	if ((error = falloc(p, &wf, &fd)) != 0)
    892   1.1       cgd 		goto free3;
    893   1.1       cgd 	wf->f_flag = FWRITE;
    894   1.1       cgd 	wf->f_type = DTYPE_SOCKET;
    895   1.1       cgd 	wf->f_ops = &socketops;
    896   1.1       cgd 	wf->f_data = (caddr_t)wso;
    897   1.1       cgd 	retval[1] = fd;
    898  1.18  christos 	if ((error = unp_connect2(wso, rso)) != 0)
    899   1.1       cgd 		goto free4;
    900   1.1       cgd 	return (0);
    901   1.1       cgd free4:
    902   1.1       cgd 	ffree(wf);
    903   1.1       cgd 	fdp->fd_ofiles[retval[1]] = 0;
    904   1.1       cgd free3:
    905   1.1       cgd 	ffree(rf);
    906   1.1       cgd 	fdp->fd_ofiles[retval[0]] = 0;
    907   1.1       cgd free2:
    908   1.1       cgd 	(void)soclose(wso);
    909   1.1       cgd free1:
    910   1.1       cgd 	(void)soclose(rso);
    911   1.1       cgd 	return (error);
    912   1.1       cgd }
    913   1.1       cgd 
    914   1.1       cgd /*
    915   1.1       cgd  * Get socket name.
    916   1.1       cgd  */
    917  1.13  christos /* ARGSUSED */
    918   1.7   mycroft int
    919  1.16   mycroft sys_getsockname(p, v, retval)
    920   1.1       cgd 	struct proc *p;
    921  1.15   thorpej 	void *v;
    922  1.15   thorpej 	register_t *retval;
    923  1.15   thorpej {
    924  1.16   mycroft 	register struct sys_getsockname_args /* {
    925   1.9       cgd 		syscallarg(int) fdes;
    926  1.23       cgd 		syscallarg(struct sockaddr *) asa;
    927   1.9       cgd 		syscallarg(int *) alen;
    928  1.15   thorpej 	} */ *uap = v;
    929   1.1       cgd 	struct file *fp;
    930   1.1       cgd 	register struct socket *so;
    931   1.1       cgd 	struct mbuf *m;
    932   1.1       cgd 	int len, error;
    933   1.1       cgd 
    934  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, fdes), &fp)) != 0)
    935   1.1       cgd 		return (error);
    936  1.34     perry 	error = copyin((caddr_t)SCARG(uap, alen), (caddr_t)&len, sizeof(len));
    937  1.18  christos 	if (error)
    938   1.1       cgd 		return (error);
    939   1.1       cgd 	so = (struct socket *)fp->f_data;
    940   1.1       cgd 	m = m_getclr(M_WAIT, MT_SONAME);
    941  1.21   mycroft 	error = (*so->so_proto->pr_usrreq)(so, PRU_SOCKADDR, (struct mbuf *)0,
    942  1.21   mycroft 	    m, (struct mbuf *)0, (struct proc *)0);
    943  1.18  christos 	if (error)
    944   1.1       cgd 		goto bad;
    945   1.1       cgd 	if (len > m->m_len)
    946   1.1       cgd 		len = m->m_len;
    947   1.9       cgd 	error = copyout(mtod(m, caddr_t), (caddr_t)SCARG(uap, asa), (u_int)len);
    948   1.1       cgd 	if (error == 0)
    949   1.9       cgd 		error = copyout((caddr_t)&len, (caddr_t)SCARG(uap, alen),
    950  1.34     perry 		    sizeof(len));
    951   1.1       cgd bad:
    952   1.1       cgd 	m_freem(m);
    953   1.1       cgd 	return (error);
    954   1.1       cgd }
    955   1.1       cgd 
    956   1.1       cgd /*
    957   1.1       cgd  * Get name of peer for connected socket.
    958   1.1       cgd  */
    959  1.13  christos /* ARGSUSED */
    960   1.7   mycroft int
    961  1.16   mycroft sys_getpeername(p, v, retval)
    962   1.1       cgd 	struct proc *p;
    963  1.15   thorpej 	void *v;
    964  1.15   thorpej 	register_t *retval;
    965  1.15   thorpej {
    966  1.16   mycroft 	register struct sys_getpeername_args /* {
    967   1.9       cgd 		syscallarg(int) fdes;
    968  1.23       cgd 		syscallarg(struct sockaddr *) asa;
    969   1.9       cgd 		syscallarg(int *) alen;
    970  1.15   thorpej 	} */ *uap = v;
    971   1.1       cgd 	struct file *fp;
    972   1.1       cgd 	register struct socket *so;
    973   1.1       cgd 	struct mbuf *m;
    974   1.1       cgd 	int len, error;
    975   1.1       cgd 
    976  1.18  christos 	if ((error = getsock(p->p_fd, SCARG(uap, fdes), &fp)) != 0)
    977   1.1       cgd 		return (error);
    978   1.1       cgd 	so = (struct socket *)fp->f_data;
    979   1.1       cgd 	if ((so->so_state & (SS_ISCONNECTED|SS_ISCONFIRMING)) == 0)
    980   1.1       cgd 		return (ENOTCONN);
    981  1.34     perry 	error = copyin((caddr_t)SCARG(uap, alen), (caddr_t)&len, sizeof(len));
    982  1.18  christos 	if (error)
    983   1.7   mycroft 		return (error);
    984   1.1       cgd 	m = m_getclr(M_WAIT, MT_SONAME);
    985  1.21   mycroft 	error = (*so->so_proto->pr_usrreq)(so, PRU_PEERADDR, (struct mbuf *)0,
    986  1.21   mycroft 	    m, (struct mbuf *)0, (struct proc *)0);
    987  1.18  christos 	if (error)
    988   1.1       cgd 		goto bad;
    989   1.1       cgd 	if (len > m->m_len)
    990   1.1       cgd 		len = m->m_len;
    991  1.18  christos 	error = copyout(mtod(m, caddr_t), (caddr_t)SCARG(uap, asa), (u_int)len);
    992  1.18  christos 	if (error)
    993   1.1       cgd 		goto bad;
    994  1.34     perry 	error = copyout((caddr_t)&len, (caddr_t)SCARG(uap, alen), sizeof(len));
    995   1.1       cgd bad:
    996   1.1       cgd 	m_freem(m);
    997   1.1       cgd 	return (error);
    998   1.1       cgd }
    999   1.1       cgd 
   1000  1.24   thorpej /*
   1001  1.24   thorpej  * XXX In a perfect world, we wouldn't pass around socket control
   1002  1.24   thorpej  * XXX arguments in mbufs, and this could go away.
   1003  1.24   thorpej  */
   1004   1.7   mycroft int
   1005   1.1       cgd sockargs(mp, buf, buflen, type)
   1006   1.1       cgd 	struct mbuf **mp;
   1007  1.23       cgd 	const void *buf;
   1008   1.1       cgd 	int buflen, type;
   1009   1.1       cgd {
   1010   1.7   mycroft 	register struct sockaddr *sa;
   1011   1.1       cgd 	register struct mbuf *m;
   1012   1.1       cgd 	int error;
   1013   1.1       cgd 
   1014  1.24   thorpej 	/*
   1015  1.25   thorpej 	 * We can't allow socket names > UCHAR_MAX in length, since that
   1016  1.24   thorpej 	 * will overflow sa_len.
   1017  1.24   thorpej 	 */
   1018  1.25   thorpej 	if (type == MT_SONAME && (u_int)buflen > UCHAR_MAX)
   1019  1.24   thorpej 		return (EINVAL);
   1020  1.24   thorpej 
   1021  1.24   thorpej 	/* Allocate an mbuf to hold the arguments. */
   1022  1.24   thorpej 	m = m_get(M_WAIT, type);
   1023   1.1       cgd 	if ((u_int)buflen > MLEN) {
   1024  1.24   thorpej 		/*
   1025  1.24   thorpej 		 * Won't fit into a regular mbuf, so we allocate just
   1026  1.24   thorpej 		 * enough external storage to hold the argument.
   1027  1.24   thorpej 		 */
   1028  1.24   thorpej 		MEXTMALLOC(m, buflen, M_WAITOK);
   1029   1.1       cgd 	}
   1030   1.1       cgd 	m->m_len = buflen;
   1031   1.1       cgd 	error = copyin(buf, mtod(m, caddr_t), (u_int)buflen);
   1032   1.1       cgd 	if (error) {
   1033   1.1       cgd 		(void) m_free(m);
   1034   1.7   mycroft 		return (error);
   1035   1.1       cgd 	}
   1036   1.1       cgd 	*mp = m;
   1037   1.1       cgd 	if (type == MT_SONAME) {
   1038   1.7   mycroft 		sa = mtod(m, struct sockaddr *);
   1039   1.1       cgd 
   1040   1.7   mycroft #if defined(COMPAT_OLDSOCK) && BYTE_ORDER != BIG_ENDIAN
   1041   1.1       cgd 		if (sa->sa_family == 0 && sa->sa_len < AF_MAX)
   1042   1.1       cgd 			sa->sa_family = sa->sa_len;
   1043   1.1       cgd #endif
   1044   1.1       cgd 		sa->sa_len = buflen;
   1045   1.1       cgd 	}
   1046   1.1       cgd 	return (0);
   1047   1.1       cgd }
   1048   1.1       cgd 
   1049   1.7   mycroft int
   1050   1.1       cgd getsock(fdp, fdes, fpp)
   1051   1.1       cgd 	struct filedesc *fdp;
   1052   1.1       cgd 	int fdes;
   1053   1.1       cgd 	struct file **fpp;
   1054   1.1       cgd {
   1055   1.1       cgd 	register struct file *fp;
   1056   1.1       cgd 
   1057   1.1       cgd 	if ((unsigned)fdes >= fdp->fd_nfiles ||
   1058   1.1       cgd 	    (fp = fdp->fd_ofiles[fdes]) == NULL)
   1059   1.1       cgd 		return (EBADF);
   1060   1.1       cgd 	if (fp->f_type != DTYPE_SOCKET)
   1061   1.1       cgd 		return (ENOTSOCK);
   1062   1.1       cgd 	*fpp = fp;
   1063   1.1       cgd 	return (0);
   1064   1.1       cgd }
   1065