Patch Detail

HTTP 200 OK
Allow: GET, PUT, PATCH, HEAD, OPTIONS
Content-Type: application/json
Vary: Accept

{
    "id": 40842,
    "url": "https://patches.dpdk.org/api/patches/40842/?format=api",
    "web_url": "https://patches.dpdk.org/project/dpdk/patch/20180608124155.140663-17-jasvinder.singh@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": "<20180608124155.140663-17-jasvinder.singh@intel.com>",
    "list_archive_url": "https://inbox.dpdk.org/dev/20180608124155.140663-17-jasvinder.singh@intel.com",
    "date": "2018-06-08T12:41:50",
    "name": "[dpdk-dev,16/21] net/softnic: add cli for pipeline table entries",
    "commit_ref": null,
    "pull_url": null,
    "state": "superseded",
    "archived": true,
    "hash": "4f902558fbb53c83fbcb76e5754df3e38eb85019",
    "submitter": {
        "id": 285,
        "url": "https://patches.dpdk.org/api/people/285/?format=api",
        "name": "Jasvinder Singh",
        "email": "jasvinder.singh@intel.com"
    },
    "delegate": {
        "id": 10018,
        "url": "https://patches.dpdk.org/api/users/10018/?format=api",
        "username": "cristian_dumitrescu",
        "first_name": "Cristian",
        "last_name": "Dumitrescu",
        "email": "cristian.dumitrescu@intel.com"
    },
    "mbox": "https://patches.dpdk.org/project/dpdk/patch/20180608124155.140663-17-jasvinder.singh@intel.com/mbox/",
    "series": [
        {
            "id": 52,
            "url": "https://patches.dpdk.org/api/series/52/?format=api",
            "web_url": "https://patches.dpdk.org/project/dpdk/list/?series=52",
            "date": "2018-06-08T12:41:35",
            "name": "[dpdk-dev,01/21] net/softnic: restructuring",
            "version": 1,
            "mbox": "https://patches.dpdk.org/series/52/mbox/"
        }
    ],
    "comments": "https://patches.dpdk.org/api/patches/40842/comments/",
    "check": "fail",
    "checks": "https://patches.dpdk.org/api/patches/40842/checks/",
    "tags": {},
    "related": [],
    "headers": {
        "Return-Path": "<dev-bounces@dpdk.org>",
        "X-Original-To": "patchwork@dpdk.org",
        "Delivered-To": "patchwork@dpdk.org",
        "Received": [
            "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id 985A97D0A;\n\tFri,  8 Jun 2018 14:42:42 +0200 (CEST)",
            "from mga04.intel.com (mga04.intel.com [192.55.52.120])\n\tby dpdk.org (Postfix) with ESMTP id DA99B6CD2\n\tfor <dev@dpdk.org>; Fri,  8 Jun 2018 14:42:15 +0200 (CEST)",
            "from fmsmga005.fm.intel.com ([10.253.24.32])\n\tby fmsmga104.fm.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384;\n\t08 Jun 2018 05:42:14 -0700",
            "from silpixa00381635.ir.intel.com (HELO\n\tsilpixa00381635.ger.corp.intel.com) ([10.237.222.149])\n\tby fmsmga005.fm.intel.com with ESMTP; 08 Jun 2018 05:42:12 -0700"
        ],
        "X-Amp-Result": "SKIPPED(no attachment in message)",
        "X-Amp-File-Uploaded": "False",
        "X-ExtLoop1": "1",
        "X-IronPort-AV": "E=Sophos;i=\"5.49,490,1520924400\"; d=\"scan'208\";a=\"235505385\"",
        "From": "Jasvinder Singh <jasvinder.singh@intel.com>",
        "To": "dev@dpdk.org",
        "Cc": "cristian.dumitrescu@intel.com",
        "Date": "Fri,  8 Jun 2018 13:41:50 +0100",
        "Message-Id": "<20180608124155.140663-17-jasvinder.singh@intel.com>",
        "X-Mailer": "git-send-email 2.9.3",
        "In-Reply-To": "<20180608124155.140663-1-jasvinder.singh@intel.com>",
        "References": "<20180608124155.140663-1-jasvinder.singh@intel.com>",
        "Subject": "[dpdk-dev] [PATCH 16/21] net/softnic: add cli for pipeline table\n\tentries",
        "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://dpdk.org/ml/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>",
        "List-Archive": "<http://dpdk.org/ml/archives/dev/>",
        "List-Post": "<mailto:dev@dpdk.org>",
        "List-Help": "<mailto:dev-request@dpdk.org?subject=help>",
        "List-Subscribe": "<https://dpdk.org/ml/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>",
        "Errors-To": "dev-bounces@dpdk.org",
        "Sender": "\"dev\" <dev-bounces@dpdk.org>"
    },
    "content": "Add cli commands for table entries in softnic pipeline objects.\n\nSigned-off-by: Cristian Dumitrescu <cristian.dumitrescu@intel.com>\nSigned-off-by: Jasvinder Singh <jasvinder.singh@intel.com>\n---\n drivers/net/softnic/rte_eth_softnic_cli.c       | 2177 ++++++++++++++++++++---\n drivers/net/softnic/rte_eth_softnic_internals.h |   35 +\n drivers/net/softnic/rte_eth_softnic_thread.c    | 1208 +++++++++++++\n 3 files changed, 3201 insertions(+), 219 deletions(-)",
    "diff": "diff --git a/drivers/net/softnic/rte_eth_softnic_cli.c b/drivers/net/softnic/rte_eth_softnic_cli.c\nindex 6884eac..20e13ad 100644\n--- a/drivers/net/softnic/rte_eth_softnic_cli.c\n+++ b/drivers/net/softnic/rte_eth_softnic_cli.c\n@@ -7,6 +7,9 @@\n #include <stdlib.h>\n #include <string.h>\n \n+#include <rte_common.h>\n+#include <rte_cycles.h>\n+\n #include \"rte_eth_softnic_internals.h\"\n #include \"parser.h\"\n \n@@ -1562,272 +1565,2008 @@ cmd_pipeline_port_in_disable(struct pmd_internals *softnic,\n }\n \n /**\n- * thread <thread_id> pipeline <pipeline_name> enable\n+ * <match> ::=\n+ *\n+ * match\n+ *    acl\n+ *       priority <priority>\n+ *       ipv4 | ipv6 <sa> <sa_depth> <da> <da_depth>\n+ *       <sp0> <sp1> <dp0> <dp1> <proto>\n+ *    | array <pos>\n+ *    | hash\n+ *       raw <key>\n+ *       | ipv4_5tuple <sa> <da> <sp> <dp> <proto>\n+ *       | ipv6_5tuple <sa> <da> <sp> <dp> <proto>\n+ *       | ipv4_addr <addr>\n+ *       | ipv6_addr <addr>\n+ *       | qinq <svlan> <cvlan>\n+ *    | lpm\n+ *       ipv4 | ipv6 <addr> <depth>\n  */\n-static void\n-cmd_thread_pipeline_enable(struct pmd_internals *softnic,\n-\tchar **tokens,\n+struct pkt_key_qinq {\n+\tuint16_t ethertype_svlan;\n+\tuint16_t svlan;\n+\tuint16_t ethertype_cvlan;\n+\tuint16_t cvlan;\n+} __attribute__((__packed__));\n+\n+struct pkt_key_ipv4_5tuple {\n+\tuint8_t time_to_live;\n+\tuint8_t proto;\n+\tuint16_t hdr_checksum;\n+\tuint32_t sa;\n+\tuint32_t da;\n+\tuint16_t sp;\n+\tuint16_t dp;\n+} __attribute__((__packed__));\n+\n+struct pkt_key_ipv6_5tuple {\n+\tuint16_t payload_length;\n+\tuint8_t proto;\n+\tuint8_t hop_limit;\n+\tuint8_t sa[16];\n+\tuint8_t da[16];\n+\tuint16_t sp;\n+\tuint16_t dp;\n+} __attribute__((__packed__));\n+\n+struct pkt_key_ipv4_addr {\n+\tuint32_t addr;\n+} __attribute__((__packed__));\n+\n+struct pkt_key_ipv6_addr {\n+\tuint8_t addr[16];\n+} __attribute__((__packed__));\n+\n+static uint32_t\n+parse_match(char **tokens,\n \tuint32_t n_tokens,\n \tchar *out,\n-\tsize_t out_size)\n+\tsize_t out_size,\n+\tstruct table_rule_match *m)\n {\n-\tchar *pipeline_name;\n-\tuint32_t thread_id;\n-\tint status;\n-\n-\tif (n_tokens != 5) {\n-\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n-\t\treturn;\n-\t}\n+\tmemset(m, 0, sizeof(*m));\n \n-\tif (parser_read_uint32(&thread_id, tokens[1]) != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"thread_id\");\n-\t\treturn;\n-\t}\n+\tif (n_tokens < 2)\n+\t\treturn 0;\n \n-\tif (strcmp(tokens[2], \"pipeline\") != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pipeline\");\n-\t\treturn;\n+\tif (strcmp(tokens[0], \"match\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"match\");\n+\t\treturn 0;\n \t}\n \n-\tpipeline_name = tokens[3];\n+\tif (strcmp(tokens[1], \"acl\") == 0) {\n+\t\tif (n_tokens < 14) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[4], \"enable\") != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"enable\");\n-\t\treturn;\n-\t}\n+\t\tm->match_type = TABLE_ACL;\n \n-\tstatus = thread_pipeline_enable(softnic, thread_id, pipeline_name);\n-\tif (status) {\n-\t\tsnprintf(out, out_size, MSG_CMD_FAIL, \"thread pipeline enable\");\n-\t\treturn;\n-\t}\n-}\n+\t\tif (strcmp(tokens[2], \"priority\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"priority\");\n+\t\t\treturn 0;\n+\t\t}\n \n-/**\n- * thread <thread_id> pipeline <pipeline_name> disable\n- */\n-static void\n-cmd_thread_pipeline_disable(struct pmd_internals *softnic,\n-\tchar **tokens,\n-\tuint32_t n_tokens,\n-\tchar *out,\n-\tsize_t out_size)\n-{\n-\tchar *pipeline_name;\n-\tuint32_t thread_id;\n-\tint status;\n+\t\tif (parser_read_uint32(&m->match.acl.priority,\n+\t\t\ttokens[3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"priority\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (n_tokens != 5) {\n-\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n-\t\treturn;\n-\t}\n+\t\tif (strcmp(tokens[4], \"ipv4\") == 0) {\n+\t\t\tstruct in_addr saddr, daddr;\n \n-\tif (parser_read_uint32(&thread_id, tokens[1]) != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"thread_id\");\n-\t\treturn;\n-\t}\n+\t\t\tm->match.acl.ip_version = 1;\n \n-\tif (strcmp(tokens[2], \"pipeline\") != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pipeline\");\n-\t\treturn;\n-\t}\n+\t\t\tif (parse_ipv4_addr(tokens[5], &saddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sa\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\t\t\tm->match.acl.ipv4.sa = rte_be_to_cpu_32(saddr.s_addr);\n \n-\tpipeline_name = tokens[3];\n+\t\t\tif (parse_ipv4_addr(tokens[7], &daddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"da\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\t\t\tm->match.acl.ipv4.da = rte_be_to_cpu_32(daddr.s_addr);\n+\t\t} else if (strcmp(tokens[4], \"ipv6\") == 0) {\n+\t\t\tstruct in6_addr saddr, daddr;\n \n-\tif (strcmp(tokens[4], \"disable\") != 0) {\n-\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"disable\");\n-\t\treturn;\n-\t}\n+\t\t\tm->match.acl.ip_version = 0;\n \n-\tstatus = thread_pipeline_disable(softnic, thread_id, pipeline_name);\n-\tif (status) {\n-\t\tsnprintf(out, out_size, MSG_CMD_FAIL,\n-\t\t\t\"thread pipeline disable\");\n-\t\treturn;\n-\t}\n-}\n+\t\t\tif (parse_ipv6_addr(tokens[5], &saddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sa\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\t\t\tmemcpy(m->match.acl.ipv6.sa, saddr.s6_addr, 16);\n \n-void\n-cli_process(char *in, char *out, size_t out_size, void *arg)\n-{\n-\tchar *tokens[CMD_MAX_TOKENS];\n-\tuint32_t n_tokens = RTE_DIM(tokens);\n-\tstruct pmd_internals *softnic = arg;\n-\tint status;\n+\t\t\tif (parse_ipv6_addr(tokens[7], &daddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"da\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\t\t\tmemcpy(m->match.acl.ipv6.da, daddr.s6_addr, 16);\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"ipv4 or ipv6\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (is_comment(in))\n-\t\treturn;\n+\t\tif (parser_read_uint32(&m->match.acl.sa_depth,\n+\t\t\ttokens[6]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sa_depth\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tstatus = parse_tokenize_string(in, tokens, &n_tokens);\n-\tif (status) {\n-\t\tsnprintf(out, out_size, MSG_ARG_TOO_MANY, \"\");\n-\t\treturn;\n-\t}\n+\t\tif (parser_read_uint32(&m->match.acl.da_depth,\n+\t\t\ttokens[8]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"da_depth\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (n_tokens == 0)\n-\t\treturn;\n+\t\tif (parser_read_uint16(&m->match.acl.sp0, tokens[9]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sp0\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[0], \"mempool\") == 0) {\n-\t\tcmd_mempool(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\tif (parser_read_uint16(&m->match.acl.sp1, tokens[10]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sp1\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[0], \"link\") == 0) {\n-\t\tcmd_link(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\tif (parser_read_uint16(&m->match.acl.dp0, tokens[11]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"dp0\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[0], \"swq\") == 0) {\n-\t\tcmd_swq(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\tif (parser_read_uint16(&m->match.acl.dp1, tokens[12]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"dp1\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[0], \"tap\") == 0) {\n-\t\tcmd_tap(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\tif (parser_read_uint8(&m->match.acl.proto, tokens[13]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"proto\");\n+\t\t\treturn 0;\n+\t\t}\n \n-\tif (strcmp(tokens[0], \"port\") == 0) {\n-\t\tcmd_port_in_action_profile(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\tm->match.acl.proto_mask = 0xff;\n \n-\tif (strcmp(tokens[0], \"table\") == 0) {\n-\t\tcmd_table_action_profile(softnic, tokens, n_tokens, out, out_size);\n-\t\treturn;\n-\t}\n+\t\treturn 14;\n+\t} /* acl */\n \n-\tif (strcmp(tokens[0], \"pipeline\") == 0) {\n-\t\tif ((n_tokens >= 3) &&\n-\t\t\t(strcmp(tokens[2], \"period\") == 0)) {\n-\t\t\tcmd_pipeline(softnic, tokens, n_tokens, out, out_size);\n-\t\t\treturn;\n+\tif (strcmp(tokens[1], \"array\") == 0) {\n+\t\tif (n_tokens < 3) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn 0;\n \t\t}\n \n-\t\tif ((n_tokens >= 5) &&\n-\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n-\t\t\t(strcmp(tokens[4], \"bsz\") == 0)) {\n-\t\t\tcmd_pipeline_port_in(softnic, tokens, n_tokens, out, out_size);\n-\t\t\treturn;\n-\t\t}\n+\t\tm->match_type = TABLE_ARRAY;\n \n-\t\tif ((n_tokens >= 5) &&\n-\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"out\") == 0) &&\n-\t\t\t(strcmp(tokens[4], \"bsz\") == 0)) {\n-\t\t\tcmd_pipeline_port_out(softnic, tokens, n_tokens, out, out_size);\n-\t\t\treturn;\n+\t\tif (parser_read_uint32(&m->match.array.pos, tokens[2]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"pos\");\n+\t\t\treturn 0;\n \t\t}\n \n-\t\tif ((n_tokens >= 4) &&\n-\t\t\t(strcmp(tokens[2], \"table\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"match\") == 0)) {\n-\t\t\tcmd_pipeline_table(softnic, tokens, n_tokens, out, out_size);\n-\t\t\treturn;\n-\t\t}\n+\t\treturn 3;\n+\t} /* array */\n \n-\t\tif ((n_tokens >= 6) &&\n-\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n-\t\t\t(strcmp(tokens[5], \"table\") == 0)) {\n-\t\t\tcmd_pipeline_port_in_table(softnic, tokens, n_tokens,\n-\t\t\t\tout, out_size);\n-\t\t\treturn;\n+\tif (strcmp(tokens[1], \"hash\") == 0) {\n+\t\tif (n_tokens < 3) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn 0;\n \t\t}\n \n-\t\tif ((n_tokens >= 6) &&\n-\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n-\t\t\t(strcmp(tokens[5], \"enable\") == 0)) {\n-\t\t\tcmd_pipeline_port_in_enable(softnic, tokens, n_tokens,\n-\t\t\t\tout, out_size);\n-\t\t\treturn;\n-\t\t}\n+\t\tm->match_type = TABLE_HASH;\n \n-\t\tif ((n_tokens >= 6) &&\n-\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n-\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n-\t\t\t(strcmp(tokens[5], \"disable\") == 0)) {\n-\t\t\tcmd_pipeline_port_in_disable(softnic, tokens, n_tokens,\n-\t\t\t\tout, out_size);\n-\t\t\treturn;\n-\t\t}\n-\t}\n+\t\tif (strcmp(tokens[2], \"raw\") == 0) {\n+\t\t\tuint32_t key_size = TABLE_RULE_MATCH_SIZE_MAX;\n \n-\tif (strcmp(tokens[0], \"thread\") == 0) {\n-\t\tif ((n_tokens >= 5) &&\n-\t\t\t(strcmp(tokens[4], \"enable\") == 0)) {\n-\t\t\tcmd_thread_pipeline_enable(softnic, tokens, n_tokens,\n-\t\t\t\tout, out_size);\n-\t\t\treturn;\n-\t\t}\n+\t\t\tif (n_tokens < 4) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t\tif ((n_tokens >= 5) &&\n-\t\t\t(strcmp(tokens[4], \"disable\") == 0)) {\n-\t\t\tcmd_thread_pipeline_disable(softnic, tokens, n_tokens,\n-\t\t\t\tout, out_size);\n-\t\t\treturn;\n-\t\t}\n-\t}\n+\t\t\tif (parse_hex_string(tokens[3],\n+\t\t\t\tm->match.hash.key, &key_size) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\tsnprintf(out, out_size, MSG_CMD_UNKNOWN, tokens[0]);\n-}\n+\t\t\treturn 4;\n+\t\t} /* hash raw */\n \n-int\n-cli_script_process(struct pmd_internals *softnic,\n-\tconst char *file_name,\n-\tsize_t msg_in_len_max,\n-\tsize_t msg_out_len_max)\n-{\n-\tchar *msg_in = NULL, *msg_out = NULL;\n-\tFILE *f = NULL;\n+\t\tif (strcmp(tokens[2], \"ipv4_5tuple\") == 0) {\n+\t\t\tstruct pkt_key_ipv4_5tuple *ipv4 =\n+\t\t\t\t(struct pkt_key_ipv4_5tuple *) m->match.hash.key;\n+\t\t\tstruct in_addr saddr, daddr;\n+\t\t\tuint16_t sp, dp;\n+\t\t\tuint8_t proto;\n \n-\t/* Check input arguments */\n-\tif ((file_name == NULL) ||\n-\t\t(strlen(file_name) == 0) ||\n-\t\t(msg_in_len_max == 0) ||\n-\t\t(msg_out_len_max == 0))\n-\t\treturn -EINVAL;\n+\t\t\tif (n_tokens < 8) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\tmsg_in = malloc(msg_in_len_max + 1);\n-\tmsg_out = malloc(msg_out_len_max + 1);\n-\tif ((msg_in == NULL) ||\n-\t\t(msg_out == NULL)) {\n-\t\tfree(msg_out);\n-\t\tfree(msg_in);\n-\t\treturn -ENOMEM;\n-\t}\n+\t\t\tif (parse_ipv4_addr(tokens[3], &saddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sa\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t/* Open input file */\n-\tf = fopen(file_name, \"r\");\n-\tif (f == NULL) {\n-\t\tfree(msg_out);\n-\t\tfree(msg_in);\n-\t\treturn -EIO;\n-\t}\n+\t\t\tif (parse_ipv4_addr(tokens[4], &daddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"da\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t/* Read file */\n-\tfor ( ; ; ) {\n-\t\tif (fgets(msg_in, msg_in_len_max + 1, f) == NULL)\n-\t\t\tbreak;\n+\t\t\tif (parser_read_uint16(&sp, tokens[5]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sp\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t\tprintf(\"%s\", msg_in);\n-\t\tmsg_out[0] = 0;\n+\t\t\tif (parser_read_uint16(&dp, tokens[6]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"dp\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t\tcli_process(msg_in,\n-\t\t\tmsg_out,\n-\t\t\tmsg_out_len_max,\n-\t\t\tsoftnic);\n+\t\t\tif (parser_read_uint8(&proto, tokens[7]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"proto\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t\tif (strlen(msg_out))\n-\t\t\tprintf(\"%s\", msg_out);\n-\t}\n+\t\t\tipv4->sa = saddr.s_addr;\n+\t\t\tipv4->da = daddr.s_addr;\n+\t\t\tipv4->sp = rte_cpu_to_be_16(sp);\n+\t\t\tipv4->dp = rte_cpu_to_be_16(dp);\n+\t\t\tipv4->proto = proto;\n+\n+\t\t\treturn 8;\n+\t\t} /* hash ipv4_5tuple */\n+\n+\t\tif (strcmp(tokens[2], \"ipv6_5tuple\") == 0) {\n+\t\t\tstruct pkt_key_ipv6_5tuple *ipv6 =\n+\t\t\t\t(struct pkt_key_ipv6_5tuple *) m->match.hash.key;\n+\t\t\tstruct in6_addr saddr, daddr;\n+\t\t\tuint16_t sp, dp;\n+\t\t\tuint8_t proto;\n+\n+\t\t\tif (n_tokens < 8) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n \n-\t/* Close file */\n-\tfclose(f);\n-\tfree(msg_out);\n-\tfree(msg_in);\n-\treturn 0;\n+\t\t\tif (parse_ipv6_addr(tokens[3], &saddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sa\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parse_ipv6_addr(tokens[4], &daddr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"da\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parser_read_uint16(&sp, tokens[5]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"sp\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parser_read_uint16(&dp, tokens[6]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"dp\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parser_read_uint8(&proto, tokens[7]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"proto\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tmemcpy(ipv6->sa, saddr.s6_addr, 16);\n+\t\t\tmemcpy(ipv6->da, daddr.s6_addr, 16);\n+\t\t\tipv6->sp = rte_cpu_to_be_16(sp);\n+\t\t\tipv6->dp = rte_cpu_to_be_16(dp);\n+\t\t\tipv6->proto = proto;\n+\n+\t\t\treturn 8;\n+\t\t} /* hash ipv6_5tuple */\n+\n+\t\tif (strcmp(tokens[2], \"ipv4_addr\") == 0) {\n+\t\t\tstruct pkt_key_ipv4_addr *ipv4_addr =\n+\t\t\t\t(struct pkt_key_ipv4_addr *) m->match.hash.key;\n+\t\t\tstruct in_addr addr;\n+\n+\t\t\tif (n_tokens < 4) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parse_ipv4_addr(tokens[3], &addr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"addr\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tipv4_addr->addr = addr.s_addr;\n+\n+\t\t\treturn 4;\n+\t\t} /* hash ipv4_addr */\n+\n+\t\tif (strcmp(tokens[2], \"ipv6_addr\") == 0) {\n+\t\t\tstruct pkt_key_ipv6_addr *ipv6_addr =\n+\t\t\t\t(struct pkt_key_ipv6_addr *) m->match.hash.key;\n+\t\t\tstruct in6_addr addr;\n+\n+\t\t\tif (n_tokens < 4) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif (parse_ipv6_addr(tokens[3], &addr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"addr\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tmemcpy(ipv6_addr->addr, addr.s6_addr, 16);\n+\n+\t\t\treturn 4;\n+\t\t} /* hash ipv6_5tuple */\n+\n+\t\tif (strcmp(tokens[2], \"qinq\") == 0) {\n+\t\t\tstruct pkt_key_qinq *qinq =\n+\t\t\t\t(struct pkt_key_qinq *) m->match.hash.key;\n+\t\t\tuint16_t svlan, cvlan;\n+\n+\t\t\tif (n_tokens < 5) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\ttokens[0]);\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif ((parser_read_uint16(&svlan, tokens[3]) != 0) ||\n+\t\t\t\t(svlan > 0xFFF)) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"svlan\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tif ((parser_read_uint16(&cvlan, tokens[4]) != 0) ||\n+\t\t\t\t(cvlan > 0xFFF)) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"cvlan\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tqinq->svlan = rte_cpu_to_be_16(svlan);\n+\t\t\tqinq->cvlan = rte_cpu_to_be_16(cvlan);\n+\n+\t\t\treturn 5;\n+\t\t} /* hash qinq */\n+\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn 0;\n+\t} /* hash */\n+\n+\tif (strcmp(tokens[1], \"lpm\") == 0) {\n+\t\tif (n_tokens < 5) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\tm->match_type = TABLE_LPM;\n+\n+\t\tif (strcmp(tokens[2], \"ipv4\") == 0) {\n+\t\t\tstruct in_addr addr;\n+\n+\t\t\tm->match.lpm.ip_version = 1;\n+\n+\t\t\tif (parse_ipv4_addr(tokens[3], &addr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"addr\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tm->match.lpm.ipv4 = rte_be_to_cpu_32(addr.s_addr);\n+\t\t} else if (strcmp(tokens[2], \"ipv6\") == 0) {\n+\t\t\tstruct in6_addr addr;\n+\n+\t\t\tm->match.lpm.ip_version = 0;\n+\n+\t\t\tif (parse_ipv6_addr(tokens[3], &addr) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\t\"addr\");\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\n+\t\t\tmemcpy(m->match.lpm.ipv6, addr.s6_addr, 16);\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"ipv4 or ipv6\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\tif (parser_read_uint8(&m->match.lpm.depth, tokens[4]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"depth\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\treturn 5;\n+\t} /* lpm */\n+\n+\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\"acl or array or hash or lpm\");\n+\treturn 0;\n+}\n+\n+/**\n+ * table_action ::=\n+ *\n+ * action\n+ *    fwd\n+ *       drop\n+ *       | port <port_id>\n+ *       | meta\n+ *       | table <table_id>\n+ *    [balance <out0> ... <out7>]\n+ *    [meter\n+ *       tc0 meter <meter_profile_id> policer g <pa> y <pa> r <pa>\n+ *       [tc1 meter <meter_profile_id> policer g <pa> y <pa> r <pa>\n+ *       tc2 meter <meter_profile_id> policer g <pa> y <pa> r <pa>\n+ *       tc3 meter <meter_profile_id> policer g <pa> y <pa> r <pa>]]\n+ *    [tm subport <subport_id> pipe <pipe_id>]\n+ *    [encap\n+ *       ether <da> <sa>\n+ *       | vlan <da> <sa> <pcp> <dei> <vid>\n+ *       | qinq <da> <sa> <pcp> <dei> <vid> <pcp> <dei> <vid>\n+ *       | mpls unicast | multicast\n+ *          <da> <sa>\n+ *          label0 <label> <tc> <ttl>\n+ *          [label1 <label> <tc> <ttl>\n+ *          [label2 <label> <tc> <ttl>\n+ *          [label3 <label> <tc> <ttl>]]]\n+ *       | pppoe <da> <sa> <session_id>]\n+ *    [nat ipv4 | ipv6 <addr> <port>]\n+ *    [ttl dec | keep]\n+ *    [stats]\n+ *    [time]\n+ *\n+ * where:\n+ *    <pa> ::= g | y | r | drop\n+ */\n+static uint32_t\n+parse_table_action_fwd(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens == 0) || (strcmp(tokens[0], \"fwd\") != 0))\n+\t\treturn 0;\n+\n+\ttokens++;\n+\tn_tokens--;\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"drop\") == 0)) {\n+\t\ta->fwd.action = RTE_PIPELINE_ACTION_DROP;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_FWD;\n+\t\treturn 1 + 1;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"port\") == 0)) {\n+\t\tuint32_t id;\n+\n+\t\tif ((n_tokens < 2) ||\n+\t\t\tparser_read_uint32(&id, tokens[1]))\n+\t\t\treturn 0;\n+\n+\t\ta->fwd.action = RTE_PIPELINE_ACTION_PORT;\n+\t\ta->fwd.id = id;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_FWD;\n+\t\treturn 1 + 2;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"meta\") == 0)) {\n+\t\ta->fwd.action = RTE_PIPELINE_ACTION_PORT_META;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_FWD;\n+\t\treturn 1 + 1;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"table\") == 0)) {\n+\t\tuint32_t id;\n+\n+\t\tif ((n_tokens < 2) ||\n+\t\t\tparser_read_uint32(&id, tokens[1]))\n+\t\t\treturn 0;\n+\n+\t\ta->fwd.action = RTE_PIPELINE_ACTION_TABLE;\n+\t\ta->fwd.id = id;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_FWD;\n+\t\treturn 1 + 2;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static uint32_t\n+parse_table_action_balance(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tuint32_t i;\n+\n+\tif ((n_tokens == 0) || (strcmp(tokens[0], \"balance\") != 0))\n+\t\treturn 0;\n+\n+\ttokens++;\n+\tn_tokens--;\n+\n+\tif (n_tokens < RTE_TABLE_ACTION_LB_TABLE_SIZE)\n+\t\treturn 0;\n+\n+\tfor (i = 0; i < RTE_TABLE_ACTION_LB_TABLE_SIZE; i++)\n+\t\tif (parser_read_uint32(&a->lb.out[i], tokens[i]) != 0)\n+\t\t\treturn 0;\n+\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_LB;\n+\treturn 1 + RTE_TABLE_ACTION_LB_TABLE_SIZE;\n+\n+}\n+\n+static int\n+parse_policer_action(char *token, enum rte_table_action_policer *a)\n+{\n+\tif (strcmp(token, \"g\") == 0) {\n+\t\t*a = RTE_TABLE_ACTION_POLICER_COLOR_GREEN;\n+\t\treturn 0;\n+\t}\n+\n+\tif (strcmp(token, \"y\") == 0) {\n+\t\t*a = RTE_TABLE_ACTION_POLICER_COLOR_YELLOW;\n+\t\treturn 0;\n+\t}\n+\n+\tif (strcmp(token, \"r\") == 0) {\n+\t\t*a = RTE_TABLE_ACTION_POLICER_COLOR_RED;\n+\t\treturn 0;\n+\t}\n+\n+\tif (strcmp(token, \"drop\") == 0) {\n+\t\t*a = RTE_TABLE_ACTION_POLICER_DROP;\n+\t\treturn 0;\n+\t}\n+\n+\treturn -1;\n+}\n+\n+static uint32_t\n+parse_table_action_meter_tc(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct rte_table_action_mtr_tc_params *mtr)\n+{\n+\tif ((n_tokens < 9) ||\n+\t\tstrcmp(tokens[0], \"meter\") ||\n+\t\tparser_read_uint32(&mtr->meter_profile_id, tokens[1]) ||\n+\t\tstrcmp(tokens[2], \"policer\") ||\n+\t\tstrcmp(tokens[3], \"g\") ||\n+\t\tparse_policer_action(tokens[4], &mtr->policer[e_RTE_METER_GREEN]) ||\n+\t\tstrcmp(tokens[5], \"y\") ||\n+\t\tparse_policer_action(tokens[6], &mtr->policer[e_RTE_METER_YELLOW]) ||\n+\t\tstrcmp(tokens[7], \"r\") ||\n+\t\tparse_policer_action(tokens[8], &mtr->policer[e_RTE_METER_RED]))\n+\t\treturn 0;\n+\n+\treturn 9;\n+}\n+\n+static uint32_t\n+parse_table_action_meter(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens == 0) || strcmp(tokens[0], \"meter\"))\n+\t\treturn 0;\n+\n+\ttokens++;\n+\tn_tokens--;\n+\n+\tif ((n_tokens < 10) ||\n+\t\tstrcmp(tokens[0], \"tc0\") ||\n+\t\t(parse_table_action_meter_tc(tokens + 1,\n+\t\t\tn_tokens - 1,\n+\t\t\t&a->mtr.mtr[0]) == 0))\n+\t\treturn 0;\n+\n+\ttokens += 10;\n+\tn_tokens -= 10;\n+\n+\tif ((n_tokens == 0) || strcmp(tokens[0], \"tc1\")) {\n+\t\ta->mtr.tc_mask = 1;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_MTR;\n+\t\treturn 1 + 10;\n+\t}\n+\n+\tif ((n_tokens < 30) ||\n+\t\t(parse_table_action_meter_tc(tokens + 1,\n+\t\t\tn_tokens - 1, &a->mtr.mtr[1]) == 0) ||\n+\t\tstrcmp(tokens[10], \"tc2\") ||\n+\t\t(parse_table_action_meter_tc(tokens + 11,\n+\t\t\tn_tokens - 11, &a->mtr.mtr[2]) == 0) ||\n+\t\tstrcmp(tokens[20], \"tc3\") ||\n+\t\t(parse_table_action_meter_tc(tokens + 21,\n+\t\t\tn_tokens - 21, &a->mtr.mtr[3]) == 0))\n+\t\treturn 0;\n+\n+\ta->mtr.tc_mask = 0xF;\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_MTR;\n+\treturn 1 + 10 + 3 * 10;\n+}\n+\n+static uint32_t\n+parse_table_action_tm(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tuint32_t subport_id, pipe_id;\n+\n+\tif ((n_tokens < 5) ||\n+\t\tstrcmp(tokens[0], \"tm\") ||\n+\t\tstrcmp(tokens[1], \"subport\") ||\n+\t\tparser_read_uint32(&subport_id, tokens[2]) ||\n+\t\tstrcmp(tokens[3], \"pipe\") ||\n+\t\tparser_read_uint32(&pipe_id, tokens[4]))\n+\t\treturn 0;\n+\n+\ta->tm.subport_id = subport_id;\n+\ta->tm.pipe_id = pipe_id;\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_TM;\n+\treturn 5;\n+}\n+\n+static uint32_t\n+parse_table_action_encap(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens == 0) || strcmp(tokens[0], \"encap\"))\n+\t\treturn 0;\n+\n+\ttokens++;\n+\tn_tokens--;\n+\n+\t/* ether */\n+\tif (n_tokens && (strcmp(tokens[0], \"ether\") == 0)) {\n+\t\tif ((n_tokens < 3) ||\n+\t\t\tparse_mac_addr(tokens[1], &a->encap.ether.ether.da) ||\n+\t\t\tparse_mac_addr(tokens[2], &a->encap.ether.ether.sa))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_ETHER;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\treturn 1 + 3;\n+\t}\n+\n+\t/* vlan */\n+\tif (n_tokens && (strcmp(tokens[0], \"vlan\") == 0)) {\n+\t\tuint32_t pcp, dei, vid;\n+\n+\t\tif ((n_tokens < 6) ||\n+\t\t\tparse_mac_addr(tokens[1], &a->encap.vlan.ether.da) ||\n+\t\t\tparse_mac_addr(tokens[2], &a->encap.vlan.ether.sa) ||\n+\t\t\tparser_read_uint32(&pcp, tokens[3]) ||\n+\t\t\t(pcp > 0x7) ||\n+\t\t\tparser_read_uint32(&dei, tokens[4]) ||\n+\t\t\t(dei > 0x1) ||\n+\t\t\tparser_read_uint32(&vid, tokens[5]) ||\n+\t\t\t(vid > 0xFFF))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.vlan.vlan.pcp = pcp & 0x7;\n+\t\ta->encap.vlan.vlan.dei = dei & 0x1;\n+\t\ta->encap.vlan.vlan.vid = vid & 0xFFF;\n+\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_VLAN;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\treturn 1 + 6;\n+\t}\n+\n+\t/* qinq */\n+\tif (n_tokens && (strcmp(tokens[0], \"qinq\") == 0)) {\n+\t\tuint32_t svlan_pcp, svlan_dei, svlan_vid;\n+\t\tuint32_t cvlan_pcp, cvlan_dei, cvlan_vid;\n+\n+\t\tif ((n_tokens < 9) ||\n+\t\t\tparse_mac_addr(tokens[1], &a->encap.qinq.ether.da) ||\n+\t\t\tparse_mac_addr(tokens[2], &a->encap.qinq.ether.sa) ||\n+\t\t\tparser_read_uint32(&svlan_pcp, tokens[3]) ||\n+\t\t\t(svlan_pcp > 0x7) ||\n+\t\t\tparser_read_uint32(&svlan_dei, tokens[4]) ||\n+\t\t\t(svlan_dei > 0x1) ||\n+\t\t\tparser_read_uint32(&svlan_vid, tokens[5]) ||\n+\t\t\t(svlan_vid > 0xFFF) ||\n+\t\t\tparser_read_uint32(&cvlan_pcp, tokens[6]) ||\n+\t\t\t(cvlan_pcp > 0x7) ||\n+\t\t\tparser_read_uint32(&cvlan_dei, tokens[7]) ||\n+\t\t\t(cvlan_dei > 0x1) ||\n+\t\t\tparser_read_uint32(&cvlan_vid, tokens[8]) ||\n+\t\t\t(cvlan_vid > 0xFFF))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.qinq.svlan.pcp = svlan_pcp & 0x7;\n+\t\ta->encap.qinq.svlan.dei = svlan_dei & 0x1;\n+\t\ta->encap.qinq.svlan.vid = svlan_vid & 0xFFF;\n+\t\ta->encap.qinq.cvlan.pcp = cvlan_pcp & 0x7;\n+\t\ta->encap.qinq.cvlan.dei = cvlan_dei & 0x1;\n+\t\ta->encap.qinq.cvlan.vid = cvlan_vid & 0xFFF;\n+\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_QINQ;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\treturn 1 + 9;\n+\t}\n+\n+\t/* mpls */\n+\tif (n_tokens && (strcmp(tokens[0], \"mpls\") == 0)) {\n+\t\tuint32_t label, tc, ttl;\n+\n+\t\tif (n_tokens < 8)\n+\t\t\treturn 0;\n+\n+\t\tif (strcmp(tokens[1], \"unicast\") == 0)\n+\t\t\ta->encap.mpls.unicast = 1;\n+\t\telse if (strcmp(tokens[1], \"multicast\") == 0)\n+\t\t\ta->encap.mpls.unicast = 0;\n+\t\telse\n+\t\t\treturn 0;\n+\n+\t\tif (parse_mac_addr(tokens[2], &a->encap.mpls.ether.da) ||\n+\t\t\tparse_mac_addr(tokens[3], &a->encap.mpls.ether.sa) ||\n+\t\t\tstrcmp(tokens[4], \"label0\") ||\n+\t\t\tparser_read_uint32(&label, tokens[5]) ||\n+\t\t\t(label > 0xFFFFF) ||\n+\t\t\tparser_read_uint32(&tc, tokens[6]) ||\n+\t\t\t(tc > 0x7) ||\n+\t\t\tparser_read_uint32(&ttl, tokens[7]) ||\n+\t\t\t(ttl > 0x3F))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.mpls.mpls[0].label = label;\n+\t\ta->encap.mpls.mpls[0].tc = tc;\n+\t\ta->encap.mpls.mpls[0].ttl = ttl;\n+\n+\t\ttokens += 8;\n+\t\tn_tokens -= 8;\n+\n+\t\tif ((n_tokens == 0) || strcmp(tokens[0], \"label1\")) {\n+\t\t\ta->encap.mpls.mpls_count = 1;\n+\t\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;\n+\t\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\t\treturn 1 + 8;\n+\t\t}\n+\n+\t\tif ((n_tokens < 4) ||\n+\t\t\tparser_read_uint32(&label, tokens[1]) ||\n+\t\t\t(label > 0xFFFFF) ||\n+\t\t\tparser_read_uint32(&tc, tokens[2]) ||\n+\t\t\t(tc > 0x7) ||\n+\t\t\tparser_read_uint32(&ttl, tokens[3]) ||\n+\t\t\t(ttl > 0x3F))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.mpls.mpls[1].label = label;\n+\t\ta->encap.mpls.mpls[1].tc = tc;\n+\t\ta->encap.mpls.mpls[1].ttl = ttl;\n+\n+\t\ttokens += 4;\n+\t\tn_tokens -= 4;\n+\n+\t\tif ((n_tokens == 0) || strcmp(tokens[0], \"label2\")) {\n+\t\t\ta->encap.mpls.mpls_count = 2;\n+\t\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;\n+\t\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\t\treturn 1 + 8 + 4;\n+\t\t}\n+\n+\t\tif ((n_tokens < 4) ||\n+\t\t\tparser_read_uint32(&label, tokens[1]) ||\n+\t\t\t(label > 0xFFFFF) ||\n+\t\t\tparser_read_uint32(&tc, tokens[2]) ||\n+\t\t\t(tc > 0x7) ||\n+\t\t\tparser_read_uint32(&ttl, tokens[3]) ||\n+\t\t\t(ttl > 0x3F))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.mpls.mpls[2].label = label;\n+\t\ta->encap.mpls.mpls[2].tc = tc;\n+\t\ta->encap.mpls.mpls[2].ttl = ttl;\n+\n+\t\ttokens += 4;\n+\t\tn_tokens -= 4;\n+\n+\t\tif ((n_tokens == 0) || strcmp(tokens[0], \"label3\")) {\n+\t\t\ta->encap.mpls.mpls_count = 3;\n+\t\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;\n+\t\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\t\treturn 1 + 8 + 4 + 4;\n+\t\t}\n+\n+\t\tif ((n_tokens < 4) ||\n+\t\t\tparser_read_uint32(&label, tokens[1]) ||\n+\t\t\t(label > 0xFFFFF) ||\n+\t\t\tparser_read_uint32(&tc, tokens[2]) ||\n+\t\t\t(tc > 0x7) ||\n+\t\t\tparser_read_uint32(&ttl, tokens[3]) ||\n+\t\t\t(ttl > 0x3F))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.mpls.mpls[3].label = label;\n+\t\ta->encap.mpls.mpls[3].tc = tc;\n+\t\ta->encap.mpls.mpls[3].ttl = ttl;\n+\n+\t\ta->encap.mpls.mpls_count = 4;\n+\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\treturn 1 + 8 + 4 + 4 + 4;\n+\t}\n+\n+\t/* pppoe */\n+\tif (n_tokens && (strcmp(tokens[0], \"pppoe\") == 0)) {\n+\t\tif ((n_tokens < 4) ||\n+\t\t\tparse_mac_addr(tokens[1], &a->encap.pppoe.ether.da) ||\n+\t\t\tparse_mac_addr(tokens[2], &a->encap.pppoe.ether.sa) ||\n+\t\t\tparser_read_uint16(&a->encap.pppoe.pppoe.session_id,\n+\t\t\t\ttokens[3]))\n+\t\t\treturn 0;\n+\n+\t\ta->encap.type = RTE_TABLE_ACTION_ENCAP_PPPOE;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;\n+\t\treturn 1 + 4;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static uint32_t\n+parse_table_action_nat(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens < 4) ||\n+\t\tstrcmp(tokens[0], \"nat\"))\n+\t\treturn 0;\n+\n+\tif (strcmp(tokens[1], \"ipv4\") == 0) {\n+\t\tstruct in_addr addr;\n+\t\tuint16_t port;\n+\n+\t\tif (parse_ipv4_addr(tokens[2], &addr) ||\n+\t\t\tparser_read_uint16(&port, tokens[3]))\n+\t\t\treturn 0;\n+\n+\t\ta->nat.ip_version = 1;\n+\t\ta->nat.addr.ipv4 = rte_be_to_cpu_32(addr.s_addr);\n+\t\ta->nat.port = port;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_NAT;\n+\t\treturn 4;\n+\t}\n+\n+\tif (strcmp(tokens[1], \"ipv6\") == 0) {\n+\t\tstruct in6_addr addr;\n+\t\tuint16_t port;\n+\n+\t\tif (parse_ipv6_addr(tokens[2], &addr) ||\n+\t\t\tparser_read_uint16(&port, tokens[3]))\n+\t\t\treturn 0;\n+\n+\t\ta->nat.ip_version = 0;\n+\t\tmemcpy(a->nat.addr.ipv6, addr.s6_addr, 16);\n+\t\ta->nat.port = port;\n+\t\ta->action_mask |= 1 << RTE_TABLE_ACTION_NAT;\n+\t\treturn 4;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static uint32_t\n+parse_table_action_ttl(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens < 2) ||\n+\t\tstrcmp(tokens[0], \"ttl\"))\n+\t\treturn 0;\n+\n+\tif (strcmp(tokens[1], \"dec\") == 0)\n+\t\ta->ttl.decrement = 1;\n+\telse if (strcmp(tokens[1], \"keep\") == 0)\n+\t\ta->ttl.decrement = 0;\n+\telse\n+\t\treturn 0;\n+\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_TTL;\n+\treturn 2;\n+}\n+\n+static uint32_t\n+parse_table_action_stats(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens < 1) ||\n+\t\tstrcmp(tokens[0], \"stats\"))\n+\t\treturn 0;\n+\n+\ta->stats.n_packets = 0;\n+\ta->stats.n_bytes = 0;\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_STATS;\n+\treturn 1;\n+}\n+\n+static uint32_t\n+parse_table_action_time(char **tokens,\n+\tuint32_t n_tokens,\n+\tstruct table_rule_action *a)\n+{\n+\tif ((n_tokens < 1) ||\n+\t\tstrcmp(tokens[0], \"time\"))\n+\t\treturn 0;\n+\n+\ta->time.time = rte_rdtsc();\n+\ta->action_mask |= 1 << RTE_TABLE_ACTION_TIME;\n+\treturn 1;\n+}\n+\n+static uint32_t\n+parse_table_action(char **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size,\n+\tstruct table_rule_action *a)\n+{\n+\tuint32_t n_tokens0 = n_tokens;\n+\n+\tmemset(a, 0, sizeof(*a));\n+\n+\tif ((n_tokens < 2) ||\n+\t\tstrcmp(tokens[0], \"action\"))\n+\t\treturn 0;\n+\n+\ttokens++;\n+\tn_tokens--;\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"fwd\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_fwd(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action fwd\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"balance\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_balance(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action balance\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"meter\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_meter(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action meter\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"tm\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_tm(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action tm\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"encap\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_encap(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action encap\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"nat\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_nat(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action nat\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"ttl\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_ttl(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action ttl\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"stats\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_stats(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action stats\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens && (strcmp(tokens[0], \"time\") == 0)) {\n+\t\tuint32_t n;\n+\n+\t\tn = parse_table_action_time(tokens, n_tokens, a);\n+\t\tif (n == 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"action time\");\n+\t\t\treturn 0;\n+\t\t}\n+\n+\t\ttokens += n;\n+\t\tn_tokens -= n;\n+\t}\n+\n+\tif (n_tokens0 - n_tokens == 1) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"action\");\n+\t\treturn 0;\n+\t}\n+\n+\treturn n_tokens0 - n_tokens;\n+}\n+\n+/**\n+ * pipeline <pipeline_name> table <table_id> rule add\n+ *    match <match>\n+ *    action <table_action>\n+ */\n+static void\n+cmd_pipeline_table_rule_add(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct table_rule_match m;\n+\tstruct table_rule_action a;\n+\tchar *pipeline_name;\n+\tvoid *data;\n+\tuint32_t table_id, t0, n_tokens_parsed;\n+\tint status;\n+\n+\tif (n_tokens < 8) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&table_id, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"rule\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rule\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"add\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"add\");\n+\t\treturn;\n+\t}\n+\n+\tt0 = 6;\n+\n+\t/* match */\n+\tn_tokens_parsed = parse_match(tokens + t0,\n+\t\tn_tokens - t0,\n+\t\tout,\n+\t\tout_size,\n+\t\t&m);\n+\tif (n_tokens_parsed == 0)\n+\t\treturn;\n+\tt0 += n_tokens_parsed;\n+\n+\t/* action */\n+\tn_tokens_parsed = parse_table_action(tokens + t0,\n+\t\tn_tokens - t0,\n+\t\tout,\n+\t\tout_size,\n+\t\t&a);\n+\tif (n_tokens_parsed == 0)\n+\t\treturn;\n+\tt0 += n_tokens_parsed;\n+\n+\tif (t0 != n_tokens) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tstatus = pipeline_table_rule_add(softnic,\n+\t\tpipeline_name,\n+\t\ttable_id,\n+\t\t&m,\n+\t\t&a,\n+\t\t&data);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * pipeline <pipeline_name> table <table_id> rule add\n+ *    match\n+ *       default\n+ *    action\n+ *       fwd\n+ *          drop\n+ *          | port <port_id>\n+ *          | meta\n+ *          | table <table_id>\n+ */\n+static void\n+cmd_pipeline_table_rule_add_default(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct table_rule_action action;\n+\tvoid *data;\n+\tchar *pipeline_name;\n+\tuint32_t table_id;\n+\tint status;\n+\n+\tif ((n_tokens != 11) && (n_tokens != 12)) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&table_id, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"rule\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rule\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"add\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"add\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[6], \"match\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"match\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[7], \"default\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"default\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[8], \"action\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"action\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[9], \"fwd\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"fwd\");\n+\t\treturn;\n+\t}\n+\n+\taction.action_mask = 1 << RTE_TABLE_ACTION_FWD;\n+\n+\tif (strcmp(tokens[10], \"drop\") == 0) {\n+\t\tif (n_tokens != 11) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\taction.fwd.action = RTE_PIPELINE_ACTION_DROP;\n+\t} else if (strcmp(tokens[10], \"port\") == 0) {\n+\t\tuint32_t id;\n+\n+\t\tif (n_tokens != 12) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (parser_read_uint32(&id, tokens[11]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\taction.fwd.action = RTE_PIPELINE_ACTION_PORT;\n+\t\taction.fwd.id = id;\n+\t} else if (strcmp(tokens[10], \"meta\") == 0) {\n+\t\tif (n_tokens != 11) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\taction.fwd.action = RTE_PIPELINE_ACTION_PORT_META;\n+\t} else if (strcmp(tokens[10], \"table\") == 0) {\n+\t\tuint32_t id;\n+\n+\t\tif (n_tokens != 12) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (parser_read_uint32(&id, tokens[11]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\taction.fwd.action = RTE_PIPELINE_ACTION_TABLE;\n+\t\taction.fwd.id = id;\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\"drop or port or meta or table\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = pipeline_table_rule_add_default(softnic,\n+\t\tpipeline_name,\n+\t\ttable_id,\n+\t\t&action,\n+\t\t&data);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * pipeline <pipeline_name> table <table_id> rule add bulk <file_name> <n_rules>\n+ *\n+ * File <file_name>:\n+ * - line format: match <match> action <action>\n+ */\n+static int\n+cli_rule_file_process(const char *file_name,\n+\tsize_t line_len_max,\n+\tstruct table_rule_match *m,\n+\tstruct table_rule_action *a,\n+\tuint32_t *n_rules,\n+\tuint32_t *line_number,\n+\tchar *out,\n+\tsize_t out_size);\n+\n+static void\n+cmd_pipeline_table_rule_add_bulk(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct table_rule_match *match;\n+\tstruct table_rule_action *action;\n+\tvoid **data;\n+\tchar *pipeline_name, *file_name;\n+\tuint32_t table_id, n_rules, n_rules_parsed, line_number;\n+\tint status;\n+\n+\tif (n_tokens != 9) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&table_id, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"rule\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rule\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"add\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"add\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[6], \"bulk\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"bulk\");\n+\t\treturn;\n+\t}\n+\n+\tfile_name = tokens[7];\n+\n+\tif ((parser_read_uint32(&n_rules, tokens[8]) != 0) ||\n+\t\t(n_rules == 0)) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_rules\");\n+\t\treturn;\n+\t}\n+\n+\t/* Memory allocation. */\n+\tmatch = calloc(n_rules, sizeof(struct table_rule_match));\n+\taction = calloc(n_rules, sizeof(struct table_rule_action));\n+\tdata = calloc(n_rules, sizeof(void *));\n+\tif ((match == NULL) || (action == NULL) || (data == NULL)) {\n+\t\tsnprintf(out, out_size, MSG_OUT_OF_MEMORY);\n+\t\tfree(data);\n+\t\tfree(action);\n+\t\tfree(match);\n+\t\treturn;\n+\t}\n+\n+\t/* Load rule file */\n+\tn_rules_parsed = n_rules;\n+\tstatus = cli_rule_file_process(file_name,\n+\t\t1024,\n+\t\tmatch,\n+\t\taction,\n+\t\t&n_rules_parsed,\n+\t\t&line_number,\n+\t\tout,\n+\t\tout_size);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_FILE_ERR, file_name, line_number);\n+\t\tfree(data);\n+\t\tfree(action);\n+\t\tfree(match);\n+\t\treturn;\n+\t}\n+\tif (n_rules_parsed != n_rules) {\n+\t\tsnprintf(out, out_size, MSG_FILE_NOT_ENOUGH, file_name);\n+\t\tfree(data);\n+\t\tfree(action);\n+\t\tfree(match);\n+\t\treturn;\n+\t}\n+\n+\t/* Rule bulk add */\n+\tstatus = pipeline_table_rule_add_bulk(softnic,\n+\t\tpipeline_name,\n+\t\ttable_id,\n+\t\tmatch,\n+\t\taction,\n+\t\tdata,\n+\t\t&n_rules);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\tfree(data);\n+\t\tfree(action);\n+\t\tfree(match);\n+\t\treturn;\n+\t}\n+\n+\t/* Memory free */\n+\tfree(data);\n+\tfree(action);\n+\tfree(match);\n+}\n+\n+/**\n+ * pipeline <pipeline_name> table <table_id> rule delete\n+ *    match <match>\n+ */\n+static void\n+cmd_pipeline_table_rule_delete(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct table_rule_match m;\n+\tchar *pipeline_name;\n+\tuint32_t table_id, n_tokens_parsed, t0;\n+\tint status;\n+\n+\tif (n_tokens < 8) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&table_id, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"rule\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rule\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"delete\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"delete\");\n+\t\treturn;\n+\t}\n+\n+\tt0 = 6;\n+\n+\t/* match */\n+\tn_tokens_parsed = parse_match(tokens + t0,\n+\t\tn_tokens - t0,\n+\t\tout,\n+\t\tout_size,\n+\t\t&m);\n+\tif (n_tokens_parsed == 0)\n+\t\treturn;\n+\tt0 += n_tokens_parsed;\n+\n+\tif (n_tokens != t0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tstatus = pipeline_table_rule_delete(softnic,\n+\t\tpipeline_name,\n+\t\ttable_id,\n+\t\t&m);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * pipeline <pipeline_name> table <table_id> rule delete\n+ *    match\n+ *       default\n+ */\n+static void\n+cmd_pipeline_table_rule_delete_default(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tchar *pipeline_name;\n+\tuint32_t table_id;\n+\tint status;\n+\n+\tif (n_tokens != 8) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&table_id, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"rule\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rule\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"delete\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"delete\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[6], \"match\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"match\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[7], \"default\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"default\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = pipeline_table_rule_delete_default(softnic,\n+\t\tpipeline_name,\n+\t\ttable_id);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * thread <thread_id> pipeline <pipeline_name> enable\n+ */\n+static void\n+cmd_thread_pipeline_enable(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tchar *pipeline_name;\n+\tuint32_t thread_id;\n+\tint status;\n+\n+\tif (n_tokens != 5) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&thread_id, tokens[1]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"thread_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[2], \"pipeline\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pipeline\");\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[3];\n+\n+\tif (strcmp(tokens[4], \"enable\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"enable\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = thread_pipeline_enable(softnic, thread_id, pipeline_name);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, \"thread pipeline enable\");\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * thread <thread_id> pipeline <pipeline_name> disable\n+ */\n+static void\n+cmd_thread_pipeline_disable(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tchar *pipeline_name;\n+\tuint32_t thread_id;\n+\tint status;\n+\n+\tif (n_tokens != 5) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tif (parser_read_uint32(&thread_id, tokens[1]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"thread_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[2], \"pipeline\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pipeline\");\n+\t\treturn;\n+\t}\n+\n+\tpipeline_name = tokens[3];\n+\n+\tif (strcmp(tokens[4], \"disable\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"disable\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = thread_pipeline_disable(softnic, thread_id, pipeline_name);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL,\n+\t\t\t\"thread pipeline disable\");\n+\t\treturn;\n+\t}\n+}\n+\n+void\n+cli_process(char *in, char *out, size_t out_size, void *arg)\n+{\n+\tchar *tokens[CMD_MAX_TOKENS];\n+\tuint32_t n_tokens = RTE_DIM(tokens);\n+\tstruct pmd_internals *softnic = arg;\n+\tint status;\n+\n+\tif (is_comment(in))\n+\t\treturn;\n+\n+\tstatus = parse_tokenize_string(in, tokens, &n_tokens);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_ARG_TOO_MANY, \"\");\n+\t\treturn;\n+\t}\n+\n+\tif (n_tokens == 0)\n+\t\treturn;\n+\n+\tif (strcmp(tokens[0], \"mempool\") == 0) {\n+\t\tcmd_mempool(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"link\") == 0) {\n+\t\tcmd_link(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"swq\") == 0) {\n+\t\tcmd_swq(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"tap\") == 0) {\n+\t\tcmd_tap(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"port\") == 0) {\n+\t\tcmd_port_in_action_profile(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"table\") == 0) {\n+\t\tcmd_table_action_profile(softnic, tokens, n_tokens, out, out_size);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[0], \"pipeline\") == 0) {\n+\t\tif ((n_tokens >= 3) &&\n+\t\t\t(strcmp(tokens[2], \"period\") == 0)) {\n+\t\t\tcmd_pipeline(softnic, tokens, n_tokens, out, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 5) &&\n+\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n+\t\t\t(strcmp(tokens[4], \"bsz\") == 0)) {\n+\t\t\tcmd_pipeline_port_in(softnic, tokens, n_tokens, out, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 5) &&\n+\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"out\") == 0) &&\n+\t\t\t(strcmp(tokens[4], \"bsz\") == 0)) {\n+\t\t\tcmd_pipeline_port_out(softnic, tokens, n_tokens, out, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 4) &&\n+\t\t\t(strcmp(tokens[2], \"table\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"match\") == 0)) {\n+\t\t\tcmd_pipeline_table(softnic, tokens, n_tokens, out, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 6) &&\n+\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"table\") == 0)) {\n+\t\t\tcmd_pipeline_port_in_table(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 6) &&\n+\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"enable\") == 0)) {\n+\t\t\tcmd_pipeline_port_in_enable(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 6) &&\n+\t\t\t(strcmp(tokens[2], \"port\") == 0) &&\n+\t\t\t(strcmp(tokens[3], \"in\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"disable\") == 0)) {\n+\t\t\tcmd_pipeline_port_in_disable(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 7) &&\n+\t\t\t(strcmp(tokens[2], \"table\") == 0) &&\n+\t\t\t(strcmp(tokens[4], \"rule\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"add\") == 0) &&\n+\t\t\t(strcmp(tokens[6], \"match\") == 0)) {\n+\t\t\tif ((n_tokens >= 8) &&\n+\t\t\t\t(strcmp(tokens[7], \"default\") == 0)) {\n+\t\t\t\tcmd_pipeline_table_rule_add_default(softnic, tokens,\n+\t\t\t\t\tn_tokens, out, out_size);\n+\t\t\t\treturn;\n+\t\t\t}\n+\n+\t\t\tcmd_pipeline_table_rule_add(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 7) &&\n+\t\t\t(strcmp(tokens[2], \"table\") == 0) &&\n+\t\t\t(strcmp(tokens[4], \"rule\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"add\") == 0) &&\n+\t\t\t(strcmp(tokens[6], \"bulk\") == 0)) {\n+\t\t\tcmd_pipeline_table_rule_add_bulk(softnic, tokens,\n+\t\t\t\tn_tokens, out, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 7) &&\n+\t\t\t(strcmp(tokens[2], \"table\") == 0) &&\n+\t\t\t(strcmp(tokens[4], \"rule\") == 0) &&\n+\t\t\t(strcmp(tokens[5], \"delete\") == 0) &&\n+\t\t\t(strcmp(tokens[6], \"match\") == 0)) {\n+\t\t\tif ((n_tokens >= 8) &&\n+\t\t\t\t(strcmp(tokens[7], \"default\") == 0)) {\n+\t\t\t\tcmd_pipeline_table_rule_delete_default(softnic, tokens,\n+\t\t\t\t\tn_tokens, out, out_size);\n+\t\t\t\treturn;\n+\t\t\t\t}\n+\n+\t\t\tcmd_pipeline_table_rule_delete(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\t}\n+\n+\tif (strcmp(tokens[0], \"thread\") == 0) {\n+\t\tif ((n_tokens >= 5) &&\n+\t\t\t(strcmp(tokens[4], \"enable\") == 0)) {\n+\t\t\tcmd_thread_pipeline_enable(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((n_tokens >= 5) &&\n+\t\t\t(strcmp(tokens[4], \"disable\") == 0)) {\n+\t\t\tcmd_thread_pipeline_disable(softnic, tokens, n_tokens,\n+\t\t\t\tout, out_size);\n+\t\t\treturn;\n+\t\t}\n+\t}\n+\n+\tsnprintf(out, out_size, MSG_CMD_UNKNOWN, tokens[0]);\n+}\n+\n+int\n+cli_script_process(struct pmd_internals *softnic,\n+\tconst char *file_name,\n+\tsize_t msg_in_len_max,\n+\tsize_t msg_out_len_max)\n+{\n+\tchar *msg_in = NULL, *msg_out = NULL;\n+\tFILE *f = NULL;\n+\n+\t/* Check input arguments */\n+\tif ((file_name == NULL) ||\n+\t\t(strlen(file_name) == 0) ||\n+\t\t(msg_in_len_max == 0) ||\n+\t\t(msg_out_len_max == 0))\n+\t\treturn -EINVAL;\n+\n+\tmsg_in = malloc(msg_in_len_max + 1);\n+\tmsg_out = malloc(msg_out_len_max + 1);\n+\tif ((msg_in == NULL) ||\n+\t\t(msg_out == NULL)) {\n+\t\tfree(msg_out);\n+\t\tfree(msg_in);\n+\t\treturn -ENOMEM;\n+\t}\n+\n+\t/* Open input file */\n+\tf = fopen(file_name, \"r\");\n+\tif (f == NULL) {\n+\t\tfree(msg_out);\n+\t\tfree(msg_in);\n+\t\treturn -EIO;\n+\t}\n+\n+\t/* Read file */\n+\tfor ( ; ; ) {\n+\t\tif (fgets(msg_in, msg_in_len_max + 1, f) == NULL)\n+\t\t\tbreak;\n+\n+\t\tprintf(\"%s\", msg_in);\n+\t\tmsg_out[0] = 0;\n+\n+\t\tcli_process(msg_in,\n+\t\t\tmsg_out,\n+\t\t\tmsg_out_len_max,\n+\t\t\tsoftnic);\n+\n+\t\tif (strlen(msg_out))\n+\t\t\tprintf(\"%s\", msg_out);\n+\t}\n+\n+\t/* Close file */\n+\tfclose(f);\n+\tfree(msg_out);\n+\tfree(msg_in);\n+\treturn 0;\n+}\n+\n+static int\n+cli_rule_file_process(const char *file_name,\n+\tsize_t line_len_max,\n+\tstruct table_rule_match *m,\n+\tstruct table_rule_action *a,\n+\tuint32_t *n_rules,\n+\tuint32_t *line_number,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tFILE *f = NULL;\n+\tchar *line = NULL;\n+\tuint32_t rule_id, line_id;\n+\tint status = 0;\n+\n+\t/* Check input arguments */\n+\tif ((file_name == NULL) ||\n+\t\t(strlen(file_name) == 0) ||\n+\t\t(line_len_max == 0)) {\n+\t\t*line_number = 0;\n+\t\treturn -EINVAL;\n+\t}\n+\n+\t/* Memory allocation */\n+\tline = malloc(line_len_max + 1);\n+\tif (line == NULL) {\n+\t\t*line_number = 0;\n+\t\treturn -ENOMEM;\n+\t}\n+\n+\t/* Open file */\n+\tf = fopen(file_name, \"r\");\n+\tif (f == NULL) {\n+\t\t*line_number = 0;\n+\t\tfree(line);\n+\t\treturn -EIO;\n+\t}\n+\n+\t/* Read file */\n+\tfor (line_id = 1, rule_id = 0; rule_id < *n_rules; line_id++) {\n+\t\tchar *tokens[CMD_MAX_TOKENS];\n+\t\tuint32_t n_tokens, n_tokens_parsed, t0;\n+\n+\t\t/* Read next line from file. */\n+\t\tif (fgets(line, line_len_max + 1, f) == NULL)\n+\t\t\tbreak;\n+\n+\t\t/* Comment. */\n+\t\tif (is_comment(line))\n+\t\t\tcontinue;\n+\n+\t\t/* Parse line. */\n+\t\tn_tokens = RTE_DIM(tokens);\n+\t\tstatus = parse_tokenize_string(line, tokens, &n_tokens);\n+\t\tif (status) {\n+\t\t\tstatus = -EINVAL;\n+\t\t\tbreak;\n+\t\t}\n+\n+\t\t/* Empty line. */\n+\t\tif (n_tokens == 0)\n+\t\t\tcontinue;\n+\t\tt0 = 0;\n+\n+\t\t/* Rule match. */\n+\t\tn_tokens_parsed = parse_match(tokens + t0,\n+\t\t\tn_tokens - t0,\n+\t\t\tout,\n+\t\t\tout_size,\n+\t\t\t&m[rule_id]);\n+\t\tif (n_tokens_parsed == 0) {\n+\t\t\tstatus = -EINVAL;\n+\t\t\tbreak;\n+\t\t}\n+\t\tt0 += n_tokens_parsed;\n+\n+\t\t/* Rule action. */\n+\t\tn_tokens_parsed = parse_table_action(tokens + t0,\n+\t\t\tn_tokens - t0,\n+\t\t\tout,\n+\t\t\tout_size,\n+\t\t\t&a[rule_id]);\n+\t\tif (n_tokens_parsed == 0) {\n+\t\t\tstatus = -EINVAL;\n+\t\t\tbreak;\n+\t\t}\n+\t\tt0 += n_tokens_parsed;\n+\n+\t\t/* Line completed. */\n+\t\tif (t0 < n_tokens) {\n+\t\t\tstatus = -EINVAL;\n+\t\t\tbreak;\n+\t\t}\n+\n+\t\t/* Increment rule count */\n+\t\trule_id++;\n+\t}\n+\n+\t/* Close file */\n+\tfclose(f);\n+\n+\t/* Memory free */\n+\tfree(line);\n+\n+\t*n_rules = rule_id;\n+\t*line_number = line_id;\n+\treturn status;\n }\ndiff --git a/drivers/net/softnic/rte_eth_softnic_internals.h b/drivers/net/softnic/rte_eth_softnic_internals.h\nindex 37c8583..eaf339b 100644\n--- a/drivers/net/softnic/rte_eth_softnic_internals.h\n+++ b/drivers/net/softnic/rte_eth_softnic_internals.h\n@@ -787,6 +787,41 @@ pipeline_port_in_disable(struct pmd_internals *p,\n \tconst char *pipeline_name,\n \tuint32_t port_id);\n \n+int\n+pipeline_table_rule_add(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match,\n+\tstruct table_rule_action *action,\n+\tvoid **data);\n+\n+int\n+pipeline_table_rule_add_bulk(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match,\n+\tstruct table_rule_action *action,\n+\tvoid **data,\n+\tuint32_t *n_rules);\n+\n+int\n+pipeline_table_rule_add_default(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_action *action,\n+\tvoid **data);\n+\n+int\n+pipeline_table_rule_delete(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match);\n+\n+int\n+pipeline_table_rule_delete_default(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id);\n+\n /**\n  * Thread\n  */\ndiff --git a/drivers/net/softnic/rte_eth_softnic_thread.c b/drivers/net/softnic/rte_eth_softnic_thread.c\nindex ecc525a..bd98b59 100644\n--- a/drivers/net/softnic/rte_eth_softnic_thread.c\n+++ b/drivers/net/softnic/rte_eth_softnic_thread.c\n@@ -4,10 +4,16 @@\n \n #include <stdlib.h>\n \n+#include <rte_common.h>\n #include <rte_cycles.h>\n #include <rte_lcore.h>\n #include <rte_ring.h>\n \n+#include <rte_table_acl.h>\n+#include <rte_table_array.h>\n+#include <rte_table_hash.h>\n+#include <rte_table_lpm.h>\n+#include <rte_table_lpm_ipv6.h>\n #include \"rte_eth_softnic_internals.h\"\n \n /**\n@@ -485,16 +491,71 @@ enum pipeline_req_type {\n \tPIPELINE_REQ_PORT_IN_ENABLE,\n \tPIPELINE_REQ_PORT_IN_DISABLE,\n \n+\t/* Table */\n+\tPIPELINE_REQ_TABLE_RULE_ADD,\n+\tPIPELINE_REQ_TABLE_RULE_ADD_DEFAULT,\n+\tPIPELINE_REQ_TABLE_RULE_ADD_BULK,\n+\tPIPELINE_REQ_TABLE_RULE_DELETE,\n+\tPIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT,\n+\n \tPIPELINE_REQ_MAX\n };\n \n+struct pipeline_msg_req_table_rule_add {\n+\tstruct table_rule_match match;\n+\tstruct table_rule_action action;\n+};\n+\n+struct pipeline_msg_req_table_rule_add_default {\n+\tstruct table_rule_action action;\n+};\n+\n+struct pipeline_msg_req_table_rule_add_bulk {\n+\tstruct table_rule_match *match;\n+\tstruct table_rule_action *action;\n+\tvoid **data;\n+\tuint32_t n_rules;\n+\tint bulk;\n+};\n+\n+struct pipeline_msg_req_table_rule_delete {\n+\tstruct table_rule_match match;\n+};\n+\n struct pipeline_msg_req {\n \tenum pipeline_req_type type;\n \tuint32_t id; /* Port IN, port OUT or table ID */\n+\n+\tRTE_STD_C11\n+\tunion {\n+\t\tstruct pipeline_msg_req_table_rule_add table_rule_add;\n+\t\tstruct pipeline_msg_req_table_rule_add_default table_rule_add_default;\n+\t\tstruct pipeline_msg_req_table_rule_add_bulk table_rule_add_bulk;\n+\t\tstruct pipeline_msg_req_table_rule_delete table_rule_delete;\n+\t};\n+};\n+\n+struct pipeline_msg_rsp_table_rule_add {\n+\tvoid *data;\n+};\n+\n+struct pipeline_msg_rsp_table_rule_add_default {\n+\tvoid *data;\n+};\n+\n+struct pipeline_msg_rsp_table_rule_add_bulk {\n+\tuint32_t n_rules;\n };\n \n struct pipeline_msg_rsp {\n \tint status;\n+\n+\tRTE_STD_C11\n+\tunion {\n+\t\tstruct pipeline_msg_rsp_table_rule_add table_rule_add;\n+\t\tstruct pipeline_msg_rsp_table_rule_add_default table_rule_add_default;\n+\t\tstruct pipeline_msg_rsp_table_rule_add_bulk table_rule_add_bulk;\n+\t};\n };\n \n /**\n@@ -623,6 +684,430 @@ pipeline_port_in_disable(struct pmd_internals *softnic,\n \treturn status;\n }\n \n+static int\n+match_check(struct table_rule_match *match,\n+\tstruct pipeline *p,\n+\tuint32_t table_id)\n+{\n+\tstruct table *table;\n+\n+\tif ((match == NULL) ||\n+\t\t(p == NULL) ||\n+\t\t(table_id >= p->n_tables))\n+\t\treturn -1;\n+\n+\ttable = &p->table[table_id];\n+\tif (match->match_type != table->params.match_type)\n+\t\treturn -1;\n+\n+\tswitch (match->match_type) {\n+\tcase TABLE_ACL:\n+\t{\n+\t\tstruct table_acl_params *t = &table->params.match.acl;\n+\t\tstruct table_rule_match_acl *r = &match->match.acl;\n+\n+\t\tif ((r->ip_version && (t->ip_version == 0)) ||\n+\t\t\t((r->ip_version == 0) && t->ip_version))\n+\t\t\treturn -1;\n+\n+\t\tif (r->ip_version) {\n+\t\t\tif ((r->sa_depth > 32) ||\n+\t\t\t\t(r->da_depth > 32))\n+\t\t\t\treturn -1;\n+\t\t} else {\n+\t\t\tif ((r->sa_depth > 128) ||\n+\t\t\t\t(r->da_depth > 128))\n+\t\t\t\treturn -1;\n+\t\t}\n+\t\treturn 0;\n+\t}\n+\n+\tcase TABLE_ARRAY:\n+\t\treturn 0;\n+\n+\tcase TABLE_HASH:\n+\t\treturn 0;\n+\n+\tcase TABLE_LPM:\n+\t{\n+\t\tstruct table_lpm_params *t = &table->params.match.lpm;\n+\t\tstruct table_rule_match_lpm *r = &match->match.lpm;\n+\n+\t\tif ((r->ip_version && (t->key_size != 4)) ||\n+\t\t\t((r->ip_version == 0) && (t->key_size != 16)))\n+\t\t\treturn -1;\n+\n+\t\tif (r->ip_version) {\n+\t\t\tif (r->depth > 32)\n+\t\t\t\treturn -1;\n+\t\t} else {\n+\t\t\tif (r->depth > 128)\n+\t\t\t\treturn -1;\n+\t\t}\n+\t\treturn 0;\n+\t}\n+\n+\tcase TABLE_STUB:\n+\t\treturn -1;\n+\n+\tdefault:\n+\t\treturn -1;\n+\t}\n+}\n+\n+static int\n+action_check(struct table_rule_action *action,\n+\tstruct pipeline *p,\n+\tuint32_t table_id)\n+{\n+\tstruct table_action_profile *ap;\n+\n+\tif ((action == NULL) ||\n+\t\t(p == NULL) ||\n+\t\t(table_id >= p->n_tables))\n+\t\treturn -1;\n+\n+\tap = p->table[table_id].ap;\n+\tif (action->action_mask != ap->params.action_mask)\n+\t\treturn -1;\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {\n+\t\tif ((action->fwd.action == RTE_PIPELINE_ACTION_PORT) &&\n+\t\t\t(action->fwd.id >= p->n_ports_out))\n+\t\t\treturn -1;\n+\n+\t\tif ((action->fwd.action == RTE_PIPELINE_ACTION_TABLE) &&\n+\t\t\t(action->fwd.id >= p->n_tables))\n+\t\t\treturn -1;\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {\n+\t\tuint32_t tc_mask0 = (1 << ap->params.mtr.n_tc) - 1;\n+\t\tuint32_t tc_mask1 = action->mtr.tc_mask;\n+\n+\t\tif (tc_mask1 != tc_mask0)\n+\t\t\treturn -1;\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {\n+\t\tuint32_t n_subports_per_port =\n+\t\t\tap->params.tm.n_subports_per_port;\n+\t\tuint32_t n_pipes_per_subport =\n+\t\t\tap->params.tm.n_pipes_per_subport;\n+\t\tuint32_t subport_id = action->tm.subport_id;\n+\t\tuint32_t pipe_id = action->tm.pipe_id;\n+\n+\t\tif ((subport_id >= n_subports_per_port) ||\n+\t\t\t(pipe_id >= n_pipes_per_subport))\n+\t\t\treturn -1;\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {\n+\t\tuint64_t encap_mask = ap->params.encap.encap_mask;\n+\t\tenum rte_table_action_encap_type type = action->encap.type;\n+\n+\t\tif ((encap_mask & (1LLU << type)) == 0)\n+\t\t\treturn -1;\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {\n+\t\tint ip_version0 = ap->params.common.ip_version;\n+\t\tint ip_version1 = action->nat.ip_version;\n+\n+\t\tif ((ip_version1 && (ip_version0 == 0)) ||\n+\t\t\t((ip_version1 == 0) && ip_version0))\n+\t\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n+action_default_check(struct table_rule_action *action,\n+\tstruct pipeline *p,\n+\tuint32_t table_id)\n+{\n+\tif ((action == NULL) ||\n+\t\t(action->action_mask != (1LLU << RTE_TABLE_ACTION_FWD)) ||\n+\t\t(p == NULL) ||\n+\t\t(table_id >= p->n_tables))\n+\t\treturn -1;\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {\n+\t\tif ((action->fwd.action == RTE_PIPELINE_ACTION_PORT) &&\n+\t\t\t(action->fwd.id >= p->n_ports_out))\n+\t\t\treturn -1;\n+\n+\t\tif ((action->fwd.action == RTE_PIPELINE_ACTION_TABLE) &&\n+\t\t\t(action->fwd.id >= p->n_tables))\n+\t\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+int\n+pipeline_table_rule_add(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match,\n+\tstruct table_rule_action *action,\n+\tvoid **data)\n+{\n+\tstruct pipeline *p;\n+\tstruct pipeline_msg_req *req;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tint status;\n+\n+\t/* Check input params */\n+\tif ((pipeline_name == NULL) ||\n+\t\t(match == NULL) ||\n+\t\t(action == NULL) ||\n+\t\t(data == NULL))\n+\t\treturn -1;\n+\n+\tp = pipeline_find(softnic, pipeline_name);\n+\tif ((p == NULL) ||\n+\t\t(p->enabled == 0) ||\n+\t\t(table_id >= p->n_tables) ||\n+\t\tmatch_check(match, p, table_id) ||\n+\t\taction_check(action, p, table_id))\n+\t\treturn -1;\n+\n+\t/* Allocate request */\n+\treq = pipeline_msg_alloc();\n+\tif (req == NULL)\n+\t\treturn -1;\n+\n+\t/* Write request */\n+\treq->type = PIPELINE_REQ_TABLE_RULE_ADD;\n+\treq->id = table_id;\n+\tmemcpy(&req->table_rule_add.match, match, sizeof(*match));\n+\tmemcpy(&req->table_rule_add.action, action, sizeof(*action));\n+\n+\t/* Send request and wait for response */\n+\trsp = pipeline_msg_send_recv(p, req);\n+\tif (rsp == NULL)\n+\t\treturn -1;\n+\n+\t/* Read response */\n+\tstatus = rsp->status;\n+\tif (status == 0)\n+\t\t*data = rsp->table_rule_add.data;\n+\n+\t/* Free response */\n+\tpipeline_msg_free(rsp);\n+\n+\treturn status;\n+}\n+\n+int\n+pipeline_table_rule_add_default(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_action *action,\n+\tvoid **data)\n+{\n+\tstruct pipeline *p;\n+\tstruct pipeline_msg_req *req;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tint status;\n+\n+\t/* Check input params */\n+\tif ((pipeline_name == NULL) ||\n+\t\t(action == NULL) ||\n+\t\t(data == NULL))\n+\t\treturn -1;\n+\n+\tp = pipeline_find(softnic, pipeline_name);\n+\tif ((p == NULL) ||\n+\t\t(p->enabled == 0) ||\n+\t\t(table_id >= p->n_tables) ||\n+\t\taction_default_check(action, p, table_id))\n+\t\treturn -1;\n+\n+\t/* Allocate request */\n+\treq = pipeline_msg_alloc();\n+\tif (req == NULL)\n+\t\treturn -1;\n+\n+\t/* Write request */\n+\treq->type = PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT;\n+\treq->id = table_id;\n+\tmemcpy(&req->table_rule_add_default.action, action, sizeof(*action));\n+\n+\t/* Send request and wait for response */\n+\trsp = pipeline_msg_send_recv(p, req);\n+\tif (rsp == NULL)\n+\t\treturn -1;\n+\n+\t/* Read response */\n+\tstatus = rsp->status;\n+\tif (status == 0)\n+\t\t*data = rsp->table_rule_add_default.data;\n+\n+\t/* Free response */\n+\tpipeline_msg_free(rsp);\n+\n+\treturn status;\n+}\n+\n+int\n+pipeline_table_rule_add_bulk(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match,\n+\tstruct table_rule_action *action,\n+\tvoid **data,\n+\tuint32_t *n_rules)\n+{\n+\tstruct pipeline *p;\n+\tstruct pipeline_msg_req *req;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tuint32_t i;\n+\tint status;\n+\n+\t/* Check input params */\n+\tif ((pipeline_name == NULL) ||\n+\t\t(match == NULL) ||\n+\t\t(action == NULL) ||\n+\t\t(data == NULL) ||\n+\t\t(n_rules == NULL) ||\n+\t\t(*n_rules == 0))\n+\t\treturn -1;\n+\n+\tp = pipeline_find(softnic, pipeline_name);\n+\tif ((p == NULL) ||\n+\t\t(p->enabled == 0) ||\n+\t\t(table_id >= p->n_tables))\n+\t\treturn -1;\n+\n+\tfor (i = 0; i < *n_rules; i++)\n+\t\tif (match_check(match, p, table_id) ||\n+\t\t\taction_check(action, p, table_id))\n+\t\t\treturn -1;\n+\n+\t/* Allocate request */\n+\treq = pipeline_msg_alloc();\n+\tif (req == NULL)\n+\t\treturn -1;\n+\n+\t/* Write request */\n+\treq->type = PIPELINE_REQ_TABLE_RULE_ADD_BULK;\n+\treq->id = table_id;\n+\treq->table_rule_add_bulk.match = match;\n+\treq->table_rule_add_bulk.action = action;\n+\treq->table_rule_add_bulk.data = data;\n+\treq->table_rule_add_bulk.n_rules = *n_rules;\n+\treq->table_rule_add_bulk.bulk =\n+\t\t(p->table[table_id].params.match_type == TABLE_ACL) ? 1 : 0;\n+\n+\t/* Send request and wait for response */\n+\trsp = pipeline_msg_send_recv(p, req);\n+\tif (rsp == NULL)\n+\t\treturn -1;\n+\n+\t/* Read response */\n+\tstatus = rsp->status;\n+\tif (status == 0)\n+\t\t*n_rules = rsp->table_rule_add_bulk.n_rules;\n+\n+\t/* Free response */\n+\tpipeline_msg_free(rsp);\n+\n+\treturn status;\n+}\n+\n+int\n+pipeline_table_rule_delete(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id,\n+\tstruct table_rule_match *match)\n+{\n+\tstruct pipeline *p;\n+\tstruct pipeline_msg_req *req;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tint status;\n+\n+\t/* Check input params */\n+\tif ((pipeline_name == NULL) ||\n+\t\t(match == NULL))\n+\t\treturn -1;\n+\n+\tp = pipeline_find(softnic, pipeline_name);\n+\tif ((p == NULL) ||\n+\t\t(p->enabled == 0) ||\n+\t\t(table_id >= p->n_tables) ||\n+\t\tmatch_check(match, p, table_id))\n+\t\treturn -1;\n+\n+\t/* Allocate request */\n+\treq = pipeline_msg_alloc();\n+\tif (req == NULL)\n+\t\treturn -1;\n+\n+\t/* Write request */\n+\treq->type = PIPELINE_REQ_TABLE_RULE_DELETE;\n+\treq->id = table_id;\n+\tmemcpy(&req->table_rule_delete.match, match, sizeof(*match));\n+\n+\t/* Send request and wait for response */\n+\trsp = pipeline_msg_send_recv(p, req);\n+\tif (rsp == NULL)\n+\t\treturn -1;\n+\n+\t/* Read response */\n+\tstatus = rsp->status;\n+\n+\t/* Free response */\n+\tpipeline_msg_free(rsp);\n+\n+\treturn status;\n+}\n+\n+int\n+pipeline_table_rule_delete_default(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t table_id)\n+{\n+\tstruct pipeline *p;\n+\tstruct pipeline_msg_req *req;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tint status;\n+\n+\t/* Check input params */\n+\tif (pipeline_name == NULL)\n+\t\treturn -1;\n+\n+\tp = pipeline_find(softnic, pipeline_name);\n+\tif ((p == NULL) ||\n+\t\t(p->enabled == 0) ||\n+\t\t(table_id >= p->n_tables))\n+\t\treturn -1;\n+\n+\t/* Allocate request */\n+\treq = pipeline_msg_alloc();\n+\tif (req == NULL)\n+\t\treturn -1;\n+\n+\t/* Write request */\n+\treq->type = PIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT;\n+\treq->id = table_id;\n+\n+\t/* Send request and wait for response */\n+\trsp = pipeline_msg_send_recv(p, req);\n+\tif (rsp == NULL)\n+\t\treturn -1;\n+\n+\t/* Read response */\n+\tstatus = rsp->status;\n+\n+\t/* Free response */\n+\tpipeline_msg_free(rsp);\n+\n+\treturn status;\n+}\n+\n /**\n  * Data plane threads: message handling\n  */\n@@ -676,6 +1161,709 @@ pipeline_msg_handle_port_in_disable(struct pipeline_data *p,\n \treturn rsp;\n }\n \n+union table_rule_match_low_level {\n+\tstruct rte_table_acl_rule_add_params acl_add;\n+\tstruct rte_table_acl_rule_delete_params acl_delete;\n+\tstruct rte_table_array_key array;\n+\tuint8_t hash[TABLE_RULE_MATCH_SIZE_MAX];\n+\tstruct rte_table_lpm_key lpm_ipv4;\n+\tstruct rte_table_lpm_ipv6_key lpm_ipv6;\n+};\n+\n+static int\n+match_convert_ipv6_depth(uint32_t depth, uint32_t *depth32)\n+{\n+\tif (depth > 128)\n+\t\treturn -1;\n+\n+\tswitch (depth / 32) {\n+\tcase 0:\n+\t\tdepth32[0] = depth;\n+\t\tdepth32[1] = 0;\n+\t\tdepth32[2] = 0;\n+\t\tdepth32[3] = 0;\n+\t\treturn 0;\n+\n+\tcase 1:\n+\t\tdepth32[0] = 32;\n+\t\tdepth32[1] = depth - 32;\n+\t\tdepth32[2] = 0;\n+\t\tdepth32[3] = 0;\n+\t\treturn 0;\n+\n+\tcase 2:\n+\t\tdepth32[0] = 32;\n+\t\tdepth32[1] = 32;\n+\t\tdepth32[2] = depth - 64;\n+\t\tdepth32[3] = 0;\n+\t\treturn 0;\n+\n+\tcase 3:\n+\t\tdepth32[0] = 32;\n+\t\tdepth32[1] = 32;\n+\t\tdepth32[2] = 32;\n+\t\tdepth32[3] = depth - 96;\n+\t\treturn 0;\n+\n+\tcase 4:\n+\t\tdepth32[0] = 32;\n+\t\tdepth32[1] = 32;\n+\t\tdepth32[2] = 32;\n+\t\tdepth32[3] = 32;\n+\t\treturn 0;\n+\n+\tdefault:\n+\t\treturn -1;\n+\t}\n+}\n+\n+static int\n+match_convert(struct table_rule_match *mh,\n+\tunion table_rule_match_low_level *ml,\n+\tint add)\n+{\n+\tmemset(ml, 0, sizeof(*ml));\n+\n+\tswitch (mh->match_type) {\n+\tcase TABLE_ACL:\n+\t\tif (mh->match.acl.ip_version)\n+\t\t\tif (add) {\n+\t\t\t\tml->acl_add.field_value[0].value.u8 =\n+\t\t\t\t\tmh->match.acl.proto;\n+\t\t\t\tml->acl_add.field_value[0].mask_range.u8 =\n+\t\t\t\t\tmh->match.acl.proto_mask;\n+\n+\t\t\t\tml->acl_add.field_value[1].value.u32 =\n+\t\t\t\t\tmh->match.acl.ipv4.sa;\n+\t\t\t\tml->acl_add.field_value[1].mask_range.u32 =\n+\t\t\t\t\tmh->match.acl.sa_depth;\n+\n+\t\t\t\tml->acl_add.field_value[2].value.u32 =\n+\t\t\t\t\tmh->match.acl.ipv4.da;\n+\t\t\t\tml->acl_add.field_value[2].mask_range.u32 =\n+\t\t\t\t\tmh->match.acl.da_depth;\n+\n+\t\t\t\tml->acl_add.field_value[3].value.u16 =\n+\t\t\t\t\tmh->match.acl.sp0;\n+\t\t\t\tml->acl_add.field_value[3].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.sp1;\n+\n+\t\t\t\tml->acl_add.field_value[4].value.u16 =\n+\t\t\t\t\tmh->match.acl.dp0;\n+\t\t\t\tml->acl_add.field_value[4].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.dp1;\n+\n+\t\t\t\tml->acl_add.priority =\n+\t\t\t\t\t(int32_t) mh->match.acl.priority;\n+\t\t\t} else {\n+\t\t\t\tml->acl_delete.field_value[0].value.u8 =\n+\t\t\t\t\tmh->match.acl.proto;\n+\t\t\t\tml->acl_delete.field_value[0].mask_range.u8 =\n+\t\t\t\t\tmh->match.acl.proto_mask;\n+\n+\t\t\t\tml->acl_delete.field_value[1].value.u32 =\n+\t\t\t\t\tmh->match.acl.ipv4.sa;\n+\t\t\t\tml->acl_delete.field_value[1].mask_range.u32 =\n+\t\t\t\t\tmh->match.acl.sa_depth;\n+\n+\t\t\t\tml->acl_delete.field_value[2].value.u32 =\n+\t\t\t\t\tmh->match.acl.ipv4.da;\n+\t\t\t\tml->acl_delete.field_value[2].mask_range.u32 =\n+\t\t\t\t\tmh->match.acl.da_depth;\n+\n+\t\t\t\tml->acl_delete.field_value[3].value.u16 =\n+\t\t\t\t\tmh->match.acl.sp0;\n+\t\t\t\tml->acl_delete.field_value[3].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.sp1;\n+\n+\t\t\t\tml->acl_delete.field_value[4].value.u16 =\n+\t\t\t\t\tmh->match.acl.dp0;\n+\t\t\t\tml->acl_delete.field_value[4].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.dp1;\n+\t\t\t}\n+\t\telse\n+\t\t\tif (add) {\n+\t\t\t\tuint32_t *sa32 =\n+\t\t\t\t\t(uint32_t *) mh->match.acl.ipv6.sa;\n+\t\t\t\tuint32_t *da32 =\n+\t\t\t\t\t(uint32_t *) mh->match.acl.ipv6.da;\n+\t\t\t\tuint32_t sa32_depth[4], da32_depth[4];\n+\t\t\t\tint status;\n+\n+\t\t\t\tstatus = match_convert_ipv6_depth(\n+\t\t\t\t\tmh->match.acl.sa_depth,\n+\t\t\t\t\tsa32_depth);\n+\t\t\t\tif (status)\n+\t\t\t\t\treturn status;\n+\n+\t\t\t\tstatus = match_convert_ipv6_depth(\n+\t\t\t\t\tmh->match.acl.da_depth,\n+\t\t\t\t\tda32_depth);\n+\t\t\t\tif (status)\n+\t\t\t\t\treturn status;\n+\n+\t\t\t\tml->acl_add.field_value[0].value.u8 =\n+\t\t\t\t\tmh->match.acl.proto;\n+\t\t\t\tml->acl_add.field_value[0].mask_range.u8 =\n+\t\t\t\t\tmh->match.acl.proto_mask;\n+\n+\t\t\t\tml->acl_add.field_value[1].value.u32 = sa32[0];\n+\t\t\t\tml->acl_add.field_value[1].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[0];\n+\t\t\t\tml->acl_add.field_value[2].value.u32 = sa32[1];\n+\t\t\t\tml->acl_add.field_value[2].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[1];\n+\t\t\t\tml->acl_add.field_value[3].value.u32 = sa32[2];\n+\t\t\t\tml->acl_add.field_value[3].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[2];\n+\t\t\t\tml->acl_add.field_value[4].value.u32 = sa32[3];\n+\t\t\t\tml->acl_add.field_value[4].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[3];\n+\n+\t\t\t\tml->acl_add.field_value[5].value.u32 = da32[0];\n+\t\t\t\tml->acl_add.field_value[5].mask_range.u32 =\n+\t\t\t\t\tda32_depth[0];\n+\t\t\t\tml->acl_add.field_value[6].value.u32 = da32[1];\n+\t\t\t\tml->acl_add.field_value[6].mask_range.u32 =\n+\t\t\t\t\tda32_depth[1];\n+\t\t\t\tml->acl_add.field_value[7].value.u32 = da32[2];\n+\t\t\t\tml->acl_add.field_value[7].mask_range.u32 =\n+\t\t\t\t\tda32_depth[2];\n+\t\t\t\tml->acl_add.field_value[8].value.u32 = da32[3];\n+\t\t\t\tml->acl_add.field_value[8].mask_range.u32 =\n+\t\t\t\t\tda32_depth[3];\n+\n+\t\t\t\tml->acl_add.field_value[9].value.u16 =\n+\t\t\t\t\tmh->match.acl.sp0;\n+\t\t\t\tml->acl_add.field_value[9].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.sp1;\n+\n+\t\t\t\tml->acl_add.field_value[10].value.u16 =\n+\t\t\t\t\tmh->match.acl.dp0;\n+\t\t\t\tml->acl_add.field_value[10].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.dp1;\n+\n+\t\t\t\tml->acl_add.priority =\n+\t\t\t\t\t(int32_t) mh->match.acl.priority;\n+\t\t\t} else {\n+\t\t\t\tuint32_t *sa32 =\n+\t\t\t\t\t(uint32_t *) mh->match.acl.ipv6.sa;\n+\t\t\t\tuint32_t *da32 =\n+\t\t\t\t\t(uint32_t *) mh->match.acl.ipv6.da;\n+\t\t\t\tuint32_t sa32_depth[4], da32_depth[4];\n+\t\t\t\tint status;\n+\n+\t\t\t\tstatus = match_convert_ipv6_depth(\n+\t\t\t\t\tmh->match.acl.sa_depth,\n+\t\t\t\t\tsa32_depth);\n+\t\t\t\tif (status)\n+\t\t\t\t\treturn status;\n+\n+\t\t\t\tstatus = match_convert_ipv6_depth(\n+\t\t\t\t\tmh->match.acl.da_depth,\n+\t\t\t\t\tda32_depth);\n+\t\t\t\tif (status)\n+\t\t\t\t\treturn status;\n+\n+\t\t\t\tml->acl_delete.field_value[0].value.u8 =\n+\t\t\t\t\tmh->match.acl.proto;\n+\t\t\t\tml->acl_delete.field_value[0].mask_range.u8 =\n+\t\t\t\t\tmh->match.acl.proto_mask;\n+\n+\t\t\t\tml->acl_delete.field_value[1].value.u32 =\n+\t\t\t\t\tsa32[0];\n+\t\t\t\tml->acl_delete.field_value[1].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[0];\n+\t\t\t\tml->acl_delete.field_value[2].value.u32 =\n+\t\t\t\t\tsa32[1];\n+\t\t\t\tml->acl_delete.field_value[2].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[1];\n+\t\t\t\tml->acl_delete.field_value[3].value.u32 =\n+\t\t\t\t\tsa32[2];\n+\t\t\t\tml->acl_delete.field_value[3].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[2];\n+\t\t\t\tml->acl_delete.field_value[4].value.u32 =\n+\t\t\t\t\tsa32[3];\n+\t\t\t\tml->acl_delete.field_value[4].mask_range.u32 =\n+\t\t\t\t\tsa32_depth[3];\n+\n+\t\t\t\tml->acl_delete.field_value[5].value.u32 =\n+\t\t\t\t\tda32[0];\n+\t\t\t\tml->acl_delete.field_value[5].mask_range.u32 =\n+\t\t\t\t\tda32_depth[0];\n+\t\t\t\tml->acl_delete.field_value[6].value.u32 =\n+\t\t\t\t\tda32[1];\n+\t\t\t\tml->acl_delete.field_value[6].mask_range.u32 =\n+\t\t\t\t\tda32_depth[1];\n+\t\t\t\tml->acl_delete.field_value[7].value.u32 =\n+\t\t\t\t\tda32[2];\n+\t\t\t\tml->acl_delete.field_value[7].mask_range.u32 =\n+\t\t\t\t\tda32_depth[2];\n+\t\t\t\tml->acl_delete.field_value[8].value.u32 =\n+\t\t\t\t\tda32[3];\n+\t\t\t\tml->acl_delete.field_value[8].mask_range.u32 =\n+\t\t\t\t\tda32_depth[3];\n+\n+\t\t\t\tml->acl_delete.field_value[9].value.u16 =\n+\t\t\t\t\tmh->match.acl.sp0;\n+\t\t\t\tml->acl_delete.field_value[9].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.sp1;\n+\n+\t\t\t\tml->acl_delete.field_value[10].value.u16 =\n+\t\t\t\t\tmh->match.acl.dp0;\n+\t\t\t\tml->acl_delete.field_value[10].mask_range.u16 =\n+\t\t\t\t\tmh->match.acl.dp1;\n+\t\t\t}\n+\t\treturn 0;\n+\n+\tcase TABLE_ARRAY:\n+\t\tml->array.pos = mh->match.array.pos;\n+\t\treturn 0;\n+\n+\tcase TABLE_HASH:\n+\t\tmemcpy(ml->hash, mh->match.hash.key, sizeof(ml->hash));\n+\t\treturn 0;\n+\n+\tcase TABLE_LPM:\n+\t\tif (mh->match.lpm.ip_version) {\n+\t\t\tml->lpm_ipv4.ip = mh->match.lpm.ipv4;\n+\t\t\tml->lpm_ipv4.depth = mh->match.lpm.depth;\n+\t\t} else {\n+\t\t\tmemcpy(ml->lpm_ipv6.ip,\n+\t\t\t\tmh->match.lpm.ipv6, sizeof(ml->lpm_ipv6.ip));\n+\t\t\tml->lpm_ipv6.depth = mh->match.lpm.depth;\n+\t\t}\n+\n+\t\treturn 0;\n+\n+\tdefault:\n+\t\treturn -1;\n+\t}\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_table_rule_add(struct pipeline_data *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\tunion table_rule_match_low_level match_ll;\n+\tstruct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;\n+\tstruct table_rule_match *match = &req->table_rule_add.match;\n+\tstruct table_rule_action *action = &req->table_rule_add.action;\n+\tstruct rte_pipeline_table_entry *data_in, *data_out;\n+\tuint32_t table_id = req->id;\n+\tint key_found, status;\n+\tstruct rte_table_action *a = p->table_data[table_id].a;\n+\n+\t/* Apply actions */\n+\tmemset(p->buffer, 0, sizeof(p->buffer));\n+\tdata_in = (struct rte_pipeline_table_entry *) p->buffer;\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_FWD,\n+\t\t\t&action->fwd);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_LB,\n+\t\t\t&action->lb);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_MTR,\n+\t\t\t&action->mtr);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_TM,\n+\t\t\t&action->tm);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_ENCAP,\n+\t\t\t&action->encap);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_NAT,\n+\t\t\t&action->nat);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_TTL)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_TTL,\n+\t\t\t&action->ttl);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_STATS)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_STATS,\n+\t\t\t&action->stats);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\tif (action->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {\n+\t\tstatus = rte_table_action_apply(a,\n+\t\t\tdata_in,\n+\t\t\tRTE_TABLE_ACTION_TIME,\n+\t\t\t&action->time);\n+\n+\t\tif (status) {\n+\t\t\trsp->status = -1;\n+\t\t\treturn rsp;\n+\t\t}\n+\t}\n+\n+\t/* Add rule (match, action) to table */\n+\tstatus = match_convert(match, &match_ll, 1);\n+\tif (status) {\n+\t\trsp->status = -1;\n+\t\treturn rsp;\n+\t}\n+\n+\tstatus = rte_pipeline_table_entry_add(p->p,\n+\t\ttable_id,\n+\t\t&match_ll,\n+\t\tdata_in,\n+\t\t&key_found,\n+\t\t&data_out);\n+\tif (status) {\n+\t\trsp->status = -1;\n+\t\treturn rsp;\n+\t}\n+\n+\t/* Write response */\n+\trsp->status = 0;\n+\trsp->table_rule_add.data = data_out;\n+\n+\treturn rsp;\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_table_rule_add_default(struct pipeline_data *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\tstruct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;\n+\tstruct table_rule_action *action = &req->table_rule_add_default.action;\n+\tstruct rte_pipeline_table_entry *data_in, *data_out;\n+\tuint32_t table_id = req->id;\n+\tint status;\n+\n+\t/* Apply actions */\n+\tmemset(p->buffer, 0, sizeof(p->buffer));\n+\tdata_in = (struct rte_pipeline_table_entry *) p->buffer;\n+\n+\tdata_in->action = action->fwd.action;\n+\tif (action->fwd.action == RTE_PIPELINE_ACTION_PORT)\n+\t\tdata_in->port_id = action->fwd.id;\n+\tif (action->fwd.action == RTE_PIPELINE_ACTION_TABLE)\n+\t\tdata_in->table_id = action->fwd.id;\n+\n+\t/* Add default rule to table */\n+\tstatus = rte_pipeline_table_default_entry_add(p->p,\n+\t\ttable_id,\n+\t\tdata_in,\n+\t\t&data_out);\n+\tif (status) {\n+\t\trsp->status = -1;\n+\t\treturn rsp;\n+\t}\n+\n+\t/* Write response */\n+\trsp->status = 0;\n+\trsp->table_rule_add_default.data = data_out;\n+\n+\treturn rsp;\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_table_rule_add_bulk(struct pipeline_data *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\n+\tstruct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;\n+\n+\tuint32_t table_id = req->id;\n+\tstruct table_rule_match *match = req->table_rule_add_bulk.match;\n+\tstruct table_rule_action *action = req->table_rule_add_bulk.action;\n+\tstruct rte_pipeline_table_entry **data =\n+\t\t(struct rte_pipeline_table_entry **)req->table_rule_add_bulk.data;\n+\tuint32_t n_rules = req->table_rule_add_bulk.n_rules;\n+\tuint32_t bulk = req->table_rule_add_bulk.bulk;\n+\n+\tstruct rte_table_action *a = p->table_data[table_id].a;\n+\tunion table_rule_match_low_level *match_ll;\n+\tuint8_t *action_ll;\n+\tvoid **match_ll_ptr;\n+\tstruct rte_pipeline_table_entry **action_ll_ptr;\n+\tint *found, status;\n+\tuint32_t i;\n+\n+\t/* Memory allocation */\n+\tmatch_ll = calloc(n_rules, sizeof(union table_rule_match_low_level));\n+\taction_ll = calloc(n_rules, TABLE_RULE_ACTION_SIZE_MAX);\n+\tmatch_ll_ptr = calloc(n_rules, sizeof(void *));\n+\taction_ll_ptr =\n+\t\tcalloc(n_rules, sizeof(struct rte_pipeline_table_entry *));\n+\tfound = calloc(n_rules, sizeof(int));\n+\n+\tif ((match_ll == NULL) ||\n+\t\t(action_ll == NULL) ||\n+\t\t(match_ll_ptr == NULL) ||\n+\t\t(action_ll_ptr == NULL) ||\n+\t\t(found == NULL))\n+\t\tgoto fail;\n+\n+\tfor (i = 0; i < n_rules; i++) {\n+\t\tmatch_ll_ptr[i] = (void *)&match_ll[i];\n+\t\taction_ll_ptr[i] =\n+\t\t\t(struct rte_pipeline_table_entry *)&action_ll[i * TABLE_RULE_ACTION_SIZE_MAX];\n+\t}\n+\n+\t/* Rule match conversion */\n+\tfor (i = 0; i < n_rules; i++) {\n+\t\tstatus = match_convert(&match[i], match_ll_ptr[i], 1);\n+\t\tif (status)\n+\t\t\tgoto fail;\n+\t}\n+\n+\t/* Rule action conversion */\n+\tfor (i = 0; i < n_rules; i++) {\n+\t\tvoid *data_in = action_ll_ptr[i];\n+\t\tstruct table_rule_action *act = &action[i];\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_FWD,\n+\t\t\t\t&act->fwd);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_LB,\n+\t\t\t\t&act->lb);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_MTR,\n+\t\t\t\t&act->mtr);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_TM,\n+\t\t\t\t&act->tm);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_ENCAP,\n+\t\t\t\t&act->encap);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_NAT,\n+\t\t\t\t&act->nat);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_TTL)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_TTL,\n+\t\t\t\t&act->ttl);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_STATS)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_STATS,\n+\t\t\t\t&act->stats);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\n+\t\tif (act->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {\n+\t\t\tstatus = rte_table_action_apply(a,\n+\t\t\t\tdata_in,\n+\t\t\t\tRTE_TABLE_ACTION_TIME,\n+\t\t\t\t&act->time);\n+\n+\t\t\tif (status)\n+\t\t\t\tgoto fail;\n+\t\t}\n+\t}\n+\n+\t/* Add rule (match, action) to table */\n+\tif (bulk) {\n+\t\tstatus = rte_pipeline_table_entry_add_bulk(p->p,\n+\t\t\ttable_id,\n+\t\t\tmatch_ll_ptr,\n+\t\t\taction_ll_ptr,\n+\t\t\tn_rules,\n+\t\t\tfound,\n+\t\t\tdata);\n+\t\tif (status)\n+\t\t\tn_rules = 0;\n+\t} else\n+\t\tfor (i = 0; i < n_rules; i++) {\n+\t\t\tstatus = rte_pipeline_table_entry_add(p->p,\n+\t\t\t\ttable_id,\n+\t\t\t\tmatch_ll_ptr[i],\n+\t\t\t\taction_ll_ptr[i],\n+\t\t\t\t&found[i],\n+\t\t\t\t&data[i]);\n+\t\t\tif (status) {\n+\t\t\t\tn_rules = i;\n+\t\t\t\tbreak;\n+\t\t\t}\n+\t\t}\n+\n+\t/* Write response */\n+\trsp->status = 0;\n+\trsp->table_rule_add_bulk.n_rules = n_rules;\n+\n+\t/* Free */\n+\tfree(found);\n+\tfree(action_ll_ptr);\n+\tfree(match_ll_ptr);\n+\tfree(action_ll);\n+\tfree(match_ll);\n+\n+\treturn rsp;\n+\n+fail:\n+\tfree(found);\n+\tfree(action_ll_ptr);\n+\tfree(match_ll_ptr);\n+\tfree(action_ll);\n+\tfree(match_ll);\n+\n+\trsp->status = -1;\n+\trsp->table_rule_add_bulk.n_rules = 0;\n+\treturn rsp;\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_table_rule_delete(struct pipeline_data *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\tunion table_rule_match_low_level match_ll;\n+\tstruct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;\n+\tstruct table_rule_match *match = &req->table_rule_delete.match;\n+\tuint32_t table_id = req->id;\n+\tint key_found, status;\n+\n+\tstatus = match_convert(match, &match_ll, 0);\n+\tif (status) {\n+\t\trsp->status = -1;\n+\t\treturn rsp;\n+\t}\n+\n+\trsp->status = rte_pipeline_table_entry_delete(p->p,\n+\t\ttable_id,\n+\t\t&match_ll,\n+\t\t&key_found,\n+\t\tNULL);\n+\n+\treturn rsp;\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_table_rule_delete_default(struct pipeline_data *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\tstruct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;\n+\tuint32_t table_id = req->id;\n+\n+\trsp->status = rte_pipeline_table_default_entry_delete(p->p,\n+\t\ttable_id,\n+\t\tNULL);\n+\n+\treturn rsp;\n+}\n+\n static void\n pipeline_msg_handle(struct pipeline_data *p)\n {\n@@ -696,6 +1884,26 @@ pipeline_msg_handle(struct pipeline_data *p)\n \t\t\trsp = pipeline_msg_handle_port_in_disable(p, req);\n \t\t\tbreak;\n \n+\t\tcase PIPELINE_REQ_TABLE_RULE_ADD:\n+\t\t\trsp = pipeline_msg_handle_table_rule_add(p, req);\n+\t\t\tbreak;\n+\n+\t\tcase PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT:\n+\t\t\trsp = pipeline_msg_handle_table_rule_add_default(p,\treq);\n+\t\t\tbreak;\n+\n+\t\tcase PIPELINE_REQ_TABLE_RULE_ADD_BULK:\n+\t\t\trsp = pipeline_msg_handle_table_rule_add_bulk(p, req);\n+\t\t\tbreak;\n+\n+\t\tcase PIPELINE_REQ_TABLE_RULE_DELETE:\n+\t\t\trsp = pipeline_msg_handle_table_rule_delete(p, req);\n+\t\t\tbreak;\n+\n+\t\tcase PIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT:\n+\t\t\trsp = pipeline_msg_handle_table_rule_delete_default(p, req);\n+\t\t\tbreak;\n+\n \t\tdefault:\n \t\t\trsp = (struct pipeline_msg_rsp *) req;\n \t\t\trsp->status = -1;\n",
    "prefixes": [
        "dpdk-dev",
        "16/21"
    ]
}