Modifier and Type	Class and Description
private static class	MessageFlusher.Entry
public static class	MessageFlusher.FlushFrame

Modifier and Type

Class and Description

private static class

MessageFlusher.Entry

public static class

MessageFlusher.FlushFrame

Modifier and Type	Field and Description
private final ByteBufferPool.Accumulator	accumulator
private final Queue<MessageFlusher.Entry>	entries
private MessageFlusher.Entry	entry
private final MessageGenerator	generator
private final AutoLock	lock
private static final Logger	LOG

Modifier and Type

Field and Description

private final ByteBufferPool.Accumulator

accumulator

private final Queue<MessageFlusher.Entry>

entries

private MessageFlusher.Entry

entry

private final MessageGenerator

generator

private final AutoLock

lock

private static final Logger

LOG

Access	Constructor and Description
public	MessageFlusher(ByteBufferPool bufferPool, QpackEncoder encoder, boolean useDirectByteBuffers)

Access

Constructor and Description

public

MessageFlusher(ByteBufferPool bufferPool, QpackEncoder encoder, boolean useDirectByteBuffers)

Modifier and Type	Method and Description
public void	failed(Throwable x) Overrides org.eclipse.jetty.util.IteratingCallback.failed. Overrides default org.eclipse.jetty.util.Callback.failed. Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.
public Invocable.InvocationType	getInvocationType() Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.
public boolean	offer(QuicStreamEndPoint endPoint, Frame frame, Callback callback)
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.

Modifier and Type

Method and Description

public void

failed(Throwable x)

Overrides org.eclipse.jetty.util.IteratingCallback.failed.

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

Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.

public Invocable.InvocationType

getInvocationType()

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

public boolean

offer(QuicStreamEndPoint endPoint, Frame frame, Callback callback)

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.

accumulator	back to summary
private final ByteBufferPool.Accumulator accumulator

accumulator

back to summary

private final ByteBufferPool.Accumulator accumulator

entries	back to summary
private final Queue<MessageFlusher.Entry> entries

entries

back to summary

private final Queue<MessageFlusher.Entry> entries

entry	back to summary
private MessageFlusher.Entry entry

entry

back to summary

private MessageFlusher.Entry entry

generator	back to summary
private final MessageGenerator generator

generator

back to summary

private final MessageGenerator generator

lock	back to summary
private final AutoLock lock

lock

back to summary

private final AutoLock lock

LOG	back to summary
private static final Logger LOG

LOG

back to summary

private static final Logger LOG

MessageFlusher	back to summary
public MessageFlusher(ByteBufferPool bufferPool, QpackEncoder encoder, boolean useDirectByteBuffers)

MessageFlusher

back to summary

public MessageFlusher(ByteBufferPool bufferPool, QpackEncoder encoder, boolean useDirectByteBuffers)

Method Detail

failed back to summary

failed	back to summary
public void failed(Throwable x) Overrides org.eclipse.jetty.util.IteratingCallback.failed. Overrides default org.eclipse.jetty.util.Callback.failed. Doc from org.eclipse.jetty.util.IteratingCallback.failed. Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration. Subclasses that override this method must always remember to call `super.failed(Throwable)`. Eventually, `onCompleteFailure(Throwable)` is called, either by the caller thread or by the processing thread. Annotations @Override

public void failed(Throwable x)

Overrides org.eclipse.jetty.util.IteratingCallback.failed.

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

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

Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.

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

Eventually, onCompleteFailure(Throwable) is called, either by the caller thread or by the processing thread.

Annotations

@Override

getInvocationType	back to summary
public Invocable.InvocationType getInvocationType() Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType. Annotations @Override

getInvocationType

back to summary

public Invocable.InvocationType getInvocationType()

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

Annotations

@Override

offer	back to summary
public boolean offer(QuicStreamEndPoint endPoint, Frame frame, Callback callback)

process back to summary

process	back 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

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

succeeded back to summary

succeeded	back 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

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

org.eclipse.jetty.http3 back to summary

private Class MessageFlusher.Entry

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.http3.MessageFlusher.Entry

Field Summary

Modifier and Type	Field and Description
private final Callback	callback
private final QuicStreamEndPoint	endPoint
private final Frame	frame

Constructor Summary

Access	Constructor and Description
private	Entry(QuicStreamEndPoint endPoint, Frame frame, Callback callback)

Method Summary

Modifier and Type	Method and Description
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

callback	back to summary
private final Callback callback

endPoint	back to summary
private final QuicStreamEndPoint endPoint

frame	back to summary
private final Frame frame

Constructor Detail

Entry	back to summary
private Entry(QuicStreamEndPoint endPoint, Frame frame, Callback callback)

Method Detail

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.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

public String toString()

Overrides java.lang.Object.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

public Class MessageFlusher.FlushFrame

Constructor Summary

Access	Constructor and Description
public	FlushFrame()

Constructor Detail

FlushFrame	back to summary
public FlushFrame()

public Class MessageFlusher

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class MessageFlusher.Entry

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class MessageFlusher.FlushFrame

Constructor Summary

Method Summary

Constructor Detail