scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-10-31 18:58:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

test_l3_longevity.py : parsing AP output

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

55
py-scripts/test_l3_longevity.py
View File

@@ -507,8 +507,6 @@ class L3VariableTime(Realm):
#print("main loop, total-dl: ", total_dl_bps, " total-ul: ", total_ul_bps)
# At end of test step, record KPI information.
self.record_kpi(len(temp_stations_list), ul, dl, ul_pdu_str, dl_pdu_str, atten_val, total_dl_bps, total_ul_bps)
# RAW OUTPUT
'''
root@Docsis-Gateway:~# wl -i wl1 bs_data
@@ -524,16 +522,15 @@ Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mc
# '''
if self.ap_read:
if self.ap_test_mode:
'''ap_stats = [];
ap_stats.append("root@Docsis-Gateway:~# wl -i wl1 bs_data")
ap_stats.append("Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mcs Nss ofdma mu-mimo")
ap_stats.append("04:f0:21:82:2f:d6 1016.6 48.9 6.5% 24.4% 16.6% 80 9.7 2 0.0% 0.0%")
ap_stats.append("50:E0:85:84:7A:E7 880.9 52.2 7.7% 26.1% 20.0% 80 8.5 2 0.0% 0.0%")
ap_stats.append("50:E0:85:89:5D:00 840.0 47.6 6.4% 23.8% 2.3% 80 8.0 2 0.0% 0.0%")
ap_stats.append("50:E0:85:87:5B:F4 960.7 51.5 5.9% 25.7% 0.0% 80 9 2 0.0% 0.0%")
# - note the MAC will match ap_stats.append("(overall) - 200.2 26.5% - -")
# '''
ap_stats = "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%"
# 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()
@@ -543,17 +540,6 @@ Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mc
ap_stats_rows = ap_stats.splitlines()
print("ap_stats_rows {}".format(ap_stats_rows))
'''for line in ap_stats:
print("ap_stats: {}".format(line))
stats_row = line.split()
print("ap_stats split {}".format(stats_row))
ap_stats_rows.append(stats_row)'''
try:
m = re.search(r'(\S+)\s+(\S+)\s+(Data Mbps)\s+(Air Use)',str(ap_stats_rows[0]))
except:
print("regedit had issue with re.search ")
# Query all of our ports
# Note: the endp eid is the shelf.resource.port.endp-id
port_eids = self.gather_port_eids()
@@ -565,26 +551,25 @@ Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mc
print("query-port: %s: incomplete response:"%(url))
pprint(response)
else:
#print("response".format(response))
pprint(response)
# print("response".format(response))
# pprint(response)
p = response['interface']
#print("#### p, response['insterface']:{}".format(p))
mac = p['mac']
ap_row = []
for row in ap_stats_rows:
print("row[0] {} mac {}".format(row[0].lower(),mac.lower()))
split_row = row.split()
print("split_row {}".format(split_row))
print("split_row[0] {} mac {}".format(split_row[0].lower(),mac.lower()))
if self.ap_test_mode:
if row[0].lower() != mac.lower():
if split_row[0].lower() != mac.lower():
ap_row = row
else:
if row[0].lower() == mac.lower():
ap_row = row
print("selected ap_row: {}".format(ap_row))
if split_row[0].lower() == mac.lower():
ap_row = split_row
print("selected ap_row (from split_row): {}".format(ap_row))
# p is map of key/values for this port
#print("port: ")
# pprint(p)
# Find latency, jitter for connections using this port.
latency, jitter, tput = self.get_endp_stats_for_port(p["port"], endps)
@@ -597,6 +582,10 @@ Station Address PHY Mbps Data Mbps Air Use Data Use Retries bw mc
# latency, jitter, tput, ap_row, ap_stats_col_titles)
# At end of test step, record KPI information.
self.record_kpi(len(temp_stations_list), ul, dl, ul_pdu_str, dl_pdu_str, atten_val, total_dl_bps, total_ul_bps)
# Stop connections.
self.cx_profile.stop_cx();
self.multicast_profile.stop_mc();