From fb5e10a8e4cff12182403dc6af6f5d8bf7a469c0 Mon Sep 17 00:00:00 2001 From: Martin Braun Date: Thu, 9 Nov 2017 18:13:16 -0800 Subject: mpm: Cache connection type in PeriphManagerBase Now, when claiming a device, the connection type will be stored as a string in PeriphManagerBase. This way we can read out the current connection type even when not currently inside an RPC call. --- mpm/python/usrp_mpm/rpc_server.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'mpm/python/usrp_mpm/rpc_server.py') diff --git a/mpm/python/usrp_mpm/rpc_server.py b/mpm/python/usrp_mpm/rpc_server.py index 7d7fe1758..10d37a3d7 100644 --- a/mpm/python/usrp_mpm/rpc_server.py +++ b/mpm/python/usrp_mpm/rpc_server.py @@ -221,6 +221,10 @@ class MPMServer(RPCServer): self._state.claim_token.value, self.client_host ) + if self.client_host in ["127.0.0.1", "::1"]: + self.periph_manager.set_connection_type("local") + else: + self.periph_manager.set_connection_type("remote") return self._state.claim_token.value @@ -284,6 +288,7 @@ class MPMServer(RPCServer): self.session_id = None self.periph_manager.claimed = False try: + self.periph_manager.set_connection_type(None) self.periph_manager.deinit() except Exception as ex: self._last_error = str(ex) @@ -345,7 +350,7 @@ class MPMServer(RPCServer): def _rpc_server_process(shared_state, port, mgr): """ - Start the RPC server + This is the actual process that's running the RPC server. """ connections = Pool(1000) server = StreamServer( -- cgit v1.2.3