class InboundMessageFragments extends Object
MessageReceiver
and telling the ACKSender
of new
peers to ACK. In addition, it drops failed fragments and keeps a
minimal list of the most recently completed messages (even though higher
up in the router we have full blown replay detection, its nice to have a
basic line of defense here).Constructor and Description |
---|
InboundMessageFragments(RouterContext ctx,
OutboundMessageFragments outbound,
UDPTransport transport) |
Modifier and Type | Method and Description |
---|---|
boolean |
isAlive() |
void |
receiveData(PeerState from,
UDPPacketReader.DataReader data)
Pull the fragments and ACKs out of the authenticated data packet
|
void |
shutdown() |
void |
startup() |
public InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport)
public void startup()
public void shutdown()
public boolean isAlive()
public void receiveData(PeerState from, UDPPacketReader.DataReader data)