anon.transport.connection.util

Class QueuedChunkReader

java.lang.Object

anon.transport.connection.util.QueuedChunkReader

All Implemented Interfaces:

IChunkReader

public class QueuedChunkReader
extends java.lang.Object
implements IChunkReader

Implementierung eines IChunkReader, welcher die auszugebenen Chunks nacheinander aus einer Eingangs uebergebenen BlockingQueue bezieht.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	m_isClosed Gibt an ob der Reader geschlossen ist.
private boolean	m_isTearDown Gibt an ob der Reader heruntergefahren werden soll.
private ObjectQueue	m_readingQueue Die BlockingQueue uas welcher chunks gelesen werden.
private int	m_timeout Das Timeout fuer Leseoperationen in millisekunden
private java.util.Vector	m_waitingThreads Sammelt alle Threats, welche sich innerhalb der read() Methode befinden.

Constructor Summary

Constructors

Constructor and Description
QueuedChunkReader(ObjectQueue a_readingQueue) Erstellt einen neuen QueuedChunkReader auf Grundlage der uebergebene Queue mit einen unendlichen Timeout.
QueuedChunkReader(ObjectQueue a_readingQueue, int a_timeout) Erstellt einen neuen QueuedChunkReader auf Grundlage der uebergebene Queue und dem entsprechenden Timeout.

Method Summary

Modifier and Type	Method and Description
int	availableChunks() Liefert die Anzahl der Chunks innerhalb der Queue.
void	close() Schliesst den Reader ungeachtet noch ausstehender Chunks innerhalb der Queue.
int	getTimeout() Liefert den aktuelle Wert des Timeout
byte[]	readChunk() Gibt den aeltesten (im Sinne des Einfuegens in den Kanal) der im Kanal befindlichen Chunks zurueck.
void	setTimeout(int a_value) Setzt den Wert fuer das Timeout der Leseoperationen
void	tearDown() Faehrt den Reader runter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

m_readingQueue

private final ObjectQueue m_readingQueue

Die BlockingQueue uas welcher chunks gelesen werden.

m_isClosed

private volatile boolean m_isClosed

Gibt an ob der Reader geschlossen ist.

m_waitingThreads

private final java.util.Vector m_waitingThreads

Sammelt alle Threats, welche sich innerhalb der read() Methode befinden.

Dient dazu um beim Schliessen des Reader evtl. blockierte Threats mittelst Thread.interrupt() aufzuwecken.

m_timeout

private int m_timeout

Das Timeout fuer Leseoperationen in millisekunden

m_isTearDown

private boolean m_isTearDown

Gibt an ob der Reader heruntergefahren werden soll.

Dies erlaubt das Schliessen des Reader solange zu verzoegern, bis keine ausstehenden Chunks mehr vorhanden sind.

Constructor Detail

QueuedChunkReader

public QueuedChunkReader(ObjectQueue a_readingQueue,
                         int a_timeout)

Erstellt einen neuen QueuedChunkReader auf Grundlage der uebergebene Queue und dem entsprechenden Timeout.

Parameters:

a_readingQueue - Die Queue aus welcher die Chunks gelesen werden.

a_timeout - Der initiale Wert fuer das Timeout der Leseoperationen. Ein Wert von 0 bestimmt ein unendliches Timeout.

QueuedChunkReader

public QueuedChunkReader(ObjectQueue a_readingQueue)

Erstellt einen neuen QueuedChunkReader auf Grundlage der uebergebene Queue mit einen unendlichen Timeout.

Parameters:

a_readingQueue - Die Queue aus welcher die Chunks gelesen werden.

Method Detail

getTimeout

public int getTimeout()

Liefert den aktuelle Wert des Timeout

setTimeout

public void setTimeout(int a_value)

Setzt den Wert fuer das Timeout der Leseoperationen

readChunk

public byte[] readChunk()
                 throws ConnectionException

Description copied from interface: IChunkReader

Gibt den aeltesten (im Sinne des Einfuegens in den Kanal) der im Kanal befindlichen Chunks zurueck. Sofern der Kanal leer ist blockiert der Aufruf bis ein Chunk ausgeliefert werden kann.

Evtl. Fehler oder unzulaessige Zustaende des Kanals koennen durch entsprechende Ausnahmen angezeigt werden.

Specified by:

readChunk in interface IChunkReader

Returns:

Den aeltesten Chunk innerhalb des Kanals. Ein Rueckgabewert von null ist nicht zulaessig und ein Rueckgabewert von byte[0] sollte vermieden werden.

Throws:

ConnectionException

close

public void close()
           throws java.io.IOException

Schliesst den Reader ungeachtet noch ausstehender Chunks innerhalb der Queue.

Wenn gewuenscht wird mit dem Schliessen bis zur Auslieferung dieser Chunks zu warten sollte tearDown() gewaehlt werden.

Specified by:

close in interface IChunkReader

Throws:

java.io.IOException

tearDown

public void tearDown()
              throws java.io.IOException

Faehrt den Reader runter.

Das heisst bis zum Erreichen einer leeren Queue bleibt der Reader offen. Danach wird er automatisch geschlossen.

Throws:

java.io.IOException

availableChunks

public int availableChunks()
                    throws ConnectionException

Liefert die Anzahl der Chunks innerhalb der Queue.

Specified by:

availableChunks in interface IChunkReader

Throws:

ConnectionException