Class DHTNetworkPositionManager

java.lang.Object

com.biglybt.core.dht.netcoords.DHTNetworkPositionManager

public class DHTNetworkPositionManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final DHTNetworkPosition[]	NP_EMPTY_ARRAY
private static CopyOnWriteList<DHTNetworkPositionListener>	position_listeners
private static final CopyOnWriteList<DHTNetworkPositionProviderListener>	provider_listeners
private static DHTNetworkPositionProvider[]	providers
private static final Object	providers_lock
private static DHTStorageAdapter	storage_adapter

Constructor Summary

Constructors

Constructor	Description
DHTNetworkPositionManager()

Method Summary

Modifier and Type	Method	Description
static void	addPositionListener(DHTNetworkPositionListener listener)
static void	addProviderListener(DHTNetworkPositionProviderListener listener)
static DHTNetworkPosition[]	createPositions(byte[] ID, boolean is_local)
static DHTNetworkPosition	deserialise(InetAddress originator, byte position_type, DataInputStream is)
static DHTNetworkPosition	deserialisePosition(InetAddress originator, byte[] bytes)
static void	destroy(DHTStorageAdapter adapter)
static float	estimateRTT(DHTNetworkPosition[] p1s, DHTNetworkPosition[] p2s)
static DHTNetworkPosition	getBestLocalPosition()
static DHTNetworkPosition[]	getLocalPositions()
static DHTNetworkPositionProvider	getProvider(byte type)
static void	initialise(DHTStorageAdapter adapter)
static DHTNetworkPositionProviderInstance	registerProvider(DHTNetworkPositionProvider provider)
static void	removePositionListener(DHTNetworkPositionListener listener)
static void	removeProviderListener(DHTNetworkPositionProviderListener listener)
static byte[]	serialisePosition(DHTNetworkPosition pos)
private static void	shutDown(DHTNetworkPositionProvider provider)
private static void	startUp(DHTNetworkPositionProvider provider)
static void	unregisterProvider(DHTNetworkPositionProvider provider)
private static boolean	unregisterProviderSupport(DHTNetworkPositionProvider provider)
static void	update(DHTNetworkPosition[] local_positions, byte[] remote_id, DHTNetworkPosition[] remote_positions, float rtt)

Methods inherited from class Object

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

Field Details

providers

private static DHTNetworkPositionProvider[] providers

providers_lock

private static final Object providers_lock

storage_adapter

private static DHTStorageAdapter storage_adapter

provider_listeners

private static final CopyOnWriteList<DHTNetworkPositionProviderListener> provider_listeners

position_listeners

private static volatile CopyOnWriteList<DHTNetworkPositionListener> position_listeners

NP_EMPTY_ARRAY

private static final DHTNetworkPosition[] NP_EMPTY_ARRAY

Constructor Details

DHTNetworkPositionManager

public DHTNetworkPositionManager()

Method Details

initialise

public static void initialise(DHTStorageAdapter adapter)

startUp

private static void startUp(DHTNetworkPositionProvider provider)

shutDown

private static void shutDown(DHTNetworkPositionProvider provider)

destroy

public static void destroy(DHTStorageAdapter adapter)

registerProvider

public static DHTNetworkPositionProviderInstance registerProvider(DHTNetworkPositionProvider provider)

unregisterProvider

public static void unregisterProvider(DHTNetworkPositionProvider provider)

unregisterProviderSupport

private static boolean unregisterProviderSupport(DHTNetworkPositionProvider provider)

getProvider

public static DHTNetworkPositionProvider getProvider(byte type)

getLocalPositions

public static DHTNetworkPosition[] getLocalPositions()

getBestLocalPosition

public static DHTNetworkPosition getBestLocalPosition()

createPositions

public static DHTNetworkPosition[] createPositions(byte[] ID,
 boolean is_local)

estimateRTT

public static float estimateRTT(DHTNetworkPosition[] p1s,
 DHTNetworkPosition[] p2s)

update

public static void update(DHTNetworkPosition[] local_positions,
 byte[] remote_id,
 DHTNetworkPosition[] remote_positions,
 float rtt)

serialisePosition

public static byte[] serialisePosition(DHTNetworkPosition pos)
                                throws IOException

Throws:

IOException

deserialisePosition

public static DHTNetworkPosition deserialisePosition(InetAddress originator,
 byte[] bytes)
                                              throws IOException

Throws:

IOException

deserialise

public static DHTNetworkPosition deserialise(InetAddress originator,
 byte position_type,
 DataInputStream is)
                                      throws IOException

Throws:

IOException

addPositionListener

public static void addPositionListener(DHTNetworkPositionListener listener)

removePositionListener

public static void removePositionListener(DHTNetworkPositionListener listener)

addProviderListener

public static void addProviderListener(DHTNetworkPositionProviderListener listener)

removeProviderListener

public static void removeProviderListener(DHTNetworkPositionProviderListener listener)