Refresh valid invokers after connectivity check

AlbumenJ · Feb 20, 2024 · 5179991 · 5179991
1 parent caed64b
commit 5179991
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java
@@ -356,11 +356,14 @@ public void checkConnectivity() {
                                 }
                                 invokersToReconnect.remove(tInvoker);
                             }
+
+                            // 4. refresh valid invokers list
+                            refreshInvoker();
                         } finally {
                             checkConnectivityPermit.release();
                         }
 
-                        // 4. submit new task if it has more to recover
+                        // 5. submit new task if it has more to recover
                         if (!invokersToReconnect.isEmpty()) {
                             checkConnectivity();
                         }