1

Assorted commits that had missed the last merge window...

-----BEGIN PGP SIGNATURE-----
 
 iHUEABYIAB0WIQQqUNBr3gm4hGXdBJlZ7Krx/gZQ6wUCZkzp/gAKCRBZ7Krx/gZQ
 63KFAQCsKv3XdcF+2BO+QuwPvR6eAvDxFjrFEcQFyyOXgFVLaAD/UMM0HcEFWxBb
 PCPvyKVP22wF9PbodkrKJn8DRdtRZwM=
 =jvWv
 -----END PGP SIGNATURE-----

Merge tag 'pull-misc' of git://git.kernel.org/pub/scm/linux/kernel/git/viro/vfs

Pull misc vfs updates from Al Viro:
 "Assorted commits that had missed the last merge window..."

* tag 'pull-misc' of git://git.kernel.org/pub/scm/linux/kernel/git/viro/vfs:
  remove call_{read,write}_iter() functions
  do_dentry_open(): kill inode argument
  kernel_file_open(): get rid of inode argument
  get_file_rcu(): no need to check for NULL separately
  fd_is_open(): move to fs/file.c
  close_on_exec(): pass files_struct instead of fdtable
This commit is contained in:
Linus Torvalds 2024-05-21 13:11:44 -07:00
commit b6394d6f71
13 changed files with 38 additions and 62 deletions

View File

@ -445,9 +445,9 @@ static int lo_rw_aio(struct loop_device *lo, struct loop_cmd *cmd,
cmd->iocb.ki_ioprio = IOPRIO_PRIO_VALUE(IOPRIO_CLASS_NONE, 0); cmd->iocb.ki_ioprio = IOPRIO_PRIO_VALUE(IOPRIO_CLASS_NONE, 0);
if (rw == ITER_SOURCE) if (rw == ITER_SOURCE)
ret = call_write_iter(file, &cmd->iocb, &iter); ret = file->f_op->write_iter(&cmd->iocb, &iter);
else else
ret = call_read_iter(file, &cmd->iocb, &iter); ret = file->f_op->read_iter(&cmd->iocb, &iter);
lo_rw_aio_do_completion(cmd); lo_rw_aio_do_completion(cmd);

View File

@ -299,9 +299,9 @@ fd_execute_rw_aio(struct se_cmd *cmd, struct scatterlist *sgl, u32 sgl_nents,
aio_cmd->iocb.ki_flags |= IOCB_DSYNC; aio_cmd->iocb.ki_flags |= IOCB_DSYNC;
if (is_write) if (is_write)
ret = call_write_iter(file, &aio_cmd->iocb, &iter); ret = file->f_op->write_iter(&aio_cmd->iocb, &iter);
else else
ret = call_read_iter(file, &aio_cmd->iocb, &iter); ret = file->f_op->read_iter(&aio_cmd->iocb, &iter);
if (ret != -EIOCBQUEUED) if (ret != -EIOCBQUEUED)
cmd_rw_aio_complete(&aio_cmd->iocb, ret); cmd_rw_aio_complete(&aio_cmd->iocb, ret);

View File

@ -1608,7 +1608,7 @@ static int aio_read(struct kiocb *req, const struct iocb *iocb,
return ret; return ret;
ret = rw_verify_area(READ, file, &req->ki_pos, iov_iter_count(&iter)); ret = rw_verify_area(READ, file, &req->ki_pos, iov_iter_count(&iter));
if (!ret) if (!ret)
aio_rw_done(req, call_read_iter(file, req, &iter)); aio_rw_done(req, file->f_op->read_iter(req, &iter));
kfree(iovec); kfree(iovec);
return ret; return ret;
} }
@ -1639,7 +1639,7 @@ static int aio_write(struct kiocb *req, const struct iocb *iocb,
if (S_ISREG(file_inode(file)->i_mode)) if (S_ISREG(file_inode(file)->i_mode))
kiocb_start_write(req); kiocb_start_write(req);
req->ki_flags |= IOCB_WRITE; req->ki_flags |= IOCB_WRITE;
aio_rw_done(req, call_write_iter(file, req, &iter)); aio_rw_done(req, file->f_op->write_iter(req, &iter));
} }
kfree(iovec); kfree(iovec);
return ret; return ret;

View File

@ -563,8 +563,7 @@ static bool cachefiles_open_file(struct cachefiles_object *object,
*/ */
path.mnt = cache->mnt; path.mnt = cache->mnt;
path.dentry = dentry; path.dentry = dentry;
file = kernel_file_open(&path, O_RDWR | O_LARGEFILE | O_DIRECT, file = kernel_file_open(&path, O_RDWR | O_LARGEFILE | O_DIRECT, cache->cache_cred);
d_backing_inode(dentry), cache->cache_cred);
if (IS_ERR(file)) { if (IS_ERR(file)) {
trace_cachefiles_vfs_error(object, d_backing_inode(dentry), trace_cachefiles_vfs_error(object, d_backing_inode(dentry),
PTR_ERR(file), PTR_ERR(file),

View File

@ -271,6 +271,11 @@ static inline void __clear_open_fd(unsigned int fd, struct fdtable *fdt)
__clear_bit(fd / BITS_PER_LONG, fdt->full_fds_bits); __clear_bit(fd / BITS_PER_LONG, fdt->full_fds_bits);
} }
static inline bool fd_is_open(unsigned int fd, const struct fdtable *fdt)
{
return test_bit(fd, fdt->open_fds);
}
static unsigned int count_open_files(struct fdtable *fdt) static unsigned int count_open_files(struct fdtable *fdt)
{ {
unsigned int size = fdt->max_fds; unsigned int size = fdt->max_fds;
@ -915,12 +920,7 @@ struct file *get_file_rcu(struct file __rcu **f)
struct file __rcu *file; struct file __rcu *file;
file = __get_file_rcu(f); file = __get_file_rcu(f);
if (unlikely(!file)) if (!IS_ERR(file))
return NULL;
if (unlikely(IS_ERR(file)))
continue;
return file; return file;
} }
} }
@ -1219,12 +1219,9 @@ void set_close_on_exec(unsigned int fd, int flag)
bool get_close_on_exec(unsigned int fd) bool get_close_on_exec(unsigned int fd)
{ {
struct files_struct *files = current->files;
struct fdtable *fdt;
bool res; bool res;
rcu_read_lock(); rcu_read_lock();
fdt = files_fdtable(files); res = close_on_exec(fd, current->files);
res = close_on_exec(fd, fdt);
rcu_read_unlock(); rcu_read_unlock();
return res; return res;
} }

View File

@ -902,10 +902,10 @@ cleanup_inode:
} }
static int do_dentry_open(struct file *f, static int do_dentry_open(struct file *f,
struct inode *inode,
int (*open)(struct inode *, struct file *)) int (*open)(struct inode *, struct file *))
{ {
static const struct file_operations empty_fops = {}; static const struct file_operations empty_fops = {};
struct inode *inode = f->f_path.dentry->d_inode;
int error; int error;
path_get(&f->f_path); path_get(&f->f_path);
@ -1047,7 +1047,7 @@ int finish_open(struct file *file, struct dentry *dentry,
BUG_ON(file->f_mode & FMODE_OPENED); /* once it's opened, it's opened */ BUG_ON(file->f_mode & FMODE_OPENED); /* once it's opened, it's opened */
file->f_path.dentry = dentry; file->f_path.dentry = dentry;
return do_dentry_open(file, d_backing_inode(dentry), open); return do_dentry_open(file, open);
} }
EXPORT_SYMBOL(finish_open); EXPORT_SYMBOL(finish_open);
@ -1086,7 +1086,7 @@ EXPORT_SYMBOL(file_path);
int vfs_open(const struct path *path, struct file *file) int vfs_open(const struct path *path, struct file *file)
{ {
file->f_path = *path; file->f_path = *path;
return do_dentry_open(file, d_backing_inode(path->dentry), NULL); return do_dentry_open(file, NULL);
} }
struct file *dentry_open(const struct path *path, int flags, struct file *dentry_open(const struct path *path, int flags,
@ -1155,7 +1155,6 @@ EXPORT_SYMBOL(dentry_create);
* kernel_file_open - open a file for kernel internal use * kernel_file_open - open a file for kernel internal use
* @path: path of the file to open * @path: path of the file to open
* @flags: open flags * @flags: open flags
* @inode: the inode
* @cred: credentials for open * @cred: credentials for open
* *
* Open a file for use by in-kernel consumers. The file is not accounted * Open a file for use by in-kernel consumers. The file is not accounted
@ -1165,7 +1164,7 @@ EXPORT_SYMBOL(dentry_create);
* Return: Opened file on success, an error pointer on failure. * Return: Opened file on success, an error pointer on failure.
*/ */
struct file *kernel_file_open(const struct path *path, int flags, struct file *kernel_file_open(const struct path *path, int flags,
struct inode *inode, const struct cred *cred) const struct cred *cred)
{ {
struct file *f; struct file *f;
int error; int error;
@ -1175,7 +1174,7 @@ struct file *kernel_file_open(const struct path *path, int flags,
return f; return f;
f->f_path = *path; f->f_path = *path;
error = do_dentry_open(f, inode, NULL); error = do_dentry_open(f, NULL);
if (error) { if (error) {
fput(f); fput(f);
f = ERR_PTR(error); f = ERR_PTR(error);

View File

@ -1376,7 +1376,7 @@ int ovl_ensure_verity_loaded(struct path *datapath)
* If this inode was not yet opened, the verity info hasn't been * If this inode was not yet opened, the verity info hasn't been
* loaded yet, so we need to do that here to force it into memory. * loaded yet, so we need to do that here to force it into memory.
*/ */
filp = kernel_file_open(datapath, O_RDONLY, inode, current_cred()); filp = kernel_file_open(datapath, O_RDONLY, current_cred());
if (IS_ERR(filp)) if (IS_ERR(filp))
return PTR_ERR(filp); return PTR_ERR(filp);
fput(filp); fput(filp);

View File

@ -39,10 +39,8 @@ static int seq_show(struct seq_file *m, void *v)
spin_lock(&files->file_lock); spin_lock(&files->file_lock);
file = files_lookup_fd_locked(files, fd); file = files_lookup_fd_locked(files, fd);
if (file) { if (file) {
struct fdtable *fdt = files_fdtable(files);
f_flags = file->f_flags; f_flags = file->f_flags;
if (close_on_exec(fd, fdt)) if (close_on_exec(fd, files))
f_flags |= O_CLOEXEC; f_flags |= O_CLOEXEC;
get_file(file); get_file(file);

View File

@ -392,7 +392,7 @@ static ssize_t new_sync_read(struct file *filp, char __user *buf, size_t len, lo
kiocb.ki_pos = (ppos ? *ppos : 0); kiocb.ki_pos = (ppos ? *ppos : 0);
iov_iter_ubuf(&iter, ITER_DEST, buf, len); iov_iter_ubuf(&iter, ITER_DEST, buf, len);
ret = call_read_iter(filp, &kiocb, &iter); ret = filp->f_op->read_iter(&kiocb, &iter);
BUG_ON(ret == -EIOCBQUEUED); BUG_ON(ret == -EIOCBQUEUED);
if (ppos) if (ppos)
*ppos = kiocb.ki_pos; *ppos = kiocb.ki_pos;
@ -494,7 +494,7 @@ static ssize_t new_sync_write(struct file *filp, const char __user *buf, size_t
kiocb.ki_pos = (ppos ? *ppos : 0); kiocb.ki_pos = (ppos ? *ppos : 0);
iov_iter_ubuf(&iter, ITER_SOURCE, (void __user *)buf, len); iov_iter_ubuf(&iter, ITER_SOURCE, (void __user *)buf, len);
ret = call_write_iter(filp, &kiocb, &iter); ret = filp->f_op->write_iter(&kiocb, &iter);
BUG_ON(ret == -EIOCBQUEUED); BUG_ON(ret == -EIOCBQUEUED);
if (ret > 0 && ppos) if (ret > 0 && ppos)
*ppos = kiocb.ki_pos; *ppos = kiocb.ki_pos;
@ -736,9 +736,9 @@ static ssize_t do_iter_readv_writev(struct file *filp, struct iov_iter *iter,
kiocb.ki_pos = (ppos ? *ppos : 0); kiocb.ki_pos = (ppos ? *ppos : 0);
if (type == READ) if (type == READ)
ret = call_read_iter(filp, &kiocb, iter); ret = filp->f_op->read_iter(&kiocb, iter);
else else
ret = call_write_iter(filp, &kiocb, iter); ret = filp->f_op->write_iter(&kiocb, iter);
BUG_ON(ret == -EIOCBQUEUED); BUG_ON(ret == -EIOCBQUEUED);
if (ppos) if (ppos)
*ppos = kiocb.ki_pos; *ppos = kiocb.ki_pos;
@ -799,7 +799,7 @@ ssize_t vfs_iocb_iter_read(struct file *file, struct kiocb *iocb,
if (ret < 0) if (ret < 0)
return ret; return ret;
ret = call_read_iter(file, iocb, iter); ret = file->f_op->read_iter(iocb, iter);
out: out:
if (ret >= 0) if (ret >= 0)
fsnotify_access(file); fsnotify_access(file);
@ -860,7 +860,7 @@ ssize_t vfs_iocb_iter_write(struct file *file, struct kiocb *iocb,
return ret; return ret;
kiocb_start_write(iocb); kiocb_start_write(iocb);
ret = call_write_iter(file, iocb, iter); ret = file->f_op->write_iter(iocb, iter);
if (ret != -EIOCBQUEUED) if (ret != -EIOCBQUEUED)
kiocb_end_write(iocb); kiocb_end_write(iocb);
if (ret > 0) if (ret > 0)

View File

@ -362,7 +362,7 @@ ssize_t copy_splice_read(struct file *in, loff_t *ppos,
iov_iter_bvec(&to, ITER_DEST, bv, npages, len); iov_iter_bvec(&to, ITER_DEST, bv, npages, len);
init_sync_kiocb(&kiocb, in); init_sync_kiocb(&kiocb, in);
kiocb.ki_pos = *ppos; kiocb.ki_pos = *ppos;
ret = call_read_iter(in, &kiocb, &to); ret = in->f_op->read_iter(&kiocb, &to);
if (ret > 0) { if (ret > 0) {
keep = DIV_ROUND_UP(ret, PAGE_SIZE); keep = DIV_ROUND_UP(ret, PAGE_SIZE);
@ -740,7 +740,7 @@ iter_file_splice_write(struct pipe_inode_info *pipe, struct file *out,
iov_iter_bvec(&from, ITER_SOURCE, array, n, sd.total_len - left); iov_iter_bvec(&from, ITER_SOURCE, array, n, sd.total_len - left);
init_sync_kiocb(&kiocb, out); init_sync_kiocb(&kiocb, out);
kiocb.ki_pos = sd.pos; kiocb.ki_pos = sd.pos;
ret = call_write_iter(out, &kiocb, &from); ret = out->f_op->write_iter(&kiocb, &from);
sd.pos = kiocb.ki_pos; sd.pos = kiocb.ki_pos;
if (ret <= 0) if (ret <= 0)
break; break;

View File

@ -33,16 +33,6 @@ struct fdtable {
struct rcu_head rcu; struct rcu_head rcu;
}; };
static inline bool close_on_exec(unsigned int fd, const struct fdtable *fdt)
{
return test_bit(fd, fdt->close_on_exec);
}
static inline bool fd_is_open(unsigned int fd, const struct fdtable *fdt)
{
return test_bit(fd, fdt->open_fds);
}
/* /*
* Open file table structure * Open file table structure
*/ */
@ -107,6 +97,11 @@ struct file *lookup_fdget_rcu(unsigned int fd);
struct file *task_lookup_fdget_rcu(struct task_struct *task, unsigned int fd); struct file *task_lookup_fdget_rcu(struct task_struct *task, unsigned int fd);
struct file *task_lookup_next_fdget_rcu(struct task_struct *task, unsigned int *fd); struct file *task_lookup_next_fdget_rcu(struct task_struct *task, unsigned int *fd);
static inline bool close_on_exec(unsigned int fd, const struct files_struct *files)
{
return test_bit(fd, files_fdtable(files)->close_on_exec);
}
struct task_struct; struct task_struct;
void put_files_struct(struct files_struct *fs); void put_files_struct(struct files_struct *fs);

View File

@ -1899,7 +1899,7 @@ struct file *kernel_tmpfile_open(struct mnt_idmap *idmap,
umode_t mode, int open_flag, umode_t mode, int open_flag,
const struct cred *cred); const struct cred *cred);
struct file *kernel_file_open(const struct path *path, int flags, struct file *kernel_file_open(const struct path *path, int flags,
struct inode *inode, const struct cred *cred); const struct cred *cred);
int vfs_mkobj(struct dentry *, umode_t, int vfs_mkobj(struct dentry *, umode_t,
int (*f)(struct dentry *, umode_t, void *), int (*f)(struct dentry *, umode_t, void *),
@ -2102,18 +2102,6 @@ struct inode_operations {
struct offset_ctx *(*get_offset_ctx)(struct inode *inode); struct offset_ctx *(*get_offset_ctx)(struct inode *inode);
} ____cacheline_aligned; } ____cacheline_aligned;
static inline ssize_t call_read_iter(struct file *file, struct kiocb *kio,
struct iov_iter *iter)
{
return file->f_op->read_iter(kio, iter);
}
static inline ssize_t call_write_iter(struct file *file, struct kiocb *kio,
struct iov_iter *iter)
{
return file->f_op->write_iter(kio, iter);
}
static inline int call_mmap(struct file *file, struct vm_area_struct *vma) static inline int call_mmap(struct file *file, struct vm_area_struct *vma)
{ {
return file->f_op->mmap(file, vma); return file->f_op->mmap(file, vma);

View File

@ -759,7 +759,7 @@ static inline int io_iter_do_read(struct io_rw *rw, struct iov_iter *iter)
struct file *file = rw->kiocb.ki_filp; struct file *file = rw->kiocb.ki_filp;
if (likely(file->f_op->read_iter)) if (likely(file->f_op->read_iter))
return call_read_iter(file, &rw->kiocb, iter); return file->f_op->read_iter(&rw->kiocb, iter);
else if (file->f_op->read) else if (file->f_op->read)
return loop_rw_iter(READ, rw, iter); return loop_rw_iter(READ, rw, iter);
else else
@ -1046,7 +1046,7 @@ int io_write(struct io_kiocb *req, unsigned int issue_flags)
kiocb->ki_flags |= IOCB_WRITE; kiocb->ki_flags |= IOCB_WRITE;
if (likely(req->file->f_op->write_iter)) if (likely(req->file->f_op->write_iter))
ret2 = call_write_iter(req->file, kiocb, &io->iter); ret2 = req->file->f_op->write_iter(kiocb, &io->iter);
else if (req->file->f_op->write) else if (req->file->f_op->write)
ret2 = loop_rw_iter(WRITE, rw, &io->iter); ret2 = loop_rw_iter(WRITE, rw, &io->iter);
else else