GaudiMP.GMPBase.Subworker Class Reference

Inheritance diagram for GaudiMP.GMPBase.Subworker:

Collaboration diagram for GaudiMP.GMPBase.Subworker:

Public Member Functions
def	__init__ (self, workerID, queues, events, params, subworkers)
def	Engine (self)
def	SetServices (self, a, evt, hvt, fsr, inc, pers, ts, cntr)
def	getCheckAlgs (self)
def	checkExecutedPassed (self, algName)
def	isEventPassed (self)
Public Member Functions inherited from GaudiMP.GMPBase.GMPComponent
def	__init__ (self, nodeType, nodeID, queues, events, params, subworkers)
def	Start (self)
def	processConfiguration (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
	writerDict
	vetoAlgs
	eventOutput
	filerecordsAgent
	nIn
	firstEvTime
	currentEvent
	tTime
	a
	evt
	hvt
	fsr
	inc
	pers
	ts
	cntr
	TS
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 832 of file GMPBase.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 833 of file GMPBase.py.

    def __init__(self, workerID, queues, events, params, subworkers):
        GMPComponent.__init__(
            self, "Worker", workerID, queues, events, params, subworkers
        )
        # Identify the writer streams
        self.writerDict = self.IdentifyWriters()
        # Identify the accept/veto checks for each event
        self.acceptAlgs, self.requireAlgs, self.vetoAlgs = self.getCheckAlgs()
        self.log.info("Subworker-%i Created OK" % (self.nodeID))
        self.eventOutput = True
 

Member Function Documentation

checkExecutedPassed()

def GaudiMP.GMPBase.Subworker.checkExecutedPassed	(		self,
			algName
	)

Definition at line 958 of file GMPBase.py.

    def checkExecutedPassed(self, algName):
        if (
            self.a.algorithm(algName)._ialg.isExecuted()
            and self.a.algorithm(algName)._ialg.filterPassed()
        ):
            return True
        else:
            return False
 

Engine()

def GaudiMP.GMPBase.Subworker.Engine

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 844 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)
 
        self.initEvent.set()
        startEngine = time.time()
        msg = self.a.service("MessageSvc")
        msg.Format = "%-13s " % ("[" + self.log.name + "]") + self.msgFormat
 
        self.log.name = "Worker-%i" % (self.nodeID)
        self.log.info("Subworker %i starting Engine" % (self.nodeID))
        self.filerecordsAgent = FileRecordsAgent(self)
 
        # populate the TESSerializer itemlist
        self.log.info("EVT WRITERS ON WORKER : %i" % (len(self.writerDict["events"])))
 
        nEventWriters = len(self.writerDict["events"])
        self.a.addAlgorithm(CollectHistograms(self))
 
        # Begin processing
        Go = True
        while Go:
            packet = self.evcom.receive()
            if packet:
                pass
            else:
                continue
            if packet == "FINISHED":
                break
            evtNumber, tbin = packet  # unpack
            if self.cntr != None:
 
                self.cntr.setEventCounter(evtNumber)
 
            self.nIn += 1
            self.TS.Load(tbin)
 
            t = time.time()
            sc = self.a.executeEvent()
            if self.nIn == 1:
                self.firstEvTime = time.time() - t
            else:
                self.rTime += time.time() - t
            if sc.isSuccess():
                pass
            else:
                self.log.name = "Worker-%i" % (self.nodeID)
                self.log.warning("Did not Execute Event")
                self.evt.clearStore()
                continue
            if self.isEventPassed():
                pass
            else:
                self.log.name = "Worker-%i" % (self.nodeID)
                self.log.warning("Event did not pass : %i" % (evtNumber))
                self.evt.clearStore()
                continue
            if self.eventOutput:
                # It may be the case of generating Event Tags; hence
                #   no event output
                self.currentEvent = self.getEventNumber()
                tb = self.TS.Dump()
                self.evcom.send((self.currentEvent, tb))
                self.nOut += 1
            self.inc.fireIncident(gbl.Incident("Subworker", "EndEvent"))
            self.eventLoopSyncer.set()
            self.evt.clearStore()
        self.log.name = "Worker-%i" % (self.nodeID)
        self.log.info("Setting <Last> Event %s" % (self.nodeID))
        self.lastEvent.set()
 
        self.evcom.finalize()
        # Now send the FileRecords and stop/finalize the appMgr
        self.filerecordsAgent.SendFileRecords()
        self.tTime = time.time() - startEngine
        self.Finalize()
        self.Report()
        # self.finalEvent.set()
 

getCheckAlgs()

def GaudiMP.GMPBase.Subworker.getCheckAlgs

(

self

)

For some output writers, a check is performed to see if the event has
executed certain algorithms.
These reside in the AcceptAlgs property for those writers

Definition at line 940 of file GMPBase.py.

    def getCheckAlgs(self):
        """
        For some output writers, a check is performed to see if the event has
        executed certain algorithms.
        These reside in the AcceptAlgs property for those writers
        """
        acc = []
        req = []
        vet = []
        for m in self.writerDict["events"]:
            if hasattr(m.w, "AcceptAlgs"):
                acc += m.w.AcceptAlgs
            if hasattr(m.w, "RequireAlgs"):
                req += m.w.RequireAlgs
            if hasattr(m.w, "VetoAlgs"):
                vet += m.w.VetoAlgs
        return (acc, req, vet)
 

isEventPassed()

def GaudiMP.GMPBase.Subworker.isEventPassed

(

self

)

Check the algorithm status for an event.
Depending on output writer settings, the event
  may be declined based on various criteria.
This is a transcript of the check that occurs in GaudiSvc::OutputStream

Definition at line 967 of file GMPBase.py.

    def isEventPassed(self):
        """
        Check the algorithm status for an event.
        Depending on output writer settings, the event
          may be declined based on various criteria.
        This is a transcript of the check that occurs in GaudiSvc::OutputStream
        """
        passed = False
 
        self.log.debug("self.acceptAlgs is %s" % (str(self.acceptAlgs)))
        if self.acceptAlgs:
            for name in self.acceptAlgs:
                if self.checkExecutedPassed(name):
                    passed = True
                    break
        else:
            passed = True
 
        self.log.debug("self.requireAlgs is %s" % (str(self.requireAlgs)))
        for name in self.requireAlgs:
            if self.checkExecutedPassed(name):
                pass
            else:
                self.log.info("Evt declined (requireAlgs) : %s" % (name))
                passed = False
 
        self.log.debug("self.vetoAlgs is %s" % (str(self.vetoAlgs)))
        for name in self.vetoAlgs:
            if self.checkExecutedPassed(name):
                pass
            else:
                self.log.info("Evt declined : (vetoAlgs) : %s" % (name))
                passed = False
        return passed
 
 
# =============================================================================
 
 

SetServices()

def GaudiMP.GMPBase.Subworker.SetServices	(		self,
			a,
			evt,
			hvt,
			fsr,
			inc,
			pers,
			ts,
			cntr
	)

Definition at line 928 of file GMPBase.py.

    def SetServices(self, a, evt, hvt, fsr, inc, pers, ts, cntr):
        self.a = a
        self.evt = evt
        self.hvt = hvt
        self.fsr = fsr
        # self.inc = inc
        self.inc = self.a.service("IncidentSvc", "IIncidentSvc")
        self.pers = pers
        self.ts = ts
        self.cntr = cntr
        self.TS = TESSerializer(self.ts, self.evt, self.nodeType, self.nodeID, self.log)
 

Member Data Documentation

a

GaudiMP.GMPBase.Subworker.a

Definition at line 929 of file GMPBase.py.

cntr

GaudiMP.GMPBase.Subworker.cntr

Definition at line 937 of file GMPBase.py.

currentEvent

GaudiMP.GMPBase.Subworker.currentEvent

Definition at line 909 of file GMPBase.py.

eventOutput

GaudiMP.GMPBase.Subworker.eventOutput

Definition at line 842 of file GMPBase.py.

evt

GaudiMP.GMPBase.Subworker.evt

Definition at line 930 of file GMPBase.py.

filerecordsAgent

GaudiMP.GMPBase.Subworker.filerecordsAgent

Definition at line 860 of file GMPBase.py.

firstEvTime

GaudiMP.GMPBase.Subworker.firstEvTime

Definition at line 889 of file GMPBase.py.

fsr

GaudiMP.GMPBase.Subworker.fsr

Definition at line 932 of file GMPBase.py.

hvt

GaudiMP.GMPBase.Subworker.hvt

Definition at line 931 of file GMPBase.py.

inc

GaudiMP.GMPBase.Subworker.inc

Definition at line 934 of file GMPBase.py.

nIn

GaudiMP.GMPBase.Subworker.nIn

Definition at line 888 of file GMPBase.py.

pers

GaudiMP.GMPBase.Subworker.pers

Definition at line 935 of file GMPBase.py.

ts

GaudiMP.GMPBase.Subworker.ts

Definition at line 936 of file GMPBase.py.

TS

GaudiMP.GMPBase.Subworker.TS

Definition at line 938 of file GMPBase.py.

tTime

GaudiMP.GMPBase.Subworker.tTime

Definition at line 923 of file GMPBase.py.

vetoAlgs

GaudiMP.GMPBase.Subworker.vetoAlgs

Definition at line 840 of file GMPBase.py.

writerDict

GaudiMP.GMPBase.Subworker.writerDict

Definition at line 838 of file GMPBase.py.

---

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

• GaudiMP/python/GaudiMP/GMPBase.py