org.gudy.azureus2.pluginsimpl.local.peers
Class PeerForeignDelegate

java.lang.Object
  org.gudy.azureus2.pluginsimpl.local.peers.PeerForeignDelegate

All Implemented Interfaces:

PEPeerTransport, PEPeer, Taggable

public class PeerForeignDelegate
extends Object
implements PEPeerTransport

Field Summary

protected int	_lastPiece
protected AEMonitor	this_mon

Fields inherited from interface org.gudy.azureus2.core3.peer.impl.PEPeerTransport

CONNECTION_CONNECTING, CONNECTION_FULLY_ESTABLISHED, CONNECTION_PENDING, CONNECTION_WAITING_FOR_HANDSHAKE

Fields inherited from interface org.gudy.azureus2.core3.peer.PEPeer

CLOSING, CONNECTING, DISCONNECTED, HANDSHAKING, MESSAGING_AZMP, MESSAGING_BT_ONLY, MESSAGING_EXTERN, MESSAGING_LTEP, StateNames, TRANSFERING

Fields inherited from interface com.aelitis.azureus.core.tag.Taggable

TT_DOWNLOAD, TT_PEER

Constructor Summary

protected

PeerForeignDelegate(PeerManagerImpl _manager, Peer _foreign)

Method Summary

void	addListener(PEPeerListener l) Add peer listener.
void	addRateLimiter(LimitedRateGroup limiter, boolean upload)
void	addReservedPieceNumber(int piece_number) adds the reserved piece for piece picking by this peer
void	checkInterested() Nothing to do if called
void	clearAvailabilityAdded() Nothing to do if called
void	clearRequestHint()
void	closeConnection(String reason) Close the peer connection
protected void	dataReceived()
void	doKeepAliveCheck() Check if we need to send a keep-alive message.
void	doPerformanceTuningCheck() Perform checks related to performance optimizations, i.e.
boolean	doTimeoutChecks() Check for possible connection timeouts.
boolean	equals(Object other)
void	generateEvidence(IndentWriter writer)
InetAddress	getAlternativeIPv6()
BitFlags	getAvailable()
long	getBytesRemaining()
String	getClient()
String	getClientNameFromExtensionHandshake()
String	getClientNameFromPeerID()
int	getConnectionState() Get the specific peer connection state.
int	getConsecutiveNoRequestCount()
PEPeerControl	getControl()
Object	getData(String key) To retreive arbitrary objects against a peer.
int	getDownloadRateLimitBytesPerSecond()
String	getEncryption() Returns name of encryption used by the peer
List	getExpiredRequests()
byte[]	getHandshakeReservedBytes()
byte[]	getId()
int	getIncomingRequestCount()
int[]	getIncomingRequestedPieceNumbers() get a list of piece numbers the peer has requested
String	getIp()
String	getIPHostName() Gets the host name for the IP, if possible, IP as string otherwise
long	getLastMessageSentTime()
int	getLastPiece()
long	getLatency()
PEPeerManager	getManager()
int	getMaxNbRequests() peer-specific request max.
int	getMessagingMode()
int	getNbRequests()
String	getNetwork()
int	getOutboundDataQueueSize() amount of data queued for delivery to peer
int	getOutgoingRequestCount()
int[]	getOutgoingRequestedPieceNumbers() get a list of piece numbers the we have requested from peer
PeerItem	getPeerItemIdentity() Get the peer's address + port identification item.
String	getPeerSource()
int	getPeerState()
int	getPercentDoneInThousandNotation() Get the peer's torrent completion percentage in thousand-notation, i.e.
int	getPercentDoneOfCurrentIncomingRequest()
int	getPercentDoneOfCurrentOutgoingRequest()
Connection	getPluginConnection() Get the connection that backs this peer.
int	getPort() Get the peer's local TCP connection port.
int[]	getPriorityOffsets() Any priority offsets this peer has, or null if none
String	getProtocol()
String	getProtocolQualifier()
LimitedRateGroup[]	getRateLimiters(boolean upload)
int[]	getRequestHint() Get current request hint for a given piece for this peer.
int	getRequestIndex(DiskManagerReadRequest request) Returns the index of this request in the peer's queue or -1 if not found
int[]	getReservedPieceNumbers() Get the reserved pieces for piece picking by this peer
long	getSnubbedTime()
PEPeerStats	getStats()
Message[]	getSupportedMessages() Get the list of messages that this peer and us both understand.
String	getTaggableID()
TaggableResolver	getTaggableResolver()
int	getTaggableType()
int	getTCPListenPort() Get the TCP port this peer is listening for incoming connections on.
long	getTimeSinceConnectionEstablished() Get the time since this connection was first established.
long	getTimeSinceGoodDataReceived() Get the time since the most-recent data that was actually written to disk was received.
long	getTimeSinceLastDataMessageReceived() Get the time since the last (most-recent) data (payload) message was received.
long	getTimeSinceLastDataMessageSent() Get the time since the last (most-recent) data (payload) message was sent.
int	getUDPListenPort() Get the UDP port this peer is listening for incoming connections on.
int	getUDPNonDataListenPort() Get the UDP port this peer is listening on for non-data connections
long	getUnchokedForMillis()
int	getUniqueAnnounce()
int	getUploadHint()
int	getUploadRateLimitBytesPerSecond()
Object	getUserData(Object key) To retreive arbitrary objects against a peer.
int	hashCode()
boolean	hasReceivedBitField()
boolean	isAvailabilityAdded() Apaprently nothing significant to do if called
boolean	isChokedByMe() Am I choking the peer.
boolean	isChokingMe() Is the peer choking me.
boolean	isClosed()
boolean	isDownloadDisabled()
boolean	isDownloadPossible() checks several factors within the object so the caller wouldn't need to for convienience and speed.
boolean	isIncoming()
boolean	isInterested() Is the peer Interested in me.
boolean	isInteresting() Am I Interested in the peer.
boolean	isLANLocal() Is the connection within the local LAN network.
boolean	isOptimisticUnchoke()
boolean	isPieceAvailable(int pieceNumber)
boolean	isPriorityConnection()
boolean	isRelativeSeed()
boolean	isSafeForReconnect() This method is called to check if it is safe to reconnect to a peer, i.e.
boolean	isSeed()
boolean	isSnubbed()
boolean	isStalledPendingLoad() is peer waiting for a disk read with no network writes queued
boolean	isTCP()
boolean	isUnchokeOverride()
boolean	isUploadDisabled()
PEPeerTransport	reconnect(boolean tryUDP, boolean tryIPv6) Attempts to reconnect to the same peer
void	removeListener(PEPeerListener l) Remove peer listener.
void	removeRateLimiter(LimitedRateGroup limiter, boolean upload)
void	removeReservedPieceNumber(int piece_number)
DiskManagerReadRequest	request(int pieceNumber, int pieceOffset, int pieceLength, boolean return_duplicates)
void	requestAllocationComplete()
boolean	requestAllocationStarts(int[] base_priorities) Two methods that allow a peer to aggregate the individual requests generated during an allocation cycle if so desired
void	sendBadPiece(int piece_number)
void	sendCancel(DiskManagerReadRequest request)
void	sendChoke() Should never be called
void	sendHave(int piece) Nothing to do if called
void	sendRejectRequest(DiskManagerReadRequest request)
boolean	sendRequestHint(int piece_number, int offset, int length, int life) Send a request hint to the peer.
void	sendStatsReply(Map reply)
void	sendStatsRequest(Map request)
void	sendUnChoke() Should never be called
void	setConsecutiveNoRequestCount(int num)
void	setData(String key, Object value) To store arbitrary objects against a peer.
void	setDownloadDisabled(Object key, boolean disabled)
void	setDownloadRateLimitBytesPerSecond(int bytes)
void	setHaveAggregationEnabled(boolean enabled)
void	setLastPiece(int pieceNumber)
void	setOptimisticUnchoke(boolean is_optimistic)
void	setPriorityConnection(boolean is_priority)
void	setSnubbed(boolean b)
void	setSuspendedLazyBitFieldEnabled(boolean enable) Enable suspended lazy bitfield for this peer - we will appear incomplete until this is disabled, at which point (well, fairly soon after) the bitfield will be completed
void	setUniqueAnnounce(int uniquePieceNumber)
void	setUploadDisabled(Object key, boolean disabled)
void	setUploadHint(int timeToSpread)
void	setUploadRateLimitBytesPerSecond(int bytes)
void	setUserData(Object key, Object value) To store arbitrary objects against a peer.
void	start() Start message processing for the peer
protected void	stop()
boolean	supportsMessaging() Whether or not this peer supports the advanced messaging API.
boolean	transferAvailable()
void	updateAutoUploadPriority(Object key, boolean inc)
void	updatePeerExchange() Do any peer exchange processing/updating.

