|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
de.bsvrz.ars.ars.mgmt.tasks.Task
de.bsvrz.ars.ars.mgmt.ArchivConfig
public class ArchivConfig
Konfiguration des Archivsystems. Die Klasse ist als Thread implementiert, damit die Anmeldungen nicht im Thread des Datenverteilers (in den Callback-Methoden
des SettingsManager) laufen muessen. Stattdessen wird ein einfacher Ping-Pong-Mechnanismus implementiert, mit dem die Parameter abgearbeitet werden, sobald
der EndOfSettingsListener aufgerufen wurde. Das Ende eines Parametrierungszyklus kann durch createEndOfParamListener()
abgewartet werden.
Task
und RingBuffer
implementiert, da sie einen von der Kernsoftware zur Verfuegung
gestellten Mechanismus zur Parameteruebernahme verwendet.
Nested Class Summary | |
---|---|
class |
ArchivConfig.EndOfParamListener
Spezielle Klasse, mit der man auf das Ende der Übernahme der nächsten Archiveinstellungen warten kann. |
static class |
ArchivConfig.SubscrMarker
Mit dieser Klasse wird während der Parameterübernahme in den Callback-Methoden vermerkt für welche Datenidentifikation (= DataIdentNode ) was
parametriert wurde. |
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary |
---|
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
archMgr, didTree, INDEX_MEMORY_SIZE, logger, persMgr, ringOfDeathListener, taskStepListeners |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ArchivConfig(ArchiveManager aMgr)
|
Method Summary | |
---|---|
ArchivConfig.EndOfParamListener |
createEndOfParamListener()
Erzeugt einen Listener der benachrichtigt wird, wenn ein Parametrierungszyklus durchlaufen ist. |
void |
printArchiveParams(File dumpFile)
Gibt die Parametrierung auf dem uebergebenen Stream aus. |
void |
restartSubscribeArchiveParams()
Startet die Uebernahme der Archivparametrierung und meldet die zu archivierenden Datenidentifikation an. |
void |
run()
|
void |
setSimConfigQueue(RingBuffer<ResultData> queue)
|
void |
startSubscribeArchiveParams(InQueuesMgr iqMgr,
DataIdentTree dTree)
Initialisiert den Thread und startet durch restartSubscribeArchiveParams() die Uebernahme der Archivparametrierung. |
void |
unsubscribeArchiveData()
Meldet alle zu archivierenden Daten ab |
void |
unsubscribeArchiveDataAck()
Meldet alle Quittierungsaspekte ab. |
void |
unsubscribeArchiveParams()
Beendet den SettingsManager und meldet die Parametrierung des Archivsystems ab. |
void |
unsubsrcibeSimVarData(int simVar)
Meldet alle zu einer Simulation gehoerenden Daten (= zu archivierende Daten + Quittungen) ab. |
void |
waitForTermination()
Beendet den ArchivConfig-Thread. |
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task |
---|
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask |
Methods inherited from class java.lang.Thread |
---|
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 |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ArchivConfig(ArchiveManager aMgr) throws ConfigurationException
ConfigurationException
Method Detail |
---|
public void setSimConfigQueue(RingBuffer<ResultData> queue)
public void run()
run
in interface Runnable
run
in class Thread
public void waitForTermination()
public ArchivConfig.EndOfParamListener createEndOfParamListener()
public void startSubscribeArchiveParams(InQueuesMgr iqMgr, DataIdentTree dTree) throws ConfigurationException
restartSubscribeArchiveParams()
die Uebernahme der Archivparametrierung.
iqMgr
- Empfaenger der DatenanmeldungdTree
- Baum, in den die Datenidentifikationen zusammen mit der Parametrierung eingetragen werden
ConfigurationException
public void restartSubscribeArchiveParams() throws ConfigurationException
ConfigurationException
public void unsubscribeArchiveParams()
public void unsubscribeArchiveData()
public void unsubsrcibeSimVarData(int simVar)
public void unsubscribeArchiveDataAck()
unsubscribeArchiveData()
geschehen, damit die Datensaetze, die noch in der Queue sind, nach
der Archivierung quittiert werden koennen.
public void printArchiveParams(File dumpFile) throws Exception
dumpFile
- Ausgabestream. Falls null, wird auf stdout ausgegeben
ConfigurationException
InterruptedException
Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |