Class DownloadManagerController

java.lang.Object

com.biglybt.core.logging.LogRelation

com.biglybt.core.download.impl.DownloadManagerController

All Implemented Interfaces:

PEPeerManagerAdapter, PeerManagerRegistrationAdapter, SimpleTimer.TimerTickReceiver

public class DownloadManagerController
extends LogRelation
implements PEPeerManagerAdapter, PeerManagerRegistrationAdapter, SimpleTimer.TimerTickReceiver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	DownloadManagerController.DiskManagerListener_Default
protected class	DownloadManagerController.fileInfoFacade
protected class	DownloadManagerController.FileInfoFacadeSet
class	DownloadManagerController.ForceRecheckDiskManagerListener
(package private) static interface	DownloadManagerController.ForceRecheckListener

Field Summary

Fields

Modifier and Type	Field	Description
private BloomFilter	activation_bloom
private long	activation_bloom_create_time
private int	activation_count
private long	activation_count_time
private static final int	ACTIVATION_REBUILD_TIME
(package private) boolean	bInitialized
private static final int	BLOOM_SIZE
private boolean	cached_complete_excluding_dnd
private boolean	cached_has_dnd_files
private Set<String>	cached_networks
(package private) final Object	cached_networks_lock
private boolean	cached_values_set
(package private) final AEMonitor	control_mon
(package private) long	data_send_rate_at_close
private final ListenerManager	disk_listeners
(package private) static final ListenerManager	disk_listeners_agregator
private final AEMonitor	disk_listeners_mon
private DiskManagerListener	disk_manager_listener_use_accessors
private WeakReference<DiskManagerPiece[]>	disk_manager_pieces_snapshot
private Object	disk_manager_pieces_snapshot_lock
private DiskManager	disk_manager_use_accessors
private DownloadManagerStateAttributeListener	dm_attribute_listener
(package private) final DownloadManagerImpl	download_manager
(package private) DownloadManagerState	download_manager_state
private String	errorDetail
private int	errorFlags
private int	errorType
private static ExternalSeedPlugin	ext_seed_plugin
private static boolean	ext_seed_plugin_tried
private List<Object[]>	external_rate_limiters_cow
private Object	external_rate_limiters_cow_lock
(package private) final AEMonitor	facade_mon
(package private) final DownloadManagerController.FileInfoFacadeSet	fileFacadeSet
(package private) boolean	files_facade_destroyed
private boolean	force_start
(package private) final GlobalManagerStats	global_stats
private final LinkedList<ExternalSeedPeer>	http_seeds
private static final int	HTTP_SEEDS_MAX
private boolean	is_force_rechecking
private static final int	LDT_DL_ADDED
private static final int	LDT_DL_REMOVED
private WeakReference<byte[]>	md_info_dict_ref
private int	md_info_dict_size
private final Map<String,int[]>	md_info_peer_history
private static final int	MD_INFO_PEER_HISTORY_MAX
private PEPeerManager	peer_manager
private PeerManagerRegistration	peer_manager_registration
private boolean	piece_checking_enabled
private long	priority_connection_count
(package private) static long	skeleton_builds
private static final long	STATE_FLAG_COMPLETE_NO_DND
private static final long	STATE_FLAG_HASDND
private final AEMonitor	state_mon
private int	state_set_by_method
(package private) final DownloadManagerStatsImpl	stats
private int	substate
(package private) static boolean	tracker_stats_exclude_lan

Fields inherited from interface PeerManagerRegistrationAdapter

AT_ACCEPTED, AT_ACCEPTED_PROBE, AT_DECLINED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DownloadManagerController(DownloadManagerImpl _download_manager)

Method Summary

Modifier and Type	Method	Description
int	activateRequest(InetSocketAddress address)
void	addDiskListener(DownloadManagerDiskListener listener)
void	addHTTPSeed(String address, int port)
void	addPeer(PEPeer peer)
void	addPiece(PEPiece piece)
void	addRateLimiter(LimitedRateGroup group, boolean upload)
private void	cacheNetworks()
protected void	calculateCompleteness(DiskManagerFileInfo[] active)
boolean	canForceRecheck()
void	dataBytesReceived(PEPeer peer, long bytes)
void	dataBytesSent(PEPeer peer, long bytes)
void	deactivateRequest(InetSocketAddress address)
protected void	destroy()
void	discarded(PEPeer peer, int bytes)
void	enqueueReadRequest(PEPeer peer, DiskManagerReadRequest request, DiskManagerReadRequestListener listener)
protected void	fileInfoChanged()
protected void	filePrioritiesChanged(List files)
boolean	filesExist(boolean expected_to_be_allocated, boolean test_only)
void	forceRecheck(Map resume_data)
void	generateEvidence(IndentWriter writer, boolean full)
int	getActivationCount()
int	getCryptoLevel()	See NetworkManager.CRYPTO_OVERRIDE constants
String	getDescription()
long	getDiskListenerCount()
protected DiskManager	getDiskManager()
DiskManagerFileInfo[]	getDiskManagerFileInfo()	Deprecated. use getDiskManagerFileInfoSet() instead
DiskManagerFileInfoSet	getDiskManagerFileInfoSet()
DiskManagerPiece[]	getDiskManagerPiecesSnapshot()
String	getDisplayName()
int	getDownloadRateLimitBytesPerSecond()
int	getEffectiveUploadRateLimitBytesPerSecond()
String[]	getEnabledNetworks()
protected String	getErrorDetail()
protected int	getErrorFlags()
protected int	getErrorType()
int	getExtendedMessagingMode()
static ExternalSeedPlugin	getExternalSeedPlugin()
byte[]	getHashOverride()
int	getHashOverrideLocalPort(boolean only_if_allocated)
LogRelation	getLogRelation()
int[]	getMaxConnections()
int[]	getMaxSeedConnections()
int	getMaxUploads()
int	getNbPieces()
byte[]	getPeerID()
protected PEPeerManager	getPeerManager()
PeerManagerRegistration	getPeerManagerRegistration()
long	getPermittedBytesToReceive()
long	getPermittedBytesToSend()
int	getPosition()
Object[]	getQueryableInterfaces()	Query this class for a reference to another class that it may hold
long	getRandomSeed()
LimitedRateGroup[]	getRateLimiters(boolean upload)
String	getRelationText()	A short description of what your class holds that can be printed by the logger
protected byte[]	getSecret2(TOTorrent torrent)
byte[][]	getSecrets()
byte[][]	getSecrets(int crypto_level)
int	getState()
protected int	getSubState()
byte[]	getTargetHash()
int	getTCPListeningPortNumber()
byte[]	getTorrentInfoDict(PEPeer peer)
int	getTorrentInfoDictSize()
String	getTrackerClientExtensions()
TRTrackerScraperResponse	getTrackerScrapeResponse()
int	getUploadPriority()
int	getUploadRateLimitBytesPerSecond()
boolean	hasPriorityConnection()
void	initializeDiskManager(boolean open_for_seeding)
protected void	initializeDiskManagerSupport(int initialising_state, DiskManagerListener listener)
protected boolean	isDownloadComplete(boolean bIncludeDND)	Determine if the download is complete, excluding DND files.
protected boolean	isForceRechecking()
boolean	isForceStart()
boolean	isMetadataDownload()
boolean	isNATHealthy()
boolean	isNetworkEnabled(String network)
boolean	isPeerExchangeEnabled()
boolean	isPeerSourceEnabled(String peer_source)
boolean	isPeriodicRescanEnabled()
boolean	isStateSeeding()
boolean	manualRoute(NetworkConnection connection)
void	permittedReceiveBytesUsed(int bytes)
void	permittedSendBytesUsed(int bytes)
void	priorityConnectionChanged(boolean added)
void	protocolBytesReceived(PEPeer peer, long bytes)
void	protocolBytesSent(PEPeer peer, long bytes)
protected void	rateLimitChanged()
void	removeDiskListener(DownloadManagerDiskListener listener)
void	removePeer(PEPeer peer)
void	removePiece(PEPiece piece)
void	removeRateLimiter(LimitedRateGroup group, boolean upload)
void	restartDownload(boolean forceRecheck)	Stops the current download, then restarts it again.
void	saveTorrentState()
protected void	setDiskManager(DiskManager new_disk_manager, DiskManagerListener new_disk_manager_listener)
protected void	setDownloadManagerState(DownloadManagerState dms)
void	setDownloadRateLimitBytesPerSecond(int b)
protected void	setErrorState(int type, String reason, int flags)
protected void	setFailed(int type, String reason)
private void	setFailed(int type, String reason, boolean recovering)
private void	setFailed(DiskManager dm)
protected void	setFailed(String reason)
protected void	setFailed(String reason, Throwable cause)
void	setForceStart(boolean _force_start)
protected void	setInitialState(int initial_state)
void	setPieceCheckingEnabled(boolean enabled)
(package private) void	setState(int _state, boolean _inform_changed)
void	setStateDownloading()
void	setStateFinishing()
protected void	setStateQueued()
void	setStateSeeding(boolean never_downloaded)
protected void	setStateWaiting()
private void	setSubState(int ss)
void	setTrackerRefreshDelayOverrides(int percent)
void	setUploadRateLimitBytesPerSecond(int b)
void	startDownload(TRTrackerAnnouncer tracker_client)
void	statsRequest(PEPeer originator, Map request, Map reply)
void	stopIt(int _stateAfterStopping, boolean remove_torrent, boolean remove_data, boolean for_removal)
void	tick(long mono_now, int tick_count)