Methods inherited from class java.lang.Object

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

Field Detail

_lastPiece

protected volatile int _lastPiece

this_mon

protected AEMonitor this_mon

Constructor Detail

PeerForeignDelegate

protected PeerForeignDelegate(PeerManagerImpl _manager,
                              Peer _foreign)

Method Detail

start

public void start()

Description copied from interface: PEPeerTransport

Start message processing for the peer

Specified by:

start in interface PEPeerTransport

stop

protected void stop()

sendChoke

public void sendChoke()

Should never be called

Specified by:

sendChoke in interface PEPeerTransport

Specified by:

sendChoke in interface PEPeer

sendHave

public void sendHave(int piece)

Nothing to do if called

Specified by:

sendHave in interface PEPeerTransport

sendUnChoke

public void sendUnChoke()

Should never be called

Specified by:

sendUnChoke in interface PEPeerTransport

Specified by:

sendUnChoke in interface PEPeer

getAlternativeIPv6

public InetAddress getAlternativeIPv6()

Specified by:

getAlternativeIPv6 in interface PEPeer

Returns:

an ipv6 address under which the peer should be connectable if it announced one, null otherwise

transferAvailable

public boolean transferAvailable()

Specified by:

transferAvailable in interface PEPeerTransport

Specified by:

transferAvailable in interface PEPeer

