PacketHandler (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.udp.PacketHandler

```
class PacketHandler
extends Object
```
Pull inbound packets from the inbound receiver's queue, figure out what peer session they belong to (if any), authenticate and decrypt them with the appropriate keys, and push them to the appropriate handler. Data and ACK packets go to the InboundMessageFragments, the various establishment packets go to the EstablishmentManager, and, once implemented, relay packets will go to the relay manager. At the moment, this is an actual pool of packet handler threads, each pulling off the inbound receiver's queue and pushing them as necessary. Supports dynamic thread count adjustment via adjustThreads().

Constructor Summary

Constructors
Constructor and Description
`PacketHandler(RouterContext ctx, UDPTransport transport, EstablishmentManager establisher, InboundMessageFragments inbound, PeerTestManager testManager, IntroductionManager introManager)` Create a new packet handler.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`adjustThreads()` Dynamically adjust handler thread count to match the target.
`int`	`getActiveHandlers()` Returns the current number of active handler threads.
`(package private) String`	`getHandlerStatus()` Get the handler status string.
`static int`	`getMaxHandlers()` Returns the current max packet handler threads.
`int`	`getProcessingCount()` Returns the number of handlers actively processing packets (not parked on take()).
`double`	`getUtilization()` Get packet handler pool utilization as a ratio (0.0-1.0).
`void`	`queueReceived(UDPPacket packet)` Queue a received packet for processing.
`UDPPacket`	`receiveNext()` Blocking call to retrieve the next inbound packet, or null if we have shut down.
`static void`	`setMaxHandlers(int handlers)` Sets the target max packet handler threads.
`void`	`shutdown()` Shut down the packet handler.
`void`	`startup()` Start the packet handler.

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

- Constructor Detail
  - PacketHandler
```
PacketHandler(RouterContext ctx,
              UDPTransport transport,
              EstablishmentManager establisher,
              InboundMessageFragments inbound,
              PeerTestManager testManager,
              IntroductionManager introManager)
```
    Create a new packet handler.
    Parameters:
    ctx - the router context
    transport - the UDP transport
    establisher - the establishment manager
    inbound - the inbound message fragments
    testManager - the peer test manager
    introManager - the introduction manager
- Method Detail
  - adjustThreads
```
void adjustThreads()
```
    Dynamically adjust handler thread count to match the target. Handlers are added or removed one at a time. Excess handlers receive a poison packet and exit cleanly.
  - getActiveHandlers
```
public int getActiveHandlers()
```
    Returns the current number of active handler threads.
    Returns:
    the active handler count
  - getHandlerStatus
```
String getHandlerStatus()
```
    Get the handler status string.
    Returns:
    the status
  - getMaxHandlers
```
public static int getMaxHandlers()
```
    Returns the current max packet handler threads.
    Returns:
    the max handlers
  - getProcessingCount
```
public int getProcessingCount()
```
    Returns the number of handlers actively processing packets (not parked on take()).
    Returns:
    the processing count
  - getUtilization
```
public double getUtilization()
```
    Get packet handler pool utilization as a ratio (0.0-1.0). Returns NaN if not started.
    Returns:
    the utilization ratio
  - queueReceived
```
public void queueReceived(UDPPacket packet)
                   throws InterruptedException
```
    Queue a received packet for processing.
    Parameters:
    packet - the packet
    Throws:
    InterruptedException - if interrupted while waiting
  - receiveNext
```
public UDPPacket receiveNext()
```
    Blocking call to retrieve the next inbound packet, or null if we have shut down.
    Returns:
    the next packet, or null if shut down
  - setMaxHandlers
```
public static void setMaxHandlers(int handlers)
```
    Sets the target max packet handler threads. Takes effect immediately via adjustThreads().
    Parameters:
    handlers - the new max handlers
  - shutdown
```
public void shutdown()
```
    Shut down the packet handler.
  - startup
```
public void startup()
```
    Start the packet handler.

Class PacketHandler

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

PacketHandler

Method Detail

adjustThreads

getActiveHandlers

getHandlerStatus

getMaxHandlers

getProcessingCount

getUtilization

queueReceived

receiveNext

setMaxHandlers

shutdown

startup