de.bsvrz.dav.daf.main.impl.archive.request
Class Query.DirectorStreamDemultiplexer
java.lang.Object
de.bsvrz.dav.daf.main.impl.archive.request.Query.DirectorStreamDemultiplexer
- All Implemented Interfaces:
- StreamDemultiplexerDirector
- Enclosing class:
- Query
private static class Query.DirectorStreamDemultiplexer
- extends Object
- implements StreamDemultiplexerDirector
Method Summary |
void |
sendNewTicketIndexToSender(byte[] streamTicketPacket)
Diese Methode schickt einem StreamMultiplexer ein streamTicketPaket(Byte-Array), dieses wird mit dem Methodenaufruf
StreamMultiplexer#setMaximumStreamTicketIndexForStream an den StreamMultiplexer übergeben. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_streamedArchiveRequester
private final StreamedArchiveRequester _streamedArchiveRequester
- Dieses Objekt wird benötigt um ihm das Ticket zu überreichen, dies wird dann verpackt und verschickt.
_archiveQueryID
private final ArchiveQueryID _archiveQueryID
Query.DirectorStreamDemultiplexer
public Query.DirectorStreamDemultiplexer(ArchiveQueryID archiveQueryID,
StreamedArchiveRequester streamedArchiveRequester)
- Implementiert den StreamDemultiplexerDirector, somit kann eine Archivanfrage einen StreamDemultiplexer erzeugen.
- Parameters:
streamedArchiveRequester
- Verpackt und verschickt das Ticket an das ArchivarchiveQueryID
- Welche Archivanfrage verschickt das Ticket
sendNewTicketIndexToSender
public void sendNewTicketIndexToSender(byte[] streamTicketPacket)
- Description copied from interface:
de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexerDirector
- Diese Methode schickt einem StreamMultiplexer ein streamTicketPaket(Byte-Array), dieses wird mit dem Methodenaufruf
StreamMultiplexer#setMaximumStreamTicketIndexForStream
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.
- Specified by:
sendNewTicketIndexToSender
in interface StreamDemultiplexerDirector
- Parameters:
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.