|
|
@ -111,6 +111,7 @@ abstract class ConnectionPool<T extends RedisConnection> {
|
|
|
|
createConnection(entry, promise);
|
|
|
|
createConnection(entry, promise);
|
|
|
|
promise.whenComplete((conn, e) -> {
|
|
|
|
promise.whenComplete((conn, e) -> {
|
|
|
|
if (e == null) {
|
|
|
|
if (e == null) {
|
|
|
|
|
|
|
|
conn.decUsage();
|
|
|
|
if (!initPromise.isDone()) {
|
|
|
|
if (!initPromise.isDone()) {
|
|
|
|
entry.addConnection(conn);
|
|
|
|
entry.addConnection(conn);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -279,6 +280,7 @@ abstract class ConnectionPool<T extends RedisConnection> {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
promise.thenApply(c -> c.incUsage());
|
|
|
|
connectedSuccessful(entry, promise, conn);
|
|
|
|
connectedSuccessful(entry, promise, conn);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|