ATLAS Offline Software
Loading...
Searching...
No Matches
python.TileCalibCrest.TileBlobReaderCrest Class Reference
Inheritance diagram for python.TileCalibCrest.TileBlobReaderCrest:
Collaboration diagram for python.TileCalibCrest.TileBlobReaderCrest:

Public Member Functions

 __init__ (self, db, folder='', tag='', run=None, lumi=0, modmin=0, modmax=275, copyBlob=False)
 getTag (self)
 getFolderTag (self, folder, prefix, globalTag, api=None)
 getIovs (self, since=(MINRUN, MINLBK), until=(MAXRUN, MAXLBK))
 getIov (self, option=0)
 getPayload (self, runlumi=None, dbg=False)
 getBlob (self, ros, mod, runlumi=None, dbg=False)
 getDrawer (self, ros, mod, runlumi=None, dbg=False, useDefault=True)
 getComment (self, runlumi=None, split=False)
 getDefault (self, ros, drawer)
 dumpIovs (self, iovList, rosmin, rosmax, drawermin, drawermax, option=1, comment=False, usenames=True)

Public Attributes

dict payload = {}

Private Member Functions

 __getIov (self, runlumi, dbg=False)
 __runlumi2iov (self, runlumi)
 __checkIov (self, runlumi)
 __make_blob (self, string)
 __create_comment (self, b64string)
 __create_drawer (self, b64string, chan)

Private Attributes

 __db = db
 __folder = folder
str __tag = tag
 __copyBlob = copyBlob
list __iovList = []
tuple __iov = (-1,0)
int __commentBlob = None
list __drawerBlob = [None]*276
 __comment = None
list __drawer = [None]*276
 __modmin = modmin
int __modmax = modmax+1
tuple __remote = (("http://" in db) or ("https://" in db) or ("CREST" in db))
 __api_instance = CrestApi(host=self.__db)

Detailed Description

TileCalibBlobReader is a helper class, managing the details of CREST interactions for
the user of TileCalibBlobs.

Definition at line 48 of file TileCalibCrest.py.

Constructor & Destructor Documentation

◆ __init__()

python.TileCalibCrest.TileBlobReaderCrest.__init__ ( self,
db,
folder = '',
tag = '',
run = None,
lumi = 0,
modmin = 0,
modmax = 275,
copyBlob = False )
Input:
- db    : server connection string or file name
- folder: full folder path
- tag   : The folder tag, e.g. \"UPD4-24\" or full tag
- run   : Run number (if known)
- lumi  : Lumi block number
- modmin: Minimal module (COOL channel number)
- modmax: Maximal module (COOL channel number)
- copyBlob: save payload from CREST (Default:False, True to copy payload to json file)

Definition at line 55 of file TileCalibCrest.py.

55 def __init__(self, db, folder='', tag='', run=None, lumi=0, modmin=0, modmax=275, copyBlob=False):
56 """
57 Input:
58 - db : server connection string or file name
59 - folder: full folder path
60 - tag : The folder tag, e.g. \"UPD4-24\" or full tag
61 - run : Run number (if known)
62 - lumi : Lumi block number
63 - modmin: Minimal module (COOL channel number)
64 - modmax: Maximal module (COOL channel number)
65 - copyBlob: save payload from CREST (Default:False, True to copy payload to json file)
66 """
67 #=== initialize base class
68 TileCalibLogger.__init__(self,"TileBlobReader")
69 self.payload = {}
70 self.__db = db
71 self.__folder = folder
72 self.__tag = tag
73 self.__copyBlob = copyBlob
74
75 self.__iovList = []
76 self.__iov = (-1,0)
77 self.__commentBlob = None
78 self.__drawerBlob = [None]*276
79 self.__comment = None
80 self.__drawer = [None]*276
81 self.__modmin = modmin
82 self.__modmax = modmax+1
83
84 #=== try to open db
85 self.__remote = (("http://" in db) or ("https://" in db) or ("CREST" in db))
86 if self.__remote:
87 if 'http' not in self.__db:
88 self.__db = os.getenv(db,os.getenv('CREST_HOST',os.getenv('CREST_SERVER_PATH','http://crest-j23.cern.ch:8080/api-v5.0')))
89 self.log().info('Host %s' , (self.__db))
90 self.__api_instance = CrestApi(host=self.__db)
91 socks = os.getenv('CREST_SOCKS', 'False')
92 if socks == 'True': self.__api_instance.socks()
93 self.__tag = self.getFolderTag(folder,None,tag)
94 if run is not None and lumi is not None:
95 log.info("Initializing for run %d, lumiblock %d", run,lumi)
96 self.__getIov((run,lumi),True)
97 else:
98 self.log().info('File %s' , (self.__db))
99 self.__api_instance = None
100 self.__tag = 'unknown'
101 self.__iovList.append(((MINRUN,MINLBK),(MAXRUN, MAXLBK)))
102 self.__iov = self.__runlumi2iov(self.__iovList[-1])
103 with open(self.__db, 'r') as the_file:
104 jdata = json.load(the_file)
105 if self.__copyBlob:
106 self.payload = jdata
107 return
108 for chan in range(self.__modmin,self.__modmax):
109 try:
110 blob=jdata[str(chan)][0]
111 except Exception:
112 blob=None
113 self.__create_drawer(blob,chan)
114 try:
115 blob=jdata['1000'][0]
116 except Exception:
117 blob=None
118 self.__create_comment(blob)
119

Member Function Documentation

◆ __checkIov()

python.TileCalibCrest.TileBlobReaderCrest.__checkIov ( self,
runlumi )
private

Definition at line 272 of file TileCalibCrest.py.

272 def __checkIov(self,runlumi):
273 point = (runlumi[0]<<32) + runlumi[1]
274 inrange = point>=self.__iov[0] and point<self.__iov[1]
275 return inrange
276

◆ __create_comment()

python.TileCalibCrest.TileBlobReaderCrest.__create_comment ( self,
b64string )
private

Definition at line 285 of file TileCalibCrest.py.

285 def __create_comment(self,b64string):
286 if b64string is None or len(b64string)==0:
287 if b64string is None:
288 self.__commentBlob = None
289 else:
290 self.__commentBlob = 0
291 self.__comment = None
292 else:
293 blob1 = base64.decodebytes(bytes(b64string,'ascii'))
294 self.__commentBlob = self.__make_blob(blob1)
295 self.__comment = TileCalibDrawerCmt.getInstance(self.__commentBlob)
296 return
297
static const TileCalibDrawerCmt * getInstance(const coral::Blob &blob)
Returns a pointer to a const TileCalibDrawerCmt.

◆ __create_drawer()

python.TileCalibCrest.TileBlobReaderCrest.__create_drawer ( self,
b64string,
chan )
private

Definition at line 299 of file TileCalibCrest.py.

299 def __create_drawer(self,b64string,chan):
300 if b64string is None or isinstance(b64string, (int, float)) or len(b64string)==0:
301 if b64string is None:
302 self.__drawerBlob[chan] = None
303 else:
304 self.__drawerBlob[chan] = 0
305 self.__drawer[chan] = None
306 return
307 blob1 = base64.decodebytes(bytes(b64string,'ascii'))
308 self.__drawerBlob[chan] = self.__make_blob(blob1)
309 cmt = TileCalibDrawerCmt.getInstance(self.__drawerBlob[chan])
310 typeName = TileCalibType.getClassName(cmt.getObjType())
311 del cmt
312 #=== create calibDrawer depending on type
313 if typeName=='TileCalibDrawerFlt':
314 self.__drawer[chan] = TileCalibDrawerFlt.getInstance(self.__drawerBlob[chan])
315 self.log().debug( "typeName = Flt " )
316 elif typeName=='TileCalibDrawerInt':
317 self.__drawer[chan] = TileCalibDrawerInt.getInstance(self.__drawerBlob[chan])
318 self.log().debug( "typeName = Int " )
319 elif typeName=='TileCalibDrawerBch':
320 self.__drawer[chan] = TileCalibDrawerBch.getInstance(self.__drawerBlob[chan])
321 self.log().debug( "typeName = Bch " )
322 elif typeName=='TileCalibDrawerOfc':
323 self.__drawer[chan] = TileCalibDrawerOfc.getInstance(self.__drawerBlob[chan])
324 self.log().debug( "typeName = Ofc " )
325 elif typeName=='TileCalibDrawerCmt':
326 self.__drawer[chan] = cppyy.gbl.CaloCondBlobFlt.getInstance(self.__drawerBlob[chan])
327 self.log().debug( "typeName = CaloFlt " )
328 else:
329 self.__drawer[chan] = None
330 self.log().warn("Unknown blob type for chan %d - ignoring", chan)
331 return
332
const bool debug
static const TileCalibDrawerBch * getInstance(const coral::Blob &blob)
Returns a pointer to a const TileCalibDrawerBch.
static const TileCalibDrawerFlt * getInstance(const coral::Blob &blob)
Returns a pointer to a const TileCalibDrawerFlt.
static const TileCalibDrawerInt * getInstance(const coral::Blob &blob)
Returns a pointer to a const TileCalibDrawerBch.
static TileCalibDrawerOfc * getInstance(coral::Blob &blob, uint16_t objVersion, uint32_t nSamples, int32_t nPhases, uint16_t nChans, uint16_t nGains, const std::string &author="", const std::string &comment="", uint64_t timeStamp=0)
Returns a pointer to a non-const TileCalibDrawerOfc.
static std::string getClassName(TileCalibType::TYPE type)
Returns the class name.

◆ __getIov()

python.TileCalibCrest.TileBlobReaderCrest.__getIov ( self,
runlumi,
dbg = False )
private

Definition at line 218 of file TileCalibCrest.py.

218 def __getIov(self,runlumi,dbg=False):
219 if self.__api_instance is None:
220 pass
221 else:
222 run_lumi1=str((runlumi[0]<<32)+runlumi[1]+1)
223 MAXRUNLUMI1=str(MAXRUNLUMI+1)
224 iovs1=self.__api_instance.select_iovs(self.__tag,"0",run_lumi1,sort='id.since:DESC,id.insertionTime:DESC',size=1,snapshot=0)
225 iovs2=self.__api_instance.select_iovs(self.__tag,run_lumi1,MAXRUNLUMI1,sort='id.since:ASC,id.insertionTime:DESC',size=1,snapshot=0)
226 if iovs1.size==0:
227 raise Exception( "IOV for tag %s run,lumi (%s,%s) not found" % (self.__tag,runlumi[0],runlumi[1]) )
228 else:
229 iov=iovs1.resources[0]
230 since=int(iov.since)
231 runS=since>>32
232 lumiS=since&0xFFFFFFFF
233 until=MAXRUNLUMI if iovs2.size==0 else iovs2.resources[0].since
234 runU=until>>32
235 lumiU=until&0xFFFFFFFF
236 hash=iov.payload_hash
237 if dbg:
238 #self.log().info('Run,Lumi (%d,%d)' , runlumi)
239 self.log().info('IOV [%d,%d] - (%d,%d)' , runS,lumiS,runU,lumiU)
240 self.log().info('Insertion time %s' , iov.insertion_time)
241 self.log().info('Hash %s' , hash)
242 payload = self.__api_instance.get_payload(hash=hash).decode('utf-8')
243 jdata=json.loads(payload)
244 #with open("payload.json", 'w') as the_file:
245 # the_file.write(payload)
246 # the_file.write('\n')
247 self.__iovList.append(((runS,lumiS),(runU, lumiU)))
248 self.__iov = self.__runlumi2iov(self.__iovList[-1])
249 if self.__copyBlob:
250 self.payload = jdata
251 return
252 for chan in range(self.__modmin,self.__modmax):
253 try:
254 blob=jdata[str(chan)][0]
255 except Exception:
256 blob=None
257 self.__create_drawer(blob,chan)
258 try:
259 blob=jdata['1000'][0]
260 except Exception:
261 blob=None
262 self.__create_comment(blob)
263 return
264

◆ __make_blob()

python.TileCalibCrest.TileBlobReaderCrest.__make_blob ( self,
string )
private

Definition at line 278 of file TileCalibCrest.py.

278 def __make_blob(self,string):
279 b = Blob()
280 b.write(string)
281 b.seek(0)
282 return b
283

◆ __runlumi2iov()

python.TileCalibCrest.TileBlobReaderCrest.__runlumi2iov ( self,
runlumi )
private

Definition at line 266 of file TileCalibCrest.py.

266 def __runlumi2iov(self,runlumi):
267 since = (runlumi[0][0]<<32) + runlumi[0][1]
268 until = (runlumi[1][0]<<32) + runlumi[1][1]
269 return (since,until)
270

◆ dumpIovs()

python.TileCalibCrest.TileBlobReaderCrest.dumpIovs ( self,
iovList,
rosmin,
rosmax,
drawermin,
drawermax,
option = 1,
comment = False,
usenames = True )
Dumps statistics - how many non-empty modules exists in different IOVs

Definition at line 436 of file TileCalibCrest.py.

436 def dumpIovs(self, iovList, rosmin, rosmax, drawermin, drawermax, option=1, comment=False, usenames=True):
437 """
438 Dumps statistics - how many non-empty modules exists in different IOVs
439 """
440
441 if len(iovList)>0:
442 alliovs={}
443 allmods={}
444 zeroiovs={}
445 nmod=0
446 rosrange=list(range(rosmin,rosmax))
447 if comment:
448 rosrange+=[9999]
449 for since in iovList:
450 iov="(%s,%s)" % since
451 allmod=""
452 missmod=""
453 zeromod=""
454 zero=0
455 miss=0
456 for ros in rosrange:
457 if ros<0:
458 (dmin,dmax) = (drawermin,drawermax)
459 elif ros>4:
461 else:
462 (dmin,dmax) = (drawermin,min(drawermax,TileCalibUtils.getMaxDrawer(ros)))
463 for drawer in range(dmin,dmax):
464 flt = self.getDrawer(ros, drawer, since, False, False)
465 if ros<0 or ros>4:
467 mod = "Comment"
468 else:
469 mod = "CH_"+str(getDrawerIdx(ros,drawer))
470 elif usenames:
471 mod = TileCalibUtils.getDrawerString(ros,drawer)
472 else:
473 mod = str(getDrawerIdx(ros,drawer))
474 if mod not in allmods:
475 allmods[mod] = ""
476 nmod += 1
477 if flt is not None:
478 if flt==0:
479 zero += 1
480 zeromod += " " + mod
481 allmod += " " + mod + "_zero"
482 allmods[mod] += " " + iov + "_zero"
483 else:
484 allmod += " " + mod
485 allmods[mod] += " " + iov
486 else:
487 miss+=1
488 missmod += " " + mod
489 word = 'module' if usenames else 'COOL channel'
490 if miss==0 and nmod>1:
491 alliovs[iov] = " All %s" % plural(nmod,word)
492 elif miss>0 and miss<10:
493 alliovs[iov] = " %s present, %s missing:%s" % (plural(nmod-miss,word),plural(miss,word),missmod)
494 else:
495 alliovs[iov] = "%s ; %s present, %s missing" % (allmod,plural(nmod-miss,word),plural(miss,word))
496 zeroiovs[iov] = (zero,zeromod)
497
498 if (option&1)==1:
499 print("")
500 for key,value in allmods.items():
501 if value=="":
502 value=" None"
503 print("%s\t%s" % (key,value))
504 if (option&2)==2:
505 print("")
506 for key,value in alliovs.items():
507 if value=="":
508 value=" None"
509 if zeroiovs[key] and zeroiovs[key][0]>0:
510 if "_zero" not in value:
511 print("%s\t%s ; zero-sized blobs for %d modules:%s" % (key,value,zeroiovs[key][0],zeroiovs[key][1]))
512 else:
513 print("%s\t%s ; zero-sized blobs for %d modules" % (key,value,zeroiovs[key][0]))
514 else:
515 print("%s\t%s" % (key,value))
516 else:
517 print("\nNo IOVs found")
518
519
void print(char *figname, TCanvas *c1)
#define min(a, b)
Definition cfImp.cxx:40
static std::string getDrawerString(unsigned int ros, unsigned int drawer)
Return the drawer name, e.g.
static unsigned int getMaxDrawer(unsigned int ros)
Returns the maximal channel number for a given drawer.
static unsigned int getCommentChannel()
Returns the COOL channel number for the comment channel.

◆ getBlob()

python.TileCalibCrest.TileBlobReaderCrest.getBlob ( self,
ros,
mod,
runlumi = None,
dbg = False )

Definition at line 342 of file TileCalibCrest.py.

342 def getBlob(self,ros, mod, runlumi=None, dbg=False):
343
344 if self.__remote and runlumi is not None and not self.__checkIov(runlumi):
345 self.__getIov(runlumi,dbg)
346
347 chanNum = getDrawerIdx(ros,mod)
348
349 if (chanNum>=0 and chanNum<len(self.__drawer)):
350 return self.__drawerBlob[chanNum]
351 else:
352 raise Exception( "Invalid drawer requested: %s %s" % (ros,mod) )
353

◆ getComment()

python.TileCalibCrest.TileBlobReaderCrest.getComment ( self,
runlumi = None,
split = False )

Definition at line 384 of file TileCalibCrest.py.

384 def getComment(self,runlumi=None,split=False):
385
386 if self.__remote and runlumi is not None and not self.__checkIov(runlumi):
387 self.__getIov(runlumi)
388 if self.__comment is not None:
389 if split:
390 return (self.__comment.getAuthor(),self.__comment.getComment(),self.__comment.getDate())
391 else:
392 return self.__comment.getFullComment()
393 else:
394 return "<no comment found>"
395

◆ getDefault()

python.TileCalibCrest.TileBlobReaderCrest.getDefault ( self,
ros,
drawer )
Returns a default drawer number (among first 20 COOL channels) for any drawer in any partition

Definition at line 397 of file TileCalibCrest.py.

397 def getDefault(self, ros, drawer):
398 """
399 Returns a default drawer number (among first 20 COOL channels) for any drawer in any partition
400 """
401 if ros==0:
402 if drawer<=4 or drawer==12 or drawer>=20:
403 drawer1=0
404 elif drawer<12:
405 drawer1=4
406 else:
407 drawer1=12
408 elif ros==1 or ros==2:
409 drawer1=4
410 elif ros==3:
411 OffsetEBA = [ 0, 0, 0, 0, 0, 0, 3, 2, #// Merged E+1: EBA07; Outer MBTS: EBA08
412 0, 0, 0, 0, 7, 6, 5, 7, #// D+4: EBA13, EBA16; Special D+4: EBA14; Special D+40: EBA15
413 7, 6, 6, 7, 0, 0, 0, 2, #// D+4: EBA17, EBA20; Special D+4: EBA18, EBA19; Outer MBTS: EBA24
414 3, 0, 0, 0, 0, 0, 0, 0, #// Merged E+1: EBA25
415 0, 0, 0, 0, 0, 0, 1, 1, #// Inner MBTS + special C+10: EBA39, EBA40
416 1, 1, 2, 3, 0, 0, 0, 0, #// Inner MBTS + special C+10: EBA41, EBA42; Outer MBTS: EBA43; Merged E+1: EBA44
417 0, 0, 0, 0, 3, 2, 1, 1, #// Merged E+1: EBA53; Outer MBTS: EBA54; Inner MBTS + special C+10: EBA55, EBA56
418 1, 1, 0, 0, 0, 0, 0, 0] #// Inner MBTS + special C+10: EBA57, EBA58
419 drawer1 = 12 + OffsetEBA[drawer]
420 elif ros==4:
421 OffsetEBC = [ 0, 0, 0, 0, 0, 0, 3, 2, #// Merged E-1: EBC07; Outer MBTS: EBC08
422 0, 0, 0, 0, 7, 6, 6, 7, # // D-4: EBC13, EBC16; Special D-4: EBC14, EBC15;
423 7, 5, 6, 7, 0, 0, 0, 2, #// D-4: EBC17, EBC20; Special D-40 EBC18; Special D-4: EBC19; Outer MBTS: EBC24
424 3, 0, 0, 3, 4, 0, 3, 4, #// Merged E-1: EBC25, EBC28, EBC31; E-4': EBC29, EBC32
425 0, 4, 3, 0, 4, 3, 1, 1, #// E-4': EBC34, EBC37; Merged E-1: EBC35, EBC38; Inner MBTS + special C-10: EBC39, EBC40
426 1, 1, 2, 3, 0, 0, 0, 0, #// Inner MBTS + special C-10: EBC41, EBC42; Outer MBTS: EBC43; Merged E-1: EBC44
427 0, 0, 0, 0, 3, 2, 1, 1, #// Merged E-1: EBC53; Outer MBTS: EBC54; Inner MBTS + special C-10: EBC55, EBC56
428 1, 1, 0, 0, 0, 0, 0, 0] #// Inner MBTS + special C-10: EBC57, EBC58
429 drawer1 = 12 + OffsetEBC[drawer]
430 else:
431 drawer1=0
432
433 return (0,drawer1)
434

◆ getDrawer()

python.TileCalibCrest.TileBlobReaderCrest.getDrawer ( self,
ros,
mod,
runlumi = None,
dbg = False,
useDefault = True )

Definition at line 355 of file TileCalibCrest.py.

355 def getDrawer(self,ros, mod, runlumi=None, dbg=False, useDefault=True):
356
357 if self.__remote and runlumi is not None and not self.__checkIov(runlumi):
358 self.__getIov(runlumi,dbg)
359
360 chanNum = getDrawerIdx(ros,mod)
361
362 if (chanNum>=0 and chanNum<len(self.__drawer)):
363 drawer=self.__drawer[chanNum]
364 if not useDefault and drawer is None:
365 if self.__drawerBlob[chanNum] is None:
366 return None
367 else:
368 return 0
369 while drawer is None:
370 #=== no default at all?
371 if ros==0 and drawer==0:
372 raise Exception('No default available')
373 #=== follow default policy
374 ros,mod = self.getDefault(ros,mod)
375 chanNum = getDrawerIdx(ros,mod)
376 drawer=self.__drawer[chanNum]
377 return drawer
378 elif (chanNum == 1000):
379 return self.__comment
380 else:
381 raise Exception( "Invalid drawer requested: %s %s" % (ros,mod) )
382

◆ getFolderTag()

python.TileCalibCrest.TileBlobReaderCrest.getFolderTag ( self,
folder,
prefix,
globalTag,
api = None )

Definition at line 125 of file TileCalibCrest.py.

125 def getFolderTag(self, folder, prefix, globalTag, api=None):
126 if globalTag=='CURRENT' or globalTag=='UPD4' or globalTag=='' or globalTag=='HEAD':
127 globalTag=TileCalibTools.getAliasFromFile('Current')
128 log.info("Resolved CURRENT globalTag to \'%s\'", globalTag)
129 elif globalTag=='CURRENTES' or globalTag=='UPD1':
130 globalTag=TileCalibTools.getAliasFromFile('CurrentES')
131 log.info("Resolved CURRENT ES globalTag to \'%s\'", globalTag)
132 elif globalTag=='NEXT':
133 globalTag=TileCalibTools.getAliasFromFile('Next')
134 log.info("Resolved NEXT globalTag to \'%s\'", globalTag)
135 elif globalTag=='NEXTES':
136 globalTag=TileCalibTools.getAliasFromFile('NextES')
137 log.info("Resolved NEXT ES globalTag to \'%s\'", globalTag)
138 globalTag=globalTag.replace('*','')
139 if prefix is None:
140 prefix = ''
141 for f in folder.split('/'):
142 if re.findall('[a-z]+',f) != [] and f!='CellNoise':
143 prefix+=f
144 else:
145 prefix+=f.capitalize()
146 else:
147 prefix=prefix.strip('-').split('-')[0]
148 if prefix.startswith('Calo') and 'NoiseCell' not in prefix:
149 prefix='CALO'+prefix[4:]
150 if 'UPD1' in globalTag or 'UPD4' in globalTag or 'COND' not in globalTag:
151 if prefix != '':
152 if globalTag.startswith(prefix) or globalTag.startswith(prefix.upper()):
153 tag=globalTag
154 else:
155 tag=prefix+'-'+globalTag
156 self.log().info("Resolved localTag \'%s\' to folderTag \'%s\'", globalTag,tag)
157 elif folder!='' and not (globalTag.upper().startswith('TILE') or globalTag.upper().startswith('CALO')):
158 tag = TileCalibUtils.getFullTag(folder, globalTag)
159 if tag.startswith('Calo') and 'NoiseCell' not in tag:
160 tag='CALO'+tag[4:]
161 self.log().info("Resolved localTag \'%s\' to folderTag \'%s\'", globalTag,tag)
162 else:
163 tag=globalTag
164 self.log().info("Use localTag \'%s\' as is", tag)
165 else:
166 tag=None
167 if api:
168 tags=api.find_global_tag_map(globalTag)
169 else:
170 tags=self.__api_instance.find_global_tag_map(globalTag)
171 if tags.size==0:
172 raise Exception( "globalTag %s not found" % (globalTag) )
173 else:
174 for i in range(tags.size):
175 t=tags.resources[i].tag_name
176 l=tags.resources[i].label
177 if (prefix!='' and t.startswith(prefix)) or l==folder:
178 tag=t
179 self.log().info("Resolved globalTag \'%s\' to folderTag \'%s\'", globalTag,tag)
180 #taginfo = self.__api_instance.find_tag(name=tag)
181 #print(taginfo)
182 return tag
183
static std::string getFullTag(const std::string &folder, const std::string &tag)
Returns the full tag string, composed of camelized folder name and tag part.
std::vector< std::string > split(const std::string &s, const std::string &t=":")
Definition hcg.cxx:177

◆ getIov()

python.TileCalibCrest.TileBlobReaderCrest.getIov ( self,
option = 0 )

Definition at line 211 of file TileCalibCrest.py.

211 def getIov(self, option=0):
212 if option!=0:
213 return self.__iov
214 else:
215 return self.__iovList[-1]
216

◆ getIovs()

python.TileCalibCrest.TileBlobReaderCrest.getIovs ( self,
since = (MINRUN,MINLBK),
until = (MAXRUN,MAXLBK) )

Definition at line 185 of file TileCalibCrest.py.

185 def getIovs(self,since=(MINRUN,MINLBK),until=(MAXRUN,MAXLBK)):
186 if self.__api_instance is None:
187 return [self.__iovList[0][0]]
188 else:
189 run_lumi1=str((since[0]<<32)+since[1]+1)
190 run_lumi2=str((until[0]<<32)+until[1]+1)
191 MAXRUNLUMI1=str(MAXRUNLUMI+1)
192 iovs1=self.__api_instance.select_iovs(self.__tag,"0",run_lumi1,sort='id.since:DESC,id.insertionTime:DESC',size=1,snapshot=0)
193 iovs2=self.__api_instance.select_iovs(self.__tag,run_lumi2,MAXRUNLUMI1,sort='id.since:ASC,id.insertionTime:DESC',size=1,snapshot=0)
194 since1=0 if iovs1.size==0 else iovs1.resources[0].since
195 until1=MAXRUNLUMI if iovs2.size==0 else iovs2.resources[0].since
196 iovs=self.__api_instance.select_iovs(self.__tag,str(since1),str(until1),sort='id.since:ASC,id.insertionTime:DESC',size=999999,snapshot=0)
197 iovList=[]
198 if iovs.size==0:
199 raise Exception( "IOV for tag %s IOV [%s,%s] - (%s,%s) not found" % (self.__tag,since[0],since[1],until[0],until[1]) )
200 else:
201 for i in range(iovs.size):
202 iov=iovs.resources[i]
203 since=int(iov.since)
204 runS=since>>32
205 lumiS=since&0xFFFFFFFF
206 if (runS,lumiS) not in iovList:
207 iovList.append((runS,lumiS))
208 return iovList
209

◆ getPayload()

python.TileCalibCrest.TileBlobReaderCrest.getPayload ( self,
runlumi = None,
dbg = False )

Definition at line 334 of file TileCalibCrest.py.

334 def getPayload(self, runlumi=None, dbg=False):
335
336 if self.__remote and runlumi is not None and not self.__checkIov(runlumi):
337 self.__getIov(runlumi,dbg)
338
339 return self.payload
340

◆ getTag()

python.TileCalibCrest.TileBlobReaderCrest.getTag ( self)

Definition at line 121 of file TileCalibCrest.py.

121 def getTag(self):
122 return self.__tag
123

Member Data Documentation

◆ __api_instance

python.TileCalibCrest.TileBlobReaderCrest.__api_instance = CrestApi(host=self.__db)
private

Definition at line 90 of file TileCalibCrest.py.

◆ __comment

python.TileCalibCrest.TileBlobReaderCrest.__comment = None
private

Definition at line 79 of file TileCalibCrest.py.

◆ __commentBlob

int python.TileCalibCrest.TileBlobReaderCrest.__commentBlob = None
private

Definition at line 77 of file TileCalibCrest.py.

◆ __copyBlob

python.TileCalibCrest.TileBlobReaderCrest.__copyBlob = copyBlob
private

Definition at line 73 of file TileCalibCrest.py.

◆ __db

python.TileCalibCrest.TileBlobReaderCrest.__db = db
private

Definition at line 70 of file TileCalibCrest.py.

◆ __drawer

list python.TileCalibCrest.TileBlobReaderCrest.__drawer = [None]*276
private

Definition at line 80 of file TileCalibCrest.py.

◆ __drawerBlob

list python.TileCalibCrest.TileBlobReaderCrest.__drawerBlob = [None]*276
private

Definition at line 78 of file TileCalibCrest.py.

◆ __folder

python.TileCalibCrest.TileBlobReaderCrest.__folder = folder
private

Definition at line 71 of file TileCalibCrest.py.

◆ __iov

tuple python.TileCalibCrest.TileBlobReaderCrest.__iov = (-1,0)
private

Definition at line 76 of file TileCalibCrest.py.

◆ __iovList

list python.TileCalibCrest.TileBlobReaderCrest.__iovList = []
private

Definition at line 75 of file TileCalibCrest.py.

◆ __modmax

python.TileCalibCrest.TileBlobReaderCrest.__modmax = modmax+1
private

Definition at line 82 of file TileCalibCrest.py.

◆ __modmin

python.TileCalibCrest.TileBlobReaderCrest.__modmin = modmin
private

Definition at line 81 of file TileCalibCrest.py.

◆ __remote

tuple python.TileCalibCrest.TileBlobReaderCrest.__remote = (("http://" in db) or ("https://" in db) or ("CREST" in db))
private

Definition at line 85 of file TileCalibCrest.py.

◆ __tag

python.TileCalibCrest.TileBlobReaderCrest.__tag = tag
private

Definition at line 72 of file TileCalibCrest.py.

◆ payload

dict python.TileCalibCrest.TileBlobReaderCrest.payload = {}

Definition at line 69 of file TileCalibCrest.py.


The documentation for this class was generated from the following file: