Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/105352/?format=api
{ "id": 105352, "url": "http://patches.dpdk.org/api/patches/105352/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/e47ad75bc37b4e56ab30aab959e41c52a985ed3f.1640242368.git.songyl@ramaxel.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": "<e47ad75bc37b4e56ab30aab959e41c52a985ed3f.1640242368.git.songyl@ramaxel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/e47ad75bc37b4e56ab30aab959e41c52a985ed3f.1640242368.git.songyl@ramaxel.com", "date": "2021-12-23T08:24:07", "name": "[v2,24/25] net/spnic: support Tx/Rx queue start/stop", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "e145420be1c368f929eb8f475d07c7846d5ca04d", "submitter": { "id": 2455, "url": "http://patches.dpdk.org/api/people/2455/?format=api", "name": "Yanling Song", "email": "songyl@ramaxel.com" }, "delegate": null, "mbox": "http://patches.dpdk.org/project/dpdk/patch/e47ad75bc37b4e56ab30aab959e41c52a985ed3f.1640242368.git.songyl@ramaxel.com/mbox/", "series": [ { "id": 21012, "url": "http://patches.dpdk.org/api/series/21012/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=21012", "date": "2021-12-23T08:23:44", "name": "Net/SPNIC: support SPNIC into DPDK 22.03", "version": 2, "mbox": "http://patches.dpdk.org/series/21012/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/105352/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/105352/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from mails.dpdk.org (mails.dpdk.org [217.70.189.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id 61876A0350;\n\tThu, 23 Dec 2021 09:27:10 +0100 (CET)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 3974B42701;\n\tThu, 23 Dec 2021 09:25:02 +0100 (CET)", "from VLXDG1SPAM1.ramaxel.com (email.ramaxel.com [221.4.138.186])\n by mails.dpdk.org (Postfix) with ESMTP id 9EC0842702\n for <dev@dpdk.org>; Thu, 23 Dec 2021 09:24:59 +0100 (CET)", "from V12DG1MBS01.ramaxel.local (v12dg1mbs01.ramaxel.local\n [172.26.18.31])\n by VLXDG1SPAM1.ramaxel.com with ESMTPS id 1BN8OG7I037299\n (version=TLSv1.2 cipher=AES256-GCM-SHA384 bits=256 verify=FAIL);\n Thu, 23 Dec 2021 16:24:16 +0800 (GMT-8)\n (envelope-from songyl@ramaxel.com)", "from localhost.localdomain (10.64.9.47) by V12DG1MBS01.ramaxel.local\n (172.26.18.31) with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256_P256) id 15.1.2308.14; Thu, 23\n Dec 2021 16:24:16 +0800" ], "From": "Yanling Song <songyl@ramaxel.com>", "To": "<dev@dpdk.org>", "CC": "<songyl@ramaxel.com>, <yanling.song@linux.dev>, <yanggan@ramaxel.com>,\n <xuyun@ramaxel.com>, <ferruh.yigit@intel.com>", "Subject": "[PATCH v2 24/25] net/spnic: support Tx/Rx queue start/stop", "Date": "Thu, 23 Dec 2021 16:24:07 +0800", "Message-ID": "\n <e47ad75bc37b4e56ab30aab959e41c52a985ed3f.1640242368.git.songyl@ramaxel.com>", "X-Mailer": "git-send-email 2.17.1", "In-Reply-To": "<cover.1640242368.git.songyl@ramaxel.com>", "References": "<cover.1640242368.git.songyl@ramaxel.com>", "MIME-Version": "1.0", "Content-Type": "text/plain", "X-Originating-IP": "[10.64.9.47]", "X-ClientProxiedBy": "V12DG1MBS03.ramaxel.local (172.26.18.33) To\n V12DG1MBS01.ramaxel.local (172.26.18.31)", "X-DNSRBL": "", "X-MAIL": "VLXDG1SPAM1.ramaxel.com 1BN8OG7I037299", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n <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 <mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org" }, "content": "This commit support starting or stopping a specified Rx/Tx queue\nFor Rx queue:\n when starting rx queue, mbuf will be allocated and fill rq\nwqe with mbuf info, then add the qid to indirect table of RSS.\nif the first rx queue is started, the valid bit in function table\nwill be set so that the packets can be received to host.\n when stopping rx queue, the PMD driver will poll the rx queue\nuntil it is empty and release the mbuf, then the PMD driver will\nremove the qid for RSS indirect table. if the last rx queue is\nstopped, the valid bit in function table will be cleared.\n\nFor Rx queue:\n when stopping tx queue, the PMD driver will wait until all tx\npackets are sent and then releases all mbuf.\n\nSigned-off-by: Yanling Song <songyl@ramaxel.com>\n---\n drivers/net/spnic/base/spnic_nic_cfg.c | 33 ++++\n drivers/net/spnic/base/spnic_nic_cfg.h | 13 ++\n drivers/net/spnic/spnic_ethdev.c | 82 +++++++++\n drivers/net/spnic/spnic_rx.c | 222 +++++++++++++++++++++++++\n drivers/net/spnic/spnic_rx.h | 4 +\n 5 files changed, 354 insertions(+)", "diff": "diff --git a/drivers/net/spnic/base/spnic_nic_cfg.c b/drivers/net/spnic/base/spnic_nic_cfg.c\nindex e740138b8e..862400de71 100644\n--- a/drivers/net/spnic/base/spnic_nic_cfg.c\n+++ b/drivers/net/spnic/base/spnic_nic_cfg.c\n@@ -1289,6 +1289,39 @@ int spnic_vf_get_default_cos(void *hwdev, u8 *cos_id)\n \treturn 0;\n }\n \n+int spnic_set_rq_flush(void *hwdev, u16 q_id)\n+{\n+\tstruct spnic_cmd_set_rq_flush *rq_flush_msg = NULL;\n+\tstruct spnic_cmd_buf *cmd_buf = NULL;\n+\tu64 out_param = EIO;\n+\tint err;\n+\n+\tcmd_buf = spnic_alloc_cmd_buf(hwdev);\n+\tif (!cmd_buf) {\n+\t\tPMD_DRV_LOG(ERR, \"Failed to allocate cmd buf\\n\");\n+\t\treturn -ENOMEM;\n+\t}\n+\n+\tcmd_buf->size = sizeof(*rq_flush_msg);\n+\n+\trq_flush_msg = cmd_buf->buf;\n+\trq_flush_msg->local_rq_id = q_id;\n+\trq_flush_msg->value = cpu_to_be32(rq_flush_msg->value);\n+\n+\terr = spnic_cmdq_direct_resp(hwdev, SPNIC_MOD_L2NIC,\n+\t\t\t\t SPNIC_UCODE_CMD_SET_RQ_FLUSH, cmd_buf,\n+\t\t\t\t &out_param, 0);\n+\tif (err || out_param != 0) {\n+\t\tPMD_DRV_LOG(ERR, \"Failed to set rq flush, err:%d, out_param: %\" PRIu64 \"\",\n+\t\t\t err, out_param);\n+\t\terr = -EFAULT;\n+\t}\n+\n+\tspnic_free_cmd_buf(cmd_buf);\n+\n+\treturn err;\n+}\n+\n static int _mag_msg_to_mgmt_sync(void *hwdev, u16 cmd, void *buf_in,\n \t\t\t\t u16 in_size, void *buf_out, u16 *out_size)\n {\ndiff --git a/drivers/net/spnic/base/spnic_nic_cfg.h b/drivers/net/spnic/base/spnic_nic_cfg.h\nindex 560c9e4e7d..7c39a32d7c 100644\n--- a/drivers/net/spnic/base/spnic_nic_cfg.h\n+++ b/drivers/net/spnic/base/spnic_nic_cfg.h\n@@ -1069,6 +1069,19 @@ int spnic_set_vlan_fliter(void *hwdev, u32 vlan_filter_ctrl);\n */\n int spnic_vf_get_default_cos(void *hwdev, u8 *cos_id);\n \n+/**\n+ * Flush rx queue resource\n+ *\n+ * @param[in] hwdev\n+ * Device pointer to hwdev\n+ * @param[in] q_id\n+ * rx queue id\n+ *\n+ * @retval zero : Success\n+ * @retval non-zero : Failure\n+ */\n+int spnic_set_rq_flush(void *hwdev, u16 q_id);\n+\n /**\n * Get service feature HW supported\n *\ndiff --git a/drivers/net/spnic/spnic_ethdev.c b/drivers/net/spnic/spnic_ethdev.c\nindex 569d29b429..aae40f9c02 100644\n--- a/drivers/net/spnic/spnic_ethdev.c\n+++ b/drivers/net/spnic/spnic_ethdev.c\n@@ -974,6 +974,80 @@ static void spnic_deinit_mac_addr(struct rte_eth_dev *eth_dev)\n \tspnic_delete_mc_addr_list(nic_dev);\n }\n \n+static int spnic_dev_rx_queue_start(__rte_unused struct rte_eth_dev *dev,\n+\t\t\t\t __rte_unused uint16_t rq_id)\n+{\n+\tstruct spnic_rxq *rxq = NULL;\n+\tint rc;\n+\n+\tif (rq_id < dev->data->nb_rx_queues) {\n+\t\trxq = dev->data->rx_queues[rq_id];\n+\n+\t\trc = spnic_start_rq(dev, rxq);\n+\t\tif (rc) {\n+\t\t\tPMD_DRV_LOG(ERR, \"Start rx queue failed, eth_dev:%s, queue_idx:%d\",\n+\t\t\t\t\tdev->data->name, rq_id);\n+\t\t\treturn rc;\n+\t\t}\n+\n+\t\tdev->data->rx_queue_state[rq_id] = RTE_ETH_QUEUE_STATE_STARTED;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int spnic_dev_rx_queue_stop(__rte_unused struct rte_eth_dev *dev,\n+\t\t\t\t __rte_unused uint16_t rq_id)\n+{\n+\tstruct spnic_rxq *rxq = NULL;\n+\tint rc;\n+\n+\tif (rq_id < dev->data->nb_rx_queues) {\n+\t\trxq = dev->data->rx_queues[rq_id];\n+\n+\t\trc = spnic_stop_rq(dev, rxq);\n+\t\tif (rc) {\n+\t\t\tPMD_DRV_LOG(ERR, \"Stop rx queue failed, eth_dev:%s, queue_idx:%d\",\n+\t\t\t\t\tdev->data->name, rq_id);\n+\t\t\treturn rc;\n+\t\t}\n+\n+\t\tdev->data->rx_queue_state[rq_id] = RTE_ETH_QUEUE_STATE_STOPPED;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int spnic_dev_tx_queue_start(__rte_unused struct rte_eth_dev *dev,\n+\t\t\t\t __rte_unused uint16_t sq_id)\n+{\n+\tPMD_DRV_LOG(INFO, \"Start tx queue, eth_dev:%s, queue_idx:%d\",\n+\t\t dev->data->name, sq_id);\n+\tdev->data->tx_queue_state[sq_id] = RTE_ETH_QUEUE_STATE_STARTED;\n+\treturn 0;\n+}\n+\n+static int spnic_dev_tx_queue_stop(__rte_unused struct rte_eth_dev *dev,\n+\t\t\t\t __rte_unused uint16_t sq_id)\n+{\n+\tstruct spnic_txq *txq = NULL;\n+\tint rc;\n+\n+\tif (sq_id < dev->data->nb_tx_queues) {\n+\t\ttxq = dev->data->tx_queues[sq_id];\n+\t\trc = spnic_stop_sq(txq);\n+\t\tif (rc) {\n+\t\t\tPMD_DRV_LOG(ERR, \"Stop tx queue failed, eth_dev:%s, queue_idx:%d\",\n+\t\t\t\t dev->data->name, sq_id);\n+\t\t\treturn rc;\n+\t\t}\n+\n+\t\tdev->data->tx_queue_state[sq_id] = RTE_ETH_QUEUE_STATE_STOPPED;\n+\t}\n+\n+\treturn 0;\n+}\n+\n int spnic_dev_rx_queue_intr_enable(struct rte_eth_dev *dev,\n \t\t\t\t uint16_t queue_id)\n {\n@@ -2698,6 +2772,10 @@ static const struct eth_dev_ops spnic_pmd_ops = {\n \t.tx_queue_setup = spnic_tx_queue_setup,\n \t.rx_queue_release = spnic_rx_queue_release,\n \t.tx_queue_release = spnic_tx_queue_release,\n+\t.rx_queue_start = spnic_dev_rx_queue_start,\n+\t.rx_queue_stop = spnic_dev_rx_queue_stop,\n+\t.tx_queue_start = spnic_dev_tx_queue_start,\n+\t.tx_queue_stop = spnic_dev_tx_queue_stop,\n \t.rx_queue_intr_enable = spnic_dev_rx_queue_intr_enable,\n \t.rx_queue_intr_disable = spnic_dev_rx_queue_intr_disable,\n \t.dev_start = spnic_dev_start,\n@@ -2733,6 +2811,10 @@ static const struct eth_dev_ops spnic_pmd_vf_ops = {\n \t.tx_queue_setup = spnic_tx_queue_setup,\n \t.rx_queue_intr_enable = spnic_dev_rx_queue_intr_enable,\n \t.rx_queue_intr_disable = spnic_dev_rx_queue_intr_disable,\n+\t.rx_queue_start = spnic_dev_rx_queue_start,\n+\t.rx_queue_stop = spnic_dev_rx_queue_stop,\n+\t.tx_queue_start = spnic_dev_tx_queue_start,\n+\t.tx_queue_stop = spnic_dev_tx_queue_stop,\n \t.dev_start = spnic_dev_start,\n \t.link_update = spnic_link_update,\n \t.rx_queue_release = spnic_rx_queue_release,\ndiff --git a/drivers/net/spnic/spnic_rx.c b/drivers/net/spnic/spnic_rx.c\nindex 2b744aac2a..a26e0b5c45 100644\n--- a/drivers/net/spnic/spnic_rx.c\n+++ b/drivers/net/spnic/spnic_rx.c\n@@ -486,6 +486,228 @@ void spnic_remove_rq_from_rx_queue_list(struct spnic_nic_dev *nic_dev,\n \tnic_dev->num_rss = rss_queue_count;\n }\n \n+static void spnic_rx_queue_release_mbufs(struct spnic_rxq *rxq)\n+{\n+\tu16 sw_ci, ci_mask, free_wqebbs;\n+\tu16 rx_buf_len;\n+\tu32 status, vlan_len, pkt_len;\n+\tu32 pkt_left_len = 0;\n+\tu32 nr_released = 0;\n+\tstruct spnic_rx_info *rx_info;\n+\tvolatile struct spnic_rq_cqe *rx_cqe;\n+\n+\tsw_ci = spnic_get_rq_local_ci(rxq);\n+\trx_info = &rxq->rx_info[sw_ci];\n+\trx_cqe = &rxq->rx_cqe[sw_ci];\n+\tfree_wqebbs = (u16)(spnic_get_rq_free_wqebb(rxq) + 1);\n+\tstatus = rx_cqe->status;\n+\tci_mask = rxq->q_mask;\n+\n+\twhile (free_wqebbs < rxq->q_depth) {\n+\t\trx_buf_len = rxq->buf_len;\n+\t\tif (pkt_left_len != 0) {\n+\t\t\t/* flush continues jumbo rqe */\n+\t\t\tpkt_left_len = (pkt_left_len <= rx_buf_len) ? 0 :\n+\t\t\t\t (pkt_left_len - rx_buf_len);\n+\t\t} else if (SPNIC_GET_RX_FLUSH(status)) {\n+\t\t\t/* flush one released rqe */\n+\t\t\tpkt_left_len = 0;\n+\t\t} else if (SPNIC_GET_RX_DONE(status)) {\n+\t\t\t/* flush single packet or first jumbo rqe */\n+\t\t\tvlan_len = rx_cqe->vlan_len;\n+\t\t\tpkt_len = SPNIC_GET_RX_PKT_LEN(vlan_len);\n+\t\t\tpkt_left_len = (pkt_len <= rx_buf_len) ? 0 :\n+\t\t\t\t (pkt_len - rx_buf_len);\n+\t\t} else {\n+\t\t\tbreak;\n+\t\t}\n+\n+\t\trte_pktmbuf_free(rx_info->mbuf);\n+\n+\t\trx_info->mbuf = NULL;\n+\t\trx_cqe->status = 0;\n+\t\tnr_released++;\n+\t\tfree_wqebbs++;\n+\n+\t\t/* see next cqe */\n+\t\tsw_ci++;\n+\t\tsw_ci &= ci_mask;\n+\t\trx_info = &rxq->rx_info[sw_ci];\n+\t\trx_cqe = &rxq->rx_cqe[sw_ci];\n+\t\tstatus = rx_cqe->status;\n+\t}\n+\n+\tspnic_update_rq_local_ci(rxq, nr_released);\n+}\n+\n+int spnic_poll_rq_empty(struct spnic_rxq *rxq)\n+{\n+\tunsigned long timeout;\n+\tint free_wqebb;\n+\tint err = -EFAULT;\n+\n+\ttimeout = msecs_to_jiffies(SPNIC_FLUSH_QUEUE_TIMEOUT) + jiffies;\n+\tdo {\n+\t\tfree_wqebb = spnic_get_rq_free_wqebb(rxq) + 1;\n+\t\tif (free_wqebb == rxq->q_depth) {\n+\t\t\terr = 0;\n+\t\t\tbreak;\n+\t\t}\n+\t\tspnic_rx_queue_release_mbufs(rxq);\n+\t\trte_delay_us(1);\n+\t} while (time_before(jiffies, timeout));\n+\n+\treturn err;\n+}\n+\n+void spnic_dump_cqe_status(struct spnic_rxq *rxq, u32 *cqe_done_cnt,\n+\t\t\t u32 *cqe_hole_cnt, u32 *head_ci,\n+\t\t\t u32 *head_done)\n+{\n+\tu16 sw_ci;\n+\tu16 avail_pkts = 0;\n+\tu16 hit_done = 0;\n+\tu16 cqe_hole = 0;\n+\tu32 status;\n+\tvolatile struct spnic_rq_cqe *rx_cqe;\n+\n+\tsw_ci = spnic_get_rq_local_ci(rxq);\n+\trx_cqe = &rxq->rx_cqe[sw_ci];\n+\tstatus = rx_cqe->status;\n+\t*head_done = SPNIC_GET_RX_DONE(status);\n+\t*head_ci = sw_ci;\n+\n+\tfor (sw_ci = 0; sw_ci < rxq->q_depth; sw_ci++) {\n+\t\trx_cqe = &rxq->rx_cqe[sw_ci];\n+\n+\t\t/* test current ci is done */\n+\t\tstatus = rx_cqe->status;\n+\t\tif (!SPNIC_GET_RX_DONE(status) ||\n+\t\t !SPNIC_GET_RX_FLUSH(status)) {\n+\t\t\tif (hit_done) {\n+\t\t\t\tcqe_hole++;\n+\t\t\t\thit_done = 0;\n+\t\t\t}\n+\n+\t\t\tcontinue;\n+\t\t}\n+\n+\t\tavail_pkts++;\n+\t\thit_done = 1;\n+\t}\n+\n+\t*cqe_done_cnt = avail_pkts;\n+\t*cqe_hole_cnt = cqe_hole;\n+}\n+\n+int spnic_stop_rq(struct rte_eth_dev *eth_dev, struct spnic_rxq *rxq)\n+{\n+\tstruct spnic_nic_dev *nic_dev = rxq->nic_dev;\n+\tu32 cqe_done_cnt = 0;\n+\tu32 cqe_hole_cnt = 0;\n+\tu32 head_ci, head_done;\n+\tint err;\n+\n+\t/* disable rxq intr */\n+\tspnic_dev_rx_queue_intr_disable(eth_dev, rxq->q_id);\n+\n+\t/* lock dev queue switch */\n+\trte_spinlock_lock(&nic_dev->queue_list_lock);\n+\n+\tspnic_remove_rq_from_rx_queue_list(nic_dev, rxq->q_id);\n+\n+\tif (nic_dev->rss_state == SPNIC_RSS_ENABLE) {\n+\t\terr = spnic_refill_indir_rqid(rxq);\n+\t\tif (err) {\n+\t\t\tPMD_DRV_LOG(ERR, \"Clear rq in indirect table failed, eth_dev:%s, queue_idx:%d\\n\",\n+\t\t\t\t nic_dev->dev_name, rxq->q_id);\n+\t\t\tspnic_add_rq_to_rx_queue_list(nic_dev, rxq->q_id);\n+\t\t\tgoto set_indir_failed;\n+\t\t}\n+\t}\n+\n+\tif (nic_dev->num_rss == 0) {\n+\t\terr = spnic_set_vport_enable(nic_dev->hwdev, false);\n+\t\tif (err) {\n+\t\t\tPMD_DRV_LOG(ERR, \"%s Disable vport failed, rc:%d\",\n+\t\t\t\t nic_dev->dev_name, err);\n+\t\t\tgoto set_vport_failed;\n+\t\t}\n+\t}\n+\n+\t/* unlock dev queue list switch */\n+\trte_spinlock_unlock(&nic_dev->queue_list_lock);\n+\n+\t/* Send flush rq cmd to uCode */\n+\terr = spnic_set_rq_flush(nic_dev->hwdev, rxq->q_id);\n+\tif (err) {\n+\t\tPMD_DRV_LOG(ERR, \"Flush rq failed, eth_dev:%s, queue_idx:%d\\n\",\n+\t\t\t nic_dev->dev_name, rxq->q_id);\n+\t\tgoto rq_flush_failed;\n+\t}\n+\n+\terr = spnic_poll_rq_empty(rxq);\n+\tif (err) {\n+\t\tspnic_dump_cqe_status(rxq, &cqe_done_cnt, &cqe_hole_cnt,\n+\t\t\t\t &head_ci, &head_done);\n+\t\tPMD_DRV_LOG(ERR, \"Poll rq empty timeout, eth_dev:%s, queue_idx:%d, \"\n+\t\t\t \"mbuf_left:%d, cqe_done:%d, cqe_hole:%d, cqe[%d].done=%d\\n\",\n+\t\t\t nic_dev->dev_name, rxq->q_id,\n+\t\t\t rxq->q_depth - spnic_get_rq_free_wqebb(rxq),\n+\t\t\t cqe_done_cnt, cqe_hole_cnt, head_ci, head_done);\n+\t\tgoto poll_rq_failed;\n+\t}\n+\n+\treturn 0;\n+\n+poll_rq_failed:\n+rq_flush_failed:\n+\trte_spinlock_lock(&nic_dev->queue_list_lock);\n+set_vport_failed:\n+\tspnic_add_rq_to_rx_queue_list(nic_dev, rxq->q_id);\n+\tif (nic_dev->rss_state == SPNIC_RSS_ENABLE)\n+\t\t(void)spnic_refill_indir_rqid(rxq);\n+set_indir_failed:\n+\trte_spinlock_unlock(&nic_dev->queue_list_lock);\n+\tspnic_dev_rx_queue_intr_enable(eth_dev, rxq->q_id);\n+\treturn err;\n+}\n+\n+int spnic_start_rq(struct rte_eth_dev *eth_dev, struct spnic_rxq *rxq)\n+{\n+\tstruct spnic_nic_dev *nic_dev = rxq->nic_dev;\n+\tint err = 0;\n+\n+\t/* lock dev queue switch */\n+\trte_spinlock_lock(&nic_dev->queue_list_lock);\n+\n+\tspnic_add_rq_to_rx_queue_list(nic_dev, rxq->q_id);\n+\n+\tspnic_rearm_rxq_mbuf(rxq);\n+\n+\tif (nic_dev->rss_state == SPNIC_RSS_ENABLE) {\n+\t\terr = spnic_refill_indir_rqid(rxq);\n+\t\tif (err) {\n+\t\t\tPMD_DRV_LOG(ERR, \"Refill rq to indrect table failed, eth_dev:%s, queue_idx:%d err:%d\\n\",\n+\t\t\t\t nic_dev->dev_name, rxq->q_id, err);\n+\t\t\tspnic_remove_rq_from_rx_queue_list(nic_dev, rxq->q_id);\n+\t\t}\n+\t}\n+\n+\tif (rxq->nic_dev->num_rss == 1) {\n+\t\terr = spnic_set_vport_enable(nic_dev->hwdev, true);\n+\t\tif (err)\n+\t\t\tPMD_DRV_LOG(ERR, \"%s enable vport failed, err:%d\",\n+\t\t\t\t nic_dev->dev_name, err);\n+\t}\n+\n+\t/* unlock dev queue list switch */\n+\trte_spinlock_unlock(&nic_dev->queue_list_lock);\n+\n+\tspnic_dev_rx_queue_intr_enable(eth_dev, rxq->q_id);\n+\n+\treturn err;\n+}\n \n static inline uint64_t spnic_rx_vlan(uint32_t offload_type, uint32_t vlan_len,\n \t\t\t\t uint16_t *vlan_tci)\ndiff --git a/drivers/net/spnic/spnic_rx.h b/drivers/net/spnic/spnic_rx.h\nindex 79cb092db0..e0a7294230 100644\n--- a/drivers/net/spnic/spnic_rx.h\n+++ b/drivers/net/spnic/spnic_rx.h\n@@ -273,6 +273,10 @@ void spnic_dump_cqe_status(struct spnic_rxq *rxq, u32 *cqe_done_cnt,\n \t\t\t u32 *cqe_hole_cnt, u32 *head_ci,\n \t\t\t u32 *head_done);\n \n+int spnic_stop_rq(struct rte_eth_dev *eth_dev, struct spnic_rxq *rxq);\n+\n+int spnic_start_rq(struct rte_eth_dev *eth_dev, struct spnic_rxq *rxq);\n+\n int spnic_start_all_rqs(struct rte_eth_dev *eth_dev);\n \n u16 spnic_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, u16 nb_pkts);\n", "prefixes": [ "v2", "24/25" ] }