Bug 38041090 - Failed to restart services: java.lang.SecurityException due to Subject is not inherited from the parent thread, fix test failure (14.1.2.0 cl 117466 --> 14.1.2.0 CE)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v14.1.2.0/": change = 117512]

Author: fryp

prj/test/functional/processor/src/main/java/processor/AbstractDistEntryProcessorTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2025, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -296,7 +296,7 @@ public void asyncBacklog()
             AsynchronousProcessor[] aAsync = new AsynchronousProcessor[COUNT];
             for (int i = 0; true; i++)
                 {
-                EntryProcessor proc = new UpdaterProcessor((ValueUpdater) null,
+                EntryProcessor proc = new UpdateProcessorForBacklog((ValueUpdater) null,
                     Integer.valueOf(Base.getRandom().nextInt()));
                 AsynchronousProcessor async = new AsynchronousProcessor(proc, i);
 
@@ -327,6 +327,7 @@ public synchronized void proceed(Object o)
 
                     if (async.checkBacklog(contNormal))
                         {
+                        m_fBackLogAnnounced = true;
                         log("Backlog announced " + i);
 
                         async.flush();
@@ -663,5 +664,53 @@ public Object process(Entry entry)
             return ctx.getBackingMapEntry(binKey).getValue();
             }
         }
+
+    /**
+     * An UpdaterProcessor that ensures backlog.
+     */
+    public static class UpdateProcessorForBacklog<K, V, T>
+            extends UpdaterProcessor<K, V, T>
+        {
+        /**
+         * Default constructor (necessary for the ExternalizableLite interface).
+         */
+        public UpdateProcessorForBacklog()
+            {
+            }
+
+        public UpdateProcessorForBacklog(ValueUpdater<V, T> updater, T value)
+            {
+            super(updater, value);
+            }
+
+        @Override
+        public Boolean process(InvocableMap.Entry<K, V> entry)
+            {
+            ValueUpdater<V, T> updater = m_updater;
+   
+            // if there isn't backlog, sleep to slow down 
+            if (!m_fBackLogAnnounced)
+                {
+                Base.sleep(100);
+                }
+
+            if (updater == null)
+                {
+                //NOTE: a possibly unsafe cast from T to V
+                entry.setValue((V) m_value, false);
+                }
+            else if (entry.isPresent())
+                {
+                entry.update(updater, m_value);
+                }
+            else
+                {
+                return Boolean.FALSE;
+                }
+            return Boolean.TRUE;
+            }
+        }
+
+    private static boolean m_fBackLogAnnounced = false;
     }