Klasse ArchiveTask
java.lang.Object
de.bsvrz.ars.ars.mgmt.tasks.Task
de.bsvrz.ars.ars.mgmt.tasks.AbstractTask
de.bsvrz.ars.ars.mgmt.tasks.RepeatingTask
de.bsvrz.ars.ars.persistence.writer.ArchiveTask
Task zur Archivierung von Datensätzen. Ist nicht von SingleTask abgeleitet, weil ein spezieller ArchiveRingBuffer verwendet wird, der zwei Objekte
(ResultData und Archivzeit) speichern kann. Die work()-Methode hat deswegen zwei Parameter.
-
Verschachtelte Klassen - Übersicht
Verschachtelte KlassenModifizierer und TypKlasseBeschreibungstatic final record
Sammlung von Wertebereichen der letzten Container -
Feldübersicht
Von Klasse geerbte Felder de.bsvrz.ars.ars.mgmt.tasks.Task
_debug, _shouldTerminate
-
Konstruktorübersicht
KonstruktorenKonstruktorBeschreibungArchiveTask
(ArchiveManager archiveMgr, SignalingQueue<ArchiveJob> inQueue) Konstruktor des Archiv-Tasks. -
Methodenübersicht
Modifizierer und TypMethodeBeschreibunglong
static de.bsvrz.sys.funclib.losb.datk.ContainerSettings
Liefert die Container-Einstellungen des Archivsystems.long
long
long
static long
Letzte verwendete Archivzeit.long
long
long
static boolean
isIndexGap
(long lastDataIdx, long nextDataIdx) Gibt zurück, ob zwischen 2 Datensätze eine Indexlücke vorliegtvoid
Setzt alle Zähler auf 0.protected void
sendAck
(de.bsvrz.dav.daf.main.ResultData rd, DataIdentNode din) Sendet eine Quittung für den angegebenen Datensatz.static void
setContainerSettings
(de.bsvrz.sys.funclib.losb.datk.ContainerSettings cs) Setzt die Container-Einstellungen des Archivsystems.static void
setLastArchiveTime
(long atime) void
step()
Implementiert die beliebige wiederholt auszuführende Aufgabevoid
Terminiert den Task, indem dafür gesorgt wird, dasTask.shouldTerminate()
true zurückliefert.Von Klasse geerbte Methoden de.bsvrz.ars.ars.mgmt.tasks.RepeatingTask
execute, getArchMgr
Von Klasse geerbte Methoden de.bsvrz.ars.ars.mgmt.tasks.AbstractTask
addTaskStepListener, cleanUp, getName, getState, isAlive, isTerminated, join, removeTaskStepListener, setName, start, taskStepDone
Von Klasse geerbte Methoden de.bsvrz.ars.ars.mgmt.tasks.Task
getDidTree, getPersistenceManager, shouldTerminate, suspendTaskIfNecessary
-
Konstruktordetails
-
ArchiveTask
Konstruktor des Archiv-Tasks.- Parameter:
archiveMgr
- Archiv-ManagerinQueue
- Input-Queue
-
-
Methodendetails
-
getSerializationHelper
-
setContainerSettings
public static void setContainerSettings(de.bsvrz.sys.funclib.losb.datk.ContainerSettings cs) Setzt die Container-Einstellungen des Archivsystems.- Parameter:
cs
- Container-Einstellungen
-
getContainerSettings
public static de.bsvrz.sys.funclib.losb.datk.ContainerSettings getContainerSettings()Liefert die Container-Einstellungen des Archivsystems.- Gibt zurück:
- Container-Einstellungen
-
step
Beschreibung aus Klasse kopiert:RepeatingTask
Implementiert die beliebige wiederholt auszuführende Aufgabe- Angegeben von:
step
in KlasseRepeatingTask
- Löst aus:
InterruptedException
- Thread unterbrochen
-
terminateTask
public void terminateTask()Beschreibung aus Klasse kopiert:Task
Terminiert den Task, indem dafür gesorgt wird, dasTask.shouldTerminate()
true zurückliefert. Der Task sollte diese Funktion regelmäßig aufrufen um dann bei Rückgabe vontrue
den Task zeitnah zu beenden.- Setzt außer Kraft:
terminateTask
in KlasseTask
-
getSuccessCount
public long getSuccessCount()- Gibt zurück:
- Anzahl der seit Systemstart erfolgreich archivierten Datensätze
-
getFailedCount
public long getFailedCount()- Gibt zurück:
- Anzahl der seit Systemstart nicht erfolgreich archivierten Datensätze
-
getSuccessCountRequested
public long getSuccessCountRequested()- Gibt zurück:
- Anzahl der seit Systemstart erfolgreich archivierten Datensätze
-
getFailedCountRequested
public long getFailedCountRequested()- Gibt zurück:
- Anzahl der seit Systemstart nicht erfolgreich archivierten Datensätze
-
getSuccessCountOnline
public long getSuccessCountOnline()- Gibt zurück:
- Anzahl der seit Systemstart erfolgreich archivierten Datensätze
-
getFailedCountOnline
public long getFailedCountOnline()- Gibt zurück:
- Anzahl der seit Systemstart nicht erfolgreich archivierten Datensätze
-
getCloseContainerSuccess
public long getCloseContainerSuccess()- Gibt zurück:
- Zahl aller seit dem Start oder letzten
resetDSCounter()
erfolgreich verarbeiteten Close-Container-Datensätze. Kann zur Test-Synchronisation verwendet werden.
-
resetDSCounter
public void resetDSCounter()Setzt alle Zähler auf 0. -
setLastArchiveTime
public static void setLastArchiveTime(long atime) -
getLastArchiveTime
public static long getLastArchiveTime()Letzte verwendete Archivzeit. Wird für die Archivzeitüberwachung benutzt. -
isIndexGap
public static boolean isIndexGap(long lastDataIdx, long nextDataIdx) Gibt zurück, ob zwischen 2 Datensätze eine Indexlücke vorliegt- Parameter:
lastDataIdx
- erster DatensatznextDataIdx
- nächster Datensatz- Gibt zurück:
- true: Indexlücke, sonst false
-
sendAck
Sendet eine Quittung für den angegebenen Datensatz.- Parameter:
rd
- Datensatzdin
- Datenknoten mit Parametrierung
-
getFailCounterOnline
-
getFailCounterRequested
-
getCloseCounter
-
getSuccessCounterOnline
-
getSuccessCounterRequested
-