forked from M-Labs/artiq
1
0
Fork 0

ctlmgr: fix the fix (107e2fe)

This commit is contained in:
Robert Jördens 2016-01-29 17:52:12 -07:00
parent d05d720b19
commit 17ac64a65e
1 changed files with 2 additions and 2 deletions

View File

@ -41,14 +41,14 @@ class Controller:
try:
targets, _ = remote.get_rpc_id()
remote.select_rpc_target(targets[0])
r = await getattr(remote, method)()
r = await getattr(remote, method)(*args, **kwargs)
finally:
remote.close_rpc()
return r
async def _ping(self):
try:
ok = await asyncio.wait_for(self._call_controller("ping"),
ok = await asyncio.wait_for(self.call("ping"),
self.ping_timeout)
if ok:
self.retry_timer_cur = self.retry_timer