From: Hemant Agrawal <hemant.agrawal@nxp.com>
To: dev@dpdk.org
Cc: ferruh.yigit@amd.com, Jun Yang <jun.yang@nxp.com>
Subject: [PATCH v4 08/18] net/dpaa: share MAC FMC scheme and CC parse
Date: Mon, 30 Sep 2024 17:45:15 +0530 [thread overview]
Message-ID: <20240930121525.3452847-9-hemant.agrawal@nxp.com> (raw)
In-Reply-To: <20240930121525.3452847-1-hemant.agrawal@nxp.com>
From: Jun Yang <jun.yang@nxp.com>
For Shared MAC:
1) Allocate RXQ from VSP scheme. (Virtual Storage Profile)
2) Allocate RXQ from Coarse classifiation (CC) rules to VSP.
2) Remove RXQ allocated which is reconfigured without VSP.
3) Don't alloc default queue and err queues.
Signed-off-by: Jun Yang <jun.yang@nxp.com>
Acked-by: Hemant Agrawal <hemant.agrawal@nxp.com>
---
drivers/bus/dpaa/include/fman.h | 1 +
drivers/net/dpaa/dpaa_ethdev.c | 60 +++--
drivers/net/dpaa/dpaa_ethdev.h | 13 +-
drivers/net/dpaa/dpaa_flow.c | 8 +-
drivers/net/dpaa/dpaa_fmc.c | 421 ++++++++++++++++++++------------
drivers/net/dpaa/dpaa_rxtx.c | 20 +-
6 files changed, 346 insertions(+), 177 deletions(-)
diff --git a/drivers/bus/dpaa/include/fman.h b/drivers/bus/dpaa/include/fman.h
index 60681068ea..6b2a1893f9 100644
--- a/drivers/bus/dpaa/include/fman.h
+++ b/drivers/bus/dpaa/include/fman.h
@@ -76,6 +76,7 @@ enum fman_mac_type {
fman_mac_1g,
fman_mac_10g,
fman_mac_2_5g,
+ fman_onic,
};
struct mac_addr {
diff --git a/drivers/net/dpaa/dpaa_ethdev.c b/drivers/net/dpaa/dpaa_ethdev.c
index 3ee3029729..bf14d73433 100644
--- a/drivers/net/dpaa/dpaa_ethdev.c
+++ b/drivers/net/dpaa/dpaa_ethdev.c
@@ -255,7 +255,6 @@ dpaa_eth_dev_configure(struct rte_eth_dev *dev)
DPAA_PMD_ERR("Cannot open IF socket");
return -errno;
}
-
strncpy(ifr.ifr_name, dpaa_intf->name, IFNAMSIZ - 1);
if (ioctl(socket_fd, SIOCGIFMTU, &ifr) < 0) {
@@ -1893,6 +1892,7 @@ dpaa_tx_conf_queue_init(struct qman_fq *fq)
return ret;
}
+#if defined(RTE_LIBRTE_DPAA_DEBUG_DRIVER)
/* Initialise a DEBUG FQ ([rt]x_error, rx_default) */
static int dpaa_def_queue_init(struct qman_fq *fq, uint32_t fqid)
{
@@ -1923,6 +1923,7 @@ static int dpaa_def_queue_init(struct qman_fq *fq, uint32_t fqid)
fqid, ret);
return ret;
}
+#endif
/* Initialise a network interface */
static int
@@ -1957,6 +1958,41 @@ dpaa_dev_init_secondary(struct rte_eth_dev *eth_dev)
return 0;
}
+#ifdef RTE_LIBRTE_DPAA_DEBUG_DRIVER
+static int
+dpaa_error_queue_init(struct dpaa_if *dpaa_intf,
+ struct fman_if *fman_intf)
+{
+ int i, ret;
+ struct qman_fq *err_queues = dpaa_intf->debug_queues;
+ uint32_t err_fqid = 0;
+
+ if (fman_intf->is_shared_mac) {
+ DPAA_PMD_DEBUG("Shared MAC's err queues are handled in kernel");
+ return 0;
+ }
+
+ for (i = 0; i < DPAA_DEBUG_FQ_MAX_NUM; i++) {
+ if (i == DPAA_DEBUG_FQ_RX_ERROR)
+ err_fqid = fman_intf->fqid_rx_err;
+ else if (i == DPAA_DEBUG_FQ_TX_ERROR)
+ err_fqid = fman_intf->fqid_tx_err;
+ else
+ continue;
+ ret = dpaa_def_queue_init(&err_queues[i], err_fqid);
+ if (ret) {
+ DPAA_PMD_ERR("DPAA %s ERROR queue init failed!",
+ i == DPAA_DEBUG_FQ_RX_ERROR ?
+ "RX" : "TX");
+ return ret;
+ }
+ err_queues[i].dpaa_intf = dpaa_intf;
+ }
+
+ return 0;
+}
+#endif
+
static int
check_devargs_handler(__rte_unused const char *key, const char *value,
__rte_unused void *opaque)
@@ -2202,25 +2238,11 @@ dpaa_dev_init(struct rte_eth_dev *eth_dev)
}
}
dpaa_intf->nb_tx_queues = MAX_DPAA_CORES;
-
-#if !defined(RTE_LIBRTE_DPAA_DEBUG_DRIVER)
- if (dpaa_ieee_1588)
+#if defined(RTE_LIBRTE_DPAA_DEBUG_DRIVER)
+ ret = dpaa_error_queue_init(dpaa_intf, fman_intf);
+ if (ret)
+ goto free_tx;
#endif
- {
- ret = dpaa_def_queue_init(&dpaa_intf->debug_queues
- [DPAA_DEBUG_FQ_RX_ERROR], fman_intf->fqid_rx_err);
- if (ret) {
- DPAA_PMD_ERR("DPAA RX ERROR queue init failed!");
- goto free_tx;
- }
- dpaa_intf->debug_queues[DPAA_DEBUG_FQ_RX_ERROR].dpaa_intf = dpaa_intf;
- ret = dpaa_def_queue_init(&dpaa_intf->debug_queues
- [DPAA_DEBUG_FQ_TX_ERROR], fman_intf->fqid_tx_err);
- if (ret) {
- DPAA_PMD_ERR("DPAA TX ERROR queue init failed!");
- goto free_tx;
- }
- }
DPAA_PMD_DEBUG("All frame queues created");
/* Get the initial configuration for flow control */
diff --git a/drivers/net/dpaa/dpaa_ethdev.h b/drivers/net/dpaa/dpaa_ethdev.h
index b427b29cb6..0a1ceb376a 100644
--- a/drivers/net/dpaa/dpaa_ethdev.h
+++ b/drivers/net/dpaa/dpaa_ethdev.h
@@ -78,8 +78,11 @@
#define DPAA_IF_RX_CONTEXT_STASH 0
/* Each "debug" FQ is represented by one of these */
-#define DPAA_DEBUG_FQ_RX_ERROR 0
-#define DPAA_DEBUG_FQ_TX_ERROR 1
+enum {
+ DPAA_DEBUG_FQ_RX_ERROR,
+ DPAA_DEBUG_FQ_TX_ERROR,
+ DPAA_DEBUG_FQ_MAX_NUM
+};
#define DPAA_RSS_OFFLOAD_ALL ( \
RTE_ETH_RSS_L2_PAYLOAD | \
@@ -107,6 +110,10 @@
#define DPAA_FD_CMD_CFQ 0x00ffffff
/**< Confirmation Frame Queue */
+#define DPAA_1G_MAC_START_IDX 1
+#define DPAA_10G_MAC_START_IDX 9
+#define DPAA_2_5G_MAC_START_IDX DPAA_10G_MAC_START_IDX
+
#define DPAA_DEFAULT_RXQ_VSP_ID 1
#define FMC_FILE "/tmp/fmc.bin"
@@ -134,7 +141,7 @@ struct dpaa_if {
struct qman_fq *tx_queues;
struct qman_fq *tx_conf_queues;
struct qman_cgr *cgr_tx;
- struct qman_fq debug_queues[2];
+ struct qman_fq debug_queues[DPAA_DEBUG_FQ_MAX_NUM];
uint16_t nb_rx_queues;
uint16_t nb_tx_queues;
uint32_t ifid;
diff --git a/drivers/net/dpaa/dpaa_flow.c b/drivers/net/dpaa/dpaa_flow.c
index 02aca78d05..082bd5d014 100644
--- a/drivers/net/dpaa/dpaa_flow.c
+++ b/drivers/net/dpaa/dpaa_flow.c
@@ -651,7 +651,13 @@ static inline int set_pcd_netenv_scheme(struct dpaa_if *dpaa_intf,
static inline int get_port_type(struct fman_if *fif)
{
- if (fif->mac_type == fman_mac_1g)
+ /* For 1G fm-mac9 and fm-mac10 ports, configure the VSP as 10G
+ * ports so that kernel can configure correct port.
+ */
+ if (fif->mac_type == fman_mac_1g &&
+ fif->mac_idx >= DPAA_10G_MAC_START_IDX)
+ return e_FM_PORT_TYPE_RX_10G;
+ else if (fif->mac_type == fman_mac_1g)
return e_FM_PORT_TYPE_RX;
else if (fif->mac_type == fman_mac_2_5g)
return e_FM_PORT_TYPE_RX_2_5G;
diff --git a/drivers/net/dpaa/dpaa_fmc.c b/drivers/net/dpaa/dpaa_fmc.c
index f8c9360311..d80ea1010a 100644
--- a/drivers/net/dpaa/dpaa_fmc.c
+++ b/drivers/net/dpaa/dpaa_fmc.c
@@ -1,5 +1,5 @@
/* SPDX-License-Identifier: BSD-3-Clause
- * Copyright 2017-2021 NXP
+ * Copyright 2017-2023 NXP
*/
/* System headers */
@@ -204,139 +204,258 @@ struct fmc_model_t {
struct fmc_model_t *g_fmc_model;
-static int dpaa_port_fmc_port_parse(struct fman_if *fif,
- const struct fmc_model_t *fmc_model,
- int apply_idx)
+static int
+dpaa_port_fmc_port_parse(struct fman_if *fif,
+ const struct fmc_model_t *fmc_model,
+ int apply_idx)
{
int current_port = fmc_model->apply_order[apply_idx].index;
const fmc_port *pport = &fmc_model->port[current_port];
- const uint8_t mac_idx[] = {-1, 0, 1, 2, 3, 4, 5, 6, 7, 0, 1};
- const uint8_t mac_type[] = {1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2};
+ uint32_t num;
+
+ if (pport->type == e_FM_PORT_TYPE_OH_OFFLINE_PARSING &&
+ pport->number == fif->mac_idx &&
+ (fif->mac_type == fman_offline ||
+ fif->mac_type == fman_onic))
+ return current_port;
+
+ if (fif->mac_type == fman_mac_1g) {
+ if (pport->type != e_FM_PORT_TYPE_RX)
+ return -ENODEV;
+ num = pport->number + DPAA_1G_MAC_START_IDX;
+ if (fif->mac_idx == num)
+ return current_port;
+
+ return -ENODEV;
+ }
+
+ if (fif->mac_type == fman_mac_2_5g) {
+ if (pport->type != e_FM_PORT_TYPE_RX_2_5G)
+ return -ENODEV;
+ num = pport->number + DPAA_2_5G_MAC_START_IDX;
+ if (fif->mac_idx == num)
+ return current_port;
+
+ return -ENODEV;
+ }
+
+ if (fif->mac_type == fman_mac_10g) {
+ if (pport->type != e_FM_PORT_TYPE_RX_10G)
+ return -ENODEV;
+ num = pport->number + DPAA_10G_MAC_START_IDX;
+ if (fif->mac_idx == num)
+ return current_port;
+
+ return -ENODEV;
+ }
+
+ DPAA_PMD_ERR("Invalid MAC(mac_idx=%d) type(%d)",
+ fif->mac_idx, fif->mac_type);
+
+ return -EINVAL;
+}
+
+static int
+dpaa_fq_is_in_kernel(uint32_t fqid,
+ struct fman_if *fif)
+{
+ if (!fif->is_shared_mac)
+ return false;
+
+ if ((fqid == fif->fqid_rx_def ||
+ (fqid >= fif->fqid_rx_pcd &&
+ fqid < (fif->fqid_rx_pcd + fif->fqid_rx_pcd_count)) ||
+ fqid == fif->fqid_rx_err ||
+ fqid == fif->fqid_tx_err))
+ return true;
+
+ return false;
+}
+
+static int
+dpaa_vsp_id_is_in_kernel(uint8_t vsp_id,
+ struct fman_if *fif)
+{
+ if (!fif->is_shared_mac)
+ return false;
+
+ if (vsp_id == fif->base_profile_id)
+ return true;
+
+ return false;
+}
+
+static uint8_t
+dpaa_enqueue_vsp_id(struct fman_if *fif,
+ const struct ioc_fm_pcd_cc_next_enqueue_params_t *eq_param)
+{
+ if (eq_param->override_fqid)
+ return eq_param->new_relative_storage_profile_id;
+
+ return fif->base_profile_id;
+}
- if (mac_idx[fif->mac_idx] != pport->number ||
- mac_type[fif->mac_idx] != pport->type)
- return -1;
+static int
+dpaa_kg_storage_is_in_kernel(struct fman_if *fif,
+ const struct ioc_fm_pcd_kg_storage_profile_t *kg_storage)
+{
+ if (!fif->is_shared_mac)
+ return false;
+
+ if (!kg_storage->direct ||
+ (kg_storage->direct &&
+ kg_storage->profile_select.direct_relative_profile_id ==
+ fif->base_profile_id))
+ return true;
- return current_port;
+ return false;
}
-static int dpaa_port_fmc_scheme_parse(struct fman_if *fif,
- const struct fmc_model_t *fmc,
- int apply_idx,
- uint16_t *rxq_idx, int max_nb_rxq,
- uint32_t *fqids, int8_t *vspids)
+static void
+dpaa_fmc_remove_fq_from_allocated(uint32_t *fqids,
+ uint16_t *rxq_idx, uint32_t rm_fqid)
{
- int idx = fmc->apply_order[apply_idx].index;
uint32_t i;
- if (!fmc->scheme[idx].override_storage_profile &&
- fif->is_shared_mac) {
- DPAA_PMD_WARN("No VSP assigned to scheme %d for sharemac %d!",
- idx, fif->mac_idx);
- DPAA_PMD_WARN("Risk to receive pkts from skb pool to CRASH!");
+ for (i = 0; i < (*rxq_idx); i++) {
+ if (fqids[i] != rm_fqid)
+ continue;
+ DPAA_PMD_WARN("Remove fq(0x%08x) allocated.",
+ rm_fqid);
+ if ((*rxq_idx) > (i + 1)) {
+ memmove(&fqids[i], &fqids[i + 1],
+ ((*rxq_idx) - (i + 1)) * sizeof(uint32_t));
+ }
+ (*rxq_idx)--;
+ break;
}
+}
- if (e_IOC_FM_PCD_DONE ==
- fmc->scheme[idx].next_engine) {
- for (i = 0; i < fmc->scheme[idx]
- .key_ext_and_hash.hash_dist_num_of_fqids; i++) {
- uint32_t fqid = fmc->scheme[idx].base_fqid + i;
- int k, found = 0;
-
- if (fqid == fif->fqid_rx_def ||
- (fqid >= fif->fqid_rx_pcd &&
- fqid < (fif->fqid_rx_pcd +
- fif->fqid_rx_pcd_count))) {
- if (fif->is_shared_mac &&
- fmc->scheme[idx].override_storage_profile &&
- fmc->scheme[idx].storage_profile.direct &&
- fmc->scheme[idx].storage_profile
- .profile_select.direct_relative_profile_id !=
- fif->base_profile_id) {
- DPAA_PMD_ERR("Def RXQ must be associated with def VSP on sharemac!");
-
- return -1;
- }
- continue;
+static int
+dpaa_port_fmc_scheme_parse(struct fman_if *fif,
+ const struct fmc_model_t *fmc,
+ int apply_idx,
+ uint16_t *rxq_idx, int max_nb_rxq,
+ uint32_t *fqids, int8_t *vspids)
+{
+ int scheme_idx = fmc->apply_order[apply_idx].index;
+ int k, found = 0;
+ uint32_t i, num_rxq, fqid, rxq_idx_start = *rxq_idx;
+ const struct fm_pcd_kg_scheme_params_t *scheme;
+ const struct ioc_fm_pcd_kg_key_extract_and_hash_params_t *params;
+ const struct ioc_fm_pcd_kg_storage_profile_t *kg_storage;
+ uint8_t vsp_id;
+
+ scheme = &fmc->scheme[scheme_idx];
+ params = &scheme->key_ext_and_hash;
+ num_rxq = params->hash_dist_num_of_fqids;
+ kg_storage = &scheme->storage_profile;
+
+ if (scheme->override_storage_profile && kg_storage->direct)
+ vsp_id = kg_storage->profile_select.direct_relative_profile_id;
+ else
+ vsp_id = fif->base_profile_id;
+
+ if (dpaa_kg_storage_is_in_kernel(fif, kg_storage)) {
+ DPAA_PMD_WARN("Scheme[%d]'s VSP is in kernel",
+ scheme_idx);
+ /* The FQ may be allocated from previous CC or scheme,
+ * find and remove it.
+ */
+ for (i = 0; i < num_rxq; i++) {
+ fqid = scheme->base_fqid + i;
+ DPAA_PMD_WARN("Removed fqid(0x%08x) of Scheme[%d]",
+ fqid, scheme_idx);
+ dpaa_fmc_remove_fq_from_allocated(fqids,
+ rxq_idx, fqid);
+ if (!dpaa_fq_is_in_kernel(fqid, fif)) {
+ char reason_msg[128];
+ char result_msg[128];
+
+ sprintf(reason_msg,
+ "NOT handled in kernel");
+ sprintf(result_msg,
+ "will DRAIN kernel pool!");
+ DPAA_PMD_WARN("Traffic to FQ(%08x)(%s) %s",
+ fqid, reason_msg, result_msg);
}
+ }
- if (fif->is_shared_mac &&
- !fmc->scheme[idx].override_storage_profile) {
- DPAA_PMD_ERR("RXQ to DPDK must be associated with VSP on sharemac!");
- return -1;
- }
+ return 0;
+ }
- if (fif->is_shared_mac &&
- fmc->scheme[idx].override_storage_profile &&
- fmc->scheme[idx].storage_profile.direct &&
- fmc->scheme[idx].storage_profile
- .profile_select.direct_relative_profile_id ==
- fif->base_profile_id) {
- DPAA_PMD_ERR("RXQ can't be associated with default VSP on sharemac!");
+ if (e_IOC_FM_PCD_DONE != scheme->next_engine) {
+ /* Do nothing.*/
+ DPAA_PMD_DEBUG("Will parse scheme[%d]'s next engine(%d)",
+ scheme_idx, scheme->next_engine);
+ return 0;
+ }
- return -1;
- }
+ for (i = 0; i < num_rxq; i++) {
+ fqid = scheme->base_fqid + i;
+ found = 0;
- if ((*rxq_idx) >= max_nb_rxq) {
- DPAA_PMD_DEBUG("Too many queues in FMC policy"
- "%d overflow %d",
- (*rxq_idx), max_nb_rxq);
+ if (dpaa_fq_is_in_kernel(fqid, fif)) {
+ DPAA_PMD_WARN("FQ(0x%08x) is handled in kernel.",
+ fqid);
+ /* The FQ may be allocated from previous CC or scheme,
+ * remove it.
+ */
+ dpaa_fmc_remove_fq_from_allocated(fqids,
+ rxq_idx, fqid);
+ continue;
+ }
- continue;
- }
+ if ((*rxq_idx) >= max_nb_rxq) {
+ DPAA_PMD_WARN("Too many queues(%d) >= MAX number(%d)",
+ (*rxq_idx), max_nb_rxq);
- for (k = 0; k < (*rxq_idx); k++) {
- if (fqids[k] == fqid) {
- found = 1;
- break;
- }
- }
+ break;
+ }
- if (found)
- continue;
- fqids[(*rxq_idx)] = fqid;
- if (fmc->scheme[idx].override_storage_profile) {
- if (fmc->scheme[idx].storage_profile.direct) {
- vspids[(*rxq_idx)] =
- fmc->scheme[idx].storage_profile
- .profile_select
- .direct_relative_profile_id;
- } else {
- vspids[(*rxq_idx)] = -1;
- }
- } else {
- vspids[(*rxq_idx)] = -1;
+ for (k = 0; k < (*rxq_idx); k++) {
+ if (fqids[k] == fqid) {
+ found = 1;
+ break;
}
- (*rxq_idx)++;
}
+
+ if (found)
+ continue;
+ fqids[(*rxq_idx)] = fqid;
+ vspids[(*rxq_idx)] = vsp_id;
+
+ (*rxq_idx)++;
}
- return 0;
+ return (*rxq_idx) - rxq_idx_start;
}
-static int dpaa_port_fmc_ccnode_parse(struct fman_if *fif,
- const struct fmc_model_t *fmc_model,
- int apply_idx,
- uint16_t *rxq_idx, int max_nb_rxq,
- uint32_t *fqids, int8_t *vspids)
+static int
+dpaa_port_fmc_ccnode_parse(struct fman_if *fif,
+ const struct fmc_model_t *fmc,
+ int apply_idx,
+ uint16_t *rxq_idx, int max_nb_rxq,
+ uint32_t *fqids, int8_t *vspids)
{
uint16_t j, k, found = 0;
const struct ioc_keys_params_t *keys_params;
- uint32_t fqid, cc_idx = fmc_model->apply_order[apply_idx].index;
-
- keys_params = &fmc_model->ccnode[cc_idx].keys_params;
+ const struct ioc_fm_pcd_cc_next_engine_params_t *params;
+ uint32_t fqid, cc_idx = fmc->apply_order[apply_idx].index;
+ uint32_t rxq_idx_start = *rxq_idx;
+ uint8_t vsp_id;
- if ((*rxq_idx) >= max_nb_rxq) {
- DPAA_PMD_WARN("Too many queues in FMC policy %d overflow %d",
- (*rxq_idx), max_nb_rxq);
-
- return 0;
- }
+ keys_params = &fmc->ccnode[cc_idx].keys_params;
for (j = 0; j < keys_params->num_of_keys; ++j) {
+ if ((*rxq_idx) >= max_nb_rxq) {
+ DPAA_PMD_WARN("Too many queues(%d) >= MAX number(%d)",
+ (*rxq_idx), max_nb_rxq);
+
+ break;
+ }
found = 0;
- fqid = keys_params->key_params[j].cc_next_engine_params
- .params.enqueue_params.new_fqid;
+ params = &keys_params->key_params[j].cc_next_engine_params;
/* We read DPDK queue from last classification rule present in
* FMC policy file. Hence, this check is required here.
@@ -344,15 +463,30 @@ static int dpaa_port_fmc_ccnode_parse(struct fman_if *fif,
* have userspace queue so that it can be used by DPDK
* application.
*/
- if (keys_params->key_params[j].cc_next_engine_params
- .next_engine != e_IOC_FM_PCD_DONE) {
- DPAA_PMD_WARN("FMC CC next engine not support");
+ if (params->next_engine != e_IOC_FM_PCD_DONE) {
+ DPAA_PMD_WARN("CC next engine(%d) not support",
+ params->next_engine);
continue;
}
- if (keys_params->key_params[j].cc_next_engine_params
- .params.enqueue_params.action !=
+ if (params->params.enqueue_params.action !=
e_IOC_FM_PCD_ENQ_FRAME)
continue;
+
+ fqid = params->params.enqueue_params.new_fqid;
+ vsp_id = dpaa_enqueue_vsp_id(fif,
+ ¶ms->params.enqueue_params);
+ if (dpaa_fq_is_in_kernel(fqid, fif) ||
+ dpaa_vsp_id_is_in_kernel(vsp_id, fif)) {
+ DPAA_PMD_DEBUG("FQ(0x%08x)/VSP(%d) is in kernel.",
+ fqid, vsp_id);
+ /* The FQ may be allocated from previous CC or scheme,
+ * remove it.
+ */
+ dpaa_fmc_remove_fq_from_allocated(fqids,
+ rxq_idx, fqid);
+ continue;
+ }
+
for (k = 0; k < (*rxq_idx); k++) {
if (fqids[k] == fqid) {
found = 1;
@@ -362,38 +496,22 @@ static int dpaa_port_fmc_ccnode_parse(struct fman_if *fif,
if (found)
continue;
- if ((*rxq_idx) >= max_nb_rxq) {
- DPAA_PMD_WARN("Too many queues in FMC policy %d overflow %d",
- (*rxq_idx), max_nb_rxq);
-
- return 0;
- }
-
fqids[(*rxq_idx)] = fqid;
- vspids[(*rxq_idx)] =
- keys_params->key_params[j].cc_next_engine_params
- .params.enqueue_params
- .new_relative_storage_profile_id;
-
- if (vspids[(*rxq_idx)] == fif->base_profile_id &&
- fif->is_shared_mac) {
- DPAA_PMD_ERR("VSP %d can NOT be used on DPDK.",
- vspids[(*rxq_idx)]);
- DPAA_PMD_ERR("It is associated to skb pool of shared interface.");
- return -1;
- }
+ vspids[(*rxq_idx)] = vsp_id;
+
(*rxq_idx)++;
}
- return 0;
+ return (*rxq_idx) - rxq_idx_start;
}
-int dpaa_port_fmc_init(struct fman_if *fif,
- uint32_t *fqids, int8_t *vspids, int max_nb_rxq)
+int
+dpaa_port_fmc_init(struct fman_if *fif,
+ uint32_t *fqids, int8_t *vspids, int max_nb_rxq)
{
int current_port = -1, ret;
uint16_t rxq_idx = 0;
- const struct fmc_model_t *fmc_model;
+ const struct fmc_model_t *fmc;
uint32_t i;
if (!g_fmc_model) {
@@ -402,14 +520,14 @@ int dpaa_port_fmc_init(struct fman_if *fif,
if (!fp) {
DPAA_PMD_ERR("%s not exists", FMC_FILE);
- return -1;
+ return -ENOENT;
}
g_fmc_model = rte_malloc(NULL, sizeof(struct fmc_model_t), 64);
if (!g_fmc_model) {
DPAA_PMD_ERR("FMC memory alloc failed");
fclose(fp);
- return -1;
+ return -ENOBUFS;
}
bytes_read = fread(g_fmc_model,
@@ -419,25 +537,28 @@ int dpaa_port_fmc_init(struct fman_if *fif,
fclose(fp);
rte_free(g_fmc_model);
g_fmc_model = NULL;
- return -1;
+ return -EIO;
}
fclose(fp);
}
- fmc_model = g_fmc_model;
+ fmc = g_fmc_model;
- if (fmc_model->format_version != FMC_OUTPUT_FORMAT_VER)
- return -1;
+ if (fmc->format_version != FMC_OUTPUT_FORMAT_VER) {
+ DPAA_PMD_ERR("FMC version(0x%08x) != Supported ver(0x%08x)",
+ fmc->format_version, FMC_OUTPUT_FORMAT_VER);
+ return -EINVAL;
+ }
- for (i = 0; i < fmc_model->apply_order_count; i++) {
- switch (fmc_model->apply_order[i].type) {
+ for (i = 0; i < fmc->apply_order_count; i++) {
+ switch (fmc->apply_order[i].type) {
case fmcengine_start:
break;
case fmcengine_end:
break;
case fmcport_start:
current_port = dpaa_port_fmc_port_parse(fif,
- fmc_model, i);
+ fmc, i);
break;
case fmcport_end:
break;
@@ -445,24 +566,24 @@ int dpaa_port_fmc_init(struct fman_if *fif,
if (current_port < 0)
break;
- ret = dpaa_port_fmc_scheme_parse(fif, fmc_model,
- i, &rxq_idx,
- max_nb_rxq,
- fqids, vspids);
- if (ret)
- return ret;
+ ret = dpaa_port_fmc_scheme_parse(fif, fmc,
+ i, &rxq_idx, max_nb_rxq, fqids, vspids);
+ DPAA_PMD_INFO("%s %d RXQ(s) from scheme[%d]",
+ ret >= 0 ? "Alloc" : "Remove",
+ ret >= 0 ? ret : -ret,
+ fmc->apply_order[i].index);
break;
case fmcccnode:
if (current_port < 0)
break;
- ret = dpaa_port_fmc_ccnode_parse(fif, fmc_model,
- i, &rxq_idx,
- max_nb_rxq, fqids,
- vspids);
- if (ret)
- return ret;
+ ret = dpaa_port_fmc_ccnode_parse(fif, fmc,
+ i, &rxq_idx, max_nb_rxq, fqids, vspids);
+ DPAA_PMD_INFO("%s %d RXQ(s) from cc[%d]",
+ ret >= 0 ? "Alloc" : "Remove",
+ ret >= 0 ? ret : -ret,
+ fmc->apply_order[i].index);
break;
case fmchtnode:
diff --git a/drivers/net/dpaa/dpaa_rxtx.c b/drivers/net/dpaa/dpaa_rxtx.c
index 3bd35c7a0e..d1338d1654 100644
--- a/drivers/net/dpaa/dpaa_rxtx.c
+++ b/drivers/net/dpaa/dpaa_rxtx.c
@@ -693,13 +693,26 @@ dpaa_rx_cb_atomic(void *event,
}
#ifdef RTE_LIBRTE_DPAA_DEBUG_DRIVER
-static inline void dpaa_eth_err_queue(struct dpaa_if *dpaa_intf)
+static inline void
+dpaa_eth_err_queue(struct qman_fq *fq)
{
struct rte_mbuf *mbuf;
struct qman_fq *debug_fq;
int ret, i;
struct qm_dqrr_entry *dq;
struct qm_fd *fd;
+ struct dpaa_if *dpaa_intf;
+
+ dpaa_intf = fq->dpaa_intf;
+ if (fq != &dpaa_intf->rx_queues[0]) {
+ /* Associate error queues to the first RXQ.*/
+ return;
+ }
+
+ if (dpaa_intf->cfg->fman_if->is_shared_mac) {
+ /* Error queues of shared MAC are handled in kernel. */
+ return;
+ }
if (unlikely(!RTE_PER_LCORE(dpaa_io))) {
ret = rte_dpaa_portal_init((void *)0);
@@ -708,7 +721,7 @@ static inline void dpaa_eth_err_queue(struct dpaa_if *dpaa_intf)
return;
}
}
- for (i = 0; i <= DPAA_DEBUG_FQ_TX_ERROR; i++) {
+ for (i = 0; i < DPAA_DEBUG_FQ_MAX_NUM; i++) {
debug_fq = &dpaa_intf->debug_queues[i];
ret = qman_set_vdq(debug_fq, 4, QM_VDQCR_EXACT);
if (ret)
@@ -751,8 +764,7 @@ uint16_t dpaa_eth_queue_rx(void *q,
rte_dpaa_bpid_info = fq->bp_array;
#ifdef RTE_LIBRTE_DPAA_DEBUG_DRIVER
- if (fq->fqid == ((struct dpaa_if *)fq->dpaa_intf)->rx_queues[0].fqid)
- dpaa_eth_err_queue((struct dpaa_if *)fq->dpaa_intf);
+ dpaa_eth_err_queue(fq);
#endif
if (likely(fq->is_static))
--
2.25.1
next prev parent reply other threads:[~2024-09-30 12:17 UTC|newest]
Thread overview: 129+ messages / expand[flat|nested] mbox.gz Atom feed top
2024-08-01 10:52 [PATCH 00/17] NXP DPAA ETH driver enhancement and fixes Hemant Agrawal
2024-08-01 10:52 ` [PATCH 01/17] bus/dpaa: fix PFDRs leaks due to FQRNIs Hemant Agrawal
2024-08-01 10:52 ` [PATCH 02/17] net/dpaa: fix typecasting ch ID to u32 Hemant Agrawal
2024-08-07 15:37 ` Ferruh Yigit
2024-08-01 10:52 ` [PATCH 03/17] bus/dpaa: fix VSP for 1G fm1-mac9 and 10 Hemant Agrawal
2024-08-07 15:38 ` Ferruh Yigit
2024-08-23 7:33 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 04/17] bus/dpaa: add port buffer manager stats Hemant Agrawal
2024-08-07 15:38 ` Ferruh Yigit
2024-08-23 7:33 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 05/17] net/dpaa: support Tx confirmation to enable PTP Hemant Agrawal
2024-08-07 15:38 ` Ferruh Yigit
2024-08-23 7:34 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 06/17] net/dpaa: add support to separate Tx conf queues Hemant Agrawal
2024-08-01 10:53 ` [PATCH 07/17] net/dpaa: share MAC FMC scheme and CC parse Hemant Agrawal
2024-08-07 15:39 ` Ferruh Yigit
2024-08-23 7:34 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 08/17] net/dpaa: support Rx/Tx timestamp read Hemant Agrawal
2024-08-01 10:53 ` [PATCH 09/17] net/dpaa: support IEEE 1588 PTP Hemant Agrawal
2024-08-07 15:39 ` Ferruh Yigit
2024-08-23 7:36 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 10/17] net/dpaa: implement detailed packet parsing Hemant Agrawal
2024-08-07 15:39 ` Ferruh Yigit
2024-08-23 7:34 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 11/17] net/dpaa: enhance DPAA frame display Hemant Agrawal
2024-08-07 15:39 ` Ferruh Yigit
2024-08-23 7:36 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 12/17] net/dpaa: support mempool debug Hemant Agrawal
2024-08-01 10:53 ` [PATCH 13/17] net/dpaa: add Tx rate limiting DPAA PMD API Hemant Agrawal
2024-08-07 15:40 ` Ferruh Yigit
2024-08-23 7:35 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 14/17] bus/dpaa: add OH port mode for dpaa eth Hemant Agrawal
2024-08-07 15:40 ` Ferruh Yigit
2024-08-23 7:35 ` Hemant Agrawal
2024-08-01 10:53 ` [PATCH 15/17] bus/dpaa: add ONIC port mode for the DPAA eth Hemant Agrawal
2024-08-01 10:53 ` [PATCH 16/17] net/dpaa: improve the dpaa port cleanup Hemant Agrawal
2024-08-01 10:53 ` [PATCH 17/17] net/dpaa: improve dpaa errata A010022 handling Hemant Agrawal
2024-08-07 15:41 ` Ferruh Yigit
2024-08-23 7:35 ` Hemant Agrawal
2024-08-07 15:42 ` [PATCH 00/17] NXP DPAA ETH driver enhancement and fixes Ferruh Yigit
2024-08-08 8:51 ` Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 00/18] " Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 01/18] bus/dpaa: fix PFDRs leaks due to FQRNIs Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 02/18] net/dpaa: fix typecasting ch ID to u32 Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 03/18] bus/dpaa: fix VSP for 1G fm1-mac9 and 10 Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 04/18] bus/dpaa: fix the fman details status Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 05/18] bus/dpaa: add port buffer manager stats Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 06/18] net/dpaa: support Tx confirmation to enable PTP Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 07/18] net/dpaa: add support to separate Tx conf queues Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 08/18] net/dpaa: share MAC FMC scheme and CC parse Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 09/18] net/dpaa: support Rx/Tx timestamp read Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 10/18] net/dpaa: support IEEE 1588 PTP Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 11/18] net/dpaa: implement detailed packet parsing Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 12/18] net/dpaa: enhance DPAA frame display Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 13/18] net/dpaa: support mempool debug Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 14/18] net/dpaa: add Tx rate limiting DPAA PMD API Hemant Agrawal
2024-09-22 3:14 ` Ferruh Yigit
2024-09-22 4:40 ` Hemant Agrawal
2024-09-22 13:10 ` Ferruh Yigit
2024-09-22 13:27 ` Ferruh Yigit
2024-09-22 15:23 ` Ferruh Yigit
2024-08-23 7:32 ` [PATCH v2 15/18] bus/dpaa: add OH port mode for dpaa eth Hemant Agrawal
2024-09-22 15:24 ` Ferruh Yigit
2024-08-23 7:32 ` [PATCH v2 16/18] bus/dpaa: add ONIC port mode for the DPAA eth Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 17/18] net/dpaa: improve the dpaa port cleanup Hemant Agrawal
2024-08-23 7:32 ` [PATCH v2 18/18] net/dpaa: improve dpaa errata A010022 handling Hemant Agrawal
2024-09-22 3:12 ` [PATCH v2 00/18] NXP DPAA ETH driver enhancement and fixes Ferruh Yigit
2024-09-22 4:38 ` Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 " Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 01/18] bus/dpaa: fix PFDRs leaks due to FQRNIs Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 02/18] net/dpaa: fix typecasting ch ID to u32 Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 03/18] bus/dpaa: fix VSP for 1G fm1-mac9 and 10 Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 04/18] bus/dpaa: fix the fman details status Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 05/18] bus/dpaa: add port buffer manager stats Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 06/18] net/dpaa: support Tx confirmation to enable PTP Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 07/18] net/dpaa: add support to separate Tx conf queues Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 08/18] net/dpaa: share MAC FMC scheme and CC parse Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 09/18] net/dpaa: support Rx/Tx timestamp read Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 10/18] net/dpaa: support IEEE 1588 PTP Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 11/18] net/dpaa: implement detailed packet parsing Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 12/18] net/dpaa: enhance DPAA frame display Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 13/18] net/dpaa: support mempool debug Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 14/18] bus/dpaa: add OH port mode for dpaa eth Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 15/18] bus/dpaa: add ONIC port mode for the DPAA eth Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 16/18] net/dpaa: improve the dpaa port cleanup Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 17/18] net/dpaa: improve dpaa errata A010022 handling Hemant Agrawal
2024-09-30 10:29 ` [PATCH v3 18/18] net/dpaa: fix reallocate_mbuf handling Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 00/18] NXP DPAA ETH driver enhancement and fixes Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 01/18] bus/dpaa: fix PFDRs leaks due to FQRNIs Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 02/18] net/dpaa: fix typecasting ch ID to u32 Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 03/18] bus/dpaa: fix VSP for 1G fm1-mac9 and 10 Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 04/18] bus/dpaa: fix the fman details status Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 05/18] bus/dpaa: add port buffer manager stats Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 06/18] net/dpaa: support Tx confirmation to enable PTP Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 07/18] net/dpaa: add support to separate Tx conf queues Hemant Agrawal
2024-09-30 12:15 ` Hemant Agrawal [this message]
2024-09-30 12:15 ` [PATCH v4 09/18] net/dpaa: support Rx/Tx timestamp read Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 10/18] net/dpaa: support IEEE 1588 PTP Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 11/18] net/dpaa: implement detailed packet parsing Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 12/18] net/dpaa: enhance DPAA frame display Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 13/18] net/dpaa: support mempool debug Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 14/18] bus/dpaa: add OH port mode for dpaa eth Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 15/18] bus/dpaa: add ONIC port mode for the DPAA eth Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 16/18] net/dpaa: improve the dpaa port cleanup Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 17/18] net/dpaa: improve dpaa errata A010022 handling Hemant Agrawal
2024-09-30 12:15 ` [PATCH v4 18/18] net/dpaa: fix reallocate_mbuf handling Hemant Agrawal
2024-10-01 8:15 ` [PATCH v4 00/18] NXP DPAA ETH driver enhancement and fixes Ferruh Yigit
2024-10-01 11:03 ` [PATCH v5 " Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 01/18] bus/dpaa: fix PFDRs leaks due to FQRNIs Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 02/18] net/dpaa: fix typecasting ch ID to u32 Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 03/18] bus/dpaa: fix VSP for 1G fm1-mac9 and 10 Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 04/18] bus/dpaa: fix the fman details status Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 05/18] bus/dpaa: add port buffer manager stats Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 06/18] net/dpaa: support Tx confirmation to enable PTP Hemant Agrawal
2024-10-04 14:01 ` David Marchand
2024-10-01 11:03 ` [PATCH v5 07/18] net/dpaa: add support to separate Tx conf queues Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 08/18] net/dpaa: share MAC FMC scheme and CC parse Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 09/18] net/dpaa: support Rx/Tx timestamp read Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 10/18] net/dpaa: support IEEE 1588 PTP Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 11/18] net/dpaa: implement detailed packet parsing Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 12/18] net/dpaa: enhance DPAA frame display Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 13/18] net/dpaa: support mempool debug Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 14/18] bus/dpaa: add OH port mode for dpaa eth Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 15/18] bus/dpaa: add ONIC port mode for the DPAA eth Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 16/18] net/dpaa: improve the dpaa port cleanup Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 17/18] net/dpaa: improve dpaa errata A010022 handling Hemant Agrawal
2024-10-01 11:03 ` [PATCH v5 18/18] net/dpaa: fix reallocate_mbuf handling Hemant Agrawal
2024-10-02 0:41 ` [PATCH v5 00/18] NXP DPAA ETH driver enhancement and fixes Ferruh Yigit
2024-10-04 14:03 ` David Marchand
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20240930121525.3452847-9-hemant.agrawal@nxp.com \
--to=hemant.agrawal@nxp.com \
--cc=dev@dpdk.org \
--cc=ferruh.yigit@amd.com \
--cc=jun.yang@nxp.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).