summaryrefslogtreecommitdiffstats
path: root/configd/src/apps/sentinel/report-connectivity.cpp
diff options
context:
space:
mode:
authorArne Juul <arnej@verizonmedia.com>2021-06-11 13:53:26 +0000
committerArne Juul <arnej@verizonmedia.com>2021-06-11 13:53:26 +0000
commitb54d4da7d22b2e27618bb2bb8865429e01ddab95 (patch)
tree01066fd388c5e29c5b5f31dbe2ccd632cd808999 /configd/src/apps/sentinel/report-connectivity.cpp
parent714a924518bc5bef4f920899d3af96b56497eaf0 (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.cpp5
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");