aboutsummaryrefslogtreecommitdiffstats
path: root/mpm/python/usrp_mpm/rpc_server.py
diff options
context:
space:
mode:
authorMartin Braun <martin.braun@ettus.com>2018-01-23 12:06:35 -0800
committerMartin Braun <martin.braun@ettus.com>2018-01-23 15:21:28 -0800
commit4c81ed0a5dd01e65db560b9ed0db14407d14ce3e (patch)
tree29618b8a2e8f0275ff81520602cbd733dcfb6795 /mpm/python/usrp_mpm/rpc_server.py
parent28405e54056b52fcd04fc71c6c2d72f3dc8c31cf (diff)
downloaduhd-4c81ed0a5dd01e65db560b9ed0db14407d14ce3e.tar.gz
uhd-4c81ed0a5dd01e65db560b9ed0db14407d14ce3e.tar.bz2
uhd-4c81ed0a5dd01e65db560b9ed0db14407d14ce3e.zip
fixup! mpm: Log timeouts during API calls, reset timer on claimed calls
Diffstat (limited to 'mpm/python/usrp_mpm/rpc_server.py')
-rw-r--r--mpm/python/usrp_mpm/rpc_server.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/mpm/python/usrp_mpm/rpc_server.py b/mpm/python/usrp_mpm/rpc_server.py
index d20796c52..4eed6b79b 100644
--- a/mpm/python/usrp_mpm/rpc_server.py
+++ b/mpm/python/usrp_mpm/rpc_server.py
@@ -186,7 +186,7 @@ class MPMServer(RPCServer):
self._last_error = str(ex)
raise
finally:
- if not self.periph_manager.claimed:
+ if not self._state.claim_status.value:
self.log.error("Lost claim during API call to `%s'!",
command)
new_claimed_function.__doc__ = function.__doc__
@@ -279,6 +279,7 @@ class MPMServer(RPCServer):
choice(ascii_letters + digits) for _ in range(TOKEN_LEN)
), 'ascii')
self._state.claim_status.value = True
+ self.periph_manager.claimed = True
self.periph_manager.claim()
self._state.lock.release()
self.session_id = session_id + " ({})".format(self.client_host)