From 07ad3e1659a3f5fd447947637d061aab801240b1 Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Fri, 12 Dec 2014 11:29:52 +0000
Subject: [PATCH] HCOLL-245 added test for - "Stateless Client to support large
 entries"

---
 .../chronicle/map/StatelessClientTest.java    | 38 +++++++++++++++++++
 1 file changed, 38 insertions(+)

diff --git a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java
index 72b1ec661..0e9338fec 100644
--- a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java
+++ b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java
@@ -23,6 +23,7 @@ import net.openhft.lang.io.ByteBufferBytes;
 import net.openhft.lang.io.Bytes;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -460,6 +461,43 @@ public class StatelessClientTest {
         }
     }
 
+    @Ignore("HCOLL-245 Stateless Client to support large entries")
+    @Test(timeout = 10000)
+    public void testLargeEntries() throws IOException,
+            InterruptedException {
+
+
+        int keySize = 4;
+        int valueSize = 1000000;
+        int entrySize = keySize + valueSize;
+
+        char[] value = new char[valueSize];
+
+        Arrays.fill(value, 'X');
+
+        try (ChronicleMap<Integer, CharSequence> serverMap = ChronicleMapBuilder.of(Integer.class, CharSequence.class)
+                .entrySize(entrySize)
+                .replication((byte) 2, TcpTransportAndNetworkConfig.of(8056)).create()) {
+            try (ChronicleMap<Integer, CharSequence> statelessMap = ChronicleMapBuilder.of(Integer
+                    .class, CharSequence.class)
+                    .entrySize(entrySize)
+                    .statelessClient(new InetSocketAddress("localhost", 8056)).create()) {
+
+           //     for (int i = 0; i < 128; i++) {
+
+                    statelessMap.put(1, new String(value));
+
+                    assertEquals("some value", statelessMap.get(1));
+                    assertEquals(1, statelessMap.size());
+
+             //   }
+
+                assertEquals(null, statelessMap.get(1));
+                assertEquals(0, statelessMap.size());
+            }
+        }
+    }
+
 
     @Test(timeout = 10000)
     public void testGetAndEntryWeDontHave() throws IOException,