app/testpmd: support cleanup Tx queue mbufs
[dpdk.git] / app / test-pmd / cmdline.c
index b338f5f..62caf70 100644 (file)
@@ -163,7 +163,7 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "Display:\n"
                        "--------\n\n"
 
-                       "show port (info|stats|summary|xstats|fdir|dcb_tc|cap) (port_id|all)\n"
+                       "show port (info|stats|summary|xstats|fdir|dcb_tc) (port_id|all)\n"
                        "    Display information for port_id, or all.\n\n"
 
                        "show port port_id (module_eeprom|eeprom)\n"
@@ -246,6 +246,10 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "show port (port_id) rxq|txq (queue_id) desc (desc_id) status"
                        "       Show status of rx|tx descriptor.\n\n"
 
+                       "show port (port_id) rxq (queue_id) desc used count\n"
+                       "    Show current number of filled receive"
+                       " packet descriptors.\n\n"
+
                        "show port (port_id) macs|mcast_macs"
                        "       Display list of mac addresses added to port.\n\n"
 
@@ -689,21 +693,20 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "show port meter cap (port_id)\n"
                        "    Show port meter capability information\n\n"
 
-                       "add port meter profile srtcm_rfc2697 (port_id) (profile_id) (cir) (cbs) (ebs)\n"
+                       "add port meter profile srtcm_rfc2697 (port_id) (profile_id) (cir) (cbs) (ebs) (packet_mode)\n"
                        "    meter profile add - srtcm rfc 2697\n\n"
 
-                       "add port meter profile trtcm_rfc2698 (port_id) (profile_id) (cir) (pir) (cbs) (pbs)\n"
+                       "add port meter profile trtcm_rfc2698 (port_id) (profile_id) (cir) (pir) (cbs) (pbs) (packet_mode)\n"
                        "    meter profile add - trtcm rfc 2698\n\n"
 
-                       "add port meter profile trtcm_rfc4115 (port_id) (profile_id) (cir) (eir) (cbs) (ebs)\n"
+                       "add port meter profile trtcm_rfc4115 (port_id) (profile_id) (cir) (eir) (cbs) (ebs) (packet_mode)\n"
                        "    meter profile add - trtcm rfc 4115\n\n"
 
                        "del port meter profile (port_id) (profile_id)\n"
                        "    meter profile delete\n\n"
 
-                       "create port meter (port_id) (mtr_id) (profile_id) (meter_enable)\n"
-                       "(g_action) (y_action) (r_action) (stats_mask) (shared)\n"
-                       "(use_pre_meter_color) [(dscp_tbl_entry0) (dscp_tbl_entry1)...\n"
+                       "create port meter (port_id) (mtr_id) (profile_id) (policy_id) (meter_enable)\n"
+                       "(stats_mask) (shared) (use_pre_meter_color) [(dscp_tbl_entry0) (dscp_tbl_entry1)...\n"
                        "(dscp_tbl_entry63)]\n"
                        "    meter create\n\n"
 
@@ -716,6 +719,13 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "del port meter (port_id) (mtr_id)\n"
                        "    meter delete\n\n"
 
+                       "add port meter policy (port_id) (policy_id) g_actions (actions)\n"
+                       "y_actions (actions) r_actions (actions)\n"
+                       "    meter policy add\n\n"
+
+                       "del port meter policy (port_id) (policy_id)\n"
+                       "    meter policy delete\n\n"
+
                        "set port meter profile (port_id) (mtr_id) (profile_id)\n"
                        "    meter update meter profile\n\n"
 
@@ -898,6 +908,9 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "    Register a dynf and Set/clear this flag on Tx. "
                        "Testpmd will set this value to any Tx packet "
                        "sent from this port\n\n"
+
+                       "port cleanup (port_id) txq (queue_id) (free_cnt)\n"
+                       "    Cleanup txq mbufs for a specific Tx queue\n\n"
                );
        }
 
@@ -998,23 +1011,23 @@ static void cmd_help_long_parsed(void *parsed_result,
                        "    List and destroy aged flows"
                        " flow rules\n\n"
 
-                       "flow shared_action {port_id} create"
-                       " [action_id {shared_action_id}]"
+                       "flow indirect_action {port_id} create"
+                       " [action_id {indirect_action_id}]"
                        " [ingress] [egress]"
                        " action {action} / end\n"
-                       "    Create shared action.\n\n"
+                       "    Create indirect action.\n\n"
 
-                       "flow shared_action {port_id} update"
-                       " {shared_action_id} action {action} / end\n"
-                       "    Update shared action.\n\n"
+                       "flow indirect_action {port_id} update"
+                       " {indirect_action_id} action {action} / end\n"
+                       "    Update indirect action.\n\n"
 
-                       "flow shared_action {port_id} destroy"
-                       " action_id {shared_action_id} [...]\n"
-                       "    Destroy specific shared actions.\n\n"
+                       "flow indirect_action {port_id} destroy"
+                       " action_id {indirect_action_id} [...]\n"
+                       "    Destroy specific indirect actions.\n\n"
 
-                       "flow shared_action {port_id} query"
-                       " {shared_action_id}\n"
-                       "    Query an existing shared action.\n\n"
+                       "flow indirect_action {port_id} query"
+                       " {indirect_action_id}\n"
+                       "    Query an existing indirect action.\n\n"
 
                        "set vxlan ip-version (ipv4|ipv6) vni (vni) udp-src"
                        " (udp-src) udp-dst (udp-dst) ip-src (ip-src) ip-dst"
@@ -1521,6 +1534,9 @@ parse_and_check_speed_duplex(char *speedstr, char *duplexstr, uint32_t *speed)
                }
        }
 
