Class PeerManager

java.lang.Object

com.biglybt.core.peermanager.PeerManager

All Implemented Interfaces:

CoreStatsProvider

public class PeerManager
extends Object
implements CoreStatsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	PeerManager.PeerManagerRegistrationImpl
private class	PeerManager.PeerManagerRegistrationRoutingFailed

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	enable_public_tcp_peers
static boolean	enable_public_udp_peers
private static boolean	ignore_v4
private static boolean	ignore_v6
private static final PeerManager	instance
private static final Object	KEY_TRANSPORT_PROBE
private final ByteBuffer	legacy_handshake_header
private static final LogIDs	LOGID
private static final int	PENDING_TIMEOUT
private final Map<HashWrapper, CopyOnWriteList<PeerManager.PeerManagerRegistrationImpl>>	registered_legacy_managers
private final Map<String, PeerManager.PeerManagerRegistrationImpl>	registered_links
private static boolean	socks_data
private static final AEMonitor	timer_mon
(package private) static final Set<PeerManager.PeerManagerRegistrationImpl>	timer_targets
private static AEThread2	timer_thread

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PeerManager()

Method Summary

Modifier and Type	Method	Description
static PeerManager	getSingleton()	Get the singleton instance of the peer manager.
protected void	init()
PeerManagerRegistration	manualMatchHash(InetSocketAddress address, byte[] hash)
PeerManagerRegistration	manualMatchLink(InetSocketAddress address, String link)
void	manualRoute(PeerManagerRegistration _registration, NetworkConnection _connection, PeerManagerRoutingListener _listener)
protected static void	registerForTimeouts(PeerManager.PeerManagerRegistrationImpl reg)
PeerManagerRegistration	registerLegacyManager(HashWrapper hash, PeerManagerRegistrationAdapter adapter)
void	updateStats(Set types, Map values)

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

KEY_TRANSPORT_PROBE

private static final Object KEY_TRANSPORT_PROBE

instance

private static final PeerManager instance

PENDING_TIMEOUT

private static final int PENDING_TIMEOUT

See Also:

• Constant Field Values

timer_mon

private static final AEMonitor timer_mon

timer_thread

private static AEThread2 timer_thread

timer_targets

static final Set<PeerManager.PeerManagerRegistrationImpl> timer_targets

enable_public_tcp_peers

public static boolean enable_public_tcp_peers

enable_public_udp_peers

public static boolean enable_public_udp_peers

socks_data

private static boolean socks_data

ignore_v4

private static volatile boolean ignore_v4

ignore_v6

private static volatile boolean ignore_v6

registered_legacy_managers

private final Map<HashWrapper, CopyOnWriteList<PeerManager.PeerManagerRegistrationImpl>> registered_legacy_managers

registered_links

private final Map<String, PeerManager.PeerManagerRegistrationImpl> registered_links

legacy_handshake_header

private final ByteBuffer legacy_handshake_header

Constructor Details

PeerManager

private PeerManager()

Method Details

registerForTimeouts

protected static void registerForTimeouts(PeerManager.PeerManagerRegistrationImpl reg)

getSingleton

public static PeerManager getSingleton()

Get the singleton instance of the peer manager.

Returns:

the peer manager

updateStats

public void updateStats(Set types,
 Map values)

Specified by:

updateStats in interface CoreStatsProvider

init

protected void init()

manualMatchHash

public PeerManagerRegistration manualMatchHash(InetSocketAddress address,
 byte[] hash)

manualMatchLink

public PeerManagerRegistration manualMatchLink(InetSocketAddress address,
 String link)

manualRoute

public void manualRoute(PeerManagerRegistration _registration,
 NetworkConnection _connection,
 PeerManagerRoutingListener _listener)

registerLegacyManager

public PeerManagerRegistration registerLegacyManager(HashWrapper hash,
 PeerManagerRegistrationAdapter adapter)