diff mbox series

[V2,1/6] framework/etgen: remove etgen

Message ID 20210831082220.47375-2-yufengx.mo@intel.com (mailing list archive)
State Accepted
Delegated to: LIjuan Tu
Headers show
Series etgen: remove etgen | expand

Commit Message

Yufen Mo Aug. 31, 2021, 8:22 a.m. UTC
remove etgen relevant source code.

Signed-off-by: Yufen Mo <yufengx.mo@intel.com>
---
 conf/crbs.cfg             |   2 -
 conf/ixia.cfg             |  15 -
 framework/config.py       |  67 +--
 framework/crb.py          |   2 +-
 framework/crbs.py         |   1 -
 framework/dts.py          |   6 -
 framework/etgen.py        | 972 --------------------------------------
 framework/logger.py       |  20 -
 framework/project_dpdk.py |  12 +-
 framework/settings.py     |   1 -
 framework/tester.py       |  90 +---
 11 files changed, 5 insertions(+), 1183 deletions(-)
 delete mode 100644 conf/ixia.cfg
 delete mode 100644 framework/etgen.py
diff mbox series

Patch

diff --git a/conf/crbs.cfg b/conf/crbs.cfg
index 0ba9d1fc..b6c0a9af 100644
--- a/conf/crbs.cfg
+++ b/conf/crbs.cfg
@@ -6,7 +6,6 @@ 
 #  os: operation system type linux or freebsd
 #  tester_ip: Tester ip address
 #  tester_passwd: Tester password
-#  ixia_group: IXIA group name
 #  pktgen_group: packet generator group name: ixia/trex/ixia_network
 #  channels: Board channel number
 #  bypass_core0: Whether by pass core0
@@ -36,7 +35,6 @@  os=linux
 dut_arch=
 tester_ip=yyy.yyy.yyy.yyy
 tester_passwd=
-ixia_group=
 pktgen_group=
 channels=4
 bypass_core0=True
diff --git a/conf/ixia.cfg b/conf/ixia.cfg
deleted file mode 100644
index 9deba603..00000000
--- a/conf/ixia.cfg
+++ /dev/null
@@ -1,15 +0,0 @@ 
-# IXIA port Configuration
-# IxiaGroup: Group name for IXIA ports
-# Version  : IXIA TCL server version
-# IP       : IXIA server IP address
-# Ports    : [IXIA port list]
-# ixia_force100g: We need to set this to enable if we need IXIA port work in 100G mode.
-[IXIA Group]
-ixia_version=6.62
-ixia_ip=xxx.xxx.xxx.xxx
-ixia_ports=
-    card=1,port=1;
-    card=1,port=2;
-    card=1,port=3;
-    card=1,port=4;
-ixia_force100g=disable
diff --git a/framework/config.py b/framework/config.py
index 88ae8ea5..ac075233 100644
--- a/framework/config.py
+++ b/framework/config.py
@@ -36,7 +36,7 @@  import os
 import re
 import configparser  # config parse module
 import argparse      # parse arguments module
-from settings import (IXIA, PKTGEN, PKTGEN_DPDK, PKTGEN_TREX, PKTGEN_IXIA, PKTGEN_IXIA_NETWORK,
+from settings import (PKTGEN, PKTGEN_DPDK, PKTGEN_TREX, PKTGEN_IXIA, PKTGEN_IXIA_NETWORK,
                       CONFIG_ROOT_PATH, SUITE_SECTION_NAME)
 from settings import load_global_setting, DTS_CFG_FOLDER
 from exception import ConfigParseException, VirtConfigParseException, PortConfigParseException
@@ -268,7 +268,7 @@  class PortConf(UserConf):
 class CrbsConf(UserConf):
     DEF_CRB = {'IP': '', 'board': 'default', 'user': '',
                'pass': '', 'tester IP': '', 'tester pass': '',
-               IXIA: None, 'memory channels': 4,
+               'memory channels': 4,
                PKTGEN: None,
                'bypass core0': True, 'dut_cores': '',
                'snapshot_load_side': 'tester'}
@@ -309,11 +309,6 @@  class CrbsConf(UserConf):
                     crb['tester IP'] = value
                 elif key == 'tester_passwd':
                     crb['tester pass'] = value
-                elif key == 'ixia_group':
-                    # None type will be check later
-                    if value.lower() == 'none':
-                        value = None
-                    crb[IXIA] = value
                 elif key == 'pktgen_group':
                     crb[PKTGEN] = value.lower()
                 elif key == 'channels':
@@ -336,64 +331,6 @@  class CrbsConf(UserConf):
         return self.crbs_cfg
 
 
-class IxiaConf(UserConf):
-
-    def __init__(self, ixia_conf=IXIACONF):
-        self.config_file = ixia_conf
-        self.ixia_cfg = {}
-        try:
-            self.ixia_conf = UserConf(self.config_file)
-        except ConfigParseException:
-            self.ixia_conf = None
-            raise ConfigParseException
-
-    def load_ixia_config(self):
-        port_reg = r'card=(\d+),port=(\d+)'
-        groups = self.ixia_conf.get_sections()
-        if not groups:
-            return self.ixia_cfg
-
-        for group in groups:
-            ixia_group = {}
-            ixia_confs = self.ixia_conf.load_section(group)
-            if not ixia_confs:
-                continue
-
-            # convert file configuration to dts ixiacfg
-            for conf in ixia_confs:
-                key, value = conf
-                if key == 'ixia_version':
-                    ixia_group['Version'] = value
-                elif key == 'ixia_ip':
-                    ixia_group['IP'] = value
-                elif key == 'ixia_ports':
-                    ports = self.ixia_conf.load_config(value)
-                    ixia_ports = []
-                    for port in ports:
-                        m = re.match(port_reg, port)
-                        if m:
-                            ixia_port = {}
-                            ixia_port["card"] = int(m.group(1))
-                            ixia_port["port"] = int(m.group(2))
-                            ixia_ports.append(ixia_port)
-                    ixia_group['Ports'] = ixia_ports
-                elif key == 'ixia_enable_rsfec':
-                    ixia_group['enable_rsfec'] = value
-
-            if 'Version' not in ixia_group:
-                print('ixia configuration file request ixia_version option!!!')
-                continue
-            if 'IP' not in ixia_group:
-                print('ixia configuration file request ixia_ip option!!!')
-                continue
-            if 'Ports' not in ixia_group:
-                print('ixia configuration file request ixia_ports option!!!')
-                continue
-
-            self.ixia_cfg[group] = ixia_group
-
-        return self.ixia_cfg
-
 class PktgenConf(UserConf):
 
     def __init__(self, pktgen_type='ixia', pktgen_conf=PKTGENCONF):
diff --git a/framework/crb.py b/framework/crb.py
index 3964e213..40fe4fd1 100644
--- a/framework/crb.py
+++ b/framework/crb.py
@@ -32,7 +32,7 @@ 
 import time
 import re
 import os
-from settings import TIMEOUT, IXIA
+from settings import TIMEOUT
 from ssh_connection import SSHConnection
 from logger import getLogger
 from config import PortConf, PORTCONF, PktgenConf
diff --git a/framework/crbs.py b/framework/crbs.py
index 2ff937ac..c586caa1 100644
--- a/framework/crbs.py
+++ b/framework/crbs.py
@@ -1,7 +1,6 @@ 
 """
 Static configuration data for any CRBs that can be used.
 """
-from settings import IXIA
 
 crbs_desc = {
     'CrownPassCRB1':
diff --git a/framework/dts.py b/framework/dts.py
index 6f621a51..e83a6ce5 100644
--- a/framework/dts.py
+++ b/framework/dts.py
@@ -281,9 +281,6 @@  def dts_log_testsuite(duts, tester, suite_obj, log_handler, test_classname):
                hasattr(tester, 'pktgen') and \
                getattr(tester, 'pktgen'):
                 tester.pktgen.logger.config_suite(test_classname, 'pktgen')
-            elif hasattr(tester, 'ixia_packet_gen') and \
-                 getattr(tester, 'ixia_packet_gen'):
-                tester.ixia_packet_gen.logger.config_suite(test_classname, 'ixia')
     except Exception as ex:
         pass
 
@@ -304,9 +301,6 @@  def dts_log_execution(duts, tester, log_handler):
                hasattr(tester, 'pktgen') and \
                getattr(tester, 'pktgen'):
                 tester.pktgen.logger.config_execution('pktgen')
-            elif hasattr(tester, 'ixia_packet_gen') and \
-                 getattr(tester, 'ixia_packet_gen'):
-                tester.ixia_packet_gen.logger.config_execution('ixia')
     except Exception as ex:
         pass
 
diff --git a/framework/etgen.py b/framework/etgen.py
deleted file mode 100644
index acfa2960..00000000
--- a/framework/etgen.py
+++ /dev/null
@@ -1,972 +0,0 @@ 
-# BSD LICENSE
-#
-# Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
-# All rights reserved.
-#
-# Redistribution and use in source and binary forms, with or without
-# modification, are permitted provided that the following conditions
-# are met:
-#
-#   * Redistributions of source code must retain the above copyright
-#     notice, this list of conditions and the following disclaimer.
-#   * Redistributions in binary form must reproduce the above copyright
-#     notice, this list of conditions and the following disclaimer in
-#     the documentation and/or other materials provided with the
-#     distribution.
-#   * Neither the name of Intel Corporation nor the names of its
-#     contributors may be used to endorse or promote products derived
-#     from this software without specific prior written permission.
-#
-# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
-# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
-# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
-# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
-# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
-# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
-# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
-# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
-# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
-# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
-# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-import re
-import string
-import time
-from config import IxiaConf
-from ssh_connection import SSHConnection
-from settings import SCAPY2IXIA
-from logger import getLogger
-from exception import VerifyFailure
-from utils import create_mask
-
-
-class SoftwarePacketGenerator():
-
-    """
-    Software WindRiver packet generator for performance measurement.
-    """
-
-    def __init__(self, tester):
-        self.tester = tester
-
-    def packet_generator(self, portList, rate_percent):
-        # bind ports
-        self.tester.send_expect("insmod igb_uio.ko", "#")
-
-        bind_cmd = ""
-        allow_list = ""
-        ports = []
-        tx_ports = []
-        for (tx_port, rx_port, pcap_file) in portList:
-            if tx_port not in ports:
-                ports.append(tx_port)
-                tx_ports.append(tx_port)
-            if rx_port not in ports:
-                ports.append(rx_port)
-
-        for port in ports:
-            bind_cmd += " %s" % self.tester.ports_info[port]['pci']
-            allow_list += " -w %s" % self.tester.ports_info[port]['pci']
-
-        self.tester.send_expect("./dpdk-devbind.py --bind=igb_uio %s" % bind_cmd, "#")
-
-        # assign core for ports
-        map_cmd = ""
-        port_index = list(range(len(ports)))
-        port_map = dict(list(zip(ports, port_index)))
-        self.tester.init_reserved_core()
-
-        # reserve one core for master process
-        used_cores = list()
-        master_core = self.tester.get_reserved_core("1C", socket=0)
-
-        if len(master_core) < 1:
-            raise VerifyFailure("Not enough core for performance!!!")
-
-        used_cores.append(int(master_core[0]))
-
-        # allocate cores for each port
-        for port in ports:
-            numa = self.tester.get_port_numa(port)
-            cores = self.tester.get_reserved_core("2C", socket=numa)
-
-            if len(cores) < 2:
-                raise VerifyFailure("Not enough cores for performance!!!")
-
-            map_cmd += "[%s:%s].%d, " % (cores[0], cores[1], port_map[port])
-            used_cores.append(int(cores[0]))
-            used_cores.append(int(cores[1]))
-
-        # prepare pcap for every port
-        pcap_cmd = ""
-        for (tx_port, rx_port, pcap_file) in portList:
-            pcap_cmd += " -s %d:%s" % (port_map[tx_port], pcap_file)
-
-        # Selected 2 for -n to optimize results on Burage
-        cores_mask = create_mask(used_cores)
-
-        # allocate enough memory for 4 ports
-        socket_mem = "--socket-mem 1024,1024"
-
-        # current support version is dpdk v18.02 + pktgen v3.5.0
-        pkt_cmd = "./pktgen -n 2 -c {CORE} --file-prefix=pktgen {ALLOW} " \
-                  "{MEM} -- -P -m \"{CORE_MAP}\" {PCAP}".format(CORE=cores_mask,
-                  ALLOW=allow_list, MEM=socket_mem, CORE_MAP=map_cmd, PCAP=pcap_cmd)
-
-        self.tester.send_expect(pkt_cmd, "Pktgen:/>", 100)
-        self.tester.send_expect("disable screen", "Pktgen:/>")
-
-        if rate_percent != 100:
-            self.tester.send_expect("set all rate %s" % rate_percent, "Pktgen:/>")
-        else:
-            self.tester.send_expect("set all rate 100", "Pktgen:/>")
-
-        self.tester.send_expect("start all", "Pktgen:/>")
-        time.sleep(10)
-        out = self.tester.send_expect("lua \"prints('portRates', pktgen.portStats('all', 'rate'))\"", "Pktgen:/>")
-        rx_bps = 0
-        rx_pps = 0
-        tx_bps = 0
-        rx_match = r"\[\"mbits_rx\"\] = (\d+),"
-        port_stats = re.findall(rx_match, out)
-        for port_stat in port_stats:
-            rx_bps += int(port_stat)
-
-        tx_match = r"\[\"mbits_tx\"\] = (\d+),"
-        port_stats = re.findall(tx_match, out)
-        for port_stat in port_stats:
-            tx_bps += int(port_stat)
-
-        pps_match = r"\[\"pkts_rx\"\] = (\d+),"
-        port_stats = re.findall(pps_match, out)
-        for port_stat in port_stats:
-            rx_pps += int(port_stat)
-
-        self.tester.send_expect("stop all", "Pktgen:/>")
-        self.tester.send_expect("quit", "#")
-        # restore stty setting
-        self.tester.send_expect('stty -echo', '#')
-        self.tester.kill_all(killall=True)
-        self.tester.restore_interfaces()
-
-        return rx_bps, tx_bps, rx_pps
-
-    def throughput(self, portList, rate_percent=100):
-        (bps_rx, _, pps_rx) = self.packet_generator(portList, rate_percent)
-        return bps_rx, pps_rx
-
-    def loss(self, portList, ratePercent):
-        (bps_rx, bps_tx, _) = self.packet_generator(portList, ratePercent)
-        assert bps_tx != 0
-        return (float(bps_tx) - float(bps_rx)) / float(bps_tx), float(bps_tx), float(bps_rx)
-
-
-class IxiaPacketGenerator(SSHConnection):
-
-    """
-    IXIA packet generator for performance measurement.
-    """
-
-    def __init__(self, tester):
-        self.tester = tester
-        self.NAME = 'ixia'
-        self.logger = getLogger(self.NAME)
-        super(IxiaPacketGenerator, self).__init__(self.get_ip_address(),
-                                                  self.NAME, self.tester.get_username(),
-                                                  self.get_password())
-        super(IxiaPacketGenerator, self).init_log(self.logger)
-
-        self.tcl_cmds = []
-        self.chasId = None
-        self.conRelation = {}
-
-        ixiaRef = self.tester.get_external_traffic_generator()
-
-        ixiacfg = IxiaConf()
-        ixiaPorts = ixiacfg.load_ixia_config()
-        if ixiaRef is None or ixiaRef not in ixiaPorts:
-            return
-
-        self.ixiaVersion = ixiaPorts[ixiaRef]["Version"]
-        self.ports = ixiaPorts[ixiaRef]["Ports"]
-
-        if 'force100g' in ixiaPorts[ixiaRef]:
-            self.enable100g = ixiaPorts[ixiaRef]['force100g']
-        else:
-            self.enable100g = 'disable'
-
-        self.logger.info(self.ixiaVersion)
-        self.logger.info(self.ports)
-
-        self.tclServerIP = ixiaPorts[ixiaRef]["IP"]
-
-        # prepare tcl shell and ixia library
-        self.send_expect("tclsh", "% ")
-        self.send_expect("source ./IxiaWish.tcl", "% ")
-        self.send_expect("set ::env(IXIA_VERSION) %s" % self.ixiaVersion, "% ")
-        out = self.send_expect("package req IxTclHal", "% ")
-        self.logger.debug("package req IxTclHal return:" + out)
-        if self.ixiaVersion in out:
-            if not self.tcl_server_login():
-                self.close()
-                self.session = None
-            for port in self.ports:
-                port['speed'] = self.get_line_rate(self.chasId, port)
-
-    def get_line_rate(self, chasid, port):
-        return self.send_expect("stat getLineSpeed %s %s %s" % (chasid, port['card'], port['port']), '%')
-
-    def get_ip_address(self):
-        return self.tester.get_ip_address()
-
-    def get_password(self):
-        return self.tester.get_password()
-
-    def add_tcl_cmd(self, cmd):
-        """
-        Add one tcl command into command list.
-        """
-        self.tcl_cmds.append(cmd)
-
-    def clean(self):
-        """
-        Clean ownership of IXIA devices and logout tcl session.
-        """
-        self.close()
-        self.send_expect("clearOwnershipAndLogout", "% ")
-
-    def parse_pcap(self, fpcap):
-        dump_str1 = "cmds = []\n"
-        dump_str2 = "for i in rdpcap('%s', -1):\n" % fpcap
-        dump_str3 = "    if 'VXLAN' in i.command():\n" + \
-                    "        vxlan_str = ''\n" + \
-                    "        l = len(i[VXLAN])\n" + \
-                    "        vxlan = str(i[VXLAN])\n" + \
-                    "        first = True\n" + \
-                    "        for j in range(l):\n" + \
-                    "            if first:\n" + \
-                    "                vxlan_str += \"VXLAN(hexval='%02X\" %ord(vxlan[j])\n" + \
-                    "                first = False\n" + \
-                    "            else:\n" + \
-                    "                vxlan_str += \" %02X\" %ord(vxlan[j])\n" + \
-                    "        vxlan_str += \"\')\"\n" + \
-                    "        command = re.sub(r\"VXLAN(.*)\", vxlan_str, i.command())\n" + \
-                    "    else:\n" + \
-                    "        command = i.command()\n" + \
-                    "    cmds.append(command)\n" + \
-                    "print cmds\n" + \
-                    "exit()"
-
-        f = open("dumppcap.py", "w")
-        f.write(dump_str1)
-        f.write(dump_str2)
-        f.write(dump_str3)
-        f.close()
-
-        self.session.copy_file_to("dumppcap.py")
-        out = self.send_expect("scapy -c dumppcap.py 2>/dev/null", "% ", 120)
-        flows = eval(out)
-        return flows
-
-    def ether(self, port, src, dst, type):
-        """
-        Configure Ether protocol.
-        """
-        self.add_tcl_cmd("protocol config -ethernetType ethernetII")
-        self.add_tcl_cmd('stream config -sa "%s"' % self.macToTclFormat(src))
-        self.add_tcl_cmd('stream config -da "%s"' % self.macToTclFormat(dst))
-
-    def ip(self, port, frag, src, proto, tos, dst, chksum, len, version, flags, ihl, ttl, id, options=None):
-        """
-        Configure IP protocol.
-        """
-        self.add_tcl_cmd("protocol config -name ip")
-        self.add_tcl_cmd('ip config -sourceIpAddr "%s"' % src)
-        self.add_tcl_cmd('ip config -destIpAddr "%s"' % dst)
-        self.add_tcl_cmd("ip config -ttl %d" % ttl)
-        self.add_tcl_cmd("ip config -totalLength %d" % len)
-        self.add_tcl_cmd("ip config -fragment %d" % frag)
-        self.add_tcl_cmd("ip config -ipProtocol %d" % proto)
-        self.add_tcl_cmd("ip config -identifier %d" % id)
-        self.add_tcl_cmd("stream config -framesize %d" % (len + 18))
-        self.add_tcl_cmd("ip set %d %d %d" % (self.chasId, port['card'], port['port']))
-
-    def macToTclFormat(self, macAddr):
-        """
-        Convert normal mac address format into IXIA's format.
-        """
-        macAddr = macAddr.upper()
-        return "%s %s %s %s %s %s" % (macAddr[:2], macAddr[3:5], macAddr[6:8], macAddr[9:11], macAddr[12:14], macAddr[15:17])
-
-    def ipv6(self, port, version, tc, fl, plen, nh, hlim, src, dst):
-        """
-        Configure IPv6 protocol.
-        """
-        self.add_tcl_cmd("protocol config -name ipV6")
-        self.add_tcl_cmd('ipV6 setDefault')
-        self.add_tcl_cmd('ipV6 config -destAddr "%s"' % self.ipv6_to_tcl_format(dst))
-        self.add_tcl_cmd('ipV6 config -sourceAddr "%s"' % self.ipv6_to_tcl_format(src))
-        self.add_tcl_cmd('ipV6 config -flowLabel %d' % fl)
-        self.add_tcl_cmd('ipV6 config -nextHeader %d' % nh)
-        self.add_tcl_cmd('ipV6 config -hopLimit %d' % hlim)
-        self.add_tcl_cmd('ipV6 config -trafficClass %d' % tc)
-        self.add_tcl_cmd("ipV6 clearAllExtensionHeaders")
-        self.add_tcl_cmd("ipV6 addExtensionHeader %d" % nh)
-
-        self.add_tcl_cmd("stream config -framesize %d" % (plen + 40 + 18))
-        self.add_tcl_cmd("ipV6 set %d %d %d" % (self.chasId, port['card'], port['port']))
-
-    def udp(self, port, dport, sport, len, chksum):
-        """
-        Configure UDP protocol.
-        """
-        self.add_tcl_cmd("udp setDefault")
-        self.add_tcl_cmd("udp config -sourcePort %d" % sport)
-        self.add_tcl_cmd("udp config -destPort %d" % dport)
-        self.add_tcl_cmd("udp config -length %d" % len)
-        self.add_tcl_cmd("udp set %d %d %d" %
-                         (self.chasId, port['card'], port['port']))
-
-    def vxlan(self, port, hexval):
-        self.add_tcl_cmd("protocolPad setDefault")
-        self.add_tcl_cmd("protocol config -enableProtocolPad true")
-        self.add_tcl_cmd("protocolPad config -dataBytes \"%s\"" % hexval)
-        self.add_tcl_cmd("protocolPad set %d %d %d" %
-                         (self.chasId, port['card'], port['port']))
-
-    def tcp(self, port, sport, dport, seq, ack, dataofs, reserved, flags, window, chksum, urgptr, options=None):
-        """
-        Configure TCP protocol.
-        """
-        self.add_tcl_cmd("tcp setDefault")
-        self.add_tcl_cmd("tcp config -sourcePort %d" % sport)
-        self.add_tcl_cmd("tcp config -destPort %d" % dport)
-        self.add_tcl_cmd("tcp set %d %d %d" % (self.chasId, port['card'], port['port']))
-
-    def sctp(self, port, sport, dport, tag, chksum):
-        """
-        Configure SCTP protocol.
-        """
-        self.add_tcl_cmd("tcp config -sourcePort %d" % sport)
-        self.add_tcl_cmd("tcp config -destPort %d" % dport)
-        self.add_tcl_cmd("tcp set %d %d %d" % (self.chasId, port['card'], port['port']))
-
-    def dot1q(self, port, prio, id, vlan, type):
-        """
-        Configure 8021Q protocol.
-        """
-        self.add_tcl_cmd("protocol config -enable802dot1qTag true")
-        self.add_tcl_cmd("vlan config -vlanID %d" % vlan)
-        self.add_tcl_cmd("vlan config -userPriority %d" % prio)
-        self.add_tcl_cmd("vlan set %d %d %d" % (self.chasId, port['card'], port['port']))
-
-    def config_stream(self, fpcap, txport, rate_percent, stream_id=1, latency=False):
-        """
-        Configure IXIA stream and enable multiple flows.
-        """
-        flows = self.parse_pcap(fpcap)
-
-        self.add_tcl_cmd("ixGlobalSetDefault")
-        self.config_ixia_stream(rate_percent, flows, latency)
-
-        pat = re.compile(r"(\w+)\((.*)\)")
-        for flow in flows:
-            for header in flow.split('/'):
-                match = pat.match(header)
-                params = eval('dict(%s)' % match.group(2))
-                method_name = match.group(1)
-                if method_name == 'VXLAN':
-                    method = getattr(self, method_name.lower())
-                    method(txport, **params)
-                    break
-                if method_name in SCAPY2IXIA:
-                    method = getattr(self, method_name.lower())
-                    method(txport, **params)
-
-            self.add_tcl_cmd("stream set %d %d %d %d" % (self.chasId, txport[
-                                                         'card'], txport['port'], stream_id))
-            stream_id += 1
-
-        if len(flows) > 1:
-            stream_id -= 1
-            self.add_tcl_cmd("stream config -dma gotoFirst")
-            self.add_tcl_cmd("stream set %d %d %d %d" %
-                             (self.chasId, txport['card'], txport['port'], stream_id))
-
-    def config_ixia_stream(self, rate_percent, flows, latency):
-        """
-        Configure IXIA stream with rate and latency.
-        Override this method if you want to add custom stream configuration.
-        """
-        self.add_tcl_cmd("stream config -rateMode usePercentRate")
-        self.add_tcl_cmd("stream config -percentPacketRate %s" % rate_percent)
-        self.add_tcl_cmd("stream config -numFrames 1")
-        if len(flows) == 1:
-            self.add_tcl_cmd("stream config -dma contPacket")
-        else:
-            self.add_tcl_cmd("stream config -dma advance")
-        # request by packet Group
-        if latency is not False:
-            self.add_tcl_cmd("stream config -fir true")
-
-    def tcl_server_login(self):
-        """
-        Connect to tcl server and take ownership of all the ports needed.
-        """
-        out = self.send_expect("ixConnectToTclServer %s" % self.tclServerIP, "% ", 30)
-        self.logger.debug("ixConnectToTclServer return:" + out)
-        if out.strip()[-1] != '0':
-            return False
-
-        self.send_expect("ixLogin IxiaTclUser", "% ")
-
-        out = self.send_expect("ixConnectToChassis %s" % self.tclServerIP, "% ", 30)
-        if out.strip()[-1] != '0':
-            return False
-
-        out = self.send_expect("set chasId [ixGetChassisID %s]" % self.tclServerIP, "% ")
-        self.chasId = int(out.strip())
-
-        out = self.send_expect("ixClearOwnership [list %s]" % ' '.join(
-            ['[list %d %d %d]' % (self.chasId, item['card'], item['port']) for item in self.ports]), "% ", 10)
-        if out.strip()[-1] != '0':
-            return False
-        out = self.send_expect("ixTakeOwnership [list %s] force" % ' '.join(
-            ['[list %d %d %d]' % (self.chasId, item['card'], item['port']) for item in self.ports]), "% ", 10)
-        if out.strip()[-1] != '0':
-            return False
-
-        return True
-
-    def tcl_server_logout(self):
-        """
-        Disconnect to tcl server and make sure has been logged out.
-        """
-        self.send_expect("ixDisconnectFromChassis %s" % self.tclServerIP, "%")
-        self.send_expect("ixLogout", "%")
-        self.send_expect("ixDisconnectTclServer %s" % self.tclServerIP, "%")
-
-    def config_port(self, pList):
-        """
-        Configure ports and make them ready for performance validation.
-        """
-        pl = list()
-        for item in pList:
-            self.add_tcl_cmd("port setFactoryDefaults chasId %d %d" % (
-                item['card'], item['port']))
-            # if the line rate is 100G and we need this port work in 100G mode,
-            # we need to add some configure to make it so.
-            if int(self.get_line_rate(self.chasId, item).strip()) == 100000 and self.enable100g == 'enable':
-                self.add_tcl_cmd("port config -ieeeL1Defaults 0")
-                self.add_tcl_cmd("port config -autonegotiate false")
-                self.add_tcl_cmd("port config -enableRsFec true")
-                self.add_tcl_cmd("port set %d %d %d" % (self.chasId, item['card'], item['port']))
-
-            pl.append('[list %d %d %d]' % (self.chasId, item['card'], item['port']))
-
-        self.add_tcl_cmd("set portList [list %s]" % ' '.join(pl))
-
-        self.add_tcl_cmd("ixClearTimeStamp portList")
-        self.add_tcl_cmd("ixWritePortsToHardware portList")
-        self.add_tcl_cmd("ixCheckLinkState portList")
-
-    def set_ixia_port_list(self, pList):
-        """
-        Implement ports/streams configuration on specified ports.
-        """
-        self.add_tcl_cmd("set portList [list %s]" %
-                         ' '.join(['[list %d %d %d]' %
-                                      (self.chasId, item['card'], item['port']) for item in pList]))
-
-    def send_ping6(self, pci, mac, ipv6):
-        """
-        Send ping6 packet from IXIA ports.
-        """
-        self.send_expect("source ./ixTcl1.0/ixiaPing6.tcl", "% ")
-        out = self.send_expect('ping6 "%s" "%s" %d %d %d' %
-                               (self.ipv6_to_tcl_format(ipv6), self.macToTclFormat(mac), self.chasId, self.pci_to_port(pci)['card'], self.pci_to_port(pci)['port']), "% ", 90)
-        return out
-
-    def ipv6_to_tcl_format(self, ipv6):
-        """
-        Convert normal IPv6 address to IXIA format.
-        """
-        ipv6 = ipv6.upper()
-        singleAddr = ipv6.split(":")
-        if '' == singleAddr[0]:
-            singleAddr = singleAddr[1:]
-        if '' in singleAddr:
-            tclFormatAddr = ''
-            addStr = '0:' * (8 - len(singleAddr)) + '0'
-            for i in range(len(singleAddr)):
-                if singleAddr[i] == '':
-                    tclFormatAddr += addStr + ":"
-                else:
-                    tclFormatAddr += singleAddr[i] + ":"
-            tclFormatAddr = tclFormatAddr[0:len(tclFormatAddr) - 1]
-            return tclFormatAddr
-        else:
-            return ipv6
-
-    def get_ports(self):
-        """
-        API to get ixia ports
-        """
-        plist = list()
-        if self.session is None:
-            return plist
-
-        for p in self.ports:
-            plist.append({'type': 'ixia', 'pci': 'IXIA:%d.%d' % (p['card'], p['port'])})
-        return plist
-
-    def pci_to_port(self, pci):
-        """
-        Convert IXIA fake pci to IXIA port.
-        """
-        ixia_pci_regex = "IXIA:(\d*).(\d*)"
-        m = re.match(ixia_pci_regex, pci)
-        if m is None:
-            return {'card': -1, 'port': -1}
-
-        return {'card': int(m.group(1)), 'port': int(m.group(2))}
-
-    def loss(self, portList, ratePercent, delay=5):
-        """
-        Run loss performance test and return loss rate.
-        """
-        rxPortlist, txPortlist = self._configure_everything(portList, ratePercent)
-        return self.get_loss_packet_rate(rxPortlist, txPortlist, delay)
-
-    def get_loss_packet_rate(self, rxPortlist, txPortlist, delay=5):
-        """
-        Get RX/TX packet statistics and calculate loss rate.
-        """
-        time.sleep(delay)
-
-        self.send_expect("ixStopTransmit portList", "%", 10)
-        time.sleep(2)
-        sendNumber = 0
-        for port in txPortlist:
-            self.stat_get_stat_all_stats(port)
-            sendNumber += self.get_frames_sent()
-            time.sleep(0.5)
-
-        self.logger.info("send :%f" % sendNumber)
-
-        assert sendNumber != 0
-
-        revNumber = 0
-        for port in rxPortlist:
-            self.stat_get_stat_all_stats(port)
-            revNumber += self.get_frames_received()
-        self.logger.info("rev  :%f" % revNumber)
-
-        return float(sendNumber - revNumber) / sendNumber, sendNumber, revNumber
-
-    def latency(self, portList, ratePercent, delay=5):
-        """
-        Run latency performance test and return latency statistics.
-        """
-        rxPortlist, txPortlist = self._configure_everything(portList, ratePercent, True)
-        return self.get_packet_latency(rxPortlist)
-
-    def get_packet_latency(self, rxPortlist):
-        """
-        Stop IXIA transmit and return latency statistics.
-        """
-        latencyList = []
-        time.sleep(10)
-        self.send_expect("ixStopTransmit portList", "%", 10)
-        for rx_port in rxPortlist:
-            self.pktGroup_get_stat_all_stats(rx_port)
-            latency = {"port": rx_port,
-                       "min": self.get_min_latency(),
-                       "max": self.get_max_latency(),
-                       "average": self.get_average_latency()}
-            latencyList.append(latency)
-        return latencyList
-
-    def throughput(self, port_list, rate_percent=100, delay=5):
-        """
-        Run throughput performance test and return throughput statistics.
-        """
-        rxPortlist, txPortlist = self._configure_everything(port_list, rate_percent)
-        return self.get_transmission_results(rxPortlist, txPortlist, delay)
-
-    """
-    This function could be used to check the packets' order whether same as the receive sequence.
-    Please notice that this function only support single-stream mode.
-    """
-    def is_packet_ordered(self, port_list, delay):
-        rxPortlist, txPortlist = self.prepare_port_list(port_list)
-        self.prepare_ixia_for_transmission(txPortlist, rxPortlist)
-        self.send_expect('port config -receiveMode [expr $::portCapture|$::portRxSequenceChecking|$::portRxModeWidePacketGroup]', '%')
-        self.send_expect('port config -autonegotiate true', '%')
-        self.send_expect('ixWritePortsToHardware portList', '%')
-        self.send_expect('set streamId 1', '%')
-        self.send_expect('stream setDefault', '%')
-        self.send_expect('ixStartPortPacketGroups %d %d %d' % (self.chasId, self.ports[0]['card'], self.ports[0]['port']), '%')
-        self.send_expect('ixStartTransmit portList', '%')
-        self.send_expect('after 1000 * %d' % delay, '%')
-        self.send_expect('ixStopTransmit portList', '%')
-        self.send_expect('ixStopPortPacketGroups %d %d %d' % (self.chasId, self.ports[0]['card'], self.ports[0]['port']), '%')
-        self.send_expect('packetGroupStats get %d %d %d 1 1' % (self.chasId, self.ports[0]['card'], self.ports[0]['port']), '%')
-        self.send_expect('packetroupStats getGroup 1', '%')
-        self.send_expect('set reverseSequenceError [packetGroupStats cget -reverseSequenceError]]', '%')
-        output = self.send_expect('puts $reverseSequenceError', '%')
-        return int(output[:-2])
-
-    def _configure_everything(self, port_list, rate_percent, latency=False):
-        """
-        Prepare and configure IXIA ports for performance test.
-        """
-        rxPortlist, txPortlist = self.prepare_port_list(port_list, rate_percent, latency)
-        self.prepare_ixia_for_transmission(txPortlist, rxPortlist)
-        self.configure_transmission()
-        self.start_transmission()
-        self.clear_tcl_commands()
-        return rxPortlist, txPortlist
-
-    def clear_tcl_commands(self):
-        """
-        Clear all commands in command list.
-        """
-        del self.tcl_cmds[:]
-
-    def start_transmission(self):
-        """
-        Run commands in command list.
-        """
-        fileContent = "\n".join(self.tcl_cmds) + "\n"
-        self.tester.create_file(fileContent, 'ixiaConfig.tcl')
-        self.send_expect("source ixiaConfig.tcl", "% ", 75)
-
-    def configure_transmission(self, latency=False):
-        """
-        Start IXIA ports transmission.
-        """
-        self.add_tcl_cmd("ixStartTransmit portList")
-
-    def prepare_port_list(self, portList, rate_percent=100, latency=False):
-        """
-        Configure stream and flow on every IXIA ports.
-        """
-        txPortlist = set()
-        rxPortlist = set()
-
-        for (txPort, rxPort, pcapFile) in portList:
-            txPortlist.add(txPort)
-            rxPortlist.add(rxPort)
-
-        # port init
-        self.config_port([self.pci_to_port(
-            self.tester.get_pci(port)) for port in txPortlist.union(rxPortlist)])
-
-        # stream/flow setting
-        for (txPort, rxPort, pcapFile) in portList:
-            self.config_stream(pcapFile, self.pci_to_port(self.tester.get_pci(txPort)), rate_percent, 1, latency)
-
-        # config stream before packetGroup
-        if latency is not False:
-            for (txPort, rxPort, pcapFile) in portList:
-                flow_num = len(self.parse_pcap(pcapFile))
-                self.config_pktGroup_rx(self.pci_to_port(self.tester.get_pci(rxPort)))
-                self.config_pktGroup_tx(self.pci_to_port(self.tester.get_pci(txPort)))
-        return rxPortlist, txPortlist
-
-    def prepare_ixia_for_transmission(self, txPortlist, rxPortlist):
-        """
-        Clear all statistics and implement configuration to IXIA hardware.
-        """
-        self.add_tcl_cmd("ixClearStats portList")
-        self.set_ixia_port_list([self.pci_to_port(self.tester.get_pci(port)) for port in txPortlist])
-        self.add_tcl_cmd("ixWriteConfigToHardware portList")
-        for port in txPortlist:
-            self.start_pktGroup(self.pci_to_port(self.tester.get_pci(port)))
-        for port in rxPortlist:
-            self.start_pktGroup(self.pci_to_port(self.tester.get_pci(port)))
-
-    def hook_transmission_func(self):
-        pass
-
-    def get_transmission_results(self, rx_port_list, tx_port_list, delay=5):
-        """
-        Override this method if you want to change the way of getting results
-        back from IXIA.
-        """
-        time.sleep(delay)
-        bpsRate = 0
-        rate = 0
-        oversize = 0
-        for port in rx_port_list:
-            self.stat_get_rate_stat_all_stats(port)
-            out = self.send_expect("stat cget -framesReceived", '%', 10)
-            rate += int(out.strip())
-            out = self.send_expect("stat cget -bitsReceived", '% ', 10)
-            self.logger.debug("port %d bits rate:" % (port) + out)
-            bpsRate += int(out.strip())
-            out = self.send_expect("stat cget -oversize", '%', 10)
-            oversize += int(out.strip())
-
-        self.logger.info("Rate: %f Mpps" % (rate * 1.0 / 1000000))
-        self.logger.info("Mbps rate: %f Mbps" % (bpsRate * 1.0 / 1000000))
-
-        self.hook_transmission_func()
-
-        self.send_expect("ixStopTransmit portList", "%", 30)
-
-        if rate == 0 and oversize > 0:
-            return (bpsRate, oversize)
-        else:
-            return (bpsRate, rate)
-
-    def config_ixia_dcb_init(self, rxPort, txPort):
-        """
-        Configure Ixia for DCB.
-        """
-        self.send_expect("source ./ixTcl1.0/ixiaDCB.tcl", "% ")
-        self.send_expect("configIxia %d %s" % (self.chasId, ' '.join(["%s" % (
-            repr(self.conRelation[port][n])) for port in [rxPort, txPort] for n in range(3)])), "% ", 100)
-
-    def config_port_dcb(self, direction, tc):
-        """
-        Configure Port for DCB.
-        """
-        self.send_expect("configPort %s %s" % (direction, tc), "% ", 100)
-
-    def cfgStreamDcb(self, stream, rate, prio, types):
-        """
-        Configure Stream for DCB.
-        """
-        self.send_expect("configStream %s %s %s %s" % (stream, rate, prio, types), "% ", 100)
-
-    def get_connection_relation(self, dutPorts):
-        """
-        Get the connect relations between DUT and Ixia.
-        """
-        for port in dutPorts:
-            info = self.tester.get_pci(self.tester.get_local_port(port)).split('.')
-            self.conRelation[port] = [int(info[0]), int(info[1]), repr(self.tester.dut.get_mac_address(port).replace(':', ' ').upper())]
-        return self.conRelation
-
-    def config_pktGroup_rx(self, rxport):
-        """
-        Sets the transmit Packet Group configuration of the stream
-        Default streamID is 1
-        """
-        self.add_tcl_cmd("port config -receiveMode $::portRxModeWidePacketGroup")
-        self.add_tcl_cmd("port set %d %d %d" % (self.chasId, rxport['card'], rxport['port']))
-        self.add_tcl_cmd("packetGroup setDefault")
-        self.add_tcl_cmd("packetGroup config -latencyControl cutThrough")
-        self.add_tcl_cmd("packetGroup setRx %d %d %d" % (self.chasId, rxport['card'], rxport['port']))
-        self.add_tcl_cmd("packetGroup setTx %d %d %d 1" % (self.chasId, rxport['card'], rxport['port']))
-
-    def config_pktGroup_tx(self, txport):
-        """
-        Configure tx port pktGroup for latency.
-        """
-        self.add_tcl_cmd("packetGroup setDefault")
-        self.add_tcl_cmd("packetGroup config -insertSignature true")
-        self.add_tcl_cmd("packetGroup setTx %d %d %d 1" % (self.chasId,
-                                                           txport['card'], txport['port']))
-
-    def start_pktGroup(self, port):
-        """
-        Start tx port pktGroup for latency.
-        """
-        self.add_tcl_cmd("ixStartPortPacketGroups %d %d %d" % (self.chasId,
-                                                               port['card'], port['port']))
-
-    def pktGroup_get_stat_all_stats(self, port_number):
-        """
-        Stop Packet Group operation on port and get current Packet Group
-        statistics on port.
-        """
-        port = self.pci_to_port(self.tester.get_pci(port_number))
-        self.send_expect("ixStopPortPacketGroups %d %d %d" % (self.chasId, port['card'], port['port']), "%", 100)
-        self.send_expect("packetGroupStats get %d %d %d 0 16384" % (self.chasId, port['card'], port['port']), "%", 100)
-        self.send_expect("packetGroupStats getGroup 0", "%", 100)
-
-    def close(self):
-        """
-        We first close the tclsh session opened at the beginning,
-        then the SSH session.
-        """
-        if self.isalive():
-            self.send_expect('exit', '# ')
-            super(IxiaPacketGenerator, self).close()
-
-    def stat_get_stat_all_stats(self, port_number):
-        """
-        Sends a IXIA TCL command to obtain all the stat values on a given port.
-        """
-        port = self.pci_to_port(self.tester.get_pci(port_number))
-        command = 'stat get statAllStats {0} {1} {2}'
-        command = command.format(self.chasId, port['card'], port['port'])
-        self.send_expect(command, '% ', 10)
-
-    def prepare_ixia_internal_buffers(self, port_number):
-        """
-        Tells IXIA to prepare the internal buffers were the frames were captured.
-        """
-        port = self.pci_to_port(self.tester.get_pci(port_number))
-        command = 'capture get {0} {1} {2}'
-        command = command.format(self.chasId, port['card'], port['port'])
-        self.send_expect(command, '% ', 30)
-
-    def stat_get_rate_stat_all_stats(self, port_number):
-        """
-        All statistics of specified IXIA port.
-        """
-        port = self.pci_to_port(self.tester.get_pci(port_number))
-        command = 'stat getRate statAllStats {0} {1} {2}'
-        command = command.format(self.chasId, port['card'], port['port'])
-        self.send_expect(command, '% ', 30)
-        out = self.send_expect(command, '% ', 30)
-
-    def ixia_capture_buffer(self, port_number, first_frame, last_frame):
-        """
-        Tells IXIA to load the captured frames into the internal buffers.
-        """
-        port = self.pci_to_port(self.tester.get_pci(port_number))
-        command = 'captureBuffer get {0} {1} {2} {3} {4}'
-        command = command.format(self.chasId, port['card'], port['port'],
-                                 first_frame, last_frame)
-        self.send_expect(command, '%', 60)
-
-    def ixia_export_buffer_to_file(self, frames_filename):
-        """
-        Tells IXIA to dump the frames it has loaded in its internal buffer to a
-        text file.
-        """
-        command = 'captureBuffer export %s' % frames_filename
-        self.send_expect(command, '%', 30)
-
-    def _stat_cget_value(self, requested_value):
-        """
-        Sends a IXIA TCL command to obtain a given stat value.
-        """
-        command = "stat cget -" + requested_value
-        result = self.send_expect(command, '%', 10)
-        return int(result.strip())
-
-    def _capture_cget_value(self, requested_value):
-        """
-        Sends a IXIA TCL command to capture certain number of packets.
-        """
-        command = "capture cget -" + requested_value
-        result = self.send_expect(command, '%', 10)
-        return int(result.strip())
-
-    def _packetgroup_cget_value(self, requested_value):
-        """
-        Sends a IXIA TCL command to get pktGroup stat value.
-        """
-        command = "packetGroupStats cget -" + requested_value
-        result = self.send_expect(command, '%', 10)
-        return int(result.strip())
-
-    def number_of_captured_packets(self):
-        """
-        Returns the number of packets captured by IXIA on a previously set
-        port. Call self.stat_get_stat_all_stats(port) before.
-        """
-        return self._capture_cget_value('nPackets')
-
-    def get_frames_received(self):
-        """
-        Returns the number of packets captured by IXIA on a previously set
-        port. Call self.stat_get_stat_all_stats(port) before.
-        """
-        if self._stat_cget_value('framesReceived') != 0:
-            return self._stat_cget_value('framesReceived')
-        else:
-            # if the packet size is large than 1518, this line will avoid return
-            # a wrong number
-            return self._stat_cget_value('oversize')
-
-    def get_flow_control_frames(self):
-        """
-        Returns the number of control frames captured by IXIA on a
-        previously set port. Call self.stat_get_stat_all_stats(port) before.
-        """
-        return self._stat_cget_value('flowControlFrames')
-
-    def get_frames_sent(self):
-        """
-        Returns the number of packets sent by IXIA on a previously set
-        port. Call self.stat_get_stat_all_stats(port) before.
-        """
-        return self._stat_cget_value('framesSent')
-
-    def get_transmit_duration(self):
-        """
-        Returns the duration in nanosecs of the last transmission on a
-        previously set port. Call self.stat_get_stat_all_stats(port) before.
-        """
-        return self._stat_cget_value('transmitDuration')
-
-    def get_min_latency(self):
-        """
-        Returns the minimum latency in nanoseconds of the frames in the
-        retrieved capture buffer. Call packetGroupStats get before.
-        """
-        return self._packetgroup_cget_value('minLatency')
-
-    def get_max_latency(self):
-        """
-        Returns the maximum latency in nanoseconds of the frames in the
-        retrieved capture buffer. Call packetGroupStats get before.
-        """
-        return self._packetgroup_cget_value('maxLatency')
-
-    def get_average_latency(self):
-        """
-        Returns the average latency in nanoseconds of the frames in the
-        retrieved capture buffer. Call packetGroupStats get before.
-        """
-        return self._packetgroup_cget_value('averageLatency')
-
-    def _transmission_pre_config(self, port_list, rate_percent, latency=False):
-        """
-        Prepare and configure IXIA ports for performance test. And remove the transmission step in this config sequence.
-        This function is set only for function send_number_packets for nic_single_core_perf test case use
-        """
-        rxPortlist, txPortlist = self.prepare_port_list(port_list, rate_percent, latency)
-        self.prepare_ixia_for_transmission(txPortlist, rxPortlist)
-        self.start_transmission()
-        self.clear_tcl_commands()
-        return rxPortlist, txPortlist
-
-    def send_number_packets(self, portList, ratePercent, packetNum):
-        """
-        Configure ixia to send fixed number of packets
-        Note that this function is only set for test_suite nic_single_core_perf,
-        Not for common use
-        """
-        rxPortlist, txPortlist = self._transmission_pre_config(portList, ratePercent)
-
-        self.send_expect("stream config -numFrames %s" % packetNum, "%", 5)
-        self.send_expect("stream config -dma stopStream", "%", 5)
-        for txPort in txPortlist:
-            port = self.pci_to_port(self.tester.get_pci(txPort))
-            self.send_expect("stream set %d %d %d 1" % (self.chasId, port['card'], port['port']), "%", 5)
-
-        self.send_expect("ixWritePortsToHardware portList", "%", 5)
-        self.send_expect("ixClearStats portList", "%", 5)
-        self.send_expect("ixStartTransmit portList", "%", 5)
-        time.sleep(10)
-
-        rxPackets = 0
-        for port in txPortlist:
-            self.stat_get_stat_all_stats(port)
-            txPackets = self.get_frames_sent()
-            while txPackets != packetNum:
-                time.sleep(10)
-                self.stat_get_stat_all_stats(port)
-                txPackets = self.get_frames_sent()
-            rxPackets += self.get_frames_received()
-        self.logger.info("Received packets :%s" % rxPackets)
-
-        return rxPackets
diff --git a/framework/logger.py b/framework/logger.py
index 63e1d831..5a04bdd2 100644
--- a/framework/logger.py
+++ b/framework/logger.py
@@ -58,9 +58,6 @@  logging.SUITE_DUT_OUTPUT = logging.DEBUG + 3
 logging.SUITE_TESTER_CMD = logging.INFO + 4
 logging.SUITE_TESTER_OUTPUT = logging.DEBUG + 4
 
-logging.DTS_IXIA_CMD = logging.INFO + 5
-logging.DTS_IXIA_OUTPUT = logging.DEBUG + 5
-
 logging.DTS_VIRTDUT_CMD = logging.INFO + 6
 logging.DTS_VIRTDUT_OUTPUT = logging.DEBUG + 6
 
@@ -75,9 +72,6 @@  logging.addLevelName(logging.DTS_TESTER_CMD, 'DTS_TESTER_CMD')
 logging.addLevelName(logging.DTS_TESTER_OUTPUT, 'DTS_TESTER_OUTPUT')
 logging.addLevelName(logging.DTS_TESTER_RESULT, 'DTS_TESTER_RESULT')
 
-logging.addLevelName(logging.DTS_IXIA_CMD, 'DTS_IXIA_CMD')
-logging.addLevelName(logging.DTS_IXIA_OUTPUT, 'DTS_IXIA_OUTPUT')
-
 logging.addLevelName(logging.DTS_VIRTDUT_CMD, 'VIRTDUT_CMD')
 logging.addLevelName(logging.DTS_VIRTDUT_OUTPUT, 'VIRTDUT_OUTPUT')
 
@@ -140,12 +134,6 @@  class BaseLoggerAdapter(logging.LoggerAdapter):
     def suite_tester_output(self, msg, *args, **kwargs):
         self.log(logging.SUITE_TESTER_OUTPUT, msg, *args, **kwargs)
 
-    def dts_ixia_cmd(self, msg, *args, **kwargs):
-        self.log(logging.DTS_IXIA_CMD, msg, *args, **kwargs)
-
-    def dts_ixia_output(self, msg, *args, **kwargs):
-        self.log(logging.DTS_IXIA_OUTPUT, msg, *args, **kwargs)
-
     def dts_virtdut_cmd(self, msg, *args, **kwargs):
         self.log(logging.DTS_VIRTDUT_CMD, msg, *args, **kwargs)
 
@@ -174,8 +162,6 @@  class ColorHandler(logging.StreamHandler):
         logging.DTS_TESTER_CMD: '',  # SYSTEM
         logging.SUITE_DUT_CMD: '',  # SYSTEM
         logging.SUITE_TESTER_CMD: '',  # SYSTEM
-        logging.DTS_IXIA_CMD: '',  # SYSTEM
-        logging.DTS_IXIA_OUTPUT: '',  # SYSTEM
         logging.DTS_PKTGEN_CMD: '',  # SYSTEM
         logging.DTS_PKTGEN_OUTPUT: '',  # SYSTEM
         logging.DTS_VIRTDUT_CMD: '',  # SYSTEM
@@ -317,9 +303,6 @@  class DTSLOG(BaseLoggerAdapter):
             self.info_lvl = logging.DTS_TESTER_CMD
             self.debug_lvl = logging.DTS_TESTER_OUTPUT
             self.warn_lvl = logging.DTS_TESTER_RESULT
-        elif crb.startswith('ixia'):
-            self.info_lvl = logging.DTS_IXIA_CMD
-            self.debug_lvl = logging.DTS_IXIA_OUTPUT
         elif crb.startswith('pktgen'):
             self.info_lvl = logging.DTS_PKTGEN_CMD
             self.debug_lvl = logging.DTS_PKTGEN_OUTPUT
@@ -352,9 +335,6 @@  class DTSLOG(BaseLoggerAdapter):
         elif crb == 'tester':
             self.info_lvl = logging.SUITE_TESTER_CMD
             self.debug_lvl = logging.SUITE_TESTER_OUTPUT
-        elif crb == 'ixia':
-            self.info_lvl = logging.DTS_IXIA_CMD
-            self.debug_lvl = logging.DTS_IXIA_OUTPUT
         elif crb == 'pktgen':
             self.info_lvl = logging.DTS_PKTGEN_CMD
             self.debug_lvl = logging.DTS_PKTGEN_OUTPUT
diff --git a/framework/project_dpdk.py b/framework/project_dpdk.py
index d96f8d63..51d32229 100644
--- a/framework/project_dpdk.py
+++ b/framework/project_dpdk.py
@@ -40,7 +40,7 @@  from crb import Crb
 from dut import Dut
 from tester import Tester
 from logger import getLogger
-from settings import IXIA, DRIVERS
+from settings import DRIVERS
 from utils import RED
 
 
@@ -707,16 +707,6 @@  class DPDKtester(Tester):
         self.tester_prerequisites()
 
         self.set_promisc()
-        # use software pktgen for performance test
-        if perf_test is True:
-            try:
-                if self.crb[IXIA] is not None:
-                    self.logger.info("Use hardware packet generator")
-            except Exception as e:
-                self.logger.warning("Use default software pktgen")
-                out = self.send_expect("ls /root/igb_uio.ko", "# ")
-                assert ("No such file or directory" not in out), "Can not find /root/igb_uio.ko for performance"
-                self.setup_memory()
 
         self.stage = "post-init"
 
diff --git a/framework/settings.py b/framework/settings.py
index fe7c01b5..c08b8709 100644
--- a/framework/settings.py
+++ b/framework/settings.py
@@ -226,7 +226,6 @@  TIMEOUT = 15
 """
 Global macro for dts.
 """
-IXIA = "ixia"
 PKTGEN = "pktgen"
 PKTGEN_DPDK = "dpdk"
 PKTGEN_TREX = "trex"
diff --git a/framework/tester.py b/framework/tester.py
index ec233b8a..8f6e97ae 100644
--- a/framework/tester.py
+++ b/framework/tester.py
@@ -38,10 +38,9 @@  import subprocess
 import os
 from time import sleep
 from settings import NICS, load_global_setting, PERF_SETTING
-from settings import IXIA, USERNAME, PKTGEN, PKTGEN_GRP
+from settings import USERNAME, PKTGEN, PKTGEN_GRP
 from crb import Crb
 from net_device import GetNicObj
-from etgen import IxiaPacketGenerator, SoftwarePacketGenerator
 import random
 from utils import (GREEN, convert_int2ip, convert_ip2int,
                    check_crb_python_version)
@@ -78,7 +77,6 @@  class Tester(Crb):
         self.bgItf = ''
         self.re_run_time = 0
         self.pktgen = None
-        self.ixia_packet_gen = None
         self.tmp_scapy_module_dir = '/tmp/dep'
         # prepare for scapy env
         self.scapy_sessions_li = list()
@@ -130,10 +128,7 @@  class Tester(Crb):
         if self.it_uses_external_generator():
             if self.is_pktgen:
                 self.pktgen_init()
-            else:
-                self.ixia_packet_gen = IxiaPacketGenerator(self)
             return
-        self.packet_gen = SoftwarePacketGenerator(self)
 
     def set_re_run(self, re_run_time):
         """
@@ -183,20 +178,12 @@  class Tester(Crb):
         try:
             # if pktgen_group is set, take pktgen config file as first selection
             if self.is_pktgen:
-                return True 
-            elif self.crb[IXIA] is not None:
                 return True
         except Exception as e:
             return False
 
         return False
 
-    def get_external_traffic_generator(self):
-        """
-        Return IXIA object.
-        """
-        return self.crb[IXIA]
-
     def it_uses_external_generator(self):
         """
         Check whether IXIA generator is ready for performance test.
@@ -456,8 +443,6 @@  class Tester(Crb):
             if self.it_uses_external_generator():
                 if self.is_pktgen:
                     self._scan_pktgen_ports()
-                else:
-                    self.ports_info.extend(self.ixia_packet_gen.get_ports())
             self.save_serializer_ports()
 
         for port_info in self.ports_info:
@@ -572,8 +557,6 @@  class Tester(Crb):
                                 self.ports_info[localPort]['pci'], mac, ipv6)
             elif self.ports_info[localPort]['type'].lower() == 'trex':
                 return "Not implemented yet"
-        elif self.ports_info[localPort]['type'].lower() in 'ixia':
-            return self.ixia_packet_gen.send_ping6(self.ports_info[localPort]['pci'], mac, ipv6)
         else:
             return self.send_expect("ping6 -w 5 -c 5 -A %s%%%s" % (ipv6, self.ports_info[localPort]['intf']), "# ", 10)
 
@@ -671,60 +654,6 @@  class Tester(Crb):
 
         return out
 
-    def traffic_generator_throughput(self, portList, rate_percent=100, delay=5):
-        """
-        Run throughput performance test on specified ports.
-        """
-        if self.check_port_list(portList, 'ixia'):
-            return self.ixia_packet_gen.throughput(portList, rate_percent, delay)
-        if not self.check_port_list(portList):
-            self.logger.warning("exception by mixed port types")
-            return None
-        return self.packet_gen.throughput(portList, rate_percent)
-
-    def verify_packet_order(self, portList, delay):
-        if self.check_port_list(portList, 'ixia'):
-            return self.ixia_packet_gen.is_packet_ordered(portList, delay)
-        else:
-            self.logger.warning("Only ixia port support check verify packet order function")
-            return False
-
-    def run_rfc2544(self, portlist, delay=120, permit_loss_rate=0):
-        """
-        test_rate: the line rate we are going to test.
-        """
-        test_rate = float(100)
-
-        self.logger.info("test rate: %f " % test_rate)
-        loss_rate, tx_num, rx_num = self.traffic_generator_loss(portlist, test_rate, delay)
-        while loss_rate > permit_loss_rate:
-                test_rate = float(1 - loss_rate) * test_rate
-                loss_rate, tx_num, rx_num = self.traffic_generator_loss(portlist, test_rate, delay)
-
-        self.logger.info("zero loss rate is %s" % test_rate)
-        return test_rate, tx_num, rx_num
-
-
-    def traffic_generator_loss(self, portList, ratePercent, delay=60):
-        """
-        Run loss performance test on specified ports.
-        """
-        if self.check_port_list(portList, 'ixia'):
-            return self.ixia_packet_gen.loss(portList, ratePercent, delay)
-        elif not self.check_port_list(portList):
-            self.logger.warning("exception by mixed port types")
-            return None
-        return self.packet_gen.loss(portList, ratePercent)
-
-    def traffic_generator_latency(self, portList, ratePercent=100, delay=5):
-        """
-        Run latency performance test on specified ports.
-        """
-        if self.check_port_list(portList, 'ixia'):
-            return self.ixia_packet_gen.latency(portList, ratePercent, delay)
-        else:
-            return None
-
     def parallel_transmit_ptks(self, pkt=None, intf='', send_times=1, interval=0.01):
         """
         Callable function for parallel processes
@@ -824,20 +753,6 @@  class Tester(Crb):
 
         return True
 
-    def extend_external_packet_generator(self, clazz, instance):
-        """
-        Update packet generator function, will implement later.
-        """
-        # packet generator has forbidden suite class to override parent class methods  
-        if self.is_pktgen:
-            return
-        # discard this in future
-        if self.it_uses_external_generator():
-            self.ixia_packet_gen.__class__ = clazz
-            current_attrs = instance.__dict__
-            instance.__dict__ = self.ixia_packet_gen.__dict__
-            instance.__dict__.update(current_attrs)
-
     def tcpdump_sniff_packets(self, intf, count=0, filters=None, lldp_forbid=True):
         """
         Wrapper for packet module sniff_packets
@@ -879,9 +794,6 @@  class Tester(Crb):
                 if 'start_trex' in list(self.pktgen.conf.keys()):
                     self.restore_trex_interfaces()
                 self.pktgen = None
-            elif self.ixia_packet_gen:
-                self.ixia_packet_gen.close()
-                self.ixia_packet_gen = None
 
         if self.scapy_sessions_li:
             for i in self.scapy_sessions_li: