class io.vertx.core.http.impl.Http2ClientConnection extends io.vertx.core.http.impl.Http2ConnectionBase implements io.vertx.core.http.impl.HttpClientConnection
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.core.http.impl.Http2ClientConnection
super_class: io.vertx.core.http.impl.Http2ConnectionBase
{
private final io.vertx.core.http.impl.pool.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection> listener;
descriptor: Lio/vertx/core/http/impl/pool/ConnectionListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
private final io.vertx.core.http.impl.HttpClientImpl client;
descriptor: Lio/vertx/core/http/impl/HttpClientImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.metrics.HttpClientMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/HttpClientMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.Object queueMetric;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
void <init>(io.vertx.core.http.impl.pool.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection>, , io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.impl.ContextInternal, io.vertx.core.http.impl.VertxHttp2ConnectionHandler, io.vertx.core.spi.metrics.HttpClientMetrics);
descriptor: (Lio/vertx/core/http/impl/pool/ConnectionListener;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;Lio/vertx/core/spi/metrics/HttpClientMetrics;)V
flags: (0x0000)
Code:
stack=3, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 4
aload 5
invokespecial io.vertx.core.http.impl.Http2ConnectionBase.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;)V
1: aload 0
aload 6
putfield io.vertx.core.http.impl.Http2ClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
2: aload 0
aload 2
putfield io.vertx.core.http.impl.Http2ClientConnection.queueMetric:Ljava/lang/Object;
3: aload 0
aload 3
putfield io.vertx.core.http.impl.Http2ClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
4: aload 0
aload 1
putfield io.vertx.core.http.impl.Http2ClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
5: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 6 1 listener Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
0 6 2 queueMetric Ljava/lang/Object;
0 6 3 client Lio/vertx/core/http/impl/HttpClientImpl;
0 6 4 context Lio/vertx/core/impl/ContextInternal;
0 6 5 connHandler Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
0 6 6 metrics Lio/vertx/core/spi/metrics/HttpClientMetrics;
Signature: (Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;Lio/vertx/core/spi/metrics/HttpClientMetrics;)V
MethodParameters:
Name Flags
listener
queueMetric
client
context
connHandler
metrics
synchronized boolean onGoAwaySent(int, long, io.netty.buffer.ByteBuf);
descriptor: (IJLio/netty/buffer/ByteBuf;)Z
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
iload 1
lload 2
aload 4
invokespecial io.vertx.core.http.impl.Http2ConnectionBase.onGoAwaySent:(IJLio/netty/buffer/ByteBuf;)Z
istore 5
start local 5 1: iload 5
ifeq 3
2: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onEvict:()V
3: StackMap locals: int
StackMap stack:
iload 5
ireturn
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 4 1 lastStreamId I
0 4 2 errorCode J
0 4 4 debugData Lio/netty/buffer/ByteBuf;
1 4 5 goneAway Z
MethodParameters:
Name Flags
lastStreamId
errorCode
debugData
synchronized boolean onGoAwayReceived(int, long, io.netty.buffer.ByteBuf);
descriptor: (IJLio/netty/buffer/ByteBuf;)Z
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
iload 1
lload 2
aload 4
invokespecial io.vertx.core.http.impl.Http2ConnectionBase.onGoAwayReceived:(IJLio/netty/buffer/ByteBuf;)Z
istore 5
start local 5 1: iload 5
ifeq 3
2: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onEvict:()V
3: StackMap locals: int
StackMap stack:
iload 5
ireturn
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 4 1 lastStreamId I
0 4 2 errorCode J
0 4 4 debugData Lio/netty/buffer/ByteBuf;
1 4 5 goneAway Z
MethodParameters:
Name Flags
lastStreamId
errorCode
debugData
protected void concurrencyChanged(long);
descriptor: (J)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2MultiplexingLimit:()I
istore 3
start local 3 1: iload 3
ifle 3
2: lload 1
iload 3
i2l
invokestatic java.lang.Math.min:(JJ)J
lstore 1
3: StackMap locals: int
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
lload 1
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onConcurrencyChange:(J)V
4: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 5 1 concurrency J
1 5 3 limit I
MethodParameters:
Name Flags
concurrency
public io.vertx.core.spi.metrics.HttpClientMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/HttpClientMetrics;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
void onStreamClosed(io.netty.handler.codec.http2.Http2Stream);
descriptor: (Lio/netty/handler/codec/http2/Http2Stream;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http2ConnectionBase.onStreamClosed:(Lio/netty/handler/codec/http2/Http2Stream;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 2 1 nettyStream Lio/netty/handler/codec/http2/Http2Stream;
MethodParameters:
Name Flags
nettyStream
void upgradeStream(, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientStream>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.handler:Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.connection:()Lio/netty/handler/codec/http2/Http2Connection;
iconst_1
invokeinterface io.netty.handler.codec.http2.Http2Connection.stream:(I)Lio/netty/handler/codec/http2/Http2Stream;
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.createStream:(Lio/netty/handler/codec/http2/Http2Stream;)Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
astore 5
start local 5 2: aload 5
aload 1
putfield io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.metric:Ljava/lang/Object;
3: aload 5
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
astore 3
end local 5 start local 3 4: goto 7
end local 3 StackMap locals: io.vertx.core.http.impl.Http2ClientConnection java.lang.Object io.vertx.core.Handler top io.vertx.core.http.impl.Http2ClientConnection
StackMap stack: java.lang.Exception
5: astore 5
start local 5 6: aload 5
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
astore 3
end local 5 start local 3 7: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection java.lang.Object io.vertx.core.Handler io.vertx.core.Future io.vertx.core.http.impl.Http2ClientConnection
StackMap stack:
aload 4
monitorexit
8: goto 11
end local 3 StackMap locals: io.vertx.core.http.impl.Http2ClientConnection java.lang.Object io.vertx.core.Handler top io.vertx.core.http.impl.Http2ClientConnection
StackMap stack: java.lang.Throwable
9: aload 4
monitorexit
10: athrow
start local 3 11: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection java.lang.Object io.vertx.core.Handler io.vertx.core.Future
StackMap stack:
aload 2
aload 3
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
12: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 13 1 metric Ljava/lang/Object;
0 13 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;
4 5 3 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
7 9 3 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
11 13 3 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
2 4 5 stream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
6 7 5 e Ljava/lang/Exception;
Exception table:
from to target type
1 4 5 Class java.lang.Exception
1 8 9 any
9 10 9 any
Signature: (Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;)V
MethodParameters:
Name Flags
metric
completionHandler
public void createStream(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientStream>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.handler:Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.connection:()Lio/netty/handler/codec/http2/Http2Connection;
astore 4
start local 4 2: aload 4
invokeinterface io.netty.handler.codec.http2.Http2Connection.local:()Lio/netty/handler/codec/http2/Http2Connection$Endpoint;
invokeinterface io.netty.handler.codec.http2.Http2Connection$Endpoint.lastStreamCreated:()I
ifne 3
iconst_1
goto 4
StackMap locals: io.vertx.core.http.impl.Http2ClientConnection io.vertx.core.Handler top io.vertx.core.http.impl.Http2ClientConnection io.netty.handler.codec.http2.Http2Connection
StackMap stack:
3: aload 4
invokeinterface io.netty.handler.codec.http2.Http2Connection.local:()Lio/netty/handler/codec/http2/Http2Connection$Endpoint;
invokeinterface io.netty.handler.codec.http2.Http2Connection$Endpoint.lastStreamCreated:()I
iconst_2
iadd
StackMap locals:
StackMap stack: int
4: istore 5
start local 5 5: aload 0
aload 4
invokeinterface io.netty.handler.codec.http2.Http2Connection.local:()Lio/netty/handler/codec/http2/Http2Connection$Endpoint;
iload 5
iconst_0
invokeinterface io.netty.handler.codec.http2.Http2Connection$Endpoint.createStream:(IZ)Lio/netty/handler/codec/http2/Http2Stream;
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.createStream:(Lio/netty/handler/codec/http2/Http2Stream;)Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
astore 6
start local 6 6: aload 6
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
astore 2
end local 6 end local 5 start local 2 7: goto 10
end local 2 StackMap locals:
StackMap stack: java.lang.Exception
8: astore 5
start local 5 9: aload 5
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
astore 2
end local 5 end local 4 start local 2 10: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection io.vertx.core.Handler io.vertx.core.Future io.vertx.core.http.impl.Http2ClientConnection
StackMap stack:
aload 3
monitorexit
11: goto 14
end local 2 StackMap locals: io.vertx.core.http.impl.Http2ClientConnection io.vertx.core.Handler top io.vertx.core.http.impl.Http2ClientConnection
StackMap stack: java.lang.Throwable
12: aload 3
monitorexit
13: athrow
start local 2 14: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection io.vertx.core.Handler io.vertx.core.Future
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
15: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 16 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;
7 8 2 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
10 12 2 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
14 16 2 fut Lio/vertx/core/Future<Lio/vertx/core/http/impl/HttpClientStream;>;
2 10 4 conn Lio/netty/handler/codec/http2/Http2Connection;
5 7 5 id I
6 7 6 stream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
9 10 5 e Ljava/lang/Exception;
Exception table:
from to target type
2 7 8 Class java.lang.Exception
1 11 12 any
12 13 12 any
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;)V
MethodParameters:
Name Flags
completionHandler
private io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream createStream(io.netty.handler.codec.http2.Http2Stream);
descriptor: (Lio/netty/handler/codec/http2/Http2Stream;)Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.handler:Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.encoder:()Lio/netty/handler/codec/http2/Http2ConnectionEncoder;
invokeinterface io.netty.handler.codec.http2.Http2ConnectionEncoder.flowController:()Lio/netty/handler/codec/http2/Http2RemoteFlowController;
aload 1
invokeinterface io.netty.handler.codec.http2.Http2RemoteFlowController.isWritable:(Lio/netty/handler/codec/http2/Http2Stream;)Z
istore 2
start local 2 1: new io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
dup
aload 0
aload 1
iload 2
invokespecial io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.<init>:(Lio/vertx/core/http/impl/Http2ClientConnection;Lio/netty/handler/codec/http2/Http2Stream;Z)V
astore 3
start local 3 2: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
aload 3
getfield io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.stream:Lio/netty/handler/codec/http2/Http2Stream;
invokeinterface io.netty.handler.codec.http2.Http2Stream.id:()I
aload 3
invokeinterface io.netty.util.collection.IntObjectMap.put:(ILjava/lang/Object;)Ljava/lang/Object;
pop
3: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 4 1 stream Lio/netty/handler/codec/http2/Http2Stream;
1 4 2 writable Z
2 4 3 clientStream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
MethodParameters:
Name Flags
stream
private void recycle();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2KeepAliveTimeout:()I
istore 1
start local 1 1: iload 1
ifle 2
invokestatic java.lang.System.currentTimeMillis:()J
iload 1
sipush 1000
imul
i2l
ladd
goto 3
StackMap locals: int
StackMap stack:
2: lconst_0
StackMap locals:
StackMap stack: long
3: lstore 2
start local 2 4: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
lload 2
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onRecycle:(J)V
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
1 6 1 timeout I
4 6 2 expired J
public synchronized void onHeadersRead(io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers, int, short, boolean, int, boolean);
descriptor: (Lio/netty/channel/ChannelHandlerContext;ILio/netty/handler/codec/http2/Http2Headers;ISZIZ)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=11, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
iload 2
invokeinterface io.netty.util.collection.IntObjectMap.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
astore 9
start local 9 1: aload 9
ifnull 8
2: new io.vertx.core.http.StreamPriority
dup
invokespecial io.vertx.core.http.StreamPriority.<init>:()V
3: iload 4
invokevirtual io.vertx.core.http.StreamPriority.setDependency:(I)Lio/vertx/core/http/StreamPriority;
4: iload 5
invokevirtual io.vertx.core.http.StreamPriority.setWeight:(S)Lio/vertx/core/http/StreamPriority;
5: iload 6
invokevirtual io.vertx.core.http.StreamPriority.setExclusive:(Z)Lio/vertx/core/http/StreamPriority;
6: astore 10
start local 10 7: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 9
aload 3
aload 10
iload 8
invokedynamic handle(Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;Lio/vertx/core/http/StreamPriority;Z)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http2ClientConnection.lambda$0(Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;Lio/vertx/core/http/StreamPriority;ZLjava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
end local 10 8: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
StackMap stack:
return
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 9 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 9 2 streamId I
0 9 3 headers Lio/netty/handler/codec/http2/Http2Headers;
0 9 4 streamDependency I
0 9 5 weight S
0 9 6 exclusive Z
0 9 7 padding I
0 9 8 endOfStream Z
1 9 9 stream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
7 8 10 streamPriority Lio/vertx/core/http/StreamPriority;
Exceptions:
throws io.netty.handler.codec.http2.Http2Exception
MethodParameters:
Name Flags
ctx
streamId
headers
streamDependency
weight
exclusive
padding
endOfStream
public synchronized void onHeadersRead(io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers, int, boolean);
descriptor: (Lio/netty/channel/ChannelHandlerContext;ILio/netty/handler/codec/http2/Http2Headers;IZ)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=4, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
iload 2
invokeinterface io.netty.util.collection.IntObjectMap.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
astore 6
start local 6 1: aload 6
ifnull 3
2: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 6
aload 3
iload 5
invokedynamic handle(Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;Z)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http2ClientConnection.lambda$1(Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;ZLjava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
3: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
StackMap stack:
return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 4 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 4 2 streamId I
0 4 3 headers Lio/netty/handler/codec/http2/Http2Headers;
0 4 4 padding I
0 4 5 endOfStream Z
1 4 6 stream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
Exceptions:
throws io.netty.handler.codec.http2.Http2Exception
MethodParameters:
Name Flags
ctx
streamId
headers
padding
endOfStream
public synchronized void onPushPromiseRead(io.netty.channel.ChannelHandlerContext, int, int, io.netty.handler.codec.http2.Http2Headers, int);
descriptor: (Lio/netty/channel/ChannelHandlerContext;IILio/netty/handler/codec/http2/Http2Headers;I)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
iload 2
invokeinterface io.netty.util.collection.IntObjectMap.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
astore 6
start local 6 1: aload 6
ifnull 6
2: aload 6
invokevirtual io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.pushHandler:()Lio/vertx/core/Handler;
astore 7
start local 7 3: aload 7
ifnull 6
4: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 0
aload 4
iload 3
aload 7
invokedynamic handle(Lio/vertx/core/http/impl/Http2ClientConnection;Lio/netty/handler/codec/http2/Http2Headers;ILio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http2ClientConnection.lambda$2(Lio/netty/handler/codec/http2/Http2Headers;ILio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Lio/vertx/core/Handler;)V
5: return
end local 7 6: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.handler:Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
iload 3
getstatic io.netty.handler.codec.http2.Http2Error.CANCEL:Lio/netty/handler/codec/http2/Http2Error;
invokevirtual io.netty.handler.codec.http2.Http2Error.code:()J
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.writeReset:(IJ)V
7: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 8 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 8 2 streamId I
0 8 3 promisedStreamId I
0 8 4 headers Lio/netty/handler/codec/http2/Http2Headers;
0 8 5 padding I
1 8 6 stream Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
3 6 7 pushHandler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpClientRequest;>;
Exceptions:
throws io.netty.handler.codec.http2.Http2Exception
MethodParameters:
Name Flags
ctx
streamId
promisedStreamId
headers
padding
protected void handleIdle();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
dup
astore 1
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
invokeinterface io.netty.util.collection.IntObjectMap.isEmpty:()Z
ifeq 4
2: aload 1
monitorexit
3: return
4: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection
StackMap stack:
aload 1
monitorexit
5: goto 8
StackMap locals:
StackMap stack: java.lang.Throwable
6: aload 1
monitorexit
7: athrow
8: StackMap locals:
StackMap stack:
aload 0
invokespecial io.vertx.core.http.impl.Http2ConnectionBase.handleIdle:()V
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
Exception table:
from to target type
1 3 6 any
4 5 6 any
6 7 6 any
public static io.vertx.core.http.impl.VertxHttp2ConnectionHandler<io.vertx.core.http.impl.Http2ClientConnection> createHttp2ConnectionHandler(io.vertx.core.http.impl.HttpClientImpl, , io.vertx.core.http.impl.pool.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection>, io.vertx.core.impl.ContextInternal, , java.util.function.BiConsumer<io.vertx.core.http.impl.Http2ClientConnection, java.lang.Long>);
descriptor: (Lio/vertx/core/http/impl/HttpClientImpl;Ljava/lang/Object;Lio/vertx/core/http/impl/pool/ConnectionListener;Lio/vertx/core/impl/ContextInternal;Ljava/lang/Object;Ljava/util/function/BiConsumer;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2MultiplexingLimit:()I
ifgt 1
ldc 9223372036854775807
goto 2
StackMap locals:
StackMap stack:
1: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2MultiplexingLimit:()I
i2l
StackMap locals:
StackMap stack: long
2: lstore 6
start local 6 3: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
astore 8
start local 8 4: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
astore 9
start local 9 5: new io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder
dup
invokespecial io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.<init>:()V
6: iconst_0
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.server:(Z)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandlerBuilder;
7: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isTryUseCompression:()Z
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.useCompression:(Z)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandlerBuilder;
8: aload 0
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getInitialSettings:()Lio/vertx/core/http/Http2Settings;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.initialSettings:(Lio/vertx/core/http/Http2Settings;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandlerBuilder;
9: aload 2
aload 1
aload 0
aload 3
aload 9
invokedynamic apply(Lio/vertx/core/http/impl/pool/ConnectionListener;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/HttpClientMetrics;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/http/impl/Http2ClientConnection.lambda$3(Lio/vertx/core/http/impl/pool/ConnectionListener;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/HttpClientMetrics;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;)Lio/vertx/core/http/impl/Http2ClientConnection; (6)
(Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;)Lio/vertx/core/http/impl/Http2ClientConnection;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.connectionFactory:(Ljava/util/function/Function;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandlerBuilder;
10: aload 8
invokevirtual io.vertx.core.http.HttpClientOptions.getLogActivity:()Z
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.logEnabled:(Z)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandlerBuilder;
11: invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandlerBuilder.build:()Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
12: astore 10
start local 10 13: aload 10
aload 8
aload 9
aload 4
aload 1
lload 6
aload 5
invokedynamic handle(Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Ljava/lang/Object;JLjava/util/function/BiConsumer;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http2ClientConnection.lambda$4(Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Ljava/lang/Object;JLjava/util/function/BiConsumer;Lio/vertx/core/http/impl/Http2ClientConnection;)V (6)
(Lio/vertx/core/http/impl/Http2ClientConnection;)V
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.addHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
pop
14: aload 10
aload 9
aload 1
aload 2
invokedynamic handle(Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Lio/vertx/core/http/impl/pool/ConnectionListener;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http2ClientConnection.lambda$5(Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Lio/vertx/core/http/impl/pool/ConnectionListener;Lio/vertx/core/http/impl/Http2ClientConnection;)V (6)
(Lio/vertx/core/http/impl/Http2ClientConnection;)V
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.removeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
pop
15: aload 10
areturn
end local 10 end local 9 end local 8 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 client Lio/vertx/core/http/impl/HttpClientImpl;
0 16 1 queueMetric Ljava/lang/Object;
0 16 2 listener Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
0 16 3 context Lio/vertx/core/impl/ContextInternal;
0 16 4 socketMetric Ljava/lang/Object;
0 16 5 c Ljava/util/function/BiConsumer<Lio/vertx/core/http/impl/Http2ClientConnection;Ljava/lang/Long;>;
3 16 6 http2MaxConcurrency J
4 16 8 options Lio/vertx/core/http/HttpClientOptions;
5 16 9 metrics Lio/vertx/core/spi/metrics/HttpClientMetrics;
13 16 10 handler Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler<Lio/vertx/core/http/impl/Http2ClientConnection;>;
Signature: (Lio/vertx/core/http/impl/HttpClientImpl;Ljava/lang/Object;Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;Lio/vertx/core/impl/ContextInternal;Ljava/lang/Object;Ljava/util/function/BiConsumer<Lio/vertx/core/http/impl/Http2ClientConnection;Ljava/lang/Long;>;)Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler<Lio/vertx/core/http/impl/Http2ClientConnection;>;
MethodParameters:
Name Flags
client
queueMetric
listener
context
socketMetric
c
public io.vertx.core.spi.metrics.NetworkMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/NetworkMetrics;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream, io.netty.handler.codec.http2.Http2Headers, io.vertx.core.http.StreamPriority, boolean, java.lang.Void);
descriptor: (Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;Lio/vertx/core/http/StreamPriority;ZLjava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=5
start local 4 0: aload 0
aload 1
aload 2
iload 3
invokevirtual io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.handleHeaders:(Lio/netty/handler/codec/http2/Http2Headers;Lio/vertx/core/http/StreamPriority;Z)V
1: return
end local 4 LocalVariableTable:
Start End Slot Name Signature
0 2 4 v Ljava/lang/Void;
private static void lambda$1(io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream, io.netty.handler.codec.http2.Http2Headers, boolean, java.lang.Void);
descriptor: (Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;Lio/netty/handler/codec/http2/Http2Headers;ZLjava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 3 0: aload 0
aload 1
aconst_null
iload 2
invokevirtual io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.handleHeaders:(Lio/netty/handler/codec/http2/Http2Headers;Lio/vertx/core/http/StreamPriority;Z)V
1: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 2 3 v Ljava/lang/Void;
private void lambda$2(io.netty.handler.codec.http2.Http2Headers, int, io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/netty/handler/codec/http2/Http2Headers;ILio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=12, locals=15, args_size=5
start local 0 start local 4 0: aload 1
invokeinterface io.netty.handler.codec.http2.Http2Headers.method:()Ljava/lang/CharSequence;
invokeinterface java.lang.CharSequence.toString:()Ljava/lang/String;
astore 5
start local 5 1: aload 5
invokestatic io.vertx.core.http.impl.HttpUtils.toVertxMethod:(Ljava/lang/String;)Lio/vertx/core/http/HttpMethod;
astore 6
start local 6 2: aload 1
invokeinterface io.netty.handler.codec.http2.Http2Headers.path:()Ljava/lang/CharSequence;
invokeinterface java.lang.CharSequence.toString:()Ljava/lang/String;
astore 7
start local 7 3: aload 1
invokeinterface io.netty.handler.codec.http2.Http2Headers.authority:()Ljava/lang/CharSequence;
ifnull 4
aload 1
invokeinterface io.netty.handler.codec.http2.Http2Headers.authority:()Ljava/lang/CharSequence;
invokeinterface java.lang.CharSequence.toString:()Ljava/lang/String;
goto 5
StackMap locals: java.lang.String io.vertx.core.http.HttpMethod java.lang.String
StackMap stack:
4: aconst_null
StackMap locals:
StackMap stack: java.lang.String
5: astore 8
start local 8 6: new io.vertx.core.http.impl.Http2HeadersAdaptor
dup
aload 1
invokespecial io.vertx.core.http.impl.Http2HeadersAdaptor.<init>:(Lio/netty/handler/codec/http2/Http2Headers;)V
astore 9
start local 9 7: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.handler:Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;
invokevirtual io.vertx.core.http.impl.VertxHttp2ConnectionHandler.connection:()Lio/netty/handler/codec/http2/Http2Connection;
iload 2
invokeinterface io.netty.handler.codec.http2.Http2Connection.stream:(I)Lio/netty/handler/codec/http2/Http2Stream;
astore 10
start local 10 8: aload 8
bipush 58
invokevirtual java.lang.String.indexOf:(I)I
istore 11
start local 11 9: iload 11
iconst_m1
if_icmpne 13
10: aload 8
astore 13
start local 13 11: bipush 80
istore 12
start local 12 12: goto 15
end local 13 end local 12 13: StackMap locals: io.vertx.core.http.impl.Http2ClientConnection io.netty.handler.codec.http2.Http2Headers int io.vertx.core.Handler java.lang.Void java.lang.String io.vertx.core.http.HttpMethod java.lang.String java.lang.String io.vertx.core.MultiMap io.netty.handler.codec.http2.Http2Stream int
StackMap stack:
aload 8
iconst_0
iload 11
invokevirtual java.lang.String.substring:(II)Ljava/lang/String;
astore 13
start local 13 14: aload 8
iload 11
iconst_1
iadd
invokevirtual java.lang.String.substring:(I)Ljava/lang/String;
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
istore 12
start local 12 15: StackMap locals: int java.lang.String
StackMap stack:
new io.vertx.core.http.impl.HttpClientRequestPushPromise
dup
aload 0
aload 10
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
aload 0
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.isSsl:()Z
aload 6
aload 5
aload 7
aload 13
iload 12
aload 9
invokespecial io.vertx.core.http.impl.HttpClientRequestPushPromise.<init>:(Lio/vertx/core/http/impl/Http2ClientConnection;Lio/netty/handler/codec/http2/Http2Stream;Lio/vertx/core/http/impl/HttpClientImpl;ZLio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILio/vertx/core/MultiMap;)V
astore 14
start local 14 16: aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
ifnull 18
17: aload 14
invokevirtual io.vertx.core.http.impl.HttpClientRequestPushPromise.getStream:()Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.queueMetric:Ljava/lang/Object;
aload 0
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.metric:()Ljava/lang/Object;
aload 0
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.localAddress:()Lio/vertx/core/net/SocketAddress;
aload 0
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.remoteAddress:()Lio/vertx/core/net/SocketAddress;
aload 14
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.responsePushed:(Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/http/HttpClientRequest;)Ljava/lang/Object;
putfield io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream.metric:Ljava/lang/Object;
18: StackMap locals: io.vertx.core.http.impl.HttpClientRequestPushPromise
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http2ClientConnection.streams:Lio/netty/util/collection/IntObjectMap;
iload 2
aload 14
invokevirtual io.vertx.core.http.impl.HttpClientRequestPushPromise.getStream:()Lio/vertx/core/http/impl/Http2ClientConnection$Http2ClientStream;
invokeinterface io.netty.util.collection.IntObjectMap.put:(ILjava/lang/Object;)Ljava/lang/Object;
pop
19: aload 3
aload 14
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 20: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/vertx/core/http/impl/Http2ClientConnection;
0 21 4 v Ljava/lang/Void;
1 20 5 rawMethod Ljava/lang/String;
2 20 6 method Lio/vertx/core/http/HttpMethod;
3 20 7 uri Ljava/lang/String;
6 20 8 authority Ljava/lang/String;
7 20 9 headersMap Lio/vertx/core/MultiMap;
8 20 10 promisedStream Lio/netty/handler/codec/http2/Http2Stream;
9 20 11 pos I
12 13 12 port I
15 20 12 port I
11 13 13 host Ljava/lang/String;
14 20 13 host Ljava/lang/String;
16 20 14 pushReq Lio/vertx/core/http/impl/HttpClientRequestPushPromise;
private static io.vertx.core.http.impl.Http2ClientConnection lambda$3(io.vertx.core.http.impl.pool.ConnectionListener, java.lang.Object, io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.metrics.HttpClientMetrics, io.vertx.core.http.impl.VertxHttp2ConnectionHandler);
descriptor: (Lio/vertx/core/http/impl/pool/ConnectionListener;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/HttpClientMetrics;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;)Lio/vertx/core/http/impl/Http2ClientConnection;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=8, locals=6, args_size=6
start local 5 0: new io.vertx.core.http.impl.Http2ClientConnection
dup
aload 0
aload 1
aload 2
aload 3
aload 5
aload 4
invokespecial io.vertx.core.http.impl.Http2ClientConnection.<init>:(Lio/vertx/core/http/impl/pool/ConnectionListener;Ljava/lang/Object;Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler;Lio/vertx/core/spi/metrics/HttpClientMetrics;)V
areturn
end local 5 LocalVariableTable:
Start End Slot Name Signature
0 1 5 connHandler Lio/vertx/core/http/impl/VertxHttp2ConnectionHandler<Lio/vertx/core/http/impl/Http2ClientConnection;>;
private static void lambda$4(io.vertx.core.http.HttpClientOptions, io.vertx.core.spi.metrics.HttpClientMetrics, java.lang.Object, java.lang.Object, long, java.util.function.BiConsumer, io.vertx.core.http.impl.Http2ClientConnection);
descriptor: (Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Ljava/lang/Object;JLjava/util/function/BiConsumer;Lio/vertx/core/http/impl/Http2ClientConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=10, args_size=7
start local 7 0: aload 0
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2ConnectionWindowSize:()I
ifle 2
1: aload 7
aload 0
invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2ConnectionWindowSize:()I
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.setWindowSize:(I)Lio/vertx/core/http/HttpConnection;
pop
2: StackMap locals:
StackMap stack:
aload 1
ifnull 8
3: aload 2
astore 8
start local 8 4: aload 8
ifnonnull 7
5: aload 1
aload 7
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.remoteAddress:()Lio/vertx/core/net/SocketAddress;
aload 7
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.remoteName:()Ljava/lang/String;
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.connected:(Lio/vertx/core/net/SocketAddress;Ljava/lang/String;)Ljava/lang/Object;
astore 8
6: aload 1
aload 3
aload 8
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.endpointConnected:(Ljava/lang/Object;Ljava/lang/Object;)V
7: StackMap locals: java.lang.Object
StackMap stack:
aload 7
aload 8
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.metric:(Ljava/lang/Object;)V
end local 8 8: StackMap locals:
StackMap stack:
aload 7
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.remoteSettings:()Lio/vertx/core/http/Http2Settings;
invokevirtual io.vertx.core.http.Http2Settings.getMaxConcurrentStreams:()J
lstore 8
start local 8 9: lload 4
lconst_0
lcmp
ifle 11
10: lload 8
lload 4
invokestatic java.lang.Math.min:(JJ)J
lstore 8
11: StackMap locals: long
StackMap stack:
aload 6
aload 7
lload 8
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
end local 8 12: return
end local 7 LocalVariableTable:
Start End Slot Name Signature
0 13 7 conn Lio/vertx/core/http/impl/Http2ClientConnection;
4 8 8 m Ljava/lang/Object;
9 12 8 concurrency J
private static void lambda$5(io.vertx.core.spi.metrics.HttpClientMetrics, java.lang.Object, io.vertx.core.http.impl.pool.ConnectionListener, io.vertx.core.http.impl.Http2ClientConnection);
descriptor: (Lio/vertx/core/spi/metrics/HttpClientMetrics;Ljava/lang/Object;Lio/vertx/core/http/impl/pool/ConnectionListener;Lio/vertx/core/http/impl/Http2ClientConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 3 0: aload 0
ifnull 2
1: aload 0
aload 1
aload 3
invokevirtual io.vertx.core.http.impl.Http2ClientConnection.metric:()Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.endpointDisconnected:(Ljava/lang/Object;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onEvict:()V
3: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 4 3 conn Lio/vertx/core/http/impl/Http2ClientConnection;
}
SourceFile: "Http2ClientConnection.java"
NestMembers:
io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream
InnerClasses:
public abstract Endpoint = io.netty.handler.codec.http2.Http2Connection$Endpoint of io.netty.handler.codec.http2.Http2Connection
Http2ClientStream = io.vertx.core.http.impl.Http2ClientConnection$Http2ClientStream of io.vertx.core.http.impl.Http2ClientConnection
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles