PrioritySendPool (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.PrioritySendPool

```
public final class PrioritySendPool
extends Object
```
Priority-aware bounded send pool for NTCP transport.
Client messages (PRIORITY_MY_DATA=1000) are always dequeued before transit messages (PRIORITY_PARTICIPATING=200). When the pool is full and a higher-priority message arrives, the lowest-priority message is evicted. Non-blocking: never stalls the caller.
Sorted array with binary search insertion — optimal for the small bounded sizes (64–8192) used by the NTCP send path. Synchronized on the backing list; contention is minimal because the thread that offers almost always polls immediately (handoff pattern).

Constructor Summary
Constructors
Constructor and Description
PrioritySendPool(int capacity)
PrioritySendPool.

Constructors
Constructor and Description
`PrioritySendPool(int capacity)` PrioritySendPool.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`drainTo(ArrayList<OutNetMessage> target)` Drain all messages into the target list (for resize).
`int`	`getAddedCount()` Snapshot of added/evicted/dropped counters since construction.
`int`	`getCapacity()`
`int`	`getDroppedCount()`
`int`	`getEvictedCount()`
`boolean`	`offer(OutNetMessage msg)` Non-blocking offer with priority eviction.
`OutNetMessage`	`poll()` Return the highest-priority message, or null if empty.
`int`	`remainingCapacity()` remainingCapacity.
`void`	`setCapacity(int newCapacity)` Resize the pool.
`int`	`size()` size.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - PrioritySendPool
```
public PrioritySendPool(int capacity)
```
    PrioritySendPool.
- Method Detail
  - drainTo
```
public void drainTo(ArrayList<OutNetMessage> target)
```
    Drain all messages into the target list (for resize).
  - getAddedCount
```
public int getAddedCount()
```
    Snapshot of added/evicted/dropped counters since construction. Callers compute deltas over a time window.
    Returns:
    the added count
  - getCapacity
```
public int getCapacity()
```
    Returns:
    the capacity
  - getDroppedCount
```
public int getDroppedCount()
```
    Returns:
    the dropped count
  - getEvictedCount
```
public int getEvictedCount()
```
    Returns:
    the evicted count
  - offer
```
public boolean offer(OutNetMessage msg)
```
    Non-blocking offer with priority eviction.
    If the pool has room, the message is inserted in sorted position and the method returns true. If the pool is full and the incoming message has strictly higher priority than the lowest-priority message in the pool, the lowest is evicted and the new message takes its place. Otherwise the incoming message is dropped.
    Parameters:
    msg - the outbound message to enqueue
    Returns:
    true if added, false if dropped
  - poll
```
public OutNetMessage poll()
```
    Return the highest-priority message, or null if empty. Highest priority first, FIFO within same priority.
  - remainingCapacity
```
public int remainingCapacity()
```
    remainingCapacity.
  - setCapacity
```
public void setCapacity(int newCapacity)
```
    Resize the pool. New capacity takes effect immediately; if the pool currently exceeds the new capacity, excess low-priority messages are evicted on the next offer().
  - size
```
public int size()
```
    size.

Class PrioritySendPool

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

PrioritySendPool

Method Detail

drainTo

getAddedCount

getCapacity

getDroppedCount

getEvictedCount

offer

poll

remainingCapacity

setCapacity

size