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