LiteTxnProcessorTests clean up (merge main -> ce/main @ 80002)

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

Author: harveyraja

prj/coherence-testing-support/src/main/java/common/AbstractTestInfrastructure.java

@@ -706,9 +706,11 @@ protected static CoherenceClusterMember startCacheServer(String sServer, String
             {
             member = startCacheServer(sServer, optionsByType, sProject, fGraceful);
             }
-        catch (IOException e)
+        catch (Throwable t)
             {
-            throw new RuntimeException("Error starting cache server", e);
+            // show OS level port usage in case of port binding conflict
+            displayPortInfo();
+            throw new RuntimeException("Error starting cache server", t);
             }
 
 

prj/test/functional/processor/src/test/java/processor/LiteTxnProcessorTests.java

@@ -153,9 +153,12 @@ public void testAtomicEntryProcessor()
         final int          cServers = 4;
 
         MemberHandler memberHandler = new MemberHandler(
-        CacheFactory.ensureCluster(), getServerPrefix() + "-Atomic",
+                CacheFactory.ensureCluster(), getServerPrefix() + "-Atomic",
                 /*fExternalKill*/false, /*fGraceful*/false);
 
+        final boolean[] afExiting = new boolean[1];
+
+        Thread thdLoad = null;
         try
             {
             // setup, start the initial cache servers
@@ -177,31 +180,28 @@ public void testAtomicEntryProcessor()
                 }
 
             // start the client (load) thread
-            final boolean[] afExiting   = new boolean[1];
-            final Object[]  aoException = new Object[1];
-            Thread thdLoad = new Thread()
+            final Object[] aoException = new Object[1];
+
+            thdLoad = new Thread(() ->
                 {
-                public void run()
+                EntryProcessor processor = new AtomicUpdateProcessor();
+                try
                     {
-                    EntryProcessor processor = new AtomicUpdateProcessor();
-                    try
+                    while (!afExiting[0])
                         {
-                        while (!afExiting[0])
+                        for (int i = 0; i < cKeys; i++)
                             {
-                            for (int i = 0; i < cKeys; i++)
-                                {
-                                cache1.invoke(getKey(i), processor);
-                                }
-                            Base.sleep(10);
+                            cache1.invoke(getKey(i), processor);
                             }
+                        Base.sleep(10);
                         }
-                    catch (Exception e)
-                        {
-                        aoException[0] = e;
-                        throw Base.ensureRuntimeException(e);
-                        }
                     }
-                };
+                catch (Exception e)
+                    {
+                    aoException[0] = e;
+                    throw Base.ensureRuntimeException(e);
+                    }
+                });
             thdLoad.start();
 
             // perform the rolling restart
@@ -224,6 +224,16 @@ public void run()
             }
         finally
             {
+            afExiting[0] = true;
+            if (thdLoad != null)
+                {
+                try
+                    {
+                    thdLoad.join();
+                    }
+                catch (InterruptedException ignored) {}
+                }
+
             memberHandler.dispose();
             Cluster cluster = CacheFactory.getCluster();
             Eventually.assertThat(invoking(cluster).getMemberSet().size(), is(1));