org.gudy.azureus2.pluginsimpl.local.utils.security
Class SESTSConnectionImpl

java.lang.Object
  org.gudy.azureus2.pluginsimpl.local.utils.security.SESTSConnectionImpl

All Implemented Interfaces:

GenericMessageConnection

public class SESTSConnectionImpl
extends Object
implements GenericMessageConnection

Field Summary

Fields inherited from interface org.gudy.azureus2.plugins.messaging.generic.GenericMessageConnection

TT_INDIRECT, TT_NONE, TT_TCP, TT_UDP

Constructor Summary

protected

SESTSConnectionImpl(AzureusCore _core, GenericMessageConnectionImpl _connection, SEPublicKey _my_public_key, SEPublicKeyLocator _key_locator, String _reason, int _block_crypto)

Method Summary

void	addInboundRateLimiter(RateLimiter limiter)
void	addListener(GenericMessageConnectionListener listener)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
void	connect()
protected void	cryptoComplete()
protected int	getConnectMethodCount()
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
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 java.lang.Object

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

Constructor Detail

SESTSConnectionImpl

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

Throws:

Exception

Method Detail

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()
             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