use username and password of controller server for ssh and need
karaf distribution location like /root/Documents/dist
"""
- print "executing ssh command"
+ print("executing ssh command")
lib = SSHLibrary()
lib.open_connection(ip)
lib.login(username=username, password=password)
- print "login done"
+ print("login done")
cmd_response = lib.execute_command(command)
- print "command executed : " + command
+ print("command executed : " + command)
lib.close_connection()
return cmd_response
url = "http://" + ip + ":" + str(port) + \
"/restconf/config/opendaylight-inventory:nodes/node/controller-config/yang-ext:mount/config:modules"
- print "Waiting for controller " + ip + " up."
+ print("Waiting for controller " + ip + " up.")
# Try 30*10s=5 minutes for the controller to be up.
for i in xrange(30):
try:
- print "attempt " + str(i) + " to url " + url
+ print("attempt %s to url %s" % (str(i), url))
resp = get(url, "admin", "admin")
- print "attempt " + str(i) + " response is " + str(resp)
- print resp.text
+ print("attempt %s response is %s" % (str(i), str(resp)))
+ print(resp.text)
if ('clustering-it-provider' in resp.text):
- print "Wait for controller " + ip + " succeeded"
+ print("Wait for controller " + ip + " succeeded")
return True
except Exception as e:
- print e
+ print(e)
time.sleep(10)
- print "Wait for controller " + ip + " failed"
+ print("Wait for controller " + ip + " failed")
return False
i = 1
while i <= tries:
stdout = lib.execute_command("ps -axf | grep karaf | grep -v grep | wc -l")
- # print "stdout: "+stdout
processCnt = stdout[0].strip('\n')
print("processCnt: " + processCnt)
if processCnt == '0':
lib.close_connection()
if i > tries:
- print "Killing controller"
+ print("Killing controller")
kill_controller(ip, username, password, karafHome)
cmd_str = base_str + controller + ' --destination ' + isolated_controller + ' -j DROP'
execute_ssh_command(isolated_controller, username, password, cmd_str)
ip_tables = execute_ssh_command(isolated_controller, username, password, 'sudo iptables -L')
- print ip_tables
+ print(ip_tables)
iso_result = 'pass'
for controller in controllers:
controller_regex_string = "[\s\S]*" + isolated_controller + " *" + controller + "[\s\S]*"
cmd_str = base_str + controller + ' --destination ' + isolated_controller + ' -j DROP'
execute_ssh_command(isolated_controller, username, password, cmd_str)
ip_tables = execute_ssh_command(isolated_controller, username, password, 'sudo iptables -L')
- print ip_tables
+ print(ip_tables)
iso_result = 'pass'
for controller in controllers:
controller_regex_string = "[\s\S]*" + isolated_controller + " *" + controller + "[\s\S]*"
"""
flush_result = 'pass'
for controller in controllers:
- print 'Flushing ' + controller
+ print('Flushing ', controller)
cmd_str = 'sudo iptables -v -F'
cmd_result = execute_ssh_command(controller, username, password, cmd_str)
- print cmd_result
+ print(cmd_result)
success_string = "Flushing chain `INPUT'" + "\n"
success_string += "Flushing chain `FORWARD'" + "\n"
success_string += "Flushing chain `OUTPUT'"
if not cmd_result == success_string:
flush_result = "Failed to flush IPTables. Check Log."
- print "."
- print "."
- print "."
+ print(".")
+ print(".")
+ print(".")
return flush_result