Class PacketPusher

  • All Implemented Interfaces:

    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.
    • Method Detail

      • 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.
        packet - non-null