Loading sjrpc/core/protocols/tunnel.py +5 −1 Original line number Diff line number Diff line Loading @@ -4,6 +4,7 @@ import threading import socket from sjrpc.core.protocols import Protocol from sjrpc.core.exceptions import RpcConnectionError import pyev Loading Loading @@ -141,7 +142,10 @@ class TunnelProtocol(Protocol): self._endpoint_reader.stop() self._endpoint_writer.stop() # Send the end of stream message to the peer: try: self._connection.rpc.send_special('protoctl', label=self._label, type='eos') except RpcConnectionError: pass # Ignore errors when connection is down. # Execute the callback: self._cb_on_shutdown(self) super(TunnelProtocol, self).shutdown() Loading Loading
sjrpc/core/protocols/tunnel.py +5 −1 Original line number Diff line number Diff line Loading @@ -4,6 +4,7 @@ import threading import socket from sjrpc.core.protocols import Protocol from sjrpc.core.exceptions import RpcConnectionError import pyev Loading Loading @@ -141,7 +142,10 @@ class TunnelProtocol(Protocol): self._endpoint_reader.stop() self._endpoint_writer.stop() # Send the end of stream message to the peer: try: self._connection.rpc.send_special('protoctl', label=self._label, type='eos') except RpcConnectionError: pass # Ignore errors when connection is down. # Execute the callback: self._cb_on_shutdown(self) super(TunnelProtocol, self).shutdown() Loading