isDownloadPossible

public boolean isDownloadPossible()

Description copied from interface: PEPeer

checks several factors within the object so the caller wouldn't need to for convienience and speed.

Specified by:

isDownloadPossible in interface PEPeer

Returns:

true if none of several criteria indicate a request can't be made of the peer

sendCancel

public void sendCancel(DiskManagerReadRequest request)

Specified by:

sendCancel in interface PEPeerTransport

request

public DiskManagerReadRequest request(int pieceNumber,
                                      int pieceOffset,
                                      int pieceLength,
                                      boolean return_duplicates)

Specified by:

request in interface PEPeerTransport

Parameters:

pieceNumber -

pieceOffset -

pieceLength -

return_duplicates - - if true and request already exists it will be returned, if false -> null

Returns:

true is the piece is really requested

getRequestIndex

public int getRequestIndex(DiskManagerReadRequest request)

Description copied from interface: PEPeerTransport

Returns the index of this request in the peer's queue or -1 if not found

Specified by:

getRequestIndex in interface PEPeerTransport

Returns:

dataReceived

protected void dataReceived()

closeConnection

public void closeConnection(String reason)

Description copied from interface: PEPeerTransport

Close the peer connection

Specified by:

closeConnection in interface PEPeerTransport

Parameters:

reason - for closure

isClosed

public boolean isClosed()

Specified by:

isClosed in interface PEPeer

getExpiredRequests

public List getExpiredRequests()

Specified by:

getExpiredRequests in interface PEPeerTransport

getLastMessageSentTime

public long getLastMessageSentTime()

Specified by:

getLastMessageSentTime in interface PEPeerTransport

getMaxNbRequests

public int getMaxNbRequests()

Description copied from interface: PEPeerTransport

peer-specific request max. return -1 to use the default piece-picker allocation method

Specified by:

getMaxNbRequests in interface PEPeerTransport

Returns:

getNbRequests

public int getNbRequests()

Specified by:

getNbRequests in interface PEPeerTransport

getPriorityOffsets

public int[] getPriorityOffsets()

Description copied from interface: PEPeerTransport

Any priority offsets this peer has, or null if none

Specified by:

getPriorityOffsets in interface PEPeerTransport

Returns:

requestAllocationStarts

public boolean requestAllocationStarts(int[] base_priorities)

Description copied from interface: PEPeerTransport

Two methods that allow a peer to aggregate the individual requests generated during an allocation cycle if so desired

Specified by:

requestAllocationStarts in interface PEPeerTransport

Returns:

true if the peer is managing request priorities and doesn't want end-game random allocation behaviour

requestAllocationComplete

public void requestAllocationComplete()

Specified by:

requestAllocationComplete in interface PEPeerTransport

getControl

public PEPeerControl getControl()

Specified by:

getControl in interface PEPeerTransport

updatePeerExchange

public void updatePeerExchange()

Description copied from interface: PEPeerTransport

Do any peer exchange processing/updating.

Specified by:

updatePeerExchange in interface PEPeerTransport

getPeerItemIdentity

public PeerItem getPeerItemIdentity()

Description copied from interface: PEPeerTransport

Get the peer's address + port identification item.

Specified by:

getPeerItemIdentity in interface PEPeerTransport

Returns:

id

getConnectionState

public int getConnectionState()

Description copied from interface: PEPeerTransport

Get the specific peer connection state.

Specified by:

getConnectionState in interface PEPeerTransport

Returns:

connection state

doKeepAliveCheck

public void doKeepAliveCheck()

Description copied from interface: PEPeerTransport

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.

Specified by:

doKeepAliveCheck in interface PEPeerTransport

doTimeoutChecks

public boolean doTimeoutChecks()

Description copied from interface: PEPeerTransport

Check for possible connection timeouts.

Specified by:

doTimeoutChecks in interface PEPeerTransport

Returns:

true if the connection has been timed-out, false if not

doPerformanceTuningCheck

public void doPerformanceTuningCheck()

Description copied from interface: PEPeerTransport

Perform checks related to performance optimizations, i.e. tune buffering related to send/receive speed.

Specified by:

doPerformanceTuningCheck in interface PEPeerTransport

setSuspendedLazyBitFieldEnabled

public void setSuspendedLazyBitFieldEnabled(boolean enable)

Description copied from interface: PEPeer

Enable suspended lazy bitfield for this peer - we will appear incomplete until this is disabled, at which point (well, fairly soon after) the bitfield will be completed

Specified by:

setSuspendedLazyBitFieldEnabled in interface PEPeer

getTimeSinceConnectionEstablished

public long getTimeSinceConnectionEstablished()

Description copied from interface: PEPeer

Get the time since this connection was first established. NOTE: This method will always return 0 at any time before the underlying transport is fully connected, i.e. before handshaking begins.

Specified by:

getTimeSinceConnectionEstablished in interface PEPeer

Returns:

time count in ms

getTimeSinceLastDataMessageReceived

public long getTimeSinceLastDataMessageReceived()

Description copied from interface: PEPeerTransport

Get the time since the last (most-recent) data (payload) message was received.

Specified by:

getTimeSinceLastDataMessageReceived in interface PEPeerTransport

Returns:

time count in ms, or -1 if we've never received a data message from them

getTimeSinceGoodDataReceived

public long getTimeSinceGoodDataReceived()

Description copied from interface: PEPeerTransport

Get the time since the most-recent data that was actually written to disk was received.

Specified by:

getTimeSinceGoodDataReceived in interface PEPeerTransport

Returns:

time count in ms, or -1 if we've never received usefull data from them

getTimeSinceLastDataMessageSent

public long getTimeSinceLastDataMessageSent()

Description copied from interface: PEPeerTransport

Get the time since the last (most-recent) data (payload) message was sent.

Specified by:

getTimeSinceLastDataMessageSent in interface PEPeerTransport

Returns:

time count in ms, or -1 if we've never sent them a data message

getUnchokedForMillis

public long getUnchokedForMillis()

Specified by:

getUnchokedForMillis in interface PEPeerTransport

getLatency

public long getLatency()

Specified by:

getLatency in interface PEPeerTransport

getConsecutiveNoRequestCount

public int getConsecutiveNoRequestCount()

Specified by:

getConsecutiveNoRequestCount in interface PEPeer

setConsecutiveNoRequestCount

public void setConsecutiveNoRequestCount(int num)

Specified by:

setConsecutiveNoRequestCount in interface PEPeer

getManager

public PEPeerManager getManager()

Specified by:

getManager in interface PEPeer

getPeerSource

public String getPeerSource()

Specified by:

getPeerSource in interface PEPeer

getPeerState

public int getPeerState()

Specified by:

getPeerState in interface PEPeer

getId

public byte[] getId()

Specified by:

getId in interface PEPeer

getIp

public String getIp()

Specified by:

getIp in interface PEPeer

getIPHostName

public String getIPHostName()

Description copied from interface: PEPeer

Gets the host name for the IP, if possible, IP as string otherwise

Specified by:

getIPHostName in interface PEPeer

Returns:

hostname or IP

getPort

public int getPort()

Description copied from interface: PEPeer

Get the peer's local TCP connection port.

Specified by:

getPort in interface PEPeer

Returns:

local port

getTCPListenPort

public int getTCPListenPort()

Description copied from interface: PEPeer

Get the TCP port this peer is listening for incoming connections on.

Specified by:

getTCPListenPort in interface PEPeer

Returns:

TCP port, or 0 if port is unknown

getUDPListenPort

public int getUDPListenPort()

Description copied from interface: PEPeer

Get the UDP port this peer is listening for incoming connections on.

Specified by:

getUDPListenPort in interface PEPeer

Returns:

UDP port, or 0 if port is unknown

getUDPNonDataListenPort

public int getUDPNonDataListenPort()

Description copied from interface: PEPeer

Get the UDP port this peer is listening on for non-data connections

Specified by:

getUDPNonDataListenPort in interface PEPeer

Returns:

getAvailable

public BitFlags getAvailable()

Specified by:

getAvailable in interface PEPeer

hasReceivedBitField

public boolean hasReceivedBitField()

Specified by:

hasReceivedBitField in interface PEPeer

isPieceAvailable

public boolean isPieceAvailable(int pieceNumber)

Specified by:

isPieceAvailable in interface PEPeer

Parameters:

pieceNumber - int

Returns:

true if this peers makes this piece available

setSnubbed

public void setSnubbed(boolean b)

Specified by:

setSnubbed in interface PEPeer

isChokingMe

public boolean isChokingMe()

Description copied from interface: PEPeer

Is the peer choking me.

Specified by:

isChokingMe in interface PEPeer

Returns:

true if I am choked by the peer, false if not

isChokedByMe

public boolean isChokedByMe()

Description copied from interface: PEPeer

Am I choking the peer.

Specified by:

isChokedByMe in interface PEPeer

Returns:

true if the peer is choked, false if not

isUnchokeOverride

public boolean isUnchokeOverride()

Specified by:

isUnchokeOverride in interface PEPeer

isInteresting

public boolean isInteresting()

Description copied from interface: PEPeer

Am I Interested in the peer.

Specified by:

isInteresting in interface PEPeer

Returns:

true if peer is interesting, false if not

isInterested

public boolean isInterested()

Description copied from interface: PEPeer

Is the peer Interested in me.

Specified by:

isInterested in interface PEPeer

Returns:

true if the peer is interested in me, false if not

isSeed

public boolean isSeed()

Specified by:

isSeed in interface PEPeer

isRelativeSeed

public boolean isRelativeSeed()

Specified by:

isRelativeSeed in interface PEPeer

Returns:

true if the peer is only uploading and can't use the data we have to offer (we're seeding) or we can't use the data he has to offer (we're downloading)

isSnubbed

public boolean isSnubbed()

Specified by:

isSnubbed in interface PEPeer

getSnubbedTime

public long getSnubbedTime()

Specified by:

getSnubbedTime in interface PEPeer

isLANLocal

public boolean isLANLocal()

Description copied from interface: PEPeerTransport

Is the connection within the local LAN network.

Specified by:

isLANLocal in interface PEPeerTransport

Specified by:

isLANLocal in interface PEPeer

Returns:

true if within LAN, false of outside the LAN segment

sendRequestHint

public boolean sendRequestHint(int piece_number,
                               int offset,
                               int length,
                               int life)

Description copied from interface: PEPeer

Send a request hint to the peer.

Specified by:

sendRequestHint in interface PEPeer

Returns:

true if sent, false otherwise

getRequestHint

public int[] getRequestHint()

Description copied from interface: PEPeer

Get current request hint for a given piece for this peer.

Specified by:

getRequestHint in interface PEPeer

Returns:

null if no hint int[]{ piece_number, offset, length } if hint found

clearRequestHint

public void clearRequestHint()

Specified by:

clearRequestHint in interface PEPeer

sendRejectRequest

public void sendRejectRequest(DiskManagerReadRequest request)

Specified by:

sendRejectRequest in interface PEPeer

sendBadPiece

public void sendBadPiece(int piece_number)

Specified by:

sendBadPiece in interface PEPeerTransport

sendStatsRequest

public void sendStatsRequest(Map request)

Specified by:

sendStatsRequest in interface PEPeerTransport

Specified by:

sendStatsRequest in interface PEPeer

sendStatsReply

public void sendStatsReply(Map reply)

Specified by:

sendStatsReply in interface PEPeerTransport

isTCP

public boolean isTCP()

Specified by:

isTCP in interface PEPeerTransport

getNetwork

public String getNetwork()

Specified by:

getNetwork in interface PEPeerTransport

getStats

public PEPeerStats getStats()

Specified by:

getStats in interface PEPeer

isIncoming

public boolean isIncoming()

Specified by:

isIncoming in interface PEPeer

getPercentDoneInThousandNotation

public int getPercentDoneInThousandNotation()

Description copied from interface: PEPeer

Get the peer's torrent completion percentage in thousand-notation, i.e. 53.7% is returned as the value 0537.

Specified by:

getPercentDoneInThousandNotation in interface PEPeer

Returns:

the percentage the peer has complete

getBytesRemaining

public long getBytesRemaining()

Specified by:

getBytesRemaining in interface PEPeer

getClient

public String getClient()

Specified by:

getClient in interface PEPeer

getHandshakeReservedBytes

public byte[] getHandshakeReservedBytes()

Specified by:

getHandshakeReservedBytes in interface PEPeer

isOptimisticUnchoke

public boolean isOptimisticUnchoke()

Specified by:

isOptimisticUnchoke in interface PEPeer

setOptimisticUnchoke

public void setOptimisticUnchoke(boolean is_optimistic)

Specified by:

setOptimisticUnchoke in interface PEPeer

getUniqueAnnounce

public int getUniqueAnnounce()

Specified by:

getUniqueAnnounce in interface PEPeer

getUploadHint

public int getUploadHint()

Specified by:

getUploadHint in interface PEPeer

setUniqueAnnounce

public void setUniqueAnnounce(int uniquePieceNumber)

Specified by:

setUniqueAnnounce in interface PEPeer

setUploadHint

public void setUploadHint(int timeToSpread)

Specified by:

setUploadHint in interface PEPeer

isStalledPendingLoad

public boolean isStalledPendingLoad()

Description copied from interface: PEPeerTransport

is peer waiting for a disk read with no network writes queued

Specified by:

isStalledPendingLoad in interface PEPeerTransport

Returns:

addListener

public void addListener(PEPeerListener l)

Description copied from interface: PEPeer

Add peer listener.

Specified by:

addListener in interface PEPeer

removeListener

public void removeListener(PEPeerListener l)

Description copied from interface: PEPeer

Remove peer listener.

Specified by:

removeListener in interface PEPeer

getPluginConnection

public Connection getPluginConnection()

Description copied from interface: PEPeer

Get the connection that backs this peer.

Specified by:

getPluginConnection in interface PEPeer

Returns:

connection

getPercentDoneOfCurrentIncomingRequest

public int getPercentDoneOfCurrentIncomingRequest()

Specified by:

getPercentDoneOfCurrentIncomingRequest in interface PEPeer

getPercentDoneOfCurrentOutgoingRequest

public int getPercentDoneOfCurrentOutgoingRequest()

Specified by:

getPercentDoneOfCurrentOutgoingRequest in interface PEPeer

supportsMessaging

public boolean supportsMessaging()

Description copied from interface: PEPeer

Whether or not this peer supports the advanced messaging API.

Specified by:

supportsMessaging in interface PEPeer

Returns:

true if extended messaging is supported, false if not

getMessagingMode

public int getMessagingMode()

Specified by:

getMessagingMode in interface PEPeer

getEncryption

public String getEncryption()

Description copied from interface: PEPeer

Returns name of encryption used by the peer

Specified by:

getEncryption in interface PEPeer

Returns:

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface PEPeer

getProtocolQualifier

public String getProtocolQualifier()

Specified by:

getProtocolQualifier in interface PEPeer

getSupportedMessages

public Message[] getSupportedMessages()

Description copied from interface: PEPeer

Get the list of messages that this peer and us both understand.

Specified by:

getSupportedMessages in interface PEPeer

Returns:

messages available for use, or null of supported is yet unknown or unavailable

getData

public Object getData(String key)

Description copied from interface: PEPeer

To retreive arbitrary objects against a peer.

Specified by:

getData in interface PEPeer

setData

public void setData(String key,
                    Object value)

Description copied from interface: PEPeer

To store arbitrary objects against a peer.

Specified by:

setData in interface PEPeer

getUserData

public Object getUserData(Object key)

To retreive arbitrary objects against a peer.

Specified by:

getUserData in interface PEPeer

setUserData

public void setUserData(Object key,
                        Object value)

To store arbitrary objects against a peer.

Specified by:

setUserData in interface PEPeer

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getReservedPieceNumbers

public int[] getReservedPieceNumbers()

Description copied from interface: PEPeer

Get the reserved pieces for piece picking by this peer

Specified by:

getReservedPieceNumbers in interface PEPeer

addReservedPieceNumber

public void addReservedPieceNumber(int piece_number)

Description copied from interface: PEPeer

adds the reserved piece for piece picking by this peer

Specified by:

addReservedPieceNumber in interface PEPeer

removeReservedPieceNumber

public void removeReservedPieceNumber(int piece_number)

Specified by:

removeReservedPieceNumber in interface PEPeer

getIncomingRequestedPieceNumbers

public int[] getIncomingRequestedPieceNumbers()

Description copied from interface: PEPeer

get a list of piece numbers the peer has requested

Specified by:

getIncomingRequestedPieceNumbers in interface PEPeer

Returns:

list of Long() representing the piece number requested, in order

getIncomingRequestCount

public int getIncomingRequestCount()

Specified by:

getIncomingRequestCount in interface PEPeer

getOutgoingRequestCount

public int getOutgoingRequestCount()

Specified by:

getOutgoingRequestCount in interface PEPeer

getOutgoingRequestedPieceNumbers

public int[] getOutgoingRequestedPieceNumbers()

Description copied from interface: PEPeer

get a list of piece numbers the we have requested from peer

Specified by:

getOutgoingRequestedPieceNumbers in interface PEPeer

Returns:

list of Long() representing the piece number requested, oldest to newest

getOutboundDataQueueSize

public int getOutboundDataQueueSize()

Description copied from interface: PEPeer

amount of data queued for delivery to peer

Specified by:

getOutboundDataQueueSize in interface PEPeer

Returns:

getLastPiece

public int getLastPiece()

Specified by:

getLastPiece in interface PEPeer

setLastPiece

public void setLastPiece(int pieceNumber)

Specified by:

setLastPiece in interface PEPeer

checkInterested

public void checkInterested()

Nothing to do if called

Specified by:

checkInterested in interface PEPeerTransport

isAvailabilityAdded

public boolean isAvailabilityAdded()

Apaprently nothing significant to do if called

clearAvailabilityAdded

public void clearAvailabilityAdded()

Nothing to do if called

reconnect

public PEPeerTransport reconnect(boolean tryUDP,
                                 boolean tryIPv6)

Description copied from interface: PEPeerTransport

Attempts to reconnect to the same peer

Specified by:

reconnect in interface PEPeerTransport

Parameters:

tryUDP - try to initate a UDP connection if true, just reestablish the previous state otherwise

tryIPv6 - TODO

Returns:

null if reconnect not possible, reconnected peer otherwise

isSafeForReconnect

public boolean isSafeForReconnect()

Description copied from interface: PEPeerTransport

This method is called to check if it is safe to reconnect to a peer, i.e. avoid hammering exchanging data with a peer should work as it takes time to setup the connection and negotiate things before that happens

Specified by:

isSafeForReconnect in interface PEPeerTransport

Returns:

true if we exchanged payload data with the peer during the current connection

setUploadRateLimitBytesPerSecond

public void setUploadRateLimitBytesPerSecond(int bytes)

Specified by:

setUploadRateLimitBytesPerSecond in interface PEPeer

setDownloadRateLimitBytesPerSecond

public void setDownloadRateLimitBytesPerSecond(int bytes)

Specified by:

setDownloadRateLimitBytesPerSecond in interface PEPeer

getUploadRateLimitBytesPerSecond

public int getUploadRateLimitBytesPerSecond()

Specified by:

getUploadRateLimitBytesPerSecond in interface PEPeer

getDownloadRateLimitBytesPerSecond

public int getDownloadRateLimitBytesPerSecond()

Specified by:

getDownloadRateLimitBytesPerSecond in interface PEPeer

updateAutoUploadPriority

public void updateAutoUploadPriority(Object key,
                                     boolean inc)

Specified by:

updateAutoUploadPriority in interface PEPeer

addRateLimiter

public void addRateLimiter(LimitedRateGroup limiter,
                           boolean upload)

Specified by:

addRateLimiter in interface PEPeer

getRateLimiters

public LimitedRateGroup[] getRateLimiters(boolean upload)

Specified by:

getRateLimiters in interface PEPeer

removeRateLimiter

public void removeRateLimiter(LimitedRateGroup limiter,
                              boolean upload)

Specified by:

removeRateLimiter in interface PEPeer

setUploadDisabled

public void setUploadDisabled(Object key,
                              boolean disabled)

Specified by:

setUploadDisabled in interface PEPeer

setDownloadDisabled

public void setDownloadDisabled(Object key,
                                boolean disabled)

Specified by:

setDownloadDisabled in interface PEPeer

isUploadDisabled

public boolean isUploadDisabled()

Specified by:

isUploadDisabled in interface PEPeer

isDownloadDisabled

public boolean isDownloadDisabled()

Specified by:

isDownloadDisabled in interface PEPeer

setHaveAggregationEnabled

public void setHaveAggregationEnabled(boolean enabled)

Specified by:

setHaveAggregationEnabled in interface PEPeer

setPriorityConnection

public void setPriorityConnection(boolean is_priority)

Specified by:

setPriorityConnection in interface PEPeer

isPriorityConnection

public boolean isPriorityConnection()

Specified by:

isPriorityConnection in interface PEPeer

generateEvidence

public void generateEvidence(IndentWriter writer)

Specified by:

generateEvidence in interface PEPeerTransport

getClientNameFromExtensionHandshake

public String getClientNameFromExtensionHandshake()

Specified by:

getClientNameFromExtensionHandshake in interface PEPeer

getClientNameFromPeerID

public String getClientNameFromPeerID()

Specified by:

getClientNameFromPeerID in interface PEPeer

getTaggableType

public int getTaggableType()

getTaggableID

public String getTaggableID()

getTaggableResolver

public TaggableResolver getTaggableResolver()