tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cluster: Prevent idle timeout during log replay.

This commit is contained in:
Gunnar Beutner 2013-09-11 17:07:07 +02:00
parent 7961dc4e78
commit a831a15f52
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
components/cluster/clustercomponent.cpp
View File

@ -806,6 +806,8 @@ void ClusterComponent::AcknowledgementClearedHandler(const Service::Ptr& service
void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Dictionary::Ptr& message) void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Dictionary::Ptr& message)
{ {
sender->SetSeen(Utility::GetTime());
if (message->Contains("ts")) { if (message->Contains("ts")) {
double ts = message->Get("ts"); double ts = message->Get("ts");
@ -838,13 +840,11 @@ void ClusterComponent::MessageHandler(const Endpoint::Ptr& sender, const Diction
return; return;
if (message->Get("method") == "cluster::HeartBeat") { if (message->Get("method") == "cluster::HeartBeat") {
sender->SetSeen(Utility::GetTime());
String identity = params->Get("identity"); String identity = params->Get("identity");
Endpoint::Ptr endpoint = Endpoint::GetByName(identity); Endpoint::Ptr endpoint = Endpoint::GetByName(identity);
if (endpoint && endpoint != sender) if (endpoint)
endpoint->SetSeen(Utility::GetTime()); endpoint->SetSeen(Utility::GetTime());
} else if (message->Get("method") == "cluster::CheckResult") { } else if (message->Get("method") == "cluster::CheckResult") {
String svc = params->Get("service"); String svc = params->Get("service");