GaudiMP.GMPBase.Reader Class Reference

Inheritance diagram for GaudiMP.GMPBase.Reader:

Collaboration diagram for GaudiMP.GMPBase.Reader:

Public Member Functions
	__init__ (self, queues, events, params, subworkers)
	processConfiguration (self)
	DumpEvent (self)
	DoFirstEvent (self)
	Engine (self)
Public Member Functions inherited from GaudiMP.GMPBase.GMPComponent
	__init__ (self, nodeType, nodeID, queues, events, params, subworkers)
	Start (self)
	SetupGaudiPython (self)
	StartGaudiPython (self)
	LoadTES (self, tbufferfile)
	getEventNumber (self)
	IdentifyWriters (self)
	dumpHistograms (self)
	Initialize (self)
	Finalize (self)
	Report (self)

Public Attributes
	evtMax = self.config["ApplicationMgr"].EvtMax
Public Attributes inherited from GaudiMP.GMPBase.GMPComponent
str	nodeType = nodeType
	initEvent
	finalEvent = events
	eventLoopSyncer
	lastEvent = eventLoopSyncer
	nWorkers
	sEvent
	config
	log = params
	subworkers = subworkers
int	nodeID = nodeID
	msgFormat = self.config["MessageSvc"].Format
	currentEvent = None
	queues = queues
int	num = 0
str	app = None
	evcom = EventCommunicator(self, qin, qout)
list	evcoms = []
	hq = histq
	fq = fq
int	nIn = 0
int	nOut = 0
	stat = SUCCESS
float	iTime = 0.0
float	rTime = 0.0
float	fTime = 0.0
float	firstEvTime = 0.0
float	tTime = 0.0
	proc = Process(target=self.Engine)
	a = AppMgr()
	evt = self.a.evtsvc()
	hvt = self.a.histsvc()
	fsr = self.a.filerecordsvc()
	inc = self.a.service("IncidentSvc", "IIncidentSvc")
	pers = self.a.service("EventPersistencySvc", "IAddressCreator")
	ts = gbl.GaudiMP.TESSerializer(self.evt._idp, self.pers)
	TS = TESSerializer(self.ts, self.evt, self.nodeType, self.nodeID, self.log)
	cntr = InterfaceCast(gbl.IEventCounter)(tool.getInterface())

Detailed Description

Definition at line 695 of file GMPBase.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 696 of file GMPBase.py.

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

Member Function Documentation

DoFirstEvent()

GaudiMP.GMPBase.Reader.DoFirstEvent

(

self

)

Definition at line 718 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(f"evtMax( {self.evtMax} ) reached")
            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(f"No More Events! (So Far : {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 Exception:
                        self.log.critical("Reader could not acquire TES List!")
                        self.lastEvent.set()
                        return FAILURE
                self.log.info(f"Reader : TES List : {len(lst)} items")
                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()

GaudiMP.GMPBase.Reader.DumpEvent

(

self

)

Definition at line 711 of file GMPBase.py.

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

Engine()

GaudiMP.GMPBase.Reader.Engine

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 762 of file GMPBase.py.

    def Engine(self):
        # rename process
        import ctypes
 
        libc = ctypes.CDLL("libc.so.6")
        name = str(self.nodeType) + str(self.nodeID) + "\0"
        libc.prctl(15, ctypes.create_unicode_buffer(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(f"evtMax( {self.evtMax} ) reached")
                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(f"No More Events! (So Far : {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()

GaudiMP.GMPBase.Reader.processConfiguration

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 699 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 = "[Reader]      " + self.msgFormat
        self.evtMax = self.config["ApplicationMgr"].EvtMax
 

Member Data Documentation

evtMax

GaudiMP.GMPBase.Reader.evtMax = self.config["ApplicationMgr"].EvtMax

Definition at line 709 of file GMPBase.py.

---

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

• GaudiMP/python/GaudiMP/GMPBase.py