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

Fields

Modifier and Type Field Description

(package private) static int ACK_FREQUENCY
how frequently do we want to send ACKs to a peer?
Constructor Summary

Constructors

Constructor Description

ACKSender(RouterContext ctx, UDPTransport transport)
Method Summary

Modifier and Type Method Description

void ackPeer(PeerState peer)
Add to the queue.

void run()

void shutdown()

void startup()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- ACK_FREQUENCY
  
  static final int ACK_FREQUENCY
  
  how frequently do we want to send ACKs to a peer?
  
  See Also:
  
  Constant Field Values
Constructor Details
- ACKSender
  
  public ACKSender(RouterContext ctx, UDPTransport transport)
Method Details
- 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

Modifier and Type	Method	Description
`void`	`ackPeer(PeerState peer)`	Add to the queue.
`void`	`run()`
`void`	`shutdown()`
`void`	`startup()`

Class ACKSender

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

ACK_FREQUENCY

Constructor Details

ACKSender

Method Details

ackPeer

startup

shutdown

run