Class UDPConnectionManager

java.lang.Object

com.biglybt.core.networkmanager.impl.udp.UDPConnectionManager

All Implemented Interfaces:

NetworkGlueListener

public class UDPConnectionManager
extends Object
implements NetworkGlueListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	UDPConnectionManager.ProtocolTimer

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BLOOM_INCREASE
private static final int	BLOOM_RECREATE
(package private) final Map	connection_sets
static final int	DEAD_KEY_RETENTION_PERIOD
private static final boolean	FORCE_LOG
private long	idle_start
private BloomFilter	incoming_bloom
private long	incoming_bloom_create_time
(package private) final IncomingConnectionManager	incoming_manager
private long	last_incoming
(package private) static boolean	LOG
(package private) static final LogIDs	LOGID
private static final boolean	LOOPBACK
private boolean	max_conn_exceeded_logged
(package private) static int	max_outbound_connections
private final NetworkGlue	network_glue
private int	next_connection_id
(package private) int	outbound_connection_count
private UDPConnectionManager.ProtocolTimer	protocol_timer
private int	rate_limit_discard_bytes
private int	rate_limit_discard_packets
(package private) final Map	recently_dead_keys
private UDPSelector	selector
private int	setup_discard_bytes
private int	setup_discard_packets
static final int	STATS_TICKS
static final int	STATS_TIME
static final int	THREAD_LINGER_ON_IDLE_PERIOD
static final int	TIMER_TICK_MILLIS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UDPConnectionManager()

Method Summary

Modifier and Type	Method	Description
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 Object

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

Field Details

LOGID

static final LogIDs LOGID

LOOPBACK

private static final boolean LOOPBACK

See Also:

• Constant Field Values

FORCE_LOG

private static final boolean FORCE_LOG

See Also:

• Constant Field Values

LOG

static boolean LOG

max_outbound_connections

static int max_outbound_connections

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

connection_sets

final Map connection_sets

recently_dead_keys

final Map recently_dead_keys

next_connection_id

private int next_connection_id

incoming_manager

final IncomingConnectionManager incoming_manager

network_glue

private final NetworkGlue network_glue

selector

private UDPSelector selector

protocol_timer

private UDPConnectionManager.ProtocolTimer protocol_timer

idle_start

private long idle_start

BLOOM_RECREATE

private static final int BLOOM_RECREATE

See Also:

• Constant Field Values

BLOOM_INCREASE

private static final int BLOOM_INCREASE

See Also:

• Constant Field Values

incoming_bloom

private BloomFilter incoming_bloom

incoming_bloom_create_time

private long incoming_bloom_create_time

last_incoming

private long last_incoming

rate_limit_discard_packets

private int rate_limit_discard_packets

rate_limit_discard_bytes

private int rate_limit_discard_bytes

setup_discard_packets

private int setup_discard_packets

setup_discard_bytes

private int setup_discard_bytes

outbound_connection_count

volatile int outbound_connection_count

max_conn_exceeded_logged

private boolean max_conn_exceeded_logged

Constructor Details

UDPConnectionManager

protected UDPConnectionManager()

Method Details

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)