mirror of
https://github.com/Telecominfraproject/wlan-lanforge-scripts.git
synced 2025-11-02 03:37:55 +00:00
Cisco power script works somewhat now.
This commit is contained in:
Ben Greear
@@ -40,6 +40,7 @@ CR = "\r\n"
|
||||
Q = '"'
|
||||
A = "'"
|
||||
FORMAT = '%(asctime)s %(name)s %(levelname)s: %(message)s'
|
||||
band = "a"
|
||||
|
||||
def usage():
|
||||
print("$0 used connect to controller:")
|
||||
@@ -49,6 +50,7 @@ def usage():
|
||||
print("-p|--pass: password")
|
||||
print("-s|--scheme (serial|telnet|ssh): connect via serial, ssh or telnet")
|
||||
print("-l|--log file: log messages here")
|
||||
print("-b|--band: a (5Ghz) or b (2.4Ghz)")
|
||||
print("-h|--help")
|
||||
|
||||
# see https://stackoverflow.com/a/13306095/11014343
|
||||
@@ -74,9 +76,11 @@ def main():
|
||||
parser.add_argument("-l", "--log", type=str, help="logfile for messages, stdout means output to console")
|
||||
#parser.add_argument("-r", "--radio", type=str, help="select radio")
|
||||
parser.add_argument("-a", "--ap", type=str, help="select AP")
|
||||
parser.add_argument("-b", "--band", type=str, help="Select band (a | b)",
|
||||
choices=["a", "b"])
|
||||
parser.add_argument("--action", type=str, help="perform action",
|
||||
choices=["config", "country", "ap_country", "enable", "disable", "summary", "advanced",
|
||||
"cmd", "txPower", "bandwidth", "show" ])
|
||||
"cmd", "txPower", "bandwidth", "channel", "show" ])
|
||||
parser.add_argument("--value", type=str, help="set value")
|
||||
|
||||
args = None
|
||||
@@ -88,6 +92,10 @@ def main():
|
||||
user = args.user
|
||||
passwd = args.passwd
|
||||
logfile = args.log
|
||||
if (args.band != None):
|
||||
band = args.band
|
||||
else:
|
||||
band = "a"
|
||||
filehandler = None
|
||||
except Exception as e:
|
||||
logging.exception(e);
|
||||
@@ -190,7 +198,7 @@ def main():
|
||||
command = "show ap summary"
|
||||
|
||||
if (args.action == "advanced"):
|
||||
command = "show advanced 802.11a summary"
|
||||
command = "show advanced 802.11%s summary"%(band)
|
||||
|
||||
if ((args.action == "ap_country") and ((args.value is None) or (args.ap is None))):
|
||||
raise Exception("ap_country requires country and AP name")
|
||||
@@ -207,19 +215,24 @@ def main():
|
||||
if (args.action in ["enable", "disable" ] and (args.ap is None)):
|
||||
raise Exception("action requires AP name")
|
||||
if (args.action == "enable"):
|
||||
command = "config 802.11a enable "+args.ap
|
||||
command = "config 802.11%s enable %s"%(band, args.ap)
|
||||
if (args.action == "disable"):
|
||||
command = "config 802.11a disable "+args.ap
|
||||
command = "config 802.11%s disable %s"%(band, args.ap)
|
||||
|
||||
if (args.action == "txPower" and ((args.ap is None) or (args.value is None))):
|
||||
raise Exception("txPower requires ap and value")
|
||||
if (args.action == "txPower"):
|
||||
command = "config 802.11a txPower ap %s %s"%(args.ap, args.value)
|
||||
command = "config 802.11%s txPower ap %s %s"%(band, args.ap, args.value)
|
||||
|
||||
if (args.action == "bandwidth" and ((args.ap is None) or (args.value is None))):
|
||||
raise Exception("bandwidth requires ap and value (20, 40, 80, 160)")
|
||||
if (args.action == "bandwidth"):
|
||||
command = "config 802.11a chan_width %s %s"%(args.ap, args.value)
|
||||
command = "config 802.11%s chan_width %s %s"%(band, args.ap, args.value)
|
||||
|
||||
if (args.action == "channel" and ((args.ap is None) or (args.value is None))):
|
||||
raise Exception("channel requires ap and value")
|
||||
if (args.action == "channel"):
|
||||
command = "config 802.11%s channel ap %s %s"%(band, args.ap, args.value)
|
||||
|
||||
|
||||
if (command is None):
|
||||
|
||||
261
lf_cisco_power.py
Normal file → Executable file
261
lf_cisco_power.py
Normal file → Executable file
@@ -11,7 +11,12 @@ $ sudo yum install python3-pexpect
|
||||
You might need to install pexpect-serial using pip:
|
||||
$ pip3 install pexpect-serial
|
||||
|
||||
./lf_cisco_power.py -d 192.168.100.112 -u admin -p Cisco123 -s ssh --port 22
|
||||
# Example run to cycle through all 8 power settings
|
||||
# See cisco_power_results.txt when complete.
|
||||
|
||||
./lf_cisco_power.py -d 192.168.100.112 -u admin -p Cisco123 -s ssh --port 22 -a VC --lfmgr 192.168.100.178 \
|
||||
--station sta00000 --bandwidth "20" --channel "36" --nss 4 --txpower "1 2 3 4 5 6 7 8" --pathloss 54
|
||||
|
||||
'''
|
||||
|
||||
|
||||
@@ -34,6 +39,11 @@ Q = '"'
|
||||
A = "'"
|
||||
FORMAT = '%(asctime)s %(name)s %(levelname)s: %(message)s'
|
||||
|
||||
lfmgr = "127.0.0.1"
|
||||
lfstation = "sta00000"
|
||||
lfresource = "1"
|
||||
outfile = "cisco_power_results.txt"
|
||||
|
||||
def usage():
|
||||
print("$0 used connect to controller:")
|
||||
print("-a|--ap: AP to act upon")
|
||||
@@ -46,6 +56,11 @@ def usage():
|
||||
print("-b|--bandwidth: List of bandwidths to test: 20 40 80 160")
|
||||
print("-c|--channel: List of channels to test: 36 100")
|
||||
print("-n|--nss: List of spatial streams to test: 1 2 3 4")
|
||||
print("--outfile: Write results here.")
|
||||
print("--station: LANforge station name")
|
||||
print("--lfmgr: LANforge manager IP address")
|
||||
print("--lfresourcer: LANforge resource ID")
|
||||
print("--pathloss: Calculated path-loss between LANforge station and AP")
|
||||
print("-h|--help")
|
||||
|
||||
# see https://stackoverflow.com/a/13306095/11014343
|
||||
@@ -61,6 +76,11 @@ class FileAdapter(object):
|
||||
pass # leave it to logging to flush properly
|
||||
|
||||
def main():
|
||||
global lfmgr
|
||||
global lfstation
|
||||
global lfresource
|
||||
global outfile
|
||||
|
||||
parser = argparse.ArgumentParser(description="Cisco TX Power report Script")
|
||||
parser.add_argument("-d", "--dest", type=str, help="address of the cisco controller")
|
||||
parser.add_argument("-o", "--port", type=int, help="control port on the controller")
|
||||
@@ -76,15 +96,28 @@ def main():
|
||||
parser.add_argument("-n", "--nss", type=str, help="List of spatial streams to test")
|
||||
parser.add_argument("-T", "--txpower", type=str, help="List of txpowers to test")
|
||||
|
||||
parser.add_argument("--station", type=str, help="LANforge station to use")
|
||||
parser.add_argument("--lfmgr", type=str, help="LANforge Manager IP address")
|
||||
parser.add_argument("--lfresource", type=str, help="LANforge resource ID for the station")
|
||||
parser.add_argument("--outfile", type=str, help="Output file for csv data")
|
||||
parser.add_argument("--pathloss", type=str, help="Calculated pathloss between LANforge Station and AP")
|
||||
|
||||
args = None
|
||||
try:
|
||||
args = parser.parse_args()
|
||||
host = args.dest
|
||||
scheme = args.scheme
|
||||
port = (default_ports[scheme], args.port)[args.port != None]
|
||||
user = args.user
|
||||
passwd = args.passwd
|
||||
logfile = args.log
|
||||
if (args.station != None):
|
||||
lfstation = args.station
|
||||
if (args.lfmgr != None):
|
||||
lfmgr = args.lfmgr
|
||||
if (args.lfresource != None):
|
||||
lfresource = args.lfresource
|
||||
if (args.outfile != None):
|
||||
outfile = args.outfile
|
||||
filehandler = None
|
||||
except Exception as e:
|
||||
logging.exception(e);
|
||||
@@ -107,6 +140,30 @@ def main():
|
||||
# stdout logging
|
||||
logging.basicConfig(format=FORMAT, handlers=[console_handler])
|
||||
|
||||
if (args.bandwidth == None):
|
||||
print("ERROR: Must specify bandwidths")
|
||||
exit(1)
|
||||
|
||||
if (args.channel == None):
|
||||
print("ERROR: Must specify channels")
|
||||
exit(1)
|
||||
|
||||
if (args.nss == None):
|
||||
print("ERROR: Must specify NSS")
|
||||
exit(1)
|
||||
|
||||
if (args.txpower == None):
|
||||
print("ERROR: Must specify txpower")
|
||||
exit(1)
|
||||
|
||||
if (args.pathloss == None):
|
||||
print("ERROR: Pathloss must be specified.")
|
||||
exit(1)
|
||||
|
||||
csv = open(outfile, "w")
|
||||
csv.write("Cfg-Pathloss\tCfg-Channel\tCfg-NSS\tCfg-BW\tCfg-Power\tCombined-Signal\tAnt-0\tAnt-1\tAnt-2\tAnt-3\tAP-BSSID\tRpt-BW\tRpt-Channel\tRpt-Mode\tRpt-NSS\tRpt-Noise\tRpt-Rxrate\tCtrl-AP-MAC\tCtrl-Channel\tCtrl-Power\tCtrl-dBm\tWarnings-and-Errors")
|
||||
csv.write("\n");
|
||||
|
||||
bandwidths = args.bandwidth.split()
|
||||
channels = args.channel.split()
|
||||
nss = args.nss.split()
|
||||
@@ -118,35 +175,211 @@ def main():
|
||||
for tx in txpowers:
|
||||
|
||||
# TODO: Down station
|
||||
port_stats = subprocess.run(["./lf_portmod.pl", "--manager", lfmgr, "--card", lfresource, "--port_name", lfstation,
|
||||
"--set_ifstate", "down"]);
|
||||
|
||||
# Disable AP, apply settings, enable AP
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "disable"])
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "cmd", "--value", "config 802.11a disable network"])
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "cmd", "--value", "config 802.11b disable network"])
|
||||
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "txPower", "--value", tx])
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "bandwidth", "--value", bw])
|
||||
# TODO: Set nss
|
||||
# TODO: Set channel
|
||||
# TODO: Set nss, could do so on LANforge STA if not on AP
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "channel", "--value", ch])
|
||||
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "cmd", "--value", "config 802.11a enable network"])
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "cmd", "--value", "config 802.11b enable network"])
|
||||
subprocess.run(["cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "enable"])
|
||||
|
||||
# TODO:
|
||||
# Wait a bit for AP to come back up
|
||||
time.sleep(1);
|
||||
advanced = subprocess.run(["./cisco_wifi_ctl.py", "-d", args.dest, "-u", args.user, "-p", args.passwd, "-a", args.ap, "-s", "ssh",
|
||||
"--action", "advanced"], capture_output=True)
|
||||
pss = advanced.stdout.decode('utf-8', 'ignore');
|
||||
print(pss)
|
||||
|
||||
searchap = False
|
||||
cc_mac = ""
|
||||
cc_ch = ""
|
||||
cc_power = ""
|
||||
cc_dbm = ""
|
||||
for line in pss.splitlines():
|
||||
if (line.startswith("---------")):
|
||||
searchap = True
|
||||
continue
|
||||
|
||||
if (searchap):
|
||||
pat = "%s\s+(\S+)\s+\S+\s+\S+\s+\S+\s+(\S+)\s+(\S+)\s+\(\s*(\S+)\s+dBm"%(args.ap)
|
||||
m = re.search(pat, line)
|
||||
if (m != None):
|
||||
cc_mac = m.group(1)
|
||||
cc_ch = m.group(2);
|
||||
cc_power = m.group(3)
|
||||
cc_power.replace("/", " of ", 1) # spread-sheets turn 1/8 into a date
|
||||
cc_dbm = m.group(4)
|
||||
break
|
||||
|
||||
# Up station
|
||||
subprocess.run(["./lf_portmod.pl", "--manager", lfmgr, "--card", lfresource, "--port_name", lfstation,
|
||||
"--set_ifstate", "up"]);
|
||||
|
||||
i = 0
|
||||
wait_ip_print = False;
|
||||
wait_assoc_print = False;
|
||||
# Wait untill LANforge station connects
|
||||
# Wait untill connect starts sending data
|
||||
while True:
|
||||
port_stats = subprocess.run(["./lf_portmod.pl", "--manager", lfmgr, "--card", lfresource, "--port_name", lfstation,
|
||||
"--show_port", "AP,IP,Mode,NSS,Bandwidth,Channel,Signal,Noise,Status,RX-Rate"], capture_output=True);
|
||||
pss = port_stats.stdout.decode('utf-8', 'ignore');
|
||||
|
||||
_status = None
|
||||
_ip = None
|
||||
|
||||
for line in pss.splitlines():
|
||||
m = re.search('Status:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_status = m.group(1)
|
||||
m = re.search('IP:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_ip = m.group(1)
|
||||
|
||||
#print("IP %s Status %s"%(_ip, _status))
|
||||
|
||||
if (_status == "Authorized"):
|
||||
if ((_ip != None) and (_ip != "0.0.0.0")):
|
||||
print("Station is associated with IP address.")
|
||||
break
|
||||
else:
|
||||
if (not wait_ip_print):
|
||||
print("Waiting for station to get IP Address.")
|
||||
wait_ip_print = True
|
||||
else:
|
||||
if (not wait_assoc_print):
|
||||
print("Waiting for station to associate.")
|
||||
wait_assoc_print = True
|
||||
|
||||
i += 1
|
||||
if (i > 60):
|
||||
print("ERROR: Station did not connect within 60 seconds.")
|
||||
break
|
||||
|
||||
time.sleep(1)
|
||||
|
||||
# Wait 10 more seconds
|
||||
print("Waiting 10 seconds to let traffic run for a bit.")
|
||||
time.sleep(10)
|
||||
|
||||
# Gather probe results and record data, verify NSS, BW, Channel
|
||||
i = 0;
|
||||
sig = None
|
||||
ants = []
|
||||
while True:
|
||||
time.sleep(1)
|
||||
port_stats = subprocess.run(["./lf_portmod.pl", "--manager", lfmgr, "--card", lfresource, "--port_name", lfstation,
|
||||
"--cli_cmd", "probe_port 1 %s %s"%(lfresource, lfstation)], capture_output=True);
|
||||
pss = port_stats.stdout.decode('utf-8', 'ignore');
|
||||
|
||||
foundit = False
|
||||
for line in pss.splitlines():
|
||||
#print("probe-line: %s"%(line))
|
||||
m = re.search('signal avg:\s+(\S+)\s+\[(.*)\]\s+dBm', line)
|
||||
if (m != None):
|
||||
sig = m.group(1)
|
||||
ants = m.group(2).split();
|
||||
|
||||
#print("sig: %s ants: %s ants-len: %s n: %s"%(sig, m.group(2), len(ants), n))
|
||||
|
||||
if (len(ants) == int(n)):
|
||||
foundit = True
|
||||
break
|
||||
else:
|
||||
print("Looking for %s spatial streams, signal avg reported fewer: %s"%(n, m.group(1)))
|
||||
|
||||
if (foundit):
|
||||
break
|
||||
|
||||
i += 1
|
||||
if (i > 10):
|
||||
print("Tried and failed 10 times to find correct spatial streams, continuing.")
|
||||
while (len(ants) < int(n)):
|
||||
ants.append("")
|
||||
break
|
||||
break
|
||||
|
||||
antstr = ""
|
||||
for x in range(4):
|
||||
if (x < int(n)):
|
||||
antstr += ants[x]
|
||||
else:
|
||||
antstr += " "
|
||||
antstr += "\t"
|
||||
|
||||
port_stats = subprocess.run(["./lf_portmod.pl", "--manager", lfmgr, "--card", lfresource, "--port_name", lfstation,
|
||||
"--show_port", "AP,IP,Mode,NSS,Bandwidth,Channel,Signal,Noise,Status,RX-Rate"], capture_output=True);
|
||||
pss = port_stats.stdout.decode('utf-8', 'ignore');
|
||||
|
||||
_ap = None
|
||||
_bw = None
|
||||
_ch = None
|
||||
_mode = None
|
||||
_nss = None
|
||||
_noise = None
|
||||
_rxrate = None
|
||||
|
||||
for line in pss.splitlines():
|
||||
m = re.search('AP:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_ap = m.group(1)
|
||||
m = re.search('Bandwidth:\s+(.*)Mhz', line)
|
||||
if (m != None):
|
||||
_bw = m.group(1)
|
||||
m = re.search('Channel:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_ch = m.group(1)
|
||||
m = re.search('Mode:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_mode = m.group(1)
|
||||
m = re.search('NSS:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_nss = m.group(1)
|
||||
m = re.search('Noise:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_noise = m.group(1)
|
||||
m = re.search('RX-Rate:\s+(.*)', line)
|
||||
if (m != None):
|
||||
_rxrate = m.group(1)
|
||||
|
||||
ln = "%s\t%s\t%s\t%s\t%s\t%s\t%s%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s"%(args.pathloss, ch, n, bw, tx, sig,
|
||||
antstr, _ap, _bw, _ch, _mode, _nss, _noise, _rxrate,
|
||||
cc_mac, cc_ch, cc_power, cc_dbm)
|
||||
|
||||
print("RESULT: %s"%(ln))
|
||||
csv.write(ln)
|
||||
csv.write("\t");
|
||||
if (_bw != bw):
|
||||
err = "ERROR: Requested bandwidth: %s != station's reported bandwidth: %s. "%(bw, _bw)
|
||||
print(err)
|
||||
csv.write(err)
|
||||
if (_ch != cc_ch):
|
||||
err = "ERROR: Station channel: %s != AP's reported channel: %s. "%(_ch, cc_ch)
|
||||
print(err)
|
||||
csv.write(err)
|
||||
if (_nss != n):
|
||||
err = "ERROR: Station NSS: %s != configured: %s. "%(_nss, n)
|
||||
print(err)
|
||||
csv.write(err)
|
||||
|
||||
csv.write("\n");
|
||||
|
||||
|
||||
# ----- ----- ----- ----- ----- ----- ----- ----- ----- ----- ----- -----
|
||||
|
||||
Reference in New Issue
Block a user