ATLAS Offline Software
Functions | Variables
python.TrigServicesConfig Namespace Reference

Functions

def getMessageSvc (flags, msgSvcType="TrigMessageSvc")
 
def getTrigCOOLUpdateHelper (flags, name='TrigCOOLUpdateHelper')
 
def getHltROBDataProviderSvc (flags, name='ROBDataProviderSvc')
 
def getHltEventLoopMgr (flags, name='HltEventLoopMgr')
 
def TrigServicesCfg (flags)
 

Variables

 log = logging.getLogger('TrigServicesConfig')
 
 flags = defaultOnlineFlags()
 
 cfg = ComponentAccumulator()
 

Function Documentation

◆ getHltEventLoopMgr()

def python.TrigServicesConfig.getHltEventLoopMgr (   flags,
  name = 'HltEventLoopMgr' 
) 
online event loop manager

Definition at line 105 of file TrigServicesConfig.py.

105 def getHltEventLoopMgr(flags, name='HltEventLoopMgr'):
106  '''online event loop manager'''
107 
108  svc = CompFactory.HltEventLoopMgr(
109  name,
110  setMagFieldFromPtree = flags.Trigger.Online.BFieldAutoConfig
111  )
112 
113  # Rewrite LVL1 result if L1 simulation and BS-writing is enabled
114  if flags.Trigger.doLVL1 and flags.Trigger.writeBS:
115  svc.RewriteLVL1 = True
116  if flags.Trigger.enableL1MuonPhase1 or flags.Trigger.enableL1CaloPhase1:
117  svc.L1TriggerResultRHKey = 'L1TriggerResult'
118  if flags.Trigger.enableL1CaloLegacy or not flags.Trigger.enableL1MuonPhase1:
119  svc.RoIBResultRHKey = 'RoIBResult'
120 
121  # Monitoring
122  svc.MonTool = GenericMonitoringTool(flags, 'MonTool', HistPath='HLTFramework/'+name)
123 
124  svc.MonTool.defineHistogram('TotalTime', path='EXPERT', type='TH1F',
125  title='Total event processing time (all events);Time [ms];Events',
126  xbins=200, xmin=0, xmax=10000)
127  svc.MonTool.defineHistogram('TotalTime;TotalTime_extRange', path='EXPERT', type='TH1F',
128  title='Total event processing time (all events);Time [ms];Events',
129  xbins=200, xmin=0, xmax=20000, opt='kCanRebin')
130 
131  svc.MonTool.defineHistogram('TotalTimeAccepted', path='EXPERT', type='TH1F',
132  title='Total event processing time (accepted events);Time [ms];Events',
133  xbins=200, xmin=0, xmax=10000)
134  svc.MonTool.defineHistogram('TotalTimeAccepted;TotalTimeAccepted_extRange', path='EXPERT', type='TH1F',
135  title='Total event processing time (accepted events);Time [ms];Events',
136  xbins=200, xmin=0, xmax=20000, opt='kCanRebin')
137 
138  svc.MonTool.defineHistogram('TotalTimeRejected', path='EXPERT', type='TH1F',
139  title='Total event processing time (rejected events);Time [ms];Events',
140  xbins=200, xmin=0, xmax=10000)
141  svc.MonTool.defineHistogram('TotalTimeRejected;TotalTimeRejected_extRange', path='EXPERT', type='TH1F',
142  title='Total event processing time (rejected events);Time [ms];Events',
143  xbins=200, xmin=0, xmax=20000, opt='kCanRebin')
144 
145  svc.MonTool.defineHistogram('SlotIdleTime', path='EXPERT', type='TH1F',
146  title='Time between freeing and assigning a scheduler slot;Time [ms];Events',
147  xbins=400, xmin=0, xmax=400)
148  svc.MonTool.defineHistogram('SlotIdleTime;SlotIdleTime_extRange', path='EXPERT', type='TH1F',
149  title='Time between freeing and assigning a scheduler slot;Time [ms];Events',
150  xbins=400, xmin=0, xmax=800, opt='kCanRebin')
151 
152  svc.MonTool.defineHistogram('TIME_clearStore', path='EXPERT', type='TH1F',
153  title='Time of clearStore() calls;Time [ms];Calls',
154  xbins=200, xmin=0, xmax=50)
155  svc.MonTool.defineHistogram('TIME_clearStore;TIME_clearStore_extRange', path='EXPERT', type='TH1F',
156  title='Time of clearStore() calls;Time [ms];Calls',
157  xbins=200, xmin=0, xmax=200, opt='kCanRebin')
158 
159  svc.MonTool.defineHistogram('PopSchedulerTime', path='EXPERT', type='TH1F',
160  title='Time spent waiting for a finished event from the Scheduler;Time [ms];drainScheduler() calls',
161  xbins=250, xmin=0, xmax=250)
162  svc.MonTool.defineHistogram('PopSchedulerNumEvt', path='EXPERT', type='TH1F',
163  title='Number of events popped out of scheduler at the same time;Time [ms];drainScheduler() calls',
164  xbins=50, xmin=0, xmax=50)
165 
166  from TrigSteerMonitor.TrigSteerMonitorConfig import getTrigErrorMonTool
167  svc.TrigErrorMonTool = getTrigErrorMonTool(flags)
168 
169  if flags.Trigger.CostMonitoring.doCostMonitoring:
170  svc.TrigErrorMonTool.TrigCostSvc = CompFactory.TrigCostSvc()
171 
172  return svc
173 
174 

