Class UDPTransportHelper
java.lang.Object
com.biglybt.core.networkmanager.impl.udp.UDPTransportHelper
- 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 InetSocketAddress
private boolean
static final int
private UDPConnection
private IOException
private final boolean
private final UDPConnectionManager
private ByteBuffer[]
private Object
private TransportHelper.selectListener
private boolean
static final int
private UDPSelector
private UDPTransport
private Map
private Object
private TransportHelper.selectListener
private boolean
-
Constructor Summary
ConstructorsConstructorDescriptionUDPTransportHelper
(UDPConnectionManager _manager, InetSocketAddress _address, UDPConnection _connection) UDPTransportHelper
(UDPConnectionManager _manager, InetSocketAddress _address, UDPTransport _transport) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
protected void
canRead()
protected void
canWrite()
void
boolean
delayWrite
(ByteBuffer buffer) void
protected void
protected void
protected UDPConnection
int
protected int
getMss()
getName
(boolean verbose) int
protected UDPTransport
getUserData
(Object key) boolean
boolean
isClosed()
boolean
boolean
void
void
protected void
poll()
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) protected void
setTransport
(UDPTransport _transport) 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:
-
manager
-
selector
-
address
-
transport
-
incoming
private final boolean incoming -
connection
-
read_listener
-
read_attachment
-
read_selects_paused
private boolean read_selects_paused -
write_listener
-
write_attachment
-
write_selects_paused
private boolean write_selects_paused -
closed
private boolean closed -
failed
-
pending_partial_writes
-
user_data
-
-
Constructor Details
-
UDPTransportHelper
public UDPTransportHelper(UDPConnectionManager _manager, InetSocketAddress _address, UDPTransport _transport) throws IOException - Throws:
IOException
-
UDPTransportHelper
public UDPTransportHelper(UDPConnectionManager _manager, InetSocketAddress _address, UDPConnection _connection)
-
-
Method Details
-
setTransport
-
getTransport
-
getMss
protected int getMss() -
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
-
getAddress
- Specified by:
getAddress
in interfaceTransportHelper
-
getName
- Specified by:
getName
in interfaceTransportHelper
-
isIncoming
public boolean isIncoming() -
getConnection
-
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
-
read
- Specified by:
read
in interfaceTransportHelper
- Throws:
IOException
-
read
- Specified by:
read
in interfaceTransportHelper
- Throws:
IOException
-
canRead
protected void canRead() -
canWrite
protected void canWrite() -
pauseReadSelects
public void pauseReadSelects()- Specified by:
pauseReadSelects
in interfaceTransportHelper
-
pauseWriteSelects
public void pauseWriteSelects()- Specified by:
pauseWriteSelects
in interfaceTransportHelper
-
resumeReadSelects
public void resumeReadSelects()- Specified by:
resumeReadSelects
in interfaceTransportHelper
-
resumeWriteSelects
public void resumeWriteSelects()- Specified by:
resumeWriteSelects
in interfaceTransportHelper
-
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
-
fireReadSelect
protected void fireReadSelect() -
fireWriteSelect
protected void fireWriteSelect() -
failed
- Specified by:
failed
in interfaceTransportHelper
-
isClosed
public boolean isClosed()- Specified by:
isClosed
in interfaceTransportHelper
-
close
- Specified by:
close
in interfaceTransportHelper
-
poll
protected void poll() -
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
-