public class io.vertx.sqlclient.impl.pool.ConnectionPool
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.sqlclient.impl.pool.ConnectionPool
super_class: java.lang.Object
{
private final io.vertx.sqlclient.impl.ConnectionFactory connector;
descriptor: Lio/vertx/sqlclient/impl/ConnectionFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.ContextInternal context;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int maxSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.ArrayDeque<io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.impl.Connection>>> waiters;
descriptor: Ljava/util/ArrayDeque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/ArrayDeque<Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;>;
private final java.util.Set<io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection> all;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;>;
private final java.util.ArrayDeque<io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection> available;
descriptor: Ljava/util/ArrayDeque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/ArrayDeque<Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;>;
private int size;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private final int maxWaitQueueSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean checkInProgress;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean closed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
public void <init>(io.vertx.sqlclient.impl.ConnectionFactory, int);
descriptor: (Lio/vertx/sqlclient/impl/ConnectionFactory;I)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
aload 1
iload 2
iconst_m1
invokespecial io.vertx.sqlclient.impl.pool.ConnectionPool.<init>:(Lio/vertx/sqlclient/impl/ConnectionFactory;II)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/pool/ConnectionPool;
0 2 1 connector Lio/vertx/sqlclient/impl/ConnectionFactory;
0 2 2 maxSize I
MethodParameters:
Name Flags
connector
maxSize
public void <init>(io.vertx.sqlclient.impl.ConnectionFactory, int, int);
descriptor: (Lio/vertx/sqlclient/impl/ConnectionFactory;II)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aconst_null
iload 2
iload 3
invokespecial io.vertx.sqlclient.impl.pool.ConnectionPool.<init>:(Lio/vertx/sqlclient/impl/ConnectionFactory;Lio/vertx/core/Context;II)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
0 2 1 connector Lio/vertx/sqlclient/impl/ConnectionFactory;
0 2 2 maxSize I
0 2 3 maxWaitQueueSize I
MethodParameters:
Name Flags
connector
maxSize
maxWaitQueueSize
public void <init>(io.vertx.sqlclient.impl.ConnectionFactory, io.vertx.core.Context, int, int);
descriptor: (Lio/vertx/sqlclient/impl/ConnectionFactory;Lio/vertx/core/Context;II)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.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
2: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.all:Ljava/util/Set;
3: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.available:Ljava/util/ArrayDeque;
4: aload 1
ldc "No null connector"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: iload 3
iconst_1
if_icmpge 7
6: new java.lang.IllegalArgumentException
dup
ldc "Pool max size must be > 0"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
7: StackMap locals: io.vertx.sqlclient.impl.pool.ConnectionPool io.vertx.sqlclient.impl.ConnectionFactory io.vertx.core.Context int int
StackMap stack:
aload 0
iload 3
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.maxSize:I
8: aload 0
aload 2
checkcast io.vertx.core.impl.ContextInternal
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
9: aload 0
iload 4
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.maxWaitQueueSize:I
10: aload 0
aload 1
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.connector:Lio/vertx/sqlclient/impl/ConnectionFactory;
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/vertx/sqlclient/impl/pool/ConnectionPool;
0 12 1 connector Lio/vertx/sqlclient/impl/ConnectionFactory;
0 12 2 context Lio/vertx/core/Context;
0 12 3 maxSize I
0 12 4 maxWaitQueueSize I
MethodParameters:
Name Flags
connector
context
maxSize
maxWaitQueueSize
public int available();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.available:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
public int size();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
public void acquire(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.impl.Connection>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
ifnull 3
1: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
aload 1
aload 0
invokedynamic handle(Lio/vertx/sqlclient/impl/pool/ConnectionPool;)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/pool/ConnectionPool.doAcquire(Lio/vertx/core/Handler;)V (7)
(Lio/vertx/core/Handler;)V
invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.sqlclient.impl.pool.ConnectionPool.doAcquire:(Lio/vertx/core/Handler;)V
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/pool/ConnectionPool;
0 5 1 waiter Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;)V
MethodParameters:
Name Flags
waiter
private void doAcquire(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.impl.Connection>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.closed:Z
ifeq 7
1: new java.lang.IllegalStateException
dup
ldc "Connection pool closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
astore 2
start local 2 2: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
ifnull 5
3: aload 1
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
aload 2
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: goto 6
5: StackMap locals: java.lang.IllegalStateException
StackMap stack:
aload 1
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
6: StackMap locals:
StackMap stack:
return
end local 2 7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
aload 1
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
8: aload 0
invokevirtual io.vertx.sqlclient.impl.pool.ConnectionPool.check:()V
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
0 10 1 waiter Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
2 7 2 err Ljava/lang/IllegalStateException;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;)V
MethodParameters:
Name Flags
waiter
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 1
start local 1 1: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.context:Lio/vertx/core/impl/ContextInternal;
aload 1
aload 0
invokedynamic handle(Lio/vertx/sqlclient/impl/pool/ConnectionPool;)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/pool/ConnectionPool.close(Lio/vertx/core/Promise;)V (5)
(Lio/vertx/core/impl/future/PromiseInternal;)V
invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
2: aload 1
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
1 3 1 promise Lio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public void close(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.closed:Z
ifeq 3
1: aload 1
ldc "Connection pool already closed"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.closed:Z
4: ldc "Connection pool closed"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 2
start local 2 5: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.iterator:()Ljava/util/Iterator;
astore 4
goto 10
StackMap locals: io.vertx.sqlclient.impl.pool.ConnectionPool io.vertx.core.Promise io.vertx.core.Future top java.util.Iterator
StackMap stack:
6: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 3
start local 3 7: aload 3
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: goto 10
StackMap locals: io.vertx.sqlclient.impl.pool.ConnectionPool io.vertx.core.Promise io.vertx.core.Future io.vertx.core.Handler java.util.Iterator
StackMap stack: java.lang.Exception
9: pop
end local 3 10: StackMap locals: io.vertx.sqlclient.impl.pool.ConnectionPool io.vertx.core.Promise io.vertx.core.Future top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
11: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 12: new java.util.ArrayList
dup
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.all:Ljava/util/Set;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 5
goto 17
StackMap locals: io.vertx.sqlclient.impl.pool.ConnectionPool io.vertx.core.Promise io.vertx.core.Future java.util.List top java.util.Iterator
StackMap stack:
13: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection
astore 4
start local 4 14: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 6
start local 6 15: aload 4
aload 6
invokevirtual io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection.close:(Lio/vertx/core/Promise;)V
16: aload 3
aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 6 end local 4 17: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
18: aload 3
invokestatic io.vertx.core.CompositeFuture.join:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
19: invokeinterface io.vertx.core.CompositeFuture.mapEmpty:()Lio/vertx/core/Future;
20: aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
21: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
0 22 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
5 22 2 failure Lio/vertx/core/Future<Lio/vertx/sqlclient/impl/Connection;>;
7 10 3 pending Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
12 22 3 futures Ljava/util/List<Lio/vertx/core/Future;>;
14 17 4 pooled Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;
15 17 6 p Lio/vertx/core/Promise<Ljava/lang/Void;>;
Exception table:
from to target type
7 8 9 Class java.lang.Exception
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
promise
private void release(io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection);
descriptor: (Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;)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.pool.ConnectionPool.all:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifeq 3
1: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.available:Ljava/util/ArrayDeque;
aload 1
invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
pop
2: aload 0
invokevirtual io.vertx.sqlclient.impl.pool.ConnectionPool.check:()V
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/pool/ConnectionPool;
0 4 1 proxy Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;
MethodParameters:
Name Flags
proxy
private void check();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.closed:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.checkInProgress:Z
ifne 29
3: aload 0
iconst_1
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.checkInProgress:Z
4: goto 23
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.available:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
ifle 10
6: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.available:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection
astore 1
start local 1 7: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 2
start local 2 8: aload 2
aload 1
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 end local 1 9: goto 23
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.maxSize:I
if_icmpge 15
11: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 1
start local 1 12: aload 0
dup
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
iconst_1
iadd
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
13: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.connector:Lio/vertx/sqlclient/impl/ConnectionFactory;
invokeinterface io.vertx.sqlclient.impl.ConnectionFactory.connect:()Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/sqlclient/impl/pool/ConnectionPool;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/sqlclient/impl/pool/ConnectionPool.lambda$2(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 1 14: goto 23
15: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.maxWaitQueueSize:I
iflt 28
16: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.all:Ljava/util/Set;
invokeinterface java.util.Set.size:()I
isub
istore 1
start local 1 17: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.maxWaitQueueSize:I
iload 1
iadd
isub
istore 2
start local 2 18: goto 21
19: StackMap locals: int int
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.pollLast:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 3
start local 3 20: aload 3
ldc "Max waiter size reached"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 3 21: StackMap locals:
StackMap stack:
iload 2
iinc 2 -1
ifgt 19
end local 2 end local 1 22: goto 28
23: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.waiters:Ljava/util/ArrayDeque;
invokevirtual java.util.ArrayDeque.size:()I
ifgt 5
24: goto 28
StackMap locals:
StackMap stack: java.lang.Throwable
25: astore 4
26: aload 0
iconst_0
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.checkInProgress:Z
27: aload 4
athrow
28: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.checkInProgress:Z
29: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
7 9 1 proxy Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;
8 9 2 waiter Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
12 14 1 waiter Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
17 22 1 numInProgress I
18 22 2 numToFail I
20 21 3 waiter Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;>;
Exception table:
from to target type
4 25 25 any
private void lambda$2(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=4, locals=5, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 7
1: aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.Connection
astore 3
start local 3 2: new io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection
dup
aload 0
aload 3
invokespecial io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection.<init>:(Lio/vertx/sqlclient/impl/pool/ConnectionPool;Lio/vertx/sqlclient/impl/Connection;)V
astore 4
start local 4 3: aload 0
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.all:Ljava/util/Set;
aload 4
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 3
aload 4
invokeinterface io.vertx.sqlclient.impl.Connection.init:(Lio/vertx/sqlclient/impl/Connection$Holder;)V
5: aload 1
aload 4
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 4 end local 3 6: goto 10
7: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
iconst_1
isub
putfield io.vertx.sqlclient.impl.pool.ConnectionPool.size:I
8: 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
9: aload 0
invokevirtual io.vertx.sqlclient.impl.pool.ConnectionPool.check:()V
10: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/sqlclient/impl/pool/ConnectionPool;
0 11 2 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/Connection;>;
2 6 3 conn Lio/vertx/sqlclient/impl/Connection;
3 6 4 proxy Lio/vertx/sqlclient/impl/pool/ConnectionPool$PooledConnection;
}
SourceFile: "ConnectionPool.java"
NestMembers:
io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection
InnerClasses:
public abstract Holder = io.vertx.sqlclient.impl.Connection$Holder of io.vertx.sqlclient.impl.Connection
private PooledConnection = io.vertx.sqlclient.impl.pool.ConnectionPool$PooledConnection of io.vertx.sqlclient.impl.pool.ConnectionPool
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles