GaudiMP.GMPBase.Writer Class Reference

Inheritance diagram for GaudiMP.GMPBase.Writer:

Collaboration diagram for GaudiMP.GMPBase.Writer:

Public Member Functions
	__init__ (self, queues, events, params, subworkers)
	processConfiguration (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
	writerDict = self.IdentifyWriters()
list	status = [False] * self.nWorkers
	histoAgent = HistoAgent(self)
	filerecordsAgent = FileRecordsAgent(self)
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 1236 of file GMPBase.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 1237 of file GMPBase.py.

    def __init__(self, queues, events, params, subworkers):
        GMPComponent.__init__(self, "Writer", -2, queues, events, params, subworkers)
        # Identify the writer streams
        self.writerDict = self.IdentifyWriters()
        # This keeps track of workers as they finish
        self.status = [False] * self.nWorkers
        self.log.name = "Writer--2"
 

Member Function Documentation

Engine()

GaudiMP.GMPBase.Writer.Engine

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 1254 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)
 
        self.Initialize()
        self.histoAgent = HistoAgent(self)
        self.filerecordsAgent = FileRecordsAgent(self)
 
        # Begin processing
        Go = True
        current = -1
        while Go:
            current = (current + 1) % self.nWorkers
            packet = self.evcoms[current].receive(timeout=0.01)
            if packet is None:
                continue
            if packet == "FINISHED":
                self.log.info(f"Writer got FINISHED flag : Worker {current}")
 
                self.status[current] = True
                if all(self.status):
                    self.log.info("FINISHED recd from all workers, break loop")
                    break
                continue
            # otherwise, continue as normal
            self.nIn += 1  # update central count (maybe needed by FSR store)
            evtNumber, tbin = packet  # unpack
            self.TS.Load(tbin)
            t = time.time()
            self.a.executeEvent()
            self.rTime += time.time() - t
            self.currentEvent = self.getEventNumber()
            self.evt.clearStore()
            self.eventLoopSyncer.set()
        self.log.name = "Writer--2"
        self.log.info("Setting <Last> Event")
        self.lastEvent.set()
 
        # finalisation steps
        [e.finalize() for e in self.evcoms]
        # Now do Histograms
        sc = self.histoAgent.Receive()
        sc = self.histoAgent.RebuildHistoStore()
        if sc.isSuccess():
            self.log.info("Histo Store rebuilt ok")
        else:
            self.log.warning("Histo Store Error in Rebuild")
 
        # Now do FileRecords
        sc = self.filerecordsAgent.Receive()
        self.filerecordsAgent.Rebuild()
        self.Finalize()
        # self.rTime = time.time()-startEngine
        self.Report()
 
 
# =============================================================================
 
# =============================================================================
 
 

processConfiguration()

GaudiMP.GMPBase.Writer.processConfiguration

(

self

)

Reimplemented from GaudiMP.GMPBase.GMPComponent.

Definition at line 1245 of file GMPBase.py.

    def processConfiguration(self):
        # Writer :
        #   No input
        #   No Algs
        self.config["ApplicationMgr"].TopAlg = []
        self.config["EventSelector"].Input = []
 
        self.config["MessageSvc"].Format = "[Writer]      " + self.msgFormat
 

Member Data Documentation

filerecordsAgent

GaudiMP.GMPBase.Writer.filerecordsAgent = FileRecordsAgent(self)

Definition at line 1264 of file GMPBase.py.

histoAgent

GaudiMP.GMPBase.Writer.histoAgent = HistoAgent(self)

Definition at line 1263 of file GMPBase.py.

status

GaudiMP.GMPBase.Writer.status = [False] * self.nWorkers

Definition at line 1242 of file GMPBase.py.

writerDict

GaudiMP.GMPBase.Writer.writerDict = self.IdentifyWriters()

Definition at line 1240 of file GMPBase.py.

---

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

• GaudiMP/python/GaudiMP/GMPBase.py