Class UDPTransportHelper

java.lang.Object

com.biglybt.core.networkmanager.impl.udp.UDPTransportHelper

All Implemented Interfaces:

TransportHelper

public class UDPTransportHelper
extends Object
implements TransportHelper

Nested Class Summary

Nested classes/interfaces inherited from interface TransportHelper

TransportHelper.selectListener

Field Summary

Fields

Modifier and Type	Field	Description
private final InetSocketAddress	address
private boolean	closed
static final int	CONNECT_TIMEOUT
private UDPConnection	connection
private IOException	failed
private final boolean	incoming
private final UDPConnectionManager	manager
private ByteBuffer[]	pending_partial_writes
private Object	read_attachment
private TransportHelper.selectListener	read_listener
private boolean	read_selects_paused
static final int	READ_TIMEOUT
private UDPSelector	selector
private UDPTransport	transport
private Map	user_data
private Object	write_attachment
private TransportHelper.selectListener	write_listener
private boolean	write_selects_paused

Constructor Summary

Constructors

Constructor	Description
UDPTransportHelper(UDPConnectionManager _manager, InetSocketAddress _address, UDPConnection _connection)
UDPTransportHelper(UDPConnectionManager _manager, InetSocketAddress _address, UDPTransport _transport)

Method Summary

Modifier and Type	Method	Description
void	cancelReadSelects()
void	cancelWriteSelects()
protected void	canRead()
protected void	canWrite()
void	close(String reason)
boolean	delayWrite(ByteBuffer buffer)
void	failed(Throwable reason)
protected void	fireReadSelect()
protected void	fireWriteSelect()
InetSocketAddress	getAddress()
protected UDPConnection	getConnection()
int	getConnectTimeout()
protected int	getMss()
String	getName(boolean verbose)
int	getReadTimeout()
protected UDPTransport	getTransport()
Object	getUserData(Object key)
boolean	hasDelayedWrite()
boolean	isClosed()
boolean	isIncoming()
boolean	minimiseOverheads()
void	pauseReadSelects()
void	pauseWriteSelects()
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	resumeReadSelects()
void	resumeWriteSelects()
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)

Methods inherited from class Object

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

Field Details

READ_TIMEOUT

public static final int READ_TIMEOUT

See Also:

• Constant Field Values

CONNECT_TIMEOUT

public static final int CONNECT_TIMEOUT

See Also:

• Constant Field Values

manager

private final UDPConnectionManager manager

selector

private UDPSelector selector

address

private final InetSocketAddress address

transport

private UDPTransport transport

incoming

private final boolean incoming

connection

private UDPConnection connection

read_listener

private TransportHelper.selectListener read_listener

read_attachment

private Object read_attachment

read_selects_paused

private boolean read_selects_paused

write_listener

private TransportHelper.selectListener write_listener

write_attachment

private Object write_attachment

write_selects_paused

private boolean write_selects_paused

closed

private boolean closed

failed

private IOException failed

pending_partial_writes

private ByteBuffer[] pending_partial_writes

user_data

private Map 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

protected void setTransport(UDPTransport _transport)

getTransport

protected UDPTransport getTransport()

getMss

protected int getMss()

minimiseOverheads

public boolean minimiseOverheads()

Specified by:

minimiseOverheads in interface TransportHelper

getConnectTimeout

public int getConnectTimeout()

Specified by:

getConnectTimeout in interface TransportHelper

getReadTimeout

public int getReadTimeout()

Specified by:

getReadTimeout in interface TransportHelper

getAddress

public InetSocketAddress getAddress()

Specified by:

getAddress in interface TransportHelper

getName

public String getName(boolean verbose)

Specified by:

getName in interface TransportHelper

isIncoming

public boolean isIncoming()

getConnection

protected UDPConnection getConnection()

delayWrite

public boolean delayWrite(ByteBuffer buffer)

Specified by:

delayWrite in interface TransportHelper

hasDelayedWrite

public boolean hasDelayedWrite()

Specified by:

hasDelayedWrite in interface TransportHelper

write

public int write(ByteBuffer buffer,
 boolean partial_write)
          throws IOException

Specified by:

write in interface TransportHelper

Throws:

IOException

write

public long write(ByteBuffer[] buffers,
 int array_offset,
 int length)
           throws IOException

Specified by:

write in interface TransportHelper

Throws:

IOException

read

public int read(ByteBuffer buffer)
         throws IOException

Specified by:

read in interface TransportHelper

Throws:

IOException

read

public long read(ByteBuffer[] buffers,
 int array_offset,
 int length)
          throws IOException

Specified by:

read in interface TransportHelper

Throws:

IOException

canRead

protected void canRead()

canWrite

protected void canWrite()

pauseReadSelects

public void pauseReadSelects()

Specified by:

pauseReadSelects in interface TransportHelper

pauseWriteSelects

public void pauseWriteSelects()

Specified by:

pauseWriteSelects in interface TransportHelper

resumeReadSelects

public void resumeReadSelects()

Specified by:

resumeReadSelects in interface TransportHelper

resumeWriteSelects

public void resumeWriteSelects()

Specified by:

resumeWriteSelects in interface TransportHelper

registerForReadSelects

public void registerForReadSelects(TransportHelper.selectListener listener,
 Object attachment)

Specified by:

registerForReadSelects in interface TransportHelper

registerForWriteSelects

public void registerForWriteSelects(TransportHelper.selectListener listener,
 Object attachment)

Specified by:

registerForWriteSelects in interface TransportHelper

cancelReadSelects

public void cancelReadSelects()

Specified by:

cancelReadSelects in interface TransportHelper

cancelWriteSelects

public void cancelWriteSelects()

Specified by:

cancelWriteSelects in interface TransportHelper

fireReadSelect

protected void fireReadSelect()

fireWriteSelect

protected void fireWriteSelect()

failed

public void failed(Throwable reason)

Specified by:

failed in interface TransportHelper

isClosed

public boolean isClosed()

Specified by:

isClosed in interface TransportHelper

close

public void close(String reason)

Specified by:

close in interface TransportHelper

poll

protected void poll()

setUserData

public void setUserData(Object key,
 Object data)

Specified by:

setUserData in interface TransportHelper

getUserData

public Object getUserData(Object key)

Specified by:

getUserData in interface TransportHelper

setTrace

public void setTrace(boolean on)

Specified by:

setTrace in interface TransportHelper

setScatteringMode

public void setScatteringMode(long forBytes)

Specified by:

setScatteringMode in interface TransportHelper