detectSimpleStall.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py

"""
The options file models an intra-event stall in algorithm scheduling. 
An early exit from a group of algorithms called 'EarlyExitBranch' is performed due to 
an inverted CF decision sot that A2 is not run. This results in an unmet DF dependency 
for a downstream algorithm A3, leading to the stall.
"""

from Gaudi.Configuration import *
from Configurables import (HiveWhiteBoard, HiveSlimEventLoopMgr,
                           AvalancheSchedulerSvc, AlgResourcePool,
                           CPUCruncher)


evtslots = 1
evtMax = 1
cardinality = 1
threads = 1


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

slimeventloopmgr = HiveSlimEventLoopMgr(SchedulerName="AvalancheSchedulerSvc",
                                        OutputLevel=DEBUG)

scheduler = AvalancheSchedulerSvc(ThreadPoolSize=threads,
                                  OutputLevel=VERBOSE)

AlgResourcePool(OutputLevel=DEBUG)

# Set up of CPU crunchers -------------------------------------------------------

a1 = CPUCruncher("A1")
# to skip algorithm 'A2', force early exit from the branch
# This leads to data flow stall
a1.InvertDecision = True

# this algorithm is not run due to early exit from the group it belongs to
a2 = CPUCruncher("A2")
a2.outKeys = ['/Event/a2']

a3 = CPUCruncher("A3")
a3.inpKeys = ['/Event/a2']

# Assemble control flow graph
branch = GaudiSequencer("EarlyExitBranch", ModeOR=False,
                        ShortCircuit=True, Sequential=True)
branch.Members = [a1, a2]

for algo in [a1, a2, a3]:
    algo.shortCalib = True
    algo.Cardinality = cardinality
    algo.avgRuntime = .1

# Application Manager ----------------------------------------------------------

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