Packages that use InboundMessageState
Package
Description
SSU2, the UDP transport: datagram sessions with Holepunch peer discovery, plus the older SSU compatibility code.
Uses of InboundMessageState in net.i2p.router.transport.udp
Fields in net.i2p.router.transport.udp with type parameters of type InboundMessageStateModifier and TypeFieldDescriptionprivate final BlockingQueue<InboundMessageState> MessageReceiver._completeMessagesList of messages (InboundMessageState) fully received but not interpreted yet.protected final ConcurrentMap<Long, InboundMessageState> PeerState._inboundMessagesList of InboundMessageState for active messages.Methods in net.i2p.router.transport.udp that return InboundMessageStateModifier and TypeMethodDescription(package private) static InboundMessageStatePeerState.evictInboundMessage(ConcurrentMap<Long, InboundMessageState> inbound) Make room for one more partially-received inbound message.Methods in net.i2p.router.transport.udp that return types with arguments of type InboundMessageStateModifier and TypeMethodDescription(package private) Map<Long, InboundMessageState> PeerState.getInboundMessages()Fetch the internal id (Long) to InboundMessageState for incomplete inbound messages.Methods in net.i2p.router.transport.udp with parameters of type InboundMessageStateModifier and TypeMethodDescriptionprivate I2NPMessageMessageReceiver.readMessage(ByteArray buf, InboundMessageState state, I2NPMessageHandler handler) Assemble all the fragments into an I2NP message.voidMessageReceiver.receiveMessage(InboundMessageState state) This queues the message for processing.private voidPeerState2.receiveMessage(InboundMessageState state) Do what MessageReceiver does, but inline and for SSU2.Method parameters in net.i2p.router.transport.udp with type arguments of type InboundMessageStateModifier and TypeMethodDescription(package private) static InboundMessageStatePeerState.evictInboundMessage(ConcurrentMap<Long, InboundMessageState> inbound) Make room for one more partially-received inbound message.