Top Fields Constructors Methods
org.eclipse.jetty.http3

public Class UnidirectionalStreamConnection

extends AbstractConnection
implements UpgradeFrom
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.io.Connection.UpgradeFrom
Imports
java.nio.ByteBuffer, java.util.concurrent.Executor, org.eclipse.jetty.http3.internal.ControlStreamConnection, .VarLenInt, org.eclipse.jetty.http3.parser.ControlParser, .ParserListener, org.eclipse.jetty.http3.qpack.QpackDecoder, .QpackEncoder, org.eclipse.jetty.io.AbstractConnection, .ByteBufferPool, .Connection, .RetainableByteBuffer, org.eclipse.jetty.quic.common.QuicStreamEndPoint, .StreamType, org.slf4j.Logger, .LoggerFactory

Field Summary

Modifier and TypeField and Description
private RetainableByteBuffer
buffer

private final ByteBufferPool
bufferPool

private final QpackDecoder
decoder

private final QpackEncoder
encoder

private final ParserListener
listener

private static final Logger
LOG

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

private final VarLenInt
parser

private boolean
useInputDirectByteBuffers

Constructor Summary

AccessConstructor and Description
public
UnidirectionalStreamConnection(QuicStreamEndPoint endPoint, Executor executor, ByteBufferPool bufferPool, QpackEncoder encoder, QpackDecoder decoder, ParserListener listener)

Method Summary

Modifier and TypeMethod and Description
private void
detectAndUpgrade(long streamType)

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.

public ByteBuffer
onUpgradeFrom()

Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom.

Invoked during an upgrade to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection.

public void
setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

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

Field Detail

bufferback to summary
private RetainableByteBuffer buffer
bufferPoolback to summary
private final ByteBufferPool bufferPool
decoderback to summary
private final QpackDecoder decoder
encoderback to summary
private final QpackEncoder encoder
listenerback to summary
private final ParserListener listener
LOGback to summary
private static final Logger LOG

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

parserback to summary
private final VarLenInt parser
useInputDirectByteBuffersback to summary
private boolean useInputDirectByteBuffers

Constructor Detail

UnidirectionalStreamConnectionback to summary
public UnidirectionalStreamConnection(QuicStreamEndPoint endPoint, Executor executor, ByteBufferPool bufferPool, QpackEncoder encoder, QpackDecoder decoder, ParserListener listener)

Method Detail

detectAndUpgradeback to summary
private void detectAndUpgrade(long streamType)
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
onUpgradeFromback to summary
public ByteBuffer onUpgradeFrom()

Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom.

Doc from org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom.

Invoked during an upgrade to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection.

Annotations
@Override
setUseInputDirectByteBuffersback to summary
public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)