Inheritance diagram for GaudiMP.GMPBase.EventCommunicator:

Collaboration diagram for GaudiMP.GMPBase.EventCommunicator:

Public Member Functions
def	__init__ (self, GMPComponent, qin, qout)

def	send (self, item)

def	receive

def	finalize (self)

def	statistics (self)

def	__init__ (self, GMPComponent, qin, qout)

def	send (self, item)

def	receive

def	finalize (self)

def	statistics (self)

Public Attributes
	log

	maxsize

	qin

	qout

	allsent

	allrecv

	nSent

	nRecv

	sizeSent

	sizeRecv

	qinTime

	qoutTime

Private Attributes
	_gmpc

Detailed Description

Definition at line 228 of file GMPBase.py.

Constructor & Destructor Documentation

def GaudiMP.GMPBase.EventCommunicator.__init__	(	self,
		GMPComponent,
		qin,
		qout
	)

Definition at line 232 of file GMPBase.py.

     def __init__( self, GMPComponent, qin, qout ) :
         self._gmpc = GMPComponent
         self.log   = self._gmpc.log
         # maximum capacity of Queues
         self.maxsize = 50
         # central variables : Queues
         self.qin  = qin
         self.qout = qout
 
         # flags
         self.allsent = False
         self.allrecv = False
 
         # statistics storage
         self.nSent    = 0    # counter : items sent
         self.nRecv    = 0    # counter : items received
         self.sizeSent = 0    # measure : size of events sent ( tbuf.Length() )
         self.sizeRecv = 0    # measure : size of events in   ( tbuf.Length() )
         self.qinTime  = 0    # time    : receiving from self.qin
         self.qoutTime = 0    # time    : sending on qout
 

def GaudiMP.GMPBase.EventCommunicator.__init__	(	self,
		GMPComponent,
		qin,
		qout
	)

Definition at line 232 of file GMPBase.py.

     def __init__( self, GMPComponent, qin, qout ) :
         self._gmpc = GMPComponent
         self.log   = self._gmpc.log
         # maximum capacity of Queues
         self.maxsize = 50
         # central variables : Queues
         self.qin  = qin
         self.qout = qout
 
         # flags
         self.allsent = False
         self.allrecv = False
 
         # statistics storage
         self.nSent    = 0    # counter : items sent
         self.nRecv    = 0    # counter : items received
         self.sizeSent = 0    # measure : size of events sent ( tbuf.Length() )
         self.sizeRecv = 0    # measure : size of events in   ( tbuf.Length() )
         self.qinTime  = 0    # time    : receiving from self.qin
         self.qoutTime = 0    # time    : sending on qout
 

Member Function Documentation

def GaudiMP.GMPBase.EventCommunicator.finalize ( self )

Definition at line 287 of file GMPBase.py.

     def finalize( self ) :
         self.log.info('Finalize Event Communicator : %s %s'%(self._gmpc, self._gmpc.nodeType))
         # Reader sends one flag for each worker
         # Workers send one flag each
         # Writer sends nothing (it's at the end of the chain)
         if   self._gmpc.nodeType == 'Reader' : downstream = self._gmpc.nWorkers
         elif self._gmpc.nodeType == 'Writer' : downstream = 0
         elif self._gmpc.nodeType == 'Worker' : downstream = 1
 
         for i in xrange(downstream) :
             self.qout.put( 'FINISHED' )
         if self._gmpc.nodeType != 'Writer' :
             self.qout.join()
         # Now some reporting...
         self.statistics( )
 

def GaudiMP.GMPBase.EventCommunicator.finalize ( self )

Definition at line 287 of file GMPBase.py.

     def finalize( self ) :
         self.log.info('Finalize Event Communicator : %s %s'%(self._gmpc, self._gmpc.nodeType))
         # Reader sends one flag for each worker
         # Workers send one flag each
         # Writer sends nothing (it's at the end of the chain)
         if   self._gmpc.nodeType == 'Reader' : downstream = self._gmpc.nWorkers
         elif self._gmpc.nodeType == 'Writer' : downstream = 0
         elif self._gmpc.nodeType == 'Worker' : downstream = 1
 
         for i in xrange(downstream) :
             self.qout.put( 'FINISHED' )
         if self._gmpc.nodeType != 'Writer' :
             self.qout.join()
         # Now some reporting...
         self.statistics( )
 

def GaudiMP.GMPBase.EventCommunicator.receive	(	self,
		timeout = `None`
	)

Definition at line 267 of file GMPBase.py.

     def receive( self, timeout=None ) :
         # Receive items from self.qin
         startWait = time.time()
         try :
             itemIn = self.qin.get( timeout=timeout )
         except Empty :
             return None
         self.qinTime += time.time()-startWait
         self.nRecv += 1
         if itemIn.__class__.__name__ == 'tuple' :
             self.sizeRecv += itemIn[1].Length()
         else :
             self.nRecv -= 1
         try :
             self.qin.task_done()
         except :
             self._gmpc.log.warning('TASK_DONE called too often by : %s'\
                                     %(self._gmpc.nodeType))
         return itemIn
 

def GaudiMP.GMPBase.EventCommunicator.receive	(	self,
		timeout = `None`
	)

Definition at line 267 of file GMPBase.py.

     def receive( self, timeout=None ) :
         # Receive items from self.qin
         startWait = time.time()
         try :
             itemIn = self.qin.get( timeout=timeout )
         except Empty :
             return None
         self.qinTime += time.time()-startWait
         self.nRecv += 1
         if itemIn.__class__.__name__ == 'tuple' :
             self.sizeRecv += itemIn[1].Length()
         else :
             self.nRecv -= 1
         try :
             self.qin.task_done()
         except :
             self._gmpc.log.warning('TASK_DONE called too often by : %s'\
                                     %(self._gmpc.nodeType))
         return itemIn
 

def GaudiMP.GMPBase.EventCommunicator.send	(	self,
		item
	)

Definition at line 253 of file GMPBase.py.

     def send( self, item ) :
         # This class manages the sending of a TBufferFile Event to a Queue
         # The actual item to be sent is a tuple : ( evtNumber, TBufferFile )
         assert item.__class__.__name__ == 'tuple'
         startTransmission = time.time()
         self.qout.put( item )
         # allow the background thread to feed the Queue; not 100% guaranteed to
         # finish before next line
         while self.qout._buffer : time.sleep( NAP )
         self.qoutTime += time.time()-startTransmission
         self.sizeSent += item[1].Length()
         self.nSent += 1
         return SUCCESS
 

def GaudiMP.GMPBase.EventCommunicator.send	(	self,
		item
	)

Definition at line 253 of file GMPBase.py.

     def send( self, item ) :
         # This class manages the sending of a TBufferFile Event to a Queue
         # The actual item to be sent is a tuple : ( evtNumber, TBufferFile )
         assert item.__class__.__name__ == 'tuple'
         startTransmission = time.time()
         self.qout.put( item )
         # allow the background thread to feed the Queue; not 100% guaranteed to
         # finish before next line
         while self.qout._buffer : time.sleep( NAP )
         self.qoutTime += time.time()-startTransmission
         self.sizeSent += item[1].Length()
         self.nSent += 1
         return SUCCESS
 

def GaudiMP.GMPBase.EventCommunicator.statistics ( self )

Definition at line 303 of file GMPBase.py.

     def statistics( self ) :
         self.log.name = '%s-%i Audit '%(self._gmpc.nodeType,self._gmpc.nodeID)
         self.log.info ( 'Items Sent     : %i'%(self.nSent) )
         self.log.info ( 'Items Received : %i'%(self.nRecv) )
         self.log.info ( 'Data  Sent     : %i'%(self.sizeSent) )
         self.log.info ( 'Data  Received : %i'%(self.sizeRecv) )
         self.log.info ( 'Q-out Time     : %5.2f'%(self.qoutTime) )
         self.log.info ( 'Q-in  Time     : %5.2f'%(self.qinTime ) )
 
 # =============================================================================
 

def GaudiMP.GMPBase.EventCommunicator.statistics ( self )

Definition at line 303 of file GMPBase.py.

     def statistics( self ) :
         self.log.name = '%s-%i Audit '%(self._gmpc.nodeType,self._gmpc.nodeID)
         self.log.info ( 'Items Sent     : %i'%(self.nSent) )
         self.log.info ( 'Items Received : %i'%(self.nRecv) )
         self.log.info ( 'Data  Sent     : %i'%(self.sizeSent) )
         self.log.info ( 'Data  Received : %i'%(self.sizeRecv) )
         self.log.info ( 'Q-out Time     : %5.2f'%(self.qoutTime) )
         self.log.info ( 'Q-in  Time     : %5.2f'%(self.qinTime ) )
 
 # =============================================================================
 

Member Data Documentation

GaudiMP.GMPBase.EventCommunicator._gmpc

private

Definition at line 233 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.allrecv

Definition at line 243 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.allsent

Definition at line 242 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.log

Definition at line 234 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.maxsize

Definition at line 236 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.nRecv

Definition at line 247 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.nSent

Definition at line 246 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.qin

Definition at line 238 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.qinTime

Definition at line 250 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.qout

Definition at line 239 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.qoutTime

Definition at line 251 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.sizeRecv

Definition at line 249 of file GMPBase.py.

GaudiMP.GMPBase.EventCommunicator.sizeSent

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

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation