public class io.reactiverse.pgclient.impl.SocketConnection implements io.reactiverse.pgclient.impl.Connection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.reactiverse.pgclient.impl.SocketConnection
super_class: java.lang.Object
{
private static final io.vertx.core.logging.Logger logger;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.impl.NetSocketInternal socket;
descriptor: Lio/vertx/core/impl/NetSocketInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.ArrayDeque<io.reactiverse.pgclient.impl.CommandBase<?>> inflight;
descriptor: Ljava/util/ArrayDeque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/ArrayDeque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
private final java.util.ArrayDeque<io.reactiverse.pgclient.impl.CommandBase<?>> pending;
descriptor: Ljava/util/ArrayDeque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/ArrayDeque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
private final io.vertx.core.Context context;
descriptor: Lio/vertx/core/Context;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.reactiverse.pgclient.impl.SocketConnection$Status status;
descriptor: Lio/reactiverse/pgclient/impl/SocketConnection$Status;
flags: (0x0002) ACC_PRIVATE
private io.reactiverse.pgclient.impl.Connection$Holder holder;
descriptor: Lio/reactiverse/pgclient/impl/Connection$Holder;
flags: (0x0002) ACC_PRIVATE
private final java.util.Map<java.lang.String, io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement> psCache;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;>;
private final io.reactiverse.pgclient.impl.StringLongSequence psSeq;
descriptor: Lio/reactiverse/pgclient/impl/StringLongSequence;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int pipeliningLimit;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder decoder;
descriptor: Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
flags: (0x0002) ACC_PRIVATE
private io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder encoder;
descriptor: Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
flags: (0x0002) ACC_PRIVATE
int processId;
descriptor: I
flags: (0x0000)
int secretKey;
descriptor: I
flags: (0x0000)
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/reactiverse/pgclient/impl/SocketConnection;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.reactiverse.pgclient.impl.SocketConnection.logger:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.impl.NetSocketInternal, boolean, int, io.vertx.core.Context);
descriptor: (Lio/vertx/core/impl/NetSocketInternal;ZILio/vertx/core/Context;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
2: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.reactiverse.pgclient.impl.SocketConnection.pending:Ljava/util/ArrayDeque;
3: aload 0
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CONNECTED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
putfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
4: aload 0
new io.reactiverse.pgclient.impl.StringLongSequence
dup
invokespecial io.reactiverse.pgclient.impl.StringLongSequence.<init>:()V
putfield io.reactiverse.pgclient.impl.SocketConnection.psSeq:Lio/reactiverse/pgclient/impl/StringLongSequence;
5: aload 0
aload 1
putfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
6: aload 0
aload 4
putfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
7: aload 0
iload 2
ifeq 8
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
goto 9
StackMap locals: io.reactiverse.pgclient.impl.SocketConnection io.vertx.core.impl.NetSocketInternal int int io.vertx.core.Context
StackMap stack: io.reactiverse.pgclient.impl.SocketConnection
8: aconst_null
StackMap locals: io.reactiverse.pgclient.impl.SocketConnection io.vertx.core.impl.NetSocketInternal int int io.vertx.core.Context
StackMap stack: io.reactiverse.pgclient.impl.SocketConnection java.util.concurrent.ConcurrentHashMap
9: putfield io.reactiverse.pgclient.impl.SocketConnection.psCache:Ljava/util/Map;
10: aload 0
iload 3
putfield io.reactiverse.pgclient.impl.SocketConnection.pipeliningLimit:I
11: return
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/reactiverse/pgclient/impl/SocketConnection;
0 12 1 socket Lio/vertx/core/impl/NetSocketInternal;
0 12 2 cachePreparedStatements Z
0 12 3 pipeliningLimit I
0 12 4 context Lio/vertx/core/Context;
MethodParameters:
Name Flags
socket
cachePreparedStatements
pipeliningLimit
context
public io.vertx.core.Context context();
descriptor: ()Lio/vertx/core/Context;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
void upgradeToSSLConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=7, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 2
start local 2 1: invokestatic io.vertx.core.Future.future:()Lio/vertx/core/Future;
astore 3
start local 3 2: aload 3
aload 1
invokedynamic handle(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/reactiverse/pgclient/impl/SocketConnection.lambda$0(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: aload 2
ldc "handler"
ldc "initiate-ssl-handler"
new io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler
dup
aload 0
aload 3
invokespecial io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.<init>:(Lio/reactiverse/pgclient/impl/SocketConnection;Lio/vertx/core/Future;)V
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 5 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 5 2 pipeline Lio/netty/channel/ChannelPipeline;
2 5 3 upgradeFuture Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
void initializeCodec();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
new io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder
dup
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
invokespecial io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.<init>:(Ljava/util/Deque;Lio/netty/buffer/ByteBufAllocator;)V
putfield io.reactiverse.pgclient.impl.SocketConnection.decoder:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
1: aload 0
new io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder
dup
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokespecial io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.<init>:(Lio/netty/channel/ChannelHandlerContext;)V
putfield io.reactiverse.pgclient.impl.SocketConnection.encoder:Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
2: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 1
start local 1 3: aload 1
ldc "handler"
ldc "decoder"
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.decoder:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
4: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/reactiverse/pgclient/impl/SocketConnection;)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/reactiverse/pgclient/impl/SocketConnection.handleClosed(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
5: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/reactiverse/pgclient/impl/SocketConnection;)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/reactiverse/pgclient/impl/SocketConnection.handleException(Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.impl.NetSocketInternal.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
6: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/reactiverse/pgclient/impl/SocketConnection;)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/reactiverse/pgclient/impl/SocketConnection.lambda$3(Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.impl.NetSocketInternal.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
pop
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
3 8 1 pipeline Lio/netty/channel/ChannelPipeline;
void sendStartupMessage(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.Handler<? super io.reactiverse.pgclient.impl.CommandResponse<io.reactiverse.pgclient.impl.Connection>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new io.reactiverse.pgclient.impl.InitCommand
dup
aload 0
aload 1
aload 2
aload 3
invokespecial io.reactiverse.pgclient.impl.InitCommand.<init>:(Lio/reactiverse/pgclient/impl/SocketConnection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
astore 5
start local 5 1: aload 5
aload 4
putfield io.reactiverse.pgclient.impl.InitCommand.handler:Lio/vertx/core/Handler;
2: aload 0
aload 5
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.schedule:(Lio/reactiverse/pgclient/impl/CommandBase;)V
3: 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 4 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 4 1 username Ljava/lang/String;
0 4 2 password Ljava/lang/String;
0 4 3 database Ljava/lang/String;
0 4 4 completionHandler Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<Lio/reactiverse/pgclient/impl/Connection;>;>;
1 4 5 cmd Lio/reactiverse/pgclient/impl/InitCommand;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<Lio/reactiverse/pgclient/impl/Connection;>;>;)V
MethodParameters:
Name Flags
username
password
database
completionHandler
void sendCancelRequestMessage(int, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (IILio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: bipush 16
invokestatic io.vertx.core.buffer.Buffer.buffer:(I)Lio/vertx/core/buffer/Buffer;
astore 4
start local 4 1: aload 4
bipush 16
invokeinterface io.vertx.core.buffer.Buffer.appendInt:(I)Lio/vertx/core/buffer/Buffer;
pop
2: aload 4
ldc 80877102
invokeinterface io.vertx.core.buffer.Buffer.appendInt:(I)Lio/vertx/core/buffer/Buffer;
pop
3: aload 4
iload 1
invokeinterface io.vertx.core.buffer.Buffer.appendInt:(I)Lio/vertx/core/buffer/Buffer;
pop
4: aload 4
iload 2
invokeinterface io.vertx.core.buffer.Buffer.appendInt:(I)Lio/vertx/core/buffer/Buffer;
pop
5: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
aload 4
aload 0
aload 3
invokedynamic handle(Lio/reactiverse/pgclient/impl/SocketConnection;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/reactiverse/pgclient/impl/SocketConnection.lambda$4(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.impl.NetSocketInternal.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
6: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 7 1 processId I
0 7 2 secretKey I
0 7 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 7 4 buffer Lio/vertx/core/buffer/Buffer;
Signature: (IILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
processId
secretKey
handler
public io.vertx.core.impl.NetSocketInternal socket();
descriptor: ()Lio/vertx/core/impl/NetSocketInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
public boolean isSsl();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.isSsl:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
public void init(io.reactiverse.pgclient.impl.Connection$Holder);
descriptor: (Lio/reactiverse/pgclient/impl/Connection$Holder;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 2 1 holder Lio/reactiverse/pgclient/impl/Connection$Holder;
MethodParameters:
Name Flags
holder
public void close(io.reactiverse.pgclient.impl.Connection$Holder);
descriptor: (Lio/reactiverse/pgclient/impl/Connection$Holder;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
if_acmpne 6
1: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CONNECTED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
if_acmpne 7
2: aload 0
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CLOSING:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
putfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
3: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pending:Ljava/util/ArrayDeque;
getstatic io.reactiverse.pgclient.impl.CloseConnectionCommand.INSTANCE:Lio/reactiverse/pgclient/impl/CloseConnectionCommand;
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
4: aload 0
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.checkPending:()V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
aload 0
aload 1
invokedynamic handle(Lio/reactiverse/pgclient/impl/SocketConnection;Lio/reactiverse/pgclient/impl/Connection$Holder;)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/reactiverse/pgclient/impl/SocketConnection.lambda$5(Lio/reactiverse/pgclient/impl/Connection$Holder;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 8 1 holder Lio/reactiverse/pgclient/impl/Connection$Holder;
MethodParameters:
Name Flags
holder
public void schedule(io.reactiverse.pgclient.impl.CommandBase<?>);
descriptor: (Lio/reactiverse/pgclient/impl/CommandBase;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=2
start local 0 start local 1 0: aload 1
getfield io.reactiverse.pgclient.impl.CommandBase.handler:Lio/vertx/core/Handler;
ifnonnull 2
1: new java.lang.IllegalArgumentException
dup
invokespecial java.lang.IllegalArgumentException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
if_acmpeq 4
3: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
4: StackMap locals:
StackMap stack:
aload 1
instanceof io.reactiverse.pgclient.impl.PrepareStatementCommand
ifeq 19
5: aload 1
checkcast io.reactiverse.pgclient.impl.PrepareStatementCommand
astore 2
start local 2 6: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.psCache:Ljava/util/Map;
astore 3
start local 3 7: aload 3
ifnull 19
8: aload 3
aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.sql:Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement
astore 4
start local 4 9: aload 4
ifnull 13
10: aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.handler:Lio/vertx/core/Handler;
astore 5
start local 5 11: aload 4
aload 5
invokevirtual io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement.get:(Lio/vertx/core/Handler;)V
12: return
end local 5 13: StackMap locals: io.reactiverse.pgclient.impl.PrepareStatementCommand java.util.Map io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement
StackMap stack:
aload 2
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.psSeq:Lio/reactiverse/pgclient/impl/StringLongSequence;
invokevirtual io.reactiverse.pgclient.impl.StringLongSequence.next:()J
putfield io.reactiverse.pgclient.impl.PrepareStatementCommand.statement:J
14: aload 2
new io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement
dup
invokespecial io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement.<init>:()V
dup
astore 4
putfield io.reactiverse.pgclient.impl.PrepareStatementCommand.cached:Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;
15: aload 3
aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.sql:Ljava/lang/String;
aload 4
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
16: aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.handler:Lio/vertx/core/Handler;
astore 5
start local 5 17: aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.cached:Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;
aload 5
invokevirtual io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement.get:(Lio/vertx/core/Handler;)V
18: aload 2
aload 2
getfield io.reactiverse.pgclient.impl.PrepareStatementCommand.cached:Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;
putfield io.reactiverse.pgclient.impl.PrepareStatementCommand.handler:Lio/vertx/core/Handler;
end local 5 end local 4 end local 3 end local 2 19: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CONNECTED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
if_acmpne 23
20: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pending:Ljava/util/ArrayDeque;
aload 1
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
21: aload 0
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.checkPending:()V
22: goto 24
23: StackMap locals:
StackMap stack:
aload 1
new io.vertx.core.VertxException
dup
new java.lang.StringBuilder
dup
ldc "Connection not open "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactiverse.pgclient.impl.CommandBase.fail:(Ljava/lang/Throwable;)V
24: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 25 1 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
6 19 2 psCmd Lio/reactiverse/pgclient/impl/PrepareStatementCommand;
7 19 3 psCache Ljava/util/Map<Ljava/lang/String;Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;>;
9 19 4 cached Lio/reactiverse/pgclient/impl/SocketConnection$CachedPreparedStatement;
11 13 5 handler Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<Lio/reactiverse/pgclient/impl/PreparedStatement;>;>;
17 19 5 a Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<Lio/reactiverse/pgclient/impl/PreparedStatement;>;>;
Signature: (Lio/reactiverse/pgclient/impl/CommandBase<*>;)V
MethodParameters:
Name Flags
cmd
public int getProcessId();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.processId:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
public int getSecretKey();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.secretKey:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
private void checkPending();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pipeliningLimit:I
if_icmpge 8
1: goto 5
start local 1 2: StackMap locals: io.reactiverse.pgclient.impl.CommandBase
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
aload 1
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
3: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.decoder:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.run:(Lio/reactiverse/pgclient/impl/CommandBase;)V
4: aload 1
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.encoder:Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
invokevirtual io.reactiverse.pgclient.impl.CommandBase.exec:(Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;)V
end local 1 5: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pipeliningLimit:I
if_icmpge 7
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pending:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
dup
astore 1
start local 1 6: ifnonnull 2
end local 1 7: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.encoder:Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.flush:()V
8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
2 5 1 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
6 7 1 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
private void handleMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.reactiverse.pgclient.impl.CommandResponse
ifeq 5
1: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
astore 2
start local 2 2: aload 0
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.checkPending:()V
3: aload 2
getfield io.reactiverse.pgclient.impl.CommandBase.handler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 4: goto 10
StackMap locals:
StackMap stack:
5: aload 1
instanceof io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse
ifeq 8
6: aload 0
aload 1
checkcast io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleNotification:(Lio/reactiverse/pgclient/impl/codec/decoder/NotificationResponse;)V
7: goto 10
StackMap locals:
StackMap stack:
8: aload 1
instanceof io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse
ifeq 10
9: aload 0
aload 1
checkcast io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleNotice:(Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
10: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 11 1 msg Ljava/lang/Object;
2 4 2 cmd Lio/reactiverse/pgclient/impl/CommandBase;
MethodParameters:
Name Flags
msg
private void handleNotification(io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse);
descriptor: (Lio/reactiverse/pgclient/impl/codec/decoder/NotificationResponse;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 2
1: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse.getProcessId:()I
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse.getChannel:()Ljava/lang/String;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse.getPayload:()Ljava/lang/String;
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleNotification:(ILjava/lang/String;Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 3 1 response Lio/reactiverse/pgclient/impl/codec/decoder/NotificationResponse;
MethodParameters:
Name Flags
response
private void handleNotice(io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse);
descriptor: (Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic io.reactiverse.pgclient.impl.SocketConnection.logger:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Backend notice: severity='"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getSeverity:()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;
2: ldc ", code='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getCode:()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;
3: ldc ", message='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getMessage:()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;
4: ldc ", detail='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getDetail:()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;
5: ldc ", hint='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getHint:()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;
6: ldc ", position='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getPosition:()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;
7: ldc ", internalPosition='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getInternalPosition:()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;
8: ldc ", internalQuery='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getInternalQuery:()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;
9: ldc ", where='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getWhere:()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;
10: ldc ", file='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getFile:()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;
11: ldc ", line='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getLine:()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;
12: ldc ", routine='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getRoutine:()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;
13: ldc ", schema='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getSchema:()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;
14: ldc ", table='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getTable:()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;
15: ldc ", column='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getColumn:()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;
16: ldc ", dataType='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getDataType:()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;
17: ldc ", constraint='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.getConstraint:()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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
18: invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;)V
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 20 1 notice Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;
MethodParameters:
Name Flags
notice
private void handleClosed(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aconst_null
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleClose:(Ljava/lang/Throwable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 2 1 v Ljava/lang/Void;
MethodParameters:
Name Flags
v
private synchronized void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.handler.codec.DecoderException
ifeq 3
1: aload 1
checkcast io.netty.handler.codec.DecoderException
astore 2
start local 2 2: aload 2
invokevirtual io.netty.handler.codec.DecoderException.getCause:()Ljava/lang/Throwable;
astore 1
end local 2 3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleClose:(Ljava/lang/Throwable;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 5 1 t Ljava/lang/Throwable;
2 3 2 err Lio/netty/handler/codec/DecoderException;
MethodParameters:
Name Flags
t
private void handleClose(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CLOSED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
if_acmpeq 23
1: aload 0
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CLOSED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
putfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
2: aload 1
ifnull 10
3: aload 0
dup
astore 2
monitorenter
4: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 6
5: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
aload 1
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleException:(Ljava/lang/Throwable;)V
6: StackMap locals: io.reactiverse.pgclient.impl.SocketConnection
StackMap stack:
aload 2
monitorexit
7: goto 10
StackMap locals:
StackMap stack: java.lang.Throwable
8: aload 2
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
aload 1
ifnonnull 11
new io.vertx.core.VertxException
dup
ldc "closed"
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
goto 12
StackMap locals:
StackMap stack:
11: aload 1
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 2
start local 2 13: iconst_2
anewarray java.util.ArrayDeque
dup
iconst_0
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.inflight:Ljava/util/ArrayDeque;
aastore
dup
iconst_1
aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.pending:Ljava/util/ArrayDeque;
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 20
StackMap locals: io.reactiverse.pgclient.impl.SocketConnection java.lang.Throwable java.lang.Throwable top java.util.Iterator
StackMap stack:
14: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.ArrayDeque
astore 3
start local 3 15: goto 18
start local 5 16: StackMap locals: io.reactiverse.pgclient.impl.SocketConnection java.lang.Throwable java.lang.Throwable java.util.ArrayDeque java.util.Iterator io.reactiverse.pgclient.impl.CommandBase
StackMap stack:
aload 5
astore 6
start local 6 17: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.context:Lio/vertx/core/Context;
aload 6
aload 2
invokedynamic handle(Lio/reactiverse/pgclient/impl/CommandBase;Ljava/lang/Throwable;)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/reactiverse/pgclient/impl/SocketConnection.lambda$6(Lio/reactiverse/pgclient/impl/CommandBase;Ljava/lang/Throwable;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
end local 6 end local 5 18: StackMap locals:
StackMap stack:
aload 3
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
dup
astore 5
start local 5 19: ifnonnull 16
end local 5 end local 3 20: StackMap locals: io.reactiverse.pgclient.impl.SocketConnection java.lang.Throwable java.lang.Throwable top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
21: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 23
22: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleClosed:()V
end local 2 23: StackMap locals: io.reactiverse.pgclient.impl.SocketConnection java.lang.Throwable
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 24 1 t Ljava/lang/Throwable;
13 23 2 cause Ljava/lang/Throwable;
15 20 3 q Ljava/util/ArrayDeque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
16 18 5 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
19 20 5 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
17 18 6 c Lio/reactiverse/pgclient/impl/CommandBase<*>;
Exception table:
from to target type
4 7 8 any
8 9 8 any
MethodParameters:
Name Flags
t
private static void lambda$0(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 8
3: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
astore 2
start local 2 4: aload 2
instanceof io.netty.handler.codec.DecoderException
ifeq 7
5: aload 2
checkcast io.netty.handler.codec.DecoderException
astore 3
start local 3 6: aload 3
invokevirtual io.netty.handler.codec.DecoderException.getCause:()Ljava/lang/Throwable;
astore 2
end local 3 7: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
aload 2
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 2 8: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 9 1 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
4 8 2 cause Ljava/lang/Throwable;
6 7 3 err Lio/netty/handler/codec/DecoderException;
private void lambda$3(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleMessage:(Ljava/lang/Object;)V
1: goto 4
StackMap locals:
StackMap stack: java.lang.Exception
2: astore 2
start local 2 3: aload 0
aload 2
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.handleException:(Ljava/lang/Throwable;)V
end local 2 4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 5 1 msg Ljava/lang/Object;
3 4 2 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.lang.Exception
private void lambda$4(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=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CONNECTED:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
if_acmpne 4
2: aload 0
getstatic io.reactiverse.pgclient.impl.SocketConnection$Status.CLOSING:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
putfield io.reactiverse.pgclient.impl.SocketConnection.status:Lio/reactiverse/pgclient/impl/SocketConnection$Status;
3: aload 0
getfield io.reactiverse.pgclient.impl.SocketConnection.socket:Lio/vertx/core/impl/NetSocketInternal;
invokeinterface io.vertx.core.impl.NetSocketInternal.close:()V
4: StackMap locals:
StackMap stack:
aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.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
7: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 8 2 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$5(io.reactiverse.pgclient.impl.Connection$Holder, java.lang.Void);
descriptor: (Lio/reactiverse/pgclient/impl/Connection$Holder;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.close:(Lio/reactiverse/pgclient/impl/Connection$Holder;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/SocketConnection;
0 1 2 v Ljava/lang/Void;
private static void lambda$6(io.reactiverse.pgclient.impl.CommandBase, java.lang.Throwable, java.lang.Void);
descriptor: (Lio/reactiverse/pgclient/impl/CommandBase;Ljava/lang/Throwable;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokevirtual io.reactiverse.pgclient.impl.CommandBase.fail:(Ljava/lang/Throwable;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 v Ljava/lang/Void;
}
SourceFile: "SocketConnection.java"
NestMembers:
io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement io.reactiverse.pgclient.impl.SocketConnection$Status
InnerClasses:
public abstract Holder = io.reactiverse.pgclient.impl.Connection$Holder of io.reactiverse.pgclient.impl.Connection
CachedPreparedStatement = io.reactiverse.pgclient.impl.SocketConnection$CachedPreparedStatement of io.reactiverse.pgclient.impl.SocketConnection
final Status = io.reactiverse.pgclient.impl.SocketConnection$Status of io.reactiverse.pgclient.impl.SocketConnection
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles