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