From: Gunnar Beutner <gunnar.beutner@netways.de>
Date: Tue, 3 Sep 2013 09:14:51 +0000 (+0200)
Subject: cluster: Send SetLogPosition messages for all message types.
X-Git-Tag: v0.0.3~611
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=9c00e560ab17d2ff16d13e560844b6f895064a6b;p=icinga2

cluster: Send SetLogPosition messages for all message types.
---

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 31efc8d17..71f46ae48 100644
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -676,11 +676,6 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
 {
 	RelayMessage(sender, message, true);
 
-	if (message->Get("method") == "cluster::HeartBeat") {
-		sender->SetSeen(Utility::GetTime());
-		return;
-	}
-
 	if (sender->GetRemoteLogPosition() + 10 < message->Get("ts")) {
 		Dictionary::Ptr lparams = boost::make_shared<Dictionary>();
 		lparams->Set("log_position", message->Get("ts"));
@@ -695,6 +690,11 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
 		sender->SetRemoteLogPosition(message->Get("ts"));
 	}
 
+	if (message->Get("method") == "cluster::HeartBeat") {
+		sender->SetSeen(Utility::GetTime());
+		return;
+	}
+
 	Dictionary::Ptr params = message->Get("params");
 
 	if (!params)