Class SpeedLimitHandler

java.lang.Object

com.biglybt.core.speedmanager.SpeedLimitHandler

All Implemented Interfaces:

LongTermStatsListener

public class SpeedLimitHandler
extends Object
implements LongTermStatsListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	SpeedLimitHandler.DML
private static class	SpeedLimitHandler.IPSetTagType
private class	SpeedLimitHandler.LimitDetails
(package private) class	SpeedLimitHandler.NetLimit
class	SpeedLimitHandler.PeerSet
private class	SpeedLimitHandler.Prioritiser
private static class	SpeedLimitHandler.ScheduleRule
private class	SpeedLimitHandler.ScheduleRuleExtensions
private class	SpeedLimitHandler.StorageDetails

Field Summary

Fields

Modifier and Type	Field	Description
private SpeedLimitHandler.ScheduleRule	active_rule
private static final int	AS_ACTIVE
private static final int	AS_INACTIVE
private static final int	AS_UNKOWN
private final FrequencyLimitedDispatcher	auto_peer_set_checker
private final List<String>	auto_peer_set_queue_client
private final List<String>	auto_peer_set_queue_intf
private BuddyPlugin	buddy_plugin
(package private) final TorrentAttribute	category_attribute
private final FrequencyLimitedDispatcher	check_ip_sets_limiter
(package private) final Core	core
private SpeedLimitHandler.DML	current_dml
private Map<String, SpeedLimitHandler.PeerSet>	current_ip_sets
private List<SpeedLimitHandler.Prioritiser>	current_prioritisers
private List<SpeedLimitHandler.ScheduleRule>	current_rules
private List<SpeedLimitHandler.StorageDetails>	current_storage_details
private final Object	extensions_lock
private final AsyncDispatcher	gm_dispatcher
private static final String	INACTIVE_PROFILE_NAME
private static final IpFilter	ip_filter
private TimerEventPeriodic	ip_set_event
private static final Object	ip_set_peer_key
private final Map<String, RateLimiter>	ip_set_rate_limiters_down
private final Map<String, RateLimiter>	ip_set_rate_limiters_up
private final SpeedLimitHandler.IPSetTagType	ip_set_tag_type
private boolean	is_enabled
private final LoggerChannel	logger
private static final String	NET_IPV4
private static final String	NET_IPV6
private static final String	NET_LAN
private boolean	net_limit_listener_added
private boolean	net_limit_pause_all_active
private List<SpeedLimitHandler.NetLimit>	net_limits_all
private Map<Integer, List<SpeedLimitHandler.NetLimit>>	net_limits_by_type
private static final String	NET_WAN
private static final int	NETLIMIT_TAG_LOG_PERIOD
private static final int	NETLIMIT_TAG_LOG_TICKS
private boolean	pause_forced_downloads
private static final Object	PEER_ASN_WAIT_START_KEY
private static final Object	PEER_LT_WAIT_START_KEY
(package private) final PluginInterface	plugin_interface
private final List<String>	predefined_profile_names
private boolean	preserve_inactive_limits
private static final int	PRIORITISER_CHECK_PERIOD_BASE
private boolean	prioritiser_enabled
private TimerEventPeriodic	prioritiser_event
private static final Object	RL_TO_BE_REMOVED_LOCK
private static final Object	RLD_TO_BE_REMOVED_KEY
private static final Object	RLU_TO_BE_REMOVED_KEY
private boolean	rule_pause_all_active
private TimerEventPeriodic	schedule_event
private static final int	SCHEDULER_PERIOD
private static SpeedLimitHandler	singleton
private static final int	STORAGE_CHECK_PERIOD
private TimerEventPeriodic	storage_event

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SpeedLimitHandler(Core _core)

Method Summary

Modifier and Type	Method	Description
void	addConfigLine(String line, boolean auto_enable)
void	addDownloadsToProfile(String name, List<byte[]> hashes)
private void	addLimiters(PeerManager peer_manager, Peer peer, SpeedLimitHandler.PeerSet set, List<RateLimiter> up_to_be_removed, List<RateLimiter> down_to_be_removed)
private void	addRemoveDownloadsToProfile(String name, List<byte[]> hashes, boolean add)
private boolean	canPauseAll()
private void	checkIPSets()
private void	checkIPSetsSupport()
private void	checkPrioritisers()
private void	checkSchedule(boolean start_of_day, int tick_count)
private void	checkStorage()
private void	checkTagNetLimits(int tick_count)
List<String>	clearCurrentLimits()
void	deleteProfile(String name)
void	dump(IndentWriter iw)
private void	exportBoolean(Map<String,Object> map, String key, boolean b)
private void	exportInt(Map<String,Object> map, String key, int i)
private void	exportLong(Map<String,Object> map, String key, long i)
private void	exportString(Map<String,Object> map, String key, String s)
private String	format(long rate)
private String	format(List<LimitedRateGroup> groups)
private String	formatDown(long rate)
private String	formatDown(List<LimitedRateGroup> groups)
private String	formatUp(long rate)
private String	formatUp(List<LimitedRateGroup> groups)
private SpeedLimitHandler.ScheduleRule	getActiveRule(Date date)
private int	getActiveState()
private BuddyPlugin	getBuddyPlugin()
List<String>	getCurrent()
private long[]	getLongTermUsage(LongTermStats lts, int type, SpeedLimitHandler.NetLimit net_limit_maybe_null)
private int	getMins(String str)
List<SpeedLimitHandler.PeerSet>	getPeerSets()
List<String>	getProfile(String name)
List<String>	getProfileNames()
List<String>	getProfilesForDownload(byte[] hash)
List<String>	getProfileSupport(String name, boolean use_hashes)
List<String>	getSchedule()
static SpeedLimitHandler	getSingleton(Core core)
private String	getString(long[] stats, long[] limits, boolean is_rate)
private String	getString(LongTermStats lts, int type, List<SpeedLimitHandler.NetLimit> net_limits)
boolean	hasAnyProfiles()
private boolean	importBoolean(Map<String,Object> map, String key)
private int	importInt(Map<String,Object> map, String key)
private long	importLong(Map<String,Object> map, String key)
private String	importString(Map<String,Object> map, String key)
private void	initialiseIPSets(Map<String, SpeedLimitHandler.PeerSet> sets)
boolean	isEnabled()
private Map	loadConfig()
private void	loadPauseAllActive()
List<String>	loadProfile(String name)
private List<String>	loadSchedule(boolean start_of_day)
private long	parseRate(String str)
private void	peerRemoved(Download download, PeerManager peer_manager, Peer peer)
private void	peersAdded(Download download, PeerManager peer_manager, Peer[] peers)
private boolean	profileExists(String name)
void	removeDownloadsFromProfile(String name, List<byte[]> hashes)
private List<String>	resetRules()
private void	saveConfig(Map map)
List<String>	saveProfile(String name)
private void	setActiveState(int state)
private void	setNetLimitPauseAllActive(boolean active)
private void	setProfileActive(String profile_name)
private void	setRulePauseAllActive(boolean active)
List<String>	setSchedule(List<String> lines)
private List<LimitedRateGroup>	trim(LimitedRateGroup[] groups)
void	updated(LongTermStats stats)

Methods inherited from class Object

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

Field Details

singleton

private static SpeedLimitHandler singleton

RL_TO_BE_REMOVED_LOCK

private static final Object RL_TO_BE_REMOVED_LOCK

RLD_TO_BE_REMOVED_KEY

private static final Object RLD_TO_BE_REMOVED_KEY

RLU_TO_BE_REMOVED_KEY

private static final Object RLU_TO_BE_REMOVED_KEY

PEER_LT_WAIT_START_KEY

private static final Object PEER_LT_WAIT_START_KEY

PEER_ASN_WAIT_START_KEY

private static final Object PEER_ASN_WAIT_START_KEY

ip_filter

private static final IpFilter ip_filter

SCHEDULER_PERIOD

private static final int SCHEDULER_PERIOD

See Also:

• Constant Field Values

NETLIMIT_TAG_LOG_PERIOD

private static final int NETLIMIT_TAG_LOG_PERIOD

See Also:

• Constant Field Values

NETLIMIT_TAG_LOG_TICKS

private static final int NETLIMIT_TAG_LOG_TICKS

See Also:

• Constant Field Values

PRIORITISER_CHECK_PERIOD_BASE

private static final int PRIORITISER_CHECK_PERIOD_BASE

See Also:

• Constant Field Values

STORAGE_CHECK_PERIOD

private static final int STORAGE_CHECK_PERIOD

See Also:

• Constant Field Values

NET_IPV4

private static final String NET_IPV4

See Also:

• Constant Field Values

NET_IPV6

private static final String NET_IPV6

See Also:

• Constant Field Values

NET_LAN

private static final String NET_LAN

See Also:

• Constant Field Values

NET_WAN

private static final String NET_WAN

See Also:

• Constant Field Values

AS_UNKOWN

private static final int AS_UNKOWN

See Also:

• Constant Field Values

AS_INACTIVE

private static final int AS_INACTIVE

See Also:

• Constant Field Values

AS_ACTIVE

private static final int AS_ACTIVE

See Also:

• Constant Field Values

core

final Core core

plugin_interface

final PluginInterface plugin_interface

category_attribute

final TorrentAttribute category_attribute

logger

private final LoggerChannel logger

is_enabled

private boolean is_enabled

schedule_event

private TimerEventPeriodic schedule_event

current_rules

private List<SpeedLimitHandler.ScheduleRule> current_rules

active_rule

private SpeedLimitHandler.ScheduleRule active_rule

preserve_inactive_limits

private boolean preserve_inactive_limits

pause_forced_downloads

private boolean pause_forced_downloads

prioritiser_enabled

private boolean prioritiser_enabled

prioritiser_event

private TimerEventPeriodic prioritiser_event

current_prioritisers

private List<SpeedLimitHandler.Prioritiser> current_prioritisers

storage_event

private TimerEventPeriodic storage_event

current_storage_details

private List<SpeedLimitHandler.StorageDetails> current_storage_details

current_ip_sets

private Map<String, SpeedLimitHandler.PeerSet> current_ip_sets

ip_set_rate_limiters_up

private final Map<String, RateLimiter> ip_set_rate_limiters_up

ip_set_rate_limiters_down

private final Map<String, RateLimiter> ip_set_rate_limiters_down

ip_set_event

private TimerEventPeriodic ip_set_event

net_limit_listener_added

private boolean net_limit_listener_added

net_limits_by_type

private Map<Integer, List<SpeedLimitHandler.NetLimit>> net_limits_by_type

net_limits_all

private List<SpeedLimitHandler.NetLimit> net_limits_all

INACTIVE_PROFILE_NAME

private static final String INACTIVE_PROFILE_NAME

See Also:

• Constant Field Values

predefined_profile_names

private final List<String> predefined_profile_names

rule_pause_all_active

private boolean rule_pause_all_active

net_limit_pause_all_active

private boolean net_limit_pause_all_active

ip_set_tag_type

private final SpeedLimitHandler.IPSetTagType ip_set_tag_type

extensions_lock

private final Object extensions_lock

auto_peer_set_queue_client

private final List<String> auto_peer_set_queue_client

auto_peer_set_queue_intf

private final List<String> auto_peer_set_queue_intf

buddy_plugin

private volatile BuddyPlugin buddy_plugin

gm_dispatcher

private final AsyncDispatcher gm_dispatcher

current_dml

private SpeedLimitHandler.DML current_dml

ip_set_peer_key

private static final Object ip_set_peer_key

check_ip_sets_limiter

private final FrequencyLimitedDispatcher check_ip_sets_limiter

auto_peer_set_checker

private final FrequencyLimitedDispatcher auto_peer_set_checker

Constructor Details

SpeedLimitHandler

private SpeedLimitHandler(Core _core)

Method Details

getSingleton

public static SpeedLimitHandler getSingleton(Core core)

getActiveState

private int getActiveState()

setActiveState

private void setActiveState(int state)

hasAnyProfiles

public boolean hasAnyProfiles()

loadConfig

private Map loadConfig()

saveConfig

private void saveConfig(Map map)

loadPauseAllActive

private void loadPauseAllActive()

getBuddyPlugin

private BuddyPlugin getBuddyPlugin()

setRulePauseAllActive

private void setRulePauseAllActive(boolean active)

setNetLimitPauseAllActive

private void setNetLimitPauseAllActive(boolean active)

clearCurrentLimits

public List<String> clearCurrentLimits()

resetRules

private List<String> resetRules()

getCurrent

public List<String> getCurrent()

getString

private String getString(LongTermStats lts,
 int type,
 List<SpeedLimitHandler.NetLimit> net_limits)

getLongTermUsage

private long[] getLongTermUsage(LongTermStats lts,
 int type,
 SpeedLimitHandler.NetLimit net_limit_maybe_null)

getString

private String getString(long[] stats,
 long[] limits,
 boolean is_rate)

getProfileNames

public List<String> getProfileNames()

loadProfile

public List<String> loadProfile(String name)

profileExists

private boolean profileExists(String name)

getProfile

public List<String> getProfile(String name)

getProfileSupport

public List<String> getProfileSupport(String name,
 boolean use_hashes)

getProfilesForDownload

public List<String> getProfilesForDownload(byte[] hash)

addRemoveDownloadsToProfile

private void addRemoveDownloadsToProfile(String name,
 List<byte[]> hashes,
 boolean add)

addDownloadsToProfile

public void addDownloadsToProfile(String name,
 List<byte[]> hashes)

removeDownloadsFromProfile

public void removeDownloadsFromProfile(String name,
 List<byte[]> hashes)

deleteProfile

public void deleteProfile(String name)

saveProfile

public List<String> saveProfile(String name)

loadSchedule

private List<String> loadSchedule(boolean start_of_day)

parseRate

private long parseRate(String str)

isEnabled

public boolean isEnabled()

addConfigLine

public void addConfigLine(String line,
 boolean auto_enable)

getPeerSets

public List<SpeedLimitHandler.PeerSet> getPeerSets()

getMins

private int getMins(String str)

checkIPSets

private void checkIPSets()

initialiseIPSets

private void initialiseIPSets(Map<String, SpeedLimitHandler.PeerSet> sets)

checkIPSetsSupport

private void checkIPSetsSupport()

peersAdded

private void peersAdded(Download download,
 PeerManager peer_manager,
 Peer[] peers)

peerRemoved

private void peerRemoved(Download download,
 PeerManager peer_manager,
 Peer peer)

addLimiters

private void addLimiters(PeerManager peer_manager,
 Peer peer,
 SpeedLimitHandler.PeerSet set,
 List<RateLimiter> up_to_be_removed,
 List<RateLimiter> down_to_be_removed)

checkPrioritisers

private void checkPrioritisers()

checkStorage

private void checkStorage()

getActiveRule

private SpeedLimitHandler.ScheduleRule getActiveRule(Date date)

setProfileActive

private void setProfileActive(String profile_name)

checkSchedule

private void checkSchedule(boolean start_of_day,
 int tick_count)

getSchedule

public List<String> getSchedule()

setSchedule

public List<String> setSchedule(List<String> lines)

trim

private List<LimitedRateGroup> trim(LimitedRateGroup[] groups)

updated

public void updated(LongTermStats stats)

Specified by:

updated in interface LongTermStatsListener

canPauseAll

private boolean canPauseAll()

checkTagNetLimits

private void checkTagNetLimits(int tick_count)

formatUp

private String formatUp(long rate)

formatDown

private String formatDown(long rate)

format

private String format(long rate)

formatUp

private String formatUp(List<LimitedRateGroup> groups)

formatDown

private String formatDown(List<LimitedRateGroup> groups)

format

private String format(List<LimitedRateGroup> groups)

exportBoolean

private void exportBoolean(Map<String,Object> map,
 String key,
 boolean b)

importBoolean

private boolean importBoolean(Map<String,Object> map,
 String key)

exportInt

private void exportInt(Map<String,Object> map,
 String key,
 int i)

importInt

private int importInt(Map<String,Object> map,
 String key)

exportLong

private void exportLong(Map<String,Object> map,
 String key,
 long i)

importLong

private long importLong(Map<String,Object> map,
 String key)

exportString

private void exportString(Map<String,Object> map,
 String key,
 String s)

importString

private String importString(Map<String,Object> map,
 String key)

dump

public void dump(IndentWriter iw)