Enh 36420687 - [36420651->24.09] Improve deserialization performance of very large byte arrays

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

Author: aseovic

prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java

@@ -8,9 +8,11 @@
 package com.tangosol.util;
 
 import com.oracle.coherence.common.base.Logger;
+import com.oracle.coherence.common.io.BufferManagers;
 
 import com.tangosol.coherence.config.Config;
 
+import com.tangosol.internal.io.BufferManagerWriteBufferPool;
 import com.tangosol.internal.util.invoke.Lambdas;
 import com.tangosol.internal.util.invoke.RemotableSupport;
 
@@ -6625,20 +6627,21 @@ protected static char[] readLargeCharArray(Utf8Reader reader, int cLength)
     protected static byte[] readLargeByteArray(DataInput in, int cb)
             throws IOException
         {
-        int    cBatchMax = CHUNK_SIZE;
-        int    cBatch    = cb / cBatchMax + 1;
-        byte[] ab        = new byte[cBatchMax];
-        byte[] aMerged   = null;
-        int    cbRead    = 0;
-        for (int i = 0; i < cBatch && cbRead < cb; i++)
+        int    cbBatchMax = CHUNK_SIZE;
+        int    cBatch     = cb / cbBatchMax + 1;
+
+        try (MultiBufferWriteBuffer buf  = new MultiBufferWriteBuffer(new BufferManagerWriteBufferPool(BufferManagers.getHeapManager()), cbBatchMax))
             {
-            in.readFully(ab);
-            aMerged = mergeByteArray(aMerged, ab);
-            cbRead += ab.length;
-            ab      = new byte[Math.min(cb - cbRead, cBatchMax)];
+            InputStreaming input = new WrapperDataInputStream(in);
+            int cbRead = 0;
+            for (int i = 0; i < cBatch && cbRead < cb; i++)
+                {
+                int cbBatch = Math.min(cb - cbRead, cbBatchMax);
+                buf.write(cbRead, input, cbBatch);
+                cbRead += cbBatch;
+                }
+            return buf.toByteArray();
             }
-
-        return aMerged;
         }
 
     /**