import threadpool
import threading
-from monitor import util
+from monitor.util import file
from monitor.util import command
from monitor import config
from nodequery import verify,query_to_dict,node_select
import traceback
-from nodecommon import nmap_port_status
+from monitor.common import nmap_port_status
#print "starting sqlfindbad.py"
# QUERY all nodes.
#cohash = cotop.coget(cotop_url)
l_nodes = plccache.l_nodes
if config.nodelist:
- f_nodes = util.file.getListFromFile(config.nodelist)
+ f_nodes = file.getListFromFile(config.nodelist)
l_nodes = filter(lambda x: x['hostname'] in f_nodes, l_nodes)
elif config.node:
f_nodes = [config.node]
elif config.site:
site = api.GetSites(config.site)
l_nodes = api.GetNodes(site[0]['node_ids'], ['hostname'])
+ elif config.sitelist:
+ site_list = config.sitelist.split(',')
+ sites = api.GetSites(site_list)
+ node_ids = []
+ for s in sites:
+ node_ids += s['node_ids']
+ l_nodes = api.GetNodes(node_ids, ['hostname'])
l_nodes = [node['hostname'] for node in l_nodes]
main()
except Exception, err:
print traceback.print_exc()
+ from monitor.common import email_exception
+ email_exception()
print "Exception: %s" % err
print "Saving data... exitting."
sys.exit(0)
print "sleeping"
- #print "final commit"
- #time.sleep(10)