python.TrigGenericAlgsConfig Namespace Reference

Functions
def	TimeBurnerCfg (flags, name="TimeBurner", **kwargs)
def	TimeBurnerHypoToolGen (chainDict)
def	EndOfEventROIConfirmerAlgCfg (name)
def	EndOfEventFilterAlgCfg (name, chainName)
def	TrigEventInfoRecorderAlgCfg (flags, name, trigEventInfoKey, decoratePFlowInfo, decorateEMTopoInfo, renounceAll=False, primaryVertexInputName="HLT_IDVertex_FS", RhoKey_PFlow='HLT_Kt4EMPFlowEventShape', RhoKey_EMTopo='HLT_Kt4EMTopoEventShape')
def	L1CorrelationMonitoringCfg (flags, name)
def	L1CorrelationAlgCfg (flags, name, **kwargs)
def	ROBPrefetchingAlgCfg (flags, name, regSelDets=[], **kwargs)
def	ROBPrefetchingAlgCfg_Si (flags, nameSuffix, **kwargs)
def	ROBPrefetchingAlgCfg_Calo (flags, nameSuffix, **kwargs)
def	ROBPrefetchingAlgCfg_Muon (flags, nameSuffix, **kwargs)
def	getChainsForPrefetching (CF_list)
def	configurePrefetchingInitialRoI (flags, chains)
def	prefetchingInitialRoIConfig (flags, CFseq_list)

Variables
	_log

Function Documentation

configurePrefetchingInitialRoI()

def python.TrigGenericAlgsConfig.configurePrefetchingInitialRoI	(		flags,
			chains
	)

Definition at line 140 of file TrigGenericAlgsConfig.py.

def configurePrefetchingInitialRoI(flags, chains):
    from AthenaCommon.AlgSequence import AlgSequence
    from AthenaCommon.CFElements import findSubSequence, findAlgorithm
    chainFilterMap = getChainsForPrefetching(chains)
 
    hltBeginSeq = findSubSequence(AlgSequence(), 'HLTBeginSeq')
    for det,chainFilter in chainFilterMap.items():
        prefetchAlg = findAlgorithm(hltBeginSeq, f'ROBPrefetchingAlg_{det}_initialRoI')
        if not chainFilter:
            # Empty filter means unconditional prefetching
            # - prevent this by adding a non-existent hash to the list which effectively disables the prefetching alg
            _log.info('No chains matched to %s - forcing ChainFilter=[0] to disable this alg\'s prefetching', prefetchAlg.getName())
            chainFilter = [0]
 
        prefetchAlg.ChainFilter = chainFilter
 
# In CA we have no access to the HLTBeginSeq in here
# Instead generate the prefetching alg configs and append the ChainFilter,
# to be merged into the global config.

EndOfEventFilterAlgCfg()

def python.TrigGenericAlgsConfig.EndOfEventFilterAlgCfg	(		name,
			chainName
	)

Definition at line 21 of file TrigGenericAlgsConfig.py.

def EndOfEventFilterAlgCfg(name, chainName):
    return CompFactory.EndOfEventFilterAlg(name, ChainName=chainName)
 

EndOfEventROIConfirmerAlgCfg()

def python.TrigGenericAlgsConfig.EndOfEventROIConfirmerAlgCfg

(

name

)

Definition at line 18 of file TrigGenericAlgsConfig.py.

def EndOfEventROIConfirmerAlgCfg(name):
    return CompFactory.EndOfEventROIConfirmerAlg(name)
 

getChainsForPrefetching()

def python.TrigGenericAlgsConfig.getChainsForPrefetching

(

CF_list

)

Definition at line 66 of file TrigGenericAlgsConfig.py.

def getChainsForPrefetching(CF_list):
    from TrigConfHLTUtils.HLTUtils import string2hash
    from AthenaCommon.CFElements import getSequenceChildren, isSequence
    from collections import defaultdict
    def sequenceAlgs(seq):
        algs = []        
        for alg in getSequenceChildren(seq):            
            if isSequence(alg):
                algs.extend(sequenceAlgs(alg))
            elif alg.getName().startswith('IMEmpty'):
                # skip empty probe step in tag&probe chains
                continue
            else:
                algs.append(alg.getName())
      
        return algs
 
    def firstNonEmptyStepAlgs(CF_list): 
        algsMap = defaultdict(list) # {chainLegName, algsInFirstNonEmptyStep}
        firstSequence = []
 
        for cfseq_per_step in CF_list:
            for cfseq in cfseq_per_step: # all the steps with same step number
                step = cfseq.sequenceCA.step                
                foundFirstSequence = False
                for ileg, menuSeq in enumerate(step.sequences): 
                    seqA = sequenceAlgs(menuSeq.sequence.Alg)                  
                    if seqA: # found not empty sequence in this step
                        for stepD, chain in zip(cfseq.stepDicts, cfseq.chains): # loop over chains
                            if chain in firstSequence:
                                continue                            
                            legName = stepD[ileg]['chainName']
                            if legName not in algsMap: # add only the first time
                                algsMap[legName] = seqA                               
                                firstSequence.append(chain)
                                foundFirstSequence = True
 
                    if foundFirstSequence:
                        break
                                    
        return algsMap
 
    detGroupIdentifierAlgs = {
        'Si' : ['PixelRawDataProvider','SCTRawDataProvider'],
        'Calo' : ['HLTCaloCellMaker','FastCaloL2EgammaAlg'],
        'Muon' : ['RpcRawDataProvider','TgcRawDataProvider','MdtRawDataProvider','sTgcRawDataProvider','MMRawDataProvider']
    }
 
    def algsToDetGroup(algs):
        groups = []
        for group,idAlgs in detGroupIdentifierAlgs.items():            
            if any([ida in algName for algName in algs for ida in idAlgs]):
                groups.append(group)
        if len(groups)>1:
            raise RuntimeError(f'Multiple detector groups: {groups:s} matched to the list of algs: {algs:s}')
        return groups[0] if groups else None
 
    chainFilterMap = { # {DetGroup, list of chain leg hashes}
        'Si': [],
        'Calo': [],
        'Muon': []
    }
    
    
    algsMap = firstNonEmptyStepAlgs(CF_list)
    for legName,algs in algsMap.items():
        det = algsToDetGroup(algs)
        if not det:
            continue
        _log.debug("%s initialRoI will prefetch %s", legName, det)
        chainFilterMap[det].append(string2hash(legName))
    return chainFilterMap
 
# Legacy searches for the algs through the top level sequence

L1CorrelationAlgCfg()

def python.TrigGenericAlgsConfig.L1CorrelationAlgCfg	(		flags,
			name,
		**	kwargs
	)

Definition at line 45 of file TrigGenericAlgsConfig.py.

def L1CorrelationAlgCfg(flags, name, **kwargs):
    kwargs.setdefault("MonTool",L1CorrelationMonitoringCfg(flags, "L1CorrelationAlg"))
    return CompFactory.L1CorrelationAlg(name, **kwargs)
 

L1CorrelationMonitoringCfg()

def python.TrigGenericAlgsConfig.L1CorrelationMonitoringCfg	(		flags,
			name
	)

Definition at line 38 of file TrigGenericAlgsConfig.py.

def L1CorrelationMonitoringCfg(flags, name):
    from AthenaMonitoringKernel.GenericMonitoringTool import GenericMonitoringTool
    monTool = GenericMonitoringTool(flags, 'MonTool')
    monTool.defineHistogram('EF_L1Corr_beforeafterflag', path='EXPERT', type='TH1F', title='beforeafterflag', xbins=4, xmin=-1.5, xmax=2.5)
    monTool.defineHistogram('EF_L1Corr_l1a_type, EF_L1Corr_other_type', path='EXPERT', type='TH2F', title="typeMatrix ; L1A; Other", xbins=8, xmin=-0.5, xmax=7.5, ybins=8, ymin=-0.5, ymax=7.5)
    return monTool
 

prefetchingInitialRoIConfig()

def python.TrigGenericAlgsConfig.prefetchingInitialRoIConfig	(		flags,
			CFseq_list
	)

Definition at line 159 of file TrigGenericAlgsConfig.py.

def prefetchingInitialRoIConfig(flags, CFseq_list):
    chainFilterMap = getChainsForPrefetching(CFseq_list)
    configurators = {
        'Si':   ROBPrefetchingAlgCfg_Si,
        'Calo': ROBPrefetchingAlgCfg_Calo,
        'Muon': ROBPrefetchingAlgCfg_Muon,
    }
 
    prefetchCfg = ComponentAccumulator()
 
    for det,chainFilter in chainFilterMap.items():
        if not chainFilter:
            # Empty filter means unconditional prefetching
            # - prevent this by adding a non-existent hash to the list which effectively disables the prefetching alg
            _log.info('No chains matched to ROBPrefetchingAlg_%s_initialRoI - forcing ChainFilter=[0] to disable this alg\'s prefetching', det)
            chainFilter = [0]
        prefetchAlg = configurators[det](flags, 'initialRoI', ChainFilter=chainFilter)
        prefetchCfg.merge(prefetchAlg)
 
    return prefetchCfg
 
 

ROBPrefetchingAlgCfg()

def python.TrigGenericAlgsConfig.ROBPrefetchingAlgCfg	(		flags,
			name,
			regSelDets = [],
		**	kwargs
	)

Definition at line 49 of file TrigGenericAlgsConfig.py.

def ROBPrefetchingAlgCfg(flags, name, regSelDets=[], **kwargs):
    acc = ComponentAccumulator()
    alg = CompFactory.ROBPrefetchingAlg(name, **kwargs)
    alg.RegionSelectorTools = acc.popToolsAndMerge(getRegSelTools(flags, regSelDets))
    acc.addEventAlgo(alg, primary=True)
 
    return acc
 

ROBPrefetchingAlgCfg_Calo()

def python.TrigGenericAlgsConfig.ROBPrefetchingAlgCfg_Calo	(		flags,
			nameSuffix,
		**	kwargs
	)

Definition at line 60 of file TrigGenericAlgsConfig.py.

def ROBPrefetchingAlgCfg_Calo(flags, nameSuffix, **kwargs):
    return ROBPrefetchingAlgCfg(flags, 'ROBPrefetchingAlg_Calo_'+nameSuffix, ['TTEM', 'TTHEC', 'FCALEM', 'FCALHAD', 'TILE'], **kwargs)
 

ROBPrefetchingAlgCfg_Muon()

def python.TrigGenericAlgsConfig.ROBPrefetchingAlgCfg_Muon	(		flags,
			nameSuffix,
		**	kwargs
	)

Definition at line 63 of file TrigGenericAlgsConfig.py.

def ROBPrefetchingAlgCfg_Muon(flags, nameSuffix, **kwargs):
    return ROBPrefetchingAlgCfg(flags, 'ROBPrefetchingAlg_Muon_'+nameSuffix, ['MDT', 'RPC', 'TGC', 'CSC', 'MM', 'sTGC'], **kwargs)
   

ROBPrefetchingAlgCfg_Si()

def python.TrigGenericAlgsConfig.ROBPrefetchingAlgCfg_Si	(		flags,
			nameSuffix,
		**	kwargs
	)

Definition at line 57 of file TrigGenericAlgsConfig.py.

def ROBPrefetchingAlgCfg_Si(flags, nameSuffix, **kwargs):
    return ROBPrefetchingAlgCfg(flags, 'ROBPrefetchingAlg_Si_'+nameSuffix, ['Pixel', 'SCT'], **kwargs)
 

TimeBurnerCfg()

def python.TrigGenericAlgsConfig.TimeBurnerCfg	(		flags,
			name = "TimeBurner",
		**	kwargs
	)

Definition at line 10 of file TrigGenericAlgsConfig.py.

def TimeBurnerCfg(flags, name="TimeBurner", **kwargs):
    return CompFactory.TimeBurner(name, **kwargs)
 

TimeBurnerHypoToolGen()

def python.TrigGenericAlgsConfig.TimeBurnerHypoToolGen

(

chainDict

)

Definition at line 13 of file TrigGenericAlgsConfig.py.

def TimeBurnerHypoToolGen(chainDict):
    # Dummy HypoTool (it is not even called by TimeBurner)
    return CompFactory.TrigGenericHypoTool(chainDict['chainName'],
                                           PassString = "")
 

TrigEventInfoRecorderAlgCfg()

def python.TrigGenericAlgsConfig.TrigEventInfoRecorderAlgCfg	(		flags,
			name,
			trigEventInfoKey,
			decoratePFlowInfo,
			decorateEMTopoInfo,
			renounceAll = False,
			primaryVertexInputName = "HLT_IDVertex_FS",
			RhoKey_PFlow = 'HLT_Kt4EMPFlowEventShape',
			RhoKey_EMTopo = 'HLT_Kt4EMTopoEventShape'
	)

Definition at line 24 of file TrigGenericAlgsConfig.py.

def TrigEventInfoRecorderAlgCfg(flags, name, trigEventInfoKey, decoratePFlowInfo, decorateEMTopoInfo, renounceAll=False, primaryVertexInputName="HLT_IDVertex_FS", RhoKey_PFlow = 'HLT_Kt4EMPFlowEventShape', RhoKey_EMTopo = 'HLT_Kt4EMTopoEventShape'):
    acc = ComponentAccumulator()
    alg = CompFactory.TrigEventInfoRecorderAlg(name,
          trigEventInfoKey = trigEventInfoKey,
          decoratePFlowInfo = decoratePFlowInfo,
          decorateEMTopoInfo = decorateEMTopoInfo,
          renounceAll = renounceAll,
          primaryVertexInputName = primaryVertexInputName,
          RhoKey_PFlow = RhoKey_PFlow,
          RhoKey_EMTopo = RhoKey_EMTopo,
          )
    acc.addEventAlgo(alg, primary=True)
    return acc
 

Variable Documentation

_log

python.TrigGenericAlgsConfig._log

private

Definition at line 7 of file TrigGenericAlgsConfig.py.