anon.transport.connection.util

Class QueuedChunkConnection

java.lang.Object

anon.transport.connection.util.QueuedChunkConnection

All Implemented Interfaces:

IChunkConnection, IConnection

public class QueuedChunkConnection
extends java.lang.Object
implements IChunkConnection

Implementierung einer IChunkConnection, welcher die 2 Kanaele der bidirektionalen Kommunikation durch zwei BlockingQueue ueber byte[] umsetzt.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	QueuedChunkConnection.QueuedAddress

Field Summary

Fields

Modifier and Type	Field and Description
protected IAddress	m_localAddress Die lokale Addresse
private QueuedChunkReader	m_reader Der reader der Verbindung
protected IAddress	m_remoteAddress Die Adresse des entfernten Endpunkt
private int	m_state Der interne Zustand der Verbindung
private IChunkWriter	m_writer Der Writer der Verbindung

Fields inherited from interface anon.transport.connection.IConnection

ConnectionState_CLOSE, ConnectionState_OPEN

Constructor Summary

Constructors

Constructor and Description
QueuedChunkConnection(ObjectQueue a_loopbackQueue) Erstellt einen neue QueuedChunkConnection bei der Ein- und Ausgabequeue durch die selbe BlockingQueue repraesentiert werden und die Connection entsprechend mit sich selbst verbunden ist.
QueuedChunkConnection(ObjectQueue a_readingQueue, ObjectQueue a_writingQueue) Erstell eine neue QueuedChunkConnection, bei welcher Ein- und Ausgabekanal durch entsprechende BlockingQueue repraesentiert sind.

Method Summary

Modifier and Type	Method and Description
void	close() Schliesst die Verbindung, indem der interne Zustand auf geschlossen gesetzt wird.
IChunkReader	getChunkReader() Liefert den IChunkReader, ueber welchen gesendete Datenbloecke des Kommunikationspartners gelesen werden koennen.
IChunkWriter	getChunkWriter() Liefert den IChunkWriter, ueber welchen Datenbloecke zum Kommunikationspartner gesendet werden koennen.
int	getCurrentState() Gibt den momentanen Zustand der Verbindung an.
IAddress	getLocalAddress() Gibt die Adresse des lokalen Endpunkt der Verbindung an.
IAddress	getRemoteAddress() Gibt die Adresse des entfernten Endpunkt an.
int	getTimeout() Ermittelt den momentanen Wert fuer das Timeout in Millisekunden fuer Lese- und Schreiboperationen der Verbindung.
void	setTimeout(int value) Setzt den Timeout in Millisekunden fuer die Lese- und Schreiboperationen der Verbindung.

Methods inherited from class java.lang.Object

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

Field Detail

m_reader

private final QueuedChunkReader m_reader

Der reader der Verbindung

m_writer

private final IChunkWriter m_writer

Der Writer der Verbindung

m_state

private int m_state

Der interne Zustand der Verbindung

m_localAddress

protected IAddress m_localAddress

Die lokale Addresse

m_remoteAddress

protected IAddress m_remoteAddress

Die Adresse des entfernten Endpunkt

Constructor Detail

QueuedChunkConnection

public QueuedChunkConnection(ObjectQueue a_loopbackQueue)

Erstellt einen neue QueuedChunkConnection bei der Ein- und Ausgabequeue durch die selbe BlockingQueue repraesentiert werden und die Connection entsprechend mit sich selbst verbunden ist.

Die Adresse fuer lokales und entferntes Ende werden auf die selbe Instanz gesetzt und erhalten den Identifier "loopback".

Parameters:

a_loopbackQueue - Die BlockingQueue welche als Ein- und Ausgabequeue dient

QueuedChunkConnection

public QueuedChunkConnection(ObjectQueue a_readingQueue,
                             ObjectQueue a_writingQueue)

Erstell eine neue QueuedChunkConnection, bei welcher Ein- und Ausgabekanal durch entsprechende BlockingQueue repraesentiert sind.

Die Adressen des lokalen, wie des entfernten, Endpunktes erhalten den Identifier "queue".

Parameters:

a_readingQueue - Die Queue, welche als Grundlage der lesenden Operationen der Verbindung Verwendung findet.

a_writingQueue - Die Queue, welche als Grundlage der schreiben Operationen der Verbindung Verwendung findet.

Method Detail

getChunkReader

public IChunkReader getChunkReader()

Description copied from interface: IChunkConnection

Liefert den IChunkReader, ueber welchen gesendete Datenbloecke des Kommunikationspartners gelesen werden koennen.

Specified by:

getChunkReader in interface IChunkConnection

getChunkWriter

public IChunkWriter getChunkWriter()

Description copied from interface: IChunkConnection

Liefert den IChunkWriter, ueber welchen Datenbloecke zum Kommunikationspartner gesendet werden koennen.

Specified by:

getChunkWriter in interface IChunkConnection

getCurrentState

public int getCurrentState()

Description copied from interface: IConnection

Gibt den momentanen Zustand der Verbindung an.

Die Belegung sollte dabei den in ConnectionState definierten Konstanten folgen.

Specified by:

getCurrentState in interface IConnection

getLocalAddress

public IAddress getLocalAddress()

Description copied from interface: IConnection

Gibt die Adresse des lokalen Endpunkt der Verbindung an.

Fuer Implementierungen, die eine bereits eingerichtete Verbindung kapseln, um weitere Funktionalitaet bereitzustellen, sollte diese Methode die Adresse der darunter gelegenen Verbindung zurueckgeben.

Specified by:

getLocalAddress in interface IConnection

getRemoteAddress

public IAddress getRemoteAddress()

Description copied from interface: IConnection

Gibt die Adresse des entfernten Endpunkt an.

Fuer Implementierungen, die eine bereits eingerichtete Verbindung kapseln, um weitere Funktionalitaet bereitzustellen, sollte diese Methode die Adresse der darunter gelegenen Verbindung zurueckgeben.

Specified by:

getRemoteAddress in interface IConnection

getTimeout

public int getTimeout()
               throws ConnectionException

Description copied from interface: IConnection

Ermittelt den momentanen Wert fuer das Timeout in Millisekunden fuer Lese- und Schreiboperationen der Verbindung. Der Definition von Socket folgend, bestimmt 0 ein unendliches Timeout.

Specified by:

getTimeout in interface IConnection

Throws:

ConnectionException - Wird geworfen, wenn der Wert nicht ermittelt werden kann.

setTimeout

public void setTimeout(int value)
                throws ConnectionException

Description copied from interface: IConnection

Setzt den Timeout in Millisekunden fuer die Lese- und Schreiboperationen der Verbindung. Der Definition von Socket folgend, bestimmt 0 ein unendliches Timeout.

Specified by:

setTimeout in interface IConnection

Throws:

ConnectionException - Wird geworfen, wenn das setzen des TimeOut nicht moeglich war. Insbesondere kann durch eine UnsupportedCommandException Ausnahme angegeben werden, dass das setzen generell nicht moeglich ist.

close

public void close()
           throws java.io.IOException

Schliesst die Verbindung, indem der interne Zustand auf geschlossen gesetzt wird.

Da noch Leseoperationen anstehen koennen, wird der Reader nur heruntergefahren um die Leerung der Buffers zu erlauben.

Specified by:

close in interface IConnection

Throws:

java.io.IOException