Class NetworkConnectionImpl

java.lang.Object

com.biglybt.core.networkmanager.NetworkConnectionHelper

com.biglybt.core.networkmanager.impl.NetworkConnectionImpl

All Implemented Interfaces:

ControllerAllocationManagement, NetworkConnection, NetworkConnectionBase

public class NetworkConnectionImpl
extends NetworkConnectionHelper
implements NetworkConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	NetworkConnectionImpl.bogusTransport

Nested classes/interfaces inherited from interface NetworkConnection

NetworkConnection.ConnectionListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allow_fallback
private boolean	closed
private boolean	connect_with_crypto
private ConnectionAttempt	connection_attempt
private final ConnectionEndpoint	connection_endpoint
private NetworkConnection.ConnectionListener	connection_listener
private int	enhanced_partition_id
private final IncomingMessageQueueImpl	incoming_message_queue
private boolean	is_connected
private final boolean	is_incoming
private byte	is_lan_local
private final OutgoingMessageQueueImpl	outgoing_message_queue
private byte[][]	shared_secrets
private boolean	started
private Transport	transport
private Map<Object,Object>	user_data

Fields inherited from interface ControllerAllocationManagement

UNALLOCATED_PARTITION

Constructor Summary

Constructors

Constructor	Description
NetworkConnectionImpl(ConnectionEndpoint _target, MessageStreamEncoder encoder, MessageStreamDecoder decoder, boolean _connect_with_crypto, boolean _allow_fallback, byte[][] _shared_secrets)	Constructor for new OUTbound connection.
NetworkConnectionImpl(Transport _transport, MessageStreamEncoder encoder, MessageStreamDecoder decoder)	Constructor for new INbound connection.

Method Summary

Modifier and Type	Method	Description
void	close(String reason)	Close and shutdown this connection.
void	connect(int priority, NetworkConnection.ConnectionListener listener)	Connect this connection's transport, i.e.
void	connect(ByteBuffer initial_outbound_data, int priority, NetworkConnection.ConnectionListener listener)
Transport	detachTransport()	Decouples the transport from this network connection so it can be reused
void	enableEnhancedMessageProcessing(boolean enable, int partition_id)	Upgrade the connection to high-speed transfer processing.
ConnectionEndpoint	getEndpoint()
IncomingMessageQueue	getIncomingMessageQueue()	Get the connection's incoming message queue.
int	getMssSize()
OutgoingMessageQueue	getOutgoingMessageQueue()	Get the connection's outgoing message queue.
String	getString()
Transport	getTransport()	Get the connection's data transport interface.
TransportBase	getTransportBase()	Get the connection's data transport interface.
Object	getUserData(Object key)
boolean	isClosed()
boolean	isConnected()
boolean	isIncoming()
boolean	isLANLocal()	Is the connection within the local LAN network.
void	notifyOfException(Throwable error)	Inform connection of a thrown exception.
void	resetLANLocalStatus()
Object	setUserData(Object key, Object value)
void	startMessageProcessing()	Begin processing incoming and outgoing message queues.
String	toString()

Methods inherited from class NetworkConnectionHelper

activeReadControllerRelease, activeWriteControllerRelease, addRateLimiter, getDownloadLimit, getPartitionID, getRateLimiters, getUploadLimit, isReadControllerActive, isWriteControllerActive, removeRateLimiter, setDownloadLimit, setReadControllerInactive, setTargetReadControllerPartition, setTargetWriteControllerPartition, setUploadLimit, setWriteControllerInactive

Methods inherited from class Object

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

Methods inherited from interface ControllerAllocationManagement

activeReadControllerRelease, activeWriteControllerRelease, isReadControllerActive, isWriteControllerActive, setReadControllerInactive, setTargetReadControllerPartition, setTargetWriteControllerPartition, setWriteControllerInactive

Methods inherited from interface NetworkConnectionBase

addRateLimiter, getDownloadLimit, getPartitionID, getRateLimiters, getUploadLimit, removeRateLimiter, setDownloadLimit, setUploadLimit

Field Details

connection_endpoint

private final ConnectionEndpoint connection_endpoint

is_incoming

private final boolean is_incoming

connect_with_crypto

private boolean connect_with_crypto

allow_fallback

private boolean allow_fallback

shared_secrets

private byte[][] shared_secrets

connection_listener

private NetworkConnection.ConnectionListener connection_listener

is_connected

private boolean is_connected

is_lan_local

private byte is_lan_local

enhanced_partition_id

private int enhanced_partition_id

outgoing_message_queue

private final OutgoingMessageQueueImpl outgoing_message_queue

incoming_message_queue

private final IncomingMessageQueueImpl incoming_message_queue

transport

private Transport transport

connection_attempt

private volatile ConnectionAttempt connection_attempt

started

private boolean started

closed

private volatile boolean closed

user_data

private Map<Object,Object> user_data

Constructor Details

NetworkConnectionImpl

public NetworkConnectionImpl(ConnectionEndpoint _target,
 MessageStreamEncoder encoder,
 MessageStreamDecoder decoder,
 boolean _connect_with_crypto,
 boolean _allow_fallback,
 byte[][] _shared_secrets)

Constructor for new OUTbound connection. The connection is not yet established upon instantiation; use connect() to do so.

Parameters:

encoder - default message stream encoder to use for the outgoing queue

decoder - default message stream decoder to use for the incoming queue

_remote_address - to connect to

NetworkConnectionImpl

public NetworkConnectionImpl(Transport _transport,
 MessageStreamEncoder encoder,
 MessageStreamDecoder decoder)

Constructor for new INbound connection. The connection is assumed to be already established, by the given already-connected channel.

Parameters:

encoder - default message stream encoder to use for the outgoing queue

decoder - default message stream decoder to use for the incoming queue

_remote_channel - connected by

data_already_read - bytestream already read during routing

Method Details

getEndpoint

public ConnectionEndpoint getEndpoint()

Specified by:

getEndpoint in interface NetworkConnectionBase

isIncoming

public boolean isIncoming()

Specified by:

isIncoming in interface NetworkConnectionBase

connect

public void connect(int priority,
 NetworkConnection.ConnectionListener listener)

Description copied from interface: NetworkConnection

Connect this connection's transport, i.e. establish the network connection. If this connection is already established (from an incoming connection for example), then this provides a mechanism to register the connection listener, in which case connectSuccess() will be called immediately.

Specified by:

connect in interface NetworkConnection

Parameters:

listener - notified on connect success or failure

connect

public void connect(ByteBuffer initial_outbound_data,
 int priority,
 NetworkConnection.ConnectionListener listener)

Specified by:

connect in interface NetworkConnection

detachTransport

public Transport detachTransport()

Description copied from interface: NetworkConnection

Decouples the transport from this network connection so it can be reused

Specified by:

detachTransport in interface NetworkConnection

Returns:

null if detach failed

close

public void close(String reason)

Description copied from interface: NetworkConnection

Close and shutdown this connection.

Specified by:

close in interface NetworkConnection

Specified by:

close in class NetworkConnectionHelper

isClosed

public boolean isClosed()

Specified by:

isClosed in interface NetworkConnectionBase

notifyOfException

public void notifyOfException(Throwable error)

Description copied from interface: NetworkConnectionBase

Inform connection of a thrown exception.

Specified by:

notifyOfException in interface NetworkConnectionBase

Parameters:

error - exception

getOutgoingMessageQueue

public OutgoingMessageQueue getOutgoingMessageQueue()

Description copied from interface: NetworkConnectionBase

Get the connection's outgoing message queue.

Specified by:

getOutgoingMessageQueue in interface NetworkConnectionBase

Returns:

outbound message queue

getIncomingMessageQueue

public IncomingMessageQueue getIncomingMessageQueue()

Description copied from interface: NetworkConnectionBase

Get the connection's incoming message queue.

Specified by:

getIncomingMessageQueue in interface NetworkConnectionBase

Returns:

inbound message queue

startMessageProcessing

public void startMessageProcessing()

Description copied from interface: NetworkConnection

Begin processing incoming and outgoing message queues.

Specified by:

startMessageProcessing in interface NetworkConnection

enableEnhancedMessageProcessing

public void enableEnhancedMessageProcessing(boolean enable,
 int partition_id)

Description copied from interface: NetworkConnection

Upgrade the connection to high-speed transfer processing.

Specified by:

enableEnhancedMessageProcessing in interface NetworkConnection

Parameters:

enable - true for high-speed processing, false for normal processing

getTransport

public Transport getTransport()

Description copied from interface: NetworkConnection

Get the connection's data transport interface.

Specified by:

getTransport in interface NetworkConnection

Returns:

the transport - MAY BE NULL if not yet fully connected

getTransportBase

public TransportBase getTransportBase()

Description copied from interface: NetworkConnectionBase

Get the connection's data transport interface.

Specified by:

getTransportBase in interface NetworkConnectionBase

Returns:

the transport - MAY BE NULL if not yet fully connected

getMssSize

public int getMssSize()

Specified by:

getMssSize in interface NetworkConnectionBase

setUserData

public Object setUserData(Object key,
 Object value)

Specified by:

setUserData in interface NetworkConnection

getUserData

public Object getUserData(Object key)

Specified by:

getUserData in interface NetworkConnection

toString

public String toString()

Overrides:

toString in class Object

isConnected

public boolean isConnected()

Specified by:

isConnected in interface NetworkConnection

isLANLocal

public boolean isLANLocal()

Description copied from interface: NetworkConnectionBase

Is the connection within the local LAN network.

Specified by:

isLANLocal in interface NetworkConnectionBase

Returns:

true if within LAN, false of outside the LAN segment

resetLANLocalStatus

public void resetLANLocalStatus()

Specified by:

resetLANLocalStatus in interface NetworkConnectionBase

getString

public String getString()

Specified by:

getString in interface NetworkConnectionBase