From aaacd96a33f5fbe3989c04a9917029c3c6e0cf10 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Fri, 11 Oct 2013 18:14:32 +0000
Subject: [PATCH] 0001438: Improve memory footprint usage when big lobs are in
 flight

---
 .../org/jumpmind/symmetric/csv/CsvReader.java | 48 +++++++++++++------
 1 file changed, 33 insertions(+), 15 deletions(-)

diff --git a/symmetric-csv/src/main/java/org/jumpmind/symmetric/csv/CsvReader.java b/symmetric-csv/src/main/java/org/jumpmind/symmetric/csv/CsvReader.java
index 28e25094e3..f5f3ca0d2e 100644
--- a/symmetric-csv/src/main/java/org/jumpmind/symmetric/csv/CsvReader.java
+++ b/symmetric-csv/src/main/java/org/jumpmind/symmetric/csv/CsvReader.java
@@ -38,6 +38,9 @@
  * stream.
  */
 public class CsvReader {
+    
+    private static int MAX_BUFFER_EXPANSION_SIZE = 1048576;
+    
     private Reader inputStream = null;
 
     private String fileName = null;
@@ -1137,8 +1140,8 @@ private void checkDataLength() throws IOException {
 
         if (userSettings.CaptureRawRecord && dataBuffer.Count > 0) {
             if (rawBuffer.Buffer.length - rawBuffer.Position < dataBuffer.Count - dataBuffer.LineStart) {
-                int newLength = rawBuffer.Buffer.length
-                        + Math.max(dataBuffer.Count - dataBuffer.LineStart, rawBuffer.Buffer.length);
+                int newLength = Math.max(rawBuffer.Buffer.length + dataBuffer.Count
+                        - dataBuffer.LineStart, newLength(rawBuffer.Buffer.length));
 
                 char[] holder = new char[newLength];
 
@@ -1286,6 +1289,7 @@ private void endColumn() throws IOException {
         }
 
         columnBuffer.Position = 0;
+        columnBuffer.Buffer = new char[StaticSettings.INITIAL_COLUMN_BUFFER_SIZE];
 
         startedColumn = false;
 
@@ -1304,7 +1308,7 @@ private void endColumn() throws IOException {
 
         if (columnsCount == values.length) {
             // holder array needs to grow to be able to hold another column
-            int newLength = values.length * 2;
+            int newLength = newLength(values.length);
 
             String[] holder = new String[newLength];
 
@@ -1334,10 +1338,18 @@ private void endColumn() throws IOException {
         startedWithQualifier=false;
         columnsCount++;
     }
+    
+    private final int newLength (int oldLength) {
+        if (oldLength < MAX_BUFFER_EXPANSION_SIZE) {
+            return oldLength*2;
+        } else {
+            return oldLength+MAX_BUFFER_EXPANSION_SIZE;
+        }
+    }
 
     private void appendLetter(char letter) {
         if (columnBuffer.Position == columnBuffer.Buffer.length) {
-            int newLength = columnBuffer.Buffer.length * 2;
+            int newLength = newLength(columnBuffer.Buffer.length);
 
             char[] holder = new char[newLength];
 
@@ -1348,20 +1360,26 @@ private void appendLetter(char letter) {
         columnBuffer.Buffer[columnBuffer.Position++] = letter;
         dataBuffer.ColumnStart = dataBuffer.Position + 1;
     }
+    
+    protected void expandColumnBuffer() {
+        int roomLeftInColumnBuffer = columnBuffer.Buffer.length - columnBuffer.Position;
+        int dataLeftInDataBuffer = dataBuffer.Position - dataBuffer.ColumnStart;
+        if (roomLeftInColumnBuffer < dataLeftInDataBuffer) {
+            int newLength = Math.max(columnBuffer.Buffer.length + dataLeftInDataBuffer
+                    - roomLeftInColumnBuffer, newLength(columnBuffer.Buffer.length));
 
-    private void updateCurrentValue() {
-        if (startedColumn && dataBuffer.ColumnStart < dataBuffer.Position) {
-            if (columnBuffer.Buffer.length - columnBuffer.Position < dataBuffer.Position - dataBuffer.ColumnStart) {
-                int newLength = columnBuffer.Buffer.length
-                        + Math.max(dataBuffer.Position - dataBuffer.ColumnStart, columnBuffer.Buffer.length);
-
-                char[] holder = new char[newLength];
-
-                System.arraycopy(columnBuffer.Buffer, 0, holder, 0, columnBuffer.Position);
+            char[] holder = new char[newLength];
+            
+            System.arraycopy(columnBuffer.Buffer, 0, holder, 0, columnBuffer.Position);
 
-                columnBuffer.Buffer = holder;
-            }
+            columnBuffer.Buffer = holder;
+        }        
+    }
 
+    private void updateCurrentValue() {
+        if (startedColumn && dataBuffer.ColumnStart < dataBuffer.Position) {
+            expandColumnBuffer();
+            
             System.arraycopy(dataBuffer.Buffer, dataBuffer.ColumnStart, columnBuffer.Buffer, columnBuffer.Position,
                     dataBuffer.Position - dataBuffer.ColumnStart);