From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by dpdk.space (Postfix) with ESMTP id 36C51A05D3 for ; Thu, 25 Apr 2019 17:41:29 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 2D0651B5EA; Thu, 25 Apr 2019 17:41:29 +0200 (CEST) Received: from mx1.redhat.com (mx1.redhat.com [209.132.183.28]) by dpdk.org (Postfix) with ESMTP id 7AFD71B5D8 for ; Thu, 25 Apr 2019 17:41:27 +0200 (CEST) Received: from smtp.corp.redhat.com (int-mx04.intmail.prod.int.phx2.redhat.com [10.5.11.14]) (using TLSv1.2 with cipher AECDH-AES256-SHA (256/256 bits)) (No client certificate requested) by mx1.redhat.com (Postfix) with ESMTPS id E20033199364; Thu, 25 Apr 2019 15:41:26 +0000 (UTC) Received: from rh.redhat.com (unknown [10.36.116.255]) by smtp.corp.redhat.com (Postfix) with ESMTP id CFC695D9C6; Thu, 25 Apr 2019 15:41:25 +0000 (UTC) From: Kevin Traynor To: Tiwei Bie Cc: Maxime Coquelin , dpdk stable Date: Thu, 25 Apr 2019 16:40:02 +0100 Message-Id: <20190425154037.28778-27-ktraynor@redhat.com> In-Reply-To: <20190425154037.28778-1-ktraynor@redhat.com> References: <20190425154037.28778-1-ktraynor@redhat.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-Scanned-By: MIMEDefang 2.79 on 10.5.11.14 X-Greylist: Sender IP whitelisted, not delayed by milter-greylist-4.5.16 (mx1.redhat.com [10.5.110.41]); Thu, 25 Apr 2019 15:41:26 +0000 (UTC) Subject: [dpdk-stable] patch 'net/virtio-user: fix multi-process support' has been queued to LTS release 18.11.2 X-BeenThere: stable@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches for DPDK stable branches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: stable-bounces@dpdk.org Sender: "stable" Hi, FYI, your patch has been queued to LTS release 18.11.2 Note it hasn't been pushed to http://dpdk.org/browse/dpdk-stable yet. It will be pushed if I get no objections before 05/01/19. So please shout if anyone has objections. Also note that after the patch there's a diff of the upstream commit vs the patch applied to the branch. This will indicate if there was any rebasing needed to apply to the stable branch. If there were code changes for rebasing (ie: not only metadata diffs), please double check that the rebase was correctly done. Queued patches can be viewed on the 18.11 branch at: https://github.com/kevintraynor/dpdk-stable-queue.git Thanks. Kevin Traynor --- >From d21964ea6b83ef0a060a628c044a3d35041ed373 Mon Sep 17 00:00:00 2001 From: Tiwei Bie Date: Mon, 25 Mar 2019 12:12:15 +0800 Subject: [PATCH] net/virtio-user: fix multi-process support [ upstream commit 1c8489da561be16ac73c6dab01db816af249713f ] This patch fixes the multi-process support for virtio-user. Currently virtio-user just provides some limited secondary process supports. Only some basic operations can be done in secondary process on virtio-user port, e.g. getting port stats. Actions which will trigger the communication with vhost backend can't be done in secondary process for now, as the fds are not synced between processes. The processing of server mode devargs is also moved into virtio_user_dev_init(). Fixes: cdb068f031c6 ("bus/vdev: scan by multi-process channel") Fixes: ee27edbe0c10 ("drivers/net: share vdev data to secondary process") Signed-off-by: Tiwei Bie Reviewed-by: Maxime Coquelin --- drivers/net/virtio/virtio_ethdev.c | 15 +++++ drivers/net/virtio/virtio_ethdev.h | 2 + .../net/virtio/virtio_user/virtio_user_dev.c | 3 +- .../net/virtio/virtio_user/virtio_user_dev.h | 2 +- drivers/net/virtio/virtio_user_ethdev.c | 61 +++++++++++-------- 5 files changed, 55 insertions(+), 28 deletions(-) diff --git a/drivers/net/virtio/virtio_ethdev.c b/drivers/net/virtio/virtio_ethdev.c index 1767140b7..a1e3752a8 100644 --- a/drivers/net/virtio/virtio_ethdev.c +++ b/drivers/net/virtio/virtio_ethdev.c @@ -779,4 +779,19 @@ static const struct eth_dev_ops virtio_eth_dev_ops = { }; +/* + * dev_ops for virtio-user in secondary processes, as we just have + * some limited supports currently. + */ +const struct eth_dev_ops virtio_user_secondary_eth_dev_ops = { + .dev_infos_get = virtio_dev_info_get, + .stats_get = virtio_dev_stats_get, + .xstats_get = virtio_dev_xstats_get, + .xstats_get_names = virtio_dev_xstats_get_names, + .stats_reset = virtio_dev_stats_reset, + .xstats_reset = virtio_dev_stats_reset, + /* collect stats per queue */ + .queue_stats_mapping_set = virtio_dev_queue_stats_mapping_set, +}; + static void virtio_update_stats(struct rte_eth_dev *dev, struct rte_eth_stats *stats) diff --git a/drivers/net/virtio/virtio_ethdev.h b/drivers/net/virtio/virtio_ethdev.h index e0f80e5a4..39a9f7b7d 100644 --- a/drivers/net/virtio/virtio_ethdev.h +++ b/drivers/net/virtio/virtio_ethdev.h @@ -46,4 +46,6 @@ 1u << VIRTIO_NET_F_HOST_TSO6) +extern const struct eth_dev_ops virtio_user_secondary_eth_dev_ops; + /* * CQ function prototype diff --git a/drivers/net/virtio/virtio_user/virtio_user_dev.c b/drivers/net/virtio/virtio_user/virtio_user_dev.c index 9c8bcd2c6..f0051f887 100644 --- a/drivers/net/virtio/virtio_user/virtio_user_dev.c +++ b/drivers/net/virtio/virtio_user/virtio_user_dev.c @@ -413,5 +413,5 @@ int virtio_user_dev_init(struct virtio_user_dev *dev, char *path, int queues, int cq, int queue_size, const char *mac, char **ifname, - int mrg_rxbuf, int in_order) + int server, int mrg_rxbuf, int in_order) { pthread_mutex_init(&dev->mutex, NULL); @@ -421,4 +421,5 @@ virtio_user_dev_init(struct virtio_user_dev *dev, char *path, int queues, dev->queue_pairs = 1; /* mq disabled by default */ dev->queue_size = queue_size; + dev->is_server = server; dev->mac_specified = 0; dev->frontend_features = 0; diff --git a/drivers/net/virtio/virtio_user/virtio_user_dev.h b/drivers/net/virtio/virtio_user/virtio_user_dev.h index c42ce5d4b..3e3a7b787 100644 --- a/drivers/net/virtio/virtio_user/virtio_user_dev.h +++ b/drivers/net/virtio/virtio_user/virtio_user_dev.h @@ -51,5 +51,5 @@ int virtio_user_stop_device(struct virtio_user_dev *dev); int virtio_user_dev_init(struct virtio_user_dev *dev, char *path, int queues, int cq, int queue_size, const char *mac, char **ifname, - int mrg_rxbuf, int in_order); + int server, int mrg_rxbuf, int in_order); void virtio_user_dev_uninit(struct virtio_user_dev *dev); void virtio_user_handle_cq(struct virtio_user_dev *dev, uint16_t queue_idx); diff --git a/drivers/net/virtio/virtio_user_ethdev.c b/drivers/net/virtio/virtio_user_ethdev.c index f8791391a..5781c0948 100644 --- a/drivers/net/virtio/virtio_user_ethdev.c +++ b/drivers/net/virtio/virtio_user_ethdev.c @@ -470,4 +470,24 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) int ret = -1; + if (rte_eal_process_type() == RTE_PROC_SECONDARY) { + const char *name = rte_vdev_device_name(dev); + eth_dev = rte_eth_dev_attach_secondary(name); + if (!eth_dev) { + RTE_LOG(ERR, PMD, "Failed to probe %s\n", name); + return -1; + } + + if (eth_virtio_dev_init(eth_dev) < 0) { + PMD_INIT_LOG(ERR, "eth_virtio_dev_init fails"); + rte_eth_dev_release_port(eth_dev); + return -1; + } + + eth_dev->dev_ops = &virtio_user_secondary_eth_dev_ops; + eth_dev->device = &dev->device; + rte_eth_dev_probing_finish(eth_dev); + return 0; + } + kvlist = rte_kvargs_parse(rte_vdev_device_args(dev), valid_args); if (!kvlist) { @@ -582,31 +602,17 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) } - if (rte_eal_process_type() == RTE_PROC_PRIMARY) { - struct virtio_user_dev *vu_dev; + eth_dev = virtio_user_eth_dev_alloc(dev); + if (!eth_dev) { + PMD_INIT_LOG(ERR, "virtio_user fails to alloc device"); + goto end; + } - eth_dev = virtio_user_eth_dev_alloc(dev); - if (!eth_dev) { - PMD_INIT_LOG(ERR, "virtio_user fails to alloc device"); - goto end; - } - - hw = eth_dev->data->dev_private; - vu_dev = virtio_user_get_dev(hw); - if (server_mode == 1) - vu_dev->is_server = true; - else - vu_dev->is_server = false; - if (virtio_user_dev_init(hw->virtio_user_dev, path, queues, cq, - queue_size, mac_addr, &ifname, mrg_rxbuf, - in_order) < 0) { - PMD_INIT_LOG(ERR, "virtio_user_dev_init fails"); - virtio_user_eth_dev_free(eth_dev); - goto end; - } - - } else { - eth_dev = rte_eth_dev_attach_secondary(rte_vdev_device_name(dev)); - if (!eth_dev) - goto end; + hw = eth_dev->data->dev_private; + if (virtio_user_dev_init(hw->virtio_user_dev, path, queues, cq, + queue_size, mac_addr, &ifname, server_mode, + mrg_rxbuf, in_order) < 0) { + PMD_INIT_LOG(ERR, "virtio_user_dev_init fails"); + virtio_user_eth_dev_free(eth_dev); + goto end; } @@ -650,4 +656,7 @@ virtio_user_pmd_remove(struct rte_vdev_device *vdev) return -ENODEV; + if (rte_eal_process_type() != RTE_PROC_PRIMARY) + return rte_eth_dev_release_port(eth_dev); + /* make sure the device is stopped, queues freed */ rte_eth_dev_close(eth_dev->data->port_id); -- 2.20.1 --- Diff of the applied patch vs upstream commit (please double-check if non-empty: --- --- - 2019-04-25 16:37:47.931380463 +0100 +++ 0027-net-virtio-user-fix-multi-process-support.patch 2019-04-25 16:37:46.735295178 +0100 @@ -1 +1 @@ -From 1c8489da561be16ac73c6dab01db816af249713f Mon Sep 17 00:00:00 2001 +From d21964ea6b83ef0a060a628c044a3d35041ed373 Mon Sep 17 00:00:00 2001 @@ -5,0 +6,2 @@ +[ upstream commit 1c8489da561be16ac73c6dab01db816af249713f ] + @@ -17 +18,0 @@ -Cc: stable@dpdk.org @@ -25 +26 @@ - .../net/virtio/virtio_user/virtio_user_dev.h | 3 +- + .../net/virtio/virtio_user/virtio_user_dev.h | 2 +- @@ -27 +28 @@ - 5 files changed, 56 insertions(+), 28 deletions(-) + 5 files changed, 55 insertions(+), 28 deletions(-) @@ -30 +31 @@ -index 85b223451..310008757 100644 +index 1767140b7..a1e3752a8 100644 @@ -33 +34 @@ -@@ -908,4 +908,19 @@ static const struct eth_dev_ops virtio_eth_dev_ops = { +@@ -779,4 +779,19 @@ static const struct eth_dev_ops virtio_eth_dev_ops = { @@ -54 +55 @@ -index b8aab7da4..45e96f32b 100644 +index e0f80e5a4..39a9f7b7d 100644 @@ -57 +58 @@ -@@ -48,4 +48,6 @@ +@@ -46,4 +46,6 @@ @@ -65 +66 @@ -index 2dc8f2051..07aabb527 100644 +index 9c8bcd2c6..f0051f887 100644 @@ -68 +69 @@ -@@ -427,5 +427,5 @@ int +@@ -413,5 +413,5 @@ int @@ -71,2 +72,2 @@ -- int mrg_rxbuf, int in_order, int packed_vq) -+ int server, int mrg_rxbuf, int in_order, int packed_vq) +- int mrg_rxbuf, int in_order) ++ int server, int mrg_rxbuf, int in_order) @@ -75 +76 @@ -@@ -435,4 +435,5 @@ virtio_user_dev_init(struct virtio_user_dev *dev, char *path, int queues, +@@ -421,4 +421,5 @@ virtio_user_dev_init(struct virtio_user_dev *dev, char *path, int queues, @@ -82 +83 @@ -index c57b298a6..829ad4140 100644 +index c42ce5d4b..3e3a7b787 100644 @@ -85 +86 @@ -@@ -62,5 +62,6 @@ int virtio_user_stop_device(struct virtio_user_dev *dev); +@@ -51,5 +51,5 @@ int virtio_user_stop_device(struct virtio_user_dev *dev); @@ -88,3 +89,2 @@ -- int mrg_rxbuf, int in_order, int packed_vq); -+ int server, int mrg_rxbuf, int in_order, -+ int packed_vq); +- int mrg_rxbuf, int in_order); ++ int server, int mrg_rxbuf, int in_order); @@ -94 +94 @@ -index c5a76bd91..129c2b9ef 100644 +index f8791391a..5781c0948 100644 @@ -97 +97 @@ -@@ -515,4 +515,24 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) +@@ -470,4 +470,24 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) @@ -122 +122 @@ -@@ -636,31 +656,17 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) +@@ -582,31 +602,17 @@ virtio_user_pmd_probe(struct rte_vdev_device *dev) @@ -147 +147 @@ -- in_order, packed_vq) < 0) { +- in_order) < 0) { @@ -160 +160 @@ -+ mrg_rxbuf, in_order, packed_vq) < 0) { ++ mrg_rxbuf, in_order) < 0) { @@ -166 +166 @@ -@@ -704,4 +710,7 @@ virtio_user_pmd_remove(struct rte_vdev_device *vdev) +@@ -650,4 +656,7 @@ virtio_user_pmd_remove(struct rte_vdev_device *vdev)