public class AbfragePufferdaten
extends java.lang.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 |
---|---|
protected static java.lang.String |
P_ABFRAGE_MODUL
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static java.lang.String |
P_ALLE_ONLINE
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static java.lang.String |
P_SM
Parameter dem man erkennen soll SteuerModule und Konfigurationsbereiche
die verwaltet werden sollen.
|
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(java.lang.String atg,
java.lang.String asp,
short var)
Erzeugt eine DatenBeschreibung mit gegebenen Parameter als Strings.
|
static java.lang.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 java.util.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(java.lang.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,
java.util.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) |
protected static final java.lang.String P_SM
protected static final java.lang.String P_ALLE_ONLINE
protected static final java.lang.String P_ABFRAGE_MODUL
protected static final long ZEIT_TOLERANZ
public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) throws java.lang.Exception
parseArguments
in interface de.bsvrz.sys.funclib.application.StandardApplication
java.lang.Exception
public static void printVerwendung()
public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) throws java.lang.Exception
initialize
in interface de.bsvrz.sys.funclib.application.StandardApplication
java.lang.Exception
public static final java.lang.String getAbfrageModul()
null
,
wenn keines angegeben wurdepublic void initLveAxlVerwaltung()
public de.bsvrz.dav.daf.main.DataDescription erzeugeDatenBeschreibung(java.lang.String atg, java.lang.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, java.util.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 wurdepublic void axlAlarm()
public void lveAlarm()
public static void main(java.lang.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 java.util.List<Station> getStationen()
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()