class InboundMessageFragments extends Object
MessageReceiver
and telling the PeerState
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).Modifier and Type | Class and Description |
---|---|
static class |
InboundMessageFragments.ModifiableLong
Modifiable Long, no locking
|
Constructor and Description |
---|
InboundMessageFragments(RouterContext ctx,
OutboundMessageFragments outbound,
UDPTransport transport) |
Modifier and Type | Method and Description |
---|---|
boolean |
isAlive() |
boolean |
messageReceived(long messageID)
This message was received.
|
void |
shutdown() |
void |
startup() |
boolean |
wasRecentlyReceived(long messageID)
Was this message recently received?
SSU 2 only.
|
public InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport)
public void startup()
public void shutdown()
public boolean isAlive()
public boolean messageReceived(long messageID)
public boolean wasRecentlyReceived(long messageID)