MiniBrunelScenario.py

Go to the documentation of this file.

import json
from Gaudi.Configuration import *
# ============================================================================
from Configurables import GaudiExamplesCommonConf, CPUCruncher, HiveSlimEventLoopMgr, HiveWhiteBoard, InertMessageSvc, ForwardSchedulerSvc
# ============================================================================
'''
Json file format:

"algorithms" : [
  {
    "name" : "Loader",
    "type" : "HiveReader",
    "inputs" : ["ROOT File"],
    "outputs" : ["DAQ/ODIN", "DAQ/RawEvent"
    
    ],
    "runtimes_wall" : [0.05]
    },
'''
#-------------------------------------------------------------------------------
# Metaconfig

NUMBEROFEVENTS = 828
NUMBEROFEVENTSINFLIGHT = 1
NUMBEROFALGOSINFLIGHT = 100
NUMBEROFTHREADS = 1
CLONEALGOS = False
DUMPQUEUES = False
VERBOSITY = 3


NumberOfEvents = NUMBEROFEVENTS
NumberOfEventsInFlight = NUMBEROFEVENTSINFLIGHT
NumberOfAlgosInFlight = NUMBEROFALGOSINFLIGHT
NumberOfThreads = NUMBEROFTHREADS
CloneAlgos = CLONEALGOS
DumpQueues = DUMPQUEUES
Verbosity = VERBOSITY


miniBruneljson = {
    "algorithms": [
        {
            "name": "Loader",
            "type": "HiveReader",
            "inputs": [],
            "outputs": ["/Event/DAQ/ODIN", "/Event/DAQ/RawEvent"

                        ],
            "runtimes_wall": [0.16]
        },
        {
            "name": "BrunelInit",
            "type": "RecInit",
            "inputs": ["DAQ/ODIN", "DAQ/RawEvent"],
            "outputs": ["/Event/Rec/Status", "/Event/Rec/Header"],
            "runtimes_wall": [0.183]
        },
        {
            "name": "BrunelEventCount",
            "type": "EventCountHisto",
            "inputs": [],
            "outputs": [],
            "runtimes_wall": [2.000000e-03]
        },
        {
            "name": "HltDecReportsDecoder",
            "type": "HltDecReportsDecoder",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Hlt/DecReports"],
            "runtimes_wall": [2.3]
        },
        {
            "name": "PrsFromRaw",
            "type": "CaloDigitsFromRaw",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Raw/Prs/Digits"],
            "runtimes_wall": [0.357]
        },
        {
            "name": "EcalZSup",
            "type": "CaloZSupAlg",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Raw/Ecal/Digits"],
            "runtimes_wall": [0.750]
        },
        {
            "name": "HcalZSup",
            "type": "CaloZSupAlg",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Raw/Hcal/Digits"],
            "runtimes_wall": [0.197]
        },
        {
            "name": "L0DUFromRaw",
            "type": "L0DUFromRawAlg",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Trig/L0/L0DUReport"],
            "runtimes_wall": [0.293]
        },
        {
            "name": "DecodeVeloClusters",
            "type": "DecodeVeloRawBuffer",
            "inputs": ["DAQ/RawEvent"],
            "outputs": ["/Event/Raw/Velo/LiteClusters", "/Event/Raw/Velo/Clusters"],
            "runtimes_wall": [1.095]
        },
        {
            "name": "CreateTTClusters",
            "type": "RawBankToSTClusterAlg",
            "inputs": ["DAQ/ODIN", "DAQ/RawEvent"],
            "outputs": ["/Event/Raw/TT/Clusters", "/Event/Rec/TT/Summary"],
            "runtimes_wall": [0.809]
        },
        {
            "name": "CreateTTLiteClusters",
            "type": "RawBankToSTLiteClusterAlg",
            "inputs": ["DAQ/ODIN", "DAQ/RawEvent"],
            "outputs": ["/Event/Raw/TT/LiteClusters"],
            "runtimes_wall": [0.208]
        },
        {
            "name": "CreateITClusters",
            "type": "RawBankToSTClusterAlg",
            "inputs": ["DAQ/ODIN", "DAQ/RawEvent"],
            "outputs": ["/Event/Raw/IT/Clusters", "/Event/Rec/IT/Summary"],
            "runtimes_wall": [0.672]
        },
        {
            "name": "CreateITLiteClusters",
            "type": "RawBankToSTLiteClusterAlg",
            "inputs": ["DAQ/ODIN", "DAQ/RawEvent"],
            "outputs": ["/Event/Raw/IT/LiteClusters"],
            "runtimes_wall": [0.177]
        },
        {
            "name": "FastVeloTracking",
            "type": "FastVeloTracking",
            "inputs": ["Raw/Velo/LiteClusters"],
            "outputs": ["/Event/Rec/Track/Velo"],
            "runtimes_wall": [4.3]
        }
    ]
}


def load_scenario():
    workflow = miniBruneljson
    cpu_cruncher_algos = []
    for algo in workflow["algorithms"]:
        theAvgRuntime = float(algo["runtimes_wall"][0] / 1000.)
        new_algo = CPUCruncher("%s@%s" % (algo["name"], algo["type"]),
                               avgRuntime=theAvgRuntime,
                               varRuntime=theAvgRuntime * 0.01,
                               DataInputs=algo["inputs"],
                               DataOutputs=algo["outputs"],
                               OutputLevel=INFO
                               )
        cpu_cruncher_algos.append(new_algo)
    return cpu_cruncher_algos

# Set output level threshold 2=DEBUG, 3=INFO, 4=WARNING, 5=ERROR, 6=FATAL )


msgSvc = InertMessageSvc("MessageSvc", OutputLevel=INFO)
ApplicationMgr().SvcMapping.append(msgSvc)
ApplicationMgr(MessageSvcType=msgSvc.getType(),
               OutputLevel=INFO)

crunchers = load_scenario()

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

slimeventloopmgr = HiveSlimEventLoopMgr(OutputLevel=INFO)

scheduler = ForwardSchedulerSvc(MaxEventsInFlight=NumberOfEventsInFlight,
                                MaxAlgosInFlight=100,
                                OutputLevel=WARNING)

# And the Application Manager
app = ApplicationMgr()
app.TopAlg = crunchers
app.EvtSel = "NONE"  # do not use any event input
app.EvtMax = NumberOfEvents
app.EventLoop = slimeventloopmgr
app.ExtSvc = [whiteboard]