From: Gunnar Beutner <gunnar@beutner.name>
Date: Wed, 11 Sep 2013 15:07:07 +0000 (+0200)
Subject: cluster: Prevent idle timeout during log replay.
X-Git-Tag: v0.0.3~554
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=a831a15f528959e7e8d3f73d1230b2613e987e63;p=icinga2

cluster: Prevent idle timeout during log replay.
---

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 56ed85494..b170f48ee 100644
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -806,6 +806,8 @@ void ClusterComponent::AcknowledgementClearedHandler(const Service::Ptr& service
 
 void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Dictionary::Ptr& message)
 {
+	sender->SetSeen(Utility::GetTime());
+
 	if (message->Contains("ts")) {
 		double ts = message->Get("ts");
 
@@ -838,13 +840,11 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
 		return;
 
 	if (message->Get("method") == "cluster::HeartBeat") {
-		sender->SetSeen(Utility::GetTime());
-
 		String identity = params->Get("identity");
 
 		Endpoint::Ptr endpoint = Endpoint::GetByName(identity);
 
-		if (endpoint && endpoint != sender)
+		if (endpoint)
 			endpoint->SetSeen(Utility::GetTime());
 	} else if (message->Get("method") == "cluster::CheckResult") {
 		String svc = params->Get("service");