net.i2p.router.transport.udp
Class PacketHandler

java.lang.Object
  extended by 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.


Constructor Summary
PacketHandler(RouterContext ctx, UDPTransport transport, EstablishmentManager establisher, InboundMessageFragments inbound, PeerTestManager testManager, IntroductionManager introManager)
           
 
Method Summary
(package private)  String getHandlerStatus()
           
 void queueReceived(UDPPacket packet)
          Blocking call to retrieve the next inbound packet, or null if we have shut down.
 UDPPacket receiveNext()
          Blocking call to retrieve the next inbound packet, or null if we have shut down.
 void shutdown()
           
 void startup()
           
 
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)
Method Detail

startup

public void startup()

shutdown

public void shutdown()

getHandlerStatus

String getHandlerStatus()

queueReceived

public void queueReceived(UDPPacket packet)
                   throws InterruptedException
Blocking call to retrieve the next inbound packet, or null if we have shut down.

Throws:
InterruptedException
Since:
IPv6 moved from UDPReceiver

receiveNext

public UDPPacket receiveNext()
Blocking call to retrieve the next inbound packet, or null if we have shut down.

Since:
IPv6 moved from UDPReceiver