org.gudy.azureus2.pluginsimpl.local.messaging
Class GenericMessageConnectionDirect

java.lang.Object
  org.gudy.azureus2.pluginsimpl.local.messaging.GenericMessageConnectionDirect

All Implemented Interfaces:

GenericMessageConnectionAdapter

public class GenericMessageConnectionDirect
extends Object
implements GenericMessageConnectionAdapter

Nested Class Summary

Nested classes/interfaces inherited from interface org.gudy.azureus2.pluginsimpl.local.messaging.GenericMessageConnectionAdapter

GenericMessageConnectionAdapter.ConnectionListener

Field Summary

static int

MAX_MESSAGE_SIZE

Constructor Summary

protected

GenericMessageConnectionDirect(String _msg_id, String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)

Method Summary

void	accepted()
void	addInboundRateLimiter(RateLimiter _limiter)
void	addOutboundRateLimiter(RateLimiter _limiter)
void	close()
void	connect(ByteBuffer upper_initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
protected void	connect(NetworkConnection _connection) Incoming connect call
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
int	getTransportType()
String	getType()
protected static GenericMessageConnectionDirect	receive(GenericMessageEndpointImpl endpoint, String msg_id, String msg_desc, int stream_crypto, byte[][] shared_secrets)
void	removeInboundRateLimiter(RateLimiter _limiter)
void	removeOutboundRateLimiter(RateLimiter _limiter)
void	send(PooledByteBuffer data)
void	setOwner(GenericMessageConnectionImpl _owner)
protected void	startProcessing()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_MESSAGE_SIZE

public static final int MAX_MESSAGE_SIZE

See Also:

Constant Field Values

Constructor Detail

GenericMessageConnectionDirect

protected GenericMessageConnectionDirect(String _msg_id,
                                         String _msg_desc,
                                         GenericMessageEndpointImpl _endpoint,
                                         int _stream_crypto,
                                         byte[][] _shared_secrets)

Method Detail

receive

protected static GenericMessageConnectionDirect receive(GenericMessageEndpointImpl endpoint,
                                                        String msg_id,
                                                        String msg_desc,
                                                        int stream_crypto,
                                                        byte[][] shared_secrets)

setOwner

public void setOwner(GenericMessageConnectionImpl _owner)

Specified by:

setOwner in interface GenericMessageConnectionAdapter

getMaximumMessageSize

public int getMaximumMessageSize()

Specified by:

getMaximumMessageSize in interface GenericMessageConnectionAdapter

getType

public String getType()

Specified by:

getType in interface GenericMessageConnectionAdapter

getTransportType

public int getTransportType()

Specified by:

getTransportType in interface GenericMessageConnectionAdapter

addInboundRateLimiter

public void addInboundRateLimiter(RateLimiter _limiter)

Specified by:

addInboundRateLimiter in interface GenericMessageConnectionAdapter

removeInboundRateLimiter

public void removeInboundRateLimiter(RateLimiter _limiter)

Specified by:

removeInboundRateLimiter in interface GenericMessageConnectionAdapter

addOutboundRateLimiter

public void addOutboundRateLimiter(RateLimiter _limiter)

Specified by:

addOutboundRateLimiter in interface GenericMessageConnectionAdapter

removeOutboundRateLimiter

public void removeOutboundRateLimiter(RateLimiter _limiter)

Specified by:

removeOutboundRateLimiter in interface GenericMessageConnectionAdapter

connect

protected void connect(NetworkConnection _connection)

Incoming connect call

Parameters:

_connection -

accepted

public void accepted()

Specified by:

accepted in interface GenericMessageConnectionAdapter

getEndpoint

public GenericMessageEndpoint getEndpoint()

Specified by:

getEndpoint in interface GenericMessageConnectionAdapter

connect

public void connect(ByteBuffer upper_initial_data,
                    GenericMessageConnectionAdapter.ConnectionListener listener)

Specified by:

connect in interface GenericMessageConnectionAdapter

startProcessing

protected void startProcessing()

send

public void send(PooledByteBuffer data)
          throws MessageException

Specified by:

send in interface GenericMessageConnectionAdapter

Throws:

MessageException

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnectionAdapter

Throws:

MessageException