Commit b21bc311 authored by Antoine Millet's avatar Antoine Millet
Browse files

Fixed bug with initial get size

parent b5e4118a

sjrpc/core/protocols/tunnel.py

+1 −1
Original line number Diff line number Diff line
@@ -131,6 +131,7 @@ class TunnelProtocol(Protocol): 
        """

        if not self._is_shutdown.is_set():

            self._connection.rpc.send_special('protoctl', label=self._label, type='ready')

            self._send_get(TunnelProtocol.DEFAULT_GET_SIZE)

            self._is_started = True

            self._endpoint_reader.start()
@@ -180,7 +181,6 @@ class TunnelProtocol(Protocol): 
                    self._endpoint_reader.start()

            elif control_type == 'ready':

                self._send_get(TunnelProtocol.GET_SIZE)

                self._ok_to_send += TunnelProtocol.GET_SIZE

                if self._is_started:

                    self._endpoint_reader.start()

            elif control_type == 'eos':