Class ClientInstanceManagerImpl

java.lang.Object

com.biglybt.core.instancemanager.impl.ClientInstanceManagerImpl

All Implemented Interfaces:

ClientInstanceManager, MCGroupAdapter

public class ClientInstanceManagerImpl
extends Object
implements ClientInstanceManager, MCGroupAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ClientInstanceManagerImpl.Request
protected static class	ClientInstanceManagerImpl.trackedInstance

Field Summary

Fields

Modifier and Type	Field	Description
private final ClientInstanceManagerAdapter	adapter
private static final long	ALIVE_PERIOD
private static final AEMonitor	class_mon
(package private) boolean	closing
(package private) static Set<String>	data_socks_proxies
private static final boolean	DISABLE_LAN_LOCAL_STUFF
private CopyOnWriteSet<InetSocketAddress>	explicit_addresses
private List<InetSocketAddress>	explicit_peers
private boolean	include_well_known_lans
private boolean	init_wait_abandoned
(package private) final AESemaphore	initial_search_sem
private boolean	initialised
private final IpFilter	ip_filter
private Set<InetAddress>	lan_addresses
private List<Pattern>	lan_subnets
private final List	listeners
private static final LogIDs	LOGID
private MCGroup	mc_group
private static final String	MC_GROUP_ADDRESS
private static final int	MC_GROUP_PORT
private static final int	MT_ALIVE
private static final int	MT_BYE
private static final int	MT_REPLY
private static final int	MT_REQUEST
private static final int	MT_REQUEST_SEARCH
private static final int	MT_REQUEST_TRACK
private static final int	MT_VERSION
(package private) final ClientMyInstanceImpl	my_instance
private final Map<String, ClientOtherInstanceImpl>	other_instances
(package private) final List<ClientInstanceManagerImpl.Request>	requests
(package private) long	search_id_next
private static ClientInstanceManagerImpl	singleton
private Map<InetSocketAddress, InetSocketAddress>	tcp_ext_to_lan
private Map<InetSocketAddress, InetSocketAddress>	tcp_lan_to_ext
(package private) final AEMonitor	this_mon
private Map<InetSocketAddress, InetSocketAddress>	udp_ext_to_lan
private Map<InetSocketAddress, InetSocketAddress>	udp_lan_to_ext
private Map<InetSocketAddress, InetSocketAddress>	udp2_ext_to_lan
private Map<InetSocketAddress, InetSocketAddress>	udp2_lan_to_ext

Fields inherited from interface ClientInstanceManager

AT_TCP, AT_UDP, AT_UDP_NON_DATA

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClientInstanceManagerImpl(ClientInstanceManagerAdapter _adapter)

Method Summary

Modifier and Type	Method	Description
protected void	addAddresses(ClientInstance inst)
void	addExplicitLANAddress(InetSocketAddress isa)
boolean	addInstance(InetAddress explicit_address)
protected boolean	addInstanceSupport(InetAddress explicit_address, boolean force_send_alive)
boolean	addLANSubnet(String subnet)
void	addListener(ClientInstanceManagerListener l)
protected ClientOtherInstanceImpl	checkAdd(ClientOtherInstanceImpl inst)
protected void	checkRemove(ClientOtherInstanceImpl inst)
protected void	checkTimeouts()
long	getClockSkew()
private MCGroup	getDummyMCGroup()
InetSocketAddress	getExternalAddress(InetSocketAddress lan_address, int address_type)
boolean	getIncludeWellKnownLANs()
InetSocketAddress	getLANAddress(InetSocketAddress external_address, int address_type)
ClientInstance	getMyInstance()
int	getOtherInstanceCount(boolean block_if_needed)
ClientInstance[]	getOtherInstances()
static ClientInstanceManager	getSingleton(ClientInstanceManagerAdapter core)
protected void	informAdded(ClientInstance inst)
protected void	informChanged(ClientInstance inst)
protected void	informRemoved(ClientOtherInstanceImpl inst)
protected void	informTracked(ClientInstanceTracked inst)
void	initialize()
void	interfaceChanged(NetworkInterface network_interface)
protected boolean	isClosing()
boolean	isExplicitLANAddress(InetSocketAddress isa)
boolean	isInitialized()
boolean	isLANAddress(InetSocketAddress isa)
void	log(String msg, Throwable e)
void	log(Throwable e)
protected Map<InetSocketAddress, InetSocketAddress>	modifyAddress(Map<InetSocketAddress, InetSocketAddress> map, InetSocketAddress key, InetSocketAddress value, boolean add)
protected void	modifyAddresses(InetAddress internal_address, InetAddress external_address, int tcp, int udp, int udp2, boolean add)
void	received(NetworkInterface network_interface, InetAddress local_address, InetSocketAddress originator, byte[] data, int length)
protected void	removeAddresses(ClientInstance inst)
void	removeExplicitLANAddress(InetSocketAddress isa)
void	removeListener(ClientInstanceManagerListener l)
protected Map	requestReceived(ClientInstance instance, Map body)
protected void	search()
protected void	sendAlive()
protected void	sendAlive(InetSocketAddress target)
protected void	sendByeBye()
protected void	sendByeBye(InetSocketAddress target)
protected void	sendMessage(int type)
protected void	sendMessage(int type, InetSocketAddress target)
protected void	sendMessage(int type, Map body)
protected void	sendMessage(int type, Map body, InetSocketAddress member)
protected Map	sendRequest(int type)
protected Map	sendRequest(int type, Map body)
void	setIncludeWellKnownLANs(boolean include)
private InetSocketAddress	setPort(InetSocketAddress isa, int port)
void	trace(String str)
ClientInstanceTracked[]	track(byte[] hash, ClientInstanceTracked.TrackTarget target)
void	updateNow()
private void	waitForInit()

Methods inherited from class Object

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

Field Details

DISABLE_LAN_LOCAL_STUFF

private static final boolean DISABLE_LAN_LOCAL_STUFF

See Also:

• Constant Field Values

LOGID

private static final LogIDs LOGID

MC_GROUP_ADDRESS

private static final String MC_GROUP_ADDRESS

See Also:

• Constant Field Values

MC_GROUP_PORT

private static final int MC_GROUP_PORT

See Also:

• Constant Field Values

MT_VERSION

private static final int MT_VERSION

See Also:

• Constant Field Values

MT_ALIVE

private static final int MT_ALIVE

See Also:

• Constant Field Values

MT_BYE

private static final int MT_BYE

See Also:

• Constant Field Values

MT_REQUEST

private static final int MT_REQUEST

See Also:

• Constant Field Values

MT_REPLY

private static final int MT_REPLY

See Also:

• Constant Field Values

MT_REQUEST_SEARCH

private static final int MT_REQUEST_SEARCH

See Also:

• Constant Field Values

MT_REQUEST_TRACK

private static final int MT_REQUEST_TRACK

See Also:

• Constant Field Values

ALIVE_PERIOD

private static final long ALIVE_PERIOD

See Also:

• Constant Field Values

singleton

private static ClientInstanceManagerImpl singleton

listeners

private final List listeners

class_mon

private static final AEMonitor class_mon

data_socks_proxies

static Set<String> data_socks_proxies

adapter

private final ClientInstanceManagerAdapter adapter

mc_group

private MCGroup mc_group

search_id_next

long search_id_next

requests

final List<ClientInstanceManagerImpl.Request> requests

my_instance

final ClientMyInstanceImpl my_instance

other_instances

private final Map<String, ClientOtherInstanceImpl> other_instances

initialised

private volatile boolean initialised

ip_filter

private final IpFilter ip_filter

tcp_lan_to_ext

private volatile Map<InetSocketAddress, InetSocketAddress> tcp_lan_to_ext

udp_lan_to_ext

private volatile Map<InetSocketAddress, InetSocketAddress> udp_lan_to_ext

udp2_lan_to_ext

private volatile Map<InetSocketAddress, InetSocketAddress> udp2_lan_to_ext

tcp_ext_to_lan

private volatile Map<InetSocketAddress, InetSocketAddress> tcp_ext_to_lan

udp_ext_to_lan

private volatile Map<InetSocketAddress, InetSocketAddress> udp_ext_to_lan

udp2_ext_to_lan

private volatile Map<InetSocketAddress, InetSocketAddress> udp2_ext_to_lan

lan_addresses

private volatile Set<InetAddress> lan_addresses

lan_subnets

private volatile List<Pattern> lan_subnets

explicit_peers

private volatile List<InetSocketAddress> explicit_peers

explicit_addresses

private CopyOnWriteSet<InetSocketAddress> explicit_addresses

include_well_known_lans

private volatile boolean include_well_known_lans

initial_search_sem

final AESemaphore initial_search_sem

init_wait_abandoned

private boolean init_wait_abandoned

this_mon

final AEMonitor this_mon

closing

boolean closing

Constructor Details

ClientInstanceManagerImpl

protected ClientInstanceManagerImpl(ClientInstanceManagerAdapter _adapter)

Method Details

getSingleton

public static ClientInstanceManager getSingleton(ClientInstanceManagerAdapter core)

initialize

public void initialize()

Specified by:

initialize in interface ClientInstanceManager

getDummyMCGroup

private MCGroup getDummyMCGroup()

getClockSkew

public long getClockSkew()

Specified by:

getClockSkew in interface ClientInstanceManager

trace

public void trace(String str)

Specified by:

trace in interface MCGroupAdapter

log

public void log(String msg,
 Throwable e)

Specified by:

log in interface MCGroupAdapter

log

public void log(Throwable e)

Specified by:

log in interface MCGroupAdapter

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface ClientInstanceManager

updateNow

public void updateNow()

Specified by:

