Patch Detail

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

{
    "id": 42552,
    "url": "http://patches.dpdk.org/api/patches/42552/?format=api",
    "web_url": "http://patches.dpdk.org/project/dpdk/patch/20180706172116.50951-15-jasvinder.singh@intel.com/",
    "project": {
        "id": 1,
        "url": "http://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": "<20180706172116.50951-15-jasvinder.singh@intel.com>",
    "list_archive_url": "https://inbox.dpdk.org/dev/20180706172116.50951-15-jasvinder.singh@intel.com",
    "date": "2018-07-06T17:21:07",
    "name": "[v5,14/23] net/softnic: add cli to create softnic objects",
    "commit_ref": null,
    "pull_url": null,
    "state": "accepted",
    "archived": true,
    "hash": "a82db6ebe9e9153ebf53d4a558b393a1be420b5a",
    "submitter": {
        "id": 285,
        "url": "http://patches.dpdk.org/api/people/285/?format=api",
        "name": "Jasvinder Singh",
        "email": "jasvinder.singh@intel.com"
    },
    "delegate": {
        "id": 10018,
        "url": "http://patches.dpdk.org/api/users/10018/?format=api",
        "username": "cristian_dumitrescu",
        "first_name": "Cristian",
        "last_name": "Dumitrescu",
        "email": "cristian.dumitrescu@intel.com"
    },
    "mbox": "http://patches.dpdk.org/project/dpdk/patch/20180706172116.50951-15-jasvinder.singh@intel.com/mbox/",
    "series": [
        {
            "id": 460,
            "url": "http://patches.dpdk.org/api/series/460/?format=api",
            "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=460",
            "date": "2018-07-06T17:20:53",
            "name": "net/softnic: refactoring",
            "version": 5,
            "mbox": "http://patches.dpdk.org/series/460/mbox/"
        }
    ],
    "comments": "http://patches.dpdk.org/api/patches/42552/comments/",
    "check": "warning",
    "checks": "http://patches.dpdk.org/api/patches/42552/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 6F8091BF78;\n\tFri,  6 Jul 2018 19:21:54 +0200 (CEST)",
            "from mga03.intel.com (mga03.intel.com [134.134.136.65])\n\tby dpdk.org (Postfix) with ESMTP id 7FCA71BF0F\n\tfor <dev@dpdk.org>; Fri,  6 Jul 2018 19:21:38 +0200 (CEST)",
            "from orsmga003.jf.intel.com ([10.7.209.27])\n\tby orsmga103.jf.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384;\n\t06 Jul 2018 10:21:37 -0700",
            "from silpixa00381635.ir.intel.com (HELO\n\tsilpixa00381635.ger.corp.intel.com) ([10.237.222.149])\n\tby orsmga003.jf.intel.com with ESMTP; 06 Jul 2018 10:21:33 -0700"
        ],
        "X-Amp-Result": "SKIPPED(no attachment in message)",
        "X-Amp-File-Uploaded": "False",
        "X-ExtLoop1": "1",
        "X-IronPort-AV": "E=Sophos;i=\"5.51,317,1526367600\"; d=\"scan'208\";a=\"64955356\"",
        "From": "Jasvinder Singh <jasvinder.singh@intel.com>",
        "To": "dev@dpdk.org",
        "Cc": "cristian.dumitrescu@intel.com",
        "Date": "Fri,  6 Jul 2018 18:21:07 +0100",
        "Message-Id": "<20180706172116.50951-15-jasvinder.singh@intel.com>",
        "X-Mailer": "git-send-email 2.9.3",
        "In-Reply-To": "<20180706172116.50951-1-jasvinder.singh@intel.com>",
        "References": "<20180705154754.147420-2-jasvinder.singh@intel.com>\n\t<20180706172116.50951-1-jasvinder.singh@intel.com>",
        "Subject": "[dpdk-dev] [PATCH v5 14/23] net/softnic: add cli to create softnic\n\tobjects",
        "X-BeenThere": "dev@dpdk.org",
        "X-Mailman-Version": "2.1.15",
        "Precedence": "list",
        "List-Id": "DPDK patches and discussions <dev.dpdk.org>",
        "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>",
        "List-Archive": "<http://mails.dpdk.org/archives/dev/>",
        "List-Post": "<mailto:dev@dpdk.org>",
        "List-Help": "<mailto:dev-request@dpdk.org?subject=help>",
        "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>",
        "Errors-To": "dev-bounces@dpdk.org",
        "Sender": "\"dev\" <dev-bounces@dpdk.org>"
    },
    "content": "Add cli commands to create softnic objects such as mempool, swq,\npipeline, etc.\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       | 1646 ++++++++++++++++++++++-\n drivers/net/softnic/rte_eth_softnic_internals.h |   85 ++\n drivers/net/softnic/rte_eth_softnic_thread.c    |  196 +++\n 3 files changed, 1925 insertions(+), 2 deletions(-)",
    "diff": "diff --git a/drivers/net/softnic/rte_eth_softnic_cli.c b/drivers/net/softnic/rte_eth_softnic_cli.c\nindex 446b186..9fbd680 100644\n--- a/drivers/net/softnic/rte_eth_softnic_cli.c\n+++ b/drivers/net/softnic/rte_eth_softnic_cli.c\n@@ -37,15 +37,1569 @@ is_comment(char *in)\n \treturn 0;\n }\n \n+/**\n+ * mempool <mempool_name>\n+ *  buffer <buffer_size>\n+ *  pool <pool_size>\n+ *  cache <cache_size>\n+ */\n+static void\n+cmd_mempool(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_mempool_params p;\n+\tchar *name;\n+\tstruct softnic_mempool *mempool;\n+\n+\tif (n_tokens != 8) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"buffer\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"buffer\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.buffer_size, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"buffer_size\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"pool\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pool\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.pool_size, tokens[5]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"pool_size\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[6], \"cache\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"cache\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.cache_size, tokens[7]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"cache_size\");\n+\t\treturn;\n+\t}\n+\n+\tmempool = softnic_mempool_create(softnic, name, &p);\n+\tif (mempool == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * link <link_name>\n+ *    dev <device_name> | port <port_id>\n+ */\n+static void\n+cmd_link(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_link_params p;\n+\tstruct softnic_link *link;\n+\tchar *name;\n+\n+\tmemset(&p, 0, sizeof(p));\n+\n+\tif (n_tokens != 4) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\tname = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"dev\") == 0) {\n+\t\tp.dev_name = tokens[3];\n+\t} else if (strcmp(tokens[2], \"port\") == 0) {\n+\t\tp.dev_name = NULL;\n+\n+\t\tif (softnic_parser_read_uint16(&p.port_id, tokens[3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\t\treturn;\n+\t\t}\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"dev or port\");\n+\t\treturn;\n+\t}\n+\n+\tlink = softnic_link_create(softnic, name, &p);\n+\tif (link == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * swq <swq_name>\n+ *  size <size>\n+ */\n+static void\n+cmd_swq(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_swq_params p;\n+\tchar *name;\n+\tstruct softnic_swq *swq;\n+\n+\tif (n_tokens != 4) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"size\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"size\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.size, tokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"size\");\n+\t\treturn;\n+\t}\n+\n+\tswq = softnic_swq_create(softnic, name, &p);\n+\tif (swq == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * tap <tap_name>\n+ */\n+static void\n+cmd_tap(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tchar *name;\n+\tstruct softnic_tap *tap;\n+\n+\tif (n_tokens != 2) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[1];\n+\n+\ttap = softnic_tap_create(softnic, name);\n+\tif (tap == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * port in action profile <profile_name>\n+ *  [filter match | mismatch offset <key_offset> mask <key_mask> key <key_value> port <port_id>]\n+ *  [balance offset <key_offset> mask <key_mask> port <port_id0> ... <port_id15>]\n+ */\n+static void\n+cmd_port_in_action_profile(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_port_in_action_profile_params p;\n+\tstruct softnic_port_in_action_profile *ap;\n+\tchar *name;\n+\tuint32_t t0;\n+\n+\tmemset(&p, 0, sizeof(p));\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 (strcmp(tokens[1], \"in\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"in\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[2], \"action\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"action\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"profile\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"profile\");\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[4];\n+\n+\tt0 = 5;\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"filter\") == 0)) {\n+\t\tuint32_t size;\n+\n+\t\tif (n_tokens < t0 + 10) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, \"port in action profile filter\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"match\") == 0) {\n+\t\t\tp.fltr.filter_on_match = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"mismatch\") == 0) {\n+\t\t\tp.fltr.filter_on_match = 0;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"match or mismatch\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.fltr.key_offset,\n+\t\t\ttokens[t0 + 3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"mask\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tsize = RTE_PORT_IN_ACTION_FLTR_KEY_SIZE;\n+\t\tif ((softnic_parse_hex_string(tokens[t0 + 5],\n+\t\t\tp.fltr.key_mask, &size) != 0) ||\n+\t\t\tsize != RTE_PORT_IN_ACTION_FLTR_KEY_SIZE) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 6], \"key\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"key\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tsize = RTE_PORT_IN_ACTION_FLTR_KEY_SIZE;\n+\t\tif ((softnic_parse_hex_string(tokens[t0 + 7],\n+\t\t\tp.fltr.key, &size) != 0) ||\n+\t\t\tsize != RTE_PORT_IN_ACTION_FLTR_KEY_SIZE) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_value\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 8], \"port\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.fltr.port_id,\n+\t\t\ttokens[t0 + 9]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_PORT_IN_ACTION_FLTR;\n+\t\tt0 += 10;\n+\t} /* filter */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"balance\") == 0)) {\n+\t\tuint32_t i;\n+\n+\t\tif (n_tokens < t0 + 22) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"port in action profile balance\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.lb.key_offset,\n+\t\t\ttokens[t0 + 2]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"mask\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.lb.key_size = RTE_PORT_IN_ACTION_LB_KEY_SIZE_MAX;\n+\t\tif (softnic_parse_hex_string(tokens[t0 + 4],\n+\t\t\tp.lb.key_mask, &p.lb.key_size) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 5], \"port\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tfor (i = 0; i < 16; i++)\n+\t\t\tif (softnic_parser_read_uint32(&p.lb.port_id[i],\n+\t\t\ttokens[t0 + 6 + i]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\t\t\treturn;\n+\t\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_PORT_IN_ACTION_LB;\n+\t\tt0 += 22;\n+\t} /* balance */\n+\n+\tif (t0 < n_tokens) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tap = softnic_port_in_action_profile_create(softnic, name, &p);\n+\tif (ap == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * table action profile <profile_name>\n+ *  ipv4 | ipv6\n+ *  offset <ip_offset>\n+ *  fwd\n+ *  [balance offset <key_offset> mask <key_mask> outoffset <out_offset>]\n+ *  [meter srtcm | trtcm\n+ *      tc <n_tc>\n+ *      stats none | pkts | bytes | both]\n+ *  [tm spp <n_subports_per_port> pps <n_pipes_per_subport>]\n+ *  [encap ether | vlan | qinq | mpls | pppoe]\n+ *  [nat src | dst\n+ *      proto udp | tcp]\n+ *  [ttl drop | fwd\n+ *      stats none | pkts]\n+ *  [stats pkts | bytes | both]\n+ *  [time]\n+ */\n+static void\n+cmd_table_action_profile(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_table_action_profile_params p;\n+\tstruct softnic_table_action_profile *ap;\n+\tchar *name;\n+\tuint32_t t0;\n+\n+\tmemset(&p, 0, sizeof(p));\n+\n+\tif (n_tokens < 8) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[1], \"action\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"action\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[2], \"profile\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"profile\");\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[3];\n+\n+\tif (strcmp(tokens[4], \"ipv4\") == 0) {\n+\t\tp.common.ip_version = 1;\n+\t} else if (strcmp(tokens[4], \"ipv6\") == 0) {\n+\t\tp.common.ip_version = 0;\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"ipv4 or ipv6\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"offset\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.common.ip_offset,\n+\t\ttokens[6]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"ip_offset\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[7], \"fwd\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"fwd\");\n+\t\treturn;\n+\t}\n+\n+\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_FWD;\n+\n+\tt0 = 8;\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"balance\") == 0)) {\n+\t\tif (n_tokens < t0 + 7) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, \"table action profile balance\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.lb.key_offset,\n+\t\t\ttokens[t0 + 2]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"mask\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.lb.key_size = RTE_PORT_IN_ACTION_LB_KEY_SIZE_MAX;\n+\t\tif (softnic_parse_hex_string(tokens[t0 + 4],\n+\t\t\tp.lb.key_mask, &p.lb.key_size) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 5], \"outoffset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"outoffset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.lb.out_offset,\n+\t\t\ttokens[t0 + 6]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"out_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_LB;\n+\t\tt0 += 7;\n+\t} /* balance */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"meter\") == 0)) {\n+\t\tif (n_tokens < t0 + 6) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"table action profile meter\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"srtcm\") == 0) {\n+\t\t\tp.mtr.alg = RTE_TABLE_ACTION_METER_SRTCM;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"trtcm\") == 0) {\n+\t\t\tp.mtr.alg = RTE_TABLE_ACTION_METER_TRTCM;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"srtcm or trtcm\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"tc\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"tc\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.mtr.n_tc,\n+\t\t\ttokens[t0 + 3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_tc\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"stats\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"stats\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 5], \"none\") == 0) {\n+\t\t\tp.mtr.n_packets_enabled = 0;\n+\t\t\tp.mtr.n_bytes_enabled = 0;\n+\t\t} else if (strcmp(tokens[t0 + 5], \"pkts\") == 0) {\n+\t\t\tp.mtr.n_packets_enabled = 1;\n+\t\t\tp.mtr.n_bytes_enabled = 0;\n+\t\t} else if (strcmp(tokens[t0 + 5], \"bytes\") == 0) {\n+\t\t\tp.mtr.n_packets_enabled = 0;\n+\t\t\tp.mtr.n_bytes_enabled = 1;\n+\t\t} else if (strcmp(tokens[t0 + 5], \"both\") == 0) {\n+\t\t\tp.mtr.n_packets_enabled = 1;\n+\t\t\tp.mtr.n_bytes_enabled = 1;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"none or pkts or bytes or both\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_MTR;\n+\t\tt0 += 6;\n+\t} /* meter */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"tm\") == 0)) {\n+\t\tif (n_tokens < t0 + 5) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"table action profile tm\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"spp\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"spp\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.tm.n_subports_per_port,\n+\t\t\ttokens[t0 + 2]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"n_subports_per_port\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"pps\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pps\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.tm.n_pipes_per_subport,\n+\t\t\ttokens[t0 + 4]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"n_pipes_per_subport\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_TM;\n+\t\tt0 += 5;\n+\t} /* tm */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"encap\") == 0)) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"action profile encap\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"ether\") == 0) {\n+\t\t\tp.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_ETHER;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"vlan\") == 0) {\n+\t\t\tp.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_VLAN;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"qinq\") == 0) {\n+\t\t\tp.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_QINQ;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"mpls\") == 0) {\n+\t\t\tp.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_MPLS;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"pppoe\") == 0) {\n+\t\t\tp.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_PPPOE;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, \"encap\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_ENCAP;\n+\t\tt0 += 2;\n+\t} /* encap */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"nat\") == 0)) {\n+\t\tif (n_tokens < t0 + 4) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"table action profile nat\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"src\") == 0) {\n+\t\t\tp.nat.source_nat = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"dst\") == 0) {\n+\t\t\tp.nat.source_nat = 0;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"src or dst\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"proto\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"proto\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"tcp\") == 0) {\n+\t\t\tp.nat.proto = 0x06;\n+\t\t} else if (strcmp(tokens[t0 + 3], \"udp\") == 0) {\n+\t\t\tp.nat.proto = 0x11;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"tcp or udp\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_NAT;\n+\t\tt0 += 4;\n+\t} /* nat */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"ttl\") == 0)) {\n+\t\tif (n_tokens < t0 + 4) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"table action profile ttl\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"drop\") == 0) {\n+\t\t\tp.ttl.drop = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"fwd\") == 0) {\n+\t\t\tp.ttl.drop = 0;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"drop or fwd\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"stats\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"stats\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"none\") == 0) {\n+\t\t\tp.ttl.n_packets_enabled = 0;\n+\t\t} else if (strcmp(tokens[t0 + 3], \"pkts\") == 0) {\n+\t\t\tp.ttl.n_packets_enabled = 1;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"none or pkts\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_TTL;\n+\t\tt0 += 4;\n+\t} /* ttl */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"stats\") == 0)) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"table action profile stats\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"pkts\") == 0) {\n+\t\t\tp.stats.n_packets_enabled = 1;\n+\t\t\tp.stats.n_bytes_enabled = 0;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"bytes\") == 0) {\n+\t\t\tp.stats.n_packets_enabled = 0;\n+\t\t\tp.stats.n_bytes_enabled = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"both\") == 0) {\n+\t\t\tp.stats.n_packets_enabled = 1;\n+\t\t\tp.stats.n_bytes_enabled = 1;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size,\tMSG_ARG_NOT_FOUND,\n+\t\t\t\t\"pkts or bytes or both\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_STATS;\n+\t\tt0 += 2;\n+\t} /* stats */\n+\n+\tif (t0 < n_tokens &&\n+\t\t(strcmp(tokens[t0], \"time\") == 0)) {\n+\t\tp.action_mask |= 1LLU << RTE_TABLE_ACTION_TIME;\n+\t\tt0 += 1;\n+\t} /* time */\n+\n+\tif (t0 < n_tokens) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tap = softnic_table_action_profile_create(softnic, name, &p);\n+\tif (ap == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * pipeline <pipeline_name>\n+ *  period <timer_period_ms>\n+ *  offset_port_id <offset_port_id>\n+ */\n+static void\n+cmd_pipeline(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct pipeline_params p;\n+\tchar *name;\n+\tstruct pipeline *pipeline;\n+\n+\tif (n_tokens != 6) {\n+\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tname = tokens[1];\n+\n+\tif (strcmp(tokens[2], \"period\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"period\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.timer_period_ms,\n+\t\ttokens[3]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"timer_period_ms\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"offset_port_id\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset_port_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.offset_port_id,\n+\t\ttokens[5]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"offset_port_id\");\n+\t\treturn;\n+\t}\n+\n+\tpipeline = softnic_pipeline_create(softnic, name, &p);\n+\tif (pipeline == NULL) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n+/**\n+ * pipeline <pipeline_name> port in\n+ *  bsz <burst_size>\n+ *  link <link_name> rxq <queue_id>\n+ *  | swq <swq_name>\n+ *  | tmgr <tmgr_name>\n+ *  | tap <tap_name> mempool <mempool_name> mtu <mtu>\n+ *  | source mempool <mempool_name> file <file_name> bpp <n_bytes_per_pkt>\n+ *  [action <port_in_action_profile_name>]\n+ *  [disabled]\n+ */\n+static void\n+cmd_pipeline_port_in(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_port_in_params p;\n+\tchar *pipeline_name;\n+\tuint32_t t0;\n+\tint enabled, status;\n+\n+\tif (n_tokens < 7) {\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], \"port\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"in\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"in\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"bsz\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"bsz\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.burst_size, tokens[5]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"burst_size\");\n+\t\treturn;\n+\t}\n+\n+\tt0 = 6;\n+\n+\tif (strcmp(tokens[t0], \"link\") == 0) {\n+\t\tif (n_tokens < t0 + 4) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port in link\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_IN_RXQ;\n+\n+\t\tp.dev_name = tokens[t0 + 1];\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"rxq\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"rxq\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint16(&p.rxq.queue_id,\n+\t\t\ttokens[t0 + 3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"queue_id\");\n+\t\t\treturn;\n+\t\t}\n+\t\tt0 += 4;\n+\t} else if (strcmp(tokens[t0], \"swq\") == 0) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port in swq\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_IN_SWQ;\n+\n+\t\tp.dev_name = tokens[t0 + 1];\n+\n+\t\tt0 += 2;\n+\t} else if (strcmp(tokens[t0], \"tmgr\") == 0) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port in tmgr\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_IN_TMGR;\n+\n+\t\tp.dev_name = tokens[t0 + 1];\n+\n+\t\tt0 += 2;\n+\t} else if (strcmp(tokens[t0], \"tap\") == 0) {\n+\t\tif (n_tokens < t0 + 6) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port in tap\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_IN_TAP;\n+\n+\t\tp.dev_name = tokens[t0 + 1];\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"mempool\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"mempool\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.tap.mempool_name = tokens[t0 + 3];\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"mtu\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"mtu\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.tap.mtu,\n+\t\t\ttokens[t0 + 5]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"mtu\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 6;\n+\t} else if (strcmp(tokens[t0], \"source\") == 0) {\n+\t\tif (n_tokens < t0 + 6) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port in source\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_IN_SOURCE;\n+\n+\t\tp.dev_name = NULL;\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"mempool\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"mempool\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.source.mempool_name = tokens[t0 + 2];\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"file\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"file\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.source.file_name = tokens[t0 + 4];\n+\n+\t\tif (strcmp(tokens[t0 + 5], \"bpp\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"bpp\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.source.n_bytes_per_pkt,\n+\t\t\ttokens[t0 + 6]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"n_bytes_per_pkt\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 7;\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tp.action_profile_name = NULL;\n+\tif (n_tokens > t0 &&\n+\t\t(strcmp(tokens[t0], \"action\") == 0)) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, \"action\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_profile_name = tokens[t0 + 1];\n+\n+\t\tt0 += 2;\n+\t}\n+\n+\tenabled = 1;\n+\tif (n_tokens > t0 &&\n+\t\t(strcmp(tokens[t0], \"disabled\") == 0)) {\n+\t\tenabled = 0;\n+\n+\t\tt0 += 1;\n+\t}\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 = softnic_pipeline_port_in_create(softnic,\n+\t\tpipeline_name,\n+\t\t&p,\n+\t\tenabled);\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> port out\n+ *  bsz <burst_size>\n+ *  link <link_name> txq <txq_id>\n+ *  | swq <swq_name>\n+ *  | tmgr <tmgr_name>\n+ *  | tap <tap_name>\n+ *  | sink [file <file_name> pkts <max_n_pkts>]\n+ */\n+static void\n+cmd_pipeline_port_out(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tstruct softnic_port_out_params p;\n+\tchar *pipeline_name;\n+\tint status;\n+\n+\tmemset(&p, 0, sizeof(p));\n+\n+\tif (n_tokens < 7) {\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], \"port\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"out\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"out\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[4], \"bsz\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"bsz\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&p.burst_size, tokens[5]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"burst_size\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[6], \"link\") == 0) {\n+\t\tif (n_tokens != 10) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port out link\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_OUT_TXQ;\n+\n+\t\tp.dev_name = tokens[7];\n+\n+\t\tif (strcmp(tokens[8], \"txq\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"txq\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint16(&p.txq.queue_id,\n+\t\t\ttokens[9]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"queue_id\");\n+\t\t\treturn;\n+\t\t}\n+\t} else if (strcmp(tokens[6], \"swq\") == 0) {\n+\t\tif (n_tokens != 8) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port out swq\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_OUT_SWQ;\n+\n+\t\tp.dev_name = tokens[7];\n+\t} else if (strcmp(tokens[6], \"tmgr\") == 0) {\n+\t\tif (n_tokens != 8) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port out tmgr\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_OUT_TMGR;\n+\n+\t\tp.dev_name = tokens[7];\n+\t} else if (strcmp(tokens[6], \"tap\") == 0) {\n+\t\tif (n_tokens != 8) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port out tap\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_OUT_TAP;\n+\n+\t\tp.dev_name = tokens[7];\n+\t} else if (strcmp(tokens[6], \"sink\") == 0) {\n+\t\tif ((n_tokens != 7) && (n_tokens != 11)) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline port out sink\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.type = PORT_OUT_SINK;\n+\n+\t\tp.dev_name = NULL;\n+\n+\t\tif (n_tokens == 7) {\n+\t\t\tp.sink.file_name = NULL;\n+\t\t\tp.sink.max_n_pkts = 0;\n+\t\t} else {\n+\t\t\tif (strcmp(tokens[7], \"file\") != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\t\"file\");\n+\t\t\t\treturn;\n+\t\t\t}\n+\n+\t\t\tp.sink.file_name = tokens[8];\n+\n+\t\t\tif (strcmp(tokens[9], \"pkts\") != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"pkts\");\n+\t\t\t\treturn;\n+\t\t\t}\n+\n+\t\t\tif (softnic_parser_read_uint32(&p.sink.max_n_pkts,\n+\t\t\t\ttokens[10]) != 0) {\n+\t\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"max_n_pkts\");\n+\t\t\t\treturn;\n+\t\t\t}\n+\t\t}\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tstatus = softnic_pipeline_port_out_create(softnic, pipeline_name, &p);\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\n+ *      match\n+ *      acl\n+ *          ipv4 | ipv6\n+ *          offset <ip_header_offset>\n+ *          size <n_rules>\n+ *      | array\n+ *          offset <key_offset>\n+ *          size <n_keys>\n+ *      | hash\n+ *          ext | lru\n+ *          key <key_size>\n+ *          mask <key_mask>\n+ *          offset <key_offset>\n+ *          buckets <n_buckets>\n+ *          size <n_keys>\n+ *      | lpm\n+ *          ipv4 | ipv6\n+ *          offset <ip_header_offset>\n+ *          size <n_rules>\n+ *      | stub\n+ *  [action <table_action_profile_name>]\n+ */\n+static void\n+cmd_pipeline_table(struct pmd_internals *softnic,\n+\tchar **tokens,\n+\tuint32_t n_tokens,\n+\tchar *out,\n+\tsize_t out_size)\n+{\n+\tuint8_t key_mask[TABLE_RULE_MATCH_SIZE_MAX];\n+\tstruct softnic_table_params p;\n+\tchar *pipeline_name;\n+\tuint32_t t0;\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+\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 (strcmp(tokens[3], \"match\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"match\");\n+\t\treturn;\n+\t}\n+\n+\tt0 = 4;\n+\tif (strcmp(tokens[t0], \"acl\") == 0) {\n+\t\tif (n_tokens < t0 + 6) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline table acl\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.match_type = TABLE_ACL;\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"ipv4\") == 0) {\n+\t\t\tp.match.acl.ip_version = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"ipv6\") == 0) {\n+\t\t\tp.match.acl.ip_version = 0;\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;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.acl.ip_header_offset,\n+\t\t\ttokens[t0 + 3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID,\n+\t\t\t\t\"ip_header_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"size\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"size\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.acl.n_rules,\n+\t\t\ttokens[t0 + 5]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_rules\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 6;\n+\t} else if (strcmp(tokens[t0], \"array\") == 0) {\n+\t\tif (n_tokens < t0 + 5) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline table array\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.match_type = TABLE_ARRAY;\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.array.key_offset,\n+\t\t\ttokens[t0 + 2]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 3], \"size\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"size\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.array.n_keys,\n+\t\t\ttokens[t0 + 4]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_keys\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 5;\n+\t} else if (strcmp(tokens[t0], \"hash\") == 0) {\n+\t\tuint32_t key_mask_size = TABLE_RULE_MATCH_SIZE_MAX;\n+\n+\t\tif (n_tokens < t0 + 12) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline table hash\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.match_type = TABLE_HASH;\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"ext\") == 0) {\n+\t\t\tp.match.hash.extendable_bucket = 1;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"lru\") == 0) {\n+\t\t\tp.match.hash.extendable_bucket = 0;\n+\t\t} else {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND,\n+\t\t\t\t\"ext or lru\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"key\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"key\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((softnic_parser_read_uint32(&p.match.hash.key_size,\n+\t\t\ttokens[t0 + 3]) != 0) ||\n+\t\t\tp.match.hash.key_size == 0 ||\n+\t\t\tp.match.hash.key_size > TABLE_RULE_MATCH_SIZE_MAX) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_size\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"mask\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"mask\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif ((softnic_parse_hex_string(tokens[t0 + 5],\n+\t\t\tkey_mask, &key_mask_size) != 0) ||\n+\t\t\tkey_mask_size != p.match.hash.key_size) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_mask\");\n+\t\t\treturn;\n+\t\t}\n+\t\tp.match.hash.key_mask = key_mask;\n+\n+\t\tif (strcmp(tokens[t0 + 6], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.hash.key_offset,\n+\t\t\ttokens[t0 + 7]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 8], \"buckets\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"buckets\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.hash.n_buckets,\n+\t\t\ttokens[t0 + 9]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_buckets\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 10], \"size\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"size\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.hash.n_keys,\n+\t\t\ttokens[t0 + 11]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_keys\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 12;\n+\t} else if (strcmp(tokens[t0], \"lpm\") == 0) {\n+\t\tif (n_tokens < t0 + 6) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH,\n+\t\t\t\t\"pipeline table lpm\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.match_type = TABLE_LPM;\n+\n+\t\tif (strcmp(tokens[t0 + 1], \"ipv4\") == 0) {\n+\t\t\tp.match.lpm.key_size = 4;\n+\t\t} else if (strcmp(tokens[t0 + 1], \"ipv6\") == 0) {\n+\t\t\tp.match.lpm.key_size = 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;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 2], \"offset\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.lpm.key_offset,\n+\t\t\ttokens[t0 + 3]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"key_offset\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (strcmp(tokens[t0 + 4], \"size\") != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"size\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tif (softnic_parser_read_uint32(&p.match.lpm.n_rules,\n+\t\t\ttokens[t0 + 5]) != 0) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"n_rules\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tt0 += 6;\n+\t} else if (strcmp(tokens[t0], \"stub\") == 0) {\n+\t\tp.match_type = TABLE_STUB;\n+\n+\t\tt0 += 1;\n+\t} else {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, tokens[0]);\n+\t\treturn;\n+\t}\n+\n+\tp.action_profile_name = NULL;\n+\tif (n_tokens > t0 &&\n+\t\t(strcmp(tokens[t0], \"action\") == 0)) {\n+\t\tif (n_tokens < t0 + 2) {\n+\t\t\tsnprintf(out, out_size, MSG_ARG_MISMATCH, \"action\");\n+\t\t\treturn;\n+\t\t}\n+\n+\t\tp.action_profile_name = tokens[t0 + 1];\n+\n+\t\tt0 += 2;\n+\t}\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 = softnic_pipeline_table_create(softnic, pipeline_name, &p);\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> port in <port_id> table <table_id>\n+ */\n+static void\n+cmd_pipeline_port_in_table(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 port_id, table_id;\n+\tint status;\n+\n+\tif (n_tokens != 7) {\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], \"port\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"in\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"in\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"table\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"table\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&table_id, tokens[6]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"table_id\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = softnic_pipeline_port_in_connect_to_table(softnic,\n+\t\tpipeline_name,\n+\t\tport_id,\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+ * pipeline <pipeline_name> port in <port_id> enable\n+ */\n+static void\n+cmd_softnic_pipeline_port_in_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 port_id;\n+\tint status;\n+\n+\tif (n_tokens != 6) {\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], \"port\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"in\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"in\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"enable\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"enable\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = softnic_pipeline_port_in_enable(softnic, pipeline_name, port_id);\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> port in <port_id> disable\n+ */\n+static void\n+cmd_softnic_pipeline_port_in_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 port_id;\n+\tint status;\n+\n+\tif (n_tokens != 6) {\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], \"port\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"port\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[3], \"in\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"in\");\n+\t\treturn;\n+\t}\n+\n+\tif (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_INVALID, \"port_id\");\n+\t\treturn;\n+\t}\n+\n+\tif (strcmp(tokens[5], \"disable\") != 0) {\n+\t\tsnprintf(out, out_size, MSG_ARG_NOT_FOUND, \"disable\");\n+\t\treturn;\n+\t}\n+\n+\tstatus = softnic_pipeline_port_in_disable(softnic, pipeline_name, port_id);\n+\tif (status) {\n+\t\tsnprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);\n+\t\treturn;\n+\t}\n+}\n+\n void\n softnic_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-\targ = arg;\n-\n \tif (is_comment(in))\n \t\treturn;\n \n@@ -58,6 +1612,94 @@ softnic_cli_process(char *in, char *out, size_t out_size, void *arg)\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_softnic_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_softnic_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+\n \tsnprintf(out, out_size, MSG_CMD_UNKNOWN, tokens[0]);\n }\n \ndiff --git a/drivers/net/softnic/rte_eth_softnic_internals.h b/drivers/net/softnic/rte_eth_softnic_internals.h\nindex c2bd637..2aba9a0 100644\n--- a/drivers/net/softnic/rte_eth_softnic_internals.h\n+++ b/drivers/net/softnic/rte_eth_softnic_internals.h\n@@ -689,6 +689,91 @@ softnic_pipeline_table_create(struct pmd_internals *p,\n \tconst char *pipeline_name,\n \tstruct softnic_table_params *params);\n \n+struct softnic_table_rule_match_acl {\n+\tint ip_version;\n+\n+\tRTE_STD_C11\n+\tunion {\n+\t\tstruct {\n+\t\t\tuint32_t sa;\n+\t\t\tuint32_t da;\n+\t\t} ipv4;\n+\n+\t\tstruct {\n+\t\t\tuint8_t sa[16];\n+\t\t\tuint8_t da[16];\n+\t\t} ipv6;\n+\t};\n+\n+\tuint32_t sa_depth;\n+\tuint32_t da_depth;\n+\tuint16_t sp0;\n+\tuint16_t sp1;\n+\tuint16_t dp0;\n+\tuint16_t dp1;\n+\tuint8_t proto;\n+\tuint8_t proto_mask;\n+\tuint32_t priority;\n+};\n+\n+struct softnic_table_rule_match_array {\n+\tuint32_t pos;\n+};\n+\n+#ifndef TABLE_RULE_MATCH_SIZE_MAX\n+#define TABLE_RULE_MATCH_SIZE_MAX                          256\n+#endif\n+\n+struct softnic_table_rule_match_hash {\n+\tuint8_t key[TABLE_RULE_MATCH_SIZE_MAX];\n+};\n+\n+struct softnic_table_rule_match_lpm {\n+\tint ip_version;\n+\n+\tRTE_STD_C11\n+\tunion {\n+\t\tuint32_t ipv4;\n+\t\tuint8_t ipv6[16];\n+\t};\n+\n+\tuint8_t depth;\n+};\n+\n+struct softnic_table_rule_match {\n+\tenum softnic_table_type match_type;\n+\n+\tunion {\n+\t\tstruct softnic_table_rule_match_acl acl;\n+\t\tstruct softnic_table_rule_match_array array;\n+\t\tstruct softnic_table_rule_match_hash hash;\n+\t\tstruct softnic_table_rule_match_lpm lpm;\n+\t} match;\n+};\n+\n+struct softnic_table_rule_action {\n+\tuint64_t action_mask;\n+\tstruct rte_table_action_fwd_params fwd;\n+\tstruct rte_table_action_lb_params lb;\n+\tstruct rte_table_action_mtr_params mtr;\n+\tstruct rte_table_action_tm_params tm;\n+\tstruct rte_table_action_encap_params encap;\n+\tstruct rte_table_action_nat_params nat;\n+\tstruct rte_table_action_ttl_params ttl;\n+\tstruct rte_table_action_stats_params stats;\n+\tstruct rte_table_action_time_params time;\n+};\n+\n+int\n+softnic_pipeline_port_in_enable(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t port_id);\n+\n+int\n+softnic_pipeline_port_in_disable(struct pmd_internals *p,\n+\tconst char *pipeline_name,\n+\tuint32_t port_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 505d34e..2d23257 100644\n--- a/drivers/net/softnic/rte_eth_softnic_thread.c\n+++ b/drivers/net/softnic/rte_eth_softnic_thread.c\n@@ -89,6 +89,29 @@ softnic_thread_init(struct pmd_internals *softnic)\n \treturn 0;\n }\n \n+static inline int\n+thread_is_running(uint32_t thread_id)\n+{\n+\tenum rte_lcore_state_t thread_state;\n+\n+\tthread_state = rte_eal_get_lcore_state(thread_id);\n+\treturn (thread_state == RUNNING)? 1 : 0;\n+}\n+\n+/**\n+ * Pipeline is running when:\n+ *    (A) Pipeline is mapped to a data plane thread AND\n+ *    (B) Its data plane thread is in RUNNING state.\n+ */\n+static inline int\n+pipeline_is_running(struct pipeline *p)\n+{\n+\tif (p->enabled == 0)\n+\t\treturn 0;\n+\n+\treturn thread_is_running(p->thread_id);\n+}\n+\n /**\n  * Master thread & data plane threads: message passing\n  */\n@@ -156,11 +179,16 @@ thread_msg_handle(struct softnic_thread_data *t)\n  * Master thread & data plane threads: message passing\n  */\n enum pipeline_req_type {\n+\t/* Port IN */\n+\tPIPELINE_REQ_PORT_IN_ENABLE,\n+\tPIPELINE_REQ_PORT_IN_DISABLE,\n+\n \tPIPELINE_REQ_MAX\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 \n struct pipeline_msg_rsp {\n@@ -168,6 +196,140 @@ struct pipeline_msg_rsp {\n };\n \n /**\n+ * Master thread\n+ */\n+static struct pipeline_msg_req *\n+pipeline_msg_alloc(void)\n+{\n+\tsize_t size = RTE_MAX(sizeof(struct pipeline_msg_req),\n+\t\tsizeof(struct pipeline_msg_rsp));\n+\n+\treturn calloc(1, size);\n+}\n+\n+static void\n+pipeline_msg_free(struct pipeline_msg_rsp *rsp)\n+{\n+\tfree(rsp);\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_send_recv(struct pipeline *p,\n+\tstruct pipeline_msg_req *req)\n+{\n+\tstruct rte_ring *msgq_req = p->msgq_req;\n+\tstruct rte_ring *msgq_rsp = p->msgq_rsp;\n+\tstruct pipeline_msg_rsp *rsp;\n+\tint status;\n+\n+\t/* send */\n+\tdo {\n+\t\tstatus = rte_ring_sp_enqueue(msgq_req, req);\n+\t} while (status == -ENOBUFS);\n+\n+\t/* recv */\n+\tdo {\n+\t\tstatus = rte_ring_sc_dequeue(msgq_rsp, (void **)&rsp);\n+\t} while (status != 0);\n+\n+\treturn rsp;\n+}\n+\n+int\n+softnic_pipeline_port_in_enable(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t port_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 = softnic_pipeline_find(softnic, pipeline_name);\n+\tif (p == NULL ||\n+\t\tport_id >= p->n_ports_in)\n+\t\treturn -1;\n+\n+\tif (!pipeline_is_running(p)) {\n+\t\tstatus = rte_pipeline_port_in_enable(p->p, port_id);\n+\t\treturn status;\n+\t}\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_PORT_IN_ENABLE;\n+\treq->id = port_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+int\n+softnic_pipeline_port_in_disable(struct pmd_internals *softnic,\n+\tconst char *pipeline_name,\n+\tuint32_t port_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 = softnic_pipeline_find(softnic, pipeline_name);\n+\tif (p == NULL ||\n+\t\tport_id >= p->n_ports_in)\n+\t\treturn -1;\n+\n+\tif (!pipeline_is_running(p)) {\n+\t\tstatus = rte_pipeline_port_in_disable(p->p, port_id);\n+\t\treturn status;\n+\t}\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_PORT_IN_DISABLE;\n+\treq->id = port_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 static inline struct pipeline_msg_req *\n@@ -194,6 +356,32 @@ pipeline_msg_send(struct rte_ring *msgq_rsp,\n \t} while (status == -ENOBUFS);\n }\n \n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_port_in_enable(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 port_id = req->id;\n+\n+\trsp->status = rte_pipeline_port_in_enable(p->p,\n+\t\tport_id);\n+\n+\treturn rsp;\n+}\n+\n+static struct pipeline_msg_rsp *\n+pipeline_msg_handle_port_in_disable(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 port_id = req->id;\n+\n+\trsp->status = rte_pipeline_port_in_disable(p->p,\n+\t\tport_id);\n+\n+\treturn rsp;\n+}\n+\n static void\n pipeline_msg_handle(struct pipeline_data *p)\n {\n@@ -206,6 +394,14 @@ pipeline_msg_handle(struct pipeline_data *p)\n \t\t\tbreak;\n \n \t\tswitch (req->type) {\n+\t\tcase PIPELINE_REQ_PORT_IN_ENABLE:\n+\t\t\trsp = pipeline_msg_handle_port_in_enable(p, req);\n+\t\t\tbreak;\n+\n+\t\tcase PIPELINE_REQ_PORT_IN_DISABLE:\n+\t\t\trsp = pipeline_msg_handle_port_in_disable(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": [
        "v5",
        "14/23"
    ]
}