Interface PEPeerControl

All Superinterfaces:

PEPeerManager

All Known Implementing Classes:

PeerManager.PeerManagerRegistrationImpl.ProbeControl, PEPeerControlImpl

public interface PEPeerControl
extends PEPeerManager

Nested Class Summary

Nested classes/interfaces inherited from interface PEPeerManager

PEPeerManager.StatsReceiver

Field Summary

Fields

Modifier and Type	Field	Description
static final int	SNUB_MILLIS
static final boolean	TEST_PERMIT_PEER_CONNECTIONS

Method Summary

Modifier and Type	Method	Description
void	addPeerTransport(PEPeerTransport transport)
void	badPieceReported(PEPeerTransport originator, int piece_number)
void	checkSnubbing(PEPeerTransport peer)
void	decNbPeersSnubbed()
boolean	doOptimisticDisconnect(boolean pending_lan_local_peer, boolean force, String network)
int	getConnectTimeout(int ct_def)
int	getExtendedMessagingMode()
PEPeerControlHashHandler	getHashHandler()
int[]	getMaxConnections()
int	getNbActivePieces()
int	getNbPeersSnubbed()
int	getNbPeersStalledPendingLoad()
byte[][]	getSecrets(int crypto_level)
byte[]	getTargetHash()	Get torrent hash including any overrides
int	getTCPListeningPortNumber()
int	getUploadPriority()
void	handleCloseReason(PEPeerTransport peer, boolean reason_outgoing, int reason)
void	havePiece(int pieceNumber, int pieceLength, PEPeer pcOrigin)
void	incNbPeersSnubbed()
boolean	isFastExtensionPermitted(PEPeerTransport originator)
boolean	isHolePunchOperationOK(PEPeerTransport peer, boolean is_connect)
boolean	isPeerExchangeEnabled()
boolean	isPrivateTorrent()
boolean	isRTA()
void	peerDiscovered(PEPeerTransport finder, PeerItem pi)
void	reportBadFastExtensionUse(PEPeerTransport originator)
void	requestAdded(PEPiece piece, PEPeerTransport peer, DiskManagerReadRequest request)
void	setNbPeersSnubbed(int n)
void	statsReply(PEPeerTransport originator, Map reply)
void	statsRequest(PEPeerTransport originator, Map request)
void	updateSuperSeedPiece(PEPeer peer, int pieceNumber)
boolean	validateHintRequest(PEPeerTransport originator, int pieceNumber, int offset, int length)
boolean	validateReadRequest(PEPeerTransport originator, int pieceNumber, int offset, int length)

Methods inherited from interface PEPeerManager

addListener, addPeer, addPeer, addPiece, addRateLimiter, canToggleSuperSeedMode, createDiskManagerRequest, createPeerExchangeConnection, createPeerStats, dataBytesReceived, dataBytesSent, discarded, generateEvidence, getAdapter, getAvailability, getAvailability, getAvailWentBadTime, getAverageCompletionInThousandNotation, getAvgAvail, getBytesQueuedForUpload, getBytesUnavailable, getConnectHealth, getData, getDiskManager, getDisplayName, getDownloadLimitedRateGroup, getDownloadRateLimitBytesPerSecond, getEffectiveUploadRateLimitBytesPerSecond, getElapsedTime, getETA, getHash, getHiddenBytes, getHiddenPiece, getLastRemoteConnectionTime, getMaxCompletionInThousandNotation, getMaxNewConnectionsAllowed, getMinAvailability, getMinAvailability, getMyPeer, getNbPeers, getNbPeersUnchoked, getNbPeersUnchoking, getNbPeersWithUploadBlocked, getNbPeersWithUploadQueued, getNbPieces, getNbRemoteTCPConnections, getNbRemoteUDPConnections, getNbRemoteUTPConnections, getNbSeeds, getPartitionID, getPeerId, getPeerIdentityDataID, getPeers, getPeers, getPendingPeerCount, getPendingPeers, getPendingPeers, getPiece, getPieceLength, getPiecePicker, getPieces, getPreferUDP, getRemaining, getStats, getTimeStarted, getTimeStartedSeeding, getTorrentInfoDictSize, getTrackerPeerSource, getTransportFromAddress, getTransportFromIdentity, getUID, getUploadLimitedRateGroup, getUploadRateLimitBytesPerSecond, hasDownloadablePiece, hasPotentialConnections, informFullyConnected, isDestroyed, isInEndGameMode, isMetadataDownload, isNetworkEnabled, isPeerSourceEnabled, isSeeding, isSuperSeedMode, isWritten, needsMD5CheckOnCompletion, peerConnectionClosed, peerDiscovered, peerVerifiedAsSelf, processTrackerResponse, protocolBytesReceived, protocolBytesSent, removeAllPeers, removeListener, removePeer, removePeer, removeRateLimiter, requestCanceled, requestExists, seedPieceRecheck, setData, setMaskDownloadCompletion, setPreferUDP, setStatsReceiver, setSuperSeedMode, setTorrentInfoDictSize, start, stopAll, validatePieceReply, writeBlock

Field Details

TEST_PERMIT_PEER_CONNECTIONS

static final boolean TEST_PERMIT_PEER_CONNECTIONS

See Also:

• Constant Field Values

SNUB_MILLIS

static final int SNUB_MILLIS

See Also:

• Constant Field Values

Method Details

validateReadRequest

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

validateHintRequest

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

requestAdded

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

havePiece

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

updateSuperSeedPiece

void updateSuperSeedPiece(PEPeer peer,
 int pieceNumber)

getTCPListeningPortNumber

int getTCPListeningPortNumber()

getTargetHash

byte[] getTargetHash()

Get torrent hash including any overrides

Returns:

isPrivateTorrent

boolean isPrivateTorrent()

getExtendedMessagingMode

int getExtendedMessagingMode()

isPeerExchangeEnabled

boolean isPeerExchangeEnabled()

getSecrets

byte[][] getSecrets(int crypto_level)

getUploadPriority

int getUploadPriority()

addPeerTransport

void addPeerTransport(PEPeerTransport transport)

getConnectTimeout

int getConnectTimeout(int ct_def)

getMaxConnections

int[] getMaxConnections()

doOptimisticDisconnect

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

getNbActivePieces

int getNbActivePieces()

getNbPeersStalledPendingLoad

int getNbPeersStalledPendingLoad()

incNbPeersSnubbed

void incNbPeersSnubbed()

decNbPeersSnubbed

void decNbPeersSnubbed()

setNbPeersSnubbed

void setNbPeersSnubbed(int n)

getNbPeersSnubbed

int getNbPeersSnubbed()

checkSnubbing

void checkSnubbing(PEPeerTransport peer)

badPieceReported

void badPieceReported(PEPeerTransport originator,
 int piece_number)

isFastExtensionPermitted

boolean isFastExtensionPermitted(PEPeerTransport originator)

reportBadFastExtensionUse

void reportBadFastExtensionUse(PEPeerTransport originator)

statsRequest

void statsRequest(PEPeerTransport originator,
 Map request)

statsReply

void statsReply(PEPeerTransport originator,
 Map reply)

isRTA

boolean isRTA()

peerDiscovered

void peerDiscovered(PEPeerTransport finder,
 PeerItem pi)

getHashHandler

PEPeerControlHashHandler getHashHandler()

isHolePunchOperationOK

boolean isHolePunchOperationOK(PEPeerTransport peer,
 boolean is_connect)

handleCloseReason

void handleCloseReason(PEPeerTransport peer,
 boolean reason_outgoing,
 int reason)