Commit 9de37328 authored by Rafael Monnerat's avatar Rafael Monnerat

Fix typo (reintroduce lock line)

parent 0280f02a
......@@ -107,7 +107,8 @@ class RPCRetry(object):
default_timeout = socket.getdefaulttimeout()
socket.setdefaulttimeout(self.timeout)
try:
return getattr(self._proxy, func_id)(*args)
with self.__rpc_lock:
return getattr(self._proxy, func_id)(*args)
finally:
socket.setdefaulttimeout(default_timeout)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment