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