From a831a15f528959e7e8d3f73d1230b2613e987e63 Mon Sep 17 00:00:00 2001 From: Gunnar Beutner Date: Wed, 11 Sep 2013 17:07:07 +0200 Subject: [PATCH] cluster: Prevent idle timeout during log replay. --- components/cluster/clustercomponent.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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");