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

pack-priv Class Http2ClientConnection

extends Http2ConnectionBase
implements HttpClientConnection
Class Inheritance
All Implemented Interfaces
io.vertx.core.http.impl.HttpClientConnection, io.vertx.core.http.HttpConnection
Imports
io.netty.buffer.ByteBuf, io.netty.channel.ChannelHandlerContext, .EventLoop, io.netty.handler.codec.http.HttpHeaderNames, .HttpResponseStatus, io.netty.handler.codec.http2.*, io.netty.handler.timeout.IdleStateEvent, io.vertx.core.*, io.vertx.core.buffer.Buffer, io.vertx.core.http.*, io.vertx.core.http.impl.headers.HeadersMultiMap, .Http2HeadersAdaptor, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.metrics.ClientMetrics, .HttpClientMetrics, io.vertx.core.spi.tracing.SpanKind, .VertxTracer, io.vertx.core.streams.WriteStream, java.util.Map, java.util.function.BiConsumer
Author
Julien Viet

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv abstract static class
Http2ClientConnection.Stream

pack-priv static class
Http2ClientConnection.StreamImpl

Field Summary

Modifier and TypeField and Description
private final HttpClientBase
client

private Handler<Long>
concurrencyChangeHandler

private boolean
evicted

private Handler<Void>
evictionHandler

private long
expirationTimestamp

private final ClientMetrics<M, T, Req, Resp>
metrics

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

Constructor Summary

AccessConstructor and Description
pack-priv
Http2ClientConnection(HttpClientBase client, ContextInternal context, VertxHttp2ConnectionHandler<C extends Http2ConnectionBase> connHandler, ClientMetrics<M, T, Req, Resp> metrics)

Method Summary

Modifier and TypeMethod and Description
public long
activeStreams()

Implements io.vertx.core.http.impl.HttpClientConnection.activeStreams.

public long
concurrency()

Implements io.vertx.core.http.impl.HttpClientConnection.concurrency.

protected void
concurrencyChanged(long concurrency)

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

public Http2ClientConnection
concurrencyChangeHandler(Handler<Long>
the handler
handler)

Implements io.vertx.core.http.impl.HttpClientConnection.concurrencyChangeHandler.

Set a handler called when the connection concurrency changes.

public static VertxHttp2ConnectionHandler<Http2ClientConnection>
createHttp2ConnectionHandler(HttpClientBase client, ClientMetrics<M, T, Req, Resp> metrics, ContextInternal context, boolean upgrade, Object socketMetric)

public Future<HttpClientRequest>
createRequest(ContextInternal
the stream context
context)

Implements io.vertx.core.http.impl.HttpClientConnection.createRequest.

Create an HTTP stream.

public void
createStream(ContextInternal
the stream context
context, Handler<AsyncResult<HttpClientStream>>
the handler called when the stream is created
handler)

Implements io.vertx.core.http.impl.HttpClientConnection.createStream.

Create an HTTP stream.

private Http2ClientConnection.StreamImpl
createStream(ContextInternal context)

public Http2ClientConnection
evictionHandler(Handler<Void>
the handler
handler)

Implements io.vertx.core.http.impl.HttpClientConnection.evictionHandler.

Set a handler called when the connection should be evicted from a pool.

protected void
handleIdle(IdleStateEvent event)

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

Called by the Netty handler when the connection becomes idle.

public boolean
isValid()

Implements io.vertx.core.http.impl.HttpClientConnection.isValid.

public long
lastResponseReceivedTimestamp()

Implements io.vertx.core.http.impl.HttpClientConnection.lastResponseReceivedTimestamp.

public HttpClientMetrics<R, W, S, T>
metrics()

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

private void
metricsEnd(Http2ClientConnection.Stream stream)

pack-priv boolean
onGoAwayReceived(GoAway goAway)

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

pack-priv boolean
onGoAwaySent(GoAway goAway)

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

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

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

public synchronized void
onPushPromiseRead(ChannelHandlerContext
the context from the handler where the frame was read.
ctx, int
the stream the frame was sent on.
streamId, int
the ID of the promised stream.
promisedStreamId, Http2Headers
the received headers.
headers, int
additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).
padding)

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

Implements io.netty.handler.codec.http2.Http2FrameListener.onPushPromiseRead.

Handles an inbound PUSH_PROMISE frame.

private void
recycle()

private void
tryEvict()

Try to evict the connection from the pool.

pack-priv void
upgradeStream(Object metric, Object trace, ContextInternal context, Handler<AsyncResult<HttpClientStream>> completionHandler)

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