Class GenericMessageConnectionImpl
java.lang.Object
com.biglybt.pifimpl.local.messaging.GenericMessageConnectionImpl
- All Implemented Interfaces:
GenericMessageConnection
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.biglybt.pif.messaging.generic.GenericMessageConnection
GenericMessageConnection.GenericMessageConnectionPropertyHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private boolean
private int
private boolean
private GenericMessageConnectionAdapter
private GenericMessageEndpointImpl
private List
private boolean
private List
private MessageManagerImpl
private String
private String
private List
(package private) byte[][]
private int
private static final boolean
private static final boolean
Fields inherited from interface com.biglybt.pif.messaging.generic.GenericMessageConnection
TT_INDIRECT, TT_NONE, TT_TCP, TT_UDP
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
GenericMessageConnectionImpl
(MessageManagerImpl _message_manager, GenericMessageConnectionAdapter _delegate) protected
GenericMessageConnectionImpl
(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
accepted()
Incoming connection has been acceptedvoid
addInboundRateLimiter
(RateLimiter limiter) void
addListener
(GenericMessageConnectionListener listener) void
addOutboundRateLimiter
(RateLimiter limiter) void
close()
void
closing()
void
void
connect
(ByteBuffer initial_data, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) Outgoing connectionprotected void
connectTCP
(ByteBuffer initial_data, InetSocketAddress tcp_ep, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) protected void
connectTunnel
(ByteBuffer initial_data, GenericMessageEndpoint ep, InetSocketAddress rendezvous, InetSocketAddress target, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) protected void
connectUDP
(ByteBuffer initial_data, InetSocketAddress udp_ep, boolean nat_traversal, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) int
int
int
getType()
boolean
protected void
receive
(GenericMessage message) void
removeInboundRateLimiter
(RateLimiter limiter) void
void
removeOutboundRateLimiter
(RateLimiter limiter) protected void
protected void
void
send
(PooledByteBuffer message) protected void
setDelegate
(GenericMessageConnectionAdapter _delegate)
-
Field Details
-
TRACE
private static final boolean TRACE- See Also:
-
TEST_TUNNEL
private static final boolean TEST_TUNNEL- See Also:
-
message_manager
-
msg_id
-
msg_desc
-
endpoint
-
stream_crypto
private int stream_crypto -
incoming
private boolean incoming -
delegate
-
closing
private volatile boolean closing -
closed
private volatile boolean closed -
connecting
private volatile boolean connecting -
listeners
-
connect_method_count
private int connect_method_count -
inbound_rls
-
outbound_rls
-
-
Constructor Details
-
GenericMessageConnectionImpl
protected GenericMessageConnectionImpl(MessageManagerImpl _message_manager, GenericMessageConnectionAdapter _delegate) -
GenericMessageConnectionImpl
protected GenericMessageConnectionImpl(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)
-
-
Method Details
-
getEndpoint
- Specified by:
getEndpoint
in interfaceGenericMessageConnection
-
getStartpoint
- Specified by:
getStartpoint
in interfaceGenericMessageConnection
- Returns:
- may be null if unknown
-
getConnection
- Specified by:
getConnection
in interfaceGenericMessageConnection
-
getMaximumMessageSize
public int getMaximumMessageSize()- Specified by:
getMaximumMessageSize
in interfaceGenericMessageConnection
-
getType
- Specified by:
getType
in interfaceGenericMessageConnection
-
getTransportType
public int getTransportType()- Specified by:
getTransportType
in interfaceGenericMessageConnection
-
addInboundRateLimiter
- Specified by:
addInboundRateLimiter
in interfaceGenericMessageConnection
-
removeInboundRateLimiter
- Specified by:
removeInboundRateLimiter
in interfaceGenericMessageConnection
-
addOutboundRateLimiter
- Specified by:
addOutboundRateLimiter
in interfaceGenericMessageConnection
-
removeOutboundRateLimiter
- Specified by:
removeOutboundRateLimiter
in interfaceGenericMessageConnection
-
isIncoming
public boolean isIncoming() -
getConnectMethodCount
public int getConnectMethodCount() -
connect
public void connect(GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) throws MessageException - Specified by:
connect
in interfaceGenericMessageConnection
- Throws:
MessageException
-
setDelegate
-
connect
public void connect(ByteBuffer initial_data, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) throws MessageException Outgoing connection- Parameters:
initial_data
-- Throws:
MessageException
-
connectTCP
protected void connectTCP(ByteBuffer initial_data, InetSocketAddress tcp_ep, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) -
connectUDP
protected void connectUDP(ByteBuffer initial_data, InetSocketAddress udp_ep, boolean nat_traversal, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) -
connectTunnel
protected void connectTunnel(ByteBuffer initial_data, GenericMessageEndpoint ep, InetSocketAddress rendezvous, InetSocketAddress target, GenericMessageConnection.GenericMessageConnectionPropertyHandler ph) -
accepted
protected void accepted()Incoming connection has been accepted -
send
- Specified by:
send
in interfaceGenericMessageConnection
- Throws:
MessageException
-
receive
-
closing
public void closing() -
close
- Specified by:
close
in interfaceGenericMessageConnection
- Throws:
MessageException
-
reportConnected
protected void reportConnected() -
reportFailed
-
addListener
- Specified by:
addListener
in interfaceGenericMessageConnection
-
removeListener
- Specified by:
removeListener
in interfaceGenericMessageConnection
-