public class LZVTask extends SingleClientSenderTask
Modifier and Type | Class and Description |
---|---|
static class |
LZVTask.CapacityCheckResultData |
static class |
LZVTask.DeleteRegularResultData |
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
static long |
CHANGETIME_REGULAR |
static long |
CHANGETIME_SPONTAN |
static boolean |
IGNORE_LOESCH_SCHUTZ |
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 |
---|
LZVTask(ArchiveManager archiveMgr,
RingOfDeathListener rodl,
RingBuffer<ResultData> inputData,
LongTermTaskStatePublisher longTermTaskStatePublisher)
Erzeugt eine neue Loeschzeit-Verlaengerungs-Task.
|
Modifier and Type | Method and Description |
---|---|
void |
containerWalk(ArchiveDataSpecification[] ads,
long changeTime,
Calendar compareDate,
de.bsvrz.ars.ars.mgmt.tasks.LZVTask.DELETE_LEVEL level)
Die generelle Container-Walk-Methode.
|
protected void |
deleteSpontan(ArchiveDataSpecification[] ads,
long changeTime)
Der
DeleteSpontanTask löscht bei knapp werdendem Speicherplatz unwichtige Container. |
static LZVTask.CapacityCheckResultData |
getCapacityCheckResultData(ArchiveManager archMgr) |
static LZVTask.DeleteRegularResultData |
getDeleteRegularResultData(ArchiveManager archMgr) |
static long |
getMinRemainingDiskCapa()
Liefert die Mindest-Restkapazitaet der Festplatte.
|
void |
run() |
static void |
setMinRemainingDiskCapa(long minRemainingDiskCapa)
Setzt die Mindest-Restkapazitaet der Festplatte.
|
protected void |
work(ResultData resultData)
Führt das Löschen, spontanes Löschen oder die Löschzeitverlängerung aus.
|
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 static boolean IGNORE_LOESCH_SCHUTZ
public static final long CHANGETIME_SPONTAN
public static final long CHANGETIME_REGULAR
public LZVTask(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
- Eingangswarteschlange.ConfigurationException
public void run()
run
in interface Runnable
run
in class SingleTask
Runnable.run()
public static long getMinRemainingDiskCapa()
public static void setMinRemainingDiskCapa(long minRemainingDiskCapa)
minRemainingDiskCapa
- Neue Mindestrestkapazitaet in Byte.protected void work(ResultData resultData)
work
in class SingleTask
resultData
- Zu verarbeitender Datensatz aus der EingangswarteschlangeSingleTask.work(ResultData)
protected void deleteSpontan(ArchiveDataSpecification[] ads, long changeTime) throws Exception
DeleteSpontanTask
löscht bei knapp werdendem Speicherplatz unwichtige Container.
Dazu ueberprueft er in einem parametrierbaren Zyklus, wieviel Speicherplatz dem Archivsystem noch zur Verfuegung steht. Erreicht die vorhandene Kapazität
einen Schwellwert, werden folgende Daten geloescht: Exception
public void containerWalk(ArchiveDataSpecification[] ads, long changeTime, Calendar compareDate, de.bsvrz.ars.ars.mgmt.tasks.LZVTask.DELETE_LEVEL level) throws Exception
ads
- changeTime
- compareDate
- PersistenceException
IndexException
Exception
public static LZVTask.CapacityCheckResultData getCapacityCheckResultData(ArchiveManager archMgr)
public static LZVTask.DeleteRegularResultData getDeleteRegularResultData(ArchiveManager archMgr)