Modifier and Type	Class and Description
private static class	QuicReceiverStreamImpl.Handles
private class	QuicReceiverStreamImpl.QuicStreamReaderImpl

Modifier and Type	Field and Description
private final OrderedFlow.StreamDataFlow	dataFlow
private final String	dbgTag
private final Logger	debug
private final long	desiredBufferSize
private volatile boolean	eof
private volatile long	errorCode
private volatile long	knownSize
private static final int	MAX_SMALL_FRAGMENTS
private volatile long	maxReceivedData
private volatile long	maxStreamData
private static final long	MIN_BUFFER_SIZE
private final ConcurrentLinkedQueue<ByteBuffer>	orderedQueue
private volatile long	processed
private volatile QuicReceiverStreamImpl.QuicStreamReaderImpl	reader
private volatile long	received
private volatile QuicReceiverStream.ReceivingStreamState	receivingState
private volatile boolean	requestedStopSending

Access	Constructor and Description
pack-priv	QuicReceiverStreamImpl(QuicConnectionImpl connection, long streamId)

Method Summary

Modifier and Type	Method and Description
pack-priv void	checkOpened()
private void	checkUpdateState(StreamFrame received stream frame streamFrame) Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws.
private void	checkUpdateState(ResetStreamFrame received reset stream frame resetStreamFrame) Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws.
public QuicStreamReader	connectReader(SequentialScheduler scheduler) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader. Connects an unstarted reader to the receiver end of this stream.
public long	dataReceived() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived. Returns the amount of data that has been received so far.
pack-priv String	dbgTag()
private void	demand(final long additional)
public void	disconnectReader(QuicStreamReader reader) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader. Disconnect the reader, so that a new reader can be connected.
private void	increaseProcessedData(long newProcessed) Notifies the connection about received data that is no longer buffered.
private void	increaseProcessedDataBy(int diff) Notifies the connection about received data that is no longer buffered.
public boolean	isDone() Implements abstract jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone. Returns true if this stream isn't expecting anything from the peer and can be removed from the streams map.
public boolean	isStopSendingRequested() Overrides default jdk.internal.net.http.quic.streams.QuicReceiverStream.isStopSendingRequested.
private boolean	markDataRead()
private boolean	markDataRecvd()
private boolean	markResetRead()
private boolean	markResetRecvd()
private boolean	markSizeKnown()
public long	maxStreamData() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData. Returns the maximum amount of data that can be received on this stream.
private void	notifyTerminalState(QuicReceiverStream.ReceivingStreamState state)
private void	offer(StreamFrame frame)
private void	offerEof()
pack-priv void	processIncomingFrame(final StreamDataBlockedFrame streamDataBlocked)
public void	processIncomingFrame(final StreamFrame the frame received streamFrame) Receives a QuicFrame from the remote peer.
pack-priv void	processIncomingResetFrame(final ResetStreamFrame the frame received resetStreamFrame) Receives a QuicFrame from the remote peer.
public long	rcvErrorCode() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode. Returns the error code for this stream, or `-1`.
public QuicReceiverStream.ReceivingStreamState	receivingState() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState. Returns the receiving state of the stream.
public void	requestStopSending(final long errorCode) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending. Cancels the reading side of this stream by sending a STOP_SENDING frame.
private void	setErrorCode(long code)
public QuicStream.StreamState	state() Implements jdk.internal.net.http.quic.streams.QuicStream.state. Returns the combined stream state.
private static QuicTransportException	streamControlOverflow(StreamFrame the stream frame that caused the excess streamFrame, long the value of MAX_STREAM_DATA which was exceeded maxData) Sends a `ConnectionCloseFrame` due to MAX_STREAM_DATA exceeded for the stream.
private boolean	switchReceivingState(QuicReceiverStream.ReceivingStreamState the new state. newState) Called when a state change is needed
pack-priv void	terminate(final TerminationCause the termination cause terminationCause) Called when the connection is closed
private void	updateMaxReceivedData(long the new max offset - typically obtained by adding the length of a frame to its offset newMax, long type of frame received frameType) Update the `maxReceivedData` value, and return the amount by which `maxReceivedData` was increased.
public void	updateMaxStreamData(long newMaxStreamData) Update the value of MAX_STREAM_DATA for this stream
private static long	validateStreamId(QuicConnectionImpl connection, long streamId)

Inherited from jdk.internal.net.http.quic.streams.AbstractQuicStream:: connection isBidirectional isClientInitiated isLocalInitiated isRemoteInitiated isServerInitiated mode streamId type

Field Detail

dataFlow	back to summary
private final OrderedFlow.StreamDataFlow dataFlow

dbgTag	back to summary
private final String dbgTag

debug	back to summary
private final Logger debug

desiredBufferSize	back to summary
private final long desiredBufferSize

eof	back to summary
private volatile boolean eof

errorCode	back to summary
private volatile long errorCode

knownSize	back to summary
private volatile long knownSize

MAX_SMALL_FRAGMENTS	back to summary
private static final int MAX_SMALL_FRAGMENTS

maxReceivedData	back to summary
private volatile long maxReceivedData

maxStreamData	back to summary
private volatile long maxStreamData

MIN_BUFFER_SIZE	back to summary
private static final long MIN_BUFFER_SIZE

orderedQueue	back to summary
private final ConcurrentLinkedQueue<ByteBuffer> orderedQueue

processed	back to summary
private volatile long processed

reader	back to summary
private volatile QuicReceiverStreamImpl.QuicStreamReaderImpl reader

received	back to summary
private volatile long received

receivingState	back to summary
private volatile QuicReceiverStream.ReceivingStreamState receivingState

requestedStopSending	back to summary
private volatile boolean requestedStopSending

Constructor Detail

QuicReceiverStreamImpl	back to summary
pack-priv QuicReceiverStreamImpl(QuicConnectionImpl connection, long streamId)

Method Detail

checkOpened	back to summary
pack-priv void checkOpened() throws IOException

checkUpdateState	back to summary
private void checkUpdateState(StreamFrame streamFrame) throws QuicTransportException Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws. Implementation Note This method may update counters before throwing. This is OK because we do not expect to use them again in this case. Parameters streamFrame:StreamFrame received stream frame Exceptions QuicTransportException: if frame is invalid

checkUpdateState

back to summary

private void checkUpdateState(StreamFrame streamFrame) throws QuicTransportException

Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws.

Implementation Note

This method may update counters before throwing. This is OK because we do not expect to use them again in this case.

Parameters

streamFrame:StreamFrame: received stream frame

Exceptions

QuicTransportException:: if frame is invalid

checkUpdateState	back to summary
private void checkUpdateState(ResetStreamFrame resetStreamFrame) throws QuicTransportException Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws. Implementation Note This method may update counters before throwing. This is OK because we do not expect to use them again in this case. Parameters resetStreamFrame:ResetStreamFrame received reset stream frame Exceptions QuicTransportException: if frame is invalid

checkUpdateState

back to summary

private void checkUpdateState(ResetStreamFrame resetStreamFrame) throws QuicTransportException

Checks for error conditions: - max stream data errors - max data errors - final size errors If everything checks OK, updates counters and returns, otherwise throws.

Implementation Note

This method may update counters before throwing. This is OK because we do not expect to use them again in this case.

Parameters

resetStreamFrame:ResetStreamFrame: received reset stream frame

Exceptions

QuicTransportException:: if frame is invalid

connectReader	back to summary
public QuicStreamReader connectReader(SequentialScheduler scheduler) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader. Connects an unstarted reader to the receiver end of this stream. Annotations @Override

connectReader

back to summary

public QuicStreamReader connectReader(SequentialScheduler scheduler)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader.

Connects an unstarted reader to the receiver end of this stream.

Annotations

@Override

dataReceived	back to summary
public long dataReceived() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived. Returns the amount of data that has been received so far. Annotations @Override

dataReceived

back to summary

public long dataReceived()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived.

Returns the amount of data that has been received so far.

Annotations

@Override

dbgTag	back to summary
pack-priv String dbgTag()

demand	back to summary
private void demand(final long additional)

disconnectReader	back to summary
public void disconnectReader(QuicStreamReader reader) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader. Disconnect the reader, so that a new reader can be connected. Annotations @Override

disconnectReader

back to summary

public void disconnectReader(QuicStreamReader reader)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader.

Disconnect the reader, so that a new reader can be connected.

Annotations

@Override

increaseProcessedData	back to summary
private void increaseProcessedData(long newProcessed) Notifies the connection about received data that is no longer buffered.

increaseProcessedDataBy	back to summary
private void increaseProcessedDataBy(int diff) Notifies the connection about received data that is no longer buffered.

isDone	back to summary
public boolean isDone() Implements abstract jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone. Doc from jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone. Returns true if this stream isn't expecting anything from the peer and can be removed from the streams map. Annotations @Override

isDone

back to summary

public boolean isDone()

Implements abstract jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone.

Doc from jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone.

Returns true if this stream isn't expecting anything from the peer and can be removed from the streams map.

Annotations

@Override

isStopSendingRequested	back to summary
public boolean isStopSendingRequested() Overrides default jdk.internal.net.http.quic.streams.QuicReceiverStream.isStopSendingRequested. Annotations @Override

isStopSendingRequested

back to summary

public boolean isStopSendingRequested()

Overrides default jdk.internal.net.http.quic.streams.QuicReceiverStream.isStopSendingRequested.

Annotations

@Override

markDataRead	back to summary
private boolean markDataRead()

markDataRecvd	back to summary
private boolean markDataRecvd()

markResetRead	back to summary
private boolean markResetRead()

markResetRecvd	back to summary
private boolean markResetRecvd()

markSizeKnown	back to summary
private boolean markSizeKnown()

maxStreamData	back to summary
public long maxStreamData() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData. Returns the maximum amount of data that can be received on this stream. Annotations @Override

maxStreamData

back to summary

public long maxStreamData()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData.

Returns the maximum amount of data that can be received on this stream.

Annotations

@Override

notifyTerminalState	back to summary
private void notifyTerminalState(QuicReceiverStream.ReceivingStreamState state)

offer	back to summary
private void offer(StreamFrame frame)

offerEof	back to summary
private void offerEof()

processIncomingFrame	back to summary
pack-priv void processIncomingFrame(final StreamDataBlockedFrame streamDataBlocked)

processIncomingFrame	back to summary
public void processIncomingFrame(final StreamFrame streamFrame) throws QuicTransportException Receives a QuicFrame from the remote peer. Parameters streamFrame:StreamFrame the frame received

processIncomingFrame

back to summary

public void processIncomingFrame(final StreamFrame streamFrame) throws QuicTransportException

Receives a QuicFrame from the remote peer.

Parameters

streamFrame:StreamFrame: the frame received

processIncomingResetFrame	back to summary
pack-priv void processIncomingResetFrame(final ResetStreamFrame resetStreamFrame) throws QuicTransportException Receives a QuicFrame from the remote peer. Parameters resetStreamFrame:ResetStreamFrame the frame received

processIncomingResetFrame

back to summary

pack-priv void processIncomingResetFrame(final ResetStreamFrame resetStreamFrame) throws QuicTransportException

Receives a QuicFrame from the remote peer.

Parameters

resetStreamFrame:ResetStreamFrame: the frame received

rcvErrorCode back to summary

rcvErrorCode	back to summary
public long rcvErrorCode() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode. Returns the error code for this stream, or `-1`. Annotations @Override

public long rcvErrorCode()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode.

Returns the error code for this stream, or -1.

Annotations

@Override

receivingState	back to summary
public QuicReceiverStream.ReceivingStreamState receivingState() Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState. Returns the receiving state of the stream. Annotations @Override

receivingState

back to summary

public QuicReceiverStream.ReceivingStreamState receivingState()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState.

Returns the receiving state of the stream.

Annotations

@Override

requestStopSending	back to summary
public void requestStopSending(final long errorCode) Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending. Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending. Cancels the reading side of this stream by sending a STOP_SENDING frame. Annotations @Override

requestStopSending

back to summary

public void requestStopSending(final long errorCode)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending.

Cancels the reading side of this stream by sending a STOP_SENDING frame.

Annotations

@Override

setErrorCode	back to summary
private void setErrorCode(long code)

state

back to summary

public QuicStream.StreamState state()

Implements jdk.internal.net.http.quic.streams.QuicStream.state.

Doc from jdk.internal.net.http.quic.streams.QuicStream.state.

Returns the combined stream state.

Annotations

@Override

streamControlOverflow back to summary

private static QuicTransportException streamControlOverflow(StreamFrame streamFrame, long maxData) throws QuicTransportException

Sends a ConnectionCloseFrame due to MAX_STREAM_DATA exceeded for the stream.

Parameters

streamFrame:StreamFrame: the stream frame that caused the excess
maxData:long: the value of MAX_STREAM_DATA which was exceeded

switchReceivingState

back to summary

private boolean switchReceivingState(QuicReceiverStream.ReceivingStreamState newState)

Called when a state change is needed

Parameters

newState:QuicReceiverStream.ReceivingStreamState: the new state.

terminate

back to summary

pack-priv void terminate(final TerminationCause terminationCause)

Called when the connection is closed

Parameters

terminationCause:TerminationCause: the termination cause

updateMaxReceivedData back to summary

private void updateMaxReceivedData(long newMax, long frameType) throws QuicTransportException

Update the maxReceivedData value, and return the amount by which maxReceivedData was increased. This method is a no-op and returns 0 if maxReceivedData >= newMax.

Parameters

newMax:long: the new max offset - typically obtained by adding the length of a frame to its offset
frameType:long: type of frame received

Exceptions

QuicTransportException:: if flow control was violated

updateMaxStreamData	back to summary
public void updateMaxStreamData(long newMaxStreamData) Update the value of MAX_STREAM_DATA for this stream

validateStreamId	back to summary
private static long validateStreamId(QuicConnectionImpl connection, long streamId)

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

private final Class QuicReceiverStreamImpl.Handles

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.quic.streams.QuicReceiverStreamImpl.Handles

Field Summary

Modifier and Type	Field and Description
pack-priv static final VarHandle	ERROR_CODE
pack-priv static final VarHandle	MAX_RECEIVED_DATA
pack-priv static final VarHandle	MAX_STREAM_DATA
pack-priv static final VarHandle	READER
pack-priv static final VarHandle	RECEIVING_STATE
pack-priv static final VarHandle	STOP_SENDING

Constructor Summary

Access	Constructor and Description
private	Handles()

Method Summary

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

Field Detail

ERROR_CODE	back to summary
pack-priv static final VarHandle ERROR_CODE

MAX_RECEIVED_DATA	back to summary
pack-priv static final VarHandle MAX_RECEIVED_DATA

MAX_STREAM_DATA	back to summary
pack-priv static final VarHandle MAX_STREAM_DATA

READER	back to summary
pack-priv static final VarHandle READER

RECEIVING_STATE	back to summary
pack-priv static final VarHandle RECEIVING_STATE

STOP_SENDING	back to summary
pack-priv static final VarHandle STOP_SENDING

Constructor Detail

Handles	back to summary
private Handles()

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

private final Class QuicReceiverStreamImpl.QuicStreamReaderImpl

Class Inheritance

extends QuicStreamReader

java.lang.Object
jdk.internal.net.http.quic.streams.QuicStreamReader
jdk.internal.net.http.quic.streams.QuicReceiverStreamImpl.QuicStreamReaderImpl

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	PENDING
pack-priv static final int	STARTED
private int	state

Inherited from jdk.internal.net.http.quic.streams.QuicStreamReader:: EOF scheduler

Constructor Summary

Access	Constructor and Description
pack-priv	QuicStreamReaderImpl(SequentialScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
private void	checkConnected()
private void	checkReset() Checks whether the stream was reset and throws an exception if yes.
public boolean	connected() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.connected. Returns true if this reader is connected to its stream.
public ByteBuffer	peek() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.peek. Returns the ByteBuffer at the head of the queue, or null if no data is available.
public ByteBuffer	poll() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.poll. Returns the ByteBuffer at the head of the queue, or null if no data is available.
public QuicReceiverStream.ReceivingStreamState	receivingState() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.receivingState. Returns the receiving state of the stream.
public void	start() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.start. Starts the reader.
public boolean	started() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.started. Returns true if this reader has been started.
public QuicReceiverStream	stream() Implements abstract jdk.internal.net.http.quic.streams.QuicStreamReader.stream. Returns the stream this reader is connected to, or `null` if this reader is not currently connected.
private long	unfulfilled()
pack-priv void	wakeup()
private boolean	wakeupOnStart(int state)