GaudiMP::GMPBase::CollectHistograms Class Reference

List of all members.

Public Member Functions
def	__init__
def	execute
def	finalize
Public Attributes
	log
Private Attributes
	_gmpc

---

Detailed Description

GaudiPython algorithm used to clean up histos on the Reader and Workers
Only has a finalize method()
This retrieves a dictionary of path:histo objects and sends it to the
writer.  It then waits for a None flag : THIS IS IMPORTANT, as if
the algorithm returns before ALL histos have been COMPLETELY RECEIVED
at the writer end, there will be an error.

Definition at line 181 of file GMPBase.py.

---

Constructor & Destructor Documentation

def GaudiMP::GMPBase::CollectHistograms::__init__	(		self,
			gmpcomponent
	)

Definition at line 190 of file GMPBase.py.

00191                                        :
00192         PyAlgorithm.__init__( self )
00193         self._gmpc = gmpcomponent
00194         self.log = self._gmpc.log
        return None

---

Member Function Documentation

def GaudiMP::GMPBase::CollectHistograms::execute

(

self )

Definition at line 195 of file GMPBase.py.

00196                         :
        return SUCCESS

def GaudiMP::GMPBase::CollectHistograms::finalize

(

self )

Definition at line 197 of file GMPBase.py.

                         :
        self.log.info('CollectHistograms Finalise (%s)'%(self._gmpc.nodeType))
        self._gmpc.hDict = self._gmpc.dumpHistograms( )
        ks = self._gmpc.hDict.keys()
        self.log.info('%i Objects in Histogram Store'%(len(ks)))
        # crashes occurred due to Memory Error during the sending of hundreds
        # histos on slc5 machines, so instead, break into chunks
        # send 100 at a time
        chunk = 100
        reps = len(ks)/chunk + 1
        for i in xrange(reps) :
            someKeys = ks[i*chunk : (i+1)*chunk]
            smalld = dict( [(key, self._gmpc.hDict[key]) for key in someKeys] )
            self._gmpc.hq.put( (self._gmpc.nodeID, smalld) )
        # "finished" Notification
        self.log.debug('Signalling end of histos to Writer')
        self._gmpc.hq.put( 'HISTOS_SENT' )
        self.log.debug( 'Waiting on Sync Event' )
        self._gmpc.sEvent.wait()
        self.log.debug( 'Histo Sync Event set, clearing and returning' )
        self._gmpc.hvt.clearStore()
        root = gbl.DataObject()
        setOwnership(root, False)
        self._gmpc.hvt.setRoot( '/stat', root )
        return SUCCESS

# =============================================================================

---

Member Data Documentation

GaudiMP::GMPBase::CollectHistograms::_gmpc [private]

Definition at line 190 of file GMPBase.py.

GaudiMP::GMPBase::CollectHistograms::log

Definition at line 190 of file GMPBase.py.

---

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

• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v23r0/GaudiMP/python/GaudiMP/GMPBase.py