public class ArchiveRequestedTask extends ArchiveTask
Task zur Archivierung nachgefordeter Daten. Unterscheidet sich hauptsaechlich in der Behandlung von Datenluecken von ArchiveTask
.
ArchiveTask.CloseContainerObject
Modifier and Type | Field and Description |
---|---|
private ArchiveData |
ad |
_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) |
private void |
presetData(ArchiveData archiveData,
long archTime)
Alle Instanzvariablen vorbelegen.
|
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
private ArchiveData ad
public ArchiveRequestedTask(ArchiveManager archiveMgr, int tskIndex, ArchiveRingBuffer inQueue)
Erzeugt einen ArchiveRequestedTask
archiveMgr
- Archiv-Managerrodl
- Ring-of-Death-ListenertskIndex
- Index des TasksinQueue
- Eingangs-Warteschlangeprivate void presetData(ArchiveData archiveData, long archTime) throws DIdNodeNotFoundException
Alle Instanzvariablen vorbelegen.
archiveData
- ArchivdatensatzarchTime
- ArchivzeitstempelDIdNodeNotFoundException
public 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)