Package org.eclipse.jetty.http2.server
Class HttpChannelOverHTTP2
- java.lang.Object
-
- org.eclipse.jetty.server.HttpChannel
-
- org.eclipse.jetty.http2.server.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
-
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
-
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
-
-
-
-
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 classorg.eclipse.jetty.server.HttpChannel
-
setIdleTimeout
public void setIdleTimeout(long timeoutMs)
- Overrides:
setIdleTimeout
in classorg.eclipse.jetty.server.HttpChannel
-
getIdleTimeout
public long getIdleTimeout()
- Overrides:
getIdleTimeout
in classorg.eclipse.jetty.server.HttpChannel
-
onFlushed
public void onFlushed(long bytes) throws java.io.IOException
- Specified by:
onFlushed
in interfaceorg.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 classorg.eclipse.jetty.server.HttpChannel
-
recycle
public void recycle()
- Overrides:
recycle
in classorg.eclipse.jetty.server.HttpChannel
-
commit
protected void commit(org.eclipse.jetty.http.MetaData.Response info)
- Overrides:
commit
in classorg.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 classorg.eclipse.jetty.server.HttpChannel
- Throws:
java.io.IOException
- if the InputStream cannot be created
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
-
toString
public java.lang.String toString()
- Overrides:
toString
in classorg.eclipse.jetty.server.HttpChannel
-
-