net.i2p.router.transport.udp.TimedWeightedPriorityMessageQueue

All Implemented Interfaces:: MessageQueue, OutboundMessageFragments.ActiveThrottle

class TimedWeightedPriorityMessageQueue
extends Object
implements MessageQueue, OutboundMessageFragments.ActiveThrottle

Weighted priority queue implementation for the outbound messages, coupled with code to fail messages that expire. WARNING - UNUSED since 0.6.1.11 See comments in DummyThrottle.java and mtn history ca. 2006-02-19

Nested Class Summary

Nested Classes

Modifier and Type Class Description

static interface TimedWeightedPriorityMessageQueue.FailedListener

Constructor Summary

Constructors
Constructor	Description
`TimedWeightedPriorityMessageQueue(RouterContext ctx, int[] priorityLimits, int[] weighting, TimedWeightedPriorityMessageQueue.FailedListener lsnr)`	Build up a new queue

Method Summary

Modifier and Type	Method	Description
`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)`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- TimedWeightedPriorityMessageQueue
  
  public TimedWeightedPriorityMessageQueue(RouterContext ctx, int[] priorityLimits, int[] weighting, TimedWeightedPriorityMessageQueue.FailedListener lsnr)
  
  Build up a new queue
  
  Parameters:
  
  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.
Method Details
- add
  
  public void add(OutNetMessage message)
  
  Description copied from interface: MessageQueue
  
  Add on a new message to the queue
  
  Specified by:
  
  add in interface 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.
  
  Specified by:
  
  getNext in interface MessageQueue
  
  Parameters:
  
  blockUntil - expiration, or -1 if indefinite
  
  Returns:
  
  message dequeued, or null if the queue was shut down
- shutdown
  
  public void shutdown()
- choke
  
  public void choke(Hash peer)
  
  Specified by:
  
  choke in interface OutboundMessageFragments.ActiveThrottle
- unchoke
  
  public void unchoke(Hash peer)
  
  Specified by:
  
  unchoke in interface OutboundMessageFragments.ActiveThrottle
- isChoked
  
  public boolean isChoked(Hash peer)
  
  Specified by:
  
  isChoked in interface OutboundMessageFragments.ActiveThrottle

Class TimedWeightedPriorityMessageQueue

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

TimedWeightedPriorityMessageQueue

Method Details

add

getNext

shutdown

choke

unchoke

isChoked