Inheritance diagram for GaudiMP.GMPBase.Subworker:

Collaboration diagram for GaudiMP.GMPBase.Subworker:

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

def	Engine (self)

def	SetServices (self, a, evt, hvt, fsr, inc, pers, ts, cntr)

def	getCheckAlgs (self)

def	checkExecutedPassed (self, algName)

def	isEventPassed (self)

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

def	Engine (self)

def	SetServices (self, a, evt, hvt, fsr, inc, pers, ts, cntr)

def	getCheckAlgs (self)

def	checkExecutedPassed (self, algName)

def	isEventPassed (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
	writerDict

	vetoAlgs

	eventOutput

	filerecordsAgent

	nIn

	firstEvTime

	currentEvent

	tTime

	a

	evt

	hvt

	fsr

	inc

	pers

	ts

	cntr

	TS

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

Constructor & Destructor Documentation

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

Definition at line 776 of file GMPBase.py.

     def __init__( self, workerID, queues, events, params, subworkers  ) :
         GMPComponent.__init__(self,'Worker', workerID, queues, events, params, subworkers )
         # Identify the writer streams
         self.writerDict = self.IdentifyWriters( )
         # Identify the accept/veto checks for each event
         self.acceptAlgs, self.requireAlgs, self.vetoAlgs = self.getCheckAlgs()
         self.log.info("Subworker-%i Created OK"%(self.nodeID))
         self.eventOutput = True
 

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

Definition at line 776 of file GMPBase.py.

     def __init__( self, workerID, queues, events, params, subworkers  ) :
         GMPComponent.__init__(self,'Worker', workerID, queues, events, params, subworkers )
         # Identify the writer streams
         self.writerDict = self.IdentifyWriters( )
         # Identify the accept/veto checks for each event
         self.acceptAlgs, self.requireAlgs, self.vetoAlgs = self.getCheckAlgs()
         self.log.info("Subworker-%i Created OK"%(self.nodeID))
         self.eventOutput = True
 

Member Function Documentation

def GaudiMP.GMPBase.Subworker.checkExecutedPassed	(	self,
		algName
	)

Definition at line 896 of file GMPBase.py.

     def checkExecutedPassed( self, algName ) :
         if  self.a.algorithm( algName )._ialg.isExecuted()\
         and self.a.algorithm( algName )._ialg.filterPassed() :
             return True
         else :
             return False
 

def GaudiMP.GMPBase.Subworker.checkExecutedPassed	(	self,
		algName
	)

Definition at line 896 of file GMPBase.py.

     def checkExecutedPassed( self, algName ) :
         if  self.a.algorithm( algName )._ialg.isExecuted()\
         and self.a.algorithm( algName )._ialg.filterPassed() :
             return True
         else :
             return False
 

def GaudiMP.GMPBase.Subworker.Engine ( self )

Definition at line 785 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)
 
         self.initEvent.set()
         startEngine = time.time()
         msg = self.a.service('MessageSvc')
         msg.Format = '[' + self.log.name + '] % F%18W%S%7W%R%T %0W%M'
 
         self.log.name = "Worker-%i"%(self.nodeID)
         self.log.info("Subworker %i starting Engine"%(self.nodeID))
         self.filerecordsAgent = FileRecordsAgent(self)
 
         # populate the TESSerializer itemlist
         self.log.info('EVT WRITERS ON WORKER : %i'\
                        %( len(self.writerDict['events'])))
 
         nEventWriters = len( self.writerDict[ "events" ] )
         self.a.addAlgorithm( CollectHistograms(self) )
 
         # Begin processing
         Go = True
         while Go :
             packet = self.evcom.receive( )
             if packet : pass
             else      : continue
             if packet == 'FINISHED' : break
             evtNumber, tbin = packet    # unpack
             if self.cntr != None:
 
                 self.cntr.setEventCounter( evtNumber )
 
             self.nIn += 1
             self.TS.Load( tbin )
 
             t = time.time()
             sc = self.a.executeEvent()
             if self.nIn == 1 :
                 self.firstEvTime = time.time()-t
             else :
                 self.rTime += (time.time()-t)
             if sc.isSuccess() :
                 pass
             else :
             self.log.name = "Worker-%i"%(self.nodeID)
                 self.log.warning('Did not Execute Event')
                 self.evt.clearStore()
                 continue
             if self.isEventPassed() :
                 pass
             else :
                 self.log.name = "Worker-%i"%(self.nodeID)
                 self.log.warning( 'Event did not pass : %i'%(evtNumber) )
                 self.evt.clearStore()
                 continue
             if self.eventOutput :
                 # It may be the case of generating Event Tags; hence
                 #   no event output
                 self.currentEvent = self.getEventNumber( )
                 tb = self.TS.Dump( )
                 self.evcom.send( (self.currentEvent, tb) )
                 self.nOut += 1
             self.inc.fireIncident(gbl.Incident('Subworker','EndEvent'))
             self.eventLoopSyncer.set()
             self.evt.clearStore( )
         self.log.name = "Worker-%i"%(self.nodeID)
         self.log.info('Setting <Last> Event %s' %(self.nodeID))
         self.lastEvent.set()
 
         self.evcom.finalize()
         # Now send the FileRecords and stop/finalize the appMgr
         self.filerecordsAgent.SendFileRecords()
         self.tTime = time.time()-startEngine
         self.Finalize()
         self.Report()
         #self.finalEvent.set()
 

def GaudiMP.GMPBase.Subworker.Engine ( self )

Definition at line 785 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)
 
         self.initEvent.set()
         startEngine = time.time()
         msg = self.a.service('MessageSvc')
         msg.Format = '[' + self.log.name + '] % F%18W%S%7W%R%T %0W%M'
 
         self.log.name = "Worker-%i"%(self.nodeID)
         self.log.info("Subworker %i starting Engine"%(self.nodeID))
         self.filerecordsAgent = FileRecordsAgent(self)
 
         # populate the TESSerializer itemlist
         self.log.info('EVT WRITERS ON WORKER : %i'\
                        %( len(self.writerDict['events'])))
 
         nEventWriters = len( self.writerDict[ "events" ] )
         self.a.addAlgorithm( CollectHistograms(self) )
 
         # Begin processing
         Go = True
         while Go :
             packet = self.evcom.receive( )
             if packet : pass
             else      : continue
             if packet == 'FINISHED' : break
             evtNumber, tbin = packet    # unpack
             if self.cntr != None:
 
                 self.cntr.setEventCounter( evtNumber )
 
             self.nIn += 1
             self.TS.Load( tbin )
 
             t = time.time()
             sc = self.a.executeEvent()
             if self.nIn == 1 :
                 self.firstEvTime = time.time()-t
             else :
                 self.rTime += (time.time()-t)
             if sc.isSuccess() :
                 pass
             else :
             self.log.name = "Worker-%i"%(self.nodeID)
                 self.log.warning('Did not Execute Event')
                 self.evt.clearStore()
                 continue
             if self.isEventPassed() :
                 pass
             else :
                 self.log.name = "Worker-%i"%(self.nodeID)
                 self.log.warning( 'Event did not pass : %i'%(evtNumber) )
                 self.evt.clearStore()
                 continue
             if self.eventOutput :
                 # It may be the case of generating Event Tags; hence
                 #   no event output
                 self.currentEvent = self.getEventNumber( )
                 tb = self.TS.Dump( )
                 self.evcom.send( (self.currentEvent, tb) )
                 self.nOut += 1
             self.inc.fireIncident(gbl.Incident('Subworker','EndEvent'))
             self.eventLoopSyncer.set()
             self.evt.clearStore( )
         self.log.name = "Worker-%i"%(self.nodeID)
         self.log.info('Setting <Last> Event %s' %(self.nodeID))
         self.lastEvent.set()
 
         self.evcom.finalize()
         # Now send the FileRecords and stop/finalize the appMgr
         self.filerecordsAgent.SendFileRecords()
         self.tTime = time.time()-startEngine
         self.Finalize()
         self.Report()
         #self.finalEvent.set()
 

def GaudiMP.GMPBase.Subworker.getCheckAlgs ( self )

For some output writers, a check is performed to see if the event has
executed certain algorithms.
These reside in the AcceptAlgs property for those writers

Definition at line 880 of file GMPBase.py.

     def getCheckAlgs( self ) :
         '''
         For some output writers, a check is performed to see if the event has
         executed certain algorithms.
         These reside in the AcceptAlgs property for those writers
         '''
         acc = []
         req = []
         vet = []
         for m in self.writerDict[ "events" ] :
             if hasattr(m.w, 'AcceptAlgs')  : acc += m.w.AcceptAlgs
             if hasattr(m.w, 'RequireAlgs') : req += m.w.RequireAlgs
             if hasattr(m.w, 'VetoAlgs')    : vet += m.w.VetoAlgs
         return (acc, req, vet)
 
 

def GaudiMP.GMPBase.Subworker.getCheckAlgs ( self )

For some output writers, a check is performed to see if the event has
executed certain algorithms.
These reside in the AcceptAlgs property for those writers

Definition at line 880 of file GMPBase.py.

     def getCheckAlgs( self ) :
         '''
         For some output writers, a check is performed to see if the event has
         executed certain algorithms.
         These reside in the AcceptAlgs property for those writers
         '''
         acc = []
         req = []
         vet = []
         for m in self.writerDict[ "events" ] :
             if hasattr(m.w, 'AcceptAlgs')  : acc += m.w.AcceptAlgs
             if hasattr(m.w, 'RequireAlgs') : req += m.w.RequireAlgs
             if hasattr(m.w, 'VetoAlgs')    : vet += m.w.VetoAlgs
         return (acc, req, vet)
 
 

def GaudiMP.GMPBase.Subworker.isEventPassed ( self )

Check the algorithm status for an event.
Depending on output writer settings, the event
  may be declined based on various criteria.
This is a transcript of the check that occurs in GaudiSvc::OutputStream

Definition at line 903 of file GMPBase.py.

     def isEventPassed( self ) :
         '''
         Check the algorithm status for an event.
         Depending on output writer settings, the event
           may be declined based on various criteria.
         This is a transcript of the check that occurs in GaudiSvc::OutputStream
         '''
         passed = False
 
         self.log.debug('self.acceptAlgs is %s'%(str(self.acceptAlgs)))
         if self.acceptAlgs :
             for name in self.acceptAlgs :
                 if self.checkExecutedPassed( name ) :
                     passed = True
                     break
         else :
             passed = True
 
         self.log.debug('self.requireAlgs is %s'%(str(self.requireAlgs)))
         for name in self.requireAlgs :
             if self.checkExecutedPassed( name ) :
                 pass
             else :
                 self.log.info('Evt declined (requireAlgs) : %s'%(name) )
                 passed = False
 
         self.log.debug('self.vetoAlgs is %s'%(str(self.vetoAlgs)))
         for name in self.vetoAlgs :
             if self.checkExecutedPassed( name ) :
                 pass
             else :
                 self.log.info( 'Evt declined : (vetoAlgs) : %s'%(name) )
                 passed = False
         return passed
 
 # =============================================================================

def GaudiMP.GMPBase.Subworker.isEventPassed ( self )

Check the algorithm status for an event.
Depending on output writer settings, the event
  may be declined based on various criteria.
This is a transcript of the check that occurs in GaudiSvc::OutputStream

Definition at line 903 of file GMPBase.py.

     def isEventPassed( self ) :
         '''
         Check the algorithm status for an event.
         Depending on output writer settings, the event
           may be declined based on various criteria.
         This is a transcript of the check that occurs in GaudiSvc::OutputStream
         '''
         passed = False
 
         self.log.debug('self.acceptAlgs is %s'%(str(self.acceptAlgs)))
         if self.acceptAlgs :
             for name in self.acceptAlgs :
                 if self.checkExecutedPassed( name ) :
                     passed = True
                     break
         else :
             passed = True
 
         self.log.debug('self.requireAlgs is %s'%(str(self.requireAlgs)))
         for name in self.requireAlgs :
             if self.checkExecutedPassed( name ) :
                 pass
             else :
                 self.log.info('Evt declined (requireAlgs) : %s'%(name) )
                 passed = False
 
         self.log.debug('self.vetoAlgs is %s'%(str(self.vetoAlgs)))
         for name in self.vetoAlgs :
             if self.checkExecutedPassed( name ) :
                 pass
             else :
                 self.log.info( 'Evt declined : (vetoAlgs) : %s'%(name) )
                 passed = False
         return passed
 
 # =============================================================================

def GaudiMP.GMPBase.Subworker.SetServices	(	self,
		a,
		evt,
		hvt,
		fsr,
		inc,
		pers,
		ts,
		cntr
	)

Definition at line 866 of file GMPBase.py.

     def SetServices(self,a, evt, hvt, fsr, inc, pers, ts , cntr):
         self.a = a
         self.evt = evt
         self.hvt = hvt
         self.fsr = fsr
         #self.inc = inc
         self.inc = self.a.service('IncidentSvc','IIncidentSvc')
         self.pers = pers
         self.ts  = ts
         self.cntr = cntr
         self.TS  = TESSerializer( self.ts, self.evt,
                                   self.nodeType, self.nodeID, self.log )
 
 

def GaudiMP.GMPBase.Subworker.SetServices	(	self,
		a,
		evt,
		hvt,
		fsr,
		inc,
		pers,
		ts,
		cntr
	)

Definition at line 866 of file GMPBase.py.

     def SetServices(self,a, evt, hvt, fsr, inc, pers, ts , cntr):
         self.a = a
         self.evt = evt
         self.hvt = hvt
         self.fsr = fsr
         #self.inc = inc
         self.inc = self.a.service('IncidentSvc','IIncidentSvc')
         self.pers = pers
         self.ts  = ts
         self.cntr = cntr
         self.TS  = TESSerializer( self.ts, self.evt,
                                   self.nodeType, self.nodeID, self.log )
 
 

Member Data Documentation

GaudiMP.GMPBase.Subworker.a

Definition at line 867 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.cntr

Definition at line 875 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.currentEvent

Definition at line 847 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.eventOutput

Definition at line 783 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.evt

Definition at line 868 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.filerecordsAgent

Definition at line 800 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.firstEvTime

Definition at line 827 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.fsr

Definition at line 870 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.hvt

Definition at line 869 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.inc

Definition at line 872 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.nIn

Definition at line 826 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.pers

Definition at line 873 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.ts

Definition at line 874 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.TS

Definition at line 876 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.tTime

Definition at line 861 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.vetoAlgs

Definition at line 781 of file GMPBase.py.

GaudiMP.GMPBase.Subworker.writerDict

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