Inheritance diagram for StandaloneBunchgroupHandler.BunchgroupHandler:

Collaboration diagram for StandaloneBunchgroupHandler.BunchgroupHandler:

Public Types
typedef HLT::TypeInformation::for_each_type_c< typenameEDMLIST::map, my_functor, my_result<>, my_arg< HLT::TypeInformation::get_cont, CONTAINER > >::type	result

Public Member Functions
	__init__ (self)
	openDB (self)
	closeDB (self)
	loadRunData (self, run)
	loadBunchgroups (self, run)
	getTrainPosition (self, run, lb, bcid)
	getNeighbourBcids (self, run, lb, bcid)
	getNeighbourPattern (self, run, lb, bcid)

Public Attributes
str	trigProdDbName = 'COOLONL_TRIGGER/COMP200'
str	bunchGroupContentFolder = '/TRIGGER/LVL1/BunchGroupContent'
str	bunchGroupDescFolder = '/TRIGGER/LVL1/BunchGroupDescription'
	trigProdDb = None
bool	verbose = True
int	physicsBunchgroupBit = 1
	runObjects = dict()
list	runArchive = []
int	runsToArchive = 20
int	bcidRange = 32

Detailed Description

Definition at line 69 of file StandaloneBunchgroupHandler.py.

Member Typedef Documentation

◆ result

typedef HLT::TypeInformation::for_each_type_c<typenameEDMLIST::map,my_functor,my_result<>,my_arg<HLT::TypeInformation::get_cont,CONTAINER>>::type master_search< typenameEDMLIST::map, HLT::TypeInformation::get_cont, CONTAINER >::result

inherited

Definition at line 90 of file EDM_MasterSearch.h.

Constructor & Destructor Documentation

◆ init()

StandaloneBunchgroupHandler.BunchgroupHandler.__init__ ( self )

Definition at line 71 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()

StandaloneBunchgroupHandler.BunchgroupHandler.closeDB ( self )

Definition at line 108 of file StandaloneBunchgroupHandler.py.

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

◆ getNeighbourBcids()

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

Definition at line 153 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()

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

Definition at line 179 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()

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

Definition at line 146 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()

StandaloneBunchgroupHandler.BunchgroupHandler.loadBunchgroups	(		self,
			run )

Definition at line 124 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()

StandaloneBunchgroupHandler.BunchgroupHandler.loadRunData	(		self,
			run )

Definition at line 114 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()

StandaloneBunchgroupHandler.BunchgroupHandler.openDB ( self )

Definition at line 98 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
 