public class ArchiveRequestedTask extends ArchiveTask
ArchiveTask
.ArchiveTask.CloseContainerObject
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private ArchiveData |
ad |
private static AtomicLong |
TOTAL_REQ_DS_FAIL |
private static AtomicLong |
TOTAL_REQ_DS_QUEUED |
private static AtomicLong |
TOTAL_REQ_DS_SUCCESS |
adk, arsTime, aspID, atg, compresser, dataEntryLen, dataIdx, dataTime, didPath, didPathA, didPathN, din, idxBuffer, MSG_PID_DATAINDEX_ANOMALY, NA, NN, objID, ONLINE, openContID, REQUESTED, sv
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ArchiveRequestedTask(ArchiveManager archiveMgr,
RingOfDeathListener rodl,
int tskIndex,
ArchiveRingBuffer inQueue)
Erzeugt einen ArchiveRequestedTask
|
Modifier and Type | Method and Description |
---|---|
static long |
getTotalDS_Fail() |
static long |
getTotalDS_Processed() |
static long |
getTotalDS_Queued() |
static long |
getTotalDS_Success() |
static void |
incrementTotalDS_Queued()
Wird vom
InQueuesMgr.ArchiveDataReceiver aufgerufen, nachdem er einen zu archivierenden Datensatz in eine der Queues gelegt
hat. |
protected void |
logReceivedData(ArchiveData ad) |
private void |
presetData(ArchiveData archiveData,
long archTime)
Alle Instanzvariablen vorbelegen.
|
static void |
resetDSCounter()
Setzt alle Zaehler auf 0.
|
void |
work(Object archiveData,
long archTime)
Archiviert den uebergebenen Datensatz unter dem angegebenen Archivzeitstempel.
|
assignIndexes, createRebuildIndexFlagFile, getCloseContainerSuccess, getContainerSettings, getLastArchiveTime, handleErr, handleErr, handleSevereErr, logManualCloseContainer, logNewContainer, logReceivedData, logWriteData, lookupLastDataIdxes, mustCloseContainer, run, setContainerSettings, setLastArchiveTime, storeData, tooLargeForNewContainer
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
private static AtomicLong TOTAL_REQ_DS_QUEUED
private static AtomicLong TOTAL_REQ_DS_SUCCESS
private static AtomicLong TOTAL_REQ_DS_FAIL
private ArchiveData ad
public ArchiveRequestedTask(ArchiveManager archiveMgr, RingOfDeathListener rodl, int tskIndex, ArchiveRingBuffer inQueue)
archiveMgr
- Archiv-Managerrodl
- Ring-of-Death-ListenertskIndex
- Index des TasksinQueue
- Eingangs-Warteschlangeprivate void presetData(ArchiveData archiveData, long archTime) throws DIdNodeNotFoundException
archiveData
- ArchivdatensatzarchTime
- ArchivzeitstempelDIdNodeNotFoundException
public void work(Object archiveData, long archTime)
ArchiveTask
work
in class ArchiveTask
archiveData
- ErgebnisdatensatzarchTime
- Archivzeitstempelprotected void logReceivedData(ArchiveData ad)
public static void incrementTotalDS_Queued()
InQueuesMgr.ArchiveDataReceiver
aufgerufen, nachdem er einen zu archivierenden Datensatz in eine der Queues gelegt
hat.public static long getTotalDS_Queued()
public static long getTotalDS_Processed()
public static long getTotalDS_Success()
public static long getTotalDS_Fail()
public static void resetDSCounter()