Methods inherited from class LogRelation

propogatedRelationText, queryForClass

Methods inherited from class Object

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

Field Details

STATE_FLAG_HASDND

private static final long STATE_FLAG_HASDND

See Also:

• Constant Field Values

STATE_FLAG_COMPLETE_NO_DND

private static final long STATE_FLAG_COMPLETE_NO_DND

See Also:

• Constant Field Values

skeleton_builds

static long skeleton_builds

tracker_stats_exclude_lan

static boolean tracker_stats_exclude_lan

ext_seed_plugin

private static ExternalSeedPlugin ext_seed_plugin

ext_seed_plugin_tried

private static boolean ext_seed_plugin_tried

LDT_DL_ADDED

private static final int LDT_DL_ADDED

See Also:

• Constant Field Values

LDT_DL_REMOVED

private static final int LDT_DL_REMOVED

See Also:

• Constant Field Values

disk_listeners_agregator

static final ListenerManager disk_listeners_agregator

disk_listeners

private final ListenerManager disk_listeners

disk_listeners_mon

private final AEMonitor disk_listeners_mon

control_mon

final AEMonitor control_mon

state_mon

private final AEMonitor state_mon

facade_mon

final AEMonitor facade_mon

download_manager

final DownloadManagerImpl download_manager

download_manager_state

DownloadManagerState download_manager_state

stats

final DownloadManagerStatsImpl stats

state_set_by_method

private volatile int state_set_by_method

substate

private volatile int substate

force_start

private volatile boolean force_start

is_force_rechecking

private volatile boolean is_force_rechecking

disk_manager_use_accessors

private volatile DiskManager disk_manager_use_accessors

disk_manager_listener_use_accessors

private DiskManagerListener disk_manager_listener_use_accessors

disk_manager_pieces_snapshot_lock

private Object disk_manager_pieces_snapshot_lock

disk_manager_pieces_snapshot

private volatile WeakReference<DiskManagerPiece[]> disk_manager_pieces_snapshot

fileFacadeSet

final DownloadManagerController.FileInfoFacadeSet fileFacadeSet

files_facade_destroyed

boolean files_facade_destroyed

cached_complete_excluding_dnd

private boolean cached_complete_excluding_dnd

cached_has_dnd_files

private boolean cached_has_dnd_files

cached_values_set

private boolean cached_values_set

cached_networks

private Set<String> cached_networks

cached_networks_lock

final Object cached_networks_lock

peer_manager_registration

private PeerManagerRegistration peer_manager_registration

peer_manager

private PEPeerManager peer_manager

dm_attribute_listener

private DownloadManagerStateAttributeListener dm_attribute_listener

external_rate_limiters_cow_lock

private Object external_rate_limiters_cow_lock

external_rate_limiters_cow

private List<Object[]> external_rate_limiters_cow

errorDetail

private String errorDetail

errorType

private int errorType

errorFlags

private int errorFlags

global_stats

final GlobalManagerStats global_stats

bInitialized

boolean bInitialized

data_send_rate_at_close

long data_send_rate_at_close

ACTIVATION_REBUILD_TIME

private static final int ACTIVATION_REBUILD_TIME

See Also:

• Constant Field Values

BLOOM_SIZE

private static final int BLOOM_SIZE

See Also:

• Constant Field Values

activation_bloom

private volatile BloomFilter activation_bloom

activation_bloom_create_time

private volatile long activation_bloom_create_time

activation_count

private volatile int activation_count

activation_count_time

private volatile long activation_count_time

piece_checking_enabled

private boolean piece_checking_enabled

priority_connection_count

private long priority_connection_count

HTTP_SEEDS_MAX

private static final int HTTP_SEEDS_MAX

See Also:

• Constant Field Values

http_seeds

private final LinkedList<ExternalSeedPeer> http_seeds

md_info_dict_size

private int md_info_dict_size

md_info_dict_ref

private volatile WeakReference<byte[]> md_info_dict_ref

MD_INFO_PEER_HISTORY_MAX

private static final int MD_INFO_PEER_HISTORY_MAX

See Also:

• Constant Field Values

md_info_peer_history

private final Map<String,int[]> md_info_peer_history

Constructor Details

DownloadManagerController

protected DownloadManagerController(DownloadManagerImpl _download_manager)

Method Details

getExternalSeedPlugin

public static ExternalSeedPlugin getExternalSeedPlugin()

setDownloadManagerState

protected void setDownloadManagerState(DownloadManagerState dms)

setInitialState

protected void setInitialState(int initial_state)

startDownload

public void startDownload(TRTrackerAnnouncer tracker_client)

initializeDiskManager

public void initializeDiskManager(boolean open_for_seeding)

initializeDiskManagerSupport

protected void initializeDiskManagerSupport(int initialising_state,
 DiskManagerListener listener)

canForceRecheck

public boolean canForceRecheck()

isForceRechecking

protected boolean isForceRechecking()

forceRecheck

public void forceRecheck(Map resume_data)

setPieceCheckingEnabled

public void setPieceCheckingEnabled(boolean enabled)

stopIt

public void stopIt(int _stateAfterStopping,
 boolean remove_torrent,
 boolean remove_data,
 boolean for_removal)

setStateWaiting

protected void setStateWaiting()

setStateFinishing

public void setStateFinishing()

Specified by:

setStateFinishing in interface PEPeerManagerAdapter

setStateDownloading

public void setStateDownloading()

setStateSeeding

public void setStateSeeding(boolean never_downloaded)

Specified by:

setStateSeeding in interface PEPeerManagerAdapter

isStateSeeding

public boolean isStateSeeding()

setStateQueued

protected void setStateQueued()

getState

public int getState()

getSubState

protected int getSubState()

setSubState

private void setSubState(int ss)

setState

void setState(int _state,
 boolean _inform_changed)

Parameters:

_state -

_inform_changed - trigger informStateChange (which may not trigger listeners if state hasn't changed since last trigger)

restartDownload

public void restartDownload(boolean forceRecheck)

Stops the current download, then restarts it again.

Specified by:

restartDownload in interface PEPeerManagerAdapter

destroy

protected void destroy()

saveTorrentState

public void saveTorrentState()

Specified by:

saveTorrentState in interface PEPeerManagerAdapter

isPeerSourceEnabled

public boolean isPeerSourceEnabled(String peer_source)

Specified by:

isPeerSourceEnabled in interface PeerManagerRegistrationAdapter

Specified by:

isPeerSourceEnabled in interface PEPeerManagerAdapter

cacheNetworks

private void cacheNetworks()

isNetworkEnabled

public boolean isNetworkEnabled(String network)

Specified by:

isNetworkEnabled in interface PEPeerManagerAdapter

getEnabledNetworks

public String[] getEnabledNetworks()

Specified by:

getEnabledNetworks in interface PEPeerManagerAdapter

getSecrets

public byte[][] getSecrets()

Specified by:

getSecrets in interface PeerManagerRegistrationAdapter

getHashOverride

public byte[] getHashOverride()

Specified by:

getHashOverride in interface PeerManagerRegistrationAdapter

getPeerID

public byte[] getPeerID()

Specified by:

getPeerID in interface PeerManagerRegistrationAdapter

getNbPieces

public int getNbPieces()

Specified by:

getNbPieces in interface PeerManagerRegistrationAdapter

getHashOverrideLocalPort

public int getHashOverrideLocalPort(boolean only_if_allocated)

Specified by:

getHashOverrideLocalPort in interface PeerManagerRegistrationAdapter

getSecrets

public byte[][] getSecrets(int crypto_level)

Specified by:

getSecrets in interface PEPeerManagerAdapter

getSecret2

protected byte[] getSecret2(TOTorrent torrent)
                     throws TOTorrentException

Throws:

TOTorrentException

manualRoute

public boolean manualRoute(NetworkConnection connection)

Specified by:

manualRoute in interface PeerManagerRegistrationAdapter

getRandomSeed

public long getRandomSeed()

Specified by:

getRandomSeed in interface PEPeerManagerAdapter

addRateLimiter

public void addRateLimiter(LimitedRateGroup group,
 boolean upload)

getRateLimiters

public LimitedRateGroup[] getRateLimiters(boolean upload)

removeRateLimiter

public void removeRateLimiter(LimitedRateGroup group,
 boolean upload)

enqueueReadRequest

public void enqueueReadRequest(PEPeer peer,
 DiskManagerReadRequest request,
 DiskManagerReadRequestListener listener)

Specified by:

enqueueReadRequest in interface PEPeerManagerAdapter

activateRequest

public int activateRequest(InetSocketAddress address)

Specified by:

activateRequest in interface PeerManagerRegistrationAdapter

Parameters:

address -

Returns:

one of the AT_ constants

deactivateRequest

public void deactivateRequest(InetSocketAddress address)

Specified by:

deactivateRequest in interface PeerManagerRegistrationAdapter

getTargetHash

public byte[] getTargetHash()

Specified by:

getTargetHash in interface PEPeerManagerAdapter

getTCPListeningPortNumber

public int getTCPListeningPortNumber()

Specified by:

getTCPListeningPortNumber in interface PEPeerManagerAdapter

getActivationCount

public int getActivationCount()

getPeerManagerRegistration

public PeerManagerRegistration getPeerManagerRegistration()

Specified by:

getPeerManagerRegistration in interface PEPeerManagerAdapter

isForceStart

public boolean isForceStart()

setForceStart

public void setForceStart(boolean _force_start)

setFailed

private void setFailed(DiskManager dm)

setFailed

protected void setFailed(String reason)

setFailed

protected void setFailed(String reason,
 Throwable cause)

setErrorState

protected void setErrorState(int type,
 String reason,
 int flags)

setFailed

protected void setFailed(int type,
 String reason)

setFailed

private void setFailed(int type,
 String reason,
 boolean recovering)

filesExist

public boolean filesExist(boolean expected_to_be_allocated,
 boolean test_only)

getDiskManagerFileInfoSet

public DiskManagerFileInfoSet getDiskManagerFileInfoSet()

getDiskManagerFileInfo

public DiskManagerFileInfo[] getDiskManagerFileInfo()

Deprecated.

use getDiskManagerFileInfoSet() instead

fileInfoChanged

protected void fileInfoChanged()

filePrioritiesChanged

protected void filePrioritiesChanged(List files)

calculateCompleteness

protected void calculateCompleteness(DiskManagerFileInfo[] active)

isDownloadComplete

protected boolean isDownloadComplete(boolean bIncludeDND)

Determine if the download is complete, excluding DND files. This function is mostly cached when there is a DiskManager.

Returns:

completion state

getPeerManager

protected PEPeerManager getPeerManager()

getDiskManager

protected DiskManager getDiskManager()

getDiskManagerPiecesSnapshot

public DiskManagerPiece[] getDiskManagerPiecesSnapshot()

getErrorDetail

protected String getErrorDetail()

getErrorType

protected int getErrorType()

getErrorFlags

protected int getErrorFlags()

setDiskManager

protected void setDiskManager(DiskManager new_disk_manager,
 DiskManagerListener new_disk_manager_listener)

addDiskListener

public void addDiskListener(DownloadManagerDiskListener listener)

removeDiskListener

public void removeDiskListener(DownloadManagerDiskListener listener)

getDiskListenerCount

public long getDiskListenerCount()

getDisplayName

public String getDisplayName()

Specified by:

getDisplayName in interface PEPeerManagerAdapter

getEffectiveUploadRateLimitBytesPerSecond

public int getEffectiveUploadRateLimitBytesPerSecond()

Specified by:

getEffectiveUploadRateLimitBytesPerSecond in interface PEPeerManagerAdapter

getUploadRateLimitBytesPerSecond

public int getUploadRateLimitBytesPerSecond()

Specified by:

getUploadRateLimitBytesPerSecond in interface PEPeerManagerAdapter

setUploadRateLimitBytesPerSecond

public void setUploadRateLimitBytesPerSecond(int b)

Specified by:

setUploadRateLimitBytesPerSecond in interface PEPeerManagerAdapter

getDownloadRateLimitBytesPerSecond

public int getDownloadRateLimitBytesPerSecond()

Specified by:

getDownloadRateLimitBytesPerSecond in interface PEPeerManagerAdapter

setDownloadRateLimitBytesPerSecond

public void setDownloadRateLimitBytesPerSecond(int b)

Specified by:

setDownloadRateLimitBytesPerSecond in interface PEPeerManagerAdapter

rateLimitChanged

protected void rateLimitChanged()

getPermittedBytesToReceive

public long getPermittedBytesToReceive()

Specified by:

getPermittedBytesToReceive in interface PEPeerManagerAdapter

permittedReceiveBytesUsed

public void permittedReceiveBytesUsed(int bytes)

Specified by:

permittedReceiveBytesUsed in interface PEPeerManagerAdapter

getPermittedBytesToSend

public long getPermittedBytesToSend()

Specified by:

getPermittedBytesToSend in interface PEPeerManagerAdapter

permittedSendBytesUsed

public void permittedSendBytesUsed(int bytes)

Specified by:

permittedSendBytesUsed in interface PEPeerManagerAdapter

getMaxUploads

public int getMaxUploads()

Specified by:

getMaxUploads in interface PEPeerManagerAdapter

getMaxConnections

public int[] getMaxConnections()

Specified by:

getMaxConnections in interface PEPeerManagerAdapter

getMaxSeedConnections

public int[] getMaxSeedConnections()

Specified by:

getMaxSeedConnections in interface PEPeerManagerAdapter

getUploadPriority

public int getUploadPriority()

Specified by:

getUploadPriority in interface PEPeerManagerAdapter

getExtendedMessagingMode

public int getExtendedMessagingMode()

Specified by:

getExtendedMessagingMode in interface PeerManagerRegistrationAdapter

Specified by:

getExtendedMessagingMode in interface PEPeerManagerAdapter

isPeerExchangeEnabled

public boolean isPeerExchangeEnabled()

Specified by:

isPeerExchangeEnabled in interface PEPeerManagerAdapter

getCryptoLevel

public int getCryptoLevel()

Description copied from interface: PEPeerManagerAdapter

See NetworkManager.CRYPTO_OVERRIDE constants

Specified by:

getCryptoLevel in interface PEPeerManagerAdapter

Returns:

isPeriodicRescanEnabled

public boolean isPeriodicRescanEnabled()

Specified by:

isPeriodicRescanEnabled in interface PEPeerManagerAdapter

getTrackerScrapeResponse

public TRTrackerScraperResponse getTrackerScrapeResponse()

Specified by:

getTrackerScrapeResponse in interface PEPeerManagerAdapter

getTrackerClientExtensions

public String getTrackerClientExtensions()

Specified by:

getTrackerClientExtensions in interface PEPeerManagerAdapter

setTrackerRefreshDelayOverrides

public void setTrackerRefreshDelayOverrides(int percent)

Specified by:

setTrackerRefreshDelayOverrides in interface PEPeerManagerAdapter

isNATHealthy

public boolean isNATHealthy()

Specified by:

isNATHealthy in interface PEPeerManagerAdapter

isMetadataDownload

public boolean isMetadataDownload()

Specified by:

isMetadataDownload in interface PEPeerManagerAdapter

getTorrentInfoDictSize

public int getTorrentInfoDictSize()

Specified by:

getTorrentInfoDictSize in interface PEPeerManagerAdapter

getTorrentInfoDict

public byte[] getTorrentInfoDict(PEPeer peer)

Specified by:

getTorrentInfoDict in interface PEPeerManagerAdapter

addPeer

public void addPeer(PEPeer peer)

Specified by:

addPeer in interface PEPeerManagerAdapter

removePeer

public void removePeer(PEPeer peer)

Specified by:

removePeer in interface PEPeerManagerAdapter

addPiece

public void addPiece(PEPiece piece)

Specified by:

addPiece in interface PEPeerManagerAdapter

removePiece

public void removePiece(PEPiece piece)

Specified by:

removePiece in interface PEPeerManagerAdapter

discarded

public void discarded(PEPeer peer,
 int bytes)

Specified by:

discarded in interface PEPeerManagerAdapter

protocolBytesReceived

public void protocolBytesReceived(PEPeer peer,
 long bytes)

Specified by:

protocolBytesReceived in interface PEPeerManagerAdapter

dataBytesReceived

public void dataBytesReceived(PEPeer peer,
 long bytes)

Specified by:

dataBytesReceived in interface PEPeerManagerAdapter

protocolBytesSent

public void protocolBytesSent(PEPeer peer,
 long bytes)

Specified by:

protocolBytesSent in interface PEPeerManagerAdapter

dataBytesSent

public void dataBytesSent(PEPeer peer,
 long bytes)

Specified by:

dataBytesSent in interface PEPeerManagerAdapter

getPosition

public int getPosition()

Specified by:

getPosition in interface PEPeerManagerAdapter

tick

public void tick(long mono_now,
 int tick_count)

Specified by:

tick in interface SimpleTimer.TimerTickReceiver

statsRequest

public void statsRequest(PEPeer originator,
 Map request,
 Map reply)

Specified by:

statsRequest in interface PEPeerManagerAdapter

addHTTPSeed

public void addHTTPSeed(String address,
 int port)

Specified by:

addHTTPSeed in interface PEPeerManagerAdapter

priorityConnectionChanged

public void priorityConnectionChanged(boolean added)

Specified by:

priorityConnectionChanged in interface PEPeerManagerAdapter

hasPriorityConnection

public boolean hasPriorityConnection()

Specified by:

hasPriorityConnection in interface PEPeerManagerAdapter

getDescription

public String getDescription()

Specified by:

getDescription in interface PeerManagerRegistrationAdapter

getLogRelation

public LogRelation getLogRelation()

Specified by:

getLogRelation in interface PEPeerManagerAdapter

getRelationText

public String getRelationText()

Description copied from class: LogRelation

A short description of what your class holds that can be printed by the logger

Overrides:

getRelationText in class LogRelation

Returns:

getQueryableInterfaces

public Object[] getQueryableInterfaces()

Description copied from class: LogRelation

Query this class for a reference to another class that it may hold

Overrides:

getQueryableInterfaces in class LogRelation

Returns:

If found, the class desired. Otherwise, null.

generateEvidence

public void generateEvidence(IndentWriter writer,
 boolean full)