diff --git a/server/src/com/cloud/agent/manager/AgentManagerImpl.java b/server/src/com/cloud/agent/manager/AgentManagerImpl.java index 2b491fbfa34..24c772bb750 100755 --- a/server/src/com/cloud/agent/manager/AgentManagerImpl.java +++ b/server/src/com/cloud/agent/manager/AgentManagerImpl.java @@ -721,6 +721,9 @@ public class AgentManagerImpl implements AgentManager, HandlerFactory, Manager { if (upasscmd.getClusterId() == null) { //update agent attache password AgentAttache agent = this.findAttache(upasscmd.getHostId()); + if (!(agent instanceof DirectAgentAttache)) { + return false; + } UpdateHostPasswordCommand cmd = new UpdateHostPasswordCommand(upasscmd.getUsername(), upasscmd.getPassword()); agent.updatePassword(cmd); } @@ -729,6 +732,9 @@ public class AgentManagerImpl implements AgentManager, HandlerFactory, Manager { List hosts = _hostDao.listByCluster(upasscmd.getClusterId()); for (HostVO h : hosts) { AgentAttache agent = this.findAttache(h.getId()); + if (!(agent instanceof DirectAgentAttache)) { + continue; + } UpdateHostPasswordCommand cmd = new UpdateHostPasswordCommand(upasscmd.getUsername(), upasscmd.getPassword()); agent.updatePassword(cmd); } diff --git a/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java b/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java index 2aa192ec626..91edfc2fb21 100644 --- a/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java +++ b/server/src/com/cloud/agent/manager/ClusteredAgentManagerImpl.java @@ -325,6 +325,9 @@ public class ClusteredAgentManagerImpl extends AgentManagerImpl implements Clust //update agent attache password try { Boolean result = _clusterMgr.propagateAgentEvent(upasscmd.getHostId(), Event.UpdatePassword); + if (result != null) { + return result; + } } catch (AgentUnavailableException e) { } } @@ -334,6 +337,9 @@ public class ClusteredAgentManagerImpl extends AgentManagerImpl implements Clust for (HostVO h : hosts) { try { Boolean result = _clusterMgr.propagateAgentEvent(h.getId(), Event.UpdatePassword); + if (result != null) { + return result; + } } catch (AgentUnavailableException e) { } }