Package com.evolveum.midpoint.repo.common.task

Class AbstractSearchIterativeResultHandler<O extends ObjectType>

java.lang.Object

com.evolveum.midpoint.repo.common.task.AbstractSearchIterativeResultHandler<O>

All Implemented Interfaces:

ResultHandler<O>

Direct Known Subclasses:

AbstractScannerResultHandler, ObjectIntegrityCheckResultHandler, ReindexResultHandler, ShadowIntegrityCheckResultHandler, SynchronizeAccountResultHandler

public abstract class AbstractSearchIterativeResultHandler<O extends ObjectType>
extends Object
implements ResultHandler<O>

Author:

semancik

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AbstractSearchIterativeResultHandler.ProcessingRequest

Constructor Summary

Constructors

Constructor	Description
AbstractSearchIterativeResultHandler(RunningTask coordinatorTask, String taskOperationPrefix, String processShortName, String contextDesc, TaskManager taskManager)
AbstractSearchIterativeResultHandler(RunningTask coordinatorTask, String taskOperationPrefix, String processShortName, String contextDesc, TaskPartitionDefinitionType taskStageType, TaskManager taskManager)

Method Summary

Modifier and Type	Method	Description
void	completeProcessing(Task task, OperationResult result)
void	createWorkerThreads(RunningTask coordinatorTask)
Float	getAverageTime()
String	getContextDesc()
Task	getCoordinatorTask()
protected String	getDisplayName(PrismObject<O> object)
long	getErrors()
Throwable	getExceptionEncountered()
protected String	getProcessShortName()
protected String	getProcessShortNameCapitalized()
long	getProgress()
protected TaskPartitionDefinitionType	getStageType()
Float	getWallAverageTime()
protected Integer	getWorkerThreadsCount(Task task)
boolean	handle(PrismObject<O> object, OperationResult parentResult)	Handle a single result.
protected abstract boolean	handleObject(PrismObject<O> object, RunningTask workerTask, OperationResult result)
long	heartbeat()
void	setContextDesc(String contextDesc)
void	setEnableActionsExecutedStatistics(boolean enableActionsExecutedStatistics)
void	setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics)
protected void	setLogErrors(boolean logErrors)
void	setLogObjectProgress(boolean logObjectProgress)
protected void	setRecordIterationStatistics(boolean recordIterationStatistics)
void	setStopOnError(boolean stopOnError)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSearchIterativeResultHandler

public AbstractSearchIterativeResultHandler(RunningTask coordinatorTask,
                                            String taskOperationPrefix,
                                            String processShortName,
                                            String contextDesc,
                                            TaskManager taskManager)

AbstractSearchIterativeResultHandler

public AbstractSearchIterativeResultHandler(RunningTask coordinatorTask,
                                            String taskOperationPrefix,
                                            String processShortName,
                                            String contextDesc,
                                            TaskPartitionDefinitionType taskStageType,
                                            TaskManager taskManager)

Method Detail

getProcessShortName

protected String getProcessShortName()

getProcessShortNameCapitalized

protected String getProcessShortNameCapitalized()

getContextDesc

public String getContextDesc()

setContextDesc

public void setContextDesc(String contextDesc)

getCoordinatorTask

public Task getCoordinatorTask()

setLogObjectProgress

public void setLogObjectProgress(boolean logObjectProgress)

setRecordIterationStatistics

protected void setRecordIterationStatistics(boolean recordIterationStatistics)

setEnableSynchronizationStatistics

public void setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics)

setEnableActionsExecutedStatistics

public void setEnableActionsExecutedStatistics(boolean enableActionsExecutedStatistics)

handle

public boolean handle(PrismObject<O> object,
                      OperationResult parentResult)

Description copied from interface: ResultHandler

Handle a single result.

Specified by:

handle in interface ResultHandler<O extends ObjectType>

Parameters:

object - Resource object to process.

Returns:

true if the operation should proceed, false if it should stop

getAverageTime

public Float getAverageTime()

getWallAverageTime

public Float getWallAverageTime()

completeProcessing

public void completeProcessing(Task task,
                               OperationResult result)

getExceptionEncountered

public Throwable getExceptionEncountered()

getDisplayName

protected String getDisplayName(PrismObject<O> object)

getStageType

protected TaskPartitionDefinitionType getStageType()

Returns:

the stageType

heartbeat

public long heartbeat()

getProgress

public long getProgress()

getErrors

public long getErrors()

setStopOnError

public void setStopOnError(boolean stopOnError)

setLogErrors

protected void setLogErrors(boolean logErrors)

handleObject

protected abstract boolean handleObject(PrismObject<O> object,
                                        RunningTask workerTask,
                                        OperationResult result)
                                 throws CommonException,
                                        PreconditionViolationException

Throws:

CommonException

PreconditionViolationException

createWorkerThreads

public void createWorkerThreads(RunningTask coordinatorTask)

getWorkerThreadsCount

protected Integer getWorkerThreadsCount(Task task)