:py:mod:`python.dgbpy.servicemgr`
=================================

.. py:module:: python.dgbpy.servicemgr


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   python.dgbpy.servicemgr.ServiceMgr
   python.dgbpy.servicemgr.Message
   python.dgbpy.servicemgr.Packet




.. py:class:: ServiceMgr(cmdserver, ppid, tornadoport, serviceID=None)

   Bases: :py:obj:`tornado.tcpserver.TCPServer`

   .. py:method:: __enter__(self)


   .. py:method:: __exit__(self, exc_type, exc_value, traceback)


   .. py:method:: _is_port_in_use(self, port, local_ip)


   .. py:method:: _startServer(self, tornadoport, attempts=20)


   .. py:method:: _register(self, port, address)


   .. py:method:: _parentChkCB(self)


   .. py:method:: handle_stream(self, stream, address)
      :async:


   .. py:method:: _processPacket(self, inpacket)


   .. py:method:: addAction(self, key, action)


   .. py:method:: sendObject(self, objkey, jsonobj)


   .. py:method:: can_connect(self)



.. py:class:: Message

   .. py:method:: parseAddress(self, address)


   .. py:method:: sendObject(self, host, port, objkey, jsonobj)


   .. py:method:: sendObjectToAddress(self, address, objkey, jsonobj)


   .. py:method:: sendEvent(self, host, port, eventstr)


   .. py:method:: sendEventToAddress(self, address, eventstr)


   .. py:method:: _send(self, host, port, packet)
      :async:



.. py:class:: Packet(packet=None)

   .. py:attribute:: _curreqid
      :annotation: = 0

      

   .. py:method:: setIsNewRequest(self)


   .. py:method:: setTextPayload(self, jsonobj)


   .. py:method:: getTextPayload(self)


   .. py:method:: _createPacket(self, payload)


   .. py:method:: _json_encode(self, obj, encoding)


   .. py:method:: _odhdr_decode(self)


   .. py:method:: _json_decode(self, json_bytes, encoding)