Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/105525/?format=api
{ "id": 105525, "url": "http://patches.dpdk.org/api/patches/105525/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/661cc77bf5c3c37b0001b4ea57b17f2f706b9bcb.1640838702.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": "<661cc77bf5c3c37b0001b4ea57b17f2f706b9bcb.1640838702.git.songyl@ramaxel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/661cc77bf5c3c37b0001b4ea57b17f2f706b9bcb.1640838702.git.songyl@ramaxel.com", "date": "2021-12-30T06:09:02", "name": "[v6,24/26] net/spnic: support Tx/Rx queue start/stop", "commit_ref": null, "pull_url": null, "state": "changes-requested", "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": { "id": 319, "url": "http://patches.dpdk.org/api/users/319/?format=api", "username": "fyigit", "first_name": "Ferruh", "last_name": "Yigit", "email": "ferruh.yigit@amd.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/661cc77bf5c3c37b0001b4ea57b17f2f706b9bcb.1640838702.git.songyl@ramaxel.com/mbox/", "series": [ { "id": 21040, "url": "http://patches.dpdk.org/api/series/21040/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=21040", "date": "2021-12-30T06:08:40", "name": "Net/SPNIC: support SPNIC into DPDK 22.03", "version": 6, "mbox": "http://patches.dpdk.org/series/21040/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/105525/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/105525/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 3F20BA00C5;\n\tThu, 30 Dec 2021 07:12:15 +0100 (CET)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id E25744270F;\n\tThu, 30 Dec 2021 07:10:08 +0100 (CET)", "from VLXDG1SPAM1.ramaxel.com (email.ramaxel.com [221.4.138.186])\n by mails.dpdk.org (Postfix) with ESMTP id 26D11426FF\n for <dev@dpdk.org>; Thu, 30 Dec 2021 07:10:03 +0100 (CET)", "from V12DG1MBS01.ramaxel.local (v12dg1mbs01.ramaxel.local\n [172.26.18.31])\n by VLXDG1SPAM1.ramaxel.com with ESMTPS id 1BU69DWo040086\n (version=TLSv1.2 cipher=AES256-GCM-SHA384 bits=256 verify=FAIL);\n Thu, 30 Dec 2021 14:09:15 +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, 30\n Dec 2021 14:09:15 +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>,\n <stephen@networkplumber.org>, <lihuisong@huawei.com>", "Subject": "[PATCH v6 24/26] net/spnic: support Tx/Rx queue start/stop", "Date": "Thu, 30 Dec 2021 14:09:02 +0800", "Message-ID": "\n <661cc77bf5c3c37b0001b4ea57b17f2f706b9bcb.1640838702.git.songyl@ramaxel.com>", "X-Mailer": "git-send-email 2.17.1", "In-Reply-To": "<cover.1640838702.git.songyl@ramaxel.com>", "References": "<cover.1640838702.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 1BU69DWo040086", "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 32d52bd81e..78561a5c64 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 3c996e2838..c73191dc81 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 d6aab64a57..035ad0d1e7 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@@ -2737,6 +2815,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 a835f8066a..8d307ef7a0 100644\n--- a/drivers/net/spnic/spnic_rx.c\n+++ b/drivers/net/spnic/spnic_rx.c\n@@ -467,6 +467,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": [ "v6", "24/26" ] }