From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 14348A0032; Thu, 1 Sep 2022 16:22:09 +0200 (CEST) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 59C7842B8A; Thu, 1 Sep 2022 16:21:13 +0200 (CEST) Received: from mga06.intel.com (mga06b.intel.com [134.134.136.31]) by mails.dpdk.org (Postfix) with ESMTP id F09D642802 for ; Thu, 1 Sep 2022 16:21:06 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1662042067; x=1693578067; h=from:to:cc:subject:date:message-id:in-reply-to: references:mime-version:content-transfer-encoding; bh=yoQpkTC8iw6xIoVUr7HzjF30M1vhbnmYoG2egDsmI+Y=; b=j6fiHBnbolDQ/LPDBaycXid8nyxnz3R6OAJWRf+LP3HC5BU5NnraNa49 Kqk6NNfr/xEvzxZVi8W6X1HX4cLh2/+cMw/Tp6dV8FW7DG6M7RvUNeFms M+haBcRRJz2Q6/E5+e+QcltOu3roYgI+iEDUn42n7vSGak6iXg3bjfkzc LuUeR+6MLLI4hJMk2Frpz58yh6vC0/Hj+Iye1aL9hdLluYYOeUCUk8Pyf 1Ljx2PBccKre/Qwt8x0HbP7Sb0I+jVUzqQjR+GCFW/Ma0WlCkQmFHF+S3 B1a1+NYkOOVtS4hAW0amqfQQlMV9zig5ryYJDp9cWHSp+t65a5NesPnAc w==; X-IronPort-AV: E=McAfee;i="6500,9779,10457"; a="357444035" X-IronPort-AV: E=Sophos;i="5.93,281,1654585200"; d="scan'208";a="357444035" Received: from fmsmga004.fm.intel.com ([10.253.24.48]) by orsmga104.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 01 Sep 2022 07:20:49 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.93,281,1654585200"; d="scan'208";a="680870173" Received: from silpixa00400573.ir.intel.com (HELO silpixa00400573.ger.corp.intel.com.) ([10.237.223.157]) by fmsmga004.fm.intel.com with ESMTP; 01 Sep 2022 07:20:48 -0700 From: Cristian Dumitrescu To: dev@dpdk.org Cc: Yogesh Jangra Subject: [PATCH V3 06/21] net/softnic: remove the legacy pipeline CLI commands Date: Thu, 1 Sep 2022 14:20:26 +0000 Message-Id: <20220901142041.2628537-7-cristian.dumitrescu@intel.com> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20220901142041.2628537-1-cristian.dumitrescu@intel.com> References: <20220804165839.1074817-1-cristian.dumitrescu@intel.com> <20220901142041.2628537-1-cristian.dumitrescu@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Remove the legacy pipeline CLI commands. Signed-off-by: Cristian Dumitrescu Signed-off-by: Yogesh Jangra --- drivers/net/softnic/rte_eth_softnic_cli.c | 4527 --------------------- 1 file changed, 4527 deletions(-) diff --git a/drivers/net/softnic/rte_eth_softnic_cli.c b/drivers/net/softnic/rte_eth_softnic_cli.c index 501ef08c4c..abe275ec83 100644 --- a/drivers/net/softnic/rte_eth_softnic_cli.c +++ b/drivers/net/softnic/rte_eth_softnic_cli.c @@ -10,7 +10,6 @@ #include #include #include -#include #include "rte_eth_softnic_internals.h" #include "parser.h" @@ -186,4227 +185,6 @@ cmd_swq(struct pmd_internals *softnic, } } -/** - * port in action profile - * [filter match | mismatch offset mask key port ] - * [balance offset mask port ... ] - */ -static void -cmd_port_in_action_profile(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct softnic_port_in_action_profile_params p; - struct softnic_port_in_action_profile *ap; - char *name; - uint32_t t0; - - memset(&p, 0, sizeof(p)); - - if (n_tokens < 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - if (strcmp(tokens[1], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (strcmp(tokens[2], "action") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "action"); - return; - } - - if (strcmp(tokens[3], "profile") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "profile"); - return; - } - - name = tokens[4]; - - t0 = 5; - - if (t0 < n_tokens && - (strcmp(tokens[t0], "filter") == 0)) { - uint32_t size; - - if (n_tokens < t0 + 10) { - snprintf(out, out_size, MSG_ARG_MISMATCH, "port in action profile filter"); - return; - } - - if (strcmp(tokens[t0 + 1], "match") == 0) { - p.fltr.filter_on_match = 1; - } else if (strcmp(tokens[t0 + 1], "mismatch") == 0) { - p.fltr.filter_on_match = 0; - } else { - snprintf(out, out_size, MSG_ARG_INVALID, "match or mismatch"); - return; - } - - if (strcmp(tokens[t0 + 2], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.fltr.key_offset, - tokens[t0 + 3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 4], "mask") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "mask"); - return; - } - - size = RTE_PORT_IN_ACTION_FLTR_KEY_SIZE; - if ((softnic_parse_hex_string(tokens[t0 + 5], - p.fltr.key_mask, &size) != 0) || - size != RTE_PORT_IN_ACTION_FLTR_KEY_SIZE) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_mask"); - return; - } - - if (strcmp(tokens[t0 + 6], "key") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "key"); - return; - } - - size = RTE_PORT_IN_ACTION_FLTR_KEY_SIZE; - if ((softnic_parse_hex_string(tokens[t0 + 7], - p.fltr.key, &size) != 0) || - size != RTE_PORT_IN_ACTION_FLTR_KEY_SIZE) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_value"); - return; - } - - if (strcmp(tokens[t0 + 8], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (softnic_parser_read_uint32(&p.fltr.port_id, - tokens[t0 + 9]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - p.action_mask |= 1LLU << RTE_PORT_IN_ACTION_FLTR; - t0 += 10; - } /* filter */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "balance") == 0)) { - uint32_t i; - - if (n_tokens < t0 + 22) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "port in action profile balance"); - return; - } - - if (strcmp(tokens[t0 + 1], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.lb.key_offset, - tokens[t0 + 2]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 3], "mask") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "mask"); - return; - } - - p.lb.key_size = RTE_PORT_IN_ACTION_LB_KEY_SIZE_MAX; - if (softnic_parse_hex_string(tokens[t0 + 4], - p.lb.key_mask, &p.lb.key_size) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_mask"); - return; - } - - if (strcmp(tokens[t0 + 5], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - for (i = 0; i < 16; i++) - if (softnic_parser_read_uint32(&p.lb.port_id[i], - tokens[t0 + 6 + i]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - p.action_mask |= 1LLU << RTE_PORT_IN_ACTION_LB; - t0 += 22; - } /* balance */ - - if (t0 < n_tokens) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - ap = softnic_port_in_action_profile_create(softnic, name, &p); - if (ap == NULL) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * table action profile - * ipv4 | ipv6 - * offset - * fwd - * [balance offset mask outoffset ] - * [meter srtcm | trtcm - * tc - * stats none | pkts | bytes | both] - * [tm spp pps ] - * [encap ether | vlan | qinq | mpls | pppoe | qinq_pppoe | - * vxlan offset ipv4 | ipv6 vlan on | off] - * [nat src | dst - * proto udp | tcp] - * [ttl drop | fwd - * stats none | pkts] - * [stats pkts | bytes | both] - * [time] - * [tag] - * [decap] - * - */ -static void -cmd_table_action_profile(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct softnic_table_action_profile_params p; - struct softnic_table_action_profile *ap; - char *name; - uint32_t t0; - - memset(&p, 0, sizeof(p)); - - if (n_tokens < 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - if (strcmp(tokens[1], "action") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "action"); - return; - } - - if (strcmp(tokens[2], "profile") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "profile"); - return; - } - - name = tokens[3]; - - if (strcmp(tokens[4], "ipv4") == 0) { - p.common.ip_version = 1; - } else if (strcmp(tokens[4], "ipv6") == 0) { - p.common.ip_version = 0; - } else { - snprintf(out, out_size, MSG_ARG_INVALID, "ipv4 or ipv6"); - return; - } - - if (strcmp(tokens[5], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.common.ip_offset, - tokens[6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "ip_offset"); - return; - } - - if (strcmp(tokens[7], "fwd") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "fwd"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_FWD; - - t0 = 8; - if (t0 < n_tokens && - (strcmp(tokens[t0], "balance") == 0)) { - if (n_tokens < t0 + 7) { - snprintf(out, out_size, MSG_ARG_MISMATCH, "table action profile balance"); - return; - } - - if (strcmp(tokens[t0 + 1], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.lb.key_offset, - tokens[t0 + 2]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 3], "mask") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "mask"); - return; - } - - p.lb.key_size = RTE_PORT_IN_ACTION_LB_KEY_SIZE_MAX; - if (softnic_parse_hex_string(tokens[t0 + 4], - p.lb.key_mask, &p.lb.key_size) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_mask"); - return; - } - - if (strcmp(tokens[t0 + 5], "outoffset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "outoffset"); - return; - } - - if (softnic_parser_read_uint32(&p.lb.out_offset, - tokens[t0 + 6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "out_offset"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_LB; - t0 += 7; - } /* balance */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "meter") == 0)) { - if (n_tokens < t0 + 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "table action profile meter"); - return; - } - - if (strcmp(tokens[t0 + 1], "srtcm") == 0) { - p.mtr.alg = RTE_TABLE_ACTION_METER_SRTCM; - } else if (strcmp(tokens[t0 + 1], "trtcm") == 0) { - p.mtr.alg = RTE_TABLE_ACTION_METER_TRTCM; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "srtcm or trtcm"); - return; - } - - if (strcmp(tokens[t0 + 2], "tc") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "tc"); - return; - } - - if (softnic_parser_read_uint32(&p.mtr.n_tc, - tokens[t0 + 3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_tc"); - return; - } - - if (strcmp(tokens[t0 + 4], "stats") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "stats"); - return; - } - - if (strcmp(tokens[t0 + 5], "none") == 0) { - p.mtr.n_packets_enabled = 0; - p.mtr.n_bytes_enabled = 0; - } else if (strcmp(tokens[t0 + 5], "pkts") == 0) { - p.mtr.n_packets_enabled = 1; - p.mtr.n_bytes_enabled = 0; - } else if (strcmp(tokens[t0 + 5], "bytes") == 0) { - p.mtr.n_packets_enabled = 0; - p.mtr.n_bytes_enabled = 1; - } else if (strcmp(tokens[t0 + 5], "both") == 0) { - p.mtr.n_packets_enabled = 1; - p.mtr.n_bytes_enabled = 1; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "none or pkts or bytes or both"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_MTR; - t0 += 6; - } /* meter */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "tm") == 0)) { - if (n_tokens < t0 + 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "table action profile tm"); - return; - } - - if (strcmp(tokens[t0 + 1], "spp") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "spp"); - return; - } - - if (softnic_parser_read_uint32(&p.tm.n_subports_per_port, - tokens[t0 + 2]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "n_subports_per_port"); - return; - } - - if (strcmp(tokens[t0 + 3], "pps") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "pps"); - return; - } - - if (softnic_parser_read_uint32(&p.tm.n_pipes_per_subport, - tokens[t0 + 4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "n_pipes_per_subport"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_TM; - t0 += 5; - } /* tm */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "encap") == 0)) { - uint32_t n_extra_tokens = 0; - - if (n_tokens < t0 + 2) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "action profile encap"); - return; - } - - if (strcmp(tokens[t0 + 1], "ether") == 0) { - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_ETHER; - } else if (strcmp(tokens[t0 + 1], "vlan") == 0) { - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_VLAN; - } else if (strcmp(tokens[t0 + 1], "qinq") == 0) { - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_QINQ; - } else if (strcmp(tokens[t0 + 1], "mpls") == 0) { - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_MPLS; - } else if (strcmp(tokens[t0 + 1], "pppoe") == 0) { - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_PPPOE; - } else if (strcmp(tokens[t0 + 1], "vxlan") == 0) { - if (n_tokens < t0 + 2 + 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "action profile encap vxlan"); - return; - } - - if (strcmp(tokens[t0 + 2], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "vxlan: offset"); - return; - } - - if (softnic_parser_read_uint32(&p.encap.vxlan.data_offset, - tokens[t0 + 2 + 1]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "vxlan: ether_offset"); - return; - } - - if (strcmp(tokens[t0 + 2 + 2], "ipv4") == 0) - p.encap.vxlan.ip_version = 1; - else if (strcmp(tokens[t0 + 2 + 2], "ipv6") == 0) - p.encap.vxlan.ip_version = 0; - else { - snprintf(out, out_size, MSG_ARG_INVALID, - "vxlan: ipv4 or ipv6"); - return; - } - - if (strcmp(tokens[t0 + 2 + 3], "vlan") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "vxlan: vlan"); - return; - } - - if (strcmp(tokens[t0 + 2 + 4], "on") == 0) - p.encap.vxlan.vlan = 1; - else if (strcmp(tokens[t0 + 2 + 4], "off") == 0) - p.encap.vxlan.vlan = 0; - else { - snprintf(out, out_size, MSG_ARG_INVALID, - "vxlan: on or off"); - return; - } - - p.encap.encap_mask = 1LLU << RTE_TABLE_ACTION_ENCAP_VXLAN; - n_extra_tokens = 5; - - } else if (strcmp(tokens[t0 + 1], "qinq_pppoe") == 0) { - p.encap.encap_mask = - 1LLU << RTE_TABLE_ACTION_ENCAP_QINQ_PPPOE; - } else { - snprintf(out, out_size, MSG_ARG_MISMATCH, "encap"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_ENCAP; - t0 += 2 + n_extra_tokens; - } /* encap */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "nat") == 0)) { - if (n_tokens < t0 + 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "table action profile nat"); - return; - } - - if (strcmp(tokens[t0 + 1], "src") == 0) { - p.nat.source_nat = 1; - } else if (strcmp(tokens[t0 + 1], "dst") == 0) { - p.nat.source_nat = 0; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "src or dst"); - return; - } - - if (strcmp(tokens[t0 + 2], "proto") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "proto"); - return; - } - - if (strcmp(tokens[t0 + 3], "tcp") == 0) { - p.nat.proto = 0x06; - } else if (strcmp(tokens[t0 + 3], "udp") == 0) { - p.nat.proto = 0x11; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "tcp or udp"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_NAT; - t0 += 4; - } /* nat */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "ttl") == 0)) { - if (n_tokens < t0 + 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "table action profile ttl"); - return; - } - - if (strcmp(tokens[t0 + 1], "drop") == 0) { - p.ttl.drop = 1; - } else if (strcmp(tokens[t0 + 1], "fwd") == 0) { - p.ttl.drop = 0; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "drop or fwd"); - return; - } - - if (strcmp(tokens[t0 + 2], "stats") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "stats"); - return; - } - - if (strcmp(tokens[t0 + 3], "none") == 0) { - p.ttl.n_packets_enabled = 0; - } else if (strcmp(tokens[t0 + 3], "pkts") == 0) { - p.ttl.n_packets_enabled = 1; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "none or pkts"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_TTL; - t0 += 4; - } /* ttl */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "stats") == 0)) { - if (n_tokens < t0 + 2) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "table action profile stats"); - return; - } - - if (strcmp(tokens[t0 + 1], "pkts") == 0) { - p.stats.n_packets_enabled = 1; - p.stats.n_bytes_enabled = 0; - } else if (strcmp(tokens[t0 + 1], "bytes") == 0) { - p.stats.n_packets_enabled = 0; - p.stats.n_bytes_enabled = 1; - } else if (strcmp(tokens[t0 + 1], "both") == 0) { - p.stats.n_packets_enabled = 1; - p.stats.n_bytes_enabled = 1; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "pkts or bytes or both"); - return; - } - - p.action_mask |= 1LLU << RTE_TABLE_ACTION_STATS; - t0 += 2; - } /* stats */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "time") == 0)) { - p.action_mask |= 1LLU << RTE_TABLE_ACTION_TIME; - t0 += 1; - } /* time */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "tag") == 0)) { - p.action_mask |= 1LLU << RTE_TABLE_ACTION_TAG; - t0 += 1; - } /* tag */ - - if (t0 < n_tokens && - (strcmp(tokens[t0], "decap") == 0)) { - p.action_mask |= 1LLU << RTE_TABLE_ACTION_DECAP; - t0 += 1; - } /* decap */ - - if (t0 < n_tokens) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - ap = softnic_table_action_profile_create(softnic, name, &p); - if (ap == NULL) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline - * period - * offset_port_id - */ -static void -cmd_pipeline(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct pipeline_params p; - char *name; - struct pipeline *pipeline; - - if (n_tokens != 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - name = tokens[1]; - - if (strcmp(tokens[2], "period") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "period"); - return; - } - - if (softnic_parser_read_uint32(&p.timer_period_ms, - tokens[3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "timer_period_ms"); - return; - } - - if (strcmp(tokens[4], "offset_port_id") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset_port_id"); - return; - } - - if (softnic_parser_read_uint32(&p.offset_port_id, - tokens[5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "offset_port_id"); - return; - } - - pipeline = softnic_pipeline_create(softnic, name, &p); - if (pipeline == NULL) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port in - * bsz - * link rxq - * | swq - * | source mempool file bpp - * [action ] - * [disabled] - */ -static void -cmd_pipeline_port_in(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct softnic_port_in_params p; - char *pipeline_name; - uint32_t t0; - int enabled, status; - - memset(&p, 0, sizeof(p)); - - if (n_tokens < 7) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (strcmp(tokens[4], "bsz") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "bsz"); - return; - } - - if (softnic_parser_read_uint32(&p.burst_size, tokens[5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "burst_size"); - return; - } - - t0 = 6; - - if (strcmp(tokens[t0], "link") == 0) { - if (n_tokens < t0 + 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port in link"); - return; - } - - p.type = PORT_IN_RXQ; - - strlcpy(p.dev_name, tokens[t0 + 1], sizeof(p.dev_name)); - - if (strcmp(tokens[t0 + 2], "rxq") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "rxq"); - return; - } - - if (softnic_parser_read_uint16(&p.rxq.queue_id, - tokens[t0 + 3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "queue_id"); - return; - } - t0 += 4; - } else if (strcmp(tokens[t0], "swq") == 0) { - if (n_tokens < t0 + 2) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port in swq"); - return; - } - - p.type = PORT_IN_SWQ; - - strlcpy(p.dev_name, tokens[t0 + 1], sizeof(p.dev_name)); - - t0 += 2; - } else if (strcmp(tokens[t0], "source") == 0) { - if (n_tokens < t0 + 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port in source"); - return; - } - - p.type = PORT_IN_SOURCE; - - if (strcmp(tokens[t0 + 1], "mempool") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "mempool"); - return; - } - - p.source.mempool_name = tokens[t0 + 2]; - - if (strcmp(tokens[t0 + 3], "file") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "file"); - return; - } - - p.source.file_name = tokens[t0 + 4]; - - if (strcmp(tokens[t0 + 5], "bpp") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "bpp"); - return; - } - - if (softnic_parser_read_uint32(&p.source.n_bytes_per_pkt, - tokens[t0 + 6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "n_bytes_per_pkt"); - return; - } - - t0 += 7; - } else { - snprintf(out, out_size, MSG_ARG_INVALID, tokens[0]); - return; - } - - if (n_tokens > t0 && - (strcmp(tokens[t0], "action") == 0)) { - if (n_tokens < t0 + 2) { - snprintf(out, out_size, MSG_ARG_MISMATCH, "action"); - return; - } - - strlcpy(p.action_profile_name, tokens[t0 + 1], - sizeof(p.action_profile_name)); - - t0 += 2; - } - - enabled = 1; - if (n_tokens > t0 && - (strcmp(tokens[t0], "disabled") == 0)) { - enabled = 0; - - t0 += 1; - } - - if (n_tokens != t0) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - status = softnic_pipeline_port_in_create(softnic, - pipeline_name, - &p, - enabled); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port out - * bsz - * link txq - * | swq - * | sink [file pkts ] - */ -static void -cmd_pipeline_port_out(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct softnic_port_out_params p; - char *pipeline_name; - int status; - - memset(&p, 0, sizeof(p)); - - if (n_tokens < 7) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "out") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "out"); - return; - } - - if (strcmp(tokens[4], "bsz") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "bsz"); - return; - } - - if (softnic_parser_read_uint32(&p.burst_size, tokens[5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "burst_size"); - return; - } - - if (strcmp(tokens[6], "link") == 0) { - if (n_tokens != 10) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port out link"); - return; - } - - p.type = PORT_OUT_TXQ; - - strlcpy(p.dev_name, tokens[7], sizeof(p.dev_name)); - - if (strcmp(tokens[8], "txq") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "txq"); - return; - } - - if (softnic_parser_read_uint16(&p.txq.queue_id, - tokens[9]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "queue_id"); - return; - } - } else if (strcmp(tokens[6], "swq") == 0) { - if (n_tokens != 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port out swq"); - return; - } - - p.type = PORT_OUT_SWQ; - - strlcpy(p.dev_name, tokens[7], sizeof(p.dev_name)); - } else if (strcmp(tokens[6], "sink") == 0) { - if ((n_tokens != 7) && (n_tokens != 11)) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline port out sink"); - return; - } - - p.type = PORT_OUT_SINK; - - if (n_tokens == 7) { - p.sink.file_name = NULL; - p.sink.max_n_pkts = 0; - } else { - if (strcmp(tokens[7], "file") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "file"); - return; - } - - p.sink.file_name = tokens[8]; - - if (strcmp(tokens[9], "pkts") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "pkts"); - return; - } - - if (softnic_parser_read_uint32(&p.sink.max_n_pkts, - tokens[10]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "max_n_pkts"); - return; - } - } - } else { - snprintf(out, out_size, MSG_ARG_INVALID, tokens[0]); - return; - } - - status = softnic_pipeline_port_out_create(softnic, pipeline_name, &p); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline table - * match - * acl - * ipv4 | ipv6 - * offset - * size - * | array - * offset - * size - * | hash - * ext | lru - * key - * mask - * offset - * buckets - * size - * | lpm - * ipv4 | ipv6 - * offset - * size - * | stub - * [action ] - */ -static void -cmd_pipeline_table(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct softnic_table_params p; - char *pipeline_name; - uint32_t t0; - int status; - - memset(&p, 0, sizeof(p)); - - if (n_tokens < 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "table") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "table"); - return; - } - - if (strcmp(tokens[3], "match") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "match"); - return; - } - - t0 = 4; - if (strcmp(tokens[t0], "acl") == 0) { - if (n_tokens < t0 + 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline table acl"); - return; - } - - p.match_type = TABLE_ACL; - - if (strcmp(tokens[t0 + 1], "ipv4") == 0) { - p.match.acl.ip_version = 1; - } else if (strcmp(tokens[t0 + 1], "ipv6") == 0) { - p.match.acl.ip_version = 0; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "ipv4 or ipv6"); - return; - } - - if (strcmp(tokens[t0 + 2], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.match.acl.ip_header_offset, - tokens[t0 + 3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "ip_header_offset"); - return; - } - - if (strcmp(tokens[t0 + 4], "size") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "size"); - return; - } - - if (softnic_parser_read_uint32(&p.match.acl.n_rules, - tokens[t0 + 5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_rules"); - return; - } - - t0 += 6; - } else if (strcmp(tokens[t0], "array") == 0) { - if (n_tokens < t0 + 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline table array"); - return; - } - - p.match_type = TABLE_ARRAY; - - if (strcmp(tokens[t0 + 1], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.match.array.key_offset, - tokens[t0 + 2]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 3], "size") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "size"); - return; - } - - if (softnic_parser_read_uint32(&p.match.array.n_keys, - tokens[t0 + 4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_keys"); - return; - } - - t0 += 5; - } else if (strcmp(tokens[t0], "hash") == 0) { - uint32_t key_mask_size = TABLE_RULE_MATCH_SIZE_MAX; - - if (n_tokens < t0 + 12) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline table hash"); - return; - } - - p.match_type = TABLE_HASH; - - if (strcmp(tokens[t0 + 1], "ext") == 0) { - p.match.hash.extendable_bucket = 1; - } else if (strcmp(tokens[t0 + 1], "lru") == 0) { - p.match.hash.extendable_bucket = 0; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "ext or lru"); - return; - } - - if (strcmp(tokens[t0 + 2], "key") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "key"); - return; - } - - if ((softnic_parser_read_uint32(&p.match.hash.key_size, - tokens[t0 + 3]) != 0) || - p.match.hash.key_size == 0 || - p.match.hash.key_size > TABLE_RULE_MATCH_SIZE_MAX) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_size"); - return; - } - - if (strcmp(tokens[t0 + 4], "mask") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "mask"); - return; - } - - if ((softnic_parse_hex_string(tokens[t0 + 5], - p.match.hash.key_mask, &key_mask_size) != 0) || - key_mask_size != p.match.hash.key_size) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_mask"); - return; - } - - if (strcmp(tokens[t0 + 6], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.match.hash.key_offset, - tokens[t0 + 7]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 8], "buckets") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "buckets"); - return; - } - - if (softnic_parser_read_uint32(&p.match.hash.n_buckets, - tokens[t0 + 9]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_buckets"); - return; - } - - if (strcmp(tokens[t0 + 10], "size") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "size"); - return; - } - - if (softnic_parser_read_uint32(&p.match.hash.n_keys, - tokens[t0 + 11]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_keys"); - return; - } - - t0 += 12; - } else if (strcmp(tokens[t0], "lpm") == 0) { - if (n_tokens < t0 + 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "pipeline table lpm"); - return; - } - - p.match_type = TABLE_LPM; - - if (strcmp(tokens[t0 + 1], "ipv4") == 0) { - p.match.lpm.key_size = 4; - } else if (strcmp(tokens[t0 + 1], "ipv6") == 0) { - p.match.lpm.key_size = 16; - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "ipv4 or ipv6"); - return; - } - - if (strcmp(tokens[t0 + 2], "offset") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "offset"); - return; - } - - if (softnic_parser_read_uint32(&p.match.lpm.key_offset, - tokens[t0 + 3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key_offset"); - return; - } - - if (strcmp(tokens[t0 + 4], "size") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "size"); - return; - } - - if (softnic_parser_read_uint32(&p.match.lpm.n_rules, - tokens[t0 + 5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "n_rules"); - return; - } - - t0 += 6; - } else if (strcmp(tokens[t0], "stub") == 0) { - p.match_type = TABLE_STUB; - - t0 += 1; - } else { - snprintf(out, out_size, MSG_ARG_INVALID, tokens[0]); - return; - } - - if (n_tokens > t0 && - (strcmp(tokens[t0], "action") == 0)) { - if (n_tokens < t0 + 2) { - snprintf(out, out_size, MSG_ARG_MISMATCH, "action"); - return; - } - - strlcpy(p.action_profile_name, tokens[t0 + 1], - sizeof(p.action_profile_name)); - - t0 += 2; - } - - if (n_tokens > t0) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - status = softnic_pipeline_table_create(softnic, pipeline_name, &p); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port in table - */ -static void -cmd_pipeline_port_in_table(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - char *pipeline_name; - uint32_t port_id, table_id; - int status; - - if (n_tokens != 7) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - if (strcmp(tokens[5], "table") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "table"); - return; - } - - if (softnic_parser_read_uint32(&table_id, tokens[6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "table_id"); - return; - } - - status = softnic_pipeline_port_in_connect_to_table(softnic, - pipeline_name, - port_id, - table_id); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port in stats read [clear] - */ - -#define MSG_PIPELINE_PORT_IN_STATS \ - "Pkts in: %" PRIu64 "\n" \ - "Pkts dropped by AH: %" PRIu64 "\n" \ - "Pkts dropped by other: %" PRIu64 "\n" - -static void -cmd_pipeline_port_in_stats(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct rte_pipeline_port_in_stats stats; - char *pipeline_name; - uint32_t port_id; - int clear, status; - - if (n_tokens != 7 && - n_tokens != 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - if (strcmp(tokens[5], "stats") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "stats"); - return; - } - - if (strcmp(tokens[6], "read") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "read"); - return; - } - - clear = 0; - if (n_tokens == 8) { - if (strcmp(tokens[7], "clear") != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "clear"); - return; - } - - clear = 1; - } - - status = softnic_pipeline_port_in_stats_read(softnic, - pipeline_name, - port_id, - &stats, - clear); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } - - snprintf(out, out_size, MSG_PIPELINE_PORT_IN_STATS, - stats.stats.n_pkts_in, - stats.n_pkts_dropped_by_ah, - stats.stats.n_pkts_drop); -} - -/** - * pipeline port in enable - */ -static void -cmd_softnic_pipeline_port_in_enable(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - char *pipeline_name; - uint32_t port_id; - int status; - - if (n_tokens != 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - if (strcmp(tokens[5], "enable") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "enable"); - return; - } - - status = softnic_pipeline_port_in_enable(softnic, pipeline_name, port_id); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port in disable - */ -static void -cmd_softnic_pipeline_port_in_disable(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - char *pipeline_name; - uint32_t port_id; - int status; - - if (n_tokens != 6) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "in") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "in"); - return; - } - - if (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - if (strcmp(tokens[5], "disable") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "disable"); - return; - } - - status = softnic_pipeline_port_in_disable(softnic, pipeline_name, port_id); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } -} - -/** - * pipeline port out stats read [clear] - */ -#define MSG_PIPELINE_PORT_OUT_STATS \ - "Pkts in: %" PRIu64 "\n" \ - "Pkts dropped by AH: %" PRIu64 "\n" \ - "Pkts dropped by other: %" PRIu64 "\n" - -static void -cmd_pipeline_port_out_stats(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct rte_pipeline_port_out_stats stats; - char *pipeline_name; - uint32_t port_id; - int clear, status; - - if (n_tokens != 7 && - n_tokens != 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "port") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (strcmp(tokens[3], "out") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "out"); - return; - } - - if (softnic_parser_read_uint32(&port_id, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "port_id"); - return; - } - - if (strcmp(tokens[5], "stats") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "stats"); - return; - } - - if (strcmp(tokens[6], "read") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "read"); - return; - } - - clear = 0; - if (n_tokens == 8) { - if (strcmp(tokens[7], "clear") != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "clear"); - return; - } - - clear = 1; - } - - status = softnic_pipeline_port_out_stats_read(softnic, - pipeline_name, - port_id, - &stats, - clear); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } - - snprintf(out, out_size, MSG_PIPELINE_PORT_OUT_STATS, - stats.stats.n_pkts_in, - stats.n_pkts_dropped_by_ah, - stats.stats.n_pkts_drop); -} - -/** - * pipeline table stats read [clear] - */ -#define MSG_PIPELINE_TABLE_STATS \ - "Pkts in: %" PRIu64 "\n" \ - "Pkts in with lookup miss: %" PRIu64 "\n" \ - "Pkts in with lookup hit dropped by AH: %" PRIu64 "\n" \ - "Pkts in with lookup hit dropped by others: %" PRIu64 "\n" \ - "Pkts in with lookup miss dropped by AH: %" PRIu64 "\n" \ - "Pkts in with lookup miss dropped by others: %" PRIu64 "\n" - -static void -cmd_pipeline_table_stats(struct pmd_internals *softnic, - char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size) -{ - struct rte_pipeline_table_stats stats; - char *pipeline_name; - uint32_t table_id; - int clear, status; - - if (n_tokens != 6 && - n_tokens != 7) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return; - } - - pipeline_name = tokens[1]; - - if (strcmp(tokens[2], "table") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "port"); - return; - } - - if (softnic_parser_read_uint32(&table_id, tokens[3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "table_id"); - return; - } - - if (strcmp(tokens[4], "stats") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "stats"); - return; - } - - if (strcmp(tokens[5], "read") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "read"); - return; - } - - clear = 0; - if (n_tokens == 7) { - if (strcmp(tokens[6], "clear") != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "clear"); - return; - } - - clear = 1; - } - - status = softnic_pipeline_table_stats_read(softnic, - pipeline_name, - table_id, - &stats, - clear); - if (status) { - snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]); - return; - } - - snprintf(out, out_size, MSG_PIPELINE_TABLE_STATS, - stats.stats.n_pkts_in, - stats.stats.n_pkts_lookup_miss, - stats.n_pkts_dropped_by_lkp_hit_ah, - stats.n_pkts_dropped_lkp_hit, - stats.n_pkts_dropped_by_lkp_miss_ah, - stats.n_pkts_dropped_lkp_miss); -} - -/** - * ::= - * - * match - * acl - * priority - * ipv4 | ipv6 - * - * | array - * | hash - * raw - * | ipv4_5tuple - * | ipv6_5tuple - * | ipv4_addr - * | ipv6_addr - * | qinq - * | lpm - * ipv4 | ipv6 - */ -struct pkt_key_qinq { - uint16_t ethertype_svlan; - uint16_t svlan; - uint16_t ethertype_cvlan; - uint16_t cvlan; -} __rte_packed; - -struct pkt_key_ipv4_5tuple { - uint8_t time_to_live; - uint8_t proto; - uint16_t hdr_checksum; - uint32_t sa; - uint32_t da; - uint16_t sp; - uint16_t dp; -} __rte_packed; - -struct pkt_key_ipv6_5tuple { - uint16_t payload_length; - uint8_t proto; - uint8_t hop_limit; - uint8_t sa[16]; - uint8_t da[16]; - uint16_t sp; - uint16_t dp; -} __rte_packed; - -struct pkt_key_ipv4_addr { - uint32_t addr; -} __rte_packed; - -struct pkt_key_ipv6_addr { - uint8_t addr[16]; -} __rte_packed; - -static uint32_t -parse_match(char **tokens, - uint32_t n_tokens, - char *out, - size_t out_size, - struct softnic_table_rule_match *m) -{ - memset(m, 0, sizeof(*m)); - - if (n_tokens < 2) - return 0; - - if (strcmp(tokens[0], "match") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "match"); - return 0; - } - - if (strcmp(tokens[1], "acl") == 0) { - if (n_tokens < 14) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return 0; - } - - m->match_type = TABLE_ACL; - - if (strcmp(tokens[2], "priority") != 0) { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, "priority"); - return 0; - } - - if (softnic_parser_read_uint32(&m->match.acl.priority, - tokens[3]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "priority"); - return 0; - } - - if (strcmp(tokens[4], "ipv4") == 0) { - struct in_addr saddr, daddr; - - m->match.acl.ip_version = 1; - - if (softnic_parse_ipv4_addr(tokens[5], &saddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sa"); - return 0; - } - m->match.acl.ipv4.sa = rte_be_to_cpu_32(saddr.s_addr); - - if (softnic_parse_ipv4_addr(tokens[7], &daddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "da"); - return 0; - } - m->match.acl.ipv4.da = rte_be_to_cpu_32(daddr.s_addr); - } else if (strcmp(tokens[4], "ipv6") == 0) { - struct in6_addr saddr, daddr; - - m->match.acl.ip_version = 0; - - if (softnic_parse_ipv6_addr(tokens[5], &saddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sa"); - return 0; - } - memcpy(m->match.acl.ipv6.sa, saddr.s6_addr, 16); - - if (softnic_parse_ipv6_addr(tokens[7], &daddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "da"); - return 0; - } - memcpy(m->match.acl.ipv6.da, daddr.s6_addr, 16); - } else { - snprintf(out, out_size, MSG_ARG_NOT_FOUND, - "ipv4 or ipv6"); - return 0; - } - - if (softnic_parser_read_uint32(&m->match.acl.sa_depth, - tokens[6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sa_depth"); - return 0; - } - - if (softnic_parser_read_uint32(&m->match.acl.da_depth, - tokens[8]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "da_depth"); - return 0; - } - - if (softnic_parser_read_uint16(&m->match.acl.sp0, tokens[9]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sp0"); - return 0; - } - - if (softnic_parser_read_uint16(&m->match.acl.sp1, tokens[10]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sp1"); - return 0; - } - - if (softnic_parser_read_uint16(&m->match.acl.dp0, tokens[11]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "dp0"); - return 0; - } - - if (softnic_parser_read_uint16(&m->match.acl.dp1, tokens[12]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "dp1"); - return 0; - } - - if (softnic_parser_read_uint8(&m->match.acl.proto, tokens[13]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "proto"); - return 0; - } - - m->match.acl.proto_mask = 0xff; - - return 14; - } /* acl */ - - if (strcmp(tokens[1], "array") == 0) { - if (n_tokens < 3) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return 0; - } - - m->match_type = TABLE_ARRAY; - - if (softnic_parser_read_uint32(&m->match.array.pos, tokens[2]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "pos"); - return 0; - } - - return 3; - } /* array */ - - if (strcmp(tokens[1], "hash") == 0) { - if (n_tokens < 3) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return 0; - } - - m->match_type = TABLE_HASH; - - if (strcmp(tokens[2], "raw") == 0) { - uint32_t key_size = TABLE_RULE_MATCH_SIZE_MAX; - - if (n_tokens < 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if (softnic_parse_hex_string(tokens[3], - m->match.hash.key, &key_size) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "key"); - return 0; - } - - return 4; - } /* hash raw */ - - if (strcmp(tokens[2], "ipv4_5tuple") == 0) { - struct pkt_key_ipv4_5tuple *ipv4 = - (struct pkt_key_ipv4_5tuple *)m->match.hash.key; - struct in_addr saddr, daddr; - uint16_t sp, dp; - uint8_t proto; - - if (n_tokens < 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if (softnic_parse_ipv4_addr(tokens[3], &saddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sa"); - return 0; - } - - if (softnic_parse_ipv4_addr(tokens[4], &daddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "da"); - return 0; - } - - if (softnic_parser_read_uint16(&sp, tokens[5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sp"); - return 0; - } - - if (softnic_parser_read_uint16(&dp, tokens[6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "dp"); - return 0; - } - - if (softnic_parser_read_uint8(&proto, tokens[7]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "proto"); - return 0; - } - - ipv4->sa = saddr.s_addr; - ipv4->da = daddr.s_addr; - ipv4->sp = rte_cpu_to_be_16(sp); - ipv4->dp = rte_cpu_to_be_16(dp); - ipv4->proto = proto; - - return 8; - } /* hash ipv4_5tuple */ - - if (strcmp(tokens[2], "ipv6_5tuple") == 0) { - struct pkt_key_ipv6_5tuple *ipv6 = - (struct pkt_key_ipv6_5tuple *)m->match.hash.key; - struct in6_addr saddr, daddr; - uint16_t sp, dp; - uint8_t proto; - - if (n_tokens < 8) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if (softnic_parse_ipv6_addr(tokens[3], &saddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sa"); - return 0; - } - - if (softnic_parse_ipv6_addr(tokens[4], &daddr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "da"); - return 0; - } - - if (softnic_parser_read_uint16(&sp, tokens[5]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "sp"); - return 0; - } - - if (softnic_parser_read_uint16(&dp, tokens[6]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "dp"); - return 0; - } - - if (softnic_parser_read_uint8(&proto, tokens[7]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "proto"); - return 0; - } - - memcpy(ipv6->sa, saddr.s6_addr, 16); - memcpy(ipv6->da, daddr.s6_addr, 16); - ipv6->sp = rte_cpu_to_be_16(sp); - ipv6->dp = rte_cpu_to_be_16(dp); - ipv6->proto = proto; - - return 8; - } /* hash ipv6_5tuple */ - - if (strcmp(tokens[2], "ipv4_addr") == 0) { - struct pkt_key_ipv4_addr *ipv4_addr = - (struct pkt_key_ipv4_addr *)m->match.hash.key; - struct in_addr addr; - - if (n_tokens < 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if (softnic_parse_ipv4_addr(tokens[3], &addr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "addr"); - return 0; - } - - ipv4_addr->addr = addr.s_addr; - - return 4; - } /* hash ipv4_addr */ - - if (strcmp(tokens[2], "ipv6_addr") == 0) { - struct pkt_key_ipv6_addr *ipv6_addr = - (struct pkt_key_ipv6_addr *)m->match.hash.key; - struct in6_addr addr; - - if (n_tokens < 4) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if (softnic_parse_ipv6_addr(tokens[3], &addr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "addr"); - return 0; - } - - memcpy(ipv6_addr->addr, addr.s6_addr, 16); - - return 4; - } /* hash ipv6_5tuple */ - - if (strcmp(tokens[2], "qinq") == 0) { - struct pkt_key_qinq *qinq = - (struct pkt_key_qinq *)m->match.hash.key; - uint16_t svlan, cvlan; - - if (n_tokens < 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, - tokens[0]); - return 0; - } - - if ((softnic_parser_read_uint16(&svlan, tokens[3]) != 0) || - svlan > 0xFFF) { - snprintf(out, out_size, MSG_ARG_INVALID, - "svlan"); - return 0; - } - - if ((softnic_parser_read_uint16(&cvlan, tokens[4]) != 0) || - cvlan > 0xFFF) { - snprintf(out, out_size, MSG_ARG_INVALID, - "cvlan"); - return 0; - } - - qinq->svlan = rte_cpu_to_be_16(svlan); - qinq->cvlan = rte_cpu_to_be_16(cvlan); - - return 5; - } /* hash qinq */ - - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return 0; - } /* hash */ - - if (strcmp(tokens[1], "lpm") == 0) { - if (n_tokens < 5) { - snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]); - return 0; - } - - m->match_type = TABLE_LPM; - - if (strcmp(tokens[2], "ipv4") == 0) { - struct in_addr addr; - - m->match.lpm.ip_version = 1; - - if (softnic_parse_ipv4_addr(tokens[3], &addr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "addr"); - return 0; - } - - m->match.lpm.ipv4 = rte_be_to_cpu_32(addr.s_addr); - } else if (strcmp(tokens[2], "ipv6") == 0) { - struct in6_addr addr; - - m->match.lpm.ip_version = 0; - - if (softnic_parse_ipv6_addr(tokens[3], &addr) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, - "addr"); - return 0; - } - - memcpy(m->match.lpm.ipv6, addr.s6_addr, 16); - } else { - snprintf(out, out_size, MSG_ARG_MISMATCH, - "ipv4 or ipv6"); - return 0; - } - - if (softnic_parser_read_uint8(&m->match.lpm.depth, tokens[4]) != 0) { - snprintf(out, out_size, MSG_ARG_INVALID, "depth"); - return 0; - } - - return 5; - } /* lpm */ - - snprintf(out, out_size, MSG_ARG_MISMATCH, - "acl or array or hash or lpm"); - return 0; -} - -/** - * table_action ::= - * - * action - * fwd - * drop - * | port - * | meta - * | table - * [balance ... ] - * [meter - * tc0 meter policer g y r - * [tc1 meter policer g y r - * tc2 meter policer g y r - * tc3 meter policer g y r ]] - * [tm subport pipe ] - * [encap - * ether - * | vlan - * | qinq - * | qinq_pppoe - * | mpls unicast | multicast - * - * label0