Class UDPConnection

java.lang.Object

com.biglybt.core.networkmanager.impl.udp.UDPConnection

public class UDPConnection
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	connected
private int	id
private final AESemaphore	read_buffer_sem
private final List	read_buffers
private final 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

Modifier and Type	Method	Description
protected boolean	canRead()
protected boolean	canWrite()
protected void	close(String reason)
protected void	closeSupport(String reason)
protected void	failed(Throwable reason)
protected void	failedSupport(Throwable reason)
protected int	getID()
protected UDPSelector	getSelector()
protected UDPTransportHelper	getTransport()
protected boolean	isConnected()
boolean	isIncoming()
protected void	poll()
protected int	read(ByteBuffer buffer)
protected void	receive(ByteBuffer data)
protected void	sent()
protected void	setID(int _id)
protected void	setSecret(byte[] session_secret)
protected void	setTransport(UDPTransportHelper _transport)
protected int	write(ByteBuffer[] buffers, int offset, int length)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

set

private final UDPConnectionSet set

id

private int id

transport

private UDPTransportHelper transport

read_buffers

private final List read_buffers

read_buffer_sem

private final AESemaphore read_buffer_sem

connected

private volatile boolean connected

Constructor Details

UDPConnection

protected UDPConnection(UDPConnectionSet _set,
 int _id,
 UDPTransportHelper _transport)

UDPConnection

protected UDPConnection(UDPConnectionSet _set,
 int _id)

Method Details

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(ByteBuffer data)
                throws IOException

Throws:

IOException

sent

protected void sent()

canRead

protected boolean canRead()

canWrite

protected boolean canWrite()

write

protected int write(ByteBuffer[] buffers,
 int offset,
 int length)
             throws IOException

Throws:

IOException

read

protected int read(ByteBuffer buffer)
            throws IOException

Throws:

IOException

close

protected void close(String reason)

failed

protected void failed(Throwable reason)

closeSupport

protected void closeSupport(String reason)

failedSupport

protected void failedSupport(Throwable reason)

isConnected

protected boolean isConnected()

poll

protected void poll()