scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-11-04 04:38:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

sta_connect.py: removing unecessary variables

Browse Source
This commit is contained in:
Jed Reynolds
2020-06-05 15:18:03 -07:00
parent 83304a1c30
commit 478d3ec768
1 changed files with 14 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
py-scripts/sta_connect.py
View File

@@ -84,7 +84,6 @@ class StaConnect(LFCliBase):
# Create stations and turn dhcp on # Create stations and turn dhcp on
print("Creating station %s and turning on dhcp..." % self.sta_name) print("Creating station %s and turning on dhcp..." % self.sta_name)
url = "cli-json/add_sta"
flags = 0x10000 flags = 0x10000
if "" != self.dut_passwd: if "" != self.dut_passwd:
flags += 0x400 flags += 0x400
@@ -100,9 +99,8 @@ class StaConnect(LFCliBase):
"flags": flags # verbose, wpa2 "flags": flags # verbose, wpa2
} }
print("Adding new station %s " % self.sta_name) print("Adding new station %s " % self.sta_name)
self.json_post(url, data) self.json_post("/cli-json/add_sta", data)
reqURL = "cli-json/set_port"
data = { data = {
"shelf": 1, "shelf": 1,
"resource": self.resource, "resource": self.resource,
@@ -111,14 +109,13 @@ class StaConnect(LFCliBase):
"interest": 0x4002 # set dhcp, current flags "interest": 0x4002 # set dhcp, current flags
} }
print("Configuring %s..." % self.sta_name) print("Configuring %s..." % self.sta_name)
self.json_post(reqURL, data) self.json_post("/cli-json/set_port", data)
reqURL = "cli-json/nc_show_ports"
data = {"shelf": 1, data = {"shelf": 1,
"resource": self.resource, "resource": self.resource,
"port": self.sta_name, "port": self.sta_name,
"probe_flags": 1} "probe_flags": 1}
self.json_post(reqURL, data) self.json_post("/cli-json/nc_show_ports", data)
LFUtils.waitUntilPortsAdminUp(self.resource, self.mgr_url, [self.sta_name]) LFUtils.waitUntilPortsAdminUp(self.resource, self.mgr_url, [self.sta_name])
# station_info = self.jsonGet(self.mgr_url, "%s?fields=port,ip,ap" % (self.getStaUrl())) # station_info = self.jsonGet(self.mgr_url, "%s?fields=port,ip,ap" % (self.getStaUrl()))
@@ -168,7 +165,6 @@ class StaConnect(LFCliBase):
# create endpoints and cxs # create endpoints and cxs
# Create UDP endpoints # Create UDP endpoints
reqURL = "cli-json/add_endp"
data = { data = {
"alias": "testUDP-A", "alias": "testUDP-A",
"shelf": 1, "shelf": 1,
@@ -178,9 +174,8 @@ class StaConnect(LFCliBase):
"ip_port": "-1", "ip_port": "-1",
"min_rate": 1000000 "min_rate": 1000000
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_endp", data)
reqURL = "cli-json/add_endp"
data = { data = {
"alias": "testUDP-B", "alias": "testUDP-B",
"shelf": 1, "shelf": 1,
@@ -190,20 +185,18 @@ class StaConnect(LFCliBase):
"ip_port": "-1", "ip_port": "-1",
"min_rate": 1000000 "min_rate": 1000000
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_endp", data)
# Create CX # Create CX
reqURL = "cli-json/add_cx"
data = { data = {
"alias": "testUDP", "alias": "testUDP",
"test_mgr": "default_tm", "test_mgr": "default_tm",
"tx_endp": "testUDP-A", "tx_endp": "testUDP-A",
"rx_endp": "testUDP-B", "rx_endp": "testUDP-B",
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_cx", data)
# Create TCP endpoints # Create TCP endpoints
reqURL = "cli-json/add_endp"
data = { data = {
"alias": "testTCP-A", "alias": "testTCP-A",
"shelf": 1, "shelf": 1,
@@ -213,9 +206,8 @@ class StaConnect(LFCliBase):
"ip_port": "0", "ip_port": "0",
"min_rate": 1000000 "min_rate": 1000000
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_endp", data)
reqURL = "cli-json/add_endp"
data = { data = {
"alias": "testTCP-B", "alias": "testTCP-B",
"shelf": 1, "shelf": 1,
@@ -225,17 +217,16 @@ class StaConnect(LFCliBase):
"ip_port": "-1", "ip_port": "-1",
"min_rate": 1000000 "min_rate": 1000000
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_endp", data)
# Create CX # Create CX
reqURL = "cli-json/add_cx"
data = { data = {
"alias": "testTCP", "alias": "testTCP",
"test_mgr": "default_tm", "test_mgr": "default_tm",
"tx_endp": "testTCP-A", "tx_endp": "testTCP-A",
"rx_endp": "testTCP-B", "rx_endp": "testTCP-B",
} }
self.json_post(reqURL, data) self.json_post("/cli-json/add_cx", data)
cxNames = ["testTCP", "testUDP"] cxNames = ["testTCP", "testUDP"]
endpNames = ["testTCP-A", "testTCP-B", endpNames = ["testTCP-A", "testTCP-B",
@@ -244,46 +235,42 @@ class StaConnect(LFCliBase):
# start cx traffic # start cx traffic
print("\nStarting CX Traffic") print("\nStarting CX Traffic")
for name in range(len(cxNames)): for name in range(len(cxNames)):
reqURL = "cli-json/set_cx_state"
data = { data = {
"test_mgr": "ALL", "test_mgr": "ALL",
"cx_name": cxNames[name], "cx_name": cxNames[name],
"cx_state": "RUNNING" "cx_state": "RUNNING"
} }
self.json_post(reqURL, data) self.json_post("/cli-json/set_cx_state", data)
# Refresh stats # Refresh stats
print("\nRefresh CX stats") print("\nRefresh CX stats")
for name in range(len(cxNames)): for name in range(len(cxNames)):
reqURL = "cli-json/show_cxe"
data = { data = {
"test_mgr": "ALL", "test_mgr": "ALL",
"cross_connect": cxNames[name] "cross_connect": cxNames[name]
} }
self.json_post(reqURL, data) self.json_post("/cli-json/show_cxe", data)
time.sleep(15) time.sleep(15)
# stop cx traffic # stop cx traffic
print("\nStopping CX Traffic") print("\nStopping CX Traffic")
for name in range(len(cxNames)): for name in range(len(cxNames)):
reqURL = "cli-json/set_cx_state"
data = { data = {
"test_mgr": "ALL", "test_mgr": "ALL",
"cx_name": cxNames[name], "cx_name": cxNames[name],
"cx_state": "STOPPED" "cx_state": "STOPPED"
} }
self.json_post(reqURL, data) self.json_post("/cli-json/set_cx_state", data)
# Refresh stats # Refresh stats
print("\nRefresh CX stats") print("\nRefresh CX stats")
for name in range(len(cxNames)): for name in range(len(cxNames)):
reqURL = "cli-json/show_cxe"
data = { data = {
"test_mgr": "ALL", "test_mgr": "ALL",
"cross_connect": cxNames[name] "cross_connect": cxNames[name]
} }
self.json_post(reqURL, data) self.json_post("/cli-json/show_cxe", data)
# print("Sleeping for 5 seconds") # print("Sleeping for 5 seconds")
time.sleep(5) time.sleep(5)
@@ -309,13 +296,12 @@ class StaConnect(LFCliBase):
except Exception as e: except Exception as e:
self.error(e) self.error(e)
print("Cleaning up...") print("Cleaning up...")
reqURL = "cli-json/rm_vlan"
data = { data = {
"shelf": 1, "shelf": 1,
"resource": self.resource, "resource": self.resource,
"port": self.sta_name "port": self.sta_name
} }
self.json_post(reqURL, data) self.json_post("/cli-json/rm_vlan", data)
removeCX(self.mgr_url, cxNames) removeCX(self.mgr_url, cxNames)
removeEndps(self.mgr_url, endpNames) removeEndps(self.mgr_url, endpNames)
return False return False