public class RestoreTask extends SingleClientSenderTask
Thread.State, Thread.UncaughtExceptionHandler
atgQuery, ddResponse, deserializer, queryAppObj, queryIdx, SENDCONTROL_TIMEOUT, serializerVersion, syncObj
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION
Constructor and Description |
---|
RestoreTask(ArchiveManager archiveMgr,
RingOfDeathListener rodl,
RingBuffer<ResultData> inputData,
LongTermTaskStatePublisher longTermTaskStatePublisher)
Erzeugt einen neuen Task zur Wiederherstellung gesicherter Container.
|
Modifier and Type | Method and Description |
---|---|
static long |
getLOESSCHUTZ_VERL() |
static boolean |
isUnavailMediumIDsFile(String name)
Prueft, ob der angegebene Dateiname der Name einer _unavailable_mediumids.dat-Datei ist.
|
void |
run() |
static void |
setLOESSCHUTZ_VERL(long loesschutz_verl) |
protected void |
work(ResultData resultData)
Fuehrt die Wiederherstellung gesicherter Datenvontainer durch.
|
dataRequest, getObjectsFromDAV, init, insertData, isRequestSupported, parseArchiveDataSpec, sendErrorResponse, sendErrorResponse, sendSuccessResponse, sendSuccessResponse, subscribeSender, unsubscribeSender
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public RestoreTask(ArchiveManager archiveMgr, RingOfDeathListener rodl, RingBuffer<ResultData> inputData, LongTermTaskStatePublisher longTermTaskStatePublisher) throws ConfigurationException
archiveMgr
- Der Archiv-Manager.rodl
- Der Listener wird benachrichtigt beim Beenden der Task.inputData
- EingangswarteschlangeConfigurationException
public void run()
run
in interface Runnable
run
in class SingleTask
Runnable.run()
public static boolean isUnavailMediumIDsFile(String name)
name
- Name einer Dateiprotected void work(ResultData resultData)
work
in class SingleTask
resultData
- Zu verarbeitender Datensatz aus der Eingangswarteschlange.public static long getLOESSCHUTZ_VERL()
public static void setLOESSCHUTZ_VERL(long loesschutz_verl)