Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
MID-2353 - errors count column for task list. doesn't work for partit…
…ioned tasks yet.
- Loading branch information
Showing
4 changed files
with
172 additions
and
111 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
200 changes: 120 additions & 80 deletions
200
infra/schema/src/main/java/com/evolveum/midpoint/schema/util/TaskTypeUtil.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,80 +1,120 @@ | ||
| /* | ||
| * Copyright (c) 2010-2018 Evolveum and contributors | ||
| * | ||
| * This work is dual-licensed under the Apache License 2.0 | ||
| * and European Union Public License. See LICENSE file for details. | ||
| */ | ||
|
|
||
| package com.evolveum.midpoint.schema.util; | ||
|
|
||
| import com.evolveum.midpoint.prism.PrismContext; | ||
| import com.evolveum.midpoint.prism.PrismObject; | ||
| import com.evolveum.midpoint.xml.ns._public.common.common_3.*; | ||
|
|
||
| import org.jetbrains.annotations.NotNull; | ||
|
|
||
| import java.util.*; | ||
| import java.util.stream.Stream; | ||
|
|
||
| /** | ||
| * @author mederly | ||
| */ | ||
| public class TaskTypeUtil { | ||
|
|
||
| /** | ||
| * Returns a stream of the task and all of its subtasks. | ||
| */ | ||
| @NotNull | ||
| public static Stream<TaskType> getAllTasksStream(TaskType root) { | ||
| return Stream.concat(Stream.of(root), | ||
| getResolvedSubtasks(root).stream().flatMap(TaskTypeUtil::getAllTasksStream)); | ||
| } | ||
|
|
||
| public static List<TaskType> getResolvedSubtasks(TaskType parent) { | ||
| List<TaskType> rv = new ArrayList<>(); | ||
| for (ObjectReferenceType childRef : parent.getSubtaskRef()) { | ||
| //noinspection unchecked | ||
| PrismObject<TaskType> child = childRef.getObject(); | ||
| if (child != null) { | ||
| rv.add(child.asObjectable()); | ||
| } else { | ||
| throw new IllegalStateException("Unresolved subtaskRef in " + parent + ": " + childRef); | ||
| } | ||
| } | ||
| return rv; | ||
| } | ||
|
|
||
| public static void addSubtask(TaskType parent, TaskType child, PrismContext prismContext) { | ||
| parent.getSubtaskRef().add(ObjectTypeUtil.createObjectRefWithFullObject(child, prismContext)); | ||
| } | ||
|
|
||
| //moved from GUI | ||
| public static boolean isCoordinator(TaskType task) { | ||
| return getKind(task) == TaskKindType.COORDINATOR; | ||
| } | ||
|
|
||
| public static boolean isPartitionedMaster(TaskType task) { | ||
| return getKind(task) == TaskKindType.PARTITIONED_MASTER; | ||
| } | ||
|
|
||
| @NotNull | ||
| public static TaskKindType getKind(TaskType task) { | ||
| if (task.getWorkManagement() != null && task.getWorkManagement().getTaskKind() != null) { | ||
| return task.getWorkManagement().getTaskKind(); | ||
| } else { | ||
| return TaskKindType.STANDALONE; | ||
| } | ||
| } | ||
|
|
||
| public static int getObjectsProcessed(TaskType task) { | ||
| OperationStatsType stats = task.getOperationStats(); | ||
| if (stats == null) { | ||
| return 0; | ||
| } | ||
| IterativeTaskInformationType iterativeStats = stats.getIterativeTaskInformation(); | ||
| if (iterativeStats == null) { | ||
| return 0; | ||
| } | ||
| return iterativeStats.getTotalSuccessCount() + iterativeStats.getTotalFailureCount(); | ||
| } | ||
| } | ||
| /* | ||
| * Copyright (c) 2010-2018 Evolveum and contributors | ||
| * | ||
| * This work is dual-licensed under the Apache License 2.0 | ||
| * and European Union Public License. See LICENSE file for details. | ||
| */ | ||
|
|
||
| package com.evolveum.midpoint.schema.util; | ||
|
|
||
| import com.evolveum.midpoint.prism.PrismContext; | ||
| import com.evolveum.midpoint.prism.PrismObject; | ||
| import com.evolveum.midpoint.schema.statistics.ActionsExecutedInformation; | ||
| import com.evolveum.midpoint.schema.statistics.IterativeTaskInformation; | ||
| import com.evolveum.midpoint.schema.statistics.SynchronizationInformation; | ||
| import com.evolveum.midpoint.xml.ns._public.common.common_3.*; | ||
|
|
||
| import org.jetbrains.annotations.NotNull; | ||
|
|
||
| import java.util.*; | ||
| import java.util.stream.Stream; | ||
|
|
||
| /** | ||
| * @author mederly | ||
| */ | ||
| public class TaskTypeUtil { | ||
|
|
||
| /** | ||
| * Returns a stream of the task and all of its subtasks. | ||
| */ | ||
| @NotNull | ||
| public static Stream<TaskType> getAllTasksStream(TaskType root) { | ||
| return Stream.concat(Stream.of(root), | ||
| getResolvedSubtasks(root).stream().flatMap(TaskTypeUtil::getAllTasksStream)); | ||
| } | ||
|
|
||
| public static List<TaskType> getResolvedSubtasks(TaskType parent) { | ||
| List<TaskType> rv = new ArrayList<>(); | ||
| for (ObjectReferenceType childRef : parent.getSubtaskRef()) { | ||
| //noinspection unchecked | ||
| PrismObject<TaskType> child = childRef.getObject(); | ||
| if (child != null) { | ||
| rv.add(child.asObjectable()); | ||
| } else { | ||
| throw new IllegalStateException("Unresolved subtaskRef in " + parent + ": " + childRef); | ||
| } | ||
| } | ||
| return rv; | ||
| } | ||
|
|
||
| public static void addSubtask(TaskType parent, TaskType child, PrismContext prismContext) { | ||
| parent.getSubtaskRef().add(ObjectTypeUtil.createObjectRefWithFullObject(child, prismContext)); | ||
| } | ||
|
|
||
| //moved from GUI | ||
| public static boolean isCoordinator(TaskType task) { | ||
| return getKind(task) == TaskKindType.COORDINATOR; | ||
| } | ||
|
|
||
| public static boolean isPartitionedMaster(TaskType task) { | ||
| return getKind(task) == TaskKindType.PARTITIONED_MASTER; | ||
| } | ||
|
|
||
| @NotNull | ||
| public static TaskKindType getKind(TaskType task) { | ||
| if (task.getWorkManagement() != null && task.getWorkManagement().getTaskKind() != null) { | ||
| return task.getWorkManagement().getTaskKind(); | ||
| } else { | ||
| return TaskKindType.STANDALONE; | ||
| } | ||
| } | ||
|
|
||
| public static int getObjectsProcessed(TaskType task) { | ||
| OperationStatsType stats = task.getOperationStats(); | ||
| if (stats == null) { | ||
| return 0; | ||
| } | ||
| IterativeTaskInformationType iterativeStats = stats.getIterativeTaskInformation(); | ||
| if (iterativeStats == null) { | ||
| return 0; | ||
| } | ||
| return iterativeStats.getTotalSuccessCount() + iterativeStats.getTotalFailureCount(); | ||
| } | ||
|
|
||
| public static int getObjectsProcessedFailures(TaskType task, PrismContext prismContext) { | ||
| OperationStatsType stats = getAggregatedOperationStats(task, prismContext); | ||
| if (stats == null) { | ||
| return 0; | ||
| } | ||
| IterativeTaskInformationType iterativeStats = stats.getIterativeTaskInformation(); | ||
| if (iterativeStats == null) { | ||
| return 0; | ||
| } | ||
| return iterativeStats.getTotalFailureCount(); | ||
| } | ||
|
|
||
| public static OperationStatsType getAggregatedOperationStats(TaskType task, PrismContext prismContext) { | ||
| if (!isPartitionedMaster(task)) { | ||
| return task.getOperationStats(); | ||
| } | ||
|
|
||
| IterativeTaskInformationType iterativeTaskInformation = new IterativeTaskInformationType(); | ||
| SynchronizationInformationType synchronizationInformation = new SynchronizationInformationType(); | ||
| ActionsExecutedInformationType actionsExecutedInformation = new ActionsExecutedInformationType(); | ||
|
|
||
| Stream<TaskType> subTasks = TaskTypeUtil.getAllTasksStream(task); | ||
| subTasks.forEach(subTask -> { | ||
| OperationStatsType operationStatsType = subTask.getOperationStats(); | ||
| if (operationStatsType != null) { | ||
| IterativeTaskInformation.addTo(iterativeTaskInformation, operationStatsType.getIterativeTaskInformation(), true); | ||
| SynchronizationInformation.addTo(synchronizationInformation, operationStatsType.getSynchronizationInformation()); | ||
| ActionsExecutedInformation.addTo(actionsExecutedInformation, operationStatsType.getActionsExecutedInformation()); | ||
| } | ||
| }); | ||
|
|
||
| return new OperationStatsType(prismContext) | ||
| .iterativeTaskInformation(iterativeTaskInformation) | ||
| .synchronizationInformation(synchronizationInformation) | ||
| .actionsExecutedInformation(actionsExecutedInformation); | ||
| } | ||
| } |