sys_generic.c revision 1.31 1 1.31 cgd /* $NetBSD: sys_generic.c,v 1.31 1996/12/22 10:21:12 cgd Exp $ */
2 1.15 cgd
3 1.15 cgd /*
4 1.15 cgd * Copyright (c) 1982, 1986, 1989, 1993
5 1.15 cgd * The Regents of the University of California. All rights reserved.
6 1.15 cgd * (c) UNIX System Laboratories, Inc.
7 1.15 cgd * All or some portions of this file are derived from material licensed
8 1.15 cgd * to the University of California by American Telephone and Telegraph
9 1.15 cgd * Co. or Unix System Laboratories, Inc. and are reproduced herein with
10 1.15 cgd * the permission of UNIX System Laboratories, Inc.
11 1.15 cgd *
12 1.15 cgd * Redistribution and use in source and binary forms, with or without
13 1.15 cgd * modification, are permitted provided that the following conditions
14 1.15 cgd * are met:
15 1.15 cgd * 1. Redistributions of source code must retain the above copyright
16 1.15 cgd * notice, this list of conditions and the following disclaimer.
17 1.15 cgd * 2. Redistributions in binary form must reproduce the above copyright
18 1.15 cgd * notice, this list of conditions and the following disclaimer in the
19 1.15 cgd * documentation and/or other materials provided with the distribution.
20 1.15 cgd * 3. All advertising materials mentioning features or use of this software
21 1.15 cgd * must display the following acknowledgement:
22 1.15 cgd * This product includes software developed by the University of
23 1.15 cgd * California, Berkeley and its contributors.
24 1.15 cgd * 4. Neither the name of the University nor the names of its contributors
25 1.15 cgd * may be used to endorse or promote products derived from this software
26 1.15 cgd * without specific prior written permission.
27 1.15 cgd *
28 1.15 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
29 1.15 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
30 1.15 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
31 1.15 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
32 1.15 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
33 1.15 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
34 1.15 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
35 1.15 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
36 1.15 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
37 1.15 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
38 1.15 cgd * SUCH DAMAGE.
39 1.15 cgd *
40 1.15 cgd * @(#)sys_generic.c 8.5 (Berkeley) 1/21/94
41 1.15 cgd */
42 1.15 cgd
43 1.15 cgd #include <sys/param.h>
44 1.15 cgd #include <sys/systm.h>
45 1.15 cgd #include <sys/filedesc.h>
46 1.15 cgd #include <sys/ioctl.h>
47 1.15 cgd #include <sys/file.h>
48 1.15 cgd #include <sys/proc.h>
49 1.15 cgd #include <sys/socketvar.h>
50 1.22 christos #include <sys/signalvar.h>
51 1.15 cgd #include <sys/uio.h>
52 1.15 cgd #include <sys/kernel.h>
53 1.15 cgd #include <sys/stat.h>
54 1.15 cgd #include <sys/malloc.h>
55 1.28 mycroft #include <sys/poll.h>
56 1.15 cgd #ifdef KTRACE
57 1.15 cgd #include <sys/ktrace.h>
58 1.15 cgd #endif
59 1.15 cgd
60 1.16 cgd #include <sys/mount.h>
61 1.16 cgd #include <sys/syscallargs.h>
62 1.22 christos
63 1.25 mycroft int selscan __P((struct proc *, fd_mask *, fd_mask *, int, register_t *));
64 1.28 mycroft int pollscan __P((struct proc *, struct pollfd *, int, register_t *));
65 1.22 christos
66 1.15 cgd /*
67 1.15 cgd * Read system call.
68 1.15 cgd */
69 1.15 cgd /* ARGSUSED */
70 1.22 christos int
71 1.21 mycroft sys_read(p, v, retval)
72 1.15 cgd struct proc *p;
73 1.20 thorpej void *v;
74 1.20 thorpej register_t *retval;
75 1.20 thorpej {
76 1.21 mycroft register struct sys_read_args /* {
77 1.16 cgd syscallarg(int) fd;
78 1.31 cgd syscallarg(void *) buf;
79 1.31 cgd syscallarg(size_t) nbyte;
80 1.20 thorpej } */ *uap = v;
81 1.15 cgd register struct file *fp;
82 1.15 cgd register struct filedesc *fdp = p->p_fd;
83 1.15 cgd struct uio auio;
84 1.15 cgd struct iovec aiov;
85 1.15 cgd long cnt, error = 0;
86 1.15 cgd #ifdef KTRACE
87 1.15 cgd struct iovec ktriov;
88 1.15 cgd #endif
89 1.15 cgd
90 1.16 cgd if (((u_int)SCARG(uap, fd)) >= fdp->fd_nfiles ||
91 1.16 cgd (fp = fdp->fd_ofiles[SCARG(uap, fd)]) == NULL ||
92 1.15 cgd (fp->f_flag & FREAD) == 0)
93 1.15 cgd return (EBADF);
94 1.16 cgd aiov.iov_base = (caddr_t)SCARG(uap, buf);
95 1.16 cgd aiov.iov_len = SCARG(uap, nbyte);
96 1.15 cgd auio.uio_iov = &aiov;
97 1.15 cgd auio.uio_iovcnt = 1;
98 1.16 cgd auio.uio_resid = SCARG(uap, nbyte);
99 1.15 cgd auio.uio_rw = UIO_READ;
100 1.15 cgd auio.uio_segflg = UIO_USERSPACE;
101 1.15 cgd auio.uio_procp = p;
102 1.15 cgd if (auio.uio_resid < 0)
103 1.15 cgd return EINVAL;
104 1.15 cgd #ifdef KTRACE
105 1.15 cgd /*
106 1.15 cgd * if tracing, save a copy of iovec
107 1.15 cgd */
108 1.15 cgd if (KTRPOINT(p, KTR_GENIO))
109 1.15 cgd ktriov = aiov;
110 1.15 cgd #endif
111 1.16 cgd cnt = SCARG(uap, nbyte);
112 1.22 christos error = (*fp->f_ops->fo_read)(fp, &auio, fp->f_cred);
113 1.22 christos if (error)
114 1.15 cgd if (auio.uio_resid != cnt && (error == ERESTART ||
115 1.15 cgd error == EINTR || error == EWOULDBLOCK))
116 1.15 cgd error = 0;
117 1.15 cgd cnt -= auio.uio_resid;
118 1.15 cgd #ifdef KTRACE
119 1.15 cgd if (KTRPOINT(p, KTR_GENIO) && error == 0)
120 1.16 cgd ktrgenio(p->p_tracep, SCARG(uap, fd), UIO_READ, &ktriov,
121 1.16 cgd cnt, error);
122 1.15 cgd #endif
123 1.15 cgd *retval = cnt;
124 1.15 cgd return (error);
125 1.15 cgd }
126 1.15 cgd
127 1.15 cgd /*
128 1.15 cgd * Scatter read system call.
129 1.15 cgd */
130 1.22 christos int
131 1.21 mycroft sys_readv(p, v, retval)
132 1.15 cgd struct proc *p;
133 1.20 thorpej void *v;
134 1.20 thorpej register_t *retval;
135 1.20 thorpej {
136 1.21 mycroft register struct sys_readv_args /* {
137 1.16 cgd syscallarg(int) fd;
138 1.31 cgd syscallarg(const struct iovec *) iovp;
139 1.16 cgd syscallarg(u_int) iovcnt;
140 1.20 thorpej } */ *uap = v;
141 1.15 cgd register struct file *fp;
142 1.15 cgd register struct filedesc *fdp = p->p_fd;
143 1.15 cgd struct uio auio;
144 1.15 cgd register struct iovec *iov;
145 1.15 cgd struct iovec *needfree;
146 1.15 cgd struct iovec aiov[UIO_SMALLIOV];
147 1.15 cgd long i, cnt, error = 0;
148 1.15 cgd u_int iovlen;
149 1.15 cgd #ifdef KTRACE
150 1.15 cgd struct iovec *ktriov = NULL;
151 1.15 cgd #endif
152 1.15 cgd
153 1.16 cgd if (((u_int)SCARG(uap, fd)) >= fdp->fd_nfiles ||
154 1.16 cgd (fp = fdp->fd_ofiles[SCARG(uap, fd)]) == NULL ||
155 1.15 cgd (fp->f_flag & FREAD) == 0)
156 1.15 cgd return (EBADF);
157 1.15 cgd /* note: can't use iovlen until iovcnt is validated */
158 1.16 cgd iovlen = SCARG(uap, iovcnt) * sizeof (struct iovec);
159 1.16 cgd if (SCARG(uap, iovcnt) > UIO_SMALLIOV) {
160 1.16 cgd if (SCARG(uap, iovcnt) > UIO_MAXIOV)
161 1.15 cgd return (EINVAL);
162 1.15 cgd MALLOC(iov, struct iovec *, iovlen, M_IOV, M_WAITOK);
163 1.15 cgd needfree = iov;
164 1.15 cgd } else {
165 1.15 cgd iov = aiov;
166 1.15 cgd needfree = NULL;
167 1.15 cgd }
168 1.15 cgd auio.uio_iov = iov;
169 1.16 cgd auio.uio_iovcnt = SCARG(uap, iovcnt);
170 1.15 cgd auio.uio_rw = UIO_READ;
171 1.15 cgd auio.uio_segflg = UIO_USERSPACE;
172 1.15 cgd auio.uio_procp = p;
173 1.31 cgd error = copyin(SCARG(uap, iovp), iov, iovlen);
174 1.22 christos if (error)
175 1.15 cgd goto done;
176 1.15 cgd auio.uio_resid = 0;
177 1.16 cgd for (i = 0; i < SCARG(uap, iovcnt); i++) {
178 1.22 christos #if 0
179 1.22 christos /* Cannot happen iov_len is unsigned */
180 1.15 cgd if (iov->iov_len < 0) {
181 1.15 cgd error = EINVAL;
182 1.15 cgd goto done;
183 1.15 cgd }
184 1.22 christos #endif
185 1.15 cgd auio.uio_resid += iov->iov_len;
186 1.15 cgd if (auio.uio_resid < 0) {
187 1.15 cgd error = EINVAL;
188 1.15 cgd goto done;
189 1.15 cgd }
190 1.15 cgd iov++;
191 1.15 cgd }
192 1.15 cgd #ifdef KTRACE
193 1.15 cgd /*
194 1.15 cgd * if tracing, save a copy of iovec
195 1.15 cgd */
196 1.15 cgd if (KTRPOINT(p, KTR_GENIO)) {
197 1.15 cgd MALLOC(ktriov, struct iovec *, iovlen, M_TEMP, M_WAITOK);
198 1.15 cgd bcopy((caddr_t)auio.uio_iov, (caddr_t)ktriov, iovlen);
199 1.15 cgd }
200 1.15 cgd #endif
201 1.15 cgd cnt = auio.uio_resid;
202 1.22 christos error = (*fp->f_ops->fo_read)(fp, &auio, fp->f_cred);
203 1.22 christos if (error)
204 1.15 cgd if (auio.uio_resid != cnt && (error == ERESTART ||
205 1.15 cgd error == EINTR || error == EWOULDBLOCK))
206 1.15 cgd error = 0;
207 1.15 cgd cnt -= auio.uio_resid;
208 1.15 cgd #ifdef KTRACE
209 1.15 cgd if (ktriov != NULL) {
210 1.15 cgd if (error == 0)
211 1.16 cgd ktrgenio(p->p_tracep, SCARG(uap, fd), UIO_READ, ktriov,
212 1.15 cgd cnt, error);
213 1.15 cgd FREE(ktriov, M_TEMP);
214 1.15 cgd }
215 1.15 cgd #endif
216 1.15 cgd *retval = cnt;
217 1.15 cgd done:
218 1.15 cgd if (needfree)
219 1.15 cgd FREE(needfree, M_IOV);
220 1.15 cgd return (error);
221 1.15 cgd }
222 1.15 cgd
223 1.15 cgd /*
224 1.15 cgd * Write system call
225 1.15 cgd */
226 1.22 christos int
227 1.21 mycroft sys_write(p, v, retval)
228 1.15 cgd struct proc *p;
229 1.20 thorpej void *v;
230 1.20 thorpej register_t *retval;
231 1.20 thorpej {
232 1.21 mycroft register struct sys_write_args /* {
233 1.16 cgd syscallarg(int) fd;
234 1.31 cgd syscallarg(const void *) buf;
235 1.31 cgd syscallarg(size_t) nbyte;
236 1.20 thorpej } */ *uap = v;
237 1.15 cgd register struct file *fp;
238 1.15 cgd register struct filedesc *fdp = p->p_fd;
239 1.15 cgd struct uio auio;
240 1.15 cgd struct iovec aiov;
241 1.15 cgd long cnt, error = 0;
242 1.15 cgd #ifdef KTRACE
243 1.15 cgd struct iovec ktriov;
244 1.15 cgd #endif
245 1.15 cgd
246 1.16 cgd if (((u_int)SCARG(uap, fd)) >= fdp->fd_nfiles ||
247 1.16 cgd (fp = fdp->fd_ofiles[SCARG(uap, fd)]) == NULL ||
248 1.15 cgd (fp->f_flag & FWRITE) == 0)
249 1.15 cgd return (EBADF);
250 1.31 cgd aiov.iov_base = (char *)SCARG(uap, buf); /* XXX kills const */
251 1.16 cgd aiov.iov_len = SCARG(uap, nbyte);
252 1.15 cgd auio.uio_iov = &aiov;
253 1.15 cgd auio.uio_iovcnt = 1;
254 1.16 cgd auio.uio_resid = SCARG(uap, nbyte);
255 1.15 cgd auio.uio_rw = UIO_WRITE;
256 1.15 cgd auio.uio_segflg = UIO_USERSPACE;
257 1.15 cgd auio.uio_procp = p;
258 1.15 cgd if (auio.uio_resid < 0)
259 1.15 cgd return EINVAL;
260 1.15 cgd #ifdef KTRACE
261 1.15 cgd /*
262 1.15 cgd * if tracing, save a copy of iovec
263 1.15 cgd */
264 1.15 cgd if (KTRPOINT(p, KTR_GENIO))
265 1.15 cgd ktriov = aiov;
266 1.15 cgd #endif
267 1.16 cgd cnt = SCARG(uap, nbyte);
268 1.22 christos error = (*fp->f_ops->fo_write)(fp, &auio, fp->f_cred);
269 1.22 christos if (error) {
270 1.15 cgd if (auio.uio_resid != cnt && (error == ERESTART ||
271 1.15 cgd error == EINTR || error == EWOULDBLOCK))
272 1.15 cgd error = 0;
273 1.15 cgd if (error == EPIPE)
274 1.15 cgd psignal(p, SIGPIPE);
275 1.15 cgd }
276 1.15 cgd cnt -= auio.uio_resid;
277 1.15 cgd #ifdef KTRACE
278 1.15 cgd if (KTRPOINT(p, KTR_GENIO) && error == 0)
279 1.16 cgd ktrgenio(p->p_tracep, SCARG(uap, fd), UIO_WRITE,
280 1.15 cgd &ktriov, cnt, error);
281 1.15 cgd #endif
282 1.15 cgd *retval = cnt;
283 1.15 cgd return (error);
284 1.15 cgd }
285 1.15 cgd
286 1.15 cgd /*
287 1.15 cgd * Gather write system call
288 1.15 cgd */
289 1.22 christos int
290 1.21 mycroft sys_writev(p, v, retval)
291 1.15 cgd struct proc *p;
292 1.20 thorpej void *v;
293 1.20 thorpej register_t *retval;
294 1.20 thorpej {
295 1.21 mycroft register struct sys_writev_args /* {
296 1.16 cgd syscallarg(int) fd;
297 1.31 cgd syscallarg(const struct iovec *) iovp;
298 1.16 cgd syscallarg(u_int) iovcnt;
299 1.20 thorpej } */ *uap = v;
300 1.15 cgd register struct file *fp;
301 1.15 cgd register struct filedesc *fdp = p->p_fd;
302 1.15 cgd struct uio auio;
303 1.15 cgd register struct iovec *iov;
304 1.15 cgd struct iovec *needfree;
305 1.15 cgd struct iovec aiov[UIO_SMALLIOV];
306 1.15 cgd long i, cnt, error = 0;
307 1.15 cgd u_int iovlen;
308 1.15 cgd #ifdef KTRACE
309 1.15 cgd struct iovec *ktriov = NULL;
310 1.15 cgd #endif
311 1.15 cgd
312 1.16 cgd if (((u_int)SCARG(uap, fd)) >= fdp->fd_nfiles ||
313 1.16 cgd (fp = fdp->fd_ofiles[SCARG(uap, fd)]) == NULL ||
314 1.15 cgd (fp->f_flag & FWRITE) == 0)
315 1.15 cgd return (EBADF);
316 1.15 cgd /* note: can't use iovlen until iovcnt is validated */
317 1.16 cgd iovlen = SCARG(uap, iovcnt) * sizeof (struct iovec);
318 1.16 cgd if (SCARG(uap, iovcnt) > UIO_SMALLIOV) {
319 1.16 cgd if (SCARG(uap, iovcnt) > UIO_MAXIOV)
320 1.15 cgd return (EINVAL);
321 1.15 cgd MALLOC(iov, struct iovec *, iovlen, M_IOV, M_WAITOK);
322 1.15 cgd needfree = iov;
323 1.15 cgd } else {
324 1.15 cgd iov = aiov;
325 1.15 cgd needfree = NULL;
326 1.15 cgd }
327 1.15 cgd auio.uio_iov = iov;
328 1.16 cgd auio.uio_iovcnt = SCARG(uap, iovcnt);
329 1.15 cgd auio.uio_rw = UIO_WRITE;
330 1.15 cgd auio.uio_segflg = UIO_USERSPACE;
331 1.15 cgd auio.uio_procp = p;
332 1.31 cgd error = copyin(SCARG(uap, iovp), iov, iovlen);
333 1.22 christos if (error)
334 1.15 cgd goto done;
335 1.15 cgd auio.uio_resid = 0;
336 1.16 cgd for (i = 0; i < SCARG(uap, iovcnt); i++) {
337 1.22 christos #if 0
338 1.22 christos /* Cannot happen iov_len is unsigned */
339 1.15 cgd if (iov->iov_len < 0) {
340 1.15 cgd error = EINVAL;
341 1.15 cgd goto done;
342 1.15 cgd }
343 1.22 christos #endif
344 1.15 cgd auio.uio_resid += iov->iov_len;
345 1.15 cgd if (auio.uio_resid < 0) {
346 1.15 cgd error = EINVAL;
347 1.15 cgd goto done;
348 1.15 cgd }
349 1.15 cgd iov++;
350 1.15 cgd }
351 1.15 cgd #ifdef KTRACE
352 1.15 cgd /*
353 1.15 cgd * if tracing, save a copy of iovec
354 1.15 cgd */
355 1.15 cgd if (KTRPOINT(p, KTR_GENIO)) {
356 1.15 cgd MALLOC(ktriov, struct iovec *, iovlen, M_TEMP, M_WAITOK);
357 1.15 cgd bcopy((caddr_t)auio.uio_iov, (caddr_t)ktriov, iovlen);
358 1.15 cgd }
359 1.15 cgd #endif
360 1.15 cgd cnt = auio.uio_resid;
361 1.22 christos error = (*fp->f_ops->fo_write)(fp, &auio, fp->f_cred);
362 1.22 christos if (error) {
363 1.15 cgd if (auio.uio_resid != cnt && (error == ERESTART ||
364 1.15 cgd error == EINTR || error == EWOULDBLOCK))
365 1.15 cgd error = 0;
366 1.15 cgd if (error == EPIPE)
367 1.15 cgd psignal(p, SIGPIPE);
368 1.15 cgd }
369 1.15 cgd cnt -= auio.uio_resid;
370 1.15 cgd #ifdef KTRACE
371 1.15 cgd if (ktriov != NULL) {
372 1.15 cgd if (error == 0)
373 1.16 cgd ktrgenio(p->p_tracep, SCARG(uap, fd), UIO_WRITE,
374 1.15 cgd ktriov, cnt, error);
375 1.15 cgd FREE(ktriov, M_TEMP);
376 1.15 cgd }
377 1.15 cgd #endif
378 1.15 cgd *retval = cnt;
379 1.15 cgd done:
380 1.15 cgd if (needfree)
381 1.15 cgd FREE(needfree, M_IOV);
382 1.15 cgd return (error);
383 1.15 cgd }
384 1.15 cgd
385 1.15 cgd /*
386 1.15 cgd * Ioctl system call
387 1.15 cgd */
388 1.15 cgd /* ARGSUSED */
389 1.22 christos int
390 1.21 mycroft sys_ioctl(p, v, retval)
391 1.15 cgd struct proc *p;
392 1.20 thorpej void *v;
393 1.20 thorpej register_t *retval;
394 1.20 thorpej {
395 1.21 mycroft register struct sys_ioctl_args /* {
396 1.16 cgd syscallarg(int) fd;
397 1.17 cgd syscallarg(u_long) com;
398 1.16 cgd syscallarg(caddr_t) data;
399 1.20 thorpej } */ *uap = v;
400 1.15 cgd register struct file *fp;
401 1.15 cgd register struct filedesc *fdp;
402 1.17 cgd register u_long com;
403 1.17 cgd register int error;
404 1.15 cgd register u_int size;
405 1.15 cgd caddr_t data, memp;
406 1.15 cgd int tmp;
407 1.15 cgd #define STK_PARAMS 128
408 1.15 cgd char stkbuf[STK_PARAMS];
409 1.15 cgd
410 1.15 cgd fdp = p->p_fd;
411 1.16 cgd if ((u_int)SCARG(uap, fd) >= fdp->fd_nfiles ||
412 1.16 cgd (fp = fdp->fd_ofiles[SCARG(uap, fd)]) == NULL)
413 1.15 cgd return (EBADF);
414 1.15 cgd
415 1.15 cgd if ((fp->f_flag & (FREAD | FWRITE)) == 0)
416 1.15 cgd return (EBADF);
417 1.15 cgd
418 1.16 cgd switch (com = SCARG(uap, com)) {
419 1.15 cgd case FIONCLEX:
420 1.16 cgd fdp->fd_ofileflags[SCARG(uap, fd)] &= ~UF_EXCLOSE;
421 1.15 cgd return (0);
422 1.15 cgd case FIOCLEX:
423 1.16 cgd fdp->fd_ofileflags[SCARG(uap, fd)] |= UF_EXCLOSE;
424 1.15 cgd return (0);
425 1.15 cgd }
426 1.15 cgd
427 1.15 cgd /*
428 1.15 cgd * Interpret high order word to find amount of data to be
429 1.15 cgd * copied to/from the user's address space.
430 1.15 cgd */
431 1.15 cgd size = IOCPARM_LEN(com);
432 1.15 cgd if (size > IOCPARM_MAX)
433 1.15 cgd return (ENOTTY);
434 1.15 cgd memp = NULL;
435 1.15 cgd if (size > sizeof (stkbuf)) {
436 1.15 cgd memp = (caddr_t)malloc((u_long)size, M_IOCTLOPS, M_WAITOK);
437 1.15 cgd data = memp;
438 1.15 cgd } else
439 1.15 cgd data = stkbuf;
440 1.15 cgd if (com&IOC_IN) {
441 1.15 cgd if (size) {
442 1.31 cgd error = copyin(SCARG(uap, data), data, size);
443 1.15 cgd if (error) {
444 1.15 cgd if (memp)
445 1.15 cgd free(memp, M_IOCTLOPS);
446 1.15 cgd return (error);
447 1.15 cgd }
448 1.15 cgd } else
449 1.16 cgd *(caddr_t *)data = SCARG(uap, data);
450 1.15 cgd } else if ((com&IOC_OUT) && size)
451 1.15 cgd /*
452 1.15 cgd * Zero the buffer so the user always
453 1.15 cgd * gets back something deterministic.
454 1.15 cgd */
455 1.15 cgd bzero(data, size);
456 1.15 cgd else if (com&IOC_VOID)
457 1.16 cgd *(caddr_t *)data = SCARG(uap, data);
458 1.15 cgd
459 1.15 cgd switch (com) {
460 1.15 cgd
461 1.15 cgd case FIONBIO:
462 1.22 christos if ((tmp = *(int *)data) != 0)
463 1.15 cgd fp->f_flag |= FNONBLOCK;
464 1.15 cgd else
465 1.15 cgd fp->f_flag &= ~FNONBLOCK;
466 1.15 cgd error = (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
467 1.15 cgd break;
468 1.15 cgd
469 1.15 cgd case FIOASYNC:
470 1.22 christos if ((tmp = *(int *)data) != 0)
471 1.15 cgd fp->f_flag |= FASYNC;
472 1.15 cgd else
473 1.15 cgd fp->f_flag &= ~FASYNC;
474 1.15 cgd error = (*fp->f_ops->fo_ioctl)(fp, FIOASYNC, (caddr_t)&tmp, p);
475 1.15 cgd break;
476 1.15 cgd
477 1.15 cgd case FIOSETOWN:
478 1.15 cgd tmp = *(int *)data;
479 1.15 cgd if (fp->f_type == DTYPE_SOCKET) {
480 1.15 cgd ((struct socket *)fp->f_data)->so_pgid = tmp;
481 1.15 cgd error = 0;
482 1.15 cgd break;
483 1.15 cgd }
484 1.15 cgd if (tmp <= 0) {
485 1.15 cgd tmp = -tmp;
486 1.15 cgd } else {
487 1.15 cgd struct proc *p1 = pfind(tmp);
488 1.15 cgd if (p1 == 0) {
489 1.15 cgd error = ESRCH;
490 1.15 cgd break;
491 1.15 cgd }
492 1.15 cgd tmp = p1->p_pgrp->pg_id;
493 1.15 cgd }
494 1.15 cgd error = (*fp->f_ops->fo_ioctl)
495 1.24 cgd (fp, TIOCSPGRP, (caddr_t)&tmp, p);
496 1.15 cgd break;
497 1.15 cgd
498 1.15 cgd case FIOGETOWN:
499 1.15 cgd if (fp->f_type == DTYPE_SOCKET) {
500 1.15 cgd error = 0;
501 1.15 cgd *(int *)data = ((struct socket *)fp->f_data)->so_pgid;
502 1.15 cgd break;
503 1.15 cgd }
504 1.17 cgd error = (*fp->f_ops->fo_ioctl)(fp, TIOCGPGRP, data, p);
505 1.15 cgd *(int *)data = -*(int *)data;
506 1.15 cgd break;
507 1.15 cgd
508 1.15 cgd default:
509 1.15 cgd error = (*fp->f_ops->fo_ioctl)(fp, com, data, p);
510 1.15 cgd /*
511 1.15 cgd * Copy any data to user, size was
512 1.15 cgd * already set and checked above.
513 1.15 cgd */
514 1.15 cgd if (error == 0 && (com&IOC_OUT) && size)
515 1.31 cgd error = copyout(data, SCARG(uap, data), size);
516 1.15 cgd break;
517 1.15 cgd }
518 1.15 cgd if (memp)
519 1.15 cgd free(memp, M_IOCTLOPS);
520 1.15 cgd return (error);
521 1.15 cgd }
522 1.15 cgd
523 1.15 cgd int selwait, nselcoll;
524 1.15 cgd
525 1.15 cgd /*
526 1.15 cgd * Select system call.
527 1.15 cgd */
528 1.22 christos int
529 1.21 mycroft sys_select(p, v, retval)
530 1.15 cgd register struct proc *p;
531 1.20 thorpej void *v;
532 1.20 thorpej register_t *retval;
533 1.20 thorpej {
534 1.21 mycroft register struct sys_select_args /* {
535 1.16 cgd syscallarg(u_int) nd;
536 1.16 cgd syscallarg(fd_set *) in;
537 1.16 cgd syscallarg(fd_set *) ou;
538 1.16 cgd syscallarg(fd_set *) ex;
539 1.16 cgd syscallarg(struct timeval *) tv;
540 1.20 thorpej } */ *uap = v;
541 1.25 mycroft caddr_t bits;
542 1.26 cgd char smallbits[howmany(FD_SETSIZE, NFDBITS) * sizeof(fd_mask) * 6];
543 1.15 cgd struct timeval atv;
544 1.15 cgd int s, ncoll, error = 0, timo;
545 1.27 mycroft size_t ni;
546 1.15 cgd
547 1.16 cgd if (SCARG(uap, nd) > p->p_fd->fd_nfiles) {
548 1.16 cgd /* forgiving; slightly wrong */
549 1.16 cgd SCARG(uap, nd) = p->p_fd->fd_nfiles;
550 1.16 cgd }
551 1.16 cgd ni = howmany(SCARG(uap, nd), NFDBITS) * sizeof(fd_mask);
552 1.27 mycroft if (ni * 6 > sizeof(smallbits))
553 1.25 mycroft bits = malloc(ni * 6, M_TEMP, M_WAITOK);
554 1.25 mycroft else
555 1.26 cgd bits = smallbits;
556 1.15 cgd
557 1.15 cgd #define getbits(name, x) \
558 1.25 mycroft if (SCARG(uap, name)) { \
559 1.31 cgd error = copyin(SCARG(uap, name), bits + ni * x, ni); \
560 1.25 mycroft if (error) \
561 1.25 mycroft goto done; \
562 1.25 mycroft } else \
563 1.25 mycroft bzero(bits + ni * x, ni);
564 1.15 cgd getbits(in, 0);
565 1.15 cgd getbits(ou, 1);
566 1.15 cgd getbits(ex, 2);
567 1.15 cgd #undef getbits
568 1.15 cgd
569 1.16 cgd if (SCARG(uap, tv)) {
570 1.31 cgd error = copyin(SCARG(uap, tv), (caddr_t)&atv,
571 1.15 cgd sizeof (atv));
572 1.15 cgd if (error)
573 1.15 cgd goto done;
574 1.15 cgd if (itimerfix(&atv)) {
575 1.15 cgd error = EINVAL;
576 1.15 cgd goto done;
577 1.15 cgd }
578 1.15 cgd s = splclock();
579 1.19 mycroft timeradd(&atv, &time, &atv);
580 1.15 cgd timo = hzto(&atv);
581 1.15 cgd /*
582 1.15 cgd * Avoid inadvertently sleeping forever.
583 1.15 cgd */
584 1.15 cgd if (timo == 0)
585 1.15 cgd timo = 1;
586 1.15 cgd splx(s);
587 1.15 cgd } else
588 1.15 cgd timo = 0;
589 1.15 cgd retry:
590 1.15 cgd ncoll = nselcoll;
591 1.15 cgd p->p_flag |= P_SELECT;
592 1.25 mycroft error = selscan(p, (fd_mask *)(bits + ni * 0),
593 1.25 mycroft (fd_mask *)(bits + ni * 3), SCARG(uap, nd), retval);
594 1.15 cgd if (error || *retval)
595 1.15 cgd goto done;
596 1.15 cgd s = splhigh();
597 1.27 mycroft if (timo && timercmp(&time, &atv, >=)) {
598 1.15 cgd splx(s);
599 1.15 cgd goto done;
600 1.15 cgd }
601 1.15 cgd if ((p->p_flag & P_SELECT) == 0 || nselcoll != ncoll) {
602 1.15 cgd splx(s);
603 1.15 cgd goto retry;
604 1.15 cgd }
605 1.15 cgd p->p_flag &= ~P_SELECT;
606 1.15 cgd error = tsleep((caddr_t)&selwait, PSOCK | PCATCH, "select", timo);
607 1.15 cgd splx(s);
608 1.15 cgd if (error == 0)
609 1.15 cgd goto retry;
610 1.15 cgd done:
611 1.15 cgd p->p_flag &= ~P_SELECT;
612 1.15 cgd /* select is not restarted after signals... */
613 1.15 cgd if (error == ERESTART)
614 1.15 cgd error = EINTR;
615 1.15 cgd if (error == EWOULDBLOCK)
616 1.15 cgd error = 0;
617 1.27 mycroft if (error == 0) {
618 1.15 cgd #define putbits(name, x) \
619 1.27 mycroft if (SCARG(uap, name)) { \
620 1.31 cgd error = copyout(bits + ni * x, SCARG(uap, name), ni); \
621 1.27 mycroft if (error) \
622 1.27 mycroft goto out; \
623 1.27 mycroft }
624 1.25 mycroft putbits(in, 3);
625 1.25 mycroft putbits(ou, 4);
626 1.25 mycroft putbits(ex, 5);
627 1.15 cgd #undef putbits
628 1.15 cgd }
629 1.27 mycroft out:
630 1.27 mycroft if (ni * 6 > sizeof(smallbits))
631 1.25 mycroft free(bits, M_TEMP);
632 1.15 cgd return (error);
633 1.15 cgd }
634 1.15 cgd
635 1.22 christos int
636 1.25 mycroft selscan(p, ibitp, obitp, nfd, retval)
637 1.15 cgd struct proc *p;
638 1.25 mycroft fd_mask *ibitp, *obitp;
639 1.16 cgd int nfd;
640 1.16 cgd register_t *retval;
641 1.15 cgd {
642 1.15 cgd register struct filedesc *fdp = p->p_fd;
643 1.15 cgd register int msk, i, j, fd;
644 1.25 mycroft register fd_mask ibits, obits;
645 1.15 cgd struct file *fp;
646 1.15 cgd int n = 0;
647 1.28 mycroft static int flag[3] = { POLLRDNORM | POLLHUP | POLLERR,
648 1.28 mycroft POLLWRNORM | POLLHUP | POLLERR,
649 1.28 mycroft POLLRDBAND };
650 1.15 cgd
651 1.15 cgd for (msk = 0; msk < 3; msk++) {
652 1.15 cgd for (i = 0; i < nfd; i += NFDBITS) {
653 1.25 mycroft ibits = *ibitp++;
654 1.25 mycroft obits = 0;
655 1.25 mycroft while ((j = ffs(ibits)) && (fd = i + --j) < nfd) {
656 1.25 mycroft ibits &= ~(1 << j);
657 1.15 cgd fp = fdp->fd_ofiles[fd];
658 1.15 cgd if (fp == NULL)
659 1.15 cgd return (EBADF);
660 1.28 mycroft if ((*fp->f_ops->fo_poll)(fp, flag[msk], p)) {
661 1.25 mycroft obits |= (1 << j);
662 1.15 cgd n++;
663 1.15 cgd }
664 1.15 cgd }
665 1.25 mycroft *obitp++ = obits;
666 1.15 cgd }
667 1.15 cgd }
668 1.15 cgd *retval = n;
669 1.15 cgd return (0);
670 1.15 cgd }
671 1.15 cgd
672 1.28 mycroft /*
673 1.28 mycroft * Poll system call.
674 1.28 mycroft */
675 1.28 mycroft int
676 1.28 mycroft sys_poll(p, v, retval)
677 1.28 mycroft register struct proc *p;
678 1.28 mycroft void *v;
679 1.28 mycroft register_t *retval;
680 1.28 mycroft {
681 1.28 mycroft register struct sys_poll_args /* {
682 1.28 mycroft syscallarg(struct pollfd *) fds;
683 1.29 mycroft syscallarg(u_int) nfds;
684 1.28 mycroft syscallarg(int) timeout;
685 1.28 mycroft } */ *uap = v;
686 1.28 mycroft caddr_t bits;
687 1.28 mycroft char smallbits[32 * sizeof(struct pollfd)];
688 1.28 mycroft struct timeval atv;
689 1.28 mycroft int s, ncoll, error = 0, timo;
690 1.28 mycroft size_t ni;
691 1.28 mycroft
692 1.28 mycroft if (SCARG(uap, nfds) > p->p_fd->fd_nfiles) {
693 1.28 mycroft /* forgiving; slightly wrong */
694 1.28 mycroft SCARG(uap, nfds) = p->p_fd->fd_nfiles;
695 1.28 mycroft }
696 1.28 mycroft ni = SCARG(uap, nfds) * sizeof(struct pollfd);
697 1.28 mycroft if (ni > sizeof(smallbits))
698 1.28 mycroft bits = malloc(ni, M_TEMP, M_WAITOK);
699 1.28 mycroft else
700 1.28 mycroft bits = smallbits;
701 1.28 mycroft
702 1.31 cgd error = copyin(SCARG(uap, fds), bits, ni);
703 1.28 mycroft if (error)
704 1.28 mycroft goto done;
705 1.28 mycroft
706 1.30 mycroft if (SCARG(uap, timeout) != INFTIM) {
707 1.28 mycroft atv.tv_sec = SCARG(uap, timeout) / 1000;
708 1.28 mycroft atv.tv_usec = (SCARG(uap, timeout) % 1000) * 1000;
709 1.28 mycroft if (itimerfix(&atv)) {
710 1.28 mycroft error = EINVAL;
711 1.28 mycroft goto done;
712 1.28 mycroft }
713 1.28 mycroft s = splclock();
714 1.28 mycroft timeradd(&atv, &time, &atv);
715 1.28 mycroft timo = hzto(&atv);
716 1.28 mycroft /*
717 1.28 mycroft * Avoid inadvertently sleeping forever.
718 1.28 mycroft */
719 1.28 mycroft if (timo == 0)
720 1.28 mycroft timo = 1;
721 1.28 mycroft splx(s);
722 1.28 mycroft } else
723 1.28 mycroft timo = 0;
724 1.28 mycroft retry:
725 1.28 mycroft ncoll = nselcoll;
726 1.28 mycroft p->p_flag |= P_SELECT;
727 1.28 mycroft error = pollscan(p, (struct pollfd *)bits, SCARG(uap, nfds), retval);
728 1.28 mycroft if (error || *retval)
729 1.28 mycroft goto done;
730 1.28 mycroft s = splhigh();
731 1.28 mycroft if (timo && timercmp(&time, &atv, >=)) {
732 1.28 mycroft splx(s);
733 1.28 mycroft goto done;
734 1.28 mycroft }
735 1.28 mycroft if ((p->p_flag & P_SELECT) == 0 || nselcoll != ncoll) {
736 1.28 mycroft splx(s);
737 1.28 mycroft goto retry;
738 1.28 mycroft }
739 1.28 mycroft p->p_flag &= ~P_SELECT;
740 1.28 mycroft error = tsleep((caddr_t)&selwait, PSOCK | PCATCH, "select", timo);
741 1.28 mycroft splx(s);
742 1.28 mycroft if (error == 0)
743 1.28 mycroft goto retry;
744 1.28 mycroft done:
745 1.28 mycroft p->p_flag &= ~P_SELECT;
746 1.28 mycroft /* poll is not restarted after signals... */
747 1.28 mycroft if (error == ERESTART)
748 1.28 mycroft error = EINTR;
749 1.28 mycroft if (error == EWOULDBLOCK)
750 1.28 mycroft error = 0;
751 1.28 mycroft if (error == 0) {
752 1.31 cgd error = copyout(bits, SCARG(uap, fds), ni);
753 1.28 mycroft if (error)
754 1.28 mycroft goto out;
755 1.28 mycroft }
756 1.28 mycroft out:
757 1.28 mycroft if (ni > sizeof(smallbits))
758 1.28 mycroft free(bits, M_TEMP);
759 1.28 mycroft return (error);
760 1.28 mycroft }
761 1.28 mycroft
762 1.28 mycroft int
763 1.28 mycroft pollscan(p, fds, nfd, retval)
764 1.28 mycroft struct proc *p;
765 1.28 mycroft struct pollfd *fds;
766 1.28 mycroft int nfd;
767 1.28 mycroft register_t *retval;
768 1.28 mycroft {
769 1.28 mycroft register struct filedesc *fdp = p->p_fd;
770 1.28 mycroft int i;
771 1.28 mycroft struct file *fp;
772 1.28 mycroft int n = 0;
773 1.28 mycroft
774 1.28 mycroft for (i = 0; i < nfd; i++, fds++) {
775 1.28 mycroft fp = fdp->fd_ofiles[fds->fd];
776 1.28 mycroft if (fp == 0) {
777 1.28 mycroft fds->revents = POLLNVAL;
778 1.28 mycroft n++;
779 1.28 mycroft } else {
780 1.28 mycroft fds->revents = (*fp->f_ops->fo_poll)(fp,
781 1.28 mycroft fds->events | POLLERR | POLLHUP, p);
782 1.28 mycroft if (fds->revents != 0)
783 1.28 mycroft n++;
784 1.28 mycroft }
785 1.28 mycroft }
786 1.28 mycroft *retval = n;
787 1.28 mycroft return (0);
788 1.28 mycroft }
789 1.28 mycroft
790 1.15 cgd /*ARGSUSED*/
791 1.22 christos int
792 1.28 mycroft seltrue(dev, events, p)
793 1.15 cgd dev_t dev;
794 1.28 mycroft int events;
795 1.15 cgd struct proc *p;
796 1.15 cgd {
797 1.15 cgd
798 1.28 mycroft return (events & (POLLIN | POLLOUT | POLLRDNORM | POLLWRNORM));
799 1.15 cgd }
800 1.15 cgd
801 1.15 cgd /*
802 1.15 cgd * Record a select request.
803 1.15 cgd */
804 1.15 cgd void
805 1.15 cgd selrecord(selector, sip)
806 1.15 cgd struct proc *selector;
807 1.15 cgd struct selinfo *sip;
808 1.15 cgd {
809 1.15 cgd struct proc *p;
810 1.15 cgd pid_t mypid;
811 1.15 cgd
812 1.15 cgd mypid = selector->p_pid;
813 1.15 cgd if (sip->si_pid == mypid)
814 1.15 cgd return;
815 1.15 cgd if (sip->si_pid && (p = pfind(sip->si_pid)) &&
816 1.15 cgd p->p_wchan == (caddr_t)&selwait)
817 1.15 cgd sip->si_flags |= SI_COLL;
818 1.15 cgd else
819 1.15 cgd sip->si_pid = mypid;
820 1.15 cgd }
821 1.15 cgd
822 1.15 cgd /*
823 1.15 cgd * Do a wakeup when a selectable event occurs.
824 1.15 cgd */
825 1.15 cgd void
826 1.15 cgd selwakeup(sip)
827 1.15 cgd register struct selinfo *sip;
828 1.15 cgd {
829 1.15 cgd register struct proc *p;
830 1.15 cgd int s;
831 1.15 cgd
832 1.15 cgd if (sip->si_pid == 0)
833 1.15 cgd return;
834 1.15 cgd if (sip->si_flags & SI_COLL) {
835 1.15 cgd nselcoll++;
836 1.15 cgd sip->si_flags &= ~SI_COLL;
837 1.15 cgd wakeup((caddr_t)&selwait);
838 1.15 cgd }
839 1.15 cgd p = pfind(sip->si_pid);
840 1.15 cgd sip->si_pid = 0;
841 1.15 cgd if (p != NULL) {
842 1.15 cgd s = splhigh();
843 1.15 cgd if (p->p_wchan == (caddr_t)&selwait) {
844 1.15 cgd if (p->p_stat == SSLEEP)
845 1.15 cgd setrunnable(p);
846 1.15 cgd else
847 1.15 cgd unsleep(p);
848 1.15 cgd } else if (p->p_flag & P_SELECT)
849 1.15 cgd p->p_flag &= ~P_SELECT;
850 1.15 cgd splx(s);
851 1.15 cgd }
852 1.15 cgd }
853