◆ getHltROBDataProviderSvc()

def python.TrigServicesConfig.getHltROBDataProviderSvc (   flags,
  name = 'ROBDataProviderSvc' 
) 
online ROB data provider service

Definition at line 76 of file TrigServicesConfig.py.

76 def getHltROBDataProviderSvc(flags, name='ROBDataProviderSvc'):
77  '''online ROB data provider service'''
78  svc = CompFactory.HltROBDataProviderSvc(name,
79  doCostMonitoring = (flags.Trigger.CostMonitoring.doCostMonitoring and
80  flags.Trigger.CostMonitoring.monitorROBs) )
81 
82  svc.MonTool = GenericMonitoringTool(flags, 'MonTool', HistPath='HLTFramework/'+name)
83  svc.MonTool.defineHistogram('TIME_ROBReserveData', path='EXPERT', type='TH1F',
84  title='Time to reserve ROBs for later retrieval;time [mu s]',
85  xbins=100, xmin=0, xmax=1000)
86  svc.MonTool.defineHistogram('NUMBER_ROBReserveData', path='EXPERT', type='TH1F',
87  title='Number of reserved ROBs for later retrieval;number',
88  xbins=100, xmin=0, xmax=500)
89  svc.MonTool.defineHistogram('TIME_ROBRequest', path='EXPERT', type='TH1F',
90  title='Time for ROB retrievals;time [mu s]',
91  xbins=400, xmin=0, xmax=200000)
92  svc.MonTool.defineHistogram('NUMBER_ROBRequest', path='EXPERT', type='TH1F',
93  title='Number of retrieved ROBs;number',
94  xbins=100, xmin=0, xmax=1000)
95  svc.MonTool.defineHistogram('TIME_CollectAllROBs', path='EXPERT', type='TH1F',
96  title='Time for retrieving complete event data;time [mu s]',
97  xbins=400, xmin=0, xmax=200000)
98  svc.MonTool.defineHistogram('NUMBER_CollectAllROBs', path='EXPERT', type='TH1F',
99  title='Number of received ROBs for collect call;number',
100  xbins=100, xmin=0, xmax=2500)
101 
102  return svc
103 
104 

◆ getMessageSvc()

def python.TrigServicesConfig.getMessageSvc (   flags,
  msgSvcType = "TrigMessageSvc" 
)

Definition at line 11 of file TrigServicesConfig.py.

11 def getMessageSvc(flags, msgSvcType="TrigMessageSvc"):
12  from AthenaCommon.Constants import DEBUG, WARNING
13 
14  # set message limit to unlimited when general DEBUG is requested
15  msgLimit = -100 if flags.Exec.OutputLevel>DEBUG else 0
16 
17  msgsvc = CompFactory.getComp(msgSvcType)(
18  "MessageSvc",
19  OutputLevel = flags.Exec.OutputLevel,
20  Format = "%t % F%40W%C%6W%R%e%4W%s%8W%R%T %0W%M",
21  ErsFormat = "%S: %M",
22  printEventIDLevel = WARNING,
23 
24  # Message suppression
25  enableSuppression = False,
26  suppressRunningOnly = True,
27  # 0 = no suppression, negative = log-suppression, positive = normal suppression
28  # Do not rely on the defaultLimit property, always set each limit separately
29  defaultLimit = msgLimit,
30  verboseLimit = msgLimit,
31  debugLimit = msgLimit,
32  infoLimit = msgLimit,
33  warningLimit = msgLimit,
34  errorLimit = 0,
35  fatalLimit = 0,
36 
37  # Message forwarding to ERS
38  useErsError = ['*'],
39  useErsFatal = ['*'],
40  ersPerEventLimit = 2, # ATR-25214
41 
42  # show summary statistics of messages in finalize
43  showStats = True,
44  statLevel = WARNING
45  )
46  return msgsvc
47 
48 

◆ getTrigCOOLUpdateHelper()

def python.TrigServicesConfig.getTrigCOOLUpdateHelper (   flags,
  name = 'TrigCOOLUpdateHelper' 
) 
Enable COOL folder updates

Definition at line 49 of file TrigServicesConfig.py.

49 def getTrigCOOLUpdateHelper(flags, name='TrigCOOLUpdateHelper'):
50  '''Enable COOL folder updates'''
51 
52  acc = ComponentAccumulator()
53 
54  montool = GenericMonitoringTool(flags, 'MonTool', HistPath='HLTFramework/'+name)
55  montool.defineHistogram('TIME_CoolFolderUpdate', path='EXPERT', type='TH1F',
56  title='Time for conditions update;time [ms]',
57  xbins=100, xmin=0, xmax=200)
58 
59  cool_helper = CompFactory.TrigCOOLUpdateHelper(
60  name,
61  MonTool = montool,
62  CoolFolderMap = '/TRIGGER/HLT/COOLUPDATE',
63  # List of folders that can be updated during the run:
64  Folders = ['/Indet/Onl/Beampos',
65  '/TRIGGER/LUMI/HLTPrefLumi',
66  '/TRIGGER/HLT/PrescaleKey'] )
67 
68  from IOVDbSvc.IOVDbSvcConfig import addFolders
69  acc.merge( addFolders(flags, cool_helper.CoolFolderMap, 'TRIGGER_ONL',
70  className='CondAttrListCollection') )
71 
72  acc.setPrivateTools( cool_helper )
73  return acc
74 
75 

◆ TrigServicesCfg()

def python.TrigServicesConfig.TrigServicesCfg (   flags)

Definition at line 175 of file TrigServicesConfig.py.

175 def TrigServicesCfg(flags):
176  acc = ComponentAccumulator()
177 
178  acc.addService( getMessageSvc(flags) )
179  acc.addService( getHltROBDataProviderSvc(flags) )
180  cool_helper = acc.popToolsAndMerge( getTrigCOOLUpdateHelper(flags) )
181 
182  loop_mgr = getHltEventLoopMgr(flags)
183  loop_mgr.CoolUpdateTool = cool_helper
184 
185  from TriggerJobOpts.TriggerHistSvcConfig import TriggerHistSvcConfig
186  acc.merge( TriggerHistSvcConfig(flags) )
187 
188  from TrigOutputHandling.TrigOutputHandlingConfig import HLTResultMTMakerCfg
189  loop_mgr.ResultMaker = HLTResultMTMakerCfg(flags)
190 
191  from TriggerJobOpts.TriggerByteStreamConfig import ByteStreamReadCfg
192  acc.merge(ByteStreamReadCfg(flags))
193  loop_mgr.EvtSel = acc.getService('EventSelectorByteStream')
194  loop_mgr.OutputCnvSvc = acc.getService('ByteStreamCnvSvc')
195 
196  # Rewrite LVL1 result if L1 simulation and BS-writing is enabled
197  if flags.Trigger.doLVL1 and flags.Trigger.writeBS:
198  from TrigT1ResultByteStream.TrigT1ResultByteStreamConfig import L1TriggerByteStreamEncoderCfg
199  acc.merge(L1TriggerByteStreamEncoderCfg(flags))
200 
201  from TrigSteerMonitor.TrigSteerMonitorConfig import SchedulerMonSvcCfg
202  acc.merge( SchedulerMonSvcCfg(flags) )
203  loop_mgr.MonitorScheduler = True
204 
205  acc.addService(loop_mgr, primary=True)
206  acc.setAppProperty("EventLoop", loop_mgr.name)
207 
208  return acc
209 
210 

Variable Documentation

◆ cfg

python.TrigServicesConfig.cfg = ComponentAccumulator()

Definition at line 216 of file TrigServicesConfig.py.

◆ flags

python.TrigServicesConfig.flags = defaultOnlineFlags()

Definition at line 213 of file TrigServicesConfig.py.

◆ log

python.TrigServicesConfig.log = logging.getLogger('TrigServicesConfig')

Definition at line 8 of file TrigServicesConfig.py.

python.TrigServicesConfig.getMessageSvc
def getMessageSvc(flags, msgSvcType="TrigMessageSvc")
Definition: TrigServicesConfig.py:11
python.TrigServicesConfig.getHltEventLoopMgr
def getHltEventLoopMgr(flags, name='HltEventLoopMgr')
Definition: TrigServicesConfig.py:105
python.JetAnalysisCommon.ComponentAccumulator
ComponentAccumulator
Definition: JetAnalysisCommon.py:302
TrigOutputHandlingConfig.HLTResultMTMakerCfg
def HLTResultMTMakerCfg(flags, name="HLTResultMTMaker")
Definition: TrigOutputHandlingConfig.py:6
GenericMonitoringTool
Definition: GenericMonitoringTool.h:53
python.ByteStreamConfig.ByteStreamReadCfg
def ByteStreamReadCfg(flags, type_names=None)
Definition: Event/ByteStreamCnvSvc/python/ByteStreamConfig.py:25
python.TrigSteerMonitorConfig.getTrigErrorMonTool
def getTrigErrorMonTool(flags, name='TrigErrorMonTool')
Definition: TrigSteerMonitorConfig.py:78
python.TrigServicesConfig.getHltROBDataProviderSvc
def getHltROBDataProviderSvc(flags, name='ROBDataProviderSvc')
Definition: TrigServicesConfig.py:76
python.TrigSteerMonitorConfig.SchedulerMonSvcCfg
def SchedulerMonSvcCfg(flags, name='SchedulerMonSvc')
Definition: TrigSteerMonitorConfig.py:7
python.TriggerHistSvcConfig.TriggerHistSvcConfig
def TriggerHistSvcConfig(flags)
Definition: TriggerHistSvcConfig.py:17
Constants
some useful constants -------------------------------------------------—
python.IOVDbSvcConfig.addFolders
def addFolders(flags, folderStrings, detDb=None, className=None, extensible=False, tag=None, db=None, modifiers='')
Definition: IOVDbSvcConfig.py:72
TrigT1ResultByteStreamConfig.L1TriggerByteStreamEncoderCfg
def L1TriggerByteStreamEncoderCfg(flags)
Definition: TrigT1ResultByteStreamConfig.py:300
python.TrigServicesConfig.TrigServicesCfg
def TrigServicesCfg(flags)
Definition: TrigServicesConfig.py:175
python.TrigServicesConfig.getTrigCOOLUpdateHelper
def getTrigCOOLUpdateHelper(flags, name='TrigCOOLUpdateHelper')
Definition: TrigServicesConfig.py:49
Generated on Tue Jul 2 2024 22:25:59 for ATLAS Offline Software by   doxygen 1.8.18