Class SpeedManagerImpl

java.lang.Object

com.biglybt.core.speedmanager.impl.SpeedManagerImpl

All Implemented Interfaces:

SpeedManagerAlgorithmProviderAdapter, SpeedManager, AEDiagnosticsEvidenceGenerator

public class SpeedManagerImpl
extends Object
implements SpeedManager, SpeedManagerAlgorithmProviderAdapter, AEDiagnosticsEvidenceGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	SpeedManagerImpl.nullProvider
protected static class	SpeedManagerImpl.pingContact

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final SpeedManagerAdapter	adapter
private String	asn
private static final int	AUTO_ADJUST_PERIOD_SECS
private static final int	AUTO_ADJUST_PERIOD_TICKS
private static final String	CONFIG_AVAIL
private static final String	CONFIG_DEBUG
private static final String[]	CONFIG_PARAMS
static final String	CONFIG_VERSION
static final String	CONFIG_VERSION_STR
private static final int	CONTACT_NUMBER
private static final int	CONTACT_PING_SECS
(package private) final Map	contacts
private SpeedManagerImpl.pingContact[]	contacts_array
(package private) final Core	core
private static boolean	DEBUG
(package private) final AsyncDispatcher	dispatcher
private static boolean	emulated_ping_source
private boolean	enabled
private final CopyOnWriteList	listeners
private final AEDiagnosticsLogger	logger
private static final int	LONG_PERIOD_SECS
private static final int	LONG_PERIOD_TICKS
(package private) static final int	MEDIUM_ESTIMATE_SAMPLES
private static final int	MEDIUM_ESTIMATE_SECS
private Object	original_limits
(package private) final SpeedManagerPingMapperImpl	ping_mapper
(package private) final SpeedManagerPingMapperImpl[]	ping_mappers
private static final boolean	pm_enabled
private SpeedManagerAlgorithmProvider	provider
private int	provider_version
private static final int	SAVE_PERIOD_SECS
private static final int	SAVE_PERIOD_TICKS
(package private) static final int	SHORT_ESTIMATE_SAMPLES
private static final int	SHORT_ESTIMATE_SECS
private static final int	SPEED_AVERAGE_PERIOD
private DHTSpeedTester	speed_tester
private int	total_contacts
private final CopyOnWriteList	transient_mappers
protected static final int	UPDATE_PERIOD_MILLIS

Constructor Summary

Constructors

Constructor	Description
SpeedManagerImpl(Core _core, SpeedManagerAdapter _adapter)

Method Summary

Modifier and Type	Method	Description
void	addListener(SpeedManagerListener l)
protected void	addPingHistory(int rtt, boolean re_base)
private void	autoAdjust()
SpeedManagerPingMapper	createTransientPingMapper()	Creates a mapper starting from current time.
protected void	destroy(SpeedManagerPingMapper mapper)
protected void	enableOrAlgChanged()
void	generate(IndentWriter writer)
SpeedManagerPingMapper	getActiveMapper()
String	getASN()
long	getCurrentChokeSpeed()	Returns the current view of when choking occurs
long	getCurrentDataDownloadSpeed()
long	getCurrentDataUploadSpeed()
long	getCurrentDownloadLimit()
int	getCurrentPingMillis()
long	getCurrentProtocolDownloadSpeed()
long	getCurrentProtocolUploadSpeed()
long	getCurrentUploadLimit()
SpeedManagerLimitEstimate	getEstimatedDownloadCapacityBytesPerSec()
SpeedManagerLimitEstimate	getEstimatedUploadCapacityBytesPerSec()
int	getIdlePingMillis()
SpeedManagerPingMapper[]	getMappers()
int	getMaxPingMillis()
long	getMaxUploadSpeed()
SpeedManagerPingMapper	getPingMapper()
SpeedManagerPingSource[]	getPingSources()
SpeedManager	getSpeedManager()
DHTSpeedTester	getSpeedTester()
protected void	informDownCapChanged()
protected void	informListeners(int type)
protected void	informUpCapChanged()
boolean	isAvailable()
boolean	isEnabled()
void	log(String str)
void	removeListener(SpeedManagerListener l)
void	reset()
void	setCurrentDownloadLimit(long bytes_per_second)
void	setCurrentUploadLimit(long bytes_per_second)
void	setEnabled(boolean _enabled)
protected void	setEnabledSupport(boolean _enabled)
void	setEstimatedDownloadCapacityBytesPerSec(long bytes_per_sec, float metric)
void	setEstimatedUploadCapacityBytesPerSec(long bytes_per_sec, float metric)
void	setLoggingEnabled(boolean enabled)
void	setSpeedTester(DHTSpeedTester _tester)

Methods inherited from class Object

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

Field Details

UPDATE_PERIOD_MILLIS

protected static final int UPDATE_PERIOD_MILLIS

See Also:

• Constant Field Values

CONTACT_NUMBER

private static final int CONTACT_NUMBER

See Also:

• Constant Field Values

CONTACT_PING_SECS

private static final int CONTACT_PING_SECS

See Also:

• Constant Field Values

LONG_PERIOD_SECS

private static final int LONG_PERIOD_SECS

See Also:

• Constant Field Values

LONG_PERIOD_TICKS

private static final int LONG_PERIOD_TICKS

See Also:

• Constant Field Values

SHORT_ESTIMATE_SECS

private static final int SHORT_ESTIMATE_SECS

See Also:

• Constant Field Values

MEDIUM_ESTIMATE_SECS

private static final int MEDIUM_ESTIMATE_SECS

See Also:

• Constant Field Values

SHORT_ESTIMATE_SAMPLES

static final int SHORT_ESTIMATE_SAMPLES

See Also:

• Constant Field Values

MEDIUM_ESTIMATE_SAMPLES

static final int MEDIUM_ESTIMATE_SAMPLES

See Also:

• Constant Field Values

SAVE_PERIOD_SECS

private static final int SAVE_PERIOD_SECS

See Also:

• Constant Field Values

SAVE_PERIOD_TICKS

private static final int SAVE_PERIOD_TICKS

See Also:

• Constant Field Values

AUTO_ADJUST_PERIOD_SECS

private static final int AUTO_ADJUST_PERIOD_SECS

See Also:

• Constant Field Values

AUTO_ADJUST_PERIOD_TICKS

private static final int AUTO_ADJUST_PERIOD_TICKS

See Also:

• Constant Field Values

SPEED_AVERAGE_PERIOD

private static final int SPEED_AVERAGE_PERIOD

See Also:

• Constant Field Values

DEBUG

private static boolean DEBUG

CONFIG_VERSION_STR

public static final String CONFIG_VERSION_STR

See Also:

• Constant Field Values

CONFIG_VERSION

public static final String CONFIG_VERSION

See Also:

• Constant Field Values

CONFIG_AVAIL

private static final String CONFIG_AVAIL

See Also:

• Constant Field Values

CONFIG_DEBUG

private static final String CONFIG_DEBUG

See Also:

• Constant Field Values

CONFIG_PARAMS

private static final String[] CONFIG_PARAMS

emulated_ping_source

private static boolean emulated_ping_source

core

final Core core

speed_tester

private DHTSpeedTester speed_tester

adapter

final SpeedManagerAdapter adapter

provider

private SpeedManagerAlgorithmProvider provider

provider_version

private int provider_version

enabled

private boolean enabled

pm_enabled

private static final boolean pm_enabled

See Also:

• Constant Field Values

contacts

final Map contacts

total_contacts

private volatile int total_contacts

contacts_array

private SpeedManagerImpl.pingContact[] contacts_array

original_limits

private Object original_limits

dispatcher

final AsyncDispatcher dispatcher

ping_mapper

final SpeedManagerPingMapperImpl ping_mapper

ping_mappers

final SpeedManagerPingMapperImpl[] ping_mappers

transient_mappers

private final CopyOnWriteList transient_mappers

logger

private final AEDiagnosticsLogger logger

asn

private String asn

listeners

private final CopyOnWriteList listeners

Constructor Details

SpeedManagerImpl

public SpeedManagerImpl(Core _core,
 SpeedManagerAdapter _adapter)

Method Details

getSpeedManager

public SpeedManager getSpeedManager()

Specified by:

getSpeedManager in interface SpeedManagerAlgorithmProviderAdapter

getASN

public String getASN()

Specified by:

getASN in interface SpeedManager

getEstimatedUploadCapacityBytesPerSec

public SpeedManagerLimitEstimate getEstimatedUploadCapacityBytesPerSec()

Specified by:

getEstimatedUploadCapacityBytesPerSec in interface SpeedManager

setEstimatedUploadCapacityBytesPerSec

public void setEstimatedUploadCapacityBytesPerSec(long bytes_per_sec,
 float metric)

Specified by:

setEstimatedUploadCapacityBytesPerSec in interface SpeedManager

Parameters:

bytes_per_sec -

getEstimatedDownloadCapacityBytesPerSec

public SpeedManagerLimitEstimate getEstimatedDownloadCapacityBytesPerSec()

Specified by:

getEstimatedDownloadCapacityBytesPerSec in interface SpeedManager

