com.aelitis.azureus.core.networkmanager.impl.udp
Class UDPConnectionManager
java.lang.Object
com.aelitis.azureus.core.networkmanager.impl.udp.UDPConnectionManager
- All Implemented Interfaces:
- NetworkGlueListener
public class UDPConnectionManager
- extends Object
- implements NetworkGlueListener
Method Summary |
protected void |
accept(int local_port,
InetSocketAddress remote_address,
UDPConnection connection)
|
protected int |
allocationConnectionID()
|
protected UDPSelector |
checkThreadCreation()
|
protected void |
checkThreadDeath(boolean connections_running)
|
void |
connectOutbound(UDPTransport udp_transport,
InetSocketAddress address,
byte[][] shared_secrets,
ByteBuffer initial_data,
Transport.ConnectListener listener)
|
void |
failed(UDPConnectionSet set)
|
int |
getMaxOutboundPermitted()
|
protected void |
logStats()
|
protected void |
poll()
|
protected boolean |
rateLimitIncoming(InetSocketAddress s_address)
|
void |
receive(int local_port,
InetSocketAddress remote_address,
byte[] data,
int data_length)
|
protected UDPConnection |
registerOutgoing(UDPTransportHelper helper)
|
void |
remove(UDPConnectionSet set,
UDPConnection connection)
|
int |
send(int local_port,
InetSocketAddress remote_address,
byte[] data)
|
protected void |
timeoutDeadKeys()
|
protected boolean |
trace()
|
protected void |
trace(String str)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TIMER_TICK_MILLIS
public static final int TIMER_TICK_MILLIS
- See Also:
- Constant Field Values
THREAD_LINGER_ON_IDLE_PERIOD
public static final int THREAD_LINGER_ON_IDLE_PERIOD
- See Also:
- Constant Field Values
DEAD_KEY_RETENTION_PERIOD
public static final int DEAD_KEY_RETENTION_PERIOD
- See Also:
- Constant Field Values
STATS_TIME
public static final int STATS_TIME
- See Also:
- Constant Field Values
STATS_TICKS
public static final int STATS_TICKS
- See Also:
- Constant Field Values
UDPConnectionManager
protected UDPConnectionManager()
connectOutbound
public void connectOutbound(UDPTransport udp_transport,
InetSocketAddress address,
byte[][] shared_secrets,
ByteBuffer initial_data,
Transport.ConnectListener listener)
getMaxOutboundPermitted
public int getMaxOutboundPermitted()
checkThreadCreation
protected UDPSelector checkThreadCreation()
checkThreadDeath
protected void checkThreadDeath(boolean connections_running)
poll
protected void poll()
remove
public void remove(UDPConnectionSet set,
UDPConnection connection)
failed
public void failed(UDPConnectionSet set)
registerOutgoing
protected UDPConnection registerOutgoing(UDPTransportHelper helper)
throws IOException
- Throws:
IOException
receive
public void receive(int local_port,
InetSocketAddress remote_address,
byte[] data,
int data_length)
- Specified by:
receive
in interface NetworkGlueListener
rateLimitIncoming
protected boolean rateLimitIncoming(InetSocketAddress s_address)
send
public int send(int local_port,
InetSocketAddress remote_address,
byte[] data)
throws IOException
- Throws:
IOException
accept
protected void accept(int local_port,
InetSocketAddress remote_address,
UDPConnection connection)
allocationConnectionID
protected int allocationConnectionID()
timeoutDeadKeys
protected void timeoutDeadKeys()
logStats
protected void logStats()
trace
protected boolean trace()
trace
protected void trace(String str)