updateNow in interface ClientInstanceManager

isClosing

protected boolean isClosing()

sendAlive

protected void sendAlive()

sendAlive

protected void sendAlive(InetSocketAddress target)

sendByeBye

protected void sendByeBye()

sendByeBye

protected void sendByeBye(InetSocketAddress target)

sendMessage

protected void sendMessage(int type)

sendMessage

protected void sendMessage(int type,
 InetSocketAddress target)

sendMessage

protected void sendMessage(int type,
 Map body)

sendMessage

protected void sendMessage(int type,
 Map body,
 InetSocketAddress member)

received

public void received(NetworkInterface network_interface,
 InetAddress local_address,
 InetSocketAddress originator,
 byte[] data,
 int length)

Specified by:

received in interface MCGroupAdapter

requestReceived

protected Map requestReceived(ClientInstance instance,
 Map body)

interfaceChanged

public void interfaceChanged(NetworkInterface network_interface)

Specified by:

interfaceChanged in interface MCGroupAdapter

checkAdd

protected ClientOtherInstanceImpl checkAdd(ClientOtherInstanceImpl inst)

checkRemove

protected void checkRemove(ClientOtherInstanceImpl inst)

getMyInstance

public ClientInstance getMyInstance()

Specified by:

getMyInstance in interface ClientInstanceManager

search

protected void search()

getOtherInstanceCount

public int getOtherInstanceCount(boolean block_if_needed)

Specified by:

getOtherInstanceCount in interface ClientInstanceManager

getOtherInstances

public ClientInstance[] getOtherInstances()

Specified by:

getOtherInstances in interface ClientInstanceManager

waitForInit

private void waitForInit()

addAddresses

protected void addAddresses(ClientInstance inst)

removeAddresses

protected void removeAddresses(ClientInstance inst)

modifyAddresses

protected void modifyAddresses(InetAddress internal_address,
 InetAddress external_address,
 int tcp,
 int udp,
 int udp2,
 boolean add)

modifyAddress

protected Map<InetSocketAddress, InetSocketAddress> modifyAddress(Map<InetSocketAddress, InetSocketAddress> map,
 InetSocketAddress key,
 InetSocketAddress value,
 boolean add)

getLANAddress

public InetSocketAddress getLANAddress(InetSocketAddress external_address,
 int address_type)

Specified by:

getLANAddress in interface ClientInstanceManager

getExternalAddress

public InetSocketAddress getExternalAddress(InetSocketAddress lan_address,
 int address_type)

Specified by:

getExternalAddress in interface ClientInstanceManager

isLANAddress

public boolean isLANAddress(InetSocketAddress isa)

Specified by:

isLANAddress in interface ClientInstanceManager

addExplicitLANAddress

public void addExplicitLANAddress(InetSocketAddress isa)

Specified by:

addExplicitLANAddress in interface ClientInstanceManager

isExplicitLANAddress

public boolean isExplicitLANAddress(InetSocketAddress isa)

Specified by:

isExplicitLANAddress in interface ClientInstanceManager

removeExplicitLANAddress

public void removeExplicitLANAddress(InetSocketAddress isa)

Specified by:

removeExplicitLANAddress in interface ClientInstanceManager

setPort

private InetSocketAddress setPort(InetSocketAddress isa,
 int port)

addLANSubnet

public boolean addLANSubnet(String subnet)
                     throws PatternSyntaxException

Specified by:

addLANSubnet in interface ClientInstanceManager

Throws:

PatternSyntaxException

setIncludeWellKnownLANs

public void setIncludeWellKnownLANs(boolean include)

Specified by:

setIncludeWellKnownLANs in interface ClientInstanceManager

getIncludeWellKnownLANs

public boolean getIncludeWellKnownLANs()

Specified by:

getIncludeWellKnownLANs in interface ClientInstanceManager

addInstance

public boolean addInstance(InetAddress explicit_address)

Specified by:

addInstance in interface ClientInstanceManager

addInstanceSupport

protected boolean addInstanceSupport(InetAddress explicit_address,
 boolean force_send_alive)

track

public ClientInstanceTracked[] track(byte[] hash,
 ClientInstanceTracked.TrackTarget target)

Specified by:

track in interface ClientInstanceManager

checkTimeouts

protected void checkTimeouts()

informRemoved

protected void informRemoved(ClientOtherInstanceImpl inst)

informAdded

protected void informAdded(ClientInstance inst)

informChanged

protected void informChanged(ClientInstance inst)

informTracked

protected void informTracked(ClientInstanceTracked inst)

sendRequest

protected Map sendRequest(int type)

sendRequest

protected Map sendRequest(int type,
 Map body)

addListener

public void addListener(ClientInstanceManagerListener l)

Specified by:

addListener in interface ClientInstanceManager

removeListener

public void removeListener(ClientInstanceManagerListener l)

Specified by:

removeListener in interface ClientInstanceManager