From 9c00e560ab17d2ff16d13e560844b6f895064a6b Mon Sep 17 00:00:00 2001 From: Gunnar Beutner Date: Tue, 3 Sep 2013 11:14:51 +0200 Subject: [PATCH] cluster: Send SetLogPosition messages for all message types. --- components/cluster/clustercomponent.cpp | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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(); 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) -- 2.40.0