Class HttpConnectionOverHTTP2

java.lang.Object
org.eclipse.jetty.client.HttpConnection
org.eclipse.jetty.http2.client.http.HttpConnectionOverHTTP2
All Implemented Interfaces:
Closeable, AutoCloseable, org.eclipse.jetty.client.api.Connection, org.eclipse.jetty.client.ConnectionPool.Multiplexable, org.eclipse.jetty.util.Attachable, org.eclipse.jetty.util.thread.Sweeper.Sweepable

public class HttpConnectionOverHTTP2 extends org.eclipse.jetty.client.HttpConnection implements org.eclipse.jetty.util.thread.Sweeper.Sweepable, org.eclipse.jetty.client.ConnectionPool.Multiplexable
  • Field Details

    • LOG

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

      private final Set<org.eclipse.jetty.client.HttpChannel> activeChannels
    • idleChannels

      private final Queue<HttpChannelOverHTTP2> idleChannels
    • closed

      private final AtomicBoolean closed
    • sweeps

      private final AtomicInteger sweeps
    • session

      private final Session session
    • recycleHttpChannels

      private boolean recycleHttpChannels
  • Constructor Details

    • HttpConnectionOverHTTP2

      public HttpConnectionOverHTTP2(org.eclipse.jetty.client.HttpDestination destination, Session session)
  • Method Details

    • getSession

      public Session getSession()
    • isRecycleHttpChannels

      public boolean isRecycleHttpChannels()
    • setRecycleHttpChannels

      public void setRecycleHttpChannels(boolean recycleHttpChannels)
    • getMaxMultiplex

      public int getMaxMultiplex()
      Specified by:
      getMaxMultiplex in interface org.eclipse.jetty.client.ConnectionPool.Multiplexable
    • getHttpChannels

      protected Iterator<org.eclipse.jetty.client.HttpChannel> getHttpChannels()
      Specified by:
      getHttpChannels in class org.eclipse.jetty.client.HttpConnection
    • send

      protected org.eclipse.jetty.client.SendFailure send(org.eclipse.jetty.client.HttpExchange exchange)
      Specified by:
      send in class org.eclipse.jetty.client.HttpConnection
    • acquireHttpChannel

      protected HttpChannelOverHTTP2 acquireHttpChannel()
    • newHttpChannel

      protected HttpChannelOverHTTP2 newHttpChannel()
    • release

      protected boolean release(HttpChannelOverHTTP2 channel)
    • onIdleTimeout

      public boolean onIdleTimeout(long idleTimeout)
      Overrides:
      onIdleTimeout in class org.eclipse.jetty.client.HttpConnection
    • remove

      void remove()
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.eclipse.jetty.client.api.Connection
    • close

      protected void close(Throwable failure)
    • isClosed

      public boolean isClosed()
      Specified by:
      isClosed in interface org.eclipse.jetty.client.api.Connection
    • abort

      private void abort(Throwable failure)
    • sweep

      public boolean sweep()
      Specified by:
      sweep in interface org.eclipse.jetty.util.thread.Sweeper.Sweepable
    • toString

      public String toString()
      Overrides:
      toString in class org.eclipse.jetty.client.HttpConnection