Package com.evolveum.midpoint.model.impl.sync.tasks.recon

Class PartialReconciliationActivityRun

java.lang.Object

com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun<WD,AH,BS>

com.evolveum.midpoint.repo.common.activity.run.LocalActivityRun<WD,AH,WS>

com.evolveum.midpoint.repo.common.activity.run.IterativeActivityRun<C,WD,AH,WS>

com.evolveum.midpoint.repo.common.activity.run.SearchBasedActivityRun<ShadowType,ReconciliationWorkDefinition,ReconciliationActivityHandler,ReconciliationWorkStateType>

com.evolveum.midpoint.model.impl.sync.tasks.recon.PartialReconciliationActivityRun

All Implemented Interfaces:

ImplicitSegmentationResolver, IterativeActivityRunSpecifics, SearchBasedActivityRunSpecifics<ShadowType>, ExecutionSupport, DebugDumpable

Direct Known Subclasses:

ResourceObjectsReconciliationActivityRun

public abstract class PartialReconciliationActivityRun
extends SearchBasedActivityRun<ShadowType,ReconciliationWorkDefinition,ReconciliationActivityHandler,ReconciliationWorkStateType>

Code common to all three reconciliation sub-activities: operation completion, resource reconciliation, and remaining shadows reconciliation.

Nested Class Summary

Nested classes/interfaces inherited from interface com.evolveum.midpoint.task.api.ExecutionSupport

ExecutionSupport.CountersGroup

Field Summary

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.SearchBasedActivityRun

searchSpecification

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.IterativeActivityRun

beans, bucket, coordinator, errorState, transientRunStatistics

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun

activity, activityState, activityStateDefinition, endTimestamp, reportingCharacteristics, startTimestamp, taskRun

Fields inherited from interface com.evolveum.midpoint.util.DebugDumpable

INDENT_STRING

Method Summary

Modifier and Type	Method	Description
void	beforeRun(OperationResult result)	Called before the run.
protected @NotNull ObjectReferenceType	getDesiredTaskObjectRef()	Returns the value that should be put into task.objectRef.
protected @NotNull ModelBeans	getModelBeans()
protected @NotNull ResourceObjectSetType	getResourceObjectSet()
ActivityState	useOtherActivityStateForCounters(@NotNull OperationResult result)	Should we use activity state other than the state of the current activity when keeping the counters (e.g.

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.SearchBasedActivityRun

countObjects, determineCurrentBucketSize, determineOverallSize, getDefaultErrorAction, getExpressionProfile, getItemType, getQuery, getSchemaService, getSearchOptions, getSearchSpecificationRequired, getTaskManager, isInRepository, iterateOverItemsInBucket, prepareItemSourceForCurrentBucket, processError, processItem

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.IterativeActivityRun

canUpdateThreadLocalStatistics, determineActivityStateForCounters, disableGlobalConnIdOperationsListener, enableGlobalConnIdOperationsListener, ensureNoWorkerThreads, getBucket, getChannelOverride, getConnIdOperationsReport, getContextDescription, getContextDescriptionSpaced, getErrorState, getItemsReport, getRootTask, getRootTaskOid, getShortName, getShortNameUncapitalized, getStartTimeMillis, getTransientRunStatistics, handleError, isMultithreaded, runLocally, setContextDescription, shouldReportConnIdOperations, shouldReportInternalOperations, shouldReportItems, updateStatistics

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.LocalActivityRun

createReportingCharacteristics, getCurrentResultStatus, getCurrentResultStatusBean, isExcludedFromStalenessChecking, runInternal, setCurrentResultStatus, shouldUpdateProgressInStateOverview, updateItemProgressInTreeOverviewIfTimePassed

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun

areActionsExecutedStatisticsSupported, areRunRecordsSupported, areStatisticsSupported, areSynchronizationStatisticsSupported, autoComputeRunResult, canRun, debugDump, debugDumpExtra, determineActivityStateDefinition, getActivity, getActivityDefinition, getActivityHandler, getActivityLocalPath, getActivityPath, getActivityState, getActivityStateDefinition, getBeans, getDiagName, getEndTimestamp, getExecutionMode, getItemsProcessed, getLocalParentRun, getPersistenceType, getPrismContext, getReportingCharacteristics, getReportingDefinition, getRunningTask, getStartTimestamp, getStartTimestampRequired, getTaskRun, getTreeStateOverview, getWorkDefinition, getWorkStateTypeName, incrementCounters, incrementProgress, isBucketAnalysis, isDryRun, isFullExecution, isNoExecution, isNonScavengingWorker, isPreview, isProgressSupported, isWorker, recordIterativeOperationStart, run, setInstanceReady, shouldCreateWorkStateOnInitialization, standardRunResult, standardRunResult, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.evolveum.midpoint.util.DebugDumpable

debugDump, debugDumpLazily, debugDumpLazily

Methods inherited from interface com.evolveum.midpoint.task.api.ExecutionSupport

getActivityPath, getExecutionMode, incrementCounters, recordIterativeOperationStart

Methods inherited from interface com.evolveum.midpoint.repo.common.activity.run.IterativeActivityRunSpecifics

afterBucketProcessing, afterRun, beforeBucketProcessing, createReportingCharacteristics, resolveImplicitSegmentation

Methods inherited from interface com.evolveum.midpoint.repo.common.activity.run.SearchBasedActivityRunSpecifics

createCustomSearchSpecification, createItemDefinitionProvider, customizeQuery, customizeSearchOptions, doesRequireDirectRepositoryAccess, processItem

Method Detail

beforeRun

public void beforeRun(OperationResult result)
               throws CommonException,
                      ActivityRunException

Description copied from interface: IterativeActivityRunSpecifics

Called before the run. Note that e.g. for search-based activities the search specification is *not* known at this moment.

Throws:

CommonException

ActivityRunException

getDesiredTaskObjectRef

@NotNull
protected @NotNull ObjectReferenceType getDesiredTaskObjectRef()

Description copied from class: LocalActivityRun

Returns the value that should be put into task.objectRef. Should be overridden by subclasses. It should be called _after_ IterativeActivityRunSpecifics.beforeRun(OperationResult) method, in order to give the execution a chance to prepare data for this method.

Overrides:

getDesiredTaskObjectRef in class LocalActivityRun<ReconciliationWorkDefinition,ReconciliationActivityHandler,ReconciliationWorkStateType>

getResourceObjectSet

@NotNull
protected @NotNull ResourceObjectSetType getResourceObjectSet()

useOtherActivityStateForCounters

public ActivityState useOtherActivityStateForCounters(@NotNull
                                                      @NotNull OperationResult result)
                                               throws SchemaException,
                                                      ObjectNotFoundException

Description copied from interface: IterativeActivityRunSpecifics

Should we use activity state other than the state of the current activity when keeping the counters (e.g. for thresholds)?

Throws:

SchemaException

ObjectNotFoundException

getModelBeans

@NotNull
protected @NotNull ModelBeans getModelBeans()