Class GenericMessageConnectionImpl

java.lang.Object

com.biglybt.pifimpl.local.messaging.GenericMessageConnectionImpl

All Implemented Interfaces:

GenericMessageConnection

public class GenericMessageConnectionImpl
extends Object
implements GenericMessageConnection

Nested Class Summary

Nested classes/interfaces inherited from interface GenericMessageConnection

GenericMessageConnection.GenericMessageConnectionPropertyHandler

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private boolean	closing
private int	connect_method_count
private boolean	connecting
private GenericMessageConnectionAdapter	delegate
private GenericMessageEndpointImpl	endpoint
private List	inbound_rls
private boolean	incoming
private List	listeners
private MessageManagerImpl	message_manager
private String	msg_desc
private String	msg_id
private List	outbound_rls
(package private) byte[][]	shared_secrets
private int	stream_crypto
private static final boolean	TEST_TUNNEL
private static final boolean	TRACE

Fields inherited from interface GenericMessageConnection

TT_INDIRECT, TT_NONE, TT_TCP, TT_UDP

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GenericMessageConnectionImpl(MessageManagerImpl _message_manager, GenericMessageConnectionAdapter _delegate)
protected	GenericMessageConnectionImpl(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)

Method Summary

Modifier and Type	Method	Description
protected void	accepted()	Incoming connection has been accepted
void	addInboundRateLimiter(RateLimiter limiter)
void	addListener(GenericMessageConnectionListener listener)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
void	closing()
void	connect(GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
void	connect(ByteBuffer initial_data, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)	Outgoing connection
protected void	connectTCP(ByteBuffer initial_data, InetSocketAddress tcp_ep, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
protected void	connectTunnel(ByteBuffer initial_data, GenericMessageEndpoint ep, InetSocketAddress rendezvous, InetSocketAddress target, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
protected void	connectUDP(ByteBuffer initial_data, InetSocketAddress udp_ep, boolean nat_traversal, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
Connection	getConnection()
int	getConnectMethodCount()
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
GenericMessageStartpoint	getStartpoint()
int	getTransportType()
String	getType()
boolean	isIncoming()
protected void	receive(GenericMessage message)
void	removeInboundRateLimiter(RateLimiter limiter)
void	removeListener(GenericMessageConnectionListener listener)
void	removeOutboundRateLimiter(RateLimiter limiter)
protected void	reportConnected()
protected void	reportFailed(Throwable e)
void	send(PooledByteBuffer message)
protected void	setDelegate(GenericMessageConnectionAdapter _delegate)

Methods inherited from class Object

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

Field Details

TRACE

private static final boolean TRACE

See Also:

• Constant Field Values

TEST_TUNNEL

private static final boolean TEST_TUNNEL

See Also:

• Constant Field Values

message_manager

private MessageManagerImpl message_manager

msg_id

private String msg_id

msg_desc

private String msg_desc

endpoint

private GenericMessageEndpointImpl endpoint

stream_crypto

private int stream_crypto

shared_secrets

byte[][] shared_secrets

incoming

private boolean incoming

delegate

private volatile GenericMessageConnectionAdapter delegate

closing

private volatile boolean closing

closed

private volatile boolean closed

connecting

private volatile boolean connecting

listeners

private List listeners

connect_method_count

private int connect_method_count

inbound_rls

private List inbound_rls

outbound_rls

private List outbound_rls

Constructor Details

GenericMessageConnectionImpl

protected GenericMessageConnectionImpl(MessageManagerImpl _message_manager,
 GenericMessageConnectionAdapter _delegate)

GenericMessageConnectionImpl

protected GenericMessageConnectionImpl(MessageManagerImpl _message_manager,
 String _msg_id,
 String _msg_desc,
 GenericMessageEndpointImpl _endpoint,
 int _stream_crypto,
 byte[][] _shared_secrets)

Method Details

getEndpoint

public GenericMessageEndpoint getEndpoint()

Specified by:

getEndpoint in interface GenericMessageConnection

getStartpoint

public GenericMessageStartpoint getStartpoint()

Specified by:

getStartpoint in interface GenericMessageConnection

Returns:

may be null if unknown

getConnection

public Connection getConnection()

Specified by:

getConnection in interface GenericMessageConnection

getMaximumMessageSize

public int getMaximumMessageSize()

Specified by:

getMaximumMessageSize in interface GenericMessageConnection

getType

public String getType()

Specified by:

getType in interface GenericMessageConnection

getTransportType

public int getTransportType()

Specified by:

getTransportType in interface GenericMessageConnection

addInboundRateLimiter

public void addInboundRateLimiter(RateLimiter limiter)

Specified by:

addInboundRateLimiter in interface GenericMessageConnection

removeInboundRateLimiter

public void removeInboundRateLimiter(RateLimiter limiter)

Specified by:

removeInboundRateLimiter in interface GenericMessageConnection

addOutboundRateLimiter

public void addOutboundRateLimiter(RateLimiter limiter)

Specified by:

addOutboundRateLimiter in interface GenericMessageConnection

removeOutboundRateLimiter

public void removeOutboundRateLimiter(RateLimiter limiter)

Specified by:

removeOutboundRateLimiter in interface GenericMessageConnection

isIncoming

public boolean isIncoming()

getConnectMethodCount

public int getConnectMethodCount()

connect

public void connect(GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
             throws MessageException

Specified by:

connect in interface GenericMessageConnection

Throws:

MessageException

setDelegate

protected void setDelegate(GenericMessageConnectionAdapter _delegate)

connect

public void connect(ByteBuffer initial_data,
 GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
             throws MessageException

Outgoing connection

Parameters:

initial_data -

Throws:

MessageException

connectTCP

protected void connectTCP(ByteBuffer initial_data,
 InetSocketAddress tcp_ep,
 GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)

connectUDP

protected void connectUDP(ByteBuffer initial_data,
 InetSocketAddress udp_ep,
 boolean nat_traversal,
 GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)

connectTunnel

protected void connectTunnel(ByteBuffer initial_data,
 GenericMessageEndpoint ep,
 InetSocketAddress rendezvous,
 InetSocketAddress target,
 GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)

accepted

protected void accepted()

Incoming connection has been accepted

send

public void send(PooledByteBuffer message)
          throws MessageException

Specified by:

send in interface GenericMessageConnection

Throws:

MessageException

receive

protected void receive(GenericMessage message)

closing

public void closing()

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnection

Throws:

MessageException

reportConnected

protected void reportConnected()

reportFailed

protected void reportFailed(Throwable e)

addListener

public void addListener(GenericMessageConnectionListener listener)

Specified by:

addListener in interface GenericMessageConnection

removeListener

public void removeListener(GenericMessageConnectionListener listener)

Specified by:

removeListener in interface GenericMessageConnection