Top Inners Fields Constructors Methods
io.vertx.core.http.impl

public Class Http2ServerConnection

extends Http2ConnectionBase
implements HttpServerConnection
Class Inheritance
All Implemented Interfaces
io.vertx.core.http.impl.HttpServerConnection, io.vertx.core.http.HttpConnection
Imports
io.netty.channel.EventLoop, io.netty.handler.codec.compression.CompressionOptions, io.netty.handler.codec.http.HttpContentCompressor, .HttpHeaderNames, io.netty.handler.codec.http2.*, .Http2Settings, io.netty.util.concurrent.Future, .FutureListener, io.vertx.core.AsyncResult, .Handler, .MultiMap, .Promise, io.vertx.core.http.*, io.vertx.core.impl.ContextInternal, io.vertx.core.net.HostAndPort, io.vertx.core.spi.metrics.HttpServerMetrics, java.util.ArrayDeque, java.util.function.Function, .Supplier
Author
Julien Viet

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
Http2ServerConnection.EncodingDetector

private class
Http2ServerConnection.Push

Field Summary

Modifier and TypeField and Description
private int
concurrentStreams

private final Function<String, String>
encodingDetector

private final HttpServerMetrics<R, W, S>
metrics

pack-priv final HttpServerOptions
options

private final ArrayDeque<Http2ServerConnection.Push>
pendingPushes

pack-priv Handler<HttpServerRequest>
requestHandler

private final String
serverOrigin

private final Supplier<ContextInternal>
streamContextSupplier

private VertxHttp2Stream<C extends Http2ConnectionBase>
upgraded

Inherited from io.vertx.core.http.impl.Http2ConnectionBase:
handlerhandlerContextstreamKey

Constructor Summary

AccessConstructor and Description
pack-priv
Http2ServerConnection(ContextInternal context, Supplier<ContextInternal> streamContextSupplier, String serverOrigin, VertxHttp2ConnectionHandler<C extends Http2ConnectionBase> connHandler, Function<String, String> encodingDetector, HttpServerOptions options, HttpServerMetrics<R, W, S> metrics)

Method Summary

Modifier and TypeMethod and Description
private Http2ServerStream
createStream(Http2Headers headers, boolean streamEnded)

pack-priv String
determineContentEncoding(Http2Headers headers)

private synchronized void
doSendPush(int streamId, HostAndPort authority, HttpMethod method, MultiMap headers, String path, StreamPriority streamPriority, Promise<HttpServerResponse> promise)

public HttpServerConnection
handler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.handler.

private void
initStream(int streamId, Http2ServerStream vertxStream)

public HttpServerConnection
invalidRequestHandler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.invalidRequestHandler.

private static boolean
isMalformedRequest(Http2ServerStream request)

public HttpServerMetrics<R, W, S>
metrics()

Implements abstract io.vertx.core.net.impl.ConnectionBase.metrics.

protected synchronized void
onHeadersRead(int streamId, Http2Headers headers, StreamPriority streamPriority, boolean endOfStream)

Implements abstract io.vertx.core.http.impl.Http2ConnectionBase.onHeadersRead.

pack-priv void
sendPush(int streamId, HostAndPort authority, HttpMethod method, MultiMap headers, String path, StreamPriority streamPriority, Promise<HttpServerResponse> promise)

pack-priv VertxHttp2Stream<?>
stream(int id)

Overrides io.vertx.core.http.impl.Http2ConnectionBase.stream.

protected void
updateSettings(Http2Settings settingsUpdate, Handler<AsyncResult<Void>> completionHandler)

Overrides io.vertx.core.http.impl.Http2ConnectionBase.updateSettings.

Inherited from io.vertx.core.http.impl.Http2ConnectionBase:
closecloseHandlerconcurrencyChangedconsumeCreditsdoShutdownexceptionHandlergetWindowSizegoAwaygoAwayHandlerhandleClosedhandleIdlehandleInterestedOpsChangedonConnectionErroronDataReadonGoAwayReadonGoAwayReceivedonGoAwaySentonHeadersReadonHeadersReadonPingAckReadonPingReadonPriorityReadonPushPromiseReadonRstStreamReadonSettingsAckReadonSettingsReadonStreamClosedonStreamErroronStreamWritabilityChangedonUnknownFrameonWindowUpdateReadpingpingpingHandlerremoteSettingsremoteSettingsHandlersettingssetWindowSizeshutdownshutdownHandlerupdateSettingsupdateSettingsvertx

Field Detail

concurrentStreamsback to summary
private int concurrentStreams
encodingDetectorback to summary
private final Function<String, String> encodingDetector
metricsback to summary
private final HttpServerMetrics<R, W, S> metrics
optionsback to summary
pack-priv final HttpServerOptions options
pendingPushesback to summary
private final ArrayDeque<Http2ServerConnection.Push> pendingPushes
requestHandlerback to summary
pack-priv Handler<HttpServerRequest> requestHandler
serverOriginback to summary
private final String serverOrigin
streamContextSupplierback to summary
private final Supplier<ContextInternal> streamContextSupplier
upgradedback to summary
private VertxHttp2Stream<C extends Http2ConnectionBase> upgraded

Constructor Detail

Http2ServerConnectionback to summary
pack-priv Http2ServerConnection(ContextInternal context, Supplier<ContextInternal> streamContextSupplier, String serverOrigin, VertxHttp2ConnectionHandler<C extends Http2ConnectionBase> connHandler, Function<String, String> encodingDetector, HttpServerOptions options, HttpServerMetrics<R, W, S> metrics)

Method Detail

createStreamback to summary
private Http2ServerStream createStream(Http2Headers headers, boolean streamEnded)
determineContentEncodingback to summary
pack-priv String determineContentEncoding(Http2Headers headers)
doSendPushback to summary
private synchronized void doSendPush(int streamId, HostAndPort authority, HttpMethod method, MultiMap headers, String path, StreamPriority streamPriority, Promise<HttpServerResponse> promise)
handlerback to summary
public HttpServerConnection handler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.handler.

Annotations
@Override
initStreamback to summary
private void initStream(int streamId, Http2ServerStream vertxStream)
invalidRequestHandlerback to summary
public HttpServerConnection invalidRequestHandler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.invalidRequestHandler.

Annotations
@Override
isMalformedRequestback to summary
private static boolean isMalformedRequest(Http2ServerStream request)
metricsback to summary
public HttpServerMetrics<R, W, S> metrics()

Implements abstract io.vertx.core.net.impl.ConnectionBase.metrics.

onHeadersReadback to summary
protected synchronized void onHeadersRead(int streamId, Http2Headers headers, StreamPriority streamPriority, boolean endOfStream)

Implements abstract io.vertx.core.http.impl.Http2ConnectionBase.onHeadersRead.

Annotations
@Override
sendPushback to summary
pack-priv void sendPush(int streamId, HostAndPort authority, HttpMethod method, MultiMap headers, String path, StreamPriority streamPriority, Promise<HttpServerResponse> promise)
streamback to summary
pack-priv VertxHttp2Stream<?> stream(int id)

Overrides io.vertx.core.http.impl.Http2ConnectionBase.stream.

updateSettingsback to summary
protected void updateSettings(Http2Settings settingsUpdate, Handler<AsyncResult<Void>> completionHandler)

Overrides io.vertx.core.http.impl.Http2ConnectionBase.updateSettings.

io.vertx.core.http.impl back to summary

private Class Http2ServerConnection.EncodingDetector

extends HttpContentCompressor
Class Inheritance

Constructor Summary

AccessConstructor and Description
private
EncodingDetector(CompressionOptions[] compressionOptions)

Method Summary

Modifier and TypeMethod and Description
protected String
determineEncoding(String acceptEncoding)

Overrides io.netty.handler.codec.http.HttpContentCompressor.determineEncoding.

Inherited from io.netty.handler.codec.http.HttpContentCompressor:
beginEncodedetermineWrapperhandlerAdded

Constructor Detail

EncodingDetectorback to summary
private EncodingDetector(CompressionOptions[] compressionOptions)

Method Detail

determineEncodingback to summary
protected String determineEncoding(String acceptEncoding)

Overrides io.netty.handler.codec.http.HttpContentCompressor.determineEncoding.

Annotations
@Override
io.vertx.core.http.impl back to summary

private Class Http2ServerConnection.Push

extends Object
implements Http2ServerStreamHandler
Class Inheritance
All Implemented Interfaces
io.vertx.core.http.impl.Http2ServerStreamHandler

Field Summary

Modifier and TypeField and Description
protected final ContextInternal
context

private final Promise<HttpServerResponse>
promise

protected final Http2ServerResponse
response

protected final Http2ServerStream
stream

Constructor Summary

AccessConstructor and Description
public
Push(Http2ServerStream stream, String contentEncoding, Promise<HttpServerResponse> promise)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
complete()

public void
dispatch(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.dispatch.

public void
handleClose()

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleClose.

public void
handleException(Throwable cause)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleException.

public void
handleReset(long errorCode)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleReset.

public Http2ServerResponse
response()

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.response.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

contextback to summary
protected final ContextInternal context
promiseback to summary
private final Promise<HttpServerResponse> promise
responseback to summary
protected final Http2ServerResponse response
streamback to summary
protected final Http2ServerStream stream

Constructor Detail

Pushback to summary
public Push(Http2ServerStream stream, String contentEncoding, Promise<HttpServerResponse> promise)

Method Detail

completeback to summary
pack-priv void complete()
dispatchback to summary
public void dispatch(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.dispatch.

Annotations
@Override
handleCloseback to summary
public void handleClose()

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleClose.

Annotations
@Override
handleExceptionback to summary
public void handleException(Throwable cause)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleException.

Annotations
@Override
handleResetback to summary
public void handleReset(long errorCode)

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.handleReset.

Annotations
@Override
responseback to summary
public Http2ServerResponse response()

Implements io.vertx.core.http.impl.Http2ServerStreamHandler.response.

Annotations
@Override