GaudiMP.GMPBase.EventCommunicator Class Reference

Public Member Functions
	__init__ (self, GMPComponent, qin, qout)
	send (self, item)
	receive (self, timeout=None)
	finalize (self)
	statistics (self)

Public Attributes
	log = self._gmpc.log
int	maxsize = 50
	qin = qin
	qout = qout
bool	allsent = False
bool	allrecv = False
int	nSent = 0
int	nRecv = 0
int	sizeSent = 0
int	sizeRecv = 0
int	qinTime = 0
int	qoutTime = 0

Protected Attributes
	_gmpc = GMPComponent

Detailed Description

Definition at line 264 of file GMPBase.py.

Constructor & Destructor Documentation

__init__()

GaudiMP.GMPBase.EventCommunicator.__init__	(		self,
			GMPComponent,
			qin,
			qout )

Definition at line 268 of file GMPBase.py.

    def __init__(self, GMPComponent, qin, qout):
        self._gmpc = GMPComponent
        self.log = self._gmpc.log
        # maximum capacity of Queues
        self.maxsize = 50
        # central variables : Queues
        self.qin = qin
        self.qout = qout
 
        # flags
        self.allsent = False
        self.allrecv = False
 
        # statistics storage
        self.nSent = 0  # counter : items sent
        self.nRecv = 0  # counter : items received
        self.sizeSent = 0  # measure : size of events sent ( tbuf.Length() )
        self.sizeRecv = 0  # measure : size of events in   ( tbuf.Length() )
        self.qinTime = 0  # time    : receiving from self.qin
        self.qoutTime = 0  # time    : sending on qout
 

Member Function Documentation

finalize()

GaudiMP.GMPBase.EventCommunicator.finalize

(

self

)

Definition at line 325 of file GMPBase.py.

    def finalize(self):
        self.log.info(
            f"Finalize Event Communicator : {self._gmpc} {self._gmpc.nodeType}"
        )
        # Reader sends one flag for each worker
        # Workers send one flag each
        # Writer sends nothing (it's at the end of the chain)
        if self._gmpc.nodeType == "Reader":
            downstream = self._gmpc.nWorkers
        elif self._gmpc.nodeType == "Writer":
            downstream = 0
        elif self._gmpc.nodeType == "Worker":
            downstream = 1
 
        for i in range(downstream):
            self.qout.put("FINISHED")
        if self._gmpc.nodeType != "Writer":
            self.qout.join()
        # Now some reporting...
        self.statistics()
 

receive()

GaudiMP.GMPBase.EventCommunicator.receive	(		self,
			timeout = None )

Definition at line 304 of file GMPBase.py.

    def receive(self, timeout=None):
        # Receive items from self.qin
        startWait = time.time()
        try:
            itemIn = self.qin.get(timeout=timeout)
        except Empty:
            return None
        self.qinTime += time.time() - startWait
        self.nRecv += 1
        if itemIn.__class__.__name__ == "tuple":
            self.sizeRecv += itemIn[1].Length()
        else:
            self.nRecv -= 1
        try:
            self.qin.task_done()
        except Exception:
            self._gmpc.log.warning(
                f"TASK_DONE called too often by : {self._gmpc.nodeType}"
            )
        return itemIn
 

send()

GaudiMP.GMPBase.EventCommunicator.send	(		self,
			item )

Definition at line 289 of file GMPBase.py.

    def send(self, item):
        # This class manages the sending of a TBufferFile Event to a Queue
        # The actual item to be sent is a tuple : ( evtNumber, TBufferFile )
        assert item.__class__.__name__ == "tuple"
        startTransmission = time.time()
        self.qout.put(item)
        # allow the background thread to feed the Queue; not 100% guaranteed to
        # finish before next line
        while self.qout._buffer:
            time.sleep(NAP)
        self.qoutTime += time.time() - startTransmission
        self.sizeSent += item[1].Length()
        self.nSent += 1
        return SUCCESS
 

statistics()

GaudiMP.GMPBase.EventCommunicator.statistics

(

self

)

Definition at line 346 of file GMPBase.py.

    def statistics(self):
        self.log.name = f"{self._gmpc.nodeType}-{self._gmpc.nodeID} Audit "
        self.log.info(f"Items Sent     : {self.nSent}")
        self.log.info(f"Items Received : {self.nRecv}")
        self.log.info(f"Data  Sent     : {self.sizeSent}")
        self.log.info(f"Data  Received : {self.sizeRecv}")
        self.log.info(f"Q-out Time     : {self.qoutTime:5.2f}")
        self.log.info(f"Q-in  Time     : {self.qinTime:5.2f}")
 
 
# =============================================================================
 
 

Member Data Documentation

_gmpc

GaudiMP.GMPBase.EventCommunicator._gmpc = GMPComponent

protected

Definition at line 269 of file GMPBase.py.

allrecv

bool GaudiMP.GMPBase.EventCommunicator.allrecv = False

Definition at line 279 of file GMPBase.py.

allsent

bool GaudiMP.GMPBase.EventCommunicator.allsent = False

Definition at line 278 of file GMPBase.py.

log

GaudiMP.GMPBase.EventCommunicator.log = self._gmpc.log

Definition at line 270 of file GMPBase.py.

maxsize

int GaudiMP.GMPBase.EventCommunicator.maxsize = 50

Definition at line 272 of file GMPBase.py.

nRecv

int GaudiMP.GMPBase.EventCommunicator.nRecv = 0

Definition at line 283 of file GMPBase.py.

nSent

int GaudiMP.GMPBase.EventCommunicator.nSent = 0

Definition at line 282 of file GMPBase.py.

qin

GaudiMP.GMPBase.EventCommunicator.qin = qin

Definition at line 274 of file GMPBase.py.

qinTime

int GaudiMP.GMPBase.EventCommunicator.qinTime = 0

Definition at line 286 of file GMPBase.py.

qout

GaudiMP.GMPBase.EventCommunicator.qout = qout

Definition at line 275 of file GMPBase.py.

qoutTime

int GaudiMP.GMPBase.EventCommunicator.qoutTime = 0

Definition at line 287 of file GMPBase.py.

sizeRecv

int GaudiMP.GMPBase.EventCommunicator.sizeRecv = 0

Definition at line 285 of file GMPBase.py.

sizeSent

int GaudiMP.GMPBase.EventCommunicator.sizeSent = 0

Definition at line 284 of file GMPBase.py.

---

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

• GaudiMP/python/GaudiMP/GMPBase.py