From: Chaoyong He <chaoyong.he@corigine.com>
To: dev@dpdk.org
Cc: oss-drivers@corigine.com, Chaoyong He <chaoyong.he@corigine.com>,
Long Wu <long.wu@corigine.com>,
Peng Zhang <peng.zhang@corigine.com>
Subject: [PATCH 6/7] net/nfp: split out the flow action check logic
Date: Wed, 19 Jun 2024 17:19:40 +0800 [thread overview]
Message-ID: <20240619091941.3479371-7-chaoyong.he@corigine.com> (raw)
In-Reply-To: <20240619091941.3479371-1-chaoyong.he@corigine.com>
Split out the flow action check logic.
Signed-off-by: Chaoyong He <chaoyong.he@corigine.com>
Reviewed-by: Long Wu <long.wu@corigine.com>
Reviewed-by: Peng Zhang <peng.zhang@corigine.com>
---
drivers/net/nfp/flower/nfp_flower_flow.c | 368 +++++++++++++++--------
1 file changed, 244 insertions(+), 124 deletions(-)
diff --git a/drivers/net/nfp/flower/nfp_flower_flow.c b/drivers/net/nfp/flower/nfp_flower_flow.c
index c8270d81f1..87a3d5b394 100644
--- a/drivers/net/nfp/flower/nfp_flower_flow.c
+++ b/drivers/net/nfp/flower/nfp_flower_flow.c
@@ -1128,8 +1128,246 @@ struct nfp_action_calculate_param {
struct nfp_action_flag *flag;
};
+typedef int (*nfp_flow_key_check_action_fn)(struct nfp_action_calculate_param *param);
typedef int (*nfp_flow_key_calculate_action_fn)(struct nfp_action_calculate_param *param);
+static int
+nfp_flow_action_check_port(struct nfp_action_calculate_param *param)
+{
+ uint32_t port_id;
+ const struct rte_flow_action *action;
+ const struct rte_flow_action_ethdev *action_ethdev;
+ const struct rte_flow_action_port_id *action_port_id;
+
+ action = param->action;
+ if (action->conf == NULL)
+ return -EINVAL;
+
+ if (action->type == RTE_FLOW_ACTION_TYPE_REPRESENTED_PORT) {
+ action_ethdev = action->conf;
+ port_id = action_ethdev->port_id;
+ } else {
+ action_port_id = action->conf;
+ port_id = action_port_id->id;
+ }
+
+ if (port_id >= RTE_MAX_ETHPORTS)
+ return -ERANGE;
+
+ return 0;
+}
+
+static int
+nfp_flow_action_check_meter(struct nfp_action_calculate_param *param)
+{
+ if (param->flag->meter_flag) {
+ PMD_DRV_LOG(ERR, "Only support one meter action.");
+ return -ENOTSUP;
+ }
+
+ param->flag->meter_flag = true;
+
+ return 0;
+}
+
+static bool
+nfp_flow_field_id_dst_support(enum rte_flow_field_id field)
+{
+ switch (field) {
+ case RTE_FLOW_FIELD_IPV4_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV4_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_TCP_PORT_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_TCP_PORT_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_UDP_PORT_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_UDP_PORT_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV4_TTL:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_HOPLIMIT:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_MAC_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_MAC_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV4_DSCP:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_DSCP:
+ return true;
+ default:
+ break;
+ }
+
+ return false;
+}
+
+static bool
+nfp_flow_field_id_src_support(enum rte_flow_field_id field)
+{
+ return field == RTE_FLOW_FIELD_POINTER ||
+ field == RTE_FLOW_FIELD_VALUE;
+}
+
+static uint32_t
+nfp_flow_field_width(enum rte_flow_field_id field,
+ uint32_t inherit)
+{
+ switch (field) {
+ case RTE_FLOW_FIELD_IPV4_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV4_DST:
+ return 32;
+ case RTE_FLOW_FIELD_IPV6_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_DST:
+ return 128;
+ case RTE_FLOW_FIELD_TCP_PORT_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_TCP_PORT_DST:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_UDP_PORT_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_UDP_PORT_DST:
+ return 16;
+ case RTE_FLOW_FIELD_IPV4_TTL:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_HOPLIMIT:
+ return 8;
+ case RTE_FLOW_FIELD_MAC_SRC:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_MAC_DST:
+ return 48;
+ case RTE_FLOW_FIELD_IPV4_DSCP:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_IPV6_DSCP:
+ return 6;
+ case RTE_FLOW_FIELD_POINTER:
+ /* FALLTHROUGH */
+ case RTE_FLOW_FIELD_VALUE:
+ return inherit;
+ default:
+ break;
+ }
+
+ return 0;
+}
+
+static bool
+nfp_flow_is_validate_field_data(const struct rte_flow_field_data *data,
+ uint32_t conf_width,
+ uint32_t data_width)
+{
+ if (data->level != 0) {
+ PMD_DRV_LOG(ERR, "The 'level' is not support");
+ return false;
+ }
+
+ if (data->tag_index != 0) {
+ PMD_DRV_LOG(ERR, "The 'tag_index' is not support");
+ return false;
+ }
+
+ if (data->class_id != 0) {
+ PMD_DRV_LOG(ERR, "The 'class_id' is not support");
+ return false;
+ }
+
+ if (data->offset + conf_width > data_width) {
+ PMD_DRV_LOG(ERR, "The 'offset' value is too big");
+ return false;
+ }
+
+ return true;
+}
+
+static int
+nfp_flow_action_check_modify(struct nfp_action_calculate_param *param)
+{
+ uint32_t width;
+ uint32_t dst_width;
+ uint32_t src_width;
+ const struct rte_flow_field_data *dst_data;
+ const struct rte_flow_field_data *src_data;
+ const struct rte_flow_action_modify_field *conf;
+
+ conf = param->action->conf;
+ if (conf == NULL)
+ return -EINVAL;
+
+ dst_data = &conf->dst;
+ src_data = &conf->src;
+ if (!nfp_flow_field_id_dst_support(dst_data->field) ||
+ !nfp_flow_field_id_src_support(src_data->field)) {
+ PMD_DRV_LOG(ERR, "Not supported field id");
+ return -EINVAL;
+ }
+
+ width = conf->width;
+ if (width == 0) {
+ PMD_DRV_LOG(ERR, "No bits are required to modify");
+ return -EINVAL;
+ }
+
+ dst_width = nfp_flow_field_width(dst_data->field, 0);
+ src_width = nfp_flow_field_width(src_data->field, dst_width);
+ if (width > dst_width || width > src_width) {
+ PMD_DRV_LOG(ERR, "Cannot modify more bits than the width of a field");
+ return -EINVAL;
+ }
+
+ if (!nfp_flow_is_validate_field_data(dst_data, width, dst_width)) {
+ PMD_DRV_LOG(ERR, "The dest field data has problem");
+ return -EINVAL;
+ }
+
+ return 0;
+}
+
+static nfp_flow_key_check_action_fn check_action_fns[] = {
+ [RTE_FLOW_ACTION_TYPE_PORT_ID] = nfp_flow_action_check_port,
+ [RTE_FLOW_ACTION_TYPE_REPRESENTED_PORT] = nfp_flow_action_check_port,
+ [RTE_FLOW_ACTION_TYPE_METER] = nfp_flow_action_check_meter,
+ [RTE_FLOW_ACTION_TYPE_MODIFY_FIELD] = nfp_flow_action_check_modify,
+};
+
+static int
+nfp_flow_key_layers_check_actions(const struct rte_flow_action actions[])
+{
+ int ret;
+ struct nfp_action_flag flag = {};
+ const struct rte_flow_action *action;
+ struct nfp_action_calculate_param param = {
+ .flag = &flag,
+ };
+
+ for (action = actions; action->type != RTE_FLOW_ACTION_TYPE_END; ++action) {
+ if (action->type >= RTE_DIM(check_action_fns)) {
+ PMD_DRV_LOG(ERR, "Flow action %d unsupported", action->type);
+ return -ERANGE;
+ }
+
+ if (check_action_fns[action->type] == NULL)
+ continue;
+
+ param.action = action;
+ ret = check_action_fns[action->type](¶m);
+ if (ret != 0) {
+ PMD_DRV_LOG(ERR, "Flow action %d calculate fail", action->type);
+ return ret;
+ }
+ }
+
+ return 0;
+}
+
static int
nfp_flow_action_calculate_stub(struct nfp_action_calculate_param *param __rte_unused)
{
@@ -1272,124 +1510,6 @@ nfp_flow_action_calculate_mark(struct nfp_action_calculate_param *param)
return 0;
}
-static bool
-nfp_flow_field_id_dst_support(enum rte_flow_field_id field)
-{
- switch (field) {
- case RTE_FLOW_FIELD_IPV4_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV4_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_TCP_PORT_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_TCP_PORT_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_UDP_PORT_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_UDP_PORT_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV4_TTL:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_HOPLIMIT:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_MAC_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_MAC_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV4_DSCP:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_DSCP:
- return true;
- default:
- break;
- }
-
- return false;
-}
-
-static bool
-nfp_flow_field_id_src_support(enum rte_flow_field_id field)
-{
- return field == RTE_FLOW_FIELD_POINTER ||
- field == RTE_FLOW_FIELD_VALUE;
-}
-
-static uint32_t
-nfp_flow_field_width(enum rte_flow_field_id field,
- uint32_t inherit)
-{
- switch (field) {
- case RTE_FLOW_FIELD_IPV4_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV4_DST:
- return 32;
- case RTE_FLOW_FIELD_IPV6_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_DST:
- return 128;
- case RTE_FLOW_FIELD_TCP_PORT_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_TCP_PORT_DST:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_UDP_PORT_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_UDP_PORT_DST:
- return 16;
- case RTE_FLOW_FIELD_IPV4_TTL:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_HOPLIMIT:
- return 8;
- case RTE_FLOW_FIELD_MAC_SRC:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_MAC_DST:
- return 48;
- case RTE_FLOW_FIELD_IPV4_DSCP:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_IPV6_DSCP:
- return 6;
- case RTE_FLOW_FIELD_POINTER:
- /* FALLTHROUGH */
- case RTE_FLOW_FIELD_VALUE:
- return inherit;
- default:
- break;
- }
-
- return 0;
-}
-
-static bool
-nfp_flow_is_validate_field_data(const struct rte_flow_field_data *data,
- uint32_t conf_width,
- uint32_t data_width)
-{
- if (data->level != 0) {
- PMD_DRV_LOG(ERR, "The 'level' is not support");
- return false;
- }
-
- if (data->tag_index != 0) {
- PMD_DRV_LOG(ERR, "The 'tag_index' is not support");
- return false;
- }
-
- if (data->class_id != 0) {
- PMD_DRV_LOG(ERR, "The 'class_id' is not support");
- return false;
- }
-
- if (data->offset + conf_width > data_width) {
- PMD_DRV_LOG(ERR, "The 'offset' value is too big");
- return false;
- }
-
- return true;
-}
-
static int
nfp_flow_action_calculate_modify_dispatch(struct nfp_action_calculate_param *param,
enum rte_flow_field_id field)
@@ -1569,6 +1689,12 @@ nfp_flow_key_layers_calculate(const struct rte_flow_item items[],
return ret;
}
+ ret = nfp_flow_key_layers_check_actions(actions);
+ if (ret != 0) {
+ PMD_DRV_LOG(ERR, "flow actions check failed");
+ return ret;
+ }
+
ret = nfp_flow_key_layers_calculate_actions(actions, key_ls);
if (ret != 0) {
PMD_DRV_LOG(ERR, "flow actions check failed");
@@ -2588,9 +2714,6 @@ nfp_flow_action_output(char *act_data,
const struct rte_flow_action_ethdev *action_ethdev;
const struct rte_flow_action_port_id *action_port_id;
- if (action->conf == NULL)
- return -EINVAL;
-
if (action->type == RTE_FLOW_ACTION_TYPE_REPRESENTED_PORT) {
action_ethdev = action->conf;
port_id = action_ethdev->port_id;
@@ -2599,9 +2722,6 @@ nfp_flow_action_output(char *act_data,
port_id = action_port_id->id;
}
- if (port_id >= RTE_MAX_ETHPORTS)
- return -ERANGE;
-
ethdev = &rte_eth_devices[port_id];
representor = ethdev->data->dev_private;
--
2.39.1
next prev parent reply other threads:[~2024-06-19 9:20 UTC|newest]
Thread overview: 8+ messages / expand[flat|nested] mbox.gz Atom feed top
2024-06-19 9:19 [PATCH 0/7] refactor flow validate and create interface Chaoyong He
2024-06-19 9:19 ` [PATCH 1/7] net/nfp: remove the unused parameter Chaoyong He
2024-06-19 9:19 ` [PATCH 2/7] net/nfp: exit as soon as possible Chaoyong He
2024-06-19 9:19 ` [PATCH 3/7] net/nfp: remove the duplicate logic of output action Chaoyong He
2024-06-19 9:19 ` [PATCH 4/7] net/nfp: split out the flow item check logic Chaoyong He
2024-06-19 9:19 ` [PATCH 5/7] net/nfp: simplify the flow item calculate logic Chaoyong He
2024-06-19 9:19 ` Chaoyong He [this message]
2024-06-19 9:19 ` [PATCH 7/7] net/nfp: simplify the flow action " Chaoyong He
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=20240619091941.3479371-7-chaoyong.he@corigine.com \
--to=chaoyong.he@corigine.com \
--cc=dev@dpdk.org \
--cc=long.wu@corigine.com \
--cc=oss-drivers@corigine.com \
--cc=peng.zhang@corigine.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).