X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=findall.py;h=d2af9b17c1de3d4d2d3b6200a1f2643909e156d0;hb=fc9068f6a15adbfd5b37bce5d223e0f83578fa06;hp=64c498776cfacee28f5a149e0638fdf4e7b3210d;hpb=c9d06f3b274ecbc092a0b3eb1f5ceb6c0f734aad;p=monitor.git

diff --git a/findall.py b/findall.py
index 64c4987..d2af9b1 100755
--- a/findall.py
+++ b/findall.py
@@ -7,6 +7,8 @@ from sitebad import main as sitebad_main
 from nodebad import main as nodebad_main
 from pcubad import main as pcubad_main
 from monitor.wrapper import plccache
+from monitor.database.info.model import  *
+from monitor.common import  *
 import sys
 
 if __name__ == '__main__':
@@ -14,7 +16,7 @@ if __name__ == '__main__':
 	parser = parsermodule.getParser(['nodesets'])
 
 	parser.set_defaults( increment=False, dbname="findbad", cachenodes=False, 
-						force=False, pcuselect=None, pcuid=None, pcu=None)
+						force=False, pcuselect=None, pcuid=None, pcu=None, checkpcu=False)
 	parser.add_option("", "--cachenodes", action="store_true",
 						help="Cache node lookup from PLC")
 	parser.add_option("", "--dbname", dest="dbname", metavar="FILE", 
@@ -23,26 +25,42 @@ if __name__ == '__main__':
 						help="Increment round number to force refresh or retry")
 	parser.add_option("", "--force", action="store_true", dest="force", 
 						help="Force probe without incrementing global 'round'.")
+	parser.add_option("", "--checkpcu", dest="checkpcu", action="store_true",
+						help="whether to include PCUs in the site status")
 
 	parser = parsermodule.getParser(['defaults'], parser)
 	
 	cfg = parsermodule.parse_args(parser)
 
 	try:
-		print "sync with plc"
-		plccache.sync()
 		print "findbad"
 		findbad_main()
+		print "befor-len: ", len( [ i for i in session] )
+		session.flush(); session.clear()
+		print "after-len: ", len( [ i for i in session] )
 		print "findbadpcu"
 		findbadpcu_main()
+		print "befor-len: ", len( [ i for i in session] )
+		session.flush(); session.clear()
+		print "after-len: ", len( [ i for i in session] )
 		print "nodebad"
 		nodebad_main()
+		print "befor-len: ", len( [ i for i in session] )
+		session.flush(); session.clear()
+		print "after-len: ", len( [ i for i in session] )
 		print "pcubad"
 		pcubad_main()
+		print "befor-len: ", len( [ i for i in session] )
+		session.flush(); session.clear()
+		print "after-len: ", len( [ i for i in session] )
 		print "sitebad"
 		sitebad_main()
+		print "befor-len: ", len( [ i for i in session] )
+		session.flush(); session.clear()
+		print "after-len: ", len( [ i for i in session] )
 	except Exception, err:
 		import traceback
+		email_exception()
 		print traceback.print_exc()
 		print "Exception: %s" % err
 		print "Saving data... exitting."