CFplusViewBug.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py

'''
A deliberately badly-configured job to demonstrate a crash in
sub-event scheduling.

The ViewTester is an algorithm specifically designed to create sub-event
contexts, pass them to the scheduler, and report on the current context.

The re-use of filter_alg causes the CF to "skip over" filter_alg2
This would then cause sub-events to be scheduled, but with the
"ShortCircuit" property of the hltStep node set True, the event can
be deleted before the sub-events have completed, causing the crash.

There is now protection in AvalancheScheduler against this crash,
but note that re-using algs in this way is still expected to cause
surprising CF behaviour.
'''
from Gaudi.Configuration import *
from Configurables import (HiveWhiteBoard, HiveSlimEventLoopMgr,
                           AvalancheSchedulerSvc, AlgResourcePool,
                           CPUCruncher, GaudiSequencer, Test__ViewTester)

# metaconfig -------------------------------------------------------------------
# It's confortable to collect the relevant parameters at the top of the optionfile
evtslots = 1
evtMax = 10
cardinality = 1
threads = 1
viewsPerEvt = 2
# -------------------------------------------------------------------------------

# 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(
    SchedulerName="AvalancheSchedulerSvc", OutputLevel=INFO)

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

# 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 = AvalancheSchedulerSvc(ThreadPoolSize=threads, OutputLevel=INFO)

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

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

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

filter_alg = CPUCruncher("filter_alg")
filter_alg.InvertDecision = False
filter_alg.avgRuntime = 0.0

filter_alg2 = CPUCruncher("filter_alg2")
filter_alg2.InvertDecision = True
filter_alg2.avgRuntime = 0.0

view_make_alg = Test__ViewTester("view_make_alg")
view_make_alg.baseViewName = 'view'
view_make_alg.viewNumber = viewsPerEvt
view_make_alg.viewNodeName = 'view_test_node'

view_test_alg = CPUCruncher("view_test_alg")
view_test_alg.InvertDecision = False
view_test_alg.avgRuntime = 1.0

for algo in [filter_alg, filter_alg2, view_make_alg, view_test_alg]:
    algo.Cardinality = cardinality
    algo.OutputLevel = INFO

view_test_node = GaudiSequencer("view_test_node",
                                Members=[view_test_alg],
                                Sequential=False,
                                OutputLevel=INFO)

view_make_node = GaudiSequencer("view_make_node",
                                Members=[filter_alg,
                                         view_make_alg, view_test_node],
                                Sequential=True,
                                OutputLevel=INFO)

hltStep = GaudiSequencer("hltStep",
                         Members=[filter_alg, filter_alg2, view_make_node],
                         Sequential=True,
                         ShortCircuit=True,
                         ModeOR=False,
                         OutputLevel=INFO)

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

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

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