In This Package:

TestMultiStream.py

Go to the documentation of this file.

#!/usr/bin/env python
'''
Put the same type of object into different streams
'''

from GaudiPython.GaudiAlgs import GaudiAlgo
from GaudiPython import SUCCESS, FAILURE, Bindings, gbl
import time

class MultiStreams(GaudiAlgo):
    '''
    Place multiple objects of the same type at multiple locations in
    the event store.
    '''
    def __init__(self,name='MultiStreams'):
        GaudiAlgo.__init__(self,name)
        self.count = 0;
        print 'MultiStreams: making one'
        return

    def execute(self):
        self.count += 1

        evt = self.evtSvc()

        print 'MultiStreams: reading in Lotsa headers'
        for ind in range(0,10):

            gh_path = '/Event/Gen/GenHeader%d'%ind
            gh = evt[gh_path]
            sh_path = '/Event/Sim/SimHeader%d'%ind
            sh = evt[sh_path]
            if not sh:
                print 'Failed to get "%s"'%sh_path
                return FAILURE

            ihs = sh.inputHeaders()
            if ihs.size():
                gh_input = ihs[0]
            else:
                print 'Got empty input headers from',sh_path
                return FAILURE

            print gh_path,gh.execNumber(),gh.timeStamp().AsString()
            print gh_path,gh_input.execNumber(),gh_input.timeStamp().AsString()
            print sh_path,sh.execNumber(),sh.timeStamp().AsString()
            print

            if gh.execNumber() != gh_input.execNumber():
                print 'GenHeader exec numbers differ: %d != %d'%\
                    (gh.execNumber(), gh_input.execNumber())
                return FAILURE
            if gh.timeStamp() != gh_input.timeStamp():
                print 'GenHeader time stamps differ: "%s" != "%s"'%\
                    (gh.timeStamp().AsString(),gh_input.timeStamp().AsString())
                return FAILURE
            continue
        return SUCCESS

        
def configure(argv=None):
    if not argv: return

    print argv
    if argv[0] == "LotsaGens":
        print 'Generating some stuff'
        from RootIOTest.RootIOTestConf import LotsaGens
        alg = LotsaGens()
        from Gaudi.Configuration import ApplicationMgr
        theApp = ApplicationMgr()
        theApp.TopAlg.append(alg)
    
    return

def run(app):
    alg = MultiStreams()
    app.addAlgorithm(alg)
    return

---