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

Call Protocol shutdown in RpcProtocol shutdown

parent 99441235

sjrpc/core/protocols/rpc.py

+1 −0
Original line number Diff line number Diff line
@@ -264,6 +264,7 @@ class RpcProtocol(Protocol): 
        * Release all waiting calls with a "Connection reset by peer" error.

        * Execute the on_disconnect callback.

        """

        super(RpcProtocol, self).shutdown()

        # Release all waiting calls from this rpc:

        for cid in self._calls.keys():

            err = {'exception': 'RpcError',