GaudiMP.GMPBase.Reader Class Reference

Inheritance diagram for GaudiMP.GMPBase.Reader:

Collaboration diagram for GaudiMP.GMPBase.Reader:

Public Member Functions
def	__init__ (self, queues, events, params, subworkers)
def	processConfiguration (self)
def	DumpEvent (self)
def	DoFirstEvent (self)
def	Engine (self)
Public Member Functions inherited from GaudiMP.GMPBase.GMPComponent
def	__init__ (self, nodeType, nodeID, queues, events, params, subworkers)
def	Start (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
	evtMax
	nOut
	app
	currentEvent
	firstEvTime
	stat
	tTime
Public Attributes inherited from GaudiMP.GMPBase.GMPComponent
	nodeType
	finalEvent
	lastEvent
	log
	subworkers
	nodeID
	msgFormat
	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 701 of file GMPBase.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 702 of file GMPBase.py.

    def __init__(self, queues, events, params, subworkers):
        GMPComponent.__init__(self, "Reader", -1, queues, events, params, subworkers)
 

Member Function Documentation

DoFirstEvent()

def GaudiMP.GMPBase.Reader.DoFirstEvent

(

self

)

Definition at line 724 of file GMPBase.py.

    def DoFirstEvent(self):
        # Do First Event ------------------------------------------------------
        # Check Termination Criteria
        startFirst = time.time()
        self.log.info("Reader : First Event")
        if self.nOut == self.evtMax:
            self.log.info("evtMax( %i ) reached" % (self.evtMax))
            self.lastEvent.set()
            return SUCCESS
        else:
            # Continue to read, dump and send event
            self.a.run(1)
            if not bool(self.evt["/Event"]):
                self.log.warning("No More Events! (So Far : %i)" % (self.nOut))
                self.lastEvent.set()
                return SUCCESS
            else:
                # Popluate TESSerializer list and send Event
                if self.app == "Gauss":
                    lst = self.evt.getHistoNames()
                else:
                    try:
                        lst = self.evt.getList()
                        if self.app == "DaVinci":
                            daqnode = self.evt.retrieveObject("/Event/DAQ").registry()
                            setOwnership(daqnode, False)
                            self.evt.getList(daqnode, lst, daqnode.address().par())
                    except:
                        self.log.critical("Reader could not acquire TES List!")
                        self.lastEvent.set()
                        return FAILURE
                self.log.info("Reader : TES List : %i items" % (len(lst)))
                for l in lst:
                    self.ts.addItem(l)
                self.currentEvent = self.getEventNumber()
                tb = self.TS.Dump()
                self.log.info("First Event Sent")
                self.evcom.send((self.currentEvent, tb))
                self.nOut += 1
                self.eventLoopSyncer.set()
                self.evt.clearStore()
                self.firstEvTime = time.time() - startFirst
                return SUCCESS
 

DumpEvent()

def GaudiMP.GMPBase.Reader.DumpEvent

(

self

)

Definition at line 717 of file GMPBase.py.

    def DumpEvent(self):
        tb = TBufferFile(TBuffer.kWrite)
        # print '----Reader dumping Buffer!!!'
        self.ts.dumpBuffer(tb)
        # print '\tBuffer Dumped, size : %i'%( tb.Length() )
        return tb
 

Engine()

def GaudiMP.GMPBase.Reader.Engine

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 768 of file GMPBase.py.

    def Engine(self):
        # rename process
        import ctypes
        import os
 
        libc = ctypes.CDLL("libc.so.6")
        name = str(self.nodeType) + str(self.nodeID) + "\0"
        libc.prctl(15, name, 0, 0, 0)
 
        startEngine = time.time()
        self.log.name = "Reader"
        self.log.info("Reader Process starting")
 
        self.Initialize()
 
        # add the Histogram Collection Algorithm
        self.a.addAlgorithm(CollectHistograms(self))
 
        self.log.info("Reader Beginning Distribution")
        sc = self.DoFirstEvent()
        if sc.isSuccess():
            self.log.info("Reader First Event OK")
        else:
            self.log.critical("Reader Failed on First Event")
            self.stat = FAILURE
 
        # Do All Others -------------------------------------------------------
        while True:
            # Check Termination Criteria
            if self.nOut == self.evtMax:
                self.log.info("evtMax( %i ) reached" % (self.evtMax))
                break
            # Check Health
            if not self.stat.isSuccess():
                self.log.critical("Reader is Damaged!")
                break
            # Continue to read, dump and send event
            t = time.time()
            self.a.run(1)
            self.rTime += time.time() - t
            if not bool(self.evt["/Event"]):
                self.log.warning("No More Events! (So Far : %i)" % (self.nOut))
                break
            self.currentEvent = self.getEventNumber()
            tb = self.TS.Dump()
            self.evcom.send((self.currentEvent, tb))
            # clean up
            self.nOut += 1
            self.eventLoopSyncer.set()
            self.evt.clearStore()
        self.log.info("Setting <Last> Event")
        self.lastEvent.set()
 
        # Finalize
        self.log.info("Reader : Event Distribution complete.")
        self.evcom.finalize()
        self.Finalize()
        self.tTime = time.time() - startEngine
        self.Report()
 
 
# =============================================================================
 
 

processConfiguration()

def GaudiMP.GMPBase.Reader.processConfiguration

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 705 of file GMPBase.py.

    def processConfiguration(self):
        # Reader :
        #   No algorithms
        #   No output
        #   No histos
        self.config["ApplicationMgr"].TopAlg = []
        self.config["ApplicationMgr"].OutStream = []
        if "HistogramPersistencySvc" in self.config.keys():
            self.config["HistogramPersistencySvc"].OutputFile = ""
        self.config["MessageSvc"].Format = "%-13s " % "[Reader]" + self.msgFormat
        self.evtMax = self.config["ApplicationMgr"].EvtMax
 

Member Data Documentation

app

GaudiMP.GMPBase.Reader.app

Definition at line 742 of file GMPBase.py.

currentEvent

GaudiMP.GMPBase.Reader.currentEvent

Definition at line 758 of file GMPBase.py.

evtMax

GaudiMP.GMPBase.Reader.evtMax

Definition at line 715 of file GMPBase.py.

firstEvTime

GaudiMP.GMPBase.Reader.firstEvTime

Definition at line 765 of file GMPBase.py.

nOut

GaudiMP.GMPBase.Reader.nOut

Definition at line 729 of file GMPBase.py.

stat

GaudiMP.GMPBase.Reader.stat

Definition at line 792 of file GMPBase.py.

tTime

GaudiMP.GMPBase.Reader.tTime

Definition at line 825 of file GMPBase.py.

---

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

• GaudiMP/python/GaudiMP/GMPBase.py