Package com.biglybt.core.download.impl
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
-
Field Summary
-
Fields inherited from interface com.biglybt.core.peermanager.PeerManagerRegistrationAdapter
AT_ACCEPTED, AT_ACCEPTED_PROBE, AT_DECLINED
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
DownloadManagerController(DownloadManagerImpl _download_manager)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description int
activateRequest(java.net.InetSocketAddress address)
void
addDiskListener(DownloadManagerDiskListener listener)
void
addHTTPSeed(java.lang.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, int bytes)
void
dataBytesSent(PEPeer peer, int bytes)
void
deactivateRequest(java.net.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(java.util.List files)
boolean
filesExist(boolean expected_to_be_allocated)
void
forceRecheck(ForceRecheckListener l)
void
generateEvidence(IndentWriter writer)
int
getActivationCount()
int
getCryptoLevel()
See NetworkManager.CRYPTO_OVERRIDE constantsjava.lang.String
getDescription()
long
getDiskListenerCount()
protected DiskManager
getDiskManager()
DiskManagerFileInfo[]
getDiskManagerFileInfo()
Deprecated.use getDiskManagerFileInfoSet() insteadDiskManagerFileInfoSet
getDiskManagerFileInfoSet()
DiskManagerPiece[]
getDiskManagerPiecesSnapshot()
java.lang.String
getDisplayName()
int
getDownloadRateLimitBytesPerSecond()
int
getEffectiveUploadRateLimitBytesPerSecond()
java.lang.String[]
getEnabledNetworks()
protected java.lang.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()
int
getPermittedBytesToReceive()
int
getPermittedBytesToSend()
int
getPosition()
java.lang.Object[]
getQueryableInterfaces()
Query this class for a reference to another class that it may holdlong
getRandomSeed()
LimitedRateGroup[]
getRateLimiters(boolean upload)
java.lang.String
getRelationText()
A short description of what your class holds that can be printed by the loggerprotected 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()
java.lang.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(java.lang.String network)
boolean
isPeerExchangeEnabled()
boolean
isPeerSourceEnabled(java.lang.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, int bytes)
void
protocolBytesSent(PEPeer peer, int bytes)
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)
void
setDownloadRateLimitBytesPerSecond(int b)
protected void
setErrorState(int type, java.lang.String reason, int flags)
protected void
setFailed(int type, java.lang.String reason)
private void
setFailed(int type, java.lang.String reason, boolean recovering)
private void
setFailed(DiskManager dm)
protected void
setFailed(java.lang.String reason)
protected void
setFailed(java.lang.String reason, java.lang.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, java.util.Map request, java.util.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 com.biglybt.core.logging.LogRelation
propogatedRelationText, queryForClass
-
-
-
-
Field Detail
-
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
-
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 java.lang.Object disk_manager_pieces_snapshot_lock
-
disk_manager_pieces_snapshot
private volatile 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
java.util.Set<java.lang.String> cached_networks
-
cached_networks_lock
final java.lang.Object cached_networks_lock
-
peer_manager_registration
private PeerManagerRegistration peer_manager_registration
-
peer_manager
PEPeerManager peer_manager
-
dm_attribute_listener
private DownloadManagerStateAttributeListener dm_attribute_listener
-
external_rate_limiters_cow_lock
private java.lang.Object external_rate_limiters_cow_lock
-
external_rate_limiters_cow
private java.util.List<java.lang.Object[]> external_rate_limiters_cow
-
errorDetail
private java.lang.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 java.util.LinkedList<ExternalSeedPeer> http_seeds
-
md_info_dict_size
private int md_info_dict_size
-
md_info_dict_ref
private volatile java.lang.ref.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 java.util.Map<java.lang.String,int[]> md_info_peer_history
-
-
Constructor Detail
-
DownloadManagerController
protected DownloadManagerController(DownloadManagerImpl _download_manager)
-
-
Method Detail
-
getExternalSeedPlugin
public static ExternalSeedPlugin getExternalSeedPlugin()
-
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(ForceRecheckListener l)
-
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 interfacePEPeerManagerAdapter
-
setStateDownloading
public void setStateDownloading()
-
setStateSeeding
public void setStateSeeding(boolean never_downloaded)
- Specified by:
setStateSeeding
in interfacePEPeerManagerAdapter
-
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 interfacePEPeerManagerAdapter
-
destroy
protected void destroy()
-
saveTorrentState
public void saveTorrentState()
- Specified by:
saveTorrentState
in interfacePEPeerManagerAdapter
-
isPeerSourceEnabled
public boolean isPeerSourceEnabled(java.lang.String peer_source)
- Specified by:
isPeerSourceEnabled
in interfacePeerManagerRegistrationAdapter
- Specified by:
isPeerSourceEnabled
in interfacePEPeerManagerAdapter
-
cacheNetworks
private void cacheNetworks()
-
isNetworkEnabled
public boolean isNetworkEnabled(java.lang.String network)
- Specified by:
isNetworkEnabled
in interfacePEPeerManagerAdapter
-
getEnabledNetworks
public java.lang.String[] getEnabledNetworks()
- Specified by:
getEnabledNetworks
in interfacePEPeerManagerAdapter
-
getSecrets
public byte[][] getSecrets()
- Specified by:
getSecrets
in interfacePeerManagerRegistrationAdapter
-
getHashOverride
public byte[] getHashOverride()
- Specified by:
getHashOverride
in interfacePeerManagerRegistrationAdapter
-
getPeerID
public byte[] getPeerID()
- Specified by:
getPeerID
in interfacePeerManagerRegistrationAdapter
-
getNbPieces
public int getNbPieces()
- Specified by:
getNbPieces
in interfacePeerManagerRegistrationAdapter
-
getHashOverrideLocalPort
public int getHashOverrideLocalPort(boolean only_if_allocated)
- Specified by:
getHashOverrideLocalPort
in interfacePeerManagerRegistrationAdapter
-
getSecrets
public byte[][] getSecrets(int crypto_level)
- Specified by:
getSecrets
in interfacePEPeerManagerAdapter
-
getSecret2
protected byte[] getSecret2(TOTorrent torrent) throws TOTorrentException
- Throws:
TOTorrentException
-
manualRoute
public boolean manualRoute(NetworkConnection connection)
- Specified by:
manualRoute
in interfacePeerManagerRegistrationAdapter
-
getRandomSeed
public long getRandomSeed()
- Specified by:
getRandomSeed
in interfacePEPeerManagerAdapter
-
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 interfacePEPeerManagerAdapter
-
activateRequest
public int activateRequest(java.net.InetSocketAddress address)
- Specified by:
activateRequest
in interfacePeerManagerRegistrationAdapter
- Returns:
- one of the AT_ constants
-
deactivateRequest
public void deactivateRequest(java.net.InetSocketAddress address)
- Specified by:
deactivateRequest
in interfacePeerManagerRegistrationAdapter
-
getTargetHash
public byte[] getTargetHash()
- Specified by:
getTargetHash
in interfacePEPeerManagerAdapter
-
getTCPListeningPortNumber
public int getTCPListeningPortNumber()
- Specified by:
getTCPListeningPortNumber
in interfacePEPeerManagerAdapter
-
getActivationCount
public int getActivationCount()
-
getPeerManagerRegistration
public PeerManagerRegistration getPeerManagerRegistration()
- Specified by:
getPeerManagerRegistration
in interfacePEPeerManagerAdapter
-
isForceStart
public boolean isForceStart()
-
setForceStart
public void setForceStart(boolean _force_start)
-
setFailed
private void setFailed(DiskManager dm)
-
setFailed
protected void setFailed(java.lang.String reason)
-
setFailed
protected void setFailed(java.lang.String reason, java.lang.Throwable cause)
-
setErrorState
protected void setErrorState(int type, java.lang.String reason, int flags)
-
setFailed
protected void setFailed(int type, java.lang.String reason)
-
setFailed
private void setFailed(int type, java.lang.String reason, boolean recovering)
-
filesExist
public boolean filesExist(boolean expected_to_be_allocated)
-
getDiskManagerFileInfoSet
public DiskManagerFileInfoSet getDiskManagerFileInfoSet()
-
getDiskManagerFileInfo
public DiskManagerFileInfo[] getDiskManagerFileInfo()
Deprecated.use getDiskManagerFileInfoSet() instead
-
fileInfoChanged
protected void fileInfoChanged()
-
filePrioritiesChanged
protected void filePrioritiesChanged(java.util.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 java.lang.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 java.lang.String getDisplayName()
- Specified by:
getDisplayName
in interfacePEPeerManagerAdapter
-
getEffectiveUploadRateLimitBytesPerSecond
public int getEffectiveUploadRateLimitBytesPerSecond()
- Specified by:
getEffectiveUploadRateLimitBytesPerSecond
in interfacePEPeerManagerAdapter
-
getUploadRateLimitBytesPerSecond
public int getUploadRateLimitBytesPerSecond()
- Specified by:
getUploadRateLimitBytesPerSecond
in interfacePEPeerManagerAdapter
-
setUploadRateLimitBytesPerSecond
public void setUploadRateLimitBytesPerSecond(int b)
- Specified by:
setUploadRateLimitBytesPerSecond
in interfacePEPeerManagerAdapter
-
getDownloadRateLimitBytesPerSecond
public int getDownloadRateLimitBytesPerSecond()
- Specified by:
getDownloadRateLimitBytesPerSecond
in interfacePEPeerManagerAdapter
-
setDownloadRateLimitBytesPerSecond
public void setDownloadRateLimitBytesPerSecond(int b)
- Specified by:
setDownloadRateLimitBytesPerSecond
in interfacePEPeerManagerAdapter
-
getPermittedBytesToReceive
public int getPermittedBytesToReceive()
- Specified by:
getPermittedBytesToReceive
in interfacePEPeerManagerAdapter
-
permittedReceiveBytesUsed
public void permittedReceiveBytesUsed(int bytes)
- Specified by:
permittedReceiveBytesUsed
in interfacePEPeerManagerAdapter
-
getPermittedBytesToSend
public int getPermittedBytesToSend()
- Specified by:
getPermittedBytesToSend
in interfacePEPeerManagerAdapter
-
permittedSendBytesUsed
public void permittedSendBytesUsed(int bytes)
- Specified by:
permittedSendBytesUsed
in interfacePEPeerManagerAdapter
-
getMaxUploads
public int getMaxUploads()
- Specified by:
getMaxUploads
in interfacePEPeerManagerAdapter
-
getMaxConnections
public int[] getMaxConnections()
- Specified by:
getMaxConnections
in interfacePEPeerManagerAdapter
-
getMaxSeedConnections
public int[] getMaxSeedConnections()
- Specified by:
getMaxSeedConnections
in interfacePEPeerManagerAdapter
-
getUploadPriority
public int getUploadPriority()
- Specified by:
getUploadPriority
in interfacePEPeerManagerAdapter
-
getExtendedMessagingMode
public int getExtendedMessagingMode()
- Specified by:
getExtendedMessagingMode
in interfacePeerManagerRegistrationAdapter
- Specified by:
getExtendedMessagingMode
in interfacePEPeerManagerAdapter
-
isPeerExchangeEnabled
public boolean isPeerExchangeEnabled()
- Specified by:
isPeerExchangeEnabled
in interfacePEPeerManagerAdapter
-
getCryptoLevel
public int getCryptoLevel()
Description copied from interface:PEPeerManagerAdapter
See NetworkManager.CRYPTO_OVERRIDE constants- Specified by:
getCryptoLevel
in interfacePEPeerManagerAdapter
- Returns:
-
isPeriodicRescanEnabled
public boolean isPeriodicRescanEnabled()
- Specified by:
isPeriodicRescanEnabled
in interfacePEPeerManagerAdapter
-
getTrackerScrapeResponse
public TRTrackerScraperResponse getTrackerScrapeResponse()
- Specified by:
getTrackerScrapeResponse
in interfacePEPeerManagerAdapter
-
getTrackerClientExtensions
public java.lang.String getTrackerClientExtensions()
- Specified by:
getTrackerClientExtensions
in interfacePEPeerManagerAdapter
-
setTrackerRefreshDelayOverrides
public void setTrackerRefreshDelayOverrides(int percent)
- Specified by:
setTrackerRefreshDelayOverrides
in interfacePEPeerManagerAdapter
-
isNATHealthy
public boolean isNATHealthy()
- Specified by:
isNATHealthy
in interfacePEPeerManagerAdapter
-
isMetadataDownload
public boolean isMetadataDownload()
- Specified by:
isMetadataDownload
in interfacePEPeerManagerAdapter
-
getTorrentInfoDictSize
public int getTorrentInfoDictSize()
- Specified by:
getTorrentInfoDictSize
in interfacePEPeerManagerAdapter
-
getTorrentInfoDict
public byte[] getTorrentInfoDict(PEPeer peer)
- Specified by:
getTorrentInfoDict
in interfacePEPeerManagerAdapter
-
addPeer
public void addPeer(PEPeer peer)
- Specified by:
addPeer
in interfacePEPeerManagerAdapter
-
removePeer
public void removePeer(PEPeer peer)
- Specified by:
removePeer
in interfacePEPeerManagerAdapter
-
addPiece
public void addPiece(PEPiece piece)
- Specified by:
addPiece
in interfacePEPeerManagerAdapter
-
removePiece
public void removePiece(PEPiece piece)
- Specified by:
removePiece
in interfacePEPeerManagerAdapter
-
discarded
public void discarded(PEPeer peer, int bytes)
- Specified by:
discarded
in interfacePEPeerManagerAdapter
-
protocolBytesReceived
public void protocolBytesReceived(PEPeer peer, int bytes)
- Specified by:
protocolBytesReceived
in interfacePEPeerManagerAdapter
-
dataBytesReceived
public void dataBytesReceived(PEPeer peer, int bytes)
- Specified by:
dataBytesReceived
in interfacePEPeerManagerAdapter
-
protocolBytesSent
public void protocolBytesSent(PEPeer peer, int bytes)
- Specified by:
protocolBytesSent
in interfacePEPeerManagerAdapter
-
dataBytesSent
public void dataBytesSent(PEPeer peer, int bytes)
- Specified by:
dataBytesSent
in interfacePEPeerManagerAdapter
-
getPosition
public int getPosition()
- Specified by:
getPosition
in interfacePEPeerManagerAdapter
-
tick
public void tick(long mono_now, int tick_count)
- Specified by:
tick
in interfaceSimpleTimer.TimerTickReceiver
-
statsRequest
public void statsRequest(PEPeer originator, java.util.Map request, java.util.Map reply)
- Specified by:
statsRequest
in interfacePEPeerManagerAdapter
-
addHTTPSeed
public void addHTTPSeed(java.lang.String address, int port)
- Specified by:
addHTTPSeed
in interfacePEPeerManagerAdapter
-
priorityConnectionChanged
public void priorityConnectionChanged(boolean added)
- Specified by:
priorityConnectionChanged
in interfacePEPeerManagerAdapter
-
hasPriorityConnection
public boolean hasPriorityConnection()
- Specified by:
hasPriorityConnection
in interfacePEPeerManagerAdapter
-
getDescription
public java.lang.String getDescription()
- Specified by:
getDescription
in interfacePeerManagerRegistrationAdapter
-
getLogRelation
public LogRelation getLogRelation()
- Specified by:
getLogRelation
in interfacePEPeerManagerAdapter
-
getRelationText
public java.lang.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 classLogRelation
- Returns:
-
getQueryableInterfaces
public java.lang.Object[] getQueryableInterfaces()
Description copied from class:LogRelation
Query this class for a reference to another class that it may hold- Overrides:
getQueryableInterfaces
in classLogRelation
- Returns:
- If found, the class desired. Otherwise, null.
-
generateEvidence
public void generateEvidence(IndentWriter writer)
-
-