public class AbfragePufferdaten extends Object implements de.bsvrz.sys.funclib.application.StandardApplication, de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface
Modifier and Type | Field and Description |
---|---|
private long |
abfrageIntervallAxl
Intervall der periodischen Axl Abfragen.
|
private long |
abfrageIntervallAxlNeu
Enthaelt das neue Wert, wenn sich der AbfrageIntervall geaendert.
|
private long |
abfrageIntervallLve
Intervall der periodischen Lve Abfragen.
|
private long |
abfrageIntervallLveNeu
Enthaelt das neue Wert, wenn sich der AbfrageIntervall geaendert.
|
private static String |
abfrageModul
die PID des verwendeten Abfragemoduls.
|
private Object |
abfrageModulEinstellungenMutex
Mutex fuer dem AbfrageModul Einstellungen.
|
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener |
aggregationStart
Listener wird vom Wecker beim Start der Aggregation gerufen.
|
private long |
aggregationVerspaetung
Die Aggregation muss ein bischen auf dem Archiv warten, damit das Archiv
sicher alle Daten bearbeitet hat.
|
private boolean |
alleMuessenOnlineSein
Ob alle DEs online sein muessen um eine Abfrage zu machen.
|
private static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager |
archivSettingsManager
Fuer die Auslesung der eigenschaften des Archivs.
|
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener |
axlAbfragen
Listener wird beim Start der Axl Abfrage vom Wecker gerufen.
|
private AbstraktDeVerwaltung |
axlDeVerwaltung
Verwaltet die Axl Abrufe.
|
private Object |
datenZugriffMutex
Mutex fuer dem settingsManager und die Listener Threads zu verwalten.
|
private de.bsvrz.dav.daf.main.ClientDavInterface |
dav
Verbindung zum Datenverteiler.
|
private static de.bsvrz.dav.daf.main.DataDescription |
ddAbfrageModul
Datenbeschreibung für Abfragemodul Parametrierung.
|
private static de.bsvrz.dav.daf.main.DataDescription |
ddGloFehler
Datenbeschreibung für Globale Fehlermeludngen.
|
private boolean |
erstmalAngemeldet
Ob wir fuer dem Empfang von GloFehler angemeldet sind.
|
private static de.bsvrz.sys.funclib.debug.Debug |
LOGGER |
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener |
lveAbfragen
Listener wird beim Start der LveAbrfagen vom Wecker gerufen.
|
private AbstraktDeVerwaltung |
lveDeVerwaltung
Verwaltet die Lve.
|
private AggregatorVerwaltung |
lzdAggregation
Stellt aggregierte LZD zur Verfuegung fuer andere Module.
|
private de.bsvrz.sys.funclib.operatingMessage.MessageSender |
nachrichtenSender
Diese Klasse versendet Betriebsmeldungen.
|
private long |
naechsteAbfrageAxl
Zeitpunkt der naechsten Axl Abfrage.
|
private long |
naechsteAbfrageAxlNeu
Zeitpunkt der naechsten Abfrage, wenn sich der Offset oder Abrufintervall
geaendert.
|
private long |
naechsteAbfrageLve
Zeitpunkt der naechsten Lve Abfrage.
|
private long |
naechsteAbfrageLveNeu
Zeitpunkt der naechsten Abfrage, wenn sich der Offset oder Abrufintervall
geaendert.
|
protected static String |
P_ABFRAGE_MODUL
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static String |
P_ALLE_ONLINE
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static String |
P_SM
Parameter dem man erkennen soll SteuerModule und Konfigurationsbereiche
die verwaltet werden sollen.
|
private String[] |
paramKonfigurationsObjekte
PIDs der SteuerModule und Konfigurationsbereiche, die als Parameter
angegeben wurden.
|
private StreamBasierteArchivAnfrage |
sbAnfrage
Streambasierte Anfrage um Infos aus dem Archiv auslesen.
|
private List<Station> |
stationen
Liste der bearbeitenden Stationen, enthaelt alle benoetigte
informationen.
|
private Collection<de.bsvrz.dav.daf.main.config.ConfigurationArea> |
sysObjKonfBereiche
SystemObjekte der konfigurationsbereichen die, die als Parameter
angegeben wurden.
|
private Collection<de.bsvrz.dav.daf.main.config.SystemObject> |
sysObjSteuerModule
SystemObjekte der SteuerModule die, die als Parameter angegeben wurden.
|
private de.bsvrz.sys.funclib.bitctrl.dua.ObjektWecker |
wecker
Der Wecker ermoeglicht regelmaesige priodische Abrufe, paralell fuer
jedem Steuermodul.
|
protected static long |
ZEIT_TOLERANZ
Wenn Zwei Zeitstempel fuer Abrufe innerhalb dieses Intervalls sind, dann
koennen wir sie als gleich betrachten, vermeidet 2 Abrufe in der selben
Zeit.
|
Constructor and Description |
---|
AbfragePufferdaten() |
Modifier and Type | Method and Description |
---|---|
void |
abmeldeGloFehler()
Meldet sich von GloFehler Meldungen ab.
|
void |
aggregationStart()
Startet die Aggregation von LZD.
|
void |
aggregiere()
Stellt dem Wecker fuer die naechste Aggregation fest.
|
void |
anmeldeAbfrageModulParametrierung()
Meldet sich online fuer die AbfrageModul Parametrierung an.
|
void |
anmeldeGloFehler()
Anmeldung fuer Empfang von Globalen FehlerMeldungen.
|
void |
axlAlarm()
Startet eine regelmaesige Axl Abfrage.
|
long |
convertAbsoluteEchtZeit(long zeit)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertAbsoluteVirtuelleZeit(long zeit)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertTimeoutIntervall(long intervall)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertZeitIntervall(long zeitIntervall)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
currentTimeMillis()
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
de.bsvrz.dav.daf.main.DataDescription |
erzeugeDatenBeschreibung(String atg,
String asp,
short var)
Erzeugt eine DatenBeschreibung mit gegebenen Parameter als Strings.
|
(package private) void |
generiereRegelmaesigeAxlAbfragen()
Generiert eine regelmaessige Axl Abfrage.
|
(package private) void |
generiereRegelmaesigeLveAbfragen()
Stellt dem Wecker fest duer die naechste regelmaesige Abfrage.
|
static String |
getAbfrageModul()
Erfragt die PID des assoziierten Abfragemoduls.
|
long |
getAbrufIntervallAxl()
Erfargt nach dem Abrufintervall fuer Axl Daten.
|
long |
getAbrufIntervallLve()
Erfraget nach den Abrufintervall fuer Lve Daten.
|
static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager |
getArchivSettingsManager()
liefert den aktiven Settingsmanager für den Archivdatensatz.
|
protected AbstraktDeVerwaltung |
getAxlDeVerwaltung() |
de.bsvrz.dav.daf.main.ClientDavInterface |
getDatenVerteiler()
Erfragt eine Instanz des DAVs.
|
protected de.bsvrz.dav.daf.main.ClientDavInterface |
getDav() |
protected AbstraktDeVerwaltung |
getLveDeVerwaltung() |
de.bsvrz.sys.funclib.operatingMessage.MessageSender |
getnachrichtenSender()
Liefert dem Nachrichtensender.
|
protected long |
getNaechsteAbfrageAxl() |
protected long |
getNaechsteAbfrageAxlNeu() |
protected long |
getNaechsteAbfrageLve() |
protected long |
getNaechsteAbfrageLveNeu() |
protected List<Station> |
getStationen() |
de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp |
getSWETyp()
Typ der SWE.
|
void |
initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) |
void |
initLveAxlVerwaltung()
Wegen Testzwecken wird es ueberschrieben.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
void |
lveAlarm()
Startet eine regelmaesige Lve Abfrage.
|
static void |
main(String[] args)
Wird zum Start der Applikation aufgerufen.
|
void |
parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) |
static void |
printVerwendung()
Anwendungsparameter.
|
void |
setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei)
Stellt die Abrufperiode fest, wird bei Aenderung der Parametrierung
gerufen.
|
protected void |
setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung) |
void |
setGloFehler(de.bsvrz.dav.daf.main.ResultData datei)
Stelt den Status des Objektes aus einer GloFehlermeldung fest.
|
protected void |
setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung) |
protected void |
setLzdAggregation(AggregatorVerwaltung lzdAggregation) |
void |
streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter,
Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte,
de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
boolean relative,
long intervalBeginnOderAnzahl,
long intervalEnde)
Macht eine StreamAbfrage.
|
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
private static final de.bsvrz.sys.funclib.debug.Debug LOGGER
private static String abfrageModul
private static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager archivSettingsManager
private de.bsvrz.dav.daf.main.ClientDavInterface dav
private final de.bsvrz.sys.funclib.operatingMessage.MessageSender nachrichtenSender
protected static final String P_SM
protected static final String P_ALLE_ONLINE
protected static final String P_ABFRAGE_MODUL
private final Object abfrageModulEinstellungenMutex
private StreamBasierteArchivAnfrage sbAnfrage
private static de.bsvrz.dav.daf.main.DataDescription ddGloFehler
private static de.bsvrz.dav.daf.main.DataDescription ddAbfrageModul
private final Collection<de.bsvrz.dav.daf.main.config.SystemObject> sysObjSteuerModule
private final Collection<de.bsvrz.dav.daf.main.config.ConfigurationArea> sysObjKonfBereiche
private String[] paramKonfigurationsObjekte
private final Object datenZugriffMutex
private final List<Station> stationen
private AbstraktDeVerwaltung lveDeVerwaltung
private AbstraktDeVerwaltung axlDeVerwaltung
private AggregatorVerwaltung lzdAggregation
private boolean erstmalAngemeldet
private boolean alleMuessenOnlineSein
private long abfrageIntervallAxl
private long abfrageIntervallAxlNeu
private long naechsteAbfrageAxl
private long naechsteAbfrageAxlNeu
private long abfrageIntervallLve
private long abfrageIntervallLveNeu
private long naechsteAbfrageLve
private long naechsteAbfrageLveNeu
private final de.bsvrz.sys.funclib.bitctrl.dua.ObjektWecker wecker
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener axlAbfragen
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener lveAbfragen
private de.bsvrz.sys.funclib.bitctrl.dua.schnittstellen.IObjektWeckerListener aggregationStart
private final long aggregationVerspaetung
protected static final long ZEIT_TOLERANZ
public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) throws Exception
parseArguments
in interface de.bsvrz.sys.funclib.application.StandardApplication
Exception
public static void printVerwendung()
public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) throws Exception
initialize
in interface de.bsvrz.sys.funclib.application.StandardApplication
Exception
public static final String getAbfrageModul()
null
,
wenn keines angegeben wurdepublic void initLveAxlVerwaltung()
public de.bsvrz.dav.daf.main.DataDescription erzeugeDatenBeschreibung(String atg, String asp, short var)
atg
- Atributgruppeasp
- Aspektvar
- Simulation Variantpublic void anmeldeAbfrageModulParametrierung()
public void anmeldeGloFehler()
public de.bsvrz.sys.funclib.operatingMessage.MessageSender getnachrichtenSender()
public void abmeldeGloFehler()
public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription, byte state)
dataRequest
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription)
isRequestSupported
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public void update(de.bsvrz.dav.daf.main.ResultData[] results)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public void streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter, Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, boolean relative, long intervalBeginnOderAnzahl, long intervalEnde)
bearbeiter
- Der Objekt, der die Antwort bearbeiten wird, muss
SBArchivAnfrageBearbeiter implementierenobjekte
- Die Objekte, an deren Daten wir nachfragen wollendatenBeschreibung
- Die DatenBeschreibung fuer die Datenrelative
- true, wenn die Abfrage relativ istintervalBeginnOderAnzahl
- Beginn des abfragenden Intervalls oder Anzahl der Datensaetze
bei relativen AbfragenintervalEnde
- Ende des abfrafenden Intervallspublic void setGloFehler(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.tlsGloFehler, die empfangen wurdepublic void setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.abfrageModul, die empfangen wurdevoid generiereRegelmaesigeAxlAbfragen()
void generiereRegelmaesigeLveAbfragen()
public void axlAlarm()
public void lveAlarm()
public static void main(String[] args)
args
- Aufrufargumente der Applikationpublic de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp getSWETyp()
public de.bsvrz.dav.daf.main.ClientDavInterface getDatenVerteiler()
public void aggregiere()
public void aggregationStart()
public long getAbrufIntervallAxl()
public long getAbrufIntervallLve()
public long currentTimeMillis()
public long convertZeitIntervall(long zeitIntervall)
zeitIntervall
- Virtueller ZeitIntervallpublic long convertTimeoutIntervall(long intervall)
intervall
- Virtueller Timeout Intervallpublic long convertAbsoluteEchtZeit(long zeit)
zeit
- Echter Zeitpunktpublic long convertAbsoluteVirtuelleZeit(long zeit)
zeit
- Virtueller Zeitpunktpublic static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager getArchivSettingsManager()
protected AbstraktDeVerwaltung getLveDeVerwaltung()
protected AbstraktDeVerwaltung getAxlDeVerwaltung()
protected void setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung)
protected void setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung)
protected long getNaechsteAbfrageLveNeu()
protected long getNaechsteAbfrageLve()
protected long getNaechsteAbfrageAxlNeu()
protected long getNaechsteAbfrageAxl()
protected void setLzdAggregation(AggregatorVerwaltung lzdAggregation)
protected de.bsvrz.dav.daf.main.ClientDavInterface getDav()
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.