Functions
def	DBSquery
	file dbs
def	defineOptions
def	extractData
def	filesize1
def	getData
def	getElement
def	getRegExp
def	getText
def	lineno
def	makecff
	file cff data
def	printLumi
	lumiCalc
def	printObj
def	serverQuery
Variables
string	comp = "{}"
tuple	data = extractData(options.workspaceName,options.regexp,options.dataset,options.site,options)
int	DEBUG = 0
	DEBUG.
list	listaDBS2 = []
tuple	options = defineOptions()
string	string = ""
string	string2 = ""
dictionary	stringDBS = {}
	if DEBUG: print lineno(), file

Function Documentation

def AlCaHLTBitMon_QueryRunRegistry::DBSquery	(	dataset,
		site,
		run
	)

file dbs

Definition at line 57 of file AlCaHLTBitMon_QueryRunRegistry.py.

00058                               :
00059 
00060     url = "https://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet"
00061     if DEBUG:
00062         print lineno()
00063     args = {}
00064     args['url']     = url
00065     args['level']   = 'CRITICAL'
00066     if DEBUG:
00067         print lineno()
00068     api = DBSAPI.dbsApi.DbsApi(args)
00069     if DEBUG:
00070         print lineno()
00071     try:
00072         files = api.listFiles(path=dataset,tier_list =site,runNumber=run)
00073     except DbsApiException, ex:
00074         print "Caught API Exception %s: %s "  % (ex.getClassName(), ex.getErrorMessage() )
00075         files = ""
00076         if ex.getErrorCode() not in (None, ""):
00077             print "DBS Exception Error Code: ", ex.getErrorCode()
00078     if DEBUG:
00079         print lineno()
00080     return files

def AlCaHLTBitMon_QueryRunRegistry::defineOptions ( )

Definition at line 122 of file AlCaHLTBitMon_QueryRunRegistry.py.

00123                    :
00124     parser = OptionParser()
00125     parser.add_option("-w", "--workspace",
00126                       dest="workspaceName",
00127                       default="GLOBAL",
00128                       help="define workspace: GLOBAL TRACKER ")
00129 
00130     parser.add_option("-r", "--regexp",
00131                       dest="regexp",
00132                       type="string",
00133                       default='groupName : LIKE %Collisions12% , runNumber : = 190000 ',
00134                       help=" \"{runNumber} >= 148127 and {runNumber} < 148128 \" ")
00135 
00136     parser.add_option("-d", "--datasetPath",
00137                       dest="dataset", \
00138                       default="/MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO",
00139                       help="For example : --datasetPath /MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO")
00140     
00141     parser.add_option("-s", "--site",
00142                       dest="site",
00143                       default="T2_CH_CAF",
00144                       help="For example : site T2_CH_CAF")                 
00145 
00146     parser.add_option("-i", "--info",
00147                       action="store_true",
00148                       dest="info",
00149                       default=False,
00150                       help="printout the column names on which it's possible to cut")
00151     
00152     (options, args) = parser.parse_args()
00153     if len(sys.argv) == 1:
00154         print("\nUsage: %s --help"%sys.argv[0])
00155         sys.exit(0)
00156     
00157     return options
00158

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

Definition at line 272 of file AlCaHLTBitMon_QueryRunRegistry.py.

00273                                               :
00274     doc = minidom.parseString(serverQuery(mode,reg))
00275     return getData(doc,options,dataset,site)

def AlCaHLTBitMon_QueryRunRegistry::filesize1 ( n )

Definition at line 39 of file AlCaHLTBitMon_QueryRunRegistry.py.

00039                 :    
00040     info = os.stat(n)
00041     sz = info[stat.ST_SIZE]
00042     return sz
00043

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

Definition at line 184 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

00185                                      :
00186     if DEBUG:
00187         print lineno(), 'getData'
00188     server = xmlrpclib.ServerProxy('https://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
00189     runs = getElement(doc,'RUN')
00190     txtLongData=""
00191     txtkey=""
00192     lista=[]
00193     
00194     sep="\t"
00195 
00196     for run in runs:
00197         txtrun=printObj(run,'NUMBER') + sep + printObj(run,'HLTKEY')
00198         txtLongData+= txtrun + sep + "\n" 
00199     for run in runs:
00200         test=printObj(run,'HLTKEY')
00201         if not (test in lista):
00202             lista.append(test)
00203 
00204         file2=open("lista_key.txt",'w')
00205         for pkey in range(len(lista)):
00206             pwkey = lista[pkey] +"\n"
00207             file2.write(pwkey)
00208             if DEBUG:
00209                 print lineno(),  lista[pkey]
00210 
00211         file2.close()
00212 
00213     for i in range(len(lista)):
00214         if DEBUG:
00215             print lineno(), lista[i]
00216         nameDBS=""
00217         nameDBS=str(i)+".data"
00218         name=""
00219         name=str(i)+".json"
00220         nameLumi=""
00221         nameLumi=str(i)+".lumi"
00222         file1 = open( name ,'w')
00223         listaDBS = []
00224         if DEBUG:
00225             print lineno(), nameDBS
00226         for run in runs:
00227             key=printObj(run,'HLTKEY')
00228             if (key == lista[i]):
00229                 print "running......", key
00230                 if DEBUG:
00231                     print lineno(), printObj(run,'NUMBER')
00232                 txtruns = "{runNumber} >= " + printObj(run,'NUMBER') +  " and {runNumber} <= " + str(int(printObj(run,'NUMBER')))
00233                 txtriv = txtruns + " and {cmpDcsBPix} = 1  and {cmpDcsFPix} = 1 and {cmpDcsTibTid} = 1 and {cmpDcsTob} = 1 and {cmpDcsTecM} = 1 and {cmpDcsTecP} = 1"
00234                 lumirun = server.RunLumiSectionRangeTable.export('GLOBAL', 'json',txtriv)
00235                 if DEBUG:
00236                     print lineno(), lumirun
00237                   ###dbs file
00238                 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 CSCBaseElectronicsSim::simulate().

00178                         :
00179     return obj.getElementsByTagName(name)

def AlCaHLTBitMon_QueryRunRegistry::getRegExp ( regexp )

Definition at line 276 of file AlCaHLTBitMon_QueryRunRegistry.py.

00277                      :
00278     items = regexp.split(',') 
00279     dd = {}
00280     for item in items:
00281         key,value = item.split(':')
00282         dd[key.replace(' ','')] = value
00283     return dd
00284 
00285 
00286 #---------------------------------------------MAIN

def AlCaHLTBitMon_QueryRunRegistry::getText ( nodelist )

Definition at line 170 of file AlCaHLTBitMon_QueryRunRegistry.py.

00171                      :
00172     rc = ""
00173     for node in nodelist:
00174         if node.nodeType == node.TEXT_NODE:
00175             rc = rc + node.data
00176     return rc

def AlCaHLTBitMon_QueryRunRegistry::lineno ( )

Returns the current line number in our program.

Definition at line 34 of file AlCaHLTBitMon_QueryRunRegistry.py.

00035             :
00036     """Returns the current line number in our program."""
00037     return inspect.currentframe().f_back.f_lineno
00038 
#size file

def AlCaHLTBitMon_QueryRunRegistry::makecff	(	file_list,
		namefile
	)

file cff data

Definition at line 82 of file AlCaHLTBitMon_QueryRunRegistry.py.

00083                                :
00084     file1 = open(namefile ,'w')
00085     stringS  =           "process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(-1) )\n"
00086     stringS  = stringS + "readFiles = cms.untracked.vstring()\n"
00087     stringS  = stringS + "secFiles = cms.untracked.vstring()\n"
00088     stringS  = stringS + "\n"
00089     file1.write(stringS)
00090     
00091     filecount = 0
00092     extendOpen = 0
00093     for filename in file_list:
00094         
00095         if extendOpen == 0:
00096             stringS  = "readFiles.extend([\n"
00097             file1.write(stringS)
00098             extendOpen = 1
00099             
00100         stringS  =           "     '"
00101         stringS  = stringS + str(filename)
00102         stringS  = stringS + "',\n"
00103         file1.write(stringS)
00104         filecount = filecount + 1
00105         if filecount == 50:
00106             stringS  = "])\n\n"
00107             file1.write(stringS)
00108             filecount = 0
00109             extendOpen = 0
00110 
00111     if extendOpen == 1:
00112         stringS  =           "])\n\n"
00113         file1.write(stringS)
00114     
00115     stringS  =           "process.source = cms.Source(\"PoolSource\",\n"
00116     stringS  = stringS + "         fileNames = readFiles,\n"
00117     stringS  = stringS + "         secondaryFileNames = secFiles\n"
00118     stringS  = stringS + ")\n"
00119     file1.write(stringS)
00120     file1.close()
00121

def AlCaHLTBitMon_QueryRunRegistry::printLumi	(	file,
		namefile
	)

lumiCalc

Definition at line 45 of file AlCaHLTBitMon_QueryRunRegistry.py.

00046                             :
00047     if(filesize1(file) != 0):
00048         string= "lumiCalc2.py -c frontier://LumiCalc/CMS_LUMI_PROD -i "
00049         string1= " --nowarning overview >"
00050         string2= string + file + string1 + namefile
00051         data = os.system(string2)
00052     else:
00053         data = ""
00054         print "0 lumi are not avaible"
00055     return data

def AlCaHLTBitMon_QueryRunRegistry::printObj	(	obj,
		name
	)

Definition at line 180 of file AlCaHLTBitMon_QueryRunRegistry.py.

00181                       :
00182     return getText(getElement(obj,name)[0].childNodes)
00183

def AlCaHLTBitMon_QueryRunRegistry::serverQuery	(	workspaceName,
		regexp
	)

Definition at line 159 of file AlCaHLTBitMon_QueryRunRegistry.py.

00160                                      :
00161 
00162     # get handler to RR XML-RPC server
00163     server = xmlrpclib.ServerProxy('https://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
00164     if DEBUG:
00165         print lineno(), regexp
00166     data = server.RunDatasetTable.export(workspaceName,'xml_all' ,regexp)
00167     return data
00168 
00169 #----------------------------------------------------