MessageQueue
, OutboundMessageFragments.ActiveThrottle
class TimedWeightedPriorityMessageQueue extends java.lang.Object implements MessageQueue, OutboundMessageFragments.ActiveThrottle
修飾子とタイプ | クラス | 説明 |
---|---|---|
static interface |
TimedWeightedPriorityMessageQueue.FailedListener |
コンストラクタ | 説明 |
---|---|
TimedWeightedPriorityMessageQueue(RouterContext ctx,
int[] priorityLimits,
int[] weighting,
TimedWeightedPriorityMessageQueue.FailedListener lsnr) |
Build up a new queue
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
add(OutNetMessage message) |
Add on a new message to the queue
|
void |
choke(Hash peer) |
|
OutNetMessage |
getNext(long blockUntil) |
Grab the next message out of the next queue.
|
boolean |
isChoked(Hash peer) |
|
void |
shutdown() |
|
void |
unchoke(Hash peer) |
public TimedWeightedPriorityMessageQueue(RouterContext ctx, int[] priorityLimits, int[] weighting, TimedWeightedPriorityMessageQueue.FailedListener lsnr)
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.public void add(OutNetMessage message)
MessageQueue
add
インタフェース内 MessageQueue
public OutNetMessage getNext(long blockUntil)
getNext
インタフェース内 MessageQueue
blockUntil
- expiration, or -1 if indefinitepublic void shutdown()
public void choke(Hash peer)
choke
インタフェース内 OutboundMessageFragments.ActiveThrottle
public void unchoke(Hash peer)
unchoke
インタフェース内 OutboundMessageFragments.ActiveThrottle
public boolean isChoked(Hash peer)
isChoked
インタフェース内 OutboundMessageFragments.ActiveThrottle