setEstimatedDownloadCapacityBytesPerSec

public void setEstimatedDownloadCapacityBytesPerSec(long bytes_per_sec,
 float metric)

Specified by:

setEstimatedDownloadCapacityBytesPerSec in interface SpeedManager

reset

public void reset()

Specified by:

reset in interface SpeedManager

enableOrAlgChanged

protected void enableOrAlgChanged()

createTransientPingMapper

public SpeedManagerPingMapper createTransientPingMapper()

Description copied from interface: SpeedManagerAlgorithmProviderAdapter

Creates a mapper starting from current time. Must be destroyed by calling "destroy" when done with

Specified by:

createTransientPingMapper in interface SpeedManagerAlgorithmProviderAdapter

Returns:

destroy

protected void destroy(SpeedManagerPingMapper mapper)

setSpeedTester

public void setSpeedTester(DHTSpeedTester _tester)

Specified by:

setSpeedTester in interface SpeedManager

addPingHistory

protected void addPingHistory(int rtt,
 boolean re_base)

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface SpeedManager

setEnabled

public void setEnabled(boolean _enabled)

Specified by:

setEnabled in interface SpeedManager

setEnabledSupport

protected void setEnabledSupport(boolean _enabled)

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface SpeedManager

getSpeedTester

public DHTSpeedTester getSpeedTester()

Specified by:

getSpeedTester in interface SpeedManager

getPingSources

public SpeedManagerPingSource[] getPingSources()

Specified by:

getPingSources in interface SpeedManager

getActiveMapper

public SpeedManagerPingMapper getActiveMapper()

Specified by:

getActiveMapper in interface SpeedManager

getPingMapper

public SpeedManagerPingMapper getPingMapper()

Specified by:

getPingMapper in interface SpeedManagerAlgorithmProviderAdapter

getMappers

public SpeedManagerPingMapper[] getMappers()

Specified by:

getMappers in interface SpeedManager

getIdlePingMillis

public int getIdlePingMillis()

getCurrentPingMillis

public int getCurrentPingMillis()

getMaxPingMillis

public int getMaxPingMillis()

getCurrentChokeSpeed

public long getCurrentChokeSpeed()

Returns the current view of when choking occurs

Returns:

speed in bytes/sec

getMaxUploadSpeed

public long getMaxUploadSpeed()

getCurrentUploadLimit

public long getCurrentUploadLimit()

Specified by:

getCurrentUploadLimit in interface SpeedManagerAlgorithmProviderAdapter

setCurrentUploadLimit

public void setCurrentUploadLimit(long bytes_per_second)

Specified by:

setCurrentUploadLimit in interface SpeedManagerAlgorithmProviderAdapter

getCurrentDownloadLimit

public long getCurrentDownloadLimit()

Specified by:

getCurrentDownloadLimit in interface SpeedManagerAlgorithmProviderAdapter

setCurrentDownloadLimit

public void setCurrentDownloadLimit(long bytes_per_second)

Specified by:

setCurrentDownloadLimit in interface SpeedManagerAlgorithmProviderAdapter

getCurrentProtocolUploadSpeed

public long getCurrentProtocolUploadSpeed()

Specified by:

getCurrentProtocolUploadSpeed in interface SpeedManagerAlgorithmProviderAdapter

getCurrentDataUploadSpeed

public long getCurrentDataUploadSpeed()

Specified by:

getCurrentDataUploadSpeed in interface SpeedManagerAlgorithmProviderAdapter

getCurrentDataDownloadSpeed

public long getCurrentDataDownloadSpeed()

Specified by:

getCurrentDataDownloadSpeed in interface SpeedManagerAlgorithmProviderAdapter

getCurrentProtocolDownloadSpeed

public long getCurrentProtocolDownloadSpeed()

Specified by:

getCurrentProtocolDownloadSpeed in interface SpeedManagerAlgorithmProviderAdapter

autoAdjust

private void autoAdjust()

setLoggingEnabled

public void setLoggingEnabled(boolean enabled)

log

public void log(String str)

Specified by:

log in interface SpeedManagerAlgorithmProviderAdapter

informDownCapChanged

protected void informDownCapChanged()

informUpCapChanged

protected void informUpCapChanged()

informListeners

protected void informListeners(int type)

addListener

public void addListener(SpeedManagerListener l)

Specified by:

addListener in interface SpeedManager

removeListener

public void removeListener(SpeedManagerListener l)

Specified by:

removeListener in interface SpeedManager

generate

public void generate(IndentWriter writer)

Specified by:

generate in interface AEDiagnosticsEvidenceGenerator