Class HTTP2Connection

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.eclipse.jetty.io.Connection, org.eclipse.jetty.io.WriteFlusher.Listener
    Direct Known Subclasses:
    HTTP2ClientConnectionFactory.HTTP2ClientConnection, HTTP2ServerConnection

    public class HTTP2Connection
    extends org.eclipse.jetty.io.AbstractConnection
    implements org.eclipse.jetty.io.WriteFlusher.Listener
    • Field Detail

      • LOG

        protected static final org.eclipse.jetty.util.log.Logger LOG
      • PEC_MODE

        private static final boolean PEC_MODE
      • tasks

        private final java.util.Queue<java.lang.Runnable> tasks
      • bytesIn

        private final java.util.concurrent.atomic.AtomicLong bytesIn
      • byteBufferPool

        private final org.eclipse.jetty.io.ByteBufferPool byteBufferPool
      • session

        private final ISession session
      • bufferSize

        private final int bufferSize
      • strategy

        private final org.eclipse.jetty.util.thread.ExecutionStrategy strategy
    • Constructor Detail

      • HTTP2Connection

        @Deprecated
        public HTTP2Connection​(org.eclipse.jetty.io.ByteBufferPool byteBufferPool,
                               java.util.concurrent.Executor executor,
                               org.eclipse.jetty.io.EndPoint endPoint,
                               Parser parser,
                               ISession session,
                               int bufferSize)
        Deprecated.
      • HTTP2Connection

        public HTTP2Connection​(org.eclipse.jetty.io.ByteBufferPool byteBufferPool,
                               java.util.concurrent.Executor executor,
                               org.eclipse.jetty.io.EndPoint endPoint,
                               ISession session,
                               int bufferSize)
    • Method Detail

      • getMessagesIn

        public long getMessagesIn()
        Specified by:
        getMessagesIn in interface org.eclipse.jetty.io.Connection
        Overrides:
        getMessagesIn in class org.eclipse.jetty.io.AbstractConnection
      • getMessagesOut

        public long getMessagesOut()
        Specified by:
        getMessagesOut in interface org.eclipse.jetty.io.Connection
        Overrides:
        getMessagesOut in class org.eclipse.jetty.io.AbstractConnection
      • getBytesIn

        public long getBytesIn()
        Specified by:
        getBytesIn in interface org.eclipse.jetty.io.Connection
        Overrides:
        getBytesIn in class org.eclipse.jetty.io.AbstractConnection
      • getBytesOut

        public long getBytesOut()
        Specified by:
        getBytesOut in interface org.eclipse.jetty.io.Connection
        Overrides:
        getBytesOut in class org.eclipse.jetty.io.AbstractConnection
      • getSession

        public ISession getSession()
      • getParser

        protected Parser getParser()
      • setInputBuffer

        protected void setInputBuffer​(java.nio.ByteBuffer buffer)
      • onOpen

        public void onOpen()
        Specified by:
        onOpen in interface org.eclipse.jetty.io.Connection
        Overrides:
        onOpen in class org.eclipse.jetty.io.AbstractConnection
      • onClose

        public void onClose()
        Specified by:
        onClose in interface org.eclipse.jetty.io.Connection
        Overrides:
        onClose in class org.eclipse.jetty.io.AbstractConnection
      • onFillable

        public void onFillable()
        Specified by:
        onFillable in class org.eclipse.jetty.io.AbstractConnection
      • fill

        private int fill​(org.eclipse.jetty.io.EndPoint endPoint,
                         java.nio.ByteBuffer buffer)
      • onIdleExpired

        public boolean onIdleExpired()
        Specified by:
        onIdleExpired in interface org.eclipse.jetty.io.Connection
        Overrides:
        onIdleExpired in class org.eclipse.jetty.io.AbstractConnection
      • offerTask

        protected void offerTask​(java.lang.Runnable task,
                                 boolean dispatch)
      • produce

        protected void produce()
      • dispatch

        protected void dispatch()
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface org.eclipse.jetty.io.Connection
        Overrides:
        close in class org.eclipse.jetty.io.AbstractConnection
      • offerTask

        private void offerTask​(java.lang.Runnable task)
      • pollTask

        private java.lang.Runnable pollTask()
      • onFlushed

        public void onFlushed​(long bytes)
                       throws java.io.IOException
        Specified by:
        onFlushed in interface org.eclipse.jetty.io.WriteFlusher.Listener
        Throws:
        java.io.IOException