Class HTTP2Connection

java.lang.Object
org.eclipse.jetty.io.AbstractConnection
org.eclipse.jetty.http2.HTTP2Connection
All Implemented Interfaces:
Closeable, 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 Details

    • LOG

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

      private static final boolean PEC_MODE
    • tasks

      private final Queue<Runnable> tasks
    • producer

      private final HTTP2Connection.HTTP2Producer producer
    • bytesIn

      private final 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 Details

    • HTTP2Connection

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

      public HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, Executor executor, org.eclipse.jetty.io.EndPoint endPoint, ISession session, int bufferSize)
  • Method Details

    • 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(ByteBuffer buffer)
    • wrapParserListener

      public Parser.Listener wrapParserListener(Parser.Listener listener)
    • 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, 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(Runnable task, boolean dispatch)
    • produce

      protected void produce()
    • dispatch

      protected void dispatch()
    • close

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

      private void offerTask(Runnable task)
    • pollTask

      private Runnable pollTask()
    • onFlushed

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