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 648 of file GMPBase.py.

Constructor & Destructor Documentation

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

Definition at line 649 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 649 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 671 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 671 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 664 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 664 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 715 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 715 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 652 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 652 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 689 of file GMPBase.py.

GaudiMP.GMPBase.Reader.currentEvent

Definition at line 705 of file GMPBase.py.

GaudiMP.GMPBase.Reader.evtMax

Definition at line 662 of file GMPBase.py.

GaudiMP.GMPBase.Reader.firstEvTime

Definition at line 712 of file GMPBase.py.

GaudiMP.GMPBase.Reader.nOut

Definition at line 676 of file GMPBase.py.

GaudiMP.GMPBase.Reader.stat

Definition at line 739 of file GMPBase.py.

GaudiMP.GMPBase.Reader.tTime

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