Top Inners Fields Constructors Methods
org.eclipse.jetty.http3

public abstract Class HTTP3StreamConnection

extends AbstractConnection
Class Inheritance
Imports
java.io.IOException, .UncheckedIOException, java.nio.ByteBuffer, java.util.concurrent.Executor, .TimeoutException, java.util.concurrent.atomic.AtomicReference, org.eclipse.jetty.http.HttpStatus, .MetaData, org.eclipse.jetty.http3.api.Stream, org.eclipse.jetty.http3.frames.DataFrame, .HeadersFrame, org.eclipse.jetty.http3.parser.MessageParser, .ParserListener, org.eclipse.jetty.io.AbstractConnection, .ByteBufferPool, .RetainableByteBuffer, org.eclipse.jetty.quic.common.QuicStreamEndPoint, org.slf4j.Logger, .LoggerFactory

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
HTTP3StreamConnection.MessageListener

private static class
HTTP3StreamConnection.StreamData

Field Summary

Modifier and TypeField and Description
private final AtomicReference<Runnable>
action

private final ByteBufferPool
bufferPool

private static final ByteBuffer
EMPTY_DATA_FRAME

private static final Logger
LOG

Hides org.eclipse.jetty.io.AbstractConnection.LOG.

private RetainableByteBuffer
networkBuffer

private final MessageParser
parser

private boolean
remotelyClosed

private HTTP3Stream
stream

private boolean
useInputDirectByteBuffers

Constructor Summary

AccessConstructor and Description
public
HTTP3StreamConnection(QuicStreamEndPoint endPoint, Executor executor, ByteBufferPool bufferPool, MessageParser parser)

Method Summary

Modifier and TypeMethod and Description
private int
fill(ByteBuffer byteBuffer)

public QuicStreamEndPoint
getEndPoint()

Overrides org.eclipse.jetty.io.AbstractConnection.getEndPoint.

Implements org.eclipse.jetty.io.Connection.getEndPoint.

public boolean
isUseInputDirectByteBuffers()

public void
onFillable()

Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable.

Callback method invoked when the endpoint is ready to be read.

public void
onOpen()

Overrides org.eclipse.jetty.io.AbstractConnection.onOpen.

Implements org.eclipse.jetty.io.Connection.onOpen.

Callback method invoked when this connection is opened.

protected boolean
onReadTimeout(TimeoutException timeout)

Overrides org.eclipse.jetty.io.AbstractConnection.onReadTimeout.

Callback method invoked when the endpoint failed to be ready to be read after a timeout

private MessageParser.Result
parseAndFill(boolean setFillInterest)

private void
processData(DataFrame frame, Runnable delegate)

private void
processDataFrames(boolean setFillInterest)

private void
processHeaders(HeadersFrame frame, boolean wasBlocked, Runnable delegate)

private void
processNonDataFrames()

public void
receive()

pack-priv void
setStream(HTTP3Stream stream)

public void
setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

private void
shutdownInput()

public String
toConnectionString()

Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString.

private void
tryAcquireBuffer()

private void
tryReleaseBuffer(boolean force)

Inherited from org.eclipse.jetty.io.AbstractConnection:
addEventListenerclosefailedCallbackfillInterestedgetBytesIngetBytesOutgetCreatedTimeStampgetExecutorgetInputBufferSizegetInvocationTypegetMessagesIngetMessagesOutisFillInterestedonCloseonFillInterestedFailedonIdleExpiredremoveEventListenersetInputBufferSizetoStringtryFillInterested

Field Detail

actionback to summary
private final AtomicReference<Runnable> action
bufferPoolback to summary
private final ByteBufferPool bufferPool
EMPTY_DATA_FRAMEback to summary
private static final ByteBuffer EMPTY_DATA_FRAME
LOGback to summary
private static final Logger LOG

Hides org.eclipse.jetty.io.AbstractConnection.LOG.

networkBufferback to summary
private RetainableByteBuffer networkBuffer
parserback to summary
private final MessageParser parser
remotelyClosedback to summary
private boolean remotelyClosed
streamback to summary
private HTTP3Stream stream
useInputDirectByteBuffersback to summary
private boolean useInputDirectByteBuffers

Constructor Detail

HTTP3StreamConnectionback to summary
public HTTP3StreamConnection(QuicStreamEndPoint endPoint, Executor executor, ByteBufferPool bufferPool, MessageParser parser)

Method Detail

fillback to summary
private int fill(ByteBuffer byteBuffer)
getEndPointback to summary
public QuicStreamEndPoint getEndPoint()

Overrides org.eclipse.jetty.io.AbstractConnection.getEndPoint.

Implements org.eclipse.jetty.io.Connection.getEndPoint.

Annotations
@Override
isUseInputDirectByteBuffersback to summary
public boolean isUseInputDirectByteBuffers()
onFillableback to summary
public void onFillable()

Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable.

Doc from org.eclipse.jetty.io.AbstractConnection.onFillable.

Callback method invoked when the endpoint is ready to be read.

Annotations
@Override
onOpenback to summary
public void onOpen()

Overrides org.eclipse.jetty.io.AbstractConnection.onOpen.

Implements org.eclipse.jetty.io.Connection.onOpen.

Doc from org.eclipse.jetty.io.Connection.onOpen.

Callback method invoked when this connection is opened.

Creators of the connection implementation are responsible for calling this method.

Annotations
@Override
onReadTimeoutback to summary
protected boolean onReadTimeout(TimeoutException timeout)

Overrides org.eclipse.jetty.io.AbstractConnection.onReadTimeout.

Doc from org.eclipse.jetty.io.AbstractConnection.onReadTimeout.

Callback method invoked when the endpoint failed to be ready to be read after a timeout

Annotations
@Override
parseAndFillback to summary
private MessageParser.Result parseAndFill(boolean setFillInterest)
processDataback to summary
private void processData(DataFrame frame, Runnable delegate)
processDataFramesback to summary
private void processDataFrames(boolean setFillInterest)
processHeadersback to summary
private void processHeaders(HeadersFrame frame, boolean wasBlocked, Runnable delegate)
processNonDataFramesback to summary
private void processNonDataFrames()
receiveback to summary
public void receive()
setStreamback to summary
pack-priv void setStream(HTTP3Stream stream)
setUseInputDirectByteBuffersback to summary
public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)
shutdownInputback to summary
private void shutdownInput()
toConnectionStringback to summary
public String toConnectionString()

Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString.

Annotations
@Override
tryAcquireBufferback to summary
private void tryAcquireBuffer()
tryReleaseBufferback to summary
private void tryReleaseBuffer(boolean force)
org.eclipse.jetty.http3 back to summary

private Class HTTP3StreamConnection.MessageListener

extends Wrapper
Class Inheritance

Field Summary

Inherited from org.eclipse.jetty.http3.parser.ParserListener.Wrapper:
listener

Constructor Summary

AccessConstructor and Description
private
MessageListener(ParserListener listener)

Method Summary

Modifier and TypeMethod and Description
public void
onData(long streamId, DataFrame frame)

Overrides org.eclipse.jetty.http3.parser.ParserListener.Wrapper.onData.

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onData.

public void
onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked)

Overrides org.eclipse.jetty.http3.parser.ParserListener.Wrapper.onHeaders.

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onHeaders.

Inherited from org.eclipse.jetty.http3.parser.ParserListener.Wrapper:
onSessionFailureonSettingsonStreamFailure

Constructor Detail

MessageListenerback to summary
private MessageListener(ParserListener listener)

Method Detail

onDataback to summary
public void onData(long streamId, DataFrame frame)

Overrides org.eclipse.jetty.http3.parser.ParserListener.Wrapper.onData.

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onData.

Annotations
@Override
onHeadersback to summary
public void onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked)

Overrides org.eclipse.jetty.http3.parser.ParserListener.Wrapper.onHeaders.

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onHeaders.

Annotations
@Override
org.eclipse.jetty.http3 back to summary

private Class HTTP3StreamConnection.StreamData

extends Data
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final RetainableByteBuffer
retainable

Inherited from org.eclipse.jetty.http3.api.Stream.Data:
EOF

Constructor Summary

AccessConstructor and Description
public
StreamData(DataFrame frame, RetainableByteBuffer retainable)

Method Summary

Modifier and TypeMethod and Description
public boolean
canRetain()

Overrides default org.eclipse.jetty.io.Retainable.canRetain.

Returns whether this resource is referenced counted by calls to retain() and release().

public boolean
release()

Overrides default org.eclipse.jetty.io.Retainable.release.

Releases this resource, potentially decrementing a reference count (if any).

public void
retain()

Overrides default org.eclipse.jetty.io.Retainable.retain.

Retains this resource, potentially incrementing a reference count if there are resources that will be released.

Inherited from org.eclipse.jetty.http3.api.Stream.Data:
getByteBufferisLasttoString

Field Detail

retainableback to summary
private final RetainableByteBuffer retainable

Constructor Detail

StreamDataback to summary
public StreamData(DataFrame frame, RetainableByteBuffer retainable)

Method Detail

canRetainback to summary
public boolean canRetain()

Overrides default org.eclipse.jetty.io.Retainable.canRetain.

Doc from org.eclipse.jetty.io.Retainable.canRetain.

Returns whether this resource is referenced counted by calls to retain() and release().

Implementations may decide that special resources are not not referenced counted (for example, static constants) so calling retain() is a no-operation, and calling release() on those special resources is a no-operation that always returns true.

Annotations
@Override
releaseback to summary
public boolean release()

Overrides default org.eclipse.jetty.io.Retainable.release.

Doc from org.eclipse.jetty.io.Retainable.release.

Releases this resource, potentially decrementing a reference count (if any).

Annotations
@Override
retainback to summary
public void retain()

Overrides default org.eclipse.jetty.io.Retainable.retain.

Doc from org.eclipse.jetty.io.Retainable.retain.

Retains this resource, potentially incrementing a reference count if there are resources that will be released.

Annotations
@Override