diff options
author | Arne Juul <arnej@verizonmedia.com> | 2021-06-11 13:53:26 +0000 |
---|---|---|
committer | Arne Juul <arnej@verizonmedia.com> | 2021-06-11 13:53:26 +0000 |
commit | b54d4da7d22b2e27618bb2bb8865429e01ddab95 (patch) | |
tree | 01066fd388c5e29c5b5f31dbe2ccd632cd808999 /configd/src/apps/sentinel/report-connectivity.cpp | |
parent | 714a924518bc5bef4f920899d3af96b56497eaf0 (diff) |
take timeout as RPC parameter here also
Diffstat (limited to 'configd/src/apps/sentinel/report-connectivity.cpp')
-rw-r--r-- | configd/src/apps/sentinel/report-connectivity.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/configd/src/apps/sentinel/report-connectivity.cpp b/configd/src/apps/sentinel/report-connectivity.cpp index 4b5d38ed125..eceb2cf64aa 100644 --- a/configd/src/apps/sentinel/report-connectivity.cpp +++ b/configd/src/apps/sentinel/report-connectivity.cpp @@ -13,8 +13,7 @@ using namespace std::chrono_literals; namespace config::sentinel { - -ReportConnectivity::ReportConnectivity(FRT_RPCRequest *req, FRT_Supervisor &orb, ModelOwner &modelOwner) +ReportConnectivity::ReportConnectivity(FRT_RPCRequest *req, int timeout_ms, FRT_Supervisor &orb, ModelOwner &modelOwner) : _parentRequest(req), _orb(orb), _checks() @@ -25,7 +24,7 @@ ReportConnectivity::ReportConnectivity(FRT_RPCRequest *req, FRT_Supervisor &orb, LOG(debug, "making connectivity report for %zd peers", map.size()); _remaining = map.size(); for (const auto & [ hostname, port ] : map) { - _checks.emplace_back(std::make_unique<PeerCheck>(*this, hostname, port, _orb, 2500)); + _checks.emplace_back(std::make_unique<PeerCheck>(*this, hostname, port, _orb, timeout_ms)); } } else { _parentRequest->SetError(FRTE_RPC_METHOD_FAILED, "failed getting model config"); |