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

java.lang.Object
  extended by org.gudy.azureus2.core3.logging.LogRelation
      extended by org.gudy.azureus2.pluginsimpl.local.peers.PeerImpl
All Implemented Interfaces:
Peer

public class PeerImpl
extends LogRelation
implements Peer


Field Summary
protected  PEPeer delegate
           
protected  PeerManagerImpl manager
           
 
Fields inherited from interface org.gudy.azureus2.plugins.peers.Peer
CLOSING, CONNECTING, DISCONNECTED, HANDSHAKING, PR_PRIORITY_CONNECTION, PR_PROTOCOL, PR_PROTOCOL_QUALIFIER, TRANSFERING
 
Constructor Summary
protected PeerImpl(PEPeer _delegate)
          don't use me, use PeerManagerImpl.getPeerForPEPeer
 
Method Summary
 void addListener(PeerListener l)
          Add peer listener.
 void addListener(PeerListener2 l)
          Add peer listener.
 void addRateLimiter(RateLimiter limiter, boolean is_upload)
           
 boolean addRequest(PeerReadRequest request)
           
 void bindConnection(ConnectionStub stub)
           
 void cancelRequest(PeerReadRequest request)
           
 void close(String reason, boolean closedOnError, boolean attemptReconnect)
           
protected  void closed()
           
 boolean equals(Object other)
           
 boolean[] getAvailable()
           
 String getClient()
           
 Connection getConnection()
          Get the network connection that backs this peer.
 PEPeer getDelegate()
           
 List getExpiredRequests()
           
 byte[] getHandshakeReservedBytes()
           
 byte[] getId()
           
 String getIp()
          Get the peer's local TCP connection port.
 PeerManager getManager()
           
 int getMaximumNumberOfRequests()
           
 int getNumberOfRequests()
           
 int getOutgoingRequestCount()
           
 int[] getOutgoingRequestedPieceNumbers()
           
 PEPeer getPEPeer()
          Core use only.
 int getPercentDone()
           
 int getPercentDoneInThousandNotation()
           
 int getPercentDoneOfCurrentIncomingRequest()
           
 int getPercentDoneOfCurrentOutgoingRequest()
           
 int getPort()
           
 int[] getPriorityOffsets()
           
 Object[] getQueryableInterfaces()
          Query this class for a reference to another class that it may hold
 RateLimiter[] getRateLimiters(boolean is_upload)
           
 String getRelationText()
          A short description of what your class holds that can be printed by the logger
 List getRequests()
           
 long getSnubbedTime()
           
 int getState()
           
 PeerStats getStats()
           
 Message[] getSupportedMessages()
          Get the list of messages that this peer and us mutually understand.
 int getTCPListenPort()
          Get the TCP port this peer is listening for incoming connections on.
 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
 Object getUserData(Object key)
           
 int hashCode()
           
 void initialize()
           
 boolean isChoked()
           
 boolean isChoking()
           
 boolean isDownloadPossible()
          This is much list isTransferAvailable(), except is more comprehensive.
 boolean isIncoming()
           
 boolean isInterested()
           
 boolean isInteresting()
           
 boolean isOptimisticUnchoke()
           
 boolean isPieceAvailable(int pieceNumber)
           
 boolean isPriorityConnection()
           
 boolean isSeed()
           
 boolean isSnubbed()
           
 boolean isTransferAvailable()
           
 int readBytes(int max)
          Rate control - gives the maximum number of bytes that can be read from this connection at this time and returns the actual number read
 void removeListener(PeerListener l)
          Remove peer listener.
 void removeListener(PeerListener2 l)
          Remove peer listener.
 void removeRateLimiter(RateLimiter limiter, boolean is_upload)
           
 void requestAllocationComplete()
           
 boolean requestAllocationStarts(int[] base_priorities)
           
 void setOptimisticUnchoke(boolean is_optimistic)
           
 void setPriorityConnection(boolean is_priority)
           
 void setSnubbed(boolean b)
           
 void setUserData(Object key, Object value)
           
 boolean supportsMessaging()
          Whether or not this peer supports the advanced messaging API.
 int writeBytes(int max)
           
 
Methods inherited from class org.gudy.azureus2.core3.logging.LogRelation
propogatedRelationText, queryForClass, queryForClass
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

manager

protected PeerManagerImpl manager

delegate

protected PEPeer delegate
Constructor Detail

PeerImpl

protected PeerImpl(PEPeer _delegate)
don't use me, use PeerManagerImpl.getPeerForPEPeer

Parameters:
_delegate -
Method Detail

bindConnection

public void bindConnection(ConnectionStub stub)
Specified by:
bindConnection in interface Peer

getManager

public PeerManager getManager()
Specified by:
getManager in interface Peer

getDelegate

public PEPeer getDelegate()

getConnection

public Connection getConnection()
Description copied from interface: Peer
Get the network connection that backs this peer.

Specified by:
getConnection in interface Peer
Returns:
connection

supportsMessaging

public boolean supportsMessaging()
Description copied from interface: Peer
Whether or not this peer supports the advanced messaging API.

Specified by:
supportsMessaging in interface Peer
Returns:
true if extended messaging is supported, false if not

getSupportedMessages

public Message[] getSupportedMessages()
Description copied from interface: Peer
Get the list of messages that this peer and us mutually understand.

Specified by:
getSupportedMessages in interface Peer
Returns:
messages available for use, or null of supported is yet unknown

getState

public int getState()
Specified by:
getState in interface Peer

getId

public byte[] getId()
Specified by:
getId in interface Peer

getIp

public String getIp()
Description copied from interface: Peer
Get the peer's local TCP connection port.

Specified by:
getIp in interface Peer
Returns:
local port

getPort

public int getPort()
Specified by:
getPort in interface Peer

getTCPListenPort

public int getTCPListenPort()
Description copied from interface: Peer
Get the TCP port this peer is listening for incoming connections on.

Specified by:
getTCPListenPort in interface Peer
Returns:
TCP port, or 0 if port is unknown

getUDPListenPort

public int getUDPListenPort()
Description copied from interface: Peer
Get the UDP port this peer is listening for incoming connections on.

Specified by:
getUDPListenPort in interface Peer
Returns:
UDP port, or 0 if port is unknown

getUDPNonDataListenPort

public int getUDPNonDataListenPort()
Description copied from interface: Peer
Get the UDP port this peer is listening on for non-data connections

Specified by:
getUDPNonDataListenPort in interface Peer
Returns:

getAvailable

public final boolean[] getAvailable()
Specified by:
getAvailable in interface Peer

isPieceAvailable

public boolean isPieceAvailable(int pieceNumber)
Specified by:
isPieceAvailable in interface Peer
Parameters:
pieceNumber - int
Returns:
true if this peers makes this piece available

isTransferAvailable

public boolean isTransferAvailable()
Specified by:
isTransferAvailable in interface Peer

isDownloadPossible

public boolean isDownloadPossible()
Description copied from interface: Peer
This is much list isTransferAvailable(), except is more comprehensive. That is; it checks a few more factors, within the object for speed, so that a more timely status is considered and the caller doesn't need to try to check each thing on it's own.

Specified by:
isDownloadPossible in interface Peer
Returns:
true if several factors say downloading can be tried.

isChoked

public boolean isChoked()
Specified by:
isChoked in interface Peer

isChoking

public boolean isChoking()
Specified by:
isChoking in interface Peer

isInterested

public boolean isInterested()
Specified by:
isInterested in interface Peer

isInteresting

public boolean isInteresting()
Specified by:
isInteresting in interface Peer

isSeed

public boolean isSeed()
Specified by:
isSeed in interface Peer

isSnubbed

public boolean isSnubbed()
Specified by:
isSnubbed in interface Peer

getSnubbedTime

public long getSnubbedTime()
Specified by:
getSnubbedTime in interface Peer

setSnubbed

public void setSnubbed(boolean b)
Specified by:
setSnubbed in interface Peer

getStats

public PeerStats getStats()
Specified by:
getStats in interface Peer

isIncoming

public boolean isIncoming()
Specified by:
isIncoming in interface Peer

getPercentDone

public int getPercentDone()
Specified by:
getPercentDone in interface Peer
Returns:

getOutgoingRequestCount

public int getOutgoingRequestCount()
Specified by:
getOutgoingRequestCount in interface Peer

getOutgoingRequestedPieceNumbers

public int[] getOutgoingRequestedPieceNumbers()
Specified by:
getOutgoingRequestedPieceNumbers in interface Peer

getPercentDoneInThousandNotation

public int getPercentDoneInThousandNotation()
Specified by:
getPercentDoneInThousandNotation in interface Peer

getClient

public String getClient()
Specified by:
getClient in interface Peer

isOptimisticUnchoke

public boolean isOptimisticUnchoke()
Specified by:
isOptimisticUnchoke in interface Peer

setOptimisticUnchoke

public void setOptimisticUnchoke(boolean is_optimistic)
Specified by:
setOptimisticUnchoke in interface Peer

initialize

public void initialize()

getExpiredRequests

public List getExpiredRequests()
Specified by:
getExpiredRequests in interface Peer

getRequests

public List getRequests()
Specified by:
getRequests in interface Peer

getNumberOfRequests

public int getNumberOfRequests()
Specified by:
getNumberOfRequests in interface Peer

getMaximumNumberOfRequests

public int getMaximumNumberOfRequests()
Specified by:
getMaximumNumberOfRequests in interface Peer

getPriorityOffsets

public int[] getPriorityOffsets()
Specified by:
getPriorityOffsets in interface Peer

requestAllocationStarts

public boolean requestAllocationStarts(int[] base_priorities)
Specified by:
requestAllocationStarts in interface Peer

requestAllocationComplete

public void requestAllocationComplete()
Specified by:
requestAllocationComplete in interface Peer

cancelRequest

public void cancelRequest(PeerReadRequest request)
Specified by:
cancelRequest in interface Peer

addRequest

public boolean addRequest(PeerReadRequest request)
Specified by:
addRequest in interface Peer

addRateLimiter

public void addRateLimiter(RateLimiter limiter,
                           boolean is_upload)
Specified by:
addRateLimiter in interface Peer
Parameters:
limiter - create via ConnectionManager
is_upload - false -> download limit

removeRateLimiter

public void removeRateLimiter(RateLimiter limiter,
                              boolean is_upload)
Specified by:
removeRateLimiter in interface Peer

getRateLimiters

public RateLimiter[] getRateLimiters(boolean is_upload)
Specified by:
getRateLimiters in interface Peer

close

public void close(String reason,
                  boolean closedOnError,
                  boolean attemptReconnect)
Specified by:
close in interface Peer

readBytes

public int readBytes(int max)
Description copied from interface: Peer
Rate control - gives the maximum number of bytes that can be read from this connection at this time and returns the actual number read

Specified by:
readBytes in interface Peer
Returns:

writeBytes

public int writeBytes(int max)
Specified by:
writeBytes in interface Peer

closed

protected void closed()

getPercentDoneOfCurrentIncomingRequest

public int getPercentDoneOfCurrentIncomingRequest()
Specified by:
getPercentDoneOfCurrentIncomingRequest in interface Peer

getPercentDoneOfCurrentOutgoingRequest

public int getPercentDoneOfCurrentOutgoingRequest()
Specified by:
getPercentDoneOfCurrentOutgoingRequest in interface Peer

addListener

public void addListener(PeerListener l)
Description copied from interface: Peer
Add peer listener.

Specified by:
addListener in interface Peer

removeListener

public void removeListener(PeerListener l)
Description copied from interface: Peer
Remove peer listener.

Specified by:
removeListener in interface Peer

addListener

public void addListener(PeerListener2 l)
Description copied from interface: Peer
Add peer listener.

Specified by:
addListener in interface Peer

removeListener

public void removeListener(PeerListener2 l)
Description copied from interface: Peer
Remove peer listener.

Specified by:
removeListener in interface Peer

isPriorityConnection

public boolean isPriorityConnection()
Specified by:
isPriorityConnection in interface Peer

setPriorityConnection

public void setPriorityConnection(boolean is_priority)
Specified by:
setPriorityConnection in interface Peer

setUserData

public void setUserData(Object key,
                        Object value)
Specified by:
setUserData in interface Peer

getUserData

public Object getUserData(Object key)
Specified by:
getUserData in interface Peer

equals

public boolean equals(Object other)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object

getPEPeer

public PEPeer getPEPeer()
Core use only. This is not propogated to the plugin interface

Returns:
PEPeer object associated with the plugin Peer object

getRelationText

public String getRelationText()
Description copied from class: LogRelation
A short description of what your class holds that can be printed by the logger

Overrides:
getRelationText in class LogRelation
Returns:

getQueryableInterfaces

public Object[] getQueryableInterfaces()
Description copied from class: LogRelation
Query this class for a reference to another class that it may hold

Overrides:
getQueryableInterfaces in class LogRelation
Returns:
If found, the class desired. Otherwise, null.

getHandshakeReservedBytes

public byte[] getHandshakeReservedBytes()
Specified by:
getHandshakeReservedBytes in interface Peer