Class SESTSConnectionImpl

java.lang.Object

com.biglybt.pifimpl.local.utils.security.SESTSConnectionImpl

All Implemented Interfaces:

GenericMessageConnection

public class SESTSConnectionImpl
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 static final byte[]	AES_IV1
private static final byte[]	AES_IV2
private final int	AES_KEY_SIZE_BYTES
private int	block_crypto
private static final int	BLOOM_INCREASE
private static final int	BLOOM_RECREATE
private boolean	closed
private GenericMessageConnectionImpl	connection
private static List<SESTSConnectionImpl>	connections
private Core	core
private final long	create_time_mono
private AESemaphore	crypto_complete
private static final int	CRYPTO_SETUP_TIMEOUT
private static AsyncDispatcher	dispatcher
private boolean	failed
private static BloomFilter	generate_bloom
private static long	generate_bloom_create_time_mono
private Cipher	incoming_cipher
private SEPublicKeyLocator	key_locator
private CopyOnWriteList<GenericMessageConnectionListener>	listeners
private static final LogIDs	LOGID
private SEPublicKey	my_public_key
private Cipher	outgoing_cipher
private PooledByteBuffer	pending_message
private String	reason
private boolean	sent_auth
private boolean	sent_keys
private CryptoSTSEngine	sts_engine

Fields inherited from interface GenericMessageConnection

TT_INDIRECT, TT_NONE, TT_TCP, TT_UDP

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SESTSConnectionImpl(Core _core, GenericMessageConnectionImpl _connection, SEPublicKey _my_public_key, SEPublicKeyLocator _key_locator, String _reason, int _block_crypto)

Method Summary

Modifier and Type	Method	Description
void	addInboundRateLimiter(RateLimiter limiter)
void	addListener(GenericMessageConnectionListener listener)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
void	connect(GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
protected void	cryptoComplete()
Connection	getConnection()
protected int	getConnectMethodCount()
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
GenericMessageStartpoint	getStartpoint()
int	getTransportType()
String	getType()
protected static void	rateLimit(InetSocketAddress originator)
void	receive(PooledByteBuffer message)
protected void	receiveContent(PooledByteBuffer message)
void	removeInboundRateLimiter(RateLimiter limiter)
void	removeListener(GenericMessageConnectionListener listener)
void	removeOutboundRateLimiter(RateLimiter limiter)
protected void	reportConnected()
protected void	reportFailed(Throwable error)
void	send(PooledByteBuffer message)
protected void	sendContent(PooledByteBuffer message)
protected void	setFailed()
protected void	setupBlockCrypto()

Methods inherited from class Object

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

Field Details

CRYPTO_SETUP_TIMEOUT

private static final int CRYPTO_SETUP_TIMEOUT

See Also:

• Constant Field Values

LOGID

private static final LogIDs LOGID

AES_IV1

private static final byte[] AES_IV1

AES_IV2

private static final byte[] AES_IV2

AES_KEY_SIZE_BYTES

private final int AES_KEY_SIZE_BYTES

connections

private static List<SESTSConnectionImpl> connections

dispatcher

private static AsyncDispatcher dispatcher

BLOOM_RECREATE

private static final int BLOOM_RECREATE

See Also:

• Constant Field Values

BLOOM_INCREASE

private static final int BLOOM_INCREASE

See Also:

• Constant Field Values

generate_bloom

private static BloomFilter generate_bloom

generate_bloom_create_time_mono

private static long generate_bloom_create_time_mono

core

private Core core

connection

private GenericMessageConnectionImpl connection

my_public_key

private SEPublicKey my_public_key

key_locator

private SEPublicKeyLocator key_locator

reason

private String reason

block_crypto

private int block_crypto

create_time_mono

private final long create_time_mono

sts_engine

private CryptoSTSEngine sts_engine

listeners

private CopyOnWriteList<GenericMessageConnectionListener> listeners

sent_keys

private boolean sent_keys

sent_auth

private boolean sent_auth

pending_message

private PooledByteBuffer pending_message

crypto_complete

private AESemaphore crypto_complete

outgoing_cipher

private Cipher outgoing_cipher

incoming_cipher

private Cipher incoming_cipher

failed

private volatile boolean failed

closed

private volatile boolean closed

Constructor Details

SESTSConnectionImpl

protected SESTSConnectionImpl(Core _core,
 GenericMessageConnectionImpl _connection,
 SEPublicKey _my_public_key,
 SEPublicKeyLocator _key_locator,
 String _reason,
 int _block_crypto)
                       throws Exception

Throws:

Exception

Method Details

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

getConnectMethodCount

protected int getConnectMethodCount()

rateLimit

protected static void rateLimit(InetSocketAddress originator)
                         throws Exception

Throws:

Exception

getEndpoint

public GenericMessageEndpoint getEndpoint()

Specified by:

getEndpoint 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

connect

public void connect(GenericMessageConnection.GenericMessageConnectionPropertyHandler ph)
             throws MessageException

Specified by:

connect in interface GenericMessageConnection

Throws:

MessageException

setFailed

protected void setFailed()

receive

public void receive(PooledByteBuffer message)
             throws MessageException

Throws:

MessageException

setupBlockCrypto

protected void setupBlockCrypto()
                         throws MessageException

Throws:

MessageException

cryptoComplete

protected void cryptoComplete()
                       throws MessageException

Throws:

MessageException

send

public void send(PooledByteBuffer message)
          throws MessageException

Specified by:

send in interface GenericMessageConnection

Throws:

MessageException

sendContent

protected void sendContent(PooledByteBuffer message)
                    throws MessageException

Throws:

MessageException

receiveContent

protected void receiveContent(PooledByteBuffer message)
                       throws MessageException

Throws:

MessageException

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnection

Throws:

MessageException

reportConnected

protected void reportConnected()

reportFailed

protected void reportFailed(Throwable error)

addListener

public void addListener(GenericMessageConnectionListener listener)

Specified by:

addListener in interface GenericMessageConnection

removeListener

public void removeListener(GenericMessageConnectionListener listener)

Specified by:

removeListener in interface GenericMessageConnection