Collaboration diagram for python.COOLUtils.COOLQuery:

Public Member Functions
def	__init__ (self, useOracle=False, debug=True)

def	__del__ (self)

def	getRunStartTime (self, runnr)

def	getLHCInfo (self, timeSinceEpochInSec)

def	getRunEndTime (self, runnr)

def	getLbTimes (self, runnr)

def	lbTime (self, runnr, lbnr)

def	getScanInfo (self, runnr)

def	scanInfo (self, runnr, lbnr)

Public Attributes
	tdaqdbname

	coolpath

	coolScanPath

	trigdbname

	coollbpath

	dcsdbname

	coollhcpath

	debug

	cooldb

	cooltrigdb

	cooldcsdb

	lbDictCache

	scanDictCache

Detailed Description

Utility to query COOL to retrieve start and end time of run and LBs.

Definition at line 122 of file COOLUtils.py.

Constructor & Destructor Documentation

◆ init()

def python.COOLUtils.COOLQuery.__init__	(	self,
		useOracle = `False`,
		debug = `True`
	)

Definition at line 124 of file COOLUtils.py.

     def __init__(self,useOracle=False,debug=True):
  
         self.tdaqdbname='COOLONL_TDAQ/CONDBR2'
         self.coolpath='/TDAQ/RunCtrl'
         self.coolScanPath='/TDAQ/OLC/LHC/SCANDATA'
  
         self.trigdbname='COOLONL_TRIGGER/CONDBR2'
         self.coollbpath='/TRIGGER/LUMI/LBLB'
  
         self.dcsdbname = 'COOLOFL_DCS/CONDBR2'
         self.coollhcpath = '/LHC/DCS/FILLSTATE'
  
         self.debug = debug
  
         print ('open cool db' )
         self.cooldb = AtlCoolLib.indirectOpen(self.tdaqdbname, True, self.debug)
         print ('open cooltrig db')
         self.cooltrigdb = AtlCoolLib.indirectOpen(self.trigdbname, True, self.debug)
         print ('open cooldcs db')
         self.cooldcsdb = AtlCoolLib.indirectOpen(self.dcsdbname, True, self.debug)
          
         self.lbDictCache = {'runnr': None, 'lbDict': None}
         self.scanDictCache = {'runnr': None, 'scanDict': None}
  

◆ del()

def python.COOLUtils.COOLQuery.__del__ ( self )

Definition at line 148 of file COOLUtils.py.

     def __del__(self):
         try:
           self.cooldb.closeDatabase()
           self.cooltrigdb.closeDatabase()
           self.cooldcsdb.closeDatabase()
         except Exception:
           print ("DB time out -- ignore")
  

Member Function Documentation

◆ getLbTimes()

def python.COOLUtils.COOLQuery.getLbTimes	(	self,
		runnr
	)

Get dict of LB start and end times in Unix time (seconds since epoch).

Definition at line 210 of file COOLUtils.py.

     def getLbTimes(self,runnr):
         """Get dict of LB start and end times in Unix time (seconds since epoch)."""
         iov1=runnr << 32
         iov2=(runnr+1) << 32
         if (iov2>cool.ValidityKeyMax): iov2=cool.ValidityKeyMax
         folderLB_Params = self.cooltrigdb.getFolder(self.coollbpath)
         itr = folderLB_Params.browseObjects(iov1, iov2, cool.ChannelSelection.all())
         lbDict = { }
         while itr.goToNext():
             obj = itr.currentRef()
             since = obj.since()
             run = since >> 32
             lb = since & 0xFFFFFFFF
             if (run != runnr): continue
  
             tlo = obj.payload()['StartTime']
             thi = obj.payload()['EndTime']
             lbDict[lb] = (COOLToUnixTime(tlo),COOLToUnixTime(thi))
         return lbDict
  

◆ getLHCInfo()

def python.COOLUtils.COOLQuery.getLHCInfo	(	self,
		timeSinceEpochInSec
	)

Get LHC fill and other info from COOL. The relevant COOL folder,
   /LHC/DCS/FILLSTATE is time-based, so the iov must be specified in
   ns since the epoch, but the argument to getLHCInfo is s since the
   epoch for convenience.

Definition at line 171 of file COOLUtils.py.

     def getLHCInfo(self,timeSinceEpochInSec):
         """Get LHC fill and other info from COOL. The relevant COOL folder,
            /LHC/DCS/FILLSTATE is time-based, so the iov must be specified in
            ns since the epoch, but the argument to getLHCInfo is s since the
            epoch for convenience."""
         t = timeSinceEpochInSec*1000000000
         lhcfolder = self.cooldcsdb.getFolder(self.coollhcpath)
         itr = lhcfolder.browseObjects(t,t,cool.ChannelSelection.all())
         try:
             info = { 'FillNumber': 0,
                      'StableBeams': False,
                      'BeamEnergyGeV': 0,
                      'NumBunchColl': 0 ,
                      'BetaStar': 0}
             itr.goToNext()
             obj = itr.currentRef()
             for k in info.keys():
                 try:
                     info[k] = obj.payload()[k]
                 except Exception:
                     print ('WARNING: Cannot find value for',k)
             return info
         except Exception:
             return None
  

◆ getRunEndTime()

def python.COOLUtils.COOLQuery.getRunEndTime	(	self,
		runnr
	)

Get end time of run in Unix time (seconds since epoch).

Definition at line 196 of file COOLUtils.py.

     def getRunEndTime(self,runnr):
         """Get end time of run in Unix time (seconds since epoch)."""
         iov=runnr << 32
         if (iov>cool.ValidityKeyMax): iov=cool.ValidityKeyMax
         folderEOR_Params = self.cooldb.getFolder(self.coolpath+'/EOR')
         itr = folderEOR_Params.browseObjects(iov, iov, cool.ChannelSelection.all())
         try:
             itr.goToNext()
             obj = itr.currentRef()
             eorTime = obj.payload()['EORTime']
             return COOLToUnixTime(eorTime)
         except Exception:
             return
  

◆ getRunStartTime()

def python.COOLUtils.COOLQuery.getRunStartTime	(	self,
		runnr
	)

Get start time of run in Unix time (seconds since epoch).

Definition at line 156 of file COOLUtils.py.

     def getRunStartTime(self,runnr):
         """Get start time of run in Unix time (seconds since epoch)."""
         iov=runnr << 32
         if (iov>cool.ValidityKeyMax): iov=cool.ValidityKeyMax
         folderSOR_Params = self.cooldb.getFolder(self.coolpath+'/SOR')
         itr = folderSOR_Params.browseObjects(iov, iov, cool.ChannelSelection.all())
         try:
             itr.goToNext()
             obj = itr.currentRef()
             sorTime = obj.payload()['SORTime']
             return COOLToUnixTime(sorTime)
         except Exception:
             return
  
  

◆ getScanInfo()

def python.COOLUtils.COOLQuery.getScanInfo	(	self,
		runnr
	)

Get dict of scan info

Definition at line 241 of file COOLUtils.py.

     def getScanInfo(self,runnr):
         """Get dict of scan info"""
         iov1 = self.getRunStartTime(runnr)*1000000000
         iov2 = self.getRunEndTime(runnr)*1000000000
         if (iov2>cool.ValidityKeyMax): iov2=cool.ValidityKeyMax
         folderScan_Params = self.cooldb.getFolder(self.coolScanPath)
         itr = folderScan_Params.browseObjects(iov1, iov2, cool.ChannelSelection.all())
         scanDict = { }
         while itr.goToNext():
             obj = itr.currentRef()
             runLB = obj.payload()['RunLB']
             run = runLB >> 32
             if (run != runnr): continue
             lb = runLB & 0xFFFFFFFF
             channelId = obj.channelId()
             scanningIP = obj.payload()['ScanningIP']
             # Select only the channel corresponding to IP
             mask = 1 << channelId
             if(scanningIP & mask == 0): continue
             acquisitionFlag = obj.payload()['AcquisitionFlag']
             nominalSeparation = obj.payload()['NominalSeparation']
             nominalSeparationPlane = obj.payload()['NominalSeparationPlane']
             B1DeltaXSet = obj.payload()['B1DeltaXSet']
             B2DeltaXSet = obj.payload()['B2DeltaXSet']
             B1DeltaYSet = obj.payload()['B1DeltaYSet']
             B2DeltaYSet = obj.payload()['B2DeltaYSet']
             scanDict[lb] = (scanningIP,acquisitionFlag,nominalSeparation,nominalSeparationPlane,B1DeltaXSet,B2DeltaXSet,B1DeltaYSet,B2DeltaYSet)
         return scanDict
  

◆ lbTime()

def python.COOLUtils.COOLQuery.lbTime	(	self,
		runnr,
		lbnr
	)

Get (startTime,endTime) for a given LB. The LB information is cached
   for the last run, in order make this efficient for querying for the
   times of individual LBs.

Definition at line 230 of file COOLUtils.py.

     def lbTime(self,runnr,lbnr):
         """Get (startTime,endTime) for a given LB. The LB information is cached
            for the last run, in order make this efficient for querying for the
            times of individual LBs."""
         runnr = int(runnr)
         if self.lbDictCache['runnr']!=runnr:
             # print ('Caching lbDict for run',runnr)
             self.lbDictCache['lbDict'] = self.getLbTimes(runnr)
             self.lbDictCache['runnr'] = runnr
         return self.lbDictCache['lbDict'].get(lbnr,None)
  

◆ scanInfo()

def python.COOLUtils.COOLQuery.scanInfo	(	self,
		runnr,
		lbnr
	)

Get scan information for a given LB. The LB information is cached
   for the last run, in order make this efficient for querying for the
   times of individual LBs.

Definition at line 270 of file COOLUtils.py.

     def scanInfo(self,runnr,lbnr):
         """Get scan information for a given LB. The LB information is cached
            for the last run, in order make this efficient for querying for the
            times of individual LBs."""
         runnr = int(runnr)
         if self.scanDictCache['runnr']!=runnr:
             self.scanDictCache['scanDict'] = self.getScanInfo(runnr)
             self.scanDictCache['runnr'] = runnr
         return self.scanDictCache['scanDict'].get(lbnr,None)
  

Member Data Documentation

◆ cooldb

python.COOLUtils.COOLQuery.cooldb

Definition at line 139 of file COOLUtils.py.

◆ cooldcsdb

python.COOLUtils.COOLQuery.cooldcsdb

Definition at line 143 of file COOLUtils.py.

◆ coollbpath

python.COOLUtils.COOLQuery.coollbpath

Definition at line 131 of file COOLUtils.py.

◆ coollhcpath

python.COOLUtils.COOLQuery.coollhcpath

Definition at line 134 of file COOLUtils.py.

◆ coolpath

python.COOLUtils.COOLQuery.coolpath

Definition at line 127 of file COOLUtils.py.

◆ coolScanPath

python.COOLUtils.COOLQuery.coolScanPath

Definition at line 128 of file COOLUtils.py.

◆ cooltrigdb

python.COOLUtils.COOLQuery.cooltrigdb

Definition at line 141 of file COOLUtils.py.

◆ dcsdbname

python.COOLUtils.COOLQuery.dcsdbname

Definition at line 133 of file COOLUtils.py.

◆ debug

python.COOLUtils.COOLQuery.debug

Definition at line 136 of file COOLUtils.py.

◆ lbDictCache

python.COOLUtils.COOLQuery.lbDictCache

Definition at line 145 of file COOLUtils.py.

◆ scanDictCache

python.COOLUtils.COOLQuery.scanDictCache

Definition at line 146 of file COOLUtils.py.

◆ tdaqdbname

python.COOLUtils.COOLQuery.tdaqdbname

Definition at line 126 of file COOLUtils.py.

◆ trigdbname

python.COOLUtils.COOLQuery.trigdbname

Definition at line 130 of file COOLUtils.py.

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

COOLUtils.py

Public Member Functions

Public Attributes