Package org.opends.server.tasks
Class InitializeTask
- java.lang.Object
-
- org.opends.server.backends.task.Task
-
- org.opends.server.tasks.InitializeTask
-
- All Implemented Interfaces:
Comparable<Task>
public final class InitializeTask extends Task
This class provides an implementation of a Directory Server task that can be used to import data over the replication protocol from another server hosting the same replication domain.
-
-
Constructor Summary
Constructors Constructor Description InitializeTask()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description LocalizableMessage
getDisplayName()
Gets a message that identifies this type of task suitable for presentation to humans in monitoring tools.void
initializeTask(Entry taskEntry)
Performs any task-specific initialization that may be required before processing can start.void
interruptTask(TaskState interruptState, LocalizableMessage interruptReason)
Performs any necessary processing to prematurely interrupt the execution of this task.void
retry(LdapException reason)
The task was not successful but can be retried, set the state accordingly.protected TaskState
runTask()
Performs the actual core processing for this task.void
setLeft(long left)
Set the total number of entries still to be imported.void
setTotal(long total)
Set the total number of entries expected to be imported.void
updateTaskCompletionState(LdapException e)
Set the state for the current task.-
Methods inherited from class org.opends.server.backends.task.Task
addLogMessage, addLogMessage, compareTo, execute, getAttributeDisplayName, getCompletionTime, getDependencyIDs, getFailedDependencyAction, getFinalTaskState, getLogMessages, getOperation, getRecurringTaskID, getScheduledStartTime, getServerContext, getTaskEntry, getTaskID, getTaskState, initializeTask, initializeTaskInternal, isInterruptible, isRecurring, replaceAttributes, sendNotificationEMailMessage, setCompletionTime, setEntriesLeftAndDone, setOperation, setTaskInterruptState, toString
-
-
-
-
Method Detail
-
getDisplayName
public LocalizableMessage getDisplayName()
Description copied from class:Task
Gets a message that identifies this type of task suitable for presentation to humans in monitoring tools.- Overrides:
getDisplayName
in classTask
- Returns:
- name of task
-
initializeTask
public void initializeTask(Entry taskEntry) throws LdapException
Description copied from class:Task
Performs any task-specific initialization that may be required before processing can start. This default implementation does not do anything, but subclasses may override it as necessary. This method will be called at the time the task is scheduled, and therefore any failure in this method will be returned to the client.- Overrides:
initializeTask
in classTask
- Parameters:
taskEntry
- the task entry- Throws:
LdapException
- If a problem occurs during initialization that should be returned to the client.
-
runTask
protected TaskState runTask()
Description copied from class:Task
Performs the actual core processing for this task. This method should not return until all processing associated with this task has completed.
-
interruptTask
public void interruptTask(TaskState interruptState, LocalizableMessage interruptReason)
Description copied from class:Task
Performs any necessary processing to prematurely interrupt the execution of this task. By default no action is performed, but if it is feasible to gracefully interrupt a task, then subclasses should override this method to do so. Implementations of this method are expected to callTask.setTaskInterruptState(TaskState)
if the interruption is accepted by this task.- Overrides:
interruptTask
in classTask
- Parameters:
interruptState
- The state to use for the task if it is successfully interrupted.interruptReason
- A human-readable explanation for the cancellation.
-
updateTaskCompletionState
public void updateTaskCompletionState(LdapException e)
Set the state for the current task.- Parameters:
e
- When the new state is different from COMPLETED_SUCCESSFULLY this is the exception that contains the cause of the failure.
-
retry
public void retry(LdapException reason)
The task was not successful but can be retried, set the state accordingly.- Parameters:
reason
- this is the exception that contains the reason for the retry
-
setTotal
public void setTotal(long total)
Set the total number of entries expected to be imported.- Parameters:
total
- The total number of entries.
-
setLeft
public void setLeft(long left)
Set the total number of entries still to be imported.- Parameters:
left
- The total number of entries to be imported.
-
-