Package net.i2p.router.transport.udp
Class InboundMessageFragments
java.lang.Object
net.i2p.router.transport.udp.InboundMessageFragments
class InboundMessageFragments extends Object
Organize the received data message fragments, feeding completed messages
to the
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).-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classInboundMessageFragments.ModifiableLongModifiable Long, no locking -
Constructor Summary
Constructors Constructor Description InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport) -
Method Summary
Modifier and Type Method Description booleanisAlive()voidreceiveData(PeerState from, UDPPacketReader.DataReader data)Pull the fragments and ACKs out of the authenticated data packetvoidshutdown()voidstartup()
-
Constructor Details
-
InboundMessageFragments
public InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport)
-
-
Method Details
-
startup
public void startup() -
shutdown
public void shutdown() -
isAlive
public boolean isAlive() -
receiveData
Pull the fragments and ACKs out of the authenticated data packet
-