Cleanup handleStreamRestarted

larry-safran · Nov 26, 2024 · a027b67 · a027b67
1 parent ea66db8
commit a027b67
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java b/xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java
@@ -960,11 +960,9 @@ public void handleStreamRestarted(ServerInfo serverInfo) {
         return;
       }
 
-      for (Map.Entry<String, List<ControlPlaneClient>> me : activatedCpClients.entrySet()) {
-        if (me.getValue().contains(controlPlaneClient)) {
-          if (getActiveCpc(me.getKey()) == controlPlaneClient) {
-            startSubscriberTimersIfNeeded(me.getKey());
-          }
+      for (String authority : activatedCpClients.keySet()) {
+        if (getActiveCpc(authority) == controlPlaneClient) {
+          startSubscriberTimersIfNeeded(authority);
         }
       }
     }