apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-12-17 19:14:40 +01:00
Code Issues Packages Projects Releases Wiki Activity

Remove CLOUDSTACK-3513 debugging messages.

Browse Source
This commit is contained in:
Min Chen 2013-07-22 16:15:20 -07:00
parent 0fb3286cb1
commit db8b9ea53a
3 changed files with 3 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
engine/storage/src/org/apache/cloudstack/storage/endpoint/DefaultEndPointSelector.java
View File

@ -191,6 +191,7 @@ public class DefaultEndPointSelector implements EndPointSelector {
// we can arbitrarily pick one ssvm to do that task // we can arbitrarily pick one ssvm to do that task
List<HostVO> ssAHosts = listUpAndConnectingSecondaryStorageVmHost(dcId); List<HostVO> ssAHosts = listUpAndConnectingSecondaryStorageVmHost(dcId);
if (ssAHosts == null || ssAHosts.isEmpty()) { 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 return LocalHostEndpoint.getEndpoint(); // use local host as endpoint in
// case of no ssvm existing // case of no ssvm existing
} }

12
server/src/com/cloud/agent/manager/AgentAttache.java
View File

@ -337,26 +337,14 @@ public abstract class AgentAttache {
checkAvailability(req.getCommands()); checkAvailability(req.getCommands());
long seq = req.getSequence(); long seq = req.getSequence();
if (s_logger.isDebugEnabled()) {
s_logger.debug("Request seq: " + seq);
}
if (listener != null) { if (listener != null) {
registerListener(seq, listener); registerListener(seq, listener);
} else if (s_logger.isDebugEnabled()) { } else if (s_logger.isDebugEnabled()) {
s_logger.debug(log(seq, "Routed from " + req.getManagementServerId())); s_logger.debug(log(seq, "Routed from " + req.getManagementServerId()));
} }
if (s_logger.isDebugEnabled()) {
s_logger.debug("waiting to send " + seq);
}
synchronized(this) { synchronized(this) {
try { try {
if (s_logger.isDebugEnabled()) {
s_logger.debug("entering synchronize block for sending " + seq);
}
if (isClosed()) { if (isClosed()) {
throw new AgentUnavailableException("The link to the agent has been closed", _id); throw new AgentUnavailableException("The link to the agent has been closed", _id);
} }

4
server/src/com/cloud/agent/manager/AgentManagerImpl.java
View File

@ -538,9 +538,7 @@ public class AgentManagerImpl extends ManagerBase implements AgentManager, Handl
} }
Request req = new Request(hostId, _nodeId, cmds, commands.stopOnError(), true); Request req = new Request(hostId, _nodeId, cmds, commands.stopOnError(), true);
req.setSequence(agent.getNextSequence()); req.setSequence(agent.getNextSequence());
if (s_logger.isDebugEnabled()) {
s_logger.debug("AgentManager sending request");
}
agent.send(req, listener); agent.send(req, listener);
return req.getSequence(); return req.getSequence();
} }