Inheritance diagram for GaudiMP.GMPBase.Reader:

Collaboration diagram for GaudiMP.GMPBase.Reader:

Public Member Functions
def	__init__ (self, queues, events, params, subworkers)

def	processConfiguration (self)

def	DumpEvent (self)

def	DoFirstEvent (self)

def	Engine (self)

def	__init__ (self, queues, events, params, subworkers)

def	processConfiguration (self)

def	DumpEvent (self)

def	DoFirstEvent (self)

def	Engine (self)

Public Member Functions inherited from GaudiMP.GMPBase.GMPComponent
def	__init__ (self, nodeType, nodeID, queues, events, params, subworkers)

def	Start (self)

def	Engine (self)

def	processConfiguration (self)

def	SetupGaudiPython (self)

def	StartGaudiPython (self)

def	LoadTES (self, tbufferfile)

def	getEventNumber (self)

def	IdentifyWriters (self)

def	dumpHistograms (self)

def	Initialize (self)

def	Finalize (self)

def	Report (self)

def	__init__ (self, nodeType, nodeID, queues, events, params, subworkers)

def	Start (self)

def	Engine (self)

def	processConfiguration (self)

def	SetupGaudiPython (self)

def	StartGaudiPython (self)

def	LoadTES (self, tbufferfile)

def	getEventNumber (self)

def	IdentifyWriters (self)

def	dumpHistograms (self)

def	Initialize (self)

def	Finalize (self)

def	Report (self)

Public Attributes
	evtMax

	nOut

	app

	currentEvent

	firstEvTime

	stat

	tTime

Public Attributes inherited from GaudiMP.GMPBase.GMPComponent
	nodeType

	finalEvent

	lastEvent

	log

	subworkers

	nodeID

	currentEvent

	queues

	num

	app

	evcom

	evcoms

	hq

	fq

	nIn

	nOut

	stat

	iTime

	rTime

	fTime

	firstEvTime

	tTime

	proc

	a

	evt

	hvt

	fsr

	inc

	pers

	ts

	TS

	cntr

Detailed Description

Definition at line 647 of file GMPBase.py.

Constructor & Destructor Documentation

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

Definition at line 648 of file GMPBase.py.

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

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

Definition at line 648 of file GMPBase.py.

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

Member Function Documentation

def GaudiMP.GMPBase.Reader.DoFirstEvent ( self )

Definition at line 670 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.DoFirstEvent ( self )

Definition at line 670 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 663 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.DumpEvent ( self )

Definition at line 663 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 714 of file GMPBase.py.

     def Engine( self ) :
         # rename process
         import os
         import ctypes
         libc = ctypes.CDLL('libc.so.6')
         name = str(self.nodeType) + str(self.nodeID) + '\0'
         libc.prctl(15,name,0,0,0)
 
 
         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.Engine ( self )

Definition at line 714 of file GMPBase.py.

     def Engine( self ) :
         # rename process
         import os
         import ctypes
         libc = ctypes.CDLL('libc.so.6')
         name = str(self.nodeType) + str(self.nodeID) + '\0'
         libc.prctl(15,name,0,0,0)
 
 
         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 651 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
 

def GaudiMP.GMPBase.Reader.processConfiguration ( self )

Definition at line 651 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
 

Member Data Documentation

GaudiMP.GMPBase.Reader.app

Definition at line 688 of file GMPBase.py.

GaudiMP.GMPBase.Reader.currentEvent

Definition at line 704 of file GMPBase.py.

GaudiMP.GMPBase.Reader.evtMax

Definition at line 661 of file GMPBase.py.

GaudiMP.GMPBase.Reader.firstEvTime

Definition at line 711 of file GMPBase.py.

GaudiMP.GMPBase.Reader.nOut

Definition at line 675 of file GMPBase.py.

GaudiMP.GMPBase.Reader.stat

Definition at line 738 of file GMPBase.py.

GaudiMP.GMPBase.Reader.tTime

Definition at line 771 of file GMPBase.py.

The documentation for this class was generated from the following file:

InstallArea/x86_64-slc6-gcc48-opt/python/GaudiMP/GMPBase.py

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation