Skip to content

Commit 06b0504

Browse files
committed
Update method to findOneInUpStateByLongestRuntime
1 parent f1e91c4 commit 06b0504

File tree

6 files changed

+6
-6
lines changed

6 files changed

+6
-6
lines changed

framework/cluster/src/main/java/com/cloud/cluster/dao/ManagementServerHostDao.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,5 +56,5 @@ public interface ManagementServerHostDao extends GenericDao<ManagementServerHost
5656

5757
ManagementServerHostVO findOneInUpState(Filter filter);
5858

59-
ManagementServerHostVO findOneByLongestRuntime();
59+
ManagementServerHostVO findOneInUpStateByLongestRuntime();
6060
}

framework/cluster/src/main/java/com/cloud/cluster/dao/ManagementServerHostDaoImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ public ManagementServerHostVO findOneInUpState(Filter filter) {
273273
}
274274

275275
@Override
276-
public ManagementServerHostVO findOneByLongestRuntime() {
276+
public ManagementServerHostVO findOneInUpStateByLongestRuntime() {
277277
SearchCriteria<ManagementServerHostVO> sc = StateSearch.create();
278278
sc.setParameters("state", ManagementServerHost.State.Up);
279279
sc.setParameters("runid", 0);

plugins/event-bus/webhook/src/main/java/org/apache/cloudstack/mom/webhook/WebhookServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,7 @@ public class WebhookDeliveryCleanupWorker extends ManagedContextRunnable {
319319

320320
protected void runCleanupForLongestRunningManagementServer() {
321321
try {
322-
ManagementServerHostVO msHost = managementServerHostDao.findOneByLongestRuntime();
322+
ManagementServerHostVO msHost = managementServerHostDao.findOneInUpStateByLongestRuntime();
323323
if (msHost == null || (msHost.getMsid() != ManagementServerNode.getManagementServerId())) {
324324
logger.debug("Skipping the webhook delivery cleanup task on this management server");
325325
return;

server/src/main/java/com/cloud/resourcelimit/ResourceLimitManagerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2152,7 +2152,7 @@ protected void runInContext() {
21522152
try {
21532153
if (lock.lock(30)) {
21542154
try {
2155-
ManagementServerHostVO msHost = managementServerHostDao.findOneByLongestRuntime();
2155+
ManagementServerHostVO msHost = managementServerHostDao.findOneInUpStateByLongestRuntime();
21562156
if (msHost == null || (msHost.getMsid() != ManagementServerNode.getManagementServerId())) {
21572157
logger.trace("Skipping the resource counters recalculation task on this management server");
21582158
return;

server/src/main/java/org/apache/cloudstack/resource/ResourceCleanupServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -629,7 +629,7 @@ protected void runInContext() {
629629
}
630630

631631
protected void runCleanupForLongestRunningManagementServer() {
632-
ManagementServerHostVO msHost = managementServerHostDao.findOneByLongestRuntime();
632+
ManagementServerHostVO msHost = managementServerHostDao.findOneInUpStateByLongestRuntime();
633633
if (msHost == null || (msHost.getMsid() != ManagementServerNode.getManagementServerId())) {
634634
logger.debug("Skipping the expunged resource cleanup task on this management server");
635635
return;

server/src/main/java/org/apache/cloudstack/vm/schedule/VMSchedulerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ public boolean start() {
196196
final TimerTask schedulerPollTask = new ManagedContextTimerTask() {
197197
@Override
198198
protected void runInContext() {
199-
ManagementServerHostVO msHost = managementServerHostDao.findOneByLongestRuntime();
199+
ManagementServerHostVO msHost = managementServerHostDao.findOneInUpStateByLongestRuntime();
200200
if (msHost == null || (msHost.getMsid() != ManagementServerNode.getManagementServerId())) {
201201
logger.debug("Skipping the vm scheduler poll task on this management server");
202202
return;

0 commit comments

Comments
 (0)