From: Gunnar Beutner <gunnar@beutner.name>
Date: Wed, 11 Sep 2013 05:49:43 +0000 (+0200)
Subject: Revert "Revert "cluster: Disconnect timed out endpoints.""
X-Git-Tag: v0.0.3~571
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=b9ef225420012464ee837055ef98eae3d36a8a32;p=icinga2

Revert "Revert "cluster: Disconnect timed out endpoints.""

This reverts commit 0cab8827311db265a8458236ef97b3f9640e9ca8.
---

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 220548b89..fdb36ac01 100644
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -450,6 +450,17 @@ void ClusterComponent::ClusterTimerHandler(void)
 
 	RelayMessage(Endpoint::Ptr(), message, false);
 
+	/* check if we've recently seen heartbeat messages from our peers */
+	BOOST_FOREACH(const Endpoint::Ptr& endpoint, DynamicType::GetObjects<Endpoint>()) {
+		if (!endpoint->IsConnected() || endpoint->GetSeen() > Utility::GetTime() - 60)
+			continue;
+
+		Stream::Ptr client = endpoint->GetClient();
+
+		if (client)
+			client->Close();
+	}
+
 	Array::Ptr peers = GetPeers();
 
 	if (!peers)