app.PollerManager.PollerManager Class Reference

Inheritance diagram for app.PollerManager.PollerManager:

Collaboration diagram for app.PollerManager.PollerManager:

Public Member Functions
def	__init__ (self, poller=None)
def	add (self, connection, name)
def	remove (self, connection)
def	poll (self, timeout)

Public Attributes
	zmq_poller
	connections

Detailed Description

Definition at line 19 of file PollerManager.py.

Constructor & Destructor Documentation

__init__()

def app.PollerManager.PollerManager.__init__	(		self,
			poller = None
	)

Definition at line 22 of file PollerManager.py.

  def __init__(self, poller=None):
    if poller is None:
      self.zmq_poller = zmq.Poller()  # pylint: disable=E1101
    else:
      self.zmq_poller = poller
    self.connections = dict()

Member Function Documentation

add()

def app.PollerManager.PollerManager.add	(		self,
			connection,
			name
	)

Definition at line 29 of file PollerManager.py.

  def add(self, connection, name):
    if hasattr(connection, "zmq_socket"):
      self.zmq_poller.register(connection.zmq_socket, zmq.POLLIN)  # pylint: disable=E1101
      self.connections[connection.zmq_socket] = name

poll()

def app.PollerManager.PollerManager.poll	(		self,
			timeout
	)

Definition at line 45 of file PollerManager.py.

  def poll(self, timeout):
    socks = dict(self.zmq_poller.poll(timeout))
    if len(socks) == 0:
      raise ConnectionTimeout("PollerManager")
    ready_connection_names = list()
    for sock in socks:
      ready_connection_names.append(self.connections[sock])
    return ready_connection_names

remove()

def app.PollerManager.PollerManager.remove	(		self,
			connection
	)

Definition at line 35 of file PollerManager.py.

  def remove(self, connection):
    if hasattr(connection, "zmq_socket"):
      self.zmq_poller.unregister(connection.zmq_socket)
      del self.connections[connection.zmq_socket]

Member Data Documentation

connections

app.PollerManager.PollerManager.connections

Definition at line 27 of file PollerManager.py.

zmq_poller

app.PollerManager.PollerManager.zmq_poller

Definition at line 24 of file PollerManager.py.

---

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

• sources/hce/app/PollerManager.py