Commit 861f1c97 authored by Hadrien Benjamin Grasland's avatar Hadrien Benjamin Grasland
Browse files

Updated test to make sure that data dependencies are declared to the Scheduler

parent b1fce252
......@@ -3,29 +3,41 @@
<argument name="program"><text>gaudirun.py</text></argument>
<argument name="options"><text>
from Gaudi.Configuration import *
from Configurables import DataHandleFlowAlgA, DataHandleFlowAlgB
from Configurables import DataHandleFlowAlgC, DataHandleFlowAlgD
from Configurables import DataHandleFlowAlgE, DataHandleFlowAlgF
from Configurables import DataHandleFlowAlgG, DataHandleFlowAlgH
from Configurables import (HiveWhiteBoard, HiveSlimEventLoopMgr,
AvalancheSchedulerSvc, AlgResourcePool,
DataHandleFlowAlgA, DataHandleFlowAlgB,
DataHandleFlowAlgC, DataHandleFlowAlgD,
DataHandleFlowAlgE, DataHandleFlowAlgF,
DataHandleFlowAlgG, DataHandleFlowAlgH)
from Configurables import EvtDataSvc
EvtDataSvc("EventDataSvc").RootCLID = 1
EvtDataSvc("EventDataSvc").RootName = "/Event"
EvtDataSvc("EventDataSvc").ForceLeaves = True
# Example configuration. We only need to check that data dependencies are fed
# to the Scheduler, so threaded execution is unnecessary unpredictability.
evtMax = 2
evtslots = 1
threads = 1
a = DataHandleFlowAlgA()
b = DataHandleFlowAlgB()
c = DataHandleFlowAlgC()
d = DataHandleFlowAlgD()
e = DataHandleFlowAlgE()
f = DataHandleFlowAlgF()
g = DataHandleFlowAlgG()
h = DataHandleFlowAlgH()
# Boring GaudiHive setup
whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots=evtslots)
slimeventloopmgr = HiveSlimEventLoopMgr(SchedulerName="AvalancheSchedulerSvc",
OutputLevel=DEBUG)
scheduler = AvalancheSchedulerSvc(ThreadPoolSize=threads,
OutputLevel=WARNING)
AlgResourcePool(OutputLevel=DEBUG)
# FIXME: Use the Scheduler instead of relying on human topological sort
app = ApplicationMgr(TopAlg = [a, b, h, d, g, e, c, f],
EvtSel = "NONE",
EvtMax = 2)
# A nontrivial Algorithm data flow graph. Notice that this is _not_ a correct
# execution order: the Scheduler should figure out a correct order using the
# data dependency information that the DataHandles provide.
algs = [DataHandleFlowAlgA(), DataHandleFlowAlgB(), DataHandleFlowAlgC(),
DataHandleFlowAlgD(), DataHandleFlowAlgE(), DataHandleFlowAlgF(),
DataHandleFlowAlgG(), DataHandleFlowAlgH()]
# Application manager setup
ApplicationMgr(EvtMax=evtMax,
EvtSel='NONE',
ExtSvc=[whiteboard],
EventLoop=slimeventloopmgr,
TopAlg=algs,
MessageSvcType="InertMessageSvc")
</text></argument>
<argument name="reference"><text>refs/data_handles_dataflow.ref</text></argument>
<argument name="exit_code"><integer>0</integer></argument>
......
# setting LC_ALL to "C"
# --> Including file '/tmp/tmpu9G5Lg.py'
# <-- End of file '/tmp/tmpu9G5Lg.py'
# --> Including file '/tmp/tmpv8_i_h.py'
# <-- End of file '/tmp/tmpv8_i_h.py'
MessageSvc INFO Activating in a separate thread
ApplicationMgr SUCCESS
====================================================================================================================================
Welcome to ApplicationMgr (GaudiCoreSvc v29r0)
running on localhost.localdomain on Fri Oct 6 14:13:47 2017
Welcome to ApplicationMgr (GaudiCoreSvc v30r2)
running on linux-2ak3 on Fri Jun 8 14:24:51 2018
====================================================================================================================================
ApplicationMgr INFO Application Manager Configured successfully
EventLoopMgr WARNING Unable to locate service "EventSelector"
EventLoopMgr WARNING No events will be processed from external input.
HiveSlimEventLo... DEBUG Property update for OutputLevel : new value = 2
HiveSlimEventLo... DEBUG Service base class initialized successfully
ThreadPoolSvc INFO no thread init tools attached
AlgResourcePool DEBUG Property update for OutputLevel : new value = 2
AlgResourcePool DEBUG Service base class initialized successfully
AlgResourcePool INFO TopAlg list empty. Recovering the one of Application Manager
AlgResourcePool DEBUG List of algorithms is:
AlgResourcePool DEBUG o DataHandleFlowAlgA/DataHandleFlowAlgA @ 0x557f11020fa0
AlgResourcePool DEBUG o DataHandleFlowAlgB/DataHandleFlowAlgB @ 0x557f11023d50
AlgResourcePool DEBUG o DataHandleFlowAlgC/DataHandleFlowAlgC @ 0x557f11025150
AlgResourcePool DEBUG o DataHandleFlowAlgD/DataHandleFlowAlgD @ 0x557f110264c0
AlgResourcePool DEBUG o DataHandleFlowAlgE/DataHandleFlowAlgE @ 0x557f11027950
AlgResourcePool DEBUG o DataHandleFlowAlgF/DataHandleFlowAlgF @ 0x557f11028fb0
AlgResourcePool DEBUG o DataHandleFlowAlgG/DataHandleFlowAlgG @ 0x557f1102a420
AlgResourcePool DEBUG o DataHandleFlowAlgH/DataHandleFlowAlgH @ 0x557f1102ba80
PrecedenceSvc INFO Assembling CF and DF task precedence rules
PrecedenceSvc INFO PrecedenceSvc initialized successfully
HiveSlimEventLo...WARNING Unable to locate service "EventSelector"
HiveSlimEventLo...WARNING No events will be processed from external input.
HistogramPersis...WARNING Histograms saving not required.
HiveSlimEventLo... INFO Found 0 events in black list
ApplicationMgr INFO Application Manager Initialized successfully
ApplicationMgr INFO Application Manager Started successfully
HiveSlimEventLo... INFO Starting loop on events
HiveSlimEventLo... DEBUG work loop iteration 0
HiveSlimEventLo... DEBUG createdEvts: 0, freeslots: 1
HiveSlimEventLo... DEBUG work loop iteration 1
HiveSlimEventLo... DEBUG Draining the scheduler
HiveSlimEventLo... DEBUG Waiting for a context
DataHandleFlowAlgA INFO Checking input keys
DataHandleFlowAlgA INFO Checking output keys
DataHandleFlowAlgA INFO Checking input values
......@@ -20,18 +45,14 @@ DataHandleFlowAlgB INFO Checking input keys
DataHandleFlowAlgB INFO Checking output keys
DataHandleFlowAlgB INFO Checking input values
DataHandleFlowAlgB INFO Sending output values
DataHandleFlowAlgH INFO Checking input keys
DataHandleFlowAlgH INFO Checking output keys
DataHandleFlowAlgH INFO Checking input values
DataHandleFlowAlgH INFO Sending output values
DataHandleFlowAlgD INFO Checking input keys
DataHandleFlowAlgD INFO Checking output keys
DataHandleFlowAlgD INFO Checking input values
DataHandleFlowAlgD INFO Sending output values
DataHandleFlowAlgG INFO Checking input keys
DataHandleFlowAlgG INFO Checking output keys
DataHandleFlowAlgG INFO Checking input values
DataHandleFlowAlgG INFO Sending output values
DataHandleFlowAlgH INFO Checking input keys
DataHandleFlowAlgH INFO Checking output keys
DataHandleFlowAlgH INFO Checking input values
DataHandleFlowAlgH INFO Sending output values
DataHandleFlowAlgE INFO Checking input keys
DataHandleFlowAlgE INFO Checking output keys
DataHandleFlowAlgE INFO Checking input values
......@@ -40,10 +61,21 @@ DataHandleFlowAlgC INFO Checking input keys
DataHandleFlowAlgC INFO Checking output keys
DataHandleFlowAlgC INFO Checking input values
DataHandleFlowAlgC INFO Sending output values
DataHandleFlowAlgG INFO Checking input keys
DataHandleFlowAlgG INFO Checking output keys
DataHandleFlowAlgG INFO Checking input values
DataHandleFlowAlgG INFO Sending output values
DataHandleFlowAlgF INFO Checking input keys
DataHandleFlowAlgF INFO Checking output keys
DataHandleFlowAlgF INFO Checking input values
DataHandleFlowAlgF INFO Sending output values
HiveSlimEventLo... DEBUG Context obtained
HiveSlimEventLo... DEBUG Clearing slot 0 (event 0) of the whiteboard
HiveSlimEventLo... DEBUG work loop iteration 2
HiveSlimEventLo... DEBUG createdEvts: 1, freeslots: 1
HiveSlimEventLo... DEBUG work loop iteration 3
HiveSlimEventLo... DEBUG Draining the scheduler
HiveSlimEventLo... DEBUG Waiting for a context
DataHandleFlowAlgA INFO Checking input keys
DataHandleFlowAlgA INFO Checking output keys
DataHandleFlowAlgA INFO Checking input values
......@@ -52,18 +84,14 @@ DataHandleFlowAlgB INFO Checking input keys
DataHandleFlowAlgB INFO Checking output keys
DataHandleFlowAlgB INFO Checking input values
DataHandleFlowAlgB INFO Sending output values
DataHandleFlowAlgH INFO Checking input keys
DataHandleFlowAlgH INFO Checking output keys
DataHandleFlowAlgH INFO Checking input values
DataHandleFlowAlgH INFO Sending output values
DataHandleFlowAlgD INFO Checking input keys
DataHandleFlowAlgD INFO Checking output keys
DataHandleFlowAlgD INFO Checking input values
DataHandleFlowAlgD INFO Sending output values
DataHandleFlowAlgG INFO Checking input keys
DataHandleFlowAlgG INFO Checking output keys
DataHandleFlowAlgG INFO Checking input values
DataHandleFlowAlgG INFO Sending output values
DataHandleFlowAlgH INFO Checking input keys
DataHandleFlowAlgH INFO Checking output keys
DataHandleFlowAlgH INFO Checking input values
DataHandleFlowAlgH INFO Sending output values
DataHandleFlowAlgE INFO Checking input keys
DataHandleFlowAlgE INFO Checking output keys
DataHandleFlowAlgE INFO Checking input values
......@@ -72,11 +100,19 @@ DataHandleFlowAlgC INFO Checking input keys
DataHandleFlowAlgC INFO Checking output keys
DataHandleFlowAlgC INFO Checking input values
DataHandleFlowAlgC INFO Sending output values
DataHandleFlowAlgG INFO Checking input keys
DataHandleFlowAlgG INFO Checking output keys
DataHandleFlowAlgG INFO Checking input values
DataHandleFlowAlgG INFO Sending output values
DataHandleFlowAlgF INFO Checking input keys
DataHandleFlowAlgF INFO Checking output keys
DataHandleFlowAlgF INFO Checking input values
DataHandleFlowAlgF INFO Sending output values
HiveSlimEventLo... DEBUG Context obtained
HiveSlimEventLo... DEBUG Clearing slot 0 (event 1) of the whiteboard
HiveSlimEventLo... INFO ---> Loop Finished (skipping 1st evt) - WSS 67.2148 total time 602568
HiveSlimEventLo... INFO 0 events were SKIPed
ApplicationMgr INFO Application Manager Stopped successfully
EventLoopMgr INFO Histograms converted successfully according to request.
HiveSlimEventLo... INFO Histograms converted successfully according to request.
ApplicationMgr INFO Application Manager Finalized successfully
ApplicationMgr INFO Application Manager Terminated successfully
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment