Class GenericMessageConnectionDirect
- java.lang.Object
-
- com.biglybt.pifimpl.local.messaging.GenericMessageConnectionDirect
-
- All Implemented Interfaces:
GenericMessageConnectionAdapter
public class GenericMessageConnectionDirect extends java.lang.Object implements GenericMessageConnectionAdapter
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.biglybt.pifimpl.local.messaging.GenericMessageConnectionAdapter
GenericMessageConnectionAdapter.ConnectionListener
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
closed
private boolean
connected
private NetworkConnection
connection
private static AsyncDispatcher
dispatcher
private GenericMessageEndpointImpl
endpoint
private java.util.List<LimitedRateGroup>
inbound_rls
static int
MAX_MESSAGE_SIZE
private java.lang.String
msg_desc
private java.lang.String
msg_id
private java.util.List<LimitedRateGroup>
outbound_rls
private GenericMessageConnectionImpl
owner
private ConnectionImpl
plugin_connection
private boolean
processing
private byte[][]
shared_secrets
private int
stream_crypto
-
Constructor Summary
Constructors Modifier Constructor Description protected
GenericMessageConnectionDirect(java.lang.String _msg_id, java.lang.String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)
-
Method Summary
-
-
-
Field Detail
-
MAX_MESSAGE_SIZE
public static final int MAX_MESSAGE_SIZE
- See Also:
- Constant Field Values
-
dispatcher
private static AsyncDispatcher dispatcher
-
owner
private GenericMessageConnectionImpl owner
-
msg_id
private java.lang.String msg_id
-
msg_desc
private java.lang.String msg_desc
-
stream_crypto
private int stream_crypto
-
shared_secrets
private byte[][] shared_secrets
-
endpoint
private GenericMessageEndpointImpl endpoint
-
connection
private NetworkConnection connection
-
plugin_connection
private ConnectionImpl plugin_connection
-
connected
private volatile boolean connected
-
processing
private boolean processing
-
closed
private volatile boolean closed
-
inbound_rls
private java.util.List<LimitedRateGroup> inbound_rls
-
outbound_rls
private java.util.List<LimitedRateGroup> outbound_rls
-
-
Constructor Detail
-
GenericMessageConnectionDirect
protected GenericMessageConnectionDirect(java.lang.String _msg_id, java.lang.String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)
-
-
Method Detail
-
receive
protected static GenericMessageConnectionDirect receive(GenericMessageEndpointImpl endpoint, java.lang.String msg_id, java.lang.String msg_desc, int stream_crypto, byte[][] shared_secrets)
-
setOwner
public void setOwner(GenericMessageConnectionImpl _owner)
- Specified by:
setOwner
in interfaceGenericMessageConnectionAdapter
-
getMaximumMessageSize
public int getMaximumMessageSize()
- Specified by:
getMaximumMessageSize
in interfaceGenericMessageConnectionAdapter
-
getType
public java.lang.String getType()
- Specified by:
getType
in interfaceGenericMessageConnectionAdapter
-
getTransportType
public int getTransportType()
- Specified by:
getTransportType
in interfaceGenericMessageConnectionAdapter
-
addInboundRateLimiter
public void addInboundRateLimiter(RateLimiter _limiter)
- Specified by:
addInboundRateLimiter
in interfaceGenericMessageConnectionAdapter
-
removeInboundRateLimiter
public void removeInboundRateLimiter(RateLimiter _limiter)
- Specified by:
removeInboundRateLimiter
in interfaceGenericMessageConnectionAdapter
-
addOutboundRateLimiter
public void addOutboundRateLimiter(RateLimiter _limiter)
- Specified by:
addOutboundRateLimiter
in interfaceGenericMessageConnectionAdapter
-
removeOutboundRateLimiter
public void removeOutboundRateLimiter(RateLimiter _limiter)
- Specified by:
removeOutboundRateLimiter
in interfaceGenericMessageConnectionAdapter
-
connect
protected void connect(NetworkConnection _connection)
Incoming connect call- Parameters:
_connection
-
-
accepted
public void accepted()
- Specified by:
accepted
in interfaceGenericMessageConnectionAdapter
-
getEndpoint
public GenericMessageEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceGenericMessageConnectionAdapter
-
getStartpoint
public GenericMessageStartpoint getStartpoint()
- Specified by:
getStartpoint
in interfaceGenericMessageConnectionAdapter
-
getConnection
public Connection getConnection()
- Specified by:
getConnection
in interfaceGenericMessageConnectionAdapter
-
connect
public void connect(java.nio.ByteBuffer upper_initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
- Specified by:
connect
in interfaceGenericMessageConnectionAdapter
-
startProcessing
protected void startProcessing()
-
send
public void send(PooledByteBuffer data) throws MessageException
- Specified by:
send
in interfaceGenericMessageConnectionAdapter
- Throws:
MessageException
-
close
public void close() throws MessageException
- Specified by:
close
in interfaceGenericMessageConnectionAdapter
- Throws:
MessageException
-
-