| # Gaudi Framework, version v21r6 |

Home |  | Generated: 11 Nov 2009

# GaudiPython::Parallel::CollectHistograms Class Reference

Inheritance diagram for GaudiPython::Parallel::CollectHistograms:

[legend]
Collaboration diagram for GaudiPython::Parallel::CollectHistograms:

[legend]

List of all members.

## Detailed Description

Definition at line 356 of file Parallel.py.

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

## 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_v21r6/GaudiPython/python/GaudiPython/Parallel.py