Class PeerManagerImpl

java.lang.Object

com.biglybt.pifimpl.local.peers.PeerManagerImpl

All Implemented Interfaces:

PeerManager

public class PeerManagerImpl
extends Object
implements PeerManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	PeerManagerImpl.CoreListener
protected class	PeerManagerImpl.pieceFacade

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	destroyed
private final DiskManagerPiece[]	dm_pieces
private Map<Peer, PeerForeignDelegate>	foreign_map
private Map<PeerManagerListener2, PeerManagerImpl.CoreListener>	listener_map2
protected PEPeerManager	manager
private final PEPiece[]	pe_pieces
private static final String	PEPEER_DATA_KEY
private static final AtomicLong	PEPEER_DATA_KEY_AL
private PeerManagerImpl.pieceFacade[]	piece_facades
protected static AEMonitor	pm_map_mon
protected AEMonitor	this_mon

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PeerManagerImpl(PEPeerManager _manager)

Method Summary

Modifier and Type	Method	Description
void	addListener(PeerManagerListener2 l)
void	addPeer(Peer peer)
void	addPeer(String ip_address, int tcp_port)	Add a new peer, using the default internal Peer implementation (like for peers given in announce reply), using the given address and port.
void	addPeer(String ip_address, int tcp_port, boolean use_crypto)
void	addPeer(String ip_address, int tcp_port, int udp_port, boolean use_crypto)
void	addPeer(String ip_address, int tcp_port, int udp_port, boolean use_crypto, Map user_data)
protected void	checkIfPrivate()
PeerStats	createPeerStats(Peer peer)
PEPeerManager	getDelegate()
DiskManager	getDiskManager()
Download	getDownload()
int	getDownloadRateLimitBytesPerSecond()
protected int	getPartitionID()
static PeerImpl	getPeerForPEPeer(PEPeer pe_peer)
static PeerManagerImpl	getPeerManager(PEPeerManager _manager)
Peer[]	getPeers()
Peer[]	getPeers(String address)	returns the peers for the given address
PeerDescriptor[]	getPendingPeers()	Get the list of currently pending peers
PeerDescriptor[]	getPendingPeers(String address)	returns the pending connections to the given address
Piece[]	getPieces()
PeerManagerStats	getStats()
long	getTimeSinceConnectionEstablished(Peer peer)
int	getUploadRateLimitBytesPerSecond()
boolean	isSeeding()
boolean	isSuperSeeding()
protected PeerForeignDelegate	lookupForeignPeer(Peer _foreign)
PEPeer	mapForeignPeer(Peer _foreign)
List<PEPeer>	mapForeignPeers(Peer[] _foreigns)
void	peerDiscovered(String peer_source, String ip_address, int tcp_port, int udp_port, boolean use_crypto)
protected boolean	pluginPeerSourceEnabled()
void	removeListener(PeerManagerListener2 l)
void	removePeer(Peer peer, String reason, int reason_code)
void	requestCancelled(PeerReadRequest request, Peer sender)
void	requestComplete(PeerReadRequest request, PooledByteBuffer data, Peer sender)

Methods inherited from class Object

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

Methods inherited from interface PeerManager

removePeer

Field Details

PEPEER_DATA_KEY

private static final String PEPEER_DATA_KEY

PEPEER_DATA_KEY_AL

private static final AtomicLong PEPEER_DATA_KEY_AL

manager

protected PEPeerManager manager

pm_map_mon

protected static AEMonitor pm_map_mon

foreign_map

private Map<Peer, PeerForeignDelegate> foreign_map

listener_map2

private Map<PeerManagerListener2, PeerManagerImpl.CoreListener> listener_map2

this_mon

protected AEMonitor this_mon

dm_pieces

private final DiskManagerPiece[] dm_pieces

pe_pieces

private final PEPiece[] pe_pieces

piece_facades

private PeerManagerImpl.pieceFacade[] piece_facades

destroyed

private boolean destroyed

Constructor Details

PeerManagerImpl

protected PeerManagerImpl(PEPeerManager _manager)

Method Details

getPeerManager

public static PeerManagerImpl getPeerManager(PEPeerManager _manager)

getDelegate

public PEPeerManager getDelegate()

getDiskManager

public DiskManager getDiskManager()

Specified by:

getDiskManager in interface PeerManager

getStats

public PeerManagerStats getStats()

Specified by:

getStats in interface PeerManager

isSeeding

public boolean isSeeding()

Specified by:

isSeeding in interface PeerManager

isSuperSeeding

public boolean isSuperSeeding()

Specified by:

isSuperSeeding in interface PeerManager

getDownload

public Download getDownload()
                     throws DownloadException

Specified by:

getDownload in interface PeerManager

Throws:

DownloadException

getPieces

public Piece[] getPieces()

Specified by:

getPieces in interface PeerManager

createPeerStats

public PeerStats createPeerStats(Peer peer)

Specified by:

createPeerStats in interface PeerManager

requestComplete

public void requestComplete(PeerReadRequest request,
 PooledByteBuffer data,
 Peer sender)

Specified by:

requestComplete in interface PeerManager

requestCancelled

public void requestCancelled(PeerReadRequest request,
 Peer sender)

Specified by:

requestCancelled in interface PeerManager

getPartitionID

protected int getPartitionID()

addPeer

public void addPeer(Peer peer)

Specified by:

addPeer in interface PeerManager

removePeer

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

Specified by:

removePeer in interface PeerManager

addPeer

public void addPeer(String ip_address,
 int tcp_port)

Description copied from interface: PeerManager

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

Specified by:

addPeer in interface PeerManager

Parameters:

ip_address - of peer to inject

tcp_port - of peer to inject

addPeer

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

Specified by:

addPeer in interface PeerManager

addPeer

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

Specified by:

addPeer in interface PeerManager

addPeer

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

Specified by:

addPeer in interface PeerManager

peerDiscovered

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

Specified by:

peerDiscovered in interface PeerManager

pluginPeerSourceEnabled

protected boolean pluginPeerSourceEnabled()

checkIfPrivate

protected void checkIfPrivate()

getPeers

public Peer[] getPeers()

Specified by:

getPeers in interface PeerManager

getPeers

public Peer[] getPeers(String address)

Description copied from interface: PeerManager

returns the peers for the given address

Specified by:

getPeers in interface PeerManager

Parameters:

address -

Returns:

getPendingPeers

public PeerDescriptor[] getPendingPeers()

Description copied from interface: PeerManager

Get the list of currently pending peers

Specified by:

getPendingPeers in interface PeerManager

Returns:

getPendingPeers

public PeerDescriptor[] getPendingPeers(String address)

Description copied from interface: PeerManager

returns the pending connections to the given address

Specified by:

getPendingPeers in interface PeerManager

Parameters:

address -

Returns:

getTimeSinceConnectionEstablished

public long getTimeSinceConnectionEstablished(Peer peer)

mapForeignPeer

public PEPeer mapForeignPeer(Peer _foreign)

lookupForeignPeer

protected PeerForeignDelegate lookupForeignPeer(Peer _foreign)

mapForeignPeers

public List<PEPeer> mapForeignPeers(Peer[] _foreigns)

getPeerForPEPeer

public static PeerImpl getPeerForPEPeer(PEPeer pe_peer)

getUploadRateLimitBytesPerSecond

public int getUploadRateLimitBytesPerSecond()

Specified by:

getUploadRateLimitBytesPerSecond in interface PeerManager

getDownloadRateLimitBytesPerSecond

public int getDownloadRateLimitBytesPerSecond()

Specified by:

getDownloadRateLimitBytesPerSecond in interface PeerManager

addListener

public void addListener(PeerManagerListener2 l)

Specified by:

addListener in interface PeerManager

removeListener

public void removeListener(PeerManagerListener2 l)

Specified by:

removeListener in interface PeerManager