Methods Summary |
---|
public void | checkInterested()if it doesn't go as expected when trying to find a piece to ask a peer for,
need to double check if we're still interested in them, and get the BT protocol sycnhed
|
public void | closeConnection(java.lang.String reason)Close the peer connection
|
public void | doKeepAliveCheck()Check if we need to send a keep-alive message.
A keep-alive is sent if no other message has been sent within the last 2min.
|
public void | doPerformanceTuningCheck()Perform checks related to performance optimizations,
i.e. tune buffering related to send/receive speed.
|
public boolean | doTimeoutChecks()Check for possible connection timeouts.
|
public void | generateEvidence(org.gudy.azureus2.core3.util.IndentWriter writer)
|
public int | getConnectionState()Get the specific peer connection state.
|
public PEPeerControl | getControl()
|
public java.util.List | getExpiredRequests()
|
public int | getMaxNbRequests()peer-specific request max. return -1 to use the default piece-picker allocation method
|
public int | getNbRequests()
|
public com.aelitis.azureus.core.peermanager.peerdb.PeerItem | getPeerItemIdentity()Get the peer's address + port identification item.
|
public int[] | getPriorityOffsets()Any priority offsets this peer has, or null if none
|
public int | getRequestIndex(org.gudy.azureus2.core3.disk.DiskManagerReadRequest request)Returns the index of this request in the peer's queue or -1 if not found
|
public long | getTimeSinceGoodDataReceived()Get the time since the most-recent data that was actually written to disk was received.
|
public long | getTimeSinceLastDataMessageReceived()Get the time since the last (most-recent) data (payload) message was received.
|
public long | getTimeSinceLastDataMessageSent()Get the time since the last (most-recent) data (payload) message was sent.
|
public boolean | isLANLocal()Is the connection within the local LAN network.
|
public boolean | isStalledPendingLoad()is peer waiting for a disk read with no network writes queued
|
public boolean | isTCP()
|
public org.gudy.azureus2.core3.peer.impl.PEPeerTransport | reconnect()Attempts to reconnect to the same peer
|
public org.gudy.azureus2.core3.disk.DiskManagerReadRequest | request(int pieceNumber, int pieceOffset, int pieceLength)
|
public void | requestAllocationComplete()
|
public boolean | requestAllocationStarts(int[] base_priorities)Two methods that allow a peer to aggregate the individual requests generated during an
allocation cycle if so desired
|
public void | sendBadPiece(int piece_number)
|
public void | sendCancel(org.gudy.azureus2.core3.disk.DiskManagerReadRequest request)
|
public void | sendChoke()
|
public void | sendHave(int piece)
|
public void | sendUnChoke()
|
public void | start()Start message processing for the peer
|
public boolean | transferAvailable()
|
public void | updatePeerExchange()Do any peer exchange processing/updating.
|