Try and AcquireConnection when ClientConnectionsEntry is FreezeReason.SYSTEM not only for MASTER

7 years ago · 196e39c3a5
parent df7de8b432
commit 196e39c3a5
1 changed files with 2 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java
+++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java
@ -198,8 +198,8 @@ abstract class ConnectionPool<T extends RedisConnection> {
    }

    public RFuture<T> get(RedisCommand<?> command, ClientConnectionsEntry entry) {
-        if (((entry.getNodeType() == NodeType.MASTER && entry.getFreezeReason() == FreezeReason.SYSTEM) || !entry.isFreezed())
-                && tryAcquireConnection(entry)) {
+        if ((!entry.isFreezed() || entry.getFreezeReason() == FreezeReason.SYSTEM) && 
+        		tryAcquireConnection(entry)) {
            return acquireConnection(command, entry);
        }