test/cuba
1
0
Fork 0
mirror of https://gitee.com/jmix/cuba.git synced 2024-12-04 04:07:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

PL-8831 Scheduled tasks don't run on other node of cluster if master has shut down when task was executing

Browse Source
This commit is contained in:
Konstantin Krivopustov 2017-03-30 15:40:46 +04:00
parent c75cf76860
commit 457bc655fb
1 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/core/src/com/haulmont/cuba/core/app/scheduling/DbBasedCoordinator.java
View File

@ -91,20 +91,18 @@ public class DbBasedCoordinator implements Coordinator {
query.setParameter(1, task.getId());
query.setParameter(2, task.getLastStartTime());
List list = query.getResultList();
if (list.isEmpty()) {
// Execution was not registered by some reason, so using timeout value or just return false
if (list.isEmpty() || list.get(0) == null) {
// Execution finish was not registered by some reason, so using timeout value or just return false
boolean result = task.getTimeout() != null && task.getLastStart() + task.getTimeout() <= now;
log.trace(task + ": finished=" + result + " because of timeout");
if (result)
log.trace(task + ": considered finished because of timeout");
else
log.trace(task + ": not finished and not timed out");
return result;
}
Date date = (Date) list.get(0);
if (date == null) {
log.trace(task + ": not finished yet");
return false;
} else {
log.trace(task + ": finished at " + date.getTime());
return true;
}
log.trace(task + ": finished at " + date.getTime());
return true;
}
@Override