- Coord starting and coord crash scenarios are now handled, too

belaban · Aug 9, 2023 · e48293b · e48293b
1 parent af7a5e2
commit e48293b
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/src/org/jgroups/protocols/relay/RELAY3.java b/src/org/jgroups/protocols/relay/RELAY3.java
@@ -202,11 +202,11 @@ public void handleView(View view) {
         if(!topo.globalViews())
             return;
 
-
         if(is_site_master) {
-            Address dest=new SiteMaster(null);
-            // send the view as a TOPO_RSP to all site masters, who then forward it locally with NO_RELAY
-            sendResponseFor(dest, false);
+            if(!become_site_master) {
+                // send my own information as a TOPO_RSP to all site masters, who then forward it locally with NO_RELAY
+                sendResponseFor(new SiteMaster(null), false);
+            }
         }
         else { // not site master
             // on the first view and as non site master -> fetch the cache from the site master
@@ -222,8 +222,12 @@ protected <T> Object handleRelayerStarted(Relayer r, long start, T ignored, Thro
             log.error(local_addr + ": failed starting relayer", t);
         else {
             log.info("%s: relayer was started in %d ms: %s", local_addr, System.currentTimeMillis() - start, r);
-            if(topo.globalViews())
+            if(topo.globalViews()) {
+                // get the caches from all site masters
                 topo.refresh(null);
+                // send my own information as a TOPO_RSP to all site masters, who then forward it locally with NO_RELAY
+                sendResponseFor(new SiteMaster(null), false);
+            }
         }
         return null;
     }