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: (0x0020) ACC_SUPER
this_class: io.vertx.core.http.impl.Http1xClientConnection
super_class: io.vertx.core.http.impl.Http1xConnectionBase
{
private static final io.vertx.core.logging.Logger log;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.http.impl.pool.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection> listener;
descriptor: Lio/vertx/core/http/impl/pool/ConnectionListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
private final io.vertx.core.http.impl.HttpClientImpl client;
descriptor: Lio/vertx/core/http/impl/HttpClientImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.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
private final java.lang.Object endpointMetric;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.metrics.HttpClientMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/HttpClientMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.http.HttpVersion version;
descriptor: Lio/vertx/core/http/HttpVersion;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.http.impl.Http1xClientConnection$StreamImpl requestInProgress;
descriptor: Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.Http1xClientConnection$StreamImpl responseInProgress;
descriptor: Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
flags: (0x0002) ACC_PRIVATE
private boolean close;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean upgraded;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int keepAliveTimeout;
descriptor: I
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.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.core.http.impl.Http1xClientConnection.log:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.http.impl.pool.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.HttpClientMetrics);
descriptor: (Lio/vertx/core/http/impl/pool/ConnectionListener;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientImpl;Ljava/lang/Object;Lio/netty/channel/ChannelHandlerContext;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/HttpClientMetrics;)V
flags: (0x0000)
Code:
stack=4, locals=10, args_size=10
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 start local 9 0: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientImpl.getVertx:()Lio/vertx/core/impl/VertxInternal;
aload 5
aload 8
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;)V
1: aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.seq:I
2: aload 0
aload 1
putfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
3: aload 0
aload 3
putfield io.vertx.core.http.impl.Http1xClientConnection.client:Lio/vertx/core/http/impl/HttpClientImpl;
4: 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;
5: aload 0
iload 6
putfield io.vertx.core.http.impl.Http1xClientConnection.ssl:Z
6: aload 0
aload 7
putfield io.vertx.core.http.impl.Http1xClientConnection.server:Lio/vertx/core/net/SocketAddress;
7: aload 0
aload 9
putfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
8: aload 0
aload 2
putfield io.vertx.core.http.impl.Http1xClientConnection.version:Lio/vertx/core/http/HttpVersion;
9: aload 0
aload 4
putfield io.vertx.core.http.impl.Http1xClientConnection.endpointMetric:Ljava/lang/Object;
10: 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
11: return
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 12 1 listener Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
0 12 2 version Lio/vertx/core/http/HttpVersion;
0 12 3 client Lio/vertx/core/http/impl/HttpClientImpl;
0 12 4 endpointMetric Ljava/lang/Object;
0 12 5 channel Lio/netty/channel/ChannelHandlerContext;
0 12 6 ssl Z
0 12 7 server Lio/vertx/core/net/SocketAddress;
0 12 8 context Lio/vertx/core/impl/ContextInternal;
0 12 9 metrics Lio/vertx/core/spi/metrics/HttpClientMetrics;
Signature: (Lio/vertx/core/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientImpl;Ljava/lang/Object;Lio/netty/channel/ChannelHandlerContext;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/spi/metrics/HttpClientMetrics;)V
MethodParameters:
Name Flags
listener
version
client
endpointMetric
channel
ssl
server
context
metrics
java.lang.Object endpointMetric();
descriptor: ()Ljava/lang/Object;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.endpointMetric:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
io.vertx.core.http.impl.pool.ConnectionListener<io.vertx.core.http.impl.HttpClientConnection> listener();
descriptor: ()Lio/vertx/core/http/impl/pool/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/http/impl/pool/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/http/impl/pool/ConnectionListener<Lio/vertx/core/http/impl/HttpClientConnection;>;
private synchronized io.vertx.core.net.NetSocket upgrade(io.vertx.core.http.impl.Http1xClientConnection$StreamImpl);
descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)Lio/vertx/core/net/NetSocket;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=10, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isPipelining:()Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "Cannot upgrade a pipe-lined request"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.upgraded:Z
ifeq 4
3: new java.lang.IllegalStateException
dup
ldc "Request already upgraded to NetSocket"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xClientConnection.upgraded:Z
5: new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
astore 2
start local 2 6: new io.vertx.core.http.impl.Http1xClientConnection$1
dup
aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
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
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
aload 2
aload 1
invokespecial io.vertx.core.http.impl.Http1xClientConnection$1.<init>:(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;Ljava/util/concurrent/atomic/AtomicBoolean;Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)V
astore 3
start local 3 7: aload 3
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
8: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.flush:()V
9: 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 4
start local 4 10: aload 4
ldc Lio/netty/handler/codec/http/HttpContentDecompressor;
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/Class;)Lio/netty/channel/ChannelHandler;
astore 5
start local 5 11: aload 5
ifnull 13
12: aload 4
aload 5
invokeinterface io.netty.channel.ChannelPipeline.remove:(Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
13: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$StreamImpl java.util.concurrent.atomic.AtomicBoolean io.vertx.core.net.impl.NetSocketImpl io.netty.channel.ChannelPipeline io.netty.channel.ChannelHandler
StackMap stack:
aload 4
ldc "handler"
ldc "handler"
aload 3
invokestatic io.vertx.core.net.impl.VertxHandler.create:(Lio/vertx/core/net/impl/ConnectionBase;)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
14: aload 4
ldc "codec"
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
15: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 2
aload 3
invokedynamic handle(Ljava/util/concurrent/atomic/AtomicBoolean;Lio/vertx/core/net/impl/NetSocketImpl;)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/util/concurrent/atomic/AtomicBoolean;Lio/vertx/core/net/impl/NetSocketImpl;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
16: aload 3
areturn
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 17 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 17 1 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
6 17 2 paused Ljava/util/concurrent/atomic/AtomicBoolean;
7 17 3 socket Lio/vertx/core/net/impl/NetSocketImpl;
10 17 4 pipeline Lio/netty/channel/ChannelPipeline;
11 17 5 inflater Lio/netty/channel/ChannelHandler;
MethodParameters:
Name Flags
stream
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.upgraded:Z
ifne 5
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
ifeq 4
2: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()V
3: goto 5
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.recycle:()V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 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=5, locals=4, 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 12
StackMap locals: java.lang.Throwable
StackMap stack:
4: aload 1
instanceof io.netty.handler.codec.http.HttpObject
ifeq 8
5: aload 1
checkcast io.netty.handler.codec.http.HttpObject
astore 3
start local 3 6: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleHttpMessage:(Lio/netty/handler/codec/http/HttpObject;)V
end local 3 7: goto 12
StackMap locals:
StackMap stack:
8: aload 1
instanceof io.netty.handler.codec.http.websocketx.WebSocketFrame
ifeq 11
9: 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
10: goto 12
11: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Invalid object "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
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
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 13 1 msg Ljava/lang/Object;
1 13 2 error Ljava/lang/Throwable;
6 7 3 obj Lio/netty/handler/codec/http/HttpObject;
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=2, locals=4, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.handler.codec.http.HttpResponse
ifeq 3
1: aload 0
aload 1
checkcast io.netty.handler.codec.http.HttpResponse
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseBegin:(Lio/netty/handler/codec/http/HttpResponse;)V
2: goto 10
StackMap locals:
StackMap stack:
3: aload 1
instanceof io.netty.handler.codec.http.HttpContent
ifeq 10
4: aload 1
checkcast io.netty.handler.codec.http.HttpContent
astore 2
start local 2 5: aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 8
6: aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
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 7: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseChunk:(Lio/vertx/core/buffer/Buffer;)V
end local 3 8: StackMap locals: io.netty.handler.codec.http.HttpContent
StackMap stack:
aload 2
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 10
9: aload 0
aload 2
checkcast io.netty.handler.codec.http.LastHttpContent
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleResponseEnd:(Lio/netty/handler/codec/http/LastHttpContent;)V
end local 2 10: StackMap locals:
StackMap stack:
return
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 obj Lio/netty/handler/codec/http/HttpObject;
5 10 2 chunk Lio/netty/handler/codec/http/HttpContent;
7 8 3 buff Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
obj
private void handleResponseBegin(io.netty.handler.codec.http.HttpResponse);
descriptor: (Lio/netty/handler/codec/http/HttpResponse;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
bipush 100
if_icmpne 11
1: aload 0
dup
astore 3
monitorenter
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 4
start local 4 3: aload 4
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.continueHandler:Lio/vertx/core/Handler;
astore 2
end local 4 start local 2 4: aload 3
monitorexit
5: goto 8
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpResponse top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
6: aload 3
monitorexit
7: athrow
start local 2 8: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpResponse io.vertx.core.Handler
StackMap stack:
aload 2
ifnull 20
9: aload 2
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 10: goto 20
11: StackMap locals:
StackMap stack:
aload 0
dup
astore 5
monitorenter
12: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
start local 2 13: aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
astore 4
start local 4 14: aload 2
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.beginResponse:(Lio/netty/handler/codec/http/HttpResponse;)Lio/vertx/core/http/impl/HttpClientResponseImpl;
astore 3
start local 3 15: aload 5
monitorexit
16: goto 19
end local 4 end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpResponse top top top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
17: aload 5
monitorexit
18: athrow
start local 2 start local 3 start local 4 19: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.HttpResponse io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.HttpClientResponseImpl io.vertx.core.http.impl.HttpClientRequestImpl
StackMap stack:
aload 4
aload 3
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleResponse:(Lio/vertx/core/http/HttpClientResponse;)V
end local 4 end local 3 end local 2 20: StackMap locals:
StackMap stack:
return
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 resp Lio/netty/handler/codec/http/HttpResponse;
4 6 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
8 10 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
3 4 4 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
13 17 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
19 20 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
15 17 3 response Lio/vertx/core/http/impl/HttpClientResponseImpl;
19 20 3 response Lio/vertx/core/http/impl/HttpClientResponseImpl;
14 17 4 request Lio/vertx/core/http/impl/HttpClientRequestImpl;
19 20 4 request Lio/vertx/core/http/impl/HttpClientRequestImpl;
Exception table:
from to target type
2 5 6 any
6 7 6 any
12 16 17 any
17 18 17 any
MethodParameters:
Name Flags
resp
private void handleResponseChunk(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)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.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
start local 2 2: aload 3
monitorexit
3: goto 6
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.buffer.Buffer top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
4: aload 3
monitorexit
5: athrow
start local 2 6: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.buffer.Buffer io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 2
ifnull 9
7: aload 2
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.handleChunk:(Lio/vertx/core/buffer/Buffer;)Z
ifne 9
8: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doPause:()V
9: StackMap locals:
StackMap stack:
return
end local 2 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 buff Lio/vertx/core/buffer/Buffer;
2 4 2 resp Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
6 10 2 resp Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
buff
private void handleResponseEnd(io.netty.handler.codec.http.LastHttpContent);
descriptor: (Lio/netty/handler/codec/http/LastHttpContent;)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.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
start local 2 2: aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
ifnonnull 5
3: aload 3
monitorexit
4: return
5: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
putfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
6: aload 3
monitorexit
7: goto 10
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.LastHttpContent top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
8: aload 3
monitorexit
9: athrow
start local 2 10: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.LastHttpContent io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 2
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.endResponse:(Lio/netty/handler/codec/http/LastHttpContent;)Z
ifeq 12
11: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.checkLifecycle:()V
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 13 1 trailer Lio/netty/handler/codec/http/LastHttpContent;
2 8 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
10 13 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
1 4 8 any
5 7 8 any
8 9 8 any
MethodParameters:
Name Flags
trailer
private void handleRequestEnd(boolean);
descriptor: (Z)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.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
start local 2 2: aload 0
aload 2
putfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
3: aload 3
monitorexit
4: goto 7
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
5: aload 3
monitorexit
6: athrow
start local 2 7: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection int io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
iload 1
ifeq 9
8: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.recycle:()V
9: StackMap locals:
StackMap stack:
aload 2
ifnull 11
10: aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.fut:Lio/vertx/core/Promise;
aload 2
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)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 recycle Z
2 5 2 next Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
7 12 2 next Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
1 4 5 any
5 6 5 any
MethodParameters:
Name Flags
recycle
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.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(java.lang.String, io.vertx.core.MultiMap, io.vertx.core.http.WebsocketVersion, java.util.List<java.lang.String>, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.WebSocket>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/MultiMap;Lio/vertx/core/http/WebsocketVersion;Ljava/util/List;ILio/vertx/core/Handler;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=8, locals=15, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 2
1: new java.lang.IllegalStateException
dup
ldc "Already websocket"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
new java.net.URI
dup
aload 1
invokespecial java.net.URI.<init>:(Ljava/lang/String;)V
astore 7
start local 7 3: aload 7
invokevirtual java.net.URI.isAbsolute:()Z
ifne 8
4: new java.net.URI
dup
5: new java.lang.StringBuilder
dup
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ssl:Z
ifeq 6
ldc "https:"
goto 7
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler java.net.URI
StackMap stack: new 4 new 4 new 5 new 5
6: ldc "http:"
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler java.net.URI
StackMap stack: new 4 new 4 new 5 new 5 java.lang.String
7: 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 1
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 7
8: StackMap locals:
StackMap stack:
aload 3
ifnonnull 10
9: getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V13:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
goto 11
StackMap locals:
StackMap stack:
10: aload 3
StackMap locals:
StackMap stack: java.lang.Enum
11: invokevirtual java.lang.Enum.toString:()Ljava/lang/String;
12: invokestatic io.netty.handler.codec.http.websocketx.WebSocketVersion.valueOf:(Ljava/lang/String;)Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
13: astore 8
start local 8 14: aload 2
ifnull 21
15: new io.netty.handler.codec.http.DefaultHttpHeaders
dup
invokespecial io.netty.handler.codec.http.DefaultHttpHeaders.<init>:()V
astore 9
start local 9 16: aload 2
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 11
goto 19
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.HttpHeaders top java.util.Iterator
StackMap stack:
17: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 10
start local 10 18: 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 19: StackMap locals:
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 17
20: goto 22
end local 9 21: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler java.net.URI io.netty.handler.codec.http.websocketx.WebSocketVersion
StackMap stack:
aconst_null
astore 9
start local 9 22: 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 10
start local 10 23: 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 11
start local 11 24: aload 11
invokevirtual java.util.ArrayList.isEmpty:()Z
ifne 28
25: aload 10
ldc "handler"
ldc "websocketsExtensionsHandler"
new io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler
dup
26: aload 11
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
27: invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
28: StackMap locals: io.netty.channel.ChannelPipeline java.util.ArrayList
StackMap stack:
aconst_null
astore 12
start local 12 29: aload 4
ifnull 31
30: ldc ","
aload 4
invokestatic java.lang.String.join:(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Ljava/lang/String;
astore 12
31: StackMap locals: java.lang.String
StackMap stack:
aload 7
32: aload 8
33: aload 12
34: aload 11
invokevirtual java.util.ArrayList.isEmpty:()Z
ifeq 35
iconst_0
goto 36
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler 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
35: iconst_1
36: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler 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 9
37: iload 5
38: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.isSendUnmaskedFrames:()Z
ifeq 39
iconst_0
goto 40
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler 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
39: iconst_1
40: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler 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
iconst_0
41: invokestatic io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory.newHandshaker:(Ljava/net/URI;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Ljava/lang/String;ZLio/netty/handler/codec/http/HttpHeaders;IZZ)Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;
astore 13
start local 13 42: new io.vertx.core.http.impl.WebSocketHandshakeInboundHandler
dup
aload 13
aload 0
aload 8
aload 13
aload 6
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http1xClientConnection.lambda$1(Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Handler;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 14
start local 14 43: aload 10
ldc "handler"
ldc "handshakeCompleter"
aload 14
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
44: aload 13
45: 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;
46: aload 6
invokedynamic operationComplete(Lio/vertx/core/Handler;)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$4(Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V (6)
(Lio/netty/util/concurrent/Future;)V
invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
pop
end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 47: goto 50
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection java.lang.String io.vertx.core.MultiMap io.vertx.core.http.WebsocketVersion java.util.List int io.vertx.core.Handler
StackMap stack: java.lang.Exception
48: astore 7
start local 7 49: aload 0
aload 7
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleException:(Ljava/lang/Throwable;)V
end local 7 50: StackMap locals:
StackMap stack:
return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 51 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 51 1 requestURI Ljava/lang/String;
0 51 2 headers Lio/vertx/core/MultiMap;
0 51 3 vers Lio/vertx/core/http/WebsocketVersion;
0 51 4 subProtocols Ljava/util/List<Ljava/lang/String;>;
0 51 5 maxWebSocketFrameSize I
0 51 6 wsHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/WebSocket;>;>;
3 47 7 wsuri Ljava/net/URI;
14 47 8 version Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
16 21 9 nettyHeaders Lio/netty/handler/codec/http/HttpHeaders;
22 47 9 nettyHeaders Lio/netty/handler/codec/http/HttpHeaders;
18 19 10 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
23 47 10 p Lio/netty/channel/ChannelPipeline;
24 47 11 extensionHandshakers Ljava/util/ArrayList<Lio/netty/handler/codec/http/websocketx/extensions/WebSocketClientExtensionHandshaker;>;
29 47 12 subp Ljava/lang/String;
42 47 13 handshaker Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;
43 47 14 handshakeInboundHandler Lio/vertx/core/http/impl/WebSocketHandshakeInboundHandler;
49 50 7 e Ljava/lang/Exception;
Exception table:
from to target type
2 47 48 Class java.lang.Exception
Signature: (Ljava/lang/String;Lio/vertx/core/MultiMap;Lio/vertx/core/http/WebsocketVersion;Ljava/util/List<Ljava/lang/String;>;ILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/WebSocket;>;>;)V
MethodParameters:
Name Flags
requestURI
headers
vers
subProtocols
maxWebSocketFrameSize
wsHandler
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 synchronized void handleInterestedOpsChanged();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.isNotWritable:()Z
ifne 7
1: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 1
start local 1 2: aload 1
ifnull 5
3: aload 1
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleDrained:()V
4: goto 7
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 7
6: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
invokevirtual io.vertx.core.http.impl.WebSocketImpl.handleDrained:()V
end local 1 7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
2 7 1 current Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
protected void handleClosed();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=5, 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.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
ifnull 3
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.endpointMetric:Ljava/lang/Object;
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.metric:()Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.endpointDisconnected:(Ljava/lang/Object;Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
astore 2
start local 2 4: aload 0
dup
astore 3
monitorenter
5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
astore 1
start local 1 6: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 4
start local 4 7: goto 14
8: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.WebSocketImpl java.util.List io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
ifnull 10
9: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
aload 4
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.requestReset:(Ljava/lang/Object;)V
10: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.List.isEmpty:()Z
ifeq 12
11: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
12: StackMap locals:
StackMap stack:
aload 2
aload 4
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
13: aload 4
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 4
StackMap locals:
StackMap stack:
14: aload 4
ifnonnull 8
end local 4 15: aload 3
monitorexit
16: goto 19
end local 1 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection top java.util.List io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
17: aload 3
monitorexit
18: athrow
start local 1 19: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.WebSocketImpl java.util.List
StackMap stack:
aload 1
ifnull 21
20: aload 1
invokevirtual io.vertx.core.http.impl.WebSocketImpl.handleClosed:()V
21: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 24
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.WebSocketImpl java.util.List top java.util.Iterator
StackMap stack:
22: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
astore 3
start local 3 23: aload 3
getstatic io.vertx.core.http.impl.Http1xClientConnection.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.handleException:(Ljava/lang/Throwable;)V
end local 3 24: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 22
25: return
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;
6 17 1 ws Lio/vertx/core/http/impl/WebSocketImpl;
19 26 1 ws Lio/vertx/core/http/impl/WebSocketImpl;
4 26 2 list Ljava/util/List<Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;>;
7 15 4 r Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
23 24 3 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
5 16 17 any
17 18 17 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.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnonnull 4
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
ifnonnull 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 synchronized void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0024) ACC_PROTECTED, ACC_SYNCHRONIZED
Code:
stack=2, locals=3, 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
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 4
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aload 1
invokevirtual io.vertx.core.http.impl.WebSocketImpl.handleException:(Ljava/lang/Throwable;)V
3: goto 9
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
start local 2 5: goto 8
6: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 2
aload 1
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.handleException:(Ljava/lang/Throwable;)V
7: aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
astore 2
StackMap locals:
StackMap stack:
8: aload 2
ifnonnull 6
end local 2 9: StackMap locals:
StackMap stack:
return
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 e Ljava/lang/Throwable;
5 9 2 r Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
MethodParameters:
Name Flags
e
public void createStream(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientStream>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: new io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
dup
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
aload 1
invokespecial io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.<init>:(Lio/vertx/core/http/impl/Http1xClientConnection;ILio/vertx/core/Handler;)V
astore 2
start local 2 2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
ifnull 6
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
aload 2
invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.append:(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)V
4: aload 3
monitorexit
5: return
6: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.Http1xClientConnection
StackMap stack:
aload 0
aload 2
putfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
7: aload 3
monitorexit
8: goto 11
end local 2 StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.Handler top io.vertx.core.http.impl.Http1xClientConnection
StackMap stack: java.lang.Throwable
9: aload 3
monitorexit
10: athrow
start local 2 11: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.Handler io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
StackMap stack:
aload 2
getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.fut:Lio/vertx/core/Promise;
aload 2
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
12: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 13 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;
2 9 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
11 13 2 stream Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
Exception table:
from to target type
1 5 9 any
6 8 9 any
9 10 9 any
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;)V
MethodParameters:
Name Flags
handler
private void recycle();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
ifne 1
lconst_0
goto 2
StackMap locals:
StackMap stack:
1: invokestatic java.lang.System.currentTimeMillis:()J
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
sipush 1000
imul
i2l
ladd
StackMap locals:
StackMap stack: long
2: lstore 1
start local 1 3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.listener:Lio/vertx/core/http/impl/pool/ConnectionListener;
lload 1
invokeinterface io.vertx.core.http.impl.pool.ConnectionListener.onRecycle:(J)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
3 5 1 expiration J
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
static io.vertx.core.impl.ContextInternal access$1(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.util.concurrent.atomic.AtomicBoolean, io.vertx.core.net.impl.NetSocketImpl, java.lang.Void);
descriptor: (Ljava/util/concurrent/atomic/AtomicBoolean;Lio/vertx/core/net/impl/NetSocketImpl;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=3, args_size=3
start local 2 0: aload 0
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifne 2
1: aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.resume:()Lio/vertx/core/net/NetSocket;
pop
2: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 v Ljava/lang/Void;
private void lambda$1(io.netty.handler.codec.http.websocketx.WebSocketVersion, io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 4 0: aload 4
aload 0
aload 1
aload 2
invokedynamic apply(Lio/vertx/core/http/impl/Http1xClientConnection;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$2(Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Ljava/lang/Void;)Lio/vertx/core/http/WebSocket; (7)
(Ljava/lang/Void;)Lio/vertx/core/http/WebSocket;
invokeinterface io.vertx.core.AsyncResult.map:(Ljava/util/function/Function;)Lio/vertx/core/AsyncResult;
astore 5
start local 5 1: aload 4
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 4
2: aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()V
3: goto 6
4: StackMap locals: io.vertx.core.AsyncResult
StackMap stack:
aload 0
aload 5
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.http.impl.WebSocketImpl
putfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
5: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws: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:
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.getContext:()Lio/vertx/core/impl/ContextInternal;
aload 5
aload 0
aload 3
invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/http/impl/Http1xClientConnection.lambda$3(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeFromIO:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
end local 5 7: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 8 4 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
1 7 5 wsRes Lio/vertx/core/AsyncResult<Lio/vertx/core/http/WebSocket;>;
private static void lambda$4(io.vertx.core.Handler, io.netty.util.concurrent.Future);
descriptor: (Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
invokeinterface io.netty.util.concurrent.Future.isSuccess:()Z
ifne 2
1: aload 0
aload 1
invokeinterface io.netty.util.concurrent.Future.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 f Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
private io.vertx.core.http.WebSocket lambda$2(io.netty.handler.codec.http.websocketx.WebSocketVersion, io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, java.lang.Void);
descriptor: (Lio/netty/handler/codec/http/websocketx/WebSocketVersion;Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;Ljava/lang/Void;)Lio/vertx/core/http/WebSocket;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 3 0: new io.vertx.core.http.impl.WebSocketImpl
dup
aload 0
aload 1
getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V00:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
if_acmpeq 1
iconst_1
goto 2
StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker java.lang.Void
StackMap stack: new 0 new 0 io.vertx.core.http.impl.Http1xClientConnection
1: iconst_0
2: StackMap locals: io.vertx.core.http.impl.Http1xClientConnection io.netty.handler.codec.http.websocketx.WebSocketVersion io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker java.lang.Void
StackMap stack: new 0 new 0 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.getMaxWebsocketFrameSize:()I
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
invokevirtual io.vertx.core.http.HttpClientOptions.getMaxWebsocketMessageSize:()I
4: invokespecial io.vertx.core.http.impl.WebSocketImpl.<init>:(Lio/vertx/core/http/impl/Http1xClientConnection;ZII)V
astore 4
start local 4 5: aload 4
aload 2
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker.actualSubprotocol:()Ljava/lang/String;
invokevirtual io.vertx.core.http.impl.WebSocketImpl.subProtocol:(Ljava/lang/String;)V
6: aload 4
areturn
end local 4 end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 7 3 v Ljava/lang/Void;
5 7 4 w Lio/vertx/core/http/impl/WebSocketImpl;
private void lambda$3(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: getstatic io.vertx.core.http.impl.Http1xClientConnection.log:Lio/vertx/core/logging/Logger;
ldc "WebSocket handshake complete"
invokevirtual io.vertx.core.logging.Logger.debug:(Ljava/lang/Object;)V
2: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
ifnull 4
3: aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.WebSocketImpl
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.endpointMetric:Ljava/lang/Object;
aload 0
invokevirtual io.vertx.core.http.impl.Http1xClientConnection.metric:()Ljava/lang/Object;
aload 0
getfield io.vertx.core.http.impl.Http1xClientConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.WebSocket
invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.connected:(Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/http/WebSocket;)Ljava/lang/Object;
invokevirtual io.vertx.core.http.impl.WebSocketImpl.setMetric:(Ljava/lang/Object;)V
4: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/http/impl/Http1xClientConnection;
0 6 2 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$1 io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
InnerClasses:
io.vertx.core.http.impl.Http1xClientConnection$1
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 abstract Entry = java.util.Map$Entry of java.util.Map
Http1xClientConnection
log: Logger
handleMessage(Object): 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)