GaudiMP.GMPBase.Reader Class Reference

Inheritance diagram for GaudiMP.GMPBase.Reader:

Collaboration diagram for GaudiMP.GMPBase.Reader:

Public Member Functions
def	__init__

def	processConfiguration

def	DumpEvent

def	DoFirstEvent

def	Engine

Public Member Functions inherited from GaudiMP.GMPBase.GMPComponent
def	__init__

def	Start

def	Engine

def	processConfiguration

def	SetupGaudiPython

def	StartGaudiPython

def	LoadTES

def	getEventNumber

def	IdentifyWriters

def	dumpHistograms

def	Initialize

def	Finalize

def	Report

Public Attributes
	evtMax

	nOut

	app

	currentEvent

	firstEvTime

	stat

	tTime

Public Attributes inherited from GaudiMP.GMPBase.GMPComponent
	nodeType

	finalEvent

	lastEvent

	log

	nodeID

	currentEvent

	evcom

	evcoms

	hq

	fq

	nIn

	nOut

	stat

	iTime

	rTime

	fTime

	firstEvTime

	tTime

	proc

	a

	evt

	hvt

	fsr

	inc

	pers

	ts

	TS

	num

	app

	cntr

Additional Inherited Members
Static Public Attributes inherited from GaudiMP.GMPBase.GMPComponent
tuple	ks self.config.keys()

list	list ["Brunel", "DaVinci", "Boole", "Gauss"]

Detailed Description

Definition at line 641 of file GMPBase.py.

Constructor & Destructor Documentation

def GaudiMP.GMPBase.Reader.__init__	(	self,
		queues,
		events,
		params
	)

Definition at line 642 of file GMPBase.py.

 
     def __init__( self, queues, events, params ) :
         GMPComponent.__init__(self, 'Reader', -1, queues, events, params )

Member Function Documentation

def GaudiMP.GMPBase.Reader.DoFirstEvent ( self )

Definition at line 664 of file GMPBase.py.

 
     def DoFirstEvent( self ) :
         # Do First Event ------------------------------------------------------
         # Check Termination Criteria
         startFirst = time.time()
         self.log.info('Reader : First Event')
         if self.nOut == self.evtMax :
             self.log.info('evtMax( %i ) reached'%(self.evtMax))
             self.lastEvent.set()
             return SUCCESS
         else :
             # Continue to read, dump and send event
             self.a.run(1)
             if not bool(self.evt['/Event']) :
                 self.log.warning('No More Events! (So Far : %i)'%(self.nOut))
                 self.lastEvent.set()
                 return SUCCESS
             else :
                 # Popluate TESSerializer list and send Event
                 if self.app == "Gauss":
                    lst = self.evt.getHistoNames()
                 else:
                   try :
                     lst = self.evt.getList()
                     if self.app == "DaVinci":
                       daqnode = self.evt.retrieveObject( '/Event/DAQ' ).registry()
                       setOwnership( daqnode, False )
                       self.evt.getList( daqnode, lst, daqnode.address().par() )
                   except :
                     self.log.critical('Reader could not acquire TES List!')
                     self.lastEvent.set()
                     return FAILURE
                 self.log.info('Reader : TES List : %i items'%(len(lst)))
                 for l in lst :
                     self.ts.addItem(l)
                 self.currentEvent = self.getEventNumber( )
                 tb = self.TS.Dump( )
                 self.log.info('First Event Sent')
                 self.evcom.send( (self.currentEvent, tb) )
                 self.nOut += 1
                 self.eventLoopSyncer.set()
                 self.evt.clearStore( )
                 self.firstEvTime = time.time()-startFirst
                 return SUCCESS

def GaudiMP.GMPBase.Reader.DumpEvent ( self )

Definition at line 657 of file GMPBase.py.

 
     def DumpEvent( self ) :
         tb = TBufferFile( TBuffer.kWrite )
         # print '----Reader dumping Buffer!!!'
         self.ts.dumpBuffer( tb )
         # print '\tBuffer Dumped, size : %i'%( tb.Length() )
         return tb

def GaudiMP.GMPBase.Reader.Engine ( self )

Definition at line 708 of file GMPBase.py.

 
     def Engine( self ) :
 
         startEngine = time.time()
         self.log.name = 'Reader'
         self.log.info('Reader Process starting')
 
         self.Initialize()
 
         # add the Histogram Collection Algorithm
         self.a.addAlgorithm( CollectHistograms(self) )
 
         self.log.info('Reader Beginning Distribution')
         sc = self.DoFirstEvent( )
         if sc.isSuccess() :
             self.log.info('Reader First Event OK')
         else :
             self.log.critical('Reader Failed on First Event')
             self.stat = FAILURE
 
         # Do All Others -------------------------------------------------------
         while True :
             # Check Termination Criteria
             if self.nOut == self.evtMax :
                 self.log.info('evtMax( %i ) reached'%(self.evtMax))
                 break
             # Check Health
             if not self.stat.isSuccess() :
                 self.log.critical( 'Reader is Damaged!' )
                 break
             # Continue to read, dump and send event
             t = time.time()
             self.a.run(1)
             self.rTime += (time.time()-t)
             if not bool(self.evt['/Event']) :
                 self.log.warning('No More Events! (So Far : %i)'%(self.nOut))
                 break
             self.currentEvent = self.getEventNumber( )
             tb = self.TS.Dump( )
             self.evcom.send( (self.currentEvent, tb) )
             # clean up
             self.nOut += 1
             self.eventLoopSyncer.set()
             self.evt.clearStore( )
         self.log.info('Setting <Last> Event')
         self.lastEvent.set()
 
         # Finalize
         self.log.info( 'Reader : Event Distribution complete.' )
         self.evcom.finalize()
         self.Finalize()
         self.tTime = time.time() - startEngine
         self.Report()
 
 # =============================================================================

def GaudiMP.GMPBase.Reader.processConfiguration ( self )

Definition at line 645 of file GMPBase.py.

 
     def processConfiguration( self ) :
         # Reader :
         #   No algorithms
         #   No output
         #   No histos
         self.config[ 'ApplicationMgr' ].TopAlg    = []
         self.config[ 'ApplicationMgr' ].OutStream = []
         if "HistogramPersistencySvc" in self.config.keys() :
             self.config[ 'HistogramPersistencySvc' ].OutputFile = ''
         self.config['MessageSvc'].Format    = '[Reader]% F%18W%S%7W%R%T %0W%M'
         self.evtMax = self.config[ 'ApplicationMgr' ].EvtMax    

Gaudi Framework, version v23r5

Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation