transport.Connection.Connection Class Reference

Inheritance diagram for transport.Connection.Connection:

Collaboration diagram for transport.Connection.Connection:

Public Member Functions
def	__init__ (self, zmq_socket, zmq_poller, socket_type=consts.CLIENT_CONNECT)
def	send (self, request, rid=-1)
def	recv (self, timeout=RECV_DEFAULT_TIMEOUT, rid=-1)
def	close (self)
def	is_closed (self)

Public Attributes
	zmq_socket
	zmq_poller
	socket_type

Static Public Attributes
int	RECV_DEFAULT_TIMEOUT = 5000

Detailed Description

Transport class

Definition at line 50 of file Connection.py.

Constructor & Destructor Documentation

__init__()

def transport.Connection.Connection.__init__	(		self,
			zmq_socket,
			zmq_poller,
			socket_type = consts.CLIENT_CONNECT
	)

Definition at line 62 of file Connection.py.

  def __init__(self, zmq_socket, zmq_poller, socket_type=consts.CLIENT_CONNECT):
    self.zmq_socket = zmq_socket
    self.zmq_poller = zmq_poller
    self.socket_type = socket_type
    # @todo remove poller
    # self.zmq_poller.register(self.zmq_socket, zmq.POLLIN)

Member Function Documentation

close()

def transport.Connection.Connection.close

(

self

)

Definition at line 142 of file Connection.py.

  def close(self):
    # self.zmq_poller.unregister(self.zmq_socket) #is right place??
    self.zmq_socket.close()

is_closed()

def transport.Connection.Connection.is_closed

(

self

)

Definition at line 150 of file Connection.py.

  def is_closed(self):
    return self.zmq_socket.closed

recv()

def transport.Connection.Connection.recv	(		self,
			timeout = RECV_DEFAULT_TIMEOUT,
			rid = -1
	)

Definition at line 117 of file Connection.py.

  def recv(self, timeout=RECV_DEFAULT_TIMEOUT, rid=-1):
    try:
      events = self.zmq_socket.poll(int(timeout), zmq.POLLIN)  # pylint: disable=E0602,E1101
      if  events == zmq.POLLIN:  # pylint: disable-msg=E1101
        if self.socket_type == consts.CLIENT_CONNECT:
          return Response(self.zmq_socket.recv_multipart())
        else:
          data = self.zmq_socket.recv_multipart()
          identity = data[:1]
          return Response(data[1:], identity[0])
      else:
        raise ConnectionTimeout('Connection.recv() timeout: ' + str(timeout) + ', request id: ' + str(rid))
    except (zmq.ZMQError, zmq.Again) as err:  # pylint: disable-msg=E1101
      logger.error("ZMQ error: " + str(err))
      raise TransportInternalErr(str(err))
    except Exception as err:
      logger.error("General error: " + str(err))
      raise TransportInternalErr(str(err))
    # finally:
#      self.zmq_poller.unregister(self.zmq_socket)

send()

def transport.Connection.Connection.send	(		self,
			request,
			rid = -1
	)

Definition at line 76 of file Connection.py.

  def send(self, request, rid=-1):
    try:
      if self.socket_type == consts.CLIENT_CONNECT:
        snd_data = request.get_body()
      else:
        # snd_data = list(request.eventObj.get_body())
        # snd_data.insert(0, request.connect_identity)
        # return self.zmq_socket.send_multipart(snd_data)
        snd_data = [request.connect_identity] + request.eventObj.get_body()

      try:
        if request.route is not None:
          request.route = json.loads(request.route)
          request.route['task_type'] = request.task_type
          request.route = json.dumps(request.route)
          snd_data.append(request.route)
        else:
          if request.task_type > 0:
            snd_data.append(json.dumps({'task_type':request.task_type}))

      except Exception as err:
        logger.debug("Error add task_type in to the route data: %s", str(err))

      logger.debug("send_multipart() socket_type: " + str(self.socket_type) + ", id:" + str(rid) + \
                   " snd_data: " + varDump(snd_data))
      r = self.zmq_socket.send_multipart(snd_data)
      logger.debug("Data sent with the zmq_socket.send_multipart()")
      return r
    except zmq.ZMQError as err:  # pylint: disable-msg=E1101
      logger.error("ZMQ error: " + str(err))
      raise TransportInternalErr(str(err))
    except Exception as err:
      raise TransportInternalErr('General error: ' + str(err))

Here is the call graph for this function:

Member Data Documentation

RECV_DEFAULT_TIMEOUT

int transport.Connection.Connection.RECV_DEFAULT_TIMEOUT = 5000

static

Definition at line 55 of file Connection.py.

socket_type

transport.Connection.Connection.socket_type

Definition at line 65 of file Connection.py.

zmq_poller

transport.Connection.Connection.zmq_poller

Definition at line 64 of file Connection.py.

zmq_socket

transport.Connection.Connection.zmq_socket

Definition at line 63 of file Connection.py.

---

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

• sources/hce/transport/Connection.py