Class 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 Classes 
      Modifier and Type Class Description
      static class  HTTP2Flusher.Entry  
      private class  HTTP2Flusher.WindowEntry  
      • Nested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback

        org.eclipse.jetty.util.IteratingCallback.Action
      • Nested 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.Nested
      • Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

        org.eclipse.jetty.util.component.Dumpable.DumpableContainer
      • Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

        org.eclipse.jetty.util.thread.Invocable.InvocationType
    • Field Detail

      • LOG

        private static final org.eclipse.jetty.util.log.Logger LOG
      • EMPTY_BYTE_BUFFERS

        private static final java.nio.ByteBuffer[] EMPTY_BYTE_BUFFERS
      • processedEntries

        private final java.util.Collection<HTTP2Flusher.Entry> processedEntries
      • lease

        private final org.eclipse.jetty.io.ByteBufferPool.Lease lease
      • invocationType

        private org.eclipse.jetty.util.thread.Invocable.InvocationType invocationType
      • terminated

        private java.lang.Throwable terminated
    • Constructor Detail

      • HTTP2Flusher

        public HTTP2Flusher​(HTTP2Session session)
    • Method Detail

      • getInvocationType

        public org.eclipse.jetty.util.thread.Invocable.InvocationType getInvocationType()
        Specified by:
        getInvocationType in interface org.eclipse.jetty.util.thread.Invocable
      • getWindowQueueSize

        private int getWindowQueueSize()
      • getFrameQueueSize

        public int getFrameQueueSize()
      • process

        protected org.eclipse.jetty.util.IteratingCallback.Action process()
                                                                   throws java.lang.Throwable
        Specified by:
        process in class org.eclipse.jetty.util.IteratingCallback
        Throws:
        java.lang.Throwable
      • onFlushed

        void onFlushed​(long bytes)
                throws java.io.IOException
        Throws:
        java.io.IOException
      • succeeded

        public void succeeded()
        Specified by:
        succeeded in interface org.eclipse.jetty.util.Callback
        Overrides:
        succeeded in class org.eclipse.jetty.util.IteratingCallback
      • finish

        private void finish()
      • onCompleteSuccess

        protected void onCompleteSuccess()
        Overrides:
        onCompleteSuccess in class org.eclipse.jetty.util.IteratingCallback
      • onCompleteFailure

        protected void onCompleteFailure​(java.lang.Throwable x)
        Overrides:
        onCompleteFailure in class org.eclipse.jetty.util.IteratingCallback
      • terminate

        void terminate​(java.lang.Throwable cause)
      • closed

        private void closed​(HTTP2Flusher.Entry entry,
                            java.lang.Throwable failure)
      • dump

        public java.lang.String dump()
        Specified by:
        dump in interface org.eclipse.jetty.util.component.Dumpable
      • dump

        public void dump​(java.lang.Appendable out,
                         java.lang.String indent)
                  throws java.io.IOException
        Specified by:
        dump in interface org.eclipse.jetty.util.component.Dumpable
        Throws:
        java.io.IOException
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class org.eclipse.jetty.util.IteratingCallback