class io.vertx.core.http.impl.Http2ClientConnection extends io.vertx.core.http.impl.Http2ConnectionBase implements io.vertx.core.http.impl.HttpClientConnection
{
private final io.vertx.core.http.impl.HttpClientImpl client;
private final io.vertx.core.spi.metrics.ClientMetrics metrics;
private io.vertx.core.Handler evictionHandler;
private io.vertx.core.Handler concurrencyChangeHandler;
private long expirationTimestamp;
private boolean evicted;
void <init>(io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.impl.EventLoopContext, io.vertx.core.http.impl.VertxHttp2ConnectionHandler, io.vertx.core.spi.metrics.ClientMetrics)
{
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v;
io.vertx.core.impl.EventLoopContext v;
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.spi.metrics.ClientMetrics v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.http.impl.HttpClientImpl;
v := @parameter: io.vertx.core.impl.EventLoopContext;
v := @parameter: io.vertx.core.http.impl.VertxHttp2ConnectionHandler;
v := @parameter: io.vertx.core.spi.metrics.ClientMetrics;
specialinvoke v.<io.vertx.core.http.impl.Http2ConnectionBase: void <init>(io.vertx.core.impl.EventLoopContext,io.vertx.core.http.impl.VertxHttp2ConnectionHandler)>(v, v);
v = <io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler DEFAULT_EVICTION_HANDLER>;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler evictionHandler> = v;
v = <io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler DEFAULT_CONCURRENCY_CHANGE_HANDLER>;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler concurrencyChangeHandler> = v;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics> = v;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client> = v;
return;
}
public io.vertx.core.http.impl.Http2ClientConnection evictionHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.impl.Http2ClientConnection v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler evictionHandler> = v;
return v;
}
public io.vertx.core.http.impl.Http2ClientConnection concurrencyChangeHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.impl.Http2ClientConnection v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler concurrencyChangeHandler> = v;
return v;
}
public long concurrency()
{
io.vertx.core.http.impl.HttpClientImpl v, v;
io.vertx.core.http.impl.Http2ClientConnection v;
long v;
io.vertx.core.http.Http2Settings v;
byte v;
int v, v;
io.vertx.core.http.HttpClientOptions v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.Http2Settings remoteSettings()>();
v = virtualinvoke v.<io.vertx.core.http.Http2Settings: long getMaxConcurrentStreams()>();
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: int getHttp2MultiplexingLimit()>();
if v <= 0 goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: int getHttp2MultiplexingLimit()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
label:
return v;
}
boolean onGoAwaySent(io.vertx.core.http.GoAway)
{
io.vertx.core.http.GoAway v;
io.vertx.core.http.impl.Http2ClientConnection v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.http.GoAway;
v = specialinvoke v.<io.vertx.core.http.impl.Http2ConnectionBase: boolean onGoAwaySent(io.vertx.core.http.GoAway)>(v);
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: void tryEvict()>();
label:
return v;
}
boolean onGoAwayReceived(io.vertx.core.http.GoAway)
{
io.vertx.core.http.GoAway v;
io.vertx.core.http.impl.Http2ClientConnection v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.http.GoAway;
v = specialinvoke v.<io.vertx.core.http.impl.Http2ConnectionBase: boolean onGoAwayReceived(io.vertx.core.http.GoAway)>(v);
if v == 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: void tryEvict()>();
label:
return v;
}
private void tryEvict()
{
io.vertx.core.Handler v;
io.vertx.core.http.impl.Http2ClientConnection v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: boolean evicted>;
if v != 0 goto label;
v.<io.vertx.core.http.impl.Http2ClientConnection: boolean evicted> = 1;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler evictionHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(null);
label:
return;
}
protected void concurrencyChanged(long)
{
io.vertx.core.http.impl.HttpClientImpl v;
java.lang.Long v;
io.vertx.core.http.impl.Http2ClientConnection v;
int v;
long v;
io.vertx.core.http.HttpClientOptions v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: long;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: int getHttp2MultiplexingLimit()>();
if v <= 0 goto label;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.Handler concurrencyChangeHandler>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
return;
}
public io.vertx.core.spi.metrics.HttpClientMetrics metrics()
{
io.vertx.core.spi.metrics.HttpClientMetrics v;
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.spi.metrics.HttpClientMetrics metrics()>();
return v;
}
void upgradeStream(java.lang.Object, java.lang.Object, io.vertx.core.impl.ContextInternal, io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Future v;
java.lang.Exception v;
io.netty.handler.codec.http.Http2Connection v;
io.netty.handler.codec.http.Http2Stream v;
java.lang.Object v, v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.Handler;
entermonitor v;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl createStream(io.vertx.core.impl.ContextInternal)>(v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Stream stream(int)>(1);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void init(io.netty.handler.codec.http.Http2Stream)>(v);
v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: java.lang.Object metric> = v;
v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: java.lang.Object trace> = v;
v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: boolean requestEnded> = 1;
v = staticinvoke <io.vertx.core.Future: io.vertx.core.Future succeededFuture(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <io.vertx.core.Future: io.vertx.core.Future failedFuture(java.lang.Throwable)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(v);
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void createStream(io.vertx.core.impl.ContextInternal, io.vertx.core.Handler)
{
java.lang.Throwable v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v;
io.vertx.core.Future v;
java.lang.Exception v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.Handler;
entermonitor v;
label:
v = specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.Http2ClientConnection$StreamImpl createStream(io.vertx.core.impl.ContextInternal)>(v);
v = staticinvoke <io.vertx.core.Future: io.vertx.core.Future succeededFuture(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <io.vertx.core.Future: io.vertx.core.Future failedFuture(java.lang.Throwable)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(v, v);
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private io.vertx.core.http.impl.Http2ClientConnection$StreamImpl createStream(io.vertx.core.impl.ContextInternal)
{
io.vertx.core.impl.ContextInternal v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.impl.ContextInternal;
v = new io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void <init>(io.vertx.core.http.impl.Http2ClientConnection,io.vertx.core.impl.ContextInternal,boolean)>(v, v, 0);
return v;
}
private void recycle()
{
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.http.impl.Http2ClientConnection v;
int v;
long v, v, v;
io.vertx.core.http.HttpClientOptions v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.HttpClientImpl client>;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: int getHttp2KeepAliveTimeout()>();
if v <= 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v * 1000L;
v = v + v;
goto label;
label:
v = 0L;
label:
v.<io.vertx.core.http.impl.Http2ClientConnection: long expirationTimestamp> = v;
return;
}
public boolean isValid()
{
byte v, v;
io.vertx.core.http.impl.Http2ClientConnection v;
long v, v, v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: long expirationTimestamp>;
v = v cmp 0L;
if v == 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<io.vertx.core.http.impl.Http2ClientConnection: long expirationTimestamp>;
v = v cmp v;
if v > 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long lastResponseReceivedTimestamp()
{
io.vertx.core.http.impl.Http2ClientConnection v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
return 0L;
}
protected synchronized void onHeadersRead(int, io.netty.handler.codec.http.Http2Headers, io.vertx.core.http.StreamPriority, boolean)
{
io.vertx.core.http.StreamPriority v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.http.impl.headers.Http2HeadersAdaptor v;
io.netty.handler.codec.http.Http2Headers v;
int v;
io.netty.handler.codec.http.Http2Stream v;
io.vertx.core.http.impl.VertxHttp2Stream v;
boolean v, v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: int;
v := @parameter: io.netty.handler.codec.http.Http2Headers;
v := @parameter: io.vertx.core.http.StreamPriority;
v := @parameter: boolean;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2Stream stream(int)>(v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: io.netty.handler.codec.http.Http2Stream stream>;
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Stream: boolean isTrailersReceived()>();
if v != 0 goto label;
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void onHeaders(io.netty.handler.codec.http.Http2Headers,io.vertx.core.http.StreamPriority)>(v, v);
if v == 0 goto label;
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void onEnd()>();
goto label;
label:
v = new io.vertx.core.http.impl.headers.Http2HeadersAdaptor;
specialinvoke v.<io.vertx.core.http.impl.headers.Http2HeadersAdaptor: void <init>(io.netty.handler.codec.http.Http2Headers)>(v);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: void onEnd(io.vertx.core.MultiMap)>(v);
label:
return;
}
private void metricsEnd(io.vertx.core.http.impl.Http2ClientConnection$Stream)
{
io.vertx.core.http.impl.Http2ClientConnection$Stream v;
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.spi.metrics.ClientMetrics v, v;
java.lang.Object v;
long v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.vertx.core.http.impl.Http2ClientConnection$Stream;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: java.lang.Object metric>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$Stream: long bytesRead()>();
interfaceinvoke v.<io.vertx.core.spi.metrics.ClientMetrics: void responseEnd(java.lang.Object,long)>(v, v);
label:
return;
}
public synchronized void onPushPromiseRead(io.netty.channel.ChannelHandlerContext, int, int, io.netty.handler.codec.http.Http2Headers, int) throws io.netty.handler.codec.http.Http2Exception
{
io.vertx.core.http.impl.Http2ClientConnection v;
io.vertx.core.impl.ContextInternal v, v;
long v;
io.netty.channel.ChannelHandlerContext v;
int v, v, v;
io.netty.handler.codec.http.Http2Stream v;
java.lang.String v;
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v, v;
io.vertx.core.http.impl.Http2ClientConnection$StreamImpl v;
java.lang.CharSequence v;
io.netty.handler.codec.http.Http2Connection v;
io.vertx.core.http.impl.HttpClientPush v;
io.netty.handler.codec.http.Http2Headers v;
io.netty.handler.codec.http.Http2Error v;
io.vertx.core.spi.metrics.ClientMetrics v, v, v;
java.lang.Object v;
io.vertx.core.Handler v;
io.vertx.core.http.impl.VertxHttp2Stream v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: int;
v := @parameter: int;
v := @parameter: io.netty.handler.codec.http.Http2Headers;
v := @parameter: int;
v = virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2Stream stream(int)>(v);
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.Handler pushHandler>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Stream stream(int)>(v);
v = new io.vertx.core.http.impl.Http2ClientConnection$StreamImpl;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.impl.ContextInternal context>;
specialinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void <init>(io.vertx.core.http.impl.Http2ClientConnection,io.vertx.core.impl.ContextInternal,boolean)>(v, v, 1);
virtualinvoke v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: void init(io.netty.handler.codec.http.Http2Stream)>(v);
v = new io.vertx.core.http.impl.HttpClientPush;
specialinvoke v.<io.vertx.core.http.impl.HttpClientPush: void <init>(io.netty.handler.codec.http.Http2Headers,io.vertx.core.http.impl.HttpClientStream)>(v, v);
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Headers: java.lang.CharSequence path()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<io.vertx.core.spi.metrics.ClientMetrics: java.lang.Object requestBegin(java.lang.String,java.lang.Object)>(v, v);
v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: java.lang.Object metric> = v;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.spi.metrics.ClientMetrics metrics>;
interfaceinvoke v.<io.vertx.core.spi.metrics.ClientMetrics: void requestEnd(java.lang.Object,long)>(v, 0L);
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection$StreamImpl: io.vertx.core.impl.ContextInternal context>;
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void dispatch(java.lang.Object,io.vertx.core.Handler)>(v, v);
return;
label:
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = <io.netty.handler.codec.http.Http2Error: io.netty.handler.codec.http.Http2Error CANCEL>;
v = virtualinvoke v.<io.netty.handler.codec.http.Http2Error: long code()>();
virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: void writeReset(int,long)>(v, v);
return;
}
protected void handleIdle(io.netty.handler.timeout.IdleStateEvent)
{
io.netty.handler.codec.http.Http2Connection$Endpoint v;
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v;
io.netty.handler.codec.http.Http2Connection v;
io.netty.handler.timeout.IdleStateEvent v;
io.vertx.core.http.impl.Http2ClientConnection v;
int v;
v := @this: io.vertx.core.http.impl.Http2ClientConnection;
v := @parameter: io.netty.handler.timeout.IdleStateEvent;
v = v.<io.vertx.core.http.impl.Http2ClientConnection: io.vertx.core.http.impl.VertxHttp2ConnectionHandler handler>;
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.netty.handler.codec.http.Http2Connection connection()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection: io.netty.handler.codec.http.Http2Connection$Endpoint local()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.Http2Connection$Endpoint: int numActiveStreams()>();
if v <= 0 goto label;
specialinvoke v.<io.vertx.core.http.impl.Http2ConnectionBase: void handleIdle(io.netty.handler.timeout.IdleStateEvent)>(v);
label:
return;
}
public static io.vertx.core.http.impl.VertxHttp2ConnectionHandler createHttp2ConnectionHandler(io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.spi.metrics.ClientMetrics, io.vertx.core.impl.EventLoopContext, boolean, java.lang.Object)
{
io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder v, v, v, v, v, v, v;
io.vertx.core.http.impl.HttpClientImpl v;
io.vertx.core.spi.metrics.HttpClientMetrics v;
io.vertx.core.http.Http2Settings v;
java.util.function.Function v;
io.vertx.core.http.HttpClientOptions v, v, v;
boolean v, v, v;
io.vertx.core.http.impl.VertxHttp2ConnectionHandler v;
io.vertx.core.impl.EventLoopContext v;
io.vertx.core.spi.metrics.ClientMetrics v;
java.lang.Object v;
io.vertx.core.Handler v, v;
v := @parameter: io.vertx.core.http.impl.HttpClientImpl;
v := @parameter: io.vertx.core.spi.metrics.ClientMetrics;
v := @parameter: io.vertx.core.impl.EventLoopContext;
v := @parameter: boolean;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.spi.metrics.HttpClientMetrics metrics()>();
v = new io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder;
specialinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: void <init>()>();
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder server(boolean)>(0);
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: boolean isTryUseCompression()>();
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder useDecompression(boolean)>(v);
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder gracefulShutdownTimeoutMillis(long)>(0L);
v = virtualinvoke v.<io.vertx.core.http.impl.HttpClientImpl: io.vertx.core.http.HttpClientOptions options()>();
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: io.vertx.core.http.Http2Settings getInitialSettings()>();
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder initialSettings(io.vertx.core.http.Http2Settings)>(v);
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$lambda_createHttp2ConnectionHandler_0__1061: java.util.function.Function bootstrap$(io.vertx.core.http.impl.HttpClientImpl,io.vertx.core.impl.EventLoopContext,io.vertx.core.spi.metrics.ClientMetrics,java.lang.Object)>(v, v, v, v);
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder connectionFactory(java.util.function.Function)>(v);
v = virtualinvoke v.<io.vertx.core.http.HttpClientOptions: boolean getLogActivity()>();
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder logEnabled(boolean)>(v);
v = virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder: io.vertx.core.http.impl.VertxHttp2ConnectionHandler build()>();
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$lambda_createHttp2ConnectionHandler_1__1062: io.vertx.core.Handler bootstrap$(io.vertx.core.http.HttpClientOptions,io.vertx.core.spi.metrics.ClientMetrics,boolean,io.vertx.core.spi.metrics.HttpClientMetrics)>(v, v, v, v);
virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.vertx.core.http.impl.VertxHttp2ConnectionHandler addHandler(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.http.impl.Http2ClientConnection$lambda_createHttp2ConnectionHandler_2__1063: io.vertx.core.Handler bootstrap$(io.vertx.core.spi.metrics.ClientMetrics,io.vertx.core.spi.metrics.HttpClientMetrics)>(v, v);
virtualinvoke v.<io.vertx.core.http.impl.VertxHttp2ConnectionHandler: io.vertx.core.http.impl.VertxHttp2ConnectionHandler removeHandler(io.vertx.core.Handler)>(v);
return v;
}
}