ForwardSchedulerControlFlowTest.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py

from Gaudi.Configuration import *
from Configurables import HiveWhiteBoard, HiveSlimEventLoopMgr, ForwardSchedulerSvc, CPUCruncher,AlgResourcePool
from Configurables import  GaudiSequencer

InertMessageSvc(OutputLevel=INFO)

# metaconfig
evtslots = 1
evtMax = 20
cardinality=10
algosInFlight=10

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

slimeventloopmgr = HiveSlimEventLoopMgr(OutputLevel=INFO)

scheduler = ForwardSchedulerSvc(MaxEventsInFlight = evtslots,
                                MaxAlgosInFlight = algosInFlight,
                                OutputLevel=DEBUG)

AlgResourcePool(OutputLevel=DEBUG)

FakeInput = CPUCruncher("FakeInput", 
                        DataOutputs = ['/Event/DAQ/ODIN','/Event/DAQ/RawEvent','/Event/Hlt/LumiSummary'],
                        shortCalib=True,
                        varRuntime=.1, 
                        avgRuntime=.1 )

BrunelInit = CPUCruncher("BrunelInit",
                         DataInputs = ['/Event/DAQ/ODIN','/Event/DAQ/RawEvent'],
                         DataOutputs = ['/Event/Rec/Status', '/Event/Rec/Header'],
                         shortCalib=True)

PhysFilter = CPUCruncher("PhysFilter", 
                         shortCalib=True,
                         DataInputs = ['/Event/Hlt/LumiSummary'])

HltDecReportsDecoder = CPUCruncher("HltDecReportsDecoder", 
                                   shortCalib=True,
                                   DataInputs = ['/Event/DAQ/RawEvent'],
                                   DataOutputs = ['/Event/Hlt/DecReports'])

HltErrorFilter = CPUCruncher("HltErrorFilter",
                             shortCalib=True,
                             DataInputs = ['/Event/Hlt/DecReports'])
                                   
sequence1 = GaudiSequencer("Sequence1")
sequence1.Members += [FakeInput,BrunelInit,PhysFilter,HltDecReportsDecoder]
sequence1.ModeOR = False
sequence1.ShortCircuit = False # whether the evaluation is lazy or not!
sequence2 = GaudiSequencer("Sequence2")
sequence2.Members += [sequence1, HltErrorFilter]


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