From patchwork Wed Oct 28 18:33:47 2015 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Pavel Boldin X-Patchwork-Id: 8142 Return-Path: X-Original-To: patchwork@dpdk.org Delivered-To: patchwork@dpdk.org Received: from [92.243.14.124] (localhost [IPv6:::1]) by dpdk.org (Postfix) with ESMTP id C77DA8DA5; Wed, 28 Oct 2015 19:34:03 +0100 (CET) Received: from mail-lb0-f179.google.com (mail-lb0-f179.google.com [209.85.217.179]) by dpdk.org (Postfix) with ESMTP id 88E0E8DA4 for ; Wed, 28 Oct 2015 19:34:02 +0100 (CET) Received: by lbjm5 with SMTP id m5so12314079lbj.3 for ; Wed, 28 Oct 2015 11:34:02 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=mirantis.com; s=google; h=from:to:cc:subject:date:message-id:in-reply-to:references :in-reply-to:references; bh=gmPwgQ0OX6i66lb3tlzTnznOZx32Svx6DJnfcaOlQ3E=; b=NeAwmX8uuoGiBJt1oP8DARS3NohPymdYY90qEtdLeiVfKirXqjM+A2hcSWBqWn9cQn +QbRWqLrJj1I3joAulq/oxFhaS1FOgKFpYmj2QiJ5cLHTvyN6o33+bFsUNh2Oraz5WRr ieUMIk17LqZdwUbNLXNhkEgxDqfmGL3uZ95Qc= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references:in-reply-to:references; bh=gmPwgQ0OX6i66lb3tlzTnznOZx32Svx6DJnfcaOlQ3E=; b=QxFHS+NjQ+XxdLfTHnOmrMKSzvVfH2nZCM1BIdG0TkPkgDcvOgpF3nofMFxbzcH9NB 0M3IgtnjMpyh9Alvg9g6iOwNVvx/K8T/VSzKTfuSjdqRNJc7a10O/ERjOthrZy0AoaJf wryVoQ3qPMqQWSSvErF0NkeumQY8hBHN5JoIilxwxxEG21zNPVY706oqkgQfFQQxCLTN cuSrVK6j/DyFTegp/ody6GsjwzMOL0Wrf3UDXzNbb1c710Lnp1WjxAmgbE2vnzxlGiFs SdoDMc0iqXXfSLJOT2XLkFxcgUsPJg6KYO3zu66Bosaj59xwXVeF1mrQnm1rtnOPTVJq v/4Q== X-Gm-Message-State: ALoCoQnNbRVelY3y1sr0UeAn2oQg8OIEQYGsi19P8mZWrmrBAEnHgUDCQl1sdiFwPEY21lycnMjS X-Received: by 10.112.149.97 with SMTP id tz1mr8683384lbb.57.1446057242100; Wed, 28 Oct 2015 11:34:02 -0700 (PDT) Received: from pboldin-pc.kha.mirantis.net ([194.213.110.67]) by smtp.gmail.com with ESMTPSA id g65sm2874107lfb.11.2015.10.28.11.34.00 (version=TLSv1.2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Wed, 28 Oct 2015 11:34:01 -0700 (PDT) From: Pavel Boldin To: dev@dpdk.org Date: Wed, 28 Oct 2015 20:33:47 +0200 Message-Id: <94749ae3774b54fa17b901f15eaccef6a0751d05.1446056748.git.pboldin@mirantis.com> X-Mailer: git-send-email 1.9.1 In-Reply-To: References: In-Reply-To: <1440787880-7079-1-git-send-email-pboldin@mirantis.com> References: <1440787880-7079-1-git-send-email-pboldin@mirantis.com> Subject: [dpdk-dev] [PATCH v6 1/3] vhost: eventfd_link: refactoring EVENTFD_COPY handler X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" * Move ioctl `EVENTFD_COPY' code to a separate function * Remove extra #includes * Introduce function fget_from_files * Fix ioctl return values Signed-off-by: Pavel Boldin --- lib/librte_vhost/eventfd_link/eventfd_link.c | 181 +++++++++++++++------------ 1 file changed, 100 insertions(+), 81 deletions(-) diff --git a/lib/librte_vhost/eventfd_link/eventfd_link.c b/lib/librte_vhost/eventfd_link/eventfd_link.c index 62c45c8..7cbebd4 100644 --- a/lib/librte_vhost/eventfd_link/eventfd_link.c +++ b/lib/librte_vhost/eventfd_link/eventfd_link.c @@ -22,18 +22,11 @@ * Intel Corporation */ -#include #include #include -#include -#include #include -#include -#include -#include -#include -#include #include +#include #include "eventfd_link.h" @@ -65,9 +58,27 @@ put_files_struct(struct files_struct *files) BUG(); } +static struct file * +fget_from_files(struct files_struct *files, unsigned fd) +{ + struct file *file; + + rcu_read_lock(); + file = fcheck_files(files, fd); + if (file) { + if (file->f_mode & FMODE_PATH || + !atomic_long_inc_not_zero(&file->f_count)) { + + file = NULL; + } + } + rcu_read_unlock(); + + return file; +} static long -eventfd_link_ioctl(struct file *f, unsigned int ioctl, unsigned long arg) +eventfd_link_ioctl_copy(unsigned long arg) { void __user *argp = (void __user *) arg; struct task_struct *task_target = NULL; @@ -75,91 +86,99 @@ eventfd_link_ioctl(struct file *f, unsigned int ioctl, unsigned long arg) struct files_struct *files; struct fdtable *fdt; struct eventfd_copy eventfd_copy; + long ret = -EFAULT; - switch (ioctl) { - case EVENTFD_COPY: - if (copy_from_user(&eventfd_copy, argp, - sizeof(struct eventfd_copy))) - return -EFAULT; - - /* - * Find the task struct for the target pid - */ - task_target = - pid_task(find_vpid(eventfd_copy.target_pid), PIDTYPE_PID); - if (task_target == NULL) { - pr_debug("Failed to get mem ctx for target pid\n"); - return -EFAULT; - } + if (copy_from_user(&eventfd_copy, argp, sizeof(struct eventfd_copy))) + goto out; - files = get_files_struct(current); - if (files == NULL) { - pr_debug("Failed to get files struct\n"); - return -EFAULT; - } + /* + * Find the task struct for the target pid + */ + ret = -ESRCH; - rcu_read_lock(); - file = fcheck_files(files, eventfd_copy.source_fd); - if (file) { - if (file->f_mode & FMODE_PATH || - !atomic_long_inc_not_zero(&file->f_count)) - file = NULL; - } - rcu_read_unlock(); - put_files_struct(files); + task_target = + get_pid_task(find_vpid(eventfd_copy.target_pid), PIDTYPE_PID); + if (task_target == NULL) { + pr_info("Unable to find pid %d\n", eventfd_copy.target_pid); + goto out; + } - if (file == NULL) { - pr_debug("Failed to get file from source pid\n"); - return 0; - } + ret = -ESTALE; + files = get_files_struct(current); + if (files == NULL) { + pr_info("Failed to get current files struct\n"); + goto out_task; + } - /* - * Release the existing eventfd in the source process - */ - spin_lock(&files->file_lock); - fput(file); - filp_close(file, files); - fdt = files_fdtable(files); - fdt->fd[eventfd_copy.source_fd] = NULL; - spin_unlock(&files->file_lock); - - /* - * Find the file struct associated with the target fd. - */ - - files = get_files_struct(task_target); - if (files == NULL) { - pr_debug("Failed to get files struct\n"); - return -EFAULT; - } + ret = -EBADF; + file = fget_from_files(files, eventfd_copy.source_fd); - rcu_read_lock(); - file = fcheck_files(files, eventfd_copy.target_fd); - if (file) { - if (file->f_mode & FMODE_PATH || - !atomic_long_inc_not_zero(&file->f_count)) - file = NULL; - } - rcu_read_unlock(); + if (file == NULL) { + pr_info("Failed to get fd %d from source\n", + eventfd_copy.source_fd); put_files_struct(files); + goto out_task; + } - if (file == NULL) { - pr_debug("Failed to get file from target pid\n"); - return 0; - } + /* + * Release the existing eventfd in the source process + */ + spin_lock(&files->file_lock); + fput(file); + filp_close(file, files); + fdt = files_fdtable(files); + fdt->fd[eventfd_copy.source_fd] = NULL; + spin_unlock(&files->file_lock); + + put_files_struct(files); + + /* + * Find the file struct associated with the target fd. + */ + + ret = -ESTALE; + files = get_files_struct(task_target); + if (files == NULL) { + pr_info("Failed to get target files struct\n"); + goto out_task; + } + + ret = -EBADF; + file = fget_from_files(files, eventfd_copy.target_fd); + put_files_struct(files); - /* - * Install the file struct from the target process into the - * file desciptor of the source process, - */ + if (file == NULL) { + pr_info("Failed to get fd %d from target\n", + eventfd_copy.target_fd); + goto out_task; + } - fd_install(eventfd_copy.source_fd, file); + /* + * Install the file struct from the target process into the + * file desciptor of the source process, + */ - return 0; + fd_install(eventfd_copy.source_fd, file); + ret = 0; - default: - return -ENOIOCTLCMD; +out_task: + put_task_struct(task_target); +out: + return ret; +} + +static long +eventfd_link_ioctl(struct file *f, unsigned int ioctl, unsigned long arg) +{ + long ret = -ENOIOCTLCMD; + + switch (ioctl) { + case EVENTFD_COPY: + ret = eventfd_link_ioctl_copy(arg); + break; } + + return ret; } static const struct file_operations eventfd_link_fops = {