Package net.i2p.router.transport.udp

Class PacketPusher

java.lang.Object
net.i2p.router.transport.udp.PacketPusher
All Implemented Interfaces:
Runnable
class PacketPusher
extends Object
implements Runnable
Blocking thread to grab new packets off the outbound fragment pool and toss 'em onto the outbound packet queues. Here we select which UDPEndpoint/UDPSender to send it out.

  • Constructor Details

  • Method Details

    • startup

      public void startup()

    • shutdown

      public void shutdown()

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • send

      public void send​(UDPPacket packet)
      This sends it directly out, bypassing OutboundMessageFragments and the PacketPusher. The only queueing is for the bandwidth limiter. BLOCKING if OB queue is full.
      Parameters:
      packet - non-null
      Since:
      IPv6