|
def | __init__ (self, queues, events, params, subworkers) |
|
def | processConfiguration (self) |
|
def | Engine (self) |
|
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) |
|
Definition at line 1236 of file GMPBase.py.
◆ __init__()
def GaudiMP.GMPBase.Writer.__init__ |
( |
|
self, |
|
|
|
queues, |
|
|
|
events, |
|
|
|
params, |
|
|
|
subworkers |
|
) |
| |
Definition at line 1237 of file GMPBase.py.
1237 def __init__(self, queues, events, params, subworkers):
1238 GMPComponent.__init__(self,
"Writer", -2, queues, events, params, subworkers)
1240 self.writerDict = self.IdentifyWriters()
1242 self.status = [
False] * self.nWorkers
1243 self.log.name =
"Writer--2"
◆ Engine()
def GaudiMP.GMPBase.Writer.Engine |
( |
|
self | ) |
|
Reimplemented from GaudiMP.GMPBase.GMPComponent.
Definition at line 1254 of file GMPBase.py.
1258 libc = ctypes.CDLL(
"libc.so.6")
1259 name = str(self.nodeType) + str(self.nodeID) +
"\0"
1260 libc.prctl(15, ctypes.create_unicode_buffer(name), 0, 0, 0)
1263 self.histoAgent = HistoAgent(self)
1264 self.filerecordsAgent = FileRecordsAgent(self)
1270 current = (current + 1) % self.nWorkers
1271 packet = self.evcoms[current].receive(timeout=0.01)
1274 if packet ==
"FINISHED":
1275 self.log.info(
"Writer got FINISHED flag : Worker %i" % (current))
1277 self.status[current] =
True
1278 if all(self.status):
1279 self.log.info(
"FINISHED recd from all workers, break loop")
1284 evtNumber, tbin = packet
1288 self.rTime += time.time() - t
1289 self.currentEvent = self.getEventNumber()
1290 self.evt.clearStore()
1291 self.eventLoopSyncer.set()
1292 self.log.name =
"Writer--2"
1293 self.log.info(
"Setting <Last> Event")
1294 self.lastEvent.set()
1297 [e.finalize()
for e
in self.evcoms]
1299 sc = self.histoAgent.Receive()
1300 sc = self.histoAgent.RebuildHistoStore()
1302 self.log.info(
"Histo Store rebuilt ok")
1304 self.log.warning(
"Histo Store Error in Rebuild")
1307 sc = self.filerecordsAgent.Receive()
1308 self.filerecordsAgent.Rebuild()
◆ processConfiguration()
def GaudiMP.GMPBase.Writer.processConfiguration |
( |
|
self | ) |
|
Reimplemented from GaudiMP.GMPBase.GMPComponent.
Definition at line 1245 of file GMPBase.py.
1245 def processConfiguration(self):
1249 self.config[
"ApplicationMgr"].TopAlg = []
1250 self.config[
"EventSelector"].Input = []
1252 self.config[
"MessageSvc"].Format =
"%-13s " %
"[Writer]" + self.msgFormat
◆ currentEvent
GaudiMP.GMPBase.Writer.currentEvent |
◆ filerecordsAgent
GaudiMP.GMPBase.Writer.filerecordsAgent |
◆ histoAgent
GaudiMP.GMPBase.Writer.histoAgent |
◆ status
GaudiMP.GMPBase.Writer.status |
◆ writerDict
GaudiMP.GMPBase.Writer.writerDict |
The documentation for this class was generated from the following file: