class io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection implements io.reactiverse.pgclient.impl.Connection, io.reactiverse.pgclient.impl.Connection$Holder
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection
super_class: java.lang.Object
{
private final io.reactiverse.pgclient.impl.Connection conn;
descriptor: Lio/reactiverse/pgclient/impl/Connection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.reactiverse.pgclient.impl.Connection$Holder holder;
descriptor: Lio/reactiverse/pgclient/impl/Connection$Holder;
flags: (0x0002) ACC_PRIVATE
final io.reactiverse.pgclient.impl.ConnectionPool this$0;
descriptor: Lio/reactiverse/pgclient/impl/ConnectionPool;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(io.reactiverse.pgclient.impl.ConnectionPool, io.reactiverse.pgclient.impl.Connection);
descriptor: (Lio/reactiverse/pgclient/impl/ConnectionPool;Lio/reactiverse/pgclient/impl/Connection;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
putfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 2
putfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
0 3 2 conn Lio/reactiverse/pgclient/impl/Connection;
MethodParameters:
Name Flags
this$0 final
conn
public io.reactiverse.pgclient.impl.Connection connection();
descriptor: ()Lio/reactiverse/pgclient/impl/Connection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
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.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
invokeinterface io.reactiverse.pgclient.impl.Connection.isSsl:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
public void schedule(io.reactiverse.pgclient.impl.CommandBase<?>);
descriptor: (Lio/reactiverse/pgclient/impl/CommandBase;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
aload 1
invokeinterface io.reactiverse.pgclient.impl.Connection.schedule:(Lio/reactiverse/pgclient/impl/CommandBase;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
0 2 1 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
Signature: (Lio/reactiverse/pgclient/impl/CommandBase<*>;)V
MethodParameters:
Name Flags
cmd
private void close();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
aload 0
invokeinterface io.reactiverse.pgclient.impl.Connection.close:(Lio/reactiverse/pgclient/impl/Connection$Holder;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
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
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 2
1: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
0 4 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=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
if_acmpeq 2
1: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
3: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
aload 0
invokevirtual io.reactiverse.pgclient.impl.ConnectionPool.release:(Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
0 5 1 holder Lio/reactiverse/pgclient/impl/Connection$Holder;
MethodParameters:
Name Flags
holder
public void handleClosed();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
getfield io.reactiverse.pgclient.impl.ConnectionPool.all:Ljava/util/Set;
aload 0
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
ifeq 8
1: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
dup
getfield io.reactiverse.pgclient.impl.ConnectionPool.size:I
iconst_1
isub
putfield io.reactiverse.pgclient.impl.ConnectionPool.size:I
2: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnonnull 5
3: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
getfield io.reactiverse.pgclient.impl.ConnectionPool.available:Ljava/util/ArrayDeque;
aload 0
invokevirtual java.util.ArrayDeque.remove:(Ljava/lang/Object;)Z
pop
4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleClosed:()V
6: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.this$0:Lio/reactiverse/pgclient/impl/ConnectionPool;
invokevirtual io.reactiverse.pgclient.impl.ConnectionPool.check:()V
7: goto 9
8: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
9: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
public void handleNotification(int, java.lang.String, java.lang.String);
descriptor: (ILjava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 2
1: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
iload 1
aload 2
aload 3
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleNotification:(ILjava/lang/String;Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
0 3 1 processId I
0 3 2 channel Ljava/lang/String;
0 3 3 payload Ljava/lang/String;
MethodParameters:
Name Flags
processId
channel
payload
public void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
ifnull 2
1: aload 0
getfield io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection.holder:Lio/reactiverse/pgclient/impl/Connection$Holder;
aload 1
invokeinterface io.reactiverse.pgclient.impl.Connection$Holder.handleException:(Ljava/lang/Throwable;)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/ConnectionPool$PooledConnection;
0 3 1 err Ljava/lang/Throwable;
MethodParameters:
Name Flags
err
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.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
invokeinterface io.reactiverse.pgclient.impl.Connection.getProcessId:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
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.ConnectionPool$PooledConnection.conn:Lio/reactiverse/pgclient/impl/Connection;
invokeinterface io.reactiverse.pgclient.impl.Connection.getSecretKey:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactiverse/pgclient/impl/ConnectionPool$PooledConnection;
}
SourceFile: "ConnectionPool.java"
NestHost: io.reactiverse.pgclient.impl.ConnectionPool
InnerClasses:
public abstract Holder = io.reactiverse.pgclient.impl.Connection$Holder of io.reactiverse.pgclient.impl.Connection
private PooledConnection = io.reactiverse.pgclient.impl.ConnectionPool$PooledConnection of io.reactiverse.pgclient.impl.ConnectionPool