from sets import Set
# Global config options
-from config import config
-from optparse import OptionParser
-parser = OptionParser()
+import parser as parsermodule
+parser = parsermodule.getParser()
parser.set_defaults(nodelist=None,
refresh=False,
parser.add_option("", "--blacklist", dest="blacklist",
help="Blacklist all nodes in this file")
-config = config(parser)
-config.parse_args()
+config = parsermodule.parse_args(parser)
# daemonize and *pid
#from util.process import *
import rt
# Correlates input with policy to form actions
import policy
-import soltesz
+import moncommands
+import database
import plc
import syncplcdb
# list will be monitored.
runningthreads = {}
# Seconds between checking threads
-WATCHSLEEP = 10
+WATCHSLEEP = 5
# Set up Logging
logger = logging.getLogger("monitor")
######### GET NODES ########################################
logger.info('Get Nodes from PLC')
print "getnode from plc: %s %s %s" % (config.debug, config.cachenodes, config.refresh)
- l_plcnodes = soltesz.if_cached_else_refresh(config.cachenodes,
+ l_plcnodes = database.if_cached_else_refresh(config.cachenodes,
config.refresh, "l_plcnodes",
lambda : syncplcdb.create_plcdb() )
print "len of l_nodes: %d" % len(l_nodes)
# Minus blacklisted ones..
- l_blacklist = soltesz.if_cached_else(1, "l_blacklist", lambda : [])
- l_ticket_blacklist = soltesz.if_cached_else(1,"l_ticket_blacklist",lambda : [])
+ l_blacklist = database.if_cached_else(1, "l_blacklist", lambda : [])
+ l_ticket_blacklist = database.if_cached_else(1,"l_ticket_blacklist",lambda : [])
l_nodes = filter(lambda x : not x['hostname'] in l_blacklist, l_nodes)
logger.info('Get Tickets from RT')
####### RT tickets #########################################
- t = soltesz.MyTimer()
- ad_dbTickets = soltesz.if_cached_else_refresh(config.cachert, config.refresh, "ad_dbTickets", rt.rt_tickets)
+ t = moncommands.MyTimer()
+ ad_dbTickets = database.if_cached_else_refresh(config.cachert, config.refresh, "ad_dbTickets", rt.rt_tickets)
if ad_dbTickets == "":
print "ad_dbTickets failed..."
sys.exit(1)