EarlyTerminatingBranchesSharingAlgorithm.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py
 
"""Test a CF configuration with an algorithm shared between branches that can terminate early."""
 
from Configurables import (
    AlgResourcePool,
    AvalancheSchedulerSvc,
    CPUCruncher,
    GaudiSequencer,
    HiveSlimEventLoopMgr,
    HiveWhiteBoard,
)
from Gaudi.Configuration import *
 
# metaconfig
evtslots = 1
evtMax = 1
algosInFlight = 1
 
whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots=evtslots, OutputLevel=INFO)
 
slimeventloopmgr = HiveSlimEventLoopMgr(
    SchedulerName="AvalancheSchedulerSvc", OutputLevel=DEBUG
)
 
AvalancheSchedulerSvc(ThreadPoolSize=algosInFlight, OutputLevel=DEBUG)
 
 
def parOR(name, subs=[]):
    """parallel OR sequencer"""
    seq = GaudiSequencer(name)
    seq.ModeOR = True
    seq.Sequential = False
    seq.ShortCircuit = False
    #    seq.StopOverride = False
    for s in subs:
        seq.Members.append(s)
    return seq
 
 
def seqAND(name, subs=[]):
    """sequential AND sequencer"""
    seq = GaudiSequencer(name)
    seq.ModeOR = False
    seq.Sequential = True
    #    seq.StopOverride = True
    seq.ShortCircuit = True
    for s in subs:
        seq.Members.append(s)
    return seq
 
 
topSequence = GaudiSequencer("topSequence")
 
and1A = seqAND("AND1A")
 
filterA = CPUCruncher("filterA")
and1A.Members.append(filterA)
 
and2A = seqAND("AND2A")
# and2A.StopOverride = True
and1A.Members.append(and2A)
 
orA = parOR("ORA")
and2A.Members.append(orA)
 
and3A = seqAND("AND3A")
# and3A.StopOverride = True
orA.Members.append(and3A)
 
alg1 = CPUCruncher("Alg1")
and3A.Members.append(alg1)
 
hypoA = CPUCruncher("hypoA")
and2A.Members.append(hypoA)
 
 
and1B = seqAND("AND1B")
 
filterB = CPUCruncher("filterB", InvertDecision=True)
and1B.Members.append(filterB)
 
and2B = seqAND("AND2B")
# and2B.StopOverride = True
and1B.Members.append(and2B)
 
orB = parOR("ORB")
and2B.Members.append(orB)
 
and3B = seqAND("AND3B")
# and3B.StopOverride = True
orB.Members.append(and3B)
 
alg2 = CPUCruncher("Alg2")
and3B.Members.append(alg1)
 
hypoB = CPUCruncher("hypoB")
and2B.Members.append(hypoB)
 
 
 
topSequence.Members.append(and1A)
topSequence.Members.append(and1B)
 
ApplicationMgr(
    EvtMax=evtMax,
    EvtSel="NONE",
    ExtSvc=[whiteboard],
    EventLoop=slimeventloopmgr,
    TopAlg=[topSequence],
    MessageSvcType="InertMessageSvc",
    OutputLevel=INFO,
)