Package org.eclipse.jetty.http2.server
Class HTTP2ServerConnection
- java.lang.Object
-
- org.eclipse.jetty.io.AbstractConnection
-
- org.eclipse.jetty.http2.HTTP2Connection
-
- org.eclipse.jetty.http2.server.HTTP2ServerConnection
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,org.eclipse.jetty.io.Connection
,org.eclipse.jetty.io.Connection.UpgradeTo
,org.eclipse.jetty.io.WriteFlusher.Listener
public class HTTP2ServerConnection extends HTTP2Connection implements org.eclipse.jetty.io.Connection.UpgradeTo
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected class
HTTP2ServerConnection.ServerHttpChannelOverHTTP2
-
Nested classes/interfaces inherited from class org.eclipse.jetty.http2.HTTP2Connection
HTTP2Connection.HTTP2Producer
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.Queue<HttpChannelOverHTTP2>
channels
private org.eclipse.jetty.server.HttpConfiguration
httpConfig
private ServerSessionListener
listener
private boolean
recycleHttpChannels
private java.util.List<Frame>
upgradeFrames
-
Fields inherited from class org.eclipse.jetty.http2.HTTP2Connection
LOG
-
-
Constructor Summary
Constructors Constructor Description HTTP2ServerConnection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, org.eclipse.jetty.server.HttpConfiguration httpConfig, ISession session, int inputBufferSize, ServerSessionListener listener)
HTTP2ServerConnection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, org.eclipse.jetty.server.HttpConfiguration httpConfig, ServerParser parser, ISession session, int inputBufferSize, ServerSessionListener listener)
Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ServerParser
getParser()
boolean
isRecycleHttpChannels()
static boolean
isSupportedProtocol(java.lang.String protocol)
protected HTTP2ServerConnection.ServerHttpChannelOverHTTP2
newServerHttpChannelOverHTTP2(org.eclipse.jetty.server.Connector connector, org.eclipse.jetty.server.HttpConfiguration httpConfig, HttpTransportOverHTTP2 transport)
private void
notifyAccept(ISession session)
private void
offerHttpChannel(HttpChannelOverHTTP2 channel)
void
onData(IStream stream, DataFrame frame, org.eclipse.jetty.util.Callback callback)
void
onNewStream(org.eclipse.jetty.server.Connector connector, IStream stream, HeadersFrame frame)
void
onOpen()
void
onSessionFailure(java.lang.Throwable failure, org.eclipse.jetty.util.Callback callback)
boolean
onSessionTimeout(java.lang.Throwable failure)
void
onStreamFailure(IStream stream, java.lang.Throwable failure, org.eclipse.jetty.util.Callback callback)
boolean
onStreamTimeout(IStream stream, java.lang.Throwable failure)
void
onTrailers(IStream stream, HeadersFrame frame)
void
onUpgradeTo(java.nio.ByteBuffer buffer)
private HttpChannelOverHTTP2
pollHttpChannel()
private HttpChannelOverHTTP2
provideHttpChannel(org.eclipse.jetty.server.Connector connector, IStream stream)
void
push(org.eclipse.jetty.server.Connector connector, IStream stream, org.eclipse.jetty.http.MetaData.Request request)
void
setRecycleHttpChannels(boolean recycleHttpChannels)
boolean
upgrade(org.eclipse.jetty.http.MetaData.Request request)
-
Methods inherited from class org.eclipse.jetty.http2.HTTP2Connection
close, dispatch, getBytesIn, getBytesOut, getMessagesIn, getMessagesOut, getSession, offerTask, onClose, onFillable, onFlushed, onIdleExpired, produce, setInputBuffer, wrapParserListener
-
Methods inherited from class org.eclipse.jetty.io.AbstractConnection
addListener, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, isFillInterested, onFillInterestedFailed, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
-
-
-
-
Field Detail
-
channels
private final java.util.Queue<HttpChannelOverHTTP2> channels
-
upgradeFrames
private final java.util.List<Frame> upgradeFrames
-
listener
private final ServerSessionListener listener
-
httpConfig
private final org.eclipse.jetty.server.HttpConfiguration httpConfig
-
recycleHttpChannels
private boolean recycleHttpChannels
-
-
Constructor Detail
-
HTTP2ServerConnection
@Deprecated public HTTP2ServerConnection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, org.eclipse.jetty.server.HttpConfiguration httpConfig, ServerParser parser, ISession session, int inputBufferSize, ServerSessionListener listener)
Deprecated.
-
HTTP2ServerConnection
public HTTP2ServerConnection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, org.eclipse.jetty.server.HttpConfiguration httpConfig, ISession session, int inputBufferSize, ServerSessionListener listener)
-
-
Method Detail
-
isSupportedProtocol
public static boolean isSupportedProtocol(java.lang.String protocol)
- Parameters:
protocol
- An HTTP2 protocol variant- Returns:
- True if the protocol version is supported
-
getParser
protected ServerParser getParser()
- Overrides:
getParser
in classHTTP2Connection
-
isRecycleHttpChannels
public boolean isRecycleHttpChannels()
-
setRecycleHttpChannels
public void setRecycleHttpChannels(boolean recycleHttpChannels)
-
onUpgradeTo
public void onUpgradeTo(java.nio.ByteBuffer buffer)
- Specified by:
onUpgradeTo
in interfaceorg.eclipse.jetty.io.Connection.UpgradeTo
-
onOpen
public void onOpen()
- Specified by:
onOpen
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
onOpen
in classHTTP2Connection
-
notifyAccept
private void notifyAccept(ISession session)
-
onNewStream
public void onNewStream(org.eclipse.jetty.server.Connector connector, IStream stream, HeadersFrame frame)
-
onData
public void onData(IStream stream, DataFrame frame, org.eclipse.jetty.util.Callback callback)
-
onTrailers
public void onTrailers(IStream stream, HeadersFrame frame)
-
onStreamTimeout
public boolean onStreamTimeout(IStream stream, java.lang.Throwable failure)
-
onStreamFailure
public void onStreamFailure(IStream stream, java.lang.Throwable failure, org.eclipse.jetty.util.Callback callback)
-
onSessionTimeout
public boolean onSessionTimeout(java.lang.Throwable failure)
-
onSessionFailure
public void onSessionFailure(java.lang.Throwable failure, org.eclipse.jetty.util.Callback callback)
-
push
public void push(org.eclipse.jetty.server.Connector connector, IStream stream, org.eclipse.jetty.http.MetaData.Request request)
-
provideHttpChannel
private HttpChannelOverHTTP2 provideHttpChannel(org.eclipse.jetty.server.Connector connector, IStream stream)
-
newServerHttpChannelOverHTTP2
protected HTTP2ServerConnection.ServerHttpChannelOverHTTP2 newServerHttpChannelOverHTTP2(org.eclipse.jetty.server.Connector connector, org.eclipse.jetty.server.HttpConfiguration httpConfig, HttpTransportOverHTTP2 transport)
-
offerHttpChannel
private void offerHttpChannel(HttpChannelOverHTTP2 channel)
-
pollHttpChannel
private HttpChannelOverHTTP2 pollHttpChannel()
-
upgrade
public boolean upgrade(org.eclipse.jetty.http.MetaData.Request request)
-
-