Commit 3e99529b authored by Antoine Millet's avatar Antoine Millet

Fixed bug with shutdown and running calls release.

parent 251078ed
......@@ -55,7 +55,7 @@ class RpcProtocol(object):
def shutdown(self):
# Release all waiting calls from this rpc:
for cid in self._calls:
for cid in self._calls.keys():
err = {'exception': 'RpcError',
'message': 'Connection reset by peer'}
self._handle_response({'id': cid, 'return': None, 'error': err})
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment