Methods Summary |
---|
public void | addListener(PEPeerManagerListener l)
|
public void | addPeer(PEPeer peer)
|
public void | addPeer(java.lang.String ip_address, int tcp_port, int udp_port, boolean use_crypto)Add a new peer, using the default internal PEPeer implementation
(like for peers given in announce reply), using the given address
and port.
|
public void | addPiece(PEPiece piece, int pieceNumber)
|
public void | addRateLimiter(com.aelitis.azureus.core.networkmanager.LimitedRateGroup group, boolean upload)
|
public boolean | canToggleSuperSeedMode()
|
public DiskManagerReadRequest | createDiskManagerRequest(int pieceNumber, int offset, int length)
|
public com.aelitis.azureus.core.peermanager.peerdb.PeerExchangerItem | createPeerExchangeConnection(org.gudy.azureus2.core3.peer.impl.PEPeerTransport base_peer)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).
|
public PEPeerStats | createPeerStats(PEPeer owner)
|
public void | dataBytesReceived(PEPeer peer, int l)Data bytes received.
|
public void | dataBytesSent(PEPeer peer, int l)Data bytes sent.
|
public void | discarded(PEPeer peer, int l)
|
public void | generateEvidence(org.gudy.azureus2.core3.util.IndentWriter writer)
|
public PEPeerManagerAdapter | getAdapter()
|
public long | getAvailWentBadTime()
|
public int[] | getAvailability()
|
public int | getAvailability(int pieceNumber)
|
public int | getAverageCompletionInThousandNotation()Get the average completion percentage of connected peers.
|
public float | getAvgAvail()
|
public java.lang.Object | getData(java.lang.String key)To retreive arbitrary objects against this object.
|
public DiskManager | getDiskManager()
|
public java.lang.String | getDisplayName()
|
public com.aelitis.azureus.core.networkmanager.LimitedRateGroup | getDownloadLimitedRateGroup()Get the limited rate group used for download limiting.
|
public int | getDownloadRateLimitBytesPerSecond()
|
public long | getETA()
|
public java.lang.String | getElapsedTime()
|
public byte[] | getHash()
|
public long | getLastRemoteConnectionTime()
|
public int | getMaxNewConnectionsAllowed()
|
public float | getMinAvailability()
|
public int | getNbPeers()
|
public int | getNbRemoteConnectionsExcludingUDP()
|
public int | getNbSeeds()
|
public byte[] | getPeerId()
|
public org.gudy.azureus2.core3.peer.util.PeerIdentityDataID | getPeerIdentityDataID()
|
public java.util.List | getPeers()
|
public java.util.List | getPeers(java.lang.String address)
|
public org.gudy.azureus2.plugins.peers.PeerDescriptor[] | getPendingPeers(java.lang.String address)
|
public PEPiece | getPiece(int pieceNumber)
|
public int | getPieceLength(int pieceNumber)
|
public com.aelitis.azureus.core.peermanager.piecepicker.PiecePicker | getPiecePicker()
|
public PEPiece[] | getPieces()Often better to use getPiece(pieceNumber)
|
public boolean | getPreferUDP()
|
public long | getRemaining()
|
public PEPeerManagerStats | getStats()
|
public long | getTimeStarted()
|
public long | getTimeStartedSeeding()
|
public org.gudy.azureus2.core3.peer.impl.PEPeerTransport | getTransportFromAddress(java.lang.String peer)Locate an existing transport via [IP] Address.
|
public org.gudy.azureus2.core3.peer.impl.PEPeerTransport | getTransportFromIdentity(byte[] peer_id)Locate an existing transport via peer id byte identity.
|
public com.aelitis.azureus.core.networkmanager.LimitedRateGroup | getUploadLimitedRateGroup()Get the limited rate group used for upload limiting.
|
public int | getUploadRateLimitBytesPerSecond()
|
public boolean | hasDownloadablePiece()
|
public boolean | hasPotentialConnections()
|
public boolean | isInEndGameMode()Are we in end-game mode?
|
public boolean | isSeeding()
|
public boolean | isSuperSeedMode()
|
public boolean | isWritten(int piece_number, int offset)
|
public boolean | needsMD5CheckOnCompletion(int pieceNumber)
|
public void | peerAdded(PEPeer pc)
|
public void | peerConnectionClosed(org.gudy.azureus2.core3.peer.impl.PEPeerTransport peer, boolean connect_failed)Notify the manager that the given peer connection has been closed.
|
public void | peerRemoved(PEPeer pc)
|
public void | peerVerifiedAsSelf(org.gudy.azureus2.core3.peer.impl.PEPeerTransport self)Notify that the given peer connection represents our own client.
|
public void | processTrackerResponse(org.gudy.azureus2.core3.tracker.client.TRTrackerAnnouncerResponse response)
|
public void | protocolBytesReceived(PEPeer peer, int length)Protocol bytes received.
|
public void | protocolBytesSent(PEPeer peer, int length)Protocol bytes sent.
|
public void | removeListener(PEPeerManagerListener l)
|
public void | removePeer(PEPeer peer)
|
public void | removePeer(PEPeer peer, java.lang.String reason)
|
public void | removeRateLimiter(com.aelitis.azureus.core.networkmanager.LimitedRateGroup group, boolean upload)
|
public void | requestCanceled(DiskManagerReadRequest item)
|
public boolean | requestExists(java.lang.String peer_ip, int piece_number, int offset, int length)
|
public boolean | seedPieceRecheck()
|
public void | setData(java.lang.String key, java.lang.Object value)To store arbitrary objects against this object.
|
public void | setPreferUDP(boolean prefer)
|
public void | setSuperSeedMode(boolean on)
|
public void | start()
|
public void | stopAll()
|
public boolean | validatePieceReply(org.gudy.azureus2.core3.peer.impl.PEPeerTransport originator, int pieceNumber, int offset, org.gudy.azureus2.core3.util.DirectByteBuffer data)
|
public void | writeBlock(int pieceNumber, int offset, org.gudy.azureus2.core3.util.DirectByteBuffer data, PEPeer sender, boolean cancel)
|