AvalancheSchedulerErrorTest.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py

"""
Test the correct handling on errors during the event processing:
- The CPUCruncher is configured to return an ERROR on a fraction of the events
- The EventLoopMgr is configured to continue with the next event on ERROR
"""

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

evtslots = 8
evtMax = 50
cardinality = 10
threads = 10

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

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

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

AlgResourcePool(OutputLevel=DEBUG)

scs = StatusCodeSvc("StatusCodeSvc", OutputLevel=DEBUG)

#
# - A3 returns an ERROR once in a while
# - A1-A2-A4 execute normally and then a stall is detected
#
#      A1
#     /  \
#    A2  A3
#    |   |
#    A4  A5
#
a1 = CPUCruncher("A1")
a1.outKeys = ['/Event/a1']

a2 = CPUCruncher("A2")
a2.inpKeys = ['/Event/a1']
a2.outKeys = ['/Event/a2']

a3 = CPUCruncher("A3")
a3.inpKeys = ['/Event/a1']
a3.outKeys = ['/Event/a3']
a3.FailNEvents = 7    # produce ERROR every Nth event

a4 = CPUCruncher("A4")
a4.inpKeys = ['/Event/a2']
a4.outKeys = ['/Event/a4']

a5 = CPUCruncher("A5")
a5.inpKeys = ['/Event/a3']
a5.outKeys = ['/Event/a5']

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

msgSvc = InertMessageSvc("MessageSvc", Format="% F%30W%S%4W%e%s%7W%R%T %0W%M")
ApplicationMgr().SvcMapping.append(msgSvc)

ApplicationMgr(EvtMax=evtMax,
               EvtSel='NONE',
               ExtSvc=[whiteboard, scs],
               EventLoop=slimeventloopmgr,
               TopAlg=[a1, a2, a3, a4, a5],
               MessageSvcType="InertMessageSvc")