public class StreamMultiplexer extends Object
| Constructor and Description |
|---|
StreamMultiplexer(int numberOfStreams,
int blockingFactor,
int bufferSizeStreamMultiplexer,
int serializerVersion,
StreamMultiplexerDirector director) |
| Modifier and Type | Method and Description |
|---|---|
void |
killAllStreams()
Alle Streams werden beendet, da die Verbindung zum Empfänger unterbrochen wurde.
|
void |
sendAllStreamData()
Diese Methode verschickt Nutzdaten, die die Senderapplikation erzeugt hat, an den Empfänger (StreamDemultiplexer).
|
void |
setMaximumStreamTicketIndexForStream(byte[] streamTicketPacket)
Diese Methode setzt den "maximumStreamTicketIndex" eines Streams herauf.
|
public StreamMultiplexer(int numberOfStreams,
int blockingFactor,
int bufferSizeStreamMultiplexer,
int serializerVersion,
StreamMultiplexerDirector director)
numberOfStreams - Anzahl von Streams, die Datenpakete versenden sollenblockingFactor - Anzahl der Pakete, die initial am Anfang versendet werdenbufferSizeStreamMultiplexer - Diese Variable bestimmt die gesamte Größe des Puffers, der zum StreamMultiplexer
gehörtserializerVersion - Diese Variable legt die Versionsnummer des Deserializer/Serializer fest, der
benutzt wird. Sowohl der StreamMultiplexer als auch der StreamDemultiplexer
müssen die selbe Version benutzendirector - Schnittstelle, die eine Methode zum verschicken von Informationen an den Sender
bereitstellt (siehe Interface Beschreibung)Serializer,
Deserializerpublic void sendAllStreamData()
throws InterruptedException
InterruptedException - Ein Thread, der auf ein Objekt in der Warteschlange gewartet hat, wurde mit Interrupt
unterbrochen.public void setMaximumStreamTicketIndexForStream(byte[] streamTicketPacket)
throws IOException
streamTicketPacket - Dieses Byte-Array enthält verschlüsselt den Index des Streams und den maximalen Index, bis
zu dem der StreamMultiplexer senden darf.IOException - Ein Fehler beim deserialisieren von Datenpublic void killAllStreams()