anon.client

Class AbstractDataChain

java.lang.Object

anon.client.AbstractDataChain

All Implemented Interfaces:

AnonChannel, java.lang.Runnable, java.util.Observer

Direct Known Subclasses:

SequentialChannelDataChain, SingleChannelDataChain

public abstract class AbstractDataChain
extends java.lang.Object
implements AnonChannel, java.util.Observer, java.lang.Runnable

Author:

Stefan Lieske

Field Summary

Fields inherited from interface anon.AnonChannel

HTTP, SMTP, SOCKS, TCP, UDP, UDP_OVER_TCP, UDP_OVER_UDP, VPN

Constructor Summary

Constructors

Constructor and Description
AbstractDataChain(IDataChannelCreator a_channelCreator, DataChainErrorListener a_errorListener, IntegrityErrorListener a_integrityErrorListener)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the channel and releases all resources used.
abstract void	createPacketPayload(DataChainSendOrderStructure a_order) Creates the packet payload from the data stored in the given order.
java.io.InputStream	getInputStream() The returned InputStream could be used to receive data.
abstract int	getOutputBlockSize() Returns a value that indicates the current optimum size of data to write.
java.io.OutputStream	getOutputStream() The returned OutputStream could be used to send data.
boolean	isClosed() Returns if the channel is already closed, i.e. no data can be sent / recieved any more on this channel.
abstract void	run()
void	update(java.util.Observable a_observedObject, java.lang.Object a_message)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDataChain

public AbstractDataChain(IDataChannelCreator a_channelCreator,
                         DataChainErrorListener a_errorListener,
                         IntegrityErrorListener a_integrityErrorListener)

Method Detail

getInputStream

public java.io.InputStream getInputStream()

Description copied from interface: AnonChannel

The returned InputStream could be used to receive data.

Specified by:

getInputStream in interface AnonChannel

Returns:

InputStream, useful for receiving data

getOutputStream

public java.io.OutputStream getOutputStream()

Description copied from interface: AnonChannel

The returned OutputStream could be used to send data.

Specified by:

getOutputStream in interface AnonChannel

Returns:

OutputStream, useful for sending data

isClosed

public boolean isClosed()

Description copied from interface: AnonChannel

Returns if the channel is already closed, i.e. no data can be sent / recieved any more on this channel.

Specified by:

isClosed in interface AnonChannel

Returns:

true, if the channel is already closed

close

public void close()

Description copied from interface: AnonChannel

Closes the channel and releases all resources used.

Specified by:

close in interface AnonChannel

update

public void update(java.util.Observable a_observedObject,
                   java.lang.Object a_message)

Specified by:

update in interface java.util.Observer

getOutputBlockSize

public abstract int getOutputBlockSize()

Description copied from interface: AnonChannel

Returns a value that indicates the current optimum size of data to write. Because often anon services transport the data fragmented into fixed sized packets for optimum performance it may be good to send data according to the packet size to avoid unneccessary overheads.

Specified by:

getOutputBlockSize in interface AnonChannel

Returns:

the current optimum size for output data. If 1 is returned the size does not matter.

createPacketPayload

public abstract void createPacketPayload(DataChainSendOrderStructure a_order)

Creates the packet payload from the data stored in the given order. Additional information may be added depending on the type of data chain that is implementing this method.

The processed data will be stored in the channel cell of the order.

Parameters:

a_order -

run

public abstract void run()

Specified by:

run in interface java.lang.Runnable