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

public Class ControlStreamConnection

extends AbstractConnection
implements UpgradeTo
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.io.Connection.UpgradeTo
Imports
java.nio.ByteBuffer, java.util.concurrent.Executor, org.eclipse.jetty.http3.parser.ControlParser, org.eclipse.jetty.io.AbstractConnection, .ByteBufferPool, .Connection, .EndPoint, .RetainableByteBuffer, org.eclipse.jetty.util.BufferUtil, org.slf4j.Logger, .LoggerFactory

Field Summary

Modifier and TypeField and Description
private RetainableByteBuffer
buffer

private final ByteBufferPool
bufferPool

private static final Logger
LOG

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

private final ControlParser
parser

public static final long
STREAM_TYPE

private boolean
useInputDirectByteBuffers

Constructor Summary

AccessConstructor and Description
public
ControlStreamConnection(EndPoint endPoint, Executor executor, ByteBufferPool bufferPool, ControlParser parser)

Method Summary

Modifier and TypeMethod and Description
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 void
onUpgradeTo(ByteBuffer upgrade)

Implements org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo.

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

public void
setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

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

Field Detail

bufferback to summary
private RetainableByteBuffer buffer
bufferPoolback to summary
private final ByteBufferPool bufferPool
LOGback to summary
private static final Logger LOG

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

parserback to summary
private final ControlParser parser
STREAM_TYPEback to summary
public static final long STREAM_TYPE
useInputDirectByteBuffersback to summary
private boolean useInputDirectByteBuffers

Constructor Detail

ControlStreamConnectionback to summary
public ControlStreamConnection(EndPoint endPoint, Executor executor, ByteBufferPool bufferPool, ControlParser parser)

Method Detail

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
onUpgradeToback to summary
public void onUpgradeTo(ByteBuffer upgrade)

Implements org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo.

Doc from org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo.

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

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