X-Git-Url: http://git.onelab.eu/?p=monitor.git;a=blobdiff_plain;f=mailmonitor.py;h=3257d63643efb36b85965a475ebddd43e32eeabb;hp=c9c1750f77175bbea8d73f5f1d0693b02324cead;hb=03f339edc8521e36a12bfc1cdfd1b1a6ea3ab2d8;hpb=0fabfc8dbe8f1f2c0d12397e1bc8c6ed686fb5ed diff --git a/mailmonitor.py b/mailmonitor.py index c9c1750..3257d63 100644 --- a/mailmonitor.py +++ b/mailmonitor.py @@ -30,72 +30,11 @@ def reboot(hostname): if len(l_nodes) == 0: raise Exception("Host removed via blacklist: %s" % hostname) - #ad_dbTickets = database.if_cached_else_refresh(True, False, "ad_dbTickets", lambda : []) - #if ad_dbTickets == None: - # raise Exception("Could not find cached dbTickets") - - #print "starting new thing" mon = MonitorMergeDiagnoseSendEscellate(hostname, True) mon.run() - #print "merge" - #merge = Merge( [node['hostname'] for node in l_nodes]) - #record_list = merge.run() - ##print "rt" - #rt = RT(record_list, ad_dbTickets, l_ticket_blacklist) - #record_list = rt.run() - ##print "diagnose" - #diag = Diagnose(record_list) - #diagnose_out = diag.run() - #print diagnose_out - #print "action" - #action = Action(diagnose_out) - #action.run() - return True -#def reboot2(hostname): -# l_nodes = api.GetNodes(hostname) -# if len(l_nodes) == 0: -# raise Exception("No such host: %s" % hostname) -# -# 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) -# if len(l_nodes) == 0: -# raise Exception("Host removed via blacklist: %s" % hostname) -# -# ad_dbTickets = database.if_cached_else_refresh(True, False, "ad_dbTickets", lambda : None) -# if ad_dbTickets == None: -# raise Exception("Could not find cached dbTickets") -# -# -# args = {} -# args['hostname'] = "%s" % hostname -# args['hostname_list'] = "%s" % hostname -# args['loginbase'] = plc.siteId(hostname) -# -# m = PersistMessage(hostname, "Please Update Boot Image for %s" % hostname, -# mailtxt.newalphacd_one[1] % args, True, db='bootcd_persistmessages') -# -# #print "merge" -# merge = Merge( [node['hostname'] for node in l_nodes]) -# record_list = merge.run() -# #print "rt" -# rt = RT(record_list, ad_dbTickets, l_ticket_blacklist) -# record_list = rt.run() -# #print "diagnose" -# diag = Diagnose(record_list) -# diagnose_out = diag.run() -# #print diagnose_out -# #print "action" -# action = Action(diagnose_out) -# action.run() -# -# return True - - def main(): for host in sys.argv[1:]: reboot(host)