diff --git a/engine/orchestration/src/com/cloud/agent/manager/AgentManagerImpl.java b/engine/orchestration/src/com/cloud/agent/manager/AgentManagerImpl.java index 31ef8be4b0c..c6664d951ba 100755 --- a/engine/orchestration/src/com/cloud/agent/manager/AgentManagerImpl.java +++ b/engine/orchestration/src/com/cloud/agent/manager/AgentManagerImpl.java @@ -775,7 +775,7 @@ public class AgentManagerImpl extends ManagerBase implements AgentManager, Handl } if (s_logger.isDebugEnabled()) { - s_logger.debug("The next status of agent " + hostId + " is " + nextStatus + ", current status is " + currentStatus); + s_logger.debug("The next status of agent " + hostId + "is " + nextStatus + ", current status is " + currentStatus); } } } @@ -1513,7 +1513,7 @@ public class AgentManagerImpl extends ManagerBase implements AgentManager, Handl || host.getType() == Host.Type.SecondaryStorageCmdExecutor)) { s_logger.warn("Disconnect agent for CPVM/SSVM due to physical connection close. host: " + host.getId()); - disconnectWithoutInvestigation(agentId, Event.PingTimeout); + disconnectWithoutInvestigation(agentId, Event.ShutdownRequested); } else { status_logger.debug("Ping timeout for host " + agentId + ", do invstigation"); disconnectWithInvestigation(agentId, Event.PingTimeout); diff --git a/server/src/com/cloud/consoleproxy/ConsoleProxyManagerImpl.java b/server/src/com/cloud/consoleproxy/ConsoleProxyManagerImpl.java index 825af39e9fe..14d782a47ef 100755 --- a/server/src/com/cloud/consoleproxy/ConsoleProxyManagerImpl.java +++ b/server/src/com/cloud/consoleproxy/ConsoleProxyManagerImpl.java @@ -324,7 +324,6 @@ public class ConsoleProxyManagerImpl extends ManagerBase implements ConsoleProxy final ConsoleProxyVO proxy = _consoleProxyDao.findById(proxyVmId); if (proxy != null) { - stopProxy(proxyVmId); // Disable this feature for now, as it conflicts // with // the case of allowing user to reboot console proxy diff --git a/server/src/com/cloud/storage/secondary/SecondaryStorageListener.java b/server/src/com/cloud/storage/secondary/SecondaryStorageListener.java index 81a42400c29..43613e7f9ca 100755 --- a/server/src/com/cloud/storage/secondary/SecondaryStorageListener.java +++ b/server/src/com/cloud/storage/secondary/SecondaryStorageListener.java @@ -88,7 +88,6 @@ public class SecondaryStorageListener implements Listener { @Override public boolean processDisconnect(long agentId, Status state) { - _ssVmMgr.onAgentDisconnect(agentId, state); return true; } diff --git a/server/src/com/cloud/storage/secondary/SecondaryStorageVmManager.java b/server/src/com/cloud/storage/secondary/SecondaryStorageVmManager.java index f2f5aa080b4..3b32c851f0a 100755 --- a/server/src/com/cloud/storage/secondary/SecondaryStorageVmManager.java +++ b/server/src/com/cloud/storage/secondary/SecondaryStorageVmManager.java @@ -21,7 +21,6 @@ import java.util.List; import com.cloud.agent.api.Command; import com.cloud.agent.api.StartupCommand; import com.cloud.host.HostVO; -import com.cloud.host.Status; import com.cloud.utils.Pair; import com.cloud.utils.component.Manager; import com.cloud.vm.SecondaryStorageVmVO; @@ -46,8 +45,6 @@ public interface SecondaryStorageVmManager extends Manager { public void onAgentConnect(Long dcId, StartupCommand cmd); - public void onAgentDisconnect(long agentId, Status state); - public boolean generateFirewallConfiguration(Long agentId); public boolean generateVMSetupCommand(Long hostId); diff --git a/services/secondary-storage/controller/src/org/apache/cloudstack/secondarystorage/SecondaryStorageManagerImpl.java b/services/secondary-storage/controller/src/org/apache/cloudstack/secondarystorage/SecondaryStorageManagerImpl.java index 045c62283fc..86d94df9e8a 100755 --- a/services/secondary-storage/controller/src/org/apache/cloudstack/secondarystorage/SecondaryStorageManagerImpl.java +++ b/services/secondary-storage/controller/src/org/apache/cloudstack/secondarystorage/SecondaryStorageManagerImpl.java @@ -79,7 +79,6 @@ import com.cloud.exception.StorageUnavailableException; import com.cloud.host.Host; import com.cloud.host.HostVO; import com.cloud.host.Status; -import com.cloud.host.Host.Type; import com.cloud.host.dao.HostDao; import com.cloud.hypervisor.Hypervisor.HypervisorType; import com.cloud.info.RunningHostCountInfo; @@ -1004,20 +1003,6 @@ public class SecondaryStorageManagerImpl extends ManagerBase implements Secondar public void onAgentConnect(Long dcId, StartupCommand cmd) { } - @Override - public void onAgentDisconnect(long agentId, Status state) { - HostVO host = _hostDao.findById(agentId); - if (host == null || !Type.SecondaryStorageVM.equals(host.getType())) { - return; - } - if (state == Status.Alert || state == Status.Disconnected) { - SecondaryStorageVmVO ssvm = getSSVMfromHost(host); - if ( ssvm != null ) { - stopSecStorageVm(ssvm.getId()); - } - } - } - private String getAllocLockName() { // to improve security, it may be better to return a unique mashed // name(for example MD5 hashed)