コンストラクタの詳細

• TimedWeightedPriorityMessageQueue

  public TimedWeightedPriorityMessageQueue​(RouterContext ctx,
                                           int[] priorityLimits,
                                           int[] weighting,
                                           TimedWeightedPriorityMessageQueue.FailedListener lsnr)

  Build up a new queue

  パラメータ:

  priorityLimits - ordered breakpoint for the different message priorities, with the lowest limit first.

  weighting - how much to prefer a given priority grouping. specifically, this means how many messages in this queue should be pulled off in a row before moving on to the next.

メソッドの詳細

• add

  public void add​(OutNetMessage message)

  インタフェースからコピーされた説明: MessageQueue
  Add on a new message to the queue

  定義:

  add インタフェース内 MessageQueue

• getNext

  public OutNetMessage getNext​(long blockUntil)

  Grab the next message out of the next queue. This only advances the _nextQueue var after pushing _weighting[currentQueue] messages or the queue is empty. This call blocks until either a message becomes available or the queue is shut down.

  定義:

  getNext インタフェース内 MessageQueue

  パラメータ:

  blockUntil - expiration, or -1 if indefinite

  戻り値:

  message dequeued, or null if the queue was shut down

• shutdown

  public void shutdown​()

• choke

  public void choke​(Hash peer)

  定義:

  choke インタフェース内 OutboundMessageFragments.ActiveThrottle

• unchoke

  public void unchoke​(Hash peer)

  定義:

  unchoke インタフェース内 OutboundMessageFragments.ActiveThrottle

• isChoked

  public boolean isChoked​(Hash peer)

  定義:

  isChoked インタフェース内 OutboundMessageFragments.ActiveThrottle