kern_descrip.c revision 1.75 1 1.75 thorpej /* $NetBSD: kern_descrip.c,v 1.75 2001/06/06 17:00:00 thorpej Exp $ */
2 1.22 cgd
3 1.16 cgd /*
4 1.17 cgd * Copyright (c) 1982, 1986, 1989, 1991, 1993
5 1.17 cgd * The Regents of the University of California. All rights reserved.
6 1.16 cgd * (c) UNIX System Laboratories, Inc.
7 1.16 cgd * All or some portions of this file are derived from material licensed
8 1.16 cgd * to the University of California by American Telephone and Telegraph
9 1.16 cgd * Co. or Unix System Laboratories, Inc. and are reproduced herein with
10 1.16 cgd * the permission of UNIX System Laboratories, Inc.
11 1.16 cgd *
12 1.16 cgd * Redistribution and use in source and binary forms, with or without
13 1.16 cgd * modification, are permitted provided that the following conditions
14 1.16 cgd * are met:
15 1.16 cgd * 1. Redistributions of source code must retain the above copyright
16 1.16 cgd * notice, this list of conditions and the following disclaimer.
17 1.16 cgd * 2. Redistributions in binary form must reproduce the above copyright
18 1.16 cgd * notice, this list of conditions and the following disclaimer in the
19 1.16 cgd * documentation and/or other materials provided with the distribution.
20 1.16 cgd * 3. All advertising materials mentioning features or use of this software
21 1.16 cgd * must display the following acknowledgement:
22 1.16 cgd * This product includes software developed by the University of
23 1.16 cgd * California, Berkeley and its contributors.
24 1.16 cgd * 4. Neither the name of the University nor the names of its contributors
25 1.16 cgd * may be used to endorse or promote products derived from this software
26 1.16 cgd * without specific prior written permission.
27 1.16 cgd *
28 1.16 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
29 1.16 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
30 1.16 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
31 1.16 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
32 1.16 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
33 1.16 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
34 1.16 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
35 1.16 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
36 1.16 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
37 1.16 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
38 1.16 cgd * SUCH DAMAGE.
39 1.16 cgd *
40 1.51 fvdl * @(#)kern_descrip.c 8.8 (Berkeley) 2/14/95
41 1.16 cgd */
42 1.50 mrg
43 1.16 cgd #include <sys/param.h>
44 1.16 cgd #include <sys/systm.h>
45 1.16 cgd #include <sys/filedesc.h>
46 1.16 cgd #include <sys/kernel.h>
47 1.16 cgd #include <sys/vnode.h>
48 1.16 cgd #include <sys/proc.h>
49 1.16 cgd #include <sys/file.h>
50 1.16 cgd #include <sys/socket.h>
51 1.16 cgd #include <sys/socketvar.h>
52 1.16 cgd #include <sys/stat.h>
53 1.16 cgd #include <sys/ioctl.h>
54 1.16 cgd #include <sys/fcntl.h>
55 1.16 cgd #include <sys/malloc.h>
56 1.55 thorpej #include <sys/pool.h>
57 1.16 cgd #include <sys/syslog.h>
58 1.17 cgd #include <sys/unistd.h>
59 1.16 cgd #include <sys/resourcevar.h>
60 1.42 christos #include <sys/conf.h>
61 1.16 cgd
62 1.25 cgd #include <sys/mount.h>
63 1.25 cgd #include <sys/syscallargs.h>
64 1.38 christos
65 1.16 cgd /*
66 1.16 cgd * Descriptor management.
67 1.16 cgd */
68 1.72 lukem struct filelist filehead; /* head of list of open files */
69 1.72 lukem int nfiles; /* actual number of open files */
70 1.72 lukem struct pool file_pool; /* memory pool for file structures */
71 1.72 lukem struct pool cwdi_pool; /* memory pool for cwdinfo structures */
72 1.72 lukem struct pool filedesc0_pool; /* memory pool for filedesc0 structures */
73 1.72 lukem
74 1.72 lukem static __inline void fd_used(struct filedesc *, int);
75 1.72 lukem static __inline void fd_unused(struct filedesc *, int);
76 1.72 lukem int finishdup(struct proc *, int, int, register_t *);
77 1.72 lukem int fcntl_forfs(int, struct proc *, int, void *);
78 1.38 christos
79 1.38 christos static __inline void
80 1.72 lukem fd_used(struct filedesc *fdp, int fd)
81 1.27 mycroft {
82 1.27 mycroft
83 1.27 mycroft if (fd > fdp->fd_lastfile)
84 1.27 mycroft fdp->fd_lastfile = fd;
85 1.27 mycroft }
86 1.27 mycroft
87 1.38 christos static __inline void
88 1.72 lukem fd_unused(struct filedesc *fdp, int fd)
89 1.27 mycroft {
90 1.27 mycroft
91 1.27 mycroft if (fd < fdp->fd_freefile)
92 1.27 mycroft fdp->fd_freefile = fd;
93 1.27 mycroft #ifdef DIAGNOSTIC
94 1.27 mycroft if (fd > fdp->fd_lastfile)
95 1.27 mycroft panic("fd_unused: fd_lastfile inconsistent");
96 1.27 mycroft #endif
97 1.27 mycroft if (fd == fdp->fd_lastfile) {
98 1.27 mycroft do {
99 1.27 mycroft fd--;
100 1.27 mycroft } while (fd >= 0 && fdp->fd_ofiles[fd] == NULL);
101 1.27 mycroft fdp->fd_lastfile = fd;
102 1.27 mycroft }
103 1.27 mycroft }
104 1.27 mycroft
105 1.16 cgd /*
106 1.16 cgd * System calls on descriptors.
107 1.16 cgd */
108 1.18 cgd
109 1.16 cgd /*
110 1.16 cgd * Duplicate a file descriptor.
111 1.16 cgd */
112 1.16 cgd /* ARGSUSED */
113 1.38 christos int
114 1.72 lukem sys_dup(struct proc *p, void *v, register_t *retval)
115 1.36 thorpej {
116 1.37 mycroft struct sys_dup_args /* {
117 1.72 lukem syscallarg(int) fd;
118 1.36 thorpej } */ *uap = v;
119 1.72 lukem struct file *fp;
120 1.72 lukem struct filedesc *fdp;
121 1.72 lukem int old, new, error;
122 1.72 lukem
123 1.72 lukem fdp = p->p_fd;
124 1.72 lukem old = SCARG(uap, fd);
125 1.16 cgd
126 1.75 thorpej restart:
127 1.59 thorpej if ((u_int)old >= fdp->fd_nfiles ||
128 1.59 thorpej (fp = fdp->fd_ofiles[old]) == NULL ||
129 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0)
130 1.16 cgd return (EBADF);
131 1.59 thorpej
132 1.59 thorpej FILE_USE(fp);
133 1.59 thorpej
134 1.59 thorpej if ((error = fdalloc(p, 0, &new)) != 0) {
135 1.59 thorpej FILE_UNUSE(fp, p);
136 1.75 thorpej if (error == ERESTART)
137 1.75 thorpej goto restart;
138 1.16 cgd return (error);
139 1.59 thorpej }
140 1.59 thorpej
141 1.59 thorpej /* finishdup() will unuse the descriptors for us */
142 1.59 thorpej return (finishdup(p, old, new, retval));
143 1.16 cgd }
144 1.16 cgd
145 1.16 cgd /*
146 1.16 cgd * Duplicate a file descriptor to a particular value.
147 1.16 cgd */
148 1.16 cgd /* ARGSUSED */
149 1.38 christos int
150 1.72 lukem sys_dup2(struct proc *p, void *v, register_t *retval)
151 1.36 thorpej {
152 1.37 mycroft struct sys_dup2_args /* {
153 1.72 lukem syscallarg(int) from;
154 1.72 lukem syscallarg(int) to;
155 1.36 thorpej } */ *uap = v;
156 1.72 lukem struct file *fp;
157 1.72 lukem struct filedesc *fdp;
158 1.72 lukem int old, new, i, error;
159 1.72 lukem
160 1.72 lukem fdp = p->p_fd;
161 1.72 lukem old = SCARG(uap, from);
162 1.72 lukem new = SCARG(uap, to);
163 1.16 cgd
164 1.75 thorpej restart:
165 1.59 thorpej if ((u_int)old >= fdp->fd_nfiles ||
166 1.59 thorpej (fp = fdp->fd_ofiles[old]) == NULL ||
167 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0 ||
168 1.27 mycroft (u_int)new >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
169 1.27 mycroft (u_int)new >= maxfiles)
170 1.16 cgd return (EBADF);
171 1.17 cgd if (old == new) {
172 1.17 cgd *retval = new;
173 1.16 cgd return (0);
174 1.17 cgd }
175 1.59 thorpej
176 1.59 thorpej FILE_USE(fp);
177 1.59 thorpej
178 1.16 cgd if (new >= fdp->fd_nfiles) {
179 1.59 thorpej if ((error = fdalloc(p, new, &i)) != 0) {
180 1.59 thorpej FILE_UNUSE(fp, p);
181 1.75 thorpej if (error == ERESTART)
182 1.75 thorpej goto restart;
183 1.16 cgd return (error);
184 1.59 thorpej }
185 1.16 cgd if (new != i)
186 1.16 cgd panic("dup2: fdalloc");
187 1.16 cgd }
188 1.59 thorpej
189 1.75 thorpej /*
190 1.75 thorpej * finishdup() will close the file that's in the `new'
191 1.75 thorpej * slot, if there's one there.
192 1.75 thorpej */
193 1.75 thorpej
194 1.59 thorpej /* finishdup() will unuse the descriptors for us */
195 1.59 thorpej return (finishdup(p, old, new, retval));
196 1.16 cgd }
197 1.16 cgd
198 1.16 cgd /*
199 1.16 cgd * The file control system call.
200 1.16 cgd */
201 1.16 cgd /* ARGSUSED */
202 1.38 christos int
203 1.72 lukem sys_fcntl(struct proc *p, void *v, register_t *retval)
204 1.36 thorpej {
205 1.66 augustss struct sys_fcntl_args /* {
206 1.72 lukem syscallarg(int) fd;
207 1.72 lukem syscallarg(int) cmd;
208 1.72 lukem syscallarg(void *) arg;
209 1.36 thorpej } */ *uap = v;
210 1.72 lukem struct filedesc *fdp;
211 1.72 lukem struct file *fp;
212 1.72 lukem struct vnode *vp;
213 1.72 lukem int fd, i, tmp, error, flg, cmd, newmin;
214 1.72 lukem struct flock fl;
215 1.72 lukem
216 1.72 lukem fd = SCARG(uap, fd);
217 1.72 lukem fdp = p->p_fd;
218 1.72 lukem error = 0;
219 1.72 lukem flg = F_POSIX;
220 1.16 cgd
221 1.75 thorpej restart:
222 1.27 mycroft if ((u_int)fd >= fdp->fd_nfiles ||
223 1.59 thorpej (fp = fdp->fd_ofiles[fd]) == NULL ||
224 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0)
225 1.16 cgd return (EBADF);
226 1.59 thorpej
227 1.59 thorpej FILE_USE(fp);
228 1.59 thorpej
229 1.61 wrstuden cmd = SCARG(uap, cmd);
230 1.61 wrstuden if ((cmd & F_FSCTL)) {
231 1.61 wrstuden error = fcntl_forfs(fd, p, cmd, SCARG(uap, arg));
232 1.61 wrstuden goto out;
233 1.61 wrstuden }
234 1.61 wrstuden
235 1.61 wrstuden switch (cmd) {
236 1.17 cgd
237 1.16 cgd case F_DUPFD:
238 1.30 cgd newmin = (long)SCARG(uap, arg);
239 1.27 mycroft if ((u_int)newmin >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
240 1.59 thorpej (u_int)newmin >= maxfiles) {
241 1.59 thorpej error = EINVAL;
242 1.59 thorpej goto out;
243 1.59 thorpej }
244 1.75 thorpej if ((error = fdalloc(p, newmin, &i)) != 0) {
245 1.75 thorpej if (error == ERESTART) {
246 1.75 thorpej FILE_UNUSE(fp, p);
247 1.75 thorpej goto restart;
248 1.75 thorpej }
249 1.59 thorpej goto out;
250 1.75 thorpej }
251 1.59 thorpej
252 1.59 thorpej /* finishdup() will unuse the descriptors for us */
253 1.59 thorpej return (finishdup(p, fd, i, retval));
254 1.16 cgd
255 1.16 cgd case F_GETFD:
256 1.27 mycroft *retval = fdp->fd_ofileflags[fd] & UF_EXCLOSE ? 1 : 0;
257 1.59 thorpej break;
258 1.16 cgd
259 1.16 cgd case F_SETFD:
260 1.27 mycroft if ((long)SCARG(uap, arg) & 1)
261 1.27 mycroft fdp->fd_ofileflags[fd] |= UF_EXCLOSE;
262 1.27 mycroft else
263 1.27 mycroft fdp->fd_ofileflags[fd] &= ~UF_EXCLOSE;
264 1.59 thorpej break;
265 1.16 cgd
266 1.16 cgd case F_GETFL:
267 1.16 cgd *retval = OFLAGS(fp->f_flag);
268 1.59 thorpej break;
269 1.16 cgd
270 1.16 cgd case F_SETFL:
271 1.61 wrstuden tmp = FFLAGS((long)SCARG(uap, arg)) & FCNTLFLAGS;
272 1.61 wrstuden error = (*fp->f_ops->fo_fcntl)(fp, F_SETFL, (caddr_t)&tmp, p);
273 1.61 wrstuden if (error)
274 1.62 sommerfe goto out;
275 1.16 cgd fp->f_flag &= ~FCNTLFLAGS;
276 1.61 wrstuden fp->f_flag |= tmp;
277 1.16 cgd tmp = fp->f_flag & FNONBLOCK;
278 1.16 cgd error = (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
279 1.16 cgd if (error)
280 1.59 thorpej goto out;
281 1.16 cgd tmp = fp->f_flag & FASYNC;
282 1.16 cgd error = (*fp->f_ops->fo_ioctl)(fp, FIOASYNC, (caddr_t)&tmp, p);
283 1.59 thorpej if (error == 0)
284 1.59 thorpej goto out;
285 1.16 cgd fp->f_flag &= ~FNONBLOCK;
286 1.16 cgd tmp = 0;
287 1.16 cgd (void) (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
288 1.59 thorpej break;
289 1.16 cgd
290 1.16 cgd case F_GETOWN:
291 1.16 cgd if (fp->f_type == DTYPE_SOCKET) {
292 1.16 cgd *retval = ((struct socket *)fp->f_data)->so_pgid;
293 1.59 thorpej goto out;
294 1.16 cgd }
295 1.16 cgd error = (*fp->f_ops->fo_ioctl)
296 1.41 cgd (fp, TIOCGPGRP, (caddr_t)retval, p);
297 1.16 cgd *retval = -*retval;
298 1.59 thorpej break;
299 1.16 cgd
300 1.16 cgd case F_SETOWN:
301 1.16 cgd if (fp->f_type == DTYPE_SOCKET) {
302 1.25 cgd ((struct socket *)fp->f_data)->so_pgid =
303 1.25 cgd (long)SCARG(uap, arg);
304 1.59 thorpej goto out;
305 1.16 cgd }
306 1.25 cgd if ((long)SCARG(uap, arg) <= 0) {
307 1.70 eeh tmp = (-(long)SCARG(uap, arg));
308 1.16 cgd } else {
309 1.25 cgd struct proc *p1 = pfind((long)SCARG(uap, arg));
310 1.59 thorpej if (p1 == 0) {
311 1.59 thorpej error = ESRCH;
312 1.59 thorpej goto out;
313 1.59 thorpej }
314 1.71 fvdl tmp = (long)p1->p_pgrp->pg_id;
315 1.16 cgd }
316 1.59 thorpej error = (*fp->f_ops->fo_ioctl)
317 1.70 eeh (fp, TIOCSPGRP, (caddr_t)&tmp, p);
318 1.59 thorpej break;
319 1.16 cgd
320 1.16 cgd case F_SETLKW:
321 1.16 cgd flg |= F_WAIT;
322 1.16 cgd /* Fall into F_SETLK */
323 1.16 cgd
324 1.16 cgd case F_SETLK:
325 1.59 thorpej if (fp->f_type != DTYPE_VNODE) {
326 1.59 thorpej error = EINVAL;
327 1.59 thorpej goto out;
328 1.59 thorpej }
329 1.16 cgd vp = (struct vnode *)fp->f_data;
330 1.16 cgd /* Copy in the lock structure */
331 1.25 cgd error = copyin((caddr_t)SCARG(uap, arg), (caddr_t)&fl,
332 1.52 perry sizeof(fl));
333 1.16 cgd if (error)
334 1.59 thorpej goto out;
335 1.16 cgd if (fl.l_whence == SEEK_CUR)
336 1.16 cgd fl.l_start += fp->f_offset;
337 1.16 cgd switch (fl.l_type) {
338 1.16 cgd case F_RDLCK:
339 1.59 thorpej if ((fp->f_flag & FREAD) == 0) {
340 1.59 thorpej error = EBADF;
341 1.59 thorpej goto out;
342 1.59 thorpej }
343 1.16 cgd p->p_flag |= P_ADVLOCK;
344 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)p, F_SETLK, &fl, flg);
345 1.59 thorpej goto out;
346 1.16 cgd
347 1.16 cgd case F_WRLCK:
348 1.59 thorpej if ((fp->f_flag & FWRITE) == 0) {
349 1.59 thorpej error = EBADF;
350 1.59 thorpej goto out;
351 1.59 thorpej }
352 1.16 cgd p->p_flag |= P_ADVLOCK;
353 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)p, F_SETLK, &fl, flg);
354 1.59 thorpej goto out;
355 1.16 cgd
356 1.16 cgd case F_UNLCK:
357 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)p, F_UNLCK, &fl,
358 1.59 thorpej F_POSIX);
359 1.59 thorpej goto out;
360 1.16 cgd
361 1.16 cgd default:
362 1.59 thorpej error = EINVAL;
363 1.59 thorpej goto out;
364 1.16 cgd }
365 1.16 cgd
366 1.16 cgd case F_GETLK:
367 1.59 thorpej if (fp->f_type != DTYPE_VNODE) {
368 1.59 thorpej error = EINVAL;
369 1.59 thorpej goto out;
370 1.59 thorpej }
371 1.16 cgd vp = (struct vnode *)fp->f_data;
372 1.16 cgd /* Copy in the lock structure */
373 1.25 cgd error = copyin((caddr_t)SCARG(uap, arg), (caddr_t)&fl,
374 1.52 perry sizeof(fl));
375 1.16 cgd if (error)
376 1.59 thorpej goto out;
377 1.16 cgd if (fl.l_whence == SEEK_CUR)
378 1.16 cgd fl.l_start += fp->f_offset;
379 1.43 kleink if (fl.l_type != F_RDLCK &&
380 1.43 kleink fl.l_type != F_WRLCK &&
381 1.59 thorpej fl.l_type != F_UNLCK) {
382 1.59 thorpej error = EINVAL;
383 1.59 thorpej goto out;
384 1.59 thorpej }
385 1.38 christos error = VOP_ADVLOCK(vp, (caddr_t)p, F_GETLK, &fl, F_POSIX);
386 1.38 christos if (error)
387 1.59 thorpej goto out;
388 1.59 thorpej error = copyout((caddr_t)&fl, (caddr_t)SCARG(uap, arg),
389 1.59 thorpej sizeof(fl));
390 1.59 thorpej break;
391 1.16 cgd
392 1.16 cgd default:
393 1.59 thorpej error = EINVAL;
394 1.16 cgd }
395 1.59 thorpej
396 1.59 thorpej out:
397 1.59 thorpej FILE_UNUSE(fp, p);
398 1.59 thorpej return (error);
399 1.16 cgd }
400 1.16 cgd
401 1.16 cgd /*
402 1.17 cgd * Common code for dup, dup2, and fcntl(F_DUPFD).
403 1.17 cgd */
404 1.17 cgd int
405 1.72 lukem finishdup(struct proc *p, int old, int new, register_t *retval)
406 1.17 cgd {
407 1.72 lukem struct filedesc *fdp;
408 1.75 thorpej struct file *fp, *delfp;
409 1.72 lukem
410 1.72 lukem fdp = p->p_fd;
411 1.59 thorpej
412 1.59 thorpej /*
413 1.75 thorpej * If there is a file in the new slot, remember it so we
414 1.75 thorpej * can close it after we've finished the dup. We need
415 1.75 thorpej * to do it after the dup is finished, since closing
416 1.75 thorpej * the file may block.
417 1.75 thorpej *
418 1.59 thorpej * Note: `old' is already used for us.
419 1.59 thorpej */
420 1.75 thorpej delfp = fdp->fd_ofiles[new];
421 1.17 cgd
422 1.17 cgd fp = fdp->fd_ofiles[old];
423 1.17 cgd fdp->fd_ofiles[new] = fp;
424 1.17 cgd fdp->fd_ofileflags[new] = fdp->fd_ofileflags[old] &~ UF_EXCLOSE;
425 1.17 cgd fp->f_count++;
426 1.75 thorpej /*
427 1.75 thorpej * Note, don't have to mark it "used" in the table if there
428 1.75 thorpej * was already a file in the `new' slot.
429 1.75 thorpej */
430 1.75 thorpej if (delfp == NULL)
431 1.75 thorpej fd_used(fdp, new);
432 1.17 cgd *retval = new;
433 1.59 thorpej FILE_UNUSE(fp, p);
434 1.75 thorpej
435 1.75 thorpej if (delfp != NULL) {
436 1.75 thorpej FILE_USE(delfp);
437 1.75 thorpej (void) closef(delfp, p);
438 1.75 thorpej }
439 1.17 cgd return (0);
440 1.65 thorpej }
441 1.65 thorpej
442 1.65 thorpej void
443 1.72 lukem fdremove(struct filedesc *fdp, int fd)
444 1.65 thorpej {
445 1.65 thorpej
446 1.65 thorpej fdp->fd_ofiles[fd] = NULL;
447 1.65 thorpej fd_unused(fdp, fd);
448 1.17 cgd }
449 1.17 cgd
450 1.27 mycroft int
451 1.72 lukem fdrelease(struct proc *p, int fd)
452 1.72 lukem {
453 1.72 lukem struct filedesc *fdp;
454 1.72 lukem struct file **fpp, *fp;
455 1.27 mycroft
456 1.72 lukem fdp = p->p_fd;
457 1.27 mycroft fpp = &fdp->fd_ofiles[fd];
458 1.27 mycroft fp = *fpp;
459 1.27 mycroft if (fp == NULL)
460 1.27 mycroft return (EBADF);
461 1.59 thorpej
462 1.59 thorpej FILE_USE(fp);
463 1.59 thorpej
464 1.27 mycroft *fpp = NULL;
465 1.75 thorpej fdp->fd_ofileflags[fd] = 0;
466 1.27 mycroft fd_unused(fdp, fd);
467 1.27 mycroft return (closef(fp, p));
468 1.27 mycroft }
469 1.27 mycroft
470 1.17 cgd /*
471 1.16 cgd * Close a file descriptor.
472 1.16 cgd */
473 1.16 cgd /* ARGSUSED */
474 1.38 christos int
475 1.72 lukem sys_close(struct proc *p, void *v, register_t *retval)
476 1.36 thorpej {
477 1.37 mycroft struct sys_close_args /* {
478 1.72 lukem syscallarg(int) fd;
479 1.36 thorpej } */ *uap = v;
480 1.72 lukem int fd;
481 1.72 lukem struct filedesc *fdp;
482 1.16 cgd
483 1.72 lukem fd = SCARG(uap, fd);
484 1.72 lukem fdp = p->p_fd;
485 1.27 mycroft if ((u_int)fd >= fdp->fd_nfiles)
486 1.16 cgd return (EBADF);
487 1.34 mycroft return (fdrelease(p, fd));
488 1.16 cgd }
489 1.16 cgd
490 1.17 cgd /*
491 1.17 cgd * Return status information about a file descriptor.
492 1.17 cgd */
493 1.16 cgd /* ARGSUSED */
494 1.38 christos int
495 1.72 lukem sys___fstat13(struct proc *p, void *v, register_t *retval)
496 1.36 thorpej {
497 1.66 augustss struct sys___fstat13_args /* {
498 1.72 lukem syscallarg(int) fd;
499 1.72 lukem syscallarg(struct stat *) sb;
500 1.36 thorpej } */ *uap = v;
501 1.72 lukem int fd;
502 1.72 lukem struct filedesc *fdp;
503 1.72 lukem struct file *fp;
504 1.72 lukem struct stat ub;
505 1.72 lukem int error;
506 1.16 cgd
507 1.72 lukem fd = SCARG(uap, fd);
508 1.72 lukem fdp = p->p_fd;
509 1.27 mycroft if ((u_int)fd >= fdp->fd_nfiles ||
510 1.59 thorpej (fp = fdp->fd_ofiles[fd]) == NULL ||
511 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0)
512 1.16 cgd return (EBADF);
513 1.59 thorpej
514 1.59 thorpej FILE_USE(fp);
515 1.74 jdolecek error = (*fp->f_ops->fo_stat)(fp, &ub, p);
516 1.73 jdolecek FILE_UNUSE(fp, p);
517 1.59 thorpej
518 1.16 cgd if (error == 0)
519 1.52 perry error = copyout(&ub, SCARG(uap, sb), sizeof(ub));
520 1.73 jdolecek
521 1.16 cgd return (error);
522 1.16 cgd }
523 1.16 cgd
524 1.16 cgd /*
525 1.16 cgd * Return pathconf information about a file descriptor.
526 1.16 cgd */
527 1.16 cgd /* ARGSUSED */
528 1.38 christos int
529 1.72 lukem sys_fpathconf(struct proc *p, void *v, register_t *retval)
530 1.36 thorpej {
531 1.66 augustss struct sys_fpathconf_args /* {
532 1.72 lukem syscallarg(int) fd;
533 1.72 lukem syscallarg(int) name;
534 1.36 thorpej } */ *uap = v;
535 1.72 lukem int fd;
536 1.72 lukem struct filedesc *fdp;
537 1.72 lukem struct file *fp;
538 1.72 lukem struct vnode *vp;
539 1.72 lukem int error;
540 1.72 lukem
541 1.72 lukem fd = SCARG(uap, fd);
542 1.72 lukem fdp = p->p_fd;
543 1.72 lukem error = 0;
544 1.17 cgd
545 1.27 mycroft if ((u_int)fd >= fdp->fd_nfiles ||
546 1.59 thorpej (fp = fdp->fd_ofiles[fd]) == NULL ||
547 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0)
548 1.17 cgd return (EBADF);
549 1.59 thorpej
550 1.59 thorpej FILE_USE(fp);
551 1.59 thorpej
552 1.17 cgd switch (fp->f_type) {
553 1.16 cgd
554 1.17 cgd case DTYPE_SOCKET:
555 1.25 cgd if (SCARG(uap, name) != _PC_PIPE_BUF)
556 1.59 thorpej error = EINVAL;
557 1.59 thorpej else
558 1.59 thorpej *retval = PIPE_BUF;
559 1.59 thorpej break;
560 1.17 cgd
561 1.17 cgd case DTYPE_VNODE:
562 1.17 cgd vp = (struct vnode *)fp->f_data;
563 1.59 thorpej error = VOP_PATHCONF(vp, SCARG(uap, name), retval);
564 1.59 thorpej break;
565 1.17 cgd
566 1.17 cgd default:
567 1.17 cgd panic("fpathconf");
568 1.17 cgd }
569 1.59 thorpej
570 1.59 thorpej FILE_UNUSE(fp, p);
571 1.59 thorpej return (error);
572 1.16 cgd }
573 1.16 cgd
574 1.16 cgd /*
575 1.16 cgd * Allocate a file descriptor for the process.
576 1.16 cgd */
577 1.72 lukem int fdexpand; /* XXX: what else uses this? */
578 1.16 cgd
579 1.38 christos int
580 1.72 lukem fdalloc(struct proc *p, int want, int *result)
581 1.72 lukem {
582 1.72 lukem struct filedesc *fdp;
583 1.75 thorpej int i, lim, last, nfiles, rv = 0;
584 1.72 lukem struct file **newofile;
585 1.72 lukem char *newofileflags;
586 1.72 lukem
587 1.72 lukem fdp = p->p_fd;
588 1.16 cgd
589 1.16 cgd /*
590 1.16 cgd * Search for a free descriptor starting at the higher
591 1.16 cgd * of want or fd_freefile. If that fails, consider
592 1.16 cgd * expanding the ofile array.
593 1.16 cgd */
594 1.17 cgd lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfiles);
595 1.16 cgd for (;;) {
596 1.16 cgd last = min(fdp->fd_nfiles, lim);
597 1.16 cgd if ((i = want) < fdp->fd_freefile)
598 1.16 cgd i = fdp->fd_freefile;
599 1.16 cgd for (; i < last; i++) {
600 1.16 cgd if (fdp->fd_ofiles[i] == NULL) {
601 1.27 mycroft fd_used(fdp, i);
602 1.16 cgd if (want <= fdp->fd_freefile)
603 1.16 cgd fdp->fd_freefile = i;
604 1.16 cgd *result = i;
605 1.75 thorpej return (rv);
606 1.16 cgd }
607 1.16 cgd }
608 1.16 cgd
609 1.16 cgd /*
610 1.16 cgd * No space in current array. Expand?
611 1.16 cgd */
612 1.16 cgd if (fdp->fd_nfiles >= lim)
613 1.16 cgd return (EMFILE);
614 1.16 cgd if (fdp->fd_nfiles < NDEXTENT)
615 1.16 cgd nfiles = NDEXTENT;
616 1.16 cgd else
617 1.16 cgd nfiles = 2 * fdp->fd_nfiles;
618 1.75 thorpej rv = ERESTART;
619 1.64 thorpej newofile = malloc(nfiles * OFILESIZE, M_FILEDESC, M_WAITOK);
620 1.16 cgd newofileflags = (char *) &newofile[nfiles];
621 1.16 cgd /*
622 1.16 cgd * Copy the existing ofile and ofileflags arrays
623 1.16 cgd * and zero the new portion of each array.
624 1.16 cgd */
625 1.53 perry memcpy(newofile, fdp->fd_ofiles,
626 1.16 cgd (i = sizeof(struct file *) * fdp->fd_nfiles));
627 1.72 lukem memset((char *)newofile + i, 0,
628 1.72 lukem nfiles * sizeof(struct file *) - i);
629 1.53 perry memcpy(newofileflags, fdp->fd_ofileflags,
630 1.72 lukem (i = sizeof(char) * fdp->fd_nfiles));
631 1.53 perry memset(newofileflags + i, 0, nfiles * sizeof(char) - i);
632 1.16 cgd if (fdp->fd_nfiles > NDFILE)
633 1.64 thorpej free(fdp->fd_ofiles, M_FILEDESC);
634 1.16 cgd fdp->fd_ofiles = newofile;
635 1.16 cgd fdp->fd_ofileflags = newofileflags;
636 1.16 cgd fdp->fd_nfiles = nfiles;
637 1.16 cgd fdexpand++;
638 1.16 cgd }
639 1.16 cgd }
640 1.16 cgd
641 1.16 cgd /*
642 1.16 cgd * Check to see whether n user file descriptors
643 1.16 cgd * are available to the process p.
644 1.16 cgd */
645 1.38 christos int
646 1.72 lukem fdavail(struct proc *p, int n)
647 1.72 lukem {
648 1.72 lukem struct filedesc *fdp;
649 1.72 lukem struct file **fpp;
650 1.72 lukem int i, lim;
651 1.16 cgd
652 1.72 lukem fdp = p->p_fd;
653 1.17 cgd lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfiles);
654 1.17 cgd if ((i = lim - fdp->fd_nfiles) > 0 && (n -= i) <= 0)
655 1.16 cgd return (1);
656 1.16 cgd fpp = &fdp->fd_ofiles[fdp->fd_freefile];
657 1.56 sommerfe for (i = min(lim,fdp->fd_nfiles) - fdp->fd_freefile; --i >= 0; fpp++)
658 1.16 cgd if (*fpp == NULL && --n <= 0)
659 1.16 cgd return (1);
660 1.16 cgd return (0);
661 1.16 cgd }
662 1.16 cgd
663 1.16 cgd /*
664 1.55 thorpej * Initialize the data structures necessary for managing files.
665 1.55 thorpej */
666 1.55 thorpej void
667 1.72 lukem finit(void)
668 1.55 thorpej {
669 1.55 thorpej
670 1.55 thorpej pool_init(&file_pool, sizeof(struct file), 0, 0, 0, "filepl",
671 1.55 thorpej 0, pool_page_alloc_nointr, pool_page_free_nointr, M_FILE);
672 1.58 thorpej pool_init(&cwdi_pool, sizeof(struct cwdinfo), 0, 0, 0, "cwdipl",
673 1.58 thorpej 0, pool_page_alloc_nointr, pool_page_free_nointr, M_FILEDESC);
674 1.64 thorpej pool_init(&filedesc0_pool, sizeof(struct filedesc0), 0, 0, 0, "fdescpl",
675 1.64 thorpej 0, pool_page_alloc_nointr, pool_page_free_nointr, M_FILEDESC);
676 1.55 thorpej }
677 1.55 thorpej
678 1.55 thorpej /*
679 1.16 cgd * Create a new open file structure and allocate
680 1.16 cgd * a file decriptor for the process that refers to it.
681 1.16 cgd */
682 1.38 christos int
683 1.72 lukem falloc(struct proc *p, struct file **resultfp, int *resultfd)
684 1.16 cgd {
685 1.72 lukem struct file *fp, *fq;
686 1.72 lukem int error, i;
687 1.16 cgd
688 1.75 thorpej restart:
689 1.75 thorpej if ((error = fdalloc(p, 0, &i)) != 0) {
690 1.75 thorpej if (error == ERESTART)
691 1.75 thorpej goto restart;
692 1.16 cgd return (error);
693 1.75 thorpej }
694 1.16 cgd if (nfiles >= maxfiles) {
695 1.69 jdolecek tablefull("file", "increase kern.maxfiles or MAXFILES");
696 1.16 cgd return (ENFILE);
697 1.16 cgd }
698 1.16 cgd /*
699 1.16 cgd * Allocate a new file descriptor.
700 1.16 cgd * If the process has file descriptor zero open, add to the list
701 1.16 cgd * of open files at that point, otherwise put it at the front of
702 1.16 cgd * the list of open files.
703 1.16 cgd */
704 1.16 cgd nfiles++;
705 1.55 thorpej fp = pool_get(&file_pool, PR_WAITOK);
706 1.53 perry memset(fp, 0, sizeof(struct file));
707 1.38 christos if ((fq = p->p_fd->fd_ofiles[0]) != NULL) {
708 1.24 mycroft LIST_INSERT_AFTER(fq, fp, f_list);
709 1.24 mycroft } else {
710 1.24 mycroft LIST_INSERT_HEAD(&filehead, fp, f_list);
711 1.24 mycroft }
712 1.16 cgd p->p_fd->fd_ofiles[i] = fp;
713 1.16 cgd fp->f_count = 1;
714 1.16 cgd fp->f_cred = p->p_ucred;
715 1.16 cgd crhold(fp->f_cred);
716 1.59 thorpej if (resultfp) {
717 1.59 thorpej FILE_USE(fp);
718 1.16 cgd *resultfp = fp;
719 1.59 thorpej }
720 1.16 cgd if (resultfd)
721 1.16 cgd *resultfd = i;
722 1.16 cgd return (0);
723 1.16 cgd }
724 1.16 cgd
725 1.16 cgd /*
726 1.16 cgd * Free a file descriptor.
727 1.16 cgd */
728 1.38 christos void
729 1.72 lukem ffree(struct file *fp)
730 1.16 cgd {
731 1.59 thorpej
732 1.59 thorpej #ifdef DIAGNOSTIC
733 1.59 thorpej if (fp->f_usecount)
734 1.59 thorpej panic("ffree");
735 1.59 thorpej #endif
736 1.59 thorpej
737 1.24 mycroft LIST_REMOVE(fp, f_list);
738 1.16 cgd crfree(fp->f_cred);
739 1.16 cgd #ifdef DIAGNOSTIC
740 1.16 cgd fp->f_count = 0;
741 1.16 cgd #endif
742 1.16 cgd nfiles--;
743 1.55 thorpej pool_put(&file_pool, fp);
744 1.48 thorpej }
745 1.48 thorpej
746 1.48 thorpej /*
747 1.58 thorpej * Create an initial cwdinfo structure, using the same current and root
748 1.58 thorpej * directories as p.
749 1.58 thorpej */
750 1.58 thorpej struct cwdinfo *
751 1.72 lukem cwdinit(struct proc *p)
752 1.58 thorpej {
753 1.58 thorpej struct cwdinfo *cwdi;
754 1.58 thorpej
755 1.58 thorpej cwdi = pool_get(&cwdi_pool, PR_WAITOK);
756 1.58 thorpej
757 1.58 thorpej cwdi->cwdi_cdir = p->p_cwdi->cwdi_cdir;
758 1.63 thorpej if (cwdi->cwdi_cdir)
759 1.63 thorpej VREF(cwdi->cwdi_cdir);
760 1.58 thorpej cwdi->cwdi_rdir = p->p_cwdi->cwdi_rdir;
761 1.58 thorpej if (cwdi->cwdi_rdir)
762 1.58 thorpej VREF(cwdi->cwdi_rdir);
763 1.60 christos cwdi->cwdi_cmask = p->p_cwdi->cwdi_cmask;
764 1.58 thorpej cwdi->cwdi_refcnt = 1;
765 1.58 thorpej
766 1.58 thorpej return (cwdi);
767 1.58 thorpej }
768 1.58 thorpej
769 1.58 thorpej /*
770 1.58 thorpej * Make p2 share p1's cwdinfo.
771 1.58 thorpej */
772 1.58 thorpej void
773 1.72 lukem cwdshare(struct proc *p1, struct proc *p2)
774 1.58 thorpej {
775 1.58 thorpej
776 1.58 thorpej p2->p_cwdi = p1->p_cwdi;
777 1.58 thorpej p1->p_cwdi->cwdi_refcnt++;
778 1.58 thorpej }
779 1.58 thorpej
780 1.58 thorpej /*
781 1.58 thorpej * Make this process not share its cwdinfo structure, maintaining
782 1.58 thorpej * all cwdinfo state.
783 1.58 thorpej */
784 1.58 thorpej void
785 1.72 lukem cwdunshare(struct proc *p)
786 1.58 thorpej {
787 1.58 thorpej struct cwdinfo *newcwdi;
788 1.58 thorpej
789 1.58 thorpej if (p->p_cwdi->cwdi_refcnt == 1)
790 1.58 thorpej return;
791 1.58 thorpej
792 1.58 thorpej newcwdi = cwdinit(p);
793 1.58 thorpej cwdfree(p);
794 1.58 thorpej p->p_cwdi = newcwdi;
795 1.58 thorpej }
796 1.58 thorpej
797 1.58 thorpej /*
798 1.58 thorpej * Release a cwdinfo structure.
799 1.58 thorpej */
800 1.58 thorpej void
801 1.72 lukem cwdfree(struct proc *p)
802 1.58 thorpej {
803 1.72 lukem struct cwdinfo *cwdi;
804 1.58 thorpej
805 1.72 lukem cwdi = p->p_cwdi;
806 1.58 thorpej if (--cwdi->cwdi_refcnt > 0)
807 1.58 thorpej return;
808 1.58 thorpej
809 1.58 thorpej p->p_cwdi = NULL;
810 1.58 thorpej
811 1.58 thorpej vrele(cwdi->cwdi_cdir);
812 1.58 thorpej if (cwdi->cwdi_rdir)
813 1.58 thorpej vrele(cwdi->cwdi_rdir);
814 1.58 thorpej pool_put(&cwdi_pool, cwdi);
815 1.58 thorpej }
816 1.58 thorpej
817 1.58 thorpej /*
818 1.48 thorpej * Create an initial filedesc structure, using the same current and root
819 1.48 thorpej * directories as p.
820 1.48 thorpej */
821 1.48 thorpej struct filedesc *
822 1.72 lukem fdinit(struct proc *p)
823 1.48 thorpej {
824 1.48 thorpej struct filedesc0 *newfdp;
825 1.48 thorpej
826 1.64 thorpej newfdp = pool_get(&filedesc0_pool, PR_WAITOK);
827 1.53 perry memset(newfdp, 0, sizeof(struct filedesc0));
828 1.48 thorpej
829 1.48 thorpej fdinit1(newfdp);
830 1.48 thorpej
831 1.48 thorpej return (&newfdp->fd_fd);
832 1.48 thorpej }
833 1.48 thorpej
834 1.48 thorpej /*
835 1.48 thorpej * Initialize a file descriptor table.
836 1.48 thorpej */
837 1.48 thorpej void
838 1.72 lukem fdinit1(struct filedesc0 *newfdp)
839 1.48 thorpej {
840 1.48 thorpej
841 1.48 thorpej newfdp->fd_fd.fd_refcnt = 1;
842 1.48 thorpej newfdp->fd_fd.fd_ofiles = newfdp->fd_dfiles;
843 1.48 thorpej newfdp->fd_fd.fd_ofileflags = newfdp->fd_dfileflags;
844 1.48 thorpej newfdp->fd_fd.fd_nfiles = NDFILE;
845 1.48 thorpej }
846 1.48 thorpej
847 1.48 thorpej /*
848 1.48 thorpej * Make p2 share p1's filedesc structure.
849 1.48 thorpej */
850 1.48 thorpej void
851 1.72 lukem fdshare(struct proc *p1, struct proc *p2)
852 1.48 thorpej {
853 1.48 thorpej
854 1.48 thorpej p2->p_fd = p1->p_fd;
855 1.48 thorpej p1->p_fd->fd_refcnt++;
856 1.48 thorpej }
857 1.48 thorpej
858 1.48 thorpej /*
859 1.48 thorpej * Make this process not share its filedesc structure, maintaining
860 1.48 thorpej * all file descriptor state.
861 1.48 thorpej */
862 1.48 thorpej void
863 1.72 lukem fdunshare(struct proc *p)
864 1.48 thorpej {
865 1.48 thorpej struct filedesc *newfd;
866 1.48 thorpej
867 1.48 thorpej if (p->p_fd->fd_refcnt == 1)
868 1.48 thorpej return;
869 1.48 thorpej
870 1.48 thorpej newfd = fdcopy(p);
871 1.48 thorpej fdfree(p);
872 1.48 thorpej p->p_fd = newfd;
873 1.48 thorpej }
874 1.48 thorpej
875 1.48 thorpej /*
876 1.48 thorpej * Clear a process's fd table.
877 1.48 thorpej */
878 1.48 thorpej void
879 1.72 lukem fdclear(struct proc *p)
880 1.48 thorpej {
881 1.48 thorpej struct filedesc *newfd;
882 1.48 thorpej
883 1.48 thorpej newfd = fdinit(p);
884 1.48 thorpej fdfree(p);
885 1.48 thorpej p->p_fd = newfd;
886 1.16 cgd }
887 1.16 cgd
888 1.16 cgd /*
889 1.16 cgd * Copy a filedesc structure.
890 1.16 cgd */
891 1.16 cgd struct filedesc *
892 1.72 lukem fdcopy(struct proc *p)
893 1.16 cgd {
894 1.72 lukem struct filedesc *newfdp, *fdp;
895 1.72 lukem struct file **fpp;
896 1.72 lukem int i;
897 1.16 cgd
898 1.72 lukem fdp = p->p_fd;
899 1.64 thorpej newfdp = pool_get(&filedesc0_pool, PR_WAITOK);
900 1.53 perry memcpy(newfdp, fdp, sizeof(struct filedesc));
901 1.16 cgd newfdp->fd_refcnt = 1;
902 1.16 cgd
903 1.16 cgd /*
904 1.16 cgd * If the number of open files fits in the internal arrays
905 1.16 cgd * of the open file structure, use them, otherwise allocate
906 1.16 cgd * additional memory for the number of descriptors currently
907 1.16 cgd * in use.
908 1.16 cgd */
909 1.16 cgd if (newfdp->fd_lastfile < NDFILE) {
910 1.16 cgd newfdp->fd_ofiles = ((struct filedesc0 *) newfdp)->fd_dfiles;
911 1.16 cgd newfdp->fd_ofileflags =
912 1.16 cgd ((struct filedesc0 *) newfdp)->fd_dfileflags;
913 1.16 cgd i = NDFILE;
914 1.16 cgd } else {
915 1.16 cgd /*
916 1.16 cgd * Compute the smallest multiple of NDEXTENT needed
917 1.16 cgd * for the file descriptors currently in use,
918 1.16 cgd * allowing the table to shrink.
919 1.16 cgd */
920 1.16 cgd i = newfdp->fd_nfiles;
921 1.27 mycroft while (i >= 2 * NDEXTENT && i > newfdp->fd_lastfile * 2)
922 1.16 cgd i /= 2;
923 1.64 thorpej newfdp->fd_ofiles = malloc(i * OFILESIZE, M_FILEDESC, M_WAITOK);
924 1.16 cgd newfdp->fd_ofileflags = (char *) &newfdp->fd_ofiles[i];
925 1.16 cgd }
926 1.16 cgd newfdp->fd_nfiles = i;
927 1.53 perry memcpy(newfdp->fd_ofiles, fdp->fd_ofiles, i * sizeof(struct file **));
928 1.53 perry memcpy(newfdp->fd_ofileflags, fdp->fd_ofileflags, i * sizeof(char));
929 1.16 cgd fpp = newfdp->fd_ofiles;
930 1.27 mycroft for (i = newfdp->fd_lastfile; i >= 0; i--, fpp++)
931 1.16 cgd if (*fpp != NULL)
932 1.16 cgd (*fpp)->f_count++;
933 1.16 cgd return (newfdp);
934 1.16 cgd }
935 1.16 cgd
936 1.16 cgd /*
937 1.16 cgd * Release a filedesc structure.
938 1.16 cgd */
939 1.16 cgd void
940 1.72 lukem fdfree(struct proc *p)
941 1.16 cgd {
942 1.72 lukem struct filedesc *fdp;
943 1.72 lukem struct file **fpp, *fp;
944 1.72 lukem int i;
945 1.16 cgd
946 1.72 lukem fdp = p->p_fd;
947 1.16 cgd if (--fdp->fd_refcnt > 0)
948 1.16 cgd return;
949 1.16 cgd fpp = fdp->fd_ofiles;
950 1.32 mycroft for (i = fdp->fd_lastfile; i >= 0; i--, fpp++) {
951 1.32 mycroft fp = *fpp;
952 1.32 mycroft if (fp != NULL) {
953 1.32 mycroft *fpp = NULL;
954 1.59 thorpej FILE_USE(fp);
955 1.32 mycroft (void) closef(fp, p);
956 1.32 mycroft }
957 1.32 mycroft }
958 1.32 mycroft p->p_fd = NULL;
959 1.16 cgd if (fdp->fd_nfiles > NDFILE)
960 1.64 thorpej free(fdp->fd_ofiles, M_FILEDESC);
961 1.64 thorpej pool_put(&filedesc0_pool, fdp);
962 1.16 cgd }
963 1.16 cgd
964 1.16 cgd /*
965 1.16 cgd * Internal form of close.
966 1.16 cgd * Decrement reference count on file structure.
967 1.17 cgd * Note: p may be NULL when closing a file
968 1.17 cgd * that was being passed in a message.
969 1.59 thorpej *
970 1.59 thorpej * Note: we expect the caller is holding a usecount, and expects us
971 1.59 thorpej * to drop it (the caller thinks the file is going away forever).
972 1.16 cgd */
973 1.38 christos int
974 1.72 lukem closef(struct file *fp, struct proc *p)
975 1.72 lukem {
976 1.72 lukem struct vnode *vp;
977 1.72 lukem struct flock lf;
978 1.72 lukem int error;
979 1.16 cgd
980 1.16 cgd if (fp == NULL)
981 1.16 cgd return (0);
982 1.59 thorpej
983 1.16 cgd /*
984 1.16 cgd * POSIX record locking dictates that any close releases ALL
985 1.16 cgd * locks owned by this process. This is handled by setting
986 1.16 cgd * a flag in the unlock to free ONLY locks obeying POSIX
987 1.16 cgd * semantics, and not to free BSD-style file locks.
988 1.17 cgd * If the descriptor was in a message, POSIX-style locks
989 1.17 cgd * aren't passed with the descriptor.
990 1.16 cgd */
991 1.16 cgd if (p && (p->p_flag & P_ADVLOCK) && fp->f_type == DTYPE_VNODE) {
992 1.16 cgd lf.l_whence = SEEK_SET;
993 1.16 cgd lf.l_start = 0;
994 1.16 cgd lf.l_len = 0;
995 1.16 cgd lf.l_type = F_UNLCK;
996 1.16 cgd vp = (struct vnode *)fp->f_data;
997 1.16 cgd (void) VOP_ADVLOCK(vp, (caddr_t)p, F_UNLCK, &lf, F_POSIX);
998 1.16 cgd }
999 1.59 thorpej
1000 1.59 thorpej /*
1001 1.59 thorpej * If WANTCLOSE is set, then the reference count on the file
1002 1.59 thorpej * is 0, but there were multiple users of the file. This can
1003 1.59 thorpej * happen if a filedesc structure is shared by multiple
1004 1.59 thorpej * processes.
1005 1.59 thorpej */
1006 1.59 thorpej if (fp->f_iflags & FIF_WANTCLOSE) {
1007 1.59 thorpej /*
1008 1.59 thorpej * Another user of the file is already closing, and is
1009 1.59 thorpej * simply waiting for other users of the file to drain.
1010 1.59 thorpej * Release our usecount, and wake up the closer if it
1011 1.59 thorpej * is the only remaining use.
1012 1.59 thorpej */
1013 1.59 thorpej #ifdef DIAGNOSTIC
1014 1.59 thorpej if (fp->f_count != 0)
1015 1.59 thorpej panic("closef: wantclose and count != 0");
1016 1.59 thorpej if (fp->f_usecount < 2)
1017 1.59 thorpej panic("closef: wantclose and usecount < 2");
1018 1.59 thorpej #endif
1019 1.59 thorpej if (--fp->f_usecount == 1)
1020 1.59 thorpej wakeup(&fp->f_usecount);
1021 1.16 cgd return (0);
1022 1.59 thorpej } else {
1023 1.59 thorpej /*
1024 1.59 thorpej * Decrement the reference count. If we were not the
1025 1.59 thorpej * last reference, then release our use and just
1026 1.59 thorpej * return.
1027 1.59 thorpej */
1028 1.59 thorpej if (--fp->f_count > 0) {
1029 1.59 thorpej #ifdef DIAGNOSTIC
1030 1.59 thorpej if (fp->f_usecount < 1)
1031 1.59 thorpej panic("closef: no wantclose and usecount < 1");
1032 1.59 thorpej #endif
1033 1.59 thorpej fp->f_usecount--;
1034 1.59 thorpej return (0);
1035 1.59 thorpej }
1036 1.59 thorpej if (fp->f_count < 0)
1037 1.59 thorpej panic("closef: count < 0");
1038 1.59 thorpej }
1039 1.59 thorpej
1040 1.59 thorpej /*
1041 1.59 thorpej * The reference count is now 0. However, there may be
1042 1.59 thorpej * multiple potential users of this file. This can happen
1043 1.59 thorpej * if multiple processes shared a single filedesc structure.
1044 1.59 thorpej *
1045 1.59 thorpej * Notify these potential users that the file is closing.
1046 1.59 thorpej * This will prevent them from adding additional uses to
1047 1.59 thorpej * the file.
1048 1.59 thorpej */
1049 1.59 thorpej fp->f_iflags |= FIF_WANTCLOSE;
1050 1.59 thorpej
1051 1.59 thorpej /*
1052 1.59 thorpej * We expect the caller to add a use to the file. So, if we
1053 1.59 thorpej * are the last user, usecount will be 1. If it is not, we
1054 1.59 thorpej * must wait for the usecount to drain. When it drains back
1055 1.59 thorpej * to 1, we will be awakened so that we may proceed with the
1056 1.59 thorpej * close.
1057 1.59 thorpej */
1058 1.59 thorpej #ifdef DIAGNOSTIC
1059 1.59 thorpej if (fp->f_usecount < 1)
1060 1.59 thorpej panic("closef: usecount < 1");
1061 1.59 thorpej #endif
1062 1.59 thorpej while (fp->f_usecount > 1)
1063 1.59 thorpej (void) tsleep(&fp->f_usecount, PRIBIO, "closef", 0);
1064 1.59 thorpej #ifdef DIAGNOSTIC
1065 1.59 thorpej if (fp->f_usecount != 1)
1066 1.59 thorpej panic("closef: usecount != 1");
1067 1.59 thorpej #endif
1068 1.59 thorpej
1069 1.16 cgd if ((fp->f_flag & FHASLOCK) && fp->f_type == DTYPE_VNODE) {
1070 1.16 cgd lf.l_whence = SEEK_SET;
1071 1.16 cgd lf.l_start = 0;
1072 1.16 cgd lf.l_len = 0;
1073 1.16 cgd lf.l_type = F_UNLCK;
1074 1.16 cgd vp = (struct vnode *)fp->f_data;
1075 1.16 cgd (void) VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK);
1076 1.16 cgd }
1077 1.17 cgd if (fp->f_ops)
1078 1.17 cgd error = (*fp->f_ops->fo_close)(fp, p);
1079 1.17 cgd else
1080 1.17 cgd error = 0;
1081 1.59 thorpej
1082 1.59 thorpej /* Nothing references the file now, drop the final use (us). */
1083 1.59 thorpej fp->f_usecount--;
1084 1.59 thorpej
1085 1.16 cgd ffree(fp);
1086 1.16 cgd return (error);
1087 1.16 cgd }
1088 1.16 cgd
1089 1.16 cgd /*
1090 1.16 cgd * Apply an advisory lock on a file descriptor.
1091 1.16 cgd *
1092 1.16 cgd * Just attempt to get a record lock of the requested type on
1093 1.16 cgd * the entire file (l_whence = SEEK_SET, l_start = 0, l_len = 0).
1094 1.16 cgd */
1095 1.16 cgd /* ARGSUSED */
1096 1.38 christos int
1097 1.72 lukem sys_flock(struct proc *p, void *v, register_t *retval)
1098 1.36 thorpej {
1099 1.66 augustss struct sys_flock_args /* {
1100 1.72 lukem syscallarg(int) fd;
1101 1.72 lukem syscallarg(int) how;
1102 1.36 thorpej } */ *uap = v;
1103 1.72 lukem int fd, how, error;
1104 1.72 lukem struct filedesc *fdp;
1105 1.72 lukem struct file *fp;
1106 1.72 lukem struct vnode *vp;
1107 1.72 lukem struct flock lf;
1108 1.16 cgd
1109 1.72 lukem fd = SCARG(uap, fd);
1110 1.72 lukem how = SCARG(uap, how);
1111 1.72 lukem fdp = p->p_fd;
1112 1.72 lukem error = 0;
1113 1.27 mycroft if ((u_int)fd >= fdp->fd_nfiles ||
1114 1.59 thorpej (fp = fdp->fd_ofiles[fd]) == NULL ||
1115 1.59 thorpej (fp->f_iflags & FIF_WANTCLOSE) != 0)
1116 1.16 cgd return (EBADF);
1117 1.59 thorpej
1118 1.59 thorpej FILE_USE(fp);
1119 1.59 thorpej
1120 1.59 thorpej if (fp->f_type != DTYPE_VNODE) {
1121 1.59 thorpej error = EOPNOTSUPP;
1122 1.59 thorpej goto out;
1123 1.59 thorpej }
1124 1.59 thorpej
1125 1.16 cgd vp = (struct vnode *)fp->f_data;
1126 1.16 cgd lf.l_whence = SEEK_SET;
1127 1.16 cgd lf.l_start = 0;
1128 1.16 cgd lf.l_len = 0;
1129 1.27 mycroft if (how & LOCK_UN) {
1130 1.16 cgd lf.l_type = F_UNLCK;
1131 1.16 cgd fp->f_flag &= ~FHASLOCK;
1132 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK);
1133 1.59 thorpej goto out;
1134 1.16 cgd }
1135 1.27 mycroft if (how & LOCK_EX)
1136 1.16 cgd lf.l_type = F_WRLCK;
1137 1.27 mycroft else if (how & LOCK_SH)
1138 1.16 cgd lf.l_type = F_RDLCK;
1139 1.59 thorpej else {
1140 1.59 thorpej error = EINVAL;
1141 1.59 thorpej goto out;
1142 1.59 thorpej }
1143 1.16 cgd fp->f_flag |= FHASLOCK;
1144 1.27 mycroft if (how & LOCK_NB)
1145 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf, F_FLOCK);
1146 1.59 thorpej else
1147 1.59 thorpej error = VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf,
1148 1.59 thorpej F_FLOCK|F_WAIT);
1149 1.59 thorpej out:
1150 1.59 thorpej FILE_UNUSE(fp, p);
1151 1.59 thorpej return (error);
1152 1.16 cgd }
1153 1.16 cgd
1154 1.16 cgd /*
1155 1.16 cgd * File Descriptor pseudo-device driver (/dev/fd/).
1156 1.16 cgd *
1157 1.16 cgd * Opening minor device N dup()s the file (if any) connected to file
1158 1.16 cgd * descriptor N belonging to the calling process. Note that this driver
1159 1.16 cgd * consists of only the ``open()'' routine, because all subsequent
1160 1.16 cgd * references to this file will be direct to the other driver.
1161 1.16 cgd */
1162 1.16 cgd /* ARGSUSED */
1163 1.28 mycroft int
1164 1.72 lukem filedescopen(dev_t dev, int mode, int type, struct proc *p)
1165 1.16 cgd {
1166 1.16 cgd
1167 1.28 mycroft /*
1168 1.67 sommerfe * XXX Kludge: set p->p_dupfd to contain the value of the
1169 1.28 mycroft * the file descriptor being sought for duplication. The error
1170 1.28 mycroft * return ensures that the vnode for this device will be released
1171 1.28 mycroft * by vn_open. Open will detect this special error and take the
1172 1.28 mycroft * actions in dupfdopen below. Other callers of vn_open or VOP_OPEN
1173 1.28 mycroft * will simply report the error.
1174 1.28 mycroft */
1175 1.28 mycroft p->p_dupfd = minor(dev);
1176 1.28 mycroft return (ENODEV);
1177 1.27 mycroft }
1178 1.27 mycroft
1179 1.28 mycroft /*
1180 1.28 mycroft * Duplicate the specified descriptor to a free descriptor.
1181 1.28 mycroft */
1182 1.27 mycroft int
1183 1.72 lukem dupfdopen(struct proc *p, int indx, int dfd, int mode, int error)
1184 1.72 lukem {
1185 1.72 lukem struct filedesc *fdp;
1186 1.72 lukem struct file *wfp, *fp;
1187 1.27 mycroft
1188 1.72 lukem fdp = p->p_fd;
1189 1.27 mycroft /*
1190 1.27 mycroft * If the to-be-dup'd fd number is greater than the allowed number
1191 1.27 mycroft * of file descriptors, or the fd to be dup'd has already been
1192 1.27 mycroft * closed, reject. Note, check for new == old is necessary as
1193 1.27 mycroft * falloc could allocate an already closed to-be-dup'd descriptor
1194 1.27 mycroft * as the new descriptor.
1195 1.27 mycroft */
1196 1.28 mycroft fp = fdp->fd_ofiles[indx];
1197 1.28 mycroft if ((u_int)dfd >= fdp->fd_nfiles ||
1198 1.59 thorpej (wfp = fdp->fd_ofiles[dfd]) == NULL ||
1199 1.59 thorpej (wfp->f_iflags & FIF_WANTCLOSE) != 0 ||
1200 1.59 thorpej fp == wfp)
1201 1.27 mycroft return (EBADF);
1202 1.27 mycroft
1203 1.59 thorpej FILE_USE(wfp);
1204 1.59 thorpej
1205 1.27 mycroft /*
1206 1.28 mycroft * There are two cases of interest here.
1207 1.28 mycroft *
1208 1.28 mycroft * For ENODEV simply dup (dfd) to file descriptor
1209 1.28 mycroft * (indx) and return.
1210 1.28 mycroft *
1211 1.28 mycroft * For ENXIO steal away the file structure from (dfd) and
1212 1.28 mycroft * store it in (indx). (dfd) is effectively closed by
1213 1.28 mycroft * this operation.
1214 1.28 mycroft *
1215 1.28 mycroft * Any other error code is just returned.
1216 1.27 mycroft */
1217 1.28 mycroft switch (error) {
1218 1.28 mycroft case ENODEV:
1219 1.28 mycroft /*
1220 1.28 mycroft * Check that the mode the file is being opened for is a
1221 1.28 mycroft * subset of the mode of the existing descriptor.
1222 1.28 mycroft */
1223 1.59 thorpej if (((mode & (FREAD|FWRITE)) | wfp->f_flag) != wfp->f_flag) {
1224 1.59 thorpej FILE_UNUSE(wfp, p);
1225 1.28 mycroft return (EACCES);
1226 1.59 thorpej }
1227 1.28 mycroft fdp->fd_ofiles[indx] = wfp;
1228 1.28 mycroft fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1229 1.28 mycroft wfp->f_count++;
1230 1.28 mycroft fd_used(fdp, indx);
1231 1.59 thorpej FILE_UNUSE(wfp, p);
1232 1.28 mycroft return (0);
1233 1.27 mycroft
1234 1.28 mycroft case ENXIO:
1235 1.28 mycroft /*
1236 1.28 mycroft * Steal away the file pointer from dfd, and stuff it into indx.
1237 1.28 mycroft */
1238 1.28 mycroft fdp->fd_ofiles[indx] = fdp->fd_ofiles[dfd];
1239 1.28 mycroft fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1240 1.28 mycroft fdp->fd_ofiles[dfd] = NULL;
1241 1.28 mycroft fdp->fd_ofileflags[dfd] = 0;
1242 1.28 mycroft /*
1243 1.28 mycroft * Complete the clean up of the filedesc structure by
1244 1.28 mycroft * recomputing the various hints.
1245 1.28 mycroft */
1246 1.28 mycroft fd_used(fdp, indx);
1247 1.28 mycroft fd_unused(fdp, dfd);
1248 1.59 thorpej FILE_UNUSE(wfp, p);
1249 1.28 mycroft return (0);
1250 1.16 cgd
1251 1.28 mycroft default:
1252 1.59 thorpej FILE_UNUSE(wfp, p);
1253 1.28 mycroft return (error);
1254 1.28 mycroft }
1255 1.28 mycroft /* NOTREACHED */
1256 1.61 wrstuden }
1257 1.61 wrstuden
1258 1.61 wrstuden /*
1259 1.61 wrstuden * fcntl call which is being passed to the file's fs.
1260 1.61 wrstuden */
1261 1.61 wrstuden int
1262 1.72 lukem fcntl_forfs(int fd, struct proc *p, int cmd, void *arg)
1263 1.61 wrstuden {
1264 1.72 lukem struct file *fp;
1265 1.72 lukem struct filedesc *fdp;
1266 1.72 lukem int error;
1267 1.72 lukem u_int size;
1268 1.72 lukem caddr_t data, memp;
1269 1.61 wrstuden #define STK_PARAMS 128
1270 1.72 lukem char stkbuf[STK_PARAMS];
1271 1.61 wrstuden
1272 1.61 wrstuden /* fd's value was validated in sys_fcntl before calling this routine */
1273 1.61 wrstuden fdp = p->p_fd;
1274 1.61 wrstuden fp = fdp->fd_ofiles[fd];
1275 1.61 wrstuden
1276 1.61 wrstuden if ((fp->f_flag & (FREAD | FWRITE)) == 0)
1277 1.61 wrstuden return (EBADF);
1278 1.61 wrstuden
1279 1.61 wrstuden /*
1280 1.61 wrstuden * Interpret high order word to find amount of data to be
1281 1.61 wrstuden * copied to/from the user's address space.
1282 1.61 wrstuden */
1283 1.61 wrstuden size = (size_t)F_PARAM_LEN(cmd);
1284 1.61 wrstuden if (size > F_PARAM_MAX)
1285 1.61 wrstuden return (EINVAL);
1286 1.61 wrstuden memp = NULL;
1287 1.61 wrstuden if (size > sizeof(stkbuf)) {
1288 1.61 wrstuden memp = (caddr_t)malloc((u_long)size, M_IOCTLOPS, M_WAITOK);
1289 1.61 wrstuden data = memp;
1290 1.61 wrstuden } else
1291 1.61 wrstuden data = stkbuf;
1292 1.61 wrstuden if (cmd & F_FSIN) {
1293 1.61 wrstuden if (size) {
1294 1.61 wrstuden error = copyin(arg, data, size);
1295 1.61 wrstuden if (error) {
1296 1.61 wrstuden if (memp)
1297 1.61 wrstuden free(memp, M_IOCTLOPS);
1298 1.61 wrstuden return (error);
1299 1.61 wrstuden }
1300 1.61 wrstuden } else
1301 1.61 wrstuden *(caddr_t *)data = arg;
1302 1.61 wrstuden } else if ((cmd & F_FSOUT) && size)
1303 1.61 wrstuden /*
1304 1.61 wrstuden * Zero the buffer so the user always
1305 1.61 wrstuden * gets back something deterministic.
1306 1.61 wrstuden */
1307 1.61 wrstuden memset(data, 0, size);
1308 1.61 wrstuden else if (cmd & F_FSVOID)
1309 1.61 wrstuden *(caddr_t *)data = arg;
1310 1.61 wrstuden
1311 1.61 wrstuden
1312 1.61 wrstuden error = (*fp->f_ops->fo_fcntl)(fp, cmd, data, p);
1313 1.61 wrstuden
1314 1.61 wrstuden /*
1315 1.61 wrstuden * Copy any data to user, size was
1316 1.61 wrstuden * already set and checked above.
1317 1.61 wrstuden */
1318 1.61 wrstuden if (error == 0 && (cmd & F_FSOUT) && size)
1319 1.61 wrstuden error = copyout(data, arg, size);
1320 1.61 wrstuden if (memp)
1321 1.61 wrstuden free(memp, M_IOCTLOPS);
1322 1.61 wrstuden return (error);
1323 1.27 mycroft }
1324 1.16 cgd
1325 1.27 mycroft /*
1326 1.27 mycroft * Close any files on exec?
1327 1.27 mycroft */
1328 1.27 mycroft void
1329 1.72 lukem fdcloseexec(struct proc *p)
1330 1.27 mycroft {
1331 1.72 lukem struct filedesc *fdp;
1332 1.72 lukem int fd;
1333 1.16 cgd
1334 1.72 lukem fdp = p->p_fd;
1335 1.27 mycroft for (fd = 0; fd <= fdp->fd_lastfile; fd++)
1336 1.27 mycroft if (fdp->fd_ofileflags[fd] & UF_EXCLOSE)
1337 1.34 mycroft (void) fdrelease(p, fd);
1338 1.16 cgd }
1339