anon.client

Class SingleChannelDataChain

java.lang.Object

anon.client.AbstractDataChain

anon.client.SingleChannelDataChain

All Implemented Interfaces:

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

public final class SingleChannelDataChain
extends AbstractDataChain

Author:

Stefan Lieske

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SingleChannelDataChain.ChainCell
private class	SingleChannelDataChain.InvalidChainCellException

Field Summary

Fields

Modifier and Type	Field and Description
private static int	CHAIN_HEADER_LEN
private static int	CLOSE_CELL_CONNECTION_ERROR
private static int	FLAG_FLOW_CONTROL
private static short	FLAG_INTEGRITY_ERROR
private AbstractDataChannel	m_associatedChannel
private boolean	m_bWithIntegrityCheck
private int	m_chainType
private int	m_downstreamSendMeCount
private int	m_downstreamSendMeLimit
private boolean	m_firstUpstreamPacket
private InternalChannelMessageQueue	m_internalChannelMessageQueue
private java.lang.Object	m_oSyncUpstreamFlowControl
private boolean	m_supportFlowControl
private boolean	m_supportUpstreamFlowControl
private int	m_upstreamSendMeCount
private int	m_upstreamSendMeLimit

Fields inherited from interface anon.AnonChannel

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

Constructor Summary

Constructors

Constructor and Description
SingleChannelDataChain(IDataChannelCreator a_channelCreator, DataChainErrorListener a_errorListener, IntegrityErrorListener a_integrityErrorListener, int a_chainType, boolean a_supportFlowControl, boolean a_supportUpstreamFlowControl, int upstreamSendMe, int downstreamSendMe, boolean a_enhancedChannelEncryption, boolean a_withIntegrityCheck)

Method Summary

Modifier and Type	Method and Description
protected void	closeDataChain()
void	createPacketPayload(DataChainSendOrderStructure a_order) Takes the order data of the given order, adds the length, the flow control flag and chain type to the front and copies that data to the channel cell buffer of the order.
int	getOutputBlockSize() Returns a value that indicates the current optimum size of data to write.
protected void	orderPacket(DataChainSendOrderStructure a_order)
protected void	outputStreamClosed()
void	run()

Methods inherited from class anon.client.AbstractDataChain

addInputStreamQueueEntry, close, createDataChannel, getInputStream, getMessageQueuesNotificationsList, getOutputStream, interruptDownstreamThread, isClosed, propagateConnectionError, propagateIntegrityError, update

Methods inherited from class java.lang.Object

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

Field Detail

FLAG_FLOW_CONTROL

private static final int FLAG_FLOW_CONTROL

See Also:

Constant Field Values

CLOSE_CELL_CONNECTION_ERROR

private static final int CLOSE_CELL_CONNECTION_ERROR

See Also:

Constant Field Values

FLAG_INTEGRITY_ERROR

private static final short FLAG_INTEGRITY_ERROR

See Also:

Constant Field Values

CHAIN_HEADER_LEN

private static final int CHAIN_HEADER_LEN

See Also:

Constant Field Values

m_chainType

private int m_chainType

m_supportFlowControl

private boolean m_supportFlowControl

m_supportUpstreamFlowControl

private boolean m_supportUpstreamFlowControl

m_associatedChannel

private AbstractDataChannel m_associatedChannel

m_firstUpstreamPacket

private boolean m_firstUpstreamPacket

m_downstreamSendMeCount

private int m_downstreamSendMeCount

m_upstreamSendMeCount

private int m_upstreamSendMeCount

m_downstreamSendMeLimit

private int m_downstreamSendMeLimit

m_upstreamSendMeLimit

private int m_upstreamSendMeLimit

m_oSyncUpstreamFlowControl

private java.lang.Object m_oSyncUpstreamFlowControl

m_bWithIntegrityCheck

private boolean m_bWithIntegrityCheck

m_internalChannelMessageQueue

private InternalChannelMessageQueue m_internalChannelMessageQueue

Constructor Detail

SingleChannelDataChain

public SingleChannelDataChain(IDataChannelCreator a_channelCreator,
                              DataChainErrorListener a_errorListener,
                              IntegrityErrorListener a_integrityErrorListener,
                              int a_chainType,
                              boolean a_supportFlowControl,
                              boolean a_supportUpstreamFlowControl,
                              int upstreamSendMe,
                              int downstreamSendMe,
                              boolean a_enhancedChannelEncryption,
                              boolean a_withIntegrityCheck)

Method Detail

getOutputBlockSize

public 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

Specified by:

getOutputBlockSize in class AbstractDataChain

Returns:

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

createPacketPayload

public void createPacketPayload(DataChainSendOrderStructure a_order)

Takes the order data of the given order, adds the length, the flow control flag and chain type to the front and copies that data to the channel cell buffer of the order.

Specified by:

createPacketPayload in class AbstractDataChain

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in class AbstractDataChain

orderPacket

protected void orderPacket(DataChainSendOrderStructure a_order)

Specified by:

orderPacket in class AbstractDataChain

outputStreamClosed

protected void outputStreamClosed()
                           throws java.io.IOException

Specified by:

outputStreamClosed in class AbstractDataChain

Throws:

java.io.IOException

closeDataChain

protected void closeDataChain()

Specified by:

closeDataChain in class AbstractDataChain