Commit b29482fd authored by Linus Torvalds's avatar Linus Torvalds

Merge branch 'work.epoll' of git://git.kernel.org/pub/scm/linux/kernel/git/viro/vfs

Pull epoll update from Al Viro:
 "epoll conversion to read_iter from Jens; I thought there might be more
  epoll stuff this cycle, but uaccess took too much time"

* 'work.epoll' of git://git.kernel.org/pub/scm/linux/kernel/git/viro/vfs:
  eventfd: convert to f_op->read_iter()
parents 4dbb29fe 12aceb89
...@@ -23,6 +23,7 @@ ...@@ -23,6 +23,7 @@
#include <linux/proc_fs.h> #include <linux/proc_fs.h>
#include <linux/seq_file.h> #include <linux/seq_file.h>
#include <linux/idr.h> #include <linux/idr.h>
#include <linux/uio.h>
DEFINE_PER_CPU(int, eventfd_wake_count); DEFINE_PER_CPU(int, eventfd_wake_count);
...@@ -216,32 +217,32 @@ int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_entry_t *w ...@@ -216,32 +217,32 @@ int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_entry_t *w
} }
EXPORT_SYMBOL_GPL(eventfd_ctx_remove_wait_queue); EXPORT_SYMBOL_GPL(eventfd_ctx_remove_wait_queue);
static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count, static ssize_t eventfd_read(struct kiocb *iocb, struct iov_iter *to)
loff_t *ppos)
{ {
struct file *file = iocb->ki_filp;
struct eventfd_ctx *ctx = file->private_data; struct eventfd_ctx *ctx = file->private_data;
ssize_t res;
__u64 ucnt = 0; __u64 ucnt = 0;
DECLARE_WAITQUEUE(wait, current); DECLARE_WAITQUEUE(wait, current);
if (count < sizeof(ucnt)) if (iov_iter_count(to) < sizeof(ucnt))
return -EINVAL; return -EINVAL;
spin_lock_irq(&ctx->wqh.lock); spin_lock_irq(&ctx->wqh.lock);
res = -EAGAIN; if (!ctx->count) {
if (ctx->count > 0) if ((file->f_flags & O_NONBLOCK) ||
res = sizeof(ucnt); (iocb->ki_flags & IOCB_NOWAIT)) {
else if (!(file->f_flags & O_NONBLOCK)) { spin_unlock_irq(&ctx->wqh.lock);
return -EAGAIN;
}
__add_wait_queue(&ctx->wqh, &wait); __add_wait_queue(&ctx->wqh, &wait);
for (;;) { for (;;) {
set_current_state(TASK_INTERRUPTIBLE); set_current_state(TASK_INTERRUPTIBLE);
if (ctx->count > 0) { if (ctx->count)
res = sizeof(ucnt);
break; break;
}
if (signal_pending(current)) { if (signal_pending(current)) {
res = -ERESTARTSYS; __remove_wait_queue(&ctx->wqh, &wait);
break; __set_current_state(TASK_RUNNING);
spin_unlock_irq(&ctx->wqh.lock);
return -ERESTARTSYS;
} }
spin_unlock_irq(&ctx->wqh.lock); spin_unlock_irq(&ctx->wqh.lock);
schedule(); schedule();
...@@ -250,17 +251,14 @@ static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count, ...@@ -250,17 +251,14 @@ static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count,
__remove_wait_queue(&ctx->wqh, &wait); __remove_wait_queue(&ctx->wqh, &wait);
__set_current_state(TASK_RUNNING); __set_current_state(TASK_RUNNING);
} }
if (likely(res > 0)) { eventfd_ctx_do_read(ctx, &ucnt);
eventfd_ctx_do_read(ctx, &ucnt); if (waitqueue_active(&ctx->wqh))
if (waitqueue_active(&ctx->wqh)) wake_up_locked_poll(&ctx->wqh, EPOLLOUT);
wake_up_locked_poll(&ctx->wqh, EPOLLOUT);
}
spin_unlock_irq(&ctx->wqh.lock); spin_unlock_irq(&ctx->wqh.lock);
if (unlikely(copy_to_iter(&ucnt, sizeof(ucnt), to) != sizeof(ucnt)))
if (res > 0 && put_user(ucnt, (__u64 __user *)buf))
return -EFAULT; return -EFAULT;
return res; return sizeof(ucnt);
} }
static ssize_t eventfd_write(struct file *file, const char __user *buf, size_t count, static ssize_t eventfd_write(struct file *file, const char __user *buf, size_t count,
...@@ -329,7 +327,7 @@ static const struct file_operations eventfd_fops = { ...@@ -329,7 +327,7 @@ static const struct file_operations eventfd_fops = {
#endif #endif
.release = eventfd_release, .release = eventfd_release,
.poll = eventfd_poll, .poll = eventfd_poll,
.read = eventfd_read, .read_iter = eventfd_read,
.write = eventfd_write, .write = eventfd_write,
.llseek = noop_llseek, .llseek = noop_llseek,
}; };
...@@ -406,6 +404,7 @@ EXPORT_SYMBOL_GPL(eventfd_ctx_fileget); ...@@ -406,6 +404,7 @@ EXPORT_SYMBOL_GPL(eventfd_ctx_fileget);
static int do_eventfd(unsigned int count, int flags) static int do_eventfd(unsigned int count, int flags)
{ {
struct eventfd_ctx *ctx; struct eventfd_ctx *ctx;
struct file *file;
int fd; int fd;
/* Check the EFD_* constants for consistency. */ /* Check the EFD_* constants for consistency. */
...@@ -425,11 +424,24 @@ static int do_eventfd(unsigned int count, int flags) ...@@ -425,11 +424,24 @@ static int do_eventfd(unsigned int count, int flags)
ctx->flags = flags; ctx->flags = flags;
ctx->id = ida_simple_get(&eventfd_ida, 0, 0, GFP_KERNEL); ctx->id = ida_simple_get(&eventfd_ida, 0, 0, GFP_KERNEL);
fd = anon_inode_getfd("[eventfd]", &eventfd_fops, ctx, flags &= EFD_SHARED_FCNTL_FLAGS;
O_RDWR | (flags & EFD_SHARED_FCNTL_FLAGS)); flags |= O_RDWR;
fd = get_unused_fd_flags(flags);
if (fd < 0) if (fd < 0)
eventfd_free_ctx(ctx); goto err;
file = anon_inode_getfile("[eventfd]", &eventfd_fops, ctx, flags);
if (IS_ERR(file)) {
put_unused_fd(fd);
fd = PTR_ERR(file);
goto err;
}
file->f_mode |= FMODE_NOWAIT;
fd_install(fd, file);
return fd;
err:
eventfd_free_ctx(ctx);
return fd; return fd;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment