Commit bccf1b7d authored by Steffen Gieseler's avatar Steffen Gieseler

Testsuite 1 bearbeitet

git-svn-id: svn://ntoserver/Datenverteiler/VRZ3/trunk/de.bsvrz.ste.tmcvew@63244 40c0be50-5d29-0410-901d-fb59edb5cafc
parent 92ae5bef
......@@ -55,7 +55,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* TMC-Meldungen wird bezüglich neuen Elementen und Löschung vorhandener
* Elemente überwacht.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......@@ -200,14 +200,7 @@ public class TMCVerwaltung implements MutableSetChangeListener, InvalidationList
return ohneZeitstempelKorrektur;
}
/*
* (Kein Javadoc)
*
* @see
* de.bsvrz.dav.daf.main.config.MutableSetChangeListener#update(de.bsvrz.dav
* .daf.main.config.MutableSet, de.bsvrz.dav.daf.main.config.SystemObject[],
* de.bsvrz.dav.daf.main.config.SystemObject[])
*/
@Override
public void update(final MutableSet set, final SystemObject[] addedObjects, final SystemObject[] removedObjects) {
DEBUG.fine("MutableSetChangeListener.update() von \"" + set.getName() + "\"");
......@@ -281,26 +274,14 @@ public class TMCVerwaltung implements MutableSetChangeListener, InvalidationList
}
}
/*
* (Kein Javadoc)
*
* @see
* de.bsvrz.dav.daf.main.config.InvalidationListener#invalidObject(de.bsvrz.
* dav.daf.main.config.DynamicObject)
*/
@Override
public void invalidObject(final DynamicObject dynamicObject) {
DEBUG.config("Objekt " + dynamicObject + " gelöscht/invalidiert => wird nicht weiter verwaltet");
bereinigeMeldung(dynamicObject);
}
/*
* (Kein Javadoc)
*
* @see
* de.bsvrz.dav.daf.main.ClientReceiverInterface#update(de.bsvrz.dav.daf.
* main.ResultData[])
*/
@Override
public void update(final ResultData[] resultData) {
for (ResultData data : resultData) {
final Aspect asp = data.getDataDescription().getAspect();
......@@ -329,7 +310,9 @@ public class TMCVerwaltung implements MutableSetChangeListener, InvalidationList
private long rdsMeldungsRueckhaltung = -1;
/**
* @return den Wert des Parameters RDSMeldungsRückhaltung
* Gibt den Wert des Parameters RDSMeldungsRückhaltung zurück.
*
* @return Wert des Parameters RDSMeldungsRückhaltung
*/
public long getRDSMeldungsRueckhaltung() {
return rdsMeldungsRueckhaltung;
......@@ -341,7 +324,9 @@ public class TMCVerwaltung implements MutableSetChangeListener, InvalidationList
private String rdsMeldungsAktion;
/**
* @return den Wert des Parameters RDSMeldungsAktion
* Gibt den Wert des Parameters RDSMeldungsAktion zurück.
*
* @return Wert des Parameters RDSMeldungsAktion
*/
public String getRDSMeldungsAktion() {
return rdsMeldungsAktion;
......
......@@ -43,9 +43,7 @@ import de.bsvrz.sys.funclib.operatingMessage.MessageSender;
* Das Konfigurationsobjekt der LMS enthält insbesondere die zu verwendeten
* Parameter.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von:
* //@author Dambach Werke GmbH
* //@author Stefan Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......@@ -160,7 +158,7 @@ public class TMCVerwaltungApp implements StandardApplication {
if (argumentList.hasArgument("-ohneZeitstempelKorrektur")) {
final String text = argumentList.fetchArgument("-ohneZeitstempelKorrektur=").asString();
if (text.equals("1") || text.equalsIgnoreCase("true") || text.equalsIgnoreCase("wahr")) {
if ("1".equals(text) || "true".equalsIgnoreCase(text) || "wahr".equalsIgnoreCase(text)) {
ohneZeitstempelKorrektur = OPTION_OHNE_ZEITSTEMPEL_KORREKTUR;
}
}
......
......@@ -47,8 +47,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* Modelliert eine TMC-Meldungen so wie sie von der SWE TMC-Meldungsverwaltung
* benötigt wird.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan
* Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......
......@@ -38,8 +38,6 @@ import de.bsvrz.dav.daf.main.SenderRole;
import de.bsvrz.dav.daf.main.config.Aspect;
import de.bsvrz.dav.daf.main.config.AttributeGroup;
import de.bsvrz.dav.daf.main.config.SystemObject;
import de.bsvrz.ste.tmcvew.parameter.ParameterEmpfaenger;
import de.bsvrz.ste.tmcvew.parameter.ParameterSender;
import de.bsvrz.sys.funclib.debug.Debug;
/**
......@@ -48,8 +46,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* ClientSenderInterface welches die Methoden zum Versenden der Daten
* bereitstellt.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan
* Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......@@ -260,7 +257,7 @@ public class TMCVewSender implements ClientSenderInterface {
}
/**
* Setzt den aktuell aktiven SendeThread
* Setzt den aktuell aktiven SendeThread.
*
* @param sendeThread
* der zu setztende SendeThread
......
......@@ -24,6 +24,5 @@
* mailto: info@bitctrl.de
*/
/** Testklassen. */
package de.bsvrz.ste.tmcvew;
......@@ -41,8 +41,7 @@ import de.bsvrz.dav.daf.main.config.TimeAttributeType;
/**
* Methoden zur Bearbeitung von Datensätzen.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan
* Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......
......@@ -47,8 +47,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* aber eine unterschiedliche ATG haben Die Empfangs-Anmeldung -und Abmeldung
* erfolgt im Konstruktor.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan
* Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......@@ -88,13 +87,22 @@ public class ParameterEmpfaenger implements ClientReceiverInterface {
/**
* Ist auf true gesetzt, solange auf update gewartet wird.
*/
private boolean _warten;
private boolean warten;
/**
* Empfangene Daten.
*/
private ResultData _data;
private ResultData davData;
/**
* Konstruktor.
*
* @param con {@link ClientDavInterface}
* @param obj {@link SystemObject}
* @param atgQuellPid PID der Quell-Attributgruppe
* @param datenBeschreibungZiel {@link DataDescription} für Zieldaten
*/
public ParameterEmpfaenger(final ClientDavInterface con, final SystemObject obj, final String atgQuellPid,
final DataDescription datenBeschreibungZiel) {
connection = con;
......@@ -114,13 +122,13 @@ public class ParameterEmpfaenger implements ClientReceiverInterface {
+ davObjekt.getPid());
synchronized (this) {
if (getData() == null) {
_warten = true;
warten = true;
try {
wait(TIMEOUT);
} catch (final InterruptedException e) {
// tue nichts
}
_warten = false;
warten = false;
}
}
......@@ -132,29 +140,25 @@ public class ParameterEmpfaenger implements ClientReceiverInterface {
DEBUG.finest("Empfang abgemeldet von " + datenBeschreibungQuell + " für " + davObjekt);
}
/**
* @deprecated Nur zur Rückwartskompatibilität erhalten, Ziel-Aspekt wird
* hier (fälschlicherweise?) auf asp.parameterSoll gesetzt
*/
public ParameterEmpfaenger(final ClientDavInterface con, final SystemObject obj, final String atgQuellPid, final String atgZielPid) {
this(con, obj, atgQuellPid, new DataDescription(con.getDataModel().getAttributeGroup(atgZielPid),
con.getDataModel().getAspect("asp.parameterSoll")));
}
// /**
// * @deprecated Nur zur Rückwartskompatibilität erhalten, Ziel-Aspekt wird
// * hier (fälschlicherweise?) auf asp.parameterSoll gesetzt
// */
// public ParameterEmpfaenger(final ClientDavInterface con, final SystemObject obj, final String atgQuellPid, final String atgZielPid) {
// this(con, obj, atgQuellPid, new DataDescription(con.getDataModel().getAttributeGroup(atgZielPid),
// con.getDataModel().getAspect("asp.parameterSoll")));
// }
/**
* @return die empfangenen Daten
* Gibt die empfangenen Daten zurück.
*
* @return {@link ResultData}
*/
public ResultData getData() {
return _data;
return davData;
}
/*
* (Kein Javadoc)
*
* @see
* de.bsvrz.dav.daf.main.ClientReceiverInterface#update(de.bsvrz.dav.daf.
* main.ResultData[])
*/
@Override
public void update(final ResultData[] resultData) {
for (ResultData data : resultData) {
final Aspect asp = data.getDataDescription().getAspect();
......@@ -165,15 +169,15 @@ public class ParameterEmpfaenger implements ClientReceiverInterface {
if (data.hasData()) {
final Data datenSatz = connection.createData(datenBeschreibungZiel.getAttributeGroup());
DatenTools.tiefeKopie(data.getData(), datenSatz);
_data = new ResultData(davObjekt, datenBeschreibungZiel, data.getDataTime(), datenSatz);
davData = new ResultData(davObjekt, datenBeschreibungZiel, data.getDataTime(), datenSatz);
DEBUG.fine(
"Bestehende Parameter-Daten empfangen von " + atg.getPid() + " für " + davObjekt.getPid());
} else {
_data = new ResultData(davObjekt, datenBeschreibungZiel, data.getDataTime(), null);
davData = new ResultData(davObjekt, datenBeschreibungZiel, data.getDataTime(), null);
}
}
}
if (_warten) {
if (warten) {
synchronized (this) {
notify();
}
......
......@@ -48,8 +48,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* Das Senden der Daten unter asp.parameterVorgabe erfolgt nach dem Starten des
* Threads, der eine Instanz dieser Klasse verkörpert.
*
* Erstellt auf Basis der SWE RDS/TMC-Meldungen von: Dambach Werke GmbH, Stefan
* Sans
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
......
/*
* Segment 7 (Ste), SWE TMC-Meldungsverwaltung
* Copyright (C) 2016 BitCtrl Systems GmbH
*
* This program is free software; you can redistribute it and/or modify it under
* the terms of the GNU Lesser General Public License as published by the Free
* Software Foundation; either version 2.1 of the License, or (at your option)
* any later version.
*
* This programm is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
* details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program; if not, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Contact Information:
* BitCtrl Systems GmbH
* Weißenfelser Straße 67
* 04229 Leipzig
* Phone: +49 341-490670
* mailto: info@bitctrl.de
*/
package de.bsvrz.ste.tmcvew.parameter;
......@@ -25,114 +25,103 @@
package de.bsvrz.ste.tmcvew;
import java.util.Iterator;
import java.util.Timer;
import java.util.TimerTask;
import java.util.Vector;
import de.bsvrz.dav.daf.main.ClientDavConnection;
import de.bsvrz.dav.daf.main.config.DynamicObject;
/**
* Klasse instanziert die RDS-Meldungen f�r jedes RDS-objekt.
* Sie empf�ngt �ber eine Listenerfunktionalit�t die RDS-Meldungen.
*
* Klasse instanziert die RDS-Meldungen f�r jedes RDS-objekt. Sie empf�ngt �ber
* eine Listenerfunktionalit�t die RDS-Meldungen.
*
* @author Dambach Werke GmbH
* @version $Revision: 1.1 $ / $Date: 2008/10/29 12:09:03 $ / ($Author: Hilpp $)
*/
public class RdsMeldungsAuswertung
{
/**
* Debug M�glichkeit
*/
private boolean _debug = false;
/**
* Pid des Objekts
*/
private String m_pid = null;
/**
* Eigenschaften des Staus
*/
private RdsMeldungsEmpfang m_rdsmeldung = null;
/**
* Verbindung zum DaV
*/
private ClientDavConnection m_connection = null;
private long m_flag = 0;
/**
* Konstruktor der Klasse:
*/
public RdsMeldungsAuswertung( )
{}
/**
* Konstruktor der Klasse:
* Meldet sich �ber eine Listenerfunktionalit�t auf die RDS-Meldungen an
* Instanziert due Objekte "RdsMeldungsEmpfang"
* @param connection Verbindung zum DaV
* @param pidStau Pid vom Typ "typ.rdsMeldung"
*/
public RdsMeldungsAuswertung(ClientDavConnection connection, String pid )
{
m_connection = connection;
m_pid = pid;
// Staueigenschaften am Listener anmelden
m_rdsmeldung = new RdsMeldungsEmpfang (m_connection, pid);
m_rdsmeldung.addListener( new INeueDatenListener ()
{
public void neueDaten()
{
setFlag();
// System.out.println("RdsmeldungsAuswertungen -> RDS-Meldung empfangen ");
}}
);
}
public RdsMeldungsEmpfang getParameter()
{
return m_rdsmeldung ;
}
public long getFlag()
{
return m_flag;
}
public long setFlag()
{
return m_flag++;
}
/**
* Methode liefert die PID des Objektes
* @return pid Stauobjekt
*/
public String getPid()
{
return m_pid;
}
/**
* Methode ermittelt die Lage der Stauwurzel relativ zum Routenanfang.
* Ergebnis in Meter
*/
/**
* Methode zum L�schen dieser Stauprognose. Dabei werden alle angemeldeten Listener und die
* Verbindungen zum DaV gel�scht.
*/
public void dispose ()
{
// Staueigenschaften
m_rdsmeldung.dispose();
}
public class RdsMeldungsAuswertung {
/**
* Debug M�glichkeit
*/
private boolean _debug = false;
/**
* Pid des Objekts
*/
private String m_pid = null;
/**
* Eigenschaften des Staus
*/
private RdsMeldungsEmpfang m_rdsmeldung = null;
/**
* Verbindung zum DaV
*/
private ClientDavConnection m_connection = null;
private long m_flag = 0;
/**
* Konstruktor der Klasse:
*/
public RdsMeldungsAuswertung() {
}
/**
* Konstruktor der Klasse: Meldet sich über eine Listenerfunktionalität auf
* die RDS-Meldungen an Instanziert due Objekte "RdsMeldungsEmpfang"
*
* @param connection
* Verbindung zum DaV
* @param pid
* Pid vom Typ "typ.rdsMeldung"
*/
public RdsMeldungsAuswertung(ClientDavConnection connection, String pid) {
m_connection = connection;
m_pid = pid;
// am Listener anmelden
m_rdsmeldung = new RdsMeldungsEmpfang(m_connection, pid);
m_rdsmeldung.addListener(new INeueDatenListener() {
public void neueDaten() {
setFlag();
System.out.println("RdsmeldungsAuswertungen -> RDS-Meldung empfangen ");
}
});
}
public RdsMeldungsEmpfang getParameter() {
return m_rdsmeldung;
}
public long getFlag() {
return m_flag;
}
public long setFlag() {
return m_flag++;
}
/**
* Methode liefert die PID des Objektes
*
* @return pid Stauobjekt
*/
public String getPid() {
return m_pid;
}
/**
* Methode ermittelt die Lage der Stauwurzel relativ zum Routenanfang.
* Ergebnis in Meter
*/
/**
* Methode zum L�schen dieser Stauprognose. Dabei werden alle angemeldeten
* Listener und die Verbindungen zum DaV gel�scht.
*/
public void dispose() {
// Staueigenschaften
m_rdsmeldung.dispose();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment