Class PairingManagerImpl

java.lang.Object

com.biglybt.core.pairing.impl.PairingManagerImpl

All Implemented Interfaces:

PairingManager, AEDiagnosticsEvidenceGenerator

public class PairingManagerImpl
extends Object
implements PairingManager, AEDiagnosticsEvidenceGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	PairingManagerImpl.PairedNodeImpl
private static class	PairingManagerImpl.PairedService2Impl
protected class	PairingManagerImpl.PairedServiceImpl
private static class	PairingManagerImpl.PairingConnectionData2
protected class	PairingManagerImpl.TestServiceImpl
static interface	PairingManagerImpl.UIAdapter

Field Summary

Fields

Modifier and Type	Field	Description
private String	_SERVICE_URL
private String	_TUNNEL_SERVER
private URL	_WEB_REMOTE_URL
private static final int	CD_REFRESH_PERIOD
private static final int	CD_REFRESH_TICKS
private static final int	CONNECT_TEST_PERIOD_MILLIS
private int	consec_update_fails
private Core	core
private InetAddress	current_v4
private InetAddress	current_v6
private static final boolean	DEBUG
private final String	DEFAULT_SERVICE_URL
private final String	DEFAULT_TUNNEL_SERVER
private final URL	DEFAULT_WEB_REMOTE_URL
private TimerEvent	deferred_update_event
private final AsyncDispatcher	dispatcher
private TimerEventPeriodic	global_update_event
private static final int	GLOBAL_UPDATE_PERIOD
private Set<InetAddress>	ignored_v4
private Set<InetAddress>	ignored_v6
private final AESemaphore	init_sem
private String	last_message
private long	last_update_time
private final CopyOnWriteList<PairingManagerListener>	listeners
(package private) final Map<String,Object[]>	local_address_checks
private String	local_v4
private String	local_v6
private int	max_update_period
private static final int	MAX_UPDATE_PERIOD_DEFAULT
private int	min_update_period
private static final int	MIN_UPDATE_PERIOD_DEFAULT
private boolean	must_update_once
private final InfoParameter	param_ac_info
private final BooleanParameter	param_e_enable
(package private) final BooleanParameter	param_enable
private final StringParameter	param_host
private final BooleanParameter	param_icon_enable
private final InfoParameter	param_last_error
private final StringParameter	param_local_ipv4
private final StringParameter	param_local_ipv6
private final BooleanParameter	param_net_enable
private final StringParameter	param_public_ipv4
private final StringParameter	param_public_ipv6
(package private) final BooleanParameter	param_srp_enable
private final LabelParameter	param_srp_state
private final InfoParameter	param_status_info
private final HyperlinkParameter	param_view
private long	qr_version
private final Map<String, PairingManagerImpl.PairedServiceImpl>	services
private static final PairingManagerImpl	singleton
private int	tests_in_progress
private PairingManagerTunnelHandler	tunnel_handler
private PairingManagerImpl.UIAdapter	ui
private boolean	update_in_progress
private boolean	update_outstanding
private boolean	updates_enabled

Fields inherited from interface PairingManager

CONFIG_SECTION_ID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PairingManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	addListener(PairingManagerListener l)
PairedService	addService(String sid, PairedServiceRequestHandler handler)
protected String	allocateAccessCode(boolean updating)
protected void	deferUpdate(long millis)
protected void	doUpdate()
protected void	enableUpdates()
protected void	fireChanged()
void	generate(IndentWriter writer)
String	getAccessCode()
void	getAccessCode(PairingManagerListener listener)
String	getGroup()
String	getLastServerError()
File	getQRCode()
String	getReplacementAccessCode()
PairingManagerImpl.PairedServiceImpl	getService(String sid)
private void	getServices()
URL	getServiceURL()
static PairingManager	getSingleton()
String	getSRPStatus()
String	getStatus()
protected String	getString(Map<String,Object> map, String name)
protected String	getString(Set<String> set)
String	getTunnelServer()
URL	getWebRemoteURL()
boolean	handleLocalTunnel(TrackerWebPageRequest request, TrackerWebPageResponse response)
boolean	hasActionOutstanding()
protected void	initialise(Core _core)
boolean	isEnabled()
boolean	isSRPEnabled()
List<PairedNode>	listGroup()
List<PairedService>	lookupServices(String access_code)
String	peekAccessCode()
protected String	readAccessCode()
private File	receiveQR(String ac, Map<String,Object> response)
void	recordRequest(String name, String ip, boolean good)
protected void	remove(PairingManagerImpl.PairedServiceImpl service)
void	removeListener(PairingManagerListener l)
private Map<String,Object>	sendRequest(String command, Map<String,Object> payload)
void	setEnabled(boolean enabled)
void	setGroup(String group)
protected void	setLastServerError(String error, Map<String,Object> payload)
void	setSRPEnabled(boolean enabled)
void	setSRPPassword(char[] password)
protected void	setStatus(String str)
protected void	sync(PairingManagerImpl.PairedServiceImpl service)
PairingTest	testService(String sid, PairingTestListener listener)
protected InetAddress	updateAddress(InetAddress current, InetAddress latest, boolean v6)
protected void	updateGlobals(boolean is_updating)
protected void	updateNeeded()
protected void	updateSRPState()
protected void	waitForInitialisation()
protected void	writeAccessCode(String ac)

Methods inherited from class Object

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

Field Details

DEBUG

private static final boolean DEBUG

See Also:

• Constant Field Values

DEFAULT_SERVICE_URL

private final String DEFAULT_SERVICE_URL

DEFAULT_WEB_REMOTE_URL

private final URL DEFAULT_WEB_REMOTE_URL

DEFAULT_TUNNEL_SERVER

private final String DEFAULT_TUNNEL_SERVER

_SERVICE_URL

private String _SERVICE_URL

_WEB_REMOTE_URL

private URL _WEB_REMOTE_URL

_TUNNEL_SERVER

private String _TUNNEL_SERVER

singleton

private static final PairingManagerImpl singleton

GLOBAL_UPDATE_PERIOD

private static final int GLOBAL_UPDATE_PERIOD

See Also:

• Constant Field Values

CD_REFRESH_PERIOD

private static final int CD_REFRESH_PERIOD

See Also:

• Constant Field Values

CD_REFRESH_TICKS

private static final int CD_REFRESH_TICKS

See Also:

• Constant Field Values

CONNECT_TEST_PERIOD_MILLIS

private static final int CONNECT_TEST_PERIOD_MILLIS

See Also:

• Constant Field Values

core

private Core core

param_enable

final BooleanParameter param_enable

param_ac_info

private final InfoParameter param_ac_info

param_status_info

private final InfoParameter param_status_info

param_last_error

private final InfoParameter param_last_error

param_view

private final HyperlinkParameter param_view

param_srp_enable

final BooleanParameter param_srp_enable

param_srp_state

private final LabelParameter param_srp_state

param_e_enable

private final BooleanParameter param_e_enable

param_public_ipv4

private final StringParameter param_public_ipv4

param_public_ipv6

private final StringParameter param_public_ipv6

param_host

private final StringParameter param_host

param_net_enable

private final BooleanParameter param_net_enable

param_local_ipv4

private final StringParameter param_local_ipv4

param_local_ipv6

private final StringParameter param_local_ipv6

param_icon_enable

private final BooleanParameter param_icon_enable

services

private final Map<String, PairingManagerImpl.PairedServiceImpl> services

init_sem

private final AESemaphore init_sem

global_update_event

private TimerEventPeriodic global_update_event

current_v4

private InetAddress current_v4

current_v6

private InetAddress current_v6

local_v4

private String local_v4

local_v6

private String local_v6

ignored_v4

private Set<InetAddress> ignored_v4

ignored_v6

private Set<InetAddress> ignored_v6

tunnel_handler

private PairingManagerTunnelHandler tunnel_handler

update_outstanding

private boolean update_outstanding

updates_enabled

private boolean updates_enabled

MIN_UPDATE_PERIOD_DEFAULT

private static final int MIN_UPDATE_PERIOD_DEFAULT

See Also:

• Constant Field Values

MAX_UPDATE_PERIOD_DEFAULT

private static final int MAX_UPDATE_PERIOD_DEFAULT

See Also:

• Constant Field Values

min_update_period

private int min_update_period

max_update_period

private int max_update_period

dispatcher

private final AsyncDispatcher dispatcher

must_update_once

private boolean must_update_once

update_in_progress

private boolean update_in_progress

deferred_update_event

private TimerEvent deferred_update_event

last_update_time

private long last_update_time

consec_update_fails

private int consec_update_fails

qr_version

private long qr_version

last_message

private String last_message

local_address_checks

final Map<String,Object[]> local_address_checks

listeners

private final CopyOnWriteList<PairingManagerListener> listeners

ui

private PairingManagerImpl.UIAdapter ui

tests_in_progress

private int tests_in_progress

Constructor Details

PairingManagerImpl

protected PairingManagerImpl()

Method Details

getSingleton

public static PairingManager getSingleton()

getServices

private void getServices()

initialise

protected void initialise(Core _core)

waitForInitialisation

protected void waitForInitialisation()
                              throws PairingException

Throws:

PairingException

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface PairingManager

setEnabled

public void setEnabled(boolean enabled)

Specified by:

setEnabled in interface PairingManager

isSRPEnabled

public boolean isSRPEnabled()

Specified by:

isSRPEnabled in interface PairingManager

setSRPEnabled

public void setSRPEnabled(boolean enabled)

Specified by:

setSRPEnabled in interface PairingManager

getServiceURL

public URL getServiceURL()

Specified by:

getServiceURL in interface PairingManager

getWebRemoteURL

public URL getWebRemoteURL()

Specified by:

getWebRemoteURL in interface PairingManager

getTunnelServer

public String getTunnelServer()

Specified by:

getTunnelServer in interface PairingManager

setGroup

public void setGroup(String group)

Specified by:

setGroup in interface PairingManager

getGroup

public String getGroup()

Specified by:

getGroup in interface PairingManager

listGroup

public List<PairedNode> listGroup()
                           throws PairingException

Specified by:

listGroup in interface PairingManager

Throws:

PairingException

lookupServices

public List<PairedService> lookupServices(String access_code)
                                   throws PairingException

Specified by:

lookupServices in interface PairingManager

Throws:

PairingException

setStatus

protected void setStatus(String str)

getStatus

public String getStatus()

Specified by:

getStatus in interface PairingManager

getSRPStatus

public String getSRPStatus()

Specified by:

getSRPStatus in interface PairingManager

setLastServerError

protected void setLastServerError(String error,
 Map<String,Object> payload)

getLastServerError

public String getLastServerError()

Specified by:

getLastServerError in interface PairingManager

hasActionOutstanding

public boolean hasActionOutstanding()

Specified by:

hasActionOutstanding in interface PairingManager

readAccessCode

protected String readAccessCode()

writeAccessCode

protected void writeAccessCode(String ac)

receiveQR

private File receiveQR(String ac,
 Map<String,Object> response)

getQRCode

public File getQRCode()

Specified by:

getQRCode in interface PairingManager

allocateAccessCode

protected String allocateAccessCode(boolean updating)
                             throws PairingException

Throws:

PairingException

peekAccessCode

public String peekAccessCode()

Specified by:

peekAccessCode in interface PairingManager

getAccessCode

public String getAccessCode()
                     throws PairingException

Specified by:

getAccessCode in interface PairingManager

Throws:

PairingException

getAccessCode

public void getAccessCode(PairingManagerListener listener)
                   throws PairingException

Throws:

PairingException

getReplacementAccessCode

public String getReplacementAccessCode()
                                throws PairingException

Specified by:

getReplacementAccessCode in interface PairingManager

Throws:

PairingException

addService

public PairedService addService(String sid,
 PairedServiceRequestHandler handler)

Specified by:

addService in interface PairingManager

getService

public PairingManagerImpl.PairedServiceImpl getService(String sid)

Specified by:

getService in interface PairingManager

remove

protected void remove(PairingManagerImpl.PairedServiceImpl service)

sync

protected void sync(PairingManagerImpl.PairedServiceImpl service)

updateAddress

protected InetAddress updateAddress(InetAddress current,
 InetAddress latest,
 boolean v6)

updateGlobals

protected void updateGlobals(boolean is_updating)

getString

protected String getString(Set<String> set)

enableUpdates

protected void enableUpdates()

updateNeeded

protected void updateNeeded()

doUpdate

protected void doUpdate()

deferUpdate

protected void deferUpdate(long millis)

sendRequest

private Map<String,Object> sendRequest(String command,
 Map<String,Object> payload)
                                throws PairingException

Throws:

PairingException

testService

public PairingTest testService(String sid,
 PairingTestListener listener)
                        throws PairingException

Specified by:

testService in interface PairingManager

Throws:

PairingException

updateSRPState

protected void updateSRPState()

setSRPPassword

public void setSRPPassword(char[] password)

Specified by:

setSRPPassword in interface PairingManager

handleLocalTunnel

public boolean handleLocalTunnel(TrackerWebPageRequest request,
 TrackerWebPageResponse response)
                          throws IOException

Specified by:

handleLocalTunnel in interface PairingManager

Throws:

IOException

recordRequest

public void recordRequest(String name,
 String ip,
 boolean good)

Specified by:

recordRequest in interface PairingManager

fireChanged

protected void fireChanged()

addListener

public void addListener(PairingManagerListener l)

Specified by:

addListener in interface PairingManager

removeListener

public void removeListener(PairingManagerListener l)

Specified by:

removeListener in interface PairingManager

getString

protected String getString(Map<String,Object> map,
 String name)
                    throws IOException

Throws:

IOException

generate

public void generate(IndentWriter writer)

Specified by:

generate in interface AEDiagnosticsEvidenceGenerator