X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=findbadpcu.py;h=e3d160ddb3455b2828dc08a9081ffc4945fca426;hb=6d46ab9b534b60675a3dcb11fcb664589a3691f8;hp=5f542358e63adcd1165e8ab43a12e4ce11730bfd;hpb=6496f5b4a0220e4055fee76c97f92293f9559117;p=monitor.git

diff --git a/findbadpcu.py b/findbadpcu.py
index 5f54235..e3d160d 100755
--- a/findbadpcu.py
+++ b/findbadpcu.py
@@ -5,6 +5,9 @@ import sys
 import string
 import time
 import socket
+import util.file
+import plc
+import sets
 
     
 import signal
@@ -380,11 +383,20 @@ def main():
 		# update global round number to force refreshes across all nodes
 		externalState['round'] += 1
 
-	if config.filename == None and config.pcuid == None:
+	if config.site is not None:
+		api = plc.getAuthAPI()
+		site = api.GetSites(config.site)
+		l_nodes = api.GetNodes(site[0]['node_ids'], ['pcu_ids'])
+		pcus = []
+		for node in l_nodes:
+			pcus += node['pcu_ids']
+		l_pcus = [pcu for pcu in sets.Set(pcus)]
+
+	elif config.nodelist == None and config.pcuid == None:
 		print "Calling API GetPCUs() : refresh(%s)" % config.refresh
 		l_pcus  = [pcu['pcu_id'] for pcu in l_pcus]
-	elif config.filename is not None:
-		l_pcus = config.getListFromFile(config.filename)
+	elif config.nodelist is not None:
+		l_pcus = util.file.getListFromFile(config.nodelist)
 		l_pcus = [int(pcu) for pcu in l_pcus]
 	elif config.pcuid is not None:
 		l_pcus = [ config.pcuid ] 
@@ -404,20 +416,23 @@ if __name__ == '__main__':
 	formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s')
 	fh.setFormatter(formatter)
 	logger.addHandler(fh)
-	from config import config
-	from optparse import OptionParser
-	parser = OptionParser()
-	parser.set_defaults(filename=None, 
+	import parser as parsermodule
+	parser = parsermodule.getParser()
+	parser.set_defaults(nodelist=None, 
 						increment=False, 
 						pcuid=None,
+						site=None,
 						dbname="findbadpcus", 
 						cachenodes=False,
 						refresh=False,
 						)
-	parser.add_option("-f", "--nodelist", dest="filename", metavar="FILE", 
+	parser.add_option("-f", "--nodelist", dest="nodelist", metavar="FILE", 
 						help="Provide the input file for the node list")
+	parser.add_option("", "--site", dest="site", metavar="FILE", 
+						help="Get all pcus associated with the given site's nodes")
 	parser.add_option("", "--pcuid", dest="pcuid", metavar="id", 
 						help="Provide the id for a single pcu")
+
 	parser.add_option("", "--cachenodes", action="store_true",
 						help="Cache node lookup from PLC")
 	parser.add_option("", "--dbname", dest="dbname", metavar="FILE", 
@@ -426,8 +441,8 @@ if __name__ == '__main__':
 						help="Refresh the cached values")
 	parser.add_option("-i", "--increment", action="store_true", dest="increment", 
 						help="Increment round number to force refresh or retry")
-	config = config(parser)
-	config.parse_args()
+	parser = parsermodule.getParser(['defaults'], parser)
+	config = parsermodule.parse_args(parser)
 	try:
 		# NOTE: evidently, there is a bizarre interaction between iLO and ssh
 		# when LANG is set... Do not know why.  Unsetting LANG, fixes the problem.