AtomicAlgSequencerTest.py

Go to the documentation of this file.

from Gaudi.Configuration import *
from Configurables import (HiveWhiteBoard, HiveSlimEventLoopMgr,
                           ForwardSchedulerSvc, AlgResourcePool,
                           CPUCruncher,
                           ContextEventCounterPtr,
                           ContextEventCounterData,
                           GaudiAtomicSequencer)

# metaconfig -------------------------------------------------------------------
# It's confortable to collect the relevant parameters at the top of the optionfile
evtslots = 5
evtMax = 20
cardinality=5
algosInFlight=10
#-------------------------------------------------------------------------------

# The configuration of the whiteboard ------------------------------------------
# It is useful to call it EventDataSvc to replace the usual data service with
# the whiteboard transparently.

whiteboard   = HiveWhiteBoard("EventDataSvc",
                              EventSlots = evtslots)

#-------------------------------------------------------------------------------

# Event Loop Manager -----------------------------------------------------------
# It's called slim since it has less functionalities overall than the good-old
# event loop manager. Here we just set its outputlevel to DEBUG.

slimeventloopmgr = HiveSlimEventLoopMgr(OutputLevel=DEBUG)

#-------------------------------------------------------------------------------

# ForwardScheduler -------------------------------------------------------------
# We just decide how many algorithms in flight we want to have and how many
# threads in the pool. The default value is -1, which is for TBB equivalent
# to take over the whole machine.

scheduler = ForwardSchedulerSvc(MaxAlgosInFlight = algosInFlight,
                                ThreadPoolSize = algosInFlight,
                                useGraphFlowManagement = True,
                                OutputLevel=DEBUG)

#-------------------------------------------------------------------------------

# Algo Resource Pool -----------------------------------------------------------
# Nothing special here, we just set the debug level.
AlgResourcePool(OutputLevel=DEBUG)

#-------------------------------------------------------------------------------

# Set up of the crunchers, daily business --------------------------------------

a1 = CPUCruncher("A1")
a1.DataOutputs.output_0.Path = '/Event/a1'

a2 = CPUCruncher("A2")
a2.DataInputs.input_0.Path = '/Skim/a1'
a2.DataInputs.input_0.AlternativePaths = ['/Event/a1']
a2.DataOutputs.output_0.Path = '/Event/a2'

a3 = CPUCruncher("A3")
a3.DataInputs.input_0.Path = '/Event/a1'
a3.DataOutputs.output_0.Path = '/Event/a3'

a4 = CPUCruncher("A4")
a4.DataInputs.input_0.Path = '/Event/a2'
a4.DataOutputs.output_0.Path = '/Event/a4'

for algo in [a1, a2, a3, a4]:
  algo.shortCalib=True
  algo.OutputLevel=DEBUG
  algo.varRuntime=.3
  algo.avgRuntime=.5

for algo in [a3]:
  algo.Cardinality = cardinality

seq = GaudiAtomicSequencer("CriticalSection",
                           Members=[a1,a2,a4],
                           OutputLevel=VERBOSE)

# Application Manager ----------------------------------------------------------
# We put everything together and change the type of message service

ApplicationMgr( EvtMax = evtMax,
                EvtSel = 'NONE',
                ExtSvc =[whiteboard],
                EventLoop = slimeventloopmgr,
                TopAlg = [seq, a3],
                MessageSvcType="InertMessageSvc")