xref: /dpdk/app/test-pmd/cmdline_tm.c (revision 25a2a0dc3de31ca0a6fbc9371cf3dd85dfd74b07)

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright(c) 2017 Intel Corporation
 */

#include <ctype.h>
#include <stdlib.h>

#include <cmdline_parse.h>
#include <cmdline_parse_num.h>
#include <cmdline_parse_string.h>

#include <rte_ethdev.h>
#include <rte_flow.h>
#include <rte_string_fns.h>
#include <rte_tm.h>

#include "testpmd.h"
#include "cmdline_tm.h"

#define PARSE_DELIMITER				" \f\n\r\t\v"
#define MAX_NUM_SHARED_SHAPERS		256

/** Display TM Error Message */
static void
print_err_msg(struct rte_tm_error *error)
{
	static const char *const errstrlist[] = {
		[RTE_TM_ERROR_TYPE_NONE] = "no error",
		[RTE_TM_ERROR_TYPE_UNSPECIFIED] = "cause unspecified",
		[RTE_TM_ERROR_TYPE_CAPABILITIES]
			= "capability parameter null",
		[RTE_TM_ERROR_TYPE_LEVEL_ID] = "level id",
		[RTE_TM_ERROR_TYPE_WRED_PROFILE]
			= "wred profile null",
		[RTE_TM_ERROR_TYPE_WRED_PROFILE_GREEN] = "wred profile(green)",
		[RTE_TM_ERROR_TYPE_WRED_PROFILE_YELLOW]
			= "wred profile(yellow)",
		[RTE_TM_ERROR_TYPE_WRED_PROFILE_RED] = "wred profile(red)",
		[RTE_TM_ERROR_TYPE_WRED_PROFILE_ID] = "wred profile id",
		[RTE_TM_ERROR_TYPE_SHARED_WRED_CONTEXT_ID]
			= "shared wred context id",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE] = "shaper profile null",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_COMMITTED_RATE]
			= "committed rate field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_COMMITTED_SIZE]
			= "committed size field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_PEAK_RATE]
			= "peak rate field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_PEAK_SIZE]
			= "peak size field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_PKT_ADJUST_LEN]
			= "packet adjust length field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_PACKET_MODE]
			= "packet mode field (shaper profile)",
		[RTE_TM_ERROR_TYPE_SHAPER_PROFILE_ID] = "shaper profile id",
		[RTE_TM_ERROR_TYPE_SHARED_SHAPER_ID] = "shared shaper id",
		[RTE_TM_ERROR_TYPE_NODE_PARENT_NODE_ID] = "parent node id",
		[RTE_TM_ERROR_TYPE_NODE_PRIORITY] = "node priority",
		[RTE_TM_ERROR_TYPE_NODE_WEIGHT] = "node weight",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS] = "node parameter null",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_SHAPER_PROFILE_ID]
			= "shaper profile id field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_SHARED_SHAPER_ID]
			= "shared shaper id field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_N_SHARED_SHAPERS]
			= "num shared shapers field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_WFQ_WEIGHT_MODE]
			= "wfq weight mode field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_N_SP_PRIORITIES]
			= "num strict priorities field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_CMAN]
			= "congestion management mode field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_WRED_PROFILE_ID] =
			"wred profile id field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_SHARED_WRED_CONTEXT_ID]
			= "shared wred context id field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_N_SHARED_WRED_CONTEXTS]
			= "num shared wred contexts field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_PARAMS_STATS]
			= "stats field (node params)",
		[RTE_TM_ERROR_TYPE_NODE_ID] = "node id",
	};

	const char *errstr;
	char buf[64];

	if ((unsigned int)error->type >= RTE_DIM(errstrlist) ||
		!errstrlist[error->type])
		errstr = "unknown type";
	else
		errstr = errstrlist[error->type];

	if (error->cause)
		snprintf(buf, sizeof(buf), "cause: %p, ", error->cause);

	fprintf(stderr, "%s: %s%s (error %d)\n",
		errstr, error->cause ? buf : "",
		error->message ? error->message : "(no stated reason)",
		error->type);
}

static int
read_uint64(uint64_t *value, const char *p)
{
	char *next;
	uint64_t val;

	p = rte_str_skip_leading_spaces(p);
	if (!isdigit(*p))
		return -EINVAL;

	val = strtoul(p, &next, 10);
	if (p == next)
		return -EINVAL;

	p = next;
	switch (*p) {
	case 'T':
		val *= 1024ULL;
		/* fall through */
	case 'G':
		val *= 1024ULL;
		/* fall through */
	case 'M':
		val *= 1024ULL;
		/* fall through */
	case 'k':
	case 'K':
		val *= 1024ULL;
		p++;
		break;
	}

	p = rte_str_skip_leading_spaces(p);
	if (*p != '\0')
		return -EINVAL;

	*value = val;
	return 0;
}

static int
read_uint32(uint32_t *value, const char *p)
{
	uint64_t val = 0;
	int ret = read_uint64(&val, p);

	if (ret < 0)
		return ret;

	if (val > UINT32_MAX)
		return -ERANGE;

	*value = val;
	return 0;
}

static int
parse_multi_ss_id_str(char *s_str, uint32_t *n_ssp, uint32_t shaper_id[])
{
	uint32_t n_shared_shapers = 0, i = 0;
	char *token;

	/* First token: num of shared shapers */
	token = strtok_r(s_str, PARSE_DELIMITER, &s_str);
	if (token ==  NULL)
		return -1;

	if (read_uint32(&n_shared_shapers, token))
		return -1;

	/* Check: num of shared shaper */
	if (n_shared_shapers >= MAX_NUM_SHARED_SHAPERS) {
		fprintf(stderr,
			" Number of shared shapers exceed the max (error)\n");
		return -1;
	}

	/* Parse shared shaper ids */
	while (1) {
		token = strtok_r(s_str, PARSE_DELIMITER, &s_str);
		if ((token !=  NULL && n_shared_shapers == 0) ||
			(token == NULL && i < n_shared_shapers))
			return -1;

		if (token == NULL)
			break;

		if (read_uint32(&shaper_id[i], token))
			return -1;
		i++;
	}
	*n_ssp = n_shared_shapers;

	return 0;
}
/* *** Port TM Capability *** */
struct cmd_show_port_tm_cap_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t cap;
	uint16_t port_id;
};

static cmdline_parse_token_string_t cmd_show_port_tm_cap_show =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_cap_result,
		show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_cap_port =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_cap_result,
		port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_cap_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_cap_result,
		tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_cap_cap =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_cap_result,
		cap, "cap");
static cmdline_parse_token_num_t cmd_show_port_tm_cap_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_cap_result,
		 port_id, RTE_UINT16);

static void cmd_show_port_tm_cap_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_show_port_tm_cap_result *res = parsed_result;
	struct rte_tm_capabilities cap;
	struct rte_tm_error error;
	portid_t port_id = res->port_id;
	uint32_t i;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&cap, 0, sizeof(struct rte_tm_capabilities));
	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_capabilities_get(port_id, &cap, &error);
	if (ret) {
		print_err_msg(&error);
		return;
	}

	printf("\n****   Port TM Capabilities ****\n\n");
	printf("cap.n_nodes_max %" PRIu32 "\n", cap.n_nodes_max);
	printf("cap.n_levels_max %" PRIu32 "\n", cap.n_levels_max);
	printf("cap.non_leaf_nodes_identical %" PRId32 "\n",
		cap.non_leaf_nodes_identical);
	printf("cap.leaf_nodes_identical %" PRId32 "\n",
		cap.leaf_nodes_identical);
	printf("cap.shaper_n_max %u\n", cap.shaper_n_max);
	printf("cap.shaper_private_n_max %" PRIu32 "\n",
		cap.shaper_private_n_max);
	printf("cap.shaper_private_dual_rate_n_max %" PRId32 "\n",
		cap.shaper_private_dual_rate_n_max);
	printf("cap.shaper_private_rate_min %" PRIu64 "\n",
		cap.shaper_private_rate_min);
	printf("cap.shaper_private_rate_max %" PRIu64 "\n",
		cap.shaper_private_rate_max);
	printf("cap.shaper_private_packet_mode_supported %" PRId32 "\n",
		cap.shaper_private_packet_mode_supported);
	printf("cap.shaper_private_byte_mode_supported %" PRId32 "\n",
		cap.shaper_private_byte_mode_supported);
	printf("cap.shaper_shared_n_max %" PRIu32 "\n",
		cap.shaper_shared_n_max);
	printf("cap.shaper_shared_n_nodes_per_shaper_max %" PRIu32 "\n",
		cap.shaper_shared_n_nodes_per_shaper_max);
	printf("cap.shaper_shared_n_shapers_per_node_max %" PRIu32 "\n",
		cap.shaper_shared_n_shapers_per_node_max);
	printf("cap.shaper_shared_dual_rate_n_max %" PRIu32 "\n",
		cap.shaper_shared_dual_rate_n_max);
	printf("cap.shaper_shared_rate_min %" PRIu64 "\n",
		cap.shaper_shared_rate_min);
	printf("cap.shaper_shared_rate_max %" PRIu64 "\n",
		cap.shaper_shared_rate_max);
	printf("cap.shaper_shared_packet_mode_supported %" PRId32 "\n",
		cap.shaper_shared_packet_mode_supported);
	printf("cap.shaper_shared_byte_mode_supported %" PRId32 "\n",
		cap.shaper_shared_byte_mode_supported);
	printf("cap.shaper_pkt_length_adjust_min %" PRId32 "\n",
		cap.shaper_pkt_length_adjust_min);
	printf("cap.shaper_pkt_length_adjust_max %" PRId32 "\n",
		cap.shaper_pkt_length_adjust_max);
	printf("cap.sched_n_children_max %" PRIu32 "\n",
		cap.sched_n_children_max);
	printf("cap.sched_sp_n_priorities_max %" PRIu32 "\n",
		cap.sched_sp_n_priorities_max);
	printf("cap.sched_wfq_n_children_per_group_max %" PRIu32 "\n",
		cap.sched_wfq_n_children_per_group_max);
	printf("cap.sched_wfq_n_groups_max %" PRIu32 "\n",
		cap.sched_wfq_n_groups_max);
	printf("cap.sched_wfq_weight_max %" PRIu32 "\n",
		cap.sched_wfq_weight_max);
	printf("cap.sched_wfq_packet_mode_supported %" PRId32 "\n",
		cap.sched_wfq_packet_mode_supported);
	printf("cap.sched_wfq_byte_mode_supported %" PRId32 "\n",
		cap.sched_wfq_byte_mode_supported);
	printf("cap.cman_head_drop_supported %" PRId32 "\n",
		cap.cman_head_drop_supported);
	printf("cap.cman_wred_context_n_max %" PRIu32 "\n",
		cap.cman_wred_context_n_max);
	printf("cap.cman_wred_context_private_n_max %" PRIu32 "\n",
		cap.cman_wred_context_private_n_max);
	printf("cap.cman_wred_context_shared_n_max %" PRIu32 "\n",
		cap.cman_wred_context_shared_n_max);
	printf("cap.cman_wred_context_shared_n_nodes_per_context_max %" PRIu32
		"\n", cap.cman_wred_context_shared_n_nodes_per_context_max);
	printf("cap.cman_wred_context_shared_n_contexts_per_node_max %" PRIu32
		"\n", cap.cman_wred_context_shared_n_contexts_per_node_max);

	for (i = 0; i < RTE_COLORS; i++) {
		printf("cap.mark_vlan_dei_supported %" PRId32 "\n",
			cap.mark_vlan_dei_supported[i]);
		printf("cap.mark_ip_ecn_tcp_supported %" PRId32 "\n",
			cap.mark_ip_ecn_tcp_supported[i]);
		printf("cap.mark_ip_ecn_sctp_supported %" PRId32 "\n",
			cap.mark_ip_ecn_sctp_supported[i]);
		printf("cap.mark_ip_dscp_supported %" PRId32 "\n",
			cap.mark_ip_dscp_supported[i]);
	}

	printf("cap.dynamic_update_mask %" PRIx64 "\n",
		cap.dynamic_update_mask);
	printf("cap.stats_mask %" PRIx64 "\n", cap.stats_mask);
}

cmdline_parse_inst_t cmd_show_port_tm_cap = {
	.f = cmd_show_port_tm_cap_parsed,
	.data = NULL,
	.help_str = "Show Port TM Capabilities",
	.tokens = {
		(void *)&cmd_show_port_tm_cap_show,
		(void *)&cmd_show_port_tm_cap_port,
		(void *)&cmd_show_port_tm_cap_tm,
		(void *)&cmd_show_port_tm_cap_cap,
		(void *)&cmd_show_port_tm_cap_port_id,
		NULL,
	},
};

/* *** Port TM Hierarchical Level Capability *** */
struct cmd_show_port_tm_level_cap_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t level;
	cmdline_fixed_string_t cap;
	uint16_t port_id;
	uint32_t level_id;
};

static cmdline_parse_token_string_t cmd_show_port_tm_level_cap_show =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_level_cap_port =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_level_cap_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_level_cap_level =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		level, "level");
static cmdline_parse_token_string_t cmd_show_port_tm_level_cap_cap =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		cap, "cap");
static cmdline_parse_token_num_t cmd_show_port_tm_level_cap_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_show_port_tm_level_cap_level_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_level_cap_result,
		 level_id, RTE_UINT32);


static void cmd_show_port_tm_level_cap_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_show_port_tm_level_cap_result *res = parsed_result;
	struct rte_tm_level_capabilities lcap;
	struct rte_tm_error error;
	portid_t port_id = res->port_id;
	uint32_t level_id = res->level_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&lcap, 0, sizeof(struct rte_tm_level_capabilities));
	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_level_capabilities_get(port_id, level_id, &lcap, &error);
	if (ret) {
		print_err_msg(&error);
		return;
	}
	printf("\n**   Port TM Hierarchy level %" PRIu32 " Capability **\n\n",
		level_id);

	printf("cap.n_nodes_max %" PRIu32 "\n", lcap.n_nodes_max);
	printf("cap.n_nodes_nonleaf_max %" PRIu32 "\n",
		lcap.n_nodes_nonleaf_max);
	printf("cap.n_nodes_leaf_max %" PRIu32 "\n", lcap.n_nodes_leaf_max);
	printf("cap.non_leaf_nodes_identical %" PRId32 "\n",
		lcap.non_leaf_nodes_identical);
	printf("cap.leaf_nodes_identical %" PRId32 "\n",
		lcap.leaf_nodes_identical);
	if (level_id <= 3) {
		printf("cap.nonleaf.shaper_private_supported %" PRId32 "\n",
			lcap.nonleaf.shaper_private_supported);
		printf("cap.nonleaf.shaper_private_dual_rate_supported %" PRId32
			"\n", lcap.nonleaf.shaper_private_dual_rate_supported);
		printf("cap.nonleaf.shaper_private_rate_min %" PRIu64 "\n",
			lcap.nonleaf.shaper_private_rate_min);
		printf("cap.nonleaf.shaper_private_rate_max %" PRIu64 "\n",
			lcap.nonleaf.shaper_private_rate_max);
		printf("cap.nonleaf.shaper_private_packet_mode_supported %"
		       PRId32 "\n",
			lcap.nonleaf.shaper_private_packet_mode_supported);
		printf("cap.nonleaf.shaper_private_byte_mode_supported %" PRId32
		       "\n", lcap.nonleaf.shaper_private_byte_mode_supported);
		printf("cap.nonleaf.shaper_shared_n_max %" PRIu32 "\n",
			lcap.nonleaf.shaper_shared_n_max);
		printf("cap.nonleaf.shaper_shared_packet_mode_supported %"
		       PRId32 "\n",
		       lcap.nonleaf.shaper_shared_packet_mode_supported);
		printf("cap.nonleaf.shaper_shared_byte_mode_supported %"
		       PRId32 "\n",
		       lcap.nonleaf.shaper_shared_byte_mode_supported);
		printf("cap.nonleaf.sched_n_children_max %" PRIu32 "\n",
			lcap.nonleaf.sched_n_children_max);
		printf("cap.nonleaf.sched_sp_n_priorities_max %" PRIu32 "\n",
			lcap.nonleaf.sched_sp_n_priorities_max);
		printf("cap.nonleaf.sched_wfq_n_children_per_group_max %" PRIu32
			"\n", lcap.nonleaf.sched_wfq_n_children_per_group_max);
		printf("cap.nonleaf.sched_wfq_n_groups_max %" PRIu32 "\n",
			lcap.nonleaf.sched_wfq_n_groups_max);
		printf("cap.nonleaf.sched_wfq_weight_max %" PRIu32 "\n",
			lcap.nonleaf.sched_wfq_weight_max);
		printf("cap.nonleaf.sched_wfq_packet_mode_supported %" PRId32 "\n",
			lcap.nonleaf.sched_wfq_packet_mode_supported);
		printf("cap.nonleaf.sched_wfq_byte_mode_supported %" PRId32
		       "\n", lcap.nonleaf.sched_wfq_byte_mode_supported);
		printf("cap.nonleaf.stats_mask %" PRIx64 "\n",
			lcap.nonleaf.stats_mask);
	} else {
		printf("cap.leaf.shaper_private_supported %" PRId32 "\n",
			lcap.leaf.shaper_private_supported);
		printf("cap.leaf.shaper_private_dual_rate_supported %" PRId32
			"\n", lcap.leaf.shaper_private_dual_rate_supported);
		printf("cap.leaf.shaper_private_rate_min %" PRIu64 "\n",
			lcap.leaf.shaper_private_rate_min);
		printf("cap.leaf.shaper_private_rate_max %" PRIu64 "\n",
			lcap.leaf.shaper_private_rate_max);
		printf("cap.leaf.shaper_private_packet_mode_supported %" PRId32
		       "\n", lcap.leaf.shaper_private_packet_mode_supported);
		printf("cap.leaf.shaper_private_byte_mode_supported %" PRId32 "\n",
			lcap.leaf.shaper_private_byte_mode_supported);
		printf("cap.leaf.shaper_shared_n_max %" PRIu32 "\n",
			lcap.leaf.shaper_shared_n_max);
		printf("cap.leaf.shaper_shared_packet_mode_supported %" PRId32 "\n",
		       lcap.leaf.shaper_shared_packet_mode_supported);
		printf("cap.leaf.shaper_shared_byte_mode_supported %" PRId32 "\n",
		       lcap.leaf.shaper_shared_byte_mode_supported);
		printf("cap.leaf.cman_head_drop_supported %" PRId32 "\n",
			lcap.leaf.cman_head_drop_supported);
		printf("cap.leaf.cman_wred_context_private_supported %"	PRId32
			"\n", lcap.leaf.cman_wred_context_private_supported);
		printf("cap.leaf.cman_wred_context_shared_n_max %" PRIu32 "\n",
			lcap.leaf.cman_wred_context_shared_n_max);
		printf("cap.leaf.stats_mask %" PRIx64 "\n",
			lcap.leaf.stats_mask);
	}
}

cmdline_parse_inst_t cmd_show_port_tm_level_cap = {
	.f = cmd_show_port_tm_level_cap_parsed,
	.data = NULL,
	.help_str = "Show port TM hierarchical level capabilities",
	.tokens = {
		(void *)&cmd_show_port_tm_level_cap_show,
		(void *)&cmd_show_port_tm_level_cap_port,
		(void *)&cmd_show_port_tm_level_cap_tm,
		(void *)&cmd_show_port_tm_level_cap_level,
		(void *)&cmd_show_port_tm_level_cap_cap,
		(void *)&cmd_show_port_tm_level_cap_port_id,
		(void *)&cmd_show_port_tm_level_cap_level_id,
		NULL,
	},
};

/* *** Port TM Hierarchy Node Capability *** */
struct cmd_show_port_tm_node_cap_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t cap;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_show_port_tm_node_cap_show =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_node_cap_port =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_node_cap_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_node_cap_node =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		node, "node");
static cmdline_parse_token_string_t cmd_show_port_tm_node_cap_cap =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		cap, "cap");
static cmdline_parse_token_num_t cmd_show_port_tm_node_cap_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_show_port_tm_node_cap_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_node_cap_result,
		 node_id, RTE_UINT32);

static void cmd_show_port_tm_node_cap_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_show_port_tm_node_cap_result *res = parsed_result;
	struct rte_tm_node_capabilities ncap;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	portid_t port_id = res->port_id;
	int ret, is_leaf = 0;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Node id must be valid */
	ret = rte_tm_node_type_get(port_id, node_id, &is_leaf, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}

	memset(&ncap, 0, sizeof(struct rte_tm_node_capabilities));
	ret = rte_tm_node_capabilities_get(port_id, node_id, &ncap, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
	printf("\n**   Port TM Hierarchy node %" PRIu32 " Capability **\n\n",
		node_id);
	printf("cap.shaper_private_supported %" PRId32 "\n",
		ncap.shaper_private_supported);
	printf("cap.shaper_private_dual_rate_supported %" PRId32 "\n",
		ncap.shaper_private_dual_rate_supported);
	printf("cap.shaper_private_rate_min %" PRIu64 "\n",
		ncap.shaper_private_rate_min);
	printf("cap.shaper_private_rate_max %" PRIu64 "\n",
		ncap.shaper_private_rate_max);
	printf("cap.shaper_private_packet_mode_supported %" PRId32 "\n",
		ncap.shaper_private_packet_mode_supported);
	printf("cap.shaper_private_byte_mode_supported %" PRId32 "\n",
		ncap.shaper_private_byte_mode_supported);
	printf("cap.shaper_shared_n_max %" PRIu32 "\n",
		ncap.shaper_shared_n_max);
	printf("cap.shaper_shared_packet_mode_supported %" PRId32 "\n",
		ncap.shaper_shared_packet_mode_supported);
	printf("cap.shaper_shared_byte_mode_supported %" PRId32 "\n",
		ncap.shaper_shared_byte_mode_supported);
	if (!is_leaf) {
		printf("cap.nonleaf.sched_n_children_max %" PRIu32 "\n",
			ncap.nonleaf.sched_n_children_max);
		printf("cap.nonleaf.sched_sp_n_priorities_max %" PRIu32 "\n",
			ncap.nonleaf.sched_sp_n_priorities_max);
		printf("cap.nonleaf.sched_wfq_n_children_per_group_max %" PRIu32
			"\n", ncap.nonleaf.sched_wfq_n_children_per_group_max);
		printf("cap.nonleaf.sched_wfq_n_groups_max %" PRIu32 "\n",
			ncap.nonleaf.sched_wfq_n_groups_max);
		printf("cap.nonleaf.sched_wfq_weight_max %" PRIu32 "\n",
			ncap.nonleaf.sched_wfq_weight_max);
		printf("cap.nonleaf.sched_wfq_packet_mode_supported %" PRId32 "\n",
			ncap.nonleaf.sched_wfq_packet_mode_supported);
		printf("cap.nonleaf.sched_wfq_byte_mode_supported %" PRId32 "\n",
			ncap.nonleaf.sched_wfq_byte_mode_supported);
	} else {
		printf("cap.leaf.cman_head_drop_supported %" PRId32 "\n",
			ncap.leaf.cman_head_drop_supported);
		printf("cap.leaf.cman_wred_context_private_supported %" PRId32
			"\n", ncap.leaf.cman_wred_context_private_supported);
		printf("cap.leaf.cman_wred_context_shared_n_max %" PRIu32 "\n",
			ncap.leaf.cman_wred_context_shared_n_max);
	}
	printf("cap.stats_mask %" PRIx64 "\n", ncap.stats_mask);
}

