public class io.vertx.core.http.impl.Http1xClientConnection extends io.vertx.core.http.impl.Http1xConnectionBase<io.vertx.core.http.impl.WebSocketImpl> implements io.vertx.core.http.impl.HttpClientConnection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.http.impl.Http1xClientConnection
super_class: io.vertx.core.http.impl.Http1xConnectionBase
{
private static final io.vertx.core.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.vertx.core.Handler<java.lang.Object> INVALID_MSG_HANDLER;
descriptor: Lio/vertx/core/Handler;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;
private final io.vertx.core.net.impl.clientconnection.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection> listener;
descriptor: Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/net/impl/clientconnection/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.http.HttpClientOptions options;
descriptor: Lio/vertx/core/http/HttpClientOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean ssl;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.SocketAddress server;
descriptor: Lio/vertx/core/net/SocketAddress;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public final io.vertx.core.spi.metrics.ClientMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/ClientMetrics;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final io.vertx.core.http.HttpVersion version;
descriptor: Lio/vertx/core/http/HttpVersion;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.util.Deque<io.vertx.core.http.impl.Http1xClientConnection$Stream> requests;
descriptor: Ljava/util/Deque;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Deque<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
private java.util.Deque<io.vertx.core.http.impl.Http1xClientConnection$Stream> responses;
descriptor: Ljava/util/Deque;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Deque<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
private boolean closed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean shutdown;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private long shutdownTimerID;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<java.lang.Object> invalidMessageHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;
private boolean close;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean isConnect;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int keepAliveTimeout;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private long expirationTimestamp;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private int seq;
descriptor: I
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/core/http/impl/Http1xClientConnection;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.core.http.impl.Http1xClientConnection.log:Lio/vertx/core/impl/logging/Logger;
1: invokedynamic handle()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/Http1xClientConnection.lambda$0(Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
putstatic io.vertx.core.http.impl.Http1xClientConnection.INVALID_MSG_HANDLER:Lio/vertx/core/Handler;
2: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.net.impl.clientconnection.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection>, io.vertx.core.http.HttpVersion, io.vertx.core.http.impl.HttpClientImpl, io.netty.channel.ChannelHandlerContext, boolean, io.vertx.core.net.SocketAddress, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.metrics.ClientMetrics);
descriptor: (Lio/vertx/core/net/impl/clientconnection/ConnectionListener;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientImpl;Lio/netty/channel/ChannelHandlerContext;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/ClientMetrics;)V
flags: (0x0000)
Code:
stack=3, locals=9, 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
aload 7
aload 4
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;)V
1: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
2: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
3: aload 0
ldc -1
putfield io.vertx.core.http.impl.Http1xClientConnection.shutdownTimerID:J
4: aload 0
getstatic io.vertx.core.http.impl.Http1xClientConnection.INVALID_MSG_HANDLER:Lio/vertx/core/Handler;
putfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
5: aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.seq:I
6: aload 0
aload 1
putfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
7: aload 0
aload 3
putfield io.vertx.core.http.impl.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
8: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
putfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
9: aload 0
iload 5
putfield io.vertx.core.http.impl.Http1xClientConnection.ssl:Z
10: aload 0
aload 6
putfield io.vertx.core.http.impl.Http1xClientConnection.server:Lio/vertx/core/net/SocketAddress;
11: aload 0
aload 8
putfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
12: aload 0
aload 2
putfield io.vertx.core.http.impl.Http1xClientConnection.version:Lio/vertx/core/http/HttpVersion;
13: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getKeepAliveTimeout:()I
putfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
14: return
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 15 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 15 1 listener Lio/vertx/core/net/impl/clientconnection/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
0 15 2 version Lio/vertx/core/http/HttpVersion;
0 15 3 client Lio/vertx/core/http/impl/HttpClientImpl;
0 15 4 channel Lio/netty/channel/ChannelHandlerContext;
0 15 5 ssl Z
0 15 6 server Lio/vertx/core/net/SocketAddress;
0 15 7 context Lio/vertx/core/impl/ContextInternal;
0 15 8 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
Signature: (Lio/vertx/core/net/impl/clientconnection/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientImpl;Lio/netty/channel/ChannelHandlerContext;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/ClientMetrics;)V
MethodParameters:
Name Flags
listener
version
client
channel
ssl
server
context
metrics
io.vertx.core.net.impl.clientconnection.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection> listener();
descriptor: ()Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
Signature: ()Lio/vertx/core/net/impl/clientconnection/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
public io.vertx.core.net.impl.NetSocketInternal toNetSocket();
descriptor: ()Lio/vertx/core/net/impl/NetSocketInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.removeChannelHandlers:()Ljava/util/List;
pop
1: new io.vertx.core.net.impl.NetSocketImpl
dup
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getSslHelper:()Lio/vertx/core/net/impl/SSLHelper;
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
invokespecial io.vertx.core.net.impl.NetSocketImpl.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
astore 1
start local 1 2: aload 1
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.metric:()Ljava/lang/Object;
invokevirtual io.vertx.core.net.impl.NetSocketImpl.metric:(Ljava/lang/Object;)V
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
invokeinterface io.vertx.core.net.impl.clientconnection.ConnectionListener.onEvict:()V
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "handler"
ldc "handler"
aload 1
invokedynamic apply(Lio/vertx/core/net/impl/NetSocketImpl;)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/Http1xClientConnection.lambda$1(Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/net/impl/NetSocketImpl; (6)
(Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/net/impl/NetSocketImpl;
invokestatic io.vertx.core.net.impl.VertxHandler.create:(Ljava/util/function/Function;)Lio/vertx/core/net/impl/VertxHandler;
invokeinterface io.netty.channel.ChannelPipeline.replace:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelHandler;
pop
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
2 6 1 socket Lio/vertx/core/net/impl/NetSocketImpl;
private io.netty.handler.codec.http.HttpRequest createRequest(io.vertx.core.http.HttpMethod, java.lang.String, io.vertx.core.MultiMap, java.lang.String, boolean, io.netty.buffer.ByteBuf, boolean);
descriptor: (Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;ZLio/netty/buffer/ByteBuf;Z)Lio/netty/handler/codec/http/HttpRequest;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=12, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: new io.netty.handler.codec.http.DefaultHttpRequest
dup
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.version:Lio/vertx/core/http/HttpVersion;
invokestatic io.vertx.core.http.impl.HttpUtils.toNettyHttpVersion:(Lio/vertx/core/http/HttpVersion;)Lio/netty/handler/codec/http/HttpVersion;
aload 1
invokevirtual io.vertx.core.http.HttpMethod.toNetty:()Lio/netty/handler/codec/http/HttpMethod;
aload 2
iconst_0
invokespecial io.netty.handler.codec.http.DefaultHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpMethod;Ljava/lang/String;Z)V
astore 8
start local 8 1: aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
astore 9
start local 9 2: aload 3
ifnull 7
3: aload 3
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 11
goto 6
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.HttpMethod java.lang.String io.vertx.core.MultiMap java.lang.String int io.netty.buffer.ByteBuf int io.netty.handler.codec.http.HttpRequest io.netty.handler.codec.http.HttpHeaders top java.util.Iterator
StackMap stack:
4: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 10
start local 10 5: aload 9
aload 10
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 10
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual io.netty.handler.codec.http.HttpHeaders.add:(Ljava/lang/String;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
end local 10 6: StackMap locals:
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.HttpMethod java.lang.String io.vertx.core.MultiMap java.lang.String int io.netty.buffer.ByteBuf int io.netty.handler.codec.http.HttpRequest io.netty.handler.codec.http.HttpHeaders
StackMap stack:
aload 9
getstatic io.vertx.core.http.HttpHeaders.HOST:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.contains:(Ljava/lang/CharSequence;)Z
ifne 10
8: aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.HOST:Ljava/lang/CharSequence;
aload 4
invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
9: goto 11
10: StackMap locals:
StackMap stack:
aload 9
getstatic io.vertx.core.http.HttpHeaders.TRANSFER_ENCODING:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.remove:(Ljava/lang/CharSequence;)Lio/netty/handler/codec/http/HttpHeaders;
pop
11: StackMap locals:
StackMap stack:
iload 5
ifeq 13
12: aload 8
iconst_1
invokestatic io.netty.handler.codec.http.HttpUtil.setTransferEncodingChunked:(Lio/netty/handler/codec/http/HttpMessage;Z)V
13: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isTryUseCompression:()Z
ifeq 15
aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.ACCEPT_ENCODING:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
ifnonnull 15
14: aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.ACCEPT_ENCODING:Ljava/lang/CharSequence;
getstatic io.vertx.core.http.HttpHeaders.DEFLATE_GZIP:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
15: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
ifne 18
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getProtocolVersion:()Lio/vertx/core/http/HttpVersion;
getstatic io.vertx.core.http.HttpVersion.HTTP_1_1:Lio/vertx/core/http/HttpVersion;
if_acmpne 18
16: aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.CONNECTION:Ljava/lang/CharSequence;
getstatic io.vertx.core.http.HttpHeaders.CLOSE:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
17: goto 20
StackMap locals:
StackMap stack:
18: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
ifeq 20
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getProtocolVersion:()Lio/vertx/core/http/HttpVersion;
getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
if_acmpne 20
19: aload 8
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.vertx.core.http.HttpHeaders.CONNECTION:Ljava/lang/CharSequence;
getstatic io.vertx.core.http.HttpHeaders.KEEP_ALIVE:Ljava/lang/CharSequence;
invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
20: StackMap locals:
StackMap stack:
iload 7
ifeq 26
21: aload 6
ifnull 24
22: new io.vertx.core.http.impl.AssembledFullHttpRequest
dup
aload 8
aload 6
invokespecial io.vertx.core.http.impl.AssembledFullHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;)V
astore 8
23: goto 28
24: StackMap locals:
StackMap stack:
new io.vertx.core.http.impl.AssembledFullHttpRequest
dup
aload 8
invokespecial io.vertx.core.http.impl.AssembledFullHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;)V
astore 8
25: goto 28
StackMap locals:
StackMap stack:
26: aload 6
ifnull 28
27: new io.vertx.core.http.impl.AssembledHttpRequest
dup
aload 8
aload 6
invokespecial io.vertx.core.http.impl.AssembledHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;)V
astore 8
28: StackMap locals:
StackMap stack:
aload 8
areturn
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 29 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 29 1 method Lio/vertx/core/http/HttpMethod;
0 29 2 uri Ljava/lang/String;
0 29 3 headerMap Lio/vertx/core/MultiMap;
0 29 4 authority Ljava/lang/String;
0 29 5 chunked Z
0 29 6 buf Lio/netty/buffer/ByteBuf;
0 29 7 end Z
1 29 8 request Lio/netty/handler/codec/http/HttpRequest;
2 29 9 headers Lio/netty/handler/codec/http/HttpHeaders;
5 6 10 header Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
method
uri
headerMap
authority
chunked
buf
end
private void beginRequest(io.vertx.core.http.impl.Http1xClientConnection$Stream, io.vertx.core.http.impl.HttpRequestHead, boolean, io.netty.buffer.ByteBuf, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=13, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 2
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.id:I
putfield io.vertx.core.http.impl.HttpRequestHead.id:I
1: aload 2
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.remoteAddress:()Lio/vertx/core/net/SocketAddress;
putfield io.vertx.core.http.impl.HttpRequestHead.remoteAddress:Lio/vertx/core/net/SocketAddress;
2: aload 1
dup
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesWritten:J
aload 4
ifnull 3
aload 4
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
goto 4
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int io.vertx.core.Handler
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$Stream long
3: lconst_0
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int io.vertx.core.Handler
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$Stream long long
4: ladd
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesWritten:J
5: aload 0
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.uri:Ljava/lang/String;
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.headers:Lio/vertx/core/MultiMap;
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.authority:Ljava/lang/String;
iload 3
aload 4
iload 5
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.createRequest:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;ZLio/netty/buffer/ByteBuf;Z)Lio/netty/handler/codec/http/HttpRequest;
astore 8
start local 8 6: aload 0
dup
astore 9
monitorenter
7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
pop
8: aload 0
iload 6
putfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
9: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 11
10: aload 1
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.uri:Ljava/lang/String;
aload 2
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.metric:Ljava/lang/Object;
11: StackMap locals: io.netty.handler.codec.http.HttpRequest io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.tracer:()Lio/vertx/core/spi/tracing/VertxTracer;
astore 10
start local 10 12: aload 10
ifnull 18
13: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 11
start local 11 14: aload 11
new java.util.AbstractMap$SimpleEntry
dup
ldc "http.url"
ldc "todo"
invokespecial java.util.AbstractMap$SimpleEntry.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: aload 11
new java.util.AbstractMap$SimpleEntry
dup
ldc "http.method"
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
invokevirtual io.vertx.core.http.HttpMethod.name:()Ljava/lang/String;
invokespecial java.util.AbstractMap$SimpleEntry.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
16: aload 8
invokedynamic accept(Lio/netty/handler/codec/http/HttpRequest;)Ljava/util/function/BiConsumer;
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;)V
io/vertx/core/http/impl/Http1xClientConnection.lambda$2(Lio/netty/handler/codec/http/HttpRequest;Ljava/lang/String;Ljava/lang/String;)V (6)
(Ljava/lang/String;Ljava/lang/String;)V
astore 12
start local 12 17: aload 1
aload 10
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
getstatic io.vertx.core.spi.tracing.SpanKind.RPC:Lio/vertx/core/spi/tracing/SpanKind;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getTracingPolicy:()Lio/vertx/core/tracing/TracingPolicy;
aload 2
aload 2
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
invokevirtual io.vertx.core.http.HttpMethod.name:()Ljava/lang/String;
aload 12
getstatic io.vertx.core.http.impl.HttpUtils.CLIENT_HTTP_REQUEST_TAG_EXTRACTOR:Lio/vertx/core/spi/tracing/TagExtractor;
invokeinterface io.vertx.core.spi.tracing.VertxTracer.sendRequest:(Lio/vertx/core/Context;Lio/vertx/core/spi/tracing/SpanKind;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/Object;Ljava/lang/String;Ljava/util/function/BiConsumer;Lio/vertx/core/spi/tracing/TagExtractor;)Ljava/lang/Object;
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.trace:Ljava/lang/Object;
end local 12 end local 11 end local 10 18: StackMap locals:
StackMap stack:
aload 9
monitorexit
19: goto 22
StackMap locals:
StackMap stack: java.lang.Throwable
20: aload 9
monitorexit
21: athrow
22: StackMap locals:
StackMap stack:
aload 0
aload 8
aload 7
ifnonnull 23
aconst_null
goto 24
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int io.vertx.core.Handler io.netty.handler.codec.http.HttpRequest
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpRequest
23: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 7
invokeinterface io.vertx.core.impl.ContextInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int io.vertx.core.Handler io.netty.handler.codec.http.HttpRequest
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpRequest io.vertx.core.impl.future.PromiseInternal
24: invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/util/concurrent/FutureListener;)V
25: iload 5
ifeq 27
26: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.endRequest:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
27: StackMap locals:
StackMap stack:
return
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 28 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 28 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
0 28 2 request Lio/vertx/core/http/impl/HttpRequestHead;
0 28 3 chunked Z
0 28 4 buf Lio/netty/buffer/ByteBuf;
0 28 5 end Z
0 28 6 connect Z
0 28 7 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
6 28 8 nettyRequest Lio/netty/handler/codec/http/HttpRequest;
12 18 10 tracer Lio/vertx/core/spi/tracing/VertxTracer;
14 18 11 tags Ljava/util/List<Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;>;
17 18 12 headers Ljava/util/function/BiConsumer<Ljava/lang/String;Ljava/lang/String;>;
Exception table:
from to target type
7 19 20 any
20 21 20 any
Signature: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
stream
request
chunked
buf
end
connect
handler
private void writeBuffer(io.vertx.core.http.impl.Http1xClientConnection$Stream, io.netty.buffer.ByteBuf, boolean, io.netty.util.concurrent.FutureListener<java.lang.Void>);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
dup
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesWritten:J
aload 2
ifnull 1
aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
goto 2
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.buffer.ByteBuf int io.netty.util.concurrent.FutureListener
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$Stream long
1: lconst_0
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.buffer.ByteBuf int io.netty.util.concurrent.FutureListener
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$Stream long long
2: ladd
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesWritten:J
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
ifeq 15
4: aload 2
ifnull 5
aload 2
goto 6
StackMap locals:
StackMap stack:
5: getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
StackMap locals:
StackMap stack: io.netty.buffer.ByteBuf
6: astore 5
start local 5 7: iload 3
ifeq 13
8: aload 0
aload 5
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.channelFuture:()Lio/netty/channel/ChannelPromise;
9: aload 4
invokeinterface io.netty.channel.ChannelPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelPromise;
10: aload 0
invokedynamic operationComplete(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/netty/util/concurrent/GenericFutureListener;
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:
(Lio/netty/util/concurrent/Future;)V
io/vertx/core/http/impl/Http1xClientConnection.lambda$3(Lio/netty/util/concurrent/Future;)V (7)
(Lio/netty/util/concurrent/Future;)V
invokeinterface io.netty.channel.ChannelPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelPromise;
11: invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
12: goto 25
13: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;)V
14: goto 25
end local 5 15: StackMap locals:
StackMap stack:
iload 3
ifeq 21
16: aload 2
ifnull 19
aload 2
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 19
17: new io.netty.handler.codec.http.DefaultLastHttpContent
dup
aload 2
iconst_0
invokespecial io.netty.handler.codec.http.DefaultLastHttpContent.<init>:(Lio/netty/buffer/ByteBuf;Z)V
astore 5
start local 5 18: goto 22
end local 5 19: StackMap locals:
StackMap stack:
getstatic io.netty.handler.codec.http.LastHttpContent.EMPTY_LAST_CONTENT:Lio/netty/handler/codec/http/LastHttpContent;
astore 5
start local 5 20: goto 22
end local 5 21: StackMap locals:
StackMap stack:
new io.netty.handler.codec.http.DefaultHttpContent
dup
aload 2
invokespecial io.netty.handler.codec.http.DefaultHttpContent.<init>:(Lio/netty/buffer/ByteBuf;)V
astore 5
start local 5 22: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
aload 4
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/util/concurrent/FutureListener;)V
23: iload 3
ifeq 25
24: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.endRequest:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
25: StackMap locals:
StackMap stack:
return
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 26 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 26 1 s Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
0 26 2 buff Lio/netty/buffer/ByteBuf;
0 26 3 end Z
0 26 4 listener Lio/netty/util/concurrent/FutureListener<Ljava/lang/Void;>;
7 15 5 msg Ljava/lang/Object;
18 19 5 msg Ljava/lang/Object;
20 21 5 msg Ljava/lang/Object;
22 26 5 msg Ljava/lang/Object;
Signature: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
s
buff
end
listener
private void endRequest(io.vertx.core.http.impl.Http1xClientConnection$Stream);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.pop:()Ljava/lang/Object;
pop
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 2
start local 2 3: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.responseEnded:Z
istore 3
start local 3 4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 6
5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.metric:Ljava/lang/Object;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesWritten:J
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;J)V
6: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$Stream int io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 4
monitorexit
7: goto 10
end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream top top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
8: aload 4
monitorexit
9: athrow
start local 2 start local 3 10: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.Http1xClientConnection$Stream int
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.flushBytesWritten:()V
11: aload 2
ifnull 13
12: aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.promise:Lio/vertx/core/Promise;
aload 2
checkcast io.vertx.core.http.impl.HttpClientStream
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
13: StackMap locals:
StackMap stack:
iload 3
ifeq 15
14: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.recycle:()V
15: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 16 1 s Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
3 8 2 next Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
10 16 2 next Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
4 8 3 recycle Z
10 16 3 recycle Z
Exception table:
from to target type
1 7 8 any
8 9 8 any
MethodParameters:
Name Flags
s
private void resetRequest(io.vertx.core.http.impl.Http1xClientConnection$Stream);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, 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.Http1xClientConnection.responses:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.remove:(Ljava/lang/Object;)Z
ifeq 4
2: iconst_1
istore 2
start local 2 3: goto 9
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.remove:(Ljava/lang/Object;)Z
ifeq 7
5: iconst_0
istore 2
start local 2 6: goto 9
end local 2 7: StackMap locals:
StackMap stack:
aload 3
monitorexit
8: return
start local 2 9: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream int io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 3
monitorexit
10: goto 13
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
11: aload 3
monitorexit
12: athrow
start local 2 13: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream int
StackMap stack:
iload 2
ifeq 16
14: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
pop
15: goto 17
16: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.recycle:()V
17: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 18 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
3 4 2 close Z
6 7 2 close Z
9 11 2 close Z
13 18 2 close Z
Exception table:
from to target type
1 8 11 any
9 10 11 any
11 12 11 any
MethodParameters:
Name Flags
stream
private void drainResponse(io.vertx.core.http.impl.Http1xClientConnection$Stream);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.responseEnded:Z
ifne 2
1: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doResume:()V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 3 1 n Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
MethodParameters:
Name Flags
n
private void checkLifecycle();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
ifeq 3
1: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
pop
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.recycle:()V
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
private java.lang.Throwable validateMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Throwable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.handler.codec.http.HttpObject
ifeq 9
1: aload 1
checkcast io.netty.handler.codec.http.HttpObject
astore 2
start local 2 2: aload 2
invokeinterface io.netty.handler.codec.http.HttpObject.decoderResult:()Lio/netty/handler/codec/DecoderResult;
astore 3
start local 3 3: aload 3
invokevirtual io.netty.handler.codec.DecoderResult.isFailure:()Z
ifeq 5
4: aload 3
invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
areturn
5: StackMap locals: io.netty.handler.codec.http.HttpObject io.netty.handler.codec.DecoderResult
StackMap stack:
aload 2
instanceof io.netty.handler.codec.http.HttpResponse
ifeq 9
6: aload 2
checkcast io.netty.handler.codec.http.HttpResponse
invokeinterface io.netty.handler.codec.http.HttpResponse.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
astore 4
start local 4 7: aload 4
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_0:Lio/netty/handler/codec/http/HttpVersion;
if_acmpeq 9
aload 4
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_1:Lio/netty/handler/codec/http/HttpVersion;
if_acmpeq 9
8: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Unsupported HTTP version: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
areturn
end local 4 end local 3 end local 2 9: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 10 1 msg Ljava/lang/Object;
2 9 2 obj Lio/netty/handler/codec/http/HttpObject;
3 9 3 result Lio/netty/handler/codec/DecoderResult;
7 9 4 version Lio/netty/handler/codec/http/HttpVersion;
MethodParameters:
Name Flags
msg
public void handleMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.validateMessage:(Ljava/lang/Object;)Ljava/lang/Throwable;
astore 2
start local 2 1: aload 2
ifnull 4
2: aload 0
aload 2
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.fail:(Ljava/lang/Throwable;)V
3: goto 14
StackMap locals: java.lang.Throwable
StackMap stack:
4: aload 1
instanceof io.netty.handler.codec.http.HttpObject
ifeq 7
5: aload 0
aload 1
checkcast io.netty.handler.codec.http.HttpObject
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleHttpMessage:(Lio/netty/handler/codec/http/HttpObject;)V
6: goto 14
StackMap locals:
StackMap stack:
7: aload 1
instanceof io.netty.buffer.ByteBuf
ifeq 10
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
ifeq 10
8: aload 0
aload 1
checkcast io.netty.buffer.ByteBuf
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleChunk:(Lio/netty/buffer/ByteBuf;)V
9: goto 14
StackMap locals:
StackMap stack:
10: aload 1
instanceof io.netty.handler.codec.http.websocketx.WebSocketFrame
ifeq 13
11: aload 0
aload 1
checkcast io.netty.handler.codec.http.websocketx.WebSocketFrame
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleWsFrame:(Lio/netty/handler/codec/http/websocketx/WebSocketFrame;)V
12: goto 14
13: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
14: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 15 1 msg Ljava/lang/Object;
1 15 2 error Ljava/lang/Throwable;
MethodParameters:
Name Flags
msg
private void handleHttpMessage(io.netty.handler.codec.http.HttpObject);
descriptor: (Lio/netty/handler/codec/http/HttpObject;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, locals=5, 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.Http1xClientConnection.responses:Ljava/util/Deque;
invokeinterface java.util.Deque.peekFirst:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 2
start local 2 2: aload 2
ifnonnull 5
3: aload 3
monitorexit
4: return
5: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 3
monitorexit
6: goto 9
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpObject top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
7: aload 3
monitorexit
8: athrow
start local 2 9: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpObject io.vertx.core.http.impl.Http1xClientConnection$Stream
StackMap stack:
aload 1
instanceof io.netty.handler.codec.http.HttpResponse
ifeq 22
10: aload 1
checkcast io.netty.handler.codec.http.HttpResponse
astore 3
start local 3 11: aload 3
invokeinterface io.netty.handler.codec.http.HttpResponse.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_0:Lio/netty/handler/codec/http/HttpVersion;
if_acmpne 14
12: getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
astore 4
start local 4 13: goto 15
end local 4 14: StackMap locals: io.netty.handler.codec.http.HttpResponse
StackMap stack:
getstatic io.vertx.core.http.HttpVersion.HTTP_1_1:Lio/vertx/core/http/HttpVersion;
astore 4
start local 4 15: StackMap locals: io.vertx.core.http.HttpVersion
StackMap stack:
aload 0
aload 2
new io.vertx.core.http.impl.HttpResponseHead
dup
16: aload 4
17: aload 3
invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
18: aload 3
invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.reasonPhrase:()Ljava/lang/String;
19: new io.vertx.core.http.impl.headers.HeadersAdaptor
dup
aload 3
invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
invokespecial io.vertx.core.http.impl.headers.HeadersAdaptor.<init>:(Lio/netty/handler/codec/http/HttpHeaders;)V
invokespecial io.vertx.core.http.impl.HttpResponseHead.<init>:(Lio/vertx/core/http/HttpVersion;ILjava/lang/String;Lio/vertx/core/MultiMap;)V
20: invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseBegin:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/vertx/core/http/impl/HttpResponseHead;)V
end local 4 end local 3 21: goto 28
StackMap locals:
StackMap stack:
22: aload 1
instanceof io.netty.handler.codec.http.HttpContent
ifeq 28
23: aload 1
checkcast io.netty.handler.codec.http.HttpContent
astore 3
start local 3 24: aload 3
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 26
25: aload 0
aload 2
aload 3
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseChunk:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;)V
26: StackMap locals: io.netty.handler.codec.http.HttpContent
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
ifne 28
aload 3
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 28
27: aload 0
aload 2
aload 3
checkcast io.netty.handler.codec.http.LastHttpContent
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseEnd:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/handler/codec/http/LastHttpContent;)V
end local 3 28: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 29 1 obj Lio/netty/handler/codec/http/HttpObject;
2 7 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
9 29 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
11 21 3 response Lio/netty/handler/codec/http/HttpResponse;
13 14 4 version Lio/vertx/core/http/HttpVersion;
15 21 4 version Lio/vertx/core/http/HttpVersion;
24 28 3 chunk Lio/netty/handler/codec/http/HttpContent;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
MethodParameters:
Name Flags
obj
private void handleChunk(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, 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.Http1xClientConnection.responses:Ljava/util/Deque;
invokeinterface java.util.Deque.peekFirst:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 2
start local 2 2: aload 2
ifnonnull 5
3: aload 3
monitorexit
4: return
5: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 3
monitorexit
6: goto 9
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.buffer.ByteBuf top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
7: aload 3
monitorexit
8: athrow
start local 2 9: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.buffer.ByteBuf io.vertx.core.http.impl.Http1xClientConnection$Stream
StackMap stack:
aload 1
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 11
10: aload 0
aload 2
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseChunk:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;)V
11: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 12 1 chunk Lio/netty/buffer/ByteBuf;
2 7 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
9 12 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
MethodParameters:
Name Flags
chunk
private void handleResponseBegin(io.vertx.core.http.impl.Http1xClientConnection$Stream, io.vertx.core.http.impl.HttpResponseHead);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/vertx/core/http/impl/HttpResponseHead;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusCode:I
bipush 100
if_icmpne 3
1: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aconst_null
aload 1
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)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/Http1xClientConnection.lambda$4(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.impl.ContextInternal.execute:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
2: goto 35
3: StackMap locals:
StackMap stack:
aload 0
dup
astore 4
monitorenter
4: aload 1
checkcast io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpRequestHead;
astore 3
start local 3 5: aload 1
aload 2
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.response:Lio/vertx/core/http/impl/HttpResponseHead;
6: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 8
7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.metric:Ljava/lang/Object;
aload 2
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.responseBegin:(Ljava/lang/Object;Ljava/lang/Object;)V
8: StackMap locals: io.vertx.core.http.impl.HttpRequestHead io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusCode:I
bipush 100
if_icmpeq 23
aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
getstatic io.vertx.core.http.HttpMethod.CONNECT:Lio/vertx/core/http/HttpMethod;
if_acmpeq 23
9: aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.headers:Lio/vertx/core/MultiMap;
getstatic io.netty.handler.codec.http.HttpHeaderNames.CONNECTION:Lio/netty/util/AsciiString;
invokeinterface io.vertx.core.MultiMap.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
astore 5
start local 5 10: aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.headers:Lio/vertx/core/MultiMap;
ifnull 11
aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.headers:Lio/vertx/core/MultiMap;
getstatic io.netty.handler.codec.http.HttpHeaderNames.CONNECTION:Lio/netty/util/AsciiString;
invokeinterface io.vertx.core.MultiMap.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
goto 12
StackMap locals: java.lang.String
StackMap stack:
11: aconst_null
StackMap locals:
StackMap stack: java.lang.String
12: astore 6
start local 6 13: getstatic io.netty.handler.codec.http.HttpHeaderValues.CLOSE:Lio/netty/util/AsciiString;
aload 5
invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
ifne 14
getstatic io.netty.handler.codec.http.HttpHeaderValues.CLOSE:Lio/netty/util/AsciiString;
aload 6
invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
ifeq 16
14: StackMap locals: java.lang.String
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
15: goto 18
StackMap locals:
StackMap stack:
16: aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.version:Lio/vertx/core/http/HttpVersion;
getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
if_acmpne 18
getstatic io.netty.handler.codec.http.HttpHeaderValues.KEEP_ALIVE:Lio/netty/util/AsciiString;
aload 5
invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
ifne 18
17: aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
18: StackMap locals:
StackMap stack:
aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.headers:Lio/vertx/core/MultiMap;
getstatic io.netty.handler.codec.http.HttpHeaderNames.KEEP_ALIVE:Lio/netty/util/AsciiString;
invokeinterface io.vertx.core.MultiMap.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
astore 7
start local 7 19: aload 7
ifnull 23
20: aload 7
invokestatic io.vertx.core.http.impl.HttpUtils.parseKeepAliveHeaderTimeout:(Ljava/lang/CharSequence;)I
istore 8
start local 8 21: iload 8
iconst_m1
if_icmpeq 23
22: aload 0
iload 8
putfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
end local 8 end local 7 end local 6 end local 5 23: StackMap locals:
StackMap stack:
aload 4
monitorexit
24: goto 27
end local 3 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpResponseHead top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
25: aload 4
monitorexit
26: athrow
start local 3 27: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.HttpResponseHead io.vertx.core.http.impl.HttpRequestHead
StackMap stack:
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$Stream.handleHead:(Lio/vertx/core/http/impl/HttpResponseHead;)V
28: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
ifeq 35
29: aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
getstatic io.vertx.core.http.HttpMethod.CONNECT:Lio/vertx/core/http/HttpMethod;
if_acmpne 31
30: aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusCode:I
sipush 200
if_icmpeq 34
31: StackMap locals:
StackMap stack:
aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.method:Lio/vertx/core/http/HttpMethod;
getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
if_acmpne 35
32: aload 3
getfield io.vertx.core.http.impl.HttpRequestHead.headers:Lio/vertx/core/MultiMap;
ldc "connection"
ldc "Upgrade"
iconst_0
invokeinterface io.vertx.core.MultiMap.contains:(Ljava/lang/String;Ljava/lang/String;Z)Z
ifeq 35
33: aload 2
getfield io.vertx.core.http.impl.HttpResponseHead.statusCode:I
bipush 101
if_icmpne 35
34: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.removeChannelHandlers:()Ljava/util/List;
pop
end local 3 35: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 36 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 36 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
0 36 2 response Lio/vertx/core/http/impl/HttpResponseHead;
5 25 3 request Lio/vertx/core/http/impl/HttpRequestHead;
27 35 3 request Lio/vertx/core/http/impl/HttpRequestHead;
10 23 5 responseConnectionHeader Ljava/lang/String;
13 23 6 requestConnectionHeader Ljava/lang/String;
19 23 7 keepAliveHeader Ljava/lang/String;
21 23 8 timeout I
Exception table:
from to target type
4 24 25 any
25 26 25 any
MethodParameters:
Name Flags
stream
response
private java.util.List<java.lang.Object> removeChannelHandlers();
descriptor: ()Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=7, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 1
start local 1 1: aload 1
ldc Lio/netty/handler/codec/http/HttpContentDecompressor;
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/Class;)Lio/netty/channel/ChannelHandler;
astore 2
start local 2 2: aload 2
ifnull 4
3: aload 1
aload 2
invokeinterface io.netty.channel.ChannelPipeline.remove:(Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
4: StackMap locals: io.netty.channel.ChannelPipeline io.netty.channel.ChannelHandler
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
astore 4
start local 4 6: aload 0
aload 3
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Ljava/util/List;)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
java/util/List.add(Ljava/lang/Object;)Z (9 itf)
(Ljava/lang/Object;)V
putfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
7: aload 1
ldc "codec"
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
8: goto 12
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.channel.ChannelPipeline io.netty.channel.ChannelHandler java.util.List io.vertx.core.Handler
StackMap stack: java.lang.Throwable
9: astore 6
10: aload 0
aload 4
putfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
11: aload 6
athrow
12: StackMap locals:
StackMap stack:
aload 0
aload 4
putfield io.vertx.core.http.impl.Http1xClientConnection.invalidMessageHandler:Lio/vertx/core/Handler;
13: aload 3
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
1 14 1 pipeline Lio/netty/channel/ChannelPipeline;
2 14 2 inflater Lio/netty/channel/ChannelHandler;
5 14 3 pending Ljava/util/List<Ljava/lang/Object;>;
6 14 4 prev Lio/vertx/core/Handler<Ljava/lang/Object;>;
Exception table:
from to target type
7 9 9 any
Signature: ()Ljava/util/List<Ljava/lang/Object;>;
private void handleResponseChunk(io.vertx.core.http.impl.Http1xClientConnection$Stream, io.netty.buffer.ByteBuf);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
invokestatic io.vertx.core.net.impl.VertxHandler.safeBuffer:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
invokestatic io.vertx.core.buffer.Buffer.buffer:(Lio/netty/buffer/ByteBuf;)Lio/vertx/core/buffer/Buffer;
astore 3
start local 3 1: aload 1
dup
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesRead:J
aload 3
invokeinterface io.vertx.core.buffer.Buffer.length:()I
i2l
ladd
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesRead:J
2: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aload 3
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)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/Http1xClientConnection$Stream.handleChunk(Lio/vertx/core/buffer/Buffer;)V (5)
(Lio/vertx/core/buffer/Buffer;)V
invokeinterface io.vertx.core.impl.ContextInternal.execute:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
3: return
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/Http1xClientConnection;
0 4 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
0 4 2 chunk Lio/netty/buffer/ByteBuf;
1 4 3 buff Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
stream
chunk
private void handleResponseEnd(io.vertx.core.http.impl.Http1xClientConnection$Stream, io.netty.handler.codec.http.LastHttpContent);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/handler/codec/http/LastHttpContent;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.response:Lio/vertx/core/http/impl/HttpResponseHead;
ifnonnull 4
2: aload 4
monitorexit
3: return
4: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.handler.codec.http.LastHttpContent top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
invokeinterface java.util.Deque.pop:()Ljava/lang/Object;
pop
5: aload 0
dup
getfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
ifeq 6
iconst_0
goto 7
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.handler.codec.http.LastHttpContent top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection int
6: iconst_1
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.handler.codec.http.LastHttpContent top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection int int
7: ior
putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
8: aload 1
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection$Stream.responseEnded:Z
9: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
aload 1
if_acmpeq 10
iconst_1
goto 11
StackMap locals:
StackMap stack:
10: iconst_0
StackMap locals:
StackMap stack: int
11: istore 3
start local 3 12: aload 4
monitorexit
13: goto 16
end local 3 StackMap locals:
StackMap stack: java.lang.Throwable
14: aload 4
monitorexit
15: athrow
start local 3 16: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream io.netty.handler.codec.http.LastHttpContent int
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.tracer:()Lio/vertx/core/spi/tracing/VertxTracer;
astore 4
start local 4 17: aload 4
ifnull 19
18: aload 4
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.response:Lio/vertx/core/http/impl/HttpResponseHead;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.trace:Ljava/lang/Object;
aconst_null
getstatic io.vertx.core.http.impl.HttpUtils.CLIENT_RESPONSE_TAG_EXTRACTOR:Lio/vertx/core/spi/tracing/TagExtractor;
invokeinterface io.vertx.core.spi.tracing.VertxTracer.receiveResponse:(Lio/vertx/core/Context;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Throwable;Lio/vertx/core/spi/tracing/TagExtractor;)V
19: StackMap locals: io.vertx.core.spi.tracing.VertxTracer
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 21
20: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.metric:Ljava/lang/Object;
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.bytesRead:J
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.responseEnd:(Ljava/lang/Object;J)V
21: StackMap locals:
StackMap stack:
aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aload 2
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)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/Http1xClientConnection$Stream.handleEnd(Lio/netty/handler/codec/http/LastHttpContent;)V (5)
(Lio/netty/handler/codec/http/LastHttpContent;)V
invokeinterface io.vertx.core.impl.ContextInternal.execute:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
22: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doResume:()V
23: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.flushBytesRead:()V
24: iload 3
ifeq 26
25: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.checkLifecycle:()V
26: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 27 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
0 27 2 trailer Lio/netty/handler/codec/http/LastHttpContent;
12 14 3 check Z
16 27 3 check Z
17 27 4 tracer Lio/vertx/core/spi/tracing/VertxTracer;
Exception table:
from to target type
1 3 14 any
4 13 14 any
14 15 14 any
MethodParameters:
Name Flags
stream
trailer
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.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.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/Http1xClientConnection;
synchronized void toWebSocket(io.vertx.core.impl.ContextInternal, java.lang.String, io.vertx.core.MultiMap, io.vertx.core.http.WebsocketVersion, java.util.List<java.lang.String>, int, io.vertx.core.Promise<io.vertx.core.http.WebSocket>);
descriptor: (Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Lio/vertx/core/MultiMap;Lio/vertx/core/http/WebsocketVersion;Ljava/util/List;ILio/vertx/core/Promise;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=8, locals=16, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: new java.net.URI
dup
aload 2
invokespecial java.net.URI.<init>:(Ljava/lang/String;)V
astore 8
start local 8 1: aload 8
invokevirtual java.net.URI.isAbsolute:()Z
ifne 6
2: new java.net.URI
dup
3: new java.lang.StringBuilder
dup
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ssl:Z
ifeq 4
ldc "https:"
goto 5
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI
StackMap stack: new 2 new 2 new 3 new 3
4: ldc "http:"
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI
StackMap stack: new 2 new 2 new 3 new 3 java.lang.String
5: invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "//"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.server:Lio/vertx/core/net/SocketAddress;
invokeinterface io.vertx.core.net.SocketAddress.host:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.server:Lio/vertx/core/net/SocketAddress;
invokeinterface io.vertx.core.net.SocketAddress.port:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.net.URI.<init>:(Ljava/lang/String;)V
astore 8
6: StackMap locals:
StackMap stack:
aload 4
ifnonnull 8
7: getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V13:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
goto 9
StackMap locals:
StackMap stack:
8: aload 4
StackMap locals:
StackMap stack: java.lang.Enum
9: invokevirtual java.lang.Enum.toString:()Ljava/lang/String;
10: invokestatic io.netty.handler.codec.http.websocketx.WebSocketVersion.valueOf:(Ljava/lang/String;)Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
11: astore 9
start local 9 12: aload 3
ifnull 19
13: new io.netty.handler.codec.http.DefaultHttpHeaders
dup
invokespecial io.netty.handler.codec.http.DefaultHttpHeaders.<init>:()V
astore 10
start local 10 14: aload 3
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 12
goto 17
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders top java.util.Iterator
StackMap stack:
15: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 11
start local 11 16: aload 10
aload 11
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 11
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual io.netty.handler.codec.http.HttpHeaders.add:(Ljava/lang/String;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
pop
end local 11 17: StackMap locals:
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
18: goto 20
end local 10 19: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion
StackMap stack:
aconst_null
astore 10
start local 10 20: StackMap locals: io.netty.handler.codec.http.HttpHeaders
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
invokeinterface io.netty.channel.Channel.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 11
start local 11 21: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.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.impl.Http1xClientConnection.initializeWebSocketExtensionHandshakers:(Lio/vertx/core/http/HttpClientOptions;)Ljava/util/ArrayList;
astore 12
start local 12 22: aload 12
invokevirtual java.util.ArrayList.isEmpty:()Z
ifne 26
23: aload 11
ldc "handler"
ldc "webSocketsExtensionsHandler"
new io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler
dup
24: aload 12
iconst_0
anewarray io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandshaker
invokevirtual java.util.ArrayList.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
checkcast io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandshaker[]
invokespecial io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler.<init>:([Lio/netty/handler/codec/http/websocketx/extensions/WebSocketClientExtensionHandshaker;)V
25: invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
26: StackMap locals: io.netty.channel.ChannelPipeline java.util.ArrayList
StackMap stack:
aconst_null
astore 13
start local 13 27: aload 5
ifnull 29
28: ldc ","
aload 5
invokestatic java.lang.String.join:(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Ljava/lang/String;
astore 13
29: StackMap locals: java.lang.String
StackMap stack:
aload 8
30: aload 9
31: aload 13
32: aload 12
invokevirtual java.util.ArrayList.isEmpty:()Z
ifeq 33
iconst_0
goto 34
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders io.netty.channel.ChannelPipeline java.util.ArrayList java.lang.String
StackMap stack: java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion java.lang.String
33: iconst_1
34: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders io.netty.channel.ChannelPipeline java.util.ArrayList java.lang.String
StackMap stack: java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion java.lang.String int
aload 10
35: iload 6
36: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isSendUnmaskedFrames:()Z
ifeq 37
iconst_0
goto 38
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders io.netty.channel.ChannelPipeline java.util.ArrayList java.lang.String
StackMap stack: java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion java.lang.String int io.netty.handler.codec.http.HttpHeaders int
37: iconst_1
38: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders io.netty.channel.ChannelPipeline java.util.ArrayList java.lang.String
StackMap stack: java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion java.lang.String int io.netty.handler.codec.http.HttpHeaders int int
invokestatic io.vertx.core.http.impl.WebSocketHandshakeInboundHandler.newHandshaker:(Ljava/net/URI;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Ljava/lang/String;ZLio/netty/handler/codec/http/HttpHeaders;IZ)Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;
astore 14
start local 14 39: new io.vertx.core.http.impl.WebSocketHandshakeInboundHandler
dup
aload 14
aload 0
aload 1
aload 9
aload 14
aload 7
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Promise;)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/Http1xClientConnection.lambda$8(Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokespecial io.vertx.core.http.impl.WebSocketHandshakeInboundHandler.<init>:(Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Handler;)V
astore 15
start local 15 40: aload 11
ldc "handler"
ldc "handshakeCompleter"
aload 15
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
41: aload 14
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker.handshake:(Lio/netty/channel/Channel;)Lio/netty/channel/ChannelFuture;
pop
end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 42: goto 45
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Promise
StackMap stack: java.lang.Exception
43: astore 8
start local 8 44: aload 0
aload 8
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleException:(Ljava/lang/Throwable;)V
end local 8 45: StackMap locals:
StackMap stack:
return
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 46 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 46 1 context Lio/vertx/core/impl/ContextInternal;
0 46 2 requestURI Ljava/lang/String;
0 46 3 headers Lio/vertx/core/MultiMap;
0 46 4 vers Lio/vertx/core/http/WebsocketVersion;
0 46 5 subProtocols Ljava/util/List<Ljava/lang/String;>;
0 46 6 maxWebSocketFrameSize I
0 46 7 promise Lio/vertx/core/Promise<Lio/vertx/core/http/WebSocket;>;
1 42 8 wsuri Ljava/net/URI;
12 42 9 version Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
14 19 10 nettyHeaders Lio/netty/handler/codec/http/HttpHeaders;
20 42 10 nettyHeaders Lio/netty/handler/codec/http/HttpHeaders;
16 17 11 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
21 42 11 p Lio/netty/channel/ChannelPipeline;
22 42 12 extensionHandshakers Ljava/util/ArrayList<Lio/netty/handler/codec/http/websocketx/extensions/WebSocketClientExtensionHandshaker;>;
27 42 13 subp Ljava/lang/String;
39 42 14 handshaker Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;
40 42 15 handshakeInboundHandler Lio/vertx/core/http/impl/WebSocketHandshakeInboundHandler;
44 45 8 e Ljava/lang/Exception;
Exception table:
from to target type
0 42 43 Class java.lang.Exception
Signature: (Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Lio/vertx/core/MultiMap;Lio/vertx/core/http/WebsocketVersion;Ljava/util/List<Ljava/lang/String;>;ILio/vertx/core/Promise<Lio/vertx/core/http/WebSocket;>;)V
MethodParameters:
Name Flags
context
requestURI
headers
vers
subProtocols
maxWebSocketFrameSize
promise
java.util.ArrayList<io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandshaker> initializeWebSocketExtensionHandshakers(io.vertx.core.http.HttpClientOptions);
descriptor: (Lio/vertx/core/http/HttpClientOptions;)Ljava/util/ArrayList;
flags: (0x0000)
Code:
stack=8, locals=3, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getTryWebSocketDeflateFrameCompression:()Z
ifeq 5
2: aload 2
new io.netty.handler.codec.http.websocketx.extensions.compression.DeflateFrameClientExtensionHandshaker
dup
aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getWebSocketCompressionLevel:()I
3: iconst_0
invokespecial io.netty.handler.codec.http.websocketx.extensions.compression.DeflateFrameClientExtensionHandshaker.<init>:(IZ)V
4: invokevirtual java.util.ArrayList.add:(Ljava/lang/Object;)Z
pop
5: StackMap locals: java.util.ArrayList
StackMap stack:
aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getTryUsePerMessageWebSocketCompression:()Z
ifeq 10
6: aload 2
new io.netty.handler.codec.http.websocketx.extensions.compression.PerMessageDeflateClientExtensionHandshaker
dup
aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getWebSocketCompressionLevel:()I
7: invokestatic io.netty.handler.codec.compression.ZlibCodecFactory.isSupportingWindowSizeAndMemLevel:()Z
bipush 15
8: aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getWebSocketCompressionAllowClientNoContext:()Z
aload 1
invokevirtual io.vertx.core.http.HttpClientOptions.getWebSocketCompressionRequestServerNoContext:()Z
invokespecial io.netty.handler.codec.http.websocketx.extensions.compression.PerMessageDeflateClientExtensionHandshaker.<init>:(IZIZZ)V
9: invokevirtual java.util.ArrayList.add:(Ljava/lang/Object;)Z
pop
10: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 11 1 options Lio/vertx/core/http/HttpClientOptions;
1 11 2 extensionHandshakers Ljava/util/ArrayList<Lio/netty/handler/codec/http/websocketx/extensions/WebSocketClientExtensionHandshaker;>;
Signature: (Lio/vertx/core/http/HttpClientOptions;)Ljava/util/ArrayList<Lio/netty/handler/codec/http/websocketx/extensions/WebSocketClientExtensionHandshaker;>;
MethodParameters:
Name Flags
options
public void handleInterestedOpsChanged();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.isNotWritable:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: istore 1
start local 1 3: aload 0
dup
astore 4
monitorenter
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 5
start local 5 5: aload 5
ifnull 9
6: aload 5
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
astore 2
start local 2 7: aload 5
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)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/Http1xClientConnection$Stream.handleWritabilityChanged(Z)V (5)
(Ljava/lang/Boolean;)V
astore 3
start local 3 8: goto 15
end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int top top io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$Stream
StackMap stack:
9: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 13
10: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
getfield io.vertx.core.http.impl.WebSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
astore 2
start local 2 11: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/vertx/core/http/impl/WebSocketImpl;)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/WebSocketImplBase.handleWritabilityChanged(Z)V (5)
(Ljava/lang/Boolean;)V
astore 3
start local 3 12: goto 15
end local 3 end local 2 13: StackMap locals:
StackMap stack:
aload 4
monitorexit
14: return
end local 5 start local 2 start local 3 15: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int io.vertx.core.impl.ContextInternal io.vertx.core.Handler io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 4
monitorexit
16: goto 19
end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int top top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
17: aload 4
monitorexit
18: athrow
start local 2 start local 3 19: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int io.vertx.core.impl.ContextInternal io.vertx.core.Handler
StackMap stack:
aload 2
iload 1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aload 3
invokeinterface io.vertx.core.impl.ContextInternal.execute:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
20: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
3 21 1 writable Z
7 9 2 context Lio/vertx/core/impl/ContextInternal;
11 13 2 context Lio/vertx/core/impl/ContextInternal;
15 17 2 context Lio/vertx/core/impl/ContextInternal;
19 21 2 context Lio/vertx/core/impl/ContextInternal;
8 9 3 handler Lio/vertx/core/Handler<Ljava/lang/Boolean;>;
12 13 3 handler Lio/vertx/core/Handler<Ljava/lang/Boolean;>;
15 17 3 handler Lio/vertx/core/Handler<Ljava/lang/Boolean;>;
19 21 3 handler Lio/vertx/core/Handler<Ljava/lang/Boolean;>;
5 15 5 current Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
Exception table:
from to target type
4 14 17 any
15 16 17 any
17 18 17 any
private java.lang.Iterable<io.vertx.core.http.impl.Http1xClientConnection$Stream> pendingStreams();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: new java.util.LinkedHashSet
dup
invokespecial java.util.LinkedHashSet.<init>:()V
astore 1
start local 1 1: aload 1
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokevirtual java.util.LinkedHashSet.addAll:(Ljava/util/Collection;)Z
pop
2: aload 1
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
invokevirtual java.util.LinkedHashSet.addAll:(Ljava/util/Collection;)Z
pop
3: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
1 4 1 list Ljava/util/LinkedHashSet<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
Signature: ()Ljava/lang/Iterable<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
protected void handleClosed();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=9, args_size=1
start local 0 0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.handleClosed:()V
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.shutdownTimerID:J
lstore 1
start local 1 2: lload 1
ldc -1
lcmp
ifeq 5
3: aload 0
ldc -1
putfield io.vertx.core.http.impl.Http1xClientConnection.shutdownTimerID:J
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.vertx:Lio/vertx/core/impl/VertxInternal;
lload 1
invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
pop
5: StackMap locals: long
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.closed:Z
6: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
astore 3
start local 3 8: aload 3
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.endpointDisconnected:(Lio/vertx/core/spi/metrics/ClientMetrics;)V
end local 3 9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.tracer:()Lio/vertx/core/spi/tracing/VertxTracer;
astore 4
start local 4 10: aload 0
dup
astore 6
monitorenter
11: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
astore 3
start local 3 12: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.pendingStreams:()Ljava/lang/Iterable;
astore 5
start local 5 13: aload 6
monitorexit
14: goto 17
end local 5 end local 3 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection long top io.vertx.core.spi.tracing.VertxTracer top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
15: aload 6
monitorexit
16: athrow
start local 3 start local 5 17: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection long io.vertx.core.http.impl.WebSocketImpl io.vertx.core.spi.tracing.VertxTracer java.lang.Iterable
StackMap stack:
aload 3
ifnull 19
18: aload 3
invokevirtual io.vertx.core.http.impl.WebSocketImpl.handleConnectionClosed:()V
19: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 7
goto 27
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection long io.vertx.core.http.impl.WebSocketImpl io.vertx.core.spi.tracing.VertxTracer java.lang.Iterable top java.util.Iterator
StackMap stack:
20: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 6
start local 6 21: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 23
22: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 6
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.metric:Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestReset:(Ljava/lang/Object;)V
23: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection long io.vertx.core.http.impl.WebSocketImpl io.vertx.core.spi.tracing.VertxTracer java.lang.Iterable io.vertx.core.http.impl.Http1xClientConnection$Stream java.util.Iterator
StackMap stack:
aload 6
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.trace:Ljava/lang/Object;
astore 8
start local 8 24: aload 4
ifnull 26
aload 8
ifnull 26
25: aload 4
aload 6
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aconst_null
aload 8
getstatic io.vertx.core.net.impl.ConnectionBase.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
invokestatic io.vertx.core.spi.tracing.TagExtractor.empty:()Lio/vertx/core/spi/tracing/TagExtractor;
invokeinterface io.vertx.core.spi.tracing.VertxTracer.receiveResponse:(Lio/vertx/core/Context;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Throwable;Lio/vertx/core/spi/tracing/TagExtractor;)V
26: StackMap locals: java.lang.Object
StackMap stack:
aload 6
getfield io.vertx.core.http.impl.Http1xClientConnection$Stream.context:Lio/vertx/core/impl/ContextInternal;
aconst_null
aload 6
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)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/Http1xClientConnection.lambda$13(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.impl.ContextInternal.execute:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
end local 8 end local 6 27: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection long io.vertx.core.http.impl.WebSocketImpl io.vertx.core.spi.tracing.VertxTracer java.lang.Iterable top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 20
28: return
end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
2 29 1 timerID J
8 9 3 met Lio/vertx/core/spi/metrics/HttpClientMetrics;
12 15 3 ws Lio/vertx/core/http/impl/WebSocketImpl;
17 29 3 ws Lio/vertx/core/http/impl/WebSocketImpl;
10 29 4 tracer Lio/vertx/core/spi/tracing/VertxTracer;
13 15 5 streams Ljava/lang/Iterable<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
17 29 5 streams Ljava/lang/Iterable<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
21 27 6 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
24 27 8 trace Ljava/lang/Object;
Exception table:
from to target type
11 14 15 any
15 16 15 any
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.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnonnull 4
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 4
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 4
2: aload 1
monitorexit
3: return
4: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
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.Http1xConnectionBase.handleIdle:()V
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
Exception table:
from to target type
1 3 6 any
4 5 6 any
6 7 6 any
protected void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.handleException:(Ljava/lang/Throwable;)V
1: aload 0
dup
astore 4
monitorenter
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
astore 2
start local 2 3: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.pendingStreams:()Ljava/lang/Iterable;
astore 3
start local 3 4: aload 4
monitorexit
5: goto 8
end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.Throwable top top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
6: aload 4
monitorexit
7: athrow
start local 2 start local 3 8: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.Throwable io.vertx.core.http.impl.WebSocketImpl java.lang.Iterable
StackMap stack:
aload 2
ifnull 10
9: aload 2
aload 1
invokevirtual io.vertx.core.http.impl.WebSocketImpl.handleException:(Ljava/lang/Throwable;)V
10: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 5
goto 13
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.Throwable io.vertx.core.http.impl.WebSocketImpl java.lang.Iterable top java.util.Iterator
StackMap stack:
11: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$Stream
astore 4
start local 4 12: aload 4
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$Stream.handleException:(Ljava/lang/Throwable;)V
end local 4 13: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
14: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 15 1 e Ljava/lang/Throwable;
3 6 2 ws Lio/vertx/core/http/impl/WebSocketImpl;
8 15 2 ws Lio/vertx/core/http/impl/WebSocketImpl;
4 6 3 streams Ljava/lang/Iterable<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
8 15 3 streams Ljava/lang/Iterable<Lio/vertx/core/http/impl/Http1xClientConnection$Stream;>;
12 13 4 stream Lio/vertx/core/http/impl/Http1xClientConnection$Stream;
Exception table:
from to target type
2 5 6 any
6 7 6 any
MethodParameters:
Name Flags
e
public void createStream(io.vertx.core.impl.ContextInternal, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientStream>>);
descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.nettyEventLoop:()Lio/netty/channel/EventLoop;
astore 3
start local 3 1: aload 3
invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
ifeq 19
2: aload 0
dup
astore 5
monitorenter
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.closed:Z
ifeq 6
4: aconst_null
astore 4
start local 4 5: goto 10
end local 4 6: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.vertx.core.Handler io.netty.channel.EventLoop top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
new io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
dup
aload 1
aload 0
aload 0
dup
getfield io.vertx.core.http.impl.Http1xClientConnection.seq:I
dup_x1
iconst_1
iadd
putfield io.vertx.core.http.impl.Http1xClientConnection.seq:I
invokespecial io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/Http1xClientConnection;I)V
astore 4
start local 4 7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
aload 4
invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
pop
8: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.size:()I
iconst_1
if_icmpne 10
9: aload 4
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.promise:Lio/vertx/core/Promise;
aload 4
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
10: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.vertx.core.Handler io.netty.channel.EventLoop io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 5
monitorexit
11: goto 14
end local 4 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.vertx.core.Handler io.netty.channel.EventLoop top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
12: aload 5
monitorexit
13: athrow
start local 4 14: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.vertx.core.Handler io.netty.channel.EventLoop io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 4
ifnull 17
15: aload 4
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.promise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
16: goto 20
17: StackMap locals:
StackMap stack:
aload 2
getstatic io.vertx.core.http.impl.Http1xClientConnection.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 4 18: goto 20
19: StackMap locals:
StackMap stack:
aload 3
aload 0
aload 1
aload 2
invokedynamic run(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)Ljava/lang/Runnable;
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:
()V
io/vertx/core/http/impl/Http1xClientConnection.lambda$14(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V (7)
()V
invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
20: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 21 1 context Lio/vertx/core/impl/ContextInternal;
0 21 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;
1 21 3 eventLoop Lio/netty/channel/EventLoop;
5 6 4 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
7 12 4 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
14 18 4 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
3 11 12 any
12 13 12 any
Signature: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;)V
MethodParameters:
Name Flags
context
handler
public boolean isValid();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.expirationTimestamp:J
lconst_0
lcmp
ifeq 1
invokestatic java.lang.System.currentTimeMillis:()J
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.expirationTimestamp:J
lcmp
ifle 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
private void recycle();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.shutdown:Z
ifeq 4
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requests:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 9
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responses:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 9
2: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
pop
3: goto 9
StackMap locals:
StackMap stack:
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.isConnect:Z
ifne 9
5: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
ifne 6
lconst_0
goto 7
StackMap locals:
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection
6: invokestatic java.lang.System.currentTimeMillis:()J
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
sipush 1000
imul
i2l
ladd
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: io.vertx.core.http.impl.Http1xClientConnection long
7: putfield io.vertx.core.http.impl.Http1xClientConnection.expirationTimestamp:J
8: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
invokeinterface io.vertx.core.net.impl.clientconnection.ConnectionListener.onRecycle:()V
9: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
public void shutdown(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.vertx:Lio/vertx/core/impl/VertxInternal;
aload 3
invokeinterface io.vertx.core.impl.VertxInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.shutdown:(JLio/vertx/core/impl/future/PromiseInternal;)V
1: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 2 1 timeout J
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
timeout
handler
public io.vertx.core.Future<java.lang.Void> shutdown(long);
descriptor: (J)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 1: aload 0
lload 1
aload 3
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.shutdown:(JLio/vertx/core/impl/future/PromiseInternal;)V
2: aload 3
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 3 1 timeoutMs J
1 3 3 promise Lio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Void;>;
Signature: (J)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
timeoutMs
private synchronized void shutdownNow();
descriptor: ()V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc -1
putfield io.vertx.core.http.impl.Http1xClientConnection.shutdownTimerID:J
1: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
pop
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
private void shutdown(long, io.vertx.core.impl.future.PromiseInternal<java.lang.Void>);
descriptor: (JLio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 3 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.shutdown:Z
ifeq 5
2: aload 3
ldc "Already shutdown"
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/String;)V
3: aload 4
monitorexit
4: return
5: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.shutdown:Z
6: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.closeFuture:()Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: aload 4
monitorexit
8: goto 11
StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 4
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/net/impl/clientconnection/ConnectionListener;
invokeinterface io.vertx.core.net.impl.clientconnection.ConnectionListener.onEvict:()V
12: aload 0
dup
astore 4
monitorenter
13: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.closed:Z
ifne 18
14: lload 1
lconst_0
lcmp
ifle 17
15: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
lload 1
aload 0
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection;)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/Http1xClientConnection.lambda$15(Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.impl.ContextInternal.setTimer:(JLio/vertx/core/Handler;)J
putfield io.vertx.core.http.impl.Http1xClientConnection.shutdownTimerID:J
16: goto 18
17: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
18: StackMap locals:
StackMap stack:
aload 4
monitorexit
19: goto 22
StackMap locals:
StackMap stack: java.lang.Throwable
20: aload 4
monitorexit
21: athrow
22: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.checkLifecycle:()V
23: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 24 1 timeoutMs J
0 24 3 promise Lio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Void;>;
Exception table:
from to target type
1 4 9 any
5 8 9 any
9 10 9 any
13 19 20 any
20 21 20 any
Signature: (JLio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
timeoutMs
promise
public io.vertx.core.http.HttpConnection shutdownHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.shutdownHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Future ping(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.ping:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection ping(io.vertx.core.buffer.Buffer, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.ping:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection updateSettings(io.vertx.core.http.Http2Settings, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/http/Http2Settings;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.updateSettings:(Lio/vertx/core/http/Http2Settings;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Future updateSettings(io.vertx.core.http.Http2Settings);
descriptor: (Lio/vertx/core/http/Http2Settings;)Lio/vertx/core/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.updateSettings:(Lio/vertx/core/http/Http2Settings;)Lio/vertx/core/Future;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection pingHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.pingHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.impl.Http1xConnectionBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.impl.Http1xConnectionBase closeHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.Http2Settings remoteSettings();
descriptor: ()Lio/vertx/core/http/Http2Settings;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.remoteSettings:()Lio/vertx/core/http/Http2Settings;
areturn
LocalVariableTable:
Start End Slot Name Signature
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.Http1xClientConnection.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection goAway(long, int, io.vertx.core.buffer.Buffer);
descriptor: (JILio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
0: aload 0
lload 1
iload 3
aload 4
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.goAway:(JILio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection goAwayHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.goAwayHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection remoteSettingsHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.remoteSettingsHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Future close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.close:()Lio/vertx/core/Future;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.Http2Settings settings();
descriptor: ()Lio/vertx/core/http/Http2Settings;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.settings:()Lio/vertx/core/http/Http2Settings;
areturn
LocalVariableTable:
Start End Slot Name Signature
static io.vertx.core.impl.ContextInternal access$15(io.vertx.core.http.impl.Http1xClientConnection);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Invalid object "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 msg Ljava/lang/Object;
private static io.vertx.core.net.impl.NetSocketImpl lambda$1(io.vertx.core.net.impl.NetSocketImpl, io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/net/impl/NetSocketImpl;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
private static void lambda$2(io.netty.handler.codec.http.HttpRequest, java.lang.String, java.lang.String);
descriptor: (Lio/netty/handler/codec/http/HttpRequest;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 1 start local 2 0: aload 0
invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
aload 1
aload 2
invokevirtual io.netty.handler.codec.http.HttpHeaders.add:(Ljava/lang/String;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 key Ljava/lang/String;
0 1 2 val Ljava/lang/String;
private void lambda$3(io.netty.util.concurrent.Future);
descriptor: (Lio/netty/util/concurrent/Future;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 1 1 v Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
private static void lambda$4(io.vertx.core.http.impl.Http1xClientConnection$Stream, java.lang.Object);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$Stream.handleContinue:()V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Object;
private void lambda$8(io.vertx.core.impl.ContextInternal, io.netty.handler.codec.http.websocketx.WebSocketVersion, io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=8, args_size=6
start local 0 start local 5 0: aload 5
aload 0
aload 1
aload 2
aload 3
invokedynamic apply(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;)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/Http1xClientConnection.lambda$9(Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/http/impl/headers/HeadersAdaptor;)Lio/vertx/core/http/WebSocket; (7)
(Lio/vertx/core/http/impl/headers/HeadersAdaptor;)Lio/vertx/core/http/WebSocket;
invokeinterface io.vertx.core.AsyncResult.map:(Ljava/util/function/Function;)Lio/vertx/core/AsyncResult;
astore 6
start local 6 1: aload 5
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 4
2: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()Lio/vertx/core/Future;
pop
3: goto 6
4: StackMap locals: io.vertx.core.AsyncResult
StackMap stack:
aload 0
aload 6
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.WebSocketImpl
putfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.eventBus:()Lio/vertx/core/eventbus/EventBus;
invokevirtual io.vertx.core.http.impl.WebSocketImpl.registerHandler:(Lio/vertx/core/eventbus/EventBus;)V
6: StackMap locals:
StackMap stack:
getstatic io.vertx.core.http.impl.Http1xClientConnection.log:Lio/vertx/core/impl/logging/Logger;
ldc "WebSocket handshake complete"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
invokevirtual io.vertx.core.http.impl.HttpClientImpl.metrics:()Lio/vertx/core/spi/metrics/HttpClientMetrics;
astore 7
start local 7 8: aload 7
ifnull 10
9: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aload 7
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.WebSocket
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.connected:(Lio/vertx/core/http/WebSocket;)Ljava/lang/Object;
invokevirtual io.vertx.core.http.impl.WebSocketImpl.setMetric:(Ljava/lang/Object;)V
10: StackMap locals: io.vertx.core.spi.metrics.HttpClientMetrics
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.getContext:()Lio/vertx/core/impl/ContextInternal;
aload 6
aload 0
aload 5
aload 4
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/AsyncResult;Lio/vertx/core/Promise;)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/Http1xClientConnection.lambda$10(Lio/vertx/core/AsyncResult;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
end local 7 end local 6 11: return
end local 5 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 12 5 ar Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/headers/HeadersAdaptor;>;
1 11 6 wsRes Lio/vertx/core/AsyncResult<Lio/vertx/core/http/WebSocket;>;
8 11 7 metrics Lio/vertx/core/spi/metrics/HttpClientMetrics;
private static void lambda$13(io.vertx.core.http.impl.Http1xClientConnection$Stream, java.lang.Object);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$Stream.handleClosed:()V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Object;
private void lambda$14(io.vertx.core.impl.ContextInternal, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.createStream:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
private void lambda$15(java.lang.Long);
descriptor: (Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.shutdownNow:()V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 1 1 id Ljava/lang/Long;
private io.vertx.core.http.WebSocket lambda$9(io.vertx.core.impl.ContextInternal, io.netty.handler.codec.http.websocketx.WebSocketVersion, io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, io.vertx.core.http.impl.headers.HeadersAdaptor);
descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/http/impl/headers/HeadersAdaptor;)Lio/vertx/core/http/WebSocket;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=9, locals=6, args_size=5
start local 0 start local 4 0: new io.vertx.core.http.impl.WebSocketImpl
dup
1: aload 1
2: aload 0
3: aload 2
getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V00:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
if_acmpeq 4
iconst_1
goto 5
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker io.vertx.core.http.impl.headers.HeadersAdaptor
StackMap stack: new 0 new 0 io.vertx.core.impl.ContextInternal io.vertx.core.http.impl.Http1xClientConnection
4: iconst_0
5: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.impl.ContextInternal io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker io.vertx.core.http.impl.headers.HeadersAdaptor
StackMap stack: new 0 new 0 io.vertx.core.impl.ContextInternal io.vertx.core.http.impl.Http1xClientConnection int
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getWebSocketClosingTimeout:()I
i2l
6: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getMaxWebSocketFrameSize:()I
7: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getMaxWebSocketMessageSize:()I
8: invokespecial io.vertx.core.http.impl.WebSocketImpl.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/Http1xClientConnection;ZJII)V
astore 5
start local 5 9: aload 5
aload 3
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker.actualSubprotocol:()Ljava/lang/String;
invokevirtual io.vertx.core.http.impl.WebSocketImpl.subProtocol:(Ljava/lang/String;)V
10: aload 5
areturn
end local 5 end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 11 4 v Lio/vertx/core/http/impl/headers/HeadersAdaptor;
9 11 5 w Lio/vertx/core/http/impl/WebSocketImpl;
private void lambda$10(io.vertx.core.AsyncResult, io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 2
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.MultiMap
invokevirtual io.vertx.core.http.impl.WebSocketImpl.headers:(Lio/vertx/core/MultiMap;)V
2: StackMap locals:
StackMap stack:
aload 2
aload 3
invokeinterface io.vertx.core.Promise.handle:(Lio/vertx/core/AsyncResult;)V
3: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
4: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.webSocket:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aconst_null
invokevirtual io.vertx.core.http.impl.WebSocketImpl.headers:(Lio/vertx/core/MultiMap;)V
5: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 6 3 res Lio/vertx/core/AsyncResult<Lio/vertx/core/http/WebSocket;>;
}
Signature: Lio/vertx/core/http/impl/Http1xConnectionBase<Lio/vertx/core/http/impl/WebSocketImpl;>;Lio/vertx/core/http/impl/HttpClientConnection;
SourceFile: "Http1xClientConnection.java"
NestMembers:
io.vertx.core.http.impl.Http1xClientConnection$Stream io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
InnerClasses:
private abstract Stream = io.vertx.core.http.impl.Http1xClientConnection$Stream of io.vertx.core.http.impl.Http1xClientConnection
private StreamImpl = io.vertx.core.http.impl.Http1xClientConnection$StreamImpl of io.vertx.core.http.impl.Http1xClientConnection
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public SimpleEntry = java.util.AbstractMap$SimpleEntry of java.util.AbstractMap
public abstract Entry = java.util.Map$Entry of java.util.Map
Http1xClientConnection
log: Logger
<clinit>(): void
handleClosed(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)