|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PEPeerManager
Nested Class Summary | |
---|---|
static interface |
PEPeerManager.StatsReceiver
|
Method Summary | |
---|---|
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 |
addPiece(PEPiece piece,
int pieceNumber,
PEPeer for_peer)
|
void |
addRateLimiter(LimitedRateGroup group,
boolean upload)
|
boolean |
canToggleSuperSeedMode()
|
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,
int l)
Data bytes received. |
void |
dataBytesSent(PEPeer peer,
int l)
Data bytes sent. |
void |
discarded(PEPeer peer,
int l)
|
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()
|
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()
|
String |
getElapsedTime()
|
long |
getETA(boolean smoothed)
|
byte[] |
getHash()
|
long |
getHiddenBytes()
|
long |
getLastRemoteConnectionTime()
|
int |
getMaxNewConnectionsAllowed(String network)
|
float |
getMinAvailability()
|
float |
getMinAvailability(int file_index)
|
int |
getNbPeers()
|
int |
getNbPeersUnchoked()
|
int |
getNbPeersWithUploadBlocked()
|
int |
getNbPeersWithUploadQueued()
|
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()
|
PEPeerManagerStats |
getStats()
|
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. |
LimitedRateGroup |
getUploadLimitedRateGroup()
Get the limited rate group used for upload limiting. |
int |
getUploadRateLimitBytesPerSecond()
|
boolean |
hasDownloadablePiece()
|
boolean |
hasPotentialConnections()
|
boolean |
isDestroyed()
|
boolean |
isInEndGameMode()
Are we in end-game mode? |
boolean |
isMetadataDownload()
|
boolean |
isNetworkEnabled(String network)
|
boolean |
isPeerSourceEnabled(String peer_source)
|
boolean |
isSeeding()
|
boolean |
isSuperSeedMode()
|
boolean |
isWritten(int piece_number,
int offset)
|
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(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,
int length)
Protocol bytes received. |
void |
protocolBytesSent(PEPeer peer,
int length)
Protocol bytes sent. |
void |
removeListener(PEPeerManagerListener l)
|
void |
removePeer(PEPeer peer)
|
void |
removePeer(PEPeer peer,
String reason)
|
void |
removeRateLimiter(LimitedRateGroup group,
boolean upload)
|
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 |
setPreferUDP(boolean prefer)
|
void |
setStatsReceiver(PEPeerManager.StatsReceiver receiver)
|
void |
setSuperSeedMode(boolean on)
|
void |
setTorrentInfoDictSize(int size)
|
void |
start()
|
void |
stopAll()
|
boolean |
validatePieceReply(PEPeerTransport originator,
int pieceNumber,
int offset,
DirectByteBuffer data)
|
void |
writeBlock(int pieceNumber,
int offset,
DirectByteBuffer data,
Object sender,
boolean cancel)
|
Method Detail |
---|
DiskManager getDiskManager()
PiecePicker getPiecePicker()
PEPeerManagerAdapter getAdapter()
void start()
void stopAll()
byte[] getHash()
String getDisplayName()
PeerIdentityDataID getPeerIdentityDataID()
byte[] getPeerId()
int[] getAvailability()
int getAvailability(int pieceNumber)
float getAvgAvail()
float getMinAvailability()
float getMinAvailability(int file_index)
long getAvailWentBadTime()
long getBytesUnavailable()
boolean hasDownloadablePiece()
int getBytesQueuedForUpload()
int getNbPeersWithUploadQueued()
int getNbPeersWithUploadBlocked()
int getNbPeersUnchoked()
PEPiece[] getPieces()
PEPiece getPiece(int pieceNumber)
PEPeerManagerStats getStats()
void processTrackerResponse(TRTrackerAnnouncerResponse response)
int getNbPeers()
int getNbSeeds()
int getPieceLength(int pieceNumber)
long getRemaining()
long getHiddenBytes()
long getETA(boolean smoothed)
String getElapsedTime()
long getTimeStarted(boolean mono_time)
long getTimeStartedSeeding(boolean mono_time)
void addListener(PEPeerManagerListener l)
void removeListener(PEPeerManagerListener l)
void addPiece(PEPiece piece, int pieceNumber, PEPeer for_peer)
boolean needsMD5CheckOnCompletion(int pieceNumber)
boolean isSeeding()
boolean isMetadataDownload()
int getTorrentInfoDictSize()
void setTorrentInfoDictSize(int size)
boolean isSuperSeedMode()
boolean canToggleSuperSeedMode()
void setSuperSeedMode(boolean on)
boolean seedPieceRecheck()
int getNbRemoteTCPConnections()
int getNbRemoteUDPConnections()
int getNbRemoteUTPConnections()
long getLastRemoteConnectionTime()
int getMaxNewConnectionsAllowed(String network)
boolean hasPotentialConnections()
void dataBytesReceived(PEPeer peer, int l)
l
- void dataBytesSent(PEPeer peer, int l)
l
- void protocolBytesSent(PEPeer peer, int length)
length
- void protocolBytesReceived(PEPeer peer, int length)
length
- void discarded(PEPeer peer, int l)
PEPeerStats createPeerStats(PEPeer owner)
List<PEPeer> getPeers()
List<PEPeer> getPeers(String address)
int getPendingPeerCount()
PeerDescriptor[] getPendingPeers()
PeerDescriptor[] getPendingPeers(String address)
void addPeer(PEPeer peer)
void addPeer(String ip_address, int tcp_port, int udp_port, boolean use_crypto, Map user_data)
ip_address
- of peer to injecttcp_port
- of peer to injectudp_port
- of peer to inject (0 if unknown)use_crypto
- use encrypted transportvoid peerDiscovered(String peer_source, String ip_address, int tcp_port, int udp_port, boolean use_crypto)
void removePeer(PEPeer peer)
void removePeer(PEPeer peer, String reason)
void peerAdded(PEPeer pc)
void peerRemoved(PEPeer pc)
DiskManagerReadRequest createDiskManagerRequest(int pieceNumber, int offset, int length)
void requestCanceled(DiskManagerReadRequest item)
boolean requestExists(String peer_ip, int piece_number, int offset, int length)
boolean validatePieceReply(PEPeerTransport originator, int pieceNumber, int offset, DirectByteBuffer data)
void writeBlock(int pieceNumber, int offset, DirectByteBuffer data, Object sender, boolean cancel)
boolean isWritten(int piece_number, int offset)
boolean isInEndGameMode()
void peerConnectionClosed(PEPeerTransport peer, boolean connect_failed, boolean network_failed)
peer
- closedPeerExchangerItem createPeerExchangeConnection(PEPeerTransport base_peer)
base_peer
- exchaning with
void peerVerifiedAsSelf(PEPeerTransport self)
self
- peerLimitedRateGroup getUploadLimitedRateGroup()
LimitedRateGroup getDownloadLimitedRateGroup()
int getUploadRateLimitBytesPerSecond()
int getDownloadRateLimitBytesPerSecond()
Object getData(String key)
void setData(String key, Object value)
int getAverageCompletionInThousandNotation()
PEPeerTransport getTransportFromIdentity(byte[] peer_id)
peer_id
- to look for
PEPeerTransport getTransportFromAddress(String peer)
peer
- String to look for
boolean getPreferUDP()
void setPreferUDP(boolean prefer)
void addRateLimiter(LimitedRateGroup group, boolean upload)
void removeRateLimiter(LimitedRateGroup group, boolean upload)
TrackerPeerSource getTrackerPeerSource()
boolean isPeerSourceEnabled(String peer_source)
boolean isNetworkEnabled(String network)
int getPartitionID()
boolean isDestroyed()
void generateEvidence(IndentWriter writer)
void setStatsReceiver(PEPeerManager.StatsReceiver receiver)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |