Skip to content

Commit 4c5f10c

Browse files
fixes
1 parent 58066b3 commit 4c5f10c

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

engine/orchestration/src/main/java/com/cloud/agent/manager/AgentManagerImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -675,6 +675,7 @@ protected AgentAttache notifyMonitorsOfConnection(final AgentAttache attache, fi
675675
public boolean start() {
676676
ManagementServerHostVO msHost = _mshostDao.findByMsid(_nodeId);
677677
if (msHost != null && (ManagementServerHost.State.Maintenance.equals(msHost.getState()) || ManagementServerHost.State.PreparingForMaintenance.equals(msHost.getState()))) {
678+
_monitorExecutor.shutdownNow();
678679
return true;
679680
}
680681

engine/orchestration/src/main/java/com/cloud/agent/manager/ClusteredAgentManagerImpl.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,13 @@ public boolean start() {
184184
_timer.schedule(new DirectAgentScanTimerTask(), STARTUP_DELAY, ScanInterval.value());
185185
logger.debug("Scheduled direct agent scan task to run at an interval of {} seconds", ScanInterval.value());
186186

187+
ManagementServerHostVO msHost = _mshostDao.findByMsid(_nodeId);
188+
if (msHost != null && (ManagementServerHost.State.Maintenance.equals(msHost.getState()) || ManagementServerHost.State.PreparingForMaintenance.equals(msHost.getState()))) {
189+
s_transferExecutor.shutdownNow();
190+
cleanupTransferMap(_nodeId);
191+
return true;
192+
}
193+
187194
// Schedule tasks for agent rebalancing
188195
if (isAgentRebalanceEnabled()) {
189196
cleanupTransferMap(_nodeId);

0 commit comments

Comments
 (0)