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

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	REQUEST_QUEUE_OFFER_TIMEOUT
static int	WORKER_THREAD_WAIT_FOR_REQUEST

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, OperationResult opResult)
Float	getAverageTime()
String	getContextDesc()
Task	getCoordinatorTask()
protected String	getDisplayName(PrismObject<O> object)
long	getErrors()
protected String	getProcessShortName()
protected String	getProcessShortNameCapitalized()
long	getProgress()
TaskPartitionDefinitionType	getStageType()
String	getTaskOperationPrefix()
Float	getWallAverageTime()
long	getWallTime()
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()
boolean	isEnableActionsExecutedStatistics()
boolean	isEnableIterationStatistics()
boolean	isEnableSynchronizationStatistics()
boolean	isLogErrors()
boolean	isLogObjectProgress()
boolean	isRecordIterationStatistics()
boolean	isStopOnError()
void	setContextDesc(String contextDesc)
void	setEnableActionsExecutedStatistics(boolean enableActionsExecutedStatistics)
void	setEnableIterationStatistics(boolean enableIterationStatistics)
void	setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics)
void	setLogErrors(boolean logErrors)
void	setLogObjectProgress(boolean logObjectProgress)
void	setRecordIterationStatistics(boolean recordIterationStatistics)
void	setStopOnError(boolean stopOnError)
void	signalAllItemsSubmitted()
void	updateOperationResult(OperationResult opResult)
void	waitForCompletion(OperationResult opResult)

Methods inherited from class java.lang.Object

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

Field Detail

WORKER_THREAD_WAIT_FOR_REQUEST

public static final int WORKER_THREAD_WAIT_FOR_REQUEST

See Also:

Constant Field Values

REQUEST_QUEUE_OFFER_TIMEOUT

protected static final long REQUEST_QUEUE_OFFER_TIMEOUT

See Also:

Constant Field Values

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()

getTaskOperationPrefix

public String getTaskOperationPrefix()

isLogObjectProgress

public boolean isLogObjectProgress()

setLogObjectProgress

public void setLogObjectProgress(boolean logObjectProgress)

isRecordIterationStatistics

public boolean isRecordIterationStatistics()

setRecordIterationStatistics

public void setRecordIterationStatistics(boolean recordIterationStatistics)

isEnableIterationStatistics

public boolean isEnableIterationStatistics()

setEnableIterationStatistics

public void setEnableIterationStatistics(boolean enableIterationStatistics)

isEnableSynchronizationStatistics

public boolean isEnableSynchronizationStatistics()

setEnableSynchronizationStatistics

public void setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics)

isEnableActionsExecutedStatistics

public boolean isEnableActionsExecutedStatistics()

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

signalAllItemsSubmitted

public void signalAllItemsSubmitted()

getAverageTime

public Float getAverageTime()

getWallAverageTime

public Float getWallAverageTime()

getWallTime

public long getWallTime()

waitForCompletion

public void waitForCompletion(OperationResult opResult)

updateOperationResult

public void updateOperationResult(OperationResult opResult)

completeProcessing

public void completeProcessing(Task task,
                               OperationResult result)

getDisplayName

protected String getDisplayName(PrismObject<O> object)

getStageType

public TaskPartitionDefinitionType getStageType()

Returns:

the stageType

heartbeat

public long heartbeat()

getProgress

public long getProgress()

getErrors

public long getErrors()

isStopOnError

public boolean isStopOnError()

setStopOnError

public void setStopOnError(boolean stopOnError)

isLogErrors

public boolean isLogErrors()

setLogErrors

public 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,
                                OperationResult opResult)

getWorkerThreadsCount

protected Integer getWorkerThreadsCount(Task task)