Class ACKSender

  • All Implemented Interfaces:
    Runnable

    class ACKSender
    extends Object
    implements Runnable
    Blocking thread that is given peers by the inboundFragment pool, sending out any outstanding ACKs. The ACKs are sent directly to UDPSender, bypassing OutboundMessageFragments and PacketPusher.
    • Field Detail

      • ACK_FREQUENCY

        static final int ACK_FREQUENCY
        how frequently do we want to send ACKs to a peer?
        See Also:
        Constant Field Values
    • Method Detail

      • ackPeer

        public void ackPeer​(PeerState peer)
        Add to the queue. For speed, don't check for duplicates here. The runner will remove them in its own thread.
      • startup

        public void startup()
      • shutdown

        public void shutdown()
      • run

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