diff --git a/stationStressTest.py b/stationStressTest.py
index a477e2dc..a6d6c327 100755
--- a/stationStressTest.py
+++ b/stationStressTest.py
@@ -5,6 +5,7 @@ import time
sys.path.append('py-json')
import json
import pprint
+from datetime import date
from LANforge import LFRequest
from LANforge import LFUtils
@@ -26,20 +27,58 @@ def execWrap(cmd):
exit(1)
def getJsonInfo(mgrURL, reqURL):
- lf_r = LFRequest.LFRequest(mgrURL + reqURL)
- json_response = lf_r.getAsJson()
- return json_response
+ lf_r = LFRequest.LFRequest(mgrURL + reqURL)
+ json_response = lf_r.getAsJson()
+ return json_response
stations = []
-radios = {"wiphy0":5, "wiphy1":5, "wiphy2":5, "wiphy3":5} #radioName:numStations
+radios = {"wiphy0":200, "wiphy1":200, "wiphy2":64, "wiphy3":200} #radioName:numStations
paddingNum = 1000 #uses all but the first number to create names for stations
mgrURL = "http://localhost:8080/"
#create stations
+print("Cleaning up old Stations")
+
+for radio, numStations in radios.items():
+ for i in range(0,numStations):
+ staName = "sta" + radio[-1:] + str(paddingNum + i)[1:]
+ if getJsonInfo(mgrURL, "port/1/1/"+staName) != None:
+ reqURL = "cli-json/rm_vlan"
+
+ data = {
+ "shelf":1,
+ "resource":1,
+ "port":staName
+ }
+
+ jsonReq(mgrURL, reqURL, data)
+
+ reqURL = "cli-json/rm_cx"
+
+ data = {
+ "test_mgr":"default_tm",
+ "cx_name":staName
+ }
+ jsonReq(mgrURL, reqURL, data)
+
+ reqURL = "cli-json/rm_endp"
+
+ data = {
+ "endp_name":staName + "-A"
+ }
+
+ jsonReq(mgrURL, reqURL, data)
+
+ reqURL = "cli-json/rm_endp"
+ data = {
+ "endp_name":staName + "-B"
+ }
+
print("Creating Stations")
reqURL = "cli-json/add_sta"
+
for radio, numStations in radios.items():
for i in range(0,numStations):
staName = "sta" + radio[-1:] + str(paddingNum + i)[1:]
@@ -49,8 +88,8 @@ for radio, numStations in radios.items():
"resource":1,
"radio":radio,
"sta_name":staName,
- "ssid":"jedway-wpa2-roam",
- "key":"jedway-wpa2-roam",
+ "ssid":"jedway-wpa2-x2048-4-1",
+ "key":"jedway-wpa2-x2048-4-1",
"mode":1,
"mac":"xx:xx:xx:xx:*:xx",
"flags":0x400
@@ -91,7 +130,7 @@ time.sleep(10)
#create cross connects
print("Creating cross connects")
for staName in stations:
- cmd = ("./lf_firemod.pl --action create_cx --cx_name " + staName + " --use_ports eth1," + staName + " --use_speeds 56000,56000 --endp_type udp > sst.log")
+ cmd = ("./lf_firemod.pl --action create_cx --cx_name " + staName + " --use_ports eth1," + staName + " --use_speeds 2600,2600 --endp_type udp > sst.log")
execWrap(cmd)
#set stations to dchp up
@@ -119,7 +158,62 @@ for name in stations:
cmd = ("./lf_firemod.pl --mgr localhost --quiet 0 --action do_cmd --cmd \"set_cx_state default_tm " + name + " RUNNING\" >> sst.log")
execWrap(cmd)
-time.sleep(30)
+
+#create weblog for monitoring stations
+webLog = "stationStressTestLog.html"
+f = open(webLog,"w")
+top = """
+
+Test report
+
+
+
+Long test on {}
+
+""".format(date.today())
+
+
+f.write(top)
+f.close()
+
+
+
+for min5 in range(1):
+ for radio, numStations in radios.items():
+
+ f = open(webLog, "a")
+ f.write("\n")
+ f.write("| {} | \n".format(radio))
+ f.write("
\n")
+
+
+ withoutIP = 0
+ dissociated = 0
+
+ f.write("")
+ for i in range(0,numStations):
+ staName = "sta" + radio[-1:] + str(paddingNum + i)[1:]
+ staStatus = getJsonInfo(mgrURL, "port/1/1/" + staName)
+ if staStatus['interface']['ip'] == "0.0.0.0":
+ withoutIP += 1
+ if staStatus['interface']['ap'] == None:
+ dissociated += 1
+
+ f.write("| \n")
+ f.write(" | {} | ".format(staName))
+ f.write("\n")
+ f.write("
")
+
+ f.write("
\n")
+ f.close()
+
+
+ #print("Without IP: {}".format(withoutIP))
+ #print("Dissociated: {}".format(dissociated))
+ time.sleep((min5 + 1) * 300) #Sleeps for five minutes at a time per loop
print("Stopping CX Traffic")
for name in stations: