public abstract class io.vertx.sqlclient.impl.SocketConnectionBase implements io.vertx.sqlclient.impl.Connection
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.vertx.sqlclient.impl.SocketConnectionBase
super_class: java.lang.Object
{
protected static final io.vertx.core.impl.logging.Logger logger;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
private static final java.lang.String PENDING_CMD_CONNECTION_CORRUPT_MSG;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "Pending requests failed to be sent due to connection has been closed."
protected final io.vertx.sqlclient.impl.cache.PreparedStatementCache psCache;
descriptor: Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
private final java.util.function.Predicate<java.lang.String> preparedStatementCacheSqlFilter;
descriptor: Ljava/util/function/Predicate;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Predicate<Ljava/lang/String;>;
private final io.vertx.core.impl.ContextInternal context;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.sqlclient.impl.Connection$Holder holder;
descriptor: Lio/vertx/sqlclient/impl/Connection$Holder;
flags: (0x0002) ACC_PRIVATE
private final int pipeliningLimit;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.ArrayDeque<io.vertx.sqlclient.impl.command.CommandBase<?>> pending;
descriptor: Ljava/util/ArrayDeque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/ArrayDeque<Lio/vertx/sqlclient/impl/command/CommandBase<*>;>;
private boolean executing;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int inflight;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean paused;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
protected final io.vertx.core.net.impl.NetSocketInternal socket;
descriptor: Lio/vertx/core/net/impl/NetSocketInternal;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected io.vertx.sqlclient.impl.SocketConnectionBase$Status status;
descriptor: Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
flags: (0x0004) ACC_PROTECTED
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/sqlclient/impl/SocketConnectionBase;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic io.vertx.sqlclient.impl.SocketConnectionBase.$assertionsDisabled:Z
3: ldc Lio/vertx/sqlclient/impl/SocketConnectionBase;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.sqlclient.impl.SocketConnectionBase.logger:Lio/vertx/core/impl/logging/Logger;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.net.impl.NetSocketInternal, boolean, int, java.util.function.Predicate<java.lang.String>, int, io.vertx.core.impl.ContextInternal);
descriptor: (Lio/vertx/core/net/impl/NetSocketInternal;ZILjava/util/function/Predicate;ILio/vertx/core/impl/ContextInternal;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.sqlclient.impl.SocketConnectionBase.pending:Ljava/util/ArrayDeque;
2: aload 0
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CONNECTED:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
putfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
3: aload 0
aload 1
putfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
4: aload 0
aload 6
putfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
5: aload 0
iload 5
putfield io.vertx.sqlclient.impl.SocketConnectionBase.pipeliningLimit:I
6: aload 0
iconst_0
putfield io.vertx.sqlclient.impl.SocketConnectionBase.paused:Z
7: aload 0
iload 2
ifeq 8
new io.vertx.sqlclient.impl.cache.PreparedStatementCache
dup
iload 3
invokespecial io.vertx.sqlclient.impl.cache.PreparedStatementCache.<init>:(I)V
goto 9
StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase io.vertx.core.net.impl.NetSocketInternal int int java.util.function.Predicate int io.vertx.core.impl.ContextInternal
StackMap stack: io.vertx.sqlclient.impl.SocketConnectionBase
8: aconst_null
StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase io.vertx.core.net.impl.NetSocketInternal int int java.util.function.Predicate int io.vertx.core.impl.ContextInternal
StackMap stack: io.vertx.sqlclient.impl.SocketConnectionBase io.vertx.sqlclient.impl.cache.PreparedStatementCache
9: putfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
10: aload 0
aload 4
putfield io.vertx.sqlclient.impl.SocketConnectionBase.preparedStatementCacheSqlFilter:Ljava/util/function/Predicate;
11: 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 12 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 12 1 socket Lio/vertx/core/net/impl/NetSocketInternal;
0 12 2 cachePreparedStatements Z
0 12 3 preparedStatementCacheSize I
0 12 4 preparedStatementCacheSqlFilter Ljava/util/function/Predicate<Ljava/lang/String;>;
0 12 5 pipeliningLimit I
0 12 6 context Lio/vertx/core/impl/ContextInternal;
Signature: (Lio/vertx/core/net/impl/NetSocketInternal;ZILjava/util/function/Predicate<Ljava/lang/String;>;ILio/vertx/core/impl/ContextInternal;)V
MethodParameters:
Name Flags
socket
cachePreparedStatements
preparedStatementCacheSize
preparedStatementCacheSqlFilter
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.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
public void init();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;)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/sqlclient/impl/SocketConnectionBase.handleClosed(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;)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/sqlclient/impl/SocketConnectionBase.handleException(Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
2: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
aload 0
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;)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/sqlclient/impl/SocketConnectionBase.lambda$2(Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
pop
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
public io.vertx.core.net.impl.NetSocketInternal socket();
descriptor: ()Lio/vertx/core/net/impl/NetSocketInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
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.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
invokeinterface io.vertx.core.net.impl.NetSocketInternal.isSsl:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
public void init(io.vertx.sqlclient.impl.Connection$Holder);
descriptor: (Lio/vertx/sqlclient/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.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 2 1 holder Lio/vertx/sqlclient/impl/Connection$Holder;
MethodParameters:
Name Flags
holder
public int getProcessId();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: new java.lang.UnsupportedOperationException
dup
invokespecial java.lang.UnsupportedOperationException.<init>:()V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
public int getSecretKey();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: new java.lang.UnsupportedOperationException
dup
invokespecial java.lang.UnsupportedOperationException.<init>:()V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
public void close(io.vertx.sqlclient.impl.Connection$Holder, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
if_acmpne 10
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CONNECTED:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
if_acmpne 11
2: aload 0
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CLOSING:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
putfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
3: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
4: invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
5: invokeinterface io.netty.channel.Channel.closeFuture:()Lio/netty/channel/ChannelFuture;
6: aload 2
invokedynamic operationComplete(Lio/vertx/core/Promise;)Lio/netty/channel/ChannelFutureListener;
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/sqlclient/impl/SocketConnectionBase.lambda$3(Lio/vertx/core/Promise;Lio/netty/channel/ChannelFuture;)V (6)
(Lio/netty/channel/ChannelFuture;)V
invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
pop
7: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.pending:Ljava/util/ArrayDeque;
getstatic io.vertx.sqlclient.impl.command.CloseConnectionCommand.INSTANCE:Lio/vertx/sqlclient/impl/command/CloseConnectionCommand;
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
8: aload 0
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.checkPending:()V
9: goto 11
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/sqlclient/impl/SocketConnectionBase.lambda$4(Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)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/sqlclient/impl/SocketConnectionBase;
0 12 1 holder Lio/vertx/sqlclient/impl/Connection$Holder;
0 12 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
holder
promise
public <R> void schedule(io.vertx.sqlclient.impl.command.CommandBase<R>, io.vertx.core.Promise<R>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/sqlclient/impl/SocketConnectionBase.lambda$5(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.emit:(Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 2 1 cmd Lio/vertx/sqlclient/impl/command/CommandBase<TR;>;
0 2 2 promise Lio/vertx/core/Promise<TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/vertx/sqlclient/impl/command/CommandBase<TR;>;Lio/vertx/core/Promise<TR;>;)V
MethodParameters:
Name Flags
cmd
promise
protected <R> void doSchedule(io.vertx.sqlclient.impl.command.CommandBase<R>, io.vertx.core.Handler<io.vertx.core.AsyncResult<R>>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Handler;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
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;
astore 3
start local 3 3: aload 3
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
if_acmpeq 5
4: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
5: StackMap locals: io.vertx.core.Context
StackMap stack:
aload 1
aload 2
putfield io.vertx.sqlclient.impl.command.CommandBase.handler:Lio/vertx/core/Handler;
6: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CONNECTED:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
if_acmpne 10
7: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.pending:Ljava/util/ArrayDeque;
aload 1
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
8: aload 0
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.checkPending:()V
9: goto 11
10: 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.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$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.vertx.sqlclient.impl.command.CommandBase.fail:(Ljava/lang/Throwable;)V
11: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 12 1 cmd Lio/vertx/sqlclient/impl/command/CommandBase<TR;>;
0 12 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;
3 12 3 context Lio/vertx/core/Context;
Signature: <R:Ljava/lang/Object;>(Lio/vertx/sqlclient/impl/command/CommandBase<TR;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;)V
MethodParameters:
Name Flags
cmd
handler
private void checkPending();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=8, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.executing:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.vertx.sqlclient.impl.SocketConnectionBase.executing:Z
3: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
astore 1
start local 1 4: iconst_0
istore 2
start local 2 5: goto 34
start local 3 6: StackMap locals: io.netty.channel.ChannelHandlerContext int io.vertx.sqlclient.impl.command.CommandBase
StackMap stack:
aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
iadd
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
7: aload 3
instanceof io.vertx.sqlclient.impl.command.ExtendedQueryCommand
ifeq 32
8: aload 3
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
astore 4
start local 4 9: aload 4
getfield io.vertx.sqlclient.impl.command.ExtendedQueryCommand.ps:Lio/vertx/sqlclient/impl/PreparedStatement;
ifnonnull 12
10: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
ifnull 12
11: aload 4
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
aload 4
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.sql:()Ljava/lang/String;
invokevirtual io.vertx.sqlclient.impl.cache.PreparedStatementCache.get:(Ljava/lang/String;)Lio/vertx/sqlclient/impl/PreparedStatement;
putfield io.vertx.sqlclient.impl.command.ExtendedQueryCommand.ps:Lio/vertx/sqlclient/impl/PreparedStatement;
12: StackMap locals: io.vertx.sqlclient.impl.command.ExtendedQueryCommand
StackMap stack:
aload 4
getfield io.vertx.sqlclient.impl.command.ExtendedQueryCommand.ps:Lio/vertx/sqlclient/impl/PreparedStatement;
ifnonnull 27
13: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
ifnull 14
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.preparedStatementCacheSqlFilter:Ljava/util/function/Predicate;
aload 4
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.sql:()Ljava/lang/String;
invokeinterface java.util.function.Predicate.test:(Ljava/lang/Object;)Z
ifeq 14
iconst_1
goto 15
StackMap locals:
StackMap stack:
14: iconst_0
StackMap locals:
StackMap stack: int
15: istore 5
start local 5 16: iload 5
ifeq 22
17: aload 0
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.evictStatementIfNecessary:()Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
astore 6
start local 6 18: aload 6
ifnull 22
19: aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
iadd
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
20: iinc 2 1
21: aload 1
aload 6
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
end local 6 22: StackMap locals: int
StackMap stack:
aload 0
aload 4
iload 5
iconst_0
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.prepareCommand:(Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;ZZ)Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
astore 6
start local 6 23: aload 0
iconst_1
putfield io.vertx.sqlclient.impl.SocketConnectionBase.paused:Z
24: aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
iadd
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
25: aload 6
astore 3
end local 6 end local 5 26: goto 32
27: StackMap locals:
StackMap stack:
aload 4
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.prepare:()Ljava/lang/String;
astore 5
start local 5 28: aload 5
ifnull 32
29: aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
isub
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
30: aload 4
new io.vertx.core.impl.NoStackTraceThrowable
dup
aload 5
invokespecial io.vertx.core.impl.NoStackTraceThrowable.<init>:(Ljava/lang/String;)V
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fail:(Ljava/lang/Throwable;)V
31: goto 34
end local 5 end local 4 32: StackMap locals:
StackMap stack:
iinc 2 1
33: aload 1
aload 3
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
end local 3 34: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.paused:Z
ifne 36
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.pipeliningLimit:I
if_icmpge 36
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.pending:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.command.CommandBase
dup
astore 3
start local 3 35: ifnonnull 6
end local 3 36: StackMap locals:
StackMap stack:
iload 2
ifle 42
37: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
pop
end local 2 end local 1 38: goto 42
StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase
StackMap stack: java.lang.Throwable
39: astore 7
40: aload 0
iconst_0
putfield io.vertx.sqlclient.impl.SocketConnectionBase.executing:Z
41: aload 7
athrow
42: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.vertx.sqlclient.impl.SocketConnectionBase.executing:Z
43: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 44 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
4 38 1 ctx Lio/netty/channel/ChannelHandlerContext;
5 38 2 written I
6 34 3 cmd Lio/vertx/sqlclient/impl/command/CommandBase<*>;
35 36 3 cmd Lio/vertx/sqlclient/impl/command/CommandBase<*>;
9 32 4 queryCmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
16 26 5 cache Z
18 22 6 closeCmd Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
23 26 6 prepareCmd Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
28 32 5 msg Ljava/lang/String;
Exception table:
from to target type
2 39 39 any
private io.vertx.sqlclient.impl.command.PrepareStatementCommand prepareCommand(io.vertx.sqlclient.impl.command.ExtendedQueryCommand<?>, boolean, boolean);
descriptor: (Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;ZZ)Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new io.vertx.sqlclient.impl.command.PrepareStatementCommand
dup
aload 1
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.sql:()Ljava/lang/String;
iload 2
iload 3
ifeq 1
aload 1
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.parameterTypes:()Ljava/util/List;
goto 2
StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase io.vertx.sqlclient.impl.command.ExtendedQueryCommand int int
StackMap stack: new 0 new 0 java.lang.String int
1: aconst_null
StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase io.vertx.sqlclient.impl.command.ExtendedQueryCommand int int
StackMap stack: new 0 new 0 java.lang.String int java.util.List
2: invokespecial io.vertx.sqlclient.impl.command.PrepareStatementCommand.<init>:(Ljava/lang/String;ZLjava/util/List;)V
astore 4
start local 4 3: aload 4
aload 0
iload 2
aload 1
iload 3
invokedynamic handle(Lio/vertx/sqlclient/impl/SocketConnectionBase;ZLio/vertx/sqlclient/impl/command/ExtendedQueryCommand;Z)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/sqlclient/impl/SocketConnectionBase.lambda$6(ZLio/vertx/sqlclient/impl/command/ExtendedQueryCommand;ZLio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
putfield io.vertx.sqlclient.impl.command.PrepareStatementCommand.handler:Lio/vertx/core/Handler;
4: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 5 1 queryCmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<*>;
0 5 2 cache Z
0 5 3 sendParameterTypes Z
3 5 4 prepareCmd Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
Signature: (Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<*>;ZZ)Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
MethodParameters:
Name Flags
queryCmd
cache
sendParameterTypes
protected void handleMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.vertx.sqlclient.impl.command.CommandResponse
ifeq 6
1: aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
isub
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
2: aload 1
checkcast io.vertx.sqlclient.impl.command.CommandResponse
astore 2
start local 2 3: aload 2
invokevirtual io.vertx.sqlclient.impl.command.CommandResponse.fire:()V
4: aload 0
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.checkPending:()V
end local 2 5: goto 9
StackMap locals:
StackMap stack:
6: aload 1
instanceof io.vertx.sqlclient.impl.codec.InvalidCachedStatementEvent
ifeq 9
7: aload 1
checkcast io.vertx.sqlclient.impl.codec.InvalidCachedStatementEvent
astore 2
start local 2 8: aload 0
aload 2
invokevirtual io.vertx.sqlclient.impl.codec.InvalidCachedStatementEvent.sql:()Ljava/lang/String;
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.removeCachedStatement:(Ljava/lang/String;)V
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/sqlclient/impl/SocketConnectionBase;
0 10 1 msg Ljava/lang/Object;
3 5 2 resp Lio/vertx/sqlclient/impl/command/CommandResponse;
8 9 2 event Lio/vertx/sqlclient/impl/codec/InvalidCachedStatementEvent;
MethodParameters:
Name Flags
msg
protected void handleEvent(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
ifnull 2
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
aload 1
invokeinterface io.vertx.sqlclient.impl.Connection$Holder.handleEvent:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 3 1 event Ljava/lang/Object;
MethodParameters:
Name Flags
event
private io.vertx.sqlclient.impl.command.CloseStatementCommand evictStatementIfNecessary();
descriptor: ()Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
ifnull 5
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
invokevirtual io.vertx.sqlclient.impl.cache.PreparedStatementCache.isFull:()Z
ifeq 5
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
invokevirtual io.vertx.sqlclient.impl.cache.PreparedStatementCache.evict:()Lio/vertx/sqlclient/impl/PreparedStatement;
astore 1
start local 1 2: new io.vertx.sqlclient.impl.command.CloseStatementCommand
dup
aload 1
invokespecial io.vertx.sqlclient.impl.command.CloseStatementCommand.<init>:(Lio/vertx/sqlclient/impl/PreparedStatement;)V
astore 2
start local 2 3: aload 2
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/sqlclient/impl/SocketConnectionBase.lambda$7(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
putfield io.vertx.sqlclient.impl.command.CloseStatementCommand.handler:Lio/vertx/core/Handler;
4: aload 2
areturn
end local 2 end local 1 5: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
2 5 1 evicted Lio/vertx/sqlclient/impl/PreparedStatement;
3 5 2 closeCmd Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
private void cacheStatement(io.vertx.sqlclient.impl.PreparedStatement);
descriptor: (Lio/vertx/sqlclient/impl/PreparedStatement;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
ifnull 3
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
aload 1
invokevirtual io.vertx.sqlclient.impl.cache.PreparedStatementCache.put:(Lio/vertx/sqlclient/impl/PreparedStatement;)Ljava/util/List;
astore 2
start local 2 2: getstatic io.vertx.sqlclient.impl.SocketConnectionBase.$assertionsDisabled:Z
ifne 3
aload 2
invokeinterface java.util.List.size:()I
ifeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 2 3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 4 1 preparedStatement Lio/vertx/sqlclient/impl/PreparedStatement;
2 3 2 evictedList Ljava/util/List<Lio/vertx/sqlclient/impl/PreparedStatement;>;
MethodParameters:
Name Flags
preparedStatement
private void removeCachedStatement(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
ifnull 2
1: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.psCache:Lio/vertx/sqlclient/impl/cache/PreparedStatementCache;
aload 1
invokevirtual io.vertx.sqlclient.impl.cache.PreparedStatementCache.remove:(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/vertx/sqlclient/impl/SocketConnectionBase;
0 3 1 sql Ljava/lang/String;
MethodParameters:
Name Flags
sql
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.vertx.sqlclient.impl.SocketConnectionBase.handleClose:(Ljava/lang/Throwable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
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.vertx.sqlclient.impl.SocketConnectionBase.handleClose:(Ljava/lang/Throwable;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 5 1 t Ljava/lang/Throwable;
2 3 2 err Lio/netty/handler/codec/DecoderException;
MethodParameters:
Name Flags
t
protected void handleClose(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CLOSED:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
if_acmpeq 20
1: aload 0
getstatic io.vertx.sqlclient.impl.SocketConnectionBase$Status.CLOSED:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
putfield io.vertx.sqlclient.impl.SocketConnectionBase.status:Lio/vertx/sqlclient/impl/SocketConnectionBase$Status;
2: aload 1
ifnull 10
3: aload 0
dup
astore 2
monitorenter
4: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
ifnull 6
5: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
aload 1
invokeinterface io.vertx.sqlclient.impl.Connection$Holder.handleException:(Ljava/lang/Throwable;)V
6: StackMap locals: io.vertx.sqlclient.impl.SocketConnectionBase
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.impl.NoStackTraceThrowable
dup
ldc "Pending requests failed to be sent due to connection has been closed."
invokespecial io.vertx.core.impl.NoStackTraceThrowable.<init>:(Ljava/lang/String;)V
goto 12
StackMap locals:
StackMap stack:
11: new io.vertx.core.VertxException
dup
ldc "Pending requests failed to be sent due to connection has been closed."
aload 1
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 2
start local 2 13: goto 16
start local 3 14: StackMap locals: java.lang.Throwable io.vertx.sqlclient.impl.command.CommandBase
StackMap stack:
aload 3
astore 4
start local 4 15: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.context:Lio/vertx/core/impl/ContextInternal;
aload 4
aload 2
invokedynamic handle(Lio/vertx/sqlclient/impl/command/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/vertx/sqlclient/impl/SocketConnectionBase.lambda$8(Lio/vertx/sqlclient/impl/command/CommandBase;Ljava/lang/Throwable;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
end local 4 end local 3 16: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.pending:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.command.CommandBase
dup
astore 3
start local 3 17: ifnonnull 14
18: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
ifnull 20
19: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.holder:Lio/vertx/sqlclient/impl/Connection$Holder;
invokeinterface io.vertx.sqlclient.impl.Connection$Holder.handleClosed:()V
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/sqlclient/impl/SocketConnectionBase;
0 21 1 t Ljava/lang/Throwable;
13 20 2 cause Ljava/lang/Throwable;
14 16 3 cmd Lio/vertx/sqlclient/impl/command/CommandBase<*>;
17 20 3 cmd Lio/vertx/sqlclient/impl/command/CommandBase<*>;
15 16 4 c Lio/vertx/sqlclient/impl/command/CommandBase<*>;
Exception table:
from to target type
4 7 8 any
8 9 8 any
MethodParameters:
Name Flags
t
private void lambda$2(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.vertx.sqlclient.impl.SocketConnectionBase.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.vertx.sqlclient.impl.SocketConnectionBase.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/vertx/sqlclient/impl/SocketConnectionBase;
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 static void lambda$3(io.vertx.core.Promise, io.netty.channel.ChannelFuture);
descriptor: (Lio/vertx/core/Promise;Lio/netty/channel/ChannelFuture;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 channelFuture Lio/netty/channel/ChannelFuture;
Exceptions:
throws java.lang.Exception
private void lambda$4(io.vertx.sqlclient.impl.Connection$Holder, io.vertx.core.Promise, java.lang.Void);
descriptor: (Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.close:(Lio/vertx/sqlclient/impl/Connection$Holder;Lio/vertx/core/Promise;)V
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 1 3 v Ljava/lang/Void;
private void lambda$5(io.vertx.sqlclient.impl.command.CommandBase, io.vertx.core.Promise, java.lang.Void);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.doSchedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Handler;)V
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 1 3 v Ljava/lang/Void;
private void lambda$6(boolean, io.vertx.sqlclient.impl.command.ExtendedQueryCommand, boolean, io.vertx.core.AsyncResult);
descriptor: (ZLio/vertx/sqlclient/impl/command/ExtendedQueryCommand;ZLio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=8, args_size=5
start local 0 start local 4 0: aload 0
iconst_0
putfield io.vertx.sqlclient.impl.SocketConnectionBase.paused:Z
1: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 15
2: aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
astore 5
start local 5 3: iload 1
ifeq 5
4: aload 0
aload 5
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.cacheStatement:(Lio/vertx/sqlclient/impl/PreparedStatement;)V
5: StackMap locals: io.vertx.sqlclient.impl.PreparedStatement
StackMap stack:
aload 2
aload 5
putfield io.vertx.sqlclient.impl.command.ExtendedQueryCommand.ps:Lio/vertx/sqlclient/impl/PreparedStatement;
6: aload 2
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.prepare:()Ljava/lang/String;
astore 6
start local 6 7: aload 6
ifnull 11
8: aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
isub
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
9: aload 2
new io.vertx.core.impl.NoStackTraceThrowable
dup
aload 6
invokespecial io.vertx.core.impl.NoStackTraceThrowable.<init>:(Ljava/lang/String;)V
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fail:(Ljava/lang/Throwable;)V
10: goto 23
11: StackMap locals: java.lang.String
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
astore 7
start local 7 12: aload 7
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
13: aload 7
invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
pop
end local 7 end local 6 end local 5 14: goto 23
15: StackMap locals:
StackMap stack:
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
astore 5
start local 5 16: aload 0
aload 5
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.isIndeterminatePreparedStatementError:(Ljava/lang/Throwable;)Z
ifeq 21
iload 3
ifne 21
17: aload 0
getfield io.vertx.sqlclient.impl.SocketConnectionBase.socket:Lio/vertx/core/net/impl/NetSocketInternal;
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
astore 6
start local 6 18: aload 6
aload 0
aload 2
iconst_0
iconst_1
invokevirtual io.vertx.sqlclient.impl.SocketConnectionBase.prepareCommand:(Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;ZZ)Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
19: aload 6
invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
pop
end local 6 20: goto 23
21: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
dup
getfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
iconst_1
isub
putfield io.vertx.sqlclient.impl.SocketConnectionBase.inflight:I
22: aload 2
aload 5
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fail:(Ljava/lang/Throwable;)V
end local 5 23: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/vertx/sqlclient/impl/SocketConnectionBase;
0 24 4 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;
3 14 5 ps Lio/vertx/sqlclient/impl/PreparedStatement;
7 14 6 msg Ljava/lang/String;
12 14 7 ctx Lio/netty/channel/ChannelHandlerContext;
16 23 5 cause Ljava/lang/Throwable;
18 20 6 ctx Lio/netty/channel/ChannelHandlerContext;
private static void lambda$7(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 2
1: getstatic io.vertx.sqlclient.impl.SocketConnectionBase.logger:Lio/vertx/core/impl/logging/Logger;
ldc "Error when closing cached prepared statement"
aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private static void lambda$8(io.vertx.sqlclient.impl.command.CommandBase, java.lang.Throwable, java.lang.Void);
descriptor: (Lio/vertx/sqlclient/impl/command/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.vertx.sqlclient.impl.command.CommandBase.fail:(Ljava/lang/Throwable;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 v Ljava/lang/Void;
}
SourceFile: "SocketConnectionBase.java"
NestMembers:
io.vertx.sqlclient.impl.SocketConnectionBase$Status
InnerClasses:
public abstract Holder = io.vertx.sqlclient.impl.Connection$Holder of io.vertx.sqlclient.impl.Connection
public final Status = io.vertx.sqlclient.impl.SocketConnectionBase$Status of io.vertx.sqlclient.impl.SocketConnectionBase
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles