diff --git a/agent/src/com/cloud/agent/Agent.java b/agent/src/com/cloud/agent/Agent.java index 993900446a3..3508e881418 100755 --- a/agent/src/com/cloud/agent/Agent.java +++ b/agent/src/com/cloud/agent/Agent.java @@ -582,6 +582,8 @@ public class Agent implements HandlerFactory, IAgentControl { try { task.getLink().send(request.toBytes()); + //if i can send pingcommand out, means the link is ok + setLastPingResponseTime(); } catch (final ClosedChannelException e) { s_logger.warn("Unable to send request: " + request.toString()); } diff --git a/api/src/com/cloud/agent/api/FenceCommand.java b/api/src/com/cloud/agent/api/FenceCommand.java index ffbc01e51aa..8cb53523e37 100644 --- a/api/src/com/cloud/agent/api/FenceCommand.java +++ b/api/src/com/cloud/agent/api/FenceCommand.java @@ -29,12 +29,18 @@ public class FenceCommand extends Command { String vmName; String hostGuid; String hostIp; + boolean inSeq; public FenceCommand(VirtualMachine vm, Host host) { super(); vmName = vm.getInstanceName(); hostGuid = host.getGuid(); hostIp = host.getPrivateIpAddress(); + inSeq = false; + } + + public void setSeq(boolean inseq) { + inSeq = inseq; } public String getVmName() { @@ -51,6 +57,6 @@ public class FenceCommand extends Command { @Override public boolean executeInSequence() { - return false; + return inSeq; } } diff --git a/server/src/com/cloud/ha/KVMFencer.java b/server/src/com/cloud/ha/KVMFencer.java index 9f6804aeda1..50acf5aa7e3 100755 --- a/server/src/com/cloud/ha/KVMFencer.java +++ b/server/src/com/cloud/ha/KVMFencer.java @@ -86,6 +86,7 @@ public class KVMFencer implements FenceBuilder { List hosts = _resourceMgr.listAllHostsInCluster(host.getClusterId()); FenceCommand fence = new FenceCommand(vm, host); + fence.setSeq(true); for (HostVO h : hosts) { if (h.getHypervisorType() == HypervisorType.KVM) {