Field Detail

• MAX_VOLLEYS

  static final int MAX_VOLLEYS

  Maximum number of times to send a packet before failing it.

  See Also:

  Constant Field Values

Constructor Detail

• OutboundMessageFragments

  public OutboundMessageFragments(RouterContext ctx,
                                  UDPTransport transport)

  OutboundMessageFragments.

Method Detail

• add

  public void add(List<OutboundMessageState> states,
                  PeerState peer)

  Short circuit the OutNetMessage, letting us send multiple messages reliably and efficiently.

• add

  public void add(OutboundMessageState state,
                  PeerState peer)

  Short circuit the OutNetMessage, letting us send the establish complete message reliably. If you have multiple messages, use the list variant, so the messages may be bundled efficiently.

• add

  public void add(OutNetMessage msg)

  Add a new message to the active pool

• add

  public void add(PeerState peer,
                  int size)

  Add the peer to the list of peers wanting to transmit something. This wakes up the packet pusher if it is sleeping. Avoid synchronization where possible. There are small chances of races. There are larger chances of adding the PeerState "behind" where the iterator is now... but these issues are the same as before concurrentification.

  Parameters:

  size - the minimum size we can send, or 0 to always notify

• dropPeer

  void dropPeer(PeerState peer)

  Remove a peer from the active outbound list and drop its pending messages.

• getNextVolley

  public List<UDPPacket> getNextVolley()

  Fetch all the packets for a message volley, blocking until there is a message which can be fully transmitted (or the transport is shut down). NOT thread-safe. Called by the PacketPusher thread only.

  Returns:

  null only on shutdown

• nudge

  void nudge()

  Wakes up the packet pusher thread.

• shutdown

  public void shutdown()

  shutdown.

• startup

  public void startup()

  startup.