Package org.eclipse.jetty.http2
Class HTTP2Flusher
java.lang.Object
org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.http2.HTTP2Flusher
- All Implemented Interfaces:
org.eclipse.jetty.util.Callback,org.eclipse.jetty.util.component.Dumpable,org.eclipse.jetty.util.thread.Invocable
public class HTTP2Flusher
extends org.eclipse.jetty.util.IteratingCallback
implements org.eclipse.jetty.util.component.Dumpable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classprivate classNested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.util.IteratingCallback.ActionNested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback
org.eclipse.jetty.util.Callback.Completable, org.eclipse.jetty.util.Callback.Completing, org.eclipse.jetty.util.Callback.NestedNested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
org.eclipse.jetty.util.component.Dumpable.DumpableContainerNested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable
org.eclipse.jetty.util.thread.Invocable.InvocationType -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final ByteBuffer[]private final Deque<HTTP2Flusher.Entry> private org.eclipse.jetty.util.thread.Invocable.InvocationTypeprivate final org.eclipse.jetty.io.ByteBufferPool.Leaseprivate static final org.eclipse.jetty.util.log.Loggerprivate final Queue<HTTP2Flusher.Entry> private final Collection<HTTP2Flusher.Entry> private final HTTP2Sessionprivate HTTP2Flusher.Entryprivate Throwableprivate final Queue<HTTP2Flusher.WindowEntry> Fields inherited from interface org.eclipse.jetty.util.Callback
NOOPFields inherited from interface org.eclipse.jetty.util.component.Dumpable
KEYFields inherited from interface org.eclipse.jetty.util.thread.Invocable
__nonBlocking -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanappend(List<HTTP2Flusher.Entry> list) booleanappend(HTTP2Flusher.Entry entry) private voidclosed(HTTP2Flusher.Entry entry, Throwable failure) dump()voiddump(Appendable out, String indent) private voidfinish()intorg.eclipse.jetty.util.thread.Invocable.InvocationTypeprivate intprotected voidprotected void(package private) voidonFlushed(long bytes) booleanprepend(HTTP2Flusher.Entry entry) protected org.eclipse.jetty.util.IteratingCallback.Actionprocess()void(package private) voidtoString()voidwindow(IStream stream, WindowUpdateFrame frame) Methods inherited from class org.eclipse.jetty.util.IteratingCallback
close, failed, isClosed, isFailed, isSucceeded, iterate, resetMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.jetty.util.component.Dumpable
dumpSelf
-
Field Details
-
LOG
private static final org.eclipse.jetty.util.log.Logger LOG -
EMPTY_BYTE_BUFFERS
-
windows
-
entries
-
pendingEntries
-
processedEntries
-
session
-
lease
private final org.eclipse.jetty.io.ByteBufferPool.Lease lease -
invocationType
private org.eclipse.jetty.util.thread.Invocable.InvocationType invocationType -
terminated
-
stalledEntry
-
-
Constructor Details
-
HTTP2Flusher
-
-
Method Details
-
getInvocationType
public org.eclipse.jetty.util.thread.Invocable.InvocationType getInvocationType()- Specified by:
getInvocationTypein interfaceorg.eclipse.jetty.util.thread.Invocable
-
window
-
prepend
-
append
-
append
-
getWindowQueueSize
private int getWindowQueueSize() -
getFrameQueueSize
public int getFrameQueueSize() -
process
- Specified by:
processin classorg.eclipse.jetty.util.IteratingCallback- Throws:
Throwable
-
onFlushed
- Throws:
IOException
-
succeeded
public void succeeded()- Specified by:
succeededin interfaceorg.eclipse.jetty.util.Callback- Overrides:
succeededin classorg.eclipse.jetty.util.IteratingCallback
-
finish
private void finish() -
onCompleteSuccess
protected void onCompleteSuccess()- Overrides:
onCompleteSuccessin classorg.eclipse.jetty.util.IteratingCallback
-
onCompleteFailure
- Overrides:
onCompleteFailurein classorg.eclipse.jetty.util.IteratingCallback
-
terminate
-
closed
-
dump
- Specified by:
dumpin interfaceorg.eclipse.jetty.util.component.Dumpable
-
dump
- Specified by:
dumpin interfaceorg.eclipse.jetty.util.component.Dumpable- Throws:
IOException
-
toString
- Overrides:
toStringin classorg.eclipse.jetty.util.IteratingCallback
-