From 235042bbac1594da604f4abc6922f01b42a5c8f9 Mon Sep 17 00:00:00 2001 From: Gunnar Beutner Date: Tue, 3 Sep 2013 10:12:07 +0200 Subject: [PATCH] cluster: Bugfix for the log timestamps. --- components/cluster/clustercomponent.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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")); } } -- 2.50.1