apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-11-03 04:12:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

agent: allow not to exit on failure if serverresource has flag

Browse Source 
Signed-off-by: Abhishek Kumar <abhishek.mrt22@gmail.com>
This commit is contained in:
Abhishek Kumar 2024-10-17 19:29:25 +05:30
parent b178946dbf
commit 290f7a944f
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
agent/src/main/java/com/cloud/agent/Agent.java
View File

@ -591,6 +591,14 @@ public class Agent implements HandlerFactory, IAgentControl, AgentStatusUpdater
final StartupAnswer startup = (StartupAnswer)answer;
if (!startup.getResult()) {
s_logger.error("Not allowed to connect to the server: " + answer.getDetails());
if (_resource != null && !_resource.isExitOnFailures()) {
if (s_logger.isTraceEnabled()) {
s_logger.trace(String.format("%s does not allow exit on failure, reconnecting",
_resource.getClass().getSimpleName()));
}
reconnect(link);
return;
}
System.exit(1);
}
if (cancelled) {
@ -652,6 +660,14 @@ public class Agent implements HandlerFactory, IAgentControl, AgentStatusUpdater
answer = new Answer(cmd, true, null);
} else if (cmd instanceof ReadyCommand && ((ReadyCommand)cmd).getDetails() != null) {
s_logger.debug("Not ready to connect to mgt server: " + ((ReadyCommand)cmd).getDetails());
if (_resource != null && !_resource.isExitOnFailures()) {
if (s_logger.isTraceEnabled()) {
s_logger.trace(String.format("%s does not allow exit on failure, reconnecting",
_resource.getClass().getSimpleName()));
}
reconnect(link);
return;
}
System.exit(1);
return;
} else if (cmd instanceof MaintainCommand) {