Top Fields Constructors Methods
org.eclipse.jetty.http3

public Class InstructionFlusher

extends IteratingCallback
Class Inheritance
Imports
java.nio.ByteBuffer, java.util.ArrayDeque, .ArrayList, .List, .Queue, org.eclipse.jetty.http3.internal.VarLenInt, org.eclipse.jetty.http3.qpack.Instruction, org.eclipse.jetty.io.ByteBufferPool, .RetainableByteBuffer, org.eclipse.jetty.quic.common.QuicSession, .QuicStreamEndPoint, org.eclipse.jetty.util.BufferUtil, .IteratingCallback, org.eclipse.jetty.util.thread.AutoLock, org.slf4j.Logger, .LoggerFactory

Field Summary

Modifier and TypeField and Description
private final ByteBufferPool.Accumulator
accumulator

private final ByteBufferPool
bufferPool

private final QuicStreamEndPoint
endPoint

private boolean
initialized

private final AutoLock
lock

private static final Logger
LOG

private final Queue<Instruction>
queue

private final long
streamType

private Throwable
terminated

Constructor Summary

AccessConstructor and Description
public
InstructionFlusher(QuicSession session, QuicStreamEndPoint endPoint, long streamType)

Method Summary

Modifier and TypeMethod and Description
public Invocable.InvocationType
getInvocationType()

Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.

public boolean
offer(List<Instruction> instructions)

protected void
onCompleteFailure(Throwable failure)

Overrides org.eclipse.jetty.util.IteratingCallback.onCompleteFailure.

Invoked when the overall task has completed with a failure.

protected IteratingCallback.Action
process()

Implements abstract org.eclipse.jetty.util.IteratingCallback.process.

Method called by iterate() to process the asynchronous sub-task.

public void
succeeded()

Overrides org.eclipse.jetty.util.IteratingCallback.succeeded.

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Method to invoke when the asynchronous sub-task succeeds.

public String
toString()

Overrides org.eclipse.jetty.util.IteratingCallback.toString.

Returns a string representation of the object.

Inherited from org.eclipse.jetty.util.IteratingCallback:
abortclosefailedisAbortedisClosedisFailedisSucceedediterateonCompleteSuccessreset

Field Detail

accumulatorback to summary
private final ByteBufferPool.Accumulator accumulator
bufferPoolback to summary
private final ByteBufferPool bufferPool
endPointback to summary
private final QuicStreamEndPoint endPoint
initializedback to summary
private boolean initialized
lockback to summary
private final AutoLock lock
LOGback to summary
private static final Logger LOG
queueback to summary
private final Queue<Instruction> queue
streamTypeback to summary
private final long streamType
terminatedback to summary
private Throwable terminated

Constructor Detail

InstructionFlusherback to summary
public InstructionFlusher(QuicSession session, QuicStreamEndPoint endPoint, long streamType)

Method Detail

getInvocationTypeback to summary
public Invocable.InvocationType getInvocationType()

Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.

Annotations
@Override
offerback to summary
public boolean offer(List<Instruction> instructions)
onCompleteFailureback to summary
protected void onCompleteFailure(Throwable failure)

Overrides org.eclipse.jetty.util.IteratingCallback.onCompleteFailure.

Doc from org.eclipse.jetty.util.IteratingCallback.onCompleteFailure.

Invoked when the overall task has completed with a failure.

Annotations
@Override
processback to summary
protected IteratingCallback.Action process()

Implements abstract org.eclipse.jetty.util.IteratingCallback.process.

Doc from org.eclipse.jetty.util.IteratingCallback.process.

Method called by iterate() to process the asynchronous sub-task.

Implementations must initiate the asynchronous execution of the sub-task (if any) and return an appropriate action:

  • Action#IDLE when no sub tasks are available for execution but the overall job is not completed yet
  • Action#SCHEDULED when the sub task asynchronous execution has been started
  • Action#SUCCEEDED when the overall job is completed
Annotations
@Override
succeededback to summary
public void succeeded()

Overrides org.eclipse.jetty.util.IteratingCallback.succeeded.

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Doc from org.eclipse.jetty.util.IteratingCallback.succeeded.

Method to invoke when the asynchronous sub-task succeeds.

Subclasses that override this method must always remember to call super.succeeded().

Annotations
@Override
toStringback to summary
public String toString()

Overrides org.eclipse.jetty.util.IteratingCallback.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations
@Override