blob: 791f1ddf8ccd914894eb050595f0a9aa6dffcdee [file] [log] [blame]
#! /usr/bin/env python
import json
import os
import sys
# http://localhost:8080/wm/onos/topology/switches
# http://localhost:8080/wm/onos/topology/links
# http://localhost:8080/wm/onos/registry/controllers/json
# http://localhost:8080/wm/onos/registry/switches/json"
def get_json(url):
try:
command = "curl -s %s" % (url)
result = os.popen(command).read()
parsedResult = json.loads(result)
except:
print "REST IF %s has issue" % command
parsedResult = ""
if type(parsedResult) == 'dict' and parsedResult.has_key('code'):
print "REST %s returned code %s" % (command, parsedResult['code'])
parsedResult = ""
return parsedResult
def check_switch(RestIP,correct_nr_switch ):
buf = ""
retcode = 0
RestPort="8080"
url="http://%s:%s/wm/onos/topology/switches" % (RestIP, RestPort)
parsedResult = get_json(url)
if parsedResult == "":
retcode = 1
return (retcode, "Rest API has an issue")
url = "http://%s:%s/wm/onos/registry/switches/json" % (RestIP, RestPort)
registry = get_json(url)
if registry == "":
retcode = 1
return (retcode, "Rest API has an issue")
buf += "switch: total %d switches\n" % len(parsedResult)
cnt = 0
active = 0
for s in parsedResult:
cnt += 1
if s['state'] == "ACTIVE":
active += 1
if not s['dpid'] in registry:
buf += "switch: dpid %s lost controller\n" % (s['dpid'])
buf += "switch: network %d : %d switches %d active\n" % (0+1, cnt, active)
if correct_nr_switch != cnt:
buf += "switch fail: network %d should have %d switches but has %d\n" % (1, correct_nr_switch, cnt)
retcode = 1
if correct_nr_switch != active:
buf += "switch fail: network %d should have %d active switches but has %d\n" % (1, correct_nr_switch, active)
retcode = 1
return (retcode, buf)
def check_link(RestIP, nr_links):
RestPort = "8080"
buf = ""
retcode = 0
url = "http://%s:%s/wm/onos/topology/links" % (RestIP, RestPort)
parsedResult = get_json(url)
if parsedResult == "":
retcode = 1
return (retcode, "Rest API has an issue")
buf += "link: total %d links (correct : %d)\n" % (len(parsedResult), nr_links)
intra = 0
interlink=0
for s in parsedResult:
intra = intra + 1
if intra != nr_links:
buf += "link fail: network %d should have %d intra links but has %d\n" % (1, nr_links, intra)
retcode = 1
return (retcode, buf)
#if __name__ == "__main__":
def check_status(ip, numoswitch, numolink):
switch = check_switch(ip, numoswitch)
link = check_link(ip, numolink)
value = switch[0]
value += link[0]
if value != 0:
print "FAIL"
return 0
else:
print "PASS"
return 1
print "%s" % switch[1]
print "%s" % link[1]
# print "%s" % check_switch_local()[1]
# print "%s" % check_controllers(8)[1]