Class PeerManager.PeerManagerRegistrationImpl.ProbeControl

java.lang.Object

com.biglybt.core.peermanager.PeerManager.PeerManagerRegistrationImpl.ProbeControl

All Implemented Interfaces:

PEPeerControl, PEPeerManager

Enclosing class:

PeerManager.PeerManagerRegistrationImpl

private class PeerManager.PeerManagerRegistrationImpl.ProbeControl
extends Object
implements PEPeerControl

Nested Class Summary

Nested classes/interfaces inherited from interface PEPeerManager

PEPeerManager.StatsReceiver

Field Summary

Fields

Modifier and Type	Field	Description
(package private) PeerIdentityDataID	data_id
private final LimitedRateGroup	download_limited_rate_group
private final LimitedRateGroup	upload_limited_rate_group

Fields inherited from interface PEPeerControl

SNUB_MILLIS, TEST_PERMIT_PEER_CONNECTIONS

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProbeControl()

Method Summary

Modifier and Type	Method	Description
void	addListener(PEPeerManagerListener l)
void	addPeer(PEPeer peer)
void	addPeer(String ip_address, int tcp_port, int udp_port, boolean use_crypto, Map user_data)	Add a new peer, using the default internal PEPeer implementation (like for peers given in announce reply), using the given address and port.
void	addPeerTransport(PEPeerTransport transport)
void	addPiece(PEPiece piece, int pieceNumber, PEPeer for_peer)
void	addRateLimiter(LimitedRateGroup group, boolean upload)
void	badPieceReported(PEPeerTransport originator, int piece_number)
boolean	canToggleSuperSeedMode()
void	checkSnubbing(PEPeerTransport peer)
DiskManagerReadRequest	createDiskManagerRequest(int pieceNumber, int offset, int length)
PeerExchangerItem	createPeerExchangeConnection(PEPeerTransport base_peer)	Register a peer connection for peer exchange handling.
PEPeerStats	createPeerStats(PEPeer owner)
void	dataBytesReceived(PEPeer peer, long l)	Data bytes received.
void	dataBytesSent(PEPeer peer, long l)	Data bytes sent.
void	decNbPeersSnubbed()
void	discarded(PEPeer peer, int l)
boolean	doOptimisticDisconnect(boolean pending_lan_local_peer, boolean force, String network)
void	generateEvidence(IndentWriter writer)
PEPeerManagerAdapter	getAdapter()
int[]	getAvailability()
int	getAvailability(int pieceNumber)
long	getAvailWentBadTime()
int	getAverageCompletionInThousandNotation()	Get the average completion percentage of connected peers.
float	getAvgAvail()
int	getBytesQueuedForUpload()
long	getBytesUnavailable()
String	getConnectHealth(boolean verbose)
int	getConnectTimeout(int ct_def)
Object	getData(String key)	To retreive arbitrary objects against this object.
DiskManager	getDiskManager()
String	getDisplayName()
LimitedRateGroup	getDownloadLimitedRateGroup()	Get the limited rate group used for download limiting.
int	getDownloadRateLimitBytesPerSecond()
int	getEffectiveUploadRateLimitBytesPerSecond()
String	getElapsedTime()
long	getETA(boolean smoothed)
int	getExtendedMessagingMode()
byte[]	getHash()
PEPeerControlHashHandler	getHashHandler()
long	getHiddenBytes()
int	getHiddenPiece()
long	getLastRemoteConnectionTime()
int	getMaxCompletionInThousandNotation(boolean never_include_seeds)	Max completion of connected peers (doesn't factor in our completion)
int[]	getMaxConnections()
int	getMaxNewConnectionsAllowed(String network)
float	getMinAvailability()
float	getMinAvailability(int file_index)
PEPeer	getMyPeer()
int	getNbActivePieces()
int	getNbPeers()
int	getNbPeersSnubbed()
int	getNbPeersStalledPendingLoad()
int	getNbPeersUnchoked()
int	getNbPeersUnchoking()
int	getNbPeersWithUploadBlocked()
int	getNbPeersWithUploadQueued()
int	getNbPieces()
int	getNbRemoteTCPConnections()
int	getNbRemoteUDPConnections()
int	getNbRemoteUTPConnections()
int	getNbSeeds()
int	getPartitionID()
byte[]	getPeerId()
PeerIdentityDataID	getPeerIdentityDataID()
List<PEPeer>	getPeers()
List<PEPeer>	getPeers(String address)
int	getPendingPeerCount()
PeerDescriptor[]	getPendingPeers()
PeerDescriptor[]	getPendingPeers(String address)
PEPiece	getPiece(int pieceNumber)
int	getPieceLength(int pieceNumber)
PiecePicker	getPiecePicker()
PEPiece[]	getPieces()	Often better to use getPiece(pieceNumber)
boolean	getPreferUDP()
long	getRemaining()
byte[][]	getSecrets(int crypto_level)
PEPeerManagerStats	getStats()
byte[]	getTargetHash()	Get torrent hash including any overrides
int	getTCPListeningPortNumber()
long	getTimeStarted(boolean mono_time)
long	getTimeStartedSeeding(boolean mono_time)
int	getTorrentInfoDictSize()
TrackerPeerSource	getTrackerPeerSource()
PEPeerTransport	getTransportFromAddress(String peer)	Locate an existing transport via [IP] Address.
PEPeerTransport	getTransportFromIdentity(byte[] peer_id)	Locate an existing transport via peer id byte identity.
int	getUID()
LimitedRateGroup	getUploadLimitedRateGroup()	Get the limited rate group used for upload limiting.
int	getUploadPriority()
int	getUploadRateLimitBytesPerSecond()
void	handleCloseReason(PEPeerTransport peer, boolean reason_out, int reason)
boolean	hasDownloadablePiece()
boolean	hasPotentialConnections()
void	havePiece(int pieceNumber, int pieceLength, PEPeer pcOrigin)
void	incNbPeersSnubbed()
void	informFullyConnected(PEPeer peer)
boolean	isDestroyed()
boolean	isFastExtensionPermitted(PEPeerTransport originator)
boolean	isHolePunchOperationOK(PEPeerTransport peer, boolean is_connect)
boolean	isInEndGameMode()	Are we in end-game mode?
boolean	isMetadataDownload()
boolean	isNetworkEnabled(String network)
boolean	isPeerExchangeEnabled()
boolean	isPeerSourceEnabled(String peer_source)
boolean	isPrivateTorrent()
boolean	isRTA()
boolean	isSeeding()
boolean	isSuperSeedMode()
boolean	isWritten(int piece_number, int offset)
private void	log()
boolean	needsMD5CheckOnCompletion(int pieceNumber)
void	peerAdded(PEPeer pc)
void	peerConnectionClosed(PEPeerTransport peer, boolean connect_failed, boolean network_failed)	Notify the manager that the given peer connection has been closed.
void	peerDiscovered(PEPeerTransport finder, PeerItem pi)
void	peerDiscovered(String peer_source, String ip_address, int tcp_port, int udp_port, boolean use_crypto)
void	peerRemoved(PEPeer pc)
void	peerVerifiedAsSelf(PEPeerTransport self)	Notify that the given peer connection represents our own client.
void	processTrackerResponse(TRTrackerAnnouncerResponse response)
void	protocolBytesReceived(PEPeer peer, long length)	Protocol bytes received.
void	protocolBytesSent(PEPeer peer, long length)	Protocol bytes sent.
void	removeAllPeers(String reason, int reason_code)
void	removeListener(PEPeerManagerListener l)
void	removePeer(PEPeer peer)
void	removePeer(PEPeer peer, String reason, int reason_code)
void	removeRateLimiter(LimitedRateGroup group, boolean upload)
void	reportBadFastExtensionUse(PEPeerTransport originator)
void	requestAdded(PEPiece piece, PEPeerTransport peer, DiskManagerReadRequest request)
void	requestCanceled(DiskManagerReadRequest item)
boolean	requestExists(String peer_ip, int piece_number, int offset, int length)
boolean	seedPieceRecheck()
void	setData(String key, Object value)	To store arbitrary objects against this object.
void	setMaskDownloadCompletion(Boolean mask)
void	setNbPeersSnubbed(int n)
void	setPreferUDP(boolean prefer)
void	setStatsReceiver(PEPeerManager.StatsReceiver receiver)
void	setSuperSeedMode(boolean on)
void	setTorrentInfoDictSize(int size)
void	start()
void	statsReply(PEPeerTransport originator, Map reply)
void	statsRequest(PEPeerTransport originator, Map request)
void	stopAll()
void	updateSuperSeedPiece(PEPeer peer, int pieceNumber)
boolean	validateHintRequest(PEPeerTransport originator, int pieceNumber, int offset, int length)
boolean	validatePieceReply(PEPeerTransport originator, int pieceNumber, int offset, DirectByteBuffer data)
boolean	validateReadRequest(PEPeerTransport originator, int pieceNumber, int offset, int length)
void	writeBlock(int pieceNumber, int offset, DirectByteBuffer data, Object sender, boolean cancel)

Methods inherited from class Object

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

Methods inherited from interface PEPeerManager

removePeer

Field Details

upload_limited_rate_group

private final LimitedRateGroup upload_limited_rate_group

download_limited_rate_group

private final LimitedRateGroup download_limited_rate_group

data_id

PeerIdentityDataID data_id

Constructor Details

ProbeControl

private ProbeControl()

Method Details

getUID

public int getUID()

Specified by:

getUID in interface PEPeerManager

getDiskManager

public DiskManager getDiskManager()

Specified by:

getDiskManager in interface PEPeerManager

getPiecePicker

public PiecePicker getPiecePicker()

Specified by:

getPiecePicker in interface PEPeerManager

getAdapter

public PEPeerManagerAdapter getAdapter()

Specified by:

getAdapter in interface PEPeerManager

informFullyConnected

public void informFullyConnected(PEPeer peer)

Specified by:

informFullyConnected in interface PEPeerManager

getConnectHealth

public String getConnectHealth(boolean verbose)

Specified by:

getConnectHealth in interface PEPeerManager

start

public void start()

Specified by:

start in interface PEPeerManager

stopAll

public void stopAll()

Specified by:

stopAll in interface PEPeerManager

getHash

public byte[] getHash()

Specified by:

getHash in interface PEPeerManager

getDisplayName

public String getDisplayName()

Specified by:

getDisplayName in interface PEPeerManager

getPeerIdentityDataID

public PeerIdentityDataID getPeerIdentityDataID()

Specified by:

getPeerIdentityDataID in interface PEPeerManager

getPeerId

public byte[] getPeerId()

Specified by:

getPeerId in interface PEPeerManager

getAvailability

public int[] getAvailability()

Specified by:

getAvailability in interface PEPeerManager

getAvailability

public int getAvailability(int pieceNumber)

Specified by:

getAvailability in interface PEPeerManager

getAvgAvail

public float getAvgAvail()

Specified by:

getAvgAvail in interface PEPeerManager

getMinAvailability

public float getMinAvailability()

Specified by:

getMinAvailability in interface PEPeerManager

getMinAvailability

public float getMinAvailability(int file_index)

Specified by:

getMinAvailability in interface PEPeerManager

getAvailWentBadTime

public long getAvailWentBadTime()

Specified by:

getAvailWentBadTime in interface PEPeerManager

Returns:

0: hasn't transitioned from good to bad this session OR known to be good; >0: time availability went from good to bad

getBytesUnavailable

public long getBytesUnavailable()

Specified by:

getBytesUnavailable in interface PEPeerManager

hasDownloadablePiece

public boolean hasDownloadablePiece()

Specified by:

hasDownloadablePiece in interface PEPeerManager

getBytesQueuedForUpload

public int getBytesQueuedForUpload()

Specified by:

getBytesQueuedForUpload in interface PEPeerManager

getNbPeersWithUploadQueued

public int getNbPeersWithUploadQueued()

Specified by:

getNbPeersWithUploadQueued in interface PEPeerManager

getNbPeersWithUploadBlocked

public int getNbPeersWithUploadBlocked()

Specified by:

getNbPeersWithUploadBlocked in interface PEPeerManager

getNbPeersUnchoked

public int getNbPeersUnchoked()

Specified by:

getNbPeersUnchoked in interface PEPeerManager

getNbPeersUnchoking

public int getNbPeersUnchoking()

Specified by:

getNbPeersUnchoking in interface PEPeerManager

getNbPieces

public int getNbPieces()

Specified by:

getNbPieces in interface PEPeerManager

getPieces

public PEPiece[] getPieces()

Description copied from interface: PEPeerManager

Often better to use getPiece(pieceNumber)

Specified by:

getPieces in interface PEPeerManager

getPiece

public PEPiece getPiece(int pieceNumber)

Specified by:

getPiece in interface PEPeerManager

Returns:

PEPiece or null if piece not currently active

getStats

public PEPeerManagerStats getStats()

Specified by:

getStats in interface PEPeerManager

processTrackerResponse

public void processTrackerResponse(TRTrackerAnnouncerResponse response)

Specified by:

processTrackerResponse in interface PEPeerManager

getNbPeers

public int getNbPeers()

Specified by:

getNbPeers in interface PEPeerManager

getNbSeeds

public int getNbSeeds()

Specified by:

getNbSeeds in interface PEPeerManager

getPieceLength

public int getPieceLength(int pieceNumber)

Specified by:

getPieceLength in interface PEPeerManager

getRemaining

public long getRemaining()

Specified by:

getRemaining in interface PEPeerManager

getHiddenBytes

public long getHiddenBytes()

Specified by:

getHiddenBytes in interface PEPeerManager

getETA

public long getETA(boolean smoothed)

Specified by:

getETA in interface PEPeerManager

getElapsedTime

public String getElapsedTime()

Specified by:

getElapsedTime in interface PEPeerManager

getTimeStarted

public long getTimeStarted(boolean mono_time)

Specified by:

getTimeStarted in interface PEPeerManager

getTimeStartedSeeding

public long getTimeStartedSeeding(boolean mono_time)

Specified by:

getTimeStartedSeeding in interface PEPeerManager

addListener

public void addListener(PEPeerManagerListener l)

Specified by:

addListener in interface PEPeerManager

removeListener

public void removeListener(PEPeerManagerListener l)

Specified by:

removeListener in interface PEPeerManager

addPiece

public void addPiece(PEPiece piece,
 int pieceNumber,
 PEPeer for_peer)

Specified by:

addPiece in interface PEPeerManager

needsMD5CheckOnCompletion

public boolean needsMD5CheckOnCompletion(int pieceNumber)

Specified by:

needsMD5CheckOnCompletion in interface PEPeerManager

isSeeding

public boolean isSeeding()

Specified by:

isSeeding in interface PEPeerManager

isMetadataDownload

public boolean isMetadataDownload()

Specified by:

isMetadataDownload in interface PEPeerManager

getTorrentInfoDictSize

public int getTorrentInfoDictSize()

Specified by:

getTorrentInfoDictSize in interface PEPeerManager

setTorrentInfoDictSize

public void setTorrentInfoDictSize(int size)

Specified by:

setTorrentInfoDictSize in interface PEPeerManager

isSuperSeedMode

public boolean isSuperSeedMode()

Specified by:

isSuperSeedMode in interface PEPeerManager

canToggleSuperSeedMode

public boolean canToggleSuperSeedMode()

Specified by:

canToggleSuperSeedMode in interface PEPeerManager

setSuperSeedMode

public void setSuperSeedMode(boolean on)

Specified by:

setSuperSeedMode in interface PEPeerManager

seedPieceRecheck

public boolean seedPieceRecheck()

Specified by:

seedPieceRecheck in interface PEPeerManager

getNbRemoteTCPConnections

public int getNbRemoteTCPConnections()

Specified by:

getNbRemoteTCPConnections in interface PEPeerManager

getNbRemoteUDPConnections

public int getNbRemoteUDPConnections()

Specified by:

getNbRemoteUDPConnections in interface PEPeerManager

getNbRemoteUTPConnections

public int getNbRemoteUTPConnections()

Specified by:

getNbRemoteUTPConnections in interface PEPeerManager

getLastRemoteConnectionTime

public long getLastRemoteConnectionTime()

Specified by:

getLastRemoteConnectionTime in interface PEPeerManager

getMaxNewConnectionsAllowed

public int getMaxNewConnectionsAllowed(String network)

Specified by:

getMaxNewConnectionsAllowed in interface PEPeerManager

hasPotentialConnections

public boolean hasPotentialConnections()

Specified by:

hasPotentialConnections in interface PEPeerManager

dataBytesReceived

public void dataBytesReceived(PEPeer peer,
 long l)

Description copied from interface: PEPeerManager

Data bytes received.

Specified by:

dataBytesReceived in interface PEPeerManager

Parameters:

l -

dataBytesSent

public void dataBytesSent(PEPeer peer,
 long l)

Description copied from interface: PEPeerManager

Data bytes sent.

Specified by:

dataBytesSent in interface PEPeerManager

Parameters:

l -

protocolBytesSent

public void protocolBytesSent(PEPeer peer,
 long length)

Description copied from interface: PEPeerManager

Protocol bytes sent.

Specified by:

protocolBytesSent in interface PEPeerManager

Parameters:

length -

protocolBytesReceived

public void protocolBytesReceived(PEPeer peer,
 long length)

Description copied from interface: PEPeerManager

Protocol bytes received.

Specified by:

protocolBytesReceived in interface PEPeerManager

Parameters:

length -

discarded

public void discarded(PEPeer peer,
 int l)

Specified by:

discarded in interface PEPeerManager

createPeerStats

public PEPeerStats createPeerStats(PEPeer owner)

Specified by:

createPeerStats in interface PEPeerManager

getMyPeer

public PEPeer getMyPeer()

Specified by:

getMyPeer in interface PEPeerManager

getPeers

public List<PEPeer> getPeers()

Specified by:

getPeers in interface PEPeerManager

getPeers

public List<PEPeer> getPeers(String address)

Specified by:

getPeers in interface PEPeerManager

getPendingPeerCount

public int getPendingPeerCount()

Specified by:

getPendingPeerCount in interface PEPeerManager

getPendingPeers

public PeerDescriptor[] getPendingPeers()

Specified by:

getPendingPeers in interface PEPeerManager

getPendingPeers

public PeerDescriptor[] getPendingPeers(String address)

Specified by:

getPendingPeers in interface PEPeerManager

addPeer

public void addPeer(PEPeer peer)

Specified by:

addPeer in interface PEPeerManager

addPeer

public void addPeer(String ip_address,
 int tcp_port,
 int udp_port,
 boolean use_crypto,
 Map user_data)

Description copied from interface: PEPeerManager

Add a new peer, using the default internal PEPeer implementation (like for peers given in announce reply), using the given address and port.

Specified by:

addPeer in interface PEPeerManager

Parameters:

ip_address - of peer to inject

tcp_port - of peer to inject

udp_port - of peer to inject (0 if unknown)

use_crypto - use encrypted transport

peerDiscovered

public void peerDiscovered(String peer_source,
 String ip_address,
 int tcp_port,
 int udp_port,
 boolean use_crypto)

Specified by:

peerDiscovered in interface PEPeerManager

removePeer

public void removePeer(PEPeer peer)

removePeer

public void removePeer(PEPeer peer,
 String reason,
 int reason_code)

Specified by:

removePeer in interface PEPeerManager

peerAdded

public void peerAdded(PEPeer pc)

peerRemoved

public void peerRemoved(PEPeer pc)

createDiskManagerRequest

public DiskManagerReadRequest createDiskManagerRequest(int pieceNumber,
 int offset,
 int length)

Specified by:

createDiskManagerRequest in interface PEPeerManager

requestCanceled

public void requestCanceled(DiskManagerReadRequest item)

Specified by:

requestCanceled in interface PEPeerManager

requestAdded

public void requestAdded(PEPiece piece,
 PEPeerTransport peer,
 DiskManagerReadRequest request)

Specified by:

requestAdded in interface PEPeerControl

requestExists

public boolean requestExists(String peer_ip,
 int piece_number,
 int offset,
 int length)

Specified by:

requestExists in interface PEPeerManager

validatePieceReply

public boolean validatePieceReply(PEPeerTransport originator,
 int pieceNumber,
 int offset,
 DirectByteBuffer data)

Specified by:

validatePieceReply in interface PEPeerManager

writeBlock

public void writeBlock(int pieceNumber,
 int offset,
 DirectByteBuffer data,
 Object sender,
 boolean cancel)

Specified by:

writeBlock in interface PEPeerManager

isWritten

public boolean isWritten(int piece_number,
 int offset)

Specified by:

isWritten in interface PEPeerManager

isInEndGameMode

public boolean isInEndGameMode()

Description copied from interface: PEPeerManager

Are we in end-game mode?

Specified by:

isInEndGameMode in interface PEPeerManager

Returns:

true if in end game mode, false if not

peerConnectionClosed

public void peerConnectionClosed(PEPeerTransport peer,
 boolean connect_failed,
 boolean network_failed)

Description copied from interface: PEPeerManager

Notify the manager that the given peer connection has been closed.

Specified by:

peerConnectionClosed in interface PEPeerManager

Parameters:

peer - closed

createPeerExchangeConnection

public PeerExchangerItem createPeerExchangeConnection(PEPeerTransport base_peer)

Description copied from interface: PEPeerManager

Register a peer connection for peer exchange handling. NOTE: Creation could fail if the peer is not eligible for peer exchange (like if it's remote port is unknown).

Specified by:

createPeerExchangeConnection in interface PEPeerManager

Parameters:

base_peer - exchanging with

Returns:

peer database connection item, or null if creation failed

peerVerifiedAsSelf

public void peerVerifiedAsSelf(PEPeerTransport self)

Description copied from interface: PEPeerManager

Notify that the given peer connection represents our own client.

Specified by:

peerVerifiedAsSelf in interface PEPeerManager

Parameters:

self - peer

getUploadLimitedRateGroup

public LimitedRateGroup getUploadLimitedRateGroup()

Description copied from interface: PEPeerManager

Get the limited rate group used for upload limiting.

Specified by:

getUploadLimitedRateGroup in interface PEPeerManager

Returns:

upload limit group

getDownloadLimitedRateGroup

public LimitedRateGroup getDownloadLimitedRateGroup()

Description copied from interface: PEPeerManager

Get the limited rate group used for download limiting.

Specified by:

getDownloadLimitedRateGroup in interface PEPeerManager

Returns:

download limit group

getEffectiveUploadRateLimitBytesPerSecond

public int getEffectiveUploadRateLimitBytesPerSecond()

Specified by:

getEffectiveUploadRateLimitBytesPerSecond in interface PEPeerManager

getUploadRateLimitBytesPerSecond

public int getUploadRateLimitBytesPerSecond()

Specified by:

getUploadRateLimitBytesPerSecond in interface PEPeerManager

getDownloadRateLimitBytesPerSecond

public int getDownloadRateLimitBytesPerSecond()

Specified by:

getDownloadRateLimitBytesPerSecond in interface PEPeerManager

getData

public Object getData(String key)

Description copied from interface: PEPeerManager

To retreive arbitrary objects against this object.

Specified by:

getData in interface PEPeerManager

setData

public void setData(String key,
 Object value)

Description copied from interface: PEPeerManager

To store arbitrary objects against this object.

Specified by:

setData in interface PEPeerManager

getAverageCompletionInThousandNotation

public int getAverageCompletionInThousandNotation()

Description copied from interface: PEPeerManager

Get the average completion percentage of connected peers.

Specified by:

getAverageCompletionInThousandNotation in interface PEPeerManager

Returns:

average percent complete in thousand notation

getMaxCompletionInThousandNotation

public int getMaxCompletionInThousandNotation(boolean never_include_seeds)

Description copied from interface: PEPeerManager

Max completion of connected peers (doesn't factor in our completion)

Specified by:

getMaxCompletionInThousandNotation in interface PEPeerManager

Returns:

getTransportFromIdentity

public PEPeerTransport getTransportFromIdentity(byte[] peer_id)

Description copied from interface: PEPeerManager

Locate an existing transport via peer id byte identity.

Specified by:

getTransportFromIdentity in interface PEPeerManager

Parameters:

peer_id - to look for

Returns:

transport with matching identity, or null if no match is found

getTransportFromAddress

public PEPeerTransport getTransportFromAddress(String peer)

Description copied from interface: PEPeerManager

Locate an existing transport via [IP] Address.

Specified by:

getTransportFromAddress in interface PEPeerManager

Parameters:

peer - String to look for

Returns:

PEPeerTransport with matching address String, or null if no match is found

getPreferUDP

public boolean getPreferUDP()

Specified by:

getPreferUDP in interface PEPeerManager

setPreferUDP

public void setPreferUDP(boolean prefer)

Specified by:

setPreferUDP in interface PEPeerManager

addRateLimiter

public void addRateLimiter(LimitedRateGroup group,
 boolean upload)

Specified by:

addRateLimiter in interface PEPeerManager

removeRateLimiter

public void removeRateLimiter(LimitedRateGroup group,
 boolean upload)

Specified by:

removeRateLimiter in interface PEPeerManager

getTrackerPeerSource

public TrackerPeerSource getTrackerPeerSource()

Specified by:

getTrackerPeerSource in interface PEPeerManager

isPeerSourceEnabled

public boolean isPeerSourceEnabled(String peer_source)

Specified by:

isPeerSourceEnabled in interface PEPeerManager

isNetworkEnabled

public boolean isNetworkEnabled(String network)

Specified by:

isNetworkEnabled in interface PEPeerManager

getPartitionID

public int getPartitionID()

Specified by:

getPartitionID in interface PEPeerManager

setMaskDownloadCompletion

public void setMaskDownloadCompletion(Boolean mask)

Specified by:

setMaskDownloadCompletion in interface PEPeerManager

removeAllPeers

public void removeAllPeers(String reason,
 int reason_code)

Specified by:

removeAllPeers in interface PEPeerManager

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface PEPeerManager

generateEvidence

public void generateEvidence(IndentWriter writer)

Specified by:

generateEvidence in interface PEPeerManager

setStatsReceiver

public void setStatsReceiver(PEPeerManager.StatsReceiver receiver)

Specified by:

setStatsReceiver in interface PEPeerManager

validateReadRequest

public boolean validateReadRequest(PEPeerTransport originator,
 int pieceNumber,
 int offset,
 int length)

Specified by:

validateReadRequest in interface PEPeerControl

validateHintRequest

public boolean validateHintRequest(PEPeerTransport originator,
 int pieceNumber,
 int offset,
 int length)

Specified by:

validateHintRequest in interface PEPeerControl

havePiece

public void havePiece(int pieceNumber,
 int pieceLength,
 PEPeer pcOrigin)

Specified by:

havePiece in interface PEPeerControl

updateSuperSeedPiece

public void updateSuperSeedPiece(PEPeer peer,
 int pieceNumber)

Specified by:

updateSuperSeedPiece in interface PEPeerControl

getTCPListeningPortNumber

public int getTCPListeningPortNumber()

Specified by:

getTCPListeningPortNumber in interface PEPeerControl

getTargetHash

public byte[] getTargetHash()

Description copied from interface: PEPeerControl

Get torrent hash including any overrides

Specified by:

getTargetHash in interface PEPeerControl

Returns:

isPrivateTorrent

public boolean isPrivateTorrent()

Specified by:

isPrivateTorrent in interface PEPeerControl

getExtendedMessagingMode

public int getExtendedMessagingMode()

Specified by:

getExtendedMessagingMode in interface PEPeerControl

isPeerExchangeEnabled

public boolean isPeerExchangeEnabled()

Specified by:

isPeerExchangeEnabled in interface PEPeerControl

getSecrets

public byte[][] getSecrets(int crypto_level)

Specified by:

getSecrets in interface PEPeerControl

getUploadPriority

public int getUploadPriority()

Specified by:

getUploadPriority in interface PEPeerControl

getHiddenPiece

public int getHiddenPiece()

Specified by:

getHiddenPiece in interface PEPeerManager

addPeerTransport

public void addPeerTransport(PEPeerTransport transport)

Specified by:

addPeerTransport in interface PEPeerControl

getConnectTimeout

public int getConnectTimeout(int ct_def)

Specified by:

getConnectTimeout in interface PEPeerControl

getMaxConnections

public int[] getMaxConnections()

Specified by:

getMaxConnections in interface PEPeerControl

doOptimisticDisconnect

public boolean doOptimisticDisconnect(boolean pending_lan_local_peer,
 boolean force,
 String network)

Specified by:

doOptimisticDisconnect in interface PEPeerControl

getNbActivePieces

public int getNbActivePieces()

Specified by:

getNbActivePieces in interface PEPeerControl

getNbPeersStalledPendingLoad

public int getNbPeersStalledPendingLoad()

Specified by:

getNbPeersStalledPendingLoad in interface PEPeerControl

incNbPeersSnubbed

public void incNbPeersSnubbed()

Specified by:

incNbPeersSnubbed in interface PEPeerControl

decNbPeersSnubbed

public void decNbPeersSnubbed()

Specified by:

decNbPeersSnubbed in interface PEPeerControl

setNbPeersSnubbed

public void setNbPeersSnubbed(int n)

Specified by:

setNbPeersSnubbed in interface PEPeerControl

getNbPeersSnubbed

public int getNbPeersSnubbed()

Specified by:

getNbPeersSnubbed in interface PEPeerControl

checkSnubbing

public void checkSnubbing(PEPeerTransport peer)

Specified by:

checkSnubbing in interface PEPeerControl

badPieceReported

public void badPieceReported(PEPeerTransport originator,
 int piece_number)

Specified by:

badPieceReported in interface PEPeerControl

isFastExtensionPermitted

public boolean isFastExtensionPermitted(PEPeerTransport originator)

Specified by:

isFastExtensionPermitted in interface PEPeerControl

reportBadFastExtensionUse

public void reportBadFastExtensionUse(PEPeerTransport originator)

Specified by:

reportBadFastExtensionUse in interface PEPeerControl

statsRequest

public void statsRequest(PEPeerTransport originator,
 Map request)

Specified by:

statsRequest in interface PEPeerControl

statsReply

public void statsReply(PEPeerTransport originator,
 Map reply)

Specified by:

statsReply in interface PEPeerControl

isRTA

public boolean isRTA()

Specified by:

isRTA in interface PEPeerControl

peerDiscovered

public void peerDiscovered(PEPeerTransport finder,
 PeerItem pi)

Specified by:

peerDiscovered in interface PEPeerControl

getHashHandler

public PEPeerControlHashHandler getHashHandler()

Specified by:

getHashHandler in interface PEPeerControl

isHolePunchOperationOK

public boolean isHolePunchOperationOK(PEPeerTransport peer,
 boolean is_connect)

Specified by:

isHolePunchOperationOK in interface PEPeerControl

handleCloseReason

public void handleCloseReason(PEPeerTransport peer,
 boolean reason_out,
 int reason)

Specified by:

handleCloseReason in interface PEPeerControl

log

private void log()