Bug 36405782 - Build: *RemoteCountDownLatchIT -> shouldAcquireAndCountDownWithRollingRestart (merge main -> ce/main @ 107702)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 107712]

Author: rlubke

prj/test/functional/concurrent/src/main/java/concurrent/ClusteredRemoteCountDownLatchIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -10,6 +10,7 @@
 
 import com.oracle.bedrock.runtime.LocalPlatform;
 
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -22,6 +23,7 @@
 
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.tangosol.net.Coherence;
 
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -71,7 +73,8 @@ public ClusteredRemoteCountDownLatchIT()
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
                           logs,
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(2,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/ClusteredRemoteSemaphoreExtendIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -66,7 +66,8 @@ public ClusteredRemoteSemaphoreExtendIT()
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
                           logs,
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/ClusteredRemoteSemaphoreExtendProxyIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -67,7 +67,8 @@ public ClusteredRemoteSemaphoreExtendProxyIT()
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
                           logs,
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/ClusteredRemoteSemaphoreIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -8,6 +8,7 @@
 
 import com.oracle.bedrock.junit.CoherenceClusterExtension;
 import com.oracle.bedrock.runtime.LocalPlatform;
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -18,6 +19,7 @@
 import com.oracle.bedrock.runtime.java.options.IPv4Preferred;
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.tangosol.net.Coherence;
 
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -63,7 +65,8 @@ public ClusteredRemoteSemaphoreIT()
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
                           logs,
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/PofClusteredRemoteCountDownLatchIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -10,6 +10,7 @@
 
 import com.oracle.bedrock.runtime.LocalPlatform;
 
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -23,6 +24,7 @@
 
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.tangosol.net.Coherence;
 
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -72,7 +74,8 @@ public PofClusteredRemoteCountDownLatchIT()
                           logs,
                           ClusterPort.automatic(),
                           Pof.enabled(),
-                          Pof.config("coherence-concurrent-pof-config.xml"))
+                          Pof.config("coherence-concurrent-pof-config.xml"),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(2,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/PofClusteredRemoteSemaphoreExtendIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -70,7 +70,8 @@ public PofClusteredRemoteSemaphoreExtendIT()
                           logs,
                           ClusterPort.automatic(),
                           Pof.enabled(),
-                          Pof.config("coherence-concurrent-pof-config.xml"))
+                          Pof.config("coherence-concurrent-pof-config.xml"),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/PofClusteredRemoteSemaphoreExtendProxyIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -69,7 +69,8 @@ public PofClusteredRemoteSemaphoreExtendProxyIT()
                           logs,
                           ClusterPort.automatic(),
                           Pof.enabled(),
-                          Pof.config("coherence-concurrent-pof-config.xml"))
+                          Pof.config("coherence-concurrent-pof-config.xml"),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/PofClusteredRemoteSemaphoreIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -8,6 +8,7 @@
 
 import com.oracle.bedrock.junit.CoherenceClusterExtension;
 import com.oracle.bedrock.runtime.LocalPlatform;
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -19,6 +20,7 @@
 import com.oracle.bedrock.runtime.java.options.IPv4Preferred;
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.tangosol.net.Coherence;
 
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -66,7 +68,8 @@ public PofClusteredRemoteSemaphoreIT()
                           logs,
                           ClusterPort.automatic(),
                           Pof.enabled(),
-                          Pof.config("coherence-concurrent-pof-config.xml"))
+                          Pof.config("coherence-concurrent-pof-config.xml"),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(3,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/config/ConcurrentCacheConfigOverrideTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -10,6 +10,7 @@
 
 import com.oracle.bedrock.runtime.LocalPlatform;
 
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -23,6 +24,7 @@
 
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.oracle.bedrock.testsupport.deferred.Eventually;
 
 import com.tangosol.net.Coherence;
@@ -61,7 +63,7 @@ public void testConcurrentCacheConfigOverride()
     // ----- data members ---------------------------------------------------
 
     /**
-     * Override file for concuurent cacheconfig xml.
+     * Override file for concurrent cacheconfig xml.
      */
     public final static String FILE_CFG_CACHE_OVERRIDE = "concurrent-cache-config-override.xml";
 
@@ -80,7 +82,8 @@ public void testConcurrentCacheConfigOverride()
                           LocalHost.only(),
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(1,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),

prj/test/functional/concurrent/src/main/java/concurrent/executor/RemoteExecutorExtendIT.java

@@ -10,6 +10,7 @@
 
 import com.oracle.bedrock.runtime.LocalPlatform;
 
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.options.ClusterPort;
 import com.oracle.bedrock.runtime.coherence.options.LocalHost;
 import com.oracle.bedrock.runtime.coherence.options.LocalStorage;
@@ -22,6 +23,7 @@
 
 import com.oracle.bedrock.runtime.options.DisplayName;
 
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.tangosol.net.Coherence;
 
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -66,7 +68,8 @@ protected Coherence getClient()
                           Multicast.ttl(0),
                           IPv4Preferred.yes(),
                           logs,
-                          ClusterPort.automatic())
+                          ClusterPort.automatic(),
+                          StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()))
                     .include(1,
                              DisplayName.of("storage"),
                              RoleName.of("storage"),