Skip to content
Snippets Groups Projects

Concurrent processing of events in hybrid MP+MT workers

Merged Vakhtang Tsulaia requested to merge tsulaia/athena:master-mpmt into master
7 files
+ 190
266
Compare changes
  • Side-by-side
  • Inline
Files
7
@@ -48,15 +48,16 @@ def _setupAtlasThreadedJob():
@@ -48,15 +48,16 @@ def _setupAtlasThreadedJob():
topSequence += SGInputLoader (FailIfNoProxy = False)
topSequence += SGInputLoader (FailIfNoProxy = False)
AlgScheduler.setDataLoaderAlg ('SGInputLoader' )
AlgScheduler.setDataLoaderAlg ('SGInputLoader' )
if theApp._opts.mtes :
if (theApp._opts.mtes or jps.ConcurrencyFlags.NumProcs()>0):
# Multi-threaded Event Service
# Either multi-threaded Event Service or hybrid MP+MT
from AthenaServices.AthenaServicesConf import AthenaMtesEventLoopMgr
from AthenaServices.AthenaServicesConf import AthenaMtesEventLoopMgr
svcMgr += AthenaMtesEventLoopMgr()
svcMgr += AthenaMtesEventLoopMgr()
svcMgr.AthenaMtesEventLoopMgr.WhiteboardSvc = "EventDataSvc"
svcMgr.AthenaMtesEventLoopMgr.WhiteboardSvc = "EventDataSvc"
svcMgr.AthenaMtesEventLoopMgr.SchedulerSvc = AlgScheduler.getScheduler().getName()
svcMgr.AthenaMtesEventLoopMgr.SchedulerSvc = AlgScheduler.getScheduler().getName()
 
 
if theApp._opts.mtes:
svcMgr.AthenaMtesEventLoopMgr.EventRangeChannel = theApp._opts.mtes_channel
svcMgr.AthenaMtesEventLoopMgr.EventRangeChannel = theApp._opts.mtes_channel
theApp.EventLoop = "AthenaMtesEventLoopMgr"
theApp.EventLoop = "AthenaMtesEventLoopMgr"
else:
else:
from AthenaServices.AthenaServicesConf import AthenaHiveEventLoopMgr
from AthenaServices.AthenaServicesConf import AthenaHiveEventLoopMgr
Loading