Inheritance diagram for StandaloneBunchgroupHandler.BunchgroupHandler:

Collaboration diagram for StandaloneBunchgroupHandler.BunchgroupHandler:

Public Member Functions
def	__init__ (self)

def	openDB (self)

def	closeDB (self)

def	loadRunData (self, run)

def	loadBunchgroups (self, run)

def	getTrainPosition (self, run, lb, bcid)

def	getNeighbourBcids (self, run, lb, bcid)

def	getNeighbourPattern (self, run, lb, bcid)

Public Attributes
	trigProdDbName

	bunchGroupContentFolder

	bunchGroupDescFolder

	trigProdDb

	verbose

	physicsBunchgroupBit

	runObjects

	runArchive

	runsToArchive

	bcidRange

Detailed Description

Definition at line 71 of file StandaloneBunchgroupHandler.py.

Constructor & Destructor Documentation

◆ init()

def StandaloneBunchgroupHandler.BunchgroupHandler.__init__ ( self )

Definition at line 73 of file StandaloneBunchgroupHandler.py.

     def __init__(self):
  
         # Database parameters
         self.trigProdDbName = 'COOLONL_TRIGGER/COMP200'
         self.bunchGroupContentFolder = '/TRIGGER/LVL1/BunchGroupContent'
         self.bunchGroupDescFolder = '/TRIGGER/LVL1/BunchGroupDescription'
  
         # Database handle
         self.trigProdDb = None
         
         # self.verbose = False
         self.verbose = True
  
         # set physics bunch group
         self.physicsBunchgroupBit = 1
  
         # run objects
         self.runObjects = dict()
  
         # remember how many runs we have, keep only runsToArchive in memory
         self.runArchive = []
         # number of runs we keep in memory
         self.runsToArchive = 20
  
         # BCID range
         self.bcidRange = 32
  

Member Function Documentation

◆ closeDB()

def StandaloneBunchgroupHandler.BunchgroupHandler.closeDB ( self )

Definition at line 110 of file StandaloneBunchgroupHandler.py.

     def closeDB(self):
         # Close the database
         if self.trigProdDb is not None:
             self.trigProdDb.closeDatabase()
         self.trigProdDb = None
  

◆ getNeighbourBcids()

def StandaloneBunchgroupHandler.BunchgroupHandler.getNeighbourBcids	(	self,
		run,
		lb,
		bcid
	)

Definition at line 155 of file StandaloneBunchgroupHandler.py.

     def getNeighbourBcids(self,run,lb,bcid):
         
         if self.verbose:
             print('getNeighbourBcids called')
  
         before, after = self.getNeighbourPattern(run,lb,bcid)
  
         l1 = []
         for bcidOffset in range(len(before)):
             checkBcid = bcid - (bcidOffset+1)
             if checkBcid < 0: checkBcid += 3564
             if before[bcidOffset]: 
                 if self.verbose:
                     print("BCID",checkBcid,"is filled")
                 l1.append(checkBcid)
         l2 = []
         for bcidOffset in range(len(after)):
             checkBcid = bcid + (bcidOffset+1)
             if checkBcid > 3563: checkBcid -= 3564
             if after[bcidOffset]:
                 if self.verbose:
                     print("BCID",checkBcid,"is filled")
                 l2.append(checkBcid)
         return l1, l2
  
  

◆ getNeighbourPattern()

def StandaloneBunchgroupHandler.BunchgroupHandler.getNeighbourPattern	(	self,
		run,
		lb,
		bcid
	)

Definition at line 181 of file StandaloneBunchgroupHandler.py.

     def getNeighbourPattern(self,run,lb,bcid):
         
         if self.verbose:
             print('getNeighbourPattern called')
  
         lbList = []
         try:
             lbList = list(self.runObjects[run].physicsBunchgroupBcids.keys())
         except KeyError:
             self.loadRunData(run)
             lbList = list(self.runObjects[run].physicsBunchgroupBcids.keys())
  
         latestLb = -1
         try:
             latestLb = self.runObjects[run].lbLookup[lb]
         except KeyError:
             for testLb in sorted(lbList):
                 if latestLb < 0: latestLb = testLb
                 if lb > testLb: latestLb = testLb
             if self.verbose:
                 print("LB",lb,"latest LB",latestLb)
             self.runObjects[run].lbLookup[lb] = latestLb
  
         return (self.runObjects[run].bcidLookupBefore[latestLb][bcid], self.runObjects[run].bcidLookupAfter[latestLb][bcid])
  

◆ getTrainPosition()

def StandaloneBunchgroupHandler.BunchgroupHandler.getTrainPosition	(	self,
		run,
		lb,
		bcid
	)

Definition at line 148 of file StandaloneBunchgroupHandler.py.

     def getTrainPosition(self,run,lb,bcid):
         
         if self.verbose:
             print('getTrainPosition called')
         before, after = self.getNeighbourBcids(run,lb,bcid)
         return (len(before)+1)
  

◆ loadBunchgroups()

def StandaloneBunchgroupHandler.BunchgroupHandler.loadBunchgroups	(	self,
		run
	)

Definition at line 126 of file StandaloneBunchgroupHandler.py.

     def loadBunchgroups(self, run):
  
         self.runObjects[run] = BunchgroupRunData(run)
         self.runArchive.append(run)
         self.runObjects[run].verbose = self.verbose
  
         if self.verbose:
             print('loadBounchgroups called, run',run)
  
         bgFolder = self.trigProdDb.getFolder(self.bunchGroupContentFolder)
         itr = bgFolder.browseObjects(run << 32,(run+1) << 32,cool.ChannelSelection.all())
         while itr.goToNext() :
             obj=itr.currentRef()
             lb=(obj.since() & 0xffff)
             self.runObjects[run].physicsBunchgroupBcids[lb] = []
             bgcont = obj.payload()['BunchCode']
             for bcid in range(3564): 
                 if(bgcont[bcid]>>self.physicsBunchgroupBit & 1): self.runObjects[run].physicsBunchgroupBcids[lb].append(bcid)
             self.runObjects[run].createLookup(lb,self.bcidRange)
             if self.verbose:
                 print("LB",lb,"BCIDs",self.runObjects[run].physicsBunchgroupBcids[lb])
  

◆ loadRunData()

def StandaloneBunchgroupHandler.BunchgroupHandler.loadRunData	(	self,
		run
	)

Definition at line 116 of file StandaloneBunchgroupHandler.py.

     def loadRunData(self, run):        
         self.openDB()
         self.loadBunchgroups(run)
         self.closeDB()
         if len(self.runArchive) > self.runsToArchive:
             if self.verbose:
                 print("Remove run",self.runArchive[0],"from memory")
             del self.runObjects[self.runArchive[0]]
             self.runArchive.pop(0)
  

◆ openDB()

def StandaloneBunchgroupHandler.BunchgroupHandler.openDB ( self )

Definition at line 100 of file StandaloneBunchgroupHandler.py.

     def openDB(self):
         # Open the trigger COOL database
         try:
             self.trigProdDb = indirectOpen(self.trigProdDbName, True, False)
             if self.verbose: print('Connected to', self.trigProdDbName, 'for Trigger data')
         except Exception as e:
             print(e)
             return False
         return True
  