Class GlobalManagerImpl

java.lang.Object

com.biglybt.core.download.impl.DownloadManagerAdapter

com.biglybt.core.global.impl.GlobalManagerImpl

All Implemented Interfaces:

CoreComponent, DownloadManagerListener, GlobalManager, TaggableResolver, AEDiagnosticsEvidenceGenerator, DataSourceResolver.DataSourceImporter

public class GlobalManagerImpl
extends DownloadManagerAdapter
implements GlobalManager, AEDiagnosticsEvidenceGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	GlobalManagerImpl.Checker
private class	GlobalManagerImpl.DownloadStateTagger
private static class	GlobalManagerImpl.PauseState

Nested classes/interfaces inherited from interface TaggableResolver

TaggableResolver.LifecycleControlListener

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final Object	ACTIVE_KEY
private final AllTrackersManager.AllTrackers	all_trackers
private long	all_trackers_options_mut
private boolean	auto_resume_disabled
private boolean	auto_resume_on_start
private TimerEvent	auto_resume_timer
private final FrequencyLimitedDispatcher	check_seeding_only_state_dispatcher
private final GlobalManagerImpl.Checker	checker
private Object	create_dm_lock
private final boolean	cripple_downloads_config
private boolean	destroyed
(package private) static boolean	disable_never_started_scrapes
private final CopyOnWriteList<DownloadManagerInitialisationAdapter>	dm_adapters
private Object	download_history_manager
private GlobalManagerImpl.DownloadStateTagger	ds_tagger
(package private) static boolean	enable_stopped_scrapes
private final GlobalManagerFileMerger	file_merger
private boolean	force_start_non_seed_exists
private GlobalManagerHostSupport	host_support
private boolean	isStopping
private long	last_swarm_stats
private long	last_swarm_stats_calc_time
private long	lastListenerUpdate
private Map<TaggableResolver.LifecycleControlListener, GlobalManagerDownloadWillBeRemovedListener>	lcl_map
private static final int	LDT_DESTROY_INITIATED
private static final int	LDT_DESTROYED
private static final int	LDT_EVENT
private static final int	LDT_MANAGER_ADDED
private static final int	LDT_MANAGER_REMOVED
private static final int	LDT_MANAGER_WBR
private static final int	LDT_SEEDING_ONLY
private final ListenerManager<Object>	listeners_and_event_listeners
(package private) boolean	loadingComplete	Whether loading of existing torrents is done
(package private) final AESemaphore	loadingSem	Monitor to block adding torrents while loading existing torrent list
(package private) DelayedEvent	loadTorrentsDelay	delay loading of torrents
(package private) static final LogIDs	LOGID
(package private) final Map<HashWrapper, DownloadManager>	manager_hash_map
(package private) final Map<DownloadManager, DownloadManager>	manager_id_set
private DownloadManager[]	managers_list_cow
private Object	managers_lock
(package private) static int	missing_file_dl_restart_check_period_millis
(package private) static final Object	missing_file_dl_restart_key
private static final Object	MOVE_POS_KEY
private String	nat_info
private String	nat_info_prefix
private int	nat_status
private long	nat_status_last_good
private boolean	nat_status_probably_ok
(package private) long	needsSavingCozStateChanged
private int	next_seed_piece_recheck_index
(package private) static long	no_space_dl_pause_min_bytes
(package private) static int	no_space_dl_restart_check_period_millis
private final Map<HashWrapper, GlobalManagerImpl.PauseState>	paused_state
private final Map<HashWrapper, GlobalManagerImpl.PauseState>	paused_state_initial
private final AEMonitor	paused_state_mon
private boolean	potentially_seeding_only_mode
private final GlobalMangerProgressListener	progress_listener
private MainlineDHTProvider	provider
private final ListenerManager<GlobalManagerDownloadWillBeRemovedListener>	removal_listeners
private final Map<HashWrapper, Map>	saved_download_manager_state
private boolean	seeding_only_mode
private final GlobalManagerStatsImpl	stats
private GlobalManagerStatsWriter	stats_writer
private final TaggableLifecycleHandler	taggable_life_manager
private final TorrentFolderWatcher	torrent_folder_watcher
private final TRTrackerScraper	trackerScraper

Fields inherited from interface GlobalManager

PS_ANY, PS_GENERAL, PS_SPEED_LIMIT_HANDLER

Constructor Summary

Constructors

Constructor	Description
GlobalManagerImpl(Core core, GlobalMangerProgressListener listener)

Method Summary

Modifier and Type	Method	Description
protected DownloadManager	addDownloadManager(DownloadManager download_manager, boolean notifyListeners, DownloadManagerInitialisationAdapter adapter, boolean for_seeding, boolean[] is_existing, boolean initial_load)
DownloadManager	addDownloadManager(String fileName, byte[] optionalHash, String savePath, int initialState, boolean persistent)	Create and add a Download Manager to the global list
DownloadManager	addDownloadManager(String torrent_file_name, byte[] optionalHash, String savePath, int initialState, boolean persistent, boolean for_seeding, DownloadManagerInitialisationAdapter _adapter)	Create and add a Download Manager to the global list
DownloadManager	addDownloadManager(String torrent_file_name, byte[] optionalHash, String savePath, String saveFile, int initialState, boolean persistent, boolean for_seeding, DownloadManagerInitialisationAdapter _adapter)	Create and add a Download Manager to the global list
DownloadManager	addDownloadManager(String fileName, String savePath)	Create and add a Download Manager to the global list
void	addDownloadManagerInitialisationAdapter(DownloadManagerInitialisationAdapter adapter)	Any adapters added will get a chance to see/set the initial state of downloads as they are added
void	addDownloadWillBeRemovedListener(GlobalManagerDownloadWillBeRemovedListener l)	Add a listener triggered when Download is about to be removed
void	addEventListener(GlobalManagerEventListener listener)
void	addLifecycleControlListener(TaggableResolver.LifecycleControlListener l)
void	addListener(GlobalManagerListener listener)	Add a Global Manager listener and triggers it
void	addListener(GlobalManagerListener listener, boolean trigger)
void	canDownloadManagerBeRemoved(DownloadManager manager, boolean remove_torrent, boolean remove_data)	Determines whether a DownloadManager can be removed
boolean	canPauseDownload(DownloadManager manager)
boolean	canPauseDownloads(boolean pause_force_start)
boolean	canResumeDownloads()	Indicates whether or not there are any paused downloads to resume.
protected void	checkForceStart(boolean known_to_exist)
protected void	checkSeedingOnlyState()
protected void	checkSeedingOnlyStateSupport()
void	clearNonPersistentDownloadState(byte[] hash)
protected void	computeNATStatus()
boolean	contains(DownloadManager manager)
private DownloadManager	createAndAddNewDownloadManager(byte[] torrent_hash, String torrentFileName, String savePath, String saveFile, int initialState, boolean persistent, boolean for_seeding, List file_priorities, DownloadManagerInitialisationAdapter adapter, boolean thisIsMagnet, boolean[] is_existing)
private DownloadManager	createNewDownloadManager(byte[] torrent_hash, String torrentFileName, String savePath, String saveFile, int initialState, boolean persistent, boolean for_seeding, List file_priorities, boolean thisIsMagnet, boolean[] is_existing)
int	downloadManagerCount(boolean bCompleted)	Retrieve the number of download managers the global manager is managing.
static Long[]	enlargeLongArray(Long[] array, int expandTo)
Map	exportDownloadStateToMap(DownloadManager dm)
private Map	exportDownloadStateToMapSupport(DownloadManager dm, boolean internal_export, boolean interim)
void	fireGlobalManagerEvent(int type, DownloadManager dm, Object data)
(package private) void	fixLongFileName(DownloadManager manager)
void	fixUpDownloadManagerPositions()	Verifies the positions of the DownloadManagers, filling in gaps and shifting duplicate IDs down if necessary.
void	generate(IndentWriter writer)
String	getDisplayName(Taggable taggable)
protected DownloadManagerInitialisationAdapter	getDMAdapter(DownloadManagerInitialisationAdapter adapter)
Object	getDownloadHistoryManager()
DownloadManager	getDownloadManager(TOTorrent torrent)	Retrieve the DownloadManager associated with a TOTorrent object
DownloadManager	getDownloadManager(HashWrapper hw)	Retrieve the DownloadManager associated with a hash
List<DownloadManager>	getDownloadManagers()	Retrieve a list of DownloadManagers that GlobalManager is handling
MainlineDHTProvider	getMainlineDHTProvider()
Object[]	getNATStatus()	See plugin ConnectionManager.NAT_ constants for return values
int	getPauseDownloadPeriodRemaining()	seconds remaining, 0 if not active
List<Taggable>	getResolvedTaggables()
long	getResolverTaggableType()
GlobalManagerStats	getStats()	Retrieve the Global Manager Statistics class
String	getSwarmMergingInfo(DownloadManager dm)
long	getTotalSwarmsPeerRate(boolean downloading, boolean seeding)
TRTrackerScraper	getTrackerScraper()	Retrieve the Tracker Scraper management class
Object	importDataSource(Map map)
DownloadManager	importDownloadStateFromMap(Map map)
protected void	informDestroyed()
private void	informDestroyInitiated(GlobalMangerProgressListener progress)
boolean	isMoveableDown(DownloadManager manager)	Retrieve whether a DownloadManager can move down in the GlobalManager list
boolean	isMoveableUp(DownloadManager manager)	Retrieve whether a DownloadManager can move up in the GlobalManager list
boolean	isPaused(DownloadManager manager)	Retrieve whether a DownloadManager is in a paused state
boolean	isPotentiallySeedingOnly()	As for isSeedingOnly but includes queued seeds
boolean	isSeedingOnly()	Determines whether we are only seeding, and not currently downloading anything.
boolean	isStopping()
boolean	isSwarmMerging(DownloadManager dm)
DownloadManager	loadDownload(Map mDownload, int currentDownload, int nbDownloads, GlobalMangerProgressListener progress_listener, boolean debug)
(package private) void	loadDownloads()
static void	main(String[] args)
void	moveDown(DownloadManager manager)	Move one DownloadManager down in the GlobalManager's list
void	moveEnd(DownloadManager[] manager)	Move a list of DownloadManagers to the end of the GlobalManager list
void	moveTo(DownloadManager manager, int newPosition)	Move a Downloadmanager to a new position.
void	moveTo(List<DownloadManager> managers, List<Integer> newPositions)
void	moveTop(DownloadManager[] manager)	Move a list of DownloadManagers to the top of the GlobalManager list
void	moveUp(DownloadManager manager)	Move one DownloadManager up in the GlobalManager's list
boolean	pauseDownload(DownloadManager manager, boolean only_if_active)	Pause one DownloadManager
void	pauseDownloads(boolean pause_force_start, int owner)
void	pauseDownloadsForPeriod(int seconds)	pause any non-paused downloads and auto-resume all downloads after n seconds
private void	pauseDownloadsInternal(boolean tag_only, boolean pause_force_start, int owner)
void	removeDownloadManager(DownloadManager manager)	Removes a DownloadManager from the global list, providing it can be removed (see invalid reference #canDownloadManagerBeRemoved(DownloadManager) )
void	removeDownloadManager(DownloadManager manager, boolean remove_torrent, boolean remove_data)
void	removeDownloadManagerInitialisationAdapter(DownloadManagerInitialisationAdapter adapter)
void	removeDownloadWillBeRemovedListener(GlobalManagerDownloadWillBeRemovedListener l)	Remove a listener triggered when Download is about to be removed
void	removeEventListener(GlobalManagerEventListener listener)
void	removeLifecycleControlListener(TaggableResolver.LifecycleControlListener l)
void	removeListener(GlobalManagerListener listener)	Removes a Global Manager listener
void	requestAttention(String id)
Taggable	resolveTaggable(String id)
void	resumeDownload(DownloadManager manager)	Resume a previously paused DownloadManager
boolean	resumeDownloads(boolean is_auto_resume, int owner)
boolean	resumingDownload(DownloadManager manager)	This reports that a download is being resumed in order to remove it from the paused set Don't use this to actually resume a download, use resumeDownload !
protected void	saveDownloads(boolean interim, GlobalMangerProgressListener listener_maybe_null)
void	saveState()
protected void	seedPieceRecheck()
protected boolean	seedPieceRecheck(DownloadManager manager)
void	setMainlineDHTProvider(MainlineDHTProvider provider)	Calling this method doesn't prepare the client to be DHT-ready, it is only used to store, or remove, a DHT provider - so that it can be globally accessible.
protected void	setSeedingOnlyState(boolean seeding, boolean potentially_seeding)
private List<DownloadManager>	sortForStop()
void	startAllDownloads()	Starts all downloads
void	stateChanged(DownloadManager manager, int new_state)
void	statsRequest(Map request, Map reply)
void	stopAllDownloads()	Stops all downloads without removing them
protected void	stopAllDownloads(boolean for_close, GlobalMangerProgressListener listener)
void	stopGlobalManager(GlobalMangerProgressListener listener)	Puts GlobalManager in a stopped state. Used when closing down the client.
boolean	stopPausedDownload(DownloadManager dm)	Don't use me, use dm.stopPausedDownload()
private void	triggerAddListener(List downloadsToAdd)

Methods inherited from class DownloadManagerAdapter

completionChanged, downloadComplete, filePriorityChanged, positionChanged

Methods inherited from class Object

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

Methods inherited from interface DownloadManagerListener

fileLocationChanged

Methods inherited from interface GlobalManager

canPauseDownloads, pauseDownloads, pauseDownloads, resumeDownloads, resumeDownloads

Field Details

LOGID

static final LogIDs LOGID

LDT_MANAGER_ADDED

private static final int LDT_MANAGER_ADDED

See Also:

• Constant Field Values

LDT_MANAGER_REMOVED

private static final int LDT_MANAGER_REMOVED

See Also:

• Constant Field Values

LDT_DESTROY_INITIATED

private static final int LDT_DESTROY_INITIATED

See Also:

• Constant Field Values

LDT_DESTROYED

private static final int LDT_DESTROYED

See Also:

• Constant Field Values

LDT_SEEDING_ONLY

private static final int LDT_SEEDING_ONLY

See Also:

• Constant Field Values

LDT_EVENT

private static final int LDT_EVENT

See Also:

• Constant Field Values

listeners_and_event_listeners

private final ListenerManager<Object> listeners_and_event_listeners

LDT_MANAGER_WBR

private static final int LDT_MANAGER_WBR

See Also:

• Constant Field Values

removal_listeners

private final ListenerManager<GlobalManagerDownloadWillBeRemovedListener> removal_listeners

enable_stopped_scrapes

static boolean enable_stopped_scrapes

disable_never_started_scrapes

static boolean disable_never_started_scrapes

no_space_dl_restart_check_period_millis

static int no_space_dl_restart_check_period_millis

no_space_dl_pause_min_bytes

static long no_space_dl_pause_min_bytes

missing_file_dl_restart_check_period_millis

static int missing_file_dl_restart_check_period_millis

missing_file_dl_restart_key

static final Object missing_file_dl_restart_key

ACTIVE_KEY

static final Object ACTIVE_KEY

create_dm_lock

private Object create_dm_lock

managers_lock

private Object managers_lock

managers_list_cow

private volatile DownloadManager[] managers_list_cow

manager_hash_map

final Map<HashWrapper, DownloadManager> manager_hash_map

manager_id_set

final Map<DownloadManager, DownloadManager> manager_id_set

progress_listener

private final GlobalMangerProgressListener progress_listener

lastListenerUpdate

private long lastListenerUpdate

checker

private final GlobalManagerImpl.Checker checker

stats

private final GlobalManagerStatsImpl stats

last_swarm_stats_calc_time

private long last_swarm_stats_calc_time

last_swarm_stats

private long last_swarm_stats

cripple_downloads_config

private final boolean cripple_downloads_config

trackerScraper

private final TRTrackerScraper trackerScraper

stats_writer

private GlobalManagerStatsWriter stats_writer

host_support

private GlobalManagerHostSupport host_support

download_history_manager

private Object download_history_manager

saved_download_manager_state

private final Map<HashWrapper, Map> saved_download_manager_state

paused_state_initial

private final Map<HashWrapper, GlobalManagerImpl.PauseState> paused_state_initial

lcl_map

private Map<TaggableResolver.LifecycleControlListener, GlobalManagerDownloadWillBeRemovedListener> lcl_map

next_seed_piece_recheck_index

private int next_seed_piece_recheck_index

torrent_folder_watcher

private final TorrentFolderWatcher torrent_folder_watcher

paused_state

private final Map<HashWrapper, GlobalManagerImpl.PauseState> paused_state

paused_state_mon

private final AEMonitor paused_state_mon

file_merger

private final GlobalManagerFileMerger file_merger

isStopping

private volatile boolean isStopping

destroyed

private volatile boolean destroyed

needsSavingCozStateChanged

volatile long needsSavingCozStateChanged

seeding_only_mode

private boolean seeding_only_mode

potentially_seeding_only_mode

private boolean potentially_seeding_only_mode

all_trackers

private final AllTrackersManager.AllTrackers all_trackers

all_trackers_options_mut

private long all_trackers_options_mut

check_seeding_only_state_dispatcher

private final FrequencyLimitedDispatcher check_seeding_only_state_dispatcher

force_start_non_seed_exists

private boolean force_start_non_seed_exists

nat_status

private int nat_status

nat_info_prefix

private String nat_info_prefix

nat_info

private String nat_info

nat_status_last_good

private long nat_status_last_good

nat_status_probably_ok

private boolean nat_status_probably_ok

dm_adapters

private final CopyOnWriteList<DownloadManagerInitialisationAdapter> dm_adapters

loadTorrentsDelay

DelayedEvent loadTorrentsDelay

delay loading of torrents

loadingComplete

boolean loadingComplete

Whether loading of existing torrents is done

loadingSem

final AESemaphore loadingSem

Monitor to block adding torrents while loading existing torrent list

provider

private MainlineDHTProvider provider

auto_resume_on_start

private boolean auto_resume_on_start

auto_resume_timer

private TimerEvent auto_resume_timer

auto_resume_disabled

private boolean auto_resume_disabled

taggable_life_manager

private final TaggableLifecycleHandler taggable_life_manager

ds_tagger

private GlobalManagerImpl.DownloadStateTagger ds_tagger

MOVE_POS_KEY

private static final Object MOVE_POS_KEY

Constructor Details

GlobalManagerImpl

public GlobalManagerImpl(Core core,
 GlobalMangerProgressListener listener)

Method Details

addDownloadManager

public DownloadManager addDownloadManager(String fileName,
 String savePath)

Description copied from interface: GlobalManager

Create and add a Download Manager to the global list

Specified by:

addDownloadManager in interface GlobalManager

Parameters:

fileName - location and name of torrent file

savePath - path to write the data to

Returns:

The Downloadmanger based on the supplied information.
May return an existing DownloadManager if torrent was already in GlobalManager.

addDownloadManager

public DownloadManager addDownloadManager(String fileName,
 byte[] optionalHash,
 String savePath,
 int initialState,
 boolean persistent)

Description copied from interface: GlobalManager

Create and add a Download Manager to the global list

Specified by:

addDownloadManager in interface GlobalManager

Parameters:

fileName - location and name of torrent file

savePath - path to write the data to

initialState - Initial state of download. See DownloadManager.STATE_*

persistent - Whether the download should be treated as persistent download

Returns:

The Downloadmanger based on the supplied information.
May return an existing DownloadManager if torrent was already in GlobalManager.

addDownloadManager

public DownloadManager addDownloadManager(String torrent_file_name,
 byte[] optionalHash,
 String savePath,
 int initialState,
 boolean persistent,
 boolean for_seeding,
 DownloadManagerInitialisationAdapter _adapter)

Description copied from interface: GlobalManager

Create and add a Download Manager to the global list

Specified by:

addDownloadManager in interface GlobalManager

Parameters:

torrent_file_name - location and name of torrent file

savePath - path to write the data to

initialState - Initial state of download. See DownloadManager.STATE_*

persistent - Whether the download should be treated as persistent download

for_seeding - Whether the manager should assume the torrent is already complete and ready for seeding.

Returns:

The Downloadmanger based on the supplied information.
May return an existing DownloadManager if torrent was already in GlobalManager.

addDownloadManager

public DownloadManager addDownloadManager(String torrent_file_name,
 byte[] optionalHash,
 String savePath,
 String saveFile,
 int initialState,
 boolean persistent,
 boolean for_seeding,
 DownloadManagerInitialisationAdapter _adapter)

Description copied from interface: GlobalManager

Create and add a Download Manager to the global list

Specified by:

addDownloadManager in interface GlobalManager

Parameters:

torrent_file_name - location and name of torrent file

savePath - path to write the data to

initialState - Initial state of download. See DownloadManager.STATE_*

persistent - Whether the download should be treated as persistent download

for_seeding - Whether the manager should assume the torrent is already complete and ready for seeding.

Returns:

true, if the download was added

createAndAddNewDownloadManager

private DownloadManager createAndAddNewDownloadManager(byte[] torrent_hash,
 String torrentFileName,
 String savePath,
 String saveFile,
 int initialState,
 boolean persistent,
 boolean for_seeding,
 List file_priorities,
 DownloadManagerInitialisationAdapter adapter,
 boolean thisIsMagnet,
 boolean[] is_existing)

createNewDownloadManager

private DownloadManager createNewDownloadManager(byte[] torrent_hash,
 String torrentFileName,
 String savePath,
 String saveFile,
 int initialState,
 boolean persistent,
 boolean for_seeding,
 List file_priorities,
 boolean thisIsMagnet,
 boolean[] is_existing)

addDownloadManager

protected DownloadManager addDownloadManager(DownloadManager download_manager,
 boolean notifyListeners,
 DownloadManagerInitialisationAdapter adapter,
 boolean for_seeding,
 boolean[] is_existing,
 boolean initial_load)

clearNonPersistentDownloadState

public void clearNonPersistentDownloadState(byte[] hash)

Specified by:

clearNonPersistentDownloadState in interface GlobalManager

getDownloadManagers

public List<DownloadManager> getDownloadManagers()

Description copied from interface: GlobalManager

Retrieve a list of DownloadManagers that GlobalManager is handling

Specified by:

getDownloadManagers in interface GlobalManager

Returns:

a list of DownloadManagers

getDownloadManager

public DownloadManager getDownloadManager(TOTorrent torrent)

Description copied from interface: GlobalManager

Retrieve the DownloadManager associated with a TOTorrent object

Specified by:

getDownloadManager in interface GlobalManager

Parameters:

torrent - Torrent to search for

Returns:

The DownloadManager associated with the TOTOrrent, or null if none found

getDownloadManager

public DownloadManager getDownloadManager(HashWrapper hw)

Description copied from interface: GlobalManager

Retrieve the DownloadManager associated with a hash

Specified by:

getDownloadManager in interface GlobalManager

Parameters:

hw - Hash to search for

Returns:

The DownloadManager associated with the hash, or null if none found

canDownloadManagerBeRemoved

public void canDownloadManagerBeRemoved(DownloadManager manager,
 boolean remove_torrent,
 boolean remove_data)
                                 throws GlobalManagerDownloadRemovalVetoException

Description copied from interface: GlobalManager

Determines whether a DownloadManager can be removed

Specified by:

canDownloadManagerBeRemoved in interface GlobalManager

Parameters:

manager - DownloadManager to check

Throws:

GlobalManagerDownloadRemovalVetoException

removeDownloadManager

public void removeDownloadManager(DownloadManager manager)
                           throws GlobalManagerDownloadRemovalVetoException

Description copied from interface: GlobalManager

Removes a DownloadManager from the global list, providing it can be removed (see

invalid reference

#canDownloadManagerBeRemoved(DownloadManager)

)

The DownloadManager will not be stopped if it is running. Scraping, however, will be turned off.

Specified by:

removeDownloadManager in interface GlobalManager

Parameters:

manager - DownloadManager to remove

Throws:

GlobalManagerDownloadRemovalVetoException

removeDownloadManager

public void removeDownloadManager(DownloadManager manager,
 boolean remove_torrent,
 boolean remove_data)
                           throws GlobalManagerDownloadRemovalVetoException

Specified by:

removeDownloadManager in interface GlobalManager

Parameters:

manager -

remove_torrent -

remove_data -

Throws:

GlobalManagerDownloadRemovalVetoException

isStopping

public boolean isStopping()

Specified by:

isStopping in interface GlobalManager

stopGlobalManager

public void stopGlobalManager(GlobalMangerProgressListener listener)

Description copied from interface: GlobalManager

Puts GlobalManager in a stopped state.
Used when closing down the client.

Specified by:

stopGlobalManager in interface GlobalManager

stopAllDownloads

public void stopAllDownloads()

Description copied from interface: GlobalManager

Stops all downloads without removing them

Specified by:

stopAllDownloads in interface GlobalManager

stopAllDownloads

protected void stopAllDownloads(boolean for_close,
 GlobalMangerProgressListener listener)

startAllDownloads

public void startAllDownloads()

Starts all downloads

Specified by:

startAllDownloads in interface GlobalManager

pauseDownload

public boolean pauseDownload(DownloadManager manager,
 boolean only_if_active)

Description copied from interface: GlobalManager

Pause one DownloadManager

Specified by:

pauseDownload in interface GlobalManager

Parameters:

manager - DownloadManager to pause

Returns:

False if DownloadManager was invalid, stopped, or pause failed

stopPausedDownload

public boolean stopPausedDownload(DownloadManager dm)

Description copied from interface: GlobalManager

Don't use me, use dm.stopPausedDownload()

Specified by:

stopPausedDownload in interface GlobalManager

Parameters:

dm -

Returns:

pauseDownloadsForPeriod

public void pauseDownloadsForPeriod(int seconds)

Description copied from interface: GlobalManager

pause any non-paused downloads and auto-resume all downloads after n seconds

Specified by:

pauseDownloadsForPeriod in interface GlobalManager

Parameters:

seconds -

getPauseDownloadPeriodRemaining

public int getPauseDownloadPeriodRemaining()

Description copied from interface: GlobalManager

seconds remaining, 0 if not active

Specified by:

getPauseDownloadPeriodRemaining in interface GlobalManager

Returns:

pauseDownloads

public void pauseDownloads(boolean pause_force_start,
 int owner)

Specified by:

pauseDownloads in interface GlobalManager

pauseDownloadsInternal

private void pauseDownloadsInternal(boolean tag_only,
 boolean pause_force_start,
 int owner)

canPauseDownload

public boolean canPauseDownload(DownloadManager manager)

isPaused

public boolean isPaused(DownloadManager manager)

Description copied from interface: GlobalManager

Retrieve whether a DownloadManager is in a paused state

Specified by:

isPaused in interface GlobalManager

Parameters:

manager - DownloadManager to query

Returns:

the pause state

canPauseDownloads

public boolean canPauseDownloads(boolean pause_force_start)

Specified by:

canPauseDownloads in interface GlobalManager

resumeDownload

public void resumeDownload(DownloadManager manager)

Description copied from interface: GlobalManager

Resume a previously paused DownloadManager

Specified by:

resumeDownload in interface GlobalManager

Parameters:

manager - DownloadManager to resume

resumingDownload

public boolean resumingDownload(DownloadManager manager)

Description copied from interface: GlobalManager

This reports that a download is being resumed in order to remove it from the paused set Don't use this to actually resume a download, use resumeDownload !

Specified by:

resumingDownload in interface GlobalManager

Parameters:

manager -

Returns:

true if download was paused AND was force started

resumeDownloads

public boolean resumeDownloads(boolean is_auto_resume,
 int owner)

Specified by:

resumeDownloads in interface GlobalManager

canResumeDownloads

public boolean canResumeDownloads()

Description copied from interface: GlobalManager

Indicates whether or not there are any paused downloads to resume.

Specified by:

canResumeDownloads in interface GlobalManager

Returns:

true if there is at least one download to resume, false if none.

isSwarmMerging

public boolean isSwarmMerging(DownloadManager dm)

Specified by:

isSwarmMerging in interface GlobalManager

getSwarmMergingInfo

public String getSwarmMergingInfo(DownloadManager dm)

Specified by:

getSwarmMergingInfo in interface GlobalManager

sortForStop

private List<DownloadManager> sortForStop()

loadDownloads

void loadDownloads()

triggerAddListener

private void triggerAddListener(List downloadsToAdd)

saveState

public void saveState()

Specified by:

saveState in interface GlobalManager

saveDownloads

protected void saveDownloads(boolean interim,
 GlobalMangerProgressListener listener_maybe_null)

loadDownload

public DownloadManager loadDownload(Map mDownload,
 int currentDownload,
 int nbDownloads,
 GlobalMangerProgressListener progress_listener,
 boolean debug)

enlargeLongArray

public static Long[] enlargeLongArray(Long[] array,
 int expandTo)

exportDownloadStateToMap

public Map exportDownloadStateToMap(DownloadManager dm)

Specified by:

exportDownloadStateToMap in interface GlobalManager

importDownloadStateFromMap

public DownloadManager importDownloadStateFromMap(Map map)

Specified by:

importDownloadStateFromMap in interface GlobalManager

exportDownloadStateToMapSupport

private Map exportDownloadStateToMapSupport(DownloadManager dm,
 boolean internal_export,
 boolean interim)

getTrackerScraper

public TRTrackerScraper getTrackerScraper()

Description copied from interface: GlobalManager

Retrieve the Tracker Scraper management class

Specified by:

getTrackerScraper in interface GlobalManager

Returns:

getStats

public GlobalManagerStats getStats()

Description copied from interface: GlobalManager

Retrieve the Global Manager Statistics class

Specified by:

getStats in interface GlobalManager

Returns:

the Global Manager Statistics class

contains

public boolean contains(DownloadManager manager)

Specified by:

contains in interface GlobalManager

Parameters:

manager -

Returns:

isMoveableUp

public boolean isMoveableUp(DownloadManager manager)

Description copied from interface: GlobalManager

Retrieve whether a DownloadManager can move up in the GlobalManager list

Specified by:

isMoveableUp in interface GlobalManager

Parameters:

manager - DownloadManager to check

Returns:

True - Can move up

downloadManagerCount

public int downloadManagerCount(boolean bCompleted)

Description copied from interface: GlobalManager

Retrieve the number of download managers the global manager is managing.

Specified by:

downloadManagerCount in interface GlobalManager

Parameters:

bCompleted - True: Return count of completed downloads
False: Return count of incomplete downloads

Returns:

count

isMoveableDown

public boolean isMoveableDown(DownloadManager manager)

Description copied from interface: GlobalManager

Retrieve whether a DownloadManager can move down in the GlobalManager list

Specified by:

isMoveableDown in interface GlobalManager

Parameters:

manager - DownloadManager to check

Returns:

True - Can move down

moveUp

public void moveUp(DownloadManager manager)

Description copied from interface: GlobalManager

Move one DownloadManager up in the GlobalManager's list

Specified by:

moveUp in interface GlobalManager

Parameters:

manager - DownloadManager to move up

moveDown

public void moveDown(DownloadManager manager)

Description copied from interface: GlobalManager

Move one DownloadManager down in the GlobalManager's list

Specified by:

moveDown in interface GlobalManager

Parameters:

manager - DownloadManager to move down

moveTop

public void moveTop(DownloadManager[] manager)

Description copied from interface: GlobalManager

Move a list of DownloadManagers to the top of the GlobalManager list

Specified by:

moveTop in interface GlobalManager

Parameters:

manager - array list of DownloadManager objects to move

moveEnd

public void moveEnd(DownloadManager[] manager)

Description copied from interface: GlobalManager

Move a list of DownloadManagers to the end of the GlobalManager list

Specified by:

moveEnd in interface GlobalManager

Parameters:

manager - array list of DownloadManager objects to move

moveTo

public void moveTo(DownloadManager manager,
 int newPosition)

Description copied from interface: GlobalManager

Move a Downloadmanager to a new position.

Specified by:

moveTo in interface GlobalManager

Parameters:

manager - DownloadManager to move

newPosition - position to place

moveTo

public void moveTo(List<DownloadManager> managers,
 List<Integer> newPositions)

Specified by:

moveTo in interface GlobalManager

fixUpDownloadManagerPositions

public void fixUpDownloadManagerPositions()

Description copied from interface: GlobalManager

Verifies the positions of the DownloadManagers, filling in gaps and shifting duplicate IDs down if necessary.

This does not need to be called after MoveXXX, addDownloadManager, or removeDownloadManager functions.

Specified by:

fixUpDownloadManagerPositions in interface GlobalManager

getResolverTaggableType

public long getResolverTaggableType()

Specified by:

getResolverTaggableType in interface TaggableResolver

resolveTaggable

public Taggable resolveTaggable(String id)

Specified by:

resolveTaggable in interface TaggableResolver

getResolvedTaggables

public List<Taggable> getResolvedTaggables()

Specified by:

getResolvedTaggables in interface TaggableResolver

importDataSource

public Object importDataSource(Map map)

Specified by:

importDataSource in interface DataSourceResolver.DataSourceImporter

getDisplayName

public String getDisplayName(Taggable taggable)

Specified by:

getDisplayName in interface TaggableResolver

requestAttention

public void requestAttention(String id)

Specified by:

requestAttention in interface TaggableResolver

addLifecycleControlListener

public void addLifecycleControlListener(TaggableResolver.LifecycleControlListener l)

Specified by:

addLifecycleControlListener in interface TaggableResolver

removeLifecycleControlListener

public void removeLifecycleControlListener(TaggableResolver.LifecycleControlListener l)

Specified by:

removeLifecycleControlListener in interface TaggableResolver

informDestroyed

protected void informDestroyed()

informDestroyInitiated

private void informDestroyInitiated(GlobalMangerProgressListener progress)

addListener

public void addListener(GlobalManagerListener listener)

Description copied from interface: GlobalManager

Add a Global Manager listener and triggers it

Specified by:

addListener in interface GlobalManager

Parameters:

listener - Listener to add

addListener

public void addListener(GlobalManagerListener listener,
 boolean trigger)

Specified by:

addListener in interface GlobalManager

Parameters:

listener -

trigger -

removeListener

public void removeListener(GlobalManagerListener listener)

Description copied from interface: GlobalManager

Removes a Global Manager listener

Specified by:

removeListener in interface GlobalManager

Parameters:

listener - Listener to remove

addEventListener

public void addEventListener(GlobalManagerEventListener listener)

Specified by:

addEventListener in interface GlobalManager

removeEventListener

public void removeEventListener(GlobalManagerEventListener listener)

Specified by:

removeEventListener in interface GlobalManager

fireGlobalManagerEvent

public void fireGlobalManagerEvent(int type,
 DownloadManager dm,
 Object data)

Specified by:

fireGlobalManagerEvent in interface GlobalManager

addDownloadWillBeRemovedListener

public void addDownloadWillBeRemovedListener(GlobalManagerDownloadWillBeRemovedListener l)

Description copied from interface: GlobalManager

Add a listener triggered when Download is about to be removed

Specified by:

addDownloadWillBeRemovedListener in interface GlobalManager

Parameters:

l - Listener to add

removeDownloadWillBeRemovedListener

public void removeDownloadWillBeRemovedListener(GlobalManagerDownloadWillBeRemovedListener l)

Description copied from interface: GlobalManager

Remove a listener triggered when Download is about to be removed

Specified by:

removeDownloadWillBeRemovedListener in interface GlobalManager

Parameters:

l - Listener to remove

stateChanged

public void stateChanged(DownloadManager manager,
 int new_state)

Specified by:

stateChanged in interface DownloadManagerListener

Overrides:

stateChanged in class DownloadManagerAdapter

checkForceStart

protected void checkForceStart(boolean known_to_exist)

checkSeedingOnlyState

protected void checkSeedingOnlyState()

checkSeedingOnlyStateSupport

protected void checkSeedingOnlyStateSupport()

setSeedingOnlyState

protected void setSeedingOnlyState(boolean seeding,
 boolean potentially_seeding)

isSeedingOnly

public boolean isSeedingOnly()

Description copied from interface: GlobalManager

Determines whether we are only seeding, and not currently downloading anything.

Specified by:

isSeedingOnly in interface GlobalManager

Returns:

Seeding Only State

isPotentiallySeedingOnly

public boolean isPotentiallySeedingOnly()

Description copied from interface: GlobalManager

As for isSeedingOnly but includes queued seeds

Specified by:

isPotentiallySeedingOnly in interface GlobalManager

Returns:

getTotalSwarmsPeerRate

public long getTotalSwarmsPeerRate(boolean downloading,
 boolean seeding)

computeNATStatus

protected void computeNATStatus()

getNATStatus

public Object[] getNATStatus()

Description copied from interface: GlobalManager

See plugin ConnectionManager.NAT_ constants for return values

Specified by:

getNATStatus in interface GlobalManager

Returns:

ConnectionManager.NAT_*

seedPieceRecheck

protected void seedPieceRecheck()

seedPieceRecheck

protected boolean seedPieceRecheck(DownloadManager manager)

getDMAdapter

protected DownloadManagerInitialisationAdapter getDMAdapter(DownloadManagerInitialisationAdapter adapter)

fixLongFileName

void fixLongFileName(DownloadManager manager)

addDownloadManagerInitialisationAdapter

public void addDownloadManagerInitialisationAdapter(DownloadManagerInitialisationAdapter adapter)

Description copied from interface: GlobalManager

Any adapters added will get a chance to see/set the initial state of downloads as they are added

Specified by:

addDownloadManagerInitialisationAdapter in interface GlobalManager

Parameters:

adapter -

removeDownloadManagerInitialisationAdapter

public void removeDownloadManagerInitialisationAdapter(DownloadManagerInitialisationAdapter adapter)

Specified by:

removeDownloadManagerInitialisationAdapter in interface GlobalManager

getDownloadHistoryManager

public Object getDownloadHistoryManager()

Specified by:

getDownloadHistoryManager in interface GlobalManager

generate

public void generate(IndentWriter writer)

Specified by:

generate in interface AEDiagnosticsEvidenceGenerator

main

public static void main(String[] args)

setMainlineDHTProvider

public void setMainlineDHTProvider(MainlineDHTProvider provider)

Description copied from interface: GlobalManager

Calling this method doesn't prepare the client to be DHT-ready, it is only used to store, or remove, a DHT provider - so that it can be globally accessible. See the DHT manager classes in the plugin API for a better way to register a provider.

Specified by:

setMainlineDHTProvider in interface GlobalManager

getMainlineDHTProvider

public MainlineDHTProvider getMainlineDHTProvider()

Specified by:

getMainlineDHTProvider in interface GlobalManager

statsRequest

public void statsRequest(Map request,
 Map reply)

Specified by:

statsRequest in interface GlobalManager