Package org.eclipse.jetty.http2.server

Class HttpChannelOverHTTP2

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable, org.eclipse.jetty.io.WriteFlusher.Listener, org.eclipse.jetty.server.HttpOutput.Interceptor
    Direct Known Subclasses:
    HTTP2ServerConnection.ServerHttpChannelOverHTTP2
    public class HttpChannelOverHTTP2
extends org.eclipse.jetty.server.HttpChannel
implements java.io.Closeable, org.eclipse.jetty.io.WriteFlusher.Listener

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      private class  HttpChannelOverHTTP2.FailureTask  

      • Nested classes/interfaces inherited from class org.eclipse.jetty.server.HttpChannel

        org.eclipse.jetty.server.HttpChannel.Listener, org.eclipse.jetty.server.HttpChannel.TransientListeners

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private boolean _delayedUntilContent  
      private boolean _expect100Continue  
      private static org.eclipse.jetty.util.log.Logger LOG  
      private static org.eclipse.jetty.http.HttpField POWERED_BY  
      private static org.eclipse.jetty.http.HttpField SERVER_VERSION  

      • Fields inherited from class org.eclipse.jetty.server.HttpChannel

        NOOP_LISTENER

    • Constructor Summary

      Constructors 
      Constructor Description
      HttpChannelOverHTTP2​(org.eclipse.jetty.server.Connector connector, org.eclipse.jetty.server.HttpConfiguration configuration, org.eclipse.jetty.io.EndPoint endPoint, HttpTransportOverHTTP2 transport)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      protected void commit​(org.eclipse.jetty.http.MetaData.Response info)  
      protected void consumeInput()  
      void continue100​(int available)
      If the associated response has the Expect header set to 100 Continue, then accessing the input stream indicates that the handler/servlet is ready for the request body and thus a 100 Continue response is sent.
      HttpTransportOverHTTP2 getHttpTransport()  
      long getIdleTimeout()  
      protected IStream getStream()  
      private void handleWithContext()  
      boolean isExpecting100Continue()  
      boolean isRequestIdle()  
      java.lang.Runnable onFailure​(java.lang.Throwable failure, org.eclipse.jetty.util.Callback callback)  
      void onFlushed​(long bytes)  
      java.lang.Runnable onPushRequest​(org.eclipse.jetty.http.MetaData.Request request)  
      java.lang.Runnable onRequest​(HeadersFrame frame)  
      java.lang.Runnable onRequestContent​(DataFrame frame, org.eclipse.jetty.util.Callback callback)  
      java.lang.Runnable onRequestTrailers​(HeadersFrame frame)  
      boolean onStreamTimeout​(java.lang.Throwable failure, java.util.function.Consumer<java.lang.Runnable> consumer)  
      void recycle()  
      void setIdleTimeout​(long timeoutMs)  
      java.lang.String toString()  

      • Methods inherited from class org.eclipse.jetty.server.HttpChannel

        abort, addListener, addRequestLog, ensureConsumeAllOrNotPersistent, execute, formatAddrOrHost, getByteBufferPool, getBytesWritten, getCommittedMetaData, getConnection, getConnector, getEndPoint, getHttpConfiguration, getLocalAddress, getLocalName, getLocalPort, getNextInterceptor, getRemoteAddress, getRequest, getRequestLog, getRequests, getResponse, getScheduler, getServer, getServerAuthority, getState, getTransientListeners, handle, handleException, isCommitted, isExpecting102Processing, isOptimizedForDirectBuffers, isPersistent, isRequestCompleted, isResponseCompleted, isSendError, newHttpInput, newHttpOutput, onAsyncWaitForContent, onBadMessage, onBlockWaitForContent, onBlockWaitForContentFailure, onCompleted, onContent, onContentComplete, onEarlyEOF, onRequest, onRequestComplete, onTrailers, removeListener, resetBuffer, run, sendResponse, sendResponse, sendResponseAndComplete, setRequestLog, unwrap, useDirectBuffers, write

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Field Detail

      • LOG

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

      • SERVER_VERSION

        private static final org.eclipse.jetty.http.HttpField SERVER_VERSION

      • POWERED_BY

        private static final org.eclipse.jetty.http.HttpField POWERED_BY

      • _expect100Continue

        private boolean _expect100Continue

      • _delayedUntilContent

        private boolean _delayedUntilContent

    • Constructor Detail

      • HttpChannelOverHTTP2

        public HttpChannelOverHTTP2​(org.eclipse.jetty.server.Connector connector,
                            org.eclipse.jetty.server.HttpConfiguration configuration,
                            org.eclipse.jetty.io.EndPoint endPoint,
                            HttpTransportOverHTTP2 transport)

    • Method Detail

      • getStream

        protected IStream getStream()

      • isExpecting100Continue

        public boolean isExpecting100Continue()
        Overrides:
        isExpecting100Continue in class org.eclipse.jetty.server.HttpChannel

      • setIdleTimeout

        public void setIdleTimeout​(long timeoutMs)
        Overrides:
        setIdleTimeout in class org.eclipse.jetty.server.HttpChannel

      • getIdleTimeout

        public long getIdleTimeout()
        Overrides:
        getIdleTimeout in class org.eclipse.jetty.server.HttpChannel

      • 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

      • onRequest

        public java.lang.Runnable onRequest​(HeadersFrame frame)

      • onPushRequest

        public java.lang.Runnable onPushRequest​(org.eclipse.jetty.http.MetaData.Request request)

      • getHttpTransport

        public HttpTransportOverHTTP2 getHttpTransport()
        Overrides:
        getHttpTransport in class org.eclipse.jetty.server.HttpChannel

      • recycle

        public void recycle()
        Overrides:
        recycle in class org.eclipse.jetty.server.HttpChannel

      • commit

        protected void commit​(org.eclipse.jetty.http.MetaData.Response info)
        Overrides:
        commit in class org.eclipse.jetty.server.HttpChannel

      • onRequestContent

        public java.lang.Runnable onRequestContent​(DataFrame frame,
                                           org.eclipse.jetty.util.Callback callback)

      • onRequestTrailers

        public java.lang.Runnable onRequestTrailers​(HeadersFrame frame)

      • isRequestIdle

        public boolean isRequestIdle()

      • onStreamTimeout

        public boolean onStreamTimeout​(java.lang.Throwable failure,
                               java.util.function.Consumer<java.lang.Runnable> consumer)

      • onFailure

        public java.lang.Runnable onFailure​(java.lang.Throwable failure,
                                    org.eclipse.jetty.util.Callback callback)

      • consumeInput

        protected void consumeInput()

      • handleWithContext

        private void handleWithContext()

      • continue100

        public void continue100​(int available)
                 throws java.io.IOException
        If the associated response has the Expect header set to 100 Continue, then accessing the input stream indicates that the handler/servlet is ready for the request body and thus a 100 Continue response is sent.
        Overrides:
        continue100 in class org.eclipse.jetty.server.HttpChannel
        Throws:
        java.io.IOException - if the InputStream cannot be created

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class org.eclipse.jetty.server.HttpChannel