net/mvpp2: support user defined configuration
authorLiron Himi <lironh@marvell.com>
Wed, 27 Jan 2021 16:09:36 +0000 (18:09 +0200)
committerFerruh Yigit <ferruh.yigit@intel.com>
Fri, 29 Jan 2021 17:16:11 +0000 (18:16 +0100)
Extend the config file with 'udf' (user-defined) settings

Signed-off-by: Liron Himi <lironh@marvell.com>
doc/guides/nics/mvpp2.rst
drivers/net/mvpp2/mrvl_ethdev.c
drivers/net/mvpp2/mrvl_qos.c
drivers/net/mvpp2/mrvl_qos.h

index 04d86f5..5b22cf3 100644 (file)
@@ -208,6 +208,13 @@ Configuration syntax
    ebs = <ebs>
    cbs = <cbs>
 
+   [parser udf <udf_id>]
+   proto = <proto>
+   field = <field>
+   key = <key>
+   mask = <mask>
+   offset = <offset>
+
    [port <portnum> default]
    dsa_mode = <dsa_mode>
    default_tc = <default_tc>
@@ -240,6 +247,18 @@ Configuration syntax
 
 Where:
 
+- ``<udf_id>``: Logical UDF id.
+
+- ``<proto>``: Indicate the preceding hdr before the UDF header (`eth` or `udp`).
+
+- ``<field>``: Indicate the field of the <proto> hdr (`type` (eth) or `dport` (udp).
+
+- ``<key>``: UDF key in string format starting with '0x'.
+
+- ``<mask>``: UDF mask in string format starting with '0x'.
+
+- ``<offset>``: Starting UDF offset from the <proto> hdr.
+
 - ``<portnum>``: DPDK Port number (0..n).
 
 - ``<dsa_mode>``: Indicate what is the dsa header mode (`none`, `dsa`, or `ext_dsa`).
@@ -348,6 +367,18 @@ Configuration file example
    rate_limit = 10000
    burst_size = 2000
 
+Configuration file example with UDF
+^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+
+.. code-block:: console
+
+   [parser udf 0]
+   proto = eth
+   field = type
+   key = 0x8842
+   mask = 0xffff
+   offset = 6
+
 Usage example
 ^^^^^^^^^^^^^
 
index 0d202b1..843de37 100644 (file)
@@ -2904,7 +2904,9 @@ mrvl_init_pp2(void)
        init_params.hif_reserved_map = MRVL_MUSDK_HIFS_RESERVED;
        init_params.bm_pool_reserved_map = MRVL_MUSDK_BPOOLS_RESERVED;
        init_params.rss_tbl_reserved_map = MRVL_MUSDK_RSS_RESERVED;
-
+       if (mrvl_cfg && mrvl_cfg->pp2_cfg.prs_udfs.num_udfs)
+               memcpy(&init_params.prs_udfs, &mrvl_cfg->pp2_cfg.prs_udfs,
+                      sizeof(struct pp2_parse_udfs));
        return pp2_init(&init_params);
 }
 
index 1c65b52..310fd73 100644 (file)
@@ -35,6 +35,7 @@
 #define MRVL_TOK_TXQ "txq"
 #define MRVL_TOK_VLAN "vlan"
 #define MRVL_TOK_VLAN_IP "vlan/ip"
+#define MRVL_TOK_PARSER_UDF "parser udf"
 
 /* egress specific configuration tokens */
 #define MRVL_TOK_BURST_SIZE "burst_size"
 #define MRVL_TOK_PLCR_DEFAULT_COLOR_YELLOW "yellow"
 #define MRVL_TOK_PLCR_DEFAULT_COLOR_RED "red"
 
+/* parser udf specific configuration tokens */
+#define MRVL_TOK_PARSER_UDF_PROTO "proto"
+#define MRVL_TOK_PARSER_UDF_FIELD "field"
+#define MRVL_TOK_PARSER_UDF_KEY "key"
+#define MRVL_TOK_PARSER_UDF_MASK "mask"
+#define MRVL_TOK_PARSER_UDF_OFFSET "offset"
+#define MRVL_TOK_PARSER_UDF_PROTO_ETH "eth"
+#define MRVL_TOK_PARSER_UDF_FIELD_ETH_TYPE "type"
+#define MRVL_TOK_PARSER_UDF_PROTO_UDP "udp"
+#define MRVL_TOK_PARSER_UDF_FIELD_UDP_DPORT "dport"
+
+
 /** Number of tokens in range a-b = 2. */
 #define MAX_RNG_TOKENS 2
 
@@ -453,6 +466,175 @@ parse_policer(struct rte_cfgfile *file, int port, const char *sec_name,
        return 0;
 }
 
+/**
+ * Parse parser udf.
+ *
+ * @param file Config file handle.
+ * @param sec_name section name
+ * @param udf udf index
+ * @param cfg[out] Parsing results.
+ * @returns 0 in case of success, negative value otherwise.
+ */
+static int
+parse_udf(struct rte_cfgfile *file, const char *sec_name, int udf,
+         struct mrvl_cfg *cfg)
+{
+       struct pp2_parse_udf_params *udf_params;
+       const char *entry, *entry_field;
+       uint32_t val, i;
+       uint8_t field_size;
+       char malloc_name[32], tmp_arr[3];
+       /* field len in chars equal to '0x' + rest of data */
+#define FIELD_LEN_IN_CHARS(field_size) (uint32_t)(2 + (field_size) * 2)
+
+       udf_params = &cfg->pp2_cfg.prs_udfs.udfs[udf];
+
+       /* Read 'proto' field */
+       entry = rte_cfgfile_get_entry(file, sec_name,
+                                     MRVL_TOK_PARSER_UDF_PROTO);
+       if (!entry) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must be set\n", udf,
+                        MRVL_TOK_PARSER_UDF_PROTO);
+               return -1;
+       }
+
+       /* Read 'field' field */
+       entry_field = rte_cfgfile_get_entry(file, sec_name,
+                                      MRVL_TOK_PARSER_UDF_FIELD);
+       if (!entry_field) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must be set\n", udf,
+                        MRVL_TOK_PARSER_UDF_FIELD);
+               return -1;
+       }
+
+       if (!strncmp(entry, MRVL_TOK_PARSER_UDF_PROTO_ETH,
+                               sizeof(MRVL_TOK_PARSER_UDF_PROTO_ETH))) {
+               udf_params->match_proto = MV_NET_PROTO_ETH;
+               if (!strncmp(entry_field, MRVL_TOK_PARSER_UDF_FIELD_ETH_TYPE,
+                            sizeof(MRVL_TOK_PARSER_UDF_FIELD_ETH_TYPE))) {
+                       udf_params->match_field.eth = MV_NET_ETH_F_TYPE;
+                       field_size = 2;
+               } else {
+                       MRVL_LOG(ERR, "UDF[%d]: mismatch between '%s' proto "
+                                "and '%s' field\n", udf,
+                                MRVL_TOK_PARSER_UDF_PROTO_ETH,
+                                entry_field);
+                       return -1;
+               }
+       } else if (!strncmp(entry, MRVL_TOK_PARSER_UDF_PROTO_UDP,
+                               sizeof(MRVL_TOK_PARSER_UDF_PROTO_UDP))) {
+               udf_params->match_proto = MV_NET_PROTO_UDP;
+               if (!strncmp(entry_field, MRVL_TOK_PARSER_UDF_FIELD_UDP_DPORT,
+                            sizeof(MRVL_TOK_PARSER_UDF_FIELD_UDP_DPORT))) {
+                       udf_params->match_field.udp = MV_NET_UDP_F_DP;
+                       field_size = 2;
+               } else {
+                       MRVL_LOG(ERR, "UDF[%d]: mismatch between '%s' proto "
+                                "and '%s' field\n", udf,
+                                MRVL_TOK_PARSER_UDF_PROTO_UDP,
+                                entry_field);
+                       return -1;
+               }
+       } else {
+               MRVL_LOG(ERR, "UDF[%d]: Unsupported '%s' proto\n", udf, entry);
+               return -1;
+       }
+
+       snprintf(malloc_name, sizeof(malloc_name), "mrvl_udf_%d_key", udf);
+       udf_params->match_key = rte_zmalloc(malloc_name, field_size, 0);
+       if (udf_params->match_key == NULL) {
+               MRVL_LOG(ERR, "Cannot allocate udf %d key\n", udf);
+               return -1;
+       }
+       snprintf(malloc_name, sizeof(malloc_name), "mrvl_udf_%d_mask", udf);
+       udf_params->match_mask = rte_zmalloc(malloc_name, field_size, 0);
+       if (udf_params->match_mask == NULL) {
+               MRVL_LOG(ERR, "Cannot allocate udf %d mask\n", udf);
+               return -1;
+       }
+
+       /* Read 'key' field */
+       entry = rte_cfgfile_get_entry(file, sec_name, MRVL_TOK_PARSER_UDF_KEY);
+       if (!entry) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must be set\n", udf,
+                        MRVL_TOK_PARSER_UDF_KEY);
+               return -1;
+       }
+
+       if (strncmp(entry, "0x", 2) != 0)  {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must start with '0x'\n",
+                        udf, MRVL_TOK_PARSER_UDF_KEY);
+               return -EINVAL;
+       }
+
+       if (strlen(entry) != FIELD_LEN_IN_CHARS(field_size)) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field's len must be %d\n", udf,
+                        MRVL_TOK_PARSER_UDF_KEY,
+                        FIELD_LEN_IN_CHARS(field_size));
+               return -EINVAL;
+       }
+
+       entry += 2; /* skip the '0x' */
+       for (i = 0; i < field_size; i++) {
+               strncpy(tmp_arr, entry, 2);
+               tmp_arr[2] = '\0';
+               if (get_val_securely8(tmp_arr, 16,
+                                     &udf_params->match_key[i]) < 0) {
+                       MRVL_LOG(ERR, "UDF[%d]: '%s' field's value is not in "
+                               "hex format\n", udf, MRVL_TOK_PARSER_UDF_KEY);
+                       return -EINVAL;
+               }
+               entry += 2;
+       }
+
+       /* Read 'mask' field */
+       entry = rte_cfgfile_get_entry(file, sec_name, MRVL_TOK_PARSER_UDF_MASK);
+       if (!entry) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must be set\n", udf,
+                        MRVL_TOK_PARSER_UDF_MASK);
+               return -1;
+       }
+       if (strncmp(entry, "0x", 2) != 0) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must start with '0x'\n",
+                        udf, MRVL_TOK_PARSER_UDF_MASK);
+               return -EINVAL;
+       }
+
+       if (strlen(entry) != FIELD_LEN_IN_CHARS(field_size)) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field's len must be %d\n", udf,
+                        MRVL_TOK_PARSER_UDF_MASK,
+                        FIELD_LEN_IN_CHARS(field_size));
+               return -EINVAL;
+       }
+
+       entry += 2; /* skip the '0x' */
+       for (i = 0; i < field_size; i++) {
+               strncpy(tmp_arr, entry, 2);
+               tmp_arr[2] = '\0';
+               if (get_val_securely8(tmp_arr, 16,
+                                     &udf_params->match_mask[i]) < 0) {
+                       MRVL_LOG(ERR, "UDF[%d]: '%s' field's value is not in "
+                               "hex format\n", udf, MRVL_TOK_PARSER_UDF_MASK);
+                       return -EINVAL;
+               }
+               entry += 2;
+       }
+
+       /* Read offset */
+       entry = rte_cfgfile_get_entry(file, sec_name,
+                                     MRVL_TOK_PARSER_UDF_OFFSET);
+       if (!entry) {
+               MRVL_LOG(ERR, "UDF[%d]: '%s' field must be set\n", udf,
+                        MRVL_TOK_PARSER_UDF_OFFSET);
+               return -1;
+       }
+       if (get_val_securely(entry, &val) < 0)
+               return -1;
+       udf_params->offset = val;
+
+       return 0;
+}
+
 /**
  * Parse configuration - rte_kvargs_process handler.
  *
@@ -487,6 +669,36 @@ mrvl_get_cfg(const char *key __rte_unused, const char *path, void *extra_args)
                return -1;
        }
 
+       /* PP2 configuration */
+       n = rte_cfgfile_num_sections(file, MRVL_TOK_PARSER_UDF,
+               sizeof(MRVL_TOK_PARSER_UDF) - 1);
+
+       if (n && n > PP2_MAX_UDFS_SUPPORTED) {
+               MRVL_LOG(ERR, "found %d udf sections, but only %d are supported\n",
+                        n, PP2_MAX_UDFS_SUPPORTED);
+               return -1;
+       }
+       (*cfg)->pp2_cfg.prs_udfs.num_udfs = n;
+       for (i = 0; i < n; i++) {
+               snprintf(sec_name, sizeof(sec_name), "%s %d",
+                               MRVL_TOK_PARSER_UDF, i);
+
+               /* udf sections must be sequential. */
+               if (rte_cfgfile_num_sections(file, sec_name,
+                               strlen(sec_name)) <= 0) {
+                       MRVL_LOG(ERR, "udf sections must be sequential (0 - %d)\n",
+                                PP2_MAX_UDFS_SUPPORTED - 1);
+                       return -1;
+               }
+
+               ret = parse_udf(file, sec_name, i, *cfg);
+               if (ret) {
+                       MRVL_LOG(ERR, "Error in parsing %s!\n", sec_name);
+                       return -1;
+               }
+       }
+
+       /* PP2 Ports configuration */
        n = rte_cfgfile_num_sections(file, MRVL_TOK_PORT,
                sizeof(MRVL_TOK_PORT) - 1);
 
index 928cfe3..daf4776 100644 (file)
@@ -19,6 +19,9 @@
 
 /* config. */
 struct mrvl_cfg {
+       struct  {
+               struct pp2_parse_udfs   prs_udfs;
+       } pp2_cfg;
        struct port_cfg {
                enum pp2_ppio_eth_start_hdr eth_start_hdr;
                int rate_limit_enable;