Uses of Class
io.github.mahmoudimus.quic.connection.Retransmits
Packages that use Retransmits
Package
Description
The sans-I/O QUIC connection and endpoint, ported from quinn-proto: the
Connection state machine (handshake, packet assembly and
processing, key updates, closing and draining), the Endpoint that routes datagrams and answers with Version
Negotiation, Retry and stateless resets, their configurations (TransportConfig, ServerConfig, ClientConfig, EndpointConfig), and the building blocks they are made of:
range sets (RangeSet), reassembly of received data
(Assembler), buffering of sent data (SendBuffer), streams and flow control (StreamsState), packet number spaces and ACK generation
(PacketSpace), loss detection (Recovery), pacing (Pacer), path MTU discovery (MtuDiscovery) and timers (TimerTable).-
Uses of Retransmits in io.github.mahmoudimus.quic.connection
Methods in io.github.mahmoudimus.quic.connection that return RetransmitsModifier and TypeMethodDescriptionPacketSpace.pending()The frames waiting to be sent in this space.SentPacket.retransmits()The control frames the packet carried.Methods in io.github.mahmoudimus.quic.connection with parameters of type RetransmitsModifier and TypeMethodDescriptionvoidRetransmits.merge(Retransmits other) Merges another set of pending frames into this one.RemoteCidQueue.onNewConnectionId(Frame.NewConnectionId frame, Retransmits pending) Processes a NEW_CONNECTION_ID frame as the connection does: stores the ID and queues RETIRE_CONNECTION_ID frames for the IDs it retires.booleanStreamsState.queueMaxStreamId(Retransmits retransmits) Queues MAX_STREAMS if enough remote streams closed: more than an eighth of the concurrency limit.StreamsState.read(StreamId id, boolean ordered, Retransmits retransmits) Starts reading a stream.voidStreamsState.reset(StreamId id, long errorCode, Retransmits retransmits) Abandons sending on a stream (RESET_STREAM).voidStreamsState.stop(StreamId id, long errorCode, Retransmits retransmits) Stops receiving a stream (STOP_SENDING).longStreamsState.takeReset(StreamId id, Retransmits retransmits) Whether the peer reset a stream.intStreamsState.write(StreamId id, ByteBuffer data, Retransmits pending) Writes data, copying as much as flow control and the send window accept.StreamsState.writeChunks(StreamId id, ByteBuffer[] chunks, Retransmits pending) Writes buffers without copying them: the stream keeps views until the data is acknowledged, so their contents must not change.voidStreamsState.writeControlFrames(ByteBuffer buf, Retransmits retransmits, Retransmits sent, int maxSize) Writes pending stream control frames: RESET_STREAM, STOP_SENDING, MAX_DATA, MAX_STREAM_DATA, MAX_STREAMS, STREAMS_BLOCKED, DATA_BLOCKED and STREAM_DATA_BLOCKED, as many as fit.Constructors in io.github.mahmoudimus.quic.connection with parameters of type RetransmitsModifierConstructorDescriptionSentPacket(long timeSent, int size, boolean ackEliciting, long largestAcked, Retransmits retransmits, List<StreamMeta> streamFrames) A sent packet.