Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/82946/?format=api
{ "id": 82946, "url": "https://patches.dpdk.org/api/patches/82946/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/patch/1604061740-2868-17-git-send-email-timothy.mcdaniel@intel.com/", "project": { "id": 1, "url": "https://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": "<1604061740-2868-17-git-send-email-timothy.mcdaniel@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/1604061740-2868-17-git-send-email-timothy.mcdaniel@intel.com", "date": "2020-10-30T12:42:12", "name": "[v9,16/23] event/dlb: add eventdev start", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "bf1f2cb995fbe60d7c50893a2657ea34397d364b", "submitter": { "id": 826, "url": "https://patches.dpdk.org/api/people/826/?format=api", "name": "Timothy McDaniel", "email": "timothy.mcdaniel@intel.com" }, "delegate": { "id": 310, "url": "https://patches.dpdk.org/api/users/310/?format=api", "username": "jerin", "first_name": "Jerin", "last_name": "Jacob", "email": "jerinj@marvell.com" }, "mbox": "https://patches.dpdk.org/project/dpdk/patch/1604061740-2868-17-git-send-email-timothy.mcdaniel@intel.com/mbox/", "series": [ { "id": 13500, "url": "https://patches.dpdk.org/api/series/13500/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/list/?series=13500", "date": "2020-10-30T12:41:57", "name": "Add DLB PMD", "version": 9, "mbox": "https://patches.dpdk.org/series/13500/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/82946/comments/", "check": "success", "checks": "https://patches.dpdk.org/api/patches/82946/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 dpdk.org (dpdk.org [92.243.14.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id 93E6DA04DE;\n\tFri, 30 Oct 2020 13:47:04 +0100 (CET)", "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id 148B3CA32;\n\tFri, 30 Oct 2020 13:41:15 +0100 (CET)", "from mga18.intel.com (mga18.intel.com [134.134.136.126])\n by dpdk.org (Postfix) with ESMTP id DACF5C90A\n for <dev@dpdk.org>; Fri, 30 Oct 2020 13:40:46 +0100 (CET)", "from fmsmga004.fm.intel.com ([10.253.24.48])\n by orsmga106.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 30 Oct 2020 05:40:46 -0700", "from txasoft-yocto.an.intel.com ([10.123.72.192])\n by fmsmga004.fm.intel.com with ESMTP; 30 Oct 2020 05:40:45 -0700" ], "IronPort-SDR": [ "\n jPK5S3G5G6Nkgw1cChRibxXbtzvPooc828lzUJNbj62qNfNCKP6tZqASnjDMWmxFF20wCjPmnw\n Qm1Is9w6wP7A==", "\n JMzNgTvLRVt1tYggpwx6cY6oiN7TOB7EkNsSLBmRRkO0PIPRhYO6qmX9iqL9cA2MFM4BzaXEwi\n Vcmnz47LfHSw==" ], "X-IronPort-AV": [ "E=McAfee;i=\"6000,8403,9789\"; a=\"156373919\"", "E=Sophos;i=\"5.77,433,1596524400\"; d=\"scan'208\";a=\"156373919\"", "E=Sophos;i=\"5.77,433,1596524400\"; d=\"scan'208\";a=\"351849675\"" ], "X-Amp-Result": "SKIPPED(no attachment in message)", "X-Amp-File-Uploaded": "False", "X-ExtLoop1": "1", "From": "Timothy McDaniel <timothy.mcdaniel@intel.com>", "To": "", "Cc": "dev@dpdk.org, erik.g.carrillo@intel.com, gage.eads@intel.com,\n harry.van.haaren@intel.com, jerinj@marvell.com, thomas@monjalon.net", "Date": "Fri, 30 Oct 2020 07:42:12 -0500", "Message-Id": "<1604061740-2868-17-git-send-email-timothy.mcdaniel@intel.com>", "X-Mailer": "git-send-email 1.7.10", "In-Reply-To": "<1604061740-2868-1-git-send-email-timothy.mcdaniel@intel.com>", "References": "<20200612212434.6852-2-timothy.mcdaniel@intel.com>\n <1604061740-2868-1-git-send-email-timothy.mcdaniel@intel.com>", "Subject": "[dpdk-dev] [PATCH v9 16/23] event/dlb: add eventdev start", "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 <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", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "Add support for the eventdev start entry point.\nDLB delays setting up single link resources until\neventdev start, because it is only then that it can\nascertain which ports have just one linked queue.\n\nSigned-off-by: Timothy McDaniel <timothy.mcdaniel@intel.com>\nReviewed-by: Gage Eads <gage.eads@intel.com>\n---\n drivers/event/dlb/dlb.c | 224 +++++++++++++++++++++++++------\n drivers/event/dlb/dlb_iface.c | 3 +\n drivers/event/dlb/dlb_iface.h | 3 +\n drivers/event/dlb/pf/base/dlb_resource.c | 142 ++++++++++++++++++++\n drivers/event/dlb/pf/dlb_pf.c | 23 ++++\n 5 files changed, 351 insertions(+), 44 deletions(-)", "diff": "diff --git a/drivers/event/dlb/dlb.c b/drivers/event/dlb/dlb.c\nindex c64f559..780ff7d 100644\n--- a/drivers/event/dlb/dlb.c\n+++ b/drivers/event/dlb/dlb.c\n@@ -1626,6 +1626,47 @@ dlb_eventdev_port_setup(struct rte_eventdev *dev,\n }\n \n static int\n+dlb_eventdev_reapply_configuration(struct rte_eventdev *dev)\n+{\n+\tstruct dlb_eventdev *dlb = dlb_pmd_priv(dev);\n+\tint ret, i;\n+\n+\t/* If an event queue or port was previously configured, but hasn't been\n+\t * reconfigured, reapply its original configuration.\n+\t */\n+\tfor (i = 0; i < dlb->num_queues; i++) {\n+\t\tstruct dlb_eventdev_queue *ev_queue;\n+\n+\t\tev_queue = &dlb->ev_queues[i];\n+\n+\t\tif (ev_queue->qm_queue.config_state != DLB_PREV_CONFIGURED)\n+\t\t\tcontinue;\n+\n+\t\tret = dlb_eventdev_queue_setup(dev, i, &ev_queue->conf);\n+\t\tif (ret < 0) {\n+\t\t\tDLB_LOG_ERR(\"dlb: failed to reconfigure queue %d\", i);\n+\t\t\treturn ret;\n+\t\t}\n+\t}\n+\n+\tfor (i = 0; i < dlb->num_ports; i++) {\n+\t\tstruct dlb_eventdev_port *ev_port = &dlb->ev_ports[i];\n+\n+\t\tif (ev_port->qm_port.config_state != DLB_PREV_CONFIGURED)\n+\t\t\tcontinue;\n+\n+\t\tret = dlb_eventdev_port_setup(dev, i, &ev_port->conf);\n+\t\tif (ret < 0) {\n+\t\t\tDLB_LOG_ERR(\"dlb: failed to reconfigure ev_port %d\",\n+\t\t\t\t i);\n+\t\t\treturn ret;\n+\t\t}\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n set_dev_id(const char *key __rte_unused,\n \t const char *value,\n \t void *opaque)\n@@ -1761,6 +1802,50 @@ dlb_validate_port_link(struct dlb_eventdev_port *ev_port,\n \treturn 0;\n }\n \n+static int32_t\n+dlb_hw_create_dir_queue(struct dlb_eventdev *dlb, int32_t qm_port_id)\n+{\n+\tstruct dlb_hw_dev *handle = &dlb->qm_instance;\n+\tstruct dlb_create_dir_queue_args cfg;\n+\tstruct dlb_cmd_response response;\n+\tint32_t ret;\n+\n+\tcfg.response = (uintptr_t)&response;\n+\n+\t/* The directed port is always configured before its queue */\n+\tcfg.port_id = qm_port_id;\n+\n+\tret = dlb_iface_dir_queue_create(handle, &cfg);\n+\tif (ret < 0) {\n+\t\tDLB_LOG_ERR(\"dlb: create DIR event queue error, ret=%d (driver status: %s)\\n\",\n+\t\t\t ret, dlb_error_strings[response.status]);\n+\t\treturn -EINVAL;\n+\t}\n+\n+\treturn response.id;\n+}\n+\n+static int\n+dlb_eventdev_dir_queue_setup(struct dlb_eventdev *dlb,\n+\t\t\t struct dlb_eventdev_queue *ev_queue,\n+\t\t\t struct dlb_eventdev_port *ev_port)\n+{\n+\tint32_t qm_qid;\n+\n+\tqm_qid = dlb_hw_create_dir_queue(dlb, ev_port->qm_port.id);\n+\n+\tif (qm_qid < 0) {\n+\t\tDLB_LOG_ERR(\"Failed to create the DIR queue\\n\");\n+\t\treturn qm_qid;\n+\t}\n+\n+\tdlb->qm_dir_to_ev_queue_id[qm_qid] = ev_queue->id;\n+\n+\tev_queue->qm_queue.id = qm_qid;\n+\n+\treturn 0;\n+}\n+\n static int16_t\n dlb_hw_map_ldb_qid_to_port(struct dlb_hw_dev *handle,\n \t\t\t uint32_t qm_port_id,\n@@ -1836,50 +1921,6 @@ dlb_event_queue_join_ldb(struct dlb_eventdev *dlb,\n \treturn ret;\n }\n \n-static int32_t\n-dlb_hw_create_dir_queue(struct dlb_eventdev *dlb, int32_t qm_port_id)\n-{\n-\tstruct dlb_hw_dev *handle = &dlb->qm_instance;\n-\tstruct dlb_create_dir_queue_args cfg;\n-\tstruct dlb_cmd_response response;\n-\tint32_t ret;\n-\n-\tcfg.response = (uintptr_t)&response;\n-\n-\t/* The directed port is always configured before its queue */\n-\tcfg.port_id = qm_port_id;\n-\n-\tret = dlb_iface_dir_queue_create(handle, &cfg);\n-\tif (ret < 0) {\n-\t\tDLB_LOG_ERR(\"dlb: create DIR event queue error, ret=%d (driver status: %s)\\n\",\n-\t\t\t ret, dlb_error_strings[response.status]);\n-\t\treturn -EINVAL;\n-\t}\n-\n-\treturn response.id;\n-}\n-\n-static int\n-dlb_eventdev_dir_queue_setup(struct dlb_eventdev *dlb,\n-\t\t\t struct dlb_eventdev_queue *ev_queue,\n-\t\t\t struct dlb_eventdev_port *ev_port)\n-{\n-\tint32_t qm_qid;\n-\n-\tqm_qid = dlb_hw_create_dir_queue(dlb, ev_port->qm_port.id);\n-\n-\tif (qm_qid < 0) {\n-\t\tDLB_LOG_ERR(\"Failed to create the DIR queue\\n\");\n-\t\treturn qm_qid;\n-\t}\n-\n-\tdlb->qm_dir_to_ev_queue_id[qm_qid] = ev_queue->id;\n-\n-\tev_queue->qm_queue.id = qm_qid;\n-\n-\treturn 0;\n-}\n-\n static int\n dlb_do_port_link(struct rte_eventdev *dev,\n \t\t struct dlb_eventdev_queue *ev_queue,\n@@ -1911,6 +1952,40 @@ dlb_do_port_link(struct rte_eventdev *dev,\n }\n \n static int\n+dlb_eventdev_apply_port_links(struct rte_eventdev *dev)\n+{\n+\tstruct dlb_eventdev *dlb = dlb_pmd_priv(dev);\n+\tint i;\n+\n+\t/* Perform requested port->queue links */\n+\tfor (i = 0; i < dlb->num_ports; i++) {\n+\t\tstruct dlb_eventdev_port *ev_port = &dlb->ev_ports[i];\n+\t\tint j;\n+\n+\t\tfor (j = 0; j < DLB_MAX_NUM_QIDS_PER_LDB_CQ; j++) {\n+\t\t\tstruct dlb_eventdev_queue *ev_queue;\n+\t\t\tuint8_t prio, queue_id;\n+\n+\t\t\tif (!ev_port->link[j].valid)\n+\t\t\t\tcontinue;\n+\n+\t\t\tprio = ev_port->link[j].priority;\n+\t\t\tqueue_id = ev_port->link[j].queue_id;\n+\n+\t\t\tif (dlb_validate_port_link(ev_port, queue_id, true, j))\n+\t\t\t\treturn -EINVAL;\n+\n+\t\t\tev_queue = &dlb->ev_queues[queue_id];\n+\n+\t\t\tif (dlb_do_port_link(dev, ev_queue, ev_port, prio))\n+\t\t\t\treturn -EINVAL;\n+\t\t}\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n dlb_eventdev_port_link(struct rte_eventdev *dev, void *event_port,\n \t\t const uint8_t queues[], const uint8_t priorities[],\n \t\t uint16_t nb_links)\n@@ -2000,12 +2075,73 @@ dlb_eventdev_port_link(struct rte_eventdev *dev, void *event_port,\n \treturn i;\n }\n \n+static int\n+dlb_eventdev_start(struct rte_eventdev *dev)\n+{\n+\tstruct dlb_eventdev *dlb = dlb_pmd_priv(dev);\n+\tstruct dlb_hw_dev *handle = &dlb->qm_instance;\n+\tstruct dlb_start_domain_args cfg;\n+\tstruct dlb_cmd_response response;\n+\tint ret, i;\n+\n+\trte_spinlock_lock(&dlb->qm_instance.resource_lock);\n+\tif (dlb->run_state != DLB_RUN_STATE_STOPPED) {\n+\t\tDLB_LOG_ERR(\"bad state %d for dev_start\\n\",\n+\t\t\t (int)dlb->run_state);\n+\t\trte_spinlock_unlock(&dlb->qm_instance.resource_lock);\n+\t\treturn -EINVAL;\n+\t}\n+\tdlb->run_state\t= DLB_RUN_STATE_STARTING;\n+\trte_spinlock_unlock(&dlb->qm_instance.resource_lock);\n+\n+\t/* If the device was configured more than once, some event ports and/or\n+\t * queues may need to be reconfigured.\n+\t */\n+\tret = dlb_eventdev_reapply_configuration(dev);\n+\tif (ret)\n+\t\treturn ret;\n+\n+\t/* The DLB PMD delays port links until the device is started. */\n+\tret = dlb_eventdev_apply_port_links(dev);\n+\tif (ret)\n+\t\treturn ret;\n+\n+\tcfg.response = (uintptr_t)&response;\n+\n+\tfor (i = 0; i < dlb->num_ports; i++) {\n+\t\tif (!dlb->ev_ports[i].setup_done) {\n+\t\t\tDLB_LOG_ERR(\"dlb: port %d not setup\", i);\n+\t\t\treturn -ESTALE;\n+\t\t}\n+\t}\n+\n+\tfor (i = 0; i < dlb->num_queues; i++) {\n+\t\tif (dlb->ev_queues[i].num_links == 0) {\n+\t\t\tDLB_LOG_ERR(\"dlb: queue %d is not linked\", i);\n+\t\t\treturn -ENOLINK;\n+\t\t}\n+\t}\n+\n+\tret = dlb_iface_sched_domain_start(handle, &cfg);\n+\tif (ret < 0) {\n+\t\tDLB_LOG_ERR(\"dlb: sched_domain_start ret=%d (driver status: %s)\\n\",\n+\t\t\t ret, dlb_error_strings[response.status]);\n+\t\treturn ret;\n+\t}\n+\n+\tdlb->run_state = DLB_RUN_STATE_STARTED;\n+\tDLB_LOG_DBG(\"dlb: sched_domain_start completed OK\\n\");\n+\n+\treturn 0;\n+}\n+\n void\n dlb_entry_points_init(struct rte_eventdev *dev)\n {\n \tstatic struct rte_eventdev_ops dlb_eventdev_entry_ops = {\n \t\t.dev_infos_get = dlb_eventdev_info_get,\n \t\t.dev_configure = dlb_eventdev_configure,\n+\t\t.dev_start = dlb_eventdev_start,\n \t\t.queue_def_conf = dlb_eventdev_queue_default_conf_get,\n \t\t.port_def_conf = dlb_eventdev_port_default_conf_get,\n \t\t.queue_setup = dlb_eventdev_queue_setup,\ndiff --git a/drivers/event/dlb/dlb_iface.c b/drivers/event/dlb/dlb_iface.c\nindex aaf4506..22d524b 100644\n--- a/drivers/event/dlb/dlb_iface.c\n+++ b/drivers/event/dlb/dlb_iface.c\n@@ -53,6 +53,9 @@ int (*dlb_iface_map_qid)(struct dlb_hw_dev *handle,\n int (*dlb_iface_unmap_qid)(struct dlb_hw_dev *handle,\n \t\t\t struct dlb_unmap_qid_args *cfg);\n \n+int (*dlb_iface_sched_domain_start)(struct dlb_hw_dev *handle,\n+\t\t\t\t struct dlb_start_domain_args *cfg);\n+\n int (*dlb_iface_pending_port_unmaps)(struct dlb_hw_dev *handle,\n \t\t\t\t struct dlb_pending_port_unmaps_args *args);\n \ndiff --git a/drivers/event/dlb/dlb_iface.h b/drivers/event/dlb/dlb_iface.h\nindex c0f5f2e..8c905ab 100644\n--- a/drivers/event/dlb/dlb_iface.h\n+++ b/drivers/event/dlb/dlb_iface.h\n@@ -55,6 +55,9 @@ extern int (*dlb_iface_map_qid)(struct dlb_hw_dev *handle,\n extern int (*dlb_iface_unmap_qid)(struct dlb_hw_dev *handle,\n \t\t\t\t struct dlb_unmap_qid_args *cfg);\n \n+extern int (*dlb_iface_sched_domain_start)(struct dlb_hw_dev *handle,\n+\t\t\t\t struct dlb_start_domain_args *cfg);\n+\n extern int (*dlb_iface_pending_port_unmaps)(struct dlb_hw_dev *handle,\n \t\t\t\tstruct dlb_pending_port_unmaps_args *args);\n \ndiff --git a/drivers/event/dlb/pf/base/dlb_resource.c b/drivers/event/dlb/pf/base/dlb_resource.c\nindex 2d0b1d0..6dad99d 100644\n--- a/drivers/event/dlb/pf/base/dlb_resource.c\n+++ b/drivers/event/dlb/pf/base/dlb_resource.c\n@@ -6410,6 +6410,32 @@ static int dlb_verify_map_qid_args(struct dlb_hw *hw,\n \treturn 0;\n }\n \n+static int dlb_verify_start_domain_args(struct dlb_hw *hw,\n+\t\t\t\t\tu32 domain_id,\n+\t\t\t\t\tstruct dlb_cmd_response *resp)\n+{\n+\tstruct dlb_domain *domain;\n+\n+\tdomain = dlb_get_domain_from_id(hw, domain_id);\n+\n+\tif (domain == NULL) {\n+\t\tresp->status = DLB_ST_INVALID_DOMAIN_ID;\n+\t\treturn -1;\n+\t}\n+\n+\tif (!domain->configured) {\n+\t\tresp->status = DLB_ST_DOMAIN_NOT_CONFIGURED;\n+\t\treturn -1;\n+\t}\n+\n+\tif (domain->started) {\n+\t\tresp->status = DLB_ST_DOMAIN_STARTED;\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n static int dlb_verify_map_qid_slot_available(struct dlb_ldb_port *port,\n \t\t\t\t\t struct dlb_ldb_queue *queue,\n \t\t\t\t\t struct dlb_cmd_response *resp)\n@@ -6671,3 +6697,119 @@ int dlb_hw_map_qid(struct dlb_hw *hw,\n \treturn 0;\n }\n \n+static void dlb_log_start_domain(struct dlb_hw *hw, u32 domain_id)\n+{\n+\tDLB_HW_INFO(hw, \"DLB start domain arguments:\\n\");\n+\tDLB_HW_INFO(hw, \"\\tDomain ID: %d\\n\", domain_id);\n+}\n+\n+static void dlb_ldb_pool_write_credit_count_reg(struct dlb_hw *hw,\n+\t\t\t\t\t\tu32 pool_id)\n+{\n+\tunion dlb_chp_ldb_pool_crd_cnt r0 = { {0} };\n+\tstruct dlb_credit_pool *pool;\n+\n+\tpool = &hw->rsrcs.ldb_credit_pools[pool_id];\n+\n+\tr0.field.count = pool->avail_credits;\n+\n+\tDLB_CSR_WR(hw,\n+\t\t DLB_CHP_LDB_POOL_CRD_CNT(pool->id),\n+\t\t r0.val);\n+}\n+\n+static void dlb_dir_pool_write_credit_count_reg(struct dlb_hw *hw,\n+\t\t\t\t\t\tu32 pool_id)\n+{\n+\tunion dlb_chp_dir_pool_crd_cnt r0 = { {0} };\n+\tstruct dlb_credit_pool *pool;\n+\n+\tpool = &hw->rsrcs.dir_credit_pools[pool_id];\n+\n+\tr0.field.count = pool->avail_credits;\n+\n+\tDLB_CSR_WR(hw,\n+\t\t DLB_CHP_DIR_POOL_CRD_CNT(pool->id),\n+\t\t r0.val);\n+}\n+\n+/**\n+ * dlb_hw_start_domain() - Lock the domain configuration\n+ * @hw:\t Contains the current state of the DLB hardware.\n+ * @args: User-provided arguments.\n+ * @resp: Response to user.\n+ *\n+ * Return: returns < 0 on error, 0 otherwise. If the driver is unable to\n+ * satisfy a request, resp->status will be set accordingly.\n+ */\n+int dlb_hw_start_domain(struct dlb_hw *hw,\n+\t\t\tu32 domain_id,\n+\t\t\tstruct dlb_start_domain_args *arg,\n+\t\t\tstruct dlb_cmd_response *resp)\n+{\n+\tstruct dlb_list_entry *iter;\n+\tstruct dlb_dir_pq_pair *dir_queue;\n+\tstruct dlb_ldb_queue *ldb_queue;\n+\tstruct dlb_credit_pool *pool;\n+\tstruct dlb_domain *domain;\n+\tRTE_SET_USED(arg);\n+\tRTE_SET_USED(iter);\n+\n+\tdlb_log_start_domain(hw, domain_id);\n+\n+\tif (dlb_verify_start_domain_args(hw, domain_id, resp))\n+\t\treturn -EINVAL;\n+\n+\tdomain = dlb_get_domain_from_id(hw, domain_id);\n+\tif (domain == NULL) {\n+\t\tDLB_HW_ERR(hw,\n+\t\t\t \"[%s():%d] Internal error: domain not found\\n\",\n+\t\t\t __func__, __LINE__);\n+\t\treturn -EFAULT;\n+\t}\n+\n+\t/* Write the domain's pool credit counts, which have been updated\n+\t * during port configuration. The sum of the pool credit count plus\n+\t * each producer port's credit count must equal the pool's credit\n+\t * allocation *before* traffic is sent.\n+\t */\n+\tDLB_DOM_LIST_FOR(domain->used_ldb_credit_pools, pool, iter)\n+\t\tdlb_ldb_pool_write_credit_count_reg(hw, pool->id);\n+\n+\tDLB_DOM_LIST_FOR(domain->used_dir_credit_pools, pool, iter)\n+\t\tdlb_dir_pool_write_credit_count_reg(hw, pool->id);\n+\n+\t/* Enable load-balanced and directed queue write permissions for the\n+\t * queues this domain owns. Without this, the DLB will drop all\n+\t * incoming traffic to those queues.\n+\t */\n+\tDLB_DOM_LIST_FOR(domain->used_ldb_queues, ldb_queue, iter) {\n+\t\tunion dlb_sys_ldb_vasqid_v r0 = { {0} };\n+\t\tunsigned int offs;\n+\n+\t\tr0.field.vasqid_v = 1;\n+\n+\t\toffs = domain->id * DLB_MAX_NUM_LDB_QUEUES + ldb_queue->id;\n+\n+\t\tDLB_CSR_WR(hw, DLB_SYS_LDB_VASQID_V(offs), r0.val);\n+\t}\n+\n+\tDLB_DOM_LIST_FOR(domain->used_dir_pq_pairs, dir_queue, iter) {\n+\t\tunion dlb_sys_dir_vasqid_v r0 = { {0} };\n+\t\tunsigned int offs;\n+\n+\t\tr0.field.vasqid_v = 1;\n+\n+\t\toffs = domain->id * DLB_MAX_NUM_DIR_PORTS + dir_queue->id;\n+\n+\t\tDLB_CSR_WR(hw, DLB_SYS_DIR_VASQID_V(offs), r0.val);\n+\t}\n+\n+\tdlb_flush_csr(hw);\n+\n+\tdomain->started = true;\n+\n+\tresp->status = 0;\n+\n+\treturn 0;\n+}\ndiff --git a/drivers/event/dlb/pf/dlb_pf.c b/drivers/event/dlb/pf/dlb_pf.c\nindex fed6719..1d2e133 100644\n--- a/drivers/event/dlb/pf/dlb_pf.c\n+++ b/drivers/event/dlb/pf/dlb_pf.c\n@@ -483,6 +483,28 @@ dlb_pf_get_sn_occupancy(struct dlb_hw_dev *handle,\n }\n \n static int\n+dlb_pf_sched_domain_start(struct dlb_hw_dev *handle,\n+\t\t\t struct dlb_start_domain_args *cfg)\n+{\n+\tstruct dlb_dev *dlb_dev = (struct dlb_dev *)handle->pf_dev;\n+\tstruct dlb_cmd_response response = {0};\n+\tint ret;\n+\n+\tDLB_INFO(dev->dlb_device, \"Entering %s()\\n\", __func__);\n+\n+\tret = dlb_hw_start_domain(&dlb_dev->hw,\n+\t\t\t\t handle->domain_id,\n+\t\t\t\t cfg,\n+\t\t\t\t &response);\n+\n+\t*(struct dlb_cmd_response *)cfg->response = response;\n+\n+\tDLB_INFO(dev->dlb_device, \"Exiting %s() with ret=%d\\n\", __func__, ret);\n+\n+\treturn ret;\n+}\n+\n+static int\n dlb_pf_pending_port_unmaps(struct dlb_hw_dev *handle,\n \t\t\t struct dlb_pending_port_unmaps_args *args)\n {\n@@ -565,6 +587,7 @@ dlb_pf_iface_fn_ptrs_init(void)\n \tdlb_iface_dir_port_create = dlb_pf_dir_port_create;\n \tdlb_iface_map_qid = dlb_pf_map_qid;\n \tdlb_iface_unmap_qid = dlb_pf_unmap_qid;\n+\tdlb_iface_sched_domain_start = dlb_pf_sched_domain_start;\n \tdlb_iface_pending_port_unmaps = dlb_pf_pending_port_unmaps;\n \tdlb_iface_get_cq_poll_mode = dlb_pf_get_cq_poll_mode;\n \tdlb_iface_get_sn_allocation = dlb_pf_get_sn_allocation;\n", "prefixes": [ "v9", "16/23" ] }