GaudiPython::Parallel::CollectHistograms Class Reference

Inheritance diagram for GaudiPython::Parallel::CollectHistograms:

[legend]

Collaboration diagram for GaudiPython::Parallel::CollectHistograms:

[legend]

List of all members.

Public Member Functions
def	__init__
def	execute
def	finalize
Public Attributes
	node
	omit

---

Detailed Description

Definition at line 356 of file Parallel.py.

---

Member Function Documentation

def GaudiPython::Parallel::CollectHistograms::__init__	(		self,
			node
	)

Definition at line 357 of file Parallel.py.

00357                                :
00358         self.node = node
00359         self.omit = node.omitHistos
00360         PyAlgorithm.__init__( self )
00361         return None
    def execute( self ) :

def GaudiPython::Parallel::CollectHistograms::execute

(

self

)

Definition at line 362 of file Parallel.py.

00362                         :
00363         return SUCCESS
    def finalize( self ) :

def GaudiPython::Parallel::CollectHistograms::finalize

(

self

)

Definition at line 364 of file Parallel.py.

00364                          :
00365         header = 'CollectHistograms : '
00366         w = self.node
00367         nodeName = w.__class__.__name__
00368         # print '*'*80
00369         w.histDict = dumpHistograms( w.hvt, node=nodeName, omitList= self.omit )
00370         # print header+'%s %i : about to send %i histos on output queue'%( nodeName, w.id, len(w.histDict.keys()) )
00371         # w.cstatq.put( (w.id, w.histDict) )
00372         ks = w.histDict.keys()
00373         # send 100 at a time
00374         chunk = 100
00375         reps = len(ks)/chunk + 1
00376         for i in xrange(reps) :
00377             someKeys = ks[i*chunk : (i+1)*chunk]
00378             smalld = dict( [(key, w.histDict[key]) for key in someKeys] )
00379             w.cstatq.put( (w.id, smalld) )
00380         w.cstatq.put( None )
00381         # print header+'%s %i: Histos queued to writer'%( nodeName, w.id )
00382         for item in iter(w.commonQ.get, None) : print 'Worker %i : Got an item on the Common Queue?'%(w.id)
00383         # now clear the histogram store
00384         # print 'Clearing Histo store'
00385         w.hvt.clearStore()
00386         root = gbl.DataObject()
00387         w.hvt.setRoot('/stat', root)
00388         w.hvt.dump()
00389         # print '*'*80
00390         return SUCCESS
00391 
00392 # ===========================================================================================
00393 # The Reader
00394 # ===========================================================================================
00395 
class Reader( ) :

---

Member Data Documentation

GaudiPython::Parallel::CollectHistograms::node

Definition at line 358 of file Parallel.py.

GaudiPython::Parallel::CollectHistograms::omit

Definition at line 359 of file Parallel.py.

---

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

• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v21r9/GaudiPython/python/GaudiPython/Parallel.py