Class TCPTransportHelper
java.lang.Object
com.biglybt.core.networkmanager.impl.tcp.TCPTransportHelper
- All Implemented Interfaces:
TransportHelper
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.biglybt.core.networkmanager.impl.TransportHelper
TransportHelper.selectListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final SocketChannel
private boolean
static final int
private ByteBuffer
static final int
private static final AEProxyAddressMapper
static final int
private long
private static final Random
private InetSocketAddress
(package private) boolean
private Map
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
private int
channelWrite
(ByteBuffer buf) void
boolean
delayWrite
(ByteBuffer buffer) void
int
getName
(boolean verbose) int
getUserData
(Object key) boolean
boolean
isClosed()
boolean
void
void
int
read
(ByteBuffer buffer) long
read
(ByteBuffer[] buffers, int array_offset, int length) void
registerForReadSelects
(TransportHelper.selectListener listener, Object attachment) void
registerForWriteSelects
(TransportHelper.selectListener listener, Object attachment) void
void
void
setScatteringMode
(long forBytes) void
setTrace
(boolean on) void
setUserData
(Object key, Object data) long
write
(ByteBuffer[] buffers, int array_offset, int length) int
write
(ByteBuffer buffer, boolean partial_write)
-
Field Details
-
READ_TIMEOUT
public static final int READ_TIMEOUT- See Also:
-
CONNECT_TIMEOUT
public static final int CONNECT_TIMEOUT- See Also:
-
proxy_address_mapper
-
MAX_PARTIAL_WRITE_RETAIN
public static final int MAX_PARTIAL_WRITE_RETAIN- See Also:
-
remainingBytesToScatter
private long remainingBytesToScatter -
channel
-
delayed_write
-
user_data
-
trace
boolean trace -
tcp_address
-
closed
private volatile boolean closed -
rnd
-
-
Constructor Details
-
TCPTransportHelper
-
-
Method Details
-
getAddress
- Specified by:
getAddress
in interfaceTransportHelper
-
getName
- Specified by:
getName
in interfaceTransportHelper
-
minimiseOverheads
public boolean minimiseOverheads()- Specified by:
minimiseOverheads
in interfaceTransportHelper
-
getConnectTimeout
public int getConnectTimeout()- Specified by:
getConnectTimeout
in interfaceTransportHelper
-
getReadTimeout
public int getReadTimeout()- Specified by:
getReadTimeout
in interfaceTransportHelper
-
delayWrite
- Specified by:
delayWrite
in interfaceTransportHelper
-
hasDelayedWrite
public boolean hasDelayedWrite()- Specified by:
hasDelayedWrite
in interfaceTransportHelper
-
write
- Specified by:
write
in interfaceTransportHelper
- Throws:
IOException
-
write
- Specified by:
write
in interfaceTransportHelper
- Throws:
IOException
-
channelWrite
- Throws:
IOException
-
read
- Specified by:
read
in interfaceTransportHelper
- Throws:
IOException
-
read
- Specified by:
read
in interfaceTransportHelper
- Throws:
IOException
-
registerForReadSelects
- Specified by:
registerForReadSelects
in interfaceTransportHelper
-
registerForWriteSelects
- Specified by:
registerForWriteSelects
in interfaceTransportHelper
-
cancelReadSelects
public void cancelReadSelects()- Specified by:
cancelReadSelects
in interfaceTransportHelper
-
cancelWriteSelects
public void cancelWriteSelects()- Specified by:
cancelWriteSelects
in interfaceTransportHelper
-
resumeReadSelects
public void resumeReadSelects()- Specified by:
resumeReadSelects
in interfaceTransportHelper
-
resumeWriteSelects
public void resumeWriteSelects()- Specified by:
resumeWriteSelects
in interfaceTransportHelper
-
pauseReadSelects
public void pauseReadSelects()- Specified by:
pauseReadSelects
in interfaceTransportHelper
-
pauseWriteSelects
public void pauseWriteSelects()- Specified by:
pauseWriteSelects
in interfaceTransportHelper
-
isClosed
public boolean isClosed()- Specified by:
isClosed
in interfaceTransportHelper
-
close
- Specified by:
close
in interfaceTransportHelper
-
failed
- Specified by:
failed
in interfaceTransportHelper
-
getSocketChannel
-
setUserData
- Specified by:
setUserData
in interfaceTransportHelper
-
getUserData
- Specified by:
getUserData
in interfaceTransportHelper
-
setTrace
public void setTrace(boolean on) - Specified by:
setTrace
in interfaceTransportHelper
-
setScatteringMode
public void setScatteringMode(long forBytes) - Specified by:
setScatteringMode
in interfaceTransportHelper
-