python.TriggerHandler.TriggerHandler Class Reference

Collaboration diagram for python.TriggerHandler.TriggerHandler:

Public Member Functions
def	__init__ (self)
def	clear (self)
def	loadData (self, startIOV, endIOV)
def	loadDataByRun (self, runnum, clear=True)
def	loadLBLBData (self, runnum)
def	loadTrigChannels (self, runnum)
def	loadTrigCounts (self, runnum)

Public Attributes
	menuReader
	countsReader
	lbtimeReader
	lblbReader
	verbose
	trigL1Dict
	allL1Triggers
	trigList
	trigChan
	chanTrig
	lblbDict
	runlist

Detailed Description

Definition at line 46 of file TriggerHandler.py.

Constructor & Destructor Documentation

__init__()

def python.TriggerHandler.TriggerHandler.__init__

(

self

)

Definition at line 48 of file TriggerHandler.py.

    def __init__(self):
 
        # Database parameters
        self.menuReader = CoolDataReader('COOLONL_TRIGGER/COMP200', '/TRIGGER/LVL1/Menu')
        self.countsReader = CoolDataReader('COOLONL_TRIGGER/COMP200', '/TRIGGER/LUMI/LVL1COUNTERS')
        self.lbtimeReader = CoolDataReader('COOLONL_TRIGGER/COMP200', '/TRIGGER/LUMI/LBTIME')
        self.lblbReader = CoolDataReader('COOLONL_TRIGGER/COMP200', '/TRIGGER/LUMI/LBLB')
 
        self.verbose = False
        #self.verbose = True
 
        # Dict of all TrigL1Data objects for the given time interval (keyed by RunLB IOV)
        self.trigL1Dict = dict()
 
        self.allL1Triggers = False
        
        # List of all trigger items to read
        self.trigList = ['L1_MBTS_2', 'L1_EM30']
 
        # Dictionary of trigger channel number keyed by trigger name
        self.trigChan = dict()
        self.chanTrig = dict() # reverse order
 
        # Store the lumi block times
        self.lblbDict = dict()
        

Member Function Documentation

clear()

def python.TriggerHandler.TriggerHandler.clear

(

self

)

Definition at line 75 of file TriggerHandler.py.

    def clear(self):
 
        # Clear trigger dict
        self.trigL1Dict.clear()
 

loadData()

def python.TriggerHandler.TriggerHandler.loadData	(		self,
			startIOV,
			endIOV
	)

Definition at line 81 of file TriggerHandler.py.

    def loadData(self, startIOV, endIOV):
 
        self.clear()
 
        # Runlist holds specific runs in this time range
        self.runlist = []
        
        if self.verbose: print('Searching for trigger information for max IOVRange', timeString(startIOV), timeString(endIOV))
        
        # Load the run based information as we fundamentally need to do this by run number
        
        # Prepare the lbtime reader
        self.lbtimeReader.setIOVRange(startIOV, endIOV)
        self.lbtimeReader.readData()
 
        for obj in self.lbtimeReader.data:
 
            runnum = int(obj.payload()['Run'])
 
            if runnum not in self.runlist:
                self.runlist.append(runnum)
                
        # Loop over each run, getting the trigger counts/Lumi
        # Must do this by run, as trigger menu can change
        # Here we are storing this in a separate list
        for runnum in self.runlist:
            self.loadDataByRun(runnum, clear=False)
 
 

loadDataByRun()

def python.TriggerHandler.TriggerHandler.loadDataByRun	(		self,
			runnum,
			clear = True
	)

Definition at line 111 of file TriggerHandler.py.

    def loadDataByRun(self, runnum, clear=True):
 
        if self.verbose:
            print('TriggerHandler.loadDataByRun(%d) called' % runnum)
            
        if clear:
            self.clear()
 
        # Figure out the channel mappings for the L1 trigger items
        self.loadTrigChannels(runnum)
 
        # Get the LB durations
        self.loadLBLBData(runnum)
        
        # Third, get the trigger counts
        self.loadTrigCounts(runnum)
 

loadLBLBData()

def python.TriggerHandler.TriggerHandler.loadLBLBData	(		self,
			runnum
	)

Definition at line 129 of file TriggerHandler.py.

    def loadLBLBData(self, runnum):
 
        if self.verbose:
            print('TriggerHandler.loadLBLBData(%d) called' % runnum)
 
        self.lblbDict.clear()
        self.lblbReader.setIOVRangeFromRun(runnum)
        self.lblbReader.readData()
 
        for obj in self.lblbReader.data:
            self.lblbDict[obj.since()] = (obj.payload()['StartTime'], obj.payload()['EndTime'])
            

loadTrigChannels()

def python.TriggerHandler.TriggerHandler.loadTrigChannels	(		self,
			runnum
	)

