1197 lines · 28.2 KB · C
RawDownload
// SPDX-License-Identifier: GPL-2.0/* *  linux/fs/file.c * *  Copyright (C) 1998-1999, Stephen Tweedie and Bill Hawes * *  Manage the dynamic fd arrays in the process files_struct. */ #include <linux/syscalls.h>#include <linux/export.h>#include <linux/fs.h>#include <linux/kernel.h>#include <linux/mm.h>#include <linux/sched/signal.h>#include <linux/slab.h>#include <linux/file.h>#include <linux/fdtable.h>#include <linux/bitops.h>#include <linux/spinlock.h>#include <linux/rcupdate.h>#include <linux/close_range.h>#include <net/sock.h> unsigned int sysctl_nr_open __read_mostly = 1024*1024;unsigned int sysctl_nr_open_min = BITS_PER_LONG;/* our min() is unusable in constant expressions ;-/ */#define __const_min(x, y) ((x) < (y) ? (x) : (y))unsigned int sysctl_nr_open_max =	__const_min(INT_MAX, ~(size_t)0/sizeof(void *)) & -BITS_PER_LONG; static void __free_fdtable(struct fdtable *fdt){	kvfree(fdt->fd);	kvfree(fdt->open_fds);	kfree(fdt);} static void free_fdtable_rcu(struct rcu_head *rcu){	__free_fdtable(container_of(rcu, struct fdtable, rcu));} #define BITBIT_NR(nr)	BITS_TO_LONGS(BITS_TO_LONGS(nr))#define BITBIT_SIZE(nr)	(BITBIT_NR(nr) * sizeof(long)) /* * Copy 'count' fd bits from the old table to the new table and clear the extra * space if any.  This does not copy the file pointers.  Called with the files * spinlock held for write. */static void copy_fd_bitmaps(struct fdtable *nfdt, struct fdtable *ofdt,			    unsigned int count){	unsigned int cpy, set; 	cpy = count / BITS_PER_BYTE;	set = (nfdt->max_fds - count) / BITS_PER_BYTE;	memcpy(nfdt->open_fds, ofdt->open_fds, cpy);	memset((char *)nfdt->open_fds + cpy, 0, set);	memcpy(nfdt->close_on_exec, ofdt->close_on_exec, cpy);	memset((char *)nfdt->close_on_exec + cpy, 0, set); 	cpy = BITBIT_SIZE(count);	set = BITBIT_SIZE(nfdt->max_fds) - cpy;	memcpy(nfdt->full_fds_bits, ofdt->full_fds_bits, cpy);	memset((char *)nfdt->full_fds_bits + cpy, 0, set);} /* * Copy all file descriptors from the old table to the new, expanded table and * clear the extra space.  Called with the files spinlock held for write. */static void copy_fdtable(struct fdtable *nfdt, struct fdtable *ofdt){	size_t cpy, set; 	BUG_ON(nfdt->max_fds < ofdt->max_fds); 	cpy = ofdt->max_fds * sizeof(struct file *);	set = (nfdt->max_fds - ofdt->max_fds) * sizeof(struct file *);	memcpy(nfdt->fd, ofdt->fd, cpy);	memset((char *)nfdt->fd + cpy, 0, set); 	copy_fd_bitmaps(nfdt, ofdt, ofdt->max_fds);} static struct fdtable * alloc_fdtable(unsigned int nr){	struct fdtable *fdt;	void *data; 	/*	 * Figure out how many fds we actually want to support in this fdtable.	 * Allocation steps are keyed to the size of the fdarray, since it	 * grows far faster than any of the other dynamic data. We try to fit	 * the fdarray into comfortable page-tuned chunks: starting at 1024B	 * and growing in powers of two from there on.	 */	nr /= (1024 / sizeof(struct file *));	nr = roundup_pow_of_two(nr + 1);	nr *= (1024 / sizeof(struct file *));	/*	 * Note that this can drive nr *below* what we had passed if sysctl_nr_open	 * had been set lower between the check in expand_files() and here.  Deal	 * with that in caller, it's cheaper that way.	 *	 * We make sure that nr remains a multiple of BITS_PER_LONG - otherwise	 * bitmaps handling below becomes unpleasant, to put it mildly...	 */	if (unlikely(nr > sysctl_nr_open))		nr = ((sysctl_nr_open - 1) | (BITS_PER_LONG - 1)) + 1; 	fdt = kmalloc(sizeof(struct fdtable), GFP_KERNEL_ACCOUNT);	if (!fdt)		goto out;	fdt->max_fds = nr;	data = kvmalloc_array(nr, sizeof(struct file *), GFP_KERNEL_ACCOUNT);	if (!data)		goto out_fdt;	fdt->fd = data; 	data = kvmalloc(max_t(size_t,				 2 * nr / BITS_PER_BYTE + BITBIT_SIZE(nr), L1_CACHE_BYTES),				 GFP_KERNEL_ACCOUNT);	if (!data)		goto out_arr;	fdt->open_fds = data;	data += nr / BITS_PER_BYTE;	fdt->close_on_exec = data;	data += nr / BITS_PER_BYTE;	fdt->full_fds_bits = data; 	return fdt; out_arr:	kvfree(fdt->fd);out_fdt:	kfree(fdt);out:	return NULL;} /* * Expand the file descriptor table. * This function will allocate a new fdtable and both fd array and fdset, of * the given size. * Return <0 error code on error; 1 on successful completion. * The files->file_lock should be held on entry, and will be held on exit. */static int expand_fdtable(struct files_struct *files, unsigned int nr)	__releases(files->file_lock)	__acquires(files->file_lock){	struct fdtable *new_fdt, *cur_fdt; 	spin_unlock(&files->file_lock);	new_fdt = alloc_fdtable(nr); 	/* make sure all __fd_install() have seen resize_in_progress	 * or have finished their rcu_read_lock_sched() section.	 */	if (atomic_read(&files->count) > 1)		synchronize_rcu(); 	spin_lock(&files->file_lock);	if (!new_fdt)		return -ENOMEM;	/*	 * extremely unlikely race - sysctl_nr_open decreased between the check in	 * caller and alloc_fdtable().  Cheaper to catch it here...	 */	if (unlikely(new_fdt->max_fds <= nr)) {		__free_fdtable(new_fdt);		return -EMFILE;	}	cur_fdt = files_fdtable(files);	BUG_ON(nr < cur_fdt->max_fds);	copy_fdtable(new_fdt, cur_fdt);	rcu_assign_pointer(files->fdt, new_fdt);	if (cur_fdt != &files->fdtab)		call_rcu(&cur_fdt->rcu, free_fdtable_rcu);	/* coupled with smp_rmb() in __fd_install() */	smp_wmb();	return 1;} /* * Expand files. * This function will expand the file structures, if the requested size exceeds * the current capacity and there is room for expansion. * Return <0 error code on error; 0 when nothing done; 1 when files were * expanded and execution may have blocked. * The files->file_lock should be held on entry, and will be held on exit. */static int expand_files(struct files_struct *files, unsigned int nr)	__releases(files->file_lock)	__acquires(files->file_lock){	struct fdtable *fdt;	int expanded = 0; repeat:	fdt = files_fdtable(files); 	/* Do we need to expand? */	if (nr < fdt->max_fds)		return expanded; 	/* Can we expand? */	if (nr >= sysctl_nr_open)		return -EMFILE; 	if (unlikely(files->resize_in_progress)) {		spin_unlock(&files->file_lock);		expanded = 1;		wait_event(files->resize_wait, !files->resize_in_progress);		spin_lock(&files->file_lock);		goto repeat;	} 	/* All good, so we try */	files->resize_in_progress = true;	expanded = expand_fdtable(files, nr);	files->resize_in_progress = false; 	wake_up_all(&files->resize_wait);	return expanded;} static inline void __set_close_on_exec(unsigned int fd, struct fdtable *fdt){	__set_bit(fd, fdt->close_on_exec);} static inline void __clear_close_on_exec(unsigned int fd, struct fdtable *fdt){	if (test_bit(fd, fdt->close_on_exec))		__clear_bit(fd, fdt->close_on_exec);} static inline void __set_open_fd(unsigned int fd, struct fdtable *fdt){	__set_bit(fd, fdt->open_fds);	fd /= BITS_PER_LONG;	if (!~fdt->open_fds[fd])		__set_bit(fd, fdt->full_fds_bits);} static inline void __clear_open_fd(unsigned int fd, struct fdtable *fdt){	__clear_bit(fd, fdt->open_fds);	__clear_bit(fd / BITS_PER_LONG, fdt->full_fds_bits);} static unsigned int count_open_files(struct fdtable *fdt){	unsigned int size = fdt->max_fds;	unsigned int i; 	/* Find the last open fd */	for (i = size / BITS_PER_LONG; i > 0; ) {		if (fdt->open_fds[--i])			break;	}	i = (i + 1) * BITS_PER_LONG;	return i;} static unsigned int sane_fdtable_size(struct fdtable *fdt, unsigned int max_fds){	unsigned int count; 	count = count_open_files(fdt);	if (max_fds < NR_OPEN_DEFAULT)		max_fds = NR_OPEN_DEFAULT;	return min(count, max_fds);} /* * Allocate a new files structure and copy contents from the * passed in files structure. * errorp will be valid only when the returned files_struct is NULL. */struct files_struct *dup_fd(struct files_struct *oldf, unsigned int max_fds, int *errorp){	struct files_struct *newf;	struct file **old_fds, **new_fds;	unsigned int open_files, i;	struct fdtable *old_fdt, *new_fdt; 	*errorp = -ENOMEM;	newf = kmem_cache_alloc(files_cachep, GFP_KERNEL);	if (!newf)		goto out; 	atomic_set(&newf->count, 1); 	spin_lock_init(&newf->file_lock);	newf->resize_in_progress = false;	init_waitqueue_head(&newf->resize_wait);	newf->next_fd = 0;	new_fdt = &newf->fdtab;	new_fdt->max_fds = NR_OPEN_DEFAULT;	new_fdt->close_on_exec = newf->close_on_exec_init;	new_fdt->open_fds = newf->open_fds_init;	new_fdt->full_fds_bits = newf->full_fds_bits_init;	new_fdt->fd = &newf->fd_array[0]; 	spin_lock(&oldf->file_lock);	old_fdt = files_fdtable(oldf);	open_files = sane_fdtable_size(old_fdt, max_fds); 	/*	 * Check whether we need to allocate a larger fd array and fd set.	 */	while (unlikely(open_files > new_fdt->max_fds)) {		spin_unlock(&oldf->file_lock); 		if (new_fdt != &newf->fdtab)			__free_fdtable(new_fdt); 		new_fdt = alloc_fdtable(open_files - 1);		if (!new_fdt) {			*errorp = -ENOMEM;			goto out_release;		} 		/* beyond sysctl_nr_open; nothing to do */		if (unlikely(new_fdt->max_fds < open_files)) {			__free_fdtable(new_fdt);			*errorp = -EMFILE;			goto out_release;		} 		/*		 * Reacquire the oldf lock and a pointer to its fd table		 * who knows it may have a new bigger fd table. We need		 * the latest pointer.		 */		spin_lock(&oldf->file_lock);		old_fdt = files_fdtable(oldf);		open_files = sane_fdtable_size(old_fdt, max_fds);	} 	copy_fd_bitmaps(new_fdt, old_fdt, open_files); 	old_fds = old_fdt->fd;	new_fds = new_fdt->fd; 	for (i = open_files; i != 0; i--) {		struct file *f = *old_fds++;		if (f) {			get_file(f);		} else {			/*			 * The fd may be claimed in the fd bitmap but not yet			 * instantiated in the files array if a sibling thread			 * is partway through open().  So make sure that this			 * fd is available to the new process.			 */			__clear_open_fd(open_files - i, new_fdt);		}		rcu_assign_pointer(*new_fds++, f);	}	spin_unlock(&oldf->file_lock); 	/* clear the remainder */	memset(new_fds, 0, (new_fdt->max_fds - open_files) * sizeof(struct file *)); 	rcu_assign_pointer(newf->fdt, new_fdt); 	return newf; out_release:	kmem_cache_free(files_cachep, newf);out:	return NULL;} static struct fdtable *close_files(struct files_struct * files){	/*	 * It is safe to dereference the fd table without RCU or	 * ->file_lock because this is the last reference to the	 * files structure.	 */	struct fdtable *fdt = rcu_dereference_raw(files->fdt);	unsigned int i, j = 0; 	for (;;) {		unsigned long set;		i = j * BITS_PER_LONG;		if (i >= fdt->max_fds)			break;		set = fdt->open_fds[j++];		while (set) {			if (set & 1) {				struct file * file = xchg(&fdt->fd[i], NULL);				if (file) {					filp_close(file, files);					cond_resched();				}			}			i++;			set >>= 1;		}	} 	return fdt;} struct files_struct *get_files_struct(struct task_struct *task){	struct files_struct *files; 	task_lock(task);	files = task->files;	if (files)		atomic_inc(&files->count);	task_unlock(task); 	return files;} void put_files_struct(struct files_struct *files){	if (atomic_dec_and_test(&files->count)) {		struct fdtable *fdt = close_files(files); 		/* free the arrays if they are not embedded */		if (fdt != &files->fdtab)			__free_fdtable(fdt);		kmem_cache_free(files_cachep, files);	}} void reset_files_struct(struct files_struct *files){	struct task_struct *tsk = current;	struct files_struct *old; 	old = tsk->files;	task_lock(tsk);	tsk->files = files;	task_unlock(tsk);	put_files_struct(old);} void exit_files(struct task_struct *tsk){	struct files_struct * files = tsk->files; 	if (files) {		task_lock(tsk);		tsk->files = NULL;		task_unlock(tsk);		put_files_struct(files);	}} struct files_struct init_files = {	.count		= ATOMIC_INIT(1),	.fdt		= &init_files.fdtab,	.fdtab		= {		.max_fds	= NR_OPEN_DEFAULT,		.fd		= &init_files.fd_array[0],		.close_on_exec	= init_files.close_on_exec_init,		.open_fds	= init_files.open_fds_init,		.full_fds_bits	= init_files.full_fds_bits_init,	},	.file_lock	= __SPIN_LOCK_UNLOCKED(init_files.file_lock),	.resize_wait	= __WAIT_QUEUE_HEAD_INITIALIZER(init_files.resize_wait),}; static unsigned int find_next_fd(struct fdtable *fdt, unsigned int start){	unsigned int maxfd = fdt->max_fds;	unsigned int maxbit = maxfd / BITS_PER_LONG;	unsigned int bitbit = start / BITS_PER_LONG; 	bitbit = find_next_zero_bit(fdt->full_fds_bits, maxbit, bitbit) * BITS_PER_LONG;	if (bitbit > maxfd)		return maxfd;	if (bitbit > start)		start = bitbit;	return find_next_zero_bit(fdt->open_fds, maxfd, start);} /* * allocate a file descriptor, mark it busy. */int __alloc_fd(struct files_struct *files,	       unsigned start, unsigned end, unsigned flags){	unsigned int fd;	int error;	struct fdtable *fdt; 	spin_lock(&files->file_lock);

Lines 1–500 of 1197.