|
|
@ -221,6 +221,9 @@ abstract class ConnectionPool<T extends RedisConnection> {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private void connectTo(ClientConnectionsEntry entry, RPromise<T> promise) {
|
|
|
|
private void connectTo(ClientConnectionsEntry entry, RPromise<T> promise) {
|
|
|
|
|
|
|
|
if (promise.isDone()) {
|
|
|
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
}
|
|
|
|
T conn = poll(entry);
|
|
|
|
T conn = poll(entry);
|
|
|
|
if (conn != null) {
|
|
|
|
if (conn != null) {
|
|
|
|
if (!conn.isActive()) {
|
|
|
|
if (!conn.isActive()) {
|
|
|
@ -228,8 +231,7 @@ abstract class ConnectionPool<T extends RedisConnection> {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
entry.resetFailedAttempts();
|
|
|
|
connectedSuccessful(entry, promise, conn);
|
|
|
|
promise.trySuccess(conn);
|
|
|
|
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|