From 6ed8b20a762f73a7c1e534b1b6d22339df94ebce Mon Sep 17 00:00:00 2001
From: Kelven Yang <kelven@cloud.com>
Date: Tue, 1 Feb 2011 12:40:17 -0800
Subject: [PATCH] add catch-all clause in cluster heartbeat

---
 server/src/com/cloud/cluster/ClusterManagerImpl.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/src/com/cloud/cluster/ClusterManagerImpl.java b/server/src/com/cloud/cluster/ClusterManagerImpl.java
index 76899196c33..c39dd91668b 100644
--- a/server/src/com/cloud/cluster/ClusterManagerImpl.java
+++ b/server/src/com/cloud/cluster/ClusterManagerImpl.java
@@ -149,7 +149,9 @@ public class ClusterManagerImpl implements ClusterManager {
     
     @Override
     public void broadcast(long agentId, Command[] cmds) {
-    	List<ManagementServerHostVO> peers = _mshostDao.getActiveList(new Date());
+		Date cutTime = DateUtil.currentGMTTime();
+
+    	List<ManagementServerHostVO> peers = _mshostDao.getActiveList(new Date(cutTime.getTime() - heartbeatThreshold));
     	for (ManagementServerHostVO peer : peers) {
     		String peerName = Long.toString(peer.getMsid());
     		if (getSelfPeerName().equals(peerName)) {
@@ -516,7 +518,7 @@ public class ClusterManagerImpl implements ClusterManager {
     	    		
         			_mshostDao.update(_mshostId, DateUtil.currentGMTTime());
         			peerScan();
-			    } catch (Exception e) {
+			    } catch (Throwable e) {
 			        s_logger.error("Problem with the cluster heartbeat!", e);
 			    }
 			}