Package com.biglybt.core.peermanager
Class PeerManager
- java.lang.Object
-
- com.biglybt.core.peermanager.PeerManager
-
- All Implemented Interfaces:
CoreStatsProvider
public class PeerManager extends java.lang.Object implements CoreStatsProvider
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
PeerManager.PeerManagerRegistrationImpl
-
Field Summary
Fields Modifier and Type Field Description private static boolean
enable_public_tcp_peers
private static boolean
enable_public_udp_peers
private static PeerManager
instance
private static java.lang.Object
KEY_TRANSPORT_PROBE
private java.nio.ByteBuffer
legacy_handshake_header
private static LogIDs
LOGID
private static int
PENDING_TIMEOUT
private java.util.Map<HashWrapper,CopyOnWriteList<PeerManager.PeerManagerRegistrationImpl>>
registered_legacy_managers
private java.util.Map<java.lang.String,PeerManager.PeerManagerRegistrationImpl>
registered_links
private static boolean
socks_data
private static AEMonitor
timer_mon
(package private) static java.util.Set<PeerManager.PeerManagerRegistrationImpl>
timer_targets
private static AEThread2
timer_thread
-
Constructor Summary
Constructors Modifier Constructor Description private
PeerManager()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static PeerManager
getSingleton()
Get the singleton instance of the peer manager.protected void
init()
PeerManagerRegistration
manualMatchHash(java.net.InetSocketAddress address, byte[] hash)
PeerManagerRegistration
manualMatchLink(java.net.InetSocketAddress address, java.lang.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(java.util.Set types, java.util.Map values)
-
-
-
Field Detail
-
LOGID
private static final LogIDs LOGID
-
KEY_TRANSPORT_PROBE
private static final java.lang.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 java.util.Set<PeerManager.PeerManagerRegistrationImpl> timer_targets
-
enable_public_tcp_peers
private static boolean enable_public_tcp_peers
-
enable_public_udp_peers
private static boolean enable_public_udp_peers
-
socks_data
private static boolean socks_data
-
registered_legacy_managers
private final java.util.Map<HashWrapper,CopyOnWriteList<PeerManager.PeerManagerRegistrationImpl>> registered_legacy_managers
-
registered_links
private final java.util.Map<java.lang.String,PeerManager.PeerManagerRegistrationImpl> registered_links
-
legacy_handshake_header
private final java.nio.ByteBuffer legacy_handshake_header
-
-
Method Detail
-
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(java.util.Set types, java.util.Map values)
- Specified by:
updateStats
in interfaceCoreStatsProvider
-
init
protected void init()
-
manualMatchHash
public PeerManagerRegistration manualMatchHash(java.net.InetSocketAddress address, byte[] hash)
-
manualMatchLink
public PeerManagerRegistration manualMatchLink(java.net.InetSocketAddress address, java.lang.String link)
-
manualRoute
public void manualRoute(PeerManagerRegistration _registration, NetworkConnection _connection, PeerManagerRoutingListener _listener)
-
registerLegacyManager
public PeerManagerRegistration registerLegacyManager(HashWrapper hash, PeerManagerRegistrationAdapter adapter)
-
-