[midPoint-git] [Evolveum/midpoint] d9eec1: Refactor and fix task manager module
mederly
noreply at github.com
Mon Feb 22 22:57:07 CET 2021
Branch: refs/heads/feature/task-state-reporting
Home: https://github.com/Evolveum/midpoint
Commit: d9eec15e52af718c81ac84070c4fac5fa87165bd
https://github.com/Evolveum/midpoint/commit/d9eec15e52af718c81ac84070c4fac5fa87165bd
Author: Pavol Mederly <mederly at evolveum.com>
Date: 2021-02-22 (Mon, 22 Feb 2021)
Changed paths:
M infra/schema/src/main/resources/xml/ns/public/common/common-core-3.xsd
M model/model-impl/src/main/java/com/evolveum/midpoint/model/impl/controller/ModelController.java
M model/model-intest/src/test/resources/logback-test.xml
M model/model-test/src/main/java/com/evolveum/midpoint/model/test/AbstractModelIntegrationTest.java
M model/rest-impl/src/main/java/com/evolveum/midpoint/rest/impl/ClusterRestController.java
M model/workflow-impl/src/main/java/com/evolveum/midpoint/wf/impl/util/ChangesSorter.java
M model/workflow-impl/src/test/java/com/evolveum/midpoint/wf/impl/AbstractWfTest.java
M repo/repo-common/src/main/java/com/evolveum/midpoint/repo/common/task/AbstractTaskHandler.java
M repo/repo-common/src/main/java/com/evolveum/midpoint/repo/common/task/ItemProcessingGatekeeper.java
M repo/repo-sql-impl/src/main/java/com/evolveum/midpoint/repo/sql/data/common/RTask.java
A repo/repo-sql-impl/src/main/java/com/evolveum/midpoint/repo/sql/data/common/enums/RTaskExecutionState.java
R repo/repo-sql-impl/src/main/java/com/evolveum/midpoint/repo/sql/data/common/enums/RTaskExecutionStatus.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/Task.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/TaskDebugUtil.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/TaskDeletionListener.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/TaskManager.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/TaskManagerInitializationException.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/TaskUtil.java
M repo/task-api/src/main/java/com/evolveum/midpoint/task/api/test/NullTaskImpl.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/casemgmt/impl/CaseEventDispatcherImpl.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/Initializer.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/InternalTaskInterface.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/LightweightTaskManager.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/LocalNodeState.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/RunningTaskQuartzImpl.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskBeans.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskHandlerRegistry.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskListenerRegistry.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskManagerConfiguration.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskManagerQuartzImpl.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskQuartzImpl.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/TaskQuartzImplUtil.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/UpAndDown.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/cluster/ClusterExecutionHelperImpl.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/cluster/ClusterManager.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/cluster/ClusterStatusInformation.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/cluster/ClusterStatusInformationRetriever.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/cluster/NodeRegistrar.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/ExecutionManager.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/HandlerExecutor.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/JobExecutor.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/JobStarter.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/LocalExecutionManager.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/LocalNodeManager.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/RemoteNodesManager.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/RemoteSchedulers.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/RepositoryConnectionProvider.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/Schedulers.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/StalledTasksWatcher.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/TaskStopper.java
R repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/TaskSynchronizer.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/TaskThreadsDumper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/package-info.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/remote/JmxConnector.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/execution/remote/RestConnector.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/handlers/LightweightPartitioningTaskHandler.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/handlers/PartitioningTaskHandler.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/handlers/WorkersCreationTaskHandler.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/handlers/WorkersRestartTaskHandler.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/nodes/NodeCleaner.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/nodes/NodeRetriever.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/nodes/package-info.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/LocalScheduler.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/NextStartTimes.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/QuartzInitializationHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/QuartzUtil.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/RepositoryConnectionProvider.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/TaskSynchronizer.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/quartz/package-info.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/run/HandlerExecutor.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/run/JobExecutor.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/run/package-info.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/CloseHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/ResumeHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/ScheduleNowHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/SuspendAndDeleteHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/TaskCleaner.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/TaskInstantiator.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/TaskPersister.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/TaskRetriever.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/TaskStateManager.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/UnpauseHelper.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/tasks/package-info.java
A repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/util/TimeBoundary.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/work/WorkStateManager.java
M repo/task-quartz-impl/src/main/java/com/evolveum/midpoint/task/quartzimpl/work/workers/WorkersManager.java
M repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/AbstractTaskManagerTest.java
M repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/MockParallelTaskHandler.java
M repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/TestPartitioning.java
A repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/TestTaskManagerBasic.java
R repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/TestTaskManagerContract.java
M repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/TestWorkDistribution.java
M repo/task-quartz-impl/src/test/java/com/evolveum/midpoint/task/quartzimpl/TestWorkersManagement.java
R repo/task-quartz-impl/src/test/resources/basic/task-003GetProgress.xml
R repo/task-quartz-impl/src/test/resources/basic/task-004TaskBigProperty.xml
R repo/task-quartz-impl/src/test/resources/basic/task-005Single.xml
R repo/task-quartz-impl/src/test/resources/basic/task-006Cycle.xml
R repo/task-quartz-impl/src/test/resources/basic/task-007Extension.xml
R repo/task-quartz-impl/src/test/resources/basic/task-008MoreHandlers.xml
R repo/task-quartz-impl/src/test/resources/basic/task-009CycleLoose.xml
R repo/task-quartz-impl/src/test/resources/basic/task-010CycleCronLoose.xml
R repo/task-quartz-impl/src/test/resources/basic/task-011MoreHandlersAndSchedules.xml
R repo/task-quartz-impl/src/test/resources/basic/task-012Suspend.xml
R repo/task-quartz-impl/src/test/resources/basic/task-013ReleaseAndSuspendLooselyBound.xml
R repo/task-quartz-impl/src/test/resources/basic/task-014SuspendLongRunning.xml
R repo/task-quartz-impl/src/test/resources/basic/task-015DeleteTaskFromRepo.xml
R repo/task-quartz-impl/src/test/resources/basic/task-016WaitForSubtasks-child-1.xml
R repo/task-quartz-impl/src/test/resources/basic/task-016WaitForSubtasks-prerequisite-1.xml
R repo/task-quartz-impl/src/test/resources/basic/task-016WaitForSubtasks.xml
R repo/task-quartz-impl/src/test/resources/basic/task-017WaitForSubtasksEmpty.xml
R repo/task-quartz-impl/src/test/resources/basic/task-019FinishedHandler.xml
R repo/task-quartz-impl/src/test/resources/basic/task-020QueryByExecutionStatus.xml
R repo/task-quartz-impl/src/test/resources/basic/task-021DeleteTaskTree-child1.xml
R repo/task-quartz-impl/src/test/resources/basic/task-021DeleteTaskTree-child2.xml
R repo/task-quartz-impl/src/test/resources/basic/task-021DeleteTaskTree.xml
R repo/task-quartz-impl/src/test/resources/basic/task-022ExecuteRecurringOnDemand.xml
R repo/task-quartz-impl/src/test/resources/basic/task-100LightweightSubtasks.xml
R repo/task-quartz-impl/src/test/resources/basic/task-105LightweightSubtasksSuspension.xml
R repo/task-quartz-impl/src/test/resources/basic/task-108SecondaryGroupLimit-2.xml
R repo/task-quartz-impl/src/test/resources/basic/task-108SecondaryGroupLimit-3.xml
R repo/task-quartz-impl/src/test/resources/basic/task-108SecondaryGroupLimit.xml
R repo/task-quartz-impl/src/test/resources/basic/task-110GroupLimit-2.xml
R repo/task-quartz-impl/src/test/resources/basic/task-110GroupLimit.xml
R repo/task-quartz-impl/src/test/resources/basic/task-120NodeAllowed.xml
R repo/task-quartz-impl/src/test/resources/basic/task-130NodeNotAllowed.xml
R repo/task-quartz-impl/src/test/resources/basic/task-200RetrieveSubtasks-child-1-1.xml
R repo/task-quartz-impl/src/test/resources/basic/task-200RetrieveSubtasks-child-1.xml
R repo/task-quartz-impl/src/test/resources/basic/task-200RetrieveSubtasks-child-2.xml
R repo/task-quartz-impl/src/test/resources/basic/task-200RetrieveSubtasks.xml
A repo/task-quartz-impl/src/test/resources/basic/task-allowed-not.xml
A repo/task-quartz-impl/src/test/resources/basic/task-allowed.xml
A repo/task-quartz-impl/src/test/resources/basic/task-cycle-loose-cron.xml
A repo/task-quartz-impl/src/test/resources/basic/task-cycle-loose.xml
A repo/task-quartz-impl/src/test/resources/basic/task-cycle-tight.xml
A repo/task-quartz-impl/src/test/resources/basic/task-for-extension-test.xml
A repo/task-quartz-impl/src/test/resources/basic/task-group-limit-concurrent.xml
A repo/task-quartz-impl/src/test/resources/basic/task-group-limit.xml
A repo/task-quartz-impl/src/test/resources/basic/task-long-running.xml
A repo/task-quartz-impl/src/test/resources/basic/task-run-on-demand.xml
A repo/task-quartz-impl/src/test/resources/basic/task-sec-group-limit-exp-1-ram-1.xml
A repo/task-quartz-impl/src/test/resources/basic/task-sec-group-limit-exp-1.xml
A repo/task-quartz-impl/src/test/resources/basic/task-sec-group-limit-ram-null.xml
A repo/task-quartz-impl/src/test/resources/basic/task-simple-waiting.xml
A repo/task-quartz-impl/src/test/resources/basic/task-single-run.xml
A repo/task-quartz-impl/src/test/resources/basic/task-suspended-tree-child-1-1.xml
A repo/task-quartz-impl/src/test/resources/basic/task-suspended-tree-child-1.xml
A repo/task-quartz-impl/src/test/resources/basic/task-suspended-tree-child-2.xml
A repo/task-quartz-impl/src/test/resources/basic/task-suspended-tree-root.xml
A repo/task-quartz-impl/src/test/resources/basic/task-to-delete.xml
A repo/task-quartz-impl/src/test/resources/basic/task-to-resume-and-suspend.xml
A repo/task-quartz-impl/src/test/resources/basic/task-to-suspend.xml
A repo/task-quartz-impl/src/test/resources/basic/task-tree-child-1.xml
A repo/task-quartz-impl/src/test/resources/basic/task-tree-child-2.xml
A repo/task-quartz-impl/src/test/resources/basic/task-tree-root.xml
A repo/task-quartz-impl/src/test/resources/basic/task-waiting-for-no-one.xml
A repo/task-quartz-impl/src/test/resources/basic/task-with-threads-to-suspend.xml
A repo/task-quartz-impl/src/test/resources/basic/task-with-threads.xml
A repo/task-quartz-impl/src/test/resources/basic/task-without-progress.xml
M repo/task-quartz-impl/testng-integration.xml
Log Message:
-----------
Refactor and fix task manager module
Task manager is now refactored into more manageable chunks and its
module tests pass. (This is a work still in progress.)
State of multi-node tasks is now correctly reported (MID-6783).
More information about the midPoint-svn
mailing list