Commit 946f6991 authored by Antoine Millet's avatar Antoine Millet
Browse files

Enhanced comments

parent 4a4ec1a9
Loading
Loading
Loading
Loading
+4 −3
Original line number Diff line number Diff line
@@ -100,7 +100,7 @@ class RpcConnection(object):
                                                 callback=self._cb_need_to_send)
        self._need_to_send.start()

        # Setup self.logger.facility:
        # Setup logging facility:
        self.logger = logging.getLogger('sjrpc.%s' % self.getpeername())

        # Protocols registered on this connection:
@@ -114,7 +114,8 @@ class RpcConnection(object):
        # By default, enter in fallback mode, no label, all frames are
        # redirected on Rpc0:
        self.fallback = True
        # Send our capabilities to the peer

        # Send our capabilities to the peer:
        self._remote_capabilities = None
        self._send_capabilities()

@@ -198,7 +199,7 @@ class RpcConnection(object):
                else:
                    label, pl_size = struct.unpack(RpcConnection.MESSAGE_HEADER, self._inbound_buffer)

                # Get the registered protocol for the specified label
                # Get the registered protocol for the specified label:
                self._proto_receiving = self._protocols.get(label)

                # If frame's label is not binded to a protocol, we create a