Revert "Revert "cluster: Disconnect timed out endpoints.""

This reverts commit 0cab882731.
This commit is contained in:
Gunnar Beutner 2013-09-11 07:49:43 +02:00
parent b95d0d3264
commit b9ef225420
1 changed files with 11 additions and 0 deletions

View File

@ -450,6 +450,17 @@ void ClusterComponent::ClusterTimerHandler(void)
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();
if (!peers)