diff --git a/engine/storage/src/org/apache/cloudstack/storage/endpoint/DefaultEndPointSelector.java b/engine/storage/src/org/apache/cloudstack/storage/endpoint/DefaultEndPointSelector.java index bbd6b6e12d1..c3f52ffcf29 100644 --- a/engine/storage/src/org/apache/cloudstack/storage/endpoint/DefaultEndPointSelector.java +++ b/engine/storage/src/org/apache/cloudstack/storage/endpoint/DefaultEndPointSelector.java @@ -191,8 +191,9 @@ public class DefaultEndPointSelector implements EndPointSelector { // we can arbitrarily pick one ssvm to do that task List ssAHosts = listUpAndConnectingSecondaryStorageVmHost(dcId); if (ssAHosts == null || ssAHosts.isEmpty()) { + s_logger.info("No running ssvm is found, so command will be sent to LocalHostEndPoint"); return LocalHostEndpoint.getEndpoint(); // use local host as endpoint in - // case of no ssvm existing + // case of no ssvm existing } Collections.shuffle(ssAHosts); HostVO host = ssAHosts.get(0); diff --git a/server/src/com/cloud/agent/manager/AgentAttache.java b/server/src/com/cloud/agent/manager/AgentAttache.java index 2cedc4d474f..92ce17bc6d3 100755 --- a/server/src/com/cloud/agent/manager/AgentAttache.java +++ b/server/src/com/cloud/agent/manager/AgentAttache.java @@ -337,26 +337,14 @@ public abstract class AgentAttache { checkAvailability(req.getCommands()); long seq = req.getSequence(); - if (s_logger.isDebugEnabled()) { - s_logger.debug("Request seq: " + seq); - } - if (listener != null) { registerListener(seq, listener); } else if (s_logger.isDebugEnabled()) { s_logger.debug(log(seq, "Routed from " + req.getManagementServerId())); } - if (s_logger.isDebugEnabled()) { - s_logger.debug("waiting to send " + seq); - } - synchronized(this) { try { - if (s_logger.isDebugEnabled()) { - s_logger.debug("entering synchronize block for sending " + seq); - } - if (isClosed()) { throw new AgentUnavailableException("The link to the agent has been closed", _id); } diff --git a/server/src/com/cloud/agent/manager/AgentManagerImpl.java b/server/src/com/cloud/agent/manager/AgentManagerImpl.java index edc0d9d4c5c..46b864485fe 100755 --- a/server/src/com/cloud/agent/manager/AgentManagerImpl.java +++ b/server/src/com/cloud/agent/manager/AgentManagerImpl.java @@ -538,9 +538,7 @@ public class AgentManagerImpl extends ManagerBase implements AgentManager, Handl } Request req = new Request(hostId, _nodeId, cmds, commands.stopOnError(), true); req.setSequence(agent.getNextSequence()); - if (s_logger.isDebugEnabled()) { - s_logger.debug("AgentManager sending request"); - } + agent.send(req, listener); return req.getSequence(); }