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

java.lang.Object
  extended by 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