Class TCPTransportImpl

java.lang.Object

com.biglybt.core.networkmanager.impl.TransportImpl

com.biglybt.core.networkmanager.impl.tcp.TCPTransportImpl

All Implemented Interfaces:

Transport, TransportBase

public class TCPTransportImpl
extends TransportImpl
implements Transport

Represents a peer TCP transport connection (eg. a network socket).

Nested Class Summary

Nested classes/interfaces inherited from interface Transport

Transport.ConnectListener

Field Summary

Fields

Modifier and Type	Field	Description
(package private) TCPConnectionManager.ConnectListener	connect_request_key
(package private) boolean	connect_with_crypto
(package private) String	description
(package private) final boolean	fallback_allowed
(package private) int	fallback_count
boolean	has_been_closed
(package private) final boolean	is_inbound_connection
(package private) boolean	is_socks
(package private) static final LogIDs	LOGID
private static final int[]	mode_map	Set the transport to the given speed mode.
(package private) AEProxyFactory.PluginProxy	plugin_proxy
private final ProtocolEndpointTCP	protocol_endpoint
private byte[][]	shared_secrets
private int	transport_recv_mode
private int	transport_send_mode

Fields inherited from interface Transport

CR_BAD_PIECE_DATA, CR_DUPLICATE_PEER_ID, CR_INTERNAL_CONNECT_FAILED, CR_INVALID_INFO_HASH, CR_IP_BLOCKED, CR_NO_MEMORY, CR_NONE, CR_NOT_INTERESTED_UPLOAD_ONLY, CR_PEER_CHURN, CR_PORT_BLOCKED, CR_PROTOCOL_BLOCKED, CR_SELF_CONNECTION, CR_STOPPED_OR_REMOVED, CR_TIMEOUT, CR_TIMEOUT_ACTIVITY, CR_TIMEOUT_HANDSHAKE, CR_TIMEOUT_INTEREST, CR_TIMEOUT_REQUEST, CR_TOO_MANY_CONNECTIONS, CR_TOO_MANY_FILES, CR_UPLOAD_TO_UPLOAD, KEY_CLOSE_REASON, TRANSPORT_MODE_FAST, TRANSPORT_MODE_MEGA_TURBO, TRANSPORT_MODE_NORMAL, TRANSPORT_MODE_TURBO

Constructor Summary

Constructors

Constructor	Description
TCPTransportImpl(ProtocolEndpointTCP endpoint, boolean use_crypto, boolean allow_fallback, byte[][] _shared_secrets)	Constructor for disconnected (outbound) transport.
TCPTransportImpl(ProtocolEndpointTCP endpoint, TransportHelperFilter filter)	Constructor for connected (inbound) transport.

Method Summary

Modifier and Type	Method	Description
protected void	close(TransportHelper helper, String reason)
void	close(String reason)	Close the transport connection.
protected void	connectedOutbound(ByteBuffer remaining_initial_data, Transport.ConnectListener listener)
void	connectOutbound(ByteBuffer initial_data, Transport.ConnectListener listener, int priority)	Request the transport connection be established.
String	getDescription()	Get a textual description for this transport.
int	getMssSize()
AEProxyFactory.PluginProxy	getPluginProxy()
String	getProtocol()
SocketChannel	getSocketChannel()	Get the socket channel used by the transport.
TransportEndpointTCP	getTransportEndpoint()	Get the socket channel used by the transport.
TransportStartpoint	getTransportStartpoint()
protected void	handleCrypto(InetSocketAddress address, SocketChannel channel, ByteBuffer initial_data, int priority, Transport.ConnectListener listener)
boolean	isClosed()
boolean	isIncoming()
boolean	isSOCKS()
boolean	isTCP()
(package private) void	setConnectResult(boolean ok)
private void	setTransportBuffersSizes(int send_bytes, int recv_bytes)
void	setTransportModes(int send_mode, int recv_mode)	Set the transport to the given speed modes.

Methods inherited from class TransportImpl

bindConnection, connectedInbound, connectedOutbound, getEncryption, getFilter, getUserData, isEncrypted, isReadyForRead, isReadyForWrite, read, readFailed, readyForRead, readyForWrite, setAlreadyRead, setFilter, setReadyForRead, setTrace, setUserData, unbindConnection, write, writeFailed

Methods inherited from class Object

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

Methods inherited from interface Transport

bindConnection, connectedInbound, getEncryption, getTransportMode, getUserData, isEncrypted, read, setAlreadyRead, setReadyForRead, setTrace, setTransportMode, setUserData, unbindConnection, write

Methods inherited from interface TransportBase

isReadyForRead, isReadyForWrite

Field Details

LOGID

static final LogIDs LOGID

protocol_endpoint

private final ProtocolEndpointTCP protocol_endpoint

connect_request_key

TCPConnectionManager.ConnectListener connect_request_key

description

String description

is_inbound_connection

final boolean is_inbound_connection

transport_send_mode

private int transport_send_mode

transport_recv_mode

private int transport_recv_mode

has_been_closed

public volatile boolean has_been_closed

connect_with_crypto

boolean connect_with_crypto

shared_secrets

private byte[][] shared_secrets

fallback_count

int fallback_count

fallback_allowed

final boolean fallback_allowed

is_socks

boolean is_socks

plugin_proxy

volatile AEProxyFactory.PluginProxy plugin_proxy

mode_map

private static final int[] mode_map

Set the transport to the given speed mode.

Constructor Details

TCPTransportImpl

public TCPTransportImpl(ProtocolEndpointTCP endpoint,
 boolean use_crypto,
 boolean allow_fallback,
 byte[][] _shared_secrets)

Constructor for disconnected (outbound) transport.

TCPTransportImpl

public TCPTransportImpl(ProtocolEndpointTCP endpoint,
 TransportHelperFilter filter)

Constructor for connected (inbound) transport.

Parameters:

channel - connection

already_read - bytes from the channel

Method Details

isIncoming

public boolean isIncoming()

getSocketChannel

public SocketChannel getSocketChannel()

Get the socket channel used by the transport.

Returns:

the socket channel

getTransportEndpoint

public TransportEndpointTCP getTransportEndpoint()

Description copied from interface: Transport

Get the socket channel used by the transport.

Specified by:

getTransportEndpoint in interface Transport

Returns:

the socket channel

getTransportStartpoint

public TransportStartpoint getTransportStartpoint()

Specified by:

getTransportStartpoint in interface Transport

Overrides:

getTransportStartpoint in class TransportImpl

getMssSize

public int getMssSize()

Specified by:

getMssSize in interface Transport

isTCP

public boolean isTCP()

Specified by:

isTCP in interface TransportBase

isSOCKS

public boolean isSOCKS()

Specified by:

isSOCKS in interface Transport

Overrides:

isSOCKS in class TransportImpl

getPluginProxy

public AEProxyFactory.PluginProxy getPluginProxy()

Specified by:

getPluginProxy in interface Transport

Overrides:

getPluginProxy in class TransportImpl

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface Transport

Overrides:

getProtocol in class TransportImpl

getDescription

public String getDescription()

Get a textual description for this transport.

Specified by:

getDescription in interface TransportBase

Returns:

description

connectOutbound

public void connectOutbound(ByteBuffer initial_data,
 Transport.ConnectListener listener,
 int priority)

Request the transport connection be established. NOTE: Will automatically connect via configured proxy if necessary.

Specified by:

connectOutbound in interface Transport

Parameters:

listener - establishment failure/success listener

address - remote peer address to connect to

handleCrypto

protected void handleCrypto(InetSocketAddress address,
 SocketChannel channel,
 ByteBuffer initial_data,
 int priority,
 Transport.ConnectListener listener)

setTransportBuffersSizes

private void setTransportBuffersSizes(int send_bytes,
 int recv_bytes)

setTransportModes

public void setTransportModes(int send_mode,
 int recv_mode)

Description copied from interface: Transport

Set the transport to the given speed modes.

Specified by:

setTransportModes in interface Transport

connectedOutbound

protected void connectedOutbound(ByteBuffer remaining_initial_data,
 Transport.ConnectListener listener)

close

protected void close(TransportHelper helper,
 String reason)

setConnectResult

void setConnectResult(boolean ok)

close

public void close(String reason)

Close the transport connection.

Specified by:

close in interface Transport

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Transport