Nested and Inner Type Summary

Modifier and Type	Class and Description
public static class	OrderedFlow.CryptoDataFlow A subclass of `OrderedFlow` used to reorder instances of `CryptoFrame`.
public static class	OrderedFlow.StreamDataFlow A subclass of `OrderedFlow` used to reorder instances of `StreamFrame`.

Field Summary

Modifier and Type	Field and Description
pack-priv long	buffered
private final ToIntFunction<T>	length
pack-priv long	offset
private final ToLongFunction<T>	position
private final ConcurrentSkipListSet<T>	queue

Constructor Summary

Access Constructor and Description

Access	Constructor and Description
public	OrderedFlow(Comparator<T> A comparator to order the frames according to their position in the ordered flow. Typically, this will compare the frame's offset: the frame with the smaller offset will be sorted before the frame with the greater offset comparator, ToLongFunction<T> A method reference that returns the position of the frame in the flow. For instance, this would be `CryptoFrame::offset` if `<T>` is `CryptoFrame`, or `StreamFrame::offset` if `<T>` is `StreamFrame` position, ToIntFunction<T> A method reference that returns the number of bytes in the frame data. This is used to compute the expected position of the next frame in the flow. For instance, this would be `CryptoFrame::length` if `<T>` is `CryptoFrame`, or `StreamFrame::dataLength` if `<T>` is `StreamFrame` length) Constructs a new instance of ordered flow to reorder frames in a given flow.

public

OrderedFlow(Comparator<T>

A comparator to order the frames according to their position in the ordered flow. Typically, this will compare the frame's offset: the frame with the smaller offset will be sorted before the frame with the greater offset

comparator, ToLongFunction<T>

A method reference that returns the position of the frame in the flow. For instance, this would be CryptoFrame::offset if <T> is CryptoFrame, or StreamFrame::offset if <T> is StreamFrame

position, ToIntFunction<T>

A method reference that returns the number of bytes in the frame data. This is used to compute the expected position of the next frame in the flow. For instance, this would be CryptoFrame::length if <T> is CryptoFrame, or StreamFrame::dataLength if <T> is StreamFrame

length)

Constructs a new instance of ordered flow to reorder frames in a given flow.

Method Summary

Modifier and Type	Method and Description
public long	Returns: the number of bytes buffered buffered() Returns the number of bytes buffered.
public void	clear() Drops all buffered frames
private long	Returns: the amount of dropped data dropuntil(long the offset below which frames should be dropped offset) Drop all frames in the buffer whose position is strictly below offset.
private void	enqueue(T frame, long pos, int length, long after)
public boolean	Returns: true if there are no buffered frames isEmpty() Returns true if there are no buffered frames.
public long	Returns: the current offset of this buffer offset() Returns the current offset of this buffer.
private T	peekFirst()
public T	Returns: the head of the queue if it is at the current offset, or `null` poll() Removes and return the head of the queue if it is at the current offset.
private T	Returns: a received frame at the current flow offset, or `null` poll(long the minimal offset offset) Pretends to receive the head of the queue, if it is at the provided offset
public T	Returns: the next frame in the flow, or `null` if it is not available yet. receive(T a frame that was received frame) Receives a new frame.
public int	Returns: the number of buffered frames size() Returns the number of buffered frames.
protected abstract T	Returns: a slice of the given frame slice(T the frame to slice frame, long the new frame offset offset, int the new frame length length) Returns a slice of the given frame.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

buffered	back to summary
pack-priv long buffered

length	back to summary
private final ToIntFunction<T> length

offset	back to summary
pack-priv long offset

position	back to summary
private final ToLongFunction<T> position

queue	back to summary
private final ConcurrentSkipListSet<T> queue

Constructor Detail

OrderedFlow back to summary

OrderedFlow	back to summary
public OrderedFlow(Comparator<T> comparator, ToLongFunction<T> position, ToIntFunction<T> length) Constructs a new instance of ordered flow to reorder frames in a given flow. Parameters comparator:Comparator<T> A comparator to order the frames according to their position in the ordered flow. Typically, this will compare the frame's offset: the frame with the smaller offset will be sorted before the frame with the greater offset position:ToLongFunction<T> A method reference that returns the position of the frame in the flow. For instance, this would be `CryptoFrame::offset` if `<T>` is `CryptoFrame`, or `StreamFrame::offset` if `<T>` is `StreamFrame` length:ToIntFunction<T> A method reference that returns the number of bytes in the frame data. This is used to compute the expected position of the next frame in the flow. For instance, this would be `CryptoFrame::length` if `<T>` is `CryptoFrame`, or `StreamFrame::dataLength` if `<T>` is `StreamFrame`

public OrderedFlow(Comparator<T> comparator, ToLongFunction<T> position, ToIntFunction<T> length)

Constructs a new instance of ordered flow to reorder frames in a given flow.

Parameters

comparator:Comparator<T>: A comparator to order the frames according to their position in the ordered flow. Typically, this will compare the frame's offset: the frame with the smaller offset will be sorted before the frame with the greater offset
position:ToLongFunction<T>: A method reference that returns the position of the frame in the flow. For instance, this would be CryptoFrame::offset if <T> is CryptoFrame, or StreamFrame::offset if <T> is StreamFrame
length:ToIntFunction<T>: A method reference that returns the number of bytes in the frame data. This is used to compute the expected position of the next frame in the flow. For instance, this would be CryptoFrame::length if <T> is CryptoFrame, or StreamFrame::dataLength if <T> is StreamFrame

Method Detail

buffered	back to summary
public long buffered() Returns the number of bytes buffered. Returns:long the number of bytes buffered

buffered

back to summary

public long buffered()

Returns the number of bytes buffered.

Returns:long: the number of bytes buffered

clear	back to summary
public void clear() Drops all buffered frames

dropuntil	back to summary
private long dropuntil(long offset) Drop all frames in the buffer whose position is strictly below offset. Parameters offset:long the offset below which frames should be dropped Returns:long the amount of dropped data

dropuntil

back to summary

private long dropuntil(long offset)

Drop all frames in the buffer whose position is strictly below offset.

Parameters

offset:long: the offset below which frames should be dropped

Returns:long

the amount of dropped data

enqueue	back to summary
private void enqueue(T frame, long pos, int length, long after)

isEmpty	back to summary
public boolean isEmpty() Returns true if there are no buffered frames. Returns:boolean true if there are no buffered frames

isEmpty

back to summary

public boolean isEmpty()

Returns true if there are no buffered frames.

Returns:boolean: true if there are no buffered frames

offset	back to summary
public long offset() Returns the current offset of this buffer. Returns:long the current offset of this buffer

offset

back to summary

public long offset()

Returns the current offset of this buffer.

Returns:long: the current offset of this buffer

peekFirst	back to summary
private T peekFirst()

poll back to summary

poll	back to summary
public T poll() Removes and return the head of the queue if it is at the current offset. Otherwise, returns null. Returns:T the head of the queue if it is at the current offset, or `null`

public T poll()

Removes and return the head of the queue if it is at the current offset. Otherwise, returns null.

Returns:T: the head of the queue if it is at the current offset, or null

poll back to summary

poll	back to summary
private T poll(long offset) Pretends to receive the head of the queue, if it is at the provided offset Parameters offset:long the minimal offset Returns:T a received frame at the current flow offset, or `null`

private T poll(long offset)

Pretends to receive the head of the queue, if it is at the provided offset

Parameters

offset:long: the minimal offset

Returns:T

a received frame at the current flow offset, or null

receive back to summary

receive	back to summary
public T receive(T frame) Receives a new frame. If the frame is below the current offset the frame is dropped. If it is above the current offset, it is queued. If the frame is exactly at the current offset, it is returned. Parameters frame:T a frame that was received Returns:T the next frame in the flow, or `null` if it is not available yet.

public T receive(T frame)

Receives a new frame. If the frame is below the current offset the frame is dropped. If it is above the current offset, it is queued. If the frame is exactly at the current offset, it is returned.

Parameters

frame:T: a frame that was received

Returns:T

the next frame in the flow, or null if it is not available yet.

size	back to summary
public int size() Returns the number of buffered frames. Returns:int the number of buffered frames

size

back to summary

public int size()

Returns the number of buffered frames.

Returns:int: the number of buffered frames

slice	back to summary
protected abstract T slice(T frame, long offset, int length) Returns a slice of the given frame. Parameters frame:T the frame to slice offset:long the new frame offset length:int the new frame length Returns:T a slice of the given frame Exceptions IndexOutOfBoundsException: if the new offset or length fall outside of the frame's bounds

slice

back to summary

protected abstract T slice(T frame, long offset, int length)

Returns a slice of the given frame.

Parameters

frame:T: the frame to slice
offset:long: the new frame offset
length:int: the new frame length

Returns:T

a slice of the given frame

Exceptions

IndexOutOfBoundsException:: if the new offset or length fall outside of the frame's bounds

jdk.internal.net.http.quic back to summary

public final Class OrderedFlow.CryptoDataFlow

Class Inheritance

extends OrderedFlow<CryptoFrame>

java.lang.Object
jdk.internal.net.http.quic.OrderedFlow
jdk.internal.net.http.quic.OrderedFlow.CryptoDataFlow

A subclass of OrderedFlow used to reorder instances of CryptoFrame.

Field Summary

Inherited from jdk.internal.net.http.quic.OrderedFlow:: buffered offset

Constructor Summary

Access	Constructor and Description
public	CryptoDataFlow() Constructs a new instance of `CryptoDataFlow` to reorder a flow of `CryptoFrame` instances.

Method Summary

Modifier and Type	Method and Description
protected CryptoFrame	slice(CryptoFrame frame, long offset, int length) Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice. Returns a slice of the given frame.

Inherited from jdk.internal.net.http.quic.OrderedFlow:: buffered clear isEmpty offset poll receive size

Constructor Detail

CryptoDataFlow	back to summary
public CryptoDataFlow() Constructs a new instance of `CryptoDataFlow` to reorder a flow of `CryptoFrame` instances.

Method Detail

slice	back to summary
protected CryptoFrame slice(CryptoFrame frame, long offset, int length) Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice. Doc from jdk.internal.net.http.quic.OrderedFlow.slice. Returns a slice of the given frame. Annotations @Override

slice

back to summary

protected CryptoFrame slice(CryptoFrame frame, long offset, int length)

Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice.

Doc from jdk.internal.net.http.quic.OrderedFlow.slice.

Returns a slice of the given frame.

Annotations

@Override

jdk.internal.net.http.quic back to summary

public final Class OrderedFlow.StreamDataFlow

Class Inheritance

extends OrderedFlow<StreamFrame>

java.lang.Object
jdk.internal.net.http.quic.OrderedFlow
jdk.internal.net.http.quic.OrderedFlow.StreamDataFlow

A subclass of OrderedFlow used to reorder instances of StreamFrame.

Field Summary

Inherited from jdk.internal.net.http.quic.OrderedFlow:: buffered offset

Constructor Summary

Access	Constructor and Description
public	StreamDataFlow() Constructs a new instance of `StreamDataFlow` to reorder a flow of `StreamFrame` instances.

Method Summary

Modifier and Type	Method and Description
protected StreamFrame	slice(StreamFrame frame, long offset, int length) Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice. Returns a slice of the given frame.

Inherited from jdk.internal.net.http.quic.OrderedFlow:: buffered clear isEmpty offset poll receive size

Constructor Detail

StreamDataFlow	back to summary
public StreamDataFlow() Constructs a new instance of `StreamDataFlow` to reorder a flow of `StreamFrame` instances.

Method Detail

slice	back to summary
protected StreamFrame slice(StreamFrame frame, long offset, int length) Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice. Doc from jdk.internal.net.http.quic.OrderedFlow.slice. Returns a slice of the given frame. Annotations @Override

slice

back to summary

protected StreamFrame slice(StreamFrame frame, long offset, int length)

Implements abstract jdk.internal.net.http.quic.OrderedFlow.slice.

Doc from jdk.internal.net.http.quic.OrderedFlow.slice.

Returns a slice of the given frame.

Annotations

@Override

public abstract sealed Class OrderedFlow<T extends QuicFrame>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class OrderedFlow.CryptoDataFlow

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public final Class OrderedFlow.StreamDataFlow

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail