public class BuildOsi7Telegram
extends java.lang.Thread
Modifier and Type | Class and Description |
---|---|
(package private) class |
BuildOsi7Telegram.MultiBlockTransfer
Klasse zur Repräsentation von zusammenhängend zu übertragenden
DE-Blöcken (mit gleicher Jobnummer).
|
Modifier and Type | Field and Description |
---|---|
private java.util.Map<De,BuildOsi7Telegram.MultiBlockTransfer> |
_blockTransfers
Map mit Zuordnungen von Blocktransfers zu De.
|
private Queue |
_deBlockQueue |
private DeBlocksMultiBlockTransfer |
_deBlocksMultiBlockTransfer
Klasse mit den Definitionen der nicht zusammenzufassenden DE-Blöcke.
|
private java.util.List<DeBlockToSend> |
_deBlocksToSend |
private int |
_jobNumber |
private de.bsvrz.kex.tls.osi2osi3.osi3.NetworkLayer |
_networkLayer |
private NewRouting |
_newRouting |
private SendingOsi7AdressNull |
_sendingOsi7AdressNull |
private boolean |
_sendOnlyConnectedSM |
private boolean |
_sendOnlyDeOk |
private int |
COUNT_DEBLOCKS_INDEX |
private static de.bsvrz.sys.funclib.debug.Debug |
debug
DebugLogger für Debug-Ausgaben
|
private int |
LENGTH_SINGLETELEGRAM_INDEX
Inices für den Aufbau des Telegrammkopfes
|
Constructor and Description |
---|
BuildOsi7Telegram(Queue deBlockQueue,
de.bsvrz.kex.tls.osi2osi3.osi3.NetworkLayer networkLayer,
boolean sendOnlyDeOk,
boolean sendOnlyConnectedSM)
Erzeugt ein Objekt vom Typ BuildOsi7Telegram
|
Modifier and Type | Method and Description |
---|---|
private void |
erzeugeOsi7Telegramme(java.util.List<DeBlockToSend> deBlocks,
boolean sendAsSingleJob)
Erzeugt und versendet OSI7-Telegramme für eine Liste von zu versendenden
DE-Blöcken.
|
private int |
getJobNumber()
Ermittelt die nächste zu verwendende Jobnummer.
|
private DeBlockToSend |
getNextDeBlockToSend(java.util.List<DeBlockToSend> deBlocksToSend,
int osi7Adress,
int fg,
int id,
int maxByteCountForDeBlocks)
Liefert einen DeBlock zurück, der in das aktuelle Einzeltelegramm eingefügt werden kann (Übereinstimmung von
Osi7Adresse, Fg, ID) und der kürzer als die noch verfügbare Restlänge des Einzeltelegramms ist.
|
private int |
getOsi7Adress(DeBlock deBlock)
Ermittelt die Osi7Adresse für den De-Block.
|
void |
run()
When an object implementing interface
Runnable is used to create a thread, starting the thread causes
the object's run method to be called in that separately executing thread. |
private void |
sendOsi7Telegramm(TlsData tlsData,
De de)
Versendet das übergebene Telegramm
|
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 de.bsvrz.sys.funclib.debug.Debug debug
private final int COUNT_DEBLOCKS_INDEX
private final int LENGTH_SINGLETELEGRAM_INDEX
private java.util.Map<De,BuildOsi7Telegram.MultiBlockTransfer> _blockTransfers
private Queue _deBlockQueue
private DeBlocksMultiBlockTransfer _deBlocksMultiBlockTransfer
private java.util.List<DeBlockToSend> _deBlocksToSend
private int _jobNumber
private de.bsvrz.kex.tls.osi2osi3.osi3.NetworkLayer _networkLayer
private NewRouting _newRouting
private SendingOsi7AdressNull _sendingOsi7AdressNull
private boolean _sendOnlyConnectedSM
private boolean _sendOnlyDeOk
public BuildOsi7Telegram(Queue deBlockQueue, de.bsvrz.kex.tls.osi2osi3.osi3.NetworkLayer networkLayer, boolean sendOnlyDeOk, boolean sendOnlyConnectedSM)
private void erzeugeOsi7Telegramme(java.util.List<DeBlockToSend> deBlocks, boolean sendAsSingleJob)
deBlocks
- zu versendende DE-BlöckesendAsSingleJob
- sende die OSI7-Telegramme mit gleicher Jobnummer ja/neinprivate int getJobNumber()
private DeBlockToSend getNextDeBlockToSend(java.util.List<DeBlockToSend> deBlocksToSend, int osi7Adress, int fg, int id, int maxByteCountForDeBlocks)
deBlocksToSend
- Die noch zu versendenden De-Blöcke.osi7Adress
- Adresse, an die der zu suchende De-Block gesendet werden muss.fg
- Funktionsgruppe, die der zu suchende De-Block haben werden muss.id
- ID, , die der zu suchende De-Block haben werden muss.maxByteCountForDeBlocks
- Maimale Länge, , die der zu suchende De-Block haben darf.private int getOsi7Adress(DeBlock deBlock)
deBlock
- De-Block, für den Osi7Adresse ermittelt werden soll.public void run()
Runnable
is used to create a thread, starting the thread causes
the object's run
method to be called in that separately executing thread.
The general contract of the method run
is that it may take any action whatsoever.run
in interface java.lang.Runnable
run
in class java.lang.Thread
Thread.run()