From patchwork Wed Sep 28 15:10:14 2016 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Matan Barak X-Patchwork-Id: 9354077 Return-Path: Received: from mail.wl.linuxfoundation.org (pdx-wl-mail.web.codeaurora.org [172.30.200.125]) by pdx-korg-patchwork.web.codeaurora.org (Postfix) with ESMTP id 28F2360757 for ; Wed, 28 Sep 2016 15:11:29 +0000 (UTC) Received: from mail.wl.linuxfoundation.org (localhost [127.0.0.1]) by mail.wl.linuxfoundation.org (Postfix) with ESMTP id 163F0296A2 for ; Wed, 28 Sep 2016 15:11:29 +0000 (UTC) Received: by mail.wl.linuxfoundation.org (Postfix, from userid 486) id 0AF8A296A3; Wed, 28 Sep 2016 15:11:29 +0000 (UTC) X-Spam-Checker-Version: SpamAssassin 3.3.1 (2010-03-16) on pdx-wl-mail.web.codeaurora.org X-Spam-Level: X-Spam-Status: No, score=-6.9 required=2.0 tests=BAYES_00, RCVD_IN_DNSWL_HI, UNPARSEABLE_RELAY autolearn=ham version=3.3.1 Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by mail.wl.linuxfoundation.org (Postfix) with ESMTP id BCED5296A5 for ; Wed, 28 Sep 2016 15:11:23 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S932486AbcI1PLW (ORCPT ); Wed, 28 Sep 2016 11:11:22 -0400 Received: from mail-il-dmz.mellanox.com ([193.47.165.129]:37320 "EHLO mellanox.co.il" rhost-flags-OK-OK-OK-FAIL) by vger.kernel.org with ESMTP id S932604AbcI1PLS (ORCPT ); Wed, 28 Sep 2016 11:11:18 -0400 Received: from Internal Mail-Server by MTLPINE1 (envelope-from matanb@mellanox.com) with ESMTPS (AES256-SHA encrypted); 28 Sep 2016 18:11:13 +0300 Received: from dev-r-vrt-064.mtr.labs.mlnx (dev-r-vrt-064.mtr.labs.mlnx [10.212.64.1]) by labmailer.mlnx (8.13.8/8.13.8) with ESMTP id u8SFBC9g001722; Wed, 28 Sep 2016 18:11:12 +0300 From: Matan Barak To: linux-rdma@vger.kernel.org Cc: Doug Ledford , Jason Gunthorpe , Sean Hefty , Liran Liss , Haggai Eran , Matan Barak , Majd Dibbiny , Christoph Lameter , Leon Romanovsky Subject: [RFC ABI V4 4/7] RDMA/core: Add new ioctl interface Date: Wed, 28 Sep 2016 18:10:14 +0300 Message-Id: <1475075417-30189-5-git-send-email-matanb@mellanox.com> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1475075417-30189-1-git-send-email-matanb@mellanox.com> References: <1475075417-30189-1-git-send-email-matanb@mellanox.com> Sender: linux-rdma-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: linux-rdma@vger.kernel.org X-Virus-Scanned: ClamAV using ClamSMTP In this proposed ioctl interface, processing the command starts from properties of the command and fetching the appropriate user objects before calling the handler. Parsing and validation is done according to a specifier declared by the driver's code. In the driver, all supported types are declared. These types are separated to different type groups, each could be declared in a different place (for example, common types and driver specific types). For each type we list all supported actions. Similarly to types, actions are separated to actions groups too. Each group is declared separately. This could be used in order to add actions to an existing type. Each action has a specifies a handler, which could be either be a standard command or a driver specific command. Along with the handler, a group of attributes is specified as well. This group lists all supported attributes and is used for automatically fetching and validating the command, response and its related objects. When a group of elements is used, a distribution function is also specified at the higher level (i.e - type specifies a distribution function for the actions it contains). The distribution function chooses the group which should be used and maps the element from the kABI language (which is driver specific) to common kernel language. The standard distribution function just uses the upper bit for that. A group of attributes is actually an array of attributes. Each attribute has a type (PTR_IN, PTR_OUT, IDR and in the future maybe FD, which could be used for completion channel) and a length. Future work here might add validation of mandatory attributes (i.e - make sure a specific attribute was given). If an IDR/fd attribute is specified, the kernel also states the object type and the required access (NEW, WRITE, READ or DESTROY). All uobject/fd management is done automatically by the infrastructure, meaning - the infrastructure will fail concurrent commands that at least one of them requires concurrent access (WRITE/DESTROY), synchronize actions with device removals (dissociate context events) and take care of reference counting (increase/decrease) for concurrent actions invocation. The reference counts on the actual kernel objects shall be handled by the handlers. types +--------+ | | | | actions +--------+ | | group action action_spec +-----+ |len | +--------+ +------+[d]+-------+ +----------------+[d]+------------+ |attr1+-> |type | | type +> |action+-> | spec +-> + attr_groups +-> |common_chain+--> +-----+ |idr_type| +--------+ +------+ |handler| | | +------------+ |attr2| |access | | | | | +-------+ +----------------+ |vendor chain| +-----+ +--------+ | | | | +------------+ | | +------+ | | | | | | | | | | | | | | | | | | | | +--------+ [d] = distribution function used The right types table is also chosen via using a distribution function over uverbs_types_groups. Once validation and object fetching (or creation) completed, we call the handler: int (*handler)(struct ib_device *ib_dev, struct ib_ucontext *ucontext, struct uverbs_attr_array *ctx, size_t num, void *priv); Where ctx is an array of uverbs_attr_array. Each element in this array is an array of attributes which corresponds to one group of attributes. For example, in the usually used case: ctx core +----------------------------+ +------------+ | core: uverbs_attr_array +---> | valid | +----------------------------+ | cmd_attr | | driver: uverbs_attr_array | +------------+ |----------------------------+--+ | valid | | | cmd_attr | | +------------+ | | valid | | | obj_attr | | +------------+ | | vendor | +------------+ +> | valid | | cmd_attr | +------------+ | valid | | cmd_attr | +------------+ | valid | | obj_attr | +------------+ Ctx array's indices corresponds to the attributes groups order. The indices of core and driver corresponds to the attributes name spaces of each group. Thus, we could think of the following as one object: 1. Set of attribute specification (with their attribute IDs) 2. Attribute group which owns (1) specifications 3. A function which could handle this attributes which the handler could call 4. The allocation descriptor of this type uverbs_type_alloc_action. That means that core and driver are the validated function (3) parameters and their types exist in this function namespace. Since the frequent used case is groups of common and vendor specific elements, we propose a wrapper that allows a definition of the following handler: int (*handler)(struct ib_device *ib_dev, struct ib_ucontext *ucontext, struct uverbs_attr_array *common, struct uverbs_attr_array *vendor, void *priv); Upon success, reference count of uobjects and use count will be a updated automatically according to the specification. Signed-off-by: Matan Barak Signed-off-by: Haggai Eran Signed-off-by: Leon Romanovsky Signed-off-by: Matan Barak --- drivers/infiniband/core/Makefile | 2 +- drivers/infiniband/core/device.c | 3 + drivers/infiniband/core/rdma_core.c | 16 ++ drivers/infiniband/core/rdma_core.h | 2 + drivers/infiniband/core/uverbs.h | 4 + drivers/infiniband/core/uverbs_cmd.c | 1 + drivers/infiniband/core/uverbs_ioctl.c | 306 +++++++++++++++++++++++++++++ drivers/infiniband/core/uverbs_ioctl_cmd.c | 79 ++++++++ drivers/infiniband/core/uverbs_main.c | 6 + include/rdma/ib_verbs.h | 3 +- include/rdma/uverbs_ioctl_cmd.h | 68 +++++++ include/uapi/rdma/rdma_user_ioctl.h | 23 +++ 12 files changed, 511 insertions(+), 2 deletions(-) create mode 100644 drivers/infiniband/core/uverbs_ioctl.c create mode 100644 drivers/infiniband/core/uverbs_ioctl_cmd.c create mode 100644 include/rdma/uverbs_ioctl_cmd.h diff --git a/drivers/infiniband/core/Makefile b/drivers/infiniband/core/Makefile index 1819623..769a299 100644 --- a/drivers/infiniband/core/Makefile +++ b/drivers/infiniband/core/Makefile @@ -29,4 +29,4 @@ ib_umad-y := user_mad.o ib_ucm-y := ucm.o ib_uverbs-y := uverbs_main.o uverbs_cmd.o uverbs_marshall.o \ - rdma_core.o + rdma_core.o uverbs_ioctl.o uverbs_ioctl_cmd.o diff --git a/drivers/infiniband/core/device.c b/drivers/infiniband/core/device.c index 5f09c40..b2e2ee2 100644 --- a/drivers/infiniband/core/device.c +++ b/drivers/infiniband/core/device.c @@ -245,6 +245,9 @@ struct ib_device *ib_alloc_device(size_t size) INIT_LIST_HEAD(&device->port_list); INIT_LIST_HEAD(&device->type_list); + /* TODO: don't forget to initialize device->driver_id, so verbs handshake between + * user space<->kernel space will work for other values than driver_id == 0. + */ return device; } EXPORT_SYMBOL(ib_alloc_device); diff --git a/drivers/infiniband/core/rdma_core.c b/drivers/infiniband/core/rdma_core.c index 337abc2..bf8e741 100644 --- a/drivers/infiniband/core/rdma_core.c +++ b/drivers/infiniband/core/rdma_core.c @@ -55,6 +55,22 @@ const struct uverbs_type *uverbs_get_type(const struct ib_device *ibdev, return types->types[type]; } +const struct uverbs_action *uverbs_get_action(const struct uverbs_type *type, + uint16_t action) +{ + const struct uverbs_type_actions_group *actions_group; + int ret = type->dist(&action, type->priv); + + if (ret >= type->num_groups) + return NULL; + + actions_group = type->action_groups[ret]; + if (action >= actions_group->num_actions) + return NULL; + + return actions_group->actions[action]; +} + static int uverbs_lock_object(struct ib_uobject *uobj, enum uverbs_idr_access access) { diff --git a/drivers/infiniband/core/rdma_core.h b/drivers/infiniband/core/rdma_core.h index 8990115..f3661ef 100644 --- a/drivers/infiniband/core/rdma_core.h +++ b/drivers/infiniband/core/rdma_core.h @@ -44,6 +44,8 @@ const struct uverbs_type *uverbs_get_type(const struct ib_device *ibdev, uint16_t type); +const struct uverbs_action *uverbs_get_action(const struct uverbs_type *type, + uint16_t action); struct ib_uobject *uverbs_get_type_from_idr(const struct uverbs_type_alloc_action *type, struct ib_ucontext *ucontext, enum uverbs_idr_access access, diff --git a/drivers/infiniband/core/uverbs.h b/drivers/infiniband/core/uverbs.h index f6ccd7b..aa783fd 100644 --- a/drivers/infiniband/core/uverbs.h +++ b/drivers/infiniband/core/uverbs.h @@ -41,6 +41,7 @@ #include #include #include +#include #include #include @@ -83,6 +84,8 @@ * released when the CQ is destroyed. */ +long ib_uverbs_ioctl(struct file *filp, unsigned int cmd, unsigned long arg); + struct ib_uverbs_device { atomic_t refcount; int num_comp_vectors; @@ -121,6 +124,7 @@ struct ib_uverbs_file { struct ib_uverbs_event_file *async_file; struct list_head list; int is_closed; + struct rw_semaphore close_sem; }; struct ib_uverbs_event { diff --git a/drivers/infiniband/core/uverbs_cmd.c b/drivers/infiniband/core/uverbs_cmd.c index 6af2c29..9648b80 100644 --- a/drivers/infiniband/core/uverbs_cmd.c +++ b/drivers/infiniband/core/uverbs_cmd.c @@ -361,6 +361,7 @@ ssize_t ib_uverbs_get_context(struct ib_uverbs_file *file, } file->ucontext = ucontext; + ucontext->ufile = file; fd_install(resp.async_fd, filp); diff --git a/drivers/infiniband/core/uverbs_ioctl.c b/drivers/infiniband/core/uverbs_ioctl.c new file mode 100644 index 0000000..40efd4b --- /dev/null +++ b/drivers/infiniband/core/uverbs_ioctl.c @@ -0,0 +1,306 @@ +/* + * Copyright (c) 2016, Mellanox Technologies inc. All rights reserved. + * + * This software is available to you under a choice of one of two + * licenses. You may choose to be licensed under the terms of the GNU + * General Public License (GPL) Version 2, available from the file + * COPYING in the main directory of this source tree, or the + * OpenIB.org BSD license below: + * + * Redistribution and use in source and binary forms, with or + * without modification, are permitted provided that the following + * conditions are met: + * + * - Redistributions of source code must retain the above + * copyright notice, this list of conditions and the following + * disclaimer. + * + * - Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials + * provided with the distribution. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. + */ + +#include +#include +#include "rdma_core.h" +#include "uverbs.h" + +static int uverbs_validate_attr(struct ib_device *ibdev, + struct ib_ucontext *ucontext, + const struct ib_uverbs_attr *uattr, + u16 attr_id, + const struct uverbs_attr_group_spec *group_spec, + struct uverbs_attr *elements, + struct ib_uverbs_attr __user *uattr_ptr) +{ + const struct uverbs_attr_spec *spec; + struct uverbs_attr *e; + const struct uverbs_type *type; + struct uverbs_obj_attr *o_attr; + + if (uattr->reserved) + return -EINVAL; + + if (attr_id >= group_spec->num_attrs) + return -EINVAL; + + spec = &group_spec->attrs[attr_id]; + e = &elements[attr_id]; + + if (e->valid) + return -EINVAL; + + switch (spec->type) { + case UVERBS_ATTR_TYPE_PTR_IN: + case UVERBS_ATTR_TYPE_PTR_OUT: + /* If spec->len is zero, don't validate (flexible) */ + if (spec->len && uattr->len != spec->len) + return -EINVAL; + e->cmd_attr.ptr = (void * __user)uattr->ptr_idr; + e->cmd_attr.len = uattr->len; + break; + + case UVERBS_ATTR_TYPE_IDR: + case UVERBS_ATTR_TYPE_FD: + if (uattr->len != 0 || (uattr->ptr_idr >> 32) || (!ucontext)) + return -EINVAL; + + o_attr = &e->obj_attr; + o_attr->val = spec; + type = uverbs_get_type(ibdev, spec->obj.obj_type); + if (!type) + return -EINVAL; + o_attr->type = type->alloc; + o_attr->uattr = uattr_ptr; + + if (spec->type == UVERBS_ATTR_TYPE_IDR) { + o_attr->uobj.idr = (uint32_t)uattr->ptr_idr; + o_attr->uobject = uverbs_get_type_from_idr(o_attr->type, + ucontext, + spec->obj.access, + o_attr->uobj.idr); + } else { + o_attr->fd.fd = (int)uattr->ptr_idr; + o_attr->uobject = uverbs_get_type_from_fd(o_attr->type, + ucontext, + spec->obj.access, + o_attr->fd.fd); + } + + if (IS_ERR(o_attr->uobject)) + return -EINVAL; + + if (spec->obj.access == UVERBS_IDR_ACCESS_NEW) { + __u64 idr = o_attr->uobject->id; + + if (put_user(idr, &o_attr->uattr->ptr_idr)) { + uverbs_unlock_object(o_attr->uobject, + UVERBS_IDR_ACCESS_NEW, + false); + return -EFAULT; + } + } + + break; + }; + + e->valid = 1; + return 0; +} + +static int uverbs_validate(struct ib_device *ibdev, + struct ib_ucontext *ucontext, + const struct ib_uverbs_attr *uattrs, + size_t num_attrs, + const struct uverbs_action_spec *action_spec, + struct uverbs_attr_array *attr_array, + struct ib_uverbs_attr __user *uattr_ptr) +{ + size_t i; + int ret; + int n_val = -1; + + for (i = 0; i < num_attrs; i++) { + const struct ib_uverbs_attr *uattr = &uattrs[i]; + __u16 attr_id = uattr->attr_id; + const struct uverbs_attr_group_spec *group_spec; + + ret = action_spec->dist(&attr_id, action_spec->priv); + if (ret < 0) + return ret; + + if (ret > n_val) + n_val = ret; + + group_spec = action_spec->attr_groups[ret]; + ret = uverbs_validate_attr(ibdev, ucontext, uattr, attr_id, + group_spec, attr_array[ret].attrs, + uattr_ptr++); + if (ret) + return ret; + } + + return n_val >= 0 ? n_val + 1 : n_val; +} + +static int uverbs_handle_action(struct ib_uverbs_attr __user *uattr_ptr, + const struct ib_uverbs_attr *uattrs, + size_t num_attrs, + struct ib_device *ibdev, + struct ib_uverbs_file *ufile, + const struct uverbs_action *handler, + struct uverbs_attr_array *attr_array) +{ + int ret; + int n_val; + + n_val = uverbs_validate(ibdev, ufile->ucontext, uattrs, num_attrs, + &handler->spec, attr_array, uattr_ptr); + if (n_val <= 0) + return n_val; + + ret = handler->handler(ibdev, ufile, attr_array, n_val, + handler->priv); + uverbs_unlock_objects(attr_array, n_val, &handler->spec, !ret); + + return ret; +} + +static long ib_uverbs_cmd_verbs(struct ib_device *ib_dev, + struct ib_uverbs_file *file, + struct ib_uverbs_ioctl_hdr *hdr, + void __user *buf) +{ + const struct uverbs_type *type; + const struct uverbs_action *action; + const struct uverbs_action_spec *action_spec; + long err = 0; + unsigned int num_specs = 0; + unsigned int i; + struct { + struct ib_uverbs_attr *uattrs; + struct uverbs_attr_array *uverbs_attr_array; + } *ctx = NULL; + struct uverbs_attr *curr_attr; + size_t ctx_size; + + if (!ib_dev) + return -EIO; + + if (ib_dev->driver_id != hdr->driver_id) + return -EINVAL; + + type = uverbs_get_type(ib_dev, hdr->object_type); + if (!type) + return -EOPNOTSUPP; + + action = uverbs_get_action(type, hdr->action); + if (!action) + return -EOPNOTSUPP; + + action_spec = &action->spec; + for (i = 0; i < action_spec->num_groups; + num_specs += action_spec->attr_groups[i]->num_attrs, i++) + ; + + ctx_size = sizeof(*ctx->uattrs) * hdr->num_attrs + + sizeof(*ctx->uverbs_attr_array->attrs) * num_specs + + sizeof(struct uverbs_attr_array) * action_spec->num_groups + + sizeof(*ctx); + + ctx = kzalloc(ctx_size, GFP_KERNEL); + if (!ctx) + return -ENOMEM; + + ctx->uverbs_attr_array = (void *)ctx + sizeof(*ctx); + ctx->uattrs = (void *)(ctx->uverbs_attr_array + + action_spec->num_groups); + curr_attr = (void *)(ctx->uattrs + hdr->num_attrs); + for (i = 0; i < action_spec->num_groups; i++) { + ctx->uverbs_attr_array[i].attrs = curr_attr; + ctx->uverbs_attr_array[i].num_attrs = + action_spec->attr_groups[i]->num_attrs; + curr_attr += action_spec->attr_groups[i]->num_attrs; + } + + err = copy_from_user(ctx->uattrs, buf, + sizeof(*ctx->uattrs) * hdr->num_attrs); + if (err) { + err = -EFAULT; + goto out; + } + + err = uverbs_handle_action(buf, ctx->uattrs, hdr->num_attrs, ib_dev, + file, action, ctx->uverbs_attr_array); +out: + kfree(ctx); + return err; +} + +#define IB_UVERBS_MAX_CMD_SZ 4096 + +long ib_uverbs_ioctl(struct file *filp, unsigned int cmd, unsigned long arg) +{ + struct ib_uverbs_file *file = filp->private_data; + struct ib_uverbs_ioctl_hdr __user *user_hdr = + (struct ib_uverbs_ioctl_hdr __user *)arg; + struct ib_uverbs_ioctl_hdr hdr; + struct ib_device *ib_dev; + int srcu_key; + long err; + + srcu_key = srcu_read_lock(&file->device->disassociate_srcu); + ib_dev = srcu_dereference(file->device->ib_dev, + &file->device->disassociate_srcu); + if (!ib_dev) { + err = -EIO; + goto out; + } + + if (cmd == RDMA_DIRECT_IOCTL) { + /* TODO? */ + err = -ENOSYS; + goto out; + } else { + if (cmd != RDMA_VERBS_IOCTL) { + err = -ENOIOCTLCMD; + goto out; + } + + err = copy_from_user(&hdr, user_hdr, sizeof(hdr)); + + if (err || hdr.length > IB_UVERBS_MAX_CMD_SZ || + hdr.length <= sizeof(hdr) || + hdr.length != sizeof(hdr) + hdr.num_attrs * sizeof(struct ib_uverbs_attr)) { + err = -EINVAL; + goto out; + } + + /* currently there are no flags supported */ + if (hdr.flags) { + err = -EOPNOTSUPP; + goto out; + } + + /* We're closing, fail all commands */ + if (!down_read_trylock(&file->close_sem)) + return -EIO; + err = ib_uverbs_cmd_verbs(ib_dev, file, &hdr, + (__user void *)arg + sizeof(hdr)); + up_read(&file->close_sem); + } +out: + srcu_read_unlock(&file->device->disassociate_srcu, srcu_key); + + return err; +} diff --git a/drivers/infiniband/core/uverbs_ioctl_cmd.c b/drivers/infiniband/core/uverbs_ioctl_cmd.c new file mode 100644 index 0000000..d84866d --- /dev/null +++ b/drivers/infiniband/core/uverbs_ioctl_cmd.c @@ -0,0 +1,79 @@ +/* + * Copyright (c) 2016, Mellanox Technologies inc. All rights reserved. + * + * This software is available to you under a choice of one of two + * licenses. You may choose to be licensed under the terms of the GNU + * General Public License (GPL) Version 2, available from the file + * COPYING in the main directory of this source tree, or the + * OpenIB.org BSD license below: + * + * Redistribution and use in source and binary forms, with or + * without modification, are permitted provided that the following + * conditions are met: + * + * - Redistributions of source code must retain the above + * copyright notice, this list of conditions and the following + * disclaimer. + * + * - Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials + * provided with the distribution. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. + */ + +#include +#include +#include +#include "uverbs.h" + +#define IB_UVERBS_VENDOR_FLAG 0x8000 + +int ib_uverbs_std_dist(__u16 *id, void *priv) +{ + if (*id & IB_UVERBS_VENDOR_FLAG) { + *id &= ~IB_UVERBS_VENDOR_FLAG; + return 1; + } + return 0; +} +EXPORT_SYMBOL(ib_uverbs_std_dist); + +int uverbs_action_std_handle(struct ib_device *ib_dev, + struct ib_uverbs_file *ufile, + struct uverbs_attr_array *ctx, size_t num, + void *_priv) +{ + struct uverbs_action_std_handler *priv = _priv; + + if (!ufile->ucontext) + return -EINVAL; + + WARN_ON((num != 1) && (num != 2)); + return priv->handler(ib_dev, ufile->ucontext, &ctx[0], + (num == 2 ? &ctx[1] : NULL), + priv->priv); +} +EXPORT_SYMBOL(uverbs_action_std_handle); + +int uverbs_action_std_ctx_handle(struct ib_device *ib_dev, + struct ib_uverbs_file *ufile, + struct uverbs_attr_array *ctx, size_t num, + void *_priv) +{ + struct uverbs_action_std_ctx_handler *priv = _priv; + + WARN_ON((num != 1) && (num != 2)); + return priv->handler(ib_dev, ufile, &ctx[0], + (num == 2 ? &ctx[1] : NULL), priv->priv); +} +EXPORT_SYMBOL(uverbs_action_std_ctx_handle); + diff --git a/drivers/infiniband/core/uverbs_main.c b/drivers/infiniband/core/uverbs_main.c index b3aa733..80582c8 100644 --- a/drivers/infiniband/core/uverbs_main.c +++ b/drivers/infiniband/core/uverbs_main.c @@ -49,6 +49,7 @@ #include #include +#include #include "uverbs.h" @@ -211,6 +212,7 @@ static int ib_uverbs_cleanup_ucontext(struct ib_uverbs_file *file, { struct ib_uobject *uobj, *tmp; + down_write(&file->close_sem); context->closing = 1; list_for_each_entry_safe(uobj, tmp, &context->ah_list, list) { @@ -306,6 +308,7 @@ static int ib_uverbs_cleanup_ucontext(struct ib_uverbs_file *file, } put_pid(context->tgid); + up_write(&file->close_sem); return context->device->dealloc_ucontext(context); } @@ -915,6 +918,7 @@ static int ib_uverbs_open(struct inode *inode, struct file *filp) goto err; } + init_rwsem(&file->close_sem); file->device = dev; file->ucontext = NULL; file->async_file = NULL; @@ -973,6 +977,7 @@ static const struct file_operations uverbs_fops = { .open = ib_uverbs_open, .release = ib_uverbs_close, .llseek = no_llseek, + .unlocked_ioctl = ib_uverbs_ioctl, }; static const struct file_operations uverbs_mmap_fops = { @@ -982,6 +987,7 @@ static const struct file_operations uverbs_mmap_fops = { .open = ib_uverbs_open, .release = ib_uverbs_close, .llseek = no_llseek, + .unlocked_ioctl = ib_uverbs_ioctl, }; static struct ib_client uverbs_client = { diff --git a/include/rdma/ib_verbs.h b/include/rdma/ib_verbs.h index 77e21b5..dd0bd42 100644 --- a/include/rdma/ib_verbs.h +++ b/include/rdma/ib_verbs.h @@ -1981,7 +1981,8 @@ struct ib_device { int (*get_port_immutable)(struct ib_device *, u8, struct ib_port_immutable *); struct list_head type_list; - const struct uverbs_types_group *types_group; + u16 driver_id; + const struct uverbs_types_group *types_group; }; struct ib_client { diff --git a/include/rdma/uverbs_ioctl_cmd.h b/include/rdma/uverbs_ioctl_cmd.h new file mode 100644 index 0000000..19806df --- /dev/null +++ b/include/rdma/uverbs_ioctl_cmd.h @@ -0,0 +1,68 @@ +/* + * Copyright (c) 2016, Mellanox Technologies inc. All rights reserved. + * + * This software is available to you under a choice of one of two + * licenses. You may choose to be licensed under the terms of the GNU + * General Public License (GPL) Version 2, available from the file + * COPYING in the main directory of this source tree, or the + * OpenIB.org BSD license below: + * + * Redistribution and use in source and binary forms, with or + * without modification, are permitted provided that the following + * conditions are met: + * + * - Redistributions of source code must retain the above + * copyright notice, this list of conditions and the following + * disclaimer. + * + * - Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following + * disclaimer in the documentation and/or other materials + * provided with the distribution. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. + */ + +#ifndef _UVERBS_IOCTL_CMD_ +#define _UVERBS_IOCTL_CMD_ + +#include + +int ib_uverbs_std_dist(__u16 *attr_id, void *priv); + +/* common validators */ + +int uverbs_action_std_handle(struct ib_device *ib_dev, + struct ib_uverbs_file *ufile, + struct uverbs_attr_array *ctx, size_t num, + void *_priv); +int uverbs_action_std_ctx_handle(struct ib_device *ib_dev, + struct ib_uverbs_file *ufile, + struct uverbs_attr_array *ctx, size_t num, + void *_priv); + +struct uverbs_action_std_handler { + int (*handler)(struct ib_device *ib_dev, struct ib_ucontext *ucontext, + struct uverbs_attr_array *common, + struct uverbs_attr_array *vendor, + void *priv); + void *priv; +}; + +struct uverbs_action_std_ctx_handler { + int (*handler)(struct ib_device *ib_dev, struct ib_uverbs_file *ufile, + struct uverbs_attr_array *common, + struct uverbs_attr_array *vendor, + void *priv); + void *priv; +}; + +#endif + diff --git a/include/uapi/rdma/rdma_user_ioctl.h b/include/uapi/rdma/rdma_user_ioctl.h index 5c1117a..f6927fc 100644 --- a/include/uapi/rdma/rdma_user_ioctl.h +++ b/include/uapi/rdma/rdma_user_ioctl.h @@ -42,6 +42,29 @@ */ #define IB_IOCTL_MAGIC RDMA_IOCTL_MAGIC +#define RDMA_VERBS_IOCTL \ + _IOWR(RDMA_IOCTL_MAGIC, 1, struct ib_uverbs_ioctl_hdr) + +#define RDMA_DIRECT_IOCTL \ + _IOWR(RDMA_IOCTL_MAGIC, 2, struct ib_uverbs_ioctl_hdr) + +struct ib_uverbs_attr { + __u16 attr_id; /* command specific type attribute */ + __u16 len; /* NA for idr */ + __u32 reserved; + __u64 ptr_idr; /* ptr typeo command/idr handle */ +}; + +struct ib_uverbs_ioctl_hdr { + __u16 length; + __u16 flags; + __u16 object_type; + __u16 driver_id; + __u16 action; + __u16 num_attrs; + struct ib_uverbs_attr attrs[0]; +}; + /* Legacy part * !!!! NOTE: It uses the same command index as VERBS */