+       if (*speed != ETH_LINK_SPEED_AUTONEG)
+               *speed |= ETH_LINK_SPEED_FIXED;
+
        return 0;
 }
 
@@ -2419,7 +2435,7 @@ cmdline_parse_token_string_t cmd_config_rss_hash_key_rss_type =
                                 "ipv6-tcp-ex#ipv6-udp-ex#"
                                 "l3-src-only#l3-dst-only#l4-src-only#l4-dst-only#"
                                 "l2-src-only#l2-dst-only#s-vlan#c-vlan#"
-                                "l2tpv3#esp#ah#pfcp#pppoe#gtpu#ecpri");
+                                "l2tpv3#esp#ah#pfcp#pppoe#gtpu#ecpri#mpls");
 cmdline_parse_token_string_t cmd_config_rss_hash_key_value =
        TOKEN_STRING_INITIALIZER(struct cmd_config_rss_hash_key, key, NULL);
 
@@ -2432,7 +2448,7 @@ cmdline_parse_inst_t cmd_config_rss_hash_key = {
                "l2-payload|ipv6-ex|ipv6-tcp-ex|ipv6-udp-ex|"
                "l3-src-only|l3-dst-only|l4-src-only|l4-dst-only|"
                "l2-src-only|l2-dst-only|s-vlan|c-vlan|"
-               "l2tpv3|esp|ah|pfcp|pppoe|gtpu|ecpri "
+               "l2tpv3|esp|ah|pfcp|pppoe|gtpu|ecpri|mpls "
                "<string of hex digits (variable length, NIC dependent)>",
        .tokens = {
                (void *)&cmd_config_rss_hash_key_port,
@@ -2445,6 +2461,90 @@ cmdline_parse_inst_t cmd_config_rss_hash_key = {
        },
 };
 
+/* *** cleanup txq mbufs *** */
+struct cmd_cleanup_txq_mbufs_result {
+       cmdline_fixed_string_t port;
+       cmdline_fixed_string_t keyword;
+       cmdline_fixed_string_t name;
+       uint16_t port_id;
+       uint16_t queue_id;
+       uint32_t free_cnt;
+};
+
+static void
+cmd_cleanup_txq_mbufs_parsed(void *parsed_result,
+                            __rte_unused struct cmdline *cl,
+                            __rte_unused void *data)
+{
+       struct cmd_cleanup_txq_mbufs_result *res = parsed_result;
+       uint16_t port_id = res->port_id;
+       uint16_t queue_id = res->queue_id;
+       uint32_t free_cnt = res->free_cnt;
+       struct rte_eth_txq_info qinfo;
+       int ret;
+
+       if (test_done == 0) {
+               printf("Please stop forwarding first\n");
+               return;
+       }
+
+       if (rte_eth_tx_queue_info_get(port_id, queue_id, &qinfo)) {
+               printf("Failed to get port %u Tx queue %u info\n",
+                      port_id, queue_id);
+               return;
+       }
+
+       if (qinfo.queue_state != RTE_ETH_QUEUE_STATE_STARTED) {
+               printf("Tx queue %u not started\n", queue_id);
+               return;
+       }
+
+       ret = rte_eth_tx_done_cleanup(port_id, queue_id, free_cnt);
+       if (ret < 0) {
+               printf("Failed to cleanup mbuf for port %u Tx queue %u "
+                      "error desc: %s(%d)\n",
+                      port_id, queue_id, strerror(-ret), ret);
+               return;
+       }
+
+       printf("Cleanup port %u Tx queue %u mbuf nums: %u\n",
+              port_id, queue_id, ret);
+}
+
+cmdline_parse_token_string_t cmd_cleanup_txq_mbufs_port =
+       TOKEN_STRING_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, port,
+                                "port");
+cmdline_parse_token_string_t cmd_cleanup_txq_mbufs_cleanup =
+       TOKEN_STRING_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, keyword,
+                                "cleanup");
+cmdline_parse_token_num_t cmd_cleanup_txq_mbufs_port_id =
+       TOKEN_NUM_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, port_id,
+                             RTE_UINT16);
+cmdline_parse_token_string_t cmd_cleanup_txq_mbufs_txq =
+       TOKEN_STRING_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, name,
+                                "txq");
+cmdline_parse_token_num_t cmd_cleanup_txq_mbufs_queue_id =
+       TOKEN_NUM_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, queue_id,
+                             RTE_UINT16);
+cmdline_parse_token_num_t cmd_cleanup_txq_mbufs_free_cnt =
+       TOKEN_NUM_INITIALIZER(struct cmd_cleanup_txq_mbufs_result, free_cnt,
+                             RTE_UINT32);
+
+cmdline_parse_inst_t cmd_cleanup_txq_mbufs = {
+       .f = cmd_cleanup_txq_mbufs_parsed,
+       .data = NULL,
+       .help_str = "port cleanup <port_id> txq <queue_id> <free_cnt>",
+       .tokens = {
+               (void *)&cmd_cleanup_txq_mbufs_port,
+               (void *)&cmd_cleanup_txq_mbufs_cleanup,
+               (void *)&cmd_cleanup_txq_mbufs_port_id,
+               (void *)&cmd_cleanup_txq_mbufs_txq,
+               (void *)&cmd_cleanup_txq_mbufs_queue_id,
+               (void *)&cmd_cleanup_txq_mbufs_free_cnt,
+               NULL,
+       },
+};
+
 /* *** configure port rxq/txq ring size *** */
 struct cmd_config_rxtx_ring_size {
        cmdline_fixed_string_t port;
@@ -3791,6 +3891,7 @@ cmd_set_rxoffs_parsed(void *parsed_result,
                                  MAX_SEGS_BUFFER_SPLIT, seg_offsets, 0);
        if (nb_segs > 0)
                set_rx_pkt_offsets(seg_offsets, nb_segs);
+       cmd_reconfig_device_queue(RTE_PORT_ALL, 0, 1);
 }
 
 cmdline_parse_token_string_t cmd_set_rxoffs_keyword =
@@ -3837,6 +3938,7 @@ cmd_set_rxpkts_parsed(void *parsed_result,
                                  MAX_SEGS_BUFFER_SPLIT, seg_lengths, 0);
        if (nb_segs > 0)
                set_rx_pkt_segments(seg_lengths, nb_segs);
+       cmd_reconfig_device_queue(RTE_PORT_ALL, 0, 1);
 }
 
 cmdline_parse_token_string_t cmd_set_rxpkts_keyword =
@@ -7567,9 +7669,6 @@ static void cmd_showportall_parsed(void *parsed_result,
        else if (!strcmp(res->what, "dcb_tc"))
                RTE_ETH_FOREACH_DEV(i)
                        port_dcb_info_display(i);
-       else if (!strcmp(res->what, "cap"))
-               RTE_ETH_FOREACH_DEV(i)
-                       port_offload_cap_display(i);
 }
 
 cmdline_parse_token_string_t cmd_showportall_show =
@@ -7579,14 +7678,14 @@ cmdline_parse_token_string_t cmd_showportall_port =
        TOKEN_STRING_INITIALIZER(struct cmd_showportall_result, port, "port");
 cmdline_parse_token_string_t cmd_showportall_what =
        TOKEN_STRING_INITIALIZER(struct cmd_showportall_result, what,
-                                "info#summary#stats#xstats#fdir#dcb_tc#cap");
+                                "info#summary#stats#xstats#fdir#dcb_tc");
 cmdline_parse_token_string_t cmd_showportall_all =
        TOKEN_STRING_INITIALIZER(struct cmd_showportall_result, all, "all");
 cmdline_parse_inst_t cmd_showportall = {
        .f = cmd_showportall_parsed,
        .data = NULL,
        .help_str = "show|clear port "
-               "info|summary|stats|xstats|fdir|dcb_tc|cap all",
+               "info|summary|stats|xstats|fdir|dcb_tc all",
        .tokens = {
                (void *)&cmd_showportall_show,
                (void *)&cmd_showportall_port,
@@ -7630,8 +7729,6 @@ static void cmd_showport_parsed(void *parsed_result,
 #endif
        else if (!strcmp(res->what, "dcb_tc"))
                port_dcb_info_display(res->portnum);
-       else if (!strcmp(res->what, "cap"))
-               port_offload_cap_display(res->portnum);
 }
 
 cmdline_parse_token_string_t cmd_showport_show =
@@ -7641,7 +7738,7 @@ cmdline_parse_token_string_t cmd_showport_port =
        TOKEN_STRING_INITIALIZER(struct cmd_showport_result, port, "port");
 cmdline_parse_token_string_t cmd_showport_what =
        TOKEN_STRING_INITIALIZER(struct cmd_showport_result, what,
-                                "info#summary#stats#xstats#fdir#dcb_tc#cap");
+                                "info#summary#stats#xstats#fdir#dcb_tc");
 cmdline_parse_token_num_t cmd_showport_portnum =
        TOKEN_NUM_INITIALIZER(struct cmd_showport_result, portnum, RTE_UINT16);
 
@@ -7649,7 +7746,7 @@ cmdline_parse_inst_t cmd_showport = {
        .f = cmd_showport_parsed,
        .data = NULL,
        .help_str = "show|clear port "
-               "info|summary|stats|xstats|fdir|dcb_tc|cap "
+               "info|summary|stats|xstats|fdir|dcb_tc "
                "<port_id>",
        .tokens = {
                (void *)&cmd_showport_show,
@@ -9096,7 +9193,7 @@ cmdline_parse_inst_t cmd_vf_rate_limit = {
 
 /* *** CONFIGURE TUNNEL UDP PORT *** */
 struct cmd_tunnel_udp_config {
-       cmdline_fixed_string_t cmd;
+       cmdline_fixed_string_t rx_vxlan_port;
        cmdline_fixed_string_t what;
        uint16_t udp_port;
        portid_t port_id;
@@ -9112,9 +9209,7 @@ cmd_tunnel_udp_config_parsed(void *parsed_result,
        int ret;
 
        tunnel_udp.udp_port = res->udp_port;
-
-       if (!strcmp(res->cmd, "rx_vxlan_port"))
-               tunnel_udp.prot_type = RTE_TUNNEL_TYPE_VXLAN;
+       tunnel_udp.prot_type = RTE_TUNNEL_TYPE_VXLAN;
 
        if (!strcmp(res->what, "add"))
                ret = rte_eth_dev_udp_tunnel_port_add(res->port_id,
@@ -9127,9 +9222,9 @@ cmd_tunnel_udp_config_parsed(void *parsed_result,
                printf("udp tunneling add error: (%s)\n", strerror(-ret));
 }
 
-cmdline_parse_token_string_t cmd_tunnel_udp_config_cmd =
+cmdline_parse_token_string_t cmd_tunnel_udp_config_rx_vxlan_port =
        TOKEN_STRING_INITIALIZER(struct cmd_tunnel_udp_config,
-                               cmd, "rx_vxlan_port");
+                               rx_vxlan_port, "rx_vxlan_port");
 cmdline_parse_token_string_t cmd_tunnel_udp_config_what =
        TOKEN_STRING_INITIALIZER(struct cmd_tunnel_udp_config,
                                what, "add#rm");
@@ -9146,7 +9241,7 @@ cmdline_parse_inst_t cmd_tunnel_udp_config = {
        .help_str = "rx_vxlan_port add|rm <udp_port> <port_id>: "
                "Add/Remove a tunneling UDP port filter",
        .tokens = {
-               (void *)&cmd_tunnel_udp_config_cmd,
+               (void *)&cmd_tunnel_udp_config_rx_vxlan_port,
                (void *)&cmd_tunnel_udp_config_what,
                (void *)&cmd_tunnel_udp_config_udp_port,
                (void *)&cmd_tunnel_udp_config_port_id,
@@ -13619,6 +13714,359 @@ cmdline_parse_inst_t cmd_set_mplsoudp_decap_with_vlan = {
        },
 };
 
+/** Set connection tracking object common details */
+struct cmd_set_conntrack_common_result {
+       cmdline_fixed_string_t set;
+       cmdline_fixed_string_t conntrack;
+       cmdline_fixed_string_t common;
+       cmdline_fixed_string_t peer;
+       cmdline_fixed_string_t is_orig;
+       cmdline_fixed_string_t enable;
+       cmdline_fixed_string_t live;
+       cmdline_fixed_string_t sack;
+       cmdline_fixed_string_t cack;
+       cmdline_fixed_string_t last_dir;
+       cmdline_fixed_string_t liberal;
+       cmdline_fixed_string_t state;
+       cmdline_fixed_string_t max_ack_win;
+       cmdline_fixed_string_t retrans;
+       cmdline_fixed_string_t last_win;
+       cmdline_fixed_string_t last_seq;
+       cmdline_fixed_string_t last_ack;
+       cmdline_fixed_string_t last_end;
+       cmdline_fixed_string_t last_index;
+       uint8_t stat;
+       uint8_t factor;
+       uint16_t peer_port;
+       uint32_t is_original;
+       uint32_t en;
+       uint32_t is_live;
+       uint32_t s_ack;
+       uint32_t c_ack;
+       uint32_t ld;
+       uint32_t lb;
+       uint8_t re_num;
+       uint8_t li;
+       uint16_t lw;
+       uint32_t ls;
+       uint32_t la;
+       uint32_t le;
+};
+
+cmdline_parse_token_string_t cmd_set_conntrack_set =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                set, "set");
+cmdline_parse_token_string_t cmd_set_conntrack_conntrack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                conntrack, "conntrack");
+cmdline_parse_token_string_t cmd_set_conntrack_common_com =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                common, "com");
+cmdline_parse_token_string_t cmd_set_conntrack_common_peer =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                peer, "peer");
+cmdline_parse_token_num_t cmd_set_conntrack_common_peer_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             peer_port, RTE_UINT16);
+cmdline_parse_token_string_t cmd_set_conntrack_common_is_orig =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                is_orig, "is_orig");
+cmdline_parse_token_num_t cmd_set_conntrack_common_is_orig_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             is_original, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_enable =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                enable, "enable");
+cmdline_parse_token_num_t cmd_set_conntrack_common_enable_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             en, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_live =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                live, "live");
+cmdline_parse_token_num_t cmd_set_conntrack_common_live_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             is_live, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_sack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                sack, "sack");
+cmdline_parse_token_num_t cmd_set_conntrack_common_sack_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             s_ack, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_cack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                cack, "cack");
+cmdline_parse_token_num_t cmd_set_conntrack_common_cack_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             c_ack, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_dir =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_dir, "last_dir");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_dir_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             ld, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_liberal =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                liberal, "liberal");
+cmdline_parse_token_num_t cmd_set_conntrack_common_liberal_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             lb, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_state =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                state, "state");
+cmdline_parse_token_num_t cmd_set_conntrack_common_state_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             stat, RTE_UINT8);
+cmdline_parse_token_string_t cmd_set_conntrack_common_max_ackwin =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                max_ack_win, "max_ack_win");
+cmdline_parse_token_num_t cmd_set_conntrack_common_max_ackwin_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             factor, RTE_UINT8);
+cmdline_parse_token_string_t cmd_set_conntrack_common_retrans =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                retrans, "r_lim");
+cmdline_parse_token_num_t cmd_set_conntrack_common_retrans_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             re_num, RTE_UINT8);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_win =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_win, "last_win");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_win_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             lw, RTE_UINT16);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_seq =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_seq, "last_seq");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_seq_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             ls, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_ack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_ack, "last_ack");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_ack_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             la, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_end =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_end, "last_end");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_end_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             le, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_common_last_index =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_common_result,
+                                last_index, "last_index");
+cmdline_parse_token_num_t cmd_set_conntrack_common_last_index_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_common_result,
+                             li, RTE_UINT8);
+
+static void cmd_set_conntrack_common_parsed(void *parsed_result,
+       __rte_unused struct cmdline *cl,
+       __rte_unused void *data)
+{
+       struct cmd_set_conntrack_common_result *res = parsed_result;
+
+       /* No need to swap to big endian. */
+       conntrack_context.peer_port = res->peer_port;
+       conntrack_context.is_original_dir = res->is_original;
+       conntrack_context.enable = res->en;
+       conntrack_context.live_connection = res->is_live;
+       conntrack_context.selective_ack = res->s_ack;
+       conntrack_context.challenge_ack_passed = res->c_ack;
+       conntrack_context.last_direction = res->ld;
+       conntrack_context.liberal_mode = res->lb;
+       conntrack_context.state = (enum rte_flow_conntrack_state)res->stat;
+       conntrack_context.max_ack_window = res->factor;
+       conntrack_context.retransmission_limit = res->re_num;
+       conntrack_context.last_window = res->lw;
+       conntrack_context.last_index =
+               (enum rte_flow_conntrack_tcp_last_index)res->li;
+       conntrack_context.last_seq = res->ls;
+       conntrack_context.last_ack = res->la;
+       conntrack_context.last_end = res->le;
+}
+
+cmdline_parse_inst_t cmd_set_conntrack_common = {
+       .f = cmd_set_conntrack_common_parsed,
+       .data = NULL,
+       .help_str = "set conntrack com peer <port_id> is_orig <dir> enable <en>"
+               " live <ack_seen> sack <en> cack <passed> last_dir <dir>"
+               " liberal <en> state <s> max_ack_win <factor> r_lim <num>"
+               " last_win <win> last_seq <seq> last_ack <ack> last_end <end>"
+               " last_index <flag>",
+       .tokens = {
+               (void *)&cmd_set_conntrack_set,
+               (void *)&cmd_set_conntrack_conntrack,
+               (void *)&cmd_set_conntrack_common_com,
+               (void *)&cmd_set_conntrack_common_peer,
+               (void *)&cmd_set_conntrack_common_peer_value,
+               (void *)&cmd_set_conntrack_common_is_orig,
+               (void *)&cmd_set_conntrack_common_is_orig_value,
+               (void *)&cmd_set_conntrack_common_enable,
+               (void *)&cmd_set_conntrack_common_enable_value,
+               (void *)&cmd_set_conntrack_common_live,
+               (void *)&cmd_set_conntrack_common_live_value,
+               (void *)&cmd_set_conntrack_common_sack,
+               (void *)&cmd_set_conntrack_common_sack_value,
+               (void *)&cmd_set_conntrack_common_cack,
+               (void *)&cmd_set_conntrack_common_cack_value,
+               (void *)&cmd_set_conntrack_common_last_dir,
+               (void *)&cmd_set_conntrack_common_last_dir_value,
+               (void *)&cmd_set_conntrack_common_liberal,
+               (void *)&cmd_set_conntrack_common_liberal_value,
+               (void *)&cmd_set_conntrack_common_state,
+               (void *)&cmd_set_conntrack_common_state_value,
+               (void *)&cmd_set_conntrack_common_max_ackwin,
+               (void *)&cmd_set_conntrack_common_max_ackwin_value,
+               (void *)&cmd_set_conntrack_common_retrans,
+               (void *)&cmd_set_conntrack_common_retrans_value,
+               (void *)&cmd_set_conntrack_common_last_win,
+               (void *)&cmd_set_conntrack_common_last_win_value,
+               (void *)&cmd_set_conntrack_common_last_seq,
+               (void *)&cmd_set_conntrack_common_last_seq_value,
+               (void *)&cmd_set_conntrack_common_last_ack,
+               (void *)&cmd_set_conntrack_common_last_ack_value,
+               (void *)&cmd_set_conntrack_common_last_end,
+               (void *)&cmd_set_conntrack_common_last_end_value,
+               (void *)&cmd_set_conntrack_common_last_index,
+               (void *)&cmd_set_conntrack_common_last_index_value,
+               NULL,
+       },
+};
+
+/** Set connection tracking object both directions' details */
+struct cmd_set_conntrack_dir_result {
+       cmdline_fixed_string_t set;
+       cmdline_fixed_string_t conntrack;
+       cmdline_fixed_string_t dir;
+       cmdline_fixed_string_t scale;
+       cmdline_fixed_string_t fin;
+       cmdline_fixed_string_t ack_seen;
+       cmdline_fixed_string_t unack;
+       cmdline_fixed_string_t sent_end;
+       cmdline_fixed_string_t reply_end;
+       cmdline_fixed_string_t max_win;
+       cmdline_fixed_string_t max_ack;
+       uint32_t factor;
+       uint32_t f;
+       uint32_t as;
+       uint32_t un;
+       uint32_t se;
+       uint32_t re;
+       uint32_t mw;
+       uint32_t ma;
+};
+
+cmdline_parse_token_string_t cmd_set_conntrack_dir_set =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                set, "set");
+cmdline_parse_token_string_t cmd_set_conntrack_dir_conntrack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                conntrack, "conntrack");
+cmdline_parse_token_string_t cmd_set_conntrack_dir_dir =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                dir, "orig#rply");
+cmdline_parse_token_string_t cmd_set_conntrack_dir_scale =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                scale, "scale");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_scale_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             factor, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_fin =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                fin, "fin");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_fin_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             f, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_ack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                ack_seen, "acked");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_ack_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             as, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_unack_data =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                unack, "unack_data");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_unack_data_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             un, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_sent_end =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                sent_end, "sent_end");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_sent_end_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             se, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_reply_end =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                reply_end, "reply_end");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_reply_end_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             re, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_max_win =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                max_win, "max_win");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_max_win_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             mw, RTE_UINT32);
+cmdline_parse_token_string_t cmd_set_conntrack_dir_max_ack =
+       TOKEN_STRING_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                                max_ack, "max_ack");
+cmdline_parse_token_num_t cmd_set_conntrack_dir_max_ack_value =
+       TOKEN_NUM_INITIALIZER(struct cmd_set_conntrack_dir_result,
+                             ma, RTE_UINT32);
+
+static void cmd_set_conntrack_dir_parsed(void *parsed_result,
+       __rte_unused struct cmdline *cl,
+       __rte_unused void *data)
+{
+       struct cmd_set_conntrack_dir_result *res = parsed_result;
+       struct rte_flow_tcp_dir_param *dir = NULL;
+
+       if (strcmp(res->dir, "orig") == 0)
+               dir = &conntrack_context.original_dir;
+       else if (strcmp(res->dir, "rply") == 0)
+               dir = &conntrack_context.reply_dir;
+       else
+               return;
+       dir->scale = res->factor;
+       dir->close_initiated = res->f;
+       dir->last_ack_seen = res->as;
+       dir->data_unacked = res->un;
+       dir->sent_end = res->se;
+       dir->reply_end = res->re;
+       dir->max_ack = res->ma;
+       dir->max_win = res->mw;
+}
+
+cmdline_parse_inst_t cmd_set_conntrack_dir = {
+       .f = cmd_set_conntrack_dir_parsed,
+       .data = NULL,
+       .help_str = "set conntrack orig|rply scale <factor> fin <sent>"
+                   " acked <seen> unack_data <unack> sent_end <sent>"
+                   " reply_end <reply> max_win <win> max_ack <ack>",
+       .tokens = {
+               (void *)&cmd_set_conntrack_set,
+               (void *)&cmd_set_conntrack_conntrack,
+               (void *)&cmd_set_conntrack_dir_dir,
+               (void *)&cmd_set_conntrack_dir_scale,
+               (void *)&cmd_set_conntrack_dir_scale_value,
+               (void *)&cmd_set_conntrack_dir_fin,
+               (void *)&cmd_set_conntrack_dir_fin_value,
+               (void *)&cmd_set_conntrack_dir_ack,
+               (void *)&cmd_set_conntrack_dir_ack_value,
+               (void *)&cmd_set_conntrack_dir_unack_data,
+               (void *)&cmd_set_conntrack_dir_unack_data_value,
+               (void *)&cmd_set_conntrack_dir_sent_end,
+               (void *)&cmd_set_conntrack_dir_sent_end_value,
+               (void *)&cmd_set_conntrack_dir_reply_end,
+               (void *)&cmd_set_conntrack_dir_reply_end_value,
+               (void *)&cmd_set_conntrack_dir_max_win,
+               (void *)&cmd_set_conntrack_dir_max_win_value,
+               (void *)&cmd_set_conntrack_dir_max_ack,
+               (void *)&cmd_set_conntrack_dir_max_ack_value,
+               NULL,
+       },
+};
+
 /* Strict link priority scheduling mode setting */
 static void
 cmd_strict_link_prio_parsed(
@@ -16630,7 +17078,8 @@ cmd_show_rx_tx_desc_status_parsed(void *parsed_result,
                rc = rte_eth_rx_descriptor_status(res->cmd_pid, res->cmd_qid,
                                             res->cmd_did);
                if (rc < 0) {
-                       printf("Invalid queueid = %d\n", res->cmd_qid);
+                       printf("Invalid input: queue id = %d, desc id = %d\n",
+                              res->cmd_qid, res->cmd_did);
                        return;
                }
                if (rc == RTE_ETH_RX_DESC_AVAIL)
@@ -16643,7 +17092,8 @@ cmd_show_rx_tx_desc_status_parsed(void *parsed_result,
                rc = rte_eth_tx_descriptor_status(res->cmd_pid, res->cmd_qid,
                                             res->cmd_did);
                if (rc < 0) {
-                       printf("Invalid queueid = %d\n", res->cmd_qid);
+                       printf("Invalid input: queue id = %d, desc id = %d\n",
+                              res->cmd_qid, res->cmd_did);
                        return;
                }
                if (rc == RTE_ETH_TX_DESC_FULL)
@@ -16697,6 +17147,88 @@ cmdline_parse_inst_t cmd_show_rx_tx_desc_status = {
        },
 };
 
+/* *** display rx queue desc used count *** */
+struct cmd_show_rx_queue_desc_used_count_result {
+       cmdline_fixed_string_t cmd_show;
+       cmdline_fixed_string_t cmd_port;
+       cmdline_fixed_string_t cmd_rxq;
+       cmdline_fixed_string_t cmd_desc;
+       cmdline_fixed_string_t cmd_used;
+       cmdline_fixed_string_t cmd_count;
+       portid_t cmd_pid;
+       portid_t cmd_qid;
+};
+
+static void
+cmd_show_rx_queue_desc_used_count_parsed(void *parsed_result,
+               __rte_unused struct cmdline *cl,
+               __rte_unused void *data)
+{
+       struct cmd_show_rx_queue_desc_used_count_result *res = parsed_result;
+       int rc;
+
+       if (!rte_eth_dev_is_valid_port(res->cmd_pid)) {
+               printf("invalid port id %u\n", res->cmd_pid);
+               return;
+       }
+
+       rc = rte_eth_rx_queue_count(res->cmd_pid, res->cmd_qid);
+       if (rc < 0) {
+               printf("Invalid queueid = %d\n", res->cmd_qid);
+               return;
+       }
+       printf("Used desc count = %d\n", rc);
+}
+
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_show =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_show, "show");
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_port =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_port, "port");
+cmdline_parse_token_num_t cmd_show_rx_queue_desc_used_count_pid =
+       TOKEN_NUM_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_pid, RTE_UINT16);
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_rxq =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_rxq, "rxq");
+cmdline_parse_token_num_t cmd_show_rx_queue_desc_used_count_qid =
+       TOKEN_NUM_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_qid, RTE_UINT16);
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_desc =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_count, "desc");
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_used =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_count, "used");
+cmdline_parse_token_string_t cmd_show_rx_queue_desc_used_count_count =
+       TOKEN_STRING_INITIALIZER
+               (struct cmd_show_rx_queue_desc_used_count_result,
+                cmd_count, "count");
+cmdline_parse_inst_t cmd_show_rx_queue_desc_used_count = {
+       .f = cmd_show_rx_queue_desc_used_count_parsed,
+       .data = NULL,
+       .help_str = "show port <port_id> rxq <queue_id> desc used count",
+       .tokens = {
+               (void *)&cmd_show_rx_queue_desc_used_count_show,
+               (void *)&cmd_show_rx_queue_desc_used_count_port,
+               (void *)&cmd_show_rx_queue_desc_used_count_pid,
+               (void *)&cmd_show_rx_queue_desc_used_count_rxq,
+               (void *)&cmd_show_rx_queue_desc_used_count_qid,
+               (void *)&cmd_show_rx_queue_desc_used_count_desc,
+               (void *)&cmd_show_rx_queue_desc_used_count_used,
+               (void *)&cmd_show_rx_queue_desc_used_count_count,
+               NULL,
+       },
+};
+
 /* Common result structure for set port ptypes */
 struct cmd_set_port_ptypes_result {
        cmdline_fixed_string_t set;
@@ -16968,6 +17500,7 @@ cmdline_parse_ctx_t main_ctx[] = {
        (cmdline_parse_inst_t *)&cmd_showport_rss_hash,
        (cmdline_parse_inst_t *)&cmd_showport_rss_hash_key,
        (cmdline_parse_inst_t *)&cmd_config_rss_hash_key,
+       (cmdline_parse_inst_t *)&cmd_cleanup_txq_mbufs,
        (cmdline_parse_inst_t *)&cmd_dump,
        (cmdline_parse_inst_t *)&cmd_dump_one,
 #ifdef RTE_NET_I40E
@@ -16986,9 +17519,9 @@ cmdline_parse_ctx_t main_ctx[] = {
        (cmdline_parse_inst_t *)&cmd_enable_port_meter,
        (cmdline_parse_inst_t *)&cmd_disable_port_meter,
        (cmdline_parse_inst_t *)&cmd_del_port_meter,
+       (cmdline_parse_inst_t *)&cmd_del_port_meter_policy,
        (cmdline_parse_inst_t *)&cmd_set_port_meter_profile,
        (cmdline_parse_inst_t *)&cmd_set_port_meter_dscp_table,
-       (cmdline_parse_inst_t *)&cmd_set_port_meter_policer_action,
        (cmdline_parse_inst_t *)&cmd_set_port_meter_stats_mask,
        (cmdline_parse_inst_t *)&cmd_show_port_meter_stats,
        (cmdline_parse_inst_t *)&cmd_mcast_addr,
@@ -17034,6 +17567,8 @@ cmdline_parse_ctx_t main_ctx[] = {
        (cmdline_parse_inst_t *)&cmd_set_mplsoudp_encap_with_vlan,
        (cmdline_parse_inst_t *)&cmd_set_mplsoudp_decap,
        (cmdline_parse_inst_t *)&cmd_set_mplsoudp_decap_with_vlan,
+       (cmdline_parse_inst_t *)&cmd_set_conntrack_common,
+       (cmdline_parse_inst_t *)&cmd_set_conntrack_dir,
        (cmdline_parse_inst_t *)&cmd_ddp_add,
        (cmdline_parse_inst_t *)&cmd_ddp_del,
        (cmdline_parse_inst_t *)&cmd_ddp_get_list,
@@ -17096,6 +17631,7 @@ cmdline_parse_ctx_t main_ctx[] = {
        (cmdline_parse_inst_t *)&cmd_config_tx_metadata_specific,
        (cmdline_parse_inst_t *)&cmd_show_tx_metadata,
        (cmdline_parse_inst_t *)&cmd_show_rx_tx_desc_status,
+       (cmdline_parse_inst_t *)&cmd_show_rx_queue_desc_used_count,
        (cmdline_parse_inst_t *)&cmd_set_raw,
        (cmdline_parse_inst_t *)&cmd_show_set_raw,
        (cmdline_parse_inst_t *)&cmd_show_set_raw_all,
@@ -17131,6 +17667,7 @@ cmdline_read_from_file(const char *filename)
 void
 prompt(void)
 {
+       int ret;
        /* initialize non-constant commands */
        cmd_set_fwd_mode_init();
        cmd_set_fwd_retry_mode_init();
@@ -17138,15 +17675,23 @@ prompt(void)
        testpmd_cl = cmdline_stdin_new(main_ctx, "testpmd> ");
        if (testpmd_cl == NULL)
                return;
+
+       ret = atexit(prompt_exit);
+       if (ret != 0)
+               printf("Cannot set exit function for cmdline\n");
+
        cmdline_interact(testpmd_cl);
-       cmdline_stdin_exit(testpmd_cl);
+       if (ret != 0)
+               cmdline_stdin_exit(testpmd_cl);
 }
 
 void
 prompt_exit(void)
 {
-       if (testpmd_cl != NULL)
+       if (testpmd_cl != NULL) {
                cmdline_quit(testpmd_cl);
+               cmdline_stdin_exit(testpmd_cl);
+       }
 }
 
 static void