Modifier and Type | Class and Description |
---|---|
private static class |
ApplicationStatusUpdater.ApplicationConnection |
private class |
ApplicationStatusUpdater.SourceApplicationUpdater |
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private List<ApplicationStatusUpdater.ApplicationConnection> |
_application
Enthält alle Applikationen, die an/ab gemeldet werden sollen.
|
private Object |
_applicationConnections |
private DataDescription |
_applicationDataDescriptionDD
Die DataDescription, die zum Versandt von Anmeldungen einer Applikation benutzt wird.
|
private ApplicationStatusUpdater.SourceApplicationUpdater |
_applicationRuntime
Zum verschicken aller Telegrammlaufzeiten der angemeldeten Applikationen
|
private DataDescription |
_applicationRuntimeDataDescription
DataDescription, mit der eine Quelle zum verschicken der Telegrammlaufzeiten der angemeldeten Applikationen.
|
private ApplicationStatusUpdater.SourceApplicationUpdater |
_applicationUpdater
Zum verschicken aller angemeldeten Applikationen
|
private DataDescription |
_applicationUpdaterDataDescription
DataDescription, mit der eine Quelle zum verschicken aller angemeldeten Applikationen angemeldet wird.
|
private ClientDavInterface |
_connection |
private HighLevelConnectionsManagerInterface |
_connectionsManager |
private DataModel |
_dataModel |
private SystemObject |
_davObject |
private static Debug |
_debug |
private static String |
_pidAngemeldeteApplikationen
ATG, die benötigt wird um einen Datensatz zu verschicken, der alle angemeldeten Applikationen enthält.
|
private static String |
_pidAngemeldeteDatenidentifikationen
ATG, die benötigt wird um einen Datensatz zu verschicken, der die angemeldeten Daten aller angemeldeten Applikationen enthält.
|
private static String |
_pidTelegrammLaufzeiten
ATG, die benötigt wird um einen Datensatz zu verschicken, der die Telegrammlaufzeiten aller angemeldeten Applikationen enthält.
|
private Map<T_A_HighLevelCommunication,ApplicationStatusUpdater.SourceApplicationUpdater> |
_subcribedDataIdentifications
Key = Applikation, die bereits Daten angemeldet hat; Value = ClientSenderInterface(SourceApplicationUpdater).
|
private Map<ApplicationCommunicationInterface,TimerTask> |
_threadsForDataIdentificationUpdates
Wird für eine Applikation eine neue Datenidentifikation angemeldet, so wird dies über einen TimerTask publiziert.
|
private Timer |
_timer
Verschickt zyklisch alle angemeldeten Applikationen und deren Telegrammlaufzeiten.
|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ApplicationStatusUpdater(HighLevelConnectionsManagerInterface connectionsManager,
ClientDavInterface connection) |
Modifier and Type | Method and Description |
---|---|
void |
applicationAdded(T_A_HighLevelCommunication applicationConnection)
Fügt eine neue Applikation den Datenstrukturen hinzu und der Thread, der Aktualisierungsdatensätze verschickt, wird aufgeweckt.
|
void |
applicationRemoved(T_A_HighLevelCommunication applicationConnection)
Speichert die entfernte Applikation und weckt den wartende Thread auf, der daraufhin eine Datensatz mit den aktuell angemeldeten Applikationen verschickt.
|
void |
applicationSubscribedNewConnection(ApplicationCommunicationInterface application)
Diese Methode wird aufgerufen, wenn eine Applikation eine neue Datenidentifikation anmeldet.
|
void |
applicationUnsubscribeConnection(ApplicationCommunicationInterface application)
Diese Methode wird aufgerufen, wenn eine Applikation eine Datenidentifikation abmeldet.
|
private void |
createPeriodicUpdateTask()
Erstellt einen TimerTask, der alls 60 Sekunden alle angemeldeten Applikationen und deren Telegrammlaufzeiten verschickt (wenn ein Empfänger angemeldet
ist).
|
private void |
inscribeDataDescription(Data data,
BaseSubscriptionInfo baseSubscriptionInfo,
String role)
Schreibt in den übergebenen Datensatz(atl.angemeldeteDatenidentifikation) alle Daten benötigten Daten.
|
private boolean |
isNotSpecialTreatedApplicationObject(ServerHighLevelCommunication unknownObject)
Prüft, ob das übergebene Objekt gleich dem Objekt ist, das die Applikation des DaV darstellt, die sich selbst beim DaV anmeldet oder aber die
Konfiguration.
|
private void |
publishConnectionChanged(ApplicationCommunicationInterface application)
Wird aufgerufen, wenn eine Applikation einen Datenidentifikation an/abmeldet.
|
void |
run() |
private void |
sendApplicationTelegramRuntimeUpdate()
Verschickt ein Telegramm, das für alle angemeldeten Applikationen die Telegrammlaufzeit vom DaV zur Applikation enthält.
|
private void |
sendApplicationUpdate()
Es wird ein Datensatz verschickt, der alle Applikationen enthält, die gerade am DaV angemeldet sind.
|
private void |
sendDataAsSource(Data data,
DataDescription applicationRuntimeDataDescription) |
private void |
sendDataDescriptionUpdate(ApplicationCommunicationInterface application)
Verschickt einen Datensatz mit der ATG "atg.angemeldeteDatenidentifikationen".
|
private void |
subscribeDataDescriptionSource(T_A_HighLevelCommunication newApplication)
Meldet für eine neue Applikation eine Quelle an, die Datensätze vom mit der ATG "atg.angemeldeteDatenidentifikationen" verschickt.
|
private void |
unsubscribeDataDescriptionSource(T_A_HighLevelCommunication removedApplication)
Meldet die Datensätze der ATG "atg.angemeldeteDatenidentifikationen" wieder ab und entfernt die Objekte aus allen Datenstrukturen.
|
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 final String _pidAngemeldeteApplikationen
private static final String _pidAngemeldeteDatenidentifikationen
private static final String _pidTelegrammLaufzeiten
private static final Debug _debug
private final List<ApplicationStatusUpdater.ApplicationConnection> _application
private final SystemObject _davObject
private final ApplicationStatusUpdater.SourceApplicationUpdater _applicationUpdater
private final DataDescription _applicationUpdaterDataDescription
private final ApplicationStatusUpdater.SourceApplicationUpdater _applicationRuntime
private final DataDescription _applicationRuntimeDataDescription
private final DataDescription _applicationDataDescriptionDD
private final Timer _timer
private final Map<ApplicationCommunicationInterface,TimerTask> _threadsForDataIdentificationUpdates
null
zurückgegeben.private final Map<T_A_HighLevelCommunication,ApplicationStatusUpdater.SourceApplicationUpdater> _subcribedDataIdentifications
private final Object _applicationConnections
private final DataModel _dataModel
private final HighLevelConnectionsManagerInterface _connectionsManager
private final ClientDavInterface _connection
public ApplicationStatusUpdater(HighLevelConnectionsManagerInterface connectionsManager, ClientDavInterface connection)
private boolean isNotSpecialTreatedApplicationObject(ServerHighLevelCommunication unknownObject)
true
zurück gegeben.unknownObject
- Objekt, das vielleicht das DaV-Objekt darstellen könnte.private void sendApplicationUpdate()
private void sendApplicationTelegramRuntimeUpdate()
private void sendDataAsSource(Data data, DataDescription applicationRuntimeDataDescription)
private void sendDataDescriptionUpdate(ApplicationCommunicationInterface application)
application
- Applikation, deren angemeldete Datenidentifiaktionen propagiert werden sollen.private void inscribeDataDescription(Data data, BaseSubscriptionInfo baseSubscriptionInfo, String role)
data
- Datensatz (atl.angemeldeteDatenidentifikation)baseSubscriptionInfo
- Enthält das SystemObject(Id), die verwendete ATGV (Id) und die Simulationsvarianterole
- Verwendete Rolle, siehe auch att.rolleAnmeldung. Zulässige Werte: Quelle, Sender, Senke, Empfängerprivate void createPeriodicUpdateTask()
private void subscribeDataDescriptionSource(T_A_HighLevelCommunication newApplication)
newApplication
- enthält alle Daten zum anmelden.private void unsubscribeDataDescriptionSource(T_A_HighLevelCommunication removedApplication)
removedApplication
- Objekt, deren Quellenanmeldung zurückgenommen werden soll.public void applicationAdded(T_A_HighLevelCommunication applicationConnection)
applicationConnection
- Neue Applikationpublic void applicationRemoved(T_A_HighLevelCommunication applicationConnection)
applicationConnection
- Applikation, die entfernt wurdepublic void applicationSubscribedNewConnection(ApplicationCommunicationInterface application)
application
- Applikation, die neue Daten anmeldet.public void applicationUnsubscribeConnection(ApplicationCommunicationInterface application)
application
- Applikation, die eine Datenidentifikation abmeldet.private void publishConnectionChanged(ApplicationCommunicationInterface application)
application
- Applikation, die neue Daten an oder abmeldet.