From: Gunnar Beutner <gunnar.beutner@netways.de>
Date: Tue, 3 Sep 2013 08:12:07 +0000 (+0200)
Subject: cluster: Bugfix for the log timestamps.
X-Git-Tag: v0.0.3~617
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=235042bbac1594da604f4abc6922f01b42a5c8f9;p=icinga2

cluster: Bugfix for the log timestamps.
---

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 54a56f22d..7810c9a48 100644
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -656,6 +656,8 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
 		lmessage->Set("params", lparams);
 
 		sender->SendMessage(lmessage);
+
+		sender->SetRemoteLogPosition(message->Get("ts"));
 	}
 
 	Dictionary::Ptr params = message->Get("params");
@@ -839,7 +841,7 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
 		ObjectLock olock(service);
 		service->ClearAcknowledgement(sender->GetName());
 	} else if (message->Get("method") == "cluster::SetLogPosition") {
-		sender->SetRemoteLogPosition(params->Get("log_position"));
+		sender->SetLocalLogPosition(params->Get("log_position"));
 	}
 }