Class HttpConnectionOverHTTP2

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.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 Detail

      • LOG

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

        private final java.util.Set<org.eclipse.jetty.client.HttpChannel> activeChannels
      • closed

        private final java.util.concurrent.atomic.AtomicBoolean closed
      • sweeps

        private final java.util.concurrent.atomic.AtomicInteger sweeps
      • session

        private final Session session
      • recycleHttpChannels

        private boolean recycleHttpChannels
    • Constructor Detail

      • HttpConnectionOverHTTP2

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

      • 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 java.util.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
      • 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 java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface org.eclipse.jetty.client.api.Connection
      • close

        protected void close​(java.lang.Throwable failure)
      • isClosed

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

        private void abort​(java.lang.Throwable failure)
      • sweep

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

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