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

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

All Implemented Interfaces:

GenericMessageConnectionAdapter

public class GenericMessageConnectionIndirect
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	GenericMessageConnectionIndirect(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpoint _endpoint, InetSocketAddress _rendezvous, InetSocketAddress _target)
protected	GenericMessageConnectionIndirect(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpoint _endpoint, long _connection_id)

Method Summary

void	accepted()
void	addInboundRateLimiter(RateLimiter limiter)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
protected void	close(Throwable close_cause)
void	connect(ByteBuffer initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
protected static String	getConnectionStatus(Map connections)
GenericMessageEndpoint	getEndpoint()
long	getLastMessageReceivedTime()
protected static String	getLocalConnectionStatus()
int	getMaximumMessageSize()
protected static String	getRemoteConnectionStatus()
int	getTransportType()
String	getType()
protected boolean	isClosed()
protected void	keepAlive()
protected static void	log(String str)
protected boolean	prepareForKeepAlive(boolean force)
protected List<byte[]>	receive(List<byte[]> messages)
protected static Map	receive(MessageManagerImpl message_manager, InetSocketAddress originator, Map message)
protected boolean	receiveIncomplete()
void	removeInboundRateLimiter(RateLimiter limiter)
void	removeOutboundRateLimiter(RateLimiter limiter)
protected void	send(List messages)
void	send(PooledByteBuffer pbb)
void	setOwner(GenericMessageConnectionImpl _owner)
protected void	trace(String str)

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

GenericMessageConnectionIndirect

protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager,
                                           String _msg_id,
                                           String _msg_desc,
                                           GenericMessageEndpoint _endpoint,
                                           InetSocketAddress _rendezvous,
                                           InetSocketAddress _target)

GenericMessageConnectionIndirect

protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager,
                                           String _msg_id,
                                           String _msg_desc,
                                           GenericMessageEndpoint _endpoint,
                                           long _connection_id)

Method Detail

receive

protected static Map receive(MessageManagerImpl message_manager,
                             InetSocketAddress originator,
                             Map message)

getRemoteConnectionStatus

protected static String getRemoteConnectionStatus()

getLocalConnectionStatus

protected static String getLocalConnectionStatus()

getConnectionStatus

protected static String getConnectionStatus(Map connections)

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

getLastMessageReceivedTime

public long getLastMessageReceivedTime()

getEndpoint

public GenericMessageEndpoint getEndpoint()

Specified by:

getEndpoint 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

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

Specified by:

connect in interface GenericMessageConnectionAdapter

accepted

public void accepted()

Specified by:

accepted in interface GenericMessageConnectionAdapter

send

public void send(PooledByteBuffer pbb)
          throws MessageException

Specified by:

send in interface GenericMessageConnectionAdapter

Throws:

MessageException

send

protected void send(List messages)

receive

protected List<byte[]> receive(List<byte[]> messages)

receiveIncomplete

protected boolean receiveIncomplete()

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnectionAdapter

Throws:

MessageException

close

protected void close(Throwable close_cause)
              throws MessageException

Throws:

MessageException

isClosed

protected boolean isClosed()

prepareForKeepAlive

protected boolean prepareForKeepAlive(boolean force)

keepAlive

protected void keepAlive()

log

protected static void log(String str)

trace

protected void trace(String str)