tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-29 16:44:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

cluster: Fix another reconnect bug.

Browse Source
This commit is contained in:
Gunnar Beutner 2013-09-11 10:21:43 +02:00
parent 63941c5f40
commit a9b7cfb777
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
components/cluster/clustercomponent.cpp
View File

@ -411,6 +411,8 @@ void ClusterComponent::NewClientHandler(const Socket::Ptr& client, TlsRole role)
return; return;
} }
endpoint->SetSeen(Utility::GetTime());
Dictionary::Ptr config = boost::make_shared<Dictionary>(); Dictionary::Ptr config = boost::make_shared<Dictionary>();
Array::Ptr configFiles = endpoint->GetConfigFiles(); Array::Ptr configFiles = endpoint->GetConfigFiles();
@ -469,7 +471,7 @@ void ClusterComponent::ClusterTimerHandler(void)
ObjectLock olock(this); ObjectLock olock(this);
/* check if we've recently seen heartbeat messages from our peers */ /* check if we've recently seen heartbeat messages from our peers */
BOOST_FOREACH(const Endpoint::Ptr& endpoint, DynamicType::GetObjects<Endpoint>()) { BOOST_FOREACH(const Endpoint::Ptr& endpoint, DynamicType::GetObjects<Endpoint>()) {
if (!endpoint->IsConnected() || endpoint->GetSeen() > Utility::GetTime() - 60) if (endpoint->GetSeen() > Utility::GetTime() - 60)
continue; continue;
Stream::Ptr client = endpoint->GetClient(); Stream::Ptr client = endpoint->GetClient();