if storage network disconnected, reboot the host

edisonSu · edisonSu · commit d8ee7d9fc320 · 2011-04-14T17:46:54.000-04:00
diff --git a/agent/src/com/cloud/agent/resource/computing/KVMHAMonitor.java b/agent/src/com/cloud/agent/resource/computing/KVMHAMonitor.java
@@ -75,7 +75,13 @@ public void run() {
 					cmd.add("-h", _hostIP);
 					String result = cmd.execute();
 					if (result != null) {
-						s_logger.debug("write heartbeat failed: " + result);
+						s_logger.debug("write heartbeat failed: " + result + "; destroy all the vms on this host");
+						cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);
+						cmd.add("-i", primaryStoragePool._poolIp);
+						cmd.add("-p", primaryStoragePool._poolMountSourcePath);
+						cmd.add("-m", primaryStoragePool._mountDestPath);
+						cmd.add("-c");
+						result = cmd.execute();
 					}
 				}
 			}
diff --git a/client/tomcatconf/components.xml.in b/client/tomcatconf/components.xml.in
@@ -64,6 +64,7 @@
         <adapters key="com.cloud.ha.Investigator">
             <adapter name="SimpleInvestigator" class="com.cloud.ha.CheckOnAgentInvestigator"/>
             <adapter name="PingInvestigator" class="com.cloud.ha.InvestigatorImpl"/>
+            <adapter name="XenServerInvestigator" class="com.cloud.ha.XenServerInvestigator"/>
         </adapters>
         <adapters key="com.cloud.ha.FenceBuilder">
             <adapter name="XenServerFenceBuilder" class="com.cloud.ha.XenServerFencer"/>
diff --git a/scripts/vm/hypervisor/kvm/kvmheartbeat.sh b/scripts/vm/hypervisor/kvm/kvmheartbeat.sh
@@ -24,6 +24,7 @@ help() {
                     -m mount point 
                     -h host  
                     -r write/read hb log 
+                    -c cleanup
                     -t interval between read hb log\n"
   exit 1
 }
@@ -34,8 +35,9 @@ MountPoint=
 HostIP=
 interval=
 rflag=0
+cflag=0
 
-while getopts 'i:p:m:h:t:r' OPTION
+while getopts 'i:p:m:h:t:rc' OPTION
 do
   case $OPTION in
   i)
@@ -56,6 +58,9 @@ do
   t)
      interval="$OPTARG"
      ;;
+  c)
+    cflag=1
+     ;;
   *)
      help
      ;;
@@ -71,7 +76,7 @@ fi
 #delete VMs on this mountpoint
 deleteVMs() {
   local mountPoint=$1
-  vmPids=$(ps aux| grep qemu | grep $mountPoint* | awk '{print $2}' &> /dev/null) 
+  vmPids=$(ps aux| grep qemu | grep "$mountPoint" | awk '{print $2}' 2> /dev/null) 
   if [ $? -gt 0 ]
   then
      return
@@ -82,7 +87,7 @@ deleteVMs() {
      return
   fi
 
-  for pid in vmPids
+  for pid in $vmPids
   do
      kill -9 $pid &> /dev/null
   done
@@ -149,6 +154,10 @@ then
     echo "=====> DEAD <======"
   fi
   exit 0
+elif [ "$cflag" == "1" ]
+then
+  reboot
+  exit $?
 else
   write_hbLog 
   exit $?

Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,13 @@ public void run() {`
`75`	`75`	`cmd.add("-h", _hostIP);`
`76`	`76`	`String result = cmd.execute();`
`77`	`77`	`if (result != null) {`
`78`		`- s_logger.debug("write heartbeat failed: " + result);`
	`78`	`+ s_logger.debug("write heartbeat failed: " + result + "; destroy all the vms on this host");`
	`79`	`+ cmd = new Script(_heartBeatPath, _heartBeatUpdateTimeout, s_logger);`
	`80`	`+ cmd.add("-i", primaryStoragePool._poolIp);`
	`81`	`+ cmd.add("-p", primaryStoragePool._poolMountSourcePath);`
	`82`	`+ cmd.add("-m", primaryStoragePool._mountDestPath);`
	`83`	`+ cmd.add("-c");`
	`84`	`+ result = cmd.execute();`
`79`	`85`	`}`
`80`	`86`	`}`
`81`	`87`	`}`