bxn478/Aviat
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Local debugging

Browse Source
This commit is contained in:
Test
2019-07-23 14:12:09 +08:00
parent 760416360c
commit e1a0bfa34f
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
aviat_config.py
View File

@@ -8,6 +8,7 @@ from dataclasses import dataclass
import telnetlib
import csv
import threading
import time
import argparse
try:
import queue
@@ -16,7 +17,7 @@ except ImportError:
PORT = 26000
NEXT = 1
WORKERS = 5
WORKERS = 1
NET_MASK = "255.255.0.0"
GATEWAY = "10.250.0.0.255.255.0.0.0.172.16.0.1"
@@ -57,8 +58,10 @@ class INUeCommand():
def get_command(self):
"""Get the command, as either a get or set, based on the value."""
if self.value:
print ('set %s %s %s\n' % (self.command, self.position, self.value))
return ('set %s %s %s\n' % (self.command, self.position, self.value)).encode('ascii')
else:
print ('get %s %s\n' % (self.command, self.position))
return ('get %s %s\n' % (self.command, self.position)).encode('ascii')
def send_config(telnet, inue_command):
@@ -113,8 +116,10 @@ class Worker(threading.Thread):
with telnetlib.Telnet(inue, PORT) as telnet:
for slot in range(1, 10):
if send_config(telnet,
INUeCommand("Slot%s_I" % slot, "ceConfigBridgeStpMode")):
INUeCommand("Slot%s_I" % slot, "ceConfigBridgeStpMode")) == b'1':
rstp_dac = slot
break
print(rstp_dac)
if not rstp_dac:
self.__failed.put(inue)
@@ -126,10 +131,11 @@ class Worker(threading.Thread):
]
elif CLEANUP:
print('cleanup')
commands = [
INUeCommand("Slot%s_I" % rstp_dac, "ceConfigNmsVid", 0, 0),
INUeCommand("Terminal_I", "ipConfigAdEntAddress", rstp_dac + 1, '0.0.0.0'),
INUeCommand("Terminal_I", "ipConfigAdEntNetMask", rstp_dac + 1, '0.0.0.0'),
INUeCommand("Terminal_I", "ipConfigAdEntNetMask", rstp_dac + 1, '255.255.255.255'),
# INUeCommand("Terminal_I", "ipConfigAutoroutingOspfEnable", rstp_dac + 1, 2),
# INUeCommand("Terminal_I", "ipCidrRouteIfIndex", rstp_dac + 48, GATEWAY, True),
]
@@ -160,6 +166,12 @@ class Worker(threading.Thread):
self.__failed.put(inue)
continue
if CLEANUP:
new_ip = inue
time.sleep(5)
try:
with telnetlib.Telnet(new_ip, PORT) as telnet:
self.__passed.put(new_ip)