Class ConnectionManagerImpl

java.lang.Object

com.biglybt.pifimpl.local.network.ConnectionManagerImpl

All Implemented Interfaces:

ConnectionManager

public class ConnectionManagerImpl
extends Object
implements ConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConnectionManagerImpl.PluginRateLimiter

Field Summary

Fields

Modifier and Type	Field	Description
private Core	core
private static ConnectionManagerImpl	instance

Fields inherited from interface ConnectionManager

NAT_BAD, NAT_OK, NAT_PROBABLY_OK, NAT_UNKNOWN

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ConnectionManagerImpl(Core _core)

Method Summary

Modifier and Type	Method	Description
Connection	createConnection(InetSocketAddress remote_address, MessageStreamEncoder encoder, MessageStreamDecoder decoder)	Create a new unconnected remote connection (for outbound-initiated connections).
RateLimiter	createRateLimiter(String name, int bps)
TransportCipher	createTransportCipher(String algorithm, int mode, SecretKeySpec key_spec, AlgorithmParameterSpec params)
TransportFilter	createTransportFilter(Connection connection, TransportCipher read_cipher, TransportCipher write_cipher)
int	getNATStatus()	Returns the current view on whether or not we are inwardly connectable via our listener port
Object[]	getNATStatusEx()
static ConnectionManagerImpl	getSingleton(Core core)

Methods inherited from class Object

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

Field Details

instance

private static ConnectionManagerImpl instance

core

private Core core

Constructor Details

ConnectionManagerImpl

private ConnectionManagerImpl(Core _core)

Method Details

getSingleton

public static ConnectionManagerImpl getSingleton(Core core)

createConnection

public Connection createConnection(InetSocketAddress remote_address,
 MessageStreamEncoder encoder,
 MessageStreamDecoder decoder)

Description copied from interface: ConnectionManager

Create a new unconnected remote connection (for outbound-initiated connections).

Specified by:

createConnection in interface ConnectionManager

Parameters:

remote_address - to connect to

Returns:

not yet established connection

getNATStatus

public int getNATStatus()

Description copied from interface: ConnectionManager

Returns the current view on whether or not we are inwardly connectable via our listener port

Specified by:

getNATStatus in interface ConnectionManager

Returns:

getNATStatusEx

public Object[] getNATStatusEx()

Specified by:

getNATStatusEx in interface ConnectionManager

createTransportCipher

public TransportCipher createTransportCipher(String algorithm,
 int mode,
 SecretKeySpec key_spec,
 AlgorithmParameterSpec params)
                                      throws TransportException

Specified by:

createTransportCipher in interface ConnectionManager

Throws:

TransportException

createTransportFilter

public TransportFilter createTransportFilter(Connection connection,
 TransportCipher read_cipher,
 TransportCipher write_cipher)
                                      throws TransportException

Specified by:

createTransportFilter in interface ConnectionManager

Throws:

TransportException

createRateLimiter

public RateLimiter createRateLimiter(String name,
 int bps)

Specified by:

createRateLimiter in interface ConnectionManager