diff --git a/agent/src/com/cloud/agent/resource/computing/KVMHABase.java b/agent/src/com/cloud/agent/resource/computing/KVMHABase.java index 74da0f25ae3..9424fd11892 100644 --- a/agent/src/com/cloud/agent/resource/computing/KVMHABase.java +++ b/agent/src/com/cloud/agent/resource/computing/KVMHABase.java @@ -39,7 +39,7 @@ import com.cloud.utils.script.Script; public class KVMHABase { private long _timeout = 60000; /*1 minutes*/ protected static String _heartBeatPath; - protected long _heartBeatUpdateTimeout = 5000; /*5 sec*/ + protected long _heartBeatUpdateTimeout = 60000; protected long _heartBeatUpdateFreq = 60000; protected long _heartBeatUpdateMaxRetry = 3; public static enum PoolType { diff --git a/agent/src/com/cloud/agent/resource/computing/KVMHAChecker.java b/agent/src/com/cloud/agent/resource/computing/KVMHAChecker.java index 29de833ed31..ed5307831ea 100644 --- a/agent/src/com/cloud/agent/resource/computing/KVMHAChecker.java +++ b/agent/src/com/cloud/agent/resource/computing/KVMHAChecker.java @@ -33,7 +33,7 @@ public class KVMHAChecker extends KVMHABase implements Callable { private static final Logger s_logger = Logger.getLogger(KVMHAChecker.class); private List _pools; private String _hostIP; - private long _heartBeatCheckerTimeout = 300000; /*5 minutes*/ + private long _heartBeatCheckerTimeout = 360000; /*6 minutes*/ public KVMHAChecker(List pools, String host) { this._pools = pools; this._hostIP = host; @@ -50,7 +50,7 @@ public class KVMHAChecker extends KVMHABase implements Callable { cmd.add("-m", pool._mountDestPath); cmd.add("-h", _hostIP); cmd.add("-r"); - cmd.add("-t", String.valueOf(_heartBeatUpdateFreq/1000 * 2)); + cmd.add("-t", String.valueOf((_heartBeatUpdateFreq + _heartBeatUpdateTimeout)/1000 * 2)); OutputInterpreter.OneLineParser parser = new OutputInterpreter.OneLineParser(); String result = cmd.execute(parser); s_logger.debug("pool: " + pool._poolIp);