- sendAllStreamData() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Diese Methode verschickt Nutzdaten, die die Senderapplikation erzeugt hat, an den Empfänger (StreamDemultiplexer).
- sendData(byte[]) - Method in interface de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexerDirector
-
Diese Methode wird von einem StreamMultiplexer aufgerufen und wenn ein Byte-Array an den entsprechenden
StreamDemultiplexer gesendet werden soll.
- sendDataToReceiver(int, int, byte[]) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Diese Methode verschickt die Nutzdaten über einen bestimmten Stream an den Empfänger.
- sendNewTicketIndexToSender(int, int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Der Sender wird benachrichtigt, dass er auf einem Stream weitere Nutzdatenpakete schicken darf.
- sendNewTicketIndexToSender(byte[]) - Method in interface de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexerDirector
-
- setCurrentStreamPacketIndex(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
- setEndStreamTrue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Der Stream bei einem take Aufruf ein null-Paket zurück geliefert.
- setLostConnectionToSenderTrue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Da die physische Verbindung zum Sender unterbrochen wurde, und somit keine Nutzdatenpakete mehr ankommen, können
die restlichen Nutdaten auch gelöscht werden.
- setMaximumStreamTicketIndexForStream(byte[]) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Diese Methode setzt den "maximumStreamTicketIndex" eines Streams herauf.
- setMaxStreamPacketIndex(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
- setMaxStreamPacketIndex(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
- setNextPacketIndex(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Der Index des Nutzdatenpakets, das als nächstes erwartet wird, wird hier neu gesetzt.
- setPacketIndexToSendNextMaxTicketIndex(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
- setStreamAbortedTrue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Der Stream wurde abgebrochen, es kann passieren, dass noch Threads in der _bigDataPacketQueue hängen und auf Daten
warten.
- setStreamFinished() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Der Stream darf keine Daten mehr senden.
- setStreamTerminated(int) - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Der Stream darf keine Daten mehr senden.
- setStreamTerminatedTrue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Da Fehlerhafte Nutzdatenpakete empfangen wurden, können alle empfangenen Nutzdatenpakete, die sich in der dataQueue
befinden, verworfen werden.
- sizeOfDataQueue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Diese Methode dient zum Debuggen.
- sizeOfSmallDataPacketQueue() - Method in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Bestimmt die Größe der Queue, die die Nutzdatenpakete für die Empfängerapplikation speichert.
- streamAborted(int) - Method in interface de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexerDirector
-
Wenn die Empfängerapplikation keine Nutzdaten mehr verarbeiten kann (aus welchem Grund auch immer), wird sie den
Stream auf Empfängerseite (StreamDemultiplexer) mit abort beenden.
- StreamDemultiplexer - Class in de.bsvrz.sys.funclib.communicationStreams
-
Diese Klasse empfängt Nutzdatenpakete, die vom StreamMultiplexer über Streams versandt wurden.
- StreamDemultiplexer(int, int, StreamDemultiplexerDirector) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
- StreamDemultiplexer.DemultiplexerStreaminformations - Class in de.bsvrz.sys.funclib.communicationStreams
-
Diese Objekt beinhaltet alle Informationen, die für einen Stream, auf Empfängerseite, wichtig sind.
- StreamDemultiplexer.DemultiplexerStreaminformations(int, int, int) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
- StreamDemultiplexer.ReferenceDataPacket - Class in de.bsvrz.sys.funclib.communicationStreams
-
Objekte dieser Klasse speichern die Nutzdaten(Byte-Array) und den Index der Nutzdaten.
- StreamDemultiplexer.ReferenceDataPacket(int, byte[]) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.ReferenceDataPacket
-
- StreamDemultiplexerDirector - Interface in de.bsvrz.sys.funclib.communicationStreams
-
Dieses Interface muss implementiert werden, wenn ein StreamMultiplexer mit einem StreamDemultiplexer Nutzdatenpakete austauschen soll.
- StreamMultiplexer - Class in de.bsvrz.sys.funclib.communicationStreams
-
Diese Klasse verschickt Nutzdatenpakete mit Streams an einen StreamDemultiplexer.
- StreamMultiplexer(int, int, int, int, StreamMultiplexerDirector) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
- StreamMultiplexer.IndexOfStreamAndMaxSendPackets - Class in de.bsvrz.sys.funclib.communicationStreams
-
Diese Klasse erzeugt ein Objekt für die Warteschlange "_queueWithStreamsPermitedToSendData".
- StreamMultiplexer.IndexOfStreamAndMaxSendPackets(int, int) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.IndexOfStreamAndMaxSendPackets
-
- StreamMultiplexer.MultiplexerStreaminformations - Class in de.bsvrz.sys.funclib.communicationStreams
-
Diese Objekt beinhaltet alle Informationen, die für einen Stream, auf Senderseiteseite, wichtig sind.
- StreamMultiplexer.MultiplexerStreaminformations(int, StreamMultiplexerDirector) - Constructor for class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Beim erzeugen des Objekts wird sofort festgelegt, wie viele Nutzdatenpakete vom Sender beim ersten Senden
verschickt werden (deblockingFactor viele).
- StreamMultiplexerDirector - Interface in de.bsvrz.sys.funclib.communicationStreams
-
Dieses Interface muss implementiert werden, wenn ein StreamMultiplexer mit einem StreamDemultiplexer Nutzdatenpakete austauschen soll.
- _abortedStreamReceivedData - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Debug Wenn ein stream aborted wird, dann darf er keine Daten mehr empfangen.
- _arrayOfStreams - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Alle Streams bekommen einen Eintrag in diesem Array.
- _bigDataPacketQueue - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
In dieser Queue werden die großen Nutzdatenpakete gespeichert.
- _blockingFactor - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Der _blockingFactor bestimmt die größe des Empfängerpuffers.
- _blockingFactor - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Der blockingFactor bestimmt die Größe des Empfangspuffers.
- _bufferSizeStream - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Diese Variable bestimmt die Größe des Puffers, den jeder Stream zur Verfügung hat.
- _bufferSizeStreamMultiplexer - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Diese Variable bestimmt die gesamte Größe des Puffers, der zum StreamMultiplexer gehört.
- _currentStreamPacketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Der aktuelle Index bis zu dem Pakete verschickt wurden
- _data - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.ReferenceDataPacket
-
- _debug - Static variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
- _debug - Static variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
- _director - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Objekt, das das versenden von Tickets (Bestätigungen, dass der Sender Datenpakete senden darf) zur Verfügung
stellen
- _director - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Objekt, das das Anfordern von Daten (von der Applikation) und versenden von Datenpaketen an den Empfänger
ermöglicht
- _director - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
- _endStream - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Wenn der Sender keine Nutzdaten mehr für den Empfänger hat, dann wird der Stream beendet (dies sollte der
Normalfall sein).
- _indexOfStream - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
- _indexOfStream - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.IndexOfStreamAndMaxSendPackets
-
Index des Streams, der Nutzdatenpakete verschicken kann
- _lostConnectionToSender - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Bei der Übertragung der Daten ist ein Fehler aufgetreten.
- _maxSendPackets - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.IndexOfStreamAndMaxSendPackets
-
Die Anzahl der Pakete, die ein Stream verschicken kann
- _maxStreamPacketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Bis zu welchem Paketindex darf der Sender Pakete versenden
- _maxStreamPacketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Bis zu welchem Paketindex darf der Sender Pakete versenden
- _nextPacketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Welchen Paketindex muß das nächste Paket haben.
- _numberOfFalseMaxTickets - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
- _numberOfOverchargesReceiver - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Debug Wie oft überlastet der Sender den Empfänger (der Sender schickt mehr Nutzdatenpakete als die dataQueue des
Empfängers aufnehmen darf (_blockingFactor)).
- _numberOfPacketsReceived - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Debug, hier wird gezählt wie viele Nutzdatenpackete empfangen wurden
- _numberOfPacketsSend - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
- _numberOfReceivedPackets - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Debug Anzahl der empfangenen Pakete je stream
- _numberOfStreams - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Anzahl der Streams auf denen Datensätze verschickt werden können
- _numberOfStreams - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Anzahl der Streams auf denen Nutzdatenpakete verschickt werden können
- _numberOfTakes - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Debug Anzahl der Takes, die auch Nutzdaten enthielten (take mit einem Datensatz, der null enthält wird nicht
gezählt)
- _numberTerminatedStreams - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Anzahl der Streams, die mit "Abort" abgebrochen wurden oder die ein Nutzdatenpaket verschickt haben, in dem die
Nutzdaten null
waren.
- _packetIndexToSendNextMaxTicketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Wann muß das nächste Ticket zum Sender geschickt werden, damit er neue Nutzdatenpakete verschickt
- _queueWithStreamsPermitedToSendData - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Eine Warteschlange, in ihr werden alle Streams gespeichert, die Nutzdatenpakete verschicken können.
- _serializerVersion - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
Mit dieser Version wird der Serializer Nutzdaten verpacken und der Deserializer Tickets auspacken.
- _smallDataPacketQueue - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
In dieser Queue werden die Nutzdaten gespeichert.
- _streamAborted - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Wenn ein Stream mit abort beendet wurde, dann geschieht dies durch den Empfänger (er will keine Nutzdaten mehr).
- _streamPacketIndex - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.ReferenceDataPacket
-
- _streams - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer
-
In diesem Array werden alle Informationen aller Streams gespeichert.
- _streamTerminated - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer.DemultiplexerStreaminformations
-
Bei der Übertragung der Daten ist ein Fehler aufgetreten, entweder wurde ein Nutzdatenpaket doppelt empfangen oder
ein Paket fehlt.
- _streamTerminated - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer.MultiplexerStreaminformations
-
Wenn ein Stream abgebrochen wurde (mit abort des Empfängers oder take liefert null oder killAllStreams
), dann wird dieser boolean true.
- _ticketBlockingFactor - Variable in class de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexer
-
Der _blockingFactor wird durch 2 geteilt.