private static class Query.DirectorStreamDemultiplexer extends Object implements StreamDemultiplexerDirector
Modifier and Type | Field and Description |
---|---|
private ArchiveQueryID |
_archiveQueryID |
private StreamedArchiveRequester |
_streamedArchiveRequester
Dieses Objekt wird benötigt um ihm das Ticket zu überreichen, dies wird dann verpackt und verschickt.
|
Constructor and Description |
---|
Query.DirectorStreamDemultiplexer(ArchiveQueryID archiveQueryID,
StreamedArchiveRequester streamedArchiveRequester)
Implementiert den StreamDemultiplexerDirector, somit kann eine Archivanfrage einen StreamDemultiplexer erzeugen.
|
Modifier and Type | Method and Description |
---|---|
void |
sendNewTicketIndexToSender(byte[] streamTicketPacket)
Diese Methode schickt einem StreamMultiplexer ein streamTicketPaket(Byte-Array), dieses wird mit dem Methodenaufruf
StreamMultiplexer.setMaximumStreamTicketIndexForStream(byte[]) an den StreamMultiplexer übergeben. |
private final StreamedArchiveRequester _streamedArchiveRequester
private final ArchiveQueryID _archiveQueryID
public Query.DirectorStreamDemultiplexer(ArchiveQueryID archiveQueryID, StreamedArchiveRequester streamedArchiveRequester)
streamedArchiveRequester
- Verpackt und verschickt das Ticket an das ArchivarchiveQueryID
- Welche Archivanfrage verschickt das Ticketpublic void sendNewTicketIndexToSender(byte[] streamTicketPacket)
StreamDemultiplexerDirector
StreamMultiplexer.setMaximumStreamTicketIndexForStream(byte[])
an den StreamMultiplexer übergeben.
Das Paket enthält den Index eines Streams und den neuen Index bis zu dem der Stream streamDataPackets verschicken darf.
Beide Informationen werden vom StreamDemultiplexer in einem Byte-Array kodiert.
Die Methode wird in einem StreamDemultilexer aufgerufen, wenn die gespeicherten Nutzdatenpakete
eine gewisse Marke unterschreiten. Dadurch erhält der StreamMultiplexer die Erlaubnis weiter Nutdatenpakete zu verschicken.sendNewTicketIndexToSender
in interface StreamDemultiplexerDirector
streamTicketPacket
- Dieses Paket wird vom StreamDemultiplexer zum StreamMultiplexer geschickt. Es hat den Index des Stream
und den neuen maximalen Index, bis zu dem der StreamMultiplexer Pakete verschicken kann, als Inhalt.