diff options
Diffstat (limited to 'host/lib/usrp')
| -rw-r--r-- | host/lib/usrp/mpmd/mpmd_impl.hpp | 2 | ||||
| -rw-r--r-- | host/lib/usrp/mpmd/mpmd_mboard_impl.cpp | 7 | 
2 files changed, 6 insertions, 3 deletions
diff --git a/host/lib/usrp/mpmd/mpmd_impl.hpp b/host/lib/usrp/mpmd/mpmd_impl.hpp index b3d753949..15eb35800 100644 --- a/host/lib/usrp/mpmd/mpmd_impl.hpp +++ b/host/lib/usrp/mpmd/mpmd_impl.hpp @@ -32,6 +32,8 @@ static constexpr size_t MPMD_DEFAULT_RPC_TIMEOUT     = 2000;  //! Short timeout value for RPC calls (ms), used for calls that shouldn't  // take long. This value can be used to quickly determine a link status.  static constexpr size_t MPMD_SHORT_RPC_TIMEOUT     = 2000; +//! Claimer loop timeout value for RPC calls (ms). +static constexpr size_t MPMD_CLAIMER_RPC_TIMEOUT     = 10000;  namespace uhd { namespace mpmd { diff --git a/host/lib/usrp/mpmd/mpmd_mboard_impl.cpp b/host/lib/usrp/mpmd/mpmd_mboard_impl.cpp index fe92f132e..a49651f10 100644 --- a/host/lib/usrp/mpmd/mpmd_mboard_impl.cpp +++ b/host/lib/usrp/mpmd/mpmd_mboard_impl.cpp @@ -193,7 +193,8 @@ namespace {       */      uhd::rpc_client::sptr make_mpm_rpc_client(          const std::string& rpc_server_addr, -        const uhd::device_addr_t& mb_args +        const uhd::device_addr_t& mb_args, +        const size_t timeout_ms = MPMD_DEFAULT_RPC_TIMEOUT      ){          return uhd::rpc_client::make(              rpc_server_addr, @@ -201,7 +202,7 @@ namespace {                  uhd::mpmd::mpmd_impl::MPM_RPC_PORT_KEY,                  uhd::mpmd::mpmd_impl::MPM_RPC_PORT              ), -            MPMD_DEFAULT_RPC_TIMEOUT, +            timeout_ms,              uhd::mpmd::mpmd_impl::MPM_RPC_GET_LAST_ERROR_CMD);      } @@ -305,7 +306,7 @@ mpmd_mboard_impl::mpmd_mboard_impl(  ) : mb_args(mb_args_)      , rpc(make_mpm_rpc_client(rpc_server_addr, mb_args_))      , num_xbars(rpc->request<size_t>("get_num_xbars")) -    , _claim_rpc(make_mpm_rpc_client(rpc_server_addr, mb_args_)) +    , _claim_rpc(make_mpm_rpc_client(rpc_server_addr, mb_args, MPMD_CLAIMER_RPC_TIMEOUT))      // xbar_local_addrs is not yet valid after this!      , xbar_local_addrs(num_xbars, 0xFF)      , _xport_mgr(xport::mpmd_xport_mgr::make(mb_args))  | 
