Increase timeouts waiting for test processes to start on slow machines

(merge main -> ce/main 107771)

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

Author: thegridman

prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/BaseTopicsTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2023, 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,8 @@
 
 import com.oracle.bedrock.Option;
 import com.oracle.bedrock.OptionsByType;
+import com.oracle.bedrock.options.Timeout;
+import com.oracle.bedrock.runtime.coherence.CoherenceCluster;
 import com.oracle.bedrock.runtime.coherence.CoherenceClusterMember;
 import com.oracle.bedrock.runtime.coherence.options.CacheConfig;
 import com.oracle.bedrock.runtime.coherence.options.ClusterName;
@@ -19,13 +21,15 @@
 import com.oracle.bedrock.runtime.java.options.IPv4Preferred;
 import com.oracle.bedrock.runtime.java.options.JvmOptions;
 import com.oracle.bedrock.runtime.options.DisplayName;
+import com.oracle.bedrock.runtime.options.StabilityPredicate;
 import com.oracle.bedrock.testsupport.MavenProjectFileUtils;
 import com.oracle.bedrock.testsupport.junit.TestLogsExtension;
 import com.oracle.coherence.common.base.Exceptions;
 import org.junit.jupiter.api.Order;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 import java.io.File;
+import java.util.concurrent.TimeUnit;
 
 /**
  * A base class for topics compatibility tests.
@@ -114,6 +118,8 @@ static ClosableCluster createCluster(String sClusterName, Version version, int c
                 IPv4Preferred.yes(),
                 JvmOptions.include("-XX:+ExitOnOutOfMemoryError", "-XX:HeapDumpPath=" + file.getAbsolutePath()),
                 HeapSize.of(64, HeapSize.Units.MB, 512, HeapSize.Units.MB, true),
+                StabilityPredicate.of(CoherenceCluster.Predicates.isCoherenceRunning()),
+                Timeout.after(5, TimeUnit.MINUTES),
                 m_testLogs);
 
         optionsByType.addAll(options);

prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/PubSubTests.java

@@ -1,11 +1,12 @@
 /*
- * Copyright (c) 2000, 2023, 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.
  */
 package topics;
 
+import com.oracle.bedrock.options.Timeout;
 import com.oracle.bedrock.runtime.coherence.CoherenceClusterMember;
 import com.oracle.bedrock.testsupport.deferred.Eventually;
 import com.oracle.coherence.common.util.Threads;
@@ -200,8 +201,8 @@ protected void shouldPubAndSub(ClosableCluster cluster, Version clusterVersion,
         try (CoherenceClusterMember memberPub = cluster.startPublisher("PublisherOne", pubSubVersion.getClassPath());
              CoherenceClusterMember memberSub = cluster.startSubscriber("SubscriberOne", pubSubVersion.getClassPath()))
             {
-            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true));
-            Eventually.assertDeferred(memberSub::isCoherenceRunning, is(true));
+            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
+            Eventually.assertDeferred(memberSub::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
 
             String sTopicName = "test-topic";
             String sGroupName = "test-group";
@@ -234,9 +235,9 @@ protected void shouldPubWithMultipleSubs(ClosableCluster cluster, Version cluste
              CoherenceClusterMember memberSub1 = cluster.startSubscriber("SubscriberOne", pubSubVersion.getClassPath());
              CoherenceClusterMember memberSub2 = cluster.startSubscriber("SubscriberTwo", pubSubVersion.getClassPath()))
             {
-            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true));
-            Eventually.assertDeferred(memberSub1::isCoherenceRunning, is(true));
-            Eventually.assertDeferred(memberSub2::isCoherenceRunning, is(true));
+            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
+            Eventually.assertDeferred(memberSub1::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
+            Eventually.assertDeferred(memberSub2::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
 
             String sTopicName = "test-topic";
             String sGroupName = "test-group";
@@ -284,9 +285,9 @@ protected void shouldPubWithMultipleSubsAndReallocation(ClosableCluster cluster,
              CoherenceClusterMember memberSub1 = cluster.startSubscriber("SubscriberOne", pubSubVersion.getClassPath());
              CoherenceClusterMember memberSub2 = cluster.startSubscriber("SubscriberTwo", pubSubVersion.getClassPath()))
             {
-            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true));
-            Eventually.assertDeferred(memberSub1::isCoherenceRunning, is(true));
-            Eventually.assertDeferred(memberSub2::isCoherenceRunning, is(true));
+            Eventually.assertDeferred(memberPub::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
+            Eventually.assertDeferred(memberSub1::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
+            Eventually.assertDeferred(memberSub2::isCoherenceRunning, is(true), Timeout.after(5, TimeUnit.MINUTES));
 
             cluster.log(">>>> Starting shouldPubWithMultipleSubsAndReallocation");
 
@@ -336,7 +337,7 @@ protected void shouldPubWithMultipleSubsAndReallocation(ClosableCluster cluster,
                 cluster.log(">>>> In shouldPubWithMultipleSubsAndReallocation - closed subscribers");
 
                 Eventually.assertDeferred(() -> TopicSubscriber.getChannelCount(memberSub1, "Sub1.2")
-                        + TopicSubscriber.getChannelCount(memberSub2, "Sub2.2"), is(17));
+                        + TopicSubscriber.getChannelCount(memberSub2, "Sub2.2"), is(17), Timeout.after(5, TimeUnit.MINUTES));
 
                 cluster.log(">>>> In shouldPubWithMultipleSubsAndReallocation - subscriber have all channels");