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 recordSammlung 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 TypMethodeBeschreibunglongstatic de.bsvrz.sys.funclib.losb.datk.ContainerSettingsLiefert die Container-Einstellungen des Archivsystems.longlonglongstatic longLetzte verwendete Archivzeit.longlonglongstatic booleanisIndexGap(long lastDataIdx, long nextDataIdx) Gibt zurück, ob zwischen 2 Datensätze eine Indexlücke vorliegtvoidSetzt alle Zähler auf 0.protected voidsendAck(de.bsvrz.dav.daf.main.ResultData rd, DataIdentNode din) Sendet eine Quittung für den angegebenen Datensatz.static voidsetContainerSettings(de.bsvrz.sys.funclib.losb.datk.ContainerSettings cs) Setzt die Container-Einstellungen des Archivsystems.static voidsetLastArchiveTime(long atime) voidstep()Implementiert die beliebige wiederholt auszuführende AufgabevoidTerminiert den Task, indem dafür gesorgt wird, dasTask.shouldTerminate()true zurückliefert.Von Klasse geerbte Methoden de.bsvrz.ars.ars.mgmt.tasks.RepeatingTask
execute, getArchMgrVon Klasse geerbte Methoden de.bsvrz.ars.ars.mgmt.tasks.AbstractTask
addTaskStepListener, cleanUp, getName, getState, isAlive, isTerminated, join, removeTaskStepListener, setName, start, taskStepDoneVon 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:RepeatingTaskImplementiert die beliebige wiederholt auszuführende Aufgabe- Angegeben von:
stepin KlasseRepeatingTask- Löst aus:
InterruptedException- Thread unterbrochen
-
terminateTask
public void terminateTask()Beschreibung aus Klasse kopiert:TaskTerminiert 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 vontrueden Task zeitnah zu beenden.- Setzt außer Kraft:
terminateTaskin 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
-