Class PEPeerControlImpl

java.lang.Object

com.biglybt.core.logging.LogRelation

com.biglybt.core.peer.impl.control.PEPeerControlImpl

All Implemented Interfaces:

DiskManagerCheckRequestListener, DiskManagerWriteRequestListener, IPFilterListener, PEPeerControl, PEPeerManager, PeerControlInstance, PeerNATInitiator

public class PEPeerControlImpl
extends LogRelation
implements PEPeerControl, DiskManagerWriteRequestListener, PeerControlInstance, PeerNATInitiator, DiskManagerCheckRequestListener, IPFilterListener

manages all peer transports for a torrent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	PEPeerControlImpl.MyPeer
private class	PEPeerControlImpl.MyPeerStats
(package private) static interface	PEPeerControlImpl.PeerCacheKey
(package private) static class	PEPeerControlImpl.PeerNonPublicCacheKey
(package private) static class	PEPeerControlImpl.PeerResolvedCacheKey
(package private) static class	PEPeerControlImpl.PeerUnresolvedCacheKey

Nested classes/interfaces inherited from interface DiskManagerCheckRequestListener

DiskManagerCheckRequestListener.HashListener

Nested classes/interfaces inherited from interface PEPeerManager

PEPeerManager.StatsReceiver

Field Summary

Fields

Modifier and Type	Field	Description
private Average	_averageReceptionSpeed
private PeerIdentityDataID	_hash
private final byte[]	_myPeerId
private final int	_nbPieces
private int	_peers
private int	_remotesTCPNoLan
private int	_remotesUDPNoLan
private int	_remotesUTPNoLan
private int	_seeds
private PEPeerManagerStatsImpl	_stats
private int	_tcp_peers_transfering
private int	_tcpConnectingConnections
private int	_tcpPendingConnections
private long	_timeFinished_mono
private long	_timeStarted
private long	_timeStarted_mono
private long	_timeStartedSeeding
private long	_timeStartedSeeding_mono
protected final PEPeerManagerAdapter	adapter
private boolean	asfe_activated
(package private) static Set<String>	auto_sequential_file_exts
private int	bad_piece_reported
private static int	ban_peer_discard_min_kb
private static float	ban_peer_discard_ratio
private int	bytes_queued_for_upload
private static final int	CHECK_REASON_BAD_PIECE_CHECK
private static final int	CHECK_REASON_COMPLETE
private static final int	CHECK_REASON_DOWNLOADED
private static final int	CHECK_REASON_SCAN
private static final int	CHECK_REASON_SEEDING_CHECK
private static final Object	CON_HEALTH_DONE_KEY
private final Map<PEPeerControlImpl.PeerCacheKey, Long>	connect_fail_history
private static final int	CONNECT_FAIL_HISTORY_MAX
private int	connections_unchoked
private int	connections_unchoking
private int	connections_with_queued_data
private int	connections_with_queued_data_blocked
private final DiskManager	disk_mgr
private final DiskManagerPiece[]	dm_pieces
private boolean	download_diabled
private final LimitedRateGroup	download_limited_rate_group
private static int	dual_ipv4_ipv6_connection_action
private static final Object	DUP_PEER_AS_KEY
private static final Object	DUP_PEER_CC_KEY
private static boolean	enable_seeding_piece_rechecks
private List<Object[]>	external_rate_limiters_cow
private static boolean	fast_unchoke_new_peers
private static final int	FE_EVENT_LIMIT
private DiskManager.DownloadEndedProgress	finish_in_progress
private static boolean	global_disconnect_seeds_when_seeding
private static boolean	global_hide_a_piece
private boolean	global_hide_a_piece_cached
private static boolean	global_hide_a_piece_ds
private final PEPeerControlHashHandler	hash_handler
private int	hidden_piece
private BloomFilter	hp_bloom
private static final int	HP_BLOOM_FILTER_SIZE
private static boolean	ignore_v4
private static boolean	ignore_v6
private static final IpFilter	ip_filter
private long	ip_filter_last_update_time
private boolean	is_destroyed
private final boolean	is_metadata_download
private final boolean	is_private_torrent
private boolean	is_running
private long	last_eta
private long	last_eta_calculation
private long	last_eta_smoothed
private long	last_remote_time
private long	last_seed_disconnect_time
private long	last_udp_reconnect_mono
private long	lastNeededUndonePieceChange
private Boolean	local_hide_a_piece_opt
private static final LogIDs	LOGID
private static final int	MAINLOOP_FIVE_MINUTE_INTERVAL
private static final int	MAINLOOP_FIVE_SECOND_INTERVAL
private long	mainloop_loop_count
private static final int	MAINLOOP_ONE_SECOND_INTERVAL
private static final int	MAINLOOP_SIXTY_SECOND_INTERVAL
private static final int	MAINLOOP_TEN_MINUTE_INTERVAL
private static final int	MAINLOOP_TEN_SECOND_INTERVAL
private static final int	MAINLOOP_THIRTY_SECOND_INTERVAL
private static final int	MAINLOOP_TWENTY_SECOND_INTERVAL
private static final int	MAX_UDP_CONNECTIONS
private static final int	MAX_UDP_TRAVERSAL_COUNT
private int	metadata_infodict_size
private final PEPeerControlImpl.MyPeer	my_peer
private final BloomFilter	naughty_fast_extension_bloom
private long	nbBytesRemaining
private int	nbPeersSnubbed
private int	nbPiecesActive
private static final NetworkAdmin	network_admin
private int	next_rescan_piece
private int	nextPEXSweepIndex
private int[]	ob_ps_stats
private boolean[][]	ob_ps_stats_history
private static final int	OB_PS_STATS_HISTORY_SIZE
private int[]	ob_ps_stats_pos
private int	optimisticDisconnectCount
private final Map<PEPeerControlImpl.PeerCacheKey, Integer>	outbound_ignore_addresses
private static final int	OUTBOUND_IGNORE_ADDRESSES_MAX
private int	outbound_message_count
private final int	partition_id
private final PeerDatabase	peer_database
private ArrayList<PEPeerManagerListener>	peer_manager_listeners_cow
private static final String	PEER_NAT_TRAVERSE_DONE_KEY
private ArrayList<PEPeerTransport>	peer_transports_cow
private final AEMonitor	peer_transports_mon
private static final int	PENDING_HOLE_PUNCH_MAX
private final Map<String,Object[]>	pending_hole_punches
private static final int	PENDING_NAT_TRAVERSAL_MAX
private final Map<String, PEPeerTransport>	pending_nat_traversals
private final PEPieceImpl[]	pePieces
private final List<Object[]>	piece_check_result_list
private final AEMonitor	piece_check_result_list_mon
private final PiecePicker	piecePicker
private final int	pm_uuid
private boolean	prefer_udp
private BloomFilter	prefer_udp_bloom
private static final int	PREFER_UDP_BLOOM_SIZE
private static boolean	prefer_udp_default
private static final int	RECONNECT_DOWNLOADING_MIN
private static final int	RECONNECT_SEEDING_MIN
private static final long	REQ_TIMEOUT_DATA_AGE_LEECH_MILLIS
private static final long	REQ_TIMEOUT_DATA_AGE_SEED_MILLIS
private static final long	REQ_TIMEOUT_OLDEST_REQ_AGE_MILLIS
private long	rescan_piece_time
private static final long	RESERVED_PIECE_TIMEOUT_MILLIS
private boolean	restart_initiated
private static final int	SEED_CHECK_WAIT_MARKER
private boolean	seeding_mode	literally seeding as in 100% torrent complete
private static int	stalled_piece_timeout
private PEPeerManager.StatsReceiver	stats_receiver
private int	stats_tick_count
private boolean	superSeedMode
private int	superSeedModeCurrentPiece
private int	superSeedModeNumberOfAnnounces
private SuperSeedPiece[]	superSeedPieces
private List<PEPeerTransport>	sweepList
private static final boolean	TEST_PERIODIC_SEEDING_SCAN_FAIL_HANDLING
private final AEMonitor	this_mon
private final TOTorrent	torrent
private static boolean	udp_fallback_for_dropped_connection
private static boolean	udp_fallback_for_failed_connection
private static boolean	udp_probe_enabled
private static final int	UDP_RECONNECT_MAX
private static final int	UDP_RECONNECT_MIN_MILLIS
private final Map<String, PEPeerTransport>	udp_reconnects
private int	udp_traversal_count
private Unchoker	unchoker
private boolean	upload_diabled
private final UploadHelper	upload_helper
private final LimitedRateGroup	upload_limited_rate_group
private Map<Object,Object>	user_data
private static final AtomicInteger	UUID_GEN
private static final int	WARNINGS_LIMIT

Fields inherited from interface PEPeerControl

SNUB_MILLIS, TEST_PERMIT_PEER_CONNECTIONS

Constructor Summary

Constructors

Constructor	Description
PEPeerControlImpl(byte[] _peer_id, PEPeerManagerAdapter _adapter, DiskManager _diskManager, int _partition_id)

Method Summary

Modifier and Type	Method	Description
private boolean	addBan(String ip, String reason)
private void	addExtendedPeersFromTracker(Map extensions)
private void	addFastUnchokes(ArrayList peers_to_unchoke)
void	addListener(PEPeerManagerListener l)
void	addPeer(PEPeer _transport)
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.
private void	addPeersFromTracker(TRTrackerAnnouncerResponsePeer[] peers)
void	addPeerTransport(PEPeerTransport transport)
protected void	addPiece(PEPiece piece, int pieceNumber, boolean force_add, PEPeer for_peer)
void	addPiece(PEPiece piece, int pieceNumber, PEPeer for_peer)	Don't pass a null to this method.
void	addRateLimiter(LimitedRateGroup group, boolean upload)
private void	addToPeerTransports(PEPeerTransport peer)
private int	addWarning(String ip, PEPeerTransport peer)
private void	analyseTrackerResponse(TRTrackerAnnouncerResponse tracker_response)	A private method that does analysis of the result sent by the tracker.
private void	badPeerDetected(String ip, int piece_number, String reason)
void	badPieceReported(PEPeerTransport originator, int piece_number)
boolean	canIPBeBanned(String ip)
boolean	canIPBeBlocked(String ip, byte[] torrent_hash)
boolean	canToggleSuperSeedMode()
private void	check99PercentBug()
private void	checkAutoSequentialFiles(DiskManagerFileInfo done_file)
private void	checkBadPieces()
void	checkCancelled(DiskManagerCheckRequest request)
void	checkCompleted(DiskManagerCheckRequest request, boolean passed)
private void	checkCompletedPieces()	A private method that checks if PEPieces being downloaded are finished If all blocks from a PEPiece are written to disk, this method will queue the piece for hash check.
protected void	checkCompletionState()
private boolean	checkEmptyPiece(int pieceNumber)	Checks given piece to see if it's active but empty, and if so deactivates it.
void	checkFailed(DiskManagerCheckRequest request, Throwable cause)
private void	checkFinished(boolean start_of_day)	This method checks if the downloading process is finished.
private void	checkForBannedConnections()
private void	checkInterested()
private void	checkRequests()	This method will locate expired requests on peers, will cancel them, and mark the peer as snubbed if we haven't received useful data from them within the last 60 seconds
private void	checkRescan()
private void	checkSeeds()
void	checkSnubbing(PEPeerTransport peer)
private void	checkSpeedAndReserved()	Check if a piece's Speed is too fast for it to be getting new data and if a reserved pieced failed to get data within 120 seconds
private void	closeAndRemoveAllPeers(String reason, int reason_code, boolean reconnect)
private void	closeAndRemovePeer(PEPeerTransport peer, String reason, int reason_code, boolean log_if_not_found)
private byte[]	computeMd5Hash(DirectByteBuffer buffer)
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 length)	Data bytes received.
void	dataBytesSent(PEPeer peer, long length)	Data bytes sent.
void	decNbPeersSnubbed()
void	discarded(PEPeer peer, int length)
private boolean	disconnectSeedsWhenSeeding()
private void	doConnectionChecks()
boolean	doOptimisticDisconnect(boolean pending_lan_local_peer, boolean force, String network)
private void	doTCPConnectionChecks(int number)
private void	doUDPConnectionChecks(int number)
private void	doUnchokes()	Do all peer choke/unchoke processing.
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)
PEPeerControl	getControl()
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)	Returns the ETA time in seconds.
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()
private int	getMaxConnections(String net)
private int[]	getMaxNewConnectionsAllowed()	returns number of whatever peers to connect and then extra ones that must be non-pub if available
int	getMaxNewConnectionsAllowed(String network)	returns the allowed connections for the given network -1 -> unlimited
int[]	getMaxSeedConnections()
private int	getMaxSeedConnections(String net)
float	getMinAvailability()
float	getMinAvailability(int file_index)
PEPeer	getMyPeer()
String	getName()
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()
int[]	getPeerCount()
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[]	getPieceCount()
int	getPieceLength(int pieceNumber)
PiecePicker	getPiecePicker()
PEPiece[]	getPieces()	Often better to use getPiece(pieceNumber)
boolean	getPreferUDP()
Object[]	getQueryableInterfaces()	Query this class for a reference to another class that it may hold
String	getRelationText()	A short description of what your class holds that can be printed by the logger
long	getRemaining()
int	getSchedulePriority()
byte[][]	getSecrets(int crypto_level)
PEPeerManagerStats	getStats()
byte[]	getTargetHash()	Get torrent hash including any overrides
int	getTCPListeningPortNumber()
long	getTimeStarted(boolean mono)
long	getTimeStartedSeeding(boolean mono)
protected byte[]	getTorrentHash()
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_outgoing, int reason)
private void	handleFilePriorityChanged()
boolean	hasDownloadablePiece()
boolean	hashRequest(int piece_number, DiskManagerCheckRequestListener.HashListener listener)
boolean	hasPotentialConnections()
void	havePiece(int pieceNumber, int pieceLength, PEPeer pcOrigin)
void	incNbPeersSnubbed()
void	informFullyConnected(PEPeer peer)
private void	initHiddenPiece()
private void	initialiseSuperSeedMode()
void	IPBanned(BannedIp ip)
void	IPBlockedListChanged(IpFilter filter)
void	IPFilterEnabledChanged(boolean is_enabled)
private boolean	isAlreadyConnected(PeerItem peer_id)
private boolean	isBlocked(PEPeerTransport peer, String name, byte[] hash)
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 net)
boolean	isPeerExchangeEnabled()
boolean	isPeerSourceEnabled(String peer_source)
boolean	isPrivateTorrent()
boolean	isRTA()
boolean	isSeeding()
boolean	isSuperSeedMode()
private boolean	isUploadOnly()
boolean	isWritten(int piece_number, int offset)
private String	makeNewOutgoingConnection(String peer_source, String address, int tcp_port, int udp_port, boolean use_tcp, boolean require_crypto, byte crypto_level, Map user_data)	Request a new outgoing peer connection.
private void	MD5CheckPiece(PEPiece piece, boolean correct)
boolean	needsMD5CheckOnCompletion(int pieceNumber)
private void	peerAdded(PEPeerTransport 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)
private void	peerRemoved(PEPeerTransport pc)
void	peerVerifiedAsSelf(PEPeerTransport self)	Notify that the given peer connection represents our own client.
private void	processPieceCheckResult(DiskManagerCheckRequest request, int outcome)
private void	processPieceChecks()	Private method to process the results given by DiskManager's piece checking thread via asyncPieceChecked(..)
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 _transport, String reason, int reason_code)
void	removePiece(PEPiece pePiece, int pieceNumber)	Sends messages to listeners that the piece is no longer active.
void	removeRateLimiter(LimitedRateGroup group, boolean upload)
void	reportBadFastExtensionUse(PEPeerTransport originator)
void	requestAdded(PEPiece piece, PEPeerTransport peer, DiskManagerReadRequest request)
void	requestCanceled(DiskManagerReadRequest request)	The way to unmark a request as being downloaded, or also called by Peer connections objects when connection is closed or choked
boolean	requestExists(String peer_ip, int piece_number, int offset, int length)
void	schedule()
boolean	seedPieceRecheck()
private void	sendHave(int pieceNumber)
void	setData(String key, Object value)	To store arbitrary objects against a control.
void	setMaskDownloadCompletion(Boolean mask)
void	setNbPeersSnubbed(int n)
void	setPreferUDP(boolean prefer)
void	setStatsReceiver(PEPeerManager.StatsReceiver receiver)
void	setSuperSeedMode(boolean _superSeedMode)
void	setTorrentInfoDictSize(int size)
void	start()
void	statsReply(PEPeerTransport originator, Map reply)
void	statsRequest(PEPeerTransport originator, Map request)
void	stopAll()
private void	updateConnectHealth(PEPeerTransport pc)
private void	updatePeersInSuperSeedMode()
private void	updateStats()
void	updateSuperSeedPiece(PEPeer peer, int pieceNumber)
private void	updateTrackerAnnounceInterval()
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)	This method will queue up a dism manager write request for the block if the block is not already written.
void	writeCompleted(DiskManagerWriteRequest request)	DiskManagerWriteRequestListener message
void	writeFailed(DiskManagerWriteRequest request, Throwable cause)

Methods inherited from class LogRelation

propogatedRelationText, queryForClass

Methods inherited from class Object

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

Methods inherited from interface DiskManagerCheckRequestListener

isFailureInteresting

Methods inherited from interface IPFilterListener

IPBanListChanged

Methods inherited from interface PEPeerManager

removePeer

Field Details

LOGID

private static final LogIDs LOGID

TEST_PERIODIC_SEEDING_SCAN_FAIL_HANDLING

private static final boolean TEST_PERIODIC_SEEDING_SCAN_FAIL_HANDLING

See Also:

• Constant Field Values

WARNINGS_LIMIT

private static final int WARNINGS_LIMIT

See Also:

• Constant Field Values

CHECK_REASON_DOWNLOADED

private static final int CHECK_REASON_DOWNLOADED

See Also:

• Constant Field Values

CHECK_REASON_COMPLETE

private static final int CHECK_REASON_COMPLETE

See Also:

• Constant Field Values

CHECK_REASON_SCAN

private static final int CHECK_REASON_SCAN

See Also:

• Constant Field Values

CHECK_REASON_SEEDING_CHECK

private static final int CHECK_REASON_SEEDING_CHECK

See Also:

• Constant Field Values

CHECK_REASON_BAD_PIECE_CHECK

private static final int CHECK_REASON_BAD_PIECE_CHECK

See Also:

• Constant Field Values

SEED_CHECK_WAIT_MARKER

private static final int SEED_CHECK_WAIT_MARKER

See Also:

• Constant Field Values

REQ_TIMEOUT_DATA_AGE_SEED_MILLIS

private static final long REQ_TIMEOUT_DATA_AGE_SEED_MILLIS

See Also:

• Constant Field Values

REQ_TIMEOUT_DATA_AGE_LEECH_MILLIS

private static final long REQ_TIMEOUT_DATA_AGE_LEECH_MILLIS

See Also:

• Constant Field Values

REQ_TIMEOUT_OLDEST_REQ_AGE_MILLIS

private static final long REQ_TIMEOUT_OLDEST_REQ_AGE_MILLIS

See Also:

• Constant Field Values

RESERVED_PIECE_TIMEOUT_MILLIS

private static final long RESERVED_PIECE_TIMEOUT_MILLIS

See Also:

• Constant Field Values

CON_HEALTH_DONE_KEY

private static final Object CON_HEALTH_DONE_KEY

DUP_PEER_CC_KEY

private static final Object DUP_PEER_CC_KEY

DUP_PEER_AS_KEY

private static final Object DUP_PEER_AS_KEY

global_disconnect_seeds_when_seeding

private static boolean global_disconnect_seeds_when_seeding

enable_seeding_piece_rechecks

private static boolean enable_seeding_piece_rechecks

stalled_piece_timeout

private static int stalled_piece_timeout

fast_unchoke_new_peers

private static boolean fast_unchoke_new_peers

ban_peer_discard_ratio

private static float ban_peer_discard_ratio

ban_peer_discard_min_kb

private static int ban_peer_discard_min_kb

udp_fallback_for_failed_connection

private static boolean udp_fallback_for_failed_connection

udp_fallback_for_dropped_connection

private static boolean udp_fallback_for_dropped_connection

udp_probe_enabled

private static boolean udp_probe_enabled

global_hide_a_piece

private static boolean global_hide_a_piece

global_hide_a_piece_ds

private static boolean global_hide_a_piece_ds

prefer_udp_default

private static boolean prefer_udp_default

dual_ipv4_ipv6_connection_action

private static int dual_ipv4_ipv6_connection_action

auto_sequential_file_exts

static volatile Set<String> auto_sequential_file_exts

network_admin

private static final NetworkAdmin network_admin

ignore_v4

private static volatile boolean ignore_v4

ignore_v6

private static volatile boolean ignore_v6

ip_filter

private static final IpFilter ip_filter

UUID_GEN

private static final AtomicInteger UUID_GEN

pm_uuid

private final int pm_uuid

is_running

private volatile boolean is_running

is_destroyed

private volatile boolean is_destroyed

peer_transports_cow

private volatile ArrayList<PEPeerTransport> peer_transports_cow

peer_transports_mon

private final AEMonitor peer_transports_mon

adapter

protected final PEPeerManagerAdapter adapter

torrent

private final TOTorrent torrent

disk_mgr

private final DiskManager disk_mgr

dm_pieces

private final DiskManagerPiece[] dm_pieces

is_private_torrent

private final boolean is_private_torrent

stats_receiver

private PEPeerManager.StatsReceiver stats_receiver

piecePicker

private final PiecePicker piecePicker

lastNeededUndonePieceChange

private long lastNeededUndonePieceChange

seeding_mode

private boolean seeding_mode

literally seeding as in 100% torrent complete

restart_initiated

private boolean restart_initiated

_nbPieces

private final int _nbPieces

pePieces

private final PEPieceImpl[] pePieces

nbPiecesActive

private int nbPiecesActive

nbBytesRemaining

private long nbBytesRemaining

nbPeersSnubbed

private int nbPeersSnubbed

_hash

private PeerIdentityDataID _hash

_myPeerId

private final byte[] _myPeerId

_stats

private PEPeerManagerStatsImpl _stats

hash_handler

private final PEPeerControlHashHandler hash_handler

stats_tick_count

private int stats_tick_count

_seeds

private int _seeds

_peers

private int _peers

_remotesTCPNoLan

private int _remotesTCPNoLan

_remotesUDPNoLan

private int _remotesUDPNoLan

_remotesUTPNoLan

private int _remotesUTPNoLan

_tcp_peers_transfering

private int _tcp_peers_transfering

_tcpPendingConnections

private int _tcpPendingConnections

_tcpConnectingConnections

private int _tcpConnectingConnections

last_remote_time

private long last_remote_time

_timeStarted

private long _timeStarted

_timeStarted_mono

private long _timeStarted_mono

_timeStartedSeeding

private long _timeStartedSeeding

_timeStartedSeeding_mono

private long _timeStartedSeeding_mono

_timeFinished_mono

private long _timeFinished_mono

_averageReceptionSpeed

private Average _averageReceptionSpeed

mainloop_loop_count

private long mainloop_loop_count

MAINLOOP_ONE_SECOND_INTERVAL

private static final int MAINLOOP_ONE_SECOND_INTERVAL

MAINLOOP_FIVE_SECOND_INTERVAL

private static final int MAINLOOP_FIVE_SECOND_INTERVAL

MAINLOOP_TEN_SECOND_INTERVAL

private static final int MAINLOOP_TEN_SECOND_INTERVAL

MAINLOOP_TWENTY_SECOND_INTERVAL

private static final int MAINLOOP_TWENTY_SECOND_INTERVAL

MAINLOOP_THIRTY_SECOND_INTERVAL

private static final int MAINLOOP_THIRTY_SECOND_INTERVAL

MAINLOOP_SIXTY_SECOND_INTERVAL

private static final int MAINLOOP_SIXTY_SECOND_INTERVAL

MAINLOOP_FIVE_MINUTE_INTERVAL

private static final int MAINLOOP_FIVE_MINUTE_INTERVAL

MAINLOOP_TEN_MINUTE_INTERVAL

private static final int MAINLOOP_TEN_MINUTE_INTERVAL

peer_manager_listeners_cow

private volatile ArrayList<PEPeerManagerListener> peer_manager_listeners_cow

piece_check_result_list

private final List<Object[]> piece_check_result_list

piece_check_result_list_mon

private final AEMonitor piece_check_result_list_mon

superSeedMode

private boolean superSeedMode

superSeedModeCurrentPiece

private int superSeedModeCurrentPiece

superSeedModeNumberOfAnnounces

private int superSeedModeNumberOfAnnounces

superSeedPieces

private SuperSeedPiece[] superSeedPieces

global_hide_a_piece_cached

private boolean global_hide_a_piece_cached

local_hide_a_piece_opt

private Boolean local_hide_a_piece_opt

hidden_piece

private int hidden_piece

OB_PS_STATS_HISTORY_SIZE

private static final int OB_PS_STATS_HISTORY_SIZE

See Also:

• Constant Field Values

ob_ps_stats_history

private boolean[][] ob_ps_stats_history

ob_ps_stats

private int[] ob_ps_stats

ob_ps_stats_pos

private int[] ob_ps_stats_pos

this_mon

private final AEMonitor this_mon

ip_filter_last_update_time

private long ip_filter_last_update_time

user_data

private Map<Object,Object> user_data

unchoker

private Unchoker unchoker

external_rate_limiters_cow

private List<Object[]> external_rate_limiters_cow

bytes_queued_for_upload

private int bytes_queued_for_upload

connections_with_queued_data

private int connections_with_queued_data

connections_with_queued_data_blocked

private int connections_with_queued_data_blocked

connections_unchoked

private int connections_unchoked

connections_unchoking

private int connections_unchoking

outbound_message_count

private int outbound_message_count

sweepList

private List<PEPeerTransport> sweepList

nextPEXSweepIndex

private int nextPEXSweepIndex

upload_helper

private final UploadHelper upload_helper

peer_database

private final PeerDatabase peer_database

bad_piece_reported

private int bad_piece_reported

next_rescan_piece

private int next_rescan_piece

rescan_piece_time

private long rescan_piece_time

last_eta

private long last_eta

last_eta_smoothed

private long last_eta_smoothed

last_eta_calculation

private long last_eta_calculation

MAX_UDP_CONNECTIONS

private static final int MAX_UDP_CONNECTIONS

See Also:

• Constant Field Values

PENDING_NAT_TRAVERSAL_MAX

private static final int PENDING_NAT_TRAVERSAL_MAX

See Also:

• Constant Field Values

MAX_UDP_TRAVERSAL_COUNT

private static final int MAX_UDP_TRAVERSAL_COUNT

See Also:

• Constant Field Values

PEER_NAT_TRAVERSE_DONE_KEY

private static final String PEER_NAT_TRAVERSE_DONE_KEY

pending_nat_traversals

private final Map<String, PEPeerTransport> pending_nat_traversals

udp_traversal_count

private int udp_traversal_count

PENDING_HOLE_PUNCH_MAX

private static final int PENDING_HOLE_PUNCH_MAX

See Also:

• Constant Field Values

pending_hole_punches

private final Map<String,Object[]> pending_hole_punches

OUTBOUND_IGNORE_ADDRESSES_MAX

private static final int OUTBOUND_IGNORE_ADDRESSES_MAX

See Also:

• Constant Field Values

outbound_ignore_addresses

private final Map<PEPeerControlImpl.PeerCacheKey, Integer> outbound_ignore_addresses

RECONNECT_SEEDING_MIN

private static final int RECONNECT_SEEDING_MIN

See Also:

• Constant Field Values

RECONNECT_DOWNLOADING_MIN

private static final int RECONNECT_DOWNLOADING_MIN

See Also:

• Constant Field Values

CONNECT_FAIL_HISTORY_MAX

private static final int CONNECT_FAIL_HISTORY_MAX

See Also:

• Constant Field Values

connect_fail_history

private final Map<PEPeerControlImpl.PeerCacheKey, Long> connect_fail_history

UDP_RECONNECT_MAX

private static final int UDP_RECONNECT_MAX

See Also:

• Constant Field Values

udp_reconnects

private final Map<String, PEPeerTransport> udp_reconnects

UDP_RECONNECT_MIN_MILLIS

private static final int UDP_RECONNECT_MIN_MILLIS

See Also:

• Constant Field Values

last_udp_reconnect_mono

private long last_udp_reconnect_mono

prefer_udp

private boolean prefer_udp

PREFER_UDP_BLOOM_SIZE

private static final int PREFER_UDP_BLOOM_SIZE

See Also:

• Constant Field Values

prefer_udp_bloom

private volatile BloomFilter prefer_udp_bloom

upload_diabled

private volatile boolean upload_diabled

download_diabled

private volatile boolean download_diabled

upload_limited_rate_group

private final LimitedRateGroup upload_limited_rate_group

download_limited_rate_group

private final LimitedRateGroup download_limited_rate_group

partition_id

private final int partition_id

is_metadata_download

private final boolean is_metadata_download

metadata_infodict_size

private int metadata_infodict_size

finish_in_progress

private DiskManager.DownloadEndedProgress finish_in_progress

last_seed_disconnect_time

private long last_seed_disconnect_time

naughty_fast_extension_bloom

private final BloomFilter naughty_fast_extension_bloom

asfe_activated

private volatile boolean asfe_activated

my_peer

private final PEPeerControlImpl.MyPeer my_peer

HP_BLOOM_FILTER_SIZE

private static final int HP_BLOOM_FILTER_SIZE

See Also:

• Constant Field Values

hp_bloom

private volatile BloomFilter hp_bloom

FE_EVENT_LIMIT

private static final int FE_EVENT_LIMIT

See Also:

• Constant Field Values

optimisticDisconnectCount

private int optimisticDisconnectCount

Constructor Details

PEPeerControlImpl

public PEPeerControlImpl(byte[] _peer_id,
 PEPeerManagerAdapter _adapter,
 DiskManager _diskManager,
 int _partition_id)

Method Details

getUID

public int getUID()

Specified by:

getUID in interface PEPeerManager

start

public void start()

Specified by:

start in interface PEPeerManager

stopAll

public void stopAll()

Specified by:

stopAll in interface PEPeerManager

removeAllPeers

public void removeAllPeers(String reason,
 int reason_code)

Specified by:

removeAllPeers in interface PEPeerManager

getPartitionID

public int getPartitionID()

Specified by:

getPartitionID in interface PEPeerManager

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:

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed 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

getDisplayName

public String getDisplayName()

Specified by:

getDisplayName in interface PeerNATInitiator

Specified by:

getDisplayName in interface PEPeerManager

getName

public String getName()

Specified by:

getName in interface PeerControlInstance

schedule

public void schedule()

Specified by:

schedule in interface PeerControlInstance

analyseTrackerResponse

private void analyseTrackerResponse(TRTrackerAnnouncerResponse tracker_response)

A private method that does analysis of the result sent by the tracker. It will mainly open new connections with peers provided and set the timeToWait variable according to the tracker response.

Parameters:

tracker_response -

processTrackerResponse

public void processTrackerResponse(TRTrackerAnnouncerResponse response)

Specified by:

processTrackerResponse in interface PEPeerManager

addExtendedPeersFromTracker

private void addExtendedPeersFromTracker(Map extensions)

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 _transport)

Specified by:

addPeer in interface PEPeerManager

getTorrentHash

protected byte[] getTorrentHash()

removePeer

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

Specified by:

removePeer in interface PEPeerManager

closeAndRemovePeer

private void closeAndRemovePeer(PEPeerTransport peer,
 String reason,
 int reason_code,
 boolean log_if_not_found)

closeAndRemoveAllPeers

private void closeAndRemoveAllPeers(String reason,
 int reason_code,
 boolean reconnect)

addPeer

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

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

Throws:

Exception

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

addPeersFromTracker

private void addPeersFromTracker(TRTrackerAnnouncerResponsePeer[] peers)

makeNewOutgoingConnection

private String makeNewOutgoingConnection(String peer_source,
 String address,
 int tcp_port,
 int udp_port,
 boolean use_tcp,
 boolean require_crypto,
 byte crypto_level,
 Map user_data)

Request a new outgoing peer connection.

Parameters:

address - ip of remote peer

port - remote peer listen port

Returns:

null if the connection was added to the transport list, reason if rejected

checkCompletedPieces

private void checkCompletedPieces()

A private method that checks if PEPieces being downloaded are finished If all blocks from a PEPiece are written to disk, this method will queue the piece for hash check. Elsewhere, if it passes sha-1 check, it will be marked as downloaded, otherwise, it will unmark it as fully downloaded, so blocks can be retreived again.

hashRequest

public boolean hashRequest(int piece_number,
 DiskManagerCheckRequestListener.HashListener listener)

Specified by:

hashRequest in interface DiskManagerCheckRequestListener

checkEmptyPiece

private boolean checkEmptyPiece(int pieceNumber)

Checks given piece to see if it's active but empty, and if so deactivates it.

Parameters:

pieceNumber - to check

Returns:

true if the piece was removed and is no longer active (pePiece ==null)

checkSpeedAndReserved

private void checkSpeedAndReserved()

Check if a piece's Speed is too fast for it to be getting new data and if a reserved pieced failed to get data within 120 seconds

check99PercentBug

private void check99PercentBug()

checkInterested

private void checkInterested()

processPieceChecks

private void processPieceChecks()

Private method to process the results given by DiskManager's piece checking thread via asyncPieceChecked(..)

checkBadPieces

private void checkBadPieces()

checkRescan

private void checkRescan()

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

setStatsReceiver

public void setStatsReceiver(PEPeerManager.StatsReceiver receiver)

Specified by:

setStatsReceiver in interface PEPeerManager

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

checkFinished

private void checkFinished(boolean start_of_day)

This method checks if the downloading process is finished.

checkCompletionState

protected void checkCompletionState()

checkRequests

private void checkRequests()

This method will locate expired requests on peers, will cancel them, and mark the peer as snubbed if we haven't received useful data from them within the last 60 seconds

checkSnubbing

public void checkSnubbing(PEPeerTransport peer)

Specified by:

checkSnubbing in interface PEPeerControl

updateTrackerAnnounceInterval

private void updateTrackerAnnounceInterval()

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

getAvailability

public int[] getAvailability()

Specified by:

getAvailability 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

getBytesUnavailable

public long getBytesUnavailable()

Specified by:

getBytesUnavailable in interface PEPeerManager

getAvgAvail

public float getAvgAvail()

Specified by:

getAvgAvail 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

addPeerTransport

public void addPeerTransport(PEPeerTransport transport)

Specified by:

addPeerTransport in interface PEPeerControl

doUnchokes

private void doUnchokes()

Do all peer choke/unchoke processing.

addFastUnchokes

private void addFastUnchokes(ArrayList peers_to_unchoke)

sendHave

private void sendHave(int pieceNumber)

checkSeeds

private void checkSeeds()

isUploadOnly

private boolean isUploadOnly()

updateStats

private void updateStats()

requestCanceled

public void requestCanceled(DiskManagerReadRequest request)

The way to unmark a request as being downloaded, or also called by Peer connections objects when connection is closed or choked

Specified by:

requestCanceled in interface PEPeerManager

Parameters:

request - a DiskManagerReadRequest holding details of what was canceled

requestAdded

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

Specified by:

requestAdded in interface PEPeerControl

getControl

public PEPeerControl getControl()

getSecrets

public byte[][] getSecrets(int crypto_level)

Specified by:

getSecrets in interface PEPeerControl

getHash

public byte[] getHash()

Specified by:

getHash in interface PEPeerManager

getPeerIdentityDataID

public PeerIdentityDataID getPeerIdentityDataID()

Specified by:

getPeerIdentityDataID in interface PEPeerManager

getPeerId

public byte[] getPeerId()

Specified by:

getPeerId in interface PEPeerManager

getRemaining

public long getRemaining()

Specified by:

getRemaining in interface PEPeerManager

discarded

public void discarded(PEPeer peer,
 int length)

Specified by:

discarded in interface PEPeerManager

dataBytesReceived

public void dataBytesReceived(PEPeer peer,
 long length)

Description copied from interface: PEPeerManager

Data bytes received.

Specified by:

dataBytesReceived 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 -

dataBytesSent

public void dataBytesSent(PEPeer peer,
 long length)

Description copied from interface: PEPeerManager

Data bytes sent.

Specified by:

dataBytesSent in interface PEPeerManager

Parameters:

length -

protocolBytesSent

public void protocolBytesSent(PEPeer peer,
 long length)

Description copied from interface: PEPeerManager

Protocol bytes sent.

Specified by:

protocolBytesSent in interface PEPeerManager

Parameters:

length -

writeCompleted

public void writeCompleted(DiskManagerWriteRequest request)

DiskManagerWriteRequestListener message

Specified by:

writeCompleted in interface DiskManagerWriteRequestListener

See Also:

• DiskManagerWriteRequestListener

writeFailed

public void writeFailed(DiskManagerWriteRequest request,
 Throwable cause)

Specified by:

writeFailed in interface DiskManagerWriteRequestListener

writeBlock

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

This method will queue up a dism manager write request for the block if the block is not already written. It will send out cancels for the block to all peer either if in end-game mode, or per cancel param

Specified by:

writeBlock in interface PEPeerManager

Parameters:

pieceNumber - to potentially write to

offset - within piece to queue write for

data - to be written

sender - peer that sent this data

cancel - if cancels definitely need to be sent to all peers for this request

isWritten

public boolean isWritten(int piece_number,
 int offset)

Specified by:

isWritten 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

validatePieceReply

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

Specified by:

validatePieceReply in interface PEPeerManager

getAvailability

public int getAvailability(int pieceNumber)

Specified by:

getAvailability in interface PEPeerManager

havePiece

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

Specified by:

havePiece in interface PEPeerControl

getPieceLength

public int getPieceLength(int pieceNumber)

Specified by:

getPieceLength in interface PEPeerManager

getNbPeers

public int getNbPeers()

Specified by:

getNbPeers in interface PEPeerManager

getNbSeeds

public int getNbSeeds()

Specified by:

getNbSeeds 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

getStats

public PEPeerManagerStats getStats()

Specified by:

getStats in interface PEPeerManager

getNbPeersStalledPendingLoad

public int getNbPeersStalledPendingLoad()

Specified by:

getNbPeersStalledPendingLoad in interface PEPeerControl

getETA

public long getETA(boolean smoothed)

Returns the ETA time in seconds. 0 = download is complete. invalid input: '<' 0 = download is complete and it took -xxx time to complete. Constants.CRAPPY_INFINITE_AS_LONG = incomplete and 0 average speed

Specified by:

getETA in interface PEPeerManager

isRTA

public boolean isRTA()

Specified by:

isRTA in interface PEPeerControl

addToPeerTransports

private void addToPeerTransports(PEPeerTransport peer)

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

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

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

informFullyConnected

public void informFullyConnected(PEPeer peer)

Specified by:

informFullyConnected in interface PEPeerManager

updateConnectHealth

private void updateConnectHealth(PEPeerTransport pc)

getConnectHealth

public String getConnectHealth(boolean verbose)

Specified by:

getConnectHealth in interface PEPeerManager

peerAdded

private void peerAdded(PEPeerTransport pc)

peerRemoved

private void peerRemoved(PEPeerTransport pc)

addPiece

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

Don't pass a null to this method. All activations of pieces must go through here.

Specified by:

addPiece in interface PEPeerManager

Parameters:

piece - PEPiece invoked; notifications of it's invocation need to be done

pieceNumber - of the PEPiece

addPiece

protected void addPiece(PEPiece piece,
 int pieceNumber,
 boolean force_add,
 PEPeer for_peer)

removePiece

public void removePiece(PEPiece pePiece,
 int pieceNumber)

Sends messages to listeners that the piece is no longer active. All closing out (deactivation) of pieces must go through here. The piece will be null upon return.

Parameters:

pePiece - PEPiece to remove

pieceNumber - int

getNbActivePieces

public int getNbActivePieces()

Specified by:

getNbActivePieces in interface PEPeerControl

getElapsedTime

public String getElapsedTime()

Specified by:

getElapsedTime in interface PEPeerManager

getTimeStarted

public long getTimeStarted(boolean mono)

Specified by:

getTimeStarted in interface PEPeerManager

getTimeStartedSeeding

public long getTimeStartedSeeding(boolean mono)

Specified by:

getTimeStartedSeeding in interface PEPeerManager

computeMd5Hash

private byte[] computeMd5Hash(DirectByteBuffer buffer)

MD5CheckPiece

private void MD5CheckPiece(PEPiece piece,
 boolean correct)

checkCompleted

public void checkCompleted(DiskManagerCheckRequest request,
 boolean passed)

Specified by:

checkCompleted in interface DiskManagerCheckRequestListener

checkCancelled

public void checkCancelled(DiskManagerCheckRequest request)

Specified by:

checkCancelled in interface DiskManagerCheckRequestListener

checkFailed

public void checkFailed(DiskManagerCheckRequest request,
 Throwable cause)

Specified by:

checkFailed in interface DiskManagerCheckRequestListener

needsMD5CheckOnCompletion

public boolean needsMD5CheckOnCompletion(int pieceNumber)

Specified by:

needsMD5CheckOnCompletion in interface PEPeerManager

processPieceCheckResult

private void processPieceCheckResult(DiskManagerCheckRequest request,
 int outcome)

badPeerDetected

private void badPeerDetected(String ip,
 int piece_number,
 String reason)

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

createPeerStats

public PEPeerStats createPeerStats(PEPeer owner)

Specified by:

createPeerStats in interface PEPeerManager

createDiskManagerRequest

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

Specified by:

createDiskManagerRequest in interface PEPeerManager

requestExists

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

Specified by:

requestExists in interface PEPeerManager

seedPieceRecheck

public boolean seedPieceRecheck()

Specified by:

seedPieceRecheck 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

checkForBannedConnections

private void checkForBannedConnections()

isBlocked

private boolean isBlocked(PEPeerTransport peer,
 String name,
 byte[] hash)

addWarning

private int addWarning(String ip,
 PEPeerTransport peer)

addBan

private boolean addBan(String ip,
 String reason)

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

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

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 _superSeedMode)

Specified by:

setSuperSeedMode in interface PEPeerManager

initialiseSuperSeedMode

private void initialiseSuperSeedMode()

updatePeersInSuperSeedMode

private void updatePeersInSuperSeedMode()

updateSuperSeedPiece

public void updateSuperSeedPiece(PEPeer peer,
 int pieceNumber)

Specified by:

updateSuperSeedPiece in interface PEPeerControl

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

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

getData

public Object getData(String key)

To retreive arbitrary objects against this object.

Specified by:

getData in interface PEPeerManager

setData

public void setData(String key,
 Object value)

To store arbitrary objects against a control.

Specified by:

setData in interface PEPeerManager

getConnectTimeout

public int getConnectTimeout(int ct_def)

Specified by:

getConnectTimeout in interface PEPeerControl

doConnectionChecks

private void doConnectionChecks()

isHolePunchOperationOK

public boolean isHolePunchOperationOK(PEPeerTransport peer,
 boolean is_connect)

Specified by:

isHolePunchOperationOK in interface PEPeerControl

doTCPConnectionChecks

private void doTCPConnectionChecks(int number)

doUDPConnectionChecks

private void doUDPConnectionChecks(int number)

doOptimisticDisconnect

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

Specified by:

doOptimisticDisconnect in interface PEPeerControl

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

isAlreadyConnected

private boolean isAlreadyConnected(PeerItem peer_id)

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

IPFilterEnabledChanged

public void IPFilterEnabledChanged(boolean is_enabled)

Specified by:

IPFilterEnabledChanged in interface IPFilterListener

canIPBeBanned

public boolean canIPBeBanned(String ip)

Specified by:

canIPBeBanned in interface IPFilterListener

canIPBeBlocked

public boolean canIPBeBlocked(String ip,
 byte[] torrent_hash)

Specified by:

canIPBeBlocked in interface IPFilterListener

IPBlockedListChanged

public void IPBlockedListChanged(IpFilter filter)

Specified by:

IPBlockedListChanged in interface IPFilterListener

IPBanned

public void IPBanned(BannedIp ip)

Specified by:

IPBanned in interface IPFilterListener

disconnectSeedsWhenSeeding

private boolean disconnectSeedsWhenSeeding()

initHiddenPiece

private void initHiddenPiece()

setMaskDownloadCompletion

public void setMaskDownloadCompletion(Boolean mask)

Specified by:

setMaskDownloadCompletion in interface PEPeerManager

getHiddenBytes

public long getHiddenBytes()

Specified by:

getHiddenBytes in interface PEPeerManager

getHiddenPiece

public int getHiddenPiece()

Specified by:

getHiddenPiece in interface PEPeerManager

getUploadPriority

public int getUploadPriority()

Specified by:

getUploadPriority in interface PEPeerControl

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:

getMaxConnections

public int[] getMaxConnections()

Specified by:

getMaxConnections in interface PEPeerControl

getMaxConnections

private int getMaxConnections(String net)

getMaxSeedConnections

public int[] getMaxSeedConnections()

getMaxSeedConnections

private int getMaxSeedConnections(String net)

getMaxNewConnectionsAllowed

public int getMaxNewConnectionsAllowed(String network)

returns the allowed connections for the given network -1 -> unlimited

Specified by:

getMaxNewConnectionsAllowed in interface PEPeerManager

getMaxNewConnectionsAllowed

private int[] getMaxNewConnectionsAllowed()

returns number of whatever peers to connect and then extra ones that must be non-pub if available

Returns:

-1 -> unlimited

getPeerCount

public int[] getPeerCount()

Specified by:

getPeerCount in interface PeerControlInstance

getPieceCount

public int[] getPieceCount()

Specified by:

getPieceCount in interface PeerControlInstance

getSchedulePriority

public int getSchedulePriority()

Specified by:

getSchedulePriority in interface PeerControlInstance

hasPotentialConnections

public boolean hasPotentialConnections()

Specified by:

hasPotentialConnections in interface PEPeerManager

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.

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

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

getPreferUDP

public boolean getPreferUDP()

Specified by:

getPreferUDP in interface PEPeerManager

setPreferUDP

public void setPreferUDP(boolean prefer)

Specified by:

setPreferUDP in interface PEPeerManager

isPeerSourceEnabled

public boolean isPeerSourceEnabled(String peer_source)

Specified by:

isPeerSourceEnabled in interface PEPeerManager

isNetworkEnabled

public boolean isNetworkEnabled(String net)

Specified by:

isNetworkEnabled in interface PEPeerManager

peerDiscovered

public void peerDiscovered(PEPeerTransport finder,
 PeerItem pi)

Specified by:

peerDiscovered in interface PEPeerControl

getTrackerPeerSource

public TrackerPeerSource getTrackerPeerSource()

Specified by:

getTrackerPeerSource in interface PEPeerManager

checkAutoSequentialFiles

private void checkAutoSequentialFiles(DiskManagerFileInfo done_file)

handleFilePriorityChanged

private void handleFilePriorityChanged()

handleCloseReason

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

Specified by:

handleCloseReason in interface PEPeerControl

getHashHandler

public PEPeerControlHashHandler getHashHandler()

Specified by:

getHashHandler in interface PEPeerControl

generateEvidence

public void generateEvidence(IndentWriter writer)

Specified by:

generateEvidence in interface PEPeerManager