From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 2CDD9A034C; Tue, 18 Jan 2022 14:26:39 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 16EBB4271E; Tue, 18 Jan 2022 14:26:39 +0100 (CET) Received: from mx0b-0016f401.pphosted.com (mx0a-0016f401.pphosted.com [67.231.148.174]) by mails.dpdk.org (Postfix) with ESMTP id C5C9B4271E for ; Tue, 18 Jan 2022 14:26:37 +0100 (CET) Received: from pps.filterd (m0045849.ppops.net [127.0.0.1]) by mx0a-0016f401.pphosted.com (8.16.1.2/8.16.1.2) with ESMTP id 20IBFZsQ021237; Tue, 18 Jan 2022 05:26:36 -0800 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=marvell.com; h=from : to : cc : subject : date : message-id : in-reply-to : references : mime-version : content-transfer-encoding : content-type; s=pfpt0220; bh=G28gu3xyi5NxupjM7lD0M2dHPU9Vf7Z2IslpQorN//I=; b=URoO+hfphwU9wdYqSI9Pu5GADN4dhIWewDN2CEcsqYmpVZ7r6oPRhssoY1evda9/NKek tqjXNssWvaEhjENMiQxNwNiNqHVh73Y88z8e60MeixPAdJCRvN4z/JGbcG2kKcYppcNs aWh+dvVoiCNHv3YNbjlHN8Mji0huSbCuerOsUMqfLlgGxtsIvgmp872bcYSLchzb4hXO gmgm//bLpykS4m+yvHJ8pOTlhQ5Y6Xps/Oww8JepMQUNGappxV0vXGAoQ4YIeKEtbfAy sfm71zcDLL5K1C0+NzZKjuXehi6ae3gibmiA6dOb/xTwRbU/plMsPOs/4xOCbineqygv mA== Received: from dc5-exch01.marvell.com ([199.233.59.181]) by mx0a-0016f401.pphosted.com (PPS) with ESMTPS id 3dnmttsu2b-11 (version=TLSv1.2 cipher=ECDHE-RSA-AES256-SHA384 bits=256 verify=NOT); Tue, 18 Jan 2022 05:26:36 -0800 Received: from DC5-EXCH01.marvell.com (10.69.176.38) by DC5-EXCH01.marvell.com (10.69.176.38) with Microsoft SMTP Server (TLS) id 15.0.1497.2; Tue, 18 Jan 2022 05:24:53 -0800 Received: from maili.marvell.com (10.69.176.80) by DC5-EXCH01.marvell.com (10.69.176.38) with Microsoft SMTP Server id 15.0.1497.2 via Frontend Transport; Tue, 18 Jan 2022 05:24:53 -0800 Received: from localhost.localdomain (unknown [10.28.34.39]) by maili.marvell.com (Postfix) with ESMTP id ED7AA3F705D; Tue, 18 Jan 2022 05:24:50 -0800 (PST) From: Tomasz Duszynski To: CC: , , Tomasz Duszynski , Jerin Jacob Kollanukkaran Subject: [PATCH v5 11/11] raw/cnxk_gpio: add option to allow using subset of GPIOs Date: Tue, 18 Jan 2022 14:24:24 +0100 Message-ID: <20220118132424.2573372-12-tduszynski@marvell.com> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20220118132424.2573372-1-tduszynski@marvell.com> References: <20220105140020.1615256-1-tduszynski@marvell.com> <20220118132424.2573372-1-tduszynski@marvell.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Content-Type: text/plain X-Proofpoint-GUID: od-Qcn5MpX64aaYUZZqyvOwA08VLr_Ht X-Proofpoint-ORIG-GUID: od-Qcn5MpX64aaYUZZqyvOwA08VLr_Ht X-Proofpoint-Virus-Version: vendor=baseguard engine=ICAP:2.0.205,Aquarius:18.0.816,Hydra:6.0.425,FMLib:17.11.62.513 definitions=2022-01-18_04,2022-01-18_01,2021-12-02_01 X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Add PMD parameter that allows one to select only subset of available GPIOs. This might be useful in cases where some GPIOs are already reserved yet still available for userspace access but particular app should not touch them. Signed-off-by: Tomasz Duszynski Reviewed-by: Jerin Jacob Kollanukkaran --- doc/guides/rawdevs/cnxk_gpio.rst | 5 + drivers/raw/cnxk_gpio/cnxk_gpio.c | 173 +++++++++++++++++---- drivers/raw/cnxk_gpio/cnxk_gpio.h | 2 + drivers/raw/cnxk_gpio/cnxk_gpio_selftest.c | 49 +++--- drivers/raw/cnxk_gpio/rte_pmd_cnxk_gpio.h | 8 + 5 files changed, 188 insertions(+), 49 deletions(-) diff --git a/doc/guides/rawdevs/cnxk_gpio.rst b/doc/guides/rawdevs/cnxk_gpio.rst index c03a5b937c..adff535a77 100644 --- a/doc/guides/rawdevs/cnxk_gpio.rst +++ b/doc/guides/rawdevs/cnxk_gpio.rst @@ -57,6 +57,11 @@ former returns number GPIOs available in the system irrespective of GPIOs being controllable or not. Thus it is user responsibility to pick the proper ones. The latter call simply returns queue capacity. +In order to allow using only subset of available GPIOs `allowlist` PMD param may +be used. For example passing `--vdev=cnxk_gpio,gpiochip=448,allowlist=[0,1,2,3]` +to EAL will deny using all GPIOs except those specified explicitly in the +`allowlist`. + Respective queue needs to be configured with ``rte_rawdev_queue_setup()``. This call barely exports GPIO to userspace. diff --git a/drivers/raw/cnxk_gpio/cnxk_gpio.c b/drivers/raw/cnxk_gpio/cnxk_gpio.c index 230016b078..4ff132861d 100644 --- a/drivers/raw/cnxk_gpio/cnxk_gpio.c +++ b/drivers/raw/cnxk_gpio/cnxk_gpio.c @@ -22,9 +22,13 @@ static const char *const cnxk_gpio_args[] = { #define CNXK_GPIO_ARG_GPIOCHIP "gpiochip" CNXK_GPIO_ARG_GPIOCHIP, +#define CNXK_GPIO_ARG_ALLOWLIST "allowlist" + CNXK_GPIO_ARG_ALLOWLIST, NULL }; +static char *allowlist; + static void cnxk_gpio_format_name(char *name, size_t len) { @@ -73,13 +77,23 @@ cnxk_gpio_parse_arg_gpiochip(const char *key __rte_unused, const char *value, } static int -cnxk_gpio_parse_args(struct cnxk_gpiochip *gpiochip, - struct rte_devargs *devargs) +cnxk_gpio_parse_arg_allowlist(const char *key __rte_unused, const char *value, + void *extra_args __rte_unused) +{ + allowlist = strdup(value); + if (!allowlist) + return -ENOMEM; + + return 0; +} + +static int +cnxk_gpio_parse_args(struct cnxk_gpiochip *gpiochip, const char *args) { struct rte_kvargs *kvlist; int ret; - kvlist = rte_kvargs_parse(devargs->args, cnxk_gpio_args); + kvlist = rte_kvargs_parse(args, cnxk_gpio_args); if (!kvlist) return 0; @@ -92,6 +106,14 @@ cnxk_gpio_parse_args(struct cnxk_gpiochip *gpiochip, goto out; } + ret = rte_kvargs_count(kvlist, CNXK_GPIO_ARG_ALLOWLIST); + if (ret == 1) { + ret = rte_kvargs_process(kvlist, CNXK_GPIO_ARG_ALLOWLIST, + cnxk_gpio_parse_arg_allowlist, NULL); + if (ret) + goto out; + } + ret = 0; out: rte_kvargs_free(kvlist); @@ -99,6 +121,60 @@ cnxk_gpio_parse_args(struct cnxk_gpiochip *gpiochip, return ret; } +static int +cnxk_gpio_parse_allowlist(struct cnxk_gpiochip *gpiochip) +{ + int i, ret, val, queue = 0; + char *token; + int *list; + + list = rte_calloc(NULL, gpiochip->num_gpios, sizeof(*list), 0); + if (!list) + return -ENOMEM; + + /* replace brackets with something meaningless for strtol() */ + allowlist[0] = ' '; + allowlist[strlen(allowlist) - 1] = ' '; + + /* quiesce -Wcast-qual */ + token = strtok((char *)(uintptr_t)allowlist, ","); + do { + errno = 0; + val = strtol(token, NULL, 10); + if (errno) { + RTE_LOG(ERR, PMD, "failed to parse %s\n", token); + ret = -errno; + goto out; + } + + if (val < 0 || val >= gpiochip->num_gpios) { + RTE_LOG(ERR, PMD, "gpio%d out of 0-%d range\n", val, + gpiochip->num_gpios - 1); + ret = -EINVAL; + goto out; + } + + for (i = 0; i < queue; i++) { + if (list[i] != val) + continue; + + RTE_LOG(WARNING, PMD, "gpio%d already allowed\n", val); + break; + } + if (i == queue) + list[queue++] = val; + } while ((token = strtok(NULL, ","))); + + gpiochip->allowlist = list; + gpiochip->num_queues = queue; + + return 0; +out: + rte_free(list); + + return ret; +} + static int cnxk_gpio_read_attr(char *attr, char *val) { @@ -175,13 +251,24 @@ cnxk_gpio_write_attr_int(const char *attr, int val) return cnxk_gpio_write_attr(attr, buf); } +static bool +cnxk_gpio_queue_valid(struct cnxk_gpiochip *gpiochip, uint16_t queue) +{ + return queue < gpiochip->num_queues; +} + +static int +cnxk_queue_to_gpio(struct cnxk_gpiochip *gpiochip, uint16_t queue) +{ + return gpiochip->allowlist ? gpiochip->allowlist[queue] : queue; +} + static struct cnxk_gpio * cnxk_gpio_lookup(struct cnxk_gpiochip *gpiochip, uint16_t queue) { - if (queue >= gpiochip->num_gpios) - return NULL; + int gpio = cnxk_queue_to_gpio(gpiochip, queue); - return gpiochip->gpios[queue]; + return gpiochip->gpios[gpio]; } static int @@ -191,11 +278,14 @@ cnxk_gpio_queue_setup(struct rte_rawdev *dev, uint16_t queue_id, struct cnxk_gpiochip *gpiochip = dev->dev_private; char buf[CNXK_GPIO_BUFSZ]; struct cnxk_gpio *gpio; - int ret; + int num, ret; RTE_SET_USED(queue_conf); RTE_SET_USED(queue_conf_size); + if (!cnxk_gpio_queue_valid(gpiochip, queue_id)) + return -EINVAL; + gpio = cnxk_gpio_lookup(gpiochip, queue_id); if (gpio) return -EEXIST; @@ -203,7 +293,9 @@ cnxk_gpio_queue_setup(struct rte_rawdev *dev, uint16_t queue_id, gpio = rte_zmalloc(NULL, sizeof(*gpio), 0); if (!gpio) return -ENOMEM; - gpio->num = queue_id + gpiochip->base; + + num = cnxk_queue_to_gpio(gpiochip, queue_id); + gpio->num = num + gpiochip->base; gpio->gpiochip = gpiochip; snprintf(buf, sizeof(buf), "%s/export", CNXK_GPIO_CLASS_PATH); @@ -213,7 +305,7 @@ cnxk_gpio_queue_setup(struct rte_rawdev *dev, uint16_t queue_id, return ret; } - gpiochip->gpios[queue_id] = gpio; + gpiochip->gpios[num] = gpio; return 0; } @@ -224,18 +316,22 @@ cnxk_gpio_queue_release(struct rte_rawdev *dev, uint16_t queue_id) struct cnxk_gpiochip *gpiochip = dev->dev_private; char buf[CNXK_GPIO_BUFSZ]; struct cnxk_gpio *gpio; - int ret; + int num, ret; + + if (!cnxk_gpio_queue_valid(gpiochip, queue_id)) + return -EINVAL; gpio = cnxk_gpio_lookup(gpiochip, queue_id); if (!gpio) return -ENODEV; snprintf(buf, sizeof(buf), "%s/unexport", CNXK_GPIO_CLASS_PATH); - ret = cnxk_gpio_write_attr_int(buf, gpiochip->base + queue_id); + ret = cnxk_gpio_write_attr_int(buf, gpio->num); if (ret) return ret; - gpiochip->gpios[queue_id] = NULL; + num = cnxk_queue_to_gpio(gpiochip, queue_id); + gpiochip->gpios[num] = NULL; rte_free(gpio); return 0; @@ -245,16 +341,17 @@ static int cnxk_gpio_queue_def_conf(struct rte_rawdev *dev, uint16_t queue_id, rte_rawdev_obj_t queue_conf, size_t queue_conf_size) { - unsigned int *conf; + struct cnxk_gpiochip *gpiochip = dev->dev_private; + struct cnxk_gpio_queue_conf *conf = queue_conf; - RTE_SET_USED(dev); - RTE_SET_USED(queue_id); + if (!cnxk_gpio_queue_valid(gpiochip, queue_id)) + return -EINVAL; if (queue_conf_size != sizeof(*conf)) return -EINVAL; - conf = (unsigned int *)queue_conf; - *conf = 1; + conf->size = 1; + conf->gpio = cnxk_queue_to_gpio(gpiochip, queue_id); return 0; } @@ -264,7 +361,7 @@ cnxk_gpio_queue_count(struct rte_rawdev *dev) { struct cnxk_gpiochip *gpiochip = dev->dev_private; - return gpiochip->num_gpios; + return gpiochip->num_queues; } static const struct { @@ -463,21 +560,27 @@ cnxk_gpio_process_buf(struct cnxk_gpio *gpio, struct rte_rawdev_buf *rbuf) return ret; } +static bool +cnxk_gpio_valid(struct cnxk_gpiochip *gpiochip, int gpio) +{ + return gpio < gpiochip->num_gpios && gpiochip->gpios[gpio]; +} + static int cnxk_gpio_enqueue_bufs(struct rte_rawdev *dev, struct rte_rawdev_buf **buffers, unsigned int count, rte_rawdev_obj_t context) { struct cnxk_gpiochip *gpiochip = dev->dev_private; - unsigned int queue = (size_t)context; + unsigned int gpio_num = (size_t)context; struct cnxk_gpio *gpio; int ret; if (count == 0) return 0; - gpio = cnxk_gpio_lookup(gpiochip, queue); - if (!gpio) - return -ENODEV; + if (!cnxk_gpio_valid(gpiochip, gpio_num)) + return -EINVAL; + gpio = gpiochip->gpios[gpio_num]; ret = cnxk_gpio_process_buf(gpio, buffers[0]); if (ret) @@ -491,15 +594,15 @@ cnxk_gpio_dequeue_bufs(struct rte_rawdev *dev, struct rte_rawdev_buf **buffers, unsigned int count, rte_rawdev_obj_t context) { struct cnxk_gpiochip *gpiochip = dev->dev_private; - unsigned int queue = (size_t)context; + unsigned int gpio_num = (size_t)context; struct cnxk_gpio *gpio; if (count == 0) return 0; - gpio = cnxk_gpio_lookup(gpiochip, queue); - if (!gpio) - return -ENODEV; + if (!cnxk_gpio_valid(gpiochip, gpio_num)) + return -EINVAL; + gpio = gpiochip->gpios[gpio_num]; if (gpio->rsp) { buffers[0]->buf_addr = gpio->rsp; @@ -558,7 +661,7 @@ cnxk_gpio_probe(struct rte_vdev_device *dev) cnxk_gpio_set_defaults(gpiochip); /* defaults may be overwritten by this call */ - ret = cnxk_gpio_parse_args(gpiochip, dev->device.devargs); + ret = cnxk_gpio_parse_args(gpiochip, rte_vdev_device_args(dev)); if (ret) goto out; @@ -583,6 +686,15 @@ cnxk_gpio_probe(struct rte_vdev_device *dev) RTE_LOG(ERR, PMD, "failed to read %s", buf); goto out; } + gpiochip->num_queues = gpiochip->num_gpios; + + if (allowlist) { + ret = cnxk_gpio_parse_allowlist(gpiochip); + free(allowlist); + allowlist = NULL; + if (ret) + goto out; + } gpiochip->gpios = rte_calloc(NULL, gpiochip->num_gpios, sizeof(struct cnxk_gpio *), 0); @@ -594,6 +706,8 @@ cnxk_gpio_probe(struct rte_vdev_device *dev) return 0; out: + free(allowlist); + rte_free(gpiochip->allowlist); rte_rawdev_pmd_release(rawdev); return ret; @@ -630,6 +744,7 @@ cnxk_gpio_remove(struct rte_vdev_device *dev) cnxk_gpio_queue_release(rawdev, gpio->num); } + rte_free(gpiochip->allowlist); rte_free(gpiochip->gpios); cnxk_gpio_irq_fini(); rte_rawdev_pmd_release(rawdev); @@ -643,4 +758,6 @@ static struct rte_vdev_driver cnxk_gpio_drv = { }; RTE_PMD_REGISTER_VDEV(cnxk_gpio, cnxk_gpio_drv); -RTE_PMD_REGISTER_PARAM_STRING(cnxk_gpio, "gpiochip="); +RTE_PMD_REGISTER_PARAM_STRING(cnxk_gpio, + "gpiochip= " + "allowlist="); diff --git a/drivers/raw/cnxk_gpio/cnxk_gpio.h b/drivers/raw/cnxk_gpio/cnxk_gpio.h index 1b31b5a486..e62f78a760 100644 --- a/drivers/raw/cnxk_gpio/cnxk_gpio.h +++ b/drivers/raw/cnxk_gpio/cnxk_gpio.h @@ -20,7 +20,9 @@ struct cnxk_gpiochip { int num; int base; int num_gpios; + int num_queues; struct cnxk_gpio **gpios; + int *allowlist; }; int cnxk_gpio_selftest(uint16_t dev_id); diff --git a/drivers/raw/cnxk_gpio/cnxk_gpio_selftest.c b/drivers/raw/cnxk_gpio/cnxk_gpio_selftest.c index 6502902f86..7fccc48f30 100644 --- a/drivers/raw/cnxk_gpio/cnxk_gpio_selftest.c +++ b/drivers/raw/cnxk_gpio/cnxk_gpio_selftest.c @@ -302,12 +302,13 @@ cnxk_gpio_test_output(uint16_t dev_id, int base, int gpio) int cnxk_gpio_selftest(uint16_t dev_id) { + struct cnxk_gpio_queue_conf conf; struct cnxk_gpiochip *gpiochip; - unsigned int queues, i, size; char buf[CNXK_GPIO_BUFSZ]; struct rte_rawdev *rawdev; + unsigned int queues, i; struct cnxk_gpio *gpio; - int ret; + int ret, ret2; rawdev = rte_rawdev_pmd_get_named_dev("cnxk_gpio"); gpiochip = rawdev->dev_private; @@ -325,62 +326,68 @@ cnxk_gpio_selftest(uint16_t dev_id) return -errno; for (i = 0; i < queues; i++) { - RTE_LOG(INFO, PMD, "testing queue %d (gpio%d)\n", i, - gpiochip->base + i); - - ret = rte_rawdev_queue_conf_get(dev_id, i, &size, sizeof(size)); + ret = rte_rawdev_queue_conf_get(dev_id, i, &conf, sizeof(conf)); if (ret) { RTE_LOG(ERR, PMD, "failed to read queue configuration (%d)\n", ret); - continue; + goto out; } - if (size != 1) { + RTE_LOG(INFO, PMD, "testing queue%d (gpio%d)\n", i, conf.gpio); + + if (conf.size != 1) { RTE_LOG(ERR, PMD, "wrong queue size received\n"); - continue; + ret = -EIO; + goto out; } ret = rte_rawdev_queue_setup(dev_id, i, NULL, 0); if (ret) { RTE_LOG(ERR, PMD, "failed to setup queue (%d)\n", ret); - continue; + goto out; } - gpio = gpiochip->gpios[i]; + gpio = gpiochip->gpios[conf.gpio]; snprintf(buf, sizeof(buf), CNXK_GPIO_PATH_FMT, gpio->num); if (!cnxk_gpio_attr_exists(buf)) { RTE_LOG(ERR, PMD, "%s does not exist\n", buf); - continue; - } - - ret = cnxk_gpio_test_input(dev_id, gpiochip->base, i); - if (ret) + ret = -ENOENT; goto release; + } - ret = cnxk_gpio_test_irq(dev_id, i); + ret = cnxk_gpio_test_input(dev_id, gpiochip->base, conf.gpio); if (ret) goto release; - ret = cnxk_gpio_test_output(dev_id, gpiochip->base, i); + ret = cnxk_gpio_test_irq(dev_id, conf.gpio); if (ret) goto release; + ret = cnxk_gpio_test_output(dev_id, gpiochip->base, conf.gpio); release: + ret2 = ret; ret = rte_rawdev_queue_release(dev_id, i); if (ret) { RTE_LOG(ERR, PMD, "failed to release queue (%d)\n", ret); - continue; + break; } if (cnxk_gpio_attr_exists(buf)) { RTE_LOG(ERR, PMD, "%s still exists\n", buf); - continue; + ret = -EIO; + break; + } + + if (ret2) { + ret = ret2; + break; } } +out: close(fd); - return 0; + return ret; } diff --git a/drivers/raw/cnxk_gpio/rte_pmd_cnxk_gpio.h b/drivers/raw/cnxk_gpio/rte_pmd_cnxk_gpio.h index e3096dc14f..80a37be9c7 100644 --- a/drivers/raw/cnxk_gpio/rte_pmd_cnxk_gpio.h +++ b/drivers/raw/cnxk_gpio/rte_pmd_cnxk_gpio.h @@ -22,6 +22,14 @@ extern "C" { #endif +/* Queue default configuration */ +struct cnxk_gpio_queue_conf { + /** Queue size */ + int size; + /** GPIO number as seen by hardware */ + int gpio; +}; + /** Available message types */ enum cnxk_gpio_msg_type { /** Type used to set output value */ -- 2.25.1