fix: set freezed when slaveConnectionPool and pubSubConnectionPool all inited completed

Signed-off-by: xujie <mikawudi@qq.com>

redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java

@@ -56,7 +56,7 @@ public class ClientConnectionsEntry {
 
     private final AtomicLong firstFailTime = new AtomicLong(0);
 
-    private volatile boolean initing = false;
+    private volatile boolean inited = false;
 
     public ClientConnectionsEntry(RedisClient client, int poolMinSize, int poolMaxSize, int subscribePoolMinSize, int subscribePoolMaxSize,
             ConnectionManager connectionManager, NodeType nodeType) {
@@ -84,12 +84,12 @@ public class ClientConnectionsEntry {
                             && getNodeType() == NodeType.MASTER;
     }
 
-    public boolean isIniting() {
-        return this.initing;
+    public boolean isInited() {
+        return this.inited;
     }
 
-    public void setIniting(boolean isIniting) {
-        this.initing = isIniting;
+    public void setInited(boolean isInited) {
+        this.inited = isInited;
     }
     
     public void setNodeType(NodeType nodeType) {
@@ -126,7 +126,7 @@ public class ClientConnectionsEntry {
     public void setFreezeReason(FreezeReason freezeReason) {
         this.freezeReason = freezeReason;
         if (freezeReason != null) {
-            this.initing = false;
+            this.inited = false;
         }
     }
 

redisson/src/main/java/org/redisson/connection/balancer/LoadBalancerManager.java

@@ -20,6 +20,8 @@ import java.util.Collection;
 import java.util.Collections;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.BiConsumer;
 
 import org.redisson.api.NodeType;
 import org.redisson.api.RFuture;
@@ -138,16 +140,27 @@ public class LoadBalancerManager {
 
             if (freezeReason != FreezeReason.RECONNECT
                     || entry.getFreezeReason() == FreezeReason.RECONNECT) {
-                if (!entry.isIniting()) {
-                    entry.setIniting(true);
-                    entry.resetFirstFail();
-                    slaveConnectionPool.initConnections(entry).onComplete((r, ex) -> {
-                        entry.setIniting(false);
+                if (!entry.isInited()) {
+                    entry.setInited(true);
+                    AtomicInteger initedCounter = new AtomicInteger(2);
+                    RPromise<Void> promise = new RedissonPromise<Void>();
+                    promise.onComplete((r, ex) -> {
                         if (ex == null) {
                             entry.setFreezeReason(null);
                         }
                     });
-                    pubSubConnectionPool.initConnections(entry);
+                    BiConsumer<Void, Throwable> initCallBack = (r, ex) -> {
+                        if (ex == null) {
+                            if (initedCounter.decrementAndGet() == 0) {
+                                promise.trySuccess(null);
+                            }
+                        } else {
+                            promise.tryFailure(ex);
+                        }
+                    };
+                    entry.resetFirstFail();
+                    slaveConnectionPool.initConnections(entry).onComplete(initCallBack);
+                    pubSubConnectionPool.initConnections(entry).onComplete(initCallBack);
                     return true;
                 }
             }