Class OutgoingBTPieceMessageHandler

java.lang.Object
com.biglybt.core.peermanager.utils.OutgoingBTPieceMessageHandler

public class OutgoingBTPieceMessageHandler extends Object
Front-end manager for handling requested outgoing bittorrent Piece messages. Peers often make piece requests in batch, with multiple requests always outstanding, all of which won't necessarily be honored (i.e. we choke them), so we don't want to waste time reading in the piece data from disk ahead of time for all the requests. Thus, we only want to perform read-aheads for a small subset of the requested data at any given time, which is what this handler does, before passing the messages onto the outgoing message queue for transmission.
  • Field Details

  • Constructor Details

    • OutgoingBTPieceMessageHandler

      public OutgoingBTPieceMessageHandler(PEPeer _peer, OutgoingMessageQueue _outgoing_message_q, OutgoingBTPieceMessageHandlerAdapter _adapter, byte _piece_version)
      Create a new handler for outbound piece messages, reading piece data from the given disk manager and transmitting the messages out the given message queue.
      Parameters:
      disk_manager -
      outgoing_message_q -
  • Method Details

    • setPieceVersion

      public void setPieceVersion(byte version)
    • trimRecentMessages

      private void trimRecentMessages()
    • addPieceRequest

      public boolean addPieceRequest(int piece_number, int piece_offset, int length)
      Register a new piece data request.
      Parameters:
      piece_number -
      piece_offset -
      length -
    • removePieceRequest

      public void removePieceRequest(int piece_number, int piece_offset, int length)
      Remove an outstanding piece data request.
      Parameters:
      piece_number -
      piece_offset -
      length -
    • removeAllPieceRequests

      public void removeAllPieceRequests()
      Remove all outstanding piece data requests.
    • setRequestReadAhead

      public void setRequestReadAhead(int num_to_read_ahead)
    • destroy

      public void destroy()
    • doReadAheadLoads

      private void doReadAheadLoads()
    • getRequestedPieceNumbers

      public int[] getRequestedPieceNumbers()
      Get a list of piece numbers being requested
    • getRequestedPieceNumberCount

      public int getRequestedPieceNumberCount()
    • getRecentMessages

      public DiskManagerReadRequest[] getRecentMessages()
    • getRequestCount

      public int getRequestCount()
    • isStalledPendingLoad

      public boolean isStalledPendingLoad()