Top Fields Constructors Methods
org.eclipse.jetty.http3

public abstract Class InstructionStreamConnection

extends AbstractConnection
implements UpgradeTo
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.io.Connection.UpgradeTo
Known Direct Subclasses
org.eclipse.jetty.http3.DecoderStreamConnection, org.eclipse.jetty.http3.EncoderStreamConnection
Imports
java.nio.ByteBuffer, java.util.concurrent.Executor, org.eclipse.jetty.http3.parser.ParserListener, org.eclipse.jetty.http3.qpack.QpackException, 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 final ParserListener
listener

private static final Logger
LOG

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

private boolean
useInputDirectByteBuffers

Constructor Summary

AccessConstructor and Description
public
InstructionStreamConnection(EndPoint endPoint, Executor executor, ByteBufferPool bufferPool, ParserListener listener)

Method Summary

Modifier and TypeMethod and Description
private void
fail(long errorCode, String message, Throwable failure)

public boolean
isUseInputDirectByteBuffers()

protected void
notifySessionFailure(long error, String reason, Throwable failure)

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.

protected abstract void
parseInstruction(ByteBuffer buffer)

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
listenerback to summary
private final ParserListener listener
LOGback to summary
private static final Logger LOG

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

useInputDirectByteBuffersback to summary
private boolean useInputDirectByteBuffers

Constructor Detail

InstructionStreamConnectionback to summary
public InstructionStreamConnection(EndPoint endPoint, Executor executor, ByteBufferPool bufferPool, ParserListener listener)

Method Detail

failback to summary
private void fail(long errorCode, String message, Throwable failure)
isUseInputDirectByteBuffersback to summary
public boolean isUseInputDirectByteBuffers()
notifySessionFailureback to summary
protected void notifySessionFailure(long error, String reason, Throwable failure)
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
parseInstructionback to summary
protected abstract void parseInstruction(ByteBuffer buffer) throws QpackException
setUseInputDirectByteBuffersback to summary
public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)