anon.transport.connection.util

Class QueuedChunkWriter

java.lang.Object

anon.transport.connection.util.QueuedChunkWriter

All Implemented Interfaces:

IChunkWriter

public class QueuedChunkWriter
extends java.lang.Object
implements IChunkWriter

Implementierung eines IChunkWriter, welcher die zu senden Chunks nacheinander in eine Eingangs uebergebenen BlockingQueue einfuegt.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	m_isClosed Gibt an ob der Writer geschlossen ist.
private int	m_timeout Das Timeout fuer Schreiboperationen in Millisekunden
private java.util.Vector	m_waitingThreads Sammelt alle Threats, welche sich innerhalb der write() Methode befinden.
private ObjectQueue	m_writingQueue Die BlockingQueue in welche Chunks eingefuegt werden.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
int	getTimeout()
void	setTimeout(int a_value)
void	writeChunk(byte[] a_chunk) Versucht den uebergeben Chunk in den Kanal einzuspeisen und somit zum Empfaenger zu uebertragen.

Methods inherited from class java.lang.Object

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

Field Detail

m_writingQueue

private final ObjectQueue m_writingQueue

Die BlockingQueue in welche Chunks eingefuegt werden.

m_isClosed

private volatile boolean m_isClosed

Gibt an ob der Writer geschlossen ist.

m_waitingThreads

private final java.util.Vector m_waitingThreads

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

Dient dazu, beim Schliessen des Writers evtl. blockierte Threats mittelst Thread.interrupt() aufzuwecken.

m_timeout

private int m_timeout

Das Timeout fuer Schreiboperationen in Millisekunden

Constructor Detail

QueuedChunkWriter

public QueuedChunkWriter(ObjectQueue a_writingQueue,
                         int a_timeout)

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

Parameters:

a_writingQueue - Die Queue in welche die Chunks eingefuegt werden.

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

QueuedChunkWriter

public QueuedChunkWriter(ObjectQueue a_writingQueue)

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

Parameters:

a_writingQueue - Die Queue in welche die Chunks eingefuegt werden.

Method Detail

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int a_value)

writeChunk

public void writeChunk(byte[] a_chunk)
                throws ConnectionException

Description copied from interface: IChunkWriter

Versucht den uebergeben Chunk in den Kanal einzuspeisen und somit zum Empfaenger zu uebertragen.

Sofern der Kanal voll ist blockiert der Aufruf, bis es moeglich war den Chunk zu uebertragen oder eine entsprechende Ausnahme wird geworfen.

Specified by:

writeChunk in interface IChunkWriter

Throws:

ConnectionException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface IChunkWriter

Throws:

java.io.IOException