Fix the write buffer

h2/src/main/org/h2/mvstore/WriteBuffer.java

@@ -13,14 +13,14 @@ import java.nio.ByteBuffer;
  */
 public class WriteBuffer {
 
-    private static final int MAX_REUSE_LIMIT = 4 * 1024 * 1024;
+    private static final int MAX_REUSE_CAPACITY = 4 * 1024 * 1024;
 
     /**
-     * The maximum byte to grow a buffer at a time.
+     * The minimum number of bytes to grow a buffer at a time.
      */
-    private static final int MAX_GROW = 1024 * 1024;
+    private static final int MIN_GROW = 1024 * 1024;
 
-    private ByteBuffer reuse = ByteBuffer.allocate(512 * 1024);
+    private ByteBuffer reuse = ByteBuffer.allocate(MIN_GROW);
 
     private ByteBuffer buff = reuse;
 
@@ -273,7 +273,7 @@ public class WriteBuffer {
      * @return this
      */
     public WriteBuffer clear() {
-        if (buff.limit() > MAX_REUSE_LIMIT) {
+        if (buff.limit() > MAX_REUSE_CAPACITY) {
             buff = reuse;
         } else if (buff != reuse) {
             reuse = buff;
@@ -300,13 +300,12 @@ public class WriteBuffer {
 
     private void grow(int len) {
         ByteBuffer temp = buff;
-        len = temp.remaining() + len;
-        int capacity = temp.capacity();
-        len = Math.max(len, Math.min(capacity + MAX_GROW, capacity * 2));
-        buff = ByteBuffer.allocate(len);
+        int needed = len - temp.remaining();
+        int newCapacity = temp.capacity() + Math.max(needed, MIN_GROW);
+        buff = ByteBuffer.allocate(newCapacity);
         temp.flip();
         buff.put(temp);
-        if (len <= MAX_REUSE_LIMIT) {
+        if (newCapacity <= MAX_REUSE_CAPACITY) {
             reuse = buff;
         }
     }

h2/src/test/org/h2/test/store/TestDataUtils.java

@@ -13,6 +13,7 @@ import java.util.HashMap;
 import java.util.Random;
 
 import org.h2.mvstore.DataUtils;
+import org.h2.mvstore.WriteBuffer;
 import org.h2.test.TestBase;
 
 /**
@@ -31,6 +32,7 @@ public class TestDataUtils extends TestBase {
 
     @Override
     public void test() {
+        testWriteBuffer();
         testEncodeLength();
         testFletcher();
         testMap();
@@ -40,6 +42,12 @@ public class TestDataUtils extends TestBase {
         testCheckValue();
         testPagePos();
     }
+    
+    private static void testWriteBuffer() {
+        WriteBuffer buff = new WriteBuffer();
+        buff.put(new byte[1500000]);
+        buff.put(new byte[1900000]);
+    }
 
     private void testFletcher() {
         byte[] data = new byte[10000];