Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/41675/?format=api
{ "id": 41675, "url": "http://patches.dpdk.org/api/patches/41675/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/1368a8720f3ec3c40e47a6b1d9ef1edf0f38a646.1530111623.git.nelio.laranjeiro@6wind.com/", "project": { "id": 1, "url": "http://patches.dpdk.org/api/projects/1/?format=api", "name": "DPDK", "link_name": "dpdk", "list_id": "dev.dpdk.org", "list_email": "dev@dpdk.org", "web_url": "http://core.dpdk.org", "scm_url": "git://dpdk.org/dpdk", "webscm_url": "http://git.dpdk.org/dpdk", "list_archive_url": "https://inbox.dpdk.org/dev", "list_archive_url_format": "https://inbox.dpdk.org/dev/{}", "commit_url_format": "" }, "msgid": "<1368a8720f3ec3c40e47a6b1d9ef1edf0f38a646.1530111623.git.nelio.laranjeiro@6wind.com>", "list_archive_url": "https://inbox.dpdk.org/dev/1368a8720f3ec3c40e47a6b1d9ef1edf0f38a646.1530111623.git.nelio.laranjeiro@6wind.com", "date": "2018-06-27T15:07:34", "name": "[v2,02/20] net/mlx5: handle drop queues are regular queues", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "2dc1fcbe18cf8537fde163bccb8302b5f670828d", "submitter": { "id": 243, "url": "http://patches.dpdk.org/api/people/243/?format=api", "name": "Nélio Laranjeiro", "email": "nelio.laranjeiro@6wind.com" }, "delegate": { "id": 6624, "url": "http://patches.dpdk.org/api/users/6624/?format=api", "username": "shahafs", "first_name": "Shahaf", "last_name": "Shuler", "email": "shahafs@mellanox.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/1368a8720f3ec3c40e47a6b1d9ef1edf0f38a646.1530111623.git.nelio.laranjeiro@6wind.com/mbox/", "series": [ { "id": 268, "url": "http://patches.dpdk.org/api/series/268/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=268", "date": "2018-06-27T15:07:32", "name": "net/mlx5: flow rework", "version": 2, "mbox": "http://patches.dpdk.org/series/268/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/41675/comments/", "check": "fail", "checks": "http://patches.dpdk.org/api/patches/41675/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@dpdk.org", "Delivered-To": "patchwork@dpdk.org", "Received": [ "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id CFAE21BF9C;\n\tWed, 27 Jun 2018 17:07:37 +0200 (CEST)", "from mail-wr0-f195.google.com (mail-wr0-f195.google.com\n\t[209.85.128.195]) by dpdk.org (Postfix) with ESMTP id 99E081BF92\n\tfor <dev@dpdk.org>; Wed, 27 Jun 2018 17:07:36 +0200 (CEST)", "by mail-wr0-f195.google.com with SMTP id b8-v6so2405812wro.6\n\tfor <dev@dpdk.org>; Wed, 27 Jun 2018 08:07:36 -0700 (PDT)", "from laranjeiro-vm.dev.6wind.com\n\t(host.78.145.23.62.rev.coltfrance.com. [62.23.145.78])\n\tby smtp.gmail.com with ESMTPSA id\n\tk17-v6sm4872513wrp.19.2018.06.27.08.07.35\n\t(version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128);\n\tWed, 27 Jun 2018 08:07:35 -0700 (PDT)" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed;\n\td=6wind-com.20150623.gappssmtp.com; s=20150623;\n\th=from:to:subject:date:message-id:in-reply-to:references;\n\tbh=ToivEB5ymVB3JKbO2dxhXZxYCY3xI42unLIODHnd6iQ=;\n\tb=ZlUDkeqlk51Lv09BeO1DLrYrwvcwdHTCqvmQI0h2yTCAaU2wjqvLrP2C9wvHiVZlDR\n\t4c4SO0ULynEPW2wfdmQlBKskEvwQiCKUSQrdlzGv8zsnSlNexhqhV7OEoFEuOaBgnkjK\n\tDwTWd5XJNUIKWkQ5MNhbw3xqEOJs6HZzemPbNfH5+w3YP2d96ZvQB0R93Vp/WONx0K+S\n\tVeqmSsYIYLYL1Wr+1UuQGIq/mTsGs/uwCsO3VBjJ4uzMWBqZOUhLKrD/zxOqiv++Ocz3\n\tDSP0kjS49Aemx4Mz+8Q/VnAgTSGjngEZEWwY071oqdrEM6HBmlr4u1BSM/lSbVFfLxm0\n\tw9ZQ==", "X-Google-DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed;\n\td=1e100.net; s=20161025;\n\th=x-gm-message-state:from:to:subject:date:message-id:in-reply-to\n\t:references;\n\tbh=ToivEB5ymVB3JKbO2dxhXZxYCY3xI42unLIODHnd6iQ=;\n\tb=pj7AE3eRjZ1PLO6RmjmOSFiY8PrtconK6dc54URui/Kh4tubAogJZcv0rjPJEHq12p\n\tC7CJsdk8DoWvQirgdES4vm0ioi4cZWAMZ+uLpua3Kpm2kft3OqvvOzzp1zoITOS18Va9\n\tl03moUHuEtEqVtqXoMK8JE2qyRsiMwOt5Rhkdv+hoEK1pQm0ztIumKrcOtloXyVMASC1\n\t0Nq/Uwmc6XfiytaqDtGQ94k6qYT+t5kmsX2PwgNggnXMjMmtcSKkNyUVb1DsXlwouZch\n\tlQCZFw0/AtG8F4l0aVPebLLC8sloUwULEMk66VgkZfo0BGfMLwmYeRFPF2313Cn8+wm7\n\tbhtw==", "X-Gm-Message-State": "APt69E2TxNvoXi4nv/7cedC2abI/V/Zmr05hf84JK8Ikq5I7r3sQlrxU\n\t1Z1DEhCeeHKJS3+0CykR+4UwIzbV8w==", "X-Google-Smtp-Source": "AAOMgpc2ewLDlrHHCecgcf77zwl21VY7c5si30FNIgmx44GhvUPDLbey9exkKiws+VlqGAUp/wuhjQ==", "X-Received": "by 2002:adf:fc8c:: with SMTP id\n\tg12-v6mr5508760wrr.216.1530112055837; \n\tWed, 27 Jun 2018 08:07:35 -0700 (PDT)", "From": "Nelio Laranjeiro <nelio.laranjeiro@6wind.com>", "To": "dev@dpdk.org, Adrien Mazarguil <adrien.mazarguil@6wind.com>,\n\tYongseok Koh <yskoh@mellanox.com>", "Date": "Wed, 27 Jun 2018 17:07:34 +0200", "Message-Id": "<1368a8720f3ec3c40e47a6b1d9ef1edf0f38a646.1530111623.git.nelio.laranjeiro@6wind.com>", "X-Mailer": "git-send-email 2.18.0", "In-Reply-To": "<cover.1530111623.git.nelio.laranjeiro@6wind.com>", "References": "<cover.1527506071.git.nelio.laranjeiro@6wind.com>\n\t<cover.1530111623.git.nelio.laranjeiro@6wind.com>", "Subject": "[dpdk-dev] [PATCH v2 02/20] net/mlx5: handle drop queues are\n\tregular queues", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.15", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "Drop queues are essentially used in flows due to Verbs API, the\ninformation if the fate of the flow is a drop or not is already present\nin the flow. Due to this, drop queues can be fully mapped on regular\nqueues.\n\nSigned-off-by: Nelio Laranjeiro <nelio.laranjeiro@6wind.com>\n---\n drivers/net/mlx5/mlx5.c | 24 ++--\n drivers/net/mlx5/mlx5.h | 14 ++-\n drivers/net/mlx5/mlx5_flow.c | 94 +++++++-------\n drivers/net/mlx5/mlx5_rxq.c | 232 +++++++++++++++++++++++++++++++++++\n drivers/net/mlx5/mlx5_rxtx.h | 8 ++\n 5 files changed, 310 insertions(+), 62 deletions(-)", "diff": "diff --git a/drivers/net/mlx5/mlx5.c b/drivers/net/mlx5/mlx5.c\nindex d01c0f6cf..aba6c1f9f 100644\n--- a/drivers/net/mlx5/mlx5.c\n+++ b/drivers/net/mlx5/mlx5.c\n@@ -260,7 +260,6 @@ mlx5_dev_close(struct rte_eth_dev *dev)\n \t\tpriv->txqs_n = 0;\n \t\tpriv->txqs = NULL;\n \t}\n-\tmlx5_flow_delete_drop_queue(dev);\n \tmlx5_mprq_free_mp(dev);\n \tmlx5_mr_release(dev);\n \tif (priv->pd != NULL) {\n@@ -1100,22 +1099,15 @@ mlx5_dev_spawn_one(struct rte_device *dpdk_dev,\n \tmlx5_link_update(eth_dev, 0);\n \t/* Store device configuration on private structure. */\n \tpriv->config = config;\n-\t/* Create drop queue. */\n-\terr = mlx5_flow_create_drop_queue(eth_dev);\n-\tif (err) {\n-\t\tDRV_LOG(ERR, \"port %u drop queue allocation failed: %s\",\n-\t\t\teth_dev->data->port_id, strerror(rte_errno));\n-\t\terr = rte_errno;\n-\t\tgoto error;\n-\t}\n \t/* Supported Verbs flow priority number detection. */\n-\tif (verb_priorities == 0)\n-\t\tverb_priorities = mlx5_get_max_verbs_prio(eth_dev);\n-\tif (verb_priorities < MLX5_VERBS_FLOW_PRIO_8) {\n-\t\tDRV_LOG(ERR, \"port %u wrong Verbs flow priorities: %u\",\n-\t\t\teth_dev->data->port_id, verb_priorities);\n-\t\terr = ENOTSUP;\n-\t\tgoto error;\n+\tif (verb_priorities == 0) {\n+\t\terr = mlx5_verbs_max_prio(eth_dev);\n+\t\tif (err < 0) {\n+\t\t\tDRV_LOG(ERR, \"port %u wrong Verbs flow priorities\",\n+\t\t\t\teth_dev->data->port_id);\n+\t\t\tgoto error;\n+\t\t}\n+\t\tverb_priorities = err;\n \t}\n \tpriv->config.max_verbs_prio = verb_priorities;\n \t/*\ndiff --git a/drivers/net/mlx5/mlx5.h b/drivers/net/mlx5/mlx5.h\nindex 6674a77d4..11aa0932f 100644\n--- a/drivers/net/mlx5/mlx5.h\n+++ b/drivers/net/mlx5/mlx5.h\n@@ -131,9 +131,6 @@ enum mlx5_verbs_alloc_type {\n \tMLX5_VERBS_ALLOC_TYPE_RX_QUEUE,\n };\n \n-/* 8 Verbs priorities. */\n-#define MLX5_VERBS_FLOW_PRIO_8 8\n-\n /**\n * Verbs allocator needs a context to know in the callback which kind of\n * resources it is allocating.\n@@ -145,6 +142,12 @@ struct mlx5_verbs_alloc_ctx {\n \n LIST_HEAD(mlx5_mr_list, mlx5_mr);\n \n+/* Flow drop context necessary due to Verbs API. */\n+struct mlx5_drop {\n+\tstruct mlx5_hrxq *hrxq; /* Hash Rx queue queue. */\n+\tstruct mlx5_rxq_ibv *rxq; /* Verbs Rx queue. */\n+};\n+\n struct priv {\n \tLIST_ENTRY(priv) mem_event_cb; /* Called by memory event callback. */\n \tstruct rte_eth_dev_data *dev_data; /* Pointer to device data. */\n@@ -175,7 +178,7 @@ struct priv {\n \tstruct rte_intr_handle intr_handle; /* Interrupt handler. */\n \tunsigned int (*reta_idx)[]; /* RETA index table. */\n \tunsigned int reta_idx_n; /* RETA index size. */\n-\tstruct mlx5_hrxq_drop *flow_drop_queue; /* Flow drop queue. */\n+\tstruct mlx5_drop drop; /* Flow drop queues. */\n \tstruct mlx5_flows flows; /* RTE Flow rules. */\n \tstruct mlx5_flows ctrl_flows; /* Control flow rules. */\n \tstruct {\n@@ -306,7 +309,8 @@ int mlx5_traffic_restart(struct rte_eth_dev *dev);\n \n /* mlx5_flow.c */\n \n-unsigned int mlx5_get_max_verbs_prio(struct rte_eth_dev *dev);\n+int mlx5_verbs_max_prio(struct rte_eth_dev *dev);\n+void mlx5_flow_print(struct rte_flow *flow);\n int mlx5_flow_validate(struct rte_eth_dev *dev,\n \t\t const struct rte_flow_attr *attr,\n \t\t const struct rte_flow_item items[],\ndiff --git a/drivers/net/mlx5/mlx5_flow.c b/drivers/net/mlx5/mlx5_flow.c\nindex a45cb06e1..8b5b695d4 100644\n--- a/drivers/net/mlx5/mlx5_flow.c\n+++ b/drivers/net/mlx5/mlx5_flow.c\n@@ -75,6 +75,58 @@ struct ibv_spec_header {\n \tuint16_t size;\n };\n \n+ /**\n+ * Get the maximum number of priority available.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ *\n+ * @return\n+ * number of supported Verbs flow priority on success, a negative errno\n+ * value otherwise and rte_errno is set.\n+ */\n+int\n+mlx5_verbs_max_prio(struct rte_eth_dev *dev)\n+{\n+\tstruct {\n+\t\tstruct ibv_flow_attr attr;\n+\t\tstruct ibv_flow_spec_eth eth;\n+\t\tstruct ibv_flow_spec_action_drop drop;\n+\t} flow_attr = {\n+\t\t.attr = {\n+\t\t\t.num_of_specs = 2,\n+\t\t},\n+\t\t.eth = {\n+\t\t\t.type = IBV_FLOW_SPEC_ETH,\n+\t\t\t.size = sizeof(struct ibv_flow_spec_eth),\n+\t\t},\n+\t\t.drop = {\n+\t\t\t.size = sizeof(struct ibv_flow_spec_action_drop),\n+\t\t\t.type = IBV_FLOW_SPEC_ACTION_DROP,\n+\t\t},\n+\t};\n+\tstruct ibv_flow *flow;\n+\tuint32_t verb_priorities;\n+\tstruct mlx5_hrxq *drop = mlx5_hrxq_drop_new(dev);\n+\n+\tif (!drop) {\n+\t\trte_errno = ENOTSUP;\n+\t\treturn -rte_errno;\n+\t}\n+\tfor (verb_priorities = 0; 1; verb_priorities++) {\n+\t\tflow_attr.attr.priority = verb_priorities;\n+\t\tflow = mlx5_glue->create_flow(drop->qp,\n+\t\t\t\t\t &flow_attr.attr);\n+\t\tif (!flow)\n+\t\t\tbreak;\n+\t\tclaim_zero(mlx5_glue->destroy_flow(flow));\n+\t}\n+\tmlx5_hrxq_drop_release(dev, drop);\n+\tDRV_LOG(INFO, \"port %u flow maximum priority: %d\",\n+\t\tdev->data->port_id, verb_priorities);\n+\treturn verb_priorities;\n+}\n+\n /**\n * Convert a flow.\n *\n@@ -184,32 +236,6 @@ mlx5_flow_list_flush(struct rte_eth_dev *dev, struct mlx5_flows *list)\n \t}\n }\n \n-/**\n- * Create drop queue.\n- *\n- * @param dev\n- * Pointer to Ethernet device.\n- *\n- * @return\n- * 0 on success, a negative errno value otherwise and rte_errno is set.\n- */\n-int\n-mlx5_flow_create_drop_queue(struct rte_eth_dev *dev __rte_unused)\n-{\n-\treturn 0;\n-}\n-\n-/**\n- * Delete drop queue.\n- *\n- * @param dev\n- * Pointer to Ethernet device.\n- */\n-void\n-mlx5_flow_delete_drop_queue(struct rte_eth_dev *dev __rte_unused)\n-{\n-}\n-\n /**\n * Remove all flows.\n *\n@@ -292,6 +318,7 @@ mlx5_ctrl_flow_vlan(struct rte_eth_dev *dev,\n \tstruct priv *priv = dev->data->dev_private;\n \tconst struct rte_flow_attr attr = {\n \t\t.ingress = 1,\n+\t\t.priority = priv->config.max_verbs_prio - 1,\n \t};\n \tstruct rte_flow_item items[] = {\n \t\t{\n@@ -830,18 +857,3 @@ mlx5_dev_filter_ctrl(struct rte_eth_dev *dev,\n \t}\n \treturn 0;\n }\n-\n-/**\n- * Detect number of Verbs flow priorities supported.\n- *\n- * @param dev\n- * Pointer to Ethernet device.\n- *\n- * @return\n- * number of supported Verbs flow priority.\n- */\n-unsigned int\n-mlx5_get_max_verbs_prio(struct rte_eth_dev *dev __rte_unused)\n-{\n-\treturn 8;\n-}\ndiff --git a/drivers/net/mlx5/mlx5_rxq.c b/drivers/net/mlx5/mlx5_rxq.c\nindex 17db7c160..5f17dce50 100644\n--- a/drivers/net/mlx5/mlx5_rxq.c\n+++ b/drivers/net/mlx5/mlx5_rxq.c\n@@ -1949,3 +1949,235 @@ mlx5_hrxq_ibv_verify(struct rte_eth_dev *dev)\n \t}\n \treturn ret;\n }\n+\n+/**\n+ * Create a drop Rx queue Verbs object.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ *\n+ * @return\n+ * The Verbs object initialised, NULL otherwise and rte_errno is set.\n+ */\n+struct mlx5_rxq_ibv *\n+mlx5_rxq_ibv_drop_new(struct rte_eth_dev *dev)\n+{\n+\tstruct priv *priv = dev->data->dev_private;\n+\tstruct ibv_cq *cq;\n+\tstruct ibv_wq *wq = NULL;\n+\tstruct mlx5_rxq_ibv *rxq;\n+\n+\tif (priv->drop.rxq)\n+\t\treturn priv->drop.rxq;\n+\tcq = mlx5_glue->create_cq(priv->ctx, 1, NULL, NULL, 0);\n+\tif (!cq) {\n+\t\tDEBUG(\"port %u cannot allocate CQ for drop queue\",\n+\t\t dev->data->port_id);\n+\t\trte_errno = errno;\n+\t\tgoto error;\n+\t}\n+\twq = mlx5_glue->create_wq(priv->ctx,\n+\t\t &(struct ibv_wq_init_attr){\n+\t\t\t.wq_type = IBV_WQT_RQ,\n+\t\t\t.max_wr = 1,\n+\t\t\t.max_sge = 1,\n+\t\t\t.pd = priv->pd,\n+\t\t\t.cq = cq,\n+\t\t });\n+\tif (!wq) {\n+\t\tDEBUG(\"port %u cannot allocate WQ for drop queue\",\n+\t\t dev->data->port_id);\n+\t\trte_errno = errno;\n+\t\tgoto error;\n+\t}\n+\trxq = rte_calloc(__func__, 1, sizeof(*rxq), 0);\n+\tif (!rxq) {\n+\t\tDEBUG(\"port %u cannot allocate drop Rx queue memory\",\n+\t\t dev->data->port_id);\n+\t\trte_errno = ENOMEM;\n+\t\tgoto error;\n+\t}\n+\trxq->cq = cq;\n+\trxq->wq = wq;\n+\tpriv->drop.rxq = rxq;\n+\treturn rxq;\n+error:\n+\tif (wq)\n+\t\tclaim_zero(mlx5_glue->destroy_wq(wq));\n+\tif (cq)\n+\t\tclaim_zero(mlx5_glue->destroy_cq(cq));\n+\treturn NULL;\n+}\n+\n+/**\n+ * Release a drop Rx queue Verbs object.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ * @param rxq\n+ * Pointer to the drop Verbs Rx queue.\n+ *\n+ * @return\n+ * The Verbs object initialised, NULL otherwise and rte_errno is set.\n+ */\n+void\n+mlx5_rxq_ibv_drop_release(struct rte_eth_dev *dev, struct mlx5_rxq_ibv *rxq)\n+{\n+\tif (rxq->wq)\n+\t\tclaim_zero(mlx5_glue->destroy_wq(rxq->wq));\n+\tif (rxq->cq)\n+\t\tclaim_zero(mlx5_glue->destroy_cq(rxq->cq));\n+\trte_free(rxq);\n+\t((struct priv *)dev->data->dev_private)->drop.rxq = NULL;\n+}\n+\n+/**\n+ * Create a drop indirection table.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ *\n+ * @return\n+ * The Verbs object initialised, NULL otherwise and rte_errno is set.\n+ */\n+struct mlx5_ind_table_ibv *\n+mlx5_ind_table_ibv_drop_new(struct rte_eth_dev *dev)\n+{\n+\tstruct priv *priv = dev->data->dev_private;\n+\tstruct mlx5_ind_table_ibv *ind_tbl;\n+\tstruct mlx5_rxq_ibv *rxq;\n+\tstruct mlx5_ind_table_ibv tmpl;\n+\n+\trxq = mlx5_rxq_ibv_drop_new(dev);\n+\tif (!rxq)\n+\t\treturn NULL;\n+\ttmpl.ind_table = mlx5_glue->create_rwq_ind_table\n+\t\t(priv->ctx,\n+\t\t &(struct ibv_rwq_ind_table_init_attr){\n+\t\t\t.log_ind_tbl_size = 0,\n+\t\t\t.ind_tbl = &rxq->wq,\n+\t\t\t.comp_mask = 0,\n+\t\t });\n+\tif (!tmpl.ind_table) {\n+\t\tDEBUG(\"port %u cannot allocate indirection table for drop\"\n+\t\t \" queue\",\n+\t\t dev->data->port_id);\n+\t\trte_errno = errno;\n+\t\tgoto error;\n+\t}\n+\tind_tbl = rte_calloc(__func__, 1, sizeof(*ind_tbl), 0);\n+\tif (!ind_tbl) {\n+\t\trte_errno = ENOMEM;\n+\t\tgoto error;\n+\t}\n+\tind_tbl->ind_table = tmpl.ind_table;\n+\treturn ind_tbl;\n+error:\n+\tmlx5_rxq_ibv_drop_release(dev, rxq);\n+\treturn NULL;\n+}\n+\n+/**\n+ * Release a drop indirection table.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ * @param ind_tbl\n+ * Indirection table to release.\n+ */\n+void\n+mlx5_ind_table_ibv_drop_release(struct rte_eth_dev *dev,\n+\t\t\t\tstruct mlx5_ind_table_ibv *ind_tbl)\n+{\n+\tclaim_zero(mlx5_glue->destroy_rwq_ind_table(ind_tbl->ind_table));\n+\tmlx5_rxq_ibv_drop_release\n+\t\t(dev, ((struct priv *)dev->data->dev_private)->drop.rxq);\n+\trte_free(ind_tbl);\n+}\n+\n+/**\n+ * Create a drop Rx Hash queue.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ *\n+ * @return\n+ * The Verbs object initialised, NULL otherwise and rte_errno is set.\n+ */\n+struct mlx5_hrxq *\n+mlx5_hrxq_drop_new(struct rte_eth_dev *dev)\n+{\n+\tstruct priv *priv = dev->data->dev_private;\n+\tstruct mlx5_ind_table_ibv *ind_tbl;\n+\tstruct ibv_qp *qp;\n+\tstruct mlx5_hrxq *hrxq;\n+\n+\tif (priv->drop.hrxq) {\n+\t\trte_atomic32_inc(&priv->drop.hrxq->refcnt);\n+\t\treturn priv->drop.hrxq;\n+\t}\n+\tind_tbl = mlx5_ind_table_ibv_drop_new(dev);\n+\tif (!ind_tbl)\n+\t\treturn NULL;\n+\tqp = mlx5_glue->create_qp_ex(priv->ctx,\n+\t\t &(struct ibv_qp_init_attr_ex){\n+\t\t\t.qp_type = IBV_QPT_RAW_PACKET,\n+\t\t\t.comp_mask =\n+\t\t\t\tIBV_QP_INIT_ATTR_PD |\n+\t\t\t\tIBV_QP_INIT_ATTR_IND_TABLE |\n+\t\t\t\tIBV_QP_INIT_ATTR_RX_HASH,\n+\t\t\t.rx_hash_conf = (struct ibv_rx_hash_conf){\n+\t\t\t\t.rx_hash_function =\n+\t\t\t\t\tIBV_RX_HASH_FUNC_TOEPLITZ,\n+\t\t\t\t.rx_hash_key_len = rss_hash_default_key_len,\n+\t\t\t\t.rx_hash_key = rss_hash_default_key,\n+\t\t\t\t.rx_hash_fields_mask = 0,\n+\t\t\t\t},\n+\t\t\t.rwq_ind_tbl = ind_tbl->ind_table,\n+\t\t\t.pd = priv->pd\n+\t\t });\n+\tif (!qp) {\n+\t\tDEBUG(\"port %u cannot allocate QP for drop queue\",\n+\t\t dev->data->port_id);\n+\t\trte_errno = errno;\n+\t\tgoto error;\n+\t}\n+\thrxq = rte_calloc(__func__, 1, sizeof(*hrxq), 0);\n+\tif (!hrxq) {\n+\t\tDRV_LOG(WARNING,\n+\t\t\t\"port %u cannot allocate memory for drop queue\",\n+\t\t\tdev->data->port_id);\n+\t\trte_errno = ENOMEM;\n+\t\tgoto error;\n+\t}\n+\thrxq->ind_table = ind_tbl;\n+\thrxq->qp = qp;\n+\tpriv->drop.hrxq = hrxq;\n+\trte_atomic32_set(&hrxq->refcnt, 1);\n+\treturn hrxq;\n+error:\n+\tif (ind_tbl)\n+\t\tmlx5_ind_table_ibv_drop_release(dev, ind_tbl);\n+\treturn NULL;\n+}\n+\n+/**\n+ * Release a drop hash Rx queue.\n+ *\n+ * @param dev\n+ * Pointer to Ethernet device.\n+ * @param hrxq\n+ * Pointer to Hash Rx queue to release.\n+ */\n+void\n+mlx5_hrxq_drop_release(struct rte_eth_dev *dev, struct mlx5_hrxq *hrxq)\n+{\n+\tstruct priv *priv = dev->data->dev_private;\n+\n+\tif (rte_atomic32_dec_and_test(&hrxq->refcnt)) {\n+\t\tclaim_zero(mlx5_glue->destroy_qp(hrxq->qp));\n+\t\tmlx5_ind_table_ibv_drop_release(dev, hrxq->ind_table);\n+\t\trte_free(hrxq);\n+\t\tpriv->drop.hrxq = NULL;\n+\t}\n+}\ndiff --git a/drivers/net/mlx5/mlx5_rxtx.h b/drivers/net/mlx5/mlx5_rxtx.h\nindex f53bb43c3..51f7f678b 100644\n--- a/drivers/net/mlx5/mlx5_rxtx.h\n+++ b/drivers/net/mlx5/mlx5_rxtx.h\n@@ -245,6 +245,9 @@ struct mlx5_rxq_ibv *mlx5_rxq_ibv_new(struct rte_eth_dev *dev, uint16_t idx);\n struct mlx5_rxq_ibv *mlx5_rxq_ibv_get(struct rte_eth_dev *dev, uint16_t idx);\n int mlx5_rxq_ibv_release(struct mlx5_rxq_ibv *rxq_ibv);\n int mlx5_rxq_ibv_releasable(struct mlx5_rxq_ibv *rxq_ibv);\n+struct mlx5_rxq_ibv *mlx5_rxq_ibv_drop_new(struct rte_eth_dev *dev);\n+void mlx5_rxq_ibv_drop_release(struct rte_eth_dev *dev,\n+\t\t\t struct mlx5_rxq_ibv *rxq);\n int mlx5_rxq_ibv_verify(struct rte_eth_dev *dev);\n struct mlx5_rxq_ctrl *mlx5_rxq_new(struct rte_eth_dev *dev, uint16_t idx,\n \t\t\t\t uint16_t desc, unsigned int socket,\n@@ -265,6 +268,9 @@ struct mlx5_ind_table_ibv *mlx5_ind_table_ibv_get(struct rte_eth_dev *dev,\n int mlx5_ind_table_ibv_release(struct rte_eth_dev *dev,\n \t\t\t struct mlx5_ind_table_ibv *ind_tbl);\n int mlx5_ind_table_ibv_verify(struct rte_eth_dev *dev);\n+struct mlx5_ind_table_ibv *mlx5_ind_table_ibv_drop_new(struct rte_eth_dev *dev);\n+void mlx5_ind_table_ibv_drop_release(struct rte_eth_dev *dev,\n+\t\t\t\t struct mlx5_ind_table_ibv *ind_tbl);\n struct mlx5_hrxq *mlx5_hrxq_new(struct rte_eth_dev *dev,\n \t\t\t\tconst uint8_t *rss_key, uint32_t rss_key_len,\n \t\t\t\tuint64_t hash_fields,\n@@ -277,6 +283,8 @@ struct mlx5_hrxq *mlx5_hrxq_get(struct rte_eth_dev *dev,\n \t\t\t\tuint32_t tunnel, uint32_t rss_level);\n int mlx5_hrxq_release(struct rte_eth_dev *dev, struct mlx5_hrxq *hxrq);\n int mlx5_hrxq_ibv_verify(struct rte_eth_dev *dev);\n+struct mlx5_hrxq *mlx5_hrxq_drop_new(struct rte_eth_dev *dev);\n+void mlx5_hrxq_drop_release(struct rte_eth_dev *dev, struct mlx5_hrxq *hrxq);\n uint64_t mlx5_get_rx_port_offloads(void);\n uint64_t mlx5_get_rx_queue_offloads(struct rte_eth_dev *dev);\n \n", "prefixes": [ "v2", "02/20" ] }