net.i2p.router.transport.udp
Class ACKSender
java.lang.Object
net.i2p.router.transport.udp.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 Summary |
(package private) static int |
ACK_FREQUENCY
how frequently do we want to send ACKs to a peer? |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ACK_FREQUENCY
static final int ACK_FREQUENCY
- how frequently do we want to send ACKs to a peer?
- See Also:
- Constant Field Values
ACKSender
public ACKSender(RouterContext ctx,
UDPTransport transport)
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