AsyncTimeline.py

Go to the documentation of this file.

 
from Configurables import Gaudi__TestSuite__AsyncSleeperAlg as AsyncSleeperAlg
from Configurables import TimelineSvc
from Configurables import Gaudi__Sequencer as Sequencer
from Configurables import (
    AvalancheSchedulerSvc,
    HiveSlimEventLoopMgr,
    HiveWhiteBoard,
)
from Gaudi.Configuration import *
 
threads = 2
offloadThreads = 2
evtslots = 1
 
# Configure parallel services
slimeventloopmgr = HiveSlimEventLoopMgr(
    SchedulerName="AvalancheSchedulerSvc", OutputLevel=ERROR
)
whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots=evtslots)
scheduler = AvalancheSchedulerSvc(
    ThreadPoolSize=threads, NumOffloadThreads=offloadThreads, OutputLevel=WARNING
)
 
# Application setup
app = ApplicationMgr()
# - Algorithms
singleSleepAlg = AsyncSleeperAlg(
    "SingleSleepAlg", SuspensionDuration=100, SuspensionPoints=1
)  # Single suspension -> two timeline events
doubleSleepAlg = AsyncSleeperAlg(
    "DoubleSleepAlg", SuspensionDuration=100, SuspensionPoints=2
)  # Two suspensions -> three timeline events
sleepersSequencer = Sequencer(
    "Sleepers", Sequential=True, Members=[singleSleepAlg, doubleSleepAlg]
)  # No data dependencies between the two algorithms but executed in sequence due to the sequential flag.
 
app.TopAlg = [sleepersSequencer]
# - Events
app.EvtMax = 2
app.EvtSel = "NONE"
app.HistogramPersistency = "NONE"
app.EventLoop = slimeventloopmgr
app.ExtSvc = [whiteboard]
# - Activate timeline service
TimelineSvc(RecordTimeline=True, DumpTimeline=True, TimelineFile="myAsyncTimeline.csv")