Definition at line 143 of file TriggerHandler.py.

    def loadTrigChannels(self, runnum):    
 
        if self.verbose:
            print('TriggerHandler.loadTrigChannels(%d) called' % runnum)
 
        # Trigger channels keyed by name            
        self.trigChan = dict()
 
        # Trigger name keyed by channel
        self.chanTrig = dict()
 
        for trig in self.trigList:
            self.trigChan[trig] = -1
 
        self.menuReader.setIOVRangeFromRun(runnum)
        self.menuReader.readData()
 
        for obj in self.menuReader.data:
            
            if self.verbose or True: print(int(obj.channelId()), obj.payload()['ItemName'])
 
            trigName = obj.payload()['ItemName']
            trigChan = int(obj.channelId())
 
            if self.allL1Triggers or self.trigList.count(trigName) > 0:
                self.trigChan[trigName] = trigChan
                self.chanTrig[trigChan] = trigName
                
        for trig in self.trigList:
            if self.trigChan[trig] == -1:
                print("Couldn't find", trig, "in run", str(runnum))
 
        if self.verbose:
            for (trig, chan) in self.trigChan.iteritems():         
                print('Found', trig, 'in channel', chan)
 

loadTrigCounts()

def python.TriggerHandler.TriggerHandler.loadTrigCounts	(		self,
			runnum
	)

Definition at line 181 of file TriggerHandler.py.

    def loadTrigCounts(self, runnum):
 
        if self.verbose:
            print('TriggerHandler.loadTrigCounts(%d) called' % runnum)
 
        self.countsReader.setIOVRangeFromRun(runnum)
 
        # Build channel list
        chanList = self.trigChan.values()
        chanList.sort()
 
        nMaxChan   = 50
        nChanBlock = 0
        chanBlock  = []
 
        # Skip any trigger we didn't find
        tmpList = []
        for chan in chanList:
            if chan < 0: continue
            tmpList.append( chan )
        chanList = tmpList
 
        if self.verbose:
            print('breaking up', len(chanList), 'into', nMaxChan, 'for run', runnum) 
 
        # There is a 50 item limit somehow hardcoded into browseObjects.
        # Use this code from Elliot to get around the limitation.
        
        # Break up list of indices into blocks:
        for x in range(0, len(chanList), nMaxChan):
            top = min([x+nMaxChan, len(chanList)])
 
            if self.verbose:
                print('Initializing block [%d] from %d to %d' % (nChanBlock, x, top))
                
            chanBlock.append( chanList[x:top] )
            nChanBlock += 1
 
        for x in range(nChanBlock):
            if self.verbose: print('Channel Selector', chanBlock[x])
            self.countsReader.setChannel(chanBlock[x])
            self.countsReader.readData()
 
            for obj in self.countsReader.data:
 
                since = obj.since()
                until = obj.until()
                if self.verbose:
                    print(runLBString(since), runLBString(until), obj.channelId(), obj.payload()['BeforePrescale'], obj.payload()['AfterPrescale'], obj.payload()['L1Accept'])
 
                # use the string as the dictionary key
                ss = since
                chan = int(obj.channelId())
                trig = self.chanTrig.get(chan, "")
                if len(trig) == 0:
                    print('TriggerHandler.loadTrigCounts(%d) - found unknown channel %d in %s!' % (runnum, chan, runLBString(ss)))
                    continue
                
                if ss not in self.trigL1Dict:
                    self.trigL1Dict[ss] = TriggerL1Data()
                    self.trigL1Dict[ss].runlb = obj.since()
                    self.trigL1Dict[ss].startTime = self.lblbDict.get(ss, (0., 0.))[0]
                    self.trigL1Dict[ss].endTime = self.lblbDict.get(ss, (0., 0.))[1]
                    self.trigL1Dict[ss].dtime = (self.trigL1Dict[ss].endTime - self.trigL1Dict[ss].startTime)/1.E9
 
                self.trigL1Dict[ss].TBP[trig] = obj.payload()['BeforePrescale']
                self.trigL1Dict[ss].TAP[trig] = obj.payload()['AfterPrescale']
                self.trigL1Dict[ss].TAV[trig] = obj.payload()['L1Accept']
                

Member Data Documentation

allL1Triggers

python.TriggerHandler.TriggerHandler.allL1Triggers

Definition at line 62 of file TriggerHandler.py.

chanTrig

python.TriggerHandler.TriggerHandler.chanTrig

Definition at line 69 of file TriggerHandler.py.

countsReader

python.TriggerHandler.TriggerHandler.countsReader

Definition at line 52 of file TriggerHandler.py.

lblbDict

python.TriggerHandler.TriggerHandler.lblbDict

Definition at line 72 of file TriggerHandler.py.

lblbReader

python.TriggerHandler.TriggerHandler.lblbReader

Definition at line 54 of file TriggerHandler.py.

lbtimeReader

python.TriggerHandler.TriggerHandler.lbtimeReader

Definition at line 53 of file TriggerHandler.py.

menuReader

python.TriggerHandler.TriggerHandler.menuReader

Definition at line 51 of file TriggerHandler.py.

runlist

python.TriggerHandler.TriggerHandler.runlist

Definition at line 86 of file TriggerHandler.py.

trigChan

python.TriggerHandler.TriggerHandler.trigChan

Definition at line 68 of file TriggerHandler.py.

trigL1Dict

python.TriggerHandler.TriggerHandler.trigL1Dict

Definition at line 60 of file TriggerHandler.py.

trigList

python.TriggerHandler.TriggerHandler.trigList

Definition at line 65 of file TriggerHandler.py.

verbose

python.TriggerHandler.TriggerHandler.verbose

Definition at line 56 of file TriggerHandler.py.

---

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

• TriggerHandler.py