From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org X-Spam-Level: X-Spam-Status: No, score=-8.2 required=3.0 tests=DKIM_SIGNED,DKIM_VALID, HEADER_FROM_DIFFERENT_DOMAINS,INCLUDES_PATCH,MAILING_LIST_MULTI,SIGNED_OFF_BY, SPF_HELO_NONE,SPF_PASS,URIBL_BLOCKED,USER_AGENT_SANE_1 autolearn=ham autolearn_force=no version=3.4.0 Received: from mail.kernel.org (mail.kernel.org [198.145.29.99]) by smtp.lore.kernel.org (Postfix) with ESMTP id 54034C47253 for ; Fri, 1 May 2020 17:53:11 +0000 (UTC) Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by mail.kernel.org (Postfix) with ESMTP id 3437920857 for ; Fri, 1 May 2020 17:53:11 +0000 (UTC) Authentication-Results: mail.kernel.org; dkim=pass (2048-bit key) header.d=kernel-dk.20150623.gappssmtp.com header.i=@kernel-dk.20150623.gappssmtp.com header.b="z//v2qYW" Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1729975AbgEARxK (ORCPT ); Fri, 1 May 2020 13:53:10 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:35732 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-FAIL-OK-FAIL) by vger.kernel.org with ESMTP id S1729676AbgEARxJ (ORCPT ); Fri, 1 May 2020 13:53:09 -0400 Received: from mail-io1-xd43.google.com (mail-io1-xd43.google.com [IPv6:2607:f8b0:4864:20::d43]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id CB66EC061A0E for ; Fri, 1 May 2020 10:53:09 -0700 (PDT) Received: by mail-io1-xd43.google.com with SMTP id k6so5625347iob.3 for ; Fri, 01 May 2020 10:53:09 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=kernel-dk.20150623.gappssmtp.com; s=20150623; h=from:subject:to:cc:message-id:date:user-agent:mime-version :content-language:content-transfer-encoding; bh=XdJA1wCaC5kLmDy04IJIo29nZqrjKJoJjzCuDdVwDTk=; b=z//v2qYWnW8SwmqV+dDk6BILpZx1qMVWZ0pkGVjWZSOKkdAa/7TlRo86mGJ9gDGwK+ vbkzgLQJ3hNMr6bP8v2YLUUiKt/l3GvgwMV8qjCHD9IUiJ3HxLJ2yI+q1dySo/LleK1Z 1OezD5QK/l6Sopbop+asqne16E1VKpBSFaCBM+iAkFsO/Whk9svAYTEogY3Bhl0NNG6g FuA4cauJYwcLuHkx7XK6BU7ASIdHAvKl4KE5iiUE+w7BXxqSGQfS3mLoSFhxBO6HQdis hNdIFoYlBd4krZ0uMSG2XsW6+iMtnU2aXYya7jHMdl2zTaP6nE2jfudyE4bo0vHKHuFe 9GRQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:subject:to:cc:message-id:date:user-agent :mime-version:content-language:content-transfer-encoding; bh=XdJA1wCaC5kLmDy04IJIo29nZqrjKJoJjzCuDdVwDTk=; b=WDjrXblBlwR4JHop0r4hPYO3a9DxNYEVitZc59uYb2uloEIY861JxVEhCjyKch5z/F j+R5cN7O63oPg1Robi1TPqZ/bXtgIQE8H88i+lF+Ou3MUA3ykveWser1Z93kvXTMkbFB mn7mC08pblU6Bv7aCxx1AKMrbUlrbE7MKuiutSlwOF2ssbKlzvf7GyKXvNCX+gQumXyy 1CG0jXhfwwB2cC4aCMQqwuVF5xXdt6wPE2tjqCkcG1iXBxcLtwPYH8NePzwNBn38bfP+ otRNQ1hQtWn5Z5KXbTpW1xNOnDkcGWrSiirekHhJwPwgBtnfH04jrn0MS0e8w47VXiNb dbmA== X-Gm-Message-State: AGi0PuaGkvIh9HoQo1SoNqiABWjMGhh7UAR1hgT4X75556Hx6L4w6jDg u0x3siFqPMHswFqEbM/WTRmGfccr7QmNVw== X-Google-Smtp-Source: APiQypKCCJ6EjlTDfVmI0HNR9sHGD+IUBltyY6FC/6vL5rBVpJipJHetgPjWqmn+enrvNZ6eV/nrmA== X-Received: by 2002:a02:cd03:: with SMTP id g3mr4112123jaq.61.1588355588807; Fri, 01 May 2020 10:53:08 -0700 (PDT) Received: from [192.168.1.159] ([65.144.74.34]) by smtp.gmail.com with ESMTPSA id z3sm1178310ior.45.2020.05.01.10.53.07 (version=TLS1_3 cipher=TLS_AES_128_GCM_SHA256 bits=128/128); Fri, 01 May 2020 10:53:08 -0700 (PDT) From: Jens Axboe Subject: [PATCH v3] eventfd: convert to f_op->read_iter() To: Alexander Viro Cc: linux-fsdevel , "linux-kernel@vger.kernel.org" Message-ID: <4037e867-af74-6a11-a501-7e5b804beec5@kernel.dk> Date: Fri, 1 May 2020 11:53:07 -0600 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:68.0) Gecko/20100101 Thunderbird/68.7.0 MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Language: en-US Content-Transfer-Encoding: 7bit Sender: linux-kernel-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org eventfd is using ->read() as it's file_operations read handler, but this prevents passing in information about whether a given IO operation is blocking or not. We can only use the file flags for that. To support async (-EAGAIN/poll based) retries for io_uring, we need ->read_iter() support. Convert eventfd to using ->read_iter(). Signed-off-by: Jens Axboe --- Since v2: - Cleanup eventfd_read() as per Al's suggestions Since v1: - Add FMODE_NOWAIT to the eventfd file diff --git a/fs/eventfd.c b/fs/eventfd.c index 78e41c7c3d05..d590c2141d39 100644 --- a/fs/eventfd.c +++ b/fs/eventfd.c @@ -216,10 +216,11 @@ int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_entry_t *w } EXPORT_SYMBOL_GPL(eventfd_ctx_remove_wait_queue); -static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count, - loff_t *ppos) +static ssize_t eventfd_read(struct kiocb *iocb, struct iov_iter *iov) { + struct file *file = iocb->ki_filp; struct eventfd_ctx *ctx = file->private_data; + size_t count = iov_iter_count(iov); ssize_t res; __u64 ucnt = 0; DECLARE_WAITQUEUE(wait, current); @@ -231,7 +232,8 @@ static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count, res = -EAGAIN; if (ctx->count > 0) res = sizeof(ucnt); - else if (!(file->f_flags & O_NONBLOCK)) { + else if (!(file->f_flags & O_NONBLOCK) && + !(iocb->ki_flags & IOCB_NOWAIT)) { __add_wait_queue(&ctx->wqh, &wait); for (;;) { set_current_state(TASK_INTERRUPTIBLE); @@ -257,7 +259,7 @@ static ssize_t eventfd_read(struct file *file, char __user *buf, size_t count, } spin_unlock_irq(&ctx->wqh.lock); - if (res > 0 && put_user(ucnt, (__u64 __user *)buf)) + if (res > 0 && copy_to_iter(&ucnt, res, iov) < res) return -EFAULT; return res; @@ -329,7 +331,7 @@ static const struct file_operations eventfd_fops = { #endif .release = eventfd_release, .poll = eventfd_poll, - .read = eventfd_read, + .read_iter = eventfd_read, .write = eventfd_write, .llseek = noop_llseek, }; @@ -427,8 +429,17 @@ static int do_eventfd(unsigned int count, int flags) fd = anon_inode_getfd("[eventfd]", &eventfd_fops, ctx, O_RDWR | (flags & EFD_SHARED_FCNTL_FLAGS)); - if (fd < 0) + if (fd < 0) { eventfd_free_ctx(ctx); + } else { + struct file *file; + + file = fget(fd); + if (file) { + file->f_mode |= FMODE_NOWAIT; + fput(file); + } + } return fd; } -- Jens Axboe