Bug 37871569 - [37331397->22.06.13] RFA: Proxy not cleaning closed connections fast enough to avoid OOME.

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v22.06/": change = 115916]

Author: lsho

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Connection.java

@@ -1,6 +1,6 @@
 
 /*
- * Copyright (c) 2000, 2023, 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.
@@ -157,7 +157,16 @@ public class Connection
      * @see com.tangosol.net.messaging.Connection#getPeerId
      */
     private com.tangosol.util.UUID __m_PeerId;
-    
+
+    /**
+     * Property PendingCloses
+     *
+     * The number of outstanding pending close requests.
+     *
+     * @see com.tangosol.net.messaging.Connection#getPendingCloses
+     */
+    private volatile int __m_PendingCloses;
+
     /**
      * Property PingLastMillis
      *
@@ -504,8 +513,10 @@ public void close(boolean fNotify, Throwable e, boolean fWait)
         {
         // import Component.Util.Daemon.QueueProcessor.Service.Peer as com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer;
 
-        if (isOpen())
+        if (isOpen() && getPendingCloses() < MAX_PENDING)
             {
+            setPendingCloses(getPendingCloses() + 1);
+
             com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer manager = (com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer) getConnectionManager();
             if (Thread.currentThread() == manager.getThread())
                 {
@@ -1016,7 +1027,17 @@ public com.tangosol.util.UUID getPeerId()
         {
         return __m_PeerId;
         }
-    
+
+    // Accessor for the property "PendingCloses"
+    /**
+     * Getter for property PendingCloses.<p>
+     * The number of outstanding pending close requests.
+     */
+    public int getPendingCloses()
+    {
+        return __m_PendingCloses;
+    }
+
     // Accessor for the property "PingLastMillis"
     /**
      * Getter for property PingLastMillis.<p>
@@ -1658,7 +1679,17 @@ public void setPeerId(com.tangosol.util.UUID uuid)
         {
         __m_PeerId = uuid;
         }
-    
+
+    // Accessor for the property "PendingCloses"
+    /**
+     * Setter for property PendingCloses.<p>
+     * The number of outstanding pending close requests.
+     */
+    public void setPendingCloses(int nCloses)
+        {
+        __m_PendingCloses = nCloses;
+        }
+
     // Accessor for the property "PingLastMillis"
     /**
      * Setter for property PingLastMillis.<p>