Class PeerImpl

java.lang.Object
com.biglybt.core.logging.LogRelation
com.biglybt.pifimpl.local.peers.PeerImpl
All Implemented Interfaces:
Peer
public class PeerImpl extends LogRelation implements Peer

  • Field Details

  • Constructor Details

    • PeerImpl

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

  • Method Details

    • 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

    • isMyPeer

      public boolean isMyPeer()
      Specified by:
      isMyPeer 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:

    • isLANLocal

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

    • resetLANLocalStatus

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

    • 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

    • 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

    • createRGListeners

      private void createRGListeners()

    • 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, int reason_code, boolean closedOnError, boolean attemptReconnect)
      Specified by:
      close in interface Peer

    • readBytes

      public long readBytes(long 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
      Parameters:
      max -
      Returns:

    • writeBytes

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

    • closed

      protected void closed()

    • getCurrentIncomingRequestProgress

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

    • getCurrentOutgoingRequestProgress

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

    • addListener

      public void addListener(PeerListener2 l)
      Description copied from interface: Peer
      Add peer listener.
      Specified by:
      addListener in interface Peer
      Parameters:
      l -

    • removeListener

      public void removeListener(PeerListener2 l)
      Description copied from interface: Peer
      Remove peer listener.
      Specified by:
      removeListener in interface Peer
      Parameters:
      l -

    • 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

    • getDescriptor

      public PeerDescriptor getDescriptor()
      Specified by:
      getDescriptor in interface Peer