|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.vew.sim.sim.datengenerator.DatenGeneratorSimulation
de.bsvrz.vew.sim.sim.datengenerator.DatenGeneratorOfflineSimulation
public class DatenGeneratorOfflineSimulation
Simulations-Datengenerator für Offline-Simulationen
Nested Class Summary | |
---|---|
class |
DatenGeneratorOfflineSimulation.QueueArbeiter
Asynchrones Abarbeiten und Versenden der Daten, die aus dem Archiv hereinkommen |
Field Summary | |
---|---|
private java.lang.Thread |
_archivAdapter
Archiv-Bearbeitungs-Thread |
private static de.bsvrz.sys.funclib.debug.Debug |
_debug
Debug-Logger für Logging-Ausgaben |
private float |
_faktor
Geschwindigkeitsfaktor der zugeordneten Simulation |
private boolean |
_isGestartet
Ist der Datengenerator gestartet? |
private boolean |
_isInaktiv
Ist der Verarbeitungsthread gerade inaktiv? |
private boolean |
_isPausiert
Ist der Datengenerator im Zustand "Pause" |
private long |
_lastPauseReal
Letzter Pausenzeitpunkt - in Echtzeit |
private long |
_lastPauseSimu
Letzter Pasenzeitpunkt - in Simulationszeit |
private long |
_letzterZeitStempel
Letzter verabeitetet Zeitstempel |
private java.lang.Thread |
_queueArbeiter
Eingangsdaten-Bearbeitungs-und Sendethread |
private java.util.Map<java.lang.String,DatenSpezifikation> |
_sendeAnmeldungen
Alle bearbeitenden Datenspezifikationen |
private long |
_simulationsBeginn
Beginn der zugeordneten Simulation |
private long |
_simulationsEnde
Ende der zugeordneten Simulation |
private java.util.LinkedList<de.bsvrz.dav.daf.main.archive.ArchiveData> |
_zuSendendeDaten
(Pseudo-) Queue der Eingangsdaten - wird vom _archivAdapter
gefüllt und vom _queueArbeiter geleert |
Fields inherited from interface de.bsvrz.dav.daf.main.ClientSenderInterface |
---|
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION |
Constructor Summary | |
---|---|
DatenGeneratorOfflineSimulation(OfflineSimulation simulation)
Erzeuge neue Instanz des Datengenerators |
Method Summary | |
---|---|
private void |
abmeldenSenden()
Abmelden aller Sendeanmeldungen |
protected OfflineSimulation |
getSimulation()
Bestimmt die Simulation, für die diese Instanz Daten generiert |
(package private) long |
getSimulationsBeginn()
Bestimme den Beginn der zugeordneten Simulation |
(package private) long |
getSimulationsEnde()
Bestimme das Ende der zugeordneten Simulation |
private long |
getSimulationsZeit()
Bestimmt die Simulationszeit |
protected void |
init()
Initilaisiere den Datengenrator |
boolean |
isGestartet()
Bestimmt den Lauf-Status des Datengenerators |
boolean |
isPausiert()
Bestimmt den Pause-Status des Datengenerators |
void |
pause()
Setze den Datengenerator in den Zustand "Pause" |
(package private) void |
putData(de.bsvrz.dav.daf.main.archive.ArchiveData archiveData)
Plaziere Datensatz in der Pseudo-Queue der Eingangsdaten |
protected void |
sendeDaten(java.util.Collection<de.bsvrz.dav.daf.main.ResultData> sendePuffer)
Sendet Daten asynchron an den Datenverteiler |
private void |
sendeSimulationZeit(long time)
Sendet eine Zeitangabe als Simulationszeit an den Datenverteiler |
void |
start()
Starte den Datengenerator |
void |
stop()
|
Methods inherited from class de.bsvrz.vew.sim.sim.datengenerator.DatenGeneratorSimulation |
---|
analysiereEingangsDaten, dataRequest, getConnection, getSimulationsStrecke, isRequestSupported, sendeDaten |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final de.bsvrz.sys.funclib.debug.Debug _debug
private java.util.LinkedList<de.bsvrz.dav.daf.main.archive.ArchiveData> _zuSendendeDaten
_archivAdapter
gefüllt und vom _queueArbeiter
geleert
private java.util.Map<java.lang.String,DatenSpezifikation> _sendeAnmeldungen
private boolean _isGestartet
private java.lang.Thread _archivAdapter
private java.lang.Thread _queueArbeiter
private long _simulationsBeginn
private long _simulationsEnde
private long _lastPauseReal
private long _lastPauseSimu
private long _letzterZeitStempel
private float _faktor
private boolean _isPausiert
private boolean _isInaktiv
Constructor Detail |
---|
public DatenGeneratorOfflineSimulation(OfflineSimulation simulation)
simulation
- Die Offline-Simulation, für die der Datengenerator
erzeugt werden sollMethod Detail |
---|
void putData(de.bsvrz.dav.daf.main.archive.ArchiveData archiveData)
archiveData
- Archiv-Datensatz der Eingangsdatenlong getSimulationsBeginn()
long getSimulationsEnde()
protected OfflineSimulation getSimulation()
DatenGeneratorSimulation
getSimulation
in class DatenGeneratorSimulation
public boolean isGestartet()
DatenGeneratorSimulation
isGestartet
in class DatenGeneratorSimulation
public boolean isPausiert()
protected void init()
DatenGeneratorSimulation
init
in class DatenGeneratorSimulation
public void pause()
public void start()
DatenGeneratorSimulation
start
in class DatenGeneratorSimulation
public void stop()
stop
in class DatenGeneratorSimulation
private void sendeSimulationZeit(long time)
time
- die Zeit, die als Simualtionszeit gesendet werden sollprivate long getSimulationsZeit()
private void abmeldenSenden()
protected void sendeDaten(java.util.Collection<de.bsvrz.dav.daf.main.ResultData> sendePuffer)
DatenGeneratorSimulation
sendeDaten
in class DatenGeneratorSimulation
sendePuffer
- die zu sendenden Daten
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |