mirror of
				https://github.com/Telecominfraproject/wlan-lanforge-scripts.git
				synced 2025-11-03 12:18:00 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			510 lines
		
	
	
		
			20 KiB
		
	
	
	
		
			Python
		
	
	
		
			Executable File
		
	
	
	
	
			
		
		
	
	
			510 lines
		
	
	
		
			20 KiB
		
	
	
	
		
			Python
		
	
	
		
			Executable File
		
	
	
	
	
#!/usr/bin/env python3
 | 
						|
import sys
 | 
						|
if sys.version_info[0] != 3:
 | 
						|
    print("This script requires Python 3")
 | 
						|
    exit(1)
 | 
						|
if 'py-json' not in sys.path:
 | 
						|
    sys.path.append('py-json')
 | 
						|
import traceback
 | 
						|
 | 
						|
from LANforge import LFUtils
 | 
						|
from LANforge.LFUtils import *
 | 
						|
from LANforge.lfcli_base import LFCliBase
 | 
						|
from generic_cx import GenericCx
 | 
						|
 | 
						|
mgrURL = "http://localhost:8080/"
 | 
						|
staName = "sta0"
 | 
						|
staNameUri = "port/1/1/" + staName
 | 
						|
suppress_related = True
 | 
						|
 | 
						|
class ConnectTest(LFCliBase):
 | 
						|
    def __init__(self, lfhost, lfport):
 | 
						|
        super().__init__(lfhost, lfport, True)
 | 
						|
        super().check_connect()
 | 
						|
 | 
						|
    # compare pre-test values to post-test values
 | 
						|
    @staticmethod
 | 
						|
    def CompareVals(_name, preVal, postVal):
 | 
						|
        print("Comparing %s" % _name)
 | 
						|
        if postVal > preVal:
 | 
						|
            print("     Test Passed")
 | 
						|
        else:
 | 
						|
            print(" Test Failed: %s did not increase after 5 seconds" % _name)
 | 
						|
 | 
						|
    def run(self):
 | 
						|
        print("See home/lanforge/Documents/connectTestLogs/connectTestLatest for specific values on latest test")
 | 
						|
 | 
						|
        eth1IP = super().json_get("/port/1/1/eth1")
 | 
						|
        if eth1IP['interface']['ip'] == "0.0.0.0":
 | 
						|
            print("Warning: Eth1 lacks ip address")
 | 
						|
            exit(1)
 | 
						|
 | 
						|
        # Create stations and turn dhcp on
 | 
						|
        print("Creating station and turning on dhcp")
 | 
						|
 | 
						|
        response = super().json_get("/" + staNameUri)
 | 
						|
        if response is not None:
 | 
						|
            if response["interface"] is not None:
 | 
						|
                print("removing old station")
 | 
						|
                removePort(1, staName, mgrURL)
 | 
						|
                waitUntilPortsDisappear(mgrURL, [staName])
 | 
						|
                time.sleep(1)
 | 
						|
 | 
						|
        url = "cli-json/add_sta"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "radio": "wiphy0",
 | 
						|
            "sta_name": staName,
 | 
						|
            "ssid": "jedway-wpa2-x2048-4-4",
 | 
						|
            "key": "jedway-wpa2-x2048-4-4",
 | 
						|
            "mode": 0,
 | 
						|
            "mac": "xx:xx:xx:xx:*:xx",
 | 
						|
            "flags": (0x400 + 0x20000 + 0x1000000000)  # create admin down
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        wait_until_ports_appear(mgrURL, [staName], True)
 | 
						|
        time.sleep(8)
 | 
						|
        reqURL = "cli-json/set_port"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": staName,
 | 
						|
            "current_flags": (0x1 + 0x80000000),
 | 
						|
            "interest": (0x2 + 0x4000 + 0x800000)  # current, dhcp, down,
 | 
						|
        }
 | 
						|
        super().json_post(reqURL, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(0.5)
 | 
						|
        super().json_post("cli-json/set_port", portUpRequest(1, staName))
 | 
						|
 | 
						|
        reqURL = "cli-json/nc_show_ports"
 | 
						|
        data = {"shelf": 1,
 | 
						|
                "resource": 1,
 | 
						|
                "port": staName,
 | 
						|
                "probe_flags": 1}
 | 
						|
        super().json_post(reqURL, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(0.5)
 | 
						|
        waitUntilPortsAdminUp(1, mgrURL, [staName])
 | 
						|
 | 
						|
        duration = 0
 | 
						|
        maxTime = 300
 | 
						|
        ip = "0.0.0.0"
 | 
						|
        while (ip == "0.0.0.0") and (duration < maxTime):
 | 
						|
            station_info = super().json_get("/" + staNameUri + "?fields=port,ip")
 | 
						|
            LFUtils.debug_printer.pprint(station_info)
 | 
						|
            if (station_info is not None) and ("interface" in station_info) and ("ip" in station_info["interface"]):
 | 
						|
                ip = station_info["interface"]["ip"]
 | 
						|
            if ip == "0.0.0.0":
 | 
						|
                duration += 4
 | 
						|
                time.sleep(4)
 | 
						|
            else:
 | 
						|
                break
 | 
						|
 | 
						|
        if duration >= maxTime:
 | 
						|
            print(staName+" failed to get an ip. Ending test")
 | 
						|
            print("Cleaning up...")
 | 
						|
            removePort(1, staName, mgrURL)
 | 
						|
            sys.exit(1)
 | 
						|
 | 
						|
        print("Creating endpoints and cross connects")
 | 
						|
 | 
						|
        #==============| ENDPOINT CREATION |=================
 | 
						|
        # create l4 endpoint
 | 
						|
        url = "/cli-json/add_l4_endp"
 | 
						|
        data = {
 | 
						|
            "alias": "l4Test",
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": staName,
 | 
						|
            "type": "l4_generic",
 | 
						|
            "timeout": 1000,
 | 
						|
            "url_rate": 600,
 | 
						|
            "url": "dl http://localhost/ /dev/null",
 | 
						|
            "proxy_port" : "NA"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        data = {
 | 
						|
            "endpoint": "all"
 | 
						|
        }
 | 
						|
        super().json_post("/cli-json/nc_show_endpoints", data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(5)
 | 
						|
 | 
						|
        # create fileio endpoint
 | 
						|
        url = "/cli-json/add_file_endp"
 | 
						|
        data = {
 | 
						|
            "alias": "fioTest",
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": staName,
 | 
						|
            "type": "fe_nfs",
 | 
						|
            "directory": "/mnt/fe-test"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(1)
 | 
						|
        data = {
 | 
						|
            "endpoint": "all"
 | 
						|
        }
 | 
						|
        super().json_post("/cli-json/nc_show_endpoints", data)
 | 
						|
        time.sleep(1)
 | 
						|
 | 
						|
        # create generic endpoints
 | 
						|
        genl = GenericCx(lfclient_host=self.lfclient_host, lfclient_port=self.lfclient_port)
 | 
						|
        genl.createGenEndp("genTest1", 1, 1, staName, "gen_generic")
 | 
						|
        genl.createGenEndp("genTest2", 1, 1, staName, "gen_generic")
 | 
						|
        genl.setFlags("genTest1", "ClearPortOnStart", 1)
 | 
						|
        genl.setFlags("genTest2", "ClearPortOnStart", 1)
 | 
						|
        genl.setFlags("genTest2", "Unmanaged", 1)
 | 
						|
        genl.setCmd("genTest1", "lfping  -i 0.1 -I %s 10.40.0.1" % staName)
 | 
						|
        time.sleep(.05)
 | 
						|
        data = {
 | 
						|
            "endpoint": "all"
 | 
						|
        }
 | 
						|
        super().json_post("/cli-json/nc_show_endpoints", data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        # create redirects for wanlink
 | 
						|
        url = "/cli-json/add_rdd"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd0",
 | 
						|
            "peer_ifname": "rdd1"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        url = "/cli-json/add_rdd"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd1",
 | 
						|
            "peer_ifname": "rdd0"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # reset redirect ports
 | 
						|
        url = "/cli-json/reset_port"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd0"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        url = "/cli-json/reset_port"
 | 
						|
        data = {
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd1"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # create wanlink endpoints
 | 
						|
        url = "/cli-json/add_wl_endp"
 | 
						|
        data = {
 | 
						|
            "alias": "wlan0",
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd0",
 | 
						|
            "latency": 20,
 | 
						|
            "max_rate": 1544000
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        url = "/cli-json/add_wl_endp"
 | 
						|
        data = {
 | 
						|
            "alias": "wlan1",
 | 
						|
            "shelf": 1,
 | 
						|
            "resource": 1,
 | 
						|
            "port": "rdd1",
 | 
						|
            "latency": 30,
 | 
						|
            "max_rate": 1544000
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
        data = {
 | 
						|
            "endpoint": "all"
 | 
						|
        }
 | 
						|
        super().json_post("/cli-json/nc_show_endpoints", data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        time.sleep(10)
 | 
						|
 | 
						|
        #==============| CX CREATION |===================
 | 
						|
        # create cx for tcp and udp
 | 
						|
        cmd = ("./lf_firemod.pl --action create_cx --cx_name testTCP --use_ports %s,eth1 --use_speeds  360000,"
 | 
						|
               "150000 --endp_type tcp > ~/Documents/connectTestLogs/connectTestLatest.log" % staName)
 | 
						|
        execWrap(cmd)
 | 
						|
        cmd = ("./lf_firemod.pl --action create_cx --cx_name testUDP --use_ports %s,eth1 --use_speeds  360000,"
 | 
						|
               "150000 --endp_type udp >> ~/Documents/connectTestLogs/connectTestLatest.log" % staName)
 | 
						|
        execWrap(cmd)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # create cx for l4_endp
 | 
						|
        url = "/cli-json/add_cx"
 | 
						|
        data = {
 | 
						|
            "alias": "CX_l4Test",
 | 
						|
            "test_mgr": "default_tm",
 | 
						|
            "tx_endp": "l4Test",
 | 
						|
            "rx_endp": "NA"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # create fileio cx
 | 
						|
        url = "/cli-json/add_cx"
 | 
						|
        data = {
 | 
						|
            "alias": "CX_fioTest",
 | 
						|
            "test_mgr": "default_tm",
 | 
						|
            "tx_endp": "fioTest",
 | 
						|
            "rx_endp": "NA"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # create generic cx
 | 
						|
        url = "/cli-json/add_cx"
 | 
						|
        data = {
 | 
						|
            "alias": "CX_genTest1",
 | 
						|
            "test_mgr": "default_tm",
 | 
						|
            "tx_endp": "genTest1",
 | 
						|
            "rx_endp": "genTest2"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.05)
 | 
						|
 | 
						|
        # create wanlink cx
 | 
						|
        url = "/cli-json/add_cx"
 | 
						|
        data = {
 | 
						|
            "alias": "CX_wlan0",
 | 
						|
            "test_mgr": "default_tm",
 | 
						|
            "tx_endp": "wlan0",
 | 
						|
            "rx_endp": "wlan1"
 | 
						|
        }
 | 
						|
        super().json_post(url, data, suppress_related_commands_=suppress_related)
 | 
						|
        time.sleep(.5)
 | 
						|
        data = {
 | 
						|
            "endpoint": "all"
 | 
						|
        }
 | 
						|
        super().json_post("/cli-json/nc_show_endpoints", data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
        cxNames = ["testTCP", "testUDP", "CX_l4Test", "CX_fioTest", "CX_genTest1", "CX_wlan0"]
 | 
						|
 | 
						|
        # get data before running traffic
 | 
						|
        try:
 | 
						|
            get_info = {}
 | 
						|
            sleep(5)
 | 
						|
            get_info['testTCPA'] = super().json_get("/endp/testTCP-A?fields=tx+bytes,rx+bytes")
 | 
						|
            get_info['testTCPB'] = super().json_get("/endp/testTCP-B?fields=tx+bytes,rx+bytes")
 | 
						|
            get_info['testUDPA'] = super().json_get("/endp/testUDP-A?fields=tx+bytes,rx+bytes")
 | 
						|
            get_info['testUDPB'] = super().json_get("/endp/testUDP-B?fields=tx+bytes,rx+bytes")
 | 
						|
            get_info['l4Test'] = super().json_get("/layer4/l4Test?fields=bytes-rd")
 | 
						|
            get_info['genTest1'] = super().json_get("/generic/genTest1?fields=last+results")
 | 
						|
            get_info['wlan0'] = super().json_get("/wl_ep/wlan0")
 | 
						|
            get_info['wlan1'] = super().json_get("/wl_ep/wlan1")
 | 
						|
 | 
						|
            for name in get_info:
 | 
						|
                #print("==================\n"+name+"\n====================")
 | 
						|
                if 'endpoint' not in get_info[name]:
 | 
						|
                    print(get_info[name])
 | 
						|
                    raise ValueError ("%s missing endpoint value" % name)
 | 
						|
 | 
						|
            testTCPATX = get_info['testTCPA']['endpoint']['tx bytes']
 | 
						|
            testTCPARX = get_info['testTCPA']['endpoint']['rx bytes']
 | 
						|
            testTCPBTX = get_info['testTCPB']['endpoint']['tx bytes']
 | 
						|
            testTCPBRX = get_info['testTCPB']['endpoint']['rx bytes']
 | 
						|
 | 
						|
            testUDPATX = get_info['testUDPA']['endpoint']['tx bytes']
 | 
						|
            testUDPARX = get_info['testUDPA']['endpoint']['rx bytes']
 | 
						|
            testUDPBTX = get_info['testUDPB']['endpoint']['tx bytes']
 | 
						|
            testUDPBRX = get_info['testUDPB']['endpoint']['rx bytes']
 | 
						|
 | 
						|
            l4TestBR = get_info['l4Test']['endpoint']['bytes-rd']
 | 
						|
            genTest1LR = get_info['genTest1']['endpoint']['last results']
 | 
						|
 | 
						|
            wlan0TXB = get_info['wlan0']['endpoint']['tx bytes']
 | 
						|
            wlan0RXP = get_info['wlan0']['endpoint']['rx pkts']
 | 
						|
            wlan1TXB = get_info['wlan1']['endpoint']['tx bytes']
 | 
						|
            wlan1RXP = get_info['wlan1']['endpoint']['rx pkts']
 | 
						|
        except Exception as e:
 | 
						|
            print("Something went wrong")
 | 
						|
            print(e)
 | 
						|
            print("Cleaning up...")
 | 
						|
            time.sleep(15)
 | 
						|
            LFUtils.removePort(1, staName, mgrURL)
 | 
						|
            endpNames = ["testTCP-A", "testTCP-B",
 | 
						|
                         "testUDP-A", "testUDP-B",
 | 
						|
                         "l4Test", "fioTest",
 | 
						|
                         "genTest1", "genTest2",
 | 
						|
                         "wlan0", "wlan1"]
 | 
						|
            removeCX(mgrURL, cxNames)
 | 
						|
            removeEndps(mgrURL, endpNames)
 | 
						|
            traceback.print_stack()
 | 
						|
            sys.exit(1)
 | 
						|
 | 
						|
        # start cx traffic
 | 
						|
        print("\nStarting CX Traffic")
 | 
						|
        for name in range(len(cxNames)):
 | 
						|
            cmd = (
 | 
						|
                "./lf_firemod.pl --mgr localhost --quiet yes --action do_cmd --cmd \"set_cx_state default_tm %s RUNNING\" >> /tmp/connectTest.log" % (cxNames[name]))
 | 
						|
            execWrap(cmd)
 | 
						|
 | 
						|
        # print("Sleeping for 5 seconds")
 | 
						|
        time.sleep(5)
 | 
						|
 | 
						|
        # show tx and rx bytes for ports
 | 
						|
 | 
						|
        os.system("echo  eth1 >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_portmod.pl --quiet 1 --manager localhost --port_name eth1 --show_port \"Txb,Rxb\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  %s >> ~/Documents/connectTestLogs/connectTestLatest.log" % staName)
 | 
						|
        cmd = (
 | 
						|
            "./lf_portmod.pl --quiet 1 --manager localhost --port_name %s --show_port \"Txb,Rxb\" >> ~/Documents/connectTestLogs/connectTestLatest.log" % staName)
 | 
						|
        execWrap(cmd)
 | 
						|
 | 
						|
        # show tx and rx for endpoints PERL
 | 
						|
        os.system("echo  TestTCP-A >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name testTCP-A --endp_vals \"Tx Bytes,Rx Bytes\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  TestTCP-B >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name testTCP-B --endp_vals  \"Tx Bytes,Rx Bytes\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  TestUDP-A >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name testUDP-A --endp_vals  \"Tx Bytes,Rx Bytes\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  TestUDP-B >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name testUDP-B --endp_vals  \"Tx Bytes,Rx Bytes\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  l4Test >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name l4Test --endp_vals Bytes-Read-Total >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  fioTest >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name fioTest --endp_vals \"Bytes Written,Bytes Read\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  genTest1 >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name genTest1 >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  wlan0 >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name wlan0 --endp_vals \"Rx Pkts,Tx Bytes,Cur-Backlog,Dump File,Tx3s\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
        os.system("echo  wlan1 >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        cmd = (
 | 
						|
            "./lf_firemod.pl --action show_endp --endp_name wlan1 --endp_vals \"Rx Pkts,Tx Bytes,Cur-Backlog,Dump File,Tx3s\" >> ~/Documents/connectTestLogs/connectTestLatest.log")
 | 
						|
        execWrap(cmd)
 | 
						|
 | 
						|
        # stop cx traffic
 | 
						|
        print("Stopping CX Traffic")
 | 
						|
        for name in range(len(cxNames)):
 | 
						|
            cmd = (
 | 
						|
                "./lf_firemod.pl --mgr localhost --quiet yes --action do_cmd --cmd \"set_cx_state default_tm %s STOPPED\"  >> /tmp/connectTest.log" % (cxNames[name]))
 | 
						|
            execWrap(cmd)
 | 
						|
        # print("Sleeping for 15 seconds")
 | 
						|
        time.sleep(15)
 | 
						|
 | 
						|
        # get data for endpoints JSON
 | 
						|
        print("Collecting Data")
 | 
						|
        try:
 | 
						|
 | 
						|
            ptestTCPA = super().json_get("endp/testTCP-A?fields=tx+bytes,rx+bytes")
 | 
						|
            ptestTCPATX = ptestTCPA['endpoint']['tx bytes']
 | 
						|
            ptestTCPARX = ptestTCPA['endpoint']['rx bytes']
 | 
						|
 | 
						|
            ptestTCPB = super().json_get("/endp/testTCP-B?fields=tx+bytes,rx+bytes")
 | 
						|
            ptestTCPBTX = ptestTCPB['endpoint']['tx bytes']
 | 
						|
            ptestTCPBRX = ptestTCPB['endpoint']['rx bytes']
 | 
						|
 | 
						|
            ptestUDPA = super().json_get("/endp/testUDP-A?fields=tx+bytes,rx+bytes")
 | 
						|
            ptestUDPATX = ptestUDPA['endpoint']['tx bytes']
 | 
						|
            ptestUDPARX = ptestUDPA['endpoint']['rx bytes']
 | 
						|
 | 
						|
            ptestUDPB = super().json_get("/endp/testUDP-B?fields=tx+bytes,rx+bytes")
 | 
						|
            ptestUDPBTX = ptestUDPB['endpoint']['tx bytes']
 | 
						|
            ptestUDPBRX = ptestUDPB['endpoint']['rx bytes']
 | 
						|
 | 
						|
            pl4Test = super().json_get("/layer4/l4Test?fields=bytes-rd")
 | 
						|
            pl4TestBR = pl4Test['endpoint']['bytes-rd']
 | 
						|
 | 
						|
            pgenTest1 = super().json_get("/generic/genTest1?fields=last+results")
 | 
						|
            pgenTest1LR = pgenTest1['endpoint']['last results']
 | 
						|
 | 
						|
            pwlan0 = super().json_get("/wl_ep/wlan0")
 | 
						|
            pwlan0TXB = pwlan0['endpoint']['tx bytes']
 | 
						|
            pwlan0RXP = pwlan0['endpoint']['rx pkts']
 | 
						|
            pwlan1 = super().json_get("/wl_ep/wlan1")
 | 
						|
            pwlan1TXB = pwlan1['endpoint']['tx bytes']
 | 
						|
            pwlan1RXP = pwlan1['endpoint']['rx pkts']
 | 
						|
        except Exception as e:
 | 
						|
            print("Something went wrong")
 | 
						|
            print(e)
 | 
						|
            print("Cleaning up...")
 | 
						|
            time.sleep(15)
 | 
						|
            reqURL = "/cli-json/rm_vlan"
 | 
						|
            data = {
 | 
						|
                "shelf": 1,
 | 
						|
                "resource": 1,
 | 
						|
                "port": staName
 | 
						|
            }
 | 
						|
            super().json_post(reqURL, data, suppress_related_commands_=suppress_related)
 | 
						|
 | 
						|
            endpNames = ["testTCP-A", "testTCP-B",
 | 
						|
                         "testUDP-A", "testUDP-B",
 | 
						|
                         "l4Test", "fioTest",
 | 
						|
                         "genTest1", "genTest2",
 | 
						|
                         "wlan0", "wlan1"]
 | 
						|
            removeCX(mgrURL, cxNames)
 | 
						|
            removeEndps(mgrURL, endpNames)
 | 
						|
            sys.exit(1)
 | 
						|
 | 
						|
        # print("Sleeping for 5 seconds")
 | 
						|
        time.sleep(5)
 | 
						|
 | 
						|
        print("\n")
 | 
						|
        self.CompareVals("testTCP-A TX", testTCPATX, ptestTCPATX)
 | 
						|
        self.CompareVals("testTCP-A RX", testTCPARX, ptestTCPARX)
 | 
						|
        self.CompareVals("testTCP-B TX", testTCPBTX, ptestTCPBTX)
 | 
						|
        self.CompareVals("testTCP-B RX", testTCPBRX, ptestTCPBRX)
 | 
						|
        self.CompareVals("testUDP-A TX", testUDPATX, ptestUDPATX)
 | 
						|
        self.CompareVals("testUDP-A RX", testUDPARX, ptestUDPARX)
 | 
						|
        self.CompareVals("testUDP-B TX", testUDPBTX, ptestUDPBTX)
 | 
						|
        self.CompareVals("testUDP-B RX", testUDPBRX, ptestUDPBRX)
 | 
						|
        self.CompareVals("l4Test Bytes Read", l4TestBR, pl4TestBR)
 | 
						|
        self.CompareVals("genTest1 Last Results", genTest1LR, pgenTest1LR)
 | 
						|
        self.CompareVals("wlan0 TX Bytes", wlan0TXB, pwlan0TXB)
 | 
						|
        self.CompareVals("wlan0 RX Pkts", wlan0RXP, pwlan0RXP)
 | 
						|
        self.CompareVals("wlan1 TX Bytes", wlan1TXB, pwlan1TXB)
 | 
						|
        self.CompareVals("wlan1 RX Pkts", wlan1RXP, pwlan1RXP)
 | 
						|
        print("\n")
 | 
						|
 | 
						|
        # remove all endpoints and cxs
 | 
						|
        print("Cleaning up...")
 | 
						|
        LFUtils.removePort(1, staName, mgrURL)
 | 
						|
 | 
						|
        endpNames = ["testTCP-A", "testTCP-B",
 | 
						|
                     "testUDP-A", "testUDP-B",
 | 
						|
                     "l4Test", "fioTest",
 | 
						|
                     "genTest1", "genTest2",
 | 
						|
                     "wlan0", "wlan1"]
 | 
						|
        removeCX(mgrURL, cxNames)
 | 
						|
        removeEndps(mgrURL, endpNames)
 | 
						|
 | 
						|
 | 
						|
# ~class
 | 
						|
 | 
						|
def main():
 | 
						|
    lfclient_host = "localhost"
 | 
						|
    lfclient_port = 8080
 | 
						|
    test = ConnectTest(lfclient_host, lfclient_port)
 | 
						|
    test.run()
 | 
						|
 | 
						|
 | 
						|
if __name__ == "__main__":
 | 
						|
    main()
 |