public class ArchiveRequestedTask extends ArchiveTask
Task zur Archivierung nachgefordeter Daten. Unterscheidet sich hauptsaechlich in der Behandlung von Datenluecken von ArchiveTask
.
ArchiveTask.CloseContainerObject
_closeCount, _failCount, _successCount, adk, arsTime, aspID, atg, compresser, dataEntryLen, dataIdx, dataTime, didPath, didPathA, didPathN, din, idxBuffer, MSG_PID_DATAINDEX_ANOMALY, NA, NN, objID, ONLINE, openContID, REQUESTED, sv
TERMINATE_TASK
_debug, _shouldTerminate, archMgr, didTree, INDEX_MEMORY_SIZE, persMgr
Constructor and Description |
---|
ArchiveRequestedTask(ArchiveManager archiveMgr,
int tskIndex,
ArchiveRingBuffer inQueue)
Erzeugt einen ArchiveRequestedTask
|
Modifier and Type | Method and Description |
---|---|
protected void |
logReceivedData(ArchiveData ad) |
void |
work(java.lang.Object archiveData,
long archTime)
Archiviert den uebergebenen Datensatz unter dem angegebenen Archivzeitstempel.
|
assignIndexes, createRebuildIndexFlagFile, getCloseContainerSuccess, getContainerSettings, getFailedCount, getLastArchiveTime, getProcessedCount, getSuccessCount, handleErr, handleErr, handleSevereErr, logManualCloseContainer, logNewContainer, logReceivedData, logWriteData, lookupLastDataIdxes, mustCloseContainer, resetDSCounter, setContainerSettings, setLastArchiveTime, step, storeData, terminateTask, tooLargeForNewContainer
execute
addTaskStepListener, cleanUp, getArchMgr, getName, getObjectsFromDav, getState, isAlive, isTerminated, join, removeTaskStepListener, setName, shouldTerminate, start, suspendTaskIfNecessary, taskStepDone
public ArchiveRequestedTask(ArchiveManager archiveMgr, int tskIndex, ArchiveRingBuffer inQueue)
Erzeugt einen ArchiveRequestedTask
archiveMgr
- Archiv-Managerrodl
- Ring-of-Death-ListenertskIndex
- Index des TasksinQueue
- Eingangs-Warteschlangepublic void work(java.lang.Object archiveData, long archTime)
ArchiveTask
Archiviert den uebergebenen Datensatz unter dem angegebenen Archivzeitstempel.
work
in class ArchiveTask
archiveData
- ErgebnisdatensatzarchTime
- Archivzeitstempelprotected void logReceivedData(ArchiveData ad)