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)
StreamDemultiplexerDirectorStreamMultiplexer.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 StreamDemultiplexerDirectorstreamTicketPacket - 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.