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

cluster: Disconnect timed out endpoints.

Browse Source
This commit is contained in:
Gunnar Beutner 2013-09-03 16:51:49 +02:00
parent 558daf7b84
commit 1f74139ab4
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
components/cluster/clustercomponent.cpp
View File

@ -410,6 +410,17 @@ void ClusterComponent::ClusterTimerHandler(void)
RelayMessage(Endpoint::Ptr(), message, false); RelayMessage(Endpoint::Ptr(), message, false);
/* check if we've recently seen heartbeat messages from our peers */
BOOST_FOREACH(const Endpoint::Ptr& endpoint, DynamicType::GetObjects<Endpoint>()) {
if (!endpoint->IsConnected() || endpoint->GetSeen() > Utility::GetTime() - 60)
continue;
Stream::Ptr client = endpoint->GetClient();
if (client)
client->Close();
}
Array::Ptr peers = GetPeers(); Array::Ptr peers = GetPeers();
if (!peers) if (!peers)