Home | History | Annotate | Line # | Download | only in kern
kern_descrip.c revision 1.159.8.2
      1  1.159.8.2      matt /*	$NetBSD: kern_descrip.c,v 1.159.8.2 2007/11/08 11:00:00 matt 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.111       agc  * 3. Neither the name of the University nor the names of its contributors
     21       1.16       cgd  *    may be used to endorse or promote products derived from this software
     22       1.16       cgd  *    without specific prior written permission.
     23       1.16       cgd  *
     24       1.16       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     25       1.16       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     26       1.16       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     27       1.16       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     28       1.16       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     29       1.16       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     30       1.16       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     31       1.16       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     32       1.16       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     33       1.16       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     34       1.16       cgd  * SUCH DAMAGE.
     35       1.16       cgd  *
     36       1.51      fvdl  *	@(#)kern_descrip.c	8.8 (Berkeley) 2/14/95
     37       1.16       cgd  */
     38       1.81     lukem 
     39       1.81     lukem #include <sys/cdefs.h>
     40  1.159.8.2      matt __KERNEL_RCSID(0, "$NetBSD: kern_descrip.c,v 1.159.8.2 2007/11/08 11:00:00 matt Exp $");
     41       1.50       mrg 
     42       1.16       cgd #include <sys/param.h>
     43       1.16       cgd #include <sys/systm.h>
     44       1.16       cgd #include <sys/filedesc.h>
     45       1.16       cgd #include <sys/kernel.h>
     46       1.16       cgd #include <sys/vnode.h>
     47       1.16       cgd #include <sys/proc.h>
     48       1.16       cgd #include <sys/file.h>
     49       1.86  christos #include <sys/namei.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.96  jdolecek #include <sys/event.h>
     62      1.143      elad #include <sys/kauth.h>
     63       1.16       cgd 
     64       1.25       cgd #include <sys/mount.h>
     65       1.25       cgd #include <sys/syscallargs.h>
     66       1.38  christos 
     67  1.159.8.2      matt static int	cwdi_ctor(void *, void *, int);
     68  1.159.8.2      matt static void	cwdi_dtor(void *, void *);
     69  1.159.8.2      matt 
     70       1.16       cgd /*
     71       1.16       cgd  * Descriptor management.
     72       1.16       cgd  */
     73       1.72     lukem struct filelist	filehead;	/* head of list of open files */
     74       1.72     lukem int		nfiles;		/* actual number of open files */
     75  1.159.8.1      matt 
     76  1.159.8.2      matt static pool_cache_t cwdi_cache;
     77  1.159.8.2      matt static pool_cache_t filedesc0_cache;
     78  1.159.8.2      matt static pool_cache_t file_cache;
     79      1.101   thorpej 
     80      1.102        pk /* Global file list lock */
     81  1.159.8.1      matt kmutex_t filelist_lock;
     82      1.102        pk 
     83      1.101   thorpej MALLOC_DEFINE(M_FILE, "file", "Open file structure");
     84      1.101   thorpej MALLOC_DEFINE(M_FILEDESC, "file desc", "Open file descriptor table");
     85      1.101   thorpej MALLOC_DEFINE(M_IOCTLOPS, "ioctlops", "ioctl data buffer");
     86       1.72     lukem 
     87      1.139     perry static inline int
     88      1.115    provos find_next_zero(uint32_t *bitmap, int want, u_int bits)
     89      1.115    provos {
     90      1.115    provos 	int i, off, maxoff;
     91      1.115    provos 	uint32_t sub;
     92      1.115    provos 
     93      1.115    provos 	if (want > bits)
     94      1.115    provos 		return -1;
     95      1.115    provos 
     96      1.115    provos 	off = want >> NDENTRYSHIFT;
     97      1.115    provos 	i = want & NDENTRYMASK;
     98      1.115    provos 	if (i) {
     99      1.115    provos 		sub = bitmap[off] | ((u_int)~0 >> (NDENTRIES - i));
    100      1.115    provos 		if (sub != ~0)
    101      1.115    provos 			goto found;
    102      1.115    provos 		off++;
    103      1.115    provos 	}
    104      1.115    provos 
    105      1.115    provos 	maxoff = NDLOSLOTS(bits);
    106      1.115    provos 	while (off < maxoff) {
    107      1.115    provos 		if ((sub = bitmap[off]) != ~0)
    108      1.115    provos 			goto found;
    109      1.115    provos 		off++;
    110      1.115    provos 	}
    111      1.115    provos 
    112      1.115    provos 	return (-1);
    113      1.115    provos 
    114      1.115    provos  found:
    115      1.115    provos 	return (off << NDENTRYSHIFT) + ffs(~sub) - 1;
    116      1.115    provos }
    117      1.115    provos 
    118      1.134   thorpej static int
    119      1.115    provos find_last_set(struct filedesc *fd, int last)
    120      1.115    provos {
    121      1.115    provos 	int off, i;
    122      1.115    provos 	struct file **ofiles = fd->fd_ofiles;
    123      1.115    provos 	uint32_t *bitmap = fd->fd_lomap;
    124      1.115    provos 
    125      1.115    provos 	off = (last - 1) >> NDENTRYSHIFT;
    126      1.115    provos 
    127      1.121    provos 	while (off >= 0 && !bitmap[off])
    128      1.115    provos 		off--;
    129      1.115    provos 
    130      1.115    provos 	if (off < 0)
    131      1.128      cube 		return (-1);
    132      1.131     perry 
    133      1.115    provos 	i = ((off + 1) << NDENTRYSHIFT) - 1;
    134      1.115    provos 	if (i >= last)
    135      1.115    provos 		i = last - 1;
    136      1.115    provos 
    137      1.115    provos 	while (i > 0 && ofiles[i] == NULL)
    138      1.115    provos 		i--;
    139      1.115    provos 
    140      1.115    provos 	return (i);
    141      1.115    provos }
    142      1.115    provos 
    143      1.139     perry static inline void
    144       1.72     lukem fd_used(struct filedesc *fdp, int fd)
    145       1.27   mycroft {
    146      1.115    provos 	u_int off = fd >> NDENTRYSHIFT;
    147      1.115    provos 
    148  1.159.8.1      matt 	KASSERT(rw_write_held(&fdp->fd_lock));
    149      1.124      yamt 	KDASSERT((fdp->fd_lomap[off] & (1 << (fd & NDENTRYMASK))) == 0);
    150      1.124      yamt 
    151      1.115    provos 	fdp->fd_lomap[off] |= 1 << (fd & NDENTRYMASK);
    152      1.124      yamt 	if (fdp->fd_lomap[off] == ~0) {
    153      1.124      yamt 		KDASSERT((fdp->fd_himap[off >> NDENTRYSHIFT] &
    154      1.124      yamt 		    (1 << (off & NDENTRYMASK))) == 0);
    155      1.115    provos 		fdp->fd_himap[off >> NDENTRYSHIFT] |= 1 << (off & NDENTRYMASK);
    156      1.124      yamt 	}
    157       1.27   mycroft 
    158       1.27   mycroft 	if (fd > fdp->fd_lastfile)
    159       1.27   mycroft 		fdp->fd_lastfile = fd;
    160       1.27   mycroft }
    161       1.27   mycroft 
    162      1.139     perry static inline void
    163       1.72     lukem fd_unused(struct filedesc *fdp, int fd)
    164       1.27   mycroft {
    165      1.115    provos 	u_int off = fd >> NDENTRYSHIFT;
    166       1.27   mycroft 
    167  1.159.8.1      matt 	KASSERT(rw_write_held(&fdp->fd_lock));
    168       1.27   mycroft 	if (fd < fdp->fd_freefile)
    169       1.27   mycroft 		fdp->fd_freefile = fd;
    170      1.115    provos 
    171      1.124      yamt 	if (fdp->fd_lomap[off] == ~0) {
    172      1.124      yamt 		KDASSERT((fdp->fd_himap[off >> NDENTRYSHIFT] &
    173      1.124      yamt 		    (1 << (off & NDENTRYMASK))) != 0);
    174      1.124      yamt 		fdp->fd_himap[off >> NDENTRYSHIFT] &=
    175      1.124      yamt 		    ~(1 << (off & NDENTRYMASK));
    176      1.124      yamt 	}
    177      1.124      yamt 	KDASSERT((fdp->fd_lomap[off] & (1 << (fd & NDENTRYMASK))) != 0);
    178      1.115    provos 	fdp->fd_lomap[off] &= ~(1 << (fd & NDENTRYMASK));
    179      1.115    provos 
    180       1.27   mycroft #ifdef DIAGNOSTIC
    181       1.27   mycroft 	if (fd > fdp->fd_lastfile)
    182       1.27   mycroft 		panic("fd_unused: fd_lastfile inconsistent");
    183       1.27   mycroft #endif
    184      1.115    provos 	if (fd == fdp->fd_lastfile)
    185      1.115    provos 		fdp->fd_lastfile = find_last_set(fdp, fd);
    186       1.27   mycroft }
    187       1.27   mycroft 
    188      1.103        pk /*
    189      1.103        pk  * Lookup the file structure corresponding to a file descriptor
    190      1.103        pk  * and return it locked.
    191      1.103        pk  * Note: typical usage is: `fp = fd_getfile(..); FILE_USE(fp);'
    192      1.103        pk  * The locking strategy has been optimised for this case, i.e.
    193      1.103        pk  * fd_getfile() returns the file locked while FILE_USE() will increment
    194      1.103        pk  * the file's use count and unlock.
    195      1.103        pk  */
    196       1.77   thorpej struct file *
    197       1.77   thorpej fd_getfile(struct filedesc *fdp, int fd)
    198       1.77   thorpej {
    199       1.77   thorpej 	struct file *fp;
    200       1.77   thorpej 
    201  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_READER);
    202  1.159.8.1      matt 	if ((u_int) fd >= fdp->fd_nfiles || (fp = fdp->fd_ofiles[fd]) == NULL) {
    203  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
    204       1.77   thorpej 		return (NULL);
    205  1.159.8.1      matt 	}
    206       1.77   thorpej 
    207  1.159.8.1      matt 	mutex_enter(&fp->f_lock);
    208      1.103        pk 	if (FILE_IS_USABLE(fp) == 0) {
    209  1.159.8.1      matt 		mutex_exit(&fp->f_lock);
    210  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
    211       1.77   thorpej 		return (NULL);
    212      1.103        pk 	}
    213  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    214       1.77   thorpej 
    215       1.77   thorpej 	return (fp);
    216       1.77   thorpej }
    217       1.77   thorpej 
    218       1.16       cgd /*
    219      1.134   thorpej  * Common code for dup, dup2, and fcntl(F_DUPFD).
    220      1.134   thorpej  */
    221      1.134   thorpej static int
    222      1.138  christos finishdup(struct lwp *l, int old, int new, register_t *retval)
    223      1.134   thorpej {
    224      1.134   thorpej 	struct filedesc	*fdp;
    225      1.134   thorpej 	struct file	*fp, *delfp;
    226      1.134   thorpej 
    227      1.138  christos 	fdp = l->l_proc->p_fd;
    228      1.134   thorpej 
    229      1.134   thorpej 	/*
    230      1.134   thorpej 	 * If there is a file in the new slot, remember it so we
    231      1.134   thorpej 	 * can close it after we've finished the dup.  We need
    232      1.134   thorpej 	 * to do it after the dup is finished, since closing
    233      1.134   thorpej 	 * the file may block.
    234      1.134   thorpej 	 *
    235      1.134   thorpej 	 * Note: `old' is already used for us.
    236      1.134   thorpej 	 * Note: Caller already marked `new' slot "used".
    237      1.134   thorpej 	 */
    238  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
    239      1.134   thorpej 	delfp = fdp->fd_ofiles[new];
    240      1.134   thorpej 
    241      1.134   thorpej 	fp = fdp->fd_ofiles[old];
    242      1.134   thorpej 	KDASSERT(fp != NULL);
    243      1.134   thorpej 	fdp->fd_ofiles[new] = fp;
    244      1.134   thorpej 	fdp->fd_ofileflags[new] = fdp->fd_ofileflags[old] &~ UF_EXCLOSE;
    245  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    246      1.134   thorpej 
    247      1.134   thorpej 	*retval = new;
    248  1.159.8.1      matt 	mutex_enter(&fp->f_lock);
    249      1.134   thorpej 	fp->f_count++;
    250      1.138  christos 	FILE_UNUSE_HAVELOCK(fp, l);
    251      1.134   thorpej 
    252      1.134   thorpej 	if (delfp != NULL) {
    253  1.159.8.1      matt 		mutex_enter(&delfp->f_lock);
    254      1.134   thorpej 		FILE_USE(delfp);
    255      1.134   thorpej 		if (new < fdp->fd_knlistsize)
    256      1.138  christos 			knote_fdclose(l, new);
    257      1.138  christos 		(void) closef(delfp, l);
    258      1.134   thorpej 	}
    259      1.134   thorpej 	return (0);
    260      1.134   thorpej }
    261      1.134   thorpej 
    262      1.134   thorpej /*
    263  1.159.8.1      matt  * Initialize the descriptor system.
    264  1.159.8.1      matt  */
    265  1.159.8.1      matt void
    266  1.159.8.1      matt filedesc_init(void)
    267  1.159.8.1      matt {
    268  1.159.8.1      matt 
    269  1.159.8.1      matt 	mutex_init(&filelist_lock, MUTEX_DEFAULT, IPL_NONE);
    270  1.159.8.1      matt 
    271  1.159.8.2      matt 	file_cache = pool_cache_init(sizeof(struct file), 0, 0, 0,
    272  1.159.8.2      matt 	    "filepl", NULL, IPL_NONE, NULL, NULL, NULL);
    273  1.159.8.2      matt 	KASSERT(file_cache != NULL);
    274  1.159.8.2      matt 
    275  1.159.8.2      matt 	cwdi_cache = pool_cache_init(sizeof(struct cwdinfo), 0, 0, 0,
    276  1.159.8.2      matt 	    "cwdipl", NULL, IPL_NONE, cwdi_ctor, cwdi_dtor, NULL);
    277  1.159.8.2      matt 	KASSERT(cwdi_cache != NULL);
    278  1.159.8.2      matt 
    279  1.159.8.2      matt 	filedesc0_cache = pool_cache_init(sizeof(struct filedesc0), 0, 0, 0,
    280  1.159.8.2      matt 	    "fdescpl", NULL, IPL_NONE, NULL, NULL, NULL);
    281  1.159.8.2      matt 	KASSERT(filedesc0_cache != NULL);
    282  1.159.8.1      matt }
    283  1.159.8.1      matt 
    284  1.159.8.1      matt /*
    285       1.16       cgd  * System calls on descriptors.
    286       1.16       cgd  */
    287       1.18       cgd 
    288       1.16       cgd /*
    289       1.16       cgd  * Duplicate a file descriptor.
    290       1.16       cgd  */
    291       1.16       cgd /* ARGSUSED */
    292       1.38  christos int
    293       1.99   thorpej sys_dup(struct lwp *l, void *v, register_t *retval)
    294       1.36   thorpej {
    295       1.37   mycroft 	struct sys_dup_args /* {
    296       1.72     lukem 		syscallarg(int)	fd;
    297       1.36   thorpej 	} */ *uap = v;
    298       1.72     lukem 	struct file	*fp;
    299       1.72     lukem 	struct filedesc	*fdp;
    300       1.99   thorpej 	struct proc	*p;
    301       1.72     lukem 	int		old, new, error;
    302       1.72     lukem 
    303       1.99   thorpej 	p = l->l_proc;
    304       1.72     lukem 	fdp = p->p_fd;
    305       1.72     lukem 	old = SCARG(uap, fd);
    306       1.16       cgd 
    307       1.75   thorpej  restart:
    308       1.77   thorpej 	if ((fp = fd_getfile(fdp, old)) == NULL)
    309       1.16       cgd 		return (EBADF);
    310       1.59   thorpej 
    311       1.59   thorpej 	FILE_USE(fp);
    312       1.59   thorpej 
    313       1.59   thorpej 	if ((error = fdalloc(p, 0, &new)) != 0) {
    314       1.76   thorpej 		if (error == ENOSPC) {
    315       1.76   thorpej 			fdexpand(p);
    316      1.138  christos 			FILE_UNUSE(fp, l);
    317       1.76   thorpej 			goto restart;
    318       1.76   thorpej 		}
    319      1.138  christos 		FILE_UNUSE(fp, l);
    320       1.16       cgd 		return (error);
    321       1.59   thorpej 	}
    322       1.59   thorpej 
    323       1.59   thorpej 	/* finishdup() will unuse the descriptors for us */
    324      1.138  christos 	return (finishdup(l, old, new, retval));
    325       1.16       cgd }
    326       1.16       cgd 
    327       1.16       cgd /*
    328       1.16       cgd  * Duplicate a file descriptor to a particular value.
    329       1.16       cgd  */
    330       1.16       cgd /* ARGSUSED */
    331       1.38  christos int
    332       1.99   thorpej sys_dup2(struct lwp *l, void *v, register_t *retval)
    333       1.36   thorpej {
    334       1.37   mycroft 	struct sys_dup2_args /* {
    335       1.72     lukem 		syscallarg(int)	from;
    336       1.72     lukem 		syscallarg(int)	to;
    337       1.36   thorpej 	} */ *uap = v;
    338       1.72     lukem 	struct file	*fp;
    339       1.72     lukem 	struct filedesc	*fdp;
    340       1.99   thorpej 	struct proc	*p;
    341       1.72     lukem 	int		old, new, i, error;
    342       1.72     lukem 
    343       1.99   thorpej 	p = l->l_proc;
    344       1.72     lukem 	fdp = p->p_fd;
    345       1.72     lukem 	old = SCARG(uap, from);
    346       1.72     lukem 	new = SCARG(uap, to);
    347       1.16       cgd 
    348       1.75   thorpej  restart:
    349       1.77   thorpej 	if ((fp = fd_getfile(fdp, old)) == NULL)
    350       1.77   thorpej 		return (EBADF);
    351       1.77   thorpej 
    352       1.77   thorpej 	if ((u_int)new >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
    353      1.103        pk 	    (u_int)new >= maxfiles) {
    354  1.159.8.1      matt 		mutex_exit(&fp->f_lock);
    355       1.16       cgd 		return (EBADF);
    356      1.103        pk 	}
    357       1.77   thorpej 
    358       1.17       cgd 	if (old == new) {
    359  1.159.8.1      matt 		mutex_exit(&fp->f_lock);
    360       1.17       cgd 		*retval = new;
    361       1.16       cgd 		return (0);
    362       1.17       cgd 	}
    363       1.59   thorpej 
    364       1.59   thorpej 	FILE_USE(fp);
    365       1.59   thorpej 
    366       1.16       cgd 	if (new >= fdp->fd_nfiles) {
    367       1.59   thorpej 		if ((error = fdalloc(p, new, &i)) != 0) {
    368       1.76   thorpej 			if (error == ENOSPC) {
    369       1.76   thorpej 				fdexpand(p);
    370      1.138  christos 				FILE_UNUSE(fp, l);
    371       1.76   thorpej 				goto restart;
    372       1.76   thorpej 			}
    373      1.138  christos 			FILE_UNUSE(fp, l);
    374       1.16       cgd 			return (error);
    375       1.59   thorpej 		}
    376       1.16       cgd 		if (new != i)
    377       1.16       cgd 			panic("dup2: fdalloc");
    378      1.126        pk 	} else {
    379  1.159.8.1      matt 		rw_enter(&fdp->fd_lock, RW_WRITER);
    380      1.117      yamt 		/*
    381      1.117      yamt 		 * Mark `new' slot "used" only if it was empty.
    382      1.117      yamt 		 */
    383      1.126        pk 		if (fdp->fd_ofiles[new] == NULL)
    384      1.126        pk 			fd_used(fdp, new);
    385  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
    386       1.16       cgd 	}
    387       1.59   thorpej 
    388       1.75   thorpej 	/*
    389       1.75   thorpej 	 * finishdup() will close the file that's in the `new'
    390       1.75   thorpej 	 * slot, if there's one there.
    391       1.75   thorpej 	 */
    392       1.75   thorpej 
    393       1.59   thorpej 	/* finishdup() will unuse the descriptors for us */
    394      1.138  christos 	return (finishdup(l, old, new, retval));
    395       1.16       cgd }
    396       1.16       cgd 
    397       1.16       cgd /*
    398      1.134   thorpej  * fcntl call which is being passed to the file's fs.
    399      1.134   thorpej  */
    400      1.134   thorpej static int
    401      1.138  christos fcntl_forfs(int fd, struct lwp *l, int cmd, void *arg)
    402      1.134   thorpej {
    403      1.134   thorpej 	struct file	*fp;
    404      1.134   thorpej 	struct filedesc	*fdp;
    405      1.134   thorpej 	int		error;
    406      1.134   thorpej 	u_int		size;
    407      1.134   thorpej 	void		*data, *memp;
    408      1.134   thorpej #define STK_PARAMS	128
    409      1.134   thorpej 	char		stkbuf[STK_PARAMS];
    410      1.134   thorpej 
    411      1.134   thorpej 	/* fd's value was validated in sys_fcntl before calling this routine */
    412      1.138  christos 	fdp = l->l_proc->p_fd;
    413      1.134   thorpej 	fp = fdp->fd_ofiles[fd];
    414      1.134   thorpej 
    415      1.134   thorpej 	if ((fp->f_flag & (FREAD | FWRITE)) == 0)
    416      1.134   thorpej 		return (EBADF);
    417      1.134   thorpej 
    418      1.134   thorpej 	/*
    419      1.134   thorpej 	 * Interpret high order word to find amount of data to be
    420      1.134   thorpej 	 * copied to/from the user's address space.
    421      1.134   thorpej 	 */
    422      1.134   thorpej 	size = (size_t)F_PARAM_LEN(cmd);
    423      1.134   thorpej 	if (size > F_PARAM_MAX)
    424      1.134   thorpej 		return (EINVAL);
    425      1.134   thorpej 	memp = NULL;
    426      1.134   thorpej 	if (size > sizeof(stkbuf)) {
    427      1.134   thorpej 		memp = malloc((u_long)size, M_IOCTLOPS, M_WAITOK);
    428      1.134   thorpej 		data = memp;
    429      1.134   thorpej 	} else
    430      1.134   thorpej 		data = stkbuf;
    431      1.134   thorpej 	if (cmd & F_FSIN) {
    432      1.134   thorpej 		if (size) {
    433      1.134   thorpej 			error = copyin(arg, data, size);
    434      1.134   thorpej 			if (error) {
    435      1.134   thorpej 				if (memp)
    436      1.134   thorpej 					free(memp, M_IOCTLOPS);
    437      1.134   thorpej 				return (error);
    438      1.134   thorpej 			}
    439      1.134   thorpej 		} else
    440      1.134   thorpej 			*(void **)data = arg;
    441      1.134   thorpej 	} else if ((cmd & F_FSOUT) && size)
    442      1.134   thorpej 		/*
    443      1.134   thorpej 		 * Zero the buffer so the user always
    444      1.134   thorpej 		 * gets back something deterministic.
    445      1.134   thorpej 		 */
    446      1.134   thorpej 		memset(data, 0, size);
    447      1.134   thorpej 	else if (cmd & F_FSVOID)
    448      1.134   thorpej 		*(void **)data = arg;
    449      1.134   thorpej 
    450      1.134   thorpej 
    451      1.138  christos 	error = (*fp->f_ops->fo_fcntl)(fp, cmd, data, l);
    452      1.134   thorpej 
    453      1.134   thorpej 	/*
    454      1.134   thorpej 	 * Copy any data to user, size was
    455      1.134   thorpej 	 * already set and checked above.
    456      1.134   thorpej 	 */
    457      1.134   thorpej 	if (error == 0 && (cmd & F_FSOUT) && size)
    458      1.134   thorpej 		error = copyout(data, arg, size);
    459      1.134   thorpej 	if (memp)
    460      1.134   thorpej 		free(memp, M_IOCTLOPS);
    461      1.134   thorpej 	return (error);
    462      1.134   thorpej }
    463      1.134   thorpej 
    464      1.158       dsl int
    465      1.158       dsl do_fcntl_lock(struct lwp *l, int fd, int cmd, struct flock *fl)
    466      1.158       dsl {
    467      1.158       dsl 	struct file *fp;
    468      1.158       dsl 	struct vnode *vp;
    469      1.158       dsl 	struct proc *p = l->l_proc;
    470      1.158       dsl 	int error, flg;
    471      1.158       dsl 
    472      1.158       dsl 	if ((fp = fd_getfile(p->p_fd, fd)) == NULL)
    473      1.158       dsl 		return (EBADF);
    474      1.158       dsl 
    475      1.158       dsl 	FILE_USE(fp);
    476      1.158       dsl 
    477      1.158       dsl 	if (fp->f_type != DTYPE_VNODE) {
    478      1.158       dsl 		error = EINVAL;
    479      1.158       dsl 		goto out;
    480      1.158       dsl 	}
    481      1.158       dsl 	vp = (struct vnode *)fp->f_data;
    482      1.158       dsl 	if (fl->l_whence == SEEK_CUR)
    483      1.158       dsl 		fl->l_start += fp->f_offset;
    484      1.158       dsl 
    485      1.158       dsl 	flg = F_POSIX;
    486      1.158       dsl 
    487      1.158       dsl 	switch (cmd) {
    488      1.158       dsl 
    489      1.158       dsl 	case F_SETLKW:
    490      1.158       dsl 		flg |= F_WAIT;
    491      1.158       dsl 		/* Fall into F_SETLK */
    492      1.158       dsl 
    493      1.158       dsl 	case F_SETLK:
    494      1.158       dsl 		switch (fl->l_type) {
    495      1.158       dsl 		case F_RDLCK:
    496      1.158       dsl 			if ((fp->f_flag & FREAD) == 0) {
    497      1.158       dsl 				error = EBADF;
    498      1.158       dsl 				goto out;
    499      1.158       dsl 			}
    500      1.158       dsl 			p->p_flag |= PK_ADVLOCK;
    501      1.158       dsl 			error = VOP_ADVLOCK(vp, p, F_SETLK, fl, flg);
    502      1.158       dsl 			goto out;
    503      1.158       dsl 
    504      1.158       dsl 		case F_WRLCK:
    505      1.158       dsl 			if ((fp->f_flag & FWRITE) == 0) {
    506      1.158       dsl 				error = EBADF;
    507      1.158       dsl 				goto out;
    508      1.158       dsl 			}
    509      1.158       dsl 			p->p_flag |= PK_ADVLOCK;
    510      1.158       dsl 			error = VOP_ADVLOCK(vp, p, F_SETLK, fl, flg);
    511      1.158       dsl 			goto out;
    512      1.158       dsl 
    513      1.158       dsl 		case F_UNLCK:
    514      1.158       dsl 			error = VOP_ADVLOCK(vp, p, F_UNLCK, fl, F_POSIX);
    515      1.158       dsl 			goto out;
    516      1.158       dsl 
    517      1.158       dsl 		default:
    518      1.158       dsl 			error = EINVAL;
    519      1.158       dsl 			goto out;
    520      1.158       dsl 		}
    521      1.158       dsl 
    522      1.158       dsl 	case F_GETLK:
    523      1.158       dsl 		if (fl->l_type != F_RDLCK &&
    524      1.158       dsl 		    fl->l_type != F_WRLCK &&
    525      1.158       dsl 		    fl->l_type != F_UNLCK) {
    526      1.158       dsl 			error = EINVAL;
    527      1.158       dsl 			goto out;
    528      1.158       dsl 		}
    529      1.158       dsl 		error = VOP_ADVLOCK(vp, p, F_GETLK, fl, F_POSIX);
    530      1.158       dsl 		break;
    531      1.158       dsl 
    532      1.158       dsl 	default:
    533      1.158       dsl 		error = EINVAL;
    534      1.158       dsl 		break;
    535      1.158       dsl 	}
    536      1.158       dsl 
    537      1.158       dsl     out:
    538      1.158       dsl 	FILE_UNUSE(fp, l);
    539      1.158       dsl 	return error;
    540      1.158       dsl }
    541      1.158       dsl 
    542      1.134   thorpej /*
    543       1.16       cgd  * The file control system call.
    544       1.16       cgd  */
    545       1.16       cgd /* ARGSUSED */
    546       1.38  christos int
    547       1.99   thorpej sys_fcntl(struct lwp *l, void *v, register_t *retval)
    548       1.36   thorpej {
    549       1.66  augustss 	struct sys_fcntl_args /* {
    550       1.72     lukem 		syscallarg(int)		fd;
    551       1.72     lukem 		syscallarg(int)		cmd;
    552       1.72     lukem 		syscallarg(void *)	arg;
    553       1.36   thorpej 	} */ *uap = v;
    554       1.72     lukem 	struct filedesc *fdp;
    555       1.72     lukem 	struct file	*fp;
    556       1.99   thorpej 	struct proc	*p;
    557      1.158       dsl 	int		fd, i, tmp, error, cmd, newmin;
    558       1.72     lukem 	struct flock	fl;
    559       1.72     lukem 
    560       1.99   thorpej 	p = l->l_proc;
    561       1.72     lukem 	fd = SCARG(uap, fd);
    562      1.122  christos 	cmd = SCARG(uap, cmd);
    563       1.72     lukem 	fdp = p->p_fd;
    564       1.72     lukem 	error = 0;
    565       1.16       cgd 
    566      1.122  christos 	switch (cmd) {
    567      1.122  christos 	case F_CLOSEM:
    568      1.122  christos 		if (fd < 0)
    569      1.122  christos 			return EBADF;
    570      1.122  christos 		while (fdp->fd_lastfile >= fd)
    571      1.138  christos 			fdrelease(l, fdp->fd_lastfile);
    572      1.122  christos 		return 0;
    573      1.122  christos 
    574      1.122  christos 	case F_MAXFD:
    575      1.123  jdolecek 		*retval = fdp->fd_lastfile;
    576      1.123  jdolecek 		return 0;
    577      1.122  christos 
    578      1.158       dsl 	case F_SETLKW:
    579      1.158       dsl 	case F_SETLK:
    580      1.158       dsl 	case F_GETLK:
    581      1.158       dsl 		error = copyin(SCARG(uap, arg), &fl, sizeof(fl));
    582      1.158       dsl 		if (error)
    583      1.158       dsl 			return error;
    584      1.158       dsl 		error = do_fcntl_lock(l, fd, cmd, &fl);
    585      1.158       dsl 		if (cmd == F_GETLK && error == 0)
    586      1.158       dsl 			error = copyout(&fl, SCARG(uap, arg), sizeof(fl));
    587      1.158       dsl 		return error;
    588      1.158       dsl 
    589      1.122  christos 	default:
    590      1.122  christos 		/* Handled below */
    591      1.122  christos 		break;
    592      1.122  christos 	}
    593      1.122  christos 
    594       1.75   thorpej  restart:
    595       1.77   thorpej 	if ((fp = fd_getfile(fdp, fd)) == NULL)
    596       1.16       cgd 		return (EBADF);
    597       1.59   thorpej 
    598       1.59   thorpej 	FILE_USE(fp);
    599       1.59   thorpej 
    600       1.61  wrstuden 	if ((cmd & F_FSCTL)) {
    601      1.138  christos 		error = fcntl_forfs(fd, l, cmd, SCARG(uap, arg));
    602       1.61  wrstuden 		goto out;
    603       1.61  wrstuden 	}
    604       1.61  wrstuden 
    605       1.61  wrstuden 	switch (cmd) {
    606       1.17       cgd 
    607       1.16       cgd 	case F_DUPFD:
    608       1.30       cgd 		newmin = (long)SCARG(uap, arg);
    609       1.27   mycroft 		if ((u_int)newmin >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
    610       1.59   thorpej 		    (u_int)newmin >= maxfiles) {
    611       1.59   thorpej 			error = EINVAL;
    612       1.59   thorpej 			goto out;
    613       1.59   thorpej 		}
    614       1.75   thorpej 		if ((error = fdalloc(p, newmin, &i)) != 0) {
    615       1.76   thorpej 			if (error == ENOSPC) {
    616       1.76   thorpej 				fdexpand(p);
    617      1.138  christos 				FILE_UNUSE(fp, l);
    618       1.75   thorpej 				goto restart;
    619       1.75   thorpej 			}
    620       1.59   thorpej 			goto out;
    621       1.75   thorpej 		}
    622       1.59   thorpej 
    623       1.59   thorpej 		/* finishdup() will unuse the descriptors for us */
    624      1.138  christos 		return (finishdup(l, fd, i, retval));
    625       1.16       cgd 
    626       1.16       cgd 	case F_GETFD:
    627       1.27   mycroft 		*retval = fdp->fd_ofileflags[fd] & UF_EXCLOSE ? 1 : 0;
    628       1.59   thorpej 		break;
    629       1.16       cgd 
    630       1.16       cgd 	case F_SETFD:
    631       1.27   mycroft 		if ((long)SCARG(uap, arg) & 1)
    632       1.27   mycroft 			fdp->fd_ofileflags[fd] |= UF_EXCLOSE;
    633       1.27   mycroft 		else
    634       1.27   mycroft 			fdp->fd_ofileflags[fd] &= ~UF_EXCLOSE;
    635       1.59   thorpej 		break;
    636       1.16       cgd 
    637       1.16       cgd 	case F_GETFL:
    638       1.16       cgd 		*retval = OFLAGS(fp->f_flag);
    639       1.59   thorpej 		break;
    640       1.16       cgd 
    641       1.16       cgd 	case F_SETFL:
    642       1.61  wrstuden 		tmp = FFLAGS((long)SCARG(uap, arg)) & FCNTLFLAGS;
    643      1.138  christos 		error = (*fp->f_ops->fo_fcntl)(fp, F_SETFL, &tmp, l);
    644       1.61  wrstuden 		if (error)
    645      1.107       dsl 			break;
    646      1.107       dsl 		i = tmp ^ fp->f_flag;
    647      1.107       dsl 		if (i & FNONBLOCK) {
    648      1.133  christos 			int flgs = tmp & FNONBLOCK;
    649      1.138  christos 			error = (*fp->f_ops->fo_ioctl)(fp, FIONBIO, &flgs, l);
    650      1.107       dsl 			if (error)
    651      1.107       dsl 				goto reset_fcntl;
    652      1.107       dsl 		}
    653      1.107       dsl 		if (i & FASYNC) {
    654      1.133  christos 			int flgs = tmp & FASYNC;
    655      1.138  christos 			error = (*fp->f_ops->fo_ioctl)(fp, FIOASYNC, &flgs, l);
    656      1.107       dsl 			if (error) {
    657      1.107       dsl 				if (i & FNONBLOCK) {
    658      1.107       dsl 					tmp = fp->f_flag & FNONBLOCK;
    659      1.107       dsl 					(void)(*fp->f_ops->fo_ioctl)(fp,
    660      1.138  christos 						FIONBIO, &tmp, l);
    661      1.107       dsl 				}
    662      1.107       dsl 				goto reset_fcntl;
    663      1.107       dsl 			}
    664      1.107       dsl 		}
    665      1.107       dsl 		fp->f_flag = (fp->f_flag & ~FCNTLFLAGS) | tmp;
    666      1.107       dsl 		break;
    667      1.107       dsl 	    reset_fcntl:
    668      1.138  christos 		(void)(*fp->f_ops->fo_fcntl)(fp, F_SETFL, &fp->f_flag, l);
    669       1.59   thorpej 		break;
    670       1.16       cgd 
    671       1.16       cgd 	case F_GETOWN:
    672      1.138  christos 		error = (*fp->f_ops->fo_ioctl)(fp, FIOGETOWN, &tmp, l);
    673      1.136       mrg 		*retval = tmp;
    674       1.59   thorpej 		break;
    675       1.16       cgd 
    676       1.16       cgd 	case F_SETOWN:
    677      1.113  jdolecek 		tmp = (int)(intptr_t) SCARG(uap, arg);
    678      1.138  christos 		error = (*fp->f_ops->fo_ioctl)(fp, FIOSETOWN, &tmp, l);
    679       1.59   thorpej 		break;
    680       1.16       cgd 
    681       1.16       cgd 	default:
    682       1.59   thorpej 		error = EINVAL;
    683       1.16       cgd 	}
    684       1.59   thorpej 
    685       1.59   thorpej  out:
    686      1.138  christos 	FILE_UNUSE(fp, l);
    687       1.59   thorpej 	return (error);
    688       1.16       cgd }
    689       1.16       cgd 
    690       1.65   thorpej void
    691       1.72     lukem fdremove(struct filedesc *fdp, int fd)
    692       1.65   thorpej {
    693       1.65   thorpej 
    694  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
    695       1.65   thorpej 	fdp->fd_ofiles[fd] = NULL;
    696       1.65   thorpej 	fd_unused(fdp, fd);
    697  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    698       1.17       cgd }
    699       1.17       cgd 
    700       1.27   mycroft int
    701      1.138  christos fdrelease(struct lwp *l, int fd)
    702       1.72     lukem {
    703      1.138  christos 	struct proc *p = l->l_proc;
    704       1.72     lukem 	struct filedesc	*fdp;
    705      1.110      fvdl 	struct file	**fpp, *fp;
    706       1.27   mycroft 
    707       1.72     lukem 	fdp = p->p_fd;
    708  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
    709      1.129      cube 	if (fd < 0 || fd > fdp->fd_lastfile)
    710      1.126        pk 		goto badf;
    711       1.27   mycroft 	fpp = &fdp->fd_ofiles[fd];
    712       1.27   mycroft 	fp = *fpp;
    713       1.27   mycroft 	if (fp == NULL)
    714      1.126        pk 		goto badf;
    715       1.59   thorpej 
    716  1.159.8.1      matt 	mutex_enter(&fp->f_lock);
    717      1.103        pk 	if (!FILE_IS_USABLE(fp)) {
    718  1.159.8.1      matt 		mutex_exit(&fp->f_lock);
    719      1.126        pk 		goto badf;
    720      1.103        pk 	}
    721      1.103        pk 
    722       1.59   thorpej 	FILE_USE(fp);
    723       1.59   thorpej 
    724       1.27   mycroft 	*fpp = NULL;
    725       1.75   thorpej 	fdp->fd_ofileflags[fd] = 0;
    726      1.126        pk 	fd_unused(fdp, fd);
    727  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    728       1.96  jdolecek 	if (fd < fdp->fd_knlistsize)
    729      1.138  christos 		knote_fdclose(l, fd);
    730      1.138  christos 	return (closef(fp, l));
    731      1.126        pk 
    732      1.126        pk badf:
    733  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    734      1.126        pk 	return (EBADF);
    735       1.27   mycroft }
    736       1.27   mycroft 
    737       1.17       cgd /*
    738       1.16       cgd  * Close a file descriptor.
    739       1.16       cgd  */
    740       1.16       cgd /* ARGSUSED */
    741       1.38  christos int
    742      1.147      yamt sys_close(struct lwp *l, void *v, register_t *retval)
    743       1.36   thorpej {
    744       1.37   mycroft 	struct sys_close_args /* {
    745       1.72     lukem 		syscallarg(int)	fd;
    746       1.36   thorpej 	} */ *uap = v;
    747       1.72     lukem 	int		fd;
    748       1.72     lukem 	struct filedesc	*fdp;
    749       1.99   thorpej 	struct proc *p;
    750       1.16       cgd 
    751       1.99   thorpej 	p = l->l_proc;
    752       1.72     lukem 	fd = SCARG(uap, fd);
    753       1.72     lukem 	fdp = p->p_fd;
    754       1.79   thorpej 
    755      1.103        pk #if 0
    756      1.100    simonb 	if (fd_getfile(fdp, fd) == NULL)
    757       1.16       cgd 		return (EBADF);
    758      1.103        pk #endif
    759       1.79   thorpej 
    760      1.138  christos 	return (fdrelease(l, fd));
    761       1.16       cgd }
    762       1.16       cgd 
    763       1.17       cgd /*
    764       1.17       cgd  * Return status information about a file descriptor.
    765      1.153       dsl  * Common function for compat code.
    766      1.153       dsl  */
    767      1.153       dsl int
    768      1.153       dsl do_sys_fstat(struct lwp *l, int fd, struct stat *sb)
    769      1.153       dsl {
    770      1.153       dsl 	struct file	*fp;
    771      1.153       dsl 	int		error;
    772      1.153       dsl 
    773      1.153       dsl 	fp = fd_getfile(l->l_proc->p_fd, fd);
    774      1.153       dsl 	if (fp == NULL)
    775      1.153       dsl 		return EBADF;
    776      1.153       dsl 
    777      1.153       dsl 	FILE_USE(fp);
    778      1.153       dsl 	error = (*fp->f_ops->fo_stat)(fp, sb, l);
    779      1.153       dsl 	FILE_UNUSE(fp, l);
    780      1.153       dsl 
    781      1.153       dsl 	return error;
    782      1.153       dsl }
    783      1.153       dsl 
    784      1.153       dsl /*
    785      1.153       dsl  * Return status information about a file descriptor.
    786       1.17       cgd  */
    787       1.16       cgd /* ARGSUSED */
    788       1.38  christos int
    789      1.147      yamt sys___fstat30(struct lwp *l, void *v, register_t *retval)
    790       1.36   thorpej {
    791      1.135  christos 	struct sys___fstat30_args /* {
    792       1.72     lukem 		syscallarg(int)			fd;
    793       1.72     lukem 		syscallarg(struct stat *)	sb;
    794       1.36   thorpej 	} */ *uap = v;
    795      1.153       dsl 	struct stat	sb;
    796       1.72     lukem 	int		error;
    797       1.16       cgd 
    798      1.153       dsl 	error = do_sys_fstat(l, SCARG(uap, fd), &sb);
    799       1.59   thorpej 
    800       1.16       cgd 	if (error == 0)
    801      1.153       dsl 		error = copyout(&sb, SCARG(uap, sb), sizeof(sb));
    802       1.73  jdolecek 
    803       1.16       cgd 	return (error);
    804       1.16       cgd }
    805       1.16       cgd 
    806       1.16       cgd /*
    807       1.16       cgd  * Return pathconf information about a file descriptor.
    808       1.16       cgd  */
    809       1.16       cgd /* ARGSUSED */
    810       1.38  christos int
    811       1.99   thorpej sys_fpathconf(struct lwp *l, void *v, register_t *retval)
    812       1.36   thorpej {
    813       1.66  augustss 	struct sys_fpathconf_args /* {
    814       1.72     lukem 		syscallarg(int)	fd;
    815       1.72     lukem 		syscallarg(int)	name;
    816       1.36   thorpej 	} */ *uap = v;
    817       1.72     lukem 	int		fd;
    818       1.72     lukem 	struct filedesc	*fdp;
    819       1.72     lukem 	struct file	*fp;
    820       1.99   thorpej 	struct proc 	*p;
    821       1.72     lukem 	struct vnode	*vp;
    822       1.72     lukem 	int		error;
    823       1.72     lukem 
    824       1.99   thorpej 	p = l->l_proc;
    825       1.72     lukem 	fd = SCARG(uap, fd);
    826       1.72     lukem 	fdp = p->p_fd;
    827       1.72     lukem 	error = 0;
    828       1.17       cgd 
    829       1.77   thorpej 	if ((fp = fd_getfile(fdp, fd)) == NULL)
    830       1.17       cgd 		return (EBADF);
    831       1.59   thorpej 
    832       1.59   thorpej 	FILE_USE(fp);
    833       1.59   thorpej 
    834       1.17       cgd 	switch (fp->f_type) {
    835       1.16       cgd 
    836       1.17       cgd 	case DTYPE_SOCKET:
    837       1.78  jdolecek 	case DTYPE_PIPE:
    838       1.25       cgd 		if (SCARG(uap, name) != _PC_PIPE_BUF)
    839       1.59   thorpej 			error = EINVAL;
    840       1.59   thorpej 		else
    841       1.59   thorpej 			*retval = PIPE_BUF;
    842       1.59   thorpej 		break;
    843       1.17       cgd 
    844       1.17       cgd 	case DTYPE_VNODE:
    845       1.17       cgd 		vp = (struct vnode *)fp->f_data;
    846       1.59   thorpej 		error = VOP_PATHCONF(vp, SCARG(uap, name), retval);
    847       1.59   thorpej 		break;
    848       1.17       cgd 
    849       1.96  jdolecek 	case DTYPE_KQUEUE:
    850       1.96  jdolecek 		error = EINVAL;
    851       1.96  jdolecek 		break;
    852       1.96  jdolecek 
    853       1.17       cgd 	default:
    854       1.93   thorpej 		error = EOPNOTSUPP;
    855       1.93   thorpej 		break;
    856       1.17       cgd 	}
    857       1.59   thorpej 
    858      1.138  christos 	FILE_UNUSE(fp, l);
    859       1.59   thorpej 	return (error);
    860       1.16       cgd }
    861       1.16       cgd 
    862       1.16       cgd /*
    863       1.16       cgd  * Allocate a file descriptor for the process.
    864       1.16       cgd  */
    865       1.76   thorpej int	fdexpanded;		/* XXX: what else uses this? */
    866       1.16       cgd 
    867       1.38  christos int
    868       1.72     lukem fdalloc(struct proc *p, int want, int *result)
    869       1.72     lukem {
    870       1.72     lukem 	struct filedesc	*fdp;
    871      1.126        pk 	int i, lim, last, error;
    872      1.115    provos 	u_int off, new;
    873       1.72     lukem 
    874       1.72     lukem 	fdp = p->p_fd;
    875  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
    876       1.16       cgd 
    877       1.16       cgd 	/*
    878       1.16       cgd 	 * Search for a free descriptor starting at the higher
    879       1.16       cgd 	 * of want or fd_freefile.  If that fails, consider
    880       1.16       cgd 	 * expanding the ofile array.
    881       1.16       cgd 	 */
    882       1.17       cgd 	lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfiles);
    883       1.90     enami 	last = min(fdp->fd_nfiles, lim);
    884      1.115    provos  again:
    885       1.90     enami 	if ((i = want) < fdp->fd_freefile)
    886       1.90     enami 		i = fdp->fd_freefile;
    887      1.115    provos 	off = i >> NDENTRYSHIFT;
    888      1.115    provos 	new = find_next_zero(fdp->fd_himap, off,
    889      1.115    provos 	    (last + NDENTRIES - 1) >> NDENTRYSHIFT);
    890      1.115    provos 	if (new != -1) {
    891      1.131     perry 		i = find_next_zero(&fdp->fd_lomap[new],
    892      1.115    provos 		    new > off ? 0 : i & NDENTRYMASK, NDENTRIES);
    893      1.115    provos 		if (i == -1) {
    894      1.131     perry 			/*
    895      1.115    provos 			 * free file descriptor in this block was
    896      1.115    provos 			 * below want, try again with higher want.
    897      1.115    provos 			 */
    898      1.115    provos 			want = (new + 1) << NDENTRYSHIFT;
    899      1.115    provos 			goto again;
    900      1.115    provos 		}
    901      1.115    provos 		i += (new << NDENTRYSHIFT);
    902      1.115    provos 		if (i < last) {
    903      1.115    provos 			if (fdp->fd_ofiles[i] == NULL) {
    904      1.115    provos 				fd_used(fdp, i);
    905      1.115    provos 				if (want <= fdp->fd_freefile)
    906      1.115    provos 					fdp->fd_freefile = i;
    907      1.115    provos 				*result = i;
    908      1.126        pk 				error = 0;
    909      1.126        pk 				goto out;
    910      1.115    provos 			}
    911       1.16       cgd 		}
    912       1.90     enami 	}
    913       1.16       cgd 
    914      1.126        pk 	/* No space in current array.  Expand or let the caller do it. */
    915      1.126        pk 	error = (fdp->fd_nfiles >= lim) ? EMFILE : ENOSPC;
    916       1.76   thorpej 
    917      1.126        pk out:
    918  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    919      1.126        pk 	return (error);
    920       1.16       cgd }
    921       1.16       cgd 
    922       1.76   thorpej void
    923       1.76   thorpej fdexpand(struct proc *p)
    924       1.76   thorpej {
    925       1.76   thorpej 	struct filedesc	*fdp;
    926      1.133  christos 	int		i, numfiles, oldnfiles;
    927       1.76   thorpej 	struct file	**newofile;
    928       1.76   thorpej 	char		*newofileflags;
    929      1.126        pk 	uint32_t	*newhimap = NULL, *newlomap = NULL;
    930       1.76   thorpej 
    931       1.76   thorpej 	fdp = p->p_fd;
    932       1.76   thorpej 
    933      1.126        pk restart:
    934      1.126        pk 	oldnfiles = fdp->fd_nfiles;
    935      1.126        pk 
    936      1.126        pk 	if (oldnfiles < NDEXTENT)
    937      1.133  christos 		numfiles = NDEXTENT;
    938       1.76   thorpej 	else
    939      1.133  christos 		numfiles = 2 * oldnfiles;
    940      1.126        pk 
    941      1.133  christos 	newofile = malloc(numfiles * OFILESIZE, M_FILEDESC, M_WAITOK);
    942      1.133  christos 	if (NDHISLOTS(numfiles) > NDHISLOTS(oldnfiles)) {
    943      1.133  christos 		newhimap = malloc(NDHISLOTS(numfiles) * sizeof(uint32_t),
    944      1.126        pk 		    M_FILEDESC, M_WAITOK);
    945      1.133  christos 		newlomap = malloc(NDLOSLOTS(numfiles) * sizeof(uint32_t),
    946      1.126        pk 		    M_FILEDESC, M_WAITOK);
    947      1.126        pk 	}
    948      1.126        pk 
    949  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
    950      1.126        pk 	/* lock fdp */
    951      1.126        pk 	if (fdp->fd_nfiles != oldnfiles) {
    952      1.126        pk 		/* fdp changed; retry */
    953  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
    954      1.126        pk 		free(newofile, M_FILEDESC);
    955      1.126        pk 		if (newhimap != NULL) free(newhimap, M_FILEDESC);
    956      1.126        pk 		if (newlomap != NULL) free(newlomap, M_FILEDESC);
    957      1.126        pk 		goto restart;
    958      1.126        pk 	}
    959      1.126        pk 
    960      1.133  christos 	newofileflags = (char *) &newofile[numfiles];
    961       1.76   thorpej 	/*
    962       1.76   thorpej 	 * Copy the existing ofile and ofileflags arrays
    963       1.76   thorpej 	 * and zero the new portion of each array.
    964       1.76   thorpej 	 */
    965       1.76   thorpej 	memcpy(newofile, fdp->fd_ofiles,
    966       1.89     enami 	    (i = sizeof(struct file *) * fdp->fd_nfiles));
    967       1.76   thorpej 	memset((char *)newofile + i, 0,
    968      1.133  christos 	    numfiles * sizeof(struct file *) - i);
    969       1.76   thorpej 	memcpy(newofileflags, fdp->fd_ofileflags,
    970       1.76   thorpej 	    (i = sizeof(char) * fdp->fd_nfiles));
    971      1.133  christos 	memset(newofileflags + i, 0, numfiles * sizeof(char) - i);
    972      1.126        pk 	if (oldnfiles > NDFILE)
    973       1.76   thorpej 		free(fdp->fd_ofiles, M_FILEDESC);
    974      1.115    provos 
    975      1.133  christos 	if (NDHISLOTS(numfiles) > NDHISLOTS(oldnfiles)) {
    976      1.115    provos 		memcpy(newhimap, fdp->fd_himap,
    977      1.126        pk 		    (i = NDHISLOTS(oldnfiles) * sizeof(uint32_t)));
    978      1.115    provos 		memset((char *)newhimap + i, 0,
    979      1.133  christos 		    NDHISLOTS(numfiles) * sizeof(uint32_t) - i);
    980      1.115    provos 
    981      1.115    provos 		memcpy(newlomap, fdp->fd_lomap,
    982      1.126        pk 		    (i = NDLOSLOTS(oldnfiles) * sizeof(uint32_t)));
    983      1.115    provos 		memset((char *)newlomap + i, 0,
    984      1.133  christos 		    NDLOSLOTS(numfiles) * sizeof(uint32_t) - i);
    985      1.115    provos 
    986      1.126        pk 		if (NDHISLOTS(oldnfiles) > NDHISLOTS(NDFILE)) {
    987      1.115    provos 			free(fdp->fd_himap, M_FILEDESC);
    988      1.115    provos 			free(fdp->fd_lomap, M_FILEDESC);
    989      1.115    provos 		}
    990      1.115    provos 		fdp->fd_himap = newhimap;
    991      1.115    provos 		fdp->fd_lomap = newlomap;
    992      1.115    provos 	}
    993      1.115    provos 
    994       1.76   thorpej 	fdp->fd_ofiles = newofile;
    995       1.76   thorpej 	fdp->fd_ofileflags = newofileflags;
    996      1.133  christos 	fdp->fd_nfiles = numfiles;
    997      1.126        pk 
    998  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
    999      1.126        pk 
   1000       1.76   thorpej 	fdexpanded++;
   1001       1.76   thorpej }
   1002       1.76   thorpej 
   1003       1.16       cgd /*
   1004       1.16       cgd  * Create a new open file structure and allocate
   1005       1.98       wiz  * a file descriptor for the process that refers to it.
   1006       1.16       cgd  */
   1007       1.38  christos int
   1008      1.144        ad falloc(struct lwp *l, struct file **resultfp, int *resultfd)
   1009       1.16       cgd {
   1010  1.159.8.1      matt 	struct filedesc	*fdp;
   1011       1.72     lukem 	struct file	*fp, *fq;
   1012      1.144        ad 	struct proc	*p;
   1013       1.72     lukem 	int		error, i;
   1014       1.16       cgd 
   1015      1.144        ad 	p = l->l_proc;
   1016  1.159.8.1      matt 	fdp = p->p_fd;
   1017      1.144        ad 
   1018       1.75   thorpej  restart:
   1019       1.75   thorpej 	if ((error = fdalloc(p, 0, &i)) != 0) {
   1020       1.76   thorpej 		if (error == ENOSPC) {
   1021       1.76   thorpej 			fdexpand(p);
   1022       1.75   thorpej 			goto restart;
   1023       1.76   thorpej 		}
   1024       1.16       cgd 		return (error);
   1025       1.75   thorpej 	}
   1026      1.102        pk 
   1027  1.159.8.2      matt 	fp = pool_cache_get(file_cache, PR_WAITOK);
   1028  1.159.8.1      matt 	memset(fp, 0, sizeof(struct file));
   1029  1.159.8.1      matt 	mutex_init(&fp->f_lock, MUTEX_DEFAULT, IPL_NONE);
   1030  1.159.8.1      matt 	mutex_enter(&filelist_lock);
   1031       1.16       cgd 	if (nfiles >= maxfiles) {
   1032       1.69  jdolecek 		tablefull("file", "increase kern.maxfiles or MAXFILES");
   1033  1.159.8.1      matt 		mutex_exit(&filelist_lock);
   1034  1.159.8.1      matt 		rw_enter(&fdp->fd_lock, RW_WRITER);
   1035  1.159.8.1      matt 		fd_unused(fdp, i);
   1036  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
   1037  1.159.8.1      matt 		mutex_destroy(&fp->f_lock);
   1038  1.159.8.2      matt 		pool_cache_put(file_cache, fp);
   1039       1.16       cgd 		return (ENFILE);
   1040       1.16       cgd 	}
   1041       1.16       cgd 	/*
   1042       1.16       cgd 	 * Allocate a new file descriptor.
   1043       1.16       cgd 	 * If the process has file descriptor zero open, add to the list
   1044       1.16       cgd 	 * of open files at that point, otherwise put it at the front of
   1045       1.16       cgd 	 * the list of open files.
   1046       1.16       cgd 	 */
   1047       1.16       cgd 	nfiles++;
   1048       1.83  jdolecek 	fp->f_iflags = FIF_LARVAL;
   1049  1.159.8.1      matt 	cv_init(&fp->f_cv, "closef");
   1050  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);	/* XXXAD check order */
   1051  1.159.8.1      matt 	if ((fq = fdp->fd_ofiles[0]) != NULL) {
   1052       1.24   mycroft 		LIST_INSERT_AFTER(fq, fp, f_list);
   1053       1.24   mycroft 	} else {
   1054       1.24   mycroft 		LIST_INSERT_HEAD(&filehead, fp, f_list);
   1055       1.24   mycroft 	}
   1056  1.159.8.1      matt 	KDASSERT(fdp->fd_ofiles[i] == NULL);
   1057  1.159.8.1      matt 	fdp->fd_ofiles[i] = fp;
   1058       1.16       cgd 	fp->f_count = 1;
   1059      1.144        ad 	fp->f_cred = l->l_cred;
   1060      1.143      elad 	kauth_cred_hold(fp->f_cred);
   1061       1.59   thorpej 	if (resultfp) {
   1062      1.103        pk 		fp->f_usecount = 1;
   1063       1.16       cgd 		*resultfp = fp;
   1064       1.59   thorpej 	}
   1065  1.159.8.1      matt 	mutex_exit(&filelist_lock);
   1066  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
   1067       1.16       cgd 	if (resultfd)
   1068       1.16       cgd 		*resultfd = i;
   1069  1.159.8.1      matt 
   1070       1.16       cgd 	return (0);
   1071       1.16       cgd }
   1072       1.16       cgd 
   1073       1.16       cgd /*
   1074       1.16       cgd  * Free a file descriptor.
   1075       1.16       cgd  */
   1076       1.38  christos void
   1077       1.72     lukem ffree(struct file *fp)
   1078       1.16       cgd {
   1079      1.149        ad 	kauth_cred_t cred;
   1080       1.59   thorpej 
   1081       1.59   thorpej #ifdef DIAGNOSTIC
   1082       1.59   thorpej 	if (fp->f_usecount)
   1083       1.59   thorpej 		panic("ffree");
   1084       1.59   thorpej #endif
   1085       1.59   thorpej 
   1086  1.159.8.1      matt 	mutex_enter(&filelist_lock);
   1087       1.24   mycroft 	LIST_REMOVE(fp, f_list);
   1088      1.149        ad 	cred = fp->f_cred;
   1089       1.16       cgd #ifdef DIAGNOSTIC
   1090      1.149        ad 	fp->f_cred = NULL;
   1091      1.103        pk 	fp->f_count = 0; /* What's the point? */
   1092       1.16       cgd #endif
   1093       1.16       cgd 	nfiles--;
   1094  1.159.8.1      matt 	mutex_exit(&filelist_lock);
   1095  1.159.8.1      matt 	mutex_destroy(&fp->f_lock);
   1096  1.159.8.1      matt 	cv_destroy(&fp->f_cv);
   1097  1.159.8.2      matt 	pool_cache_put(file_cache, fp);
   1098      1.149        ad 	kauth_cred_free(cred);
   1099       1.48   thorpej }
   1100       1.48   thorpej 
   1101       1.48   thorpej /*
   1102       1.58   thorpej  * Create an initial cwdinfo structure, using the same current and root
   1103       1.58   thorpej  * directories as p.
   1104       1.58   thorpej  */
   1105       1.58   thorpej struct cwdinfo *
   1106       1.72     lukem cwdinit(struct proc *p)
   1107       1.58   thorpej {
   1108       1.58   thorpej 	struct cwdinfo *cwdi;
   1109  1.159.8.1      matt 	struct cwdinfo *copy;
   1110       1.58   thorpej 
   1111  1.159.8.2      matt 	cwdi = pool_cache_get(cwdi_cache, PR_WAITOK);
   1112  1.159.8.1      matt 	copy = p->p_cwdi;
   1113  1.159.8.1      matt 
   1114  1.159.8.1      matt 	rw_enter(&copy->cwdi_lock, RW_READER);
   1115       1.58   thorpej 	cwdi->cwdi_cdir = p->p_cwdi->cwdi_cdir;
   1116       1.63   thorpej 	if (cwdi->cwdi_cdir)
   1117       1.63   thorpej 		VREF(cwdi->cwdi_cdir);
   1118       1.58   thorpej 	cwdi->cwdi_rdir = p->p_cwdi->cwdi_rdir;
   1119       1.58   thorpej 	if (cwdi->cwdi_rdir)
   1120       1.58   thorpej 		VREF(cwdi->cwdi_rdir);
   1121      1.157       dsl 	cwdi->cwdi_edir = p->p_cwdi->cwdi_edir;
   1122      1.157       dsl 	if (cwdi->cwdi_edir)
   1123      1.157       dsl 		VREF(cwdi->cwdi_edir);
   1124       1.60  christos 	cwdi->cwdi_cmask =  p->p_cwdi->cwdi_cmask;
   1125       1.58   thorpej 	cwdi->cwdi_refcnt = 1;
   1126  1.159.8.1      matt 	rw_exit(&copy->cwdi_lock);
   1127       1.58   thorpej 
   1128       1.58   thorpej 	return (cwdi);
   1129       1.58   thorpej }
   1130       1.58   thorpej 
   1131  1.159.8.2      matt static int
   1132  1.159.8.2      matt cwdi_ctor(void *arg, void *obj, int flags)
   1133  1.159.8.2      matt {
   1134  1.159.8.2      matt 	struct cwdinfo *cwdi;
   1135  1.159.8.2      matt 
   1136  1.159.8.2      matt 	cwdi = obj;
   1137  1.159.8.2      matt 	rw_init(&cwdi->cwdi_lock);
   1138  1.159.8.2      matt 
   1139  1.159.8.2      matt 	return 0;
   1140  1.159.8.2      matt }
   1141  1.159.8.2      matt 
   1142  1.159.8.2      matt static void
   1143  1.159.8.2      matt cwdi_dtor(void *arg, void *obj)
   1144  1.159.8.2      matt {
   1145  1.159.8.2      matt 	struct cwdinfo *cwdi;
   1146  1.159.8.2      matt 
   1147  1.159.8.2      matt 	cwdi = obj;
   1148  1.159.8.2      matt 	rw_destroy(&cwdi->cwdi_lock);
   1149  1.159.8.2      matt }
   1150  1.159.8.2      matt 
   1151       1.58   thorpej /*
   1152       1.58   thorpej  * Make p2 share p1's cwdinfo.
   1153       1.58   thorpej  */
   1154       1.58   thorpej void
   1155       1.72     lukem cwdshare(struct proc *p1, struct proc *p2)
   1156       1.58   thorpej {
   1157      1.126        pk 	struct cwdinfo *cwdi = p1->p_cwdi;
   1158       1.58   thorpej 
   1159      1.159        ad 	rw_enter(&cwdi->cwdi_lock, RW_WRITER);
   1160      1.126        pk 	cwdi->cwdi_refcnt++;
   1161      1.159        ad 	rw_exit(&cwdi->cwdi_lock);
   1162      1.126        pk 	p2->p_cwdi = cwdi;
   1163       1.58   thorpej }
   1164       1.58   thorpej 
   1165       1.58   thorpej /*
   1166       1.58   thorpej  * Make this process not share its cwdinfo structure, maintaining
   1167       1.58   thorpej  * all cwdinfo state.
   1168       1.58   thorpej  */
   1169       1.58   thorpej void
   1170       1.72     lukem cwdunshare(struct proc *p)
   1171       1.58   thorpej {
   1172      1.126        pk 	struct cwdinfo *oldcwdi, *newcwdi;
   1173       1.58   thorpej 
   1174       1.58   thorpej 	if (p->p_cwdi->cwdi_refcnt == 1)
   1175       1.58   thorpej 		return;
   1176       1.58   thorpej 
   1177       1.58   thorpej 	newcwdi = cwdinit(p);
   1178      1.126        pk 	oldcwdi = p->p_cwdi;
   1179       1.58   thorpej 	p->p_cwdi = newcwdi;
   1180      1.126        pk 	cwdfree(oldcwdi);
   1181       1.58   thorpej }
   1182       1.58   thorpej 
   1183       1.58   thorpej /*
   1184       1.58   thorpej  * Release a cwdinfo structure.
   1185       1.58   thorpej  */
   1186       1.58   thorpej void
   1187      1.126        pk cwdfree(struct cwdinfo *cwdi)
   1188       1.58   thorpej {
   1189      1.126        pk 	int n;
   1190       1.58   thorpej 
   1191      1.159        ad 	rw_enter(&cwdi->cwdi_lock, RW_WRITER);
   1192      1.126        pk 	n = --cwdi->cwdi_refcnt;
   1193      1.159        ad 	rw_exit(&cwdi->cwdi_lock);
   1194      1.126        pk 	if (n > 0)
   1195       1.58   thorpej 		return;
   1196       1.58   thorpej 
   1197       1.58   thorpej 	vrele(cwdi->cwdi_cdir);
   1198       1.58   thorpej 	if (cwdi->cwdi_rdir)
   1199       1.58   thorpej 		vrele(cwdi->cwdi_rdir);
   1200      1.156       dsl 	if (cwdi->cwdi_edir)
   1201      1.156       dsl 		vrele(cwdi->cwdi_edir);
   1202  1.159.8.2      matt 	pool_cache_put(cwdi_cache, cwdi);
   1203       1.58   thorpej }
   1204       1.58   thorpej 
   1205       1.58   thorpej /*
   1206       1.48   thorpej  * Create an initial filedesc structure, using the same current and root
   1207       1.48   thorpej  * directories as p.
   1208       1.48   thorpej  */
   1209       1.48   thorpej struct filedesc *
   1210      1.147      yamt fdinit(struct proc *p)
   1211       1.48   thorpej {
   1212       1.48   thorpej 	struct filedesc0 *newfdp;
   1213       1.48   thorpej 
   1214  1.159.8.2      matt 	newfdp = pool_cache_get(filedesc0_cache, PR_WAITOK);
   1215       1.53     perry 	memset(newfdp, 0, sizeof(struct filedesc0));
   1216       1.48   thorpej 
   1217       1.48   thorpej 	fdinit1(newfdp);
   1218       1.48   thorpej 
   1219       1.48   thorpej 	return (&newfdp->fd_fd);
   1220       1.48   thorpej }
   1221       1.48   thorpej 
   1222       1.48   thorpej /*
   1223       1.48   thorpej  * Initialize a file descriptor table.
   1224       1.48   thorpej  */
   1225       1.48   thorpej void
   1226       1.72     lukem fdinit1(struct filedesc0 *newfdp)
   1227       1.48   thorpej {
   1228       1.48   thorpej 
   1229       1.48   thorpej 	newfdp->fd_fd.fd_refcnt = 1;
   1230       1.48   thorpej 	newfdp->fd_fd.fd_ofiles = newfdp->fd_dfiles;
   1231       1.48   thorpej 	newfdp->fd_fd.fd_ofileflags = newfdp->fd_dfileflags;
   1232       1.48   thorpej 	newfdp->fd_fd.fd_nfiles = NDFILE;
   1233       1.96  jdolecek 	newfdp->fd_fd.fd_knlistsize = -1;
   1234      1.115    provos 	newfdp->fd_fd.fd_himap = newfdp->fd_dhimap;
   1235      1.115    provos 	newfdp->fd_fd.fd_lomap = newfdp->fd_dlomap;
   1236      1.128      cube 	newfdp->fd_fd.fd_lastfile = -1;
   1237  1.159.8.1      matt 	rw_init(&newfdp->fd_fd.fd_lock);
   1238       1.48   thorpej }
   1239       1.48   thorpej 
   1240       1.48   thorpej /*
   1241       1.48   thorpej  * Make p2 share p1's filedesc structure.
   1242       1.48   thorpej  */
   1243       1.48   thorpej void
   1244       1.72     lukem fdshare(struct proc *p1, struct proc *p2)
   1245       1.48   thorpej {
   1246      1.126        pk 	struct filedesc *fdp = p1->p_fd;
   1247       1.48   thorpej 
   1248  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
   1249      1.126        pk 	p2->p_fd = fdp;
   1250      1.126        pk 	fdp->fd_refcnt++;
   1251  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
   1252       1.48   thorpej }
   1253       1.48   thorpej 
   1254       1.48   thorpej /*
   1255       1.48   thorpej  * Make this process not share its filedesc structure, maintaining
   1256       1.48   thorpej  * all file descriptor state.
   1257       1.48   thorpej  */
   1258       1.48   thorpej void
   1259      1.138  christos fdunshare(struct lwp *l)
   1260       1.48   thorpej {
   1261      1.138  christos 	struct proc *p = l->l_proc;
   1262       1.48   thorpej 	struct filedesc *newfd;
   1263       1.48   thorpej 
   1264       1.48   thorpej 	if (p->p_fd->fd_refcnt == 1)
   1265       1.48   thorpej 		return;
   1266       1.48   thorpej 
   1267       1.48   thorpej 	newfd = fdcopy(p);
   1268      1.138  christos 	fdfree(l);
   1269       1.48   thorpej 	p->p_fd = newfd;
   1270       1.48   thorpej }
   1271       1.48   thorpej 
   1272       1.48   thorpej /*
   1273       1.48   thorpej  * Clear a process's fd table.
   1274       1.48   thorpej  */
   1275       1.48   thorpej void
   1276      1.138  christos fdclear(struct lwp *l)
   1277       1.48   thorpej {
   1278      1.138  christos 	struct proc *p = l->l_proc;
   1279       1.48   thorpej 	struct filedesc *newfd;
   1280       1.48   thorpej 
   1281       1.48   thorpej 	newfd = fdinit(p);
   1282      1.138  christos 	fdfree(l);
   1283       1.48   thorpej 	p->p_fd = newfd;
   1284       1.16       cgd }
   1285       1.16       cgd 
   1286       1.16       cgd /*
   1287       1.16       cgd  * Copy a filedesc structure.
   1288       1.16       cgd  */
   1289       1.16       cgd struct filedesc *
   1290       1.72     lukem fdcopy(struct proc *p)
   1291       1.16       cgd {
   1292       1.72     lukem 	struct filedesc	*newfdp, *fdp;
   1293      1.126        pk 	struct file	**fpp, **nfpp;
   1294      1.133  christos 	int		i, numfiles, lastfile;
   1295       1.16       cgd 
   1296       1.72     lukem 	fdp = p->p_fd;
   1297  1.159.8.2      matt 	newfdp = pool_cache_get(filedesc0_cache, PR_WAITOK);
   1298       1.16       cgd 	newfdp->fd_refcnt = 1;
   1299  1.159.8.1      matt 	rw_init(&newfdp->fd_lock);
   1300      1.126        pk 
   1301      1.126        pk restart:
   1302      1.133  christos 	numfiles = fdp->fd_nfiles;
   1303      1.126        pk 	lastfile = fdp->fd_lastfile;
   1304       1.16       cgd 
   1305       1.16       cgd 	/*
   1306       1.16       cgd 	 * If the number of open files fits in the internal arrays
   1307       1.16       cgd 	 * of the open file structure, use them, otherwise allocate
   1308       1.16       cgd 	 * additional memory for the number of descriptors currently
   1309       1.16       cgd 	 * in use.
   1310       1.16       cgd 	 */
   1311      1.126        pk 	if (lastfile < NDFILE) {
   1312       1.16       cgd 		i = NDFILE;
   1313       1.16       cgd 	} else {
   1314       1.16       cgd 		/*
   1315       1.16       cgd 		 * Compute the smallest multiple of NDEXTENT needed
   1316       1.16       cgd 		 * for the file descriptors currently in use,
   1317       1.16       cgd 		 * allowing the table to shrink.
   1318       1.16       cgd 		 */
   1319      1.133  christos 		i = numfiles;
   1320      1.126        pk 		while (i >= 2 * NDEXTENT && i > lastfile * 2)
   1321       1.16       cgd 			i /= 2;
   1322       1.64   thorpej 		newfdp->fd_ofiles = malloc(i * OFILESIZE, M_FILEDESC, M_WAITOK);
   1323      1.126        pk 	}
   1324      1.126        pk 	if (NDHISLOTS(i) > NDHISLOTS(NDFILE)) {
   1325      1.126        pk 		newfdp->fd_himap = malloc(NDHISLOTS(i) * sizeof(uint32_t),
   1326      1.126        pk 		    M_FILEDESC, M_WAITOK);
   1327      1.126        pk 		newfdp->fd_lomap = malloc(NDLOSLOTS(i) * sizeof(uint32_t),
   1328      1.126        pk 		    M_FILEDESC, M_WAITOK);
   1329      1.126        pk 	}
   1330      1.126        pk 
   1331  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_READER);
   1332      1.133  christos 	if (numfiles != fdp->fd_nfiles || lastfile != fdp->fd_lastfile) {
   1333  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
   1334      1.126        pk 		if (i > NDFILE)
   1335      1.126        pk 			free(newfdp->fd_ofiles, M_FILEDESC);
   1336      1.126        pk 		if (NDHISLOTS(i) > NDHISLOTS(NDFILE)) {
   1337      1.126        pk 			free(newfdp->fd_himap, M_FILEDESC);
   1338      1.126        pk 			free(newfdp->fd_lomap, M_FILEDESC);
   1339      1.126        pk 		}
   1340      1.126        pk 		goto restart;
   1341      1.126        pk 	}
   1342      1.126        pk 
   1343      1.126        pk 	if (lastfile < NDFILE) {
   1344      1.126        pk 		newfdp->fd_ofiles = ((struct filedesc0 *) newfdp)->fd_dfiles;
   1345      1.126        pk 		newfdp->fd_ofileflags =
   1346      1.126        pk 		    ((struct filedesc0 *) newfdp)->fd_dfileflags;
   1347      1.126        pk 	} else {
   1348       1.16       cgd 		newfdp->fd_ofileflags = (char *) &newfdp->fd_ofiles[i];
   1349       1.16       cgd 	}
   1350      1.115    provos 	if (NDHISLOTS(i) <= NDHISLOTS(NDFILE)) {
   1351      1.115    provos 		newfdp->fd_himap =
   1352      1.115    provos 		    ((struct filedesc0 *) newfdp)->fd_dhimap;
   1353      1.115    provos 		newfdp->fd_lomap =
   1354      1.115    provos 		    ((struct filedesc0 *) newfdp)->fd_dlomap;
   1355      1.115    provos 	}
   1356      1.115    provos 
   1357       1.16       cgd 	newfdp->fd_nfiles = i;
   1358      1.126        pk 	newfdp->fd_lastfile = lastfile;
   1359      1.126        pk 	newfdp->fd_freefile = fdp->fd_freefile;
   1360      1.126        pk 
   1361      1.128      cube 	/* Clear the entries that will not be copied over.
   1362      1.128      cube 	 * Avoid calling memset with 0 size (i.e. when
   1363      1.128      cube 	 * lastfile == i-1 */
   1364      1.128      cube 	if (lastfile < (i-1))
   1365      1.128      cube 		memset(newfdp->fd_ofiles + lastfile + 1, 0,
   1366      1.128      cube 		    (i - lastfile - 1) * sizeof(struct file **));
   1367       1.53     perry 	memcpy(newfdp->fd_ofileflags, fdp->fd_ofileflags, i * sizeof(char));
   1368      1.120      yamt 	if (i < NDENTRIES * NDENTRIES)
   1369      1.120      yamt 		i = NDENTRIES * NDENTRIES; /* size of inlined bitmaps */
   1370      1.115    provos 	memcpy(newfdp->fd_himap, fdp->fd_himap, NDHISLOTS(i)*sizeof(uint32_t));
   1371      1.115    provos 	memcpy(newfdp->fd_lomap, fdp->fd_lomap, NDLOSLOTS(i)*sizeof(uint32_t));
   1372      1.126        pk 
   1373      1.126        pk 	fpp = fdp->fd_ofiles;
   1374      1.126        pk 	nfpp = newfdp->fd_ofiles;
   1375      1.126        pk 	for (i = 0; i <= lastfile; i++, fpp++, nfpp++) {
   1376      1.126        pk 		if ((*nfpp = *fpp) == NULL)
   1377      1.126        pk 			continue;
   1378      1.126        pk 
   1379      1.126        pk 		if ((*fpp)->f_type == DTYPE_KQUEUE)
   1380      1.126        pk 			/* kq descriptors cannot be copied. */
   1381      1.126        pk 			fdremove(newfdp, i);
   1382      1.126        pk 		else {
   1383  1.159.8.1      matt 			mutex_enter(&(*fpp)->f_lock);
   1384      1.126        pk 			(*fpp)->f_count++;
   1385  1.159.8.1      matt 			mutex_exit(&(*fpp)->f_lock);
   1386       1.96  jdolecek 		}
   1387      1.126        pk 	}
   1388      1.126        pk 
   1389  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
   1390      1.126        pk 
   1391      1.126        pk 	newfdp->fd_knlist = NULL;
   1392      1.126        pk 	newfdp->fd_knlistsize = -1;
   1393      1.126        pk 	newfdp->fd_knhash = NULL;
   1394      1.126        pk 	newfdp->fd_knhashmask = 0;
   1395      1.126        pk 
   1396       1.16       cgd 	return (newfdp);
   1397       1.16       cgd }
   1398       1.16       cgd 
   1399       1.16       cgd /*
   1400       1.16       cgd  * Release a filedesc structure.
   1401       1.16       cgd  */
   1402       1.16       cgd void
   1403      1.138  christos fdfree(struct lwp *l)
   1404       1.16       cgd {
   1405      1.138  christos 	struct proc	*p = l->l_proc;
   1406       1.72     lukem 	struct filedesc	*fdp;
   1407       1.72     lukem 	struct file	**fpp, *fp;
   1408       1.72     lukem 	int		i;
   1409       1.16       cgd 
   1410       1.72     lukem 	fdp = p->p_fd;
   1411  1.159.8.1      matt 	rw_enter(&fdp->fd_lock, RW_WRITER);
   1412      1.126        pk 	i = --fdp->fd_refcnt;
   1413  1.159.8.1      matt 	rw_exit(&fdp->fd_lock);
   1414      1.126        pk 	if (i > 0)
   1415       1.16       cgd 		return;
   1416      1.126        pk 
   1417  1.159.8.1      matt 	rw_destroy(&fdp->fd_lock);
   1418       1.16       cgd 	fpp = fdp->fd_ofiles;
   1419       1.32   mycroft 	for (i = fdp->fd_lastfile; i >= 0; i--, fpp++) {
   1420       1.32   mycroft 		fp = *fpp;
   1421       1.32   mycroft 		if (fp != NULL) {
   1422       1.32   mycroft 			*fpp = NULL;
   1423  1.159.8.1      matt 			mutex_enter(&fp->f_lock);
   1424       1.59   thorpej 			FILE_USE(fp);
   1425      1.132  wrstuden 			if ((fdp->fd_lastfile - i) < fdp->fd_knlistsize)
   1426      1.138  christos 				knote_fdclose(l, fdp->fd_lastfile - i);
   1427      1.138  christos 			(void) closef(fp, l);
   1428       1.32   mycroft 		}
   1429       1.32   mycroft 	}
   1430       1.32   mycroft 	p->p_fd = NULL;
   1431       1.16       cgd 	if (fdp->fd_nfiles > NDFILE)
   1432       1.64   thorpej 		free(fdp->fd_ofiles, M_FILEDESC);
   1433      1.115    provos 	if (NDHISLOTS(fdp->fd_nfiles) > NDHISLOTS(NDFILE)) {
   1434      1.115    provos 		free(fdp->fd_himap, M_FILEDESC);
   1435      1.115    provos 		free(fdp->fd_lomap, M_FILEDESC);
   1436      1.115    provos 	}
   1437       1.96  jdolecek 	if (fdp->fd_knlist)
   1438       1.96  jdolecek 		free(fdp->fd_knlist, M_KEVENT);
   1439       1.96  jdolecek 	if (fdp->fd_knhash)
   1440       1.96  jdolecek 		hashdone(fdp->fd_knhash, M_KEVENT);
   1441  1.159.8.2      matt 	pool_cache_put(filedesc0_cache, fdp);
   1442       1.16       cgd }
   1443       1.16       cgd 
   1444       1.16       cgd /*
   1445       1.16       cgd  * Internal form of close.
   1446       1.16       cgd  * Decrement reference count on file structure.
   1447       1.17       cgd  * Note: p may be NULL when closing a file
   1448       1.17       cgd  * that was being passed in a message.
   1449       1.59   thorpej  *
   1450       1.59   thorpej  * Note: we expect the caller is holding a usecount, and expects us
   1451       1.59   thorpej  * to drop it (the caller thinks the file is going away forever).
   1452       1.16       cgd  */
   1453       1.38  christos int
   1454      1.138  christos closef(struct file *fp, struct lwp *l)
   1455       1.72     lukem {
   1456      1.138  christos 	struct proc	*p = l ? l->l_proc : NULL;
   1457       1.72     lukem 	struct vnode	*vp;
   1458       1.72     lukem 	struct flock	lf;
   1459       1.72     lukem 	int		error;
   1460       1.16       cgd 
   1461       1.16       cgd 	if (fp == NULL)
   1462       1.16       cgd 		return (0);
   1463       1.59   thorpej 
   1464       1.16       cgd 	/*
   1465       1.16       cgd 	 * POSIX record locking dictates that any close releases ALL
   1466       1.16       cgd 	 * locks owned by this process.  This is handled by setting
   1467       1.16       cgd 	 * a flag in the unlock to free ONLY locks obeying POSIX
   1468       1.16       cgd 	 * semantics, and not to free BSD-style file locks.
   1469       1.17       cgd 	 * If the descriptor was in a message, POSIX-style locks
   1470       1.17       cgd 	 * aren't passed with the descriptor.
   1471       1.16       cgd 	 */
   1472      1.151     pavel 	if (p && (p->p_flag & PK_ADVLOCK) && fp->f_type == DTYPE_VNODE) {
   1473       1.16       cgd 		lf.l_whence = SEEK_SET;
   1474       1.16       cgd 		lf.l_start = 0;
   1475       1.16       cgd 		lf.l_len = 0;
   1476       1.16       cgd 		lf.l_type = F_UNLCK;
   1477       1.16       cgd 		vp = (struct vnode *)fp->f_data;
   1478      1.106       dsl 		(void) VOP_ADVLOCK(vp, p, F_UNLCK, &lf, F_POSIX);
   1479       1.16       cgd 	}
   1480       1.59   thorpej 
   1481       1.59   thorpej 	/*
   1482       1.59   thorpej 	 * If WANTCLOSE is set, then the reference count on the file
   1483       1.59   thorpej 	 * is 0, but there were multiple users of the file.  This can
   1484       1.59   thorpej 	 * happen if a filedesc structure is shared by multiple
   1485       1.59   thorpej 	 * processes.
   1486       1.59   thorpej 	 */
   1487  1.159.8.1      matt 	mutex_enter(&fp->f_lock);
   1488       1.83  jdolecek 	if (fp->f_iflags & FIF_WANTCLOSE) {
   1489       1.59   thorpej 		/*
   1490       1.59   thorpej 		 * Another user of the file is already closing, and is
   1491       1.59   thorpej 		 * simply waiting for other users of the file to drain.
   1492       1.59   thorpej 		 * Release our usecount, and wake up the closer if it
   1493       1.59   thorpej 		 * is the only remaining use.
   1494       1.59   thorpej 		 */
   1495       1.59   thorpej #ifdef DIAGNOSTIC
   1496       1.59   thorpej 		if (fp->f_count != 0)
   1497       1.59   thorpej 			panic("closef: wantclose and count != 0");
   1498       1.59   thorpej 		if (fp->f_usecount < 2)
   1499       1.59   thorpej 			panic("closef: wantclose and usecount < 2");
   1500       1.59   thorpej #endif
   1501       1.59   thorpej 		if (--fp->f_usecount == 1)
   1502  1.159.8.1      matt 			cv_broadcast(&fp->f_cv);
   1503  1.159.8.1      matt 		mutex_exit(&fp->f_lock);
   1504       1.16       cgd 		return (0);
   1505       1.59   thorpej 	} else {
   1506       1.59   thorpej 		/*
   1507       1.59   thorpej 		 * Decrement the reference count.  If we were not the
   1508       1.59   thorpej 		 * last reference, then release our use and just
   1509       1.59   thorpej 		 * return.
   1510       1.59   thorpej 		 */
   1511       1.59   thorpej 		if (--fp->f_count > 0) {
   1512       1.59   thorpej #ifdef DIAGNOSTIC
   1513       1.59   thorpej 			if (fp->f_usecount < 1)
   1514       1.59   thorpej 				panic("closef: no wantclose and usecount < 1");
   1515       1.59   thorpej #endif
   1516       1.59   thorpej 			fp->f_usecount--;
   1517  1.159.8.1      matt 			mutex_exit(&fp->f_lock);
   1518       1.59   thorpej 			return (0);
   1519       1.59   thorpej 		}
   1520       1.59   thorpej 	}
   1521       1.59   thorpej 
   1522       1.59   thorpej 	/*
   1523       1.59   thorpej 	 * The reference count is now 0.  However, there may be
   1524       1.59   thorpej 	 * multiple potential users of this file.  This can happen
   1525       1.59   thorpej 	 * if multiple processes shared a single filedesc structure.
   1526       1.59   thorpej 	 *
   1527       1.59   thorpej 	 * Notify these potential users that the file is closing.
   1528       1.59   thorpej 	 * This will prevent them from adding additional uses to
   1529       1.59   thorpej 	 * the file.
   1530       1.59   thorpej 	 */
   1531       1.83  jdolecek 	fp->f_iflags |= FIF_WANTCLOSE;
   1532       1.59   thorpej 
   1533       1.59   thorpej 	/*
   1534       1.59   thorpej 	 * We expect the caller to add a use to the file.  So, if we
   1535       1.59   thorpej 	 * are the last user, usecount will be 1.  If it is not, we
   1536       1.59   thorpej 	 * must wait for the usecount to drain.  When it drains back
   1537       1.59   thorpej 	 * to 1, we will be awakened so that we may proceed with the
   1538       1.59   thorpej 	 * close.
   1539       1.59   thorpej 	 */
   1540       1.59   thorpej #ifdef DIAGNOSTIC
   1541       1.59   thorpej 	if (fp->f_usecount < 1)
   1542       1.59   thorpej 		panic("closef: usecount < 1");
   1543       1.59   thorpej #endif
   1544       1.59   thorpej 	while (fp->f_usecount > 1)
   1545  1.159.8.1      matt 		cv_wait(&fp->f_cv, &fp->f_lock);
   1546       1.59   thorpej #ifdef DIAGNOSTIC
   1547       1.59   thorpej 	if (fp->f_usecount != 1)
   1548       1.59   thorpej 		panic("closef: usecount != 1");
   1549       1.59   thorpej #endif
   1550       1.59   thorpej 
   1551  1.159.8.1      matt 	mutex_exit(&fp->f_lock);
   1552       1.16       cgd 	if ((fp->f_flag & FHASLOCK) && fp->f_type == DTYPE_VNODE) {
   1553       1.16       cgd 		lf.l_whence = SEEK_SET;
   1554       1.16       cgd 		lf.l_start = 0;
   1555       1.16       cgd 		lf.l_len = 0;
   1556       1.16       cgd 		lf.l_type = F_UNLCK;
   1557       1.16       cgd 		vp = (struct vnode *)fp->f_data;
   1558      1.106       dsl 		(void) VOP_ADVLOCK(vp, fp, F_UNLCK, &lf, F_FLOCK);
   1559       1.16       cgd 	}
   1560       1.17       cgd 	if (fp->f_ops)
   1561      1.138  christos 		error = (*fp->f_ops->fo_close)(fp, l);
   1562       1.17       cgd 	else
   1563       1.17       cgd 		error = 0;
   1564       1.59   thorpej 
   1565       1.59   thorpej 	/* Nothing references the file now, drop the final use (us). */
   1566       1.59   thorpej 	fp->f_usecount--;
   1567       1.59   thorpej 
   1568       1.16       cgd 	ffree(fp);
   1569       1.16       cgd 	return (error);
   1570       1.16       cgd }
   1571       1.16       cgd 
   1572       1.16       cgd /*
   1573       1.16       cgd  * Apply an advisory lock on a file descriptor.
   1574       1.16       cgd  *
   1575       1.16       cgd  * Just attempt to get a record lock of the requested type on
   1576       1.16       cgd  * the entire file (l_whence = SEEK_SET, l_start = 0, l_len = 0).
   1577       1.16       cgd  */
   1578       1.16       cgd /* ARGSUSED */
   1579       1.38  christos int
   1580      1.147      yamt sys_flock(struct lwp *l, void *v, register_t *retval)
   1581       1.36   thorpej {
   1582       1.66  augustss 	struct sys_flock_args /* {
   1583       1.72     lukem 		syscallarg(int)	fd;
   1584       1.72     lukem 		syscallarg(int)	how;
   1585       1.36   thorpej 	} */ *uap = v;
   1586       1.72     lukem 	int		fd, how, error;
   1587       1.99   thorpej 	struct proc	*p;
   1588       1.72     lukem 	struct filedesc	*fdp;
   1589       1.72     lukem 	struct file	*fp;
   1590       1.72     lukem 	struct vnode	*vp;
   1591       1.72     lukem 	struct flock	lf;
   1592       1.16       cgd 
   1593       1.99   thorpej 	p = l->l_proc;
   1594       1.72     lukem 	fd = SCARG(uap, fd);
   1595       1.72     lukem 	how = SCARG(uap, how);
   1596       1.72     lukem 	fdp = p->p_fd;
   1597       1.72     lukem 	error = 0;
   1598       1.77   thorpej 
   1599       1.77   thorpej 	if ((fp = fd_getfile(fdp, fd)) == NULL)
   1600       1.16       cgd 		return (EBADF);
   1601       1.59   thorpej 
   1602       1.59   thorpej 	FILE_USE(fp);
   1603       1.59   thorpej 
   1604       1.59   thorpej 	if (fp->f_type != DTYPE_VNODE) {
   1605       1.59   thorpej 		error = EOPNOTSUPP;
   1606       1.59   thorpej 		goto out;
   1607       1.59   thorpej 	}
   1608       1.59   thorpej 
   1609       1.16       cgd 	vp = (struct vnode *)fp->f_data;
   1610       1.16       cgd 	lf.l_whence = SEEK_SET;
   1611       1.16       cgd 	lf.l_start = 0;
   1612       1.16       cgd 	lf.l_len = 0;
   1613       1.27   mycroft 	if (how & LOCK_UN) {
   1614       1.16       cgd 		lf.l_type = F_UNLCK;
   1615       1.16       cgd 		fp->f_flag &= ~FHASLOCK;
   1616      1.106       dsl 		error = VOP_ADVLOCK(vp, fp, F_UNLCK, &lf, F_FLOCK);
   1617       1.59   thorpej 		goto out;
   1618       1.16       cgd 	}
   1619       1.27   mycroft 	if (how & LOCK_EX)
   1620       1.16       cgd 		lf.l_type = F_WRLCK;
   1621       1.27   mycroft 	else if (how & LOCK_SH)
   1622       1.16       cgd 		lf.l_type = F_RDLCK;
   1623       1.59   thorpej 	else {
   1624       1.59   thorpej 		error = EINVAL;
   1625       1.59   thorpej 		goto out;
   1626       1.59   thorpej 	}
   1627       1.16       cgd 	fp->f_flag |= FHASLOCK;
   1628       1.27   mycroft 	if (how & LOCK_NB)
   1629      1.106       dsl 		error = VOP_ADVLOCK(vp, fp, F_SETLK, &lf, F_FLOCK);
   1630       1.59   thorpej 	else
   1631      1.106       dsl 		error = VOP_ADVLOCK(vp, fp, F_SETLK, &lf,
   1632       1.59   thorpej 		    F_FLOCK|F_WAIT);
   1633       1.59   thorpej  out:
   1634      1.138  christos 	FILE_UNUSE(fp, l);
   1635       1.59   thorpej 	return (error);
   1636       1.16       cgd }
   1637       1.16       cgd 
   1638      1.137      yamt /* ARGSUSED */
   1639      1.137      yamt int
   1640      1.137      yamt sys_posix_fadvise(struct lwp *l, void *v, register_t *retval)
   1641      1.137      yamt {
   1642      1.137      yamt 	const struct sys_posix_fadvise_args /* {
   1643      1.137      yamt 		syscallarg(int) fd;
   1644      1.137      yamt 		syscallarg(off_t) offset;
   1645      1.137      yamt 		syscallarg(off_t) len;
   1646      1.137      yamt 		syscallarg(int) advice;
   1647      1.137      yamt 	} */ *uap = v;
   1648      1.137      yamt 	const int fd = SCARG(uap, fd);
   1649      1.137      yamt 	const int advice = SCARG(uap, advice);
   1650      1.137      yamt 	struct proc *p = l->l_proc;
   1651      1.137      yamt 	struct file *fp;
   1652      1.137      yamt 	int error = 0;
   1653      1.137      yamt 
   1654      1.137      yamt 	fp = fd_getfile(p->p_fd, fd);
   1655      1.137      yamt 	if (fp == NULL) {
   1656      1.137      yamt 		error = EBADF;
   1657      1.137      yamt 		goto out;
   1658      1.137      yamt 	}
   1659      1.137      yamt 	FILE_USE(fp);
   1660      1.137      yamt 
   1661      1.137      yamt 	if (fp->f_type != DTYPE_VNODE) {
   1662      1.137      yamt 		if (fp->f_type == DTYPE_PIPE || fp->f_type == DTYPE_SOCKET) {
   1663      1.137      yamt 			error = ESPIPE;
   1664      1.137      yamt 		} else {
   1665      1.137      yamt 			error = EOPNOTSUPP;
   1666      1.137      yamt 		}
   1667      1.137      yamt 		goto out;
   1668      1.137      yamt 	}
   1669      1.137      yamt 
   1670      1.137      yamt 	switch (advice) {
   1671      1.137      yamt 	case POSIX_FADV_NORMAL:
   1672      1.137      yamt 	case POSIX_FADV_RANDOM:
   1673      1.137      yamt 	case POSIX_FADV_SEQUENTIAL:
   1674      1.137      yamt 		KASSERT(POSIX_FADV_NORMAL == UVM_ADV_NORMAL);
   1675      1.137      yamt 		KASSERT(POSIX_FADV_RANDOM == UVM_ADV_RANDOM);
   1676      1.137      yamt 		KASSERT(POSIX_FADV_SEQUENTIAL == UVM_ADV_SEQUENTIAL);
   1677      1.137      yamt 
   1678      1.137      yamt 		/*
   1679      1.137      yamt 		 * we ignore offset and size.
   1680      1.137      yamt 		 */
   1681      1.137      yamt 
   1682      1.137      yamt 		fp->f_advice = advice;
   1683      1.137      yamt 		break;
   1684      1.137      yamt 
   1685      1.137      yamt 	case POSIX_FADV_WILLNEED:
   1686      1.137      yamt 	case POSIX_FADV_DONTNEED:
   1687      1.137      yamt 	case POSIX_FADV_NOREUSE:
   1688      1.137      yamt 
   1689      1.137      yamt 		/*
   1690      1.137      yamt 		 * not implemented yet.
   1691      1.137      yamt 		 */
   1692      1.137      yamt 
   1693      1.137      yamt 		break;
   1694      1.137      yamt 	default:
   1695      1.137      yamt 		error = EINVAL;
   1696      1.137      yamt 		break;
   1697      1.137      yamt 	}
   1698      1.137      yamt out:
   1699      1.137      yamt 	if (fp != NULL) {
   1700      1.138  christos 		FILE_UNUSE(fp, l);
   1701      1.137      yamt 	}
   1702      1.137      yamt 	*retval = error;
   1703      1.137      yamt 	return 0;
   1704      1.137      yamt }
   1705      1.137      yamt 
   1706       1.16       cgd /*
   1707       1.16       cgd  * File Descriptor pseudo-device driver (/dev/fd/).
   1708       1.16       cgd  *
   1709       1.16       cgd  * Opening minor device N dup()s the file (if any) connected to file
   1710       1.16       cgd  * descriptor N belonging to the calling process.  Note that this driver
   1711       1.16       cgd  * consists of only the ``open()'' routine, because all subsequent
   1712       1.16       cgd  * references to this file will be direct to the other driver.
   1713       1.16       cgd  */
   1714       1.16       cgd /* ARGSUSED */
   1715      1.134   thorpej static int
   1716      1.147      yamt filedescopen(dev_t dev, int mode, int type, struct lwp *l)
   1717       1.16       cgd {
   1718       1.16       cgd 
   1719       1.28   mycroft 	/*
   1720      1.112  jdolecek 	 * XXX Kludge: set dupfd to contain the value of the
   1721       1.89     enami 	 * the file descriptor being sought for duplication. The error
   1722       1.28   mycroft 	 * return ensures that the vnode for this device will be released
   1723       1.28   mycroft 	 * by vn_open. Open will detect this special error and take the
   1724       1.28   mycroft 	 * actions in dupfdopen below. Other callers of vn_open or VOP_OPEN
   1725       1.28   mycroft 	 * will simply report the error.
   1726       1.28   mycroft 	 */
   1727      1.138  christos 	l->l_dupfd = minor(dev);	/* XXX */
   1728      1.127  christos 	return EDUPFD;
   1729       1.27   mycroft }
   1730       1.27   mycroft 
   1731      1.134   thorpej const struct cdevsw filedesc_cdevsw = {
   1732      1.134   thorpej 	filedescopen, noclose, noread, nowrite, noioctl,
   1733      1.145  christos 	    nostop, notty, nopoll, nommap, nokqfilter, D_OTHER,
   1734      1.134   thorpej };
   1735      1.134   thorpej 
   1736       1.28   mycroft /*
   1737       1.28   mycroft  * Duplicate the specified descriptor to a free descriptor.
   1738      1.118      yamt  *
   1739      1.118      yamt  * 'indx' has been fdalloc'ed (and will be fdremove'ed on error) by the caller.
   1740       1.28   mycroft  */
   1741       1.27   mycroft int
   1742      1.138  christos dupfdopen(struct lwp *l, int indx, int dfd, int mode, int error)
   1743       1.72     lukem {
   1744      1.138  christos 	struct proc	*p = l->l_proc;
   1745      1.138  christos 	struct filedesc *fdp;
   1746      1.118      yamt 	struct file	*wfp;
   1747       1.27   mycroft 
   1748       1.72     lukem 	fdp = p->p_fd;
   1749      1.118      yamt 
   1750      1.118      yamt 	/* should be cleared by the caller */
   1751      1.118      yamt 	KASSERT(fdp->fd_ofiles[indx] == NULL);
   1752      1.118      yamt 
   1753       1.27   mycroft 	/*
   1754       1.27   mycroft 	 * If the to-be-dup'd fd number is greater than the allowed number
   1755       1.27   mycroft 	 * of file descriptors, or the fd to be dup'd has already been
   1756      1.118      yamt 	 * closed, reject.
   1757       1.27   mycroft 	 */
   1758       1.77   thorpej 
   1759      1.118      yamt 	/*
   1760      1.118      yamt 	 * Note, in the case of indx == dfd, fd_getfile below returns NULL.
   1761      1.118      yamt 	 */
   1762       1.77   thorpej 	if ((wfp = fd_getfile(fdp, dfd)) == NULL)
   1763       1.77   thorpej 		return (EBADF);
   1764       1.77   thorpej 
   1765       1.59   thorpej 	FILE_USE(wfp);
   1766       1.59   thorpej 
   1767       1.27   mycroft 	/*
   1768       1.28   mycroft 	 * There are two cases of interest here.
   1769       1.28   mycroft 	 *
   1770      1.127  christos 	 * For EDUPFD simply dup (dfd) to file descriptor
   1771       1.28   mycroft 	 * (indx) and return.
   1772       1.28   mycroft 	 *
   1773      1.127  christos 	 * For EMOVEFD steal away the file structure from (dfd) and
   1774       1.28   mycroft 	 * store it in (indx).  (dfd) is effectively closed by
   1775       1.28   mycroft 	 * this operation.
   1776       1.28   mycroft 	 *
   1777       1.28   mycroft 	 * Any other error code is just returned.
   1778       1.27   mycroft 	 */
   1779       1.28   mycroft 	switch (error) {
   1780      1.127  christos 	case EDUPFD:
   1781       1.28   mycroft 		/*
   1782       1.28   mycroft 		 * Check that the mode the file is being opened for is a
   1783       1.28   mycroft 		 * subset of the mode of the existing descriptor.
   1784       1.28   mycroft 		 */
   1785       1.59   thorpej 		if (((mode & (FREAD|FWRITE)) | wfp->f_flag) != wfp->f_flag) {
   1786      1.138  christos 			FILE_UNUSE(wfp, l);
   1787       1.28   mycroft 			return (EACCES);
   1788       1.59   thorpej 		}
   1789  1.159.8.1      matt 		rw_enter(&fdp->fd_lock, RW_WRITER);
   1790       1.28   mycroft 		fdp->fd_ofiles[indx] = wfp;
   1791       1.28   mycroft 		fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
   1792  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
   1793  1.159.8.1      matt 		mutex_enter(&wfp->f_lock);
   1794       1.28   mycroft 		wfp->f_count++;
   1795      1.119      yamt 		/* 'indx' has been fd_used'ed by caller */
   1796      1.138  christos 		FILE_UNUSE_HAVELOCK(wfp, l);
   1797       1.28   mycroft 		return (0);
   1798       1.27   mycroft 
   1799      1.127  christos 	case EMOVEFD:
   1800       1.28   mycroft 		/*
   1801       1.28   mycroft 		 * Steal away the file pointer from dfd, and stuff it into indx.
   1802       1.28   mycroft 		 */
   1803  1.159.8.1      matt 		rw_enter(&fdp->fd_lock, RW_WRITER);
   1804       1.28   mycroft 		fdp->fd_ofiles[indx] = fdp->fd_ofiles[dfd];
   1805       1.28   mycroft 		fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
   1806       1.28   mycroft 		fdp->fd_ofiles[dfd] = NULL;
   1807       1.28   mycroft 		fdp->fd_ofileflags[dfd] = 0;
   1808       1.28   mycroft 		/*
   1809       1.28   mycroft 		 * Complete the clean up of the filedesc structure by
   1810       1.28   mycroft 		 * recomputing the various hints.
   1811       1.28   mycroft 		 */
   1812      1.119      yamt 		/* 'indx' has been fd_used'ed by caller */
   1813       1.28   mycroft 		fd_unused(fdp, dfd);
   1814  1.159.8.1      matt 		rw_exit(&fdp->fd_lock);
   1815      1.138  christos 		FILE_UNUSE(wfp, l);
   1816       1.28   mycroft 		return (0);
   1817       1.16       cgd 
   1818       1.28   mycroft 	default:
   1819      1.138  christos 		FILE_UNUSE(wfp, l);
   1820       1.28   mycroft 		return (error);
   1821       1.28   mycroft 	}
   1822       1.28   mycroft 	/* NOTREACHED */
   1823       1.61  wrstuden }
   1824       1.61  wrstuden 
   1825       1.61  wrstuden /*
   1826       1.27   mycroft  * Close any files on exec?
   1827       1.27   mycroft  */
   1828       1.27   mycroft void
   1829      1.138  christos fdcloseexec(struct lwp *l)
   1830       1.27   mycroft {
   1831      1.138  christos 	struct proc	*p = l->l_proc;
   1832      1.138  christos 	struct filedesc *fdp;
   1833       1.72     lukem 	int		fd;
   1834       1.80   thorpej 
   1835      1.138  christos 	fdunshare(l);
   1836       1.80   thorpej 	cwdunshare(p);
   1837       1.16       cgd 
   1838      1.156       dsl 	if (p->p_cwdi->cwdi_edir)
   1839      1.156       dsl 		vrele(p->p_cwdi->cwdi_edir);
   1840      1.156       dsl 
   1841       1.72     lukem 	fdp = p->p_fd;
   1842       1.27   mycroft 	for (fd = 0; fd <= fdp->fd_lastfile; fd++)
   1843       1.27   mycroft 		if (fdp->fd_ofileflags[fd] & UF_EXCLOSE)
   1844      1.138  christos 			(void) fdrelease(l, fd);
   1845       1.86  christos }
   1846       1.86  christos 
   1847       1.86  christos /*
   1848       1.86  christos  * It is unsafe for set[ug]id processes to be started with file
   1849       1.86  christos  * descriptors 0..2 closed, as these descriptors are given implicit
   1850       1.86  christos  * significance in the Standard C library.  fdcheckstd() will create a
   1851       1.86  christos  * descriptor referencing /dev/null for each of stdin, stdout, and
   1852       1.86  christos  * stderr that is not already open.
   1853       1.86  christos  */
   1854       1.92    atatat #define CHECK_UPTO 3
   1855       1.86  christos int
   1856      1.155       dsl fdcheckstd(struct lwp *l)
   1857      1.138  christos {
   1858      1.110      fvdl 	struct proc *p;
   1859       1.86  christos 	struct nameidata nd;
   1860       1.86  christos 	struct filedesc *fdp;
   1861       1.86  christos 	struct file *fp;
   1862       1.97       scw 	struct file *devnullfp = NULL;	/* Quell compiler warning */
   1863       1.91     enami 	struct proc *pp;
   1864       1.86  christos 	register_t retval;
   1865       1.92    atatat 	int fd, i, error, flags = FREAD|FWRITE, devnull = -1;
   1866       1.92    atatat 	char closed[CHECK_UPTO * 3 + 1], which[3 + 1];
   1867       1.86  christos 
   1868      1.138  christos 	p = l->l_proc;
   1869       1.92    atatat 	closed[0] = '\0';
   1870       1.86  christos 	if ((fdp = p->p_fd) == NULL)
   1871       1.89     enami 		return (0);
   1872       1.92    atatat 	for (i = 0; i < CHECK_UPTO; i++) {
   1873       1.86  christos 		if (fdp->fd_ofiles[i] != NULL)
   1874       1.86  christos 			continue;
   1875       1.92    atatat 		snprintf(which, sizeof(which), ",%d", i);
   1876      1.108    itojun 		strlcat(closed, which, sizeof(closed));
   1877      1.142  christos 		if (devnullfp == NULL) {
   1878      1.144        ad 			if ((error = falloc(l, &fp, &fd)) != 0)
   1879       1.89     enami 				return (error);
   1880       1.86  christos 			NDINIT(&nd, LOOKUP, FOLLOW, UIO_SYSSPACE, "/dev/null",
   1881      1.138  christos 			    l);
   1882       1.86  christos 			if ((error = vn_open(&nd, flags, 0)) != 0) {
   1883      1.138  christos 				FILE_UNUSE(fp, l);
   1884       1.86  christos 				ffree(fp);
   1885       1.86  christos 				fdremove(p->p_fd, fd);
   1886       1.89     enami 				return (error);
   1887       1.86  christos 			}
   1888      1.106       dsl 			fp->f_data = nd.ni_vp;
   1889       1.86  christos 			fp->f_flag = flags;
   1890       1.86  christos 			fp->f_ops = &vnops;
   1891       1.86  christos 			fp->f_type = DTYPE_VNODE;
   1892       1.86  christos 			VOP_UNLOCK(nd.ni_vp, 0);
   1893       1.86  christos 			devnull = fd;
   1894       1.88  christos 			devnullfp = fp;
   1895       1.87  christos 			FILE_SET_MATURE(fp);
   1896       1.86  christos 		} else {
   1897       1.86  christos restart:
   1898       1.86  christos 			if ((error = fdalloc(p, 0, &fd)) != 0) {
   1899       1.86  christos 				if (error == ENOSPC) {
   1900       1.86  christos 					fdexpand(p);
   1901       1.86  christos 					goto restart;
   1902       1.86  christos 				}
   1903       1.89     enami 				return (error);
   1904       1.86  christos 			}
   1905       1.88  christos 
   1906  1.159.8.1      matt 			mutex_enter(&devnullfp->f_lock);
   1907       1.88  christos 			FILE_USE(devnullfp);
   1908       1.88  christos 			/* finishdup() will unuse the descriptors for us */
   1909      1.138  christos 			if ((error = finishdup(l, devnull, fd, &retval)) != 0)
   1910       1.89     enami 				return (error);
   1911       1.86  christos 		}
   1912       1.86  christos 	}
   1913      1.104      yamt 	if (devnullfp)
   1914      1.138  christos 		FILE_UNUSE(devnullfp, l);
   1915       1.92    atatat 	if (closed[0] != '\0') {
   1916      1.152        ad 		mutex_enter(&proclist_lock);
   1917       1.92    atatat 		pp = p->p_pptr;
   1918      1.150        ad 		mutex_enter(&pp->p_mutex);
   1919       1.92    atatat 		log(LOG_WARNING, "set{u,g}id pid %d (%s) "
   1920       1.92    atatat 		    "was invoked by uid %d ppid %d (%s) "
   1921       1.92    atatat 		    "with fd %s closed\n",
   1922      1.143      elad 		    p->p_pid, p->p_comm, kauth_cred_geteuid(pp->p_cred),
   1923       1.92    atatat 		    pp->p_pid, pp->p_comm, &closed[1]);
   1924      1.150        ad 		mutex_exit(&pp->p_mutex);
   1925      1.152        ad 		mutex_exit(&proclist_lock);
   1926       1.92    atatat 	}
   1927       1.89     enami 	return (0);
   1928       1.16       cgd }
   1929       1.92    atatat #undef CHECK_UPTO
   1930      1.113  jdolecek 
   1931      1.113  jdolecek /*
   1932      1.113  jdolecek  * Sets descriptor owner. If the owner is a process, 'pgid'
   1933      1.113  jdolecek  * is set to positive value, process ID. If the owner is process group,
   1934      1.113  jdolecek  * 'pgid' is set to -pg_id.
   1935      1.113  jdolecek  */
   1936      1.113  jdolecek int
   1937      1.113  jdolecek fsetown(struct proc *p, pid_t *pgid, int cmd, const void *data)
   1938      1.113  jdolecek {
   1939      1.133  christos 	int id = *(const int *)data;
   1940      1.113  jdolecek 	int error;
   1941      1.113  jdolecek 
   1942      1.113  jdolecek 	switch (cmd) {
   1943      1.113  jdolecek 	case TIOCSPGRP:
   1944      1.113  jdolecek 		if (id < 0)
   1945      1.113  jdolecek 			return (EINVAL);
   1946      1.113  jdolecek 		id = -id;
   1947      1.113  jdolecek 		break;
   1948      1.113  jdolecek 	default:
   1949      1.113  jdolecek 		break;
   1950      1.113  jdolecek 	}
   1951      1.113  jdolecek 
   1952      1.113  jdolecek 	if (id > 0 && !pfind(id))
   1953      1.113  jdolecek 		return (ESRCH);
   1954      1.113  jdolecek 	else if (id < 0 && (error = pgid_in_session(p, -id)))
   1955      1.113  jdolecek 		return (error);
   1956      1.113  jdolecek 
   1957      1.113  jdolecek 	*pgid = id;
   1958      1.113  jdolecek 	return (0);
   1959      1.113  jdolecek }
   1960      1.113  jdolecek 
   1961      1.113  jdolecek /*
   1962      1.113  jdolecek  * Return descriptor owner information. If the value is positive,
   1963      1.113  jdolecek  * it's process ID. If it's negative, it's process group ID and
   1964      1.113  jdolecek  * needs the sign removed before use.
   1965      1.113  jdolecek  */
   1966      1.113  jdolecek int
   1967      1.147      yamt fgetown(struct proc *p, pid_t pgid, int cmd, void *data)
   1968      1.113  jdolecek {
   1969      1.113  jdolecek 	switch (cmd) {
   1970      1.113  jdolecek 	case TIOCGPGRP:
   1971      1.113  jdolecek 		*(int *)data = -pgid;
   1972      1.113  jdolecek 		break;
   1973      1.113  jdolecek 	default:
   1974      1.113  jdolecek 		*(int *)data = pgid;
   1975      1.113  jdolecek 		break;
   1976      1.113  jdolecek 	}
   1977      1.113  jdolecek 	return (0);
   1978      1.113  jdolecek }
   1979      1.113  jdolecek 
   1980      1.113  jdolecek /*
   1981      1.113  jdolecek  * Send signal to descriptor owner, either process or process group.
   1982      1.113  jdolecek  */
   1983      1.113  jdolecek void
   1984      1.114  christos fownsignal(pid_t pgid, int signo, int code, int band, void *fdescdata)
   1985      1.113  jdolecek {
   1986      1.113  jdolecek 	struct proc *p1;
   1987      1.150        ad 	struct pgrp *pgrp;
   1988      1.131     perry 	ksiginfo_t ksi;
   1989      1.113  jdolecek 
   1990      1.148      yamt 	KSI_INIT(&ksi);
   1991      1.114  christos 	ksi.ksi_signo = signo;
   1992      1.113  jdolecek 	ksi.ksi_code = code;
   1993      1.113  jdolecek 	ksi.ksi_band = band;
   1994      1.113  jdolecek 
   1995      1.150        ad 	/*
   1996      1.150        ad 	 * Since we may be called from an interrupt context, we must use
   1997      1.150        ad 	 * the proclist_mutex.
   1998      1.150        ad 	 */
   1999      1.150        ad 	mutex_enter(&proclist_mutex);
   2000      1.150        ad 	if (pgid > 0 && (p1 = p_find(pgid, PFIND_LOCKED)))
   2001      1.113  jdolecek 		kpsignal(p1, &ksi, fdescdata);
   2002      1.150        ad 	else if (pgid < 0 && (pgrp = pg_find(-pgid, PFIND_LOCKED)))
   2003      1.150        ad 		kpgsignal(pgrp, &ksi, fdescdata, 0);
   2004      1.150        ad 	mutex_exit(&proclist_mutex);
   2005      1.113  jdolecek }
   2006      1.127  christos 
   2007      1.127  christos int
   2008      1.138  christos fdclone(struct lwp *l, struct file *fp, int fd, int flag,
   2009      1.130  christos     const struct fileops *fops, void *data)
   2010      1.127  christos {
   2011      1.130  christos 	fp->f_flag = flag;
   2012      1.127  christos 	fp->f_type = DTYPE_MISC;
   2013      1.127  christos 	fp->f_ops = fops;
   2014      1.127  christos 	fp->f_data = data;
   2015      1.127  christos 
   2016      1.138  christos 	l->l_dupfd = fd;
   2017      1.127  christos 
   2018      1.127  christos 	FILE_SET_MATURE(fp);
   2019      1.138  christos 	FILE_UNUSE(fp, l);
   2020      1.127  christos 	return EMOVEFD;
   2021      1.127  christos }
   2022      1.127  christos 
   2023      1.127  christos /* ARGSUSED */
   2024      1.127  christos int
   2025      1.147      yamt fnullop_fcntl(struct file *fp, u_int cmd, void *data, struct lwp *l)
   2026      1.127  christos {
   2027      1.147      yamt 
   2028      1.127  christos 	if (cmd == F_SETFL)
   2029      1.127  christos 		return 0;
   2030      1.127  christos 
   2031      1.127  christos 	return EOPNOTSUPP;
   2032      1.127  christos }
   2033      1.127  christos 
   2034      1.127  christos /* ARGSUSED */
   2035      1.127  christos int
   2036      1.147      yamt fnullop_poll(struct file *fp, int which, struct lwp *l)
   2037      1.127  christos {
   2038      1.147      yamt 
   2039      1.127  christos 	return 0;
   2040      1.127  christos }
   2041      1.127  christos 
   2042      1.127  christos 
   2043      1.127  christos /* ARGSUSED */
   2044      1.127  christos int
   2045      1.147      yamt fnullop_kqfilter(struct file *fp, struct knote *kn)
   2046      1.127  christos {
   2047      1.127  christos 
   2048      1.127  christos 	return 0;
   2049      1.127  christos }
   2050      1.127  christos 
   2051      1.127  christos /* ARGSUSED */
   2052      1.127  christos int
   2053  1.159.8.1      matt fbadop_read(struct file *fp, off_t *offset, struct uio *uio,
   2054  1.159.8.1      matt     kauth_cred_t cred, int flags)
   2055  1.159.8.1      matt {
   2056  1.159.8.1      matt 
   2057  1.159.8.1      matt 	return EOPNOTSUPP;
   2058  1.159.8.1      matt }
   2059  1.159.8.1      matt 
   2060  1.159.8.1      matt /* ARGSUSED */
   2061  1.159.8.1      matt int
   2062  1.159.8.1      matt fbadop_write(struct file *fp, off_t *offset, struct uio *uio,
   2063  1.159.8.1      matt     kauth_cred_t cred, int flags)
   2064  1.159.8.1      matt {
   2065  1.159.8.1      matt 
   2066  1.159.8.1      matt 	return EOPNOTSUPP;
   2067  1.159.8.1      matt }
   2068  1.159.8.1      matt 
   2069  1.159.8.1      matt /* ARGSUSED */
   2070  1.159.8.1      matt int
   2071  1.159.8.1      matt fbadop_ioctl(struct file *fp, u_long com, void *data, struct lwp *l)
   2072  1.159.8.1      matt {
   2073  1.159.8.1      matt 
   2074  1.159.8.1      matt 	return EOPNOTSUPP;
   2075  1.159.8.1      matt }
   2076  1.159.8.1      matt 
   2077  1.159.8.1      matt /* ARGSUSED */
   2078  1.159.8.1      matt int
   2079      1.147      yamt fbadop_stat(struct file *fp, struct stat *sb, struct lwp *l)
   2080      1.127  christos {
   2081      1.147      yamt 
   2082      1.127  christos 	return EOPNOTSUPP;
   2083      1.127  christos }
   2084  1.159.8.1      matt 
   2085  1.159.8.1      matt /* ARGSUSED */
   2086  1.159.8.1      matt int
   2087  1.159.8.1      matt fbadop_close(struct file *fp, struct lwp *l)
   2088  1.159.8.1      matt {
   2089  1.159.8.1      matt 
   2090  1.159.8.1      matt 	return EOPNOTSUPP;
   2091  1.159.8.1      matt }
   2092