cmdline_parse_inst_t cmd_show_port_tm_node_cap = {
	.f = cmd_show_port_tm_node_cap_parsed,
	.data = NULL,
	.help_str = "Show Port TM Hierarchy node capabilities",
	.tokens = {
		(void *)&cmd_show_port_tm_node_cap_show,
		(void *)&cmd_show_port_tm_node_cap_port,
		(void *)&cmd_show_port_tm_node_cap_tm,
		(void *)&cmd_show_port_tm_node_cap_node,
		(void *)&cmd_show_port_tm_node_cap_cap,
		(void *)&cmd_show_port_tm_node_cap_port_id,
		(void *)&cmd_show_port_tm_node_cap_node_id,
		NULL,
	},
};

/* *** Show Port TM Node Statistics *** */
struct cmd_show_port_tm_node_stats_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t stats;
	uint16_t port_id;
	uint32_t node_id;
	uint32_t clear;
};

static cmdline_parse_token_string_t cmd_show_port_tm_node_stats_show =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_node_stats_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_node_stats_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_node_stats_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, node, "node");
static cmdline_parse_token_string_t cmd_show_port_tm_node_stats_stats =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, stats, "stats");
static cmdline_parse_token_num_t cmd_show_port_tm_node_stats_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_node_stats_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_show_port_tm_node_stats_node_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result,
			node_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_show_port_tm_node_stats_clear =
	TOKEN_NUM_INITIALIZER(
		struct cmd_show_port_tm_node_stats_result, clear, RTE_UINT32);

static void cmd_show_port_tm_node_stats_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_show_port_tm_node_stats_result *res = parsed_result;
	struct rte_tm_node_stats stats;
	struct rte_tm_error error;
	uint64_t stats_mask = 0;
	uint32_t node_id = res->node_id;
	uint32_t clear = res->clear;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Port status */
	if (!port_is_started(port_id)) {
		fprintf(stderr, " Port %u not started (error)\n", port_id);
		return;
	}

	memset(&stats, 0, sizeof(struct rte_tm_node_stats));
	ret = rte_tm_node_stats_read(port_id, node_id, &stats,
			&stats_mask, clear, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}

	/* Display stats */
	if (stats_mask & RTE_TM_STATS_N_PKTS)
		printf("\tPkts scheduled from node: %" PRIu64 "\n",
			stats.n_pkts);
	if (stats_mask & RTE_TM_STATS_N_BYTES)
		printf("\tBytes scheduled from node: %" PRIu64 "\n",
			stats.n_bytes);
	if (stats_mask & RTE_TM_STATS_N_PKTS_GREEN_DROPPED)
		printf("\tPkts dropped (green): %" PRIu64 "\n",
			stats.leaf.n_pkts_dropped[RTE_COLOR_GREEN]);
	if (stats_mask & RTE_TM_STATS_N_PKTS_YELLOW_DROPPED)
		printf("\tPkts dropped (yellow): %" PRIu64 "\n",
			stats.leaf.n_pkts_dropped[RTE_COLOR_YELLOW]);
	if (stats_mask & RTE_TM_STATS_N_PKTS_RED_DROPPED)
		printf("\tPkts dropped (red): %" PRIu64 "\n",
			stats.leaf.n_pkts_dropped[RTE_COLOR_RED]);
	if (stats_mask & RTE_TM_STATS_N_BYTES_GREEN_DROPPED)
		printf("\tBytes dropped (green): %" PRIu64 "\n",
			stats.leaf.n_bytes_dropped[RTE_COLOR_GREEN]);
	if (stats_mask & RTE_TM_STATS_N_BYTES_YELLOW_DROPPED)
		printf("\tBytes dropped (yellow): %" PRIu64 "\n",
			stats.leaf.n_bytes_dropped[RTE_COLOR_YELLOW]);
	if (stats_mask & RTE_TM_STATS_N_BYTES_RED_DROPPED)
		printf("\tBytes dropped (red): %" PRIu64 "\n",
			stats.leaf.n_bytes_dropped[RTE_COLOR_RED]);
	if (stats_mask & RTE_TM_STATS_N_PKTS_QUEUED)
		printf("\tPkts queued: %" PRIu64 "\n",
			stats.leaf.n_pkts_queued);
	if (stats_mask & RTE_TM_STATS_N_BYTES_QUEUED)
		printf("\tBytes queued: %" PRIu64 "\n",
			stats.leaf.n_bytes_queued);
}

cmdline_parse_inst_t cmd_show_port_tm_node_stats = {
	.f = cmd_show_port_tm_node_stats_parsed,
	.data = NULL,
	.help_str = "Show port tm node stats",
	.tokens = {
		(void *)&cmd_show_port_tm_node_stats_show,
		(void *)&cmd_show_port_tm_node_stats_port,
		(void *)&cmd_show_port_tm_node_stats_tm,
		(void *)&cmd_show_port_tm_node_stats_node,
		(void *)&cmd_show_port_tm_node_stats_stats,
		(void *)&cmd_show_port_tm_node_stats_port_id,
		(void *)&cmd_show_port_tm_node_stats_node_id,
		(void *)&cmd_show_port_tm_node_stats_clear,
		NULL,
	},
};

/* *** Show Port TM Node Type *** */
struct cmd_show_port_tm_node_type_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t type;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_show_port_tm_node_type_show =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_type_result, show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_node_type_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_type_result, port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_node_type_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_type_result, tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_node_type_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_type_result, node, "node");
static cmdline_parse_token_string_t cmd_show_port_tm_node_type_type =
	TOKEN_STRING_INITIALIZER(
		struct cmd_show_port_tm_node_type_result, type, "type");
static cmdline_parse_token_num_t cmd_show_port_tm_node_type_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_show_port_tm_node_type_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_show_port_tm_node_type_node_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_show_port_tm_node_type_result,
			node_id, RTE_UINT32);

static void cmd_show_port_tm_node_type_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_show_port_tm_node_type_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	portid_t port_id = res->port_id;
	int ret, is_leaf = 0;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_node_type_get(port_id, node_id, &is_leaf, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}

	if (is_leaf == 1)
		printf("leaf node\n");
	else
		printf("nonleaf node\n");

}

cmdline_parse_inst_t cmd_show_port_tm_node_type = {
	.f = cmd_show_port_tm_node_type_parsed,
	.data = NULL,
	.help_str = "Show port tm node type",
	.tokens = {
		(void *)&cmd_show_port_tm_node_type_show,
		(void *)&cmd_show_port_tm_node_type_port,
		(void *)&cmd_show_port_tm_node_type_tm,
		(void *)&cmd_show_port_tm_node_type_node,
		(void *)&cmd_show_port_tm_node_type_type,
		(void *)&cmd_show_port_tm_node_type_port_id,
		(void *)&cmd_show_port_tm_node_type_node_id,
		NULL,
	},
};

/* *** Add Port TM Private Shaper Profile *** */
struct cmd_add_port_tm_node_shaper_profile_result {
	cmdline_fixed_string_t add;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t shaper;
	cmdline_fixed_string_t profile;
	uint16_t port_id;
	uint32_t shaper_id;
	uint64_t cmit_tb_rate;
	uint64_t cmit_tb_size;
	uint64_t peak_tb_rate;
	uint64_t peak_tb_size;
	uint32_t pktlen_adjust;
	int pkt_mode;
};

static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_add =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result, add, "add");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			node, "node");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_shaper =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			shaper, "shaper");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shaper_profile_profile =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			profile, "profile");
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_shaper_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			shaper_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_cmit_tb_rate =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			cmit_tb_rate, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_cmit_tb_size =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			cmit_tb_size, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_peak_tb_rate =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			peak_tb_rate, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_peak_tb_size =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			peak_tb_size, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_pktlen_adjust =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			pktlen_adjust, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shaper_profile_packet_mode =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shaper_profile_result,
			pkt_mode, RTE_UINT32);

static int
get_printable_rate(uint64_t rate, char *buffer, size_t size)
{
	if (rate >= 1000 * 1000 * 1000)
		return snprintf(buffer, size, "%.1fG", rate / (1000 * 1000 * 1000.0));
	else if (rate >= 1000 * 1000)
		return snprintf(buffer, size, "%.1fM", rate / (1000 * 1000.0));
	else if (rate >= 1000)
		return snprintf(buffer, size, "%.1fK", rate / 1000.0);
	else
		return snprintf(buffer, size, "%"PRIu64, rate);
}

static void cmd_add_port_tm_node_shaper_profile_parsed(void *parsed_result,
	struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_node_shaper_profile_result *res = parsed_result;
	struct rte_tm_shaper_params sp;
	struct rte_tm_error error;
	uint32_t shaper_id = res->shaper_id;
	uint32_t pkt_len_adjust = res->pktlen_adjust;
	portid_t port_id = res->port_id;
	char rate_str[20];
	int ret;

	cmdline_printf(cl, "adding node shaper on port %u, with id %u\n", res->port_id, shaper_id);
	get_printable_rate(res->cmit_tb_rate, rate_str, sizeof(rate_str));
	cmdline_printf(cl, "# committed rate: %s, t.b. size: %"PRIu64"\n",
			rate_str, res->cmit_tb_size);

	get_printable_rate(res->peak_tb_rate, rate_str, sizeof(rate_str));
	cmdline_printf(cl, "# peak rate: %s, t.b. size: %"PRIu64"\n",
			rate_str, res->peak_tb_size);
	cmdline_printf(cl, "# pkt length adjust: %u\n", res->pktlen_adjust);
	cmdline_printf(cl, "# packet mode: %s\n", res->pkt_mode ? "true" : "false (bytes mode)");

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	/* Private shaper profile params */
	memset(&sp, 0, sizeof(struct rte_tm_shaper_params));
	memset(&error, 0, sizeof(struct rte_tm_error));
	sp.committed.rate = res->cmit_tb_rate;
	sp.committed.size = res->cmit_tb_size;
	sp.peak.rate = res->peak_tb_rate;
	sp.peak.size = res->peak_tb_size;
	sp.pkt_length_adjust = pkt_len_adjust;
	sp.packet_mode = res->pkt_mode;

	ret = rte_tm_shaper_profile_add(port_id, shaper_id, &sp, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_node_shaper_profile = {
	.f = cmd_add_port_tm_node_shaper_profile_parsed,
	.data = NULL,
	.help_str = "Add port tm node private shaper profile",
	.tokens = {
		(void *)&cmd_add_port_tm_node_shaper_profile_add,
		(void *)&cmd_add_port_tm_node_shaper_profile_port,
		(void *)&cmd_add_port_tm_node_shaper_profile_tm,
		(void *)&cmd_add_port_tm_node_shaper_profile_node,
		(void *)&cmd_add_port_tm_node_shaper_profile_shaper,
		(void *)&cmd_add_port_tm_node_shaper_profile_profile,
		(void *)&cmd_add_port_tm_node_shaper_profile_port_id,
		(void *)&cmd_add_port_tm_node_shaper_profile_shaper_id,
		(void *)&cmd_add_port_tm_node_shaper_profile_cmit_tb_rate,
		(void *)&cmd_add_port_tm_node_shaper_profile_cmit_tb_size,
		(void *)&cmd_add_port_tm_node_shaper_profile_peak_tb_rate,
		(void *)&cmd_add_port_tm_node_shaper_profile_peak_tb_size,
		(void *)&cmd_add_port_tm_node_shaper_profile_pktlen_adjust,
		(void *)&cmd_add_port_tm_node_shaper_profile_packet_mode,
		NULL,
	},
};

/* *** Delete Port TM Private Shaper Profile *** */
struct cmd_del_port_tm_node_shaper_profile_result {
	cmdline_fixed_string_t del;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t shaper;
	cmdline_fixed_string_t profile;
	uint16_t port_id;
	uint32_t shaper_id;
};

static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_del =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result, del, "del");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			port, "port");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result, tm, "tm");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			node, "node");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_shaper =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			shaper, "shaper");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shaper_profile_profile =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			profile, "profile");
static cmdline_parse_token_num_t cmd_del_port_tm_node_shaper_profile_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_del_port_tm_node_shaper_profile_shaper_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_shaper_profile_result,
			shaper_id, RTE_UINT32);

static void cmd_del_port_tm_node_shaper_profile_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_del_port_tm_node_shaper_profile_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t shaper_id = res->shaper_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_shaper_profile_delete(port_id, shaper_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_del_port_tm_node_shaper_profile = {
	.f = cmd_del_port_tm_node_shaper_profile_parsed,
	.data = NULL,
	.help_str = "Delete port tm node private shaper profile",
	.tokens = {
		(void *)&cmd_del_port_tm_node_shaper_profile_del,
		(void *)&cmd_del_port_tm_node_shaper_profile_port,
		(void *)&cmd_del_port_tm_node_shaper_profile_tm,
		(void *)&cmd_del_port_tm_node_shaper_profile_node,
		(void *)&cmd_del_port_tm_node_shaper_profile_shaper,
		(void *)&cmd_del_port_tm_node_shaper_profile_profile,
		(void *)&cmd_del_port_tm_node_shaper_profile_port_id,
		(void *)&cmd_del_port_tm_node_shaper_profile_shaper_id,
		NULL,
	},
};

/* *** Add/Update Port TM shared Shaper *** */
struct cmd_add_port_tm_node_shared_shaper_result {
	cmdline_fixed_string_t cmd_type;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t shared;
	cmdline_fixed_string_t shaper;
	uint16_t port_id;
	uint32_t shared_shaper_id;
	uint32_t shaper_profile_id;
};

static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_cmd_type =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			cmd_type, "add#set");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result, port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result, tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result, node, "node");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_shared =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			shared, "shared");
static cmdline_parse_token_string_t cmd_add_port_tm_node_shared_shaper_shaper =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			shaper, "shaper");
static cmdline_parse_token_num_t cmd_add_port_tm_node_shared_shaper_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shared_shaper_shared_shaper_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			shared_shaper_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_node_shared_shaper_shaper_profile_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_shared_shaper_result,
			shaper_profile_id, RTE_UINT32);

static void cmd_add_port_tm_node_shared_shaper_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_node_shared_shaper_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t shared_shaper_id = res->shared_shaper_id;
	uint32_t shaper_profile_id = res->shaper_profile_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Command type: add */
	if ((strcmp(res->cmd_type, "add") == 0) &&
		(port_is_started(port_id))) {
		fprintf(stderr, " Port %u not stopped (error)\n", port_id);
		return;
	}

	/* Command type: set (update) */
	if ((strcmp(res->cmd_type, "set") == 0) &&
		(!port_is_started(port_id))) {
		fprintf(stderr, " Port %u not started (error)\n", port_id);
		return;
	}

	ret = rte_tm_shared_shaper_add_update(port_id, shared_shaper_id,
		shaper_profile_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_node_shared_shaper = {
	.f = cmd_add_port_tm_node_shared_shaper_parsed,
	.data = NULL,
	.help_str = "add/update port tm node shared shaper",
	.tokens = {
		(void *)&cmd_add_port_tm_node_shared_shaper_cmd_type,
		(void *)&cmd_add_port_tm_node_shared_shaper_port,
		(void *)&cmd_add_port_tm_node_shared_shaper_tm,
		(void *)&cmd_add_port_tm_node_shared_shaper_node,
		(void *)&cmd_add_port_tm_node_shared_shaper_shared,
		(void *)&cmd_add_port_tm_node_shared_shaper_shaper,
		(void *)&cmd_add_port_tm_node_shared_shaper_port_id,
		(void *)&cmd_add_port_tm_node_shared_shaper_shared_shaper_id,
		(void *)&cmd_add_port_tm_node_shared_shaper_shaper_profile_id,
		NULL,
	},
};

/* *** Delete Port TM shared Shaper *** */
struct cmd_del_port_tm_node_shared_shaper_result {
	cmdline_fixed_string_t del;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t shared;
	cmdline_fixed_string_t shaper;
	uint16_t port_id;
	uint32_t shared_shaper_id;
};

static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_del =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result, del, "del");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result, port, "port");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result, tm, "tm");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result, node, "node");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_shared =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result,
			shared, "shared");
static cmdline_parse_token_string_t cmd_del_port_tm_node_shared_shaper_shaper =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result,
			shaper, "shaper");
static cmdline_parse_token_num_t cmd_del_port_tm_node_shared_shaper_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_del_port_tm_node_shared_shaper_shared_shaper_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_shared_shaper_result,
			shared_shaper_id, RTE_UINT32);

static void cmd_del_port_tm_node_shared_shaper_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_del_port_tm_node_shared_shaper_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t shared_shaper_id = res->shared_shaper_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_shared_shaper_delete(port_id, shared_shaper_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_del_port_tm_node_shared_shaper = {
	.f = cmd_del_port_tm_node_shared_shaper_parsed,
	.data = NULL,
	.help_str = "delete port tm node shared shaper",
	.tokens = {
		(void *)&cmd_del_port_tm_node_shared_shaper_del,
		(void *)&cmd_del_port_tm_node_shared_shaper_port,
		(void *)&cmd_del_port_tm_node_shared_shaper_tm,
		(void *)&cmd_del_port_tm_node_shared_shaper_node,
		(void *)&cmd_del_port_tm_node_shared_shaper_shared,
		(void *)&cmd_del_port_tm_node_shared_shaper_shaper,
		(void *)&cmd_del_port_tm_node_shared_shaper_port_id,
		(void *)&cmd_del_port_tm_node_shared_shaper_shared_shaper_id,
		NULL,
	},
};

/* *** Add Port TM Node WRED Profile *** */
struct cmd_add_port_tm_node_wred_profile_result {
	cmdline_fixed_string_t add;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t wred;
	cmdline_fixed_string_t profile;
	uint16_t port_id;
	uint32_t wred_profile_id;
	cmdline_fixed_string_t color_g;
	uint64_t min_th_g;
	uint64_t max_th_g;
	uint16_t maxp_inv_g;
	uint16_t wq_log2_g;
	cmdline_fixed_string_t color_y;
	uint64_t min_th_y;
	uint64_t max_th_y;
	uint16_t maxp_inv_y;
	uint16_t wq_log2_y;
	cmdline_fixed_string_t color_r;
	uint64_t min_th_r;
	uint64_t max_th_r;
	uint16_t maxp_inv_r;
	uint16_t wq_log2_r;
};

static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_add =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result, add, "add");
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result, port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result, tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result, node, "node");
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_wred =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result, wred, "wred");
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_profile =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			profile, "profile");
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_wred_profile_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			wred_profile_id, RTE_UINT32);
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_color_g =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			color_g, "G#g");
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_min_th_g =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			min_th_g, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_max_th_g =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			max_th_g, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_maxp_inv_g =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			maxp_inv_g, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_wq_log2_g =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			wq_log2_g, RTE_UINT16);
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_color_y =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			color_y, "Y#y");
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_min_th_y =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			min_th_y, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_max_th_y =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			max_th_y, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_maxp_inv_y =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			maxp_inv_y, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_wq_log2_y =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			wq_log2_y, RTE_UINT16);
static cmdline_parse_token_string_t cmd_add_port_tm_node_wred_profile_color_r =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			color_r, "R#r");
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_min_th_r =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			min_th_r, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_max_th_r =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			max_th_r, RTE_UINT64);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_maxp_inv_r =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			maxp_inv_r, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_node_wred_profile_wq_log2_r =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_node_wred_profile_result,
			wq_log2_r, RTE_UINT16);


static void cmd_add_port_tm_node_wred_profile_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_node_wred_profile_result *res = parsed_result;
	struct rte_tm_wred_params wp;
	enum rte_color color;
	struct rte_tm_error error;
	uint32_t wred_profile_id = res->wred_profile_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&wp, 0, sizeof(struct rte_tm_wred_params));
	memset(&error, 0, sizeof(struct rte_tm_error));

	/* WRED Params  (Green Color)*/
	color = RTE_COLOR_GREEN;
	wp.red_params[color].min_th = res->min_th_g;
	wp.red_params[color].max_th = res->max_th_g;
	wp.red_params[color].maxp_inv = res->maxp_inv_g;
	wp.red_params[color].wq_log2 = res->wq_log2_g;


	/* WRED Params  (Yellow Color)*/
	color = RTE_COLOR_YELLOW;
	wp.red_params[color].min_th = res->min_th_y;
	wp.red_params[color].max_th = res->max_th_y;
	wp.red_params[color].maxp_inv = res->maxp_inv_y;
	wp.red_params[color].wq_log2 = res->wq_log2_y;

	/* WRED Params  (Red Color)*/
	color = RTE_COLOR_RED;
	wp.red_params[color].min_th = res->min_th_r;
	wp.red_params[color].max_th = res->max_th_r;
	wp.red_params[color].maxp_inv = res->maxp_inv_r;
	wp.red_params[color].wq_log2 = res->wq_log2_r;

	ret = rte_tm_wred_profile_add(port_id, wred_profile_id, &wp, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_node_wred_profile = {
	.f = cmd_add_port_tm_node_wred_profile_parsed,
	.data = NULL,
	.help_str = "Add port tm node wred profile",
	.tokens = {
		(void *)&cmd_add_port_tm_node_wred_profile_add,
		(void *)&cmd_add_port_tm_node_wred_profile_port,
		(void *)&cmd_add_port_tm_node_wred_profile_tm,
		(void *)&cmd_add_port_tm_node_wred_profile_node,
		(void *)&cmd_add_port_tm_node_wred_profile_wred,
		(void *)&cmd_add_port_tm_node_wred_profile_profile,
		(void *)&cmd_add_port_tm_node_wred_profile_port_id,
		(void *)&cmd_add_port_tm_node_wred_profile_wred_profile_id,
		(void *)&cmd_add_port_tm_node_wred_profile_color_g,
		(void *)&cmd_add_port_tm_node_wred_profile_min_th_g,
		(void *)&cmd_add_port_tm_node_wred_profile_max_th_g,
		(void *)&cmd_add_port_tm_node_wred_profile_maxp_inv_g,
		(void *)&cmd_add_port_tm_node_wred_profile_wq_log2_g,
		(void *)&cmd_add_port_tm_node_wred_profile_color_y,
		(void *)&cmd_add_port_tm_node_wred_profile_min_th_y,
		(void *)&cmd_add_port_tm_node_wred_profile_max_th_y,
		(void *)&cmd_add_port_tm_node_wred_profile_maxp_inv_y,
		(void *)&cmd_add_port_tm_node_wred_profile_wq_log2_y,
		(void *)&cmd_add_port_tm_node_wred_profile_color_r,
		(void *)&cmd_add_port_tm_node_wred_profile_min_th_r,
		(void *)&cmd_add_port_tm_node_wred_profile_max_th_r,
		(void *)&cmd_add_port_tm_node_wred_profile_maxp_inv_r,
		(void *)&cmd_add_port_tm_node_wred_profile_wq_log2_r,
		NULL,
	},
};

/* *** Delete Port TM node WRED Profile *** */
struct cmd_del_port_tm_node_wred_profile_result {
	cmdline_fixed_string_t del;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t wred;
	cmdline_fixed_string_t profile;
	uint16_t port_id;
	uint32_t wred_profile_id;
};

static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_del =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result, del, "del");
static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result, port, "port");
static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result, tm, "tm");
static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result, node, "node");
static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_wred =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result, wred, "wred");
static cmdline_parse_token_string_t cmd_del_port_tm_node_wred_profile_profile =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result,
			profile, "profile");
static cmdline_parse_token_num_t cmd_del_port_tm_node_wred_profile_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_del_port_tm_node_wred_profile_wred_profile_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_del_port_tm_node_wred_profile_result,
			wred_profile_id, RTE_UINT32);

static void cmd_del_port_tm_node_wred_profile_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_del_port_tm_node_wred_profile_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t wred_profile_id = res->wred_profile_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_wred_profile_delete(port_id, wred_profile_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_del_port_tm_node_wred_profile = {
	.f = cmd_del_port_tm_node_wred_profile_parsed,
	.data = NULL,
	.help_str = "Delete port tm node wred profile",
	.tokens = {
		(void *)&cmd_del_port_tm_node_wred_profile_del,
		(void *)&cmd_del_port_tm_node_wred_profile_port,
		(void *)&cmd_del_port_tm_node_wred_profile_tm,
		(void *)&cmd_del_port_tm_node_wred_profile_node,
		(void *)&cmd_del_port_tm_node_wred_profile_wred,
		(void *)&cmd_del_port_tm_node_wred_profile_profile,
		(void *)&cmd_del_port_tm_node_wred_profile_port_id,
		(void *)&cmd_del_port_tm_node_wred_profile_wred_profile_id,
		NULL,
	},
};

/* *** Update Port TM Node Shaper profile *** */
struct cmd_set_port_tm_node_shaper_profile_result {
	cmdline_fixed_string_t set;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t shaper;
	cmdline_fixed_string_t profile;
	uint16_t port_id;
	uint32_t node_id;
	uint32_t shaper_profile_id;
};

static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_set =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result, set, "set");
static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result,
			port, "port");
static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result, tm, "tm");
static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result,
			node, "node");
static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_shaper =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result,
			shaper, "shaper");
static cmdline_parse_token_string_t cmd_set_port_tm_node_shaper_profile_profile =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result,
			profile, "profile");
static cmdline_parse_token_num_t cmd_set_port_tm_node_shaper_profile_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_set_port_tm_node_shaper_profile_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_set_port_tm_node_shaper_profile_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_set_port_tm_node_shaper_profile_result,
		node_id, RTE_UINT32);
static cmdline_parse_token_num_t
	cmd_set_port_tm_node_shaper_shaper_profile_profile_id =
		TOKEN_NUM_INITIALIZER(
			struct cmd_set_port_tm_node_shaper_profile_result,
			shaper_profile_id, RTE_UINT32);

static void cmd_set_port_tm_node_shaper_profile_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_set_port_tm_node_shaper_profile_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	uint32_t shaper_profile_id = res->shaper_profile_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Port status */
	if (!port_is_started(port_id)) {
		fprintf(stderr, " Port %u not started (error)\n", port_id);
		return;
	}

	ret = rte_tm_node_shaper_update(port_id, node_id,
		shaper_profile_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_set_port_tm_node_shaper_profile = {
	.f = cmd_set_port_tm_node_shaper_profile_parsed,
	.data = NULL,
	.help_str = "Set port tm node shaper profile",
	.tokens = {
		(void *)&cmd_set_port_tm_node_shaper_profile_set,
		(void *)&cmd_set_port_tm_node_shaper_profile_port,
		(void *)&cmd_set_port_tm_node_shaper_profile_tm,
		(void *)&cmd_set_port_tm_node_shaper_profile_node,
		(void *)&cmd_set_port_tm_node_shaper_profile_shaper,
		(void *)&cmd_set_port_tm_node_shaper_profile_profile,
		(void *)&cmd_set_port_tm_node_shaper_profile_port_id,
		(void *)&cmd_set_port_tm_node_shaper_profile_node_id,
		(void *)&cmd_set_port_tm_node_shaper_shaper_profile_profile_id,
		NULL,
	},
};

/* *** Add Port TM nonleaf node *** */
struct cmd_add_port_tm_nonleaf_node_result {
	cmdline_fixed_string_t add;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t nonleaf;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
	int32_t parent_node_id;
	uint32_t priority;
	uint32_t weight;
	uint32_t level_id;
	int32_t shaper_profile_id;
	uint32_t n_sp_priorities;
	uint64_t stats_mask;
	cmdline_multi_string_t multi_shared_shaper_id;
};

static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_add =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result, add, "add");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result, port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_nonleaf =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result, nonleaf, "nonleaf");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result, node, "node");
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 node_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_parent_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 parent_node_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_priority =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 priority, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_weight =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 weight, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_level_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 level_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_shaper_profile_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 shaper_profile_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_n_sp_priorities =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 n_sp_priorities, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_stats_mask =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 stats_mask, RTE_UINT64);
static cmdline_parse_token_string_t
	cmd_add_port_tm_nonleaf_node_multi_shared_shaper_id =
	TOKEN_STRING_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_result,
		 multi_shared_shaper_id, TOKEN_STRING_MULTI);

static void cmd_add_port_tm_nonleaf_node_parsed(void *parsed_result,
	struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_nonleaf_node_result *res = parsed_result;
	struct rte_tm_error error;
	struct rte_tm_node_params np;
	uint32_t *shared_shaper_id;
	uint32_t parent_node_id, n_shared_shapers = 0;
	char *s_str = res->multi_shared_shaper_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&np, 0, sizeof(struct rte_tm_node_params));
	memset(&error, 0, sizeof(struct rte_tm_error));

	/* Node parameters */
	if (res->parent_node_id < 0)
		parent_node_id = UINT32_MAX;
	else
		parent_node_id = res->parent_node_id;

	if (parent_node_id != UINT32_MAX)
		cmdline_printf(cl, "adding node on port %u, with id %u and parent node %u\n",
				port_id, res->node_id, parent_node_id);
	else
		cmdline_printf(cl, "adding node on port %u, with id %u as root node\n",
				port_id, res->node_id);
	cmdline_printf(cl, "# priority: %u\n", res->priority);
	cmdline_printf(cl, "# weight: %u\n", res->weight);
	cmdline_printf(cl, "# level_id: %u\n", res->level_id);
	cmdline_printf(cl, "# shaper_profile_id: %d\n", res->shaper_profile_id);
	cmdline_printf(cl, "# num SP priorities: %u\n", res->n_sp_priorities);
	cmdline_printf(cl, "# stats_mask: %"PRIx64"\n", res->stats_mask);
	cmdline_printf(cl, "# shared shapers: '%s'\n", s_str);

	shared_shaper_id = (uint32_t *)malloc(MAX_NUM_SHARED_SHAPERS *
		sizeof(uint32_t));
	if (shared_shaper_id == NULL) {
		fprintf(stderr,
			" Memory not allocated for shared shapers (error)\n");
		return;
	}

	/* Parse multi shared shaper id string */
	ret = parse_multi_ss_id_str(s_str, &n_shared_shapers, shared_shaper_id);
	if (ret) {
		fprintf(stderr, " Shared shapers params string parse error\n");
		free(shared_shaper_id);
		return;
	}

	if (res->shaper_profile_id < 0)
		np.shaper_profile_id = UINT32_MAX;
	else
		np.shaper_profile_id = res->shaper_profile_id;

	np.n_shared_shapers = n_shared_shapers;
	if (np.n_shared_shapers) {
		np.shared_shaper_id = &shared_shaper_id[0];
	} else {
		free(shared_shaper_id);
		shared_shaper_id = NULL;
	}

	np.nonleaf.n_sp_priorities = res->n_sp_priorities;
	np.stats_mask = res->stats_mask;
	np.nonleaf.wfq_weight_mode = NULL;

	ret = rte_tm_node_add(port_id, res->node_id, parent_node_id,
				res->priority, res->weight, res->level_id,
				&np, &error);
	if (ret != 0) {
		print_err_msg(&error);
		free(shared_shaper_id);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_nonleaf_node = {
	.f = cmd_add_port_tm_nonleaf_node_parsed,
	.data = NULL,
	.help_str = "Add port tm nonleaf node",
	.tokens = {
		(void *)&cmd_add_port_tm_nonleaf_node_add,
		(void *)&cmd_add_port_tm_nonleaf_node_port,
		(void *)&cmd_add_port_tm_nonleaf_node_tm,
		(void *)&cmd_add_port_tm_nonleaf_node_nonleaf,
		(void *)&cmd_add_port_tm_nonleaf_node_node,
		(void *)&cmd_add_port_tm_nonleaf_node_port_id,
		(void *)&cmd_add_port_tm_nonleaf_node_node_id,
		(void *)&cmd_add_port_tm_nonleaf_node_parent_node_id,
		(void *)&cmd_add_port_tm_nonleaf_node_priority,
		(void *)&cmd_add_port_tm_nonleaf_node_weight,
		(void *)&cmd_add_port_tm_nonleaf_node_level_id,
		(void *)&cmd_add_port_tm_nonleaf_node_shaper_profile_id,
		(void *)&cmd_add_port_tm_nonleaf_node_n_sp_priorities,
		(void *)&cmd_add_port_tm_nonleaf_node_stats_mask,
		(void *)&cmd_add_port_tm_nonleaf_node_multi_shared_shaper_id,
		NULL,
	},
};

/* *** Add Port TM nonleaf node pkt mode *** */
struct cmd_add_port_tm_nonleaf_node_pmode_result {
	cmdline_fixed_string_t add;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t nonleaf;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
	int32_t parent_node_id;
	uint32_t priority;
	uint32_t weight;
	uint32_t level_id;
	int32_t shaper_profile_id;
	uint32_t n_sp_priorities;
	uint64_t stats_mask;
	cmdline_multi_string_t multi_shared_shaper_id;
};

static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_add =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, add, "add");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_nonleaf =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, nonleaf, "nonleaf");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, node, "node");
static cmdline_parse_token_string_t cmd_add_port_tm_nonleaf_node_pmode_pktmode =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result, node, "pktmode");
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 node_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_parent_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 parent_node_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_priority =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 priority, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_weight =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 weight, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_level_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 level_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_shaper_profile_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 shaper_profile_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_n_sp_priorities =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 n_sp_priorities, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_nonleaf_node_pmode_stats_mask =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_nonleaf_node_pmode_result,
		 stats_mask, RTE_UINT64);
