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

test_l3_longevity.py : query every poll period

Browse Source 
Signed-off-by: Chuck SmileyRekiere <chuck.smileyrekiere@candelatech.com>
This commit is contained in:
Chuck SmileyRekiere
2021-05-12 20:12:37 -06:00
parent d701a4a0b1
commit 52987f1e1a
1 changed files with 58 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

130
py-scripts/test_l3_longevity.py
View File

@@ -507,79 +507,65 @@ class L3VariableTime(Realm):
#print("main loop, total-dl: ", total_dl_bps, " total-ul: ", total_ul_bps) #print("main loop, total-dl: ", total_dl_bps, " total-ul: ", total_ul_bps)
# RAW OUTPUT # AP OUTPUT
''' if self.ap_read:
root@Docsis-Gateway:~# wl -i wl1 bs_data if self.ap_test_mode:
Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mcs Nss ofdma mu-mimo # Create the test data as a continuous string
50:E0:85:87:AA:19 1064.5 52.8 6.0% 25.0% 1.5% 80 10.0 2 0.0% 0.0% ap_stats="{}{}{}{}{}{}".format("root@Docsis-Gateway:~# wl -i wl1 bs_data\n",
50:E0:85:84:7A:E7 927.1 53.6 7.0% 25.4% 5.7% 80 8.8 2 0.0% 0.0% "Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mcs Nss ofdma mu-mimo\n",
50:E0:85:89:5D:00 857.5 51.8 6.8% 24.6% 0.8% 80 8 2 0.0% 0.0% "04:f0:21:82:2f:d6 1016.6 48.9 6.5% 24.4% 16.6% 80 9.7 2 0.0% 0.0%\n",
50:E0:85:87:5B:F4 1071.7 52.8 6.0% 25.0% 1.3% 80 10 2 0.0% 0.0% "50:E0:85:84:7A:E7 880.9 52.2 7.7% 26.1% 20.0% 80 8.5 2 0.0% 0.0%\n",
(overall) - 210.9 25.8% - - "50:E0:85:89:5D:00 840.0 47.6 6.4% 23.8% 2.3% 80 8.0 2 0.0% 0.0%\n",
''' "50:E0:85:87:5B:F4 960.7 51.5 5.9% 25.7% 0.0% 80 9 2 0.0% 0.0%\n",
"- note the MAC will match ap_stats.append((overall) - 200.2 26.5% - - \n")
# Query AP for its stats. Result for /ax bcm APs looks something like this: print("ap_stats {}".format(ap_stats))
# ''' # read from the AP
if self.ap_read:
if self.ap_test_mode:
# Create the test data as a continuous string
ap_stats="{}{}{}{}{}{}".format("root@Docsis-Gateway:~# wl -i wl1 bs_data\n",
"Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mcs Nss ofdma mu-mimo\n",
"04:f0:21:82:2f:d6 1016.6 48.9 6.5% 24.4% 16.6% 80 9.7 2 0.0% 0.0%\n",
"50:E0:85:84:7A:E7 880.9 52.2 7.7% 26.1% 20.0% 80 8.5 2 0.0% 0.0%\n",
"50:E0:85:89:5D:00 840.0 47.6 6.4% 23.8% 2.3% 80 8.0 2 0.0% 0.0%\n",
"50:E0:85:87:5B:F4 960.7 51.5 5.9% 25.7% 0.0% 80 9 2 0.0% 0.0%\n",
"- note the MAC will match ap_stats.append((overall) - 200.2 26.5% - - \n")
print("ap_stats {}".format(ap_stats))
# read from the AP
else:
ap_stats = self.read_ap_stats()
#ap_stats_rows = [] # Array of Arrays
ap_stats_rows = ap_stats.splitlines()
print("ap_stats_rows {}".format(ap_stats_rows))
# Query all of our ports
# Note: the endp eid is the shelf.resource.port.endp-id
port_eids = self.gather_port_eids()
for eid_name in port_eids:
eid = self.name_to_eid(eid_name)
url = "/port/%s/%s/%s"%(eid[0], eid[1], eid[2])
response = self.json_get(url)
if (response is None) or ("interface" not in response):
print("query-port: %s: incomplete response:"%(url))
pprint(response)
else: else:
# print("response".format(response)) ap_stats = self.read_ap_stats()
# pprint(response)
p = response['interface'] #ap_stats_rows = [] # Array of Arrays
#print("#### p, response['insterface']:{}".format(p))
mac = p['mac'] ap_stats_rows = ap_stats.splitlines()
print("ap_stats_rows {}".format(ap_stats_rows))
ap_row = []
for row in ap_stats_rows: # Query all of our ports
split_row = row.split() # Note: the endp eid is the shelf.resource.port.endp-id
print("split_row {}".format(split_row)) port_eids = self.gather_port_eids()
print("split_row[0] {} mac {}".format(split_row[0].lower(),mac.lower())) for eid_name in port_eids:
if self.ap_test_mode: eid = self.name_to_eid(eid_name)
if split_row[0].lower() != mac.lower(): url = "/port/%s/%s/%s"%(eid[0], eid[1], eid[2])
ap_row = row response = self.json_get(url)
else: if (response is None) or ("interface" not in response):
if split_row[0].lower() == mac.lower(): print("query-port: %s: incomplete response:"%(url))
ap_row = split_row pprint(response)
print("selected ap_row (from split_row): {}".format(ap_row)) else:
# print("response".format(response))
# pprint(response)
# Find latency, jitter for connections using this port. p = response['interface']
latency, jitter, tput = self.get_endp_stats_for_port(p["port"], endps) #print("#### p, response['insterface']:{}".format(p))
mac = p['mac']
ap_stats_col_titles = ['Station Address','PHY Mbps','Data Mbps','Air Use','Data Use','Retries','bw','mcs','Nss','ofdma','mu-mimo']
ap_row = []
self.write_port_csv(len(temp_stations_list), ul, dl, ul_pdu_str, dl_pdu_str, atten_val, eid_name, p, for row in ap_stats_rows:
latency, jitter, tput, ap_row, ap_stats_col_titles) #ap_stats_col_titles used as a length split_row = row.split()
#self.write_port_csv(len(temp_stations_list), ul, dl, ul_pdu_str, dl_pdu_str, atten_val, eid_name, p, #print("split_row {}".format(split_row))
# latency, jitter, tput, ap_row, ap_stats_col_titles) #print("split_row[0] {} mac {}".format(split_row[0].lower(),mac.lower()))
if self.ap_test_mode:
if split_row[0].lower() != mac.lower():
ap_row = row
else:
if split_row[0].lower() == mac.lower():
ap_row = split_row
print("selected ap_row (from split_row): {}".format(ap_row))
# Find latency, jitter for connections using this port.
latency, jitter, tput = self.get_endp_stats_for_port(p["port"], endps)
ap_stats_col_titles = ['Station Address','PHY Mbps','Data Mbps','Air Use','Data Use','Retries','bw','mcs','Nss','ofdma','mu-mimo']
self.write_port_csv(len(temp_stations_list), ul, dl, ul_pdu_str, dl_pdu_str, atten_val, eid_name, p,
latency, jitter, tput, ap_row, ap_stats_col_titles) #ap_stats_col_titles used as a length