etan39
/
cloudstack
mirror of https://github.com/apache/cloudstack.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

try 5 times if write heartbeat failed

This commit is contained in:
Edison Su 2011-06-17 17:37:27 -04:00
parent 36ee97334b
commit 5483bc21de
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
agent/src/com/cloud/agent/resource/computing/KVMHAMonitor.java
View File

@ -67,16 +67,24 @@ public class KVMHAMonitor extends KVMHABase implements Runnable{
public void run() {
synchronized (_storagePool) {
for (NfsStoragePool primaryStoragePool : _storagePool.values()) {
String result = null;
for (int i = 0; i < 5; i++) {
Script cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);
cmd.add("-i", primaryStoragePool._poolIp);
cmd.add("-p", primaryStoragePool._poolMountSourcePath);
cmd.add("-m", primaryStoragePool._mountDestPath);
cmd.add("-h", _hostIP);
result = cmd.execute();
if (result != null) {
s_logger.debug("write heartbeat failed: " + result + ", retry: " + i);
} else {
break;
}
}
Script cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);
cmd.add("-i", primaryStoragePool._poolIp);
cmd.add("-p", primaryStoragePool._poolMountSourcePath);
cmd.add("-m", primaryStoragePool._mountDestPath);
cmd.add("-h", _hostIP);
String result = cmd.execute();
if (result != null) {
s_logger.debug("write heartbeat failed: " + result + "; destroy all the vms on this host");
cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);
s_logger.debug("write heartbeat failed: " + result + "; reboot the host");
Script cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);
cmd.add("-i", primaryStoragePool._poolIp);
cmd.add("-p", primaryStoragePool._poolMountSourcePath);
cmd.add("-m", primaryStoragePool._mountDestPath);