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

java.lang.Object
  extended by org.gudy.azureus2.pluginsimpl.local.messaging.GenericMessageConnectionIndirect
All Implemented Interfaces:
GenericMessageConnectionAdapter

public class GenericMessageConnectionIndirect
extends java.lang.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, java.lang.String _msg_id, java.lang.String _msg_desc, GenericMessageEndpoint _endpoint, java.net.InetSocketAddress _rendezvous, java.net.InetSocketAddress _target)
           
protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager, java.lang.String _msg_id, java.lang.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(java.lang.Throwable close_cause)
           
 void connect(java.nio.ByteBuffer initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
           
protected static java.lang.String getConnectionStatus(java.util.Map connections)
           
 GenericMessageEndpoint getEndpoint()
           
 long getLastMessageReceivedTime()
           
protected static java.lang.String getLocalConnectionStatus()
           
 int getMaximumMessageSize()
           
protected static java.lang.String getRemoteConnectionStatus()
           
 int getTransportType()
           
 java.lang.String getType()
           
protected  boolean isClosed()
           
protected  void keepAlive()
           
protected static void log(java.lang.String str)
           
protected  boolean prepareForKeepAlive(boolean force)
           
protected  java.util.List<byte[]> receive(java.util.List<byte[]> messages)
           
protected static java.util.Map receive(MessageManagerImpl message_manager, java.net.InetSocketAddress originator, java.util.Map message)
           
protected  boolean receiveIncomplete()
           
 void removeInboundRateLimiter(RateLimiter limiter)
           
 void removeOutboundRateLimiter(RateLimiter limiter)
           
protected  void send(java.util.List messages)
           
 void send(PooledByteBuffer pbb)
           
 void setOwner(GenericMessageConnectionImpl _owner)
           
protected  void trace(java.lang.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,
                                           java.lang.String _msg_id,
                                           java.lang.String _msg_desc,
                                           GenericMessageEndpoint _endpoint,
                                           java.net.InetSocketAddress _rendezvous,
                                           java.net.InetSocketAddress _target)

GenericMessageConnectionIndirect

protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager,
                                           java.lang.String _msg_id,
                                           java.lang.String _msg_desc,
                                           GenericMessageEndpoint _endpoint,
                                           long _connection_id)
Method Detail

receive

protected static java.util.Map receive(MessageManagerImpl message_manager,
                                       java.net.InetSocketAddress originator,
                                       java.util.Map message)

getRemoteConnectionStatus

protected static java.lang.String getRemoteConnectionStatus()

getLocalConnectionStatus

protected static java.lang.String getLocalConnectionStatus()

getConnectionStatus

protected static java.lang.String getConnectionStatus(java.util.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 java.lang.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(java.nio.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(java.util.List messages)

receive

protected java.util.List<byte[]> receive(java.util.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(java.lang.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(java.lang.String str)

trace

protected void trace(java.lang.String str)