Class UDPConnection
- java.lang.Object
-
- com.biglybt.core.networkmanager.impl.udp.UDPConnection
-
public class UDPConnection extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
connected
private int
id
private AESemaphore
read_buffer_sem
private java.util.List
read_buffers
private UDPConnectionSet
set
private UDPTransportHelper
transport
-
Constructor Summary
Constructors Modifier Constructor Description protected
UDPConnection(UDPConnectionSet _set, int _id)
protected
UDPConnection(UDPConnectionSet _set, int _id, UDPTransportHelper _transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
canRead()
protected boolean
canWrite()
protected void
close(java.lang.String reason)
protected void
closeSupport(java.lang.String reason)
protected void
failed(java.lang.Throwable reason)
protected void
failedSupport(java.lang.Throwable reason)
protected int
getID()
protected UDPSelector
getSelector()
protected UDPTransportHelper
getTransport()
protected boolean
isConnected()
boolean
isIncoming()
protected void
poll()
protected int
read(java.nio.ByteBuffer buffer)
protected void
receive(java.nio.ByteBuffer data)
protected void
sent()
protected void
setID(int _id)
protected void
setSecret(byte[] session_secret)
protected void
setTransport(UDPTransportHelper _transport)
protected int
write(java.nio.ByteBuffer[] buffers, int offset, int length)
-
-
-
Field Detail
-
set
private final UDPConnectionSet set
-
id
private int id
-
transport
private UDPTransportHelper transport
-
read_buffers
private final java.util.List read_buffers
-
read_buffer_sem
private final AESemaphore read_buffer_sem
-
connected
private volatile boolean connected
-
-
Constructor Detail
-
UDPConnection
protected UDPConnection(UDPConnectionSet _set, int _id, UDPTransportHelper _transport)
-
UDPConnection
protected UDPConnection(UDPConnectionSet _set, int _id)
-
-
Method Detail
-
getSelector
protected UDPSelector getSelector()
-
getID
protected int getID()
-
setID
protected void setID(int _id)
-
isIncoming
public boolean isIncoming()
-
setSecret
protected void setSecret(byte[] session_secret)
-
setTransport
protected void setTransport(UDPTransportHelper _transport)
-
getTransport
protected UDPTransportHelper getTransport()
-
receive
protected void receive(java.nio.ByteBuffer data) throws java.io.IOException
- Throws:
java.io.IOException
-
sent
protected void sent()
-
canRead
protected boolean canRead()
-
canWrite
protected boolean canWrite()
-
write
protected int write(java.nio.ByteBuffer[] buffers, int offset, int length) throws java.io.IOException
- Throws:
java.io.IOException
-
read
protected int read(java.nio.ByteBuffer buffer) throws java.io.IOException
- Throws:
java.io.IOException
-
close
protected void close(java.lang.String reason)
-
failed
protected void failed(java.lang.Throwable reason)
-
closeSupport
protected void closeSupport(java.lang.String reason)
-
failedSupport
protected void failedSupport(java.lang.Throwable reason)
-
isConnected
protected boolean isConnected()
-
poll
protected void poll()
-
-