static cmdline_parse_token_string_t
	cmd_add_port_tm_nonleaf_node_pmode_multi_shrd_shpr_id =
	TOKEN_STRING_INITIALIZER(
			struct cmd_add_port_tm_nonleaf_node_pmode_result,
			multi_shared_shaper_id, TOKEN_STRING_MULTI);

static void cmd_add_port_tm_nonleaf_node_pmode_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_nonleaf_node_pmode_result *res = parsed_result;
	uint32_t parent_node_id, n_shared_shapers = 0;
	char *s_str = res->multi_shared_shaper_id;
	portid_t port_id = res->port_id;
	struct rte_tm_node_params np;
	int *wfq_weight_mode = NULL;
	uint32_t *shared_shaper_id;
	struct rte_tm_error error;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&np, 0, sizeof(struct rte_tm_node_params));
	memset(&error, 0, sizeof(struct rte_tm_error));

	/* Node parameters */
	if (res->parent_node_id < 0)
		parent_node_id = UINT32_MAX;
	else
		parent_node_id = res->parent_node_id;

	shared_shaper_id = (uint32_t *)malloc(MAX_NUM_SHARED_SHAPERS *
		sizeof(uint32_t));
	if (shared_shaper_id == NULL) {
		fprintf(stderr,
			" Memory not allocated for shared shapers (error)\n");
		return;
	}

	/* Parse multi shared shaper id string */
	ret = parse_multi_ss_id_str(s_str, &n_shared_shapers, shared_shaper_id);
	if (ret) {
		fprintf(stderr, " Shared shapers params string parse error\n");
		free(shared_shaper_id);
		return;
	}

	if (res->shaper_profile_id < 0)
		np.shaper_profile_id = UINT32_MAX;
	else
		np.shaper_profile_id = res->shaper_profile_id;

	np.n_shared_shapers = n_shared_shapers;
	if (np.n_shared_shapers) {
		np.shared_shaper_id = &shared_shaper_id[0];
	} else {
		free(shared_shaper_id);
		shared_shaper_id = NULL;
	}

	if (res->n_sp_priorities)
		wfq_weight_mode = calloc(res->n_sp_priorities, sizeof(int));
	np.nonleaf.n_sp_priorities = res->n_sp_priorities;
	np.stats_mask = res->stats_mask;
	np.nonleaf.wfq_weight_mode = wfq_weight_mode;

	ret = rte_tm_node_add(port_id, res->node_id, parent_node_id,
				res->priority, res->weight, res->level_id,
				&np, &error);
	if (ret != 0) {
		print_err_msg(&error);
		free(shared_shaper_id);
		free(wfq_weight_mode);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_nonleaf_node_pmode = {
	.f = cmd_add_port_tm_nonleaf_node_pmode_parsed,
	.data = NULL,
	.help_str = "Add port tm nonleaf node pktmode",
	.tokens = {
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_add,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_port,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_tm,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_nonleaf,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_node,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_pktmode,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_port_id,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_node_id,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_parent_node_id,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_priority,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_weight,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_level_id,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_shaper_profile_id,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_n_sp_priorities,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_stats_mask,
		(void *)&cmd_add_port_tm_nonleaf_node_pmode_multi_shrd_shpr_id,
		NULL,
	},
};
/* *** Add Port TM leaf node *** */
struct cmd_add_port_tm_leaf_node_result {
	cmdline_fixed_string_t add;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t leaf;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
	int32_t parent_node_id;
	uint32_t priority;
	uint32_t weight;
	uint32_t level_id;
	int32_t shaper_profile_id;
	uint32_t cman_mode;
	uint32_t wred_profile_id;
	uint64_t stats_mask;
	cmdline_multi_string_t multi_shared_shaper_id;
};

static cmdline_parse_token_string_t cmd_add_port_tm_leaf_node_add =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_leaf_node_result, add, "add");
static cmdline_parse_token_string_t cmd_add_port_tm_leaf_node_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_leaf_node_result, port, "port");
static cmdline_parse_token_string_t cmd_add_port_tm_leaf_node_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_leaf_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_add_port_tm_leaf_node_nonleaf =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_leaf_node_result, leaf, "leaf");
static cmdline_parse_token_string_t cmd_add_port_tm_leaf_node_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_add_port_tm_leaf_node_result, node, "node");
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 node_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_parent_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 parent_node_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_priority =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 priority, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_weight =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 weight, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_level_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 level_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_shaper_profile_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 shaper_profile_id, RTE_INT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_cman_mode =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 cman_mode, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_wred_profile_id =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 wred_profile_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_add_port_tm_leaf_node_stats_mask =
	TOKEN_NUM_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 stats_mask, RTE_UINT64);
static cmdline_parse_token_string_t
	cmd_add_port_tm_leaf_node_multi_shared_shaper_id =
	TOKEN_STRING_INITIALIZER(struct cmd_add_port_tm_leaf_node_result,
		 multi_shared_shaper_id, TOKEN_STRING_MULTI);

static void cmd_add_port_tm_leaf_node_parsed(void *parsed_result,
	struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_add_port_tm_leaf_node_result *res = parsed_result;
	struct rte_tm_error error;
	struct rte_tm_node_params np;
	uint32_t *shared_shaper_id;
	uint32_t parent_node_id, n_shared_shapers = 0;
	portid_t port_id = res->port_id;
	char *s_str = res->multi_shared_shaper_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&np, 0, sizeof(struct rte_tm_node_params));
	memset(&error, 0, sizeof(struct rte_tm_error));

	/* Node parameters */
	if (res->parent_node_id < 0)
		parent_node_id = UINT32_MAX;
	else
		parent_node_id = res->parent_node_id;

	if (parent_node_id != UINT32_MAX)
		cmdline_printf(cl, "adding leaf node on port %u, with id %u and parent node %u\n",
				port_id, res->node_id, parent_node_id);
	else
		cmdline_printf(cl, "adding leaf node on port %u, with id %u as root node\n",
				port_id, res->node_id);
	cmdline_printf(cl, "# priority: %u\n", res->priority);
	cmdline_printf(cl, "# weight: %u\n", res->weight);
	cmdline_printf(cl, "# level_id: %u\n", res->level_id);
	cmdline_printf(cl, "# shaper_profile_id: %d\n", res->shaper_profile_id);
	cmdline_printf(cl, "# cman_mode: %u\n", res->cman_mode);
	cmdline_printf(cl, "# wred_profile_id: %d\n", res->wred_profile_id);
	cmdline_printf(cl, "# stats_mask: %"PRIx64"\n", res->stats_mask);
	cmdline_printf(cl, "# shared shapers: '%s'\n", s_str);

	shared_shaper_id = (uint32_t *)malloc(MAX_NUM_SHARED_SHAPERS *
		sizeof(uint32_t));
	if (shared_shaper_id == NULL) {
		fprintf(stderr,
			" Memory not allocated for shared shapers (error)\n");
		return;
	}

	/* Parse multi shared shaper id string */
	ret = parse_multi_ss_id_str(s_str, &n_shared_shapers, shared_shaper_id);
	if (ret) {
		fprintf(stderr, " Shared shapers params string parse error\n");
		free(shared_shaper_id);
		return;
	}

	if (res->shaper_profile_id < 0)
		np.shaper_profile_id = UINT32_MAX;
	else
		np.shaper_profile_id = res->shaper_profile_id;

	np.n_shared_shapers = n_shared_shapers;

	if (np.n_shared_shapers) {
		np.shared_shaper_id = &shared_shaper_id[0];
	} else {
		free(shared_shaper_id);
		shared_shaper_id = NULL;
	}

	np.leaf.cman = res->cman_mode;
	np.leaf.wred.wred_profile_id = res->wred_profile_id;
	np.stats_mask = res->stats_mask;

	ret = rte_tm_node_add(port_id, res->node_id, parent_node_id,
				res->priority, res->weight, res->level_id,
				&np, &error);
	if (ret != 0) {
		print_err_msg(&error);
		free(shared_shaper_id);
		return;
	}
}

cmdline_parse_inst_t cmd_add_port_tm_leaf_node = {
	.f = cmd_add_port_tm_leaf_node_parsed,
	.data = NULL,
	.help_str = "Add port tm leaf node",
	.tokens = {
		(void *)&cmd_add_port_tm_leaf_node_add,
		(void *)&cmd_add_port_tm_leaf_node_port,
		(void *)&cmd_add_port_tm_leaf_node_tm,
		(void *)&cmd_add_port_tm_leaf_node_nonleaf,
		(void *)&cmd_add_port_tm_leaf_node_node,
		(void *)&cmd_add_port_tm_leaf_node_port_id,
		(void *)&cmd_add_port_tm_leaf_node_node_id,
		(void *)&cmd_add_port_tm_leaf_node_parent_node_id,
		(void *)&cmd_add_port_tm_leaf_node_priority,
		(void *)&cmd_add_port_tm_leaf_node_weight,
		(void *)&cmd_add_port_tm_leaf_node_level_id,
		(void *)&cmd_add_port_tm_leaf_node_shaper_profile_id,
		(void *)&cmd_add_port_tm_leaf_node_cman_mode,
		(void *)&cmd_add_port_tm_leaf_node_wred_profile_id,
		(void *)&cmd_add_port_tm_leaf_node_stats_mask,
		(void *)&cmd_add_port_tm_leaf_node_multi_shared_shaper_id,
		NULL,
	},
};

struct cmd_show_port_tm_node_result {
	cmdline_fixed_string_t show;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_show_port_tm_node_show_tok =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_result, show, "show");
static cmdline_parse_token_string_t cmd_show_port_tm_node_port_tok =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_result, port, "port");
static cmdline_parse_token_string_t cmd_show_port_tm_node_tm_tok =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_show_port_tm_node_node_tok =
	TOKEN_STRING_INITIALIZER(struct cmd_show_port_tm_node_result, node, "node");
static cmdline_parse_token_num_t cmd_show_port_tm_node_port_id_tok =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_node_result, port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_show_port_tm_node_node_id_tok =
	TOKEN_NUM_INITIALIZER(struct cmd_show_port_tm_node_result, node_id, RTE_UINT32);

static void
cmd_show_port_tm_node_parsed(void *parsed_result, struct cmdline *cl, void *data __rte_unused)
{
	const struct cmd_show_port_tm_node_result *res = parsed_result;
	const portid_t port_id = res->port_id;
	const uint32_t node_id = res->node_id;
	struct rte_tm_node_params params = {0};
	struct rte_tm_error error = {0};
	uint32_t parent_id, priority, weight, level_id;
	int is_leaf;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	ret = rte_tm_node_query(port_id, node_id,
			&parent_id, &priority, &weight, &level_id, &params, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}

	ret = rte_tm_node_type_get(port_id, node_id, &is_leaf, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}

	cmdline_printf(cl, "Port %u TM Node %u\n", port_id, node_id);
	if (parent_id == RTE_TM_NODE_ID_NULL)
		cmdline_printf(cl, "  Parent Node ID: <NULL>\n");
	else
		cmdline_printf(cl, "  Parent Node ID: %d\n", parent_id);
	cmdline_printf(cl, "  Level ID: %u\n", level_id);
	cmdline_printf(cl, "  Priority: %u\n", priority);
	cmdline_printf(cl, "  Weight: %u\n", weight);
	if (params.shaper_profile_id == RTE_TM_SHAPER_PROFILE_ID_NONE)
		cmdline_printf(cl, "  Shaper Profile ID: <none>\n");
	else
		cmdline_printf(cl, "  Shaper Profile ID: %d\n", params.shaper_profile_id);
	cmdline_printf(cl, "  Shared Shaper IDs: ");
	if (params.n_shared_shapers == 0)
		cmdline_printf(cl, "<none>\n");
	else {
		for (uint32_t i = 0; i < params.n_shared_shapers; i++)
			cmdline_printf(cl, "%u ", params.shared_shaper_id[i]);
		cmdline_printf(cl, "\n");
	}
	cmdline_printf(cl, "  Stats Mask: %"PRIu64"\n", params.stats_mask);
	if (is_leaf) {
		cmdline_printf(cl, "  Leaf Node Parameters\n");
		switch (params.leaf.cman) {
		case RTE_TM_CMAN_TAIL_DROP:
			cmdline_printf(cl, "    CMAN Mode: Tail Drop\n");
			break;
		case RTE_TM_CMAN_HEAD_DROP:
			cmdline_printf(cl, "    CMAN Mode: Head Drop\n");
			break;
		case RTE_TM_CMAN_WRED:
			cmdline_printf(cl, "    CMAN Mode: WRED\n");
			break;
		}
		if (params.leaf.wred.wred_profile_id == RTE_TM_WRED_PROFILE_ID_NONE)
			cmdline_printf(cl, "    WRED Profile ID: <none>\n");
		else
			cmdline_printf(cl, "    WRED Profile ID: %u\n",
					params.leaf.wred.wred_profile_id);
		cmdline_printf(cl, "    Shared WRED Context Ids: ");
		if (params.leaf.wred.n_shared_wred_contexts == 0)
			cmdline_printf(cl, "<none>\n");
		else {
			for (uint32_t i = 0; i < params.leaf.wred.n_shared_wred_contexts; i++)
				cmdline_printf(cl, "%u ",
						params.leaf.wred.shared_wred_context_id[i]);
			cmdline_printf(cl, "\n");
		}
	} else {
		cmdline_printf(cl, "  Nonleaf Node Parameters\n");
		cmdline_printf(cl, "    Num Strict Priorities: %u\n",
				params.nonleaf.n_sp_priorities);
		cmdline_printf(cl, "    WFQ Weights Mode: ");
		if (params.nonleaf.wfq_weight_mode == NULL)
			cmdline_printf(cl, "WFQ\n");
		else {
			for (uint32_t i = 0; i < params.nonleaf.n_sp_priorities; i++)
				cmdline_printf(cl, "%s(%d) ",
					params.nonleaf.wfq_weight_mode[i] ? "Bytes" : "Packet",
					params.nonleaf.wfq_weight_mode[i]);
			cmdline_printf(cl, "\n");
		}
	}
}


cmdline_parse_inst_t cmd_show_port_tm_node = {
	.f = cmd_show_port_tm_node_parsed,
	.data = NULL,
	.help_str = "",
	.tokens = {
		(void *)&cmd_show_port_tm_node_show_tok,
		(void *)&cmd_show_port_tm_node_port_tok,
		(void *)&cmd_show_port_tm_node_tm_tok,
		(void *)&cmd_show_port_tm_node_node_tok,
		(void *)&cmd_show_port_tm_node_port_id_tok,
		(void *)&cmd_show_port_tm_node_node_id_tok,
		NULL,
	}
};

/* *** Delete Port TM Node *** */
struct cmd_del_port_tm_node_result {
	cmdline_fixed_string_t del;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_del_port_tm_node_del =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_result, del, "del");
static cmdline_parse_token_string_t cmd_del_port_tm_node_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_result, port, "port");
static cmdline_parse_token_string_t cmd_del_port_tm_node_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_del_port_tm_node_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_del_port_tm_node_result, node, "node");
static cmdline_parse_token_num_t cmd_del_port_tm_node_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_del_port_tm_node_result,
		 port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_del_port_tm_node_node_id =
	TOKEN_NUM_INITIALIZER(struct cmd_del_port_tm_node_result,
		node_id, RTE_UINT32);

static void cmd_del_port_tm_node_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_del_port_tm_node_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Port status */
	if (port_is_started(port_id)) {
		fprintf(stderr, " Port %u not stopped (error)\n", port_id);
		return;
	}

	ret = rte_tm_node_delete(port_id, node_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_del_port_tm_node = {
	.f = cmd_del_port_tm_node_parsed,
	.data = NULL,
	.help_str = "Delete port tm node",
	.tokens = {
		(void *)&cmd_del_port_tm_node_del,
		(void *)&cmd_del_port_tm_node_port,
		(void *)&cmd_del_port_tm_node_tm,
		(void *)&cmd_del_port_tm_node_node,
		(void *)&cmd_del_port_tm_node_port_id,
		(void *)&cmd_del_port_tm_node_node_id,
		NULL,
	},
};

/* *** Update Port TM Node Parent *** */
struct cmd_set_port_tm_node_parent_result {
	cmdline_fixed_string_t set;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	cmdline_fixed_string_t parent;
	uint16_t port_id;
	uint32_t node_id;
	uint32_t parent_id;
	uint32_t priority;
	uint32_t weight;
};

static cmdline_parse_token_string_t cmd_set_port_tm_node_parent_set =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, set, "set");
static cmdline_parse_token_string_t cmd_set_port_tm_node_parent_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, port, "port");
static cmdline_parse_token_string_t cmd_set_port_tm_node_parent_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, tm, "tm");
static cmdline_parse_token_string_t cmd_set_port_tm_node_parent_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, node, "node");
static cmdline_parse_token_string_t cmd_set_port_tm_node_parent_parent =
	TOKEN_STRING_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, parent, "parent");
static cmdline_parse_token_num_t cmd_set_port_tm_node_parent_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, port_id,
		RTE_UINT16);
static cmdline_parse_token_num_t cmd_set_port_tm_node_parent_node_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_set_port_tm_node_parent_result, node_id,
		RTE_UINT32);
static cmdline_parse_token_num_t cmd_set_port_tm_node_parent_parent_id =
	TOKEN_NUM_INITIALIZER(struct cmd_set_port_tm_node_parent_result,
		parent_id, RTE_UINT32);
static cmdline_parse_token_num_t cmd_set_port_tm_node_parent_priority =
	TOKEN_NUM_INITIALIZER(struct cmd_set_port_tm_node_parent_result,
		priority, RTE_UINT32);
static cmdline_parse_token_num_t cmd_set_port_tm_node_parent_weight =
	TOKEN_NUM_INITIALIZER(struct cmd_set_port_tm_node_parent_result,
		weight, RTE_UINT32);

static void cmd_set_port_tm_node_parent_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_set_port_tm_node_parent_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	uint32_t parent_id = res->parent_id;
	uint32_t priority = res->priority;
	uint32_t weight = res->weight;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	/* Port status */
	if (!port_is_started(port_id)) {
		fprintf(stderr, " Port %u not started (error)\n", port_id);
		return;
	}

	ret = rte_tm_node_parent_update(port_id, node_id,
		parent_id, priority, weight, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_set_port_tm_node_parent = {
	.f = cmd_set_port_tm_node_parent_parsed,
	.data = NULL,
	.help_str = "Set port tm node parent",
	.tokens = {
		(void *)&cmd_set_port_tm_node_parent_set,
		(void *)&cmd_set_port_tm_node_parent_port,
		(void *)&cmd_set_port_tm_node_parent_tm,
		(void *)&cmd_set_port_tm_node_parent_node,
		(void *)&cmd_set_port_tm_node_parent_parent,
		(void *)&cmd_set_port_tm_node_parent_port_id,
		(void *)&cmd_set_port_tm_node_parent_node_id,
		(void *)&cmd_set_port_tm_node_parent_parent_id,
		(void *)&cmd_set_port_tm_node_parent_priority,
		(void *)&cmd_set_port_tm_node_parent_weight,
		NULL,
	},
};

/* *** Suspend Port TM Node *** */
struct cmd_suspend_port_tm_node_result {
	cmdline_fixed_string_t suspend;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_suspend_port_tm_node_suspend =
	TOKEN_STRING_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, suspend, "suspend");
static cmdline_parse_token_string_t cmd_suspend_port_tm_node_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, port, "port");
static cmdline_parse_token_string_t cmd_suspend_port_tm_node_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_suspend_port_tm_node_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, node, "node");
static cmdline_parse_token_num_t cmd_suspend_port_tm_node_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, port_id,
		RTE_UINT16);
static cmdline_parse_token_num_t cmd_suspend_port_tm_node_node_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_suspend_port_tm_node_result, node_id,
		RTE_UINT32);

static void cmd_suspend_port_tm_node_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_suspend_port_tm_node_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_node_suspend(port_id, node_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_suspend_port_tm_node = {
	.f = cmd_suspend_port_tm_node_parsed,
	.data = NULL,
	.help_str = "Suspend port tm node",
	.tokens = {
		(void *)&cmd_suspend_port_tm_node_suspend,
		(void *)&cmd_suspend_port_tm_node_port,
		(void *)&cmd_suspend_port_tm_node_tm,
		(void *)&cmd_suspend_port_tm_node_node,
		(void *)&cmd_suspend_port_tm_node_port_id,
		(void *)&cmd_suspend_port_tm_node_node_id,
		NULL,
	},
};

/* *** Resume Port TM Node *** */
struct cmd_resume_port_tm_node_result {
	cmdline_fixed_string_t resume;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t node;
	uint16_t port_id;
	uint32_t node_id;
};

static cmdline_parse_token_string_t cmd_resume_port_tm_node_resume =
	TOKEN_STRING_INITIALIZER(
		struct cmd_resume_port_tm_node_result, resume, "resume");
static cmdline_parse_token_string_t cmd_resume_port_tm_node_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_resume_port_tm_node_result, port, "port");
static cmdline_parse_token_string_t cmd_resume_port_tm_node_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_resume_port_tm_node_result, tm, "tm");
static cmdline_parse_token_string_t cmd_resume_port_tm_node_node =
	TOKEN_STRING_INITIALIZER(
		struct cmd_resume_port_tm_node_result, node, "node");
static cmdline_parse_token_num_t cmd_resume_port_tm_node_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_resume_port_tm_node_result, port_id, RTE_UINT16);
static cmdline_parse_token_num_t cmd_resume_port_tm_node_node_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_resume_port_tm_node_result, node_id, RTE_UINT32);

static void cmd_resume_port_tm_node_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_resume_port_tm_node_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t node_id = res->node_id;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_node_resume(port_id, node_id, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_resume_port_tm_node = {
	.f = cmd_resume_port_tm_node_parsed,
	.data = NULL,
	.help_str = "Resume port tm node",
	.tokens = {
		(void *)&cmd_resume_port_tm_node_resume,
		(void *)&cmd_resume_port_tm_node_port,
		(void *)&cmd_resume_port_tm_node_tm,
		(void *)&cmd_resume_port_tm_node_node,
		(void *)&cmd_resume_port_tm_node_port_id,
		(void *)&cmd_resume_port_tm_node_node_id,
		NULL,
	},
};

/* *** Port TM Hierarchy Commit *** */
struct cmd_port_tm_hierarchy_commit_result {
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t hierarchy;
	cmdline_fixed_string_t commit;
	uint16_t port_id;
	cmdline_fixed_string_t clean_on_fail;
};

static cmdline_parse_token_string_t cmd_port_tm_hierarchy_commit_port =
	TOKEN_STRING_INITIALIZER(
		struct cmd_port_tm_hierarchy_commit_result, port, "port");
static cmdline_parse_token_string_t cmd_port_tm_hierarchy_commit_tm =
	TOKEN_STRING_INITIALIZER(
		struct cmd_port_tm_hierarchy_commit_result, tm, "tm");
static cmdline_parse_token_string_t cmd_port_tm_hierarchy_commit_hierarchy =
	TOKEN_STRING_INITIALIZER(
		struct cmd_port_tm_hierarchy_commit_result,
			hierarchy, "hierarchy");
static cmdline_parse_token_string_t cmd_port_tm_hierarchy_commit_commit =
	TOKEN_STRING_INITIALIZER(
		struct cmd_port_tm_hierarchy_commit_result, commit, "commit");
static cmdline_parse_token_num_t cmd_port_tm_hierarchy_commit_port_id =
	TOKEN_NUM_INITIALIZER(
		struct cmd_port_tm_hierarchy_commit_result,
			port_id, RTE_UINT16);
static cmdline_parse_token_string_t cmd_port_tm_hierarchy_commit_clean_on_fail =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_hierarchy_commit_result,
		 clean_on_fail, "yes#no");

static void cmd_port_tm_hierarchy_commit_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_port_tm_hierarchy_commit_result *res = parsed_result;
	struct rte_tm_error error;
	uint32_t clean_on_fail;
	portid_t port_id = res->port_id;
	int ret;

	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	if (strcmp(res->clean_on_fail, "yes") == 0)
		clean_on_fail = 1;
	else
		clean_on_fail = 0;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_hierarchy_commit(port_id, clean_on_fail, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_port_tm_hierarchy_commit = {
	.f = cmd_port_tm_hierarchy_commit_parsed,
	.data = NULL,
	.help_str = "Commit port tm hierarchy",
	.tokens = {
		(void *)&cmd_port_tm_hierarchy_commit_port,
		(void *)&cmd_port_tm_hierarchy_commit_tm,
		(void *)&cmd_port_tm_hierarchy_commit_hierarchy,
		(void *)&cmd_port_tm_hierarchy_commit_commit,
		(void *)&cmd_port_tm_hierarchy_commit_port_id,
		(void *)&cmd_port_tm_hierarchy_commit_clean_on_fail,
		NULL,
	},
};

/* *** Port TM Mark IP ECN *** */
struct cmd_port_tm_mark_ip_ecn_result {
	cmdline_fixed_string_t set;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t mark;
	cmdline_fixed_string_t ip_ecn;
	uint16_t port_id;
	uint16_t green;
	uint16_t yellow;
	uint16_t red;
};

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_ecn_set =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
				 set, "set");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_ecn_port =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
				 port, "port");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_ecn_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result, tm,
				 "tm");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_ecn_mark =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
				 mark, "mark");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_ecn_ip_ecn =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
				 ip_ecn, "ip_ecn");
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_ecn_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
			      port_id, RTE_UINT16);

static cmdline_parse_token_num_t cmd_port_tm_mark_ip_ecn_green =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
			      green, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_ecn_yellow =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
			      yellow, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_ecn_red =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_ecn_result,
				red, RTE_UINT16);

static void cmd_port_tm_mark_ip_ecn_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_port_tm_mark_ip_ecn_result *res = parsed_result;
	struct rte_tm_error error;
	portid_t port_id = res->port_id;
	int green = res->green;
	int yellow = res->yellow;
	int red = res->red;
	int ret;
	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_mark_ip_ecn(port_id, green, yellow, red, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_port_tm_mark_ip_ecn = {
	.f = cmd_port_tm_mark_ip_ecn_parsed,
	.data = NULL,
	.help_str = "set port tm mark ip_ecn <port> <green> <yellow> <red>",
	.tokens = {
		(void *)&cmd_port_tm_mark_ip_ecn_set,
		(void *)&cmd_port_tm_mark_ip_ecn_port,
		(void *)&cmd_port_tm_mark_ip_ecn_tm,
		(void *)&cmd_port_tm_mark_ip_ecn_mark,
		(void *)&cmd_port_tm_mark_ip_ecn_ip_ecn,
		(void *)&cmd_port_tm_mark_ip_ecn_port_id,
		(void *)&cmd_port_tm_mark_ip_ecn_green,
		(void *)&cmd_port_tm_mark_ip_ecn_yellow,
		(void *)&cmd_port_tm_mark_ip_ecn_red,
		NULL,
	},
};


/* *** Port TM Mark IP DSCP *** */
struct cmd_port_tm_mark_ip_dscp_result {
	cmdline_fixed_string_t set;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t mark;
	cmdline_fixed_string_t ip_dscp;
	uint16_t port_id;
	uint16_t green;
	uint16_t yellow;
	uint16_t red;
};

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_dscp_set =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				 set, "set");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_dscp_port =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				 port, "port");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_dscp_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result, tm,
				 "tm");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_dscp_mark =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				 mark, "mark");

static cmdline_parse_token_string_t cmd_port_tm_mark_ip_dscp_ip_dscp =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				 ip_dscp, "ip_dscp");
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_dscp_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
			      port_id, RTE_UINT16);

static cmdline_parse_token_num_t cmd_port_tm_mark_ip_dscp_green =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				green, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_dscp_yellow =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				yellow, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_ip_dscp_red =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_ip_dscp_result,
				red, RTE_UINT16);

static void cmd_port_tm_mark_ip_dscp_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_port_tm_mark_ip_dscp_result *res = parsed_result;
	struct rte_tm_error error;
	portid_t port_id = res->port_id;
	int green = res->green;
	int yellow = res->yellow;
	int red = res->red;
	int ret;
	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_mark_ip_dscp(port_id, green, yellow, red, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_port_tm_mark_ip_dscp = {
	.f = cmd_port_tm_mark_ip_dscp_parsed,
	.data = NULL,
	.help_str = "set port tm mark ip_dscp <port> <green> <yellow> <red>",
	.tokens = {
		(void *)&cmd_port_tm_mark_ip_dscp_set,
		(void *)&cmd_port_tm_mark_ip_dscp_port,
		(void *)&cmd_port_tm_mark_ip_dscp_tm,
		(void *)&cmd_port_tm_mark_ip_dscp_mark,
		(void *)&cmd_port_tm_mark_ip_dscp_ip_dscp,
		(void *)&cmd_port_tm_mark_ip_dscp_port_id,
		(void *)&cmd_port_tm_mark_ip_dscp_green,
		(void *)&cmd_port_tm_mark_ip_dscp_yellow,
		(void *)&cmd_port_tm_mark_ip_dscp_red,
		NULL,
	},
};


/* *** Port TM Mark VLAN_DEI *** */
struct cmd_port_tm_mark_vlan_dei_result {
	cmdline_fixed_string_t set;
	cmdline_fixed_string_t port;
	cmdline_fixed_string_t tm;
	cmdline_fixed_string_t mark;
	cmdline_fixed_string_t vlan_dei;
	uint16_t port_id;
	uint16_t green;
	uint16_t yellow;
	uint16_t red;
};

static cmdline_parse_token_string_t cmd_port_tm_mark_vlan_dei_set =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				 set, "set");

static cmdline_parse_token_string_t cmd_port_tm_mark_vlan_dei_port =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				 port, "port");

static cmdline_parse_token_string_t cmd_port_tm_mark_vlan_dei_tm =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result, tm,
				 "tm");

static cmdline_parse_token_string_t cmd_port_tm_mark_vlan_dei_mark =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				 mark, "mark");

static cmdline_parse_token_string_t cmd_port_tm_mark_vlan_dei_vlan_dei =
	TOKEN_STRING_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				 vlan_dei, "vlan_dei");
static cmdline_parse_token_num_t cmd_port_tm_mark_vlan_dei_port_id =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
			      port_id, RTE_UINT16);

static cmdline_parse_token_num_t cmd_port_tm_mark_vlan_dei_green =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				green, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_vlan_dei_yellow =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				yellow, RTE_UINT16);
static cmdline_parse_token_num_t cmd_port_tm_mark_vlan_dei_red =
	TOKEN_NUM_INITIALIZER(struct cmd_port_tm_mark_vlan_dei_result,
				red, RTE_UINT16);

static void cmd_port_tm_mark_vlan_dei_parsed(void *parsed_result,
	__rte_unused struct cmdline *cl,
	__rte_unused void *data)
{
	struct cmd_port_tm_mark_vlan_dei_result *res = parsed_result;
	struct rte_tm_error error;
	portid_t port_id = res->port_id;
	int green = res->green;
	int yellow = res->yellow;
	int red = res->red;
	int ret;
	if (port_id_is_invalid(port_id, ENABLED_WARN))
		return;

	memset(&error, 0, sizeof(struct rte_tm_error));
	ret = rte_tm_mark_vlan_dei(port_id, green, yellow, red, &error);
	if (ret != 0) {
		print_err_msg(&error);
		return;
	}
}

cmdline_parse_inst_t cmd_port_tm_mark_vlan_dei = {
	.f = cmd_port_tm_mark_vlan_dei_parsed,
	.data = NULL,
	.help_str = "set port tm mark vlan_dei <port> <green> <yellow> <red>",
	.tokens = {
		(void *)&cmd_port_tm_mark_vlan_dei_set,
		(void *)&cmd_port_tm_mark_vlan_dei_port,
		(void *)&cmd_port_tm_mark_vlan_dei_tm,
		(void *)&cmd_port_tm_mark_vlan_dei_mark,
		(void *)&cmd_port_tm_mark_vlan_dei_vlan_dei,
		(void *)&cmd_port_tm_mark_vlan_dei_port_id,
		(void *)&cmd_port_tm_mark_vlan_dei_green,
		(void *)&cmd_port_tm_mark_vlan_dei_yellow,
		(void *)&cmd_port_tm_mark_vlan_dei_red,
		NULL,
	},
};