1 files changed, 71 insertions, 0 deletions
diff --git a/configd/src/apps/sentinel/report-connectivity.cpp b/configd/src/apps/sentinel/report-connectivity.cpp
new file mode 100644
index 00000000000..8e855f296c1
--- /dev/null
+++ b/configd/src/apps/sentinel/report-connectivity.cpp
@@ -0,0 +1,71 @@
+// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+
+#include "report-connectivity.h"
+#include "connectivity.h"
+#include <vespa/log/log.h>
+
+LOG_SETUP(".report-connectivity");
+
+using cloud::config::ModelConfig;
+
+namespace config::sentinel {
+
+ConnectivityCheckResult::~ConnectivityCheckResult() = default;
+
+void ConnectivityCheckResult::returnStatus(bool ok) {
+    status = ok ? "ok" : "ping failed";
+    LOG(debug, "peer %s [port %d] -> %s", peerName.c_str(), peerPort, status.c_str());
+    parent.requestDone();
+}
+
+ConnectivityReportResult::~ConnectivityReportResult() = default;
+
+
+ReportConnectivity::ReportConnectivity(FRT_RPCRequest *req, FRT_Supervisor &orb)
+  : _parentRequest(req),
+    _orb(orb),
+    _result(),
+    _configFetcher()
+{
+    _configFetcher.subscribe<ModelConfig>("admin/model", this);
+    _configFetcher.start();
+}
+
+ReportConnectivity::~ReportConnectivity() = default;
+
+void ReportConnectivity::requestDone() {
+    {
+        std::lock_guard<std::mutex> guard(_lock);
+        if (--_remaining != 0) {
+            return;
+        }
+    }
+    finish();
+}
+
+void ReportConnectivity::configure(std::unique_ptr<ModelConfig> config) {
+    _configFetcher.close();
+    auto map = Connectivity::specsFrom(*config);
+    for (const auto & [ hostname, port ] : map) {
+        _result.peers.emplace_back(*this, hostname, port);
+    }
+    LOG(debug, "making connectivity report for %zd peers", _result.peers.size());
+    _remaining = _result.peers.size();
+    for (auto & peer : _result.peers) {
+        peer.check = std::make_unique<PeerCheck>(peer, peer.peerName, peer.peerPort, _orb, 2500);
+    }
+}
+
+
+void ReportConnectivity::finish() const {
+    FRT_Values *dst = _parentRequest->GetReturn();
+    FRT_StringValue *pt_hn = dst->AddStringArray(_result.peers.size());
+    FRT_StringValue *pt_ss = dst->AddStringArray(_result.peers.size());
+    for (const auto & peer : _result.peers) {
+        dst->SetString(pt_hn++, peer.peerName.c_str());
+        dst->SetString(pt_ss++, peer.status.c_str());
+    }
+    _parentRequest->Return();
+}
+
+}