Functions
def	DBSquery (dataset, site, run)
	file dbs More...

def	defineOptions ()

def	extractData (mode, reg, dataset, site, options)

def	filesize1 (n)

def	getData (doc, options, dataset, site)

def	getElement (obj, name)

def	getRegExp (regexp)

def	getText (nodelist)

def	lineno ()

def	makecff (file_list, namefile)
	file cff data More...

def	printLumi (file, namefile)
	lumiCalc More...

def	printObj (obj, name)

def	serverQuery (workspaceName, regexp)

Variables
	comp

	data

	DEBUG
	DEBUG. More...

	listaDBS2

	options

	string

	string2

	stringDBS
	if DEBUG: print lineno(), file More...

Function Documentation

def AlCaHLTBitMon_QueryRunRegistry.DBSquery	(	dataset,
		site,
		run
	)

file dbs

Definition at line 57 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno().

Referenced by getData().

 def DBSquery(dataset,site,run):
 
     url = "http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet"
     if DEBUG:
         print lineno()
     args = {}
     args['url']     = url
     args['level']   = 'CRITICAL'
     if DEBUG:
         print lineno()
     api = DBSAPI.dbsApi.DbsApi(args)
     if DEBUG:
         print lineno()
     try:
         files = api.listFiles(path=dataset,tier_list =site,runNumber=run)
     except DbsApiException as ex:
         print "Caught API Exception %s: %s "  % (ex.getClassName(), ex.getErrorMessage() )
         files = ""
         if ex.getErrorCode() not in (None, ""):
             print "DBS Exception Error Code: ", ex.getErrorCode()
     if DEBUG:
         print lineno()
     return files
 

def AlCaHLTBitMon_QueryRunRegistry.defineOptions ( )

Definition at line 122 of file AlCaHLTBitMon_QueryRunRegistry.py.

References reco.print().

 def defineOptions():
     parser = OptionParser()
     parser.add_option("-w", "--workspace",
                       dest="workspaceName",
                       default="GLOBAL",
                       help="define workspace: GLOBAL TRACKER ")
 
     parser.add_option("-r", "--regexp",
                       dest="regexp",
                       type="string",
                       default='groupName : LIKE %Collisions12% , runNumber : = 190000 ',
                       help=" \"{runNumber} >= 148127 and {runNumber} < 148128 \" ")
 
     parser.add_option("-d", "--datasetPath",
                       dest="dataset", \
                       default="/MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO",
                       help="For example : --datasetPath /MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO")
     
     parser.add_option("-s", "--site",
                       dest="site",
                       default="T2_CH_CAF",
                       help="For example : site T2_CH_CAF")                 
 
     parser.add_option("-i", "--info",
                       action="store_true",
                       dest="info",
                       default=False,
                       help="printout the column names on which it's possible to cut")
     
     (options, args) = parser.parse_args()
     if len(sys.argv) == 1:
     print("\nUsage: %s --help"%sys.argv[0])
         sys.exit(0)
     
     return options
 
     

def AlCaHLTBitMon_QueryRunRegistry.extractData	(	mode,
		reg,
		dataset,
		site,
		options
	)

Definition at line 272 of file AlCaHLTBitMon_QueryRunRegistry.py.

References getData(), and serverQuery().

 def extractData(mode,reg,dataset,site,options):
     doc = minidom.parseString(serverQuery(mode,reg))
     return getData(doc,options,dataset,site)
 

def AlCaHLTBitMon_QueryRunRegistry.filesize1 ( n )

Definition at line 39 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by printLumi().

 def filesize1(n):    
     info = os.stat(n)
     sz = info[stat.ST_SIZE]
     return sz
             

def AlCaHLTBitMon_QueryRunRegistry.getData	(	doc,
		options,
		dataset,
		site
	)

Definition at line 184 of file AlCaHLTBitMon_QueryRunRegistry.py.

References DBSquery(), getElement(), createfilelist.int, lineno(), printObj(), and harvestTrackValidationPlots.str.

Referenced by extractData(), HcalTBWriter.extractEventInfo(), PixelPopConDCSSourceHandler< Type >.getNewObjects(), and HcalTBSource.produce().

 def getData(doc,options,dataset,site):
     if DEBUG:
         print lineno(), 'getData'
     server = xmlrpclib.ServerProxy('http://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
     runs = getElement(doc,'RUN')
     txtLongData=""
     txtkey=""
     lista=[]
     
     sep="\t"
 
     for run in runs:
         txtrun=printObj(run,'NUMBER') + sep + printObj(run,'HLTKEY')
         txtLongData+= txtrun + sep + "\n" 
     for run in runs:
         test=printObj(run,'HLTKEY')
         if not (test in lista):
             lista.append(test)
 
         file2=open("lista_key.txt",'w')
         for pkey in range(len(lista)):
             pwkey = lista[pkey] +"\n"
             file2.write(pwkey)
             if DEBUG:
                 print lineno(),  lista[pkey]
 
         file2.close()
 
     for i in range(len(lista)):
         if DEBUG:
             print lineno(), lista[i]
         nameDBS=""
         nameDBS=str(i)+".data"
         name=""
         name=str(i)+".json"
         nameLumi=""
         nameLumi=str(i)+".lumi"
         file1 = open( name ,'w')
         listaDBS = []
         if DEBUG:
             print lineno(), nameDBS
         for run in runs:
             key=printObj(run,'HLTKEY')
             if (key == lista[i]):
                 print "running......", key
                 if DEBUG:
                     print lineno(), printObj(run,'NUMBER')
                 txtruns = "{runNumber} >= " + printObj(run,'NUMBER') +  " and {runNumber} <= " + str(int(printObj(run,'NUMBER')))
                 txtriv = txtruns + " and {cmpDcsBPix} = 1  and {cmpDcsFPix} = 1 and {cmpDcsTibTid} = 1 and {cmpDcsTob} = 1 and {cmpDcsTecM} = 1 and {cmpDcsTecP} = 1"
                 lumirun = server.RunLumiSectionRangeTable.export('GLOBAL', 'json',txtriv)
                 if DEBUG:
                     print lineno(), lumirun
                   ###dbs file
                 if lumirun:
                     file = DBSquery(dataset,site,str(printObj(run,'NUMBER')))                    

def AlCaHLTBitMon_QueryRunRegistry.getElement	(	obj,
		name
	)

Definition at line 177 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by getData(), printObj(), DQMStore::IGetter.removeElement(), and CSCBaseElectronicsSim.simulate().

 def getElement(obj,name):
     return obj.getElementsByTagName(name)
 

def AlCaHLTBitMon_QueryRunRegistry.getRegExp ( regexp )

Definition at line 276 of file AlCaHLTBitMon_QueryRunRegistry.py.

 def getRegExp(regexp):
     items = regexp.split(',') 
     dd = {}
     for item in items:
         key,value = item.split(':')
         dd[key.replace(' ','')] = value
     return dd
 
 
 #---------------------------------------------MAIN
 

def AlCaHLTBitMon_QueryRunRegistry.getText ( nodelist )

Definition at line 170 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by printObj().

 def getText(nodelist):
     rc = ""
     for node in nodelist:
         if node.nodeType == node.TEXT_NODE:
             rc = rc + node.data
     return rc
 

def AlCaHLTBitMon_QueryRunRegistry.lineno ( )

Returns the current line number in our program.

Definition at line 34 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by DBSquery(), getData(), and serverQuery().

 def lineno():
     """Returns the current line number in our program."""
     return inspect.currentframe().f_back.f_lineno
 
 #size file

def AlCaHLTBitMon_QueryRunRegistry.makecff	(	file_list,
		namefile
	)

file cff data

Definition at line 82 of file AlCaHLTBitMon_QueryRunRegistry.py.

References harvestTrackValidationPlots.str.

 def makecff(file_list,namefile):
     file1 = open(namefile ,'w')
     stringS  =           "process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(-1) )\n"
     stringS  = stringS + "readFiles = cms.untracked.vstring()\n"
     stringS  = stringS + "secFiles = cms.untracked.vstring()\n"
     stringS  = stringS + "\n"
     file1.write(stringS)
     
     filecount = 0
     extendOpen = 0
     for filename in file_list:
         
         if extendOpen == 0:
             stringS  = "readFiles.extend([\n"
             file1.write(stringS)
             extendOpen = 1
             
         stringS  =           "     '"
         stringS  = stringS + str(filename)
         stringS  = stringS + "',\n"
         file1.write(stringS)
         filecount = filecount + 1
         if filecount == 50:
             stringS  = "])\n\n"
             file1.write(stringS)
             filecount = 0
             extendOpen = 0
 
     if extendOpen == 1:
         stringS  =           "])\n\n"
         file1.write(stringS)
     
     stringS  =           "process.source = cms.Source(\"PoolSource\",\n"
     stringS  = stringS + "         fileNames = readFiles,\n"
     stringS  = stringS + "         secondaryFileNames = secFiles\n"
     stringS  = stringS + ")\n"
     file1.write(stringS)
     file1.close()
 
 

def AlCaHLTBitMon_QueryRunRegistry.printLumi	(	file,
		namefile
	)

lumiCalc

Definition at line 45 of file AlCaHLTBitMon_QueryRunRegistry.py.

References filesize1(), and reco.if().

 def printLumi(file,namefile):
     if(filesize1(file) != 0):
         string= "lumiCalc2.py -c frontier://LumiCalc/CMS_LUMI_PROD -i "
         string1= " --nowarning overview >"
         string2= string + file + string1 + namefile
         data = os.system(string2)
     else:
         data = ""
         print "0 lumi are not avaible"
     return data
 

def AlCaHLTBitMon_QueryRunRegistry.printObj	(	obj,
		name
	)

Definition at line 180 of file AlCaHLTBitMon_QueryRunRegistry.py.

References getElement(), and getText().

Referenced by getData().

 def printObj(obj,name):
     return getText(getElement(obj,name)[0].childNodes)

def AlCaHLTBitMon_QueryRunRegistry.serverQuery	(	workspaceName,
		regexp
	)

Definition at line 159 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno().

Referenced by extractData().

 def serverQuery(workspaceName,regexp):
 
     # get handler to RR XML-RPC server
     server = xmlrpclib.ServerProxy('http://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
     if DEBUG:
         print lineno(), regexp
     data = server.RunDatasetTable.export(workspaceName,'xml_all' ,regexp)
     return data
 
 #----------